Lines Matching refs:pwrite
41 rbuf->pwrite = 0; in dvb_ringbuffer_init()
61 return (rbuf->pread == smp_load_acquire(&rbuf->pwrite)); in dvb_ringbuffer_empty()
75 free = READ_ONCE(rbuf->pread) - rbuf->pwrite; in dvb_ringbuffer_free()
91 avail = smp_load_acquire(&rbuf->pwrite) - rbuf->pread; in dvb_ringbuffer_avail()
107 smp_store_release(&rbuf->pread, smp_load_acquire(&rbuf->pwrite)); in dvb_ringbuffer_flush()
119 smp_store_release(&rbuf->pwrite, 0); in dvb_ringbuffer_reset()
188 split = (rbuf->pwrite + len > rbuf->size) ? rbuf->size - rbuf->pwrite : 0; in dvb_ringbuffer_write()
191 memcpy(rbuf->data+rbuf->pwrite, buf, split); in dvb_ringbuffer_write()
199 smp_store_release(&rbuf->pwrite, 0); in dvb_ringbuffer_write()
201 memcpy(rbuf->data+rbuf->pwrite, buf, todo); in dvb_ringbuffer_write()
203 smp_store_release(&rbuf->pwrite, (rbuf->pwrite + todo) % rbuf->size); in dvb_ringbuffer_write()
215 split = (rbuf->pwrite + len > rbuf->size) ? rbuf->size - rbuf->pwrite : 0; in dvb_ringbuffer_write_user()
218 status = copy_from_user(rbuf->data+rbuf->pwrite, buf, split); in dvb_ringbuffer_write_user()
228 smp_store_release(&rbuf->pwrite, 0); in dvb_ringbuffer_write_user()
230 status = copy_from_user(rbuf->data+rbuf->pwrite, buf, todo); in dvb_ringbuffer_write_user()
234 smp_store_release(&rbuf->pwrite, (rbuf->pwrite + todo) % rbuf->size); in dvb_ringbuffer_write_user()
242 ssize_t oldpwrite = rbuf->pwrite; in dvb_ringbuffer_pkt_write()
250 rbuf->pwrite = oldpwrite; in dvb_ringbuffer_pkt_write()