dvb_ringbuffer.h 6.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187
  1. /*
  2. *
  3. * dvb_ringbuffer.h: ring buffer implementation for the dvb driver
  4. *
  5. * Copyright (C) 2003 Oliver Endriss
  6. * Copyright (C) 2004 Andrew de Quincey
  7. *
  8. * based on code originally found in av7110.c & dvb_ci.c:
  9. * Copyright (C) 1999-2003 Ralph Metzler & Marcus Metzler
  10. * for convergence integrated media GmbH
  11. *
  12. * This program is free software; you can redistribute it and/or
  13. * modify it under the terms of the GNU Lesser General Public License
  14. * as published by the Free Software Foundation; either version 2.1
  15. * of the License, or (at your option) any later version.
  16. *
  17. * This program is distributed in the hope that it will be useful,
  18. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  19. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  20. * GNU Lesser General Public License for more details.
  21. *
  22. * You should have received a copy of the GNU Lesser General Public License
  23. * along with this program; if not, write to the Free Software
  24. * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
  25. */
  26. #ifndef _DVB_RINGBUFFER_H_
  27. #define _DVB_RINGBUFFER_H_
  28. #include <linux/spinlock.h>
  29. #include <linux/wait.h>
  30. struct dvb_ringbuffer {
  31. u8 *data;
  32. ssize_t size;
  33. ssize_t pread;
  34. ssize_t pwrite;
  35. int error;
  36. wait_queue_head_t queue;
  37. spinlock_t lock;
  38. };
  39. #define DVB_RINGBUFFER_PKTHDRSIZE 3
  40. /*
  41. ** Notes:
  42. ** ------
  43. ** (1) For performance reasons read and write routines don't check buffer sizes
  44. ** and/or number of bytes free/available. This has to be done before these
  45. ** routines are called. For example:
  46. **
  47. ** *** write <buflen> bytes ***
  48. ** free = dvb_ringbuffer_free(rbuf);
  49. ** if (free >= buflen)
  50. ** count = dvb_ringbuffer_write(rbuf, buffer, buflen);
  51. ** else
  52. ** ...
  53. **
  54. ** *** read min. 1000, max. <bufsize> bytes ***
  55. ** avail = dvb_ringbuffer_avail(rbuf);
  56. ** if (avail >= 1000)
  57. ** count = dvb_ringbuffer_read(rbuf, buffer, min(avail, bufsize));
  58. ** else
  59. ** ...
  60. **
  61. ** (2) If there is exactly one reader and one writer, there is no need
  62. ** to lock read or write operations.
  63. ** Two or more readers must be locked against each other.
  64. ** Flushing the buffer counts as a read operation.
  65. ** Resetting the buffer counts as a read and write operation.
  66. ** Two or more writers must be locked against each other.
  67. */
  68. /* initialize ring buffer, lock and queue */
  69. extern void dvb_ringbuffer_init(struct dvb_ringbuffer *rbuf, void *data, size_t len);
  70. /* test whether buffer is empty */
  71. extern int dvb_ringbuffer_empty(struct dvb_ringbuffer *rbuf);
  72. /* return the number of free bytes in the buffer */
  73. extern ssize_t dvb_ringbuffer_free(struct dvb_ringbuffer *rbuf);
  74. /* return the number of bytes waiting in the buffer */
  75. extern ssize_t dvb_ringbuffer_avail(struct dvb_ringbuffer *rbuf);
  76. /*
  77. ** Reset the read and write pointers to zero and flush the buffer
  78. ** This counts as a read and write operation
  79. */
  80. extern void dvb_ringbuffer_reset(struct dvb_ringbuffer *rbuf);
  81. /* read routines & macros */
  82. /* ---------------------- */
  83. /* flush buffer */
  84. extern void dvb_ringbuffer_flush(struct dvb_ringbuffer *rbuf);
  85. /* flush buffer protected by spinlock and wake-up waiting task(s) */
  86. extern void dvb_ringbuffer_flush_spinlock_wakeup(struct dvb_ringbuffer *rbuf);
  87. /* peek at byte <offs> in the buffer */
  88. #define DVB_RINGBUFFER_PEEK(rbuf,offs) \
  89. (rbuf)->data[((rbuf)->pread+(offs))%(rbuf)->size]
  90. /* advance read ptr by <num> bytes */
  91. #define DVB_RINGBUFFER_SKIP(rbuf,num) \
  92. (rbuf)->pread=((rbuf)->pread+(num))%(rbuf)->size
  93. /*
  94. ** read <len> bytes from ring buffer into <buf>
  95. ** <usermem> specifies whether <buf> resides in user space
  96. ** returns number of bytes transferred or -EFAULT
  97. */
  98. extern ssize_t dvb_ringbuffer_read_user(struct dvb_ringbuffer *rbuf,
  99. u8 __user *buf, size_t len);
  100. extern void dvb_ringbuffer_read(struct dvb_ringbuffer *rbuf,
  101. u8 *buf, size_t len);
  102. /* write routines & macros */
  103. /* ----------------------- */
  104. /* write single byte to ring buffer */
  105. #define DVB_RINGBUFFER_WRITE_BYTE(rbuf,byte) \
  106. { (rbuf)->data[(rbuf)->pwrite]=(byte); \
  107. (rbuf)->pwrite=((rbuf)->pwrite+1)%(rbuf)->size; }
  108. /*
  109. ** write <len> bytes to ring buffer
  110. ** <usermem> specifies whether <buf> resides in user space
  111. ** returns number of bytes transferred or -EFAULT
  112. */
  113. extern ssize_t dvb_ringbuffer_write(struct dvb_ringbuffer *rbuf, const u8 *buf,
  114. size_t len);
  115. /**
  116. * Write a packet into the ringbuffer.
  117. *
  118. * <rbuf> Ringbuffer to write to.
  119. * <buf> Buffer to write.
  120. * <len> Length of buffer (currently limited to 65535 bytes max).
  121. * returns Number of bytes written, or -EFAULT, -ENOMEM, -EVINAL.
  122. */
  123. extern ssize_t dvb_ringbuffer_pkt_write(struct dvb_ringbuffer *rbuf, u8* buf,
  124. size_t len);
  125. /**
  126. * Read from a packet in the ringbuffer. Note: unlike dvb_ringbuffer_read(), this
  127. * does NOT update the read pointer in the ringbuffer. You must use
  128. * dvb_ringbuffer_pkt_dispose() to mark a packet as no longer required.
  129. *
  130. * <rbuf> Ringbuffer concerned.
  131. * <idx> Packet index as returned by dvb_ringbuffer_pkt_next().
  132. * <offset> Offset into packet to read from.
  133. * <buf> Destination buffer for data.
  134. * <len> Size of destination buffer.
  135. * <usermem> Set to 1 if <buf> is in userspace.
  136. * returns Number of bytes read, or -EFAULT.
  137. */
  138. extern ssize_t dvb_ringbuffer_pkt_read_user(struct dvb_ringbuffer *rbuf, size_t idx,
  139. int offset, u8 __user *buf, size_t len);
  140. extern ssize_t dvb_ringbuffer_pkt_read(struct dvb_ringbuffer *rbuf, size_t idx,
  141. int offset, u8 *buf, size_t len);
  142. /**
  143. * Dispose of a packet in the ring buffer.
  144. *
  145. * <rbuf> Ring buffer concerned.
  146. * <idx> Packet index as returned by dvb_ringbuffer_pkt_next().
  147. */
  148. extern void dvb_ringbuffer_pkt_dispose(struct dvb_ringbuffer *rbuf, size_t idx);
  149. /**
  150. * Get the index of the next packet in a ringbuffer.
  151. *
  152. * <rbuf> Ringbuffer concerned.
  153. * <idx> Previous packet index, or -1 to return the first packet index.
  154. * <pktlen> On success, will be updated to contain the length of the packet in bytes.
  155. * returns Packet index (if >=0), or -1 if no packets available.
  156. */
  157. extern ssize_t dvb_ringbuffer_pkt_next(struct dvb_ringbuffer *rbuf, size_t idx, size_t* pktlen);
  158. #endif /* _DVB_RINGBUFFER_H_ */