[gvfs] afp: print some debug upon DSI_CLOSE_SESSION and DSI_TICKLE
- From: Christian Kellner <gicmo src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [gvfs] afp: print some debug upon DSI_CLOSE_SESSION and DSI_TICKLE
- Date: Thu, 25 Aug 2011 19:26:45 +0000 (UTC)
commit 5f43cc1871b14d6c46f32cbfb2d31dc163a1e4d2
Author: Carl-Anton Ingmarsson <ca ingmarsson gmail com>
Date: Sat Jul 23 01:27:08 2011 +0200
afp: print some debug upon DSI_CLOSE_SESSION and DSI_TICKLE
daemon/gvfsafpconnection.c | 85 +++++++++++++++++++++++++++-----------------
1 files changed, 52 insertions(+), 33 deletions(-)
---
diff --git a/daemon/gvfsafpconnection.c b/daemon/gvfsafpconnection.c
index 5b30047..00c1969 100644
--- a/daemon/gvfsafpconnection.c
+++ b/daemon/gvfsafpconnection.c
@@ -634,50 +634,69 @@ dispatch_reply (GVfsAfpConnection *afp_connection)
GVfsAfpConnectionPrivate *priv = afp_connection->priv;
DSIHeader *dsi_header = &priv->read_dsi_header;
- RequestData *req_data;
-
- if (dsi_header->command == DSI_TICKLE)
+ switch (dsi_header->command)
{
- RequestData *req_data;
+ case DSI_CLOSE_SESSION:
+ {
+ g_warning ("Server closed session\n");
+ break;
+ }
- /* Send back a tickle message */
- req_data = g_slice_new0 (RequestData);
- req_data->type = REQUEST_TYPE_TICKLE;
+ case DSI_TICKLE:
+ {
+ RequestData *req_data;
- g_queue_push_head (priv->request_queue, req_data);
- run_loop (afp_connection);
- }
+ g_debug ("Received tickle from server\n");
+
+ /* Send back a tickle message */
+ req_data = g_slice_new0 (RequestData);
+ req_data->type = REQUEST_TYPE_TICKLE;
- else if (dsi_header->command == DSI_ATTENTION)
- {
- guint8 attention_code;
+ g_queue_push_head (priv->request_queue, req_data);
+ run_loop (afp_connection);
+ break;
+ }
- attention_code = priv->data[0] >> 4;
+ case DSI_ATTENTION:
+ {
+ guint8 attention_code;
- g_signal_emit (afp_connection, signals[ATTENTION], 0, attention_code);
- g_free (priv->data);
- }
-
- else if (dsi_header->command == DSI_COMMAND || dsi_header->command == DSI_WRITE)
- {
- req_data = g_hash_table_lookup (priv->request_hash,
- GUINT_TO_POINTER (priv->read_dsi_header.requestID));
- if (req_data)
+ attention_code = priv->data[0] >> 4;
+
+ g_signal_emit (afp_connection, signals[ATTENTION], 0, attention_code);
+ g_free (priv->data);
+ break;
+ }
+
+ case DSI_COMMAND:
+ case DSI_WRITE:
{
- GVfsAfpReply *reply;
+ RequestData *req_data;
+
+ req_data = g_hash_table_lookup (priv->request_hash,
+ GUINT_TO_POINTER (priv->read_dsi_header.requestID));
+ if (req_data)
+ {
+ GVfsAfpReply *reply;
- reply = g_vfs_afp_reply_new (priv->read_dsi_header.errorCode, priv->data,
- priv->read_dsi_header.totalDataLength);
+ reply = g_vfs_afp_reply_new (priv->read_dsi_header.errorCode, priv->data,
+ priv->read_dsi_header.totalDataLength);
- g_simple_async_result_set_op_res_gpointer (req_data->simple, reply,
- g_object_unref);
- g_simple_async_result_complete (req_data->simple);
+ g_simple_async_result_set_op_res_gpointer (req_data->simple, reply,
+ g_object_unref);
+ g_simple_async_result_complete (req_data->simple);
+
+ g_hash_table_remove (priv->request_hash, GUINT_TO_POINTER (priv->read_dsi_header.requestID));
+ }
+ else
+ g_free (priv->data);
- g_hash_table_remove (priv->request_hash, GUINT_TO_POINTER (priv->read_dsi_header.requestID));
+ break;
}
+
+ default:
+ g_assert_not_reached ();
}
- else
- g_free (priv->data);
}
static void
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]