summaryrefslogtreecommitdiff
path: root/src/inspector_socket_server.cc
diff options
context:
space:
mode:
Diffstat (limited to 'src/inspector_socket_server.cc')
-rw-r--r--src/inspector_socket_server.cc25
1 files changed, 12 insertions, 13 deletions
diff --git a/src/inspector_socket_server.cc b/src/inspector_socket_server.cc
index 1e1d0ff567..f3e56b6ceb 100644
--- a/src/inspector_socket_server.cc
+++ b/src/inspector_socket_server.cc
@@ -230,9 +230,9 @@ class SocketSession {
private:
enum class State { kHttp, kWebSocket, kClosing, kEOF, kDeclined };
- static void CloseCallback_(InspectorSocket* socket, int code);
- static void ReadCallback_(uv_stream_t* stream, ssize_t read,
- const uv_buf_t* buf);
+ static void CloseCallback(InspectorSocket* socket, int code);
+ static void ReadCallback(uv_stream_t* stream, ssize_t read,
+ const uv_buf_t* buf);
void OnRemoteDataIO(ssize_t read, const uv_buf_t* buf);
const int id_;
InspectorSocket socket_;
@@ -242,9 +242,10 @@ class SocketSession {
};
InspectorSocketServer::InspectorSocketServer(SocketServerDelegate* delegate,
+ uv_loop_t* loop,
const std::string& host,
int port,
- FILE* out) : loop_(nullptr),
+ FILE* out) : loop_(loop),
delegate_(delegate),
host_(host),
port_(port),
@@ -255,7 +256,6 @@ InspectorSocketServer::InspectorSocketServer(SocketServerDelegate* delegate,
state_ = ServerState::kNew;
}
-
// static
bool InspectorSocketServer::HandshakeCallback(InspectorSocket* socket,
inspector_handshake_event event,
@@ -361,7 +361,7 @@ void InspectorSocketServer::SendListResponse(InspectorSocket* socket) {
}
if (!connected) {
std::string host;
- GetSocketHost(&socket->client, &host);
+ GetSocketHost(&socket->tcp, &host);
std::string address = GetWsUrl(host, port_, id);
std::ostringstream frontend_url;
frontend_url << "chrome-devtools://devtools/bundled";
@@ -374,9 +374,8 @@ void InspectorSocketServer::SendListResponse(InspectorSocket* socket) {
SendHttpResponse(socket, MapsToString(response));
}
-bool InspectorSocketServer::Start(uv_loop_t* loop) {
+bool InspectorSocketServer::Start() {
CHECK_EQ(state_, ServerState::kNew);
- loop_ = loop;
sockaddr_in addr;
uv_tcp_init(loop_, &server_);
uv_ip4_addr(host_.c_str(), port_, &addr);
@@ -470,11 +469,11 @@ SocketSession::SocketSession(InspectorSocketServer* server, int id)
void SocketSession::Close() {
CHECK_NE(state_, State::kClosing);
state_ = State::kClosing;
- inspector_close(&socket_, CloseCallback_);
+ inspector_close(&socket_, CloseCallback);
}
// static
-void SocketSession::CloseCallback_(InspectorSocket* socket, int code) {
+void SocketSession::CloseCallback(InspectorSocket* socket, int code) {
SocketSession* session = SocketSession::From(socket);
CHECK_EQ(State::kClosing, session->state_);
session->server_->SessionTerminated(session);
@@ -483,12 +482,12 @@ void SocketSession::CloseCallback_(InspectorSocket* socket, int code) {
void SocketSession::FrontendConnected() {
CHECK_EQ(State::kHttp, state_);
state_ = State::kWebSocket;
- inspector_read_start(&socket_, OnBufferAlloc, ReadCallback_);
+ inspector_read_start(&socket_, OnBufferAlloc, ReadCallback);
}
// static
-void SocketSession::ReadCallback_(uv_stream_t* stream, ssize_t read,
- const uv_buf_t* buf) {
+void SocketSession::ReadCallback(uv_stream_t* stream, ssize_t read,
+ const uv_buf_t* buf) {
InspectorSocket* socket = inspector_from_stream(stream);
SocketSession::From(socket)->OnRemoteDataIO(read, buf);
}