Package de.uniluebeck.itm.tcpip

Examples of de.uniluebeck.itm.tcpip.Storage

53
54
55
56
57
58
59
      (byte) (AN_INTEGER >> 16),
      (byte) (AN_INTEGER >>  8),
      (byte) (AN_INTEGER      )
    };
   
    return new Storage(buf);
  }
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
87
88
  }

  @Test
  public void testWriteRawTo() {
    Command cmd = new Command(sampleStorage());
    Storage s = new Storage();
    cmd.writeRawTo(s);
    Iterator<Byte> bytes = s.getStorageList().iterator();
    assertEquals(0, (int)bytes.next());
    assertEquals(0, (int)bytes.next());
    assertEquals(0, (int)bytes.next());
    assertEquals(0, (int)bytes.next());
    assertEquals(10, (int)bytes.next());
View Full Code Here
32
33
34
35
36
37
38
39
    super(dis, dos, commandID, objectID, varID);
  }

  @Override
  protected Program readValue(Command resp) throws TraCIException {
    Storage content = resp.content();
    return new Program(content);
  }
View Full Code Here
40
41
42
43
44
45
46
47
  public void setUp() throws Exception {
  }

  @Test
  public void testCommandStorage() {
    Storage s = sampleStorage();
    new Command(s);
  }
View Full Code Here
54
55
56
57
58
59
60
      (byte) (AN_INTEGER >> 16),
      (byte) (AN_INTEGER >>  8),
      (byte) (AN_INTEGER      )
    };
   
    return new Storage(buf);
  }
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
88
89
  }

  @Test
  public void testWriteRawTo() {
    Command cmd = new Command(sampleStorage());
    Storage s = new Storage();
    cmd.writeRawTo(s);
    Iterator<Byte> bytes = s.getStorageList().iterator();
    assertEquals(0, (int)bytes.next());
    assertEquals(0, (int)bytes.next());
    assertEquals(0, (int)bytes.next());
    assertEquals(0, (int)bytes.next());
    assertEquals(10, (int)bytes.next());
View Full Code Here
56
57
58
59
60
61
62
63
64
65
66
  protected abstract C makeCollection();
 
  @Override
  protected C readValue(Command resp) throws TraCIException {
    Storage content = resp.content();
    List<String> ids = new StringList(content, true);
    C out = makeCollection();
    for (String id : ids) {
      try {
        out.add(repository.getByID(id));
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
  }

  @Override
  protected List<Link> readValue(Command resp) throws TraCIException {
    List<Link> out = new ArrayList<Link>();
    Storage content = resp.content();
    Utils.checkType(content, Constants.TYPE_COMPOUND);
    content.readInt(); // ignore link data length
    Utils.checkType(content, Constants.TYPE_INTEGER);
    int count = content.readInt();
    for (int i=0; i<count; i++) {
      try {
        out.add(new Link(content, laneRepo));
      } catch (IOException e) {
        throw new TraCIException(e.toString());
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
56
57
  }

  @Override
  protected ControlledLinks readValue(Command resp)
      throws TraCIException {
    final Storage content = resp.content();
    Utils.checkType(content, Constants.TYPE_COMPOUND);
    content.readInt(); // ignore data length
    try {
      return new ControlledLinks(content, laneRepo);
    } catch (IOException e) {
      throw new TraCIException(e.getMessage());
    }
View Full Code Here
64
65
66
67
68
69
70
71
72
73
  }
 
  @Override
  List<Command> getRequests() {
    Command cmd = new Command(commandID);
    Storage content = cmd.content();
    content.writeUnsignedByte(varID);
    content.writeStringASCII(objectID);
    return Collections.singletonList(cmd);
  }
View Full Code Here
TOP

Related Classes of de.uniluebeck.itm.tcpip.Storage

  • it.polito.appeal.traci.ObjectCollectionQuery
  • it.polito.appeal.traci.protocol.Command
  • it.polito.appeal.traci.protocol.RequestMessage
  • it.polito.appeal.traci.protocol.ResponseMessage
  • it.polito.appeal.traci.ReadCompleteDefinitionQuery
  • it.polito.appeal.traci.ReadControlledLinksQuery
  • it.polito.appeal.traci.ReadLinksQuery
  • it.polito.appeal.traci.ReadObjectVarQuery
  • it.polito.appeal.traci.ReadObjectVarQuery$BoundingBoxQ
  • it.polito.appeal.traci.ReadObjectVarQuery$ColorQ
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.