| 33544 | } |
| 33545 | |
| 33546 | func (p *IClientRPCServiceInsertTabletsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error { |
| 33547 | if _, err := iprot.ReadStructBegin(ctx); err != nil { |
| 33548 | return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) |
| 33549 | } |
| 33550 | |
| 33551 | |
| 33552 | for { |
| 33553 | _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) |
| 33554 | if err != nil { |
| 33555 | return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) |
| 33556 | } |
| 33557 | if fieldTypeId == thrift.STOP { break; } |
| 33558 | switch fieldId { |
| 33559 | case 1: |
| 33560 | if fieldTypeId == thrift.STRUCT { |
| 33561 | if err := p.ReadField1(ctx, iprot); err != nil { |
| 33562 | return err |
| 33563 | } |
| 33564 | } else { |
| 33565 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 33566 | return err |
| 33567 | } |
| 33568 | } |
| 33569 | default: |
| 33570 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 33571 | return err |
| 33572 | } |
| 33573 | } |
| 33574 | if err := iprot.ReadFieldEnd(ctx); err != nil { |
| 33575 | return err |
| 33576 | } |
| 33577 | } |
| 33578 | if err := iprot.ReadStructEnd(ctx); err != nil { |
| 33579 | return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) |
| 33580 | } |
| 33581 | return nil |
| 33582 | } |
| 33583 | |
| 33584 | func (p *IClientRPCServiceInsertTabletsArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { |
| 33585 | p.Req = &TSInsertTabletsReq{} |