NewConnection()

void Spices::Net::TcpServer::NewConnection ( SOCKET socketFd, const InetAddress & peerAddress )

private

Handle New Connection to Acceptor.

Parameters

socketFd	Accept return SOCKET.
peerAddress	Accept return Address.

Definition at line 57 of file TcpServer.cpp.

    {
        SPICES_PROFILE_ZONE;
 
        EventLoop* ioLoop = m_ThreadPool->GetNextLoop();
        char buf[64] = {};
        snprintf(buf, sizeof(buf), "-%s#%d", m_IpPort.c_str(), m_NextConnectedId);
        ++m_NextConnectedId;
        std::string connName = buf;
 
        sockaddr_in local = {};
        socklen_t addrLen = sizeof(local);
        if (::getsockname(socketFd, (sockaddr*)&local, &addrLen) < 0)
        {
            std::stringstream ss;
            ss << "TcpServer::NewConnection::getsockname error, fd: " << socketFd << ", Error: " << WSAGetLastError();
 
            SPICES_CORE_ERROR(ss.str())
        }
        InetAddress localAddress(local);
 
        const TcpConnectionPtr connectionPtr = std::make_shared<TcpConnection>(ioLoop, connName, socketFd, localAddress, peerAddress);
        m_Connections[connName] = connectionPtr;
 
        connectionPtr->SetConnectionCallback(m_ConnectionCallback);
        connectionPtr->SetMessageCallback(m_MessageCallback);
        connectionPtr->SetWriteCompleteCallback(m_WriteCompleteCallback);
 
        DelegateCloseCallback closeCallback;
        closeCallback.Bind([=](const TcpConnectionPtr& connection) { RemoveConnection(connection); });
        connectionPtr->SetCloseCallback(closeCallback);
 
        ioLoop->RunInLoop([=]() { connectionPtr->ConnectEstablished(); });
    }

References m_IpPort, m_NextConnectedId, and RemoveConnection().