|
|
@@ -10,7 +10,7 @@ import ( |
|
|
|
) |
|
|
|
|
|
|
|
var ( |
|
|
|
DefaultTimeout time.Duration = 1000 |
|
|
|
DefaultTimeout time.Duration = time.Second |
|
|
|
) |
|
|
|
|
|
|
|
// One client connect to one server. |
|
|
@@ -25,7 +25,7 @@ type Client struct { |
|
|
|
conn net.Conn |
|
|
|
rw *bufio.ReadWriter |
|
|
|
|
|
|
|
ResponseTimeout time.Duration // response timeout for do() in ms |
|
|
|
ResponseTimeout time.Duration // response timeout for do() |
|
|
|
|
|
|
|
ErrorHandler ErrorHandler |
|
|
|
} |
|
|
@@ -239,7 +239,7 @@ func (client *Client) do(funcname string, data []byte, |
|
|
|
client.innerHandler.remove("c") |
|
|
|
return |
|
|
|
} |
|
|
|
var timer = time.After(client.ResponseTimeout * time.Millisecond) |
|
|
|
var timer = time.After(client.ResponseTimeout) |
|
|
|
select { |
|
|
|
case ret := <-result: |
|
|
|
return ret.handle, ret.err |
|
|
|