resolve race condition during creation (#219)

Author: zc

cluster/calcium/create.go

@@ -225,10 +225,15 @@ func (c *Calcium) doCreateAndStartContainer(
 			// Copy data to container
 			if len(opts.Data) > 0 {
 				for dst, src := range opts.Data {
-					if _, err = src.Seek(0, io.SeekStart); err != nil {
-						return err
+					mutexSend := func() error {
+						opts.Mux.Lock()
+						defer opts.Mux.Unlock()
+						if _, err = src.Seek(0, io.SeekStart); err != nil {
+							return err
+						}
+						return c.doSendFileToContainer(ctx, node.Engine, container.ID, dst, src, true, true)
 					}
-					if err = c.doSendFileToContainer(ctx, node.Engine, container.ID, dst, src, true, true); err != nil {
+					if err = mutexSend(); err != nil {
 						return err
 					}
 				}

types/options.go

@@ -1,6 +1,9 @@
 package types
 
-import "bytes"
+import (
+	"bytes"
+	"sync"
+)
 
 // DeployOptions is options for deploying
 type DeployOptions struct {
@@ -35,6 +38,8 @@ type DeployOptions struct {
 	AfterCreate  []string                 // AfterCreate support run cmds after create
 	RawArgs      []byte                   // RawArgs for raw args processing
 	Lambda       bool                     // indicate is lambda container or not
+
+	Mux sync.Mutex // used for concurrent send during creation
 }
 
 // Normalize keeps deploy options consistant