Browse code

add lock in libcontainerd client AddProcess of Windows

Signed-off-by: allencloud <allen.sun@daocloud.io>

allencloud authored on 2016/10/04 11:29:21
Showing 2 changed files
... ...
@@ -669,7 +669,7 @@ func NewDaemon(config *Config, registryService registry.Service, containerdRemot
669 669
 		return nil, err
670 670
 	}
671 671
 
672
-	// Plugin system initialization should happen before restore. Dont change order.
672
+	// Plugin system initialization should happen before restore. Do not change order.
673 673
 	if err := pluginInit(d, config, containerdRemote); err != nil {
674 674
 		return nil, err
675 675
 	}
... ...
@@ -328,6 +328,7 @@ func (clnt *client) AddProcess(ctx context.Context, containerID, processFriendly
328 328
 
329 329
 	// Tell the engine to attach streams back to the client
330 330
 	if err := clnt.backend.AttachStreams(processFriendlyName, *iopipe); err != nil {
331
+		clnt.lock(containerID)
331 332
 		return err
332 333
 	}
333 334