server_common/a8
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
azw 2023-08-19 15:43:55 +08:00
parent 66aa3a6fbb
commit 261a025565
2 changed files with 2 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
a8/websocketclient.cc
View File

@ -194,7 +194,7 @@ namespace a8
int prev_offset = 0; int prev_offset = 0;
do { do {
prev_offset = offset; prev_offset = offset;
DecodeUserPacket(decoded_buff_, offset, decoded_bufflen_); on_decode_userpacket(decoded_buff_, offset, decoded_bufflen_);
} while (prev_offset < offset && offset < decoded_bufflen_); } while (prev_offset < offset && offset < decoded_bufflen_);
if (offset > 0 && offset < decoded_bufflen_){ if (offset > 0 && offset < decoded_bufflen_){
@ -292,11 +292,6 @@ namespace a8
} }
} }
void WebSocketClient::DecodeUserPacket(char* buf, int& offset, unsigned int buflen)
{
int i = 0;
}
} }
#endif #endif

3
a8/websocketclient.h
View File

@ -20,7 +20,7 @@ namespace a8
std::function<void (a8::WebSocketClient*, int)> on_error; std::function<void (a8::WebSocketClient*, int)> on_error;
std::function<void (a8::WebSocketClient*)> on_connect; std::function<void (a8::WebSocketClient*)> on_connect;
std::function<void (a8::WebSocketClient*)> on_disconnect; std::function<void (a8::WebSocketClient*)> on_disconnect;
std::function<void (a8::WebSocketClient*, char*, unsigned int)> on_socketread; std::function<void (char*, int&, unsigned int)> on_decode_userpacket;
void Open(); void Open();
void Close(); void Close();
@ -30,7 +30,6 @@ namespace a8
private: private:
void DecodePacket(char* buf, int& offset, unsigned int buflen); void DecodePacket(char* buf, int& offset, unsigned int buflen);
void DecodeUserPacket(char* buf, int& offset, unsigned int buflen);
void ProcessHandShake(char* buf, int& offset, unsigned int buflen); void ProcessHandShake(char* buf, int& offset, unsigned int buflen);
void ProcessWsHandShake(char* buf, int& offset, unsigned int buflen); void ProcessWsHandShake(char* buf, int& offset, unsigned int buflen);