Home
last modified time | relevance | path

Searched refs:seqId (Results 1 – 17 of 17) sorted by relevance

/thrift-3.4.0/lib/go/thrift/
Dclient.go20 seqId int32 member
33 func (p *TStandardClient) Send(ctx context.Context, oprot TProtocol, seqId int32, method string, ar…
44 if err := oprot.WriteMessageBegin(ctx, method, CALL, seqId); err != nil {
56 func (p *TStandardClient) Recv(ctx context.Context, iprot TProtocol, seqId int32, method string, re…
64 } else if seqId != rSeqId {
89 p.seqId++
90 seqId := p.seqId
92 if err := p.Send(ctx, p.oprot, seqId, method, args); err != nil {
101 err := p.Recv(ctx, p.iprot, seqId, method, result)
Dbinary_protocol.go108 …ocol) WriteMessageBegin(ctx context.Context, name string, typeId TMessageType, seqId int32) error {
119 e = p.WriteI32(ctx, seqId)
130 e = p.WriteI32(ctx, seqId)
272 … ReadMessageBegin(ctx context.Context) (name string, typeId TMessageType, seqId int32, err error) {
281 …return name, typeId, seqId, NewTProtocolExceptionWithType(BAD_VERSION, fmt.Errorf("Bad version in …
285 return name, typeId, seqId, NewTProtocolException(e)
287 seqId, e = p.ReadI32(ctx)
289 return name, typeId, seqId, NewTProtocolException(e)
291 return name, typeId, seqId, nil
294 …return name, typeId, seqId, NewTProtocolExceptionWithType(BAD_VERSION, fmt.Errorf("Missing version…
[all …]
Dmiddleware_test.go46 Wrapped: func(ctx context.Context, seqId int32, in, out TProtocol) (bool, TException) {
48 return next.Process(ctx, seqId, in, out)
70 Wrapped: func(ctx context.Context, seqId int32, in, out TProtocol) (bool, TException) {
93 Wrapped: func(ctx context.Context, seqId int32, in, out TProtocol) (bool, TException) {
102 Wrapped: func(ctx context.Context, seqId int32, in, out TProtocol) (bool, TException) {
Dexample_processor_middleware_test.go29 Wrapped: func(ctx context.Context, seqId int32, in, out TProtocol) (bool, TException) {
31 success, err := next.Process(ctx, seqId, in, out)
Dmultiplexed_protocol_test.go16 Wrapped: func(ctx context.Context, seqId int32, in, out TProtocol) (bool, TException) {
25 Wrapped: func(ctx context.Context, seqId int32, in, out TProtocol) (bool, TException) {
Djson_protocol.go59 …ocol) WriteMessageBegin(ctx context.Context, name string, typeId TMessageType, seqId int32) error {
73 if e := p.WriteI32(ctx, seqId); e != nil {
221 … ReadMessageBegin(ctx context.Context) (name string, typeId TMessageType, seqId int32, err error) {
224 return name, typeId, seqId, err
228 return name, typeId, seqId, err
232 return name, typeId, seqId, NewTProtocolExceptionWithType(INVALID_DATA, e)
236 return name, typeId, seqId, err
241 return name, typeId, seqId, err
243 if seqId, err = p.ReadI32(ctx); err != nil {
244 return name, typeId, seqId, err
[all …]
Dprocessor_factory.go41 Process(ctx context.Context, seqId int32, in, out TProtocol) (bool, TException)
Dcommon_test.go38 Wrapped: func(ctx context.Context, seqId int32, in, out TProtocol) (bool, TException) {
Dmiddleware.go60 Wrapped func(ctx context.Context, seqId int32, in, out TProtocol) (bool, TException)
Dsimple_json_protocol.go212 …ocol) WriteMessageBegin(ctx context.Context, name string, typeId TMessageType, seqId int32) error {
223 if e := p.WriteI32(ctx, seqId); e != nil {
348 … ReadMessageBegin(ctx context.Context) (name string, typeId TMessageType, seqId int32, err error) {
351 return name, typeId, seqId, err
354 return name, typeId, seqId, err
359 return name, typeId, seqId, err
361 if seqId, err = p.ReadI32(ctx); err != nil {
362 return name, typeId, seqId, err
364 return name, typeId, seqId, nil
Dcompact_protocol.go370 … ReadMessageBegin(ctx context.Context) (name string, typeId TMessageType, seqId int32, err error) {
390 return "", typeId, seqId, NewTProtocolExceptionWithType(BAD_VERSION, e)
405 seqId, e := p.readVarint32()
/thrift-3.4.0/lib/cpp/src/thrift/transport/
DTHeaderTransport.h81 seqId(0), in TVirtualTransport()
96 seqId(0), in TVirtualTransport()
164 int32_t getSequenceNumber() const { return seqId; } in getSequenceNumber()
165 void setSequenceNumber(int32_t seqId) { this->seqId = seqId; } in setSequenceNumber() argument
199 uint32_t seqId; variable
DTHeaderTransport.cpp156 seqId = ntohl(seqId_n); in readFrame()
469 uint32_t seqIdN = htonl(seqId); in flush()
/thrift-3.4.0/lib/cpp/src/thrift/protocol/
DTHeaderProtocol.cpp59 const int32_t seqId) { in writeMessageBegin() argument
61 trans_->setSequenceNumber(seqId); in writeMessageBegin()
62 return proto_->writeMessageBegin(name, messageType, seqId); in writeMessageBegin()
155 int32_t& seqId) { in readMessageBegin() argument
171 return proto_->readMessageBegin(name, messageType, seqId); in readMessageBegin()
DTHeaderProtocol.h96 const int32_t seqId);
142 /*ol*/ uint32_t readMessageBegin(std::string& name, TMessageType& messageType, int32_t& seqId);
/thrift-3.4.0/lib/go/test/tests/
Dprocessor_middleware_test.go46 …Wrapped: func(ctx context.Context, seqId int32, in, out thrift.TProtocol) (_ bool, err thrift.TExc…
50 return next.Process(ctx, seqId, in, out)
/thrift-3.4.0/lib/dart/lib/src/protocol/
Dt_compact_protocol.dart288 int seqId = _readVarInt32().toInt();
290 return TMessage(messageName, type, seqId);