prevent any kind of operation simultaneously

Upstream-commit: 2db99441c85fdf1e7d468bc02b085d9e1b95704c Component: engine
2013-07-17 20:39:36 +00:00
parent edde9aeb1c
commit fb0bdc7ba8
1 changed files with 3 additions and 0 deletions
--- a/components/engine/server.go
+++ b/components/engine/server.go
@ -477,6 +477,9 @@ func (srv *Server) poolAdd(kind, key string) error {
 	if _, exists := srv.pullingPool[key]; exists {
 		return fmt.Errorf("pull %s is already in progress", key)
 	}
+	if _, exists := srv.pushingPool[key]; exists {
+		return fmt.Errorf("push %s is already in progress", key)
+	}

 	switch kind {
 	case "pull":