Changeset View
Changeset View
Standalone View
Standalone View
source/network/NetSession.h
/* Copyright (C) 2020 Wildfire Games. | /* Copyright (C) 2021 Wildfire Games. | ||||
* This file is part of 0 A.D. | * This file is part of 0 A.D. | ||||
* | * | ||||
* 0 A.D. is free software: you can redistribute it and/or modify | * 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 | * it under the terms of the GNU General Public License as published by | ||||
* the Free Software Foundation, either version 2 of the License, or | * the Free Software Foundation, either version 2 of the License, or | ||||
* (at your option) any later version. | * (at your option) any later version. | ||||
* | * | ||||
* 0 A.D. is distributed in the hope that it will be useful, | * 0 A.D. is distributed in the hope that it will be useful, | ||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of | * but WITHOUT ANY WARRANTY; without even the implied warranty of | ||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | ||||
* GNU General Public License for more details. | * GNU General Public License for more details. | ||||
* | * | ||||
* You should have received a copy of the GNU General Public License | * 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/>. | * along with 0 A.D. If not, see <http://www.gnu.org/licenses/>. | ||||
*/ | */ | ||||
#ifndef NETSESSION_H | #ifndef NETSESSION_H | ||||
#define NETSESSION_H | #define NETSESSION_H | ||||
#include "lib/external_libraries/enet.h" | #include "lib/external_libraries/enet.h" | ||||
#include "network/fsm.h" | #include "network/fsm.h" | ||||
#include "network/NetFileTransfer.h" | #include "network/NetFileTransfer.h" | ||||
#include "network/NetHost.h" | #include "network/NetHost.h" | ||||
#include "ps/CStr.h" | #include "ps/CStr.h" | ||||
#include "ps/ThreadPoolForward.h" | |||||
#include <boost/lockfree/queue.hpp> | #include <boost/lockfree/queue.hpp> | ||||
#include <atomic> | #include <atomic> | ||||
/** | /** | ||||
* Report the peer if we didn't receive a packet after this time (milliseconds). | * Report the peer if we didn't receive a packet after this time (milliseconds). | ||||
*/ | */ | ||||
Show All 39 Lines | public: | ||||
~CNetClientSession(); | ~CNetClientSession(); | ||||
bool Connect(const CStr& server, const u16 port, ENetHost* enetClient); | bool Connect(const CStr& server, const u16 port, ENetHost* enetClient); | ||||
/** | /** | ||||
* The client NetSession is threaded to avoid getting timeouts if the main thread hangs. | * The client NetSession is threaded to avoid getting timeouts if the main thread hangs. | ||||
* Call Connect() before starting this loop. | * Call Connect() before starting this loop. | ||||
*/ | */ | ||||
static void RunNetLoop(CNetClientSession* session); | static void StartRecurrentTask(CNetClientSession* session); | ||||
ThreadPool::RecurrentTaskStatus RunNetUpdate(Future<void>& future, ThreadPool::PoolExecutor& exec); | |||||
/** | /** | ||||
* Shut down the net session. | * Shut down the net session. | ||||
*/ | */ | ||||
void Shutdown(); | void Shutdown(); | ||||
/** | /** | ||||
* Processes pending messages. | * Processes pending messages. | ||||
Show All 15 Lines | public: | ||||
*/ | */ | ||||
u32 GetMeanRTT() const; | u32 GetMeanRTT() const; | ||||
CNetFileTransferer& GetFileTransferer() { return m_FileTransferer; } | CNetFileTransferer& GetFileTransferer() { return m_FileTransferer; } | ||||
private: | private: | ||||
/** | /** | ||||
* Process queued incoming messages. | * Process queued incoming messages. | ||||
*/ | */ | ||||
void Poll(); | void Poll(const ENetEvent& event); | ||||
/** | /** | ||||
* Flush queued outgoing network messages. | * Flush queued outgoing network messages. | ||||
*/ | */ | ||||
void Flush(); | void Flush(); | ||||
CNetClient& m_Client; | CNetClient& m_Client; | ||||
▲ Show 20 Lines • Show All 98 Lines • Show Last 20 Lines |
Wildfire Games · Phabricator