Mercurial > hg > Database > Alice

comparison src/alice/codesegment/InputDataSegment.java @ 254:2ec10cfa8cc3

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
refactor
author sugi
date Mon, 01 Jul 2013 20:00:07 +0900
parents 32e7d5271477
children b4690114a0cd
comparison
equal deleted inserted replaced
253:32e7d5271477 254:2ec10cfa8cc3
21 private AtomicInteger keyCount = new AtomicInteger(0); // number of DataSegments 21 private AtomicInteger keyCount = new AtomicInteger(0); // number of DataSegments
22 public InputDataSegment(CodeSegment cs) { 22 public InputDataSegment(CodeSegment cs) {
23 this.cs = cs; 23 this.cs = cs;
24 } 24 }
25 25
26 public void quickPeek(Receiver receiver, String managerKey, String key, int index) { 26 public void quickPeek(Receiver receiver) {
27 cs.list.add(receiver); 27 cs.list.add(receiver);
28 DataSegment.get(managerKey).quickPeek(receiver, key, index, cs); 28 if (receiver.managerKey==null){
29 DataSegment.getLocal().quickPeek(receiver, cs);
30 } else {
31 DataSegment.get(receiver.managerKey).quickPeek(receiver ,cs);
32 }
29 } 33 }
30 34
31 public void quickTake(Receiver receiver, String managerKey, String key, int index) { 35 public void quickTake(Receiver receiver) {
32 cs.list.add(receiver); 36 cs.list.add(receiver);
33 DataSegment.get(managerKey).quickTake(receiver, key, index, cs); 37 if (receiver.managerKey==null){
38 DataSegment.getLocal().quickTake(receiver, cs);
39 } else {
40 DataSegment.get(receiver.managerKey).quickTake(receiver ,cs);
41 }
34 } 42 }
35 43
36 44 public void peek(Receiver receiver) {
37 public void peek(Receiver receiver, String managerKey, String key, int index) {
38 cs.list.add(receiver); 45 cs.list.add(receiver);
39 DataSegment.get(managerKey).peek(receiver, key, index, cs); 46 if (receiver.managerKey==null){
40 } 47 DataSegment.getLocal().peek(receiver, cs);
41 48 } else {
42 public void peek(Receiver receiver, String key, int index) { 49 DataSegment.get(receiver.managerKey).peek(receiver, cs);
43 cs.list.add(receiver); 50 }
44 DataSegment.getLocal().peek(receiver, key, index, cs);
45 } 51 }
46 52
47 53
48 public void take(Receiver receiver, String managerKey, String key, int index) { 54 public void take(Receiver receiver) {
49 cs.list.add(receiver); 55 cs.list.add(receiver);
50 DataSegment.get(managerKey).take(receiver, key, index, cs); 56 if (receiver.managerKey==null){
51 } 57 DataSegment.getLocal().take(receiver, cs);
52 58 } else {
53 public void take(Receiver receiver, String key, int index) { 59 DataSegment.get(receiver.managerKey).take(receiver, cs);
54 cs.list.add(receiver); 60 }
55 DataSegment.getLocal().take(receiver, key, index, cs);
56 } 61 }
57 62
58 public void reply(Receiver receiver, Command reply) { 63 public void reply(Receiver receiver, Command reply) {
59 receiver.index = reply.index; 64 receiver.index = reply.index;
60 receiver.from = reply.reverseKey; 65 receiver.from = reply.reverseKey;