diff options
| author | Evan Prodromou <evan@prodromou.name> | 2008-09-05 21:55:01 -0400 |
|---|---|---|
| committer | Evan Prodromou <evan@prodromou.name> | 2008-09-05 21:55:01 -0400 |
| commit | 0c71340c9fecfad17d2619dfa44cb669023f8179 (patch) | |
| tree | 1c936b6ffb2361a15a4e71fba2ffed5ce1226b73 /lib/queuehandler.php | |
| parent | 9e8ae6a1e79c51baeca1063810ad96dadeab714d (diff) | |
free and unset DB_DataObjects after we're done with them
darcs-hash:20080906015501-84dde-e787962b9805759224389dd42a211dfa21da3473.gz
Diffstat (limited to 'lib/queuehandler.php')
| -rw-r--r-- | lib/queuehandler.php | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/lib/queuehandler.php b/lib/queuehandler.php index d673f7f94..237df9a7b 100644 --- a/lib/queuehandler.php +++ b/lib/queuehandler.php @@ -87,11 +87,15 @@ class QueueHandler extends Daemon { continue; } $this->log(LOG_INFO, 'finished broadcasting notice ID = ' . $notice->id); + $notice->free(); + unset($notice); $notice = NULL; } else { $this->log(LOG_WARNING, 'queue item for notice that does not exist'); } $qi->delete(); + $qi->free(); + unset($qi); $this->idle(0); } else { $this->clear_old_claims(); @@ -115,6 +119,8 @@ class QueueHandler extends Daemon { $qi->transport = $this->transport(); $qi->whereAdd('now() - claimed > '.CLAIM_TIMEOUT); $qi->update(DB_DATAOBJECT_WHEREADD_ONLY); + $qi->free(); + unset($qi); } function log($level, $msg) { |