| /thrift-3.4.0/lib/py/src/protocol/ |
| D | TBase.py | 43 def read(self, iprot): argument
44 if (iprot._fast_decode is not None and
45 isinstance(iprot.trans, TTransport.CReadableTransport) and
47 iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
49 iprot.readStruct(self, self.thrift_spec)
74 def read(cls, iprot): argument
75 if (iprot._fast_decode is not None and
76 isinstance(iprot.trans, TTransport.CReadableTransport) and
79 return iprot._fast_decode(None, iprot,
82 return iprot.readStruct(cls, cls.thrift_spec, True)
|
| /thrift-3.4.0/lib/rb/lib/thrift/ |
| D | struct_union.rb | 51 def read_field(iprot, field = {}) argument
55 value.read(iprot)
57 key_type, val_type, size = iprot.read_map_begin
61 iprot.skip(key_type)
62 iprot.skip(val_type)
68 k = read_field(iprot, field_info(field[:key]))
69 v = read_field(iprot, field_info(field[:value]))
73 iprot.read_map_end
75 e_type, size = iprot.read_list_begin
79 iprot.skip(e_type)
[all …]
|
| D | exceptions.rb | 51 def read(iprot) argument
52 iprot.read_struct_begin
54 fname, ftype, fid = iprot.read_field_begin
59 @message = iprot.read_string
61 @type = iprot.read_i32
63 iprot.skip(ftype)
65 iprot.read_field_end
67 iprot.read_struct_end
|
| D | processor.rb | 34 def process(iprot, oprot) argument
35 name, type, seqid = iprot.read_message_begin
38 send("process_#{name}", seqid, iprot, oprot)
46 iprot.skip(Types::STRUCT)
47 iprot.read_message_end
54 def read_args(iprot, args_class) argument
56 args.read(iprot)
57 iprot.read_message_end
|
| D | union.rb | 56 def read(iprot) argument
57 iprot.read_struct_begin
58 fname, ftype, fid = iprot.read_field_begin
59 handle_message(iprot, fid, ftype)
60 iprot.read_field_end
62 fname, ftype, fid = iprot.read_field_begin
65 iprot.read_struct_end
165 def handle_message(iprot, fid, ftype) argument
168 @value = read_field(iprot, field)
172 iprot.skip(ftype)
|
| D | struct.rb | 83 def read(iprot) argument
84 iprot.read_struct_begin
86 fname, ftype, fid = iprot.read_field_begin
88 handle_message(iprot, fid, ftype)
89 iprot.read_field_end
91 iprot.read_struct_end
227 def handle_message(iprot, fid, ftype) argument
230 value = read_field(iprot, field)
233 iprot.skip(ftype)
|
| D | multiplexed_processor.rb | 32 def process(iprot, oprot) argument
33 name, type, seqid = iprot.read_message_begin
37 … processor(service_name).process(StoredMessageProtocol.new(iprot, [method, type, seqid]), oprot)
|
| /thrift-3.4.0/lib/cpp/src/thrift/ |
| D | TApplicationException.cpp | 26 uint32_t TApplicationException::read(apache::thrift::protocol::TProtocol* iprot) { in read() argument
32 xfer += iprot->readStructBegin(fname); in read()
35 xfer += iprot->readFieldBegin(fname, ftype, fid); in read()
42 xfer += iprot->readString(message_); in read()
44 xfer += iprot->skip(ftype); in read()
50 xfer += iprot->readI32(type); in read()
53 xfer += iprot->skip(ftype); in read()
57 xfer += iprot->skip(ftype); in read()
60 xfer += iprot->readFieldEnd(); in read()
63 xfer += iprot->readStructEnd(); in read()
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/ |
| D | TApplicationException.java | 83 public void read(TProtocol iprot) throws TException { in read() argument
85 iprot.readStructBegin(); in read()
91 field = iprot.readFieldBegin(); in read()
98 message = iprot.readString(); in read()
100 TProtocolUtil.skip(iprot, field.type); in read()
105 type = iprot.readI32(); in read()
107 TProtocolUtil.skip(iprot, field.type); in read()
111 TProtocolUtil.skip(iprot, field.type); in read()
114 iprot.readFieldEnd(); in read()
116 iprot.readStructEnd(); in read()
[all …]
|
| D | TUnion.java | 144 public void read(TProtocol iprot) throws TException { in read() argument
145 schemes.get(iprot.getScheme()).getScheme().read(iprot, this); in read()
180 protected abstract Object standardSchemeReadValue(TProtocol iprot, TField field) in standardSchemeReadValue() argument
185 protected abstract Object tupleSchemeReadValue(TProtocol iprot, short fieldID) throws TException; in tupleSchemeReadValue() argument
230 public void read(TProtocol iprot, TUnion struct) throws TException { in read() argument
234 iprot.readStructBegin(); in read()
236 TField field = iprot.readFieldBegin(); in read()
238 struct.value_ = struct.standardSchemeReadValue(iprot, field); in read()
243 iprot.readFieldEnd(); in read()
247 iprot.readFieldBegin(); in read()
[all …]
|
| /thrift-3.4.0/lib/go/thrift/ |
| D | serializer_types_test.go | 166 func (p *MyTestStruct) Read(ctx context.Context, iprot TProtocol) error {
167 if _, err := iprot.ReadStructBegin(ctx); err != nil {
171 _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx)
180 if err := p.readField1(ctx, iprot); err != nil {
184 if err := p.readField2(ctx, iprot); err != nil {
188 if err := p.readField3(ctx, iprot); err != nil {
192 if err := p.readField4(ctx, iprot); err != nil {
196 if err := p.readField5(ctx, iprot); err != nil {
200 if err := p.readField6(ctx, iprot); err != nil {
204 if err := p.readField7(ctx, iprot); err != nil {
[all …]
|
| D | client.go | 21 iprot, oprot TProtocol member
28 iprot: inputProtocol,
56 func (p *TStandardClient) Recv(ctx context.Context, iprot TProtocol, seqId int32, method string, re…
57 rMethod, rTypeId, rSeqId, err := iprot.ReadMessageBegin(ctx)
68 if err := exception.Read(ctx, iprot); err != nil {
72 if err := iprot.ReadMessageEnd(ctx); err != nil {
81 if err := result.Read(ctx, iprot); err != nil {
85 return iprot.ReadMessageEnd(ctx)
101 err := p.Recv(ctx, p.iprot, seqId, method, result)
103 if hp, ok := p.iprot.(*THeaderProtocol); ok {
|
| D | application_exception.go | 61 Read(ctx context.Context, iprot TProtocol) error
133 func (p *tApplicationException) Read(ctx context.Context, iprot TProtocol) error {
135 _, err := iprot.ReadStructBegin(ctx)
144 _, ttype, id, err := iprot.ReadFieldBegin(ctx)
154 if message, err = iprot.ReadString(ctx); err != nil {
158 if err = SkipDefaultDepth(ctx, iprot, ttype); err != nil {
164 if type_, err = iprot.ReadI32(ctx); err != nil {
168 if err = SkipDefaultDepth(ctx, iprot, ttype); err != nil {
173 if err = SkipDefaultDepth(ctx, iprot, ttype); err != nil {
177 if err = iprot.ReadFieldEnd(ctx); err != nil {
[all …]
|
| /thrift-3.4.0/lib/javame/src/org/apache/thrift/ |
| D | TApplicationException.java | 72 public static TApplicationException read(TProtocol iprot) throws TException { in read() argument
74 iprot.readStructBegin(); in read()
80 field = iprot.readFieldBegin(); in read()
87 message = iprot.readString(); in read()
89 TProtocolUtil.skip(iprot, field.type); in read()
94 type = iprot.readI32(); in read()
96 TProtocolUtil.skip(iprot, field.type); in read()
100 TProtocolUtil.skip(iprot, field.type); in read()
103 iprot.readFieldEnd(); in read()
105 iprot.readStructEnd(); in read()
|
| /thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/ |
| D | TestMultiplexedProcessor.java | 36 private TProtocol iprot; field in TestMultiplexedProcessor
42 iprot = mock(TProtocol.class); in setUp()
48 when(iprot.readMessageBegin()).thenReturn(new TMessage("service:func", TMessageType.REPLY, 42)); in testWrongMessageType()
49 assertThrows(TException.class, () -> mp.process(iprot, oprot)); in testWrongMessageType()
54 when(iprot.readMessageBegin()).thenReturn(new TMessage("service:func", TMessageType.CALL, 42)); in testNoSuchService()
56 assertThrows(TException.class, () -> mp.process(iprot, oprot)); in testNoSuchService()
72 when(iprot.readMessageBegin()).thenReturn(new TMessage("service:func", TMessageType.CALL, 42)); in testExistingService()
74 mp.process(iprot, oprot); in testExistingService()
80 when(iprot.readMessageBegin()).thenReturn(new TMessage("func", TMessageType.CALL, 42)); in testDefaultService()
82 mp.process(iprot, oprot); in testDefaultService()
|
| /thrift-3.4.0/lib/py/src/ |
| D | Thrift.py | 72 def process(self, iprot, oprot): argument
141 def read(self, iprot): argument
142 iprot.readStructBegin()
144 (fname, ftype, fid) = iprot.readFieldBegin()
149 self.message = iprot.readString()
151 iprot.skip(ftype)
154 self.type = iprot.readI32()
156 iprot.skip(ftype)
158 iprot.skip(ftype)
159 iprot.readFieldEnd()
[all …]
|
| D | TMultiplexedProcessor.py | 46 def process(self, iprot, oprot): argument
47 (name, type, seqid) = iprot.readMessageBegin()
57 StoredMessageProtocol(iprot, (name, type, seqid)), oprot)
74 StoredMessageProtocol(iprot, standardMessage), oprot)
|
| /thrift-3.4.0/lib/lua/ |
| D | Thrift.lua | 194 function TException:read(iprot)
195 iprot:readStructBegin()
197 local fname, ftype, fid = iprot:readFieldBegin()
202 self.message = iprot:readString()
204 iprot:skip(ftype)
208 self.errorCode = iprot:readI32()
210 iprot:skip(ftype)
213 iprot:skip(ftype)
215 iprot:readFieldEnd()
217 iprot:readStructEnd()
[all …]
|
| /thrift-3.4.0/lib/perl/lib/Thrift/ |
| D | Server.pm | 103 my $iprot = shift;
109 $self->{serverEventHandler}->clientBegin($iprot, $oprot);
163 my $iprot = $self->{inputProtocolFactory}->getProtocol($itrans);
166 $self->_clientBegin($iprot, $oprot);
169 $self->{processor}->process($iprot, $oprot);
226 my $iprot = $self->{inputProtocolFactory}->getProtocol($itrans);
229 $self->_clientBegin($iprot, $oprot);
238 $self->_child($itrans, $otrans, $iprot, $oprot);
263 my $iprot = shift;
272 $self->{processor}->process($iprot, $oprot);
|
| /thrift-3.4.0/lib/delphi/src/ |
| D | Thrift.pas | 77 procedure IBase_Read( const iprot: IProtocol);
80 class function Read( const iprot: IProtocol): TApplicationException; in Read()
226 procedure TApplicationException.IBase_Read( const iprot: IProtocol);
231 struc := iprot.ReadStructBegin;
234 field := iprot.ReadFieldBegin;
242 Exception(Self).Message := iprot.ReadString;
244 TProtocolUtil.Skip( iprot, field.Type_ );
250 FExceptionType := TExceptionType( iprot.ReadI32 );
252 TProtocolUtil.Skip( iprot, field.Type_ );
255 TProtocolUtil.Skip( iprot, field.Type_);
[all …]
|
| /thrift-3.4.0/lib/dart/lib/src/ |
| D | t_application_error.dart | 45 static TApplicationError read(TProtocol iprot) {
51 iprot.readStructBegin();
53 field = iprot.readFieldBegin();
62 message = iprot.readString();
64 TProtocolUtil.skip(iprot, field.type);
70 type = iprot.readI32();
72 TProtocolUtil.skip(iprot, field.type);
77 TProtocolUtil.skip(iprot, field.type);
80 iprot.readFieldEnd();
82 iprot.readStructEnd();
|
| /thrift-3.4.0/lib/haxe/src/org/apache/thrift/ |
| D | TApplicationException.hx | 55 public static function read(iprot:TProtocol) : TApplicationException {
57 iprot.readStructBegin();
63 field = iprot.readFieldBegin();
70 message = iprot.readString();
73 TProtocolUtil.skip(iprot, field.type);
77 type = iprot.readI32();
80 TProtocolUtil.skip(iprot, field.type);
83 TProtocolUtil.skip(iprot, field.type);
85 iprot.readFieldEnd();
87 iprot.readStructEnd();
|
| /thrift-3.4.0/lib/dart/test/serializer/ |
| D | serializer_test_data.dart | 204 read(TProtocol iprot) {
206 iprot.readStructBegin();
208 field = iprot.readFieldBegin();
215 this.i = iprot.readI32();
218 TProtocolUtil.skip(iprot, field.type);
223 this.d = iprot.readDouble();
226 TProtocolUtil.skip(iprot, field.type);
231 this.s = iprot.readString();
233 TProtocolUtil.skip(iprot, field.type);
239 TList _list74 = iprot.readListBegin();
[all …]
|
| /thrift-3.4.0/lib/py/src/server/ |
| D | TServer.py | 88 iprot = self.inputProtocolFactory.getProtocol(itrans)
95 oprot = iprot
102 self.processor.process(iprot, oprot)
137 iprot = self.inputProtocolFactory.getProtocol(itrans)
144 oprot = iprot
151 self.processor.process(iprot, oprot)
187 iprot = self.inputProtocolFactory.getProtocol(itrans)
194 oprot = iprot
201 self.processor.process(iprot, oprot)
278 iprot = self.inputProtocolFactory.getProtocol(itrans)
[all …]
|
| /thrift-3.4.0/lib/d/src/thrift/codegen/ |
| D | processor.d | 100 override bool process(TProtocol iprot, TProtocol oprot,
103 auto msg = iprot.readMessageBegin();
115 skip(iprot, TType.STRUCT);
116 iprot.readMessageEnd();
117 iprot.transport.readEnd();
126 skip(iprot, TType.STRUCT);
127 iprot.readMessageEnd();
128 iprot.transport.readEnd();
136 (*dg)(msg.seqid, iprot, oprot, context);
188 auto castedIProt = cast(IProt)iprot;
[all …]
|
