[libvirt] [PATCH v2 26/38] remote_driver: Implement virStreamSkip

[John Ferlan]

On 04/20/2017 06:01 AM, Michal Privoznik wrote:
> Now that we have RPC wrappers over VIR_NET_STREAM_SKIP we can
> start wiring them up. This commit wires up situation when a
> client wants to send a hole to daemon.
> 
> To keep stream offsets synchronous, upon successful call on the
> daemon skip the same hole in local part of the stream.
> 
> Signed-off-by: Michal Privoznik <mprivozn at redhat.com>
> ---
>  src/remote/remote_driver.c | 29 +++++++++++++++++++++++++++++
>  1 file changed, 29 insertions(+)
> 

Seems reasonable - would be affected by a flags argument though...

John

> diff --git a/src/remote/remote_driver.c b/src/remote/remote_driver.c
> index 6a2c6f6..6037e08 100644
> --- a/src/remote/remote_driver.c
> +++ b/src/remote/remote_driver.c
> @@ -5683,6 +5683,34 @@ remoteStreamRecv(virStreamPtr st,
>      return remoteStreamRecvFlags(st, data, nbytes, 0);
>  }
>  
> +
> +static int
> +remoteStreamSkip(virStreamPtr st,
> +                 unsigned long long length)
> +{
> +    VIR_DEBUG("st=%p length=%llu", st, length);
> +    struct private_data *priv = st->conn->privateData;
> +    virNetClientStreamPtr privst = st->privateData;
> +    int rv;
> +
> +    if (virNetClientStreamRaiseError(privst))
> +        return -1;
> +
> +    remoteDriverLock(priv);
> +    priv->localUses++;
> +    remoteDriverUnlock(priv);
> +
> +    rv = virNetClientStreamSendSkip(privst,
> +                                    priv->client,
> +                                    length);
> +
> +    remoteDriverLock(priv);
> +    priv->localUses--;
> +    remoteDriverUnlock(priv);
> +    return rv;
> +}
> +
> +
>  struct remoteStreamCallbackData {
>      virStreamPtr st;
>      virStreamEventCallback cb;
> @@ -5857,6 +5885,7 @@ static virStreamDriver remoteStreamDrv = {
>      .streamRecv = remoteStreamRecv,
>      .streamRecvFlags = remoteStreamRecvFlags,
>      .streamSend = remoteStreamSend,
> +    .streamSkip = remoteStreamSkip,
>      .streamFinish = remoteStreamFinish,
>      .streamAbort = remoteStreamAbort,
>      .streamEventAddCallback = remoteStreamEventAddCallback,
>