SocketReader.cpp

   1 #include "SocketReader.h"
   2
   3 CSocketReader::CSocketReader(SOCKET s)
   4         : buffer(NULL), bufferSize(0), readedPointer(0), TEMP_READ_BUFFER_SIZE(1024), socket(s)
   5 {}
   6
   7 CSocketReader::~CSocketReader(void)
   8 {
   9         SAFE_DELETE_ARRAY(buffer);
  10 }
  11
  12 bool CSocketReader::read()
  13 {
  14         char *buf = new char[TEMP_READ_BUFFER_SIZE];
  15         int readed = 0;
  16
  17         while ((readed = recv(socket, buf, TEMP_READ_BUFFER_SIZE, 0/*MSG_DONTWAIT*/)) > 0)
  18         {
  19                 buffer = (char*)realloc(buffer, bufferSize+readed);
  20                 memcpy( &buffer[bufferSize], buf, readed);
  21         }
  22
  23         SAFE_DELETE_ARRAY(buf);
  24         return true;
  25 }
  26
  27 int CSocketReader::getData(int size, char* buff)
  28 {
  29         /**
  30          * \todo implement
  31          */
  32         return 0;
  33 }
  34