Fix for File Share Limit Reached Error

cmd/make.go

@@ -208,6 +208,6 @@ func init() {
 		},
 	}
 
-	makeCmd.PersistentFlags().Uint32Var(&rawArgs.quota, "quota-gb", 0, "Specifies the maximum size of the share in gigabytes (GiB), 0 means you accept the file service's default quota.")
+	makeCmd.PersistentFlags().Uint32Var(&rawArgs.quota, "quota-gb", 0, "Specifies the maximum size of the share in gigabytes (GiB), 0 means you accept the file service's default quota. If `ShareSizeLimitReached` error is hit, increase quota and call resume command.")
 	rootCmd.AddCommand(makeCmd)
 }

ste/jobStatusManager.go

@@ -21,6 +21,7 @@
 package ste
 
 import (
+	"sync"
 	"time"
 
 	"github.com/Azure/azure-storage-azcopy/v10/common"
@@ -44,6 +45,7 @@ type jobStatusManager struct {
 	xferDone        chan xferDoneMsg
 	xferDoneDrained chan struct{} // To signal that all xferDone have been processed
 	statusMgrDone   chan struct{} // To signal statusManager has closed
+	once            sync.Once     // Ensure xferDoneDrained is closed once
 }
 
 func (jm *jobMgr) waitToDrainXferDone() {
@@ -134,10 +136,9 @@ func (jm *jobMgr) handleStatusUpdateMessage() {
 		case msg, ok := <-jstm.xferDone:
 			if !ok { // Channel is closed, all transfers have been attended.
 				jstm.xferDone = nil
-
 				// close drainXferDone so that other components can know no further updates happen
 				allXferDoneHandled = true
-				close(jstm.xferDoneDrained)
+				jstm.once.Do(func() { close(jstm.xferDoneDrained) })
 				continue
 			}
 

ste/mgr-JobMgr.go

@@ -717,6 +717,7 @@ func (jm *jobMgr) reportJobPartDoneHandler() {
 				// Inform StatusManager that all parts are done.
 				if jm.jstm.xferDone != nil {
 					close(jm.jstm.xferDone)
+					// jm.jstm.xferDone = nil
 				}
 
 				// Wait  for all XferDone messages to be processed by statusManager. Front end