diff options
| author | Carl-Anton Ingmarsson <ca.ingmarsson@gmail.com> | 2011-08-25 18:34:45 +0200 |
|---|---|---|
| committer | Christian Kellner <gicmo@gnome.org> | 2011-08-25 21:19:57 +0200 |
| commit | 5c1242031634859004ce330581342c273a251d20 (patch) | |
| tree | 6d6b0876dcb9e7a7fb6dc60df677b74e930120bd /daemon/gvfsafpconnection.c | |
| parent | ecc1730d3bfdc11fa07f15893267a7ea054328f1 (diff) | |
| download | gvfs-5c1242031634859004ce330581342c273a251d20.tar.gz | |
afp: start read loop directly on connect
also change g_vfs_afp_connection_get_server_info to take a GSocketConnectable
instead of a GVfsAfpConnection
Diffstat (limited to 'daemon/gvfsafpconnection.c')
| -rw-r--r-- | daemon/gvfsafpconnection.c | 16 |
1 files changed, 5 insertions, 11 deletions
diff --git a/daemon/gvfsafpconnection.c b/daemon/gvfsafpconnection.c index 1551d82e..96cea8e1 100644 --- a/daemon/gvfsafpconnection.c +++ b/daemon/gvfsafpconnection.c @@ -585,7 +585,6 @@ struct _GVfsAfpConnectionPrivate DSIHeader write_dsi_header; /* read loop */ - gboolean read_loop_running; DSIHeader read_dsi_header; char *reply_buf; gboolean free_reply_buf; @@ -652,11 +651,6 @@ run_loop (GVfsAfpConnection *afp_connection) priv->send_loop_running = TRUE; send_request (afp_connection); } - if (!priv->read_loop_running) - { - priv->read_loop_running = TRUE; - read_reply (afp_connection); - } } typedef struct @@ -1540,16 +1534,17 @@ g_vfs_afp_connection_open (GVfsAfpConnection *afp_connection, } g_free (reply); + /* Start readloop */ + read_reply (afp_connection); + return TRUE; } GVfsAfpReply * -g_vfs_afp_connection_get_server_info (GVfsAfpConnection *afp_connection, +g_vfs_afp_connection_get_server_info (GSocketConnectable *addr, GCancellable *cancellable, GError **error) { - GVfsAfpConnectionPrivate *priv = afp_connection->priv; - GSocketClient *client; GIOStream *conn; gboolean res; @@ -1557,7 +1552,7 @@ g_vfs_afp_connection_get_server_info (GVfsAfpConnection *afp_connection, char *data; client = g_socket_client_new (); - conn = G_IO_STREAM (g_socket_client_connect (client, priv->addr, cancellable, error)); + conn = G_IO_STREAM (g_socket_client_connect (client, addr, cancellable, error)); g_object_unref (client); if (!conn) @@ -1620,7 +1615,6 @@ g_vfs_afp_connection_init (GVfsAfpConnection *afp_connection) NULL, (GDestroyNotify)free_request_data); priv->send_loop_running = FALSE; - priv->read_loop_running = FALSE; } static void |