| 30301 | } |
| 30302 | |
| 30303 | func (p *IClientRPCServiceCloseOperationArgs) Read(ctx context.Context, iprot thrift.TProtocol) error { |
| 30304 | if _, err := iprot.ReadStructBegin(ctx); err != nil { |
| 30305 | return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) |
| 30306 | } |
| 30307 | |
| 30308 | |
| 30309 | for { |
| 30310 | _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) |
| 30311 | if err != nil { |
| 30312 | return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) |
| 30313 | } |
| 30314 | if fieldTypeId == thrift.STOP { break; } |
| 30315 | switch fieldId { |
| 30316 | case 1: |
| 30317 | if fieldTypeId == thrift.STRUCT { |
| 30318 | if err := p.ReadField1(ctx, iprot); err != nil { |
| 30319 | return err |
| 30320 | } |
| 30321 | } else { |
| 30322 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 30323 | return err |
| 30324 | } |
| 30325 | } |
| 30326 | default: |
| 30327 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 30328 | return err |
| 30329 | } |
| 30330 | } |
| 30331 | if err := iprot.ReadFieldEnd(ctx); err != nil { |
| 30332 | return err |
| 30333 | } |
| 30334 | } |
| 30335 | if err := iprot.ReadStructEnd(ctx); err != nil { |
| 30336 | return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) |
| 30337 | } |
| 30338 | return nil |
| 30339 | } |
| 30340 | |
| 30341 | func (p *IClientRPCServiceCloseOperationArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { |
| 30342 | p.Req = &TSCloseOperationReq{} |