(ctx context.Context, iprot thrift.TProtocol)
| 32701 | return p.StorageGroup |
| 32702 | } |
| 32703 | func (p *IClientRPCServiceDeleteStorageGroupsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error { |
| 32704 | if _, err := iprot.ReadStructBegin(ctx); err != nil { |
| 32705 | return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) |
| 32706 | } |
| 32707 | |
| 32708 | |
| 32709 | for { |
| 32710 | _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) |
| 32711 | if err != nil { |
| 32712 | return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) |
| 32713 | } |
| 32714 | if fieldTypeId == thrift.STOP { break; } |
| 32715 | switch fieldId { |
| 32716 | case 1: |
| 32717 | if fieldTypeId == thrift.I64 { |
| 32718 | if err := p.ReadField1(ctx, iprot); err != nil { |
| 32719 | return err |
| 32720 | } |
| 32721 | } else { |
| 32722 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 32723 | return err |
| 32724 | } |
| 32725 | } |
| 32726 | case 2: |
| 32727 | if fieldTypeId == thrift.LIST { |
| 32728 | if err := p.ReadField2(ctx, iprot); err != nil { |
| 32729 | return err |
| 32730 | } |
| 32731 | } else { |
| 32732 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 32733 | return err |
| 32734 | } |
| 32735 | } |
| 32736 | default: |
| 32737 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 32738 | return err |
| 32739 | } |
| 32740 | } |
| 32741 | if err := iprot.ReadFieldEnd(ctx); err != nil { |
| 32742 | return err |
| 32743 | } |
| 32744 | } |
| 32745 | if err := iprot.ReadStructEnd(ctx); err != nil { |
| 32746 | return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) |
| 32747 | } |
| 32748 | return nil |
| 32749 | } |
| 32750 | |
| 32751 | func (p *IClientRPCServiceDeleteStorageGroupsArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { |
| 32752 | if v, err := iprot.ReadI64(ctx); err != nil { |
no test coverage detected