From 25e93288ba63dd65285dab68935b05b4e077aff5 Mon Sep 17 00:00:00 2001 From: Evan Prodromou Date: Fri, 4 Jul 2008 20:22:07 -0400 Subject: a little more error-checking in the queuedaemon darcs-hash:20080705002207-84dde-c5bc4da7dbca8a32ea4126badb772e99bd4f8bf1.gz --- queuedaemon.php | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) (limited to 'queuedaemon.php') diff --git a/queuedaemon.php b/queuedaemon.php index 91cfff0bf..8da69b9da 100755 --- a/queuedaemon.php +++ b/queuedaemon.php @@ -96,7 +96,15 @@ do { if ($notice) { qd_log(LOG_INFO, 'broadcasting notice ID = ' . $notice->id); # XXX: what to do if broadcast fails? - common_real_broadcast($notice, qd_is_remote($notice)); + $result = common_real_broadcast($notice, qd_is_remote($notice)); + if (!$result) { + qd_log(LOG_WARNING, 'Failed broadcast for notice ID = ' . $notice->id); + $orig = $qi; + $qi->claimed = NULL; + $qi->update($orig); + qd_log(LOG_WARNING, 'Abandoned claim for notice ID = ' . $notice->id); + continue; + } qd_log(LOG_INFO, 'finished broadcasting notice ID = ' . $notice->id); $notice = NULL; } else { @@ -105,7 +113,7 @@ do { $qi->delete(); $qi = NULL; } else { - # qd_clear_old_claims(); + qd_clear_old_claims(); # In busy times, sleep less $sleeptime = 30000000/($in_a_row+1); qd_log(LOG_INFO, 'sleeping ' . $sleeptime . ' microseconds'); -- cgit v1.2.3-54-g00ecf