github
/
aria2
mirror of https://github.com/aria2/aria2
1
0
Fork 0
Code Issues Releases Wiki Activity

Enabled TCP_NODELAY in SocketCore::establishConnection and acceptConnection

pull/36/head
Tatsuhiro Tsujikawa 2012-11-28 00:20:43 +09:00
parent e781e6eac1
commit 16e25ef4e1
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/HttpServerCommand.cc
View File

@ -220,7 +220,6 @@ bool HttpServerCommand::execute()
httpServer_->feedUpgradeResponse("websocket", httpServer_->feedUpgradeResponse("websocket",
fmt("Sec-WebSocket-Accept: %s\r\n", fmt("Sec-WebSocket-Accept: %s\r\n",
serverKey.c_str())); serverKey.c_str()));
httpServer_->getSocket()->setTcpNodelay(true);
command = new rpc::WebSocketResponseCommand(getCuid(), httpServer_, command = new rpc::WebSocketResponseCommand(getCuid(), httpServer_,
e_, socket_); e_, socket_);
} else { } else {

2
src/SocketCore.cc
View File

@ -369,6 +369,7 @@ SharedHandle<SocketCore> SocketCore::acceptConnection() const
} }
SharedHandle<SocketCore> sock(new SocketCore(fd, sockType_)); SharedHandle<SocketCore> sock(new SocketCore(fd, sockType_));
sock->setNonBlockingMode(); sock->setNonBlockingMode();
sock->setTcpNodelay(true);
return sock; return sock;
} }
@ -461,6 +462,7 @@ void SocketCore::establishConnection(const std::string& host, uint16_t port)
sockfd_ = fd; sockfd_ = fd;
// make socket non-blocking mode // make socket non-blocking mode
setNonBlockingMode(); setNonBlockingMode();
setTcpNodelay(true);
if(connect(fd, rp->ai_addr, rp->ai_addrlen) == -1 && if(connect(fd, rp->ai_addr, rp->ai_addrlen) == -1 &&
SOCKET_ERRNO != A2_EINPROGRESS) { SOCKET_ERRNO != A2_EINPROGRESS) {
errNum = SOCKET_ERRNO; errNum = SOCKET_ERRNO;