|
@@ -377,7 +377,7 @@ func main_worker(app AppCtx, objUploadChan *util.DChan[string]) {
|
|
delete(objFailCounter, key)
|
|
delete(objFailCounter, key)
|
|
mutexObjFailCounter.Unlock()
|
|
mutexObjFailCounter.Unlock()
|
|
// Queue the object for upload
|
|
// Queue the object for upload
|
|
- objUploadChan.Write(key)
|
|
|
|
|
|
+ objUploadChan.DelayedWrite(key, 1*time.Second)
|
|
}
|
|
}
|
|
if notifyInfo.Err != nil {
|
|
if notifyInfo.Err != nil {
|
|
logger.Errorf("Bucket notification listener error: %v", notifyInfo.Err)
|
|
logger.Errorf("Bucket notification listener error: %v", notifyInfo.Err)
|
|
@@ -554,6 +554,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) {
|
|
func upload_one_stream(app AppCtx, streamName string) (fullyUploaded bool, err error) {
|