[FIX] Don't hang in md_input_zeromq_handle_event while loop

Lukasz Baj · Lukasz Baj · commit 0fe29da72798 · 2017-07-17T10:54:06.000+02:00
We should check zmq_events every in every loop run.
diff --git a/metadata_input_zeromq.c b/metadata_input_zeromq.c
@@ -153,9 +153,10 @@ static void md_input_zeromq_handle_event(void *ptr, int32_t fd, uint32_t events)
             default:
                 META_PRINT(miz->parent->logfile, "Unknown event type\n");
                 break;
-    }
+        }
 
-    json_object_put(zmqh_obj);
+        json_object_put(zmqh_obj);
+        zmq_getsockopt(miz->zmq_socket, ZMQ_EVENTS, &zmq_events, &events_len);
     }
 }
 

Original file line number	Diff line number	Diff line change
`@@ -153,9 +153,10 @@ static void md_input_zeromq_handle_event(void *ptr, int32_t fd, uint32_t events)`
`153`	`153`	`default:`
`154`	`154`	`META_PRINT(miz->parent->logfile, "Unknown event type\n");`
`155`	`155`	`break;`
`156`		`- }`
	`156`	`+ }`
`157`	`157`
`158`		`- json_object_put(zmqh_obj);`
	`158`	`+ json_object_put(zmqh_obj);`
	`159`	`+ zmq_getsockopt(miz->zmq_socket, ZMQ_EVENTS, &zmq_events, &events_len);`
`159`	`160`	`}`
`160`	`161`	`}`
`161`	`162`