github/distribution
1
0
Fork 0
mirror of https://github.com/distribution/distribution.git synced 2025-08-31 06:34:11 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #776 from noxiouz/tiny_cleaninig

Browse Source 
[IPC] Tiny cleaning
This commit is contained in:
Olivier Gambier
2014-11-23 19:22:56 -08:00
parent b60ee6dfa0 4635a1e903
commit a463f48b1a
1 changed files with 0 additions and 4 deletions
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
} }