mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-04-26 06:54:49 +00:00
Code Issues 1 Projects Releases Wiki Activity

tcpserver{sink,src}: improve docs and property strings

Browse source 
And some minor clean-ups.
This commit is contained in:
Tim-Philipp Müller 2012-10-19 18:29:00 +01:00
parent d2f1d82778
commit 0ea6526770
2 changed files with 26 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
gst/tcp/gsttcpserversink.c
View file

@ -88,12 +88,22 @@ gst_tcp_server_sink_class_init (GstTCPServerSinkClass * klass)
gobject_class->finalize = gst_tcp_server_sink_finalize; gobject_class->finalize = gst_tcp_server_sink_finalize;
g_object_class_install_property (gobject_class, PROP_HOST, g_object_class_install_property (gobject_class, PROP_HOST,
g_param_spec_string ("host", "host", "The host/IP to send the packets to", g_param_spec_string ("host", "host", "The host/IP to listen on",
TCP_DEFAULT_HOST, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); TCP_DEFAULT_HOST, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
g_object_class_install_property (gobject_class, PROP_PORT, g_object_class_install_property (gobject_class, PROP_PORT,
g_param_spec_int ("port", "port", "The port to send the packets to", g_param_spec_int ("port", "port",
"The port to listen to (0=random available port)",
0, TCP_HIGHEST_PORT, TCP_DEFAULT_PORT, 0, TCP_HIGHEST_PORT, TCP_DEFAULT_PORT,
G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
/**
* GstTCPServerSink:current-port:
*
* The port number the socket is currently bound to. Applications can use
* this property to retrieve the port number actually bound to in case
* the port requested was 0 (=allocate a random available port).
*
* Since: 1.0.2
**/
g_object_class_install_property (gobject_class, PROP_CURRENT_PORT, g_object_class_install_property (gobject_class, PROP_CURRENT_PORT,
g_param_spec_int ("current-port", "current-port", g_param_spec_int ("current-port", "current-port",
"The port number the socket is currently bound to", 0, "The port number the socket is currently bound to", 0,
@ -185,15 +195,12 @@ static void
gst_tcp_server_sink_removed (GstMultiHandleSink * sink, gst_tcp_server_sink_removed (GstMultiHandleSink * sink,
GstMultiSinkHandle handle) GstMultiSinkHandle handle)
{ {
#ifndef GST_DISABLE_GST_DEBUG
GstTCPServerSink *this = GST_TCP_SERVER_SINK (sink);
#endif
GError *err = NULL; GError *err = NULL;
GST_DEBUG_OBJECT (this, "closing socket"); GST_DEBUG_OBJECT (sink, "closing socket");
if (!g_socket_close (handle.socket, &err)) { if (!g_socket_close (handle.socket, &err)) {
GST_ERROR_OBJECT (this, "Failed to close socket: %s", err->message); GST_ERROR_OBJECT (sink, "Failed to close socket: %s", err->message);
g_clear_error (&err); g_clear_error (&err);
} }
} }
@ -224,7 +231,6 @@ gst_tcp_server_sink_set_property (GObject * object, guint prop_id,
{ {
GstTCPServerSink *sink; GstTCPServerSink *sink;
g_return_if_fail (GST_IS_TCP_SERVER_SINK (object));
sink = GST_TCP_SERVER_SINK (object); sink = GST_TCP_SERVER_SINK (object);
switch (prop_id) { switch (prop_id) {
@ -251,7 +257,6 @@ gst_tcp_server_sink_get_property (GObject * object, guint prop_id,
{ {
GstTCPServerSink *sink; GstTCPServerSink *sink;
g_return_if_fail (GST_IS_TCP_SERVER_SINK (object));
sink = GST_TCP_SERVER_SINK (object); sink = GST_TCP_SERVER_SINK (object);
switch (prop_id) { switch (prop_id) {
@ -335,9 +340,7 @@ gst_tcp_server_sink_init_send (GstMultiHandleSink * parent)
if (!g_socket_listen (this->server_socket, &err)) if (!g_socket_listen (this->server_socket, &err))
goto listen_failed; goto listen_failed;
GST_DEBUG_OBJECT (this, GST_DEBUG_OBJECT (this, "listened on server socket %p", this->server_socket);
"listened on server socket %p, returning from connection setup",
this->server_socket);
if (this->server_port == 0) { if (this->server_port == 0) {
saddr = g_socket_get_local_address (this->server_socket, NULL); saddr = g_socket_get_local_address (this->server_socket, NULL);

12
gst/tcp/gsttcpserversrc.c
View file

@ -102,9 +102,19 @@ gst_tcp_server_src_class_init (GstTCPServerSrcClass * klass)
g_param_spec_string ("host", "Host", "The hostname to listen as", g_param_spec_string ("host", "Host", "The hostname to listen as",
TCP_DEFAULT_LISTEN_HOST, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); TCP_DEFAULT_LISTEN_HOST, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
g_object_class_install_property (gobject_class, PROP_PORT, g_object_class_install_property (gobject_class, PROP_PORT,
g_param_spec_int ("port", "Port", "The port to listen to", g_param_spec_int ("port", "Port",
"The port to listen to (0=random available port)",
0, TCP_HIGHEST_PORT, TCP_DEFAULT_PORT, 0, TCP_HIGHEST_PORT, TCP_DEFAULT_PORT,
G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS)); G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
/**
* GstTCPServerSrc:current-port:
*
* The port number the socket is currently bound to. Applications can use
* this property to retrieve the port number actually bound to in case
* the port requested was 0 (=allocate a random available port).
*
* Since: 1.0.2
**/
g_object_class_install_property (gobject_class, PROP_CURRENT_PORT, g_object_class_install_property (gobject_class, PROP_CURRENT_PORT,
g_param_spec_int ("current-port", "current-port", g_param_spec_int ("current-port", "current-port",
"The port number the socket is currently bound to", 0, "The port number the socket is currently bound to", 0,