Home
last modified time | relevance | path

Searched refs:TCompactProtocol (Results 1 – 25 of 76) sorted by relevance

1234

/thrift-3.4.0/lib/nodejs/lib/thrift/
Dcompact_protocol.js25 module.exports = TCompactProtocol;
43 function TCompactProtocol(trans) { class
71 TCompactProtocol.PROTOCOL_ID = -126; //1000 0010
78 TCompactProtocol.VERSION_N = 1;
85 TCompactProtocol.VERSION_MASK = 0x1f; //0001 1111
92 TCompactProtocol.TYPE_MASK = -32; //1110 0000
99 TCompactProtocol.TYPE_BITS = 7; //0000 0111
106 TCompactProtocol.TYPE_SHIFT_AMOUNT = 5;
125 TCompactProtocol.Types = {
145 TCompactProtocol.TTypeToCType = [
[all …]
Dheader_transport.js21 var TCompactProtocol = require('./compact_protocol'); variable
65 this.protocol = new TCompactProtocol(this.transport);
206 return protocolId === TCompactProtocol.PROTOCOL_ID &&
207 (version & TCompactProtocol.VERSION_MASK) === TCompactProtocol.VERSION_N;
Dprotocol.js21 module.exports.TCompactProtocol = require('./compact_protocol');
/thrift-3.4.0/lib/lua/
DTCompactProtocol.lua25 TCompactProtocol = __TObject.new(TProtocolBase, {
96 function TCompactProtocol:resetLastField()
102 function TCompactProtocol:packCompactType(ktype, vtype)
106 function TCompactProtocol:writeMessageBegin(name, ttype, seqid)
107 self:writeByte(TCompactProtocol.COMPACT_PROTOCOL_ID)
108 self:writeByte(libluabpack.packMesgType(TCompactProtocol.COMPACT_VERSION,
109 TCompactProtocol.COMPACT_VERSION_MASK,ttype,
110 TCompactProtocol.COMPACT_TYPE_SHIFT_AMOUNT,
111 TCompactProtocol.COMPACT_TYPE_MASK))
117 function TCompactProtocol:writeMessageEnd()
[all …]
/thrift-3.4.0/lib/php/lib/Protocol/
DTCompactProtocol.php33 class TCompactProtocol extends TProtocol class
67 TType::STOP => TCompactProtocol::COMPACT_STOP,
68 TType::BOOL => TCompactProtocol::COMPACT_TRUE, // used for collection
69 TType::BYTE => TCompactProtocol::COMPACT_BYTE,
70 TType::I16 => TCompactProtocol::COMPACT_I16,
71 TType::I32 => TCompactProtocol::COMPACT_I32,
72 TType::I64 => TCompactProtocol::COMPACT_I64,
73 TType::DOUBLE => TCompactProtocol::COMPACT_DOUBLE,
74 TType::STRING => TCompactProtocol::COMPACT_BINARY,
75 TType::STRUCT => TCompactProtocol::COMPACT_STRUCT,
[all …]
/thrift-3.4.0/lib/go/thrift/
Dcompact_protocol.go105 type TCompactProtocol struct { struct
130 func NewTCompactProtocol(trans TTransport) *TCompactProtocol {
136 func NewTCompactProtocolConf(trans TTransport, conf *TConfiguration) *TCompactProtocol {
138 p := &TCompactProtocol{
157 func (p *TCompactProtocol) WriteMessageBegin(ctx context.Context, name string, typeId TMessageType,… argument
175 func (p *TCompactProtocol) WriteMessageEnd(ctx context.Context) error { return nil } argument
180 func (p *TCompactProtocol) WriteStructBegin(ctx context.Context, name string) error { argument
189 func (p *TCompactProtocol) WriteStructEnd(ctx context.Context) error { argument
198 func (p *TCompactProtocol) WriteFieldBegin(ctx context.Context, name string, typeId TType, id int16… argument
211 func (p *TCompactProtocol) writeFieldBeginInternal(ctx context.Context, name string, typeId TType, … argument
[all …]
/thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/protocol/
DTestTProtocolUtil.java35 TProtocolUtil.guessProtocolFactory(data, new TCompactProtocol.Factory()); in testGuessProtocolFactory_JSON()
43 byte[] ser = new TSerializer(new TCompactProtocol.Factory()).serialize(s); in testGuessProtocolFactory_JSON()
44 factory = TProtocolUtil.guessProtocolFactory(ser, new TCompactProtocol.Factory()); in testGuessProtocolFactory_JSON()
56 TProtocolUtil.guessProtocolFactory(buf, new TCompactProtocol.Factory()); in testGuessProtocolFactory_Binary()
63 TProtocolUtil.guessProtocolFactory(buf, new TCompactProtocol.Factory()); in testGuessProtocolFactory_Binary()
74 assertTrue(factory instanceof TCompactProtocol.Factory); in testGuessProtocolFactory_Compact()
81 assertTrue(factory instanceof TCompactProtocol.Factory); in testGuessProtocolFactory_Compact()
DTestTCompactProtocol.java30 return new TCompactProtocol.Factory(); in getFactory()
43 TDeserializer deser = new TDeserializer(new TCompactProtocol.Factory(1000)); in testOOMDenialOfService()
/thrift-3.4.0/lib/py/test/
Dthrift_TCompactProtocol.py21 from thrift.protocol import TCompactProtocol
39 protocol = TCompactProtocol.TCompactProtocol(transport)
77 protocol = TCompactProtocol.TCompactProtocol(transport)
115 protocol = TCompactProtocol.TCompactProtocol(transport)
150 protocol = TCompactProtocol.TCompactProtocol(transport)
189 protocol = TCompactProtocol.TCompactProtocol(transport)
198 protocol = TCompactProtocol.TCompactProtocol(transport)
Dthrift_TSerializer.py32 from thrift.protocol.TCompactProtocol import TCompactProtocolFactory
33 from thrift.protocol.TCompactProtocol import TCompactProtocolAcceleratedFactory
/thrift-3.4.0/lib/netstd/Tests/Thrift.IntegrationTests/Protocols/
DProtocolsOperationsTests.cs43 [DataRow(typeof(TCompactProtocol), TMessageType.Call)]
44 [DataRow(typeof(TCompactProtocol), TMessageType.Exception)]
45 [DataRow(typeof(TCompactProtocol), TMessageType.Oneway)]
46 [DataRow(typeof(TCompactProtocol), TMessageType.Reply)]
82 [DataRow(typeof(TCompactProtocol))]
117 [DataRow(typeof(TCompactProtocol))]
151 [DataRow(typeof(TCompactProtocol))]
185 [DataRow(typeof(TCompactProtocol))]
218 [DataRow(typeof(TCompactProtocol))]
251 [DataRow(typeof(TCompactProtocol))]
[all …]
/thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/test/
DTestServlet.java23 import org.apache.thrift.protocol.TCompactProtocol;
34 TProtocolFactory tProtocolFactory = new TCompactProtocol.Factory(); in getInProtocolFactory()
40 TProtocolFactory tProtocolFactory = new TCompactProtocol.Factory(); in getOutProtocolFactory()
/thrift-3.4.0/test/py/
DTestEof.py25 from thrift.protocol import TCompactProtocol
115 self.eofTestHelper(TCompactProtocol.TCompactProtocolFactory())
116 self.eofTestHelperStress(TCompactProtocol.TCompactProtocolFactory())
120 self.eofTestHelper(TCompactProtocol.TCompactProtocolAcceleratedFactory(fallback=False))
121 … self.eofTestHelperStress(TCompactProtocol.TCompactProtocolAcceleratedFactory(fallback=False))
/thrift-3.4.0/lib/php/lib/Factory/
DTCompactProtocolFactory.php25 use Thrift\Protocol\TCompactProtocol; alias
38 return new TCompactProtocol($trans);
/thrift-3.4.0/test/features/
Dutil.py9 from thrift.protocol.TCompactProtocol import TCompactProtocol
38 'compact': TCompactProtocol,
Dtheader_binary.py13 from thrift.protocol.TCompactProtocol import TCompactProtocol
59 proto = TCompactProtocol(trans)
/thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/partial/
DThriftSerDe.java27 import org.apache.thrift.protocol.TCompactProtocol;
37 this.compactSerializer = new TSerializer(new TCompactProtocol.Factory()); in ThriftSerDe()
39 this.compactDeserializer = new TDeserializer(new TCompactProtocol.Factory()); in ThriftSerDe()
DPartialThriftComparerTest.java30 import org.apache.thrift.protocol.TCompactProtocol;
55 new TDeserializer(TestStruct.class, fieldNames, new TCompactProtocol.Factory()); in testCompareSimple()
/thrift-3.4.0/lib/py/src/transport/
DTHeaderTransport.py25 from thrift.protocol.TCompactProtocol import TCompactProtocol, readVarint, writeVarint
187 elif (byte_index(first_word, 0) == TCompactProtocol.PROTOCOL_ID and
188 … byte_index(first_word, 1) & TCompactProtocol.VERSION_MASK == TCompactProtocol.VERSION):
221 elif (byte_index(second_word, 0) == TCompactProtocol.PROTOCOL_ID and
222 … byte_index(second_word, 1) & TCompactProtocol.VERSION_MASK == TCompactProtocol.VERSION):
/thrift-3.4.0/test/swift/CrossTests/Sources/TestServer/
Dmain.swift45 let proto = TCompactProtocol.self in run()
48 let proto = TCompactProtocol.self in run()
/thrift-3.4.0/lib/dart/test/serializer/
Dserializer_test.dart104 serializer.protocol = TCompactProtocol(serializer.transport);
105 deserializer.protocol = TCompactProtocol(deserializer.transport);
111 serializer.protocol = TCompactProtocol(serializer.transport);
112 deserializer.protocol = TCompactProtocol(deserializer.transport);
/thrift-3.4.0/lib/swift/Sources/
DTCompactProtocol.swift46 public class TCompactProtocol: TProtocol { class
247 if protocolId != TCompactProtocol.protocolID { in readMessageBegin()
248 let expected = String(format:"%2X", TCompactProtocol.protocolID) in readMessageBegin()
255 let version: UInt8 = versionAndType & TCompactProtocol.versionMask in readMessageBegin()
256 if version != TCompactProtocol.version { in readMessageBegin()
447 try writebyteDirect(TCompactProtocol.protocolID)
448 let nextByte: UInt8 = (TCompactProtocol.version & TCompactProtocol.versionMask) |
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/protocol/
DTProtocolUtil.java182 return new TCompactProtocol.Factory(); in guessProtocolFactory()
204 return new TCompactProtocol.Factory(); in guessProtocolFactory()
/thrift-3.4.0/lib/cpp/test/
DAllProtocolTests.cpp46 testProtocol<TCompactProtocol>("TCompactProtocol"); in BOOST_AUTO_TEST_CASE()
/thrift-3.4.0/lib/nodejs/test/
Dhelpers.js31 compact: thrift.TCompactProtocol,

1234