home *** CD-ROM | disk | FTP | other *** search
/ Informática Multimedia: Special Games / INFESPGAMES.mdf / os2 / ribble / support / cbr.cpp < prev    next >
Encoding:
C/C++ Source or Header  |  1994-08-26  |  4.1 KB  |  217 lines
  1. #include <CSupport.h>
  2. #include <CAssert.h>
  3. #include <CBR.h>
  4.  
  5. #include <string.h>
  6. #include <stdio.h>
  7. #include <direct.h>
  8. #include <fcntl.h>
  9. #include <io.h>
  10.  
  11. #if defined(__OS2__) && defined(__IBMC__)
  12. #define open(a,b) _open(a,b)
  13. #define lseek(a,b,c) _lseek(a,b,c)
  14. #endif
  15.  
  16. CBufferedRead::CBufferedRead(const char* _filename, int _mode)
  17. {
  18.   fd = open(_filename, _mode);
  19.   if (fd != -1)
  20.     {
  21.       fdOpened = 1;
  22.       buffer = new CSHuge char[BufferSize];
  23.       CAssert(buffer);
  24.     }
  25.   else
  26.     {
  27.       fdOpened = 0;
  28.       buffer = 0;
  29.     }
  30.   lineBuffer = 0;
  31.   lineBufferLen = 0;
  32.   bufferSeekPos = 0;
  33.   flush();
  34. }
  35.  
  36. CBufferedRead::CBufferedRead(int _fd)
  37. {
  38.   fd = _fd;
  39.  
  40.   if (fd != -1)
  41.     {
  42.       buffer = new CSHuge char[BufferSize];
  43.       CAssert(buffer);
  44.       bufferSeekPos = lseek(_fd, 0, SEEK_CUR);
  45.       flush();
  46.     }
  47.   else
  48.     {
  49.       fdOpened = 0;
  50.       buffer = 0;
  51.       bufferSeekPos = 0;
  52.       bufferSize = 0;
  53.       bufferOff = 0;
  54.     }
  55.   lineBuffer = 0;
  56.   lineBufferLen = 0;
  57. }
  58.  
  59. CBufferedRead::~CBufferedRead()
  60. {
  61.   if (fdOpened)
  62.     ::close(fd);
  63.   if (buffer)
  64.     delete [] buffer;
  65. }
  66.  
  67. void
  68. CBufferedRead::close(void)
  69. {
  70.   if (fdOpened)
  71.     ::close(fd);
  72.   fdOpened = 0;
  73.   fd = -1;
  74. }
  75.  
  76. long
  77. CBufferedRead::opened(void)
  78. {
  79.   return fd != -1;
  80. }
  81.  
  82. long 
  83. CBufferedRead::rewind(void) 
  84. { 
  85.   flush();
  86.   return seek(0);
  87. }
  88.  
  89. long 
  90. CBufferedRead::seek(long _position)
  91. {
  92.   if (fd == -1) return -1;
  93.  
  94.   long sdiff = _position - bufferSeekPos;
  95.  
  96.   if (sdiff >= 0 && sdiff < bufferSize)
  97.     {
  98.       bufferOff = sdiff;
  99.       return _position;
  100.     }
  101.   else
  102.     {
  103.       bufferSeekPos = lseek(fd, _position, SEEK_SET);
  104.       flush();
  105.       return bufferSeekPos;
  106.     }
  107. }
  108.  
  109. void 
  110. CBufferedRead::flush(void)
  111. {
  112.   bufferSize = 0;
  113.   bufferOff = 0;
  114. }
  115.  
  116. long 
  117. CBufferedRead::read(char* _buffer, unsigned int _length)
  118. {
  119.   if (fd == -1) return -1;
  120.  
  121.   long bufferLeft = bufferSize - bufferOff;
  122.  
  123.   if (_length <= bufferLeft)
  124.     {
  125.       memcpy(_buffer, buffer + bufferOff, _length);
  126.       bufferOff += _length;
  127.     }
  128.   else
  129.     {
  130.       if (_length >= BufferSize)
  131.         {
  132.           if (bufferLeft)
  133.             {
  134.               memcpy(_buffer, buffer + bufferOff, (size_t)bufferLeft);
  135.               bufferOff = bufferSize;
  136.             }
  137.  
  138.           long r = ::read(fd, _buffer + bufferLeft, (size_t)(_length - bufferLeft));
  139.           return r == -1 ? -1 : bufferLeft + r;
  140.         }
  141.  
  142.       if (bufferLeft)
  143.         {
  144.           memmove(buffer, buffer + bufferOff, (size_t)bufferLeft);
  145.           bufferSize = bufferLeft;
  146.           bufferOff = 0;
  147.         }
  148.       else
  149.         {
  150.           bufferSize = 0;
  151.           bufferOff = 0;
  152.         }
  153.  
  154.       bufferSeekPos = lseek(fd, 0, SEEK_CUR);
  155.       long r = ::read(fd, buffer + bufferSize, (size_t)(BufferSize - bufferSize));
  156.       if (r == -1)
  157.         return r;
  158.  
  159.       bufferSize += r;
  160.  
  161.       bufferLeft = bufferSize - bufferOff;
  162.       if (_length > bufferLeft)
  163.         {
  164.           memcpy(_buffer, buffer + bufferOff, (size_t)bufferLeft);
  165.           bufferOff += bufferLeft;
  166.           return bufferLeft;
  167.         }
  168.  
  169.       memcpy(_buffer, buffer + bufferOff, _length);
  170.       bufferOff += _length;
  171.     }
  172.   return _length;
  173. }
  174.  
  175. char*
  176. CBufferedRead::getline(void)
  177. {
  178.   if (lineBufferLen == 0)
  179.     {
  180.       lineBufferLen = 64;
  181.       lineBuffer = new char[lineBufferLen];
  182.       CAssert(lineBuffer);
  183.     }
  184.  
  185.   *lineBuffer = '\0';
  186.  
  187.   int eof = 0;
  188.  
  189.   for (int got = 0; !eof;)
  190.     {
  191.       char ch;
  192.       if (read(&ch, sizeof(ch)) == sizeof(ch))
  193.         {
  194.           if (ch == '\n')
  195.             {
  196.               lineBuffer[got] = '\0';
  197.               break;
  198.             }
  199.           lineBuffer[got++] = ch;
  200.           if (got >= lineBufferLen)
  201.             {
  202.               lineBufferLen <<= 1;
  203.               char* ext = new char[lineBufferLen];
  204.               memcpy(ext, lineBuffer, got);
  205.               delete [] lineBuffer;
  206.               lineBuffer = ext;
  207.             }
  208.         }
  209.       else
  210.         eof = 1;
  211.     }
  212.   return !got && eof ? 0 : lineBuffer;
  213. }
  214.  
  215.  
  216.  
  217.