1 package at.ac.tuwien.sbc.valesriegler.xvsm;
4 import at.ac.tuwien.sbc.valesriegler.common.Bill;
5 import at.ac.tuwien.sbc.valesriegler.common.Util;
6 import at.ac.tuwien.sbc.valesriegler.types.DeliveryGroupData;
7 import at.ac.tuwien.sbc.valesriegler.types.DeliveryStatus;
8 import at.ac.tuwien.sbc.valesriegler.xvsm.spacehelpers.SpaceAction;
9 import at.ac.tuwien.sbc.valesriegler.xvsm.spacehelpers.SpaceListener;
10 import org.mozartspaces.core.ContainerReference;
11 import org.mozartspaces.core.MzsConstants;
12 import org.mozartspaces.core.TransactionReference;
13 import org.slf4j.Logger;
14 import org.slf4j.LoggerFactory;
16 import java.io.Serializable;
18 import java.util.Arrays;
19 import java.util.List;
21 public class DriverXVSM extends AbstractXVSMConnector {
22 private static final Logger log = LoggerFactory.getLogger(DriverXVSM.class);
26 public DriverXVSM(int id, int port) {
31 this.preparedDeliveryPizzasContainer = useContainer(Util.DELIVER_DELIVERY_PIZZAS);
32 this.deliveryOrderTakenContainer = useContainer(Util.DELIVERY_ORDER_TAKEN);
33 this.deliverDeliveryOrderContainer = useContainer(Util.DELIVER_DELIVERY_ORDER);
34 pizzeriaDeliveryContainer = useContainer(Util.PIZZERIA_DELIVERY);
35 deliveryDone = useContainer(Util.DELIVERY_DONE);
36 deliveryInProgress = useContainer(Util.DELIVERY_PROGRESS);
40 public void listenForPreparedDeliveryOrders() {
41 SpaceListener orderListener = getDefaultBuilder().setCref(deliverDeliveryOrderContainer).setLookaround(true).setSpaceAction(new SpaceAction() {
44 public void onEntriesWritten(List<? extends Serializable> entries) throws Exception {
45 final List<DeliveryGroupData> deliveries = castEntries(entries);
47 for (DeliveryGroupData delivery : deliveries) {
48 DeliveryGroupData template = new DeliveryGroupData(delivery.getId());
49 template.setDeliveryStatus(DeliveryStatus.ORDERED);
51 final TransactionReference tx = capi.createTransaction(
53 URI.create(String.format(Util.SERVER_ADDR, port)));
54 final String error = "Another driver wants to deliver this order!";
57 // Get lock for delivering this delivery order
58 takeMatchingEntity(template, deliverDeliveryOrderContainer, tx, MzsConstants.RequestTimeout.DEFAULT, error);
59 final DeliveryGroupData group = takeMatchingEntity(template, pizzeriaDeliveryContainer, tx, MzsConstants.RequestTimeout.INFINITE, "Cannot get the delivery order!");
60 group.setDriverId(driverId);
61 group.setDeliveryStatus(DeliveryStatus.IN_PROGRESS);
63 final List<DeliveryGroupData> groups = Arrays.asList(group);
64 sendItemsToContainer(groups,
65 deliveryInProgress, MzsConstants.RequestTimeout.ZERO, null);
66 sendItemsToContainer(groups,
67 pizzeriaDeliveryContainer, MzsConstants.RequestTimeout.ZERO, null);
69 if (! Util.runSimulation) {
73 final String address = String.format(Util.SERVER_ADDR, Util.DELIVERY_CUSTOMERS_PORT);
74 ContainerReference cref = null;
75 boolean success = false;
77 cref = capi.lookupContainer(group.getAddress(), URI.create(address), MzsConstants.RequestTimeout.ZERO, null);
78 log.debug("Looked up container {} successfully!", address);
81 } catch (Exception ex) {
82 log.info("Could not find container {}", address);
85 group.setDeliveryStatus(DeliveryStatus.DELIVERED);
86 sendItemsToContainer(Arrays.asList(new Bill(1000, group.getId())), cref, MzsConstants.RequestTimeout.DEFAULT, null);
88 group.setDeliveryStatus(DeliveryStatus.DELIVERY_FAILED);
90 sendItemsToContainer(groups, deliveryDone, MzsConstants.RequestTimeout.DEFAULT, tx);
91 sendItemsToContainer(groups, pizzeriaDeliveryContainer, MzsConstants.RequestTimeout.DEFAULT, tx);
92 capi.commitTransaction(tx);
95 } catch (Exception e) {
96 log.info("DRiverXVSM exception");
97 log.info(e.getMessage());
103 }).createSpaceListenerImpl();