pengjunjie/core
1
0
Fork 1
mirror of https://github.com/ONLYOFFICE/core.git synced 2026-04-07 13:55:33 +08:00
Code Issues Packages Projects Releases Wiki Activity

restored v8.pri and ixwebsocket sources

Browse Source
This commit is contained in:
Maxim Selyanin
2021-07-30 14:06:49 +03:00
parent 7698d47e09
commit af184659f3
3 changed files with 9 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
Common/Network/WebSocket/src/ixwebsocket/ixwebsocket_internal.cpp
View File

@ -31,17 +31,11 @@
*/
#include "ixwebsocket_internal.h"
#include <iostream>
namespace NSNetwork
{
namespace NSWebSocket
{
CIXWebSocket::CIXWebSocket(const std::string &url, std::shared_ptr<IListener> listener): CWebWorkerBase(url, listener)
{
//
}
void CIXWebSocket::open()
{
ix::SocketTLSOptions tls;
@ -65,14 +59,6 @@ namespace NSNetwork
}
else if (msg->type == ix::WebSocketMessageType::Error)
{
auto errinfo = msg->errorInfo;
std::cerr << std::boolalpha
<< "is decomp err " << errinfo.decompressionError << std::endl
<< "http status " << errinfo.http_status << std::endl
<< "reason " << errinfo.reason << std::endl
<< "retries " << errinfo.retries << std::endl
<< "wait time " << errinfo.wait_time << std::endl
<< std::endl;
CWebWorkerBase::listener->onError(msg->errorInfo.reason);
}
else if (msg->type == ix::WebSocketMessageType::Close)
@ -81,11 +67,6 @@ namespace NSNetwork
}
}
CIXWebSocket::~CIXWebSocket()
{
this->close();
}
void CIXWebSocket::send(const std::string& message)
{
webSocket.send(message);
@ -95,5 +76,7 @@ namespace NSNetwork
{
webSocket.stop();
}
CIXWebSocket::~CIXWebSocket() = default;
}
}

8
Common/Network/WebSocket/src/ixwebsocket/ixwebsocket_internal.h
View File

@ -48,13 +48,19 @@ namespace NSNetwork
public:
CIXWebSocket(const std::string& url, std::shared_ptr<IListener> listener);
CIXWebSocket(const std::string& url, std::shared_ptr<IListener> listener): CWebWorkerBase(url, listener)
{
ix::initNetSystem();
}
public:
virtual void open() override;
virtual void send(const std::string& message) override;
virtual void close() override;
void receive(const ix::WebSocketMessagePtr& msg);
virtual ~CIXWebSocket();
};
}
}