1 /* GIO - GLib Input, Output and Streaming Library
3 * Copyright © 2010 Collabora Ltd.
5 * This library is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU Lesser General Public
7 * License as published by the Free Software Foundation; either
8 * version 2 of the License, or (at your option) any later version.
10 * This library is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * Lesser General Public License for more details.
15 * You should have received a copy of the GNU Lesser General
16 * Public License along with this library; if not, write to the
17 * Free Software Foundation, Inc., 59 Temple Place, Suite 330,
18 * Boston, MA 02111-1307, USA.
20 * Authors: Nicolas Dufresne <nicolas.dufresne@colllabora.co.uk>
24 * SECTION:gtcpwrapperconnection
25 * @title: GTcpWrapperConnection
26 * @short_description: Wrapper for non-GSocketConnection-based, GSocket-based GIOStreams
27 * @see_also: #GSocketConnection.
29 * A #GTcpWrapperConnection can be used to wrap a #GIOStream that is
30 * based on a #GSocket, but which is not actually a
31 * #GSocketConnection. This is used by #GSocketClient so that it can
32 * always return a #GSocketConnection, even when the connection it has
33 * actually created is not directly a #GSocketConnection.
40 #include "gtcpwrapperconnection.h"
42 #include "gtcpconnection.h"
45 struct _GTcpWrapperConnectionPrivate
47 GIOStream
*base_io_stream
;
50 G_DEFINE_TYPE_WITH_PRIVATE (GTcpWrapperConnection
, g_tcp_wrapper_connection
, G_TYPE_TCP_CONNECTION
)
59 g_tcp_wrapper_connection_get_input_stream (GIOStream
*io_stream
)
61 GTcpWrapperConnection
*connection
= G_TCP_WRAPPER_CONNECTION (io_stream
);
63 return g_io_stream_get_input_stream (connection
->priv
->base_io_stream
);
66 static GOutputStream
*
67 g_tcp_wrapper_connection_get_output_stream (GIOStream
*io_stream
)
69 GTcpWrapperConnection
*connection
= G_TCP_WRAPPER_CONNECTION (io_stream
);
71 return g_io_stream_get_output_stream (connection
->priv
->base_io_stream
);
75 g_tcp_wrapper_connection_get_property (GObject
*object
,
80 GTcpWrapperConnection
*connection
= G_TCP_WRAPPER_CONNECTION (object
);
84 case PROP_BASE_IO_STREAM
:
85 g_value_set_object (value
, connection
->priv
->base_io_stream
);
89 G_OBJECT_WARN_INVALID_PROPERTY_ID (object
, prop_id
, pspec
);
94 g_tcp_wrapper_connection_set_property (GObject
*object
,
99 GTcpWrapperConnection
*connection
= G_TCP_WRAPPER_CONNECTION (object
);
103 case PROP_BASE_IO_STREAM
:
104 connection
->priv
->base_io_stream
= g_value_dup_object (value
);
108 G_OBJECT_WARN_INVALID_PROPERTY_ID (object
, prop_id
, pspec
);
113 g_tcp_wrapper_connection_finalize (GObject
*object
)
115 GTcpWrapperConnection
*connection
= G_TCP_WRAPPER_CONNECTION (object
);
117 if (connection
->priv
->base_io_stream
)
118 g_object_unref (connection
->priv
->base_io_stream
);
120 G_OBJECT_CLASS (g_tcp_wrapper_connection_parent_class
)->finalize (object
);
124 g_tcp_wrapper_connection_class_init (GTcpWrapperConnectionClass
*klass
)
126 GObjectClass
*gobject_class
= G_OBJECT_CLASS (klass
);
127 GIOStreamClass
*stream_class
= G_IO_STREAM_CLASS (klass
);
129 gobject_class
->set_property
= g_tcp_wrapper_connection_set_property
;
130 gobject_class
->get_property
= g_tcp_wrapper_connection_get_property
;
131 gobject_class
->finalize
= g_tcp_wrapper_connection_finalize
;
133 stream_class
->get_input_stream
= g_tcp_wrapper_connection_get_input_stream
;
134 stream_class
->get_output_stream
= g_tcp_wrapper_connection_get_output_stream
;
136 g_object_class_install_property (gobject_class
,
138 g_param_spec_object ("base-io-stream",
139 P_("Base IO Stream"),
140 P_("The wrapped GIOStream"),
142 G_PARAM_CONSTRUCT_ONLY
|
144 G_PARAM_STATIC_STRINGS
));
148 g_tcp_wrapper_connection_init (GTcpWrapperConnection
*connection
)
150 connection
->priv
= g_tcp_wrapper_connection_get_instance_private (connection
);
154 * g_tcp_wrapper_connection_new:
155 * @base_io_stream: the #GIOStream to wrap
156 * @socket: the #GSocket associated with @base_io_stream
158 * Wraps @base_io_stream and @socket together as a #GSocketConnection.
160 * Return value: the new #GSocketConnection.
165 g_tcp_wrapper_connection_new (GIOStream
*base_io_stream
,
168 g_return_val_if_fail (G_IS_IO_STREAM (base_io_stream
), NULL
);
169 g_return_val_if_fail (G_IS_SOCKET (socket
), NULL
);
170 g_return_val_if_fail (g_socket_get_family (socket
) == G_SOCKET_FAMILY_IPV4
||
171 g_socket_get_family (socket
) == G_SOCKET_FAMILY_IPV6
, NULL
);
172 g_return_val_if_fail (g_socket_get_socket_type (socket
) == G_SOCKET_TYPE_STREAM
, NULL
);
174 return g_object_new (G_TYPE_TCP_WRAPPER_CONNECTION
,
175 "base-io-stream", base_io_stream
,
181 * g_tcp_wrapper_connection_get_base_io_stream:
182 * @conn: a #GTcpWrapperConnection
184 * Get's @conn's base #GIOStream
186 * Return value: (transfer none): @conn's base #GIOStream
189 g_tcp_wrapper_connection_get_base_io_stream (GTcpWrapperConnection
*conn
)
191 g_return_val_if_fail (G_IS_TCP_WRAPPER_CONNECTION (conn
), NULL
);
193 return conn
->priv
->base_io_stream
;