1 /* GIO - GLib Input, Output and Streaming Library
3 * Copyright © 2008 Christian Kellner, Samuel Cormier-Iijima
6 * This library is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Lesser General Public
8 * License as published by the Free Software Foundation; either
9 * version 2 of the License, or (at your option) any later version.
11 * This library is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Lesser General Public License for more details.
16 * You should have received a copy of the GNU Lesser General
17 * Public License along with this library; if not, write to the
18 * Free Software Foundation, Inc., 59 Temple Place, Suite 330,
19 * Boston, MA 02111-1307, USA.
21 * Authors: Christian Kellner <gicmo@gnome.org>
22 * Samuel Cormier-Iijima <sciyoshi@gmail.com>
23 * Ryan Lortie <desrt@desrt.ca>
27 #include "gsocketinputstream.h"
30 #include "gsimpleasyncresult.h"
31 #include "gcancellable.h"
32 #include "gpollableinputstream.h"
34 #include "gfiledescriptorbased.h"
36 static void g_socket_input_stream_pollable_iface_init (GPollableInputStreamInterface
*iface
);
38 static void g_socket_input_stream_file_descriptor_based_iface_init (GFileDescriptorBasedIface
*iface
);
41 #define g_socket_input_stream_get_type _g_socket_input_stream_get_type
44 G_DEFINE_TYPE_WITH_CODE (GSocketInputStream
, g_socket_input_stream
, G_TYPE_INPUT_STREAM
,
45 G_IMPLEMENT_INTERFACE (G_TYPE_POLLABLE_INPUT_STREAM
, g_socket_input_stream_pollable_iface_init
)
46 G_IMPLEMENT_INTERFACE (G_TYPE_FILE_DESCRIPTOR_BASED
, g_socket_input_stream_file_descriptor_based_iface_init
)
49 G_DEFINE_TYPE_WITH_CODE (GSocketInputStream
, g_socket_input_stream
, G_TYPE_INPUT_STREAM
,
50 G_IMPLEMENT_INTERFACE (G_TYPE_POLLABLE_INPUT_STREAM
, g_socket_input_stream_pollable_iface_init
)
60 struct _GSocketInputStreamPrivate
64 /* pending operation metadata */
65 GSimpleAsyncResult
*result
;
66 GCancellable
*cancellable
;
72 g_socket_input_stream_get_property (GObject
*object
,
77 GSocketInputStream
*stream
= G_SOCKET_INPUT_STREAM (object
);
82 g_value_set_object (value
, stream
->priv
->socket
);
86 G_OBJECT_WARN_INVALID_PROPERTY_ID (object
, prop_id
, pspec
);
91 g_socket_input_stream_set_property (GObject
*object
,
96 GSocketInputStream
*stream
= G_SOCKET_INPUT_STREAM (object
);
101 stream
->priv
->socket
= g_value_dup_object (value
);
105 G_OBJECT_WARN_INVALID_PROPERTY_ID (object
, prop_id
, pspec
);
110 g_socket_input_stream_finalize (GObject
*object
)
112 GSocketInputStream
*stream
= G_SOCKET_INPUT_STREAM (object
);
114 if (stream
->priv
->socket
)
115 g_object_unref (stream
->priv
->socket
);
117 if (G_OBJECT_CLASS (g_socket_input_stream_parent_class
)->finalize
)
118 (*G_OBJECT_CLASS (g_socket_input_stream_parent_class
)->finalize
) (object
);
122 g_socket_input_stream_read (GInputStream
*stream
,
125 GCancellable
*cancellable
,
128 GSocketInputStream
*input_stream
= G_SOCKET_INPUT_STREAM (stream
);
130 return g_socket_receive_with_blocking (input_stream
->priv
->socket
,
136 g_socket_input_stream_pollable_is_readable (GPollableInputStream
*pollable
)
138 GSocketInputStream
*input_stream
= G_SOCKET_INPUT_STREAM (pollable
);
140 return g_socket_condition_check (input_stream
->priv
->socket
, G_IO_IN
);
144 g_socket_input_stream_pollable_create_source (GPollableInputStream
*pollable
,
145 GCancellable
*cancellable
)
147 GSocketInputStream
*input_stream
= G_SOCKET_INPUT_STREAM (pollable
);
148 GSource
*socket_source
, *pollable_source
;
150 pollable_source
= g_pollable_source_new (G_OBJECT (input_stream
));
151 socket_source
= g_socket_create_source (input_stream
->priv
->socket
,
152 G_IO_IN
, cancellable
);
153 g_source_set_dummy_callback (socket_source
);
154 g_source_add_child_source (pollable_source
, socket_source
);
155 g_source_unref (socket_source
);
157 return pollable_source
;
161 g_socket_input_stream_pollable_read_nonblocking (GPollableInputStream
*pollable
,
166 GSocketInputStream
*input_stream
= G_SOCKET_INPUT_STREAM (pollable
);
168 return g_socket_receive_with_blocking (input_stream
->priv
->socket
,
175 g_socket_input_stream_get_fd (GFileDescriptorBased
*fd_based
)
177 GSocketInputStream
*input_stream
= G_SOCKET_INPUT_STREAM (fd_based
);
179 return g_socket_get_fd (input_stream
->priv
->socket
);
184 g_socket_input_stream_class_init (GSocketInputStreamClass
*klass
)
186 GObjectClass
*gobject_class
= G_OBJECT_CLASS (klass
);
187 GInputStreamClass
*ginputstream_class
= G_INPUT_STREAM_CLASS (klass
);
189 g_type_class_add_private (klass
, sizeof (GSocketInputStreamPrivate
));
191 gobject_class
->finalize
= g_socket_input_stream_finalize
;
192 gobject_class
->get_property
= g_socket_input_stream_get_property
;
193 gobject_class
->set_property
= g_socket_input_stream_set_property
;
195 ginputstream_class
->read_fn
= g_socket_input_stream_read
;
197 g_object_class_install_property (gobject_class
, PROP_SOCKET
,
198 g_param_spec_object ("socket",
200 P_("The socket that this stream wraps"),
201 G_TYPE_SOCKET
, G_PARAM_CONSTRUCT_ONLY
|
202 G_PARAM_READWRITE
| G_PARAM_STATIC_STRINGS
));
207 g_socket_input_stream_file_descriptor_based_iface_init (GFileDescriptorBasedIface
*iface
)
209 iface
->get_fd
= g_socket_input_stream_get_fd
;
214 g_socket_input_stream_pollable_iface_init (GPollableInputStreamInterface
*iface
)
216 iface
->is_readable
= g_socket_input_stream_pollable_is_readable
;
217 iface
->create_source
= g_socket_input_stream_pollable_create_source
;
218 iface
->read_nonblocking
= g_socket_input_stream_pollable_read_nonblocking
;
222 g_socket_input_stream_init (GSocketInputStream
*stream
)
224 stream
->priv
= G_TYPE_INSTANCE_GET_PRIVATE (stream
, G_TYPE_SOCKET_INPUT_STREAM
, GSocketInputStreamPrivate
);
228 _g_socket_input_stream_new (GSocket
*socket
)
230 return G_SOCKET_INPUT_STREAM (g_object_new (G_TYPE_SOCKET_INPUT_STREAM
, "socket", socket
, NULL
));