klesh/grpcox
1
0
Fork 0
mirror of https://github.com/gusaul/grpcox.git synced 2024-12-26 02:40:10 +00:00
Code Issues Projects Releases Wiki Activity

add timeout cancelation connection

Browse Source
This commit is contained in:
gusaul 2019-04-02 09:45:50 +07:00
parent c3cb947507
commit 37d525bcb8
2 changed files with 20 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
core/resource.go
View File

@ -165,6 +165,8 @@ func (r *Resource) Invoke(ctx context.Context, symbol string, in io.Reader) (str
// Close - to close all resources that was opened before // Close - to close all resources that was opened before
func (r *Resource) Close() { func (r *Resource) Close() {
done := make(chan int)
go func() {
if r.refClient != nil { if r.refClient != nil {
r.refClient.Reset() r.refClient.Reset()
r.refClient = nil r.refClient = nil
@ -173,6 +175,15 @@ func (r *Resource) Close() {
r.clientConn.Close() r.clientConn.Close()
r.clientConn = nil r.clientConn = nil
} }
done <- 1
}()
select {
case <-done:
return
case <-time.After(3 * time.Second):
return
}
} }
func (r *Resource) exit(code int) { func (r *Resource) exit(code int) {

3
index/js/style.js
View File

@ -248,7 +248,8 @@ function refreshConnCount() {
function refreshToolTip() { function refreshToolTip() {
$(function () { $(function () {
$('[data-toggle="tooltip"]').tooltip() $('[data-toggle="tooltip"]').tooltip('dispose');
$('[data-toggle="tooltip"]').tooltip();
}) })
} }