Mercurial > hg > FederatedLinda
annotate src/fdl/MetaLinda.java @ 33:64071f8e2e0d
*** empty log message ***
| author | kono |
|---|---|
| date | Sun, 24 Aug 2008 03:23:08 +0900 |
| parents | 846c6c14cf04 |
| children | d5bca4b5ee95 |
| rev | line source |
|---|---|
| 15 | 1 |
| 2 /* | |
| 3 * @(#)MetaLinda.java 1.1 06/04/01 | |
| 4 * | |
| 5 * Copyright 2008 Shinji KONO | |
| 6 * | |
| 7 | |
| 8 Meta Lidna | |
| 9 Trasport layer of Meta Linda API | |
| 10 | |
| 11 */ | |
| 12 | |
| 13 package fdl; | |
| 14 | |
|
19
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
15 import java.io.IOException; |
| 15 | 16 import java.nio.ByteBuffer; |
| 31 | 17 import java.util.LinkedList; |
| 15 | 18 |
| 19 /** | |
|
19
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
20 MetaLinda |
| 15 | 21 * |
| 22 * @author Shinji Kono | |
| 23 * | |
| 24 | |
| 25 meta tuple interface in Linda Server | |
| 26 | |
| 27 */ | |
| 28 | |
| 25 | 29 public class MetaLinda implements PSXLinda { |
| 15 | 30 |
|
19
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
31 public TupleSpace ts; |
|
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
32 public FDLindaServ fds; |
| 21 | 33 public FederatedLinda fdl=null; |
| 25 | 34 public PSXLinda next=null; |
| 31 | 35 private LinkedList<MetaReply> replies=new LinkedList<MetaReply>(); |
| 15 | 36 |
| 21 | 37 public MetaLinda(TupleSpace ts,FDLindaServ fds) { |
|
19
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
38 this.ts = ts; |
| 21 | 39 this.fds = fds; |
| 15 | 40 } |
| 41 | |
| 42 public PSXReply in(int id) { | |
| 43 return null; | |
| 44 } | |
| 45 | |
| 46 public void in(int id, PSXCallback callback) { | |
| 26 | 47 MetaReply r = new MetaReply(PSX.PSX_IN,id,ts, callback); |
| 48 addReply(r); | |
| 49 } | |
| 50 | |
| 51 private void addReply(MetaReply r) { | |
| 31 | 52 replies.add(r); |
| 15 | 53 } |
| 54 | |
| 55 public PSXReply ck(int id) { | |
|
19
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
56 MetaReply r = new MetaReply(PSX.PSX_CHECK,id,ts); |
| 15 | 57 return r; |
| 58 } | |
| 59 | |
| 60 public void ck(int id, PSXCallback callback) { | |
| 26 | 61 MetaReply r = new MetaReply(PSX.PSX_CHECK,id,ts,callback); |
| 62 addReply(r); | |
| 15 | 63 } |
| 64 | |
| 23 | 65 public PSXReply out(int id, ByteBuffer data) { |
|
19
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
66 MetaReply r = new MetaReply(PSX.PSX_OUT,id,ts,data,null); |
| 26 | 67 addReply(r); |
|
19
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
68 return r; |
| 15 | 69 } |
| 70 | |
| 23 | 71 public PSXReply update(int id, ByteBuffer data) { |
|
19
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
72 MetaReply r = new MetaReply(PSX.PSX_UPDATE,id,ts,data,null); |
|
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
73 return r; |
| 15 | 74 } |
| 75 | |
| 23 | 76 public void update(int id, ByteBuffer data,PSXCallback callback) { |
|
19
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
77 MetaReply r = new MetaReply(PSX.PSX_UPDATE,id,ts,data,callback); |
| 26 | 78 addReply(r); |
| 15 | 79 } |
| 80 | |
| 81 public PSXReply rd(int id) { | |
|
19
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
82 MetaReply r = new MetaReply(PSX.PSX_RD,id,ts); |
|
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
83 return r; |
| 15 | 84 } |
| 85 | |
| 86 public void rd(int id, PSXCallback callback) { | |
| 26 | 87 MetaReply r = new MetaReply(PSX.PSX_RD,id,ts,callback); |
| 88 addReply(r); | |
| 15 | 89 } |
| 90 | |
| 25 | 91 public PSXLinda add(PSXLinda linda) { |
| 15 | 92 next = linda; |
|
19
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
93 return this; |
| 15 | 94 } |
| 95 | |
| 96 | |
| 97 public int sync() { | |
|
19
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
98 return sync(0); |
| 15 | 99 } |
| 100 | |
|
19
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
101 public int sync(long timeout) { |
|
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
102 fds.checkTuple(timeout); |
| 33 | 103 if (replies.size()>0) { |
| 104 // copy replies to avoid insert during r.ready() | |
| 105 LinkedList<MetaReply> list = replies; | |
| 106 replies = new LinkedList<MetaReply>(); | |
| 107 for(MetaReply r:list) { | |
| 108 if (!r.ready()) { | |
| 109 addReply(r); | |
| 110 } | |
|
19
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
111 } |
|
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
112 } |
|
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
113 if (fdl!=null) { |
|
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
114 try { |
|
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
115 fdl.sync(timeout); |
|
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
116 } catch (IOException e) { |
|
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
117 e.printStackTrace(); |
|
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
118 } |
|
0243987383b7
Meta Protocol Engine and sample implementation of event logger.
kono
parents:
17
diff
changeset
|
119 } |
| 15 | 120 return 0; |
| 121 } | |
| 25 | 122 |
| 123 public void send(ByteBuffer command, ByteBuffer data) { | |
| 124 | |
| 125 } | |
| 15 | 126 } |
| 127 | |
| 128 | |
| 129 /* end */ |