Mercurial > hg > Database > Alice

comparison src/alice/codesegment/InputDataSegment.java @ 33:20c67f673224

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
change name of DataSegmentReceiver
author kazz <kazz@cr.ie.u-ryukyu.ac.jp>
date Wed, 18 Jan 2012 01:34:23 +0900
parents 2bfb796b0fa1
children 73158dc54c59
comparison
equal deleted inserted replaced
32:2bfb796b0fa1 33:20c67f673224
2 2
3 import java.util.concurrent.atomic.AtomicInteger; 3 import java.util.concurrent.atomic.AtomicInteger;
4 4
5 import alice.datasegment.CommandType; 5 import alice.datasegment.CommandType;
6 import alice.datasegment.DataSegment; 6 import alice.datasegment.DataSegment;
7 import alice.datasegment.DataSegmentReceiver; 7 import alice.datasegment.Receiver;
8 import alice.datasegment.DataSegmentValue; 8 import alice.datasegment.DataSegmentValue;
9 9
10 public class InputDataSegment { 10 public class InputDataSegment {
11 11
12 private CodeSegment cs; 12 private CodeSegment cs;
15 15
16 public InputDataSegment(CodeSegment cs) { 16 public InputDataSegment(CodeSegment cs) {
17 this.cs = cs; 17 this.cs = cs;
18 } 18 }
19 19
20 public void peek(DataSegmentReceiver receiver, String managerKey, String key) { 20 public void peek(Receiver receiver, String managerKey, String key) {
21 peek(receiver, managerKey, key, 0); 21 peek(receiver, managerKey, key, 0);
22 } 22 }
23 23
24 public void peek(DataSegmentReceiver receiver, String managerKey, String key, int index) { 24 public void peek(Receiver receiver, String managerKey, String key, int index) {
25 DataSegment.get(managerKey).peek(receiver, key, index, cs); 25 DataSegment.get(managerKey).peek(receiver, key, index, cs);
26 } 26 }
27 27
28 public void take(DataSegmentReceiver receiver, String managerKey, String key) { 28 public void take(Receiver receiver, String managerKey, String key) {
29 take(receiver, managerKey, key, 0); 29 take(receiver, managerKey, key, 0);
30 } 30 }
31 31
32 public void take(DataSegmentReceiver receiver, String managerKey, String key, int index) { 32 public void take(Receiver receiver, String managerKey, String key, int index) {
33 DataSegment.get(managerKey).take(receiver, key, index, cs); 33 DataSegment.get(managerKey).take(receiver, key, index, cs);
34 } 34 }
35 35
36 public void reply(DataSegmentReceiver receiver, DataSegmentValue val) { 36 public void reply(Receiver receiver, DataSegmentValue val) {
37 receiver.index = val.index; 37 receiver.index = val.index;
38 receiver.val = val.val; 38 receiver.val = val.val;
39 receiver.from = val.from; 39 receiver.from = val.from;
40 receive(); 40 receive();
41 } 41 }
59 e.printStackTrace(); 59 e.printStackTrace();
60 } 60 }
61 } 61 }
62 } 62 }
63 63
64 public DataSegmentReceiver createReceiver(CommandType type) { 64 public Receiver create(CommandType type) {
65 return new DataSegmentReceiver(this, type); 65 return new Receiver(this, type);
66 } 66 }
67 67
68 } 68 }