fin_(),

opcode_(),

mask_(),

masking_key_(),

payload_length_(),

payload_()

{

int pos = 0;

fetch_fin(msg, pos);

fetch_opcode(msg, pos);

fetch_mask(msg, pos);

fetch_payload_length(msg, pos);

fetch_masking_key(msg, pos);

return fetch_payload(msg, pos);

DEBUG_LOG("WEBSOCKET PROTOCOL\n"

"FIN: %d\n"

"OPCODE: %d\n"

"MASK: %d\n"

"PAYLOADLEN: %d\n"

"PAYLOAD: %s",

fin_, opcode_, mask_, payload_length_, payload_);

fin_ = 0;

opcode_ = 0;

mask_ = 0;

memset(masking_key_, 0, sizeof(masking_key_));

payload_length_ = 0;

memset(payload_, 0, sizeof(payload_));

if (payload_length_ > 0) {

payload.assign(payload_, payload_length_);

}

return payload_length_;

opcode_ = msg[pos] & 0x0f;

pos++;

return 0;

if(mask_ != 1)

return 0;

for(int i = 0; i < 4; i++)

masking_key_[i] = msg[pos + i];

pos += 4;

return 0;

payload_length_ = msg[pos] & 0x7f;

pos++;

if(payload_length_ == 126){

uint16_t length = 0;

memcpy(&length, msg + pos, 2);

pos += 2;

payload_length_ = ntohs(length);

}

else if(payload_length_ == 127){

uint32_t length = 0;

memcpy(&length, msg + pos, 4);

pos += 4;

payload_length_ = ntohl(length);

}

return 0;

memset(payload_, 0, sizeof(payload_));

if(mask_ != 1){

memcpy(payload_, msg + pos, payload_length_);

}

else {

for(uint i = 0; i < payload_length_; i++){

int j = i % 4;

payload_[i] = msg[pos + i] ^ masking_key_[j];

}

}

pos += payload_length_;

return 0;