4 import java.util.Arrays;
7 class TestCloudComm extends CloudComm {
11 buffer = new SlotBuffer();
14 public synchronized Slot[] putSlot(Slot slot, int max) {
15 if ((buffer.size()==0 && 1 == slot.getSequenceNumber()) ||
16 buffer.getNewestSeqNum()+1 == slot.getSequenceNumber()) {
22 return getSlots(slot.getSequenceNumber());
25 public synchronized Slot[] getSlots(long sequencenumber) {
26 long newestseqnum=buffer.getNewestSeqNum();
27 long oldestseqnum=buffer.getOldestSeqNum();
28 if (sequencenumber < oldestseqnum)
29 sequencenumber=oldestseqnum;
30 int numslots=(int)((newestseqnum - sequencenumber)+1);
31 Slot[] slots=new Slot[numslots];
32 for(int i=0; i<numslots; i++,sequencenumber++)
33 slots[i]=buffer.getSlot(sequencenumber);