开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 电子书籍 > VC书籍 > 查看源码
RingBuffer.cpp
资源名称：VC++视频传输.rar　[点击查看]
上传用户：hxb_1234
上传日期：2010-03-30
资源大小：8328k
文件大小：2k
源码类别：

VC书籍

开发平台：

Visual C++

RingBuffer.cpp：源码内容
  2. #include "RingBuffer.h"
  6. MediaRingBuffer::MediaRingBuffer()
  7. {
  8. this->ring = (char *) new char[RING_SIZE];
  10. this->read_pos  = 0;
  11. this->write_pos = 0;
  12. }
  14. MediaRingBuffer::~MediaRingBuffer()
  15. {
  16. free(this->ring);
  17. }
  20. void MediaRingBuffer::Init()
  21. {
  22. this->read_pos  = 0;
  23. this->write_pos = 0;
  24. }
  27. void MediaRingBuffer::Read(char *outData, unsigned int size)
  28. {
  29. if(write_pos <= read_pos) {
  30.     
  31.     if(read_pos + size < RING_SIZE) {
  32. memcpy(outData, ring + read_pos, size);
  33. read_pos += size;
  34. }
  35. else {
  37. if(read_pos + size < RING_SIZE + write_pos) {
  39. unsigned int before, after;
  41. before = (RING_SIZE - 1) - read_pos;
  42. after = size - before;
  44. memcpy(outData, ring + read_pos, before);
  45. memcpy(outData + before, ring, after);
  47. read_pos = after;
  48. }
  49. else {
  50. }
  51. }
  52. }
  53. else {
  55. if(read_pos + size <= write_pos) {
  57. memcpy(outData, ring + read_pos, size);
  58. read_pos += size;
  59. }
  60. else {
  61. }
  62. } 
  63. }
  65. void MediaRingBuffer::Write(char *inData, unsigned int size)
  66. {
  67. if(write_pos >= read_pos) {
  68.     
  69. if(write_pos + size < RING_SIZE) {
  71. memcpy(ring + write_pos, inData, size);
  72. write_pos += size;
  73. }
  74. else {
  76. if(write_pos + size < RING_SIZE + read_pos) {
  78. unsigned int before, after;
  80. before = (RING_SIZE - 1) - write_pos;
  81. after = size - before;
  83. memcpy(ring + write_pos, inData, before);
  84. memcpy(ring, inData + before, after);
  86. write_pos = after;
  87. }
  88. }
  89. }
  90. else {
  91.     
  92. if(write_pos + size <= read_pos) {
  94. memcpy(ring + write_pos, inData, size);
  95. write_pos += size;
  96. }
  97. }
  98. }
  100. int  MediaRingBuffer::IsFullFor(unsigned int size)
  101. {
  102. if(write_pos == read_pos)
  103. return 0;
  105. if(write_pos > read_pos) {
  107. if(write_pos + size < read_pos + RING_SIZE)
  108. return 0;
  110. return 1;
  111. }
  112. else {
  114. if(write_pos + size < read_pos)
  115. return 0;
  117. return 1;
  118. }
  119. }