summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorEvan Prodromou <evan@prodromou.name>2008-07-04 02:20:56 -0400
committerEvan Prodromou <evan@prodromou.name>2008-07-04 02:20:56 -0400
commita742505306e13b41eb180ff3117da07e61f7b9a1 (patch)
tree5dc5463327fb53e9a5369dea85c9ee16def173c3
parent3eb131358726ede1d747fbb009073f3932856ec8 (diff)
log some errors for missed inserts
darcs-hash:20080704062056-84dde-6d5173a345be8fe3e9099e09b438fe69f3d2a1e2.gz
-rw-r--r--lib/util.php9
1 files changed, 6 insertions, 3 deletions
diff --git a/lib/util.php b/lib/util.php
index 3dec09d8e..e62e800dc 100644
--- a/lib/util.php
+++ b/lib/util.php
@@ -819,13 +819,16 @@ function common_broadcast_notice($notice, $remote=false) {
# Stick the notice on the queue
function common_enqueue_notice($notice) {
- common_log(LOG_INFO, 'queueing notice ID = ' . $notice->id);
+ common_log(LOG_INFO, 'start queueing notice ID = ' . $notice->id);
$qi = new Queue_item();
- $qi->query('BEGIN');
$qi->notice_id = $notice->id;
$qi->created = DB_DataObject_Cast::dateTime();
$result = $qi->insert();
- $qi->query('COMMIT');
+ if ($result === FALSE) {
+ common_log_db_error($qi, 'INSERT', __FILE__);
+ return;
+ }
+ common_log(LOG_INFO, 'complete queueing notice ID = ' . $notice->id);
return $result;
}