if (GST_OBJECT_FLAG_IS_SET (this, GST_TCP_CLIENT_SINK_OPEN))
return TRUE;
- /* create sending client socket */
- GST_DEBUG_OBJECT (this, "opening sending client socket to %s:%d", this->host,
- this->port);
- this->socket =
- g_socket_new (G_SOCKET_FAMILY_IPV4, G_SOCKET_TYPE_STREAM,
- G_SOCKET_PROTOCOL_TCP, &err);
- if (!this->socket)
- goto no_socket;
-
- GST_DEBUG_OBJECT (this, "opened sending client socket");
-
/* look up name if we need to */
addr = g_inet_address_new_from_string (this->host);
if (!addr) {
g_free (ip);
}
#endif
+ saddr = g_inet_socket_address_new (addr, this->port);
+ g_object_unref (addr);
+
+ /* create sending client socket */
+ GST_DEBUG_OBJECT (this, "opening sending client socket to %s:%d", this->host,
+ this->port);
+ this->socket =
+ g_socket_new (g_socket_address_get_family (saddr), G_SOCKET_TYPE_STREAM,
+ G_SOCKET_PROTOCOL_TCP, &err);
+ if (!this->socket)
+ goto no_socket;
+
+ GST_DEBUG_OBJECT (this, "opened sending client socket");
/* connect to server */
- saddr = g_inet_socket_address_new (addr, this->port);
if (!g_socket_connect (this->socket, saddr, this->cancellable, &err))
goto connect_failed;
g_object_unref (saddr);
- g_object_unref (addr);
GST_OBJECT_FLAG_SET (this, GST_TCP_CLIENT_SINK_OPEN);
GST_ELEMENT_ERROR (this, RESOURCE, OPEN_READ, (NULL),
("Failed to create socket: %s", err->message));
g_clear_error (&err);
+ g_object_unref (saddr);
return FALSE;
}
name_resolve:
}
g_clear_error (&err);
g_object_unref (resolver);
- gst_tcp_client_sink_stop (GST_BASE_SINK (this));
return FALSE;
}
connect_failed:
}
g_clear_error (&err);
g_object_unref (saddr);
- g_object_unref (addr);
gst_tcp_client_sink_stop (GST_BASE_SINK (this));
return FALSE;
}
GSocketAddress *saddr;
GResolver *resolver;
- /* create receiving client socket */
- GST_DEBUG_OBJECT (src, "opening receiving client socket to %s:%d",
- src->host, src->port);
-
- src->socket =
- g_socket_new (G_SOCKET_FAMILY_IPV4, G_SOCKET_TYPE_STREAM,
- G_SOCKET_PROTOCOL_TCP, &err);
- if (!src->socket)
- goto no_socket;
-
- GST_DEBUG_OBJECT (src, "opened receiving client socket");
- GST_OBJECT_FLAG_SET (src, GST_TCP_CLIENT_SRC_OPEN);
-
/* look up name if we need to */
addr = g_inet_address_new_from_string (src->host);
if (!addr) {
}
#endif
- /* connect to server */
saddr = g_inet_socket_address_new (addr, src->port);
+ g_object_unref (addr);
+
+ /* create receiving client socket */
+ GST_DEBUG_OBJECT (src, "opening receiving client socket to %s:%d",
+ src->host, src->port);
+
+ src->socket =
+ g_socket_new (g_socket_address_get_family (saddr), G_SOCKET_TYPE_STREAM,
+ G_SOCKET_PROTOCOL_TCP, &err);
+ if (!src->socket)
+ goto no_socket;
+
+ GST_DEBUG_OBJECT (src, "opened receiving client socket");
+ GST_OBJECT_FLAG_SET (src, GST_TCP_CLIENT_SRC_OPEN);
+
+ /* connect to server */
if (!g_socket_connect (src->socket, saddr, src->cancellable, &err))
goto connect_failed;
g_object_unref (saddr);
- g_object_unref (addr);
return TRUE;
GST_ELEMENT_ERROR (src, RESOURCE, OPEN_READ, (NULL),
("Failed to create socket: %s", err->message));
g_clear_error (&err);
+ g_object_unref (saddr);
return FALSE;
}
name_resolve:
}
g_clear_error (&err);
g_object_unref (resolver);
- gst_tcp_client_src_stop (GST_BASE_SRC (src));
return FALSE;
}
connect_failed:
}
g_clear_error (&err);
g_object_unref (saddr);
- g_object_unref (addr);
gst_tcp_client_src_stop (GST_BASE_SRC (src));
return FALSE;
}
GSocketAddress *saddr;
GResolver *resolver;
- /* create the server listener socket */
- this->server_socket =
- g_socket_new (G_SOCKET_FAMILY_IPV4, G_SOCKET_TYPE_STREAM,
- G_SOCKET_PROTOCOL_TCP, &err);
- if (!this->server_socket)
- goto no_socket;
-
- GST_DEBUG_OBJECT (this, "opened sending server socket with socket %p",
- this->server_socket);
-
/* look up name if we need to */
addr = g_inet_address_new_from_string (this->host);
if (!addr) {
g_free (ip);
}
#endif
+ saddr = g_inet_socket_address_new (addr, this->server_port);
+ g_object_unref (addr);
+
+ /* create the server listener socket */
+ this->server_socket =
+ g_socket_new (g_socket_address_get_family (saddr), G_SOCKET_TYPE_STREAM,
+ G_SOCKET_PROTOCOL_TCP, &err);
+ if (!this->server_socket)
+ goto no_socket;
+
+ GST_DEBUG_OBJECT (this, "opened sending server socket with socket %p",
+ this->server_socket);
g_socket_set_blocking (this->server_socket, FALSE);
/* bind it */
- saddr = g_inet_socket_address_new (addr, this->server_port);
GST_DEBUG_OBJECT (this, "binding server socket to address");
if (!g_socket_bind (this->server_socket, saddr, TRUE, &err))
goto bind_failed;
+ g_object_unref (saddr);
+
GST_DEBUG_OBJECT (this, "listening on server socket");
g_socket_set_listen_backlog (this->server_socket, TCP_BACKLOG);
GST_ELEMENT_ERROR (this, RESOURCE, OPEN_READ, (NULL),
("Failed to create socket: %s", err->message));
g_clear_error (&err);
+ g_object_unref (saddr);
return FALSE;
}
name_resolve:
}
g_clear_error (&err);
g_object_unref (resolver);
- gst_tcp_server_sink_close (&this->element);
return FALSE;
}
bind_failed:
}
g_clear_error (&err);
g_object_unref (saddr);
- g_object_unref (addr);
gst_tcp_server_sink_close (&this->element);
return FALSE;
}
this->server_port, err->message));
}
g_clear_error (&err);
- g_object_unref (saddr);
- g_object_unref (addr);
gst_tcp_server_sink_close (&this->element);
return FALSE;
}
GSocketAddress *saddr;
GResolver *resolver;
- /* create the server listener socket */
- src->server_socket = g_socket_new (G_SOCKET_FAMILY_IPV4, G_SOCKET_TYPE_STREAM,
- G_SOCKET_PROTOCOL_TCP, &err);
- if (!src->server_socket)
- goto no_socket;
-
- GST_DEBUG_OBJECT (src, "opened receiving server socket");
-
/* look up name if we need to */
addr = g_inet_address_new_from_string (src->host);
if (!addr) {
}
#endif
- /* bind it */
saddr = g_inet_socket_address_new (addr, src->server_port);
+ g_object_unref (addr);
+
+ /* create the server listener socket */
+ src->server_socket =
+ g_socket_new (g_socket_address_get_family (saddr), G_SOCKET_TYPE_STREAM,
+ G_SOCKET_PROTOCOL_TCP, &err);
+ if (!src->server_socket)
+ goto no_socket;
+
+ GST_DEBUG_OBJECT (src, "opened receiving server socket");
+
+ /* bind it */
GST_DEBUG_OBJECT (src, "binding server socket to address");
if (!g_socket_bind (src->server_socket, saddr, TRUE, &err))
goto bind_failed;
+ g_object_unref (saddr);
+
GST_DEBUG_OBJECT (src, "listening on server socket");
g_socket_set_listen_backlog (src->server_socket, TCP_BACKLOG);
GST_ELEMENT_ERROR (src, RESOURCE, OPEN_READ, (NULL),
("Failed to create socket: %s", err->message));
g_clear_error (&err);
+ g_object_unref (saddr);
return FALSE;
}
name_resolve:
}
g_clear_error (&err);
g_object_unref (resolver);
- gst_tcp_server_src_stop (GST_BASE_SRC (src));
return FALSE;
}
bind_failed:
}
g_clear_error (&err);
g_object_unref (saddr);
- g_object_unref (addr);
gst_tcp_server_src_stop (GST_BASE_SRC (src));
return FALSE;
}
err->message));
}
g_clear_error (&err);
- g_object_unref (saddr);
- g_object_unref (addr);
gst_tcp_server_src_stop (GST_BASE_SRC (src));
return FALSE;
}