diff options
| author | Sven Werchner <Sven.Werchner@t-online.de> | 2014-08-20 12:02:19 +0200 |
|---|---|---|
| committer | Matthias Vogelgesang <matthias.vogelgesang@kit.edu> | 2015-02-11 09:11:46 +0100 |
| commit | cc965010374473cce62ab99a1fcce3189bac522a (patch) | |
| tree | cc3338a6dbbabae647f9212ce8e8c766f150edbc /ufo/ufo-zmq-messenger.c | |
| parent | 586d981a453d405758c7d52006ad3f9aeecac455 (diff) | |
Allow multi input tasks for remote processing
Diffstat (limited to 'ufo/ufo-zmq-messenger.c')
| -rw-r--r-- | ufo/ufo-zmq-messenger.c | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/ufo/ufo-zmq-messenger.c b/ufo/ufo-zmq-messenger.c index e2eab01..ec86e0c 100644 --- a/ufo/ufo-zmq-messenger.c +++ b/ufo/ufo-zmq-messenger.c @@ -223,6 +223,9 @@ ufo_zmq_messenger_send_blocking (UfoMessenger *msger, UfoMessage *reply_msg = ufo_message_new (resp_frame->type, resp_frame->data_size); memcpy (reply_msg->data, resp_frame->data, resp_frame->data_size); + //if (frame->type != 5 && frame->type != 7 && frame->type!=8) + //g_message ("Type: %i \tData_size: %i",(int) frame->type, (int) resp_frame->data_size); + zmq_msg_close (&reply); result = reply_msg; goto finalize; @@ -264,7 +267,6 @@ ufo_zmq_messenger_recv_blocking (UfoMessenger *msger, } DataFrame *frame = zmq_msg_data (&reply); - guint expected_size = (guint) (sizeof (DataFrame) + frame->data_size); if ((guint)size != expected_size) { g_set_error (error, ufo_messenger_error_quark(), |