From caf5760c45e0ac5b080f8da017c5414778057f1e Mon Sep 17 00:00:00 2001 From: Manabu Sugimoto Date: Fri, 18 Jun 2021 18:34:36 +0900 Subject: [PATCH] runtime: Update golang proto code We should update golang proto files. These changes are updated using libprotoc v3.6.1. Fixes: #2064 Signed-off-by: Manabu Sugimoto --- src/runtime/protocols/cache/cache.pb.go | 704 +++++++++++------- .../pkg/agent/protocols/grpc/agent.pb.go | 293 ++------ .../pkg/agent/protocols/grpc/health.pb.go | 15 +- .../pkg/agent/protocols/grpc/oci.pb.go | 169 +---- .../pkg/agent/protocols/types.pb.go | 20 +- 5 files changed, 552 insertions(+), 649 deletions(-) diff --git a/src/runtime/protocols/cache/cache.pb.go b/src/runtime/protocols/cache/cache.pb.go index c4120d97b6..7df565a8e9 100644 --- a/src/runtime/protocols/cache/cache.pb.go +++ b/src/runtime/protocols/cache/cache.pb.go @@ -1,32 +1,21 @@ // Code generated by protoc-gen-gogo. DO NOT EDIT. // source: cache.proto -/* - Package cache is a generated protocol buffer package. - - It is generated from these files: - cache.proto - - It has these top-level messages: - GrpcVMConfig - GrpcVM - GrpcStatus - GrpcVMStatus -*/ package cache -import proto "github.com/gogo/protobuf/proto" -import fmt "fmt" -import math "math" -import google_protobuf "github.com/gogo/protobuf/types" - import ( - context "golang.org/x/net/context" + context "context" + fmt "fmt" + proto "github.com/gogo/protobuf/proto" + types "github.com/gogo/protobuf/types" grpc "google.golang.org/grpc" + codes "google.golang.org/grpc/codes" + status "google.golang.org/grpc/status" + io "io" + math "math" + math_bits "math/bits" ) -import io "io" - // Reference imports to suppress errors if they are not otherwise used. var _ = proto.Marshal var _ = fmt.Errorf @@ -36,17 +25,48 @@ var _ = math.Inf // 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.GoGoProtoPackageIsVersion2 // please upgrade the proto package +const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package type GrpcVMConfig struct { - Data []byte `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"` - AgentConfig []byte `protobuf:"bytes,2,opt,name=AgentConfig,proto3" json:"AgentConfig,omitempty"` + Data []byte `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"` + AgentConfig []byte `protobuf:"bytes,2,opt,name=AgentConfig,proto3" json:"AgentConfig,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` } -func (m *GrpcVMConfig) Reset() { *m = GrpcVMConfig{} } -func (m *GrpcVMConfig) String() string { return proto.CompactTextString(m) } -func (*GrpcVMConfig) ProtoMessage() {} -func (*GrpcVMConfig) Descriptor() ([]byte, []int) { return fileDescriptorCache, []int{0} } +func (m *GrpcVMConfig) Reset() { *m = GrpcVMConfig{} } +func (m *GrpcVMConfig) String() string { return proto.CompactTextString(m) } +func (*GrpcVMConfig) ProtoMessage() {} +func (*GrpcVMConfig) Descriptor() ([]byte, []int) { + return fileDescriptor_5fca3b110c9bbf3a, []int{0} +} +func (m *GrpcVMConfig) XXX_Unmarshal(b []byte) error { + return m.Unmarshal(b) +} +func (m *GrpcVMConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + if deterministic { + return xxx_messageInfo_GrpcVMConfig.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 *GrpcVMConfig) XXX_Merge(src proto.Message) { + xxx_messageInfo_GrpcVMConfig.Merge(m, src) +} +func (m *GrpcVMConfig) XXX_Size() int { + return m.Size() +} +func (m *GrpcVMConfig) XXX_DiscardUnknown() { + xxx_messageInfo_GrpcVMConfig.DiscardUnknown(m) +} + +var xxx_messageInfo_GrpcVMConfig proto.InternalMessageInfo func (m *GrpcVMConfig) GetData() []byte { if m != nil { @@ -63,19 +83,50 @@ func (m *GrpcVMConfig) GetAgentConfig() []byte { } type GrpcVM struct { - Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` - Hypervisor []byte `protobuf:"bytes,2,opt,name=hypervisor,proto3" json:"hypervisor,omitempty"` - ProxyPid int64 `protobuf:"varint,3,opt,name=proxyPid,proto3" json:"proxyPid,omitempty"` - ProxyURL string `protobuf:"bytes,4,opt,name=proxyURL,proto3" json:"proxyURL,omitempty"` - Cpu uint32 `protobuf:"varint,5,opt,name=cpu,proto3" json:"cpu,omitempty"` - Memory uint32 `protobuf:"varint,6,opt,name=memory,proto3" json:"memory,omitempty"` - CpuDelta uint32 `protobuf:"varint,7,opt,name=cpuDelta,proto3" json:"cpuDelta,omitempty"` + Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` + Hypervisor []byte `protobuf:"bytes,2,opt,name=hypervisor,proto3" json:"hypervisor,omitempty"` + ProxyPid int64 `protobuf:"varint,3,opt,name=proxyPid,proto3" json:"proxyPid,omitempty"` + ProxyURL string `protobuf:"bytes,4,opt,name=proxyURL,proto3" json:"proxyURL,omitempty"` + Cpu uint32 `protobuf:"varint,5,opt,name=cpu,proto3" json:"cpu,omitempty"` + Memory uint32 `protobuf:"varint,6,opt,name=memory,proto3" json:"memory,omitempty"` + CpuDelta uint32 `protobuf:"varint,7,opt,name=cpuDelta,proto3" json:"cpuDelta,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` } -func (m *GrpcVM) Reset() { *m = GrpcVM{} } -func (m *GrpcVM) String() string { return proto.CompactTextString(m) } -func (*GrpcVM) ProtoMessage() {} -func (*GrpcVM) Descriptor() ([]byte, []int) { return fileDescriptorCache, []int{1} } +func (m *GrpcVM) Reset() { *m = GrpcVM{} } +func (m *GrpcVM) String() string { return proto.CompactTextString(m) } +func (*GrpcVM) ProtoMessage() {} +func (*GrpcVM) Descriptor() ([]byte, []int) { + return fileDescriptor_5fca3b110c9bbf3a, []int{1} +} +func (m *GrpcVM) XXX_Unmarshal(b []byte) error { + return m.Unmarshal(b) +} +func (m *GrpcVM) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + if deterministic { + return xxx_messageInfo_GrpcVM.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 *GrpcVM) XXX_Merge(src proto.Message) { + xxx_messageInfo_GrpcVM.Merge(m, src) +} +func (m *GrpcVM) XXX_Size() int { + return m.Size() +} +func (m *GrpcVM) XXX_DiscardUnknown() { + xxx_messageInfo_GrpcVM.DiscardUnknown(m) +} + +var xxx_messageInfo_GrpcVM proto.InternalMessageInfo func (m *GrpcVM) GetId() string { if m != nil { @@ -127,14 +178,45 @@ func (m *GrpcVM) GetCpuDelta() uint32 { } type GrpcStatus struct { - Pid int64 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"` - Vmstatus []*GrpcVMStatus `protobuf:"bytes,2,rep,name=vmstatus" json:"vmstatus,omitempty"` + Pid int64 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"` + Vmstatus []*GrpcVMStatus `protobuf:"bytes,2,rep,name=vmstatus,proto3" json:"vmstatus,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` } -func (m *GrpcStatus) Reset() { *m = GrpcStatus{} } -func (m *GrpcStatus) String() string { return proto.CompactTextString(m) } -func (*GrpcStatus) ProtoMessage() {} -func (*GrpcStatus) Descriptor() ([]byte, []int) { return fileDescriptorCache, []int{2} } +func (m *GrpcStatus) Reset() { *m = GrpcStatus{} } +func (m *GrpcStatus) String() string { return proto.CompactTextString(m) } +func (*GrpcStatus) ProtoMessage() {} +func (*GrpcStatus) Descriptor() ([]byte, []int) { + return fileDescriptor_5fca3b110c9bbf3a, []int{2} +} +func (m *GrpcStatus) XXX_Unmarshal(b []byte) error { + return m.Unmarshal(b) +} +func (m *GrpcStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + if deterministic { + return xxx_messageInfo_GrpcStatus.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 *GrpcStatus) XXX_Merge(src proto.Message) { + xxx_messageInfo_GrpcStatus.Merge(m, src) +} +func (m *GrpcStatus) XXX_Size() int { + return m.Size() +} +func (m *GrpcStatus) XXX_DiscardUnknown() { + xxx_messageInfo_GrpcStatus.DiscardUnknown(m) +} + +var xxx_messageInfo_GrpcStatus proto.InternalMessageInfo func (m *GrpcStatus) GetPid() int64 { if m != nil { @@ -151,15 +233,46 @@ func (m *GrpcStatus) GetVmstatus() []*GrpcVMStatus { } type GrpcVMStatus struct { - Pid int64 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"` - Cpu uint32 `protobuf:"varint,2,opt,name=cpu,proto3" json:"cpu,omitempty"` - Memory uint32 `protobuf:"varint,3,opt,name=memory,proto3" json:"memory,omitempty"` + Pid int64 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"` + Cpu uint32 `protobuf:"varint,2,opt,name=cpu,proto3" json:"cpu,omitempty"` + Memory uint32 `protobuf:"varint,3,opt,name=memory,proto3" json:"memory,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` } -func (m *GrpcVMStatus) Reset() { *m = GrpcVMStatus{} } -func (m *GrpcVMStatus) String() string { return proto.CompactTextString(m) } -func (*GrpcVMStatus) ProtoMessage() {} -func (*GrpcVMStatus) Descriptor() ([]byte, []int) { return fileDescriptorCache, []int{3} } +func (m *GrpcVMStatus) Reset() { *m = GrpcVMStatus{} } +func (m *GrpcVMStatus) String() string { return proto.CompactTextString(m) } +func (*GrpcVMStatus) ProtoMessage() {} +func (*GrpcVMStatus) Descriptor() ([]byte, []int) { + return fileDescriptor_5fca3b110c9bbf3a, []int{3} +} +func (m *GrpcVMStatus) XXX_Unmarshal(b []byte) error { + return m.Unmarshal(b) +} +func (m *GrpcVMStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + if deterministic { + return xxx_messageInfo_GrpcVMStatus.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 *GrpcVMStatus) XXX_Merge(src proto.Message) { + xxx_messageInfo_GrpcVMStatus.Merge(m, src) +} +func (m *GrpcVMStatus) XXX_Size() int { + return m.Size() +} +func (m *GrpcVMStatus) XXX_DiscardUnknown() { + xxx_messageInfo_GrpcVMStatus.DiscardUnknown(m) +} + +var xxx_messageInfo_GrpcVMStatus proto.InternalMessageInfo func (m *GrpcVMStatus) GetPid() int64 { if m != nil { @@ -189,6 +302,36 @@ func init() { proto.RegisterType((*GrpcVMStatus)(nil), "cache.GrpcVMStatus") } +func init() { proto.RegisterFile("cache.proto", fileDescriptor_5fca3b110c9bbf3a) } + +var fileDescriptor_5fca3b110c9bbf3a = []byte{ + // 374 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x51, 0xcd, 0x0a, 0xda, 0x40, + 0x10, 0x66, 0x13, 0x4d, 0x75, 0x8c, 0xa5, 0xdd, 0x82, 0x2c, 0x16, 0x42, 0xc8, 0x29, 0xa7, 0x08, + 0x4a, 0x7b, 0xaf, 0x5a, 0x84, 0x52, 0x69, 0x1b, 0xa9, 0xf7, 0x18, 0xd7, 0x18, 0x30, 0xee, 0x92, + 0x6c, 0xa4, 0x79, 0xb1, 0x3e, 0x43, 0x8f, 0x7d, 0x84, 0xe2, 0xa1, 0xcf, 0x51, 0x76, 0xb3, 0x86, + 0x08, 0xcd, 0x6d, 0x66, 0xbe, 0x9f, 0xfd, 0x76, 0x06, 0x46, 0x71, 0x14, 0x9f, 0x69, 0xc0, 0x73, + 0x26, 0x18, 0xee, 0xab, 0x66, 0xfa, 0x36, 0x61, 0x2c, 0xb9, 0xd0, 0x99, 0x1a, 0x1e, 0xca, 0xd3, + 0x8c, 0x66, 0x5c, 0x54, 0x35, 0xc7, 0x5b, 0x83, 0xbd, 0xc9, 0x79, 0xbc, 0xdf, 0xae, 0xd8, 0xf5, + 0x94, 0x26, 0x18, 0x43, 0x6f, 0x1d, 0x89, 0x88, 0x20, 0x17, 0xf9, 0x76, 0xa8, 0x6a, 0xec, 0xc2, + 0xe8, 0x43, 0x42, 0xaf, 0xa2, 0xa6, 0x10, 0x43, 0x41, 0xed, 0x91, 0xf7, 0x13, 0x81, 0x55, 0xdb, + 0xe0, 0x97, 0x60, 0xa4, 0x47, 0x25, 0x1f, 0x86, 0x46, 0x7a, 0xc4, 0x0e, 0xc0, 0xb9, 0xe2, 0x34, + 0xbf, 0xa5, 0x05, 0xcb, 0xb5, 0xb6, 0x35, 0xc1, 0x53, 0x18, 0xf0, 0x9c, 0xfd, 0xa8, 0xbe, 0xa6, + 0x47, 0x62, 0xba, 0xc8, 0x37, 0xc3, 0xa6, 0x6f, 0xb0, 0xef, 0xe1, 0x67, 0xd2, 0x53, 0x8e, 0x4d, + 0x8f, 0x5f, 0x81, 0x19, 0xf3, 0x92, 0xf4, 0x5d, 0xe4, 0x8f, 0x43, 0x59, 0xe2, 0x09, 0x58, 0x19, + 0xcd, 0x58, 0x5e, 0x11, 0x4b, 0x0d, 0x75, 0x27, 0x5d, 0x62, 0x5e, 0xae, 0xe9, 0x45, 0x44, 0xe4, + 0x85, 0x42, 0x9a, 0xde, 0xfb, 0x02, 0x20, 0x73, 0xef, 0x44, 0x24, 0xca, 0x42, 0x7a, 0x72, 0x1d, + 0xde, 0x0c, 0x65, 0x89, 0x67, 0x30, 0xb8, 0x65, 0x85, 0x42, 0x89, 0xe1, 0x9a, 0xfe, 0x68, 0xfe, + 0x26, 0xa8, 0x57, 0x5c, 0x7f, 0xb7, 0x16, 0x86, 0x0d, 0xc9, 0xfb, 0xf4, 0xd8, 0x67, 0xa7, 0xa5, + 0x0e, 0x6e, 0xfc, 0x2f, 0xb8, 0xd9, 0x0e, 0x3e, 0xff, 0x8b, 0xc0, 0x5e, 0xc9, 0xc7, 0x76, 0x72, + 0x59, 0x31, 0xc5, 0xef, 0xc0, 0xd2, 0x67, 0x9a, 0x04, 0xf5, 0x51, 0x83, 0xc7, 0x51, 0x83, 0x8f, + 0xf2, 0xa8, 0xd3, 0xe7, 0x74, 0x9a, 0x3c, 0x87, 0xe1, 0x86, 0x8a, 0x65, 0x54, 0xd0, 0xfd, 0xb6, + 0x53, 0x39, 0x7e, 0x52, 0xe2, 0x05, 0x58, 0xfa, 0x07, 0x5d, 0x82, 0xd7, 0x2d, 0x81, 0xa6, 0xbe, + 0x87, 0xde, 0xb7, 0x32, 0x15, 0x9d, 0x92, 0x8e, 0xf9, 0xd2, 0xfe, 0x75, 0x77, 0xd0, 0xef, 0xbb, + 0x83, 0xfe, 0xdc, 0x1d, 0x74, 0xb0, 0x14, 0xba, 0xf8, 0x17, 0x00, 0x00, 0xff, 0xff, 0x40, 0x5e, + 0x19, 0x6e, 0xcc, 0x02, 0x00, 0x00, +} + // Reference imports to suppress errors if they are not otherwise used. var _ context.Context var _ grpc.ClientConn @@ -197,13 +340,14 @@ var _ grpc.ClientConn // is compatible with the grpc package it is being compiled against. const _ = grpc.SupportPackageIsVersion4 -// Client API for CacheService service - +// CacheServiceClient is the client API for CacheService service. +// +// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. type CacheServiceClient interface { - Config(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*GrpcVMConfig, error) - GetBaseVM(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*GrpcVM, error) - Status(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*GrpcStatus, error) - Quit(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*google_protobuf.Empty, error) + Config(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*GrpcVMConfig, error) + GetBaseVM(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*GrpcVM, error) + Status(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*GrpcStatus, error) + Quit(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.Empty, error) } type cacheServiceClient struct { @@ -214,49 +358,65 @@ func NewCacheServiceClient(cc *grpc.ClientConn) CacheServiceClient { return &cacheServiceClient{cc} } -func (c *cacheServiceClient) Config(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*GrpcVMConfig, error) { +func (c *cacheServiceClient) Config(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*GrpcVMConfig, error) { out := new(GrpcVMConfig) - err := grpc.Invoke(ctx, "/cache.CacheService/Config", in, out, c.cc, opts...) + err := c.cc.Invoke(ctx, "/cache.CacheService/Config", in, out, opts...) if err != nil { return nil, err } return out, nil } -func (c *cacheServiceClient) GetBaseVM(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*GrpcVM, error) { +func (c *cacheServiceClient) GetBaseVM(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*GrpcVM, error) { out := new(GrpcVM) - err := grpc.Invoke(ctx, "/cache.CacheService/GetBaseVM", in, out, c.cc, opts...) + err := c.cc.Invoke(ctx, "/cache.CacheService/GetBaseVM", in, out, opts...) if err != nil { return nil, err } return out, nil } -func (c *cacheServiceClient) Status(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*GrpcStatus, error) { +func (c *cacheServiceClient) Status(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*GrpcStatus, error) { out := new(GrpcStatus) - err := grpc.Invoke(ctx, "/cache.CacheService/Status", in, out, c.cc, opts...) + err := c.cc.Invoke(ctx, "/cache.CacheService/Status", in, out, opts...) if err != nil { return nil, err } return out, nil } -func (c *cacheServiceClient) Quit(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*google_protobuf.Empty, error) { - out := new(google_protobuf.Empty) - err := grpc.Invoke(ctx, "/cache.CacheService/Quit", in, out, c.cc, opts...) +func (c *cacheServiceClient) Quit(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.Empty, error) { + out := new(types.Empty) + err := c.cc.Invoke(ctx, "/cache.CacheService/Quit", in, out, opts...) if err != nil { return nil, err } return out, nil } -// Server API for CacheService service - +// CacheServiceServer is the server API for CacheService service. type CacheServiceServer interface { - Config(context.Context, *google_protobuf.Empty) (*GrpcVMConfig, error) - GetBaseVM(context.Context, *google_protobuf.Empty) (*GrpcVM, error) - Status(context.Context, *google_protobuf.Empty) (*GrpcStatus, error) - Quit(context.Context, *google_protobuf.Empty) (*google_protobuf.Empty, error) + Config(context.Context, *types.Empty) (*GrpcVMConfig, error) + GetBaseVM(context.Context, *types.Empty) (*GrpcVM, error) + Status(context.Context, *types.Empty) (*GrpcStatus, error) + Quit(context.Context, *types.Empty) (*types.Empty, error) +} + +// UnimplementedCacheServiceServer can be embedded to have forward compatible implementations. +type UnimplementedCacheServiceServer struct { +} + +func (*UnimplementedCacheServiceServer) Config(ctx context.Context, req *types.Empty) (*GrpcVMConfig, error) { + return nil, status.Errorf(codes.Unimplemented, "method Config not implemented") +} +func (*UnimplementedCacheServiceServer) GetBaseVM(ctx context.Context, req *types.Empty) (*GrpcVM, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetBaseVM not implemented") +} +func (*UnimplementedCacheServiceServer) Status(ctx context.Context, req *types.Empty) (*GrpcStatus, error) { + return nil, status.Errorf(codes.Unimplemented, "method Status not implemented") +} +func (*UnimplementedCacheServiceServer) Quit(ctx context.Context, req *types.Empty) (*types.Empty, error) { + return nil, status.Errorf(codes.Unimplemented, "method Quit not implemented") } func RegisterCacheServiceServer(s *grpc.Server, srv CacheServiceServer) { @@ -264,7 +424,7 @@ func RegisterCacheServiceServer(s *grpc.Server, srv CacheServiceServer) { } func _CacheService_Config_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(google_protobuf.Empty) + in := new(types.Empty) if err := dec(in); err != nil { return nil, err } @@ -276,13 +436,13 @@ func _CacheService_Config_Handler(srv interface{}, ctx context.Context, dec func FullMethod: "/cache.CacheService/Config", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(CacheServiceServer).Config(ctx, req.(*google_protobuf.Empty)) + return srv.(CacheServiceServer).Config(ctx, req.(*types.Empty)) } return interceptor(ctx, in, info, handler) } func _CacheService_GetBaseVM_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(google_protobuf.Empty) + in := new(types.Empty) if err := dec(in); err != nil { return nil, err } @@ -294,13 +454,13 @@ func _CacheService_GetBaseVM_Handler(srv interface{}, ctx context.Context, dec f FullMethod: "/cache.CacheService/GetBaseVM", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(CacheServiceServer).GetBaseVM(ctx, req.(*google_protobuf.Empty)) + return srv.(CacheServiceServer).GetBaseVM(ctx, req.(*types.Empty)) } return interceptor(ctx, in, info, handler) } func _CacheService_Status_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(google_protobuf.Empty) + in := new(types.Empty) if err := dec(in); err != nil { return nil, err } @@ -312,13 +472,13 @@ func _CacheService_Status_Handler(srv interface{}, ctx context.Context, dec func FullMethod: "/cache.CacheService/Status", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(CacheServiceServer).Status(ctx, req.(*google_protobuf.Empty)) + return srv.(CacheServiceServer).Status(ctx, req.(*types.Empty)) } return interceptor(ctx, in, info, handler) } func _CacheService_Quit_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(google_protobuf.Empty) + in := new(types.Empty) if err := dec(in); err != nil { return nil, err } @@ -330,7 +490,7 @@ func _CacheService_Quit_Handler(srv interface{}, ctx context.Context, dec func(i FullMethod: "/cache.CacheService/Quit", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(CacheServiceServer).Quit(ctx, req.(*google_protobuf.Empty)) + return srv.(CacheServiceServer).Quit(ctx, req.(*types.Empty)) } return interceptor(ctx, in, info, handler) } @@ -363,7 +523,7 @@ var _CacheService_serviceDesc = grpc.ServiceDesc{ func (m *GrpcVMConfig) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) - n, err := m.MarshalTo(dAtA) + n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } @@ -371,29 +531,40 @@ func (m *GrpcVMConfig) Marshal() (dAtA []byte, err error) { } func (m *GrpcVMConfig) MarshalTo(dAtA []byte) (int, error) { - var i int + size := m.Size() + return m.MarshalToSizedBuffer(dAtA[:size]) +} + +func (m *GrpcVMConfig) MarshalToSizedBuffer(dAtA []byte) (int, error) { + i := len(dAtA) _ = i var l int _ = l - if len(m.Data) > 0 { - dAtA[i] = 0xa - i++ - i = encodeVarintCache(dAtA, i, uint64(len(m.Data))) - i += copy(dAtA[i:], m.Data) + if m.XXX_unrecognized != nil { + i -= len(m.XXX_unrecognized) + copy(dAtA[i:], m.XXX_unrecognized) } if len(m.AgentConfig) > 0 { - dAtA[i] = 0x12 - i++ + i -= len(m.AgentConfig) + copy(dAtA[i:], m.AgentConfig) i = encodeVarintCache(dAtA, i, uint64(len(m.AgentConfig))) - i += copy(dAtA[i:], m.AgentConfig) + i-- + dAtA[i] = 0x12 } - return i, nil + if len(m.Data) > 0 { + i -= len(m.Data) + copy(dAtA[i:], m.Data) + i = encodeVarintCache(dAtA, i, uint64(len(m.Data))) + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil } func (m *GrpcVM) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) - n, err := m.MarshalTo(dAtA) + n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } @@ -401,55 +572,67 @@ func (m *GrpcVM) Marshal() (dAtA []byte, err error) { } func (m *GrpcVM) MarshalTo(dAtA []byte) (int, error) { - var i int + size := m.Size() + return m.MarshalToSizedBuffer(dAtA[:size]) +} + +func (m *GrpcVM) MarshalToSizedBuffer(dAtA []byte) (int, error) { + i := len(dAtA) _ = i var l int _ = l - if len(m.Id) > 0 { - dAtA[i] = 0xa - i++ - i = encodeVarintCache(dAtA, i, uint64(len(m.Id))) - i += copy(dAtA[i:], m.Id) - } - if len(m.Hypervisor) > 0 { - dAtA[i] = 0x12 - i++ - i = encodeVarintCache(dAtA, i, uint64(len(m.Hypervisor))) - i += copy(dAtA[i:], m.Hypervisor) - } - if m.ProxyPid != 0 { - dAtA[i] = 0x18 - i++ - i = encodeVarintCache(dAtA, i, uint64(m.ProxyPid)) - } - if len(m.ProxyURL) > 0 { - dAtA[i] = 0x22 - i++ - i = encodeVarintCache(dAtA, i, uint64(len(m.ProxyURL))) - i += copy(dAtA[i:], m.ProxyURL) - } - if m.Cpu != 0 { - dAtA[i] = 0x28 - i++ - i = encodeVarintCache(dAtA, i, uint64(m.Cpu)) - } - if m.Memory != 0 { - dAtA[i] = 0x30 - i++ - i = encodeVarintCache(dAtA, i, uint64(m.Memory)) + if m.XXX_unrecognized != nil { + i -= len(m.XXX_unrecognized) + copy(dAtA[i:], m.XXX_unrecognized) } if m.CpuDelta != 0 { - dAtA[i] = 0x38 - i++ i = encodeVarintCache(dAtA, i, uint64(m.CpuDelta)) + i-- + dAtA[i] = 0x38 } - return i, nil + if m.Memory != 0 { + i = encodeVarintCache(dAtA, i, uint64(m.Memory)) + i-- + dAtA[i] = 0x30 + } + if m.Cpu != 0 { + i = encodeVarintCache(dAtA, i, uint64(m.Cpu)) + i-- + dAtA[i] = 0x28 + } + if len(m.ProxyURL) > 0 { + i -= len(m.ProxyURL) + copy(dAtA[i:], m.ProxyURL) + i = encodeVarintCache(dAtA, i, uint64(len(m.ProxyURL))) + i-- + dAtA[i] = 0x22 + } + if m.ProxyPid != 0 { + i = encodeVarintCache(dAtA, i, uint64(m.ProxyPid)) + i-- + dAtA[i] = 0x18 + } + if len(m.Hypervisor) > 0 { + i -= len(m.Hypervisor) + copy(dAtA[i:], m.Hypervisor) + i = encodeVarintCache(dAtA, i, uint64(len(m.Hypervisor))) + i-- + dAtA[i] = 0x12 + } + if len(m.Id) > 0 { + i -= len(m.Id) + copy(dAtA[i:], m.Id) + i = encodeVarintCache(dAtA, i, uint64(len(m.Id))) + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil } func (m *GrpcStatus) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) - n, err := m.MarshalTo(dAtA) + n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } @@ -457,34 +640,45 @@ func (m *GrpcStatus) Marshal() (dAtA []byte, err error) { } func (m *GrpcStatus) MarshalTo(dAtA []byte) (int, error) { - var i int + size := m.Size() + return m.MarshalToSizedBuffer(dAtA[:size]) +} + +func (m *GrpcStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) { + i := len(dAtA) _ = i var l int _ = l - if m.Pid != 0 { - dAtA[i] = 0x8 - i++ - i = encodeVarintCache(dAtA, i, uint64(m.Pid)) + if m.XXX_unrecognized != nil { + i -= len(m.XXX_unrecognized) + copy(dAtA[i:], m.XXX_unrecognized) } if len(m.Vmstatus) > 0 { - for _, msg := range m.Vmstatus { - dAtA[i] = 0x12 - i++ - i = encodeVarintCache(dAtA, i, uint64(msg.Size())) - n, err := msg.MarshalTo(dAtA[i:]) - if err != nil { - return 0, err + for iNdEx := len(m.Vmstatus) - 1; iNdEx >= 0; iNdEx-- { + { + size, err := m.Vmstatus[iNdEx].MarshalToSizedBuffer(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = encodeVarintCache(dAtA, i, uint64(size)) } - i += n + i-- + dAtA[i] = 0x12 } } - return i, nil + if m.Pid != 0 { + i = encodeVarintCache(dAtA, i, uint64(m.Pid)) + i-- + dAtA[i] = 0x8 + } + return len(dAtA) - i, nil } func (m *GrpcVMStatus) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) - n, err := m.MarshalTo(dAtA) + n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } @@ -492,38 +686,52 @@ func (m *GrpcVMStatus) Marshal() (dAtA []byte, err error) { } func (m *GrpcVMStatus) MarshalTo(dAtA []byte) (int, error) { - var i int + size := m.Size() + return m.MarshalToSizedBuffer(dAtA[:size]) +} + +func (m *GrpcVMStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) { + i := len(dAtA) _ = i var l int _ = l - if m.Pid != 0 { - dAtA[i] = 0x8 - i++ - i = encodeVarintCache(dAtA, i, uint64(m.Pid)) - } - if m.Cpu != 0 { - dAtA[i] = 0x10 - i++ - i = encodeVarintCache(dAtA, i, uint64(m.Cpu)) + if m.XXX_unrecognized != nil { + i -= len(m.XXX_unrecognized) + copy(dAtA[i:], m.XXX_unrecognized) } if m.Memory != 0 { - dAtA[i] = 0x18 - i++ i = encodeVarintCache(dAtA, i, uint64(m.Memory)) + i-- + dAtA[i] = 0x18 } - return i, nil + if m.Cpu != 0 { + i = encodeVarintCache(dAtA, i, uint64(m.Cpu)) + i-- + dAtA[i] = 0x10 + } + if m.Pid != 0 { + i = encodeVarintCache(dAtA, i, uint64(m.Pid)) + i-- + dAtA[i] = 0x8 + } + return len(dAtA) - i, nil } func encodeVarintCache(dAtA []byte, offset int, v uint64) int { + offset -= sovCache(v) + base := offset for v >= 1<<7 { dAtA[offset] = uint8(v&0x7f | 0x80) v >>= 7 offset++ } dAtA[offset] = uint8(v) - return offset + 1 + return base } func (m *GrpcVMConfig) Size() (n int) { + if m == nil { + return 0 + } var l int _ = l l = len(m.Data) @@ -534,10 +742,16 @@ func (m *GrpcVMConfig) Size() (n int) { if l > 0 { n += 1 + l + sovCache(uint64(l)) } + if m.XXX_unrecognized != nil { + n += len(m.XXX_unrecognized) + } return n } func (m *GrpcVM) Size() (n int) { + if m == nil { + return 0 + } var l int _ = l l = len(m.Id) @@ -564,10 +778,16 @@ func (m *GrpcVM) Size() (n int) { if m.CpuDelta != 0 { n += 1 + sovCache(uint64(m.CpuDelta)) } + if m.XXX_unrecognized != nil { + n += len(m.XXX_unrecognized) + } return n } func (m *GrpcStatus) Size() (n int) { + if m == nil { + return 0 + } var l int _ = l if m.Pid != 0 { @@ -579,10 +799,16 @@ func (m *GrpcStatus) Size() (n int) { n += 1 + l + sovCache(uint64(l)) } } + if m.XXX_unrecognized != nil { + n += len(m.XXX_unrecognized) + } return n } func (m *GrpcVMStatus) Size() (n int) { + if m == nil { + return 0 + } var l int _ = l if m.Pid != 0 { @@ -594,18 +820,14 @@ func (m *GrpcVMStatus) Size() (n int) { if m.Memory != 0 { n += 1 + sovCache(uint64(m.Memory)) } + if m.XXX_unrecognized != nil { + n += len(m.XXX_unrecognized) + } return n } func sovCache(x uint64) (n int) { - for { - n++ - x >>= 7 - if x == 0 { - break - } - } - return n + return (math_bits.Len64(x|1) + 6) / 7 } func sozCache(x uint64) (n int) { return sovCache(uint64((x << 1) ^ uint64((int64(x) >> 63)))) @@ -625,7 +847,7 @@ func (m *GrpcVMConfig) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -653,7 +875,7 @@ func (m *GrpcVMConfig) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - byteLen |= (int(b) & 0x7F) << shift + byteLen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -662,6 +884,9 @@ func (m *GrpcVMConfig) Unmarshal(dAtA []byte) error { return ErrInvalidLengthCache } postIndex := iNdEx + byteLen + if postIndex < 0 { + return ErrInvalidLengthCache + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -684,7 +909,7 @@ func (m *GrpcVMConfig) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - byteLen |= (int(b) & 0x7F) << shift + byteLen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -693,6 +918,9 @@ func (m *GrpcVMConfig) Unmarshal(dAtA []byte) error { return ErrInvalidLengthCache } postIndex := iNdEx + byteLen + if postIndex < 0 { + return ErrInvalidLengthCache + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -707,12 +935,13 @@ func (m *GrpcVMConfig) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthCache } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } + m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } @@ -737,7 +966,7 @@ func (m *GrpcVM) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -765,7 +994,7 @@ func (m *GrpcVM) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -775,6 +1004,9 @@ func (m *GrpcVM) Unmarshal(dAtA []byte) error { return ErrInvalidLengthCache } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthCache + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -794,7 +1026,7 @@ func (m *GrpcVM) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - byteLen |= (int(b) & 0x7F) << shift + byteLen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -803,6 +1035,9 @@ func (m *GrpcVM) Unmarshal(dAtA []byte) error { return ErrInvalidLengthCache } postIndex := iNdEx + byteLen + if postIndex < 0 { + return ErrInvalidLengthCache + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -825,7 +1060,7 @@ func (m *GrpcVM) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.ProxyPid |= (int64(b) & 0x7F) << shift + m.ProxyPid |= int64(b&0x7F) << shift if b < 0x80 { break } @@ -844,7 +1079,7 @@ func (m *GrpcVM) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - stringLen |= (uint64(b) & 0x7F) << shift + stringLen |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -854,6 +1089,9 @@ func (m *GrpcVM) Unmarshal(dAtA []byte) error { return ErrInvalidLengthCache } postIndex := iNdEx + intStringLen + if postIndex < 0 { + return ErrInvalidLengthCache + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -873,7 +1111,7 @@ func (m *GrpcVM) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.Cpu |= (uint32(b) & 0x7F) << shift + m.Cpu |= uint32(b&0x7F) << shift if b < 0x80 { break } @@ -892,7 +1130,7 @@ func (m *GrpcVM) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.Memory |= (uint32(b) & 0x7F) << shift + m.Memory |= uint32(b&0x7F) << shift if b < 0x80 { break } @@ -911,7 +1149,7 @@ func (m *GrpcVM) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.CpuDelta |= (uint32(b) & 0x7F) << shift + m.CpuDelta |= uint32(b&0x7F) << shift if b < 0x80 { break } @@ -922,12 +1160,13 @@ func (m *GrpcVM) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthCache } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } + m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } @@ -952,7 +1191,7 @@ func (m *GrpcStatus) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -980,7 +1219,7 @@ func (m *GrpcStatus) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.Pid |= (int64(b) & 0x7F) << shift + m.Pid |= int64(b&0x7F) << shift if b < 0x80 { break } @@ -999,7 +1238,7 @@ func (m *GrpcStatus) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - msglen |= (int(b) & 0x7F) << shift + msglen |= int(b&0x7F) << shift if b < 0x80 { break } @@ -1008,6 +1247,9 @@ func (m *GrpcStatus) Unmarshal(dAtA []byte) error { return ErrInvalidLengthCache } postIndex := iNdEx + msglen + if postIndex < 0 { + return ErrInvalidLengthCache + } if postIndex > l { return io.ErrUnexpectedEOF } @@ -1022,12 +1264,13 @@ func (m *GrpcStatus) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthCache } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } + m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } @@ -1052,7 +1295,7 @@ func (m *GrpcVMStatus) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - wire |= (uint64(b) & 0x7F) << shift + wire |= uint64(b&0x7F) << shift if b < 0x80 { break } @@ -1080,7 +1323,7 @@ func (m *GrpcVMStatus) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.Pid |= (int64(b) & 0x7F) << shift + m.Pid |= int64(b&0x7F) << shift if b < 0x80 { break } @@ -1099,7 +1342,7 @@ func (m *GrpcVMStatus) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.Cpu |= (uint32(b) & 0x7F) << shift + m.Cpu |= uint32(b&0x7F) << shift if b < 0x80 { break } @@ -1118,7 +1361,7 @@ func (m *GrpcVMStatus) Unmarshal(dAtA []byte) error { } b := dAtA[iNdEx] iNdEx++ - m.Memory |= (uint32(b) & 0x7F) << shift + m.Memory |= uint32(b&0x7F) << shift if b < 0x80 { break } @@ -1129,12 +1372,13 @@ func (m *GrpcVMStatus) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthCache } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } + m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) iNdEx += skippy } } @@ -1147,6 +1391,7 @@ func (m *GrpcVMStatus) Unmarshal(dAtA []byte) error { func skipCache(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 { @@ -1178,10 +1423,8 @@ func skipCache(dAtA []byte) (n int, err error) { break } } - return iNdEx, nil case 1: iNdEx += 8 - return iNdEx, nil case 2: var length int for shift := uint(0); ; shift += 7 { @@ -1198,83 +1441,34 @@ func skipCache(dAtA []byte) (n int, err error) { break } } - iNdEx += length if length < 0 { return 0, ErrInvalidLengthCache } - return iNdEx, nil + iNdEx += length case 3: - for { - var innerWire uint64 - var start int = iNdEx - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return 0, ErrIntOverflowCache - } - if iNdEx >= l { - return 0, io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - innerWire |= (uint64(b) & 0x7F) << shift - if b < 0x80 { - break - } - } - innerWireType := int(innerWire & 0x7) - if innerWireType == 4 { - break - } - next, err := skipCache(dAtA[start:]) - if err != nil { - return 0, err - } - iNdEx = start + next - } - return iNdEx, nil + depth++ case 4: - return iNdEx, nil + if depth == 0 { + return 0, ErrUnexpectedEndOfGroupCache + } + depth-- case 5: iNdEx += 4 - return iNdEx, nil default: return 0, fmt.Errorf("proto: illegal wireType %d", wireType) } + if iNdEx < 0 { + return 0, ErrInvalidLengthCache + } + if depth == 0 { + return iNdEx, nil + } } - panic("unreachable") + return 0, io.ErrUnexpectedEOF } var ( - ErrInvalidLengthCache = fmt.Errorf("proto: negative length found during unmarshaling") - ErrIntOverflowCache = fmt.Errorf("proto: integer overflow") + ErrInvalidLengthCache = fmt.Errorf("proto: negative length found during unmarshaling") + ErrIntOverflowCache = fmt.Errorf("proto: integer overflow") + ErrUnexpectedEndOfGroupCache = fmt.Errorf("proto: unexpected end of group") ) - -func init() { proto.RegisterFile("cache.proto", fileDescriptorCache) } - -var fileDescriptorCache = []byte{ - // 374 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x51, 0xcd, 0x0a, 0xda, 0x40, - 0x10, 0x66, 0x13, 0x4d, 0x75, 0x8c, 0xa5, 0xdd, 0x82, 0x2c, 0x16, 0x42, 0xc8, 0x29, 0xa7, 0x08, - 0x4a, 0x7b, 0xaf, 0x5a, 0x84, 0x52, 0x69, 0x1b, 0xa9, 0xf7, 0x18, 0xd7, 0x18, 0x30, 0xee, 0x92, - 0x6c, 0xa4, 0x79, 0xb1, 0x3e, 0x43, 0x8f, 0x7d, 0x84, 0xe2, 0xa1, 0xcf, 0x51, 0x76, 0xb3, 0x86, - 0x08, 0xcd, 0x6d, 0x66, 0xbe, 0x9f, 0xfd, 0x76, 0x06, 0x46, 0x71, 0x14, 0x9f, 0x69, 0xc0, 0x73, - 0x26, 0x18, 0xee, 0xab, 0x66, 0xfa, 0x36, 0x61, 0x2c, 0xb9, 0xd0, 0x99, 0x1a, 0x1e, 0xca, 0xd3, - 0x8c, 0x66, 0x5c, 0x54, 0x35, 0xc7, 0x5b, 0x83, 0xbd, 0xc9, 0x79, 0xbc, 0xdf, 0xae, 0xd8, 0xf5, - 0x94, 0x26, 0x18, 0x43, 0x6f, 0x1d, 0x89, 0x88, 0x20, 0x17, 0xf9, 0x76, 0xa8, 0x6a, 0xec, 0xc2, - 0xe8, 0x43, 0x42, 0xaf, 0xa2, 0xa6, 0x10, 0x43, 0x41, 0xed, 0x91, 0xf7, 0x13, 0x81, 0x55, 0xdb, - 0xe0, 0x97, 0x60, 0xa4, 0x47, 0x25, 0x1f, 0x86, 0x46, 0x7a, 0xc4, 0x0e, 0xc0, 0xb9, 0xe2, 0x34, - 0xbf, 0xa5, 0x05, 0xcb, 0xb5, 0xb6, 0x35, 0xc1, 0x53, 0x18, 0xf0, 0x9c, 0xfd, 0xa8, 0xbe, 0xa6, - 0x47, 0x62, 0xba, 0xc8, 0x37, 0xc3, 0xa6, 0x6f, 0xb0, 0xef, 0xe1, 0x67, 0xd2, 0x53, 0x8e, 0x4d, - 0x8f, 0x5f, 0x81, 0x19, 0xf3, 0x92, 0xf4, 0x5d, 0xe4, 0x8f, 0x43, 0x59, 0xe2, 0x09, 0x58, 0x19, - 0xcd, 0x58, 0x5e, 0x11, 0x4b, 0x0d, 0x75, 0x27, 0x5d, 0x62, 0x5e, 0xae, 0xe9, 0x45, 0x44, 0xe4, - 0x85, 0x42, 0x9a, 0xde, 0xfb, 0x02, 0x20, 0x73, 0xef, 0x44, 0x24, 0xca, 0x42, 0x7a, 0x72, 0x1d, - 0xde, 0x0c, 0x65, 0x89, 0x67, 0x30, 0xb8, 0x65, 0x85, 0x42, 0x89, 0xe1, 0x9a, 0xfe, 0x68, 0xfe, - 0x26, 0xa8, 0x57, 0x5c, 0x7f, 0xb7, 0x16, 0x86, 0x0d, 0xc9, 0xfb, 0xf4, 0xd8, 0x67, 0xa7, 0xa5, - 0x0e, 0x6e, 0xfc, 0x2f, 0xb8, 0xd9, 0x0e, 0x3e, 0xff, 0x8b, 0xc0, 0x5e, 0xc9, 0xc7, 0x76, 0x72, - 0x59, 0x31, 0xc5, 0xef, 0xc0, 0xd2, 0x67, 0x9a, 0x04, 0xf5, 0x51, 0x83, 0xc7, 0x51, 0x83, 0x8f, - 0xf2, 0xa8, 0xd3, 0xe7, 0x74, 0x9a, 0x3c, 0x87, 0xe1, 0x86, 0x8a, 0x65, 0x54, 0xd0, 0xfd, 0xb6, - 0x53, 0x39, 0x7e, 0x52, 0xe2, 0x05, 0x58, 0xfa, 0x07, 0x5d, 0x82, 0xd7, 0x2d, 0x81, 0xa6, 0xbe, - 0x87, 0xde, 0xb7, 0x32, 0x15, 0x9d, 0x92, 0x8e, 0xf9, 0xd2, 0xfe, 0x75, 0x77, 0xd0, 0xef, 0xbb, - 0x83, 0xfe, 0xdc, 0x1d, 0x74, 0xb0, 0x14, 0xba, 0xf8, 0x17, 0x00, 0x00, 0xff, 0xff, 0x40, 0x5e, - 0x19, 0x6e, 0xcc, 0x02, 0x00, 0x00, -} diff --git a/src/runtime/virtcontainers/pkg/agent/protocols/grpc/agent.pb.go b/src/runtime/virtcontainers/pkg/agent/protocols/grpc/agent.pb.go index 3ee3bff7aa..bea5225d2e 100644 --- a/src/runtime/virtcontainers/pkg/agent/protocols/grpc/agent.pb.go +++ b/src/runtime/virtcontainers/pkg/agent/protocols/grpc/agent.pb.go @@ -7009,7 +7009,7 @@ func (this *MemoryStats) String() string { return "nil" } keysForStats := make([]string, 0, len(this.Stats)) - for k := range this.Stats { + for k, _ := range this.Stats { keysForStats = append(keysForStats, k) } github_com_gogo_protobuf_sortkeys.Strings(keysForStats) @@ -7120,7 +7120,7 @@ func (this *CgroupStats) String() string { return "nil" } keysForHugetlbStats := make([]string, 0, len(this.HugetlbStats)) - for k := range this.HugetlbStats { + for k, _ := range this.HugetlbStats { keysForHugetlbStats = append(keysForHugetlbStats, k) } github_com_gogo_protobuf_sortkeys.Strings(keysForHugetlbStats) @@ -8408,10 +8408,7 @@ func (m *CreateContainerRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -8494,10 +8491,7 @@ func (m *StartContainerRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -8599,10 +8593,7 @@ func (m *RemoveContainerRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -8789,10 +8780,7 @@ func (m *ExecProcessRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -8926,10 +8914,7 @@ func (m *SignalProcessRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -9044,10 +9029,7 @@ func (m *WaitProcessRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -9117,10 +9099,7 @@ func (m *WaitProcessResponse) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -9239,10 +9218,7 @@ func (m *UpdateContainerRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -9325,10 +9301,7 @@ func (m *StatsContainerRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -9411,10 +9384,7 @@ func (m *PauseContainerRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -9497,10 +9467,7 @@ func (m *ResumeContainerRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -9684,10 +9651,7 @@ func (m *CpuUsage) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -9795,10 +9759,7 @@ func (m *ThrottlingData) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -9921,10 +9882,7 @@ func (m *CpuStats) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -10013,10 +9971,7 @@ func (m *PidsStats) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -10143,10 +10098,7 @@ func (m *MemoryData) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -10440,7 +10392,7 @@ func (m *MemoryStats) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > postIndex { @@ -10457,10 +10409,7 @@ func (m *MemoryStats) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -10600,10 +10549,7 @@ func (m *BlkioStatsEntry) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -10926,10 +10872,7 @@ func (m *BlkioStats) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -11037,10 +10980,7 @@ func (m *HugetlbStats) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -11347,7 +11287,7 @@ func (m *CgroupStats) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > postIndex { @@ -11364,10 +11304,7 @@ func (m *CgroupStats) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -11602,10 +11539,7 @@ func (m *NetworkStats) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -11726,10 +11660,7 @@ func (m *StatsContainerResponse) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -11878,10 +11809,7 @@ func (m *WriteStreamRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -11951,10 +11879,7 @@ func (m *WriteStreamResponse) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -12088,10 +12013,7 @@ func (m *ReadStreamRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -12176,10 +12098,7 @@ func (m *ReadStreamResponse) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -12294,10 +12213,7 @@ func (m *CloseStdinRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -12450,10 +12366,7 @@ func (m *TtyWinResizeRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -12568,10 +12481,7 @@ func (m *KernelModule) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -12838,10 +12748,7 @@ func (m *CreateSandboxRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -12892,10 +12799,7 @@ func (m *DestroySandboxRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -12980,10 +12884,7 @@ func (m *Interfaces) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -13068,10 +12969,7 @@ func (m *Routes) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -13158,10 +13056,7 @@ func (m *UpdateInterfaceRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -13248,10 +13143,7 @@ func (m *UpdateRoutesRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -13302,10 +13194,7 @@ func (m *ListInterfacesRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -13356,10 +13245,7 @@ func (m *ListRoutesRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -13444,10 +13330,7 @@ func (m *ARPNeighbors) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -13534,10 +13417,7 @@ func (m *AddARPNeighborsRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -13647,10 +13527,7 @@ func (m *OnlineCPUMemRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -13735,10 +13612,7 @@ func (m *ReseedRandomDevRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -13925,10 +13799,7 @@ func (m *AgentDetails) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -14019,10 +13890,7 @@ func (m *GuestDetailsRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -14148,10 +14016,7 @@ func (m *GuestDetailsResponse) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -14278,10 +14143,7 @@ func (m *MemHotplugByProbeRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -14370,10 +14232,7 @@ func (m *SetGuestDateTimeRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -14616,10 +14475,7 @@ func (m *Storage) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -14830,10 +14686,7 @@ func (m *Device) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -14980,10 +14833,7 @@ func (m *StringUser) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -15214,10 +15064,7 @@ func (m *CopyFileRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -15268,10 +15115,7 @@ func (m *StartTracingRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -15322,10 +15166,7 @@ func (m *StopTracingRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -15376,10 +15217,7 @@ func (m *GetOOMEventRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -15462,10 +15300,7 @@ func (m *OOMEvent) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -15516,10 +15351,7 @@ func (m *GetMetricsRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { @@ -15602,10 +15434,7 @@ func (m *Metrics) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthAgent - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthAgent } if (iNdEx + skippy) > l { diff --git a/src/runtime/virtcontainers/pkg/agent/protocols/grpc/health.pb.go b/src/runtime/virtcontainers/pkg/agent/protocols/grpc/health.pb.go index 931605fb62..7a46e51a56 100644 --- a/src/runtime/virtcontainers/pkg/agent/protocols/grpc/health.pb.go +++ b/src/runtime/virtcontainers/pkg/agent/protocols/grpc/health.pb.go @@ -732,10 +732,7 @@ func (m *CheckRequest) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthHealth - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthHealth } if (iNdEx + skippy) > l { @@ -805,10 +802,7 @@ func (m *HealthCheckResponse) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthHealth - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthHealth } if (iNdEx + skippy) > l { @@ -923,10 +917,7 @@ func (m *VersionCheckResponse) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthHealth - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthHealth } if (iNdEx + skippy) > l { diff --git a/src/runtime/virtcontainers/pkg/agent/protocols/grpc/oci.pb.go b/src/runtime/virtcontainers/pkg/agent/protocols/grpc/oci.pb.go index 4a7cd2d00b..2dc8fd757f 100644 --- a/src/runtime/virtcontainers/pkg/agent/protocols/grpc/oci.pb.go +++ b/src/runtime/virtcontainers/pkg/agent/protocols/grpc/oci.pb.go @@ -6797,7 +6797,7 @@ func (this *Spec) String() string { } repeatedStringForMounts += "}" keysForAnnotations := make([]string, 0, len(this.Annotations)) - for k := range this.Annotations { + for k, _ := range this.Annotations { keysForAnnotations = append(keysForAnnotations, k) } github_com_gogo_protobuf_sortkeys.Strings(keysForAnnotations) @@ -6996,7 +6996,7 @@ func (this *Linux) String() string { } repeatedStringForDevices += "}" keysForSysctl := make([]string, 0, len(this.Sysctl)) - for k := range this.Sysctl { + for k, _ := range this.Sysctl { keysForSysctl = append(keysForSysctl, k) } github_com_gogo_protobuf_sortkeys.Strings(keysForSysctl) @@ -7717,10 +7717,7 @@ func (m *Spec) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > postIndex { @@ -7845,10 +7842,7 @@ func (m *Spec) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -8257,10 +8251,7 @@ func (m *Process) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -8349,10 +8340,7 @@ func (m *Box) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -8549,10 +8537,7 @@ func (m *User) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -8763,10 +8748,7 @@ func (m *LinuxCapabilities) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -8887,10 +8869,7 @@ func (m *POSIXRlimit) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -9069,10 +9048,7 @@ func (m *Mount) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -9175,10 +9151,7 @@ func (m *Root) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -9331,10 +9304,7 @@ func (m *Hooks) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -9500,10 +9470,7 @@ func (m *Hook) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -9732,10 +9699,7 @@ func (m *Linux) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > postIndex { @@ -10088,10 +10052,7 @@ func (m *Linux) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -10174,10 +10135,7 @@ func (m *Windows) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -10260,10 +10218,7 @@ func (m *Solaris) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -10371,10 +10326,7 @@ func (m *LinuxIDMapping) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -10489,10 +10441,7 @@ func (m *LinuxNamespace) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -10702,10 +10651,7 @@ func (m *LinuxDevice) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -11004,10 +10950,7 @@ func (m *LinuxResources) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -11192,10 +11135,7 @@ func (m *LinuxMemory) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -11405,10 +11345,7 @@ func (m *LinuxCPU) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -11535,10 +11472,7 @@ func (m *LinuxWeightDevice) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -11646,10 +11580,7 @@ func (m *LinuxThrottleDevice) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -11908,10 +11839,7 @@ func (m *LinuxBlockIO) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -11981,10 +11909,7 @@ func (m *LinuxPids) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -12157,10 +12082,7 @@ func (m *LinuxDeviceCgroup) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -12264,10 +12186,7 @@ func (m *LinuxNetwork) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -12369,10 +12288,7 @@ func (m *LinuxHugepageLimit) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -12474,10 +12390,7 @@ func (m *LinuxInterfacePriority) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -12658,10 +12571,7 @@ func (m *LinuxSeccomp) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -12801,10 +12711,7 @@ func (m *LinuxSeccompArg) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -12973,10 +12880,7 @@ func (m *LinuxSyscall) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { @@ -13059,10 +12963,7 @@ func (m *LinuxIntelRdt) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthOci - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthOci } if (iNdEx + skippy) > l { diff --git a/src/runtime/virtcontainers/pkg/agent/protocols/types.pb.go b/src/runtime/virtcontainers/pkg/agent/protocols/types.pb.go index 497cb55a40..263afa8f16 100644 --- a/src/runtime/virtcontainers/pkg/agent/protocols/types.pb.go +++ b/src/runtime/virtcontainers/pkg/agent/protocols/types.pb.go @@ -865,10 +865,7 @@ func (m *IPAddress) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthTypes - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthTypes } if (iNdEx + skippy) > l { @@ -1151,10 +1148,7 @@ func (m *Interface) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthTypes - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthTypes } if (iNdEx + skippy) > l { @@ -1352,10 +1346,7 @@ func (m *Route) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthTypes - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthTypes } if (iNdEx + skippy) > l { @@ -1544,10 +1535,7 @@ func (m *ARPNeighbor) Unmarshal(dAtA []byte) error { if err != nil { return err } - if skippy < 0 { - return ErrInvalidLengthTypes - } - if (iNdEx + skippy) < 0 { + if (skippy < 0) || (iNdEx+skippy) < 0 { return ErrInvalidLengthTypes } if (iNdEx + skippy) > l {