Re: [Xen-devel] [PATCH XTF v3] Implement pv_read_some

[Andrew Cooper <andrew.cooper3@xxxxxxxxxx>]

On 20/07/17 09:09, Felix Schmoll wrote:
> Implement reading from PV console. Making use of polling.
>
> Signed-off-by: Felix Schmoll <eggi.innovations@xxxxxxxxx>
>
> ---
> Changed since v2:
>   * Change function name from pv_read to pv_read_some
>   * Add comment to function name
>   * Remove unnecessary code
> ---
>   common/console.c      | 24 ++++++++++++++++++++++++
>   include/xtf/console.h |  2 ++
>   2 files changed, 26 insertions(+)
>
> diff --git a/common/console.c b/common/console.c
> index 7cb2361..1b79652 100644
> --- a/common/console.c
> +++ b/common/console.c
> @@ -46,6 +46,30 @@ static size_t pv_console_write_some(const char *buf, size_t 
> len)
>   }
>   
>   /*
> + * Read out data from the pv ring, either until buffer is filled or no
> + * more data are available. Might result in partial strings, depending
> + * on how xenconsoled passes in data.
Much better.  Just one final question.  Do you intend this function to 
block until data becomes available?  (because that appears to be how it 
behaves.)
~Andrew

> + */
> +size_t pv_console_read_some(char *buf, size_t len)
> +{
> +    size_t s = 0;
> +    uint32_t cons, prod;
> +
> +    while ( !test_and_clear_bit(pv_evtchn, shared_info.evtchn_pending) ||
> +            (pv_ring->in_cons == pv_ring->in_prod) )
> +        hypercall_poll(pv_evtchn);
> +
> +    cons = pv_ring->in_cons, prod = LOAD_ACQUIRE(&pv_ring->in_prod);
> +
> +    while ( (s < len) && (0 < (prod - cons)) )
> +        buf[s++] = pv_ring->in[cons++ & (sizeof(pv_ring->in) - 1)];
> +
> +    STORE_RELEASE(&pv_ring->in_cons, cons);
> +
> +    return s;
> +}
> +
> +/*
>    * Write some data into the pv ring, synchronously waiting for all data to be
>    * consumed.
>    */
> diff --git a/include/xtf/console.h b/include/xtf/console.h
> index 2a93c06..caec790 100644
> --- a/include/xtf/console.h
> +++ b/include/xtf/console.h
> @@ -25,6 +25,8 @@ void init_pv_console(xencons_interface_t *ring,
>   void vprintk(const char *fmt, va_list args) __printf(1, 0);
>   void printk(const char *fmt, ...) __printf(1, 2);
>   
> +size_t pv_console_read_some(char *buf, size_t len);
> +
>   #endif /* XTF_CONSOLE_H */
>   
>   /*

_______________________________________________
Xen-devel mailing list
Xen-devel@xxxxxxxxxxxxx
https://lists.xen.org/xen-devel