[Spice-devel] [spice-gtk v3 02/16] file-xfer: introduce flush_callback and flush_done
Pavel Grunt
pgrunt at redhat.com
Thu Jun 2 06:20:02 UTC 2016
On Wed, 2016-06-01 at 16:23 +0200, Victor Toso wrote:
> Hi,
>
> On Wed, Jun 01, 2016 at 03:24:09PM +0200, Pavel Grunt wrote:
> > Hi Victor,
> >
> > I put some questions/comments inline
> >
> > On Mon, 2016-05-30 at 11:54 +0200, Victor Toso wrote:
> > > By introducing a flush_callback such as SpiceFileTransferTaskFlushCb
> > > SpiceFileTransferTask becomes agnostic on how channel-main flushes
> > > the data.
> > >
> > > The spice_file_transfer_task_flush_done() function is now introduced
> > > to tell SpiceFileTransferTask that flushing is over and we can read
> > > more data if no error has happened.
> > >
> > > This change is related to split SpiceFileTransferTask from
> > > channel-main.
> > > ---
> > > src/channel-main.c | 143 ++++++++++++++++++++++++++++++++--------------
> > > ----
> > > ---
> > > 1 file changed, 88 insertions(+), 55 deletions(-)
> > >
> > > diff --git a/src/channel-main.c b/src/channel-main.c
> > > index 89675d5..702f146 100644
> > > --- a/src/channel-main.c
> > > +++ b/src/channel-main.c
> > > @@ -54,9 +54,14 @@
> > >
> > > typedef struct spice_migrate spice_migrate;
> > >
> > > +typedef void (*SpiceFileTransferTaskFlushCb)(SpiceFileTransferTask
> > > *xfer_task,
> > to be consistent with other functions, use 'self' instead of 'xfer_task'
>
> This was on purpose. I would like to use _self_ for functions inside
> spice-file-transfer-task.c and xfer_task elsewhere. As this is callback,
> I thought xfer_task would fit in situation I just mentioned.
>
> The main reason to change the name is, as you point out, some places
> that use _self_ and some places that use even _task_ (which are very
> confusing with the GTask).
>
> At the end of the series most of the places have consistent names this
> way. What do you think about it?
>
> >
> > > + void *buffer,
> > > + gssize count,
> > > + gpointer user_data);
> > > static guint32 spice_file_transfer_task_get_id(SpiceFileTransferTask
> > > *self);
> > > static SpiceMainChannel
> > > *spice_file_transfer_task_get_channel(SpiceFileTransferTask *self);
> > > static GCancellable
> > > *spice_file_transfer_task_get_cancellable(SpiceFileTransferTask *self);
> > > +static void spice_file_transfer_task_flush_done(SpiceFileTransferTask
> > > *self,
> > > GError *error);
> > >
> > > /**
> > > * SECTION:file-transfer-task
> > > @@ -89,6 +94,8 @@ struct _SpiceFileTransferTask
> > > GCancellable *cancellable;
> > > GFileProgressCallback progress_callback;
> > > gpointer progress_callback_data;
> > > + SpiceFileTransferTaskFlushCb flush_callback;
> > > + gpointer flush_callback_data;
> > > GAsyncReadyCallback callback;
> > > gpointer user_data;
> > > char *buffer;
> > > @@ -1859,73 +1866,49 @@ static void file_xfer_data_flushed_cb(GObject
> > > *source_object,
> > > SpiceMainChannel *channel = (SpiceMainChannel *)source_object;
> > > GError *error = NULL;
> > >
> > > - self->pending = FALSE;
> > > file_xfer_flush_finish(channel, res, &error);
> > > - if (error || self->error) {
> > > - spice_file_transfer_task_completed(self, error);
> > > - return;
> > > - }
> > > -
> > > - if (spice_util_get_debug()) {
> > > - const GTimeSpan interval = 20 * G_TIME_SPAN_SECOND;
> > > - gint64 now = g_get_monotonic_time();
> > > -
> > > - if (interval < now - self->last_update) {
> > > - gchar *basename = g_file_get_basename(self->file);
> > > - self->last_update = now;
> > > - SPICE_DEBUG("transferred %.2f%% of the file %s",
> > > - 100.0 * self->read_bytes / self->file_size,
> > > basename);
> > > - g_free(basename);
> > > - }
> > > - }
> > > -
> > > - if (self->progress_callback) {
> > > - goffset read = 0;
> > > - goffset total = 0;
> > > - SpiceMainChannel *main_channel = self->channel;
> > > - GHashTableIter iter;
> > > - gpointer key, value;
> > > -
> > > - /* since the progress_callback does not have a parameter to
> > > indicate
> > > - * which file the progress is associated with, report progress on
> > > all
> > > - * current transfers */
> > > - g_hash_table_iter_init(&iter, main_channel->priv-
> > > >file_xfer_tasks);
> > > - while (g_hash_table_iter_next(&iter, &key, &value)) {
> > > - SpiceFileTransferTask *t = (SpiceFileTransferTask *)value;
> > > - read += t->read_bytes;
> > > - total += t->file_size;
> > > - }
> > > -
> > > - self->progress_callback(read, total, self-
> > > >progress_callback_data);
> > > - }
> > > -
> > > - /* Read more data */
> > > - file_xfer_continue_read(self);
> > > + spice_file_transfer_task_flush_done(self, error);
> > > }
> > >
> > > -static void file_xfer_queue(SpiceFileTransferTask *self, int data_size)
> > > +static void file_xfer_queue(SpiceFileTransferTask *xfer_task, void
> > > *buffer,
> > so the renames in this function are not needed,
>
> For the reason I mentioned above. This is a function that will stay on
> channel-main in the end of series so I'm changing to xfer_task!
> >
> > the buffer change is related to this patch ? Will it be different than
> > task's
> > buffer
>
> It is! It was included in the flush-callback :)
So is it different than the task's buffer.
>
> > > int data_size)
> > > {
> > > VDAgentFileXferDataMessage msg;
> > > SpiceMainChannel *channel;
> > >
> > > - channel = spice_file_transfer_task_get_channel(self);
> > > + channel = spice_file_transfer_task_get_channel(xfer_task);
> > > g_return_if_fail(channel != NULL);
> > >
> > > - msg.id = spice_file_transfer_task_get_id(self);
> > > + msg.id = spice_file_transfer_task_get_id(xfer_task);
> > > msg.size = data_size;
> > > agent_msg_queue_many(channel, VD_AGENT_FILE_XFER_DATA,
> > > &msg, sizeof(msg),
> > > - self->buffer, data_size, NULL);
> > > + buffer, data_size, NULL);
> > > spice_channel_wakeup(SPICE_CHANNEL(channel), FALSE);
> > > }
> > >
> > > +static void file_xfer_flush_callback(SpiceFileTransferTask *xfer_task,
> > xfer_task / self ?
> > > + void *buffer,
> > > + gssize count,
> > > + gpointer user_data)
> > > +{
> > > + SpiceMainChannel *main_channel;
> > > + GCancellable *cancellable;
> > > +
> > > + file_xfer_queue(xfer_task, buffer, count);
> > aha, this is the buffer
> > > + if (count == 0)
> > > + return;
> > > +
> > > + main_channel = spice_file_transfer_task_get_channel(xfer_task);
> > > + cancellable = spice_file_transfer_task_get_cancellable(xfer_task);
> > > + file_xfer_flush_async(main_channel, cancellable,
> > > file_xfer_data_flushed_cb, xfer_task);
> > > +}
> > > +
> > > /* main context */
> > > static void file_xfer_read_cb(GObject *source_object,
> > > GAsyncResult *res,
> > > gpointer user_data)
> > > {
> > > SpiceFileTransferTask *self = user_data;
> > > - SpiceMainChannel *channel = self->channel;
> > > gssize count;
> > > GError *error = NULL;
> > >
> > > @@ -1939,17 +1922,12 @@ static void file_xfer_read_cb(GObject
> > > *source_object,
> > > }
> > >
> > > if (count > 0 || self->file_size == 0) {
> > > - GCancellable *cancellable;
> > > -
> > > self->read_bytes += count;
> > > g_object_notify(G_OBJECT(self), "progress");
> > > - file_xfer_queue(self, count);
> > > - if (count == 0)
> > > - return;
> > > - cancellable = spice_file_transfer_task_get_cancellable(self);
> > > - file_xfer_flush_async(channel, cancellable,
> > > - file_xfer_data_flushed_cb, self);
> > > - self->pending = TRUE;
> > > + if (self->flush_callback) {
> > > + self->pending = TRUE;
> > > + self->flush_callback(self, self->buffer, count, self-
> > > > flush_callback_data);
> > > + }
> > > } else if (error) {
> > > spice_channel_wakeup(SPICE_CHANNEL(self->channel), FALSE);
> > > spice_file_transfer_task_completed(self, error);
> > > @@ -3097,6 +3075,8 @@ static void
> > > file_xfer_send_start_msg_async(SpiceMainChannel *channel,
> > > GCancellable *cancellable,
> > > GFileProgressCallback
> > > progress_callback,
> > > gpointer
> > > progress_callback_data,
> > > + SpiceFileTransferTaskFlushCb
> > > flush_callback,
> > > + gpointer flush_callback_data,
> > > GAsyncReadyCallback callback,
> > > gpointer user_data)
> > > {
> > > @@ -3116,6 +3096,8 @@ static void
> > > file_xfer_send_start_msg_async(SpiceMainChannel *channel,
> > > task->flags = flags;
> > > task->progress_callback = progress_callback;
> > > task->progress_callback_data = progress_callback_data;
> > > + task->flush_callback = flush_callback;
> > > + task->flush_callback_data = flush_callback_data;
> > > task->callback = callback;
> > > task->user_data = user_data;
> > >
> > > @@ -3204,6 +3186,8 @@ void spice_main_file_copy_async(SpiceMainChannel
> > > *channel,
> > > cancellable,
> > > progress_callback,
> > > progress_callback_data,
> > > + file_xfer_flush_callback,
> > > + NULL,
> > > callback,
> > > user_data);
> > > }
> > > @@ -3249,6 +3233,55 @@ static GCancellable
> > > *spice_file_transfer_task_get_cancellable(SpiceFileTransferT
> > > return self->cancellable;
> > > }
> > >
> > > +static void spice_file_transfer_task_flush_done(SpiceFileTransferTask
> > > *self,
> > > GError *error)
> > xfer_task / self ?
> > > +{
> > > + g_return_if_fail(self != NULL);
> > > + g_return_if_fail(self->pending);
> > > +
> > > + self->pending = FALSE;
> > > +
> > > + if (error || self->error) {
> > > + spice_file_transfer_task_completed(self, error);
> > > + return;
> > > + }
> > > +
> > > + if (spice_util_get_debug()) {
> > > + const GTimeSpan interval = 20 * G_TIME_SPAN_SECOND;
> > > + gint64 now = g_get_monotonic_time();
> > > +
> > > + if (interval < now - self->last_update) {
> > > + gchar *basename = g_file_get_basename(self->file);
> > > + self->last_update = now;
> > > + SPICE_DEBUG("transferred %.2f%% of the file %s",
> > > + 100.0 * self->read_bytes / self->file_size,
> > > basename);
> > > + g_free(basename);
> > > + }
> > > + }
> > > +
> > > + if (self->progress_callback) {
> > > + goffset read = 0;
> > > + goffset total = 0;
> > > + SpiceMainChannel *main_channel = self->channel;
> > > + GHashTableIter iter;
> > > + gpointer key, value;
> > > +
> > > + /* since the progress_callback does not have a parameter to
> > > indicate
> > > + * which file the progress is associated with, report progress on
> > > all
> > > + * current transfers */
> > > + g_hash_table_iter_init(&iter, main_channel->priv-
> > > >file_xfer_tasks);
> > > + while (g_hash_table_iter_next(&iter, &key, &value)) {
> > > + SpiceFileTransferTask *t = (SpiceFileTransferTask *)value;
> > > + read += t->read_bytes;
> > > + total += t->file_size;
> > > + }
> > > +
> > > + self->progress_callback(read, total, self-
> > > >progress_callback_data);
> > > + }
> > > +
> > > + /* Read more data */
> > > + file_xfer_continue_read(self);
> > > +}
> > > +
> > > static void
> > > spice_file_transfer_task_get_property(GObject *object,
> > > guint property_id,
> >
> > Pavel
>
> Let me know if I should do a different approach (or none at all) for the
> vars names.
It is up to you, it was just not clear for me why sometimes is task and
sometimes self
Pavel
>
> Thanks again for reviewing!
> toso
More information about the Spice-devel
mailing list