summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Vogelgesang <matthias.vogelgesang@kit.edu>2015-07-08 15:41:48 +0200
committerMatthias Vogelgesang <matthias.vogelgesang@kit.edu>2015-07-08 15:41:48 +0200
commitf3e0bb64bbd14387d9a936bd7a5b9e36f06b3cb8 (patch)
treebb83bf146fafef2a804c5586508f3493eaf9215a
parent50e3a525a84b2853631b5bbbadaa1798505fadac (diff)
Add better debug output
-rw-r--r--ufo/ufo-daemon.c12
-rw-r--r--ufo/ufo-remote-node.c2
-rw-r--r--ufo/ufo-remote-task.c1
3 files changed, 7 insertions, 8 deletions
diff --git a/ufo/ufo-daemon.c b/ufo/ufo-daemon.c
index f069b64..385c042 100644
--- a/ufo/ufo-daemon.c
+++ b/ufo/ufo-daemon.c
@@ -139,6 +139,9 @@ send_message (UfoMessenger *msger, UfoMessage *msg, const gchar *str)
else
break;
}
+
+ g_debug ("daemon: sent message [type=%i]", msg->type);
+
return TRUE;
}
@@ -337,18 +340,14 @@ handle_send_inputs (UfoDaemon *daemon, UfoMessage *request)
ufo_buffer_resize (priv->input, &requisition);
}
- g_debug ("daemon: received input sized [%zu, %zu, ...]", requisition.dims[0], requisition.dims[1]);
+ g_debug ("daemon: recv input [%zu, %zu, ...]", requisition.dims[0], requisition.dims[1]);
memcpy (ufo_buffer_get_host_array (priv->input, NULL),
base + sizeof (struct Header),
ufo_buffer_get_size (priv->input));
ufo_input_task_release_input_buffer (UFO_INPUT_TASK (priv->input_task), priv->input);
- g_debug ("daemon: released input buffer");
-
- UfoMessage *reply = ufo_message_new (UFO_MESSAGE_ACK, 0);
- send_message (priv->messenger, reply, "inputs reply");
- ufo_message_free (reply);
+ send_ack (priv->messenger);
}
static void
@@ -481,6 +480,7 @@ ufo_daemon_start_impl (UfoDaemon *daemon)
while (wait_for_messages) {
GError *err = NULL;
UfoMessage *message = ufo_messenger_recv_blocking (priv->messenger, &err);
+ g_debug ("daemon: recv message [type=%i]", message->type);
if (err != NULL) {
/* If daemon is stopped, socket will be closed and message_recv will
diff --git a/ufo/ufo-remote-node.c b/ufo/ufo-remote-node.c
index 7f2bea4..b248fd0 100644
--- a/ufo/ufo-remote-node.c
+++ b/ufo/ufo-remote-node.c
@@ -262,7 +262,7 @@ ufo_remote_node_get_result (UfoRemoteNode *node,
ufo_buffer_get_requisition (buffer, &requisition);
- g_debug ("remote: recvd result sized [%zu, %zu, ...]",
+ g_debug ("remote: recv result [%zu, %zu, ...]",
requisition.dims[0], requisition.dims[1]);
ufo_message_free (request);
diff --git a/ufo/ufo-remote-task.c b/ufo/ufo-remote-task.c
index 7d40f35..7076f03 100644
--- a/ufo/ufo-remote-task.c
+++ b/ufo/ufo-remote-task.c
@@ -116,7 +116,6 @@ ufo_remote_task_process (UfoTask *task,
priv = UFO_REMOTE_TASK_GET_PRIVATE (UFO_REMOTE_TASK (task));
ufo_remote_node_get_result (priv->remote, output);
- g_debug ("remote: received result");
return TRUE;
}