From e5120274f3def0956d89f1d8b8c41a449fec9693 Mon Sep 17 00:00:00 2001
From: Paul Querna <pquerna@apache.org>
Date: Sat, 17 Mar 2012 09:07:15 -0700
Subject: [PATCH] fixes for actually running

---
 src/spedye_main.c   | 1 +
 src/spedye_master.c | 6 +++---
 src/spedye_worker.c | 4 ++--
 3 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/src/spedye_main.c b/src/spedye_main.c
index 15ebede..7039766 100644
--- a/src/spedye_main.c
+++ b/src/spedye_main.c
@@ -35,6 +35,7 @@ process_args(spedye_conf_t *conf, int argc, char *argv[])
   for (i = 0; i < argc; i++) {
     printf("[%d] =  %s\n", i, argv[i]);
   }
+  conf->worker_count = 10;
   return 0;
 }
 
diff --git a/src/spedye_master.c b/src/spedye_master.c
index ec4021b..33a09a2 100644
--- a/src/spedye_master.c
+++ b/src/spedye_master.c
@@ -26,8 +26,7 @@ master_create_workers(spedye_master_t *m)
 {
   int i;
   for (i = 0; i < m->conf->worker_count; i++) {
-    spedye_worker_t *w = m->workers[i];
-    spedye_worker_create(&w, m);
+    spedye_worker_create(&m->workers[i], m);
   }
 }
 
@@ -48,6 +47,7 @@ master_destroy_workers(spedye_master_t *m)
   for (i = 0; i < m->conf->worker_count; i++) {
     spedye_worker_t *w = m->workers[i];
     spedye_worker_destroy(w);
+    m->workers[i] = NULL;
   }
 }
 
@@ -72,7 +72,7 @@ master_shutdown(uv_async_t* handle, int status)
   spedye_master_t *m = handle->data;
   m->state = SPEDYE_STOPING;
   master_destroy_workers(m);
-  uv_close((uv_handle_t*)&m->master_wakeup, master_shutdown_closecb);
+  uv_close((uv_handle_t*)handle, master_shutdown_closecb);
 }
 
 int
diff --git a/src/spedye_worker.c b/src/spedye_worker.c
index 451636a..1f63f69 100644
--- a/src/spedye_worker.c
+++ b/src/spedye_worker.c
@@ -29,7 +29,7 @@ worker_shutdown(uv_async_t* handle, int status)
 {
   spedye_worker_t *w = handle->data;
   w->state = SPEDYE_STOPING;
-  uv_close((uv_handle_t*)&w->worker_wakeup, worker_shutdown_closecb);
+  uv_close((uv_handle_t*)handle, worker_shutdown_closecb);
 }
 
 static void
@@ -55,7 +55,7 @@ spedye_worker_create(spedye_worker_t **w_out, spedye_master_t *m)
 
   rc = uv_async_init(w->loop, &w->worker_wakeup, worker_shutdown);
 
-  w->worker_wakeup.data = m;
+  w->worker_wakeup.data = w;
 
   *w_out = w;