|
@@ -477,6 +477,9 @@ func (srv *Server) poolAdd(kind, key string) error {
|
|
if _, exists := srv.pullingPool[key]; exists {
|
|
if _, exists := srv.pullingPool[key]; exists {
|
|
return fmt.Errorf("pull %s is already in progress", key)
|
|
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 {
|
|
switch kind {
|
|
case "pull":
|
|
case "pull":
|