a little more error-checking in the queuedaemon

darcs-hash:20080705002207-84dde-c5bc4da7dbca8a32ea4126badb772e99bd4f8bf1.gz

1 files changed, 10 insertions, 2 deletions

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');