summaryrefslogtreecommitdiff
path: root/src/pkg/rpc/client.go
diff options
context:
space:
mode:
Diffstat (limited to 'src/pkg/rpc/client.go')
-rw-r--r--src/pkg/rpc/client.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/pkg/rpc/client.go b/src/pkg/rpc/client.go
index 5846d6b33..8663ad442 100644
--- a/src/pkg/rpc/client.go
+++ b/src/pkg/rpc/client.go
@@ -46,7 +46,7 @@ func (client *Client) send(c *Call) {
if client.shutdown != nil {
c.Error = client.shutdown;
client.mutex.Unlock();
- doNotBlock := c.Done <- c;
+ _ = c.Done <- c; // do not block
return;
}
c.seq = client.seq;
@@ -87,14 +87,14 @@ func (client *Client) input() {
c.Error = os.ErrorString(response.Error);
// We don't want to block here. It is the caller's responsibility to make
// sure the channel has enough buffer space. See comment in Go().
- doNotBlock := c.Done <- c;
+ _ = c.Done <- c; // do not block
}
// Terminate pending calls.
client.mutex.Lock();
client.shutdown = err;
for seq, call := range client.pending {
call.Error = err;
- doNotBlock := call.Done <- call;
+ _ = call.Done <- call; // do not block
}
client.mutex.Unlock();
log.Stderr("client protocol error:", err);
@@ -161,7 +161,7 @@ func (client *Client) Go(serviceMethod string, args interface{}, reply interface
c.Done = done;
if client.shutdown != nil {
c.Error = client.shutdown;
- doNotBlock := c.Done <- c;
+ _ = c.Done <- c; // do not block
return c;
}
client.send(c);