-
Notifications
You must be signed in to change notification settings - Fork 929
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Rft: network & codec #673
Rft: network & codec #673
Conversation
Imp: refactor the network transport layer
fix issue for network refactor
fix: resove dev RPCResult struct change
Refact seri
Codecov Report
@@ Coverage Diff @@
## develop #673 +/- ##
===========================================
- Coverage 61.44% 59.78% -1.66%
===========================================
Files 251 259 +8
Lines 12084 12722 +638
===========================================
+ Hits 7425 7606 +181
- Misses 3766 4166 +400
- Partials 893 950 +57
Continue to review full report at Codecov.
|
feat: delete dubbo_protocol assert remoting.ExchangeClient
func (p *RpcServerPackageHandler) Read(ss getty.Session, data []byte) (interface{}, int, error) { | ||
req, length, err := (p.server.codec).Decode(data) | ||
//resp,len, err := (*p.).DecodeResponse(buf) | ||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
pls do not left a blank line btw assignment and the if condition checker.
} | ||
|
||
// DubboCodec. It is implements remoting.Codec | ||
type DubboCodec struct { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
singleton or not?
requestTimeout := config.GetConsumerConfig().RequestTimeout | ||
|
||
requestTimeoutStr := url.GetParam(constant.TIMEOUT_KEY, config.GetConsumerConfig().Request_Timeout) | ||
if t, err := time.ParseDuration(requestTimeoutStr); err == nil { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think you should print error if error is not null
invokeResult := invoker.Invoke(ctx, rpcInvocation) | ||
if err := invokeResult.Error(); err != nil { | ||
result.Err = invokeResult.Error() | ||
//p.Header.ResponseStatus = hessian.Response_OK |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
delete them if useless
Rft: network & codec
What this PR does: