1 | package bargainingchips.protocol;
|
---|
2 |
|
---|
3 | import java.util.concurrent.BlockingQueue;
|
---|
4 | import java.util.concurrent.LinkedBlockingQueue;
|
---|
5 |
|
---|
6 | import bargainingchips.actions.Accept;
|
---|
7 | import bargainingchips.actions.Offer;
|
---|
8 | import bargainingchips.actions.OfferBy;
|
---|
9 |
|
---|
10 |
|
---|
11 | public class AsynchronousOffersProtocol extends BilateralProtocol
|
---|
12 | {
|
---|
13 | public AsynchronousOffersProtocol(BlockingQueue<OfferBy> from, String nameA,
|
---|
14 | BlockingQueue<Offer> toA, String nameB, BlockingQueue<Offer> toB) {
|
---|
15 | super(from, nameA, toA, nameB, toB);
|
---|
16 | }
|
---|
17 |
|
---|
18 | /**
|
---|
19 | * An offer is valid iff:
|
---|
20 | * 1) An offer or walk-away is sent by anyone at any time: $o_{t+1} \in \Omega \cup \{End\}$; or
|
---|
21 | * 2) A bid is accepted by the other: $o_{t+1} = Accept$ and $o_{t}\in\Omega$ and $g_t \neq g_{t+1}$; or
|
---|
22 | * 3) An accept is acknowledged, concluding the thread: $o_{t+1} = Accept$ and $o_{t} = Accept$ and $o_{t-1} \in \Omega$ and $g_{t-1} = g_{t+1} \neq g_{t}$.
|
---|
23 | */
|
---|
24 | @Override
|
---|
25 | protected ValidationResult validate(OfferBy curOfferBy)
|
---|
26 | {
|
---|
27 | Offer curOffer = curOfferBy.getOffer();
|
---|
28 | String curSender = curOfferBy.getSender();
|
---|
29 |
|
---|
30 | // 1)
|
---|
31 | if (curOffer.isBid())
|
---|
32 | return new ValidationSuccess();
|
---|
33 |
|
---|
34 | if (curOffer.isBreakoff())
|
---|
35 | return new ValidationSuccessWithDisagreement(); // we are done
|
---|
36 |
|
---|
37 | // 2)
|
---|
38 | if (log.size() < 2) // o_t should exist
|
---|
39 | return new ValidationFailure();
|
---|
40 |
|
---|
41 | OfferBy prevOfferBy = getLastOffer();
|
---|
42 | Offer prevOffer = prevOfferBy.getOffer();
|
---|
43 | String prevSender = prevOfferBy.getSender();
|
---|
44 |
|
---|
45 | if (curOffer.isAccept() && prevOffer.isBid() && !curSender.equals(prevSender))
|
---|
46 | return new ValidationSuccess();
|
---|
47 |
|
---|
48 | // 3)
|
---|
49 | if (log.size() < 3) // o_{t-1} should exist
|
---|
50 | return new ValidationFailure();
|
---|
51 |
|
---|
52 | OfferBy prevprevBy = log.get(log.size() - 2);
|
---|
53 | Offer prevprev = prevprevBy.getOffer();
|
---|
54 | String prevprevSender = prevprevBy.getSender();
|
---|
55 |
|
---|
56 | if (curOffer.isAccept() && prevOffer.isAccept()
|
---|
57 | && prevprev.isBid() && prevprevSender.equals(curSender)
|
---|
58 | && !curSender.equals(prevSender))
|
---|
59 | return new ValidationSuccessWithAgreement(prevprev.getBundle()); // we are done
|
---|
60 |
|
---|
61 | return new ValidationFailure();
|
---|
62 | }
|
---|
63 |
|
---|
64 | public static void main(String[] args) throws InterruptedException
|
---|
65 | {
|
---|
66 | BlockingQueue<OfferBy> from = new LinkedBlockingQueue<OfferBy>();
|
---|
67 | String nameA = "Buyer";
|
---|
68 | BlockingQueue<Offer> toA = new LinkedBlockingQueue<Offer>();
|
---|
69 | String nameB = "Seller";
|
---|
70 | BlockingQueue<Offer> toB = new LinkedBlockingQueue<Offer>();
|
---|
71 |
|
---|
72 | AsynchronousOffersProtocol aop = new AsynchronousOffersProtocol(from, nameA, toA, nameB, toB);
|
---|
73 |
|
---|
74 | Thread aopThread = new Thread(aop);
|
---|
75 | aopThread.start();
|
---|
76 |
|
---|
77 | from.put(OfferBy.getSampleOffer("Buyer", "Red", 3));
|
---|
78 | // Thread.sleep(1000);
|
---|
79 | from.put(OfferBy.getSampleOffer("Buyer", "Red", 6));
|
---|
80 | // Thread.sleep(1000);
|
---|
81 | from.put(new OfferBy("Seller", new Accept(Offer.getSampleOffer(6))));
|
---|
82 | // Thread.sleep(1000);
|
---|
83 | from.put(new OfferBy("Buyer", new Accept(Offer.getSampleOffer(6))));
|
---|
84 | // from.put(new OfferBy("Buyer", new Breakoff()));
|
---|
85 |
|
---|
86 | Thread.sleep(1000);
|
---|
87 | System.out.println("Sent to A:" + toA);
|
---|
88 | System.out.println("Sent to B:" + toB);
|
---|
89 | }
|
---|
90 |
|
---|
91 | }
|
---|