diff options
Diffstat (limited to 'src/unstable')
-rw-r--r-- | src/unstable/protocolwebsocket.cpp | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/src/unstable/protocolwebsocket.cpp b/src/unstable/protocolwebsocket.cpp index 0beb5d4..9e8b1de 100644 --- a/src/unstable/protocolwebsocket.cpp +++ b/src/unstable/protocolwebsocket.cpp | |||
@@ -67,6 +67,7 @@ void Bu::ProtocolWebSocket::onNewData( Bu::Client * /*pClient*/ ) | |||
67 | void Bu::ProtocolWebSocket::writeMessage( const Bu::String &sData, | 67 | void Bu::ProtocolWebSocket::writeMessage( const Bu::String &sData, |
68 | Bu::ProtocolWebSocket::Operation eOp ) | 68 | Bu::ProtocolWebSocket::Operation eOp ) |
69 | { | 69 | { |
70 | //Bu::println("websocket: Writing message, %1 bytes").arg( sData.getSize() ); | ||
70 | uint8_t cHeader[32]; | 71 | uint8_t cHeader[32]; |
71 | //uint8_t *cMask; | 72 | //uint8_t *cMask; |
72 | memset( cHeader, 0, 32 ); | 73 | memset( cHeader, 0, 32 ); |
@@ -78,10 +79,12 @@ void Bu::ProtocolWebSocket::writeMessage( const Bu::String &sData, | |||
78 | uint64_t iLen = sData.getSize(); | 79 | uint64_t iLen = sData.getSize(); |
79 | if( iLen < 126 ) | 80 | if( iLen < 126 ) |
80 | { | 81 | { |
82 | //Bu::println("websocket: --> Tiny header"); | ||
81 | cHeader[1] = ((uint8_t)iLen); | 83 | cHeader[1] = ((uint8_t)iLen); |
82 | } | 84 | } |
83 | else if( iLen < 2147483648 ) | 85 | else if( iLen < 65536 ) |
84 | { | 86 | { |
87 | //Bu::println("websocket: --> Mid header"); | ||
85 | cHeader[1] = ((uint8_t)126); | 88 | cHeader[1] = ((uint8_t)126); |
86 | uint16_t uLen = iLen; | 89 | uint16_t uLen = iLen; |
87 | uLen = htobe16( uLen ); | 90 | uLen = htobe16( uLen ); |
@@ -90,6 +93,7 @@ void Bu::ProtocolWebSocket::writeMessage( const Bu::String &sData, | |||
90 | } | 93 | } |
91 | else | 94 | else |
92 | { | 95 | { |
96 | // Bu::println("websocket: --> Big header?"); | ||
93 | cHeader[1] = ((uint8_t)127); | 97 | cHeader[1] = ((uint8_t)127); |
94 | uint64_t iTmp = htobe64( iLen ); | 98 | uint64_t iTmp = htobe64( iLen ); |
95 | memcpy( cHeader+idx, &iTmp, 8 ); | 99 | memcpy( cHeader+idx, &iTmp, 8 ); |
@@ -145,6 +149,8 @@ bool Bu::ProtocolWebSocket::stateProtoId() | |||
145 | 149 | ||
146 | bool Bu::ProtocolWebSocket::stateHandshake() | 150 | bool Bu::ProtocolWebSocket::stateHandshake() |
147 | { | 151 | { |
152 | //Bu::println("websocket: Begining handshake."); | ||
153 | |||
148 | Bu::String sLine; | 154 | Bu::String sLine; |
149 | if( !readHttpHdrLine( sLine ) ) | 155 | if( !readHttpHdrLine( sLine ) ) |
150 | return false; | 156 | return false; |
@@ -234,6 +240,8 @@ bool Bu::ProtocolWebSocket::processHeaders() | |||
234 | "\r\n" | 240 | "\r\n" |
235 | ); | 241 | ); |
236 | 242 | ||
243 | //Bu::println("websocket: Switching protocols."); | ||
244 | |||
237 | return true; | 245 | return true; |
238 | } | 246 | } |
239 | 247 | ||
@@ -253,6 +261,8 @@ bool Bu::ProtocolWebSocket::headerMatch( const Bu::String &sKey, const Bu::Strin | |||
253 | 261 | ||
254 | bool Bu::ProtocolWebSocket::parseMessage() | 262 | bool Bu::ProtocolWebSocket::parseMessage() |
255 | { | 263 | { |
264 | //Bu::println("websocket: Recieved message, input available: %1").arg( pClient->getInputSize() ); | ||
265 | |||
256 | if( pClient->getInputSize() < 2 ) | 266 | if( pClient->getInputSize() < 2 ) |
257 | return false; | 267 | return false; |
258 | 268 | ||