Return abandoned jobs to the queue.

If a connection dies and it has a reserved job, put that job back in the queue.
echou · Sep 24, 2007 · 29e2f39 · 29e2f39
1 parent 575a7a7
commit 29e2f39
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/beanstalkd.h b/beanstalkd.h
@@ -30,4 +30,6 @@
 #define CMD_RESERVE_LEN CONSTSTRLEN(CMD_RESERVE)
 #define CMD_STATS_LEN CONSTSTRLEN(CMD_STATS)
 
+int enqueue_job(job j);
+
 #endif /*beanstalk_h*/
diff --git a/conn.c b/conn.c
@@ -6,6 +6,7 @@
 #include "conn.h"
 #include "net.h"
 #include "util.h"
+#include "beanstalkd.h"
 
 conn
 make_conn(int fd, char start_state)
@@ -55,6 +56,7 @@ conn_close(conn c)
  event_del(&c->evq);
 
  close(c->fd);
+ if (c->reserved_job) enqueue_job(c->reserved_job);
 
  free(c);
 }