localtime_r(&start_date, &bdt);
if (cct->_conf->rgw_lc_debug_interval > 0) {
- /* We're debugging, so say we can run */
- return false;
+ if (now - start_date < cct->_conf->rgw_lc_debug_interval)
+ return true;
+ else
+ return false;
}
bdt.tm_hour = 0;
l.unlock(&store->lc_pool_ctx, obj_names[index]);
ret = bucket_lc_process(entry.first);
bucket_lc_post(index, max_lock_secs, entry, ret);
- return 0;
+ }while(1);
+
exit:
l.unlock(&store->lc_pool_ctx, obj_names[index]);
return 0;
-
- }while(1);
-
}
void RGWLC::start_processor()