// Code generated by protoc-gen-gogo. DO NOT EDIT. // source: ibc.core.channel.v0/channel.proto package v10 import ( fmt "fmt" _ "github.com/cosmos/gogoproto/gogoproto" proto "github.com/cosmos/gogoproto/proto" types "github.com/cosmos/ibc-go/v10/modules/core/02-client/types" io "io" math "math" math_bits "math/bits" ) // Reference imports to suppress errors if they are not otherwise used. var _ = proto.Marshal var _ = fmt.Errorf var _ = math.Inf // This is a compile-time assertion to ensure that this generated file // is compatible with the proto package it is being compiled against. // A compilation error at this line likely means your copy of the // proto package needs to be updated. const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package // State defines if a channel is in one of the following states: // CLOSED, INIT, TRYOPEN, OPEN, FLUSHING, FLUSHCOMPLETE or UNINITIALIZED. type State int32 const ( // Default State UNINITIALIZED State = 0 // A channel has just started the opening handshake. INIT State = 1 // A channel has acknowledged the handshake step on the counterparty chain. TRYOPEN State = 2 // A channel has completed the handshake. Open channels are // ready to send and receive packets. OPEN State = 3 // A channel has been closed and can no longer be used to send or receive // packets. CLOSED State = 4 // A channel has just accepted the upgrade handshake attempt and is flushing in-flight packets. FLUSHING State = 5 // A channel has just completed flushing any in-flight packets. FLUSHCOMPLETE State = 6 ) var State_name = map[int32]string{ 0: "STATE_UNINITIALIZED_UNSPECIFIED", 1: "STATE_INIT", 2: "STATE_TRYOPEN", 3: "STATE_OPEN", 4: "STATE_CLOSED", 5: "STATE_FLUSHING", 6: "STATE_FLUSHCOMPLETE", } var State_value = map[string]int32{ "STATE_UNINITIALIZED_UNSPECIFIED": 0, "STATE_INIT": 1, "STATE_TRYOPEN": 2, "STATE_OPEN": 3, "STATE_CLOSED": 4, "STATE_FLUSHING": 5, "STATE_FLUSHCOMPLETE": 6, } func (x State) String() string { return proto.EnumName(State_name, int32(x)) } func (State) EnumDescriptor() ([]byte, []int) { return fileDescriptor_c3a07336710636a0, []int{0} } // Order defines if a channel is ORDERED or UNORDERED type Order int32 const ( // zero-value for channel ordering NONE Order = 0 // packets can be delivered in any order, which may differ from the order in // which they were sent. UNORDERED Order = 1 // packets are delivered exactly in the order which they were sent ORDERED Order = 2 ) var Order_name = map[int32]string{ 0: "ORDER_NONE_UNSPECIFIED", 1: "ORDER_UNORDERED", 2: "ORDER_ORDERED", } var Order_value = map[string]int32{ "ORDER_NONE_UNSPECIFIED": 0, "ORDER_UNORDERED": 1, "ORDER_ORDERED": 2, } func (x Order) String() string { return proto.EnumName(Order_name, int32(x)) } func (Order) EnumDescriptor() ([]byte, []int) { return fileDescriptor_c3a07336710636a0, []int{1} } // Channel defines pipeline for exactly-once packet delivery between specific // modules on separate blockchains, which has at least one end capable of // sending packets and one end capable of receiving packets. type Channel struct { // current state of the channel end State State `protobuf:"varint,1,opt,name=state,proto3,enum=ibc.core.channel.v0.State" json:"state,omitempty"` // whether the channel is ordered or unordered Ordering Order `protobuf:"varint,2,opt,name=ordering,proto3,enum=ibc.core.channel.v0.Order" json:"ordering,omitempty"` // counterparty channel end Counterparty Counterparty `protobuf:"bytes,3,opt,name=counterparty,proto3" json:"counterparty"` // list of connection identifiers, in order, along which packets sent on // this channel will travel ConnectionHops []string `protobuf:"bytes,4,rep,name=connection_hops,json=connectionHops,proto3" json:"connection_hops,omitempty"` // opaque channel version, which is agreed upon during the handshake Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"` // upgrade sequence indicates the latest upgrade attempt performed by this channel // the value of 0 indicates the channel has never been upgraded UpgradeSequence uint64 `protobuf:"varint,6,opt,name=upgrade_sequence,json=upgradeSequence,proto3" json:"upgrade_sequence,omitempty"` } func (m *Channel) Reset() { *m = Channel{} } func (m *Channel) String() string { return proto.CompactTextString(m) } func (*Channel) ProtoMessage() {} func (*Channel) Descriptor() ([]byte, []int) { return fileDescriptor_c3a07336710636a0, []int{0} } func (m *Channel) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Channel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Channel.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Channel) XXX_Merge(src proto.Message) { xxx_messageInfo_Channel.Merge(m, src) } func (m *Channel) XXX_Size() int { return m.Size() } func (m *Channel) XXX_DiscardUnknown() { xxx_messageInfo_Channel.DiscardUnknown(m) } var xxx_messageInfo_Channel proto.InternalMessageInfo // IdentifiedChannel defines a channel with additional port and channel // identifier fields. type IdentifiedChannel struct { // current state of the channel end State State `protobuf:"varint,1,opt,name=state,proto3,enum=ibc.core.channel.v0.State" json:"state,omitempty"` // whether the channel is ordered or unordered Ordering Order `protobuf:"varint,2,opt,name=ordering,proto3,enum=ibc.core.channel.v0.Order" json:"ordering,omitempty"` // counterparty channel end Counterparty Counterparty `protobuf:"bytes,3,opt,name=counterparty,proto3" json:"counterparty"` // list of connection identifiers, in order, along which packets sent on // this channel will travel ConnectionHops []string `protobuf:"bytes,4,rep,name=connection_hops,json=connectionHops,proto3" json:"connection_hops,omitempty"` // opaque channel version, which is agreed upon during the handshake Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"` // port identifier PortId string `protobuf:"bytes,6,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` // channel identifier ChannelId string `protobuf:"bytes,7,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // upgrade sequence indicates the latest upgrade attempt performed by this channel // the value of 0 indicates the channel has never been upgraded UpgradeSequence uint64 `protobuf:"varint,8,opt,name=upgrade_sequence,json=upgradeSequence,proto3" json:"upgrade_sequence,omitempty"` } func (m *IdentifiedChannel) Reset() { *m = IdentifiedChannel{} } func (m *IdentifiedChannel) String() string { return proto.CompactTextString(m) } func (*IdentifiedChannel) ProtoMessage() {} func (*IdentifiedChannel) Descriptor() ([]byte, []int) { return fileDescriptor_c3a07336710636a0, []int{1} } func (m *IdentifiedChannel) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *IdentifiedChannel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_IdentifiedChannel.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *IdentifiedChannel) XXX_Merge(src proto.Message) { xxx_messageInfo_IdentifiedChannel.Merge(m, src) } func (m *IdentifiedChannel) XXX_Size() int { return m.Size() } func (m *IdentifiedChannel) XXX_DiscardUnknown() { xxx_messageInfo_IdentifiedChannel.DiscardUnknown(m) } var xxx_messageInfo_IdentifiedChannel proto.InternalMessageInfo // Counterparty defines a channel end counterparty type Counterparty struct { // port on the counterparty chain which owns the other end of the channel. PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` // channel end on the counterparty chain ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` } func (m *Counterparty) Reset() { *m = Counterparty{} } func (m *Counterparty) String() string { return proto.CompactTextString(m) } func (*Counterparty) ProtoMessage() {} func (*Counterparty) Descriptor() ([]byte, []int) { return fileDescriptor_c3a07336710636a0, []int{2} } func (m *Counterparty) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Counterparty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Counterparty.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Counterparty) XXX_Merge(src proto.Message) { xxx_messageInfo_Counterparty.Merge(m, src) } func (m *Counterparty) XXX_Size() int { return m.Size() } func (m *Counterparty) XXX_DiscardUnknown() { xxx_messageInfo_Counterparty.DiscardUnknown(m) } var xxx_messageInfo_Counterparty proto.InternalMessageInfo // Packet defines a type that carries data across different chains through IBC type Packet struct { // number corresponds to the order of sends and receives, where a Packet // with an earlier sequence number must be sent and received before a Packet // with a later sequence number. Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"` // identifies the port on the sending chain. SourcePort string `protobuf:"bytes,2,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"` // identifies the channel end on the sending chain. SourceChannel string `protobuf:"bytes,3,opt,name=source_channel,json=sourceChannel,proto3" json:"source_channel,omitempty"` // identifies the port on the receiving chain. DestinationPort string `protobuf:"bytes,4,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"` // identifies the channel end on the receiving chain. DestinationChannel string `protobuf:"bytes,5,opt,name=destination_channel,json=destinationChannel,proto3" json:"destination_channel,omitempty"` // actual opaque bytes transferred directly to the application module Data []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"` // block height after which the packet times out TimeoutHeight types.Height `protobuf:"bytes,7,opt,name=timeout_height,json=timeoutHeight,proto3" json:"timeout_height"` // block timestamp (in nanoseconds) after which the packet times out TimeoutTimestamp uint64 `protobuf:"varint,8,opt,name=timeout_timestamp,json=timeoutTimestamp,proto3" json:"timeout_timestamp,omitempty"` } func (m *Packet) Reset() { *m = Packet{} } func (m *Packet) String() string { return proto.CompactTextString(m) } func (*Packet) ProtoMessage() {} func (*Packet) Descriptor() ([]byte, []int) { return fileDescriptor_c3a07336710636a0, []int{3} } func (m *Packet) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Packet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Packet.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Packet) XXX_Merge(src proto.Message) { xxx_messageInfo_Packet.Merge(m, src) } func (m *Packet) XXX_Size() int { return m.Size() } func (m *Packet) XXX_DiscardUnknown() { xxx_messageInfo_Packet.DiscardUnknown(m) } var xxx_messageInfo_Packet proto.InternalMessageInfo // PacketState defines the generic type necessary to retrieve and store // packet commitments, acknowledgements, and receipts. // Caller is responsible for knowing the context necessary to interpret this // state as a commitment, acknowledgement, or a receipt. type PacketState struct { // channel port identifier. PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` // channel unique identifier. ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // packet sequence. Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"` // embedded data that represents packet state. Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` } func (m *PacketState) Reset() { *m = PacketState{} } func (m *PacketState) String() string { return proto.CompactTextString(m) } func (*PacketState) ProtoMessage() {} func (*PacketState) Descriptor() ([]byte, []int) { return fileDescriptor_c3a07336710636a0, []int{4} } func (m *PacketState) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *PacketState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_PacketState.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *PacketState) XXX_Merge(src proto.Message) { xxx_messageInfo_PacketState.Merge(m, src) } func (m *PacketState) XXX_Size() int { return m.Size() } func (m *PacketState) XXX_DiscardUnknown() { xxx_messageInfo_PacketState.DiscardUnknown(m) } var xxx_messageInfo_PacketState proto.InternalMessageInfo // PacketId is an identifier for a unique Packet // Source chains refer to packets by source port/channel // Destination chains refer to packets by destination port/channel type PacketId struct { // channel port identifier PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` // channel unique identifier ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // packet sequence Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"` } func (m *PacketId) Reset() { *m = PacketId{} } func (m *PacketId) String() string { return proto.CompactTextString(m) } func (*PacketId) ProtoMessage() {} func (*PacketId) Descriptor() ([]byte, []int) { return fileDescriptor_c3a07336710636a0, []int{5} } func (m *PacketId) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *PacketId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_PacketId.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *PacketId) XXX_Merge(src proto.Message) { xxx_messageInfo_PacketId.Merge(m, src) } func (m *PacketId) XXX_Size() int { return m.Size() } func (m *PacketId) XXX_DiscardUnknown() { xxx_messageInfo_PacketId.DiscardUnknown(m) } var xxx_messageInfo_PacketId proto.InternalMessageInfo // Acknowledgement is the recommended acknowledgement format to be used by // app-specific protocols. // NOTE: The field numbers 21 and 22 were explicitly chosen to avoid accidental // conflicts with other protobuf message formats used for acknowledgements. // The first byte of any message with this format will be the non-ASCII values // `0xaa` (result) or `0xb2` (error). Implemented as defined by ICS: // https://github.com/cosmos/ibc/tree/master/spec/core/ics-004-channel-and-packet-semantics#acknowledgement-envelope type Acknowledgement struct { // response contains either a result or an error and must be non-empty // // Types that are valid to be assigned to Response: // *Acknowledgement_Result // *Acknowledgement_Error Response isAcknowledgement_Response `protobuf_oneof:"response"` } func (m *Acknowledgement) Reset() { *m = Acknowledgement{} } func (m *Acknowledgement) String() string { return proto.CompactTextString(m) } func (*Acknowledgement) ProtoMessage() {} func (*Acknowledgement) Descriptor() ([]byte, []int) { return fileDescriptor_c3a07336710636a0, []int{6} } func (m *Acknowledgement) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Acknowledgement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Acknowledgement.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Acknowledgement) XXX_Merge(src proto.Message) { xxx_messageInfo_Acknowledgement.Merge(m, src) } func (m *Acknowledgement) XXX_Size() int { return m.Size() } func (m *Acknowledgement) XXX_DiscardUnknown() { xxx_messageInfo_Acknowledgement.DiscardUnknown(m) } var xxx_messageInfo_Acknowledgement proto.InternalMessageInfo type isAcknowledgement_Response interface { isAcknowledgement_Response() MarshalTo([]byte) (int, error) Size() int } type Acknowledgement_Result struct { Result []byte `protobuf:"bytes,21,opt,name=result,proto3,oneof" json:"result,omitempty"` } type Acknowledgement_Error struct { Error string `protobuf:"bytes,22,opt,name=error,proto3,oneof" json:"error,omitempty"` } func (*Acknowledgement_Result) isAcknowledgement_Response() {} func (*Acknowledgement_Error) isAcknowledgement_Response() {} func (m *Acknowledgement) GetResponse() isAcknowledgement_Response { if m != nil { return m.Response } return nil } func (m *Acknowledgement) GetResult() []byte { if x, ok := m.GetResponse().(*Acknowledgement_Result); ok { return x.Result } return nil } func (m *Acknowledgement) GetError() string { if x, ok := m.GetResponse().(*Acknowledgement_Error); ok { return x.Error } return "" } // XXX_OneofWrappers is for the internal use of the proto package. func (*Acknowledgement) XXX_OneofWrappers() []interface{} { return []interface{}{ (*Acknowledgement_Result)(nil), (*Acknowledgement_Error)(nil), } } // Timeout defines an execution deadline structure for 04-channel handlers. // This includes packet lifecycle handlers as well as the upgrade handshake handlers. // A valid Timeout contains either one or both of a timestamp and block height (sequence). type Timeout struct { // block height after which the packet or upgrade times out Height types.Height `protobuf:"bytes,1,opt,name=height,proto3" json:"height"` // block timestamp (in nanoseconds) after which the packet or upgrade times out Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` } func (m *Timeout) Reset() { *m = Timeout{} } func (m *Timeout) String() string { return proto.CompactTextString(m) } func (*Timeout) ProtoMessage() {} func (*Timeout) Descriptor() ([]byte, []int) { return fileDescriptor_c3a07336710636a0, []int{7} } func (m *Timeout) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Timeout) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Timeout.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Timeout) XXX_Merge(src proto.Message) { xxx_messageInfo_Timeout.Merge(m, src) } func (m *Timeout) XXX_Size() int { return m.Size() } func (m *Timeout) XXX_DiscardUnknown() { xxx_messageInfo_Timeout.DiscardUnknown(m) } var xxx_messageInfo_Timeout proto.InternalMessageInfo func (m *Timeout) GetHeight() types.Height { if m != nil { return m.Height } return types.Height{} } func (m *Timeout) GetTimestamp() uint64 { if m != nil { return m.Timestamp } return 0 } // Params defines the set of IBC channel parameters. type Params struct { // the relative timeout after which channel upgrades will time out. UpgradeTimeout Timeout `protobuf:"bytes,1,opt,name=upgrade_timeout,json=upgradeTimeout,proto3" json:"upgrade_timeout"` } func (m *Params) Reset() { *m = Params{} } func (m *Params) String() string { return proto.CompactTextString(m) } func (*Params) ProtoMessage() {} func (*Params) Descriptor() ([]byte, []int) { return fileDescriptor_c3a07336710636a0, []int{8} } func (m *Params) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Params.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Params) XXX_Merge(src proto.Message) { xxx_messageInfo_Params.Merge(m, src) } func (m *Params) XXX_Size() int { return m.Size() } func (m *Params) XXX_DiscardUnknown() { xxx_messageInfo_Params.DiscardUnknown(m) } var xxx_messageInfo_Params proto.InternalMessageInfo func (m *Params) GetUpgradeTimeout() Timeout { if m != nil { return m.UpgradeTimeout } return Timeout{} } func init() { proto.RegisterEnum("ibc.core.channel.v0.State", State_name, State_value) proto.RegisterEnum("ibc.core.channel.v0.Order", Order_name, Order_value) proto.RegisterType((*Channel)(nil), "ibc.core.channel.v0.Channel") proto.RegisterType((*IdentifiedChannel)(nil), "ibc.core.channel.v0.IdentifiedChannel") proto.RegisterType((*Counterparty)(nil), "ibc.core.channel.v0.Counterparty") proto.RegisterType((*Packet)(nil), "ibc.core.channel.v0.Packet") proto.RegisterType((*PacketState)(nil), "ibc.core.channel.v0.PacketState") proto.RegisterType((*PacketId)(nil), "ibc.core.channel.v0.PacketId") proto.RegisterType((*Acknowledgement)(nil), "ibc.core.channel.v0.Acknowledgement") proto.RegisterType((*Timeout)(nil), "ibc.core.channel.v0.Timeout") proto.RegisterType((*Params)(nil), "ibc.core.channel.v0.Params") } func init() { proto.RegisterFile("ibc.core.channel.v0/channel.proto", fileDescriptor_c3a07336710636a0) } var fileDescriptor_c3a07336710636a0 = []byte{ // 936 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xec, 0x56, 0x4f, 0x6f, 0xe2, 0x46, 0x14, 0xc7, 0xc4, 0xfc, 0x7b, 0x49, 0xc0, 0x3b, 0x69, 0x53, 0xcb, 0x4a, 0xc1, 0x8b, 0x5a, 0x95, 0x4d, 0xb5, 0x90, 0x6c, 0xab, 0xaa, 0xda, 0x5b, 0x02, 0xde, 0xc5, 0x5a, 0x0a, 0xc8, 0xc0, 0xa1, 0x7b, 0x41, 0xc6, 0x9e, 0x82, 0xb5, 0xe0, 0xa1, 0xf6, 0xc0, 0x6a, 0xd5, 0x73, 0xa5, 0x15, 0xa7, 0x7e, 0x01, 0xa4, 0x4a, 0xfd, 0x0a, 0xfd, 0x10, 0x7b, 0xdc, 0xe3, 0x9e, 0xaa, 0x2a, 0xf9, 0x0e, 0x3d, 0x57, 0x9e, 0x19, 0x07, 0x88, 0xa2, 0xa8, 0xaa, 0xd4, 0x5b, 0x4f, 0xcc, 0xfb, 0xbd, 0xdf, 0x7b, 0xbf, 0xf7, 0x67, 0x18, 0x19, 0x1e, 0x7a, 0x23, 0xa7, 0xe6, 0x90, 0x00, 0xd7, 0x9c, 0x89, 0xed, 0xfb, 0x78, 0x5a, 0x5b, 0x9e, 0xc7, 0xc7, 0xea, 0x3c, 0x20, 0x94, 0xa0, 0x23, 0x6f, 0xe4, 0x54, 0x23, 0x4a, 0x35, 0xc6, 0x97, 0xe7, 0xda, 0x47, 0x63, 0x32, 0x26, 0xcc, 0x5f, 0x8b, 0x4e, 0x9c, 0xaa, 0x95, 0x36, 0xd9, 0xa6, 0x1e, 0xf6, 0x29, 0x4b, 0xc6, 0x4e, 0x9c, 0x50, 0xfe, 0x3d, 0x09, 0x99, 0x3a, 0xcf, 0x82, 0xce, 0x20, 0x15, 0x52, 0x9b, 0x62, 0x55, 0xd2, 0xa5, 0x4a, 0xfe, 0x89, 0x56, 0xbd, 0x43, 0xa7, 0xda, 0x8b, 0x18, 0x16, 0x27, 0xa2, 0x6f, 0x20, 0x4b, 0x02, 0x17, 0x07, 0x9e, 0x3f, 0x56, 0x93, 0xf7, 0x04, 0x75, 0x22, 0x92, 0x75, 0xc3, 0x45, 0x2f, 0xe0, 0xc0, 0x21, 0x0b, 0x9f, 0xe2, 0x60, 0x6e, 0x07, 0xf4, 0x8d, 0xba, 0xa7, 0x4b, 0x95, 0xfd, 0x27, 0x0f, 0xef, 0x8c, 0xad, 0x6f, 0x11, 0x2f, 0xe5, 0x77, 0x7f, 0x94, 0x12, 0xd6, 0x4e, 0x30, 0xfa, 0x02, 0x0a, 0x0e, 0xf1, 0x7d, 0xec, 0x50, 0x8f, 0xf8, 0xc3, 0x09, 0x99, 0x87, 0xaa, 0xac, 0xef, 0x55, 0x72, 0x56, 0x7e, 0x03, 0x37, 0xc9, 0x3c, 0x44, 0x2a, 0x64, 0x96, 0x38, 0x08, 0x3d, 0xe2, 0xab, 0x29, 0x5d, 0xaa, 0xe4, 0xac, 0xd8, 0x44, 0x8f, 0x40, 0x59, 0xcc, 0xc7, 0x81, 0xed, 0xe2, 0x61, 0x88, 0x7f, 0x5c, 0x60, 0xdf, 0xc1, 0x6a, 0x5a, 0x97, 0x2a, 0xb2, 0x55, 0x10, 0x78, 0x4f, 0xc0, 0x4f, 0xe5, 0xb7, 0xbf, 0x96, 0x12, 0xe5, 0xbf, 0x92, 0xf0, 0xc0, 0x74, 0xb1, 0x4f, 0xbd, 0x1f, 0x3c, 0xec, 0xfe, 0x3f, 0xc0, 0x4f, 0x20, 0x33, 0x27, 0x01, 0x1d, 0x7a, 0x2e, 0x9b, 0x5b, 0xce, 0x4a, 0x47, 0xa6, 0xe9, 0xa2, 0x4f, 0x01, 0x44, 0x29, 0x91, 0x2f, 0xc3, 0x7c, 0x39, 0x81, 0x98, 0xee, 0x9d, 0x83, 0xcf, 0xde, 0x37, 0xf8, 0x16, 0x1c, 0x6c, 0xf7, 0xb3, 0x2d, 0x2c, 0xdd, 0x23, 0x9c, 0xbc, 0x25, 0x2c, 0xb2, 0x7d, 0x48, 0x42, 0xba, 0x6b, 0x3b, 0xaf, 0x30, 0x45, 0x1a, 0x64, 0x6f, 0x2a, 0x90, 0x58, 0x05, 0x37, 0x36, 0x2a, 0xc1, 0x7e, 0x48, 0x16, 0x81, 0x83, 0x87, 0x51, 0x72, 0x91, 0x0c, 0x38, 0xd4, 0x25, 0x01, 0x45, 0x9f, 0x43, 0x5e, 0x10, 0x84, 0x02, 0x5b, 0x48, 0xce, 0x3a, 0xe4, 0x68, 0x7c, 0x3f, 0x1e, 0x81, 0xe2, 0xe2, 0x90, 0x7a, 0xbe, 0xcd, 0x26, 0xcd, 0x92, 0xc9, 0x8c, 0x58, 0xd8, 0xc2, 0x59, 0xc6, 0x1a, 0x1c, 0x6d, 0x53, 0xe3, 0xb4, 0x7c, 0xec, 0x68, 0xcb, 0x15, 0xe7, 0x46, 0x20, 0xbb, 0x36, 0xb5, 0xd9, 0xf8, 0x0f, 0x2c, 0x76, 0x46, 0xcf, 0x21, 0x4f, 0xbd, 0x19, 0x26, 0x0b, 0x3a, 0x9c, 0x60, 0x6f, 0x3c, 0xa1, 0x6c, 0x01, 0xfb, 0x3b, 0x77, 0x8c, 0x3f, 0x06, 0xcb, 0xf3, 0x6a, 0x93, 0x31, 0xc4, 0x05, 0x39, 0x14, 0x71, 0x1c, 0x44, 0x5f, 0xc2, 0x83, 0x38, 0x51, 0xf4, 0x1b, 0x52, 0x7b, 0x36, 0x17, 0x7b, 0x52, 0x84, 0xa3, 0x1f, 0xe3, 0x62, 0xb4, 0x3f, 0xc1, 0x3e, 0x9f, 0x2c, 0xbb, 0xef, 0xff, 0x76, 0x4f, 0x3b, 0x6b, 0xd9, 0xbb, 0xb5, 0x96, 0xb8, 0x65, 0x79, 0xd3, 0xb2, 0x10, 0x77, 0x21, 0xcb, 0xc5, 0x4d, 0xf7, 0xbf, 0x50, 0x16, 0x2a, 0x1d, 0x28, 0x5c, 0x38, 0xaf, 0x7c, 0xf2, 0x7a, 0x8a, 0xdd, 0x31, 0x9e, 0x61, 0x9f, 0x22, 0x15, 0xd2, 0x01, 0x0e, 0x17, 0x53, 0xaa, 0x7e, 0x1c, 0x15, 0xd5, 0x4c, 0x58, 0xc2, 0x46, 0xc7, 0x90, 0xc2, 0x41, 0x40, 0x02, 0xf5, 0x38, 0x12, 0x6a, 0x26, 0x2c, 0x6e, 0x5e, 0x02, 0x64, 0x03, 0x1c, 0xce, 0x89, 0x1f, 0xe2, 0xb2, 0x0d, 0x99, 0x3e, 0x9f, 0x26, 0xfa, 0x16, 0xd2, 0x62, 0x65, 0xd2, 0x3f, 0x5c, 0x99, 0xe0, 0xa3, 0x13, 0xc8, 0x6d, 0x76, 0x94, 0x64, 0x85, 0x6f, 0x80, 0xf2, 0x20, 0xba, 0xf0, 0x81, 0x3d, 0x0b, 0xd1, 0x0b, 0x88, 0xff, 0x62, 0x43, 0xb1, 0x42, 0x21, 0x75, 0x72, 0xe7, 0x2b, 0x22, 0x0a, 0x13, 0x62, 0x79, 0x11, 0x2a, 0xd0, 0xd3, 0x9f, 0x93, 0x90, 0xea, 0x89, 0x17, 0xad, 0xd4, 0xeb, 0x5f, 0xf4, 0x8d, 0xe1, 0xa0, 0x6d, 0xb6, 0xcd, 0xbe, 0x79, 0xd1, 0x32, 0x5f, 0x1a, 0x8d, 0xe1, 0xa0, 0xdd, 0xeb, 0x1a, 0x75, 0xf3, 0x99, 0x69, 0x34, 0x94, 0x84, 0xf6, 0x60, 0xb5, 0xd6, 0x0f, 0x77, 0x08, 0x48, 0x05, 0xe0, 0x71, 0x11, 0xa8, 0x48, 0x5a, 0x76, 0xb5, 0xd6, 0xe5, 0xe8, 0x8c, 0x8a, 0x70, 0xc8, 0x3d, 0x7d, 0xeb, 0xfb, 0x4e, 0xd7, 0x68, 0x2b, 0x49, 0x6d, 0x7f, 0xb5, 0xd6, 0x33, 0xc2, 0xdc, 0x44, 0x32, 0xe7, 0x1e, 0x8f, 0x64, 0x9e, 0x13, 0x38, 0xe0, 0x9e, 0x7a, 0xab, 0xd3, 0x33, 0x1a, 0x8a, 0xac, 0xc1, 0x6a, 0xad, 0xa7, 0xb9, 0x85, 0x74, 0xc8, 0x73, 0xef, 0xb3, 0xd6, 0xa0, 0xd7, 0x34, 0xdb, 0xcf, 0x95, 0x94, 0x76, 0xb0, 0x5a, 0xeb, 0xd9, 0xd8, 0x46, 0xa7, 0x70, 0xb4, 0xc5, 0xa8, 0x77, 0xbe, 0xeb, 0xb6, 0x8c, 0xbe, 0xa1, 0xa4, 0x79, 0xfd, 0x3b, 0xa0, 0x26, 0xbf, 0xfd, 0xad, 0x98, 0x38, 0x7d, 0x0d, 0x29, 0xf6, 0x54, 0xa3, 0xcf, 0xe0, 0xb8, 0x63, 0x35, 0x0c, 0x6b, 0xd8, 0xee, 0xb4, 0x8d, 0x5b, 0xdd, 0xb3, 0x02, 0x23, 0x1c, 0x95, 0xa1, 0xc0, 0x59, 0x83, 0x36, 0xfb, 0x35, 0x1a, 0x8a, 0xa4, 0x1d, 0xae, 0xd6, 0x7a, 0xee, 0x06, 0x88, 0xda, 0xe7, 0x9c, 0x98, 0x21, 0xda, 0x17, 0x26, 0x17, 0xbe, 0xec, 0xbf, 0xbb, 0x2a, 0x4a, 0xef, 0xaf, 0x8a, 0xd2, 0x9f, 0x57, 0x45, 0xe9, 0x97, 0xeb, 0x62, 0xe2, 0xfd, 0x75, 0x31, 0xf1, 0xe1, 0xba, 0x98, 0x78, 0xf9, 0x74, 0xec, 0xd1, 0xc9, 0x62, 0x54, 0x75, 0xc8, 0xac, 0xe6, 0x90, 0x70, 0x46, 0xc2, 0x9a, 0x37, 0x72, 0x1e, 0x8f, 0x49, 0x6d, 0x79, 0x7e, 0x56, 0x9b, 0x11, 0x77, 0x31, 0xc5, 0x21, 0xff, 0x46, 0x38, 0xfb, 0xfa, 0x71, 0xfc, 0xd1, 0x41, 0xdf, 0xcc, 0x71, 0x38, 0x4a, 0xb3, 0x8f, 0x84, 0xaf, 0xfe, 0x0e, 0x00, 0x00, 0xff, 0xff, 0xaf, 0x78, 0x54, 0x46, 0x95, 0x08, 0x00, 0x00, } func (m *Channel) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *Channel) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *Channel) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.UpgradeSequence != 0 { i = encodeVarintChannel(dAtA, i, uint64(m.UpgradeSequence)) i-- dAtA[i] = 0x30 } if len(m.Version) > 0 { i -= len(m.Version) copy(dAtA[i:], m.Version) i = encodeVarintChannel(dAtA, i, uint64(len(m.Version))) i-- dAtA[i] = 0x2a } if len(m.ConnectionHops) > 0 { for iNdEx := len(m.ConnectionHops) - 1; iNdEx >= 0; iNdEx-- { i -= len(m.ConnectionHops[iNdEx]) copy(dAtA[i:], m.ConnectionHops[iNdEx]) i = encodeVarintChannel(dAtA, i, uint64(len(m.ConnectionHops[iNdEx]))) i-- dAtA[i] = 0x22 } } { size, err := m.Counterparty.MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintChannel(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x1a if m.Ordering != 0 { i = encodeVarintChannel(dAtA, i, uint64(m.Ordering)) i-- dAtA[i] = 0x10 } if m.State != 0 { i = encodeVarintChannel(dAtA, i, uint64(m.State)) i-- dAtA[i] = 0x8 } return len(dAtA) - i, nil } func (m *IdentifiedChannel) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *IdentifiedChannel) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *IdentifiedChannel) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.UpgradeSequence != 0 { i = encodeVarintChannel(dAtA, i, uint64(m.UpgradeSequence)) i-- dAtA[i] = 0x40 } if len(m.ChannelId) > 0 { i -= len(m.ChannelId) copy(dAtA[i:], m.ChannelId) i = encodeVarintChannel(dAtA, i, uint64(len(m.ChannelId))) i-- dAtA[i] = 0x3a } if len(m.PortId) > 0 { i -= len(m.PortId) copy(dAtA[i:], m.PortId) i = encodeVarintChannel(dAtA, i, uint64(len(m.PortId))) i-- dAtA[i] = 0x32 } if len(m.Version) > 0 { i -= len(m.Version) copy(dAtA[i:], m.Version) i = encodeVarintChannel(dAtA, i, uint64(len(m.Version))) i-- dAtA[i] = 0x2a } if len(m.ConnectionHops) > 0 { for iNdEx := len(m.ConnectionHops) - 1; iNdEx >= 0; iNdEx-- { i -= len(m.ConnectionHops[iNdEx]) copy(dAtA[i:], m.ConnectionHops[iNdEx]) i = encodeVarintChannel(dAtA, i, uint64(len(m.ConnectionHops[iNdEx]))) i-- dAtA[i] = 0x22 } } { size, err := m.Counterparty.MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintChannel(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x1a if m.Ordering != 0 { i = encodeVarintChannel(dAtA, i, uint64(m.Ordering)) i-- dAtA[i] = 0x10 } if m.State != 0 { i = encodeVarintChannel(dAtA, i, uint64(m.State)) i-- dAtA[i] = 0x8 } return len(dAtA) - i, nil } func (m *Counterparty) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *Counterparty) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *Counterparty) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if len(m.ChannelId) > 0 { i -= len(m.ChannelId) copy(dAtA[i:], m.ChannelId) i = encodeVarintChannel(dAtA, i, uint64(len(m.ChannelId))) i-- dAtA[i] = 0x12 } if len(m.PortId) > 0 { i -= len(m.PortId) copy(dAtA[i:], m.PortId) i = encodeVarintChannel(dAtA, i, uint64(len(m.PortId))) i-- dAtA[i] = 0xa } return len(dAtA) - i, nil } func (m *Packet) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *Packet) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *Packet) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.TimeoutTimestamp != 0 { i = encodeVarintChannel(dAtA, i, uint64(m.TimeoutTimestamp)) i-- dAtA[i] = 0x40 } { size, err := m.TimeoutHeight.MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintChannel(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x3a if len(m.Data) > 0 { i -= len(m.Data) copy(dAtA[i:], m.Data) i = encodeVarintChannel(dAtA, i, uint64(len(m.Data))) i-- dAtA[i] = 0x32 } if len(m.DestinationChannel) > 0 { i -= len(m.DestinationChannel) copy(dAtA[i:], m.DestinationChannel) i = encodeVarintChannel(dAtA, i, uint64(len(m.DestinationChannel))) i-- dAtA[i] = 0x2a } if len(m.DestinationPort) > 0 { i -= len(m.DestinationPort) copy(dAtA[i:], m.DestinationPort) i = encodeVarintChannel(dAtA, i, uint64(len(m.DestinationPort))) i-- dAtA[i] = 0x22 } if len(m.SourceChannel) > 0 { i -= len(m.SourceChannel) copy(dAtA[i:], m.SourceChannel) i = encodeVarintChannel(dAtA, i, uint64(len(m.SourceChannel))) i-- dAtA[i] = 0x1a } if len(m.SourcePort) > 0 { i -= len(m.SourcePort) copy(dAtA[i:], m.SourcePort) i = encodeVarintChannel(dAtA, i, uint64(len(m.SourcePort))) i-- dAtA[i] = 0x12 } if m.Sequence != 0 { i = encodeVarintChannel(dAtA, i, uint64(m.Sequence)) i-- dAtA[i] = 0x8 } return len(dAtA) - i, nil } func (m *PacketState) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *PacketState) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *PacketState) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if len(m.Data) > 0 { i -= len(m.Data) copy(dAtA[i:], m.Data) i = encodeVarintChannel(dAtA, i, uint64(len(m.Data))) i-- dAtA[i] = 0x22 } if m.Sequence != 0 { i = encodeVarintChannel(dAtA, i, uint64(m.Sequence)) i-- dAtA[i] = 0x18 } if len(m.ChannelId) > 0 { i -= len(m.ChannelId) copy(dAtA[i:], m.ChannelId) i = encodeVarintChannel(dAtA, i, uint64(len(m.ChannelId))) i-- dAtA[i] = 0x12 } if len(m.PortId) > 0 { i -= len(m.PortId) copy(dAtA[i:], m.PortId) i = encodeVarintChannel(dAtA, i, uint64(len(m.PortId))) i-- dAtA[i] = 0xa } return len(dAtA) - i, nil } func (m *PacketId) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *PacketId) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *PacketId) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.Sequence != 0 { i = encodeVarintChannel(dAtA, i, uint64(m.Sequence)) i-- dAtA[i] = 0x18 } if len(m.ChannelId) > 0 { i -= len(m.ChannelId) copy(dAtA[i:], m.ChannelId) i = encodeVarintChannel(dAtA, i, uint64(len(m.ChannelId))) i-- dAtA[i] = 0x12 } if len(m.PortId) > 0 { i -= len(m.PortId) copy(dAtA[i:], m.PortId) i = encodeVarintChannel(dAtA, i, uint64(len(m.PortId))) i-- dAtA[i] = 0xa } return len(dAtA) - i, nil } func (m *Acknowledgement) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *Acknowledgement) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *Acknowledgement) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.Response != nil { { size := m.Response.Size() i -= size if _, err := m.Response.MarshalTo(dAtA[i:]); err != nil { return 0, err } } } return len(dAtA) - i, nil } func (m *Acknowledgement_Result) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *Acknowledgement_Result) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) if m.Result != nil { i -= len(m.Result) copy(dAtA[i:], m.Result) i = encodeVarintChannel(dAtA, i, uint64(len(m.Result))) i-- dAtA[i] = 0x1 i-- dAtA[i] = 0xaa } return len(dAtA) - i, nil } func (m *Acknowledgement_Error) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *Acknowledgement_Error) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) i -= len(m.Error) copy(dAtA[i:], m.Error) i = encodeVarintChannel(dAtA, i, uint64(len(m.Error))) i-- dAtA[i] = 0x1 i-- dAtA[i] = 0xb2 return len(dAtA) - i, nil } func (m *Timeout) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *Timeout) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *Timeout) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.Timestamp != 0 { i = encodeVarintChannel(dAtA, i, uint64(m.Timestamp)) i-- dAtA[i] = 0x10 } { size, err := m.Height.MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintChannel(dAtA, i, uint64(size)) } i-- dAtA[i] = 0xa return len(dAtA) - i, nil } func (m *Params) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *Params) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l { size, err := m.UpgradeTimeout.MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintChannel(dAtA, i, uint64(size)) } i-- dAtA[i] = 0xa return len(dAtA) - i, nil } func encodeVarintChannel(dAtA []byte, offset int, v uint64) int { offset -= sovChannel(v) base := offset for v >= 1<<7 { dAtA[offset] = uint8(v&0x7f | 0x80) v >>= 7 offset++ } dAtA[offset] = uint8(v) return base } func (m *Channel) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.State != 0 { n += 1 + sovChannel(uint64(m.State)) } if m.Ordering != 0 { n += 1 + sovChannel(uint64(m.Ordering)) } l = m.Counterparty.Size() n += 1 + l + sovChannel(uint64(l)) if len(m.ConnectionHops) > 0 { for _, s := range m.ConnectionHops { l = len(s) n += 1 + l + sovChannel(uint64(l)) } } l = len(m.Version) if l > 0 { n += 1 + l + sovChannel(uint64(l)) } if m.UpgradeSequence != 0 { n += 1 + sovChannel(uint64(m.UpgradeSequence)) } return n } func (m *IdentifiedChannel) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.State != 0 { n += 1 + sovChannel(uint64(m.State)) } if m.Ordering != 0 { n += 1 + sovChannel(uint64(m.Ordering)) } l = m.Counterparty.Size() n += 1 + l + sovChannel(uint64(l)) if len(m.ConnectionHops) > 0 { for _, s := range m.ConnectionHops { l = len(s) n += 1 + l + sovChannel(uint64(l)) } } l = len(m.Version) if l > 0 { n += 1 + l + sovChannel(uint64(l)) } l = len(m.PortId) if l > 0 { n += 1 + l + sovChannel(uint64(l)) } l = len(m.ChannelId) if l > 0 { n += 1 + l + sovChannel(uint64(l)) } if m.UpgradeSequence != 0 { n += 1 + sovChannel(uint64(m.UpgradeSequence)) } return n } func (m *Counterparty) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.PortId) if l > 0 { n += 1 + l + sovChannel(uint64(l)) } l = len(m.ChannelId) if l > 0 { n += 1 + l + sovChannel(uint64(l)) } return n } func (m *Packet) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Sequence != 0 { n += 1 + sovChannel(uint64(m.Sequence)) } l = len(m.SourcePort) if l > 0 { n += 1 + l + sovChannel(uint64(l)) } l = len(m.SourceChannel) if l > 0 { n += 1 + l + sovChannel(uint64(l)) } l = len(m.DestinationPort) if l > 0 { n += 1 + l + sovChannel(uint64(l)) } l = len(m.DestinationChannel) if l > 0 { n += 1 + l + sovChannel(uint64(l)) } l = len(m.Data) if l > 0 { n += 1 + l + sovChannel(uint64(l)) } l = m.TimeoutHeight.Size() n += 1 + l + sovChannel(uint64(l)) if m.TimeoutTimestamp != 0 { n += 1 + sovChannel(uint64(m.TimeoutTimestamp)) } return n } func (m *PacketState) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.PortId) if l > 0 { n += 1 + l + sovChannel(uint64(l)) } l = len(m.ChannelId) if l > 0 { n += 1 + l + sovChannel(uint64(l)) } if m.Sequence != 0 { n += 1 + sovChannel(uint64(m.Sequence)) } l = len(m.Data) if l > 0 { n += 1 + l + sovChannel(uint64(l)) } return n } func (m *PacketId) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.PortId) if l > 0 { n += 1 + l + sovChannel(uint64(l)) } l = len(m.ChannelId) if l > 0 { n += 1 + l + sovChannel(uint64(l)) } if m.Sequence != 0 { n += 1 + sovChannel(uint64(m.Sequence)) } return n } func (m *Acknowledgement) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Response != nil { n += m.Response.Size() } return n } func (m *Acknowledgement_Result) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Result != nil { l = len(m.Result) n += 2 + l + sovChannel(uint64(l)) } return n } func (m *Acknowledgement_Error) Size() (n int) { if m == nil { return 0 } var l int _ = l l = len(m.Error) n += 2 + l + sovChannel(uint64(l)) return n } func (m *Timeout) Size() (n int) { if m == nil { return 0 } var l int _ = l l = m.Height.Size() n += 1 + l + sovChannel(uint64(l)) if m.Timestamp != 0 { n += 1 + sovChannel(uint64(m.Timestamp)) } return n } func (m *Params) Size() (n int) { if m == nil { return 0 } var l int _ = l l = m.UpgradeTimeout.Size() n += 1 + l + sovChannel(uint64(l)) return n } func sovChannel(x uint64) (n int) { return (math_bits.Len64(x|1) + 6) / 7 } func sozChannel(x uint64) (n int) { return sovChannel(uint64((x << 1) ^ uint64((int64(x) >> 63)))) } func (m *Channel) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= uint64(b&0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: Channel: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Channel: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field State", wireType) } m.State = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.State |= State(b&0x7F) << shift if b < 0x80 { break } } case 2: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Ordering", wireType) } m.Ordering = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Ordering |= Order(b&0x7F) << shift if b < 0x80 { break } } case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Counterparty", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } if err := m.Counterparty.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field ConnectionHops", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.ConnectionHops = append(m.ConnectionHops, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Version", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.Version = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 6: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field UpgradeSequence", wireType) } m.UpgradeSequence = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.UpgradeSequence |= uint64(b&0x7F) << shift if b < 0x80 { break } } default: iNdEx = preIndex skippy, err := skipChannel(dAtA[iNdEx:]) if err != nil { return err } if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthChannel } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *IdentifiedChannel) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= uint64(b&0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: IdentifiedChannel: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: IdentifiedChannel: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field State", wireType) } m.State = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.State |= State(b&0x7F) << shift if b < 0x80 { break } } case 2: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Ordering", wireType) } m.Ordering = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Ordering |= Order(b&0x7F) << shift if b < 0x80 { break } } case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Counterparty", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } if err := m.Counterparty.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field ConnectionHops", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.ConnectionHops = append(m.ConnectionHops, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Version", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.Version = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 6: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field PortId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.PortId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 7: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field ChannelId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.ChannelId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 8: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field UpgradeSequence", wireType) } m.UpgradeSequence = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.UpgradeSequence |= uint64(b&0x7F) << shift if b < 0x80 { break } } default: iNdEx = preIndex skippy, err := skipChannel(dAtA[iNdEx:]) if err != nil { return err } if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthChannel } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *Counterparty) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= uint64(b&0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: Counterparty: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Counterparty: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field PortId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.PortId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field ChannelId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.ChannelId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipChannel(dAtA[iNdEx:]) if err != nil { return err } if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthChannel } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *Packet) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= uint64(b&0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: Packet: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Packet: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Sequence", wireType) } m.Sequence = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Sequence |= uint64(b&0x7F) << shift if b < 0x80 { break } } case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field SourcePort", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.SourcePort = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field SourceChannel", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.SourceChannel = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field DestinationPort", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.DestinationPort = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field DestinationChannel", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.DestinationChannel = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 6: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Data", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.Data = append(m.Data[:0], dAtA[iNdEx:postIndex]...) if m.Data == nil { m.Data = []byte{} } iNdEx = postIndex case 7: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field TimeoutHeight", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } if err := m.TimeoutHeight.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 8: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field TimeoutTimestamp", wireType) } m.TimeoutTimestamp = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.TimeoutTimestamp |= uint64(b&0x7F) << shift if b < 0x80 { break } } default: iNdEx = preIndex skippy, err := skipChannel(dAtA[iNdEx:]) if err != nil { return err } if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthChannel } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *PacketState) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= uint64(b&0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: PacketState: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: PacketState: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field PortId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.PortId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field ChannelId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.ChannelId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Sequence", wireType) } m.Sequence = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Sequence |= uint64(b&0x7F) << shift if b < 0x80 { break } } case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Data", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.Data = append(m.Data[:0], dAtA[iNdEx:postIndex]...) if m.Data == nil { m.Data = []byte{} } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipChannel(dAtA[iNdEx:]) if err != nil { return err } if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthChannel } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *PacketId) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= uint64(b&0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: PacketId: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: PacketId: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field PortId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.PortId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field ChannelId", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.ChannelId = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Sequence", wireType) } m.Sequence = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Sequence |= uint64(b&0x7F) << shift if b < 0x80 { break } } default: iNdEx = preIndex skippy, err := skipChannel(dAtA[iNdEx:]) if err != nil { return err } if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthChannel } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *Acknowledgement) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= uint64(b&0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: Acknowledgement: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Acknowledgement: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 21: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Result", wireType) } var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ byteLen |= int(b&0x7F) << shift if b < 0x80 { break } } if byteLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + byteLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } v := make([]byte, postIndex-iNdEx) copy(v, dAtA[iNdEx:postIndex]) m.Response = &Acknowledgement_Result{v} iNdEx = postIndex case 22: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Error", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } m.Response = &Acknowledgement_Error{string(dAtA[iNdEx:postIndex])} iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipChannel(dAtA[iNdEx:]) if err != nil { return err } if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthChannel } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *Timeout) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= uint64(b&0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: Timeout: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Timeout: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Height", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } if err := m.Height.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 2: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Timestamp", wireType) } m.Timestamp = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Timestamp |= uint64(b&0x7F) << shift if b < 0x80 { break } } default: iNdEx = preIndex skippy, err := skipChannel(dAtA[iNdEx:]) if err != nil { return err } if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthChannel } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *Params) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= uint64(b&0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: Params: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Params: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field UpgradeTimeout", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowChannel } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthChannel } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthChannel } if postIndex > l { return io.ErrUnexpectedEOF } if err := m.UpgradeTimeout.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipChannel(dAtA[iNdEx:]) if err != nil { return err } if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthChannel } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func skipChannel(dAtA []byte) (n int, err error) { l := len(dAtA) iNdEx := 0 depth := 0 for iNdEx < l { var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowChannel } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } wireType := int(wire & 0x7) switch wireType { case 0: for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowChannel } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } iNdEx++ if dAtA[iNdEx-1] < 0x80 { break } } case 1: iNdEx += 8 case 2: var length int for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowChannel } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ length |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if length < 0 { return 0, ErrInvalidLengthChannel } iNdEx += length case 3: depth++ case 4: if depth == 0 { return 0, ErrUnexpectedEndOfGroupChannel } depth-- case 5: iNdEx += 4 default: return 0, fmt.Errorf("proto: illegal wireType %d", wireType) } if iNdEx < 0 { return 0, ErrInvalidLengthChannel } if depth == 0 { return iNdEx, nil } } return 0, io.ErrUnexpectedEOF } var ( ErrInvalidLengthChannel = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowChannel = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupChannel = fmt.Errorf("proto: unexpected end of group") )