ConnectionContext *con,

size_t dataLength,

uint8_t *pMask,

size_t bufferSize

) {

_con = con; // The socket we will be reading from

_dataLength = dataLength; // The size of the record we wish to read.

_pMask = pMask;

_bufferSize = bufferSize; // The size of the buffer used to hold data

_sizeRead = 0; // The size of data read from the socket

_buffer = new char[bufferSize]; // Create the buffer used to hold the data read from the socket.

setg(_buffer, _buffer, _buffer); // Set the initial get buffer pointers to no data.

uint8_t byte;

HTTPS_LOGD(">> WebsocketContext.discard(): %d bytes", _dataLength - _sizeRead);

while(_sizeRead < _dataLength) {

_con->readBuffer(&byte, 1);

_sizeRead++;

}

HTTPS_LOGD("<< WebsocketContext.discard()");

HTTPS_LOGD(">> WebSocketInputStreambuf.underflow()");

// If we have already read as many bytes as our record definition says we should read

// then don't attempt to ready any further.

if (_sizeRead >= getRecordSize()) {

HTTPS_LOGD("<< WebSocketInputStreambuf.underflow(): Already read maximum");

return EOF;

}

// We wish to refill the buffer. We want to read data from the socket. We want to read either

// the size of the buffer to fill it or the maximum number of bytes remaining to be read.

// We will choose which ever is smaller as the number of bytes to read into the buffer.

int remainingBytes = getRecordSize()-_sizeRead;

size_t sizeToRead;

if (remainingBytes < _bufferSize) {

sizeToRead = remainingBytes;

} else {

sizeToRead = _bufferSize;

}

HTTPS_LOGD("WebSocketInputRecordStreambuf - getting next buffer of data; size request: %d", sizeToRead);

int bytesRead = _con->readBuffer((uint8_t*)_buffer, sizeToRead);

if (bytesRead == 0) {

HTTPS_LOGD("<< WebSocketInputRecordStreambuf.underflow(): Read 0 bytes");

return EOF;

}

// If the WebSocket frame shows that we have a mask bit set then we have to unmask the data.

if (_pMask != nullptr) {

for (int i=0; i<bytesRead; i++) {

_buffer[i] = _buffer[i] ^ _pMask[(_sizeRead+i)%4];

}

}

_sizeRead += bytesRead; // Increase the count of number of bytes actually read from the source.

setg(_buffer, _buffer, _buffer + bytesRead); // Change the buffer pointers to reflect the new data read.

HTTPS_LOGD("<< WebSocketInputRecordStreambuf.underflow(): got %d bytes", bytesRead);

return traits_type::to_int_type(*gptr());