-
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
Ftr: Triple Protocol Support #1071
Conversation
Codecov Report
@@ Coverage Diff @@
## 3.0 #1071 +/- ##
==========================================
- Coverage 60.03% 59.32% -0.72%
==========================================
Files 260 272 +12
Lines 12855 13350 +495
==========================================
+ Hits 7718 7920 +202
- Misses 4174 4453 +279
- Partials 963 977 +14
Continue to review full report at Codecov.
|
go.mod
Outdated
) | ||
|
||
replace ( | ||
github.com/coreos/bbolt => go.etcd.io/bbolt v1.3.4 | ||
github.com/envoyproxy/go-control-plane => github.com/envoyproxy/go-control-plane v0.8.0 | ||
github.com/shirou/gopsutil => github.com/shirou/gopsutil v0.0.0-20181107111621-48177ef5f880 | ||
go.etcd.io/bbolt v1.3.4 => github.com/coreos/bbolt v1.3.3 |
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.
go.etcd.io/bbolt v1.3.4 => github.com/coreos/bbolt v1.3.4
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.
fixed!
protocol.BaseInvoker | ||
// the net layer client, it is focus on network communication. | ||
client *dubbo3.TripleClient | ||
quitOnce sync.Once |
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.
quitOnce for which object?
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.
fixed, for quit dubbo3 invoker.
protocol/dubbo3/dubbo3_invoker.go
Outdated
dubbo3 "github.com/dubbogo/triple/pkg/triple" | ||
) | ||
|
||
// DubboInvoker is implement of protocol.Invoker. A dubboInvoker refer to one service and ip. |
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.
Please refact implementation follow
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.
fixed!
protocol/dubbo3/dubbo3_protocol.go
Outdated
"github.com/apache/dubbo-go/common/logger" | ||
"github.com/apache/dubbo-go/config" | ||
"github.com/apache/dubbo-go/protocol" | ||
dubbo3 "github.com/dubbogo/triple/pkg/triple" |
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.
move it up to the 2rd import block.
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.
fixed !
protocol/dubbo3/dubbo3_protocol.go
Outdated
@@ -18,6 +18,7 @@ package dubbo3 | |||
|
|||
import ( | |||
"fmt" | |||
tripleCommon "github.com/dubbogo/triple/pkg/common" |
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.
move out.
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.
fixed!
protocol/dubbo3/dubbo3_protocol.go
Outdated
dp.serverLock.Lock() | ||
defer dp.serverLock.Unlock() | ||
// Stop all server | ||
keyList := make([]string, 16) |
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.
move this line out of lock, pls.
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.
fixed!
config/config_loader.go
Outdated
@@ -201,13 +201,17 @@ func loadProviderConfig() { | |||
checkRegistries(providerConfig.Registries, providerConfig.Registry) | |||
|
|||
for key, svs := range providerConfig.Services { | |||
if key == "GrpcGreeterImpl2" { | |||
fmt.Println("here") |
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.
the prints may be for your debug ??
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.
fixed!
Ftr: Triple Protocol Support
What this PR does:
Add Triple Protocol Support
Which issue(s) this PR fixes:
Fixes #
Special notes for your reviewer:
Does this PR introduce a user-facing change?: