|
Packit |
ae235b |
/* GIO - GLib Input, Output and Streaming Library
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Copyright (C) 2010 Collabora, Ltd.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* This library is free software; you can redistribute it and/or
|
|
Packit |
ae235b |
* modify it under the terms of the GNU Lesser General Public
|
|
Packit |
ae235b |
* License as published by the Free Software Foundation; either
|
|
Packit |
ae235b |
* version 2.1 of the License, or (at your option) any later version.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* This library is distributed in the hope that it will be useful,
|
|
Packit |
ae235b |
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
Packit |
ae235b |
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
Packit |
ae235b |
* Lesser General Public License for more details.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* You should have received a copy of the GNU Lesser General
|
|
Packit |
ae235b |
* Public License along with this library; if not, see <http://www.gnu.org/licenses/>.
|
|
Packit |
ae235b |
*
|
|
Packit |
ae235b |
* Author: Nicolas Dufresne <nicolas.dufresne@collabora.co.uk>
|
|
Packit |
ae235b |
*/
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
#include "config.h"
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
#include "gsocks4aproxy.h"
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
#include <string.h>
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
#include "giomodule.h"
|
|
Packit |
ae235b |
#include "giomodule-priv.h"
|
|
Packit |
ae235b |
#include "giostream.h"
|
|
Packit |
ae235b |
#include "ginetaddress.h"
|
|
Packit |
ae235b |
#include "ginputstream.h"
|
|
Packit |
ae235b |
#include "glibintl.h"
|
|
Packit |
ae235b |
#include "goutputstream.h"
|
|
Packit |
ae235b |
#include "gproxy.h"
|
|
Packit |
ae235b |
#include "gproxyaddress.h"
|
|
Packit |
ae235b |
#include "gtask.h"
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
#define SOCKS4_VERSION 4
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
#define SOCKS4_CMD_CONNECT 1
|
|
Packit |
ae235b |
#define SOCKS4_CMD_BIND 2
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
#define SOCKS4_MAX_LEN 255
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
#define SOCKS4_REP_VERSION 0
|
|
Packit |
ae235b |
#define SOCKS4_REP_GRANTED 90
|
|
Packit |
ae235b |
#define SOCKS4_REP_REJECTED 91
|
|
Packit |
ae235b |
#define SOCKS4_REP_NO_IDENT 92
|
|
Packit |
ae235b |
#define SOCKS4_REP_BAD_IDENT 93
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void g_socks4a_proxy_iface_init (GProxyInterface *proxy_iface);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
#define g_socks4a_proxy_get_type _g_socks4a_proxy_get_type
|
|
Packit |
ae235b |
G_DEFINE_TYPE_WITH_CODE (GSocks4aProxy, g_socks4a_proxy, G_TYPE_OBJECT,
|
|
Packit |
ae235b |
G_IMPLEMENT_INTERFACE (G_TYPE_PROXY,
|
|
Packit |
ae235b |
g_socks4a_proxy_iface_init)
|
|
Packit |
ae235b |
_g_io_modules_ensure_extension_points_registered ();
|
|
Packit |
ae235b |
g_io_extension_point_implement (G_PROXY_EXTENSION_POINT_NAME,
|
|
Packit |
ae235b |
g_define_type_id,
|
|
Packit |
ae235b |
"socks4a",
|
|
Packit |
ae235b |
0))
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void
|
|
Packit |
ae235b |
g_socks4a_proxy_finalize (GObject *object)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
/* must chain up */
|
|
Packit |
ae235b |
G_OBJECT_CLASS (g_socks4a_proxy_parent_class)->finalize (object);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void
|
|
Packit |
ae235b |
g_socks4a_proxy_init (GSocks4aProxy *proxy)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
proxy->supports_hostname = TRUE;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
/* |-> SOCKSv4a only
|
|
Packit |
ae235b |
* +----+----+----+----+----+----+----+----+----+----+....+----+------+....+------+
|
|
Packit |
ae235b |
* | VN | CD | DSTPORT | DSTIP | USERID |NULL| HOST | | NULL |
|
|
Packit |
ae235b |
* +----+----+----+----+----+----+----+----+----+----+....+----+------+....+------+
|
|
Packit |
ae235b |
* 1 1 2 4 variable 1 variable
|
|
Packit |
ae235b |
*/
|
|
Packit |
ae235b |
#define SOCKS4_CONN_MSG_LEN (9 + SOCKS4_MAX_LEN * 2)
|
|
Packit |
ae235b |
static gint
|
|
Packit |
ae235b |
set_connect_msg (guint8 *msg,
|
|
Packit |
ae235b |
const gchar *hostname,
|
|
Packit |
ae235b |
guint16 port,
|
|
Packit |
ae235b |
const char *username,
|
|
Packit |
ae235b |
GError **error)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GInetAddress *addr;
|
|
Packit |
ae235b |
guint len = 0;
|
|
Packit |
ae235b |
gsize addr_len;
|
|
Packit |
ae235b |
gboolean is_ip;
|
|
Packit |
ae235b |
const gchar *ip;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
msg[len++] = SOCKS4_VERSION;
|
|
Packit |
ae235b |
msg[len++] = SOCKS4_CMD_CONNECT;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
guint16 hp = g_htons (port);
|
|
Packit |
ae235b |
memcpy (msg + len, &hp, 2);
|
|
Packit |
ae235b |
len += 2;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
is_ip = g_hostname_is_ip_address (hostname);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (is_ip)
|
|
Packit |
ae235b |
ip = hostname;
|
|
Packit |
ae235b |
else
|
|
Packit |
ae235b |
ip = "0.0.0.1";
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
addr = g_inet_address_new_from_string (ip);
|
|
Packit |
ae235b |
addr_len = g_inet_address_get_native_size (addr);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (addr_len != 4)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
g_set_error (error, G_IO_ERROR, G_IO_ERROR_PROXY_FAILED,
|
|
Packit |
ae235b |
_("SOCKSv4 does not support IPv6 address ā%sā"),
|
|
Packit |
ae235b |
ip);
|
|
Packit |
ae235b |
g_object_unref (addr);
|
|
Packit |
ae235b |
return -1;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
memcpy (msg + len, g_inet_address_to_bytes (addr), addr_len);
|
|
Packit |
ae235b |
len += addr_len;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
g_object_unref (addr);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (username)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
gsize user_len = strlen (username);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (user_len > SOCKS4_MAX_LEN)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
g_set_error_literal (error, G_IO_ERROR, G_IO_ERROR_PROXY_FAILED,
|
|
Packit |
ae235b |
_("Username is too long for SOCKSv4 protocol"));
|
|
Packit |
ae235b |
return -1;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
memcpy (msg + len, username, user_len);
|
|
Packit |
ae235b |
len += user_len;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
msg[len++] = '\0';
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (!is_ip)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
gsize host_len = strlen (hostname);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (host_len > SOCKS4_MAX_LEN)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
g_set_error (error, G_IO_ERROR, G_IO_ERROR_PROXY_FAILED,
|
|
Packit |
ae235b |
_("Hostname ā%sā is too long for SOCKSv4 protocol"),
|
|
Packit |
ae235b |
hostname);
|
|
Packit |
ae235b |
return -1;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
memcpy (msg + len, hostname, host_len);
|
|
Packit |
ae235b |
len += host_len;
|
|
Packit |
ae235b |
msg[len++] = '\0';
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
return len;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
/*
|
|
Packit |
ae235b |
* +----+----+----+----+----+----+----+----+
|
|
Packit |
ae235b |
* | VN | CD | DSTPORT | DSTIP |
|
|
Packit |
ae235b |
* +----+----+----+----+----+----+----+----+
|
|
Packit |
ae235b |
* 1 1 2 4
|
|
Packit |
ae235b |
*/
|
|
Packit |
ae235b |
#define SOCKS4_CONN_REP_LEN 8
|
|
Packit |
ae235b |
static gboolean
|
|
Packit |
ae235b |
parse_connect_reply (const guint8 *data, GError **error)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
if (data[0] != SOCKS4_REP_VERSION)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
g_set_error_literal (error, G_IO_ERROR, G_IO_ERROR_PROXY_FAILED,
|
|
Packit |
ae235b |
_("The server is not a SOCKSv4 proxy server."));
|
|
Packit |
ae235b |
return FALSE;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (data[1] != SOCKS4_REP_GRANTED)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
g_set_error_literal (error, G_IO_ERROR, G_IO_ERROR_PROXY_FAILED,
|
|
Packit |
ae235b |
_("Connection through SOCKSv4 server was rejected"));
|
|
Packit |
ae235b |
return FALSE;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
return TRUE;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static GIOStream *
|
|
Packit |
ae235b |
g_socks4a_proxy_connect (GProxy *proxy,
|
|
Packit |
ae235b |
GIOStream *io_stream,
|
|
Packit |
ae235b |
GProxyAddress *proxy_address,
|
|
Packit |
ae235b |
GCancellable *cancellable,
|
|
Packit |
ae235b |
GError **error)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GInputStream *in;
|
|
Packit |
ae235b |
GOutputStream *out;
|
|
Packit |
ae235b |
const gchar *hostname;
|
|
Packit |
ae235b |
guint16 port;
|
|
Packit |
ae235b |
const gchar *username;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
hostname = g_proxy_address_get_destination_hostname (proxy_address);
|
|
Packit |
ae235b |
port = g_proxy_address_get_destination_port (proxy_address);
|
|
Packit |
ae235b |
username = g_proxy_address_get_username (proxy_address);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
in = g_io_stream_get_input_stream (io_stream);
|
|
Packit |
ae235b |
out = g_io_stream_get_output_stream (io_stream);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
/* Send SOCKS4 connection request */
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
guint8 msg[SOCKS4_CONN_MSG_LEN];
|
|
Packit |
ae235b |
gint len;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
len = set_connect_msg (msg, hostname, port, username, error);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (len < 0)
|
|
Packit |
ae235b |
goto error;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (!g_output_stream_write_all (out, msg, len, NULL,
|
|
Packit |
ae235b |
cancellable, error))
|
|
Packit |
ae235b |
goto error;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
/* Read SOCKS4 response */
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
guint8 data[SOCKS4_CONN_REP_LEN];
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (!g_input_stream_read_all (in, data, SOCKS4_CONN_REP_LEN, NULL,
|
|
Packit |
ae235b |
cancellable, error))
|
|
Packit |
ae235b |
goto error;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (!parse_connect_reply (data, error))
|
|
Packit |
ae235b |
goto error;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
return g_object_ref (io_stream);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
error:
|
|
Packit |
ae235b |
return NULL;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
typedef struct
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GIOStream *io_stream;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
/* For connecting */
|
|
Packit |
ae235b |
guint8 *buffer;
|
|
Packit |
ae235b |
gssize length;
|
|
Packit |
ae235b |
gssize offset;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
} ConnectAsyncData;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void connect_msg_write_cb (GObject *source,
|
|
Packit |
ae235b |
GAsyncResult *result,
|
|
Packit |
ae235b |
gpointer user_data);
|
|
Packit |
ae235b |
static void connect_reply_read_cb (GObject *source,
|
|
Packit |
ae235b |
GAsyncResult *result,
|
|
Packit |
ae235b |
gpointer user_data);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void
|
|
Packit |
ae235b |
free_connect_data (ConnectAsyncData *data)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
g_object_unref (data->io_stream);
|
|
Packit |
ae235b |
g_slice_free (ConnectAsyncData, data);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void
|
|
Packit |
ae235b |
do_read (GAsyncReadyCallback callback, GTask *task, ConnectAsyncData *data)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GInputStream *in;
|
|
Packit |
ae235b |
in = g_io_stream_get_input_stream (data->io_stream);
|
|
Packit |
ae235b |
g_input_stream_read_async (in,
|
|
Packit |
ae235b |
data->buffer + data->offset,
|
|
Packit |
ae235b |
data->length - data->offset,
|
|
Packit |
ae235b |
g_task_get_priority (task),
|
|
Packit |
ae235b |
g_task_get_cancellable (task),
|
|
Packit |
ae235b |
callback, task);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void
|
|
Packit |
ae235b |
do_write (GAsyncReadyCallback callback, GTask *task, ConnectAsyncData *data)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GOutputStream *out;
|
|
Packit |
ae235b |
out = g_io_stream_get_output_stream (data->io_stream);
|
|
Packit |
ae235b |
g_output_stream_write_async (out,
|
|
Packit |
ae235b |
data->buffer + data->offset,
|
|
Packit |
ae235b |
data->length - data->offset,
|
|
Packit |
ae235b |
g_task_get_priority (task),
|
|
Packit |
ae235b |
g_task_get_cancellable (task),
|
|
Packit |
ae235b |
callback, task);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void
|
|
Packit |
ae235b |
g_socks4a_proxy_connect_async (GProxy *proxy,
|
|
Packit |
ae235b |
GIOStream *io_stream,
|
|
Packit |
ae235b |
GProxyAddress *proxy_address,
|
|
Packit |
ae235b |
GCancellable *cancellable,
|
|
Packit |
ae235b |
GAsyncReadyCallback callback,
|
|
Packit |
ae235b |
gpointer user_data)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GError *error = NULL;
|
|
Packit |
ae235b |
GTask *task;
|
|
Packit |
ae235b |
ConnectAsyncData *data;
|
|
Packit |
ae235b |
const gchar *hostname;
|
|
Packit |
ae235b |
guint16 port;
|
|
Packit |
ae235b |
const gchar *username;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
data = g_slice_new0 (ConnectAsyncData);
|
|
Packit |
ae235b |
data->io_stream = g_object_ref (io_stream);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
task = g_task_new (proxy, cancellable, callback, user_data);
|
|
Packit |
ae235b |
g_task_set_source_tag (task, g_socks4a_proxy_connect_async);
|
|
Packit |
ae235b |
g_task_set_task_data (task, data, (GDestroyNotify) free_connect_data);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
hostname = g_proxy_address_get_destination_hostname (proxy_address);
|
|
Packit |
ae235b |
port = g_proxy_address_get_destination_port (proxy_address);
|
|
Packit |
ae235b |
username = g_proxy_address_get_username (proxy_address);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
data->buffer = g_malloc0 (SOCKS4_CONN_MSG_LEN);
|
|
Packit |
ae235b |
data->length = set_connect_msg (data->buffer,
|
|
Packit |
ae235b |
hostname, port, username,
|
|
Packit |
ae235b |
&error);
|
|
Packit |
ae235b |
data->offset = 0;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (data->length < 0)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
g_task_return_error (task, error);
|
|
Packit |
ae235b |
g_object_unref (task);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
else
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
do_write (connect_msg_write_cb, task, data);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void
|
|
Packit |
ae235b |
connect_msg_write_cb (GObject *source,
|
|
Packit |
ae235b |
GAsyncResult *result,
|
|
Packit |
ae235b |
gpointer user_data)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GTask *task = user_data;
|
|
Packit |
ae235b |
ConnectAsyncData *data = g_task_get_task_data (task);
|
|
Packit |
ae235b |
GError *error = NULL;
|
|
Packit |
ae235b |
gssize written;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
written = g_output_stream_write_finish (G_OUTPUT_STREAM (source),
|
|
Packit |
ae235b |
result, &error);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (written < 0)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
g_task_return_error (task, error);
|
|
Packit |
ae235b |
g_object_unref (task);
|
|
Packit |
ae235b |
return;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
data->offset += written;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (data->offset == data->length)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
g_free (data->buffer);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
data->buffer = g_malloc0 (SOCKS4_CONN_REP_LEN);
|
|
Packit |
ae235b |
data->length = SOCKS4_CONN_REP_LEN;
|
|
Packit |
ae235b |
data->offset = 0;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
do_read (connect_reply_read_cb, task, data);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
else
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
do_write (connect_msg_write_cb, task, data);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void
|
|
Packit |
ae235b |
connect_reply_read_cb (GObject *source,
|
|
Packit |
ae235b |
GAsyncResult *result,
|
|
Packit |
ae235b |
gpointer user_data)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GTask *task = user_data;
|
|
Packit |
ae235b |
ConnectAsyncData *data = g_task_get_task_data (task);
|
|
Packit |
ae235b |
GError *error = NULL;
|
|
Packit |
ae235b |
gssize read;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
read = g_input_stream_read_finish (G_INPUT_STREAM (source),
|
|
Packit |
ae235b |
result, &error);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (read < 0)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
g_task_return_error (task, error);
|
|
Packit |
ae235b |
g_object_unref (task);
|
|
Packit |
ae235b |
return;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
data->offset += read;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
if (data->offset == data->length)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
if (!parse_connect_reply (data->buffer, &error))
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
g_task_return_error (task, error);
|
|
Packit |
ae235b |
g_object_unref (task);
|
|
Packit |
ae235b |
return;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
else
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
g_task_return_pointer (task, g_object_ref (data->io_stream), g_object_unref);
|
|
Packit |
ae235b |
g_object_unref (task);
|
|
Packit |
ae235b |
return;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
else
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
do_read (connect_reply_read_cb, task, data);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static GIOStream *g_socks4a_proxy_connect_finish (GProxy *proxy,
|
|
Packit |
ae235b |
GAsyncResult *result,
|
|
Packit |
ae235b |
GError **error);
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static GIOStream *
|
|
Packit |
ae235b |
g_socks4a_proxy_connect_finish (GProxy *proxy,
|
|
Packit |
ae235b |
GAsyncResult *result,
|
|
Packit |
ae235b |
GError **error)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
return g_task_propagate_pointer (G_TASK (result), error);
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static gboolean
|
|
Packit |
ae235b |
g_socks4a_proxy_supports_hostname (GProxy *proxy)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
return G_SOCKS4A_PROXY (proxy)->supports_hostname;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void
|
|
Packit |
ae235b |
g_socks4a_proxy_class_init (GSocks4aProxyClass *class)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
GObjectClass *object_class;
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
object_class = (GObjectClass *) class;
|
|
Packit |
ae235b |
object_class->finalize = g_socks4a_proxy_finalize;
|
|
Packit |
ae235b |
}
|
|
Packit |
ae235b |
|
|
Packit |
ae235b |
static void
|
|
Packit |
ae235b |
g_socks4a_proxy_iface_init (GProxyInterface *proxy_iface)
|
|
Packit |
ae235b |
{
|
|
Packit |
ae235b |
proxy_iface->connect = g_socks4a_proxy_connect;
|
|
Packit |
ae235b |
proxy_iface->connect_async = g_socks4a_proxy_connect_async;
|
|
Packit |
ae235b |
proxy_iface->connect_finish = g_socks4a_proxy_connect_finish;
|
|
Packit |
ae235b |
proxy_iface->supports_hostname = g_socks4a_proxy_supports_hostname;
|
|
Packit |
ae235b |
}
|