Skip to content

GitLab

新注册的用户请输入邮箱并保存，随后登录邮箱激活账号。后续可直接使用邮箱登录！

Commit b3bd453f authored by gh lu's avatar gh lu
Browse files
Options

fix: rm marshal unmarshal size 

--bug=0
parent d57600be
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 5236 additions and 1387 deletions
Makefile
View file @ b3bd453f
gen:
cd pb/proto && protoc \
--go_out=../protogo --plugin protoc-gen-go="$(GOPATH)/bin/protoc-gen-go" \
--go-grpc_out=../protogo --go-grpc_opt=require_unimplemented_servers=false --plugin protoc-gen-go-grpc="$(GOPATH)/bin/protoc-gen-go-grpc" \
--gogofaster_out=plugins=grpc:../protogo \
--gogofaster_opt=paths=source_relative \
--go-vtproto_out=../protogo --plugin protoc-gen-go-vtproto="$(GOPATH)/bin/protoc-gen-go-vtproto" \
--go_opt=paths=source_relative \
--go-grpc_opt=paths=source_relative \
--go-vtproto_opt=paths=source_relative \
--go-vtproto_opt=features=marshal+unmarshal+size+pool \
--go-vtproto_opt=features=pool \
--go-vtproto_opt=pool=chainmaker.org/chainmaker/contract-sdk-go/pb/protogo.DockerVMMessage \
dockervm_message.proto
......
pb/protogo/dockervm_message.pb.go
View file @ b3bd453f
This diff is collapsed.
pb/protogo/dockervm_message_grpc.pb.go deleted 100644 → 0
View file @ d57600be
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.2.0
// - protoc v3.17.3
// source: dockervm_message.proto
package protogo
import (
context "context"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
)
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// DockerVMRpcClient is the client API for DockerVMRpc service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type DockerVMRpcClient interface {
DockerVMCommunicate(ctx context.Context, opts ...grpc.CallOption) (DockerVMRpc_DockerVMCommunicateClient, error)
}
type dockerVMRpcClient struct {
cc grpc.ClientConnInterface
}
func NewDockerVMRpcClient(cc grpc.ClientConnInterface) DockerVMRpcClient {
return &dockerVMRpcClient{cc}
}
func (c *dockerVMRpcClient) DockerVMCommunicate(ctx context.Context, opts ...grpc.CallOption) (DockerVMRpc_DockerVMCommunicateClient, error) {
stream, err := c.cc.NewStream(ctx, &DockerVMRpc_ServiceDesc.Streams[0], "/proto.DockerVMRpc/DockerVMCommunicate", opts...)
if err != nil {
return nil, err
}
x := &dockerVMRpcDockerVMCommunicateClient{stream}
return x, nil
}
type DockerVMRpc_DockerVMCommunicateClient interface {
Send(*DockerVMMessage) error
Recv() (*DockerVMMessage, error)
grpc.ClientStream
}
type dockerVMRpcDockerVMCommunicateClient struct {
grpc.ClientStream
}
func (x *dockerVMRpcDockerVMCommunicateClient) Send(m *DockerVMMessage) error {
return x.ClientStream.SendMsg(m)
}
func (x *dockerVMRpcDockerVMCommunicateClient) Recv() (*DockerVMMessage, error) {
m := new(DockerVMMessage)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
// DockerVMRpcServer is the server API for DockerVMRpc service.
// All implementations should embed UnimplementedDockerVMRpcServer
// for forward compatibility
type DockerVMRpcServer interface {
DockerVMCommunicate(DockerVMRpc_DockerVMCommunicateServer) error
}
// UnimplementedDockerVMRpcServer should be embedded to have forward compatible implementations.
type UnimplementedDockerVMRpcServer struct {
}
func (UnimplementedDockerVMRpcServer) DockerVMCommunicate(DockerVMRpc_DockerVMCommunicateServer) error {
return status.Errorf(codes.Unimplemented, "method DockerVMCommunicate not implemented")
}
// UnsafeDockerVMRpcServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to DockerVMRpcServer will
// result in compilation errors.
type UnsafeDockerVMRpcServer interface {
mustEmbedUnimplementedDockerVMRpcServer()
}
func RegisterDockerVMRpcServer(s grpc.ServiceRegistrar, srv DockerVMRpcServer) {
s.RegisterService(&DockerVMRpc_ServiceDesc, srv)
}
func _DockerVMRpc_DockerVMCommunicate_Handler(srv interface{}, stream grpc.ServerStream) error {
return srv.(DockerVMRpcServer).DockerVMCommunicate(&dockerVMRpcDockerVMCommunicateServer{stream})
}
type DockerVMRpc_DockerVMCommunicateServer interface {
Send(*DockerVMMessage) error
Recv() (*DockerVMMessage, error)
grpc.ServerStream
}
type dockerVMRpcDockerVMCommunicateServer struct {
grpc.ServerStream
}
func (x *dockerVMRpcDockerVMCommunicateServer) Send(m *DockerVMMessage) error {
return x.ServerStream.SendMsg(m)
}
func (x *dockerVMRpcDockerVMCommunicateServer) Recv() (*DockerVMMessage, error) {
m := new(DockerVMMessage)
if err := x.ServerStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
// DockerVMRpc_ServiceDesc is the grpc.ServiceDesc for DockerVMRpc service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var DockerVMRpc_ServiceDesc = grpc.ServiceDesc{
ServiceName: "proto.DockerVMRpc",
HandlerType: (*DockerVMRpcServer)(nil),
Methods: []grpc.MethodDesc{},
Streams: []grpc.StreamDesc{
{
StreamName: "DockerVMCommunicate",
Handler: _DockerVMRpc_DockerVMCommunicate_Handler,
ServerStreams: true,
ClientStreams: true,
},
},
Metadata: "dockervm_message.proto",
}
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment

Copyright © 2021 ChainMaker Org. All Rights Reserved. 长安链 版权所有。