Lines Matching refs:protocol
23 from thrift.protocol.TBinaryProtocol import TBinaryProtocol
30 protocol = TBinaryProtocol(transport)
32 protocol.writeByte(data)
35 protocol.writeI16(data)
38 protocol.writeI32(data)
41 protocol.writeI64(data)
44 protocol.writeString(data)
47 protocol.writeDouble(data)
50 protocol.writeBinary(data)
53 protocol.writeBool(data)
59 protocol = TBinaryProtocol(transport)
61 return protocol.readByte()
64 return protocol.readI16()
67 return protocol.readI32()
70 return protocol.readI64()
73 return protocol.readString()
76 return protocol.readDouble()
79 return protocol.readBinary()
82 return protocol.readBool()
89 protocol = TBinaryProtocol(transport)
90 protocol.writeStructBegin('struct')
91 protocol.writeFieldBegin("field", TType[type.capitalize()], 10)
93 protocol.writeByte(data)
96 protocol.writeI16(data)
99 protocol.writeI32(data)
102 protocol.writeI64(data)
105 protocol.writeString(data)
108 protocol.writeDouble(data)
111 protocol.writeBinary(data)
114 protocol.writeBool(data)
116 protocol.writeFieldEnd()
117 protocol.writeStructEnd()
124 protocol = TBinaryProtocol(transport)
125 protocol.readStructBegin()
126 protocol.readFieldBegin()
128 return protocol.readByte()
131 return protocol.readI16()
134 return protocol.readI32()
137 return protocol.readI64()
140 return protocol.readString()
143 return protocol.readDouble()
146 return protocol.readBinary()
149 return protocol.readBool()
151 protocol.readFieldEnd()
152 protocol.readStructEnd()
163 protocol = TBinaryProtocol(transport)
164 protocol.writeMessageBegin(message['name'], message['type'], message['seqid'])
165 protocol.writeMessageEnd()
172 protocol = TBinaryProtocol(transport)
173 result = protocol.readMessageBegin()
174 protocol.readMessageEnd()