daniel
/
distribution
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[IPC] Tiny cleaning

master
Anton Tiurin 2014-11-22 23:23:03 +03:00
parent b60ee6dfa0
commit 4635a1e903
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
storagedriver/ipc/client.go
View File

@ -423,7 +423,6 @@ func (driver *StorageDriverClient) handleSubprocessExit() {
func (driver *StorageDriverClient) receiveResponse(receiver libchan.Receiver, response interface{}) error { func (driver *StorageDriverClient) receiveResponse(receiver libchan.Receiver, response interface{}) error {
receiveChan := make(chan error, 1) receiveChan := make(chan error, 1)
go func(receiver libchan.Receiver, receiveChan chan<- error) { go func(receiver libchan.Receiver, receiveChan chan<- error) {
defer close(receiveChan)
receiveChan <- receiver.Receive(response) receiveChan <- receiver.Receive(response)
}(receiver, receiveChan) }(receiver, receiveChan)
@ -432,9 +431,6 @@ func (driver *StorageDriverClient) receiveResponse(receiver libchan.Receiver, re
select { select {
case err = <-receiveChan: case err = <-receiveChan:
case err, ok = <-driver.exitChan: case err, ok = <-driver.exitChan:
go func(receiveChan <-chan error) {
<-receiveChan
}(receiveChan)
if !ok { if !ok {
err = driver.exitErr err = driver.exitErr
} }