mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-28 12:41:05 +00:00
Code Issues 1 Projects Releases Wiki Activity

tcp: adjust comment style

Browse source
This commit is contained in:
Mark Nauwelaerts 2012-09-10 12:45:17 +02:00
parent 0ce33461c8
commit 6a87cb5248
3 changed files with 10 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
gst/tcp/gstmultifdsink.c
View file

@ -697,9 +697,9 @@ gst_multi_fd_sink_handle_client_write (GstMultiFdSink * sink,
if (mhclient->bufpos == -1) { if (mhclient->bufpos == -1) {
/* client is too fast, remove from write queue until new buffer is /* client is too fast, remove from write queue until new buffer is
* available */ * available */
// FIXME: specific /* FIXME: specific */
gst_poll_fd_ctl_write (sink->fdset, &client->gfd, FALSE); gst_poll_fd_ctl_write (sink->fdset, &client->gfd, FALSE);
//
/* if we flushed out all of the client buffers, we can stop */ /* if we flushed out all of the client buffers, we can stop */
if (mhclient->flushcount == 0) if (mhclient->flushcount == 0)
goto flushed; goto flushed;
@ -722,7 +722,7 @@ gst_multi_fd_sink_handle_client_write (GstMultiFdSink * sink,
mhclient->bufpos = position; mhclient->bufpos = position;
} else { } else {
/* cannot send data to this client yet */ /* cannot send data to this client yet */
// FIXME: specific /* FIXME: specific */
gst_poll_fd_ctl_write (sink->fdset, &client->gfd, FALSE); gst_poll_fd_ctl_write (sink->fdset, &client->gfd, FALSE);
return TRUE; return TRUE;
} }
@ -774,7 +774,7 @@ gst_multi_fd_sink_handle_client_write (GstMultiFdSink * sink,
data = info.data; data = info.data;
maxsize = info.size - mhclient->bufoffset; maxsize = info.size - mhclient->bufoffset;
// FIXME: specific /* FIXME: specific */
/* try to write the complete buffer */ /* try to write the complete buffer */
#ifdef MSG_NOSIGNAL #ifdef MSG_NOSIGNAL
#define FLAGS MSG_NOSIGNAL #define FLAGS MSG_NOSIGNAL

2
gst/tcp/gstmultioutputsink.c
View file

@ -1083,7 +1083,7 @@ gst_multi_output_sink_remove_client_link (GstMultiOutputSink * sink,
break; break;
} }
// FIXME: convert to vfunc to cleanup a client /* FIXME: convert to vfunc to cleanup a client */
fclass->delete_client (sink, client); fclass->delete_client (sink, client);

10
gst/tcp/gstmultisocketsink.c
View file

@ -656,13 +656,13 @@ gst_multi_socket_sink_handle_client_write (GstMultiSocketSink * sink,
if (mhclient->bufpos == -1) { if (mhclient->bufpos == -1) {
/* client is too fast, remove from write queue until new buffer is /* client is too fast, remove from write queue until new buffer is
* available */ * available */
// FIXME: specific /* FIXME: specific */
if (client->source) { if (client->source) {
g_source_destroy (client->source); g_source_destroy (client->source);
g_source_unref (client->source); g_source_unref (client->source);
client->source = NULL; client->source = NULL;
} }
//
/* if we flushed out all of the client buffers, we can stop */ /* if we flushed out all of the client buffers, we can stop */
if (mhclient->flushcount == 0) if (mhclient->flushcount == 0)
goto flushed; goto flushed;
@ -685,13 +685,13 @@ gst_multi_socket_sink_handle_client_write (GstMultiSocketSink * sink,
mhclient->bufpos = position; mhclient->bufpos = position;
} else { } else {
/* cannot send data to this client yet */ /* cannot send data to this client yet */
// FIXME: specific /* FIXME: specific */
if (client->source) { if (client->source) {
g_source_destroy (client->source); g_source_destroy (client->source);
g_source_unref (client->source); g_source_unref (client->source);
client->source = NULL; client->source = NULL;
} }
//
return TRUE; return TRUE;
} }
} }
@ -738,7 +738,7 @@ gst_multi_socket_sink_handle_client_write (GstMultiSocketSink * sink,
gst_buffer_map (head, &map, GST_MAP_READ); gst_buffer_map (head, &map, GST_MAP_READ);
maxsize = map.size - mhclient->bufoffset; maxsize = map.size - mhclient->bufoffset;
// FIXME: specific /* FIXME: specific */
/* try to write the complete buffer */ /* try to write the complete buffer */
wrote = wrote =