if (mhclient->bufpos == -1) {
/* client is too fast, remove from write queue until new buffer is
* available */
- // FIXME: specific
+ /* FIXME: specific */
gst_poll_fd_ctl_write (sink->fdset, &client->gfd, FALSE);
- //
+
/* if we flushed out all of the client buffers, we can stop */
if (mhclient->flushcount == 0)
goto flushed;
mhclient->bufpos = position;
} else {
/* cannot send data to this client yet */
- // FIXME: specific
+ /* FIXME: specific */
gst_poll_fd_ctl_write (sink->fdset, &client->gfd, FALSE);
return TRUE;
}
data = info.data;
maxsize = info.size - mhclient->bufoffset;
- // FIXME: specific
+ /* FIXME: specific */
/* try to write the complete buffer */
#ifdef MSG_NOSIGNAL
#define FLAGS MSG_NOSIGNAL
break;
}
- // FIXME: convert to vfunc to cleanup a client
+ /* FIXME: convert to vfunc to cleanup a client */
fclass->delete_client (sink, client);
if (mhclient->bufpos == -1) {
/* client is too fast, remove from write queue until new buffer is
* available */
- // FIXME: specific
+ /* FIXME: specific */
if (client->source) {
g_source_destroy (client->source);
g_source_unref (client->source);
client->source = NULL;
}
- //
+
/* if we flushed out all of the client buffers, we can stop */
if (mhclient->flushcount == 0)
goto flushed;
mhclient->bufpos = position;
} else {
/* cannot send data to this client yet */
- // FIXME: specific
+ /* FIXME: specific */
if (client->source) {
g_source_destroy (client->source);
g_source_unref (client->source);
client->source = NULL;
}
- //
+
return TRUE;
}
}
gst_buffer_map (head, &map, GST_MAP_READ);
maxsize = map.size - mhclient->bufoffset;
- // FIXME: specific
+ /* FIXME: specific */
/* try to write the complete buffer */
wrote =