Skip to content
GitLab
Explore
Projects
Groups
Topics
Snippets
Projects
Groups
Topics
Snippets
/
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Menu
MKCLOS
Core Development Platform
corepkgv2
Commits
5c9522ff
Commit
5c9522ff
authored
4 years ago
by
Vikram Ingawale
Committed by
Vikram Ingawale
4 years ago
Browse files
Options
Downloads
Patches
Plain Diff
gRPC: Send & Receive Message Size Changed
(cherry picked from commit
0fbdf0f2
)
parent
670c7ccc
Branches
Branches containing commit
Tags
Tags containing commit
2 merge requests
!231
Release v1.2.1
,
!228
gRPC: Send & Receive Message Size Changed
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
grpcclientmdl/grpcclientmdl.go
+6
-1
grpcclientmdl/grpcclientmdl.go
routebuildermdl/grpcservermdl.go
+2
-1
routebuildermdl/grpcservermdl.go
with
8 additions
and
2 deletions
grpcclientmdl/grpcclientmdl.go
+
6
−
1
View file @
5c9522ff
...
@@ -65,7 +65,12 @@ func ByteHandler(req *grpcbuildermdl.GRPCRequest, grpcServerURL string) ([]byte,
...
@@ -65,7 +65,12 @@ func ByteHandler(req *grpcbuildermdl.GRPCRequest, grpcServerURL string) ([]byte,
func
CreateConnection
(
serverURL
string
,
grpcClientName
string
)
{
func
CreateConnection
(
serverURL
string
,
grpcClientName
string
)
{
var
factory
grpcpool
.
Factory
var
factory
grpcpool
.
Factory
factory
=
func
()
(
*
grpc
.
ClientConn
,
error
)
{
factory
=
func
()
(
*
grpc
.
ClientConn
,
error
)
{
conn
,
err
:=
grpc
.
Dial
(
serverURL
,
grpc
.
WithInsecure
())
maxMsgSize
:=
50
*
1024
*
1024
conn
,
err
:=
grpc
.
Dial
(
serverURL
,
grpc
.
WithDefaultCallOptions
(
grpc
.
MaxCallRecvMsgSize
(
maxMsgSize
),
grpc
.
MaxCallSendMsgSize
(
maxMsgSize
)),
grpc
.
WithInsecure
(),
)
if
err
!=
nil
{
if
err
!=
nil
{
loggermdl
.
LogError
(
"Failed to start gRPC connection: %v"
,
err
)
loggermdl
.
LogError
(
"Failed to start gRPC connection: %v"
,
err
)
}
}
...
...
This diff is collapsed.
Click to expand it.
routebuildermdl/grpcservermdl.go
+
2
−
1
View file @
5c9522ff
...
@@ -21,7 +21,8 @@ type Server struct{}
...
@@ -21,7 +21,8 @@ type Server struct{}
// GRPCInit init
// GRPCInit init
func
GRPCInit
(
GRPCPort
net
.
Listener
)
{
func
GRPCInit
(
GRPCPort
net
.
Listener
)
{
loggermdl
.
LogInfo
(
"In GRPCInit"
)
loggermdl
.
LogInfo
(
"In GRPCInit"
)
s
:=
grpc
.
NewServer
()
maxMsgSize
:=
50
*
1024
*
1024
s
:=
grpc
.
NewServer
(
grpc
.
MaxRecvMsgSize
(
maxMsgSize
),
grpc
.
MaxSendMsgSize
(
maxMsgSize
))
grpcbuildermdl
.
RegisterGRPCCheckServer
(
s
,
&
Server
{})
grpcbuildermdl
.
RegisterGRPCCheckServer
(
s
,
&
Server
{})
grpcbuildermdl
.
RegisterGRPCServiceServer
(
s
,
&
Server
{})
grpcbuildermdl
.
RegisterGRPCServiceServer
(
s
,
&
Server
{})
if
err
:=
s
.
Serve
(
GRPCPort
);
err
!=
nil
{
if
err
:=
s
.
Serve
(
GRPCPort
);
err
!=
nil
{
...
...
This diff is collapsed.
Click to expand it.
Preview
0%
Try again
or
attach a new file
.
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Save comment
Cancel
Please
register
or
sign in
to comment
Menu
Explore
Projects
Groups
Topics
Snippets