Browse code

Add lock before accessing native driver active containers

Signed-off-by: Antonio Murdaca <me@runcom.ninja>

Antonio Murdaca authored on 2015/05/26 20:54:53
Showing 1 changed files
... ...
@@ -259,7 +259,9 @@ func (d *driver) Kill(c *execdriver.Command, sig int) error {
259 259
 }
260 260
 
261 261
 func (d *driver) Pause(c *execdriver.Command) error {
262
+	d.Lock()
262 263
 	active := d.activeContainers[c.ID]
264
+	d.Unlock()
263 265
 	if active == nil {
264 266
 		return fmt.Errorf("active container for %s does not exist", c.ID)
265 267
 	}
... ...
@@ -267,7 +269,9 @@ func (d *driver) Pause(c *execdriver.Command) error {
267 267
 }
268 268
 
269 269
 func (d *driver) Unpause(c *execdriver.Command) error {
270
+	d.Lock()
270 271
 	active := d.activeContainers[c.ID]
272
+	d.Unlock()
271 273
 	if active == nil {
272 274
 		return fmt.Errorf("active container for %s does not exist", c.ID)
273 275
 	}