internal/test/protocol.d

29   auto prot = new Protocol(buffer);
32   prot.containerSizeLimit = 3;
35     prot.writeListBegin(TList(TType.I32, 4));
36     prot.writeI32(0); // Make sure size can be read e.g. for JSON protocol.
37     prot.reset();
39     auto e = cast(TProtocolException)collectException(prot.readListBegin());
41     prot.reset();
46     prot.writeMapBegin(TMap(TType.I32, TType.I32, 4));
47     prot.writeI32(0); // Make sure size can be read e.g. for JSON protocol.
48     prot.reset();
50     auto e = cast(TProtocolException)collectException(prot.readMapBegin());
52     prot.reset();
57     prot.writeSetBegin(TSet(TType.I32, 4));
58     prot.writeI32(0); // Make sure size can be read e.g. for JSON protocol.
59     prot.reset();
61     auto e = cast(TProtocolException)collectException(prot.readSetBegin());
63     prot.reset();
70     prot.containerSizeLimit = limit;
73       prot.writeListBegin(TList(TType.I32, 2));
74       prot.writeI32(0);
75       prot.writeI32(1);
76       prot.writeListEnd();
77       prot.reset();
79       auto list = prot.readListBegin();
82       enforce(prot.readI32() == 0);
83       enforce(prot.readI32() == 1);
84       prot.readListEnd();
86       prot.reset();
91       prot.writeMapBegin(TMap(TType.I32, TType.I32, 2));
92       prot.writeI32(0);
93       prot.writeI32(1);
94       prot.writeI32(2);
95       prot.writeI32(3);
96       prot.writeMapEnd();
97       prot.reset();
99       auto map = prot.readMapBegin();
103       enforce(prot.readI32() == 0);
104       enforce(prot.readI32() == 1);
105       enforce(prot.readI32() == 2);
106       enforce(prot.readI32() == 3);
107       prot.readMapEnd();
109       prot.reset();
114       prot.writeSetBegin(TSet(TType.I32, 2));
115       prot.writeI32(0);
116       prot.writeI32(1);
117       prot.writeSetEnd();
118       prot.reset();
120       auto set = prot.readSetBegin();
123       enforce(prot.readI32() == 0);
124       enforce(prot.readI32() == 1);
125       prot.readSetEnd();
127       prot.reset();
135   auto prot = new Protocol(buffer);
138   prot.stringSizeLimit = 3;
141     prot.writeString("asdf");
142     prot.reset();
144     auto e = cast(TProtocolException)collectException(prot.readString());
146     prot.reset();
151     prot.writeBinary([1, 2, 3, 4]);
152     prot.reset();
154     auto e = cast(TProtocolException)collectException(prot.readBinary());
156     prot.reset();
163     prot.containerSizeLimit = limit;
166       prot.writeString("as");
167       prot.reset();
169       enforce(prot.readString() == "as");
170       prot.reset();
175       prot.writeBinary([1, 2]);
176       prot.reset();
178       enforce(prot.readBinary() == [1, 2]);
179       prot.reset();