notify delay

main.go

@@ -611,7 +611,7 @@ func main_worker(app AppCtx, objUploadChan *util.DChan[string]) {
 					delete(objFailCounter, key)
 					mutexObjFailCounter.Unlock()
 					// Queue the object for upload
-					objUploadChan.Write(key)
+					objUploadChan.DelayedWrite(key, 1*time.Second)
 				}
 				if notifyInfo.Err != nil {
 					logger.Errorf("Bucket notification listener error: %v", notifyInfo.Err)
@@ -788,6 +788,8 @@ func trigger_full_upload(app AppCtx, objToUploadChan chan<- string) {
 			}
 		}
 	}
+
+	logger.Infoln("Full upload trigger finished")
 }
 
 func upload_one_stream(app AppCtx, streamName string) (fullyUploaded bool, err error) {