NetSession.cpp

Go to the documentation of this file.

/* Copyright (C) 2011 Wildfire Games.
 * This file is part of 0 A.D.
 *
 * 0 A.D. is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 2 of the License, or
 * (at your option) any later version.
 *
 * 0 A.D. is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with 0 A.D.  If not, see <http://www.gnu.org/licenses/>.
 */

#include "precompiled.h"
#include "NetSession.h"
#include "NetClient.h"
#include "NetServer.h"
#include "NetMessage.h"
#include "NetStats.h"
#include "lib/external_libraries/enet.h"
#include "ps/CLogger.h"
#include "scriptinterface/ScriptInterface.h"

static const int CHANNEL_COUNT = 1;

CNetClientSession::CNetClientSession(CNetClient& client) :
    m_Client(client), m_FileTransferer(this), m_Host(NULL), m_Server(NULL), m_Stats(NULL)
{
}

CNetClientSession::~CNetClientSession()
{
    delete m_Stats;

    if (m_Host && m_Server)
    {
        // Disconnect immediately (we can't wait for acks)
        enet_peer_disconnect_now(m_Server, NDR_UNEXPECTED_SHUTDOWN);
        enet_host_destroy(m_Host);

        m_Host = NULL;
        m_Server = NULL;
    }
}

bool CNetClientSession::Connect(u16 port, const CStr& server)
{
    ENSURE(!m_Host);
    ENSURE(!m_Server);

    // Create ENet host
    ENetHost* host = enet_host_create(NULL, 1, CHANNEL_COUNT, 0, 0);
    if (!host)
        return false;

    // Bind to specified host
    ENetAddress addr;
    addr.port = port;
    if (enet_address_set_host(&addr, server.c_str()) < 0)
        return false;

    // Initiate connection to server
    ENetPeer* peer = enet_host_connect(host, &addr, CHANNEL_COUNT, 0);
    if (!peer)
        return false;

    m_Host = host;
    m_Server = peer;

    m_Stats = new CNetStatsTable(m_Server);
    if (CProfileViewer::IsInitialised())
        g_ProfileViewer.AddRootTable(m_Stats);

    return true;
}

void CNetClientSession::Disconnect(u32 reason)
{
    ENSURE(m_Host && m_Server);

    // TODO: ought to do reliable async disconnects, probably
    enet_peer_disconnect_now(m_Server, reason);
    enet_host_destroy(m_Host);

    m_Host = NULL;
    m_Server = NULL;

    SAFE_DELETE(m_Stats);
}

void CNetClientSession::Poll()
{
    PROFILE3("net client poll");

    ENSURE(m_Host && m_Server);

    m_FileTransferer.Poll();

    ENetEvent event;
    while (enet_host_service(m_Host, &event, 0) > 0)
    {
        switch (event.type)
        {
        case ENET_EVENT_TYPE_CONNECT:
        {
            ENSURE(event.peer == m_Server);

            // Report the server address
            char hostname[256] = "(error)";
            enet_address_get_host_ip(&event.peer->address, hostname, ARRAY_SIZE(hostname));
            LOGMESSAGE(L"Net client: Connected to %hs:%u", hostname, (unsigned int)event.peer->address.port);

            m_Client.HandleConnect();

            break;
        }

        case ENET_EVENT_TYPE_DISCONNECT:
        {
            ENSURE(event.peer == m_Server);

            LOGMESSAGE(L"Net client: Disconnected");
            m_Client.HandleDisconnect(event.data);
            return;
        }

        case ENET_EVENT_TYPE_RECEIVE:
        {
            CNetMessage* msg = CNetMessageFactory::CreateMessage(event.packet->data, event.packet->dataLength, m_Client.GetScriptInterface());
            if (msg)
            {
                LOGMESSAGE(L"Net client: Received message %hs of size %lu from server", msg->ToString().c_str(), (unsigned long)msg->GetSerializedLength());

                m_Client.HandleMessage(msg);

                delete msg;
            }

            enet_packet_destroy(event.packet);

            break;
        }

        case ENET_EVENT_TYPE_NONE:
            break;
        }
    }

}

void CNetClientSession::Flush()
{
    PROFILE3("net client flush");

    ENSURE(m_Host && m_Server);

    enet_host_flush(m_Host);
}

bool CNetClientSession::SendMessage(const CNetMessage* message)
{
    ENSURE(m_Host && m_Server);

    return CNetHost::SendMessage(message, m_Server, "server");
}



CNetServerSession::CNetServerSession(CNetServerWorker& server, ENetPeer* peer) :
    m_Server(server), m_FileTransferer(this), m_Peer(peer)
{
}

void CNetServerSession::Disconnect(u32 reason)
{
    Update((uint)NMT_CONNECTION_LOST, NULL);

    enet_peer_disconnect(m_Peer, reason);
}

void CNetServerSession::DisconnectNow(u32 reason)
{
    enet_peer_disconnect_now(m_Peer, reason);
}

bool CNetServerSession::SendMessage(const CNetMessage* message)
{
    return m_Server.SendMessage(m_Peer, message);
}