| 28717 | } |
| 28718 | |
| 28719 | func (p *IClientRPCServiceCloseSessionArgs) Read(ctx context.Context, iprot thrift.TProtocol) error { |
| 28720 | if _, err := iprot.ReadStructBegin(ctx); err != nil { |
| 28721 | return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) |
| 28722 | } |
| 28723 | |
| 28724 | |
| 28725 | for { |
| 28726 | _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) |
| 28727 | if err != nil { |
| 28728 | return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) |
| 28729 | } |
| 28730 | if fieldTypeId == thrift.STOP { break; } |
| 28731 | switch fieldId { |
| 28732 | case 1: |
| 28733 | if fieldTypeId == thrift.STRUCT { |
| 28734 | if err := p.ReadField1(ctx, iprot); err != nil { |
| 28735 | return err |
| 28736 | } |
| 28737 | } else { |
| 28738 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 28739 | return err |
| 28740 | } |
| 28741 | } |
| 28742 | default: |
| 28743 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 28744 | return err |
| 28745 | } |
| 28746 | } |
| 28747 | if err := iprot.ReadFieldEnd(ctx); err != nil { |
| 28748 | return err |
| 28749 | } |
| 28750 | } |
| 28751 | if err := iprot.ReadStructEnd(ctx); err != nil { |
| 28752 | return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) |
| 28753 | } |
| 28754 | return nil |
| 28755 | } |
| 28756 | |
| 28757 | func (p *IClientRPCServiceCloseSessionArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { |
| 28758 | p.Req = &TSCloseSessionReq{} |