1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
#pragma once
#if defined(WITH_MULTIPLAYER) || defined(DOXYGEN_GENERATING_OUTPUT)
#include "NetworkManagerBase.h"
#include "MpGameMode.h"
#include "ServerInitialization.h"
#include "PeerDescriptor.h"
#include "../../nCine/Threading/LockedPtr.h"
namespace Jazz2::Actors::Multiplayer
{
class MpPlayer;
}
namespace Jazz2::Multiplayer
{
/**
@brief Manages game-specific network connections
@experimental
*/
class NetworkManager : public NetworkManagerBase
{
public:
NetworkManager();
~NetworkManager();
NetworkManager(const NetworkManager&) = delete;
NetworkManager& operator=(const NetworkManager&) = delete;
void CreateClient(INetworkHandler* handler, StringView endpoint, std::uint16_t defaultPort, std::uint32_t clientData) override;
/** @brief Creates a server that accepts incoming connections */
virtual bool CreateServer(INetworkHandler* handler, ServerConfiguration&& serverConfig);
void Dispose() override;
/** @brief Returns server configuration */
ServerConfiguration& GetServerConfiguration() const;
/** @brief Returns connected peer count */
std::uint32_t GetPeerCount();
/** @brief Returns all connected peers */
LockedPtr<const HashMap<Peer, std::shared_ptr<PeerDescriptor>>, Spinlock> GetPeers();
/** @brief Returns session peer descriptor for the local peer */
std::shared_ptr<PeerDescriptor> GetPeerDescriptor(LocalPeerT);
/** @brief Returns session peer descriptor for the specified connected remote peer */
std::shared_ptr<PeerDescriptor> GetPeerDescriptor(const Peer& peer);
/** @brief Returns `true` if there are any inbound connections */
bool HasInboundConnections() const;
/** @brief Reloads server configuration from the source file */
void RefreshServerConfiguration();
/** @brief Sets status provider */
void SetStatusProvider(std::weak_ptr<IServerStatusProvider> statusProvider);
/**
* @brief Creates a default server configuration from the default template file
*
* This method reads a JSON configuration file described in @ref ServerConfiguration. If the JSON
* contains a @cpp "$include" @ce directive, it recursively loads the referenced files.
*/
static ServerConfiguration CreateDefaultServerConfiguration();
/**
* @brief Loads a server configuration from the specified file
*
* This method reads a JSON configuration file described in @ref ServerConfiguration. If the JSON
* contains a @cpp "$include" @ce directive, it recursively loads the referenced files.
*/
static ServerConfiguration LoadServerConfigurationFromFile(StringView path);
/** @brief Converts @ref MpGameMode to the string representation */
static StringView GameModeToString(MpGameMode mode);
/** @brief Converts the non-localized string representation back to @ref MpGameMode */
static MpGameMode StringToGameMode(StringView value);
/** @brief Converts UUID to the string representation */
static String UuidToString(StaticArrayView<Uuid::Size, Uuid::Type> uuid);
protected:
#ifndef DOXYGEN_GENERATING_OUTPUT
using NetworkManagerBase::CreateServer;
#endif
ConnectionResult OnPeerConnected(const Peer& peer, std::uint32_t clientData) override;
void OnPeerDisconnected(const Peer& peer, Reason reason) override;
private:
std::unique_ptr<ServerConfiguration> _serverConfig;
std::unique_ptr<ServerDiscovery> _discovery;
HashMap<Peer, std::shared_ptr<PeerDescriptor>> _peerDesc;
Spinlock _lock;
String OnOverrideContentPath(StringView path);
static void FillServerConfigurationFromFile(StringView path, ServerConfiguration& serverConfig, HashMap<String, bool>& includedFiles, std::int32_t level);
static void VerifyServerConfiguration(ServerConfiguration& serverConfig);
};
}
#endif
|
