Merge pull request #95 from hintjens/master

Fixed HWM=1 on thread pipes

Author: miniway

src/zhash.c

@@ -379,7 +379,8 @@ zhash_size (zhash_t *self)
 //  --------------------------------------------------------------------------
 //  Make copy of hash table
 //  Does not copy items themselves. Rebuilds new table so may be slow on 
-//  very large tables.
+//  very large tables. NOTE: only works with item values that are strings
+//  since there's no other way to know how to duplicate the item value.
 
 zhash_t *
 zhash_dup (zhash_t *self)
@@ -393,7 +394,8 @@ zhash_dup (zhash_t *self)
         for (index = 0; index != self->limit; index++) {
             item_t *item = self->items [index];
             while (item) {
-                zhash_insert (copy, item->key, item->value);
+                zhash_insert (copy, item->key, strdup (item->value));
+                zhash_freefn (copy, item->key, free);
                 item = item->next;
             }
         }

src/zthread.c

@@ -199,7 +199,6 @@ zthread_fork (zctx_t *ctx, zthread_attached_fn *thread_fn, void *args)
     shim->pipe = zsocket_new (shim->ctx, ZMQ_PAIR);
     if (!shim->pipe)
         return NULL;
-    zsocket_set_hwm (shim->pipe, 1);
     zsocket_connect (shim->pipe, "inproc://zctx-pipe-%p", pipe);
 
     s_thread_start (shim);