networkmanager.h

Go to the documentation of this file.

/*****************************************************************************************
 * SGCT                                                                                  *
 * Simple Graphics Cluster Toolkit                                                       *
 *                                                                                       *
 * Copyright (c) 2012-2026                                                               *
 * For conditions of distribution and use, see copyright notice in LICENSE.md            *
 ****************************************************************************************/
 
#ifndef __SGCT__NETWORKMANAGER__H__
#define __SGCT__NETWORKMANAGER__H__
 
#include <sgct/sgctexports.h>
 
#include <sgct/network.h>
#include <condition_variable>
#include <functional>
#include <memory>
#include <optional>
#include <string>
#include <string_view>
#include <utility>
#include <vector>
 
namespace sgct {
 
class Network;

class SGCT_EXPORT NetworkManager {
public:
    enum class SyncMode { SendDataToClients = 0, Acknowledge };
    enum class NetworkMode { Remote = 0, LocalServer, LocalClient };
 
    static NetworkManager& instance();
    static void create(NetworkMode nm,
        std::function<void(void*, int, int, int)> dataTransferDecode,
        std::function<void(bool, int)> dataTransferStatus,
        std::function<void(int, int)> dataTransferAcknowledge);
    static void destroy();
 
    static std::condition_variable cond;
 
    ~NetworkManager();
 
    void initialize();
    void clearCallbacks();

    std::optional<std::pair<double, double>> sync(SyncMode sm) const;

    bool isSyncComplete() const;
 
    bool matchesAddress(std::string_view address) const;

    bool isComputerServer() const;
    bool isRunning() const;
    bool areAllNodesConnected() const;
    void transferData(const void* data, int length, int packageId) const;
    void transferData(const void* data, int length, int packageId,
        const Network& connection) const;
 
    unsigned int activeConnectionsCount() const;
    int connectionsCount() const;
    int syncConnectionsCount() const;
    const Network& connection(int index) const;
    const Network& syncConnection(int index) const;
 
private:
    static NetworkManager* _instance;
 
    NetworkManager(NetworkMode nm,
        std::function<void(void*, int, int, int)> dataTransferDecode,
        std::function<void(bool, int)> dataTransferStatus,
        std::function<void(int, int)> dataTransferAcknowledge);
    NetworkManager(const NetworkManager&) = delete;
    NetworkManager(NetworkManager&&) = delete;
    NetworkManager& operator=(const NetworkManager&) = delete;
    NetworkManager& operator=(NetworkManager&&) = delete;
 
 
    void addConnection(int port, std::string address,
        Network::ConnectionType connectionType = Network::ConnectionType::SyncConnection);
    void updateConnectionStatus(Network& connection);
    void setAllNodesConnected();
 
    std::function<void(void*, int, int, int)> _dataTransferDecodeFn;
    std::function<void(bool, int)> _dataTransferStatusFn;
    std::function<void(int, int)> _dataTransferAcknowledgeFn;
 
    // This could be a std::vector<Network>, but Network is not move-constructible
    // because of the std::condition_variable in it
    std::vector<std::unique_ptr<Network>> _networkConnections;
    std::vector<Network*> _syncConnections;
    std::vector<Network*> _dataTransferConnections;
 
    std::vector<std::string> _localAddresses;
 
    bool _isServer = true;
    bool _isRunning = true;
    bool _allNodesConnected = false;
    const NetworkMode _mode;
    unsigned int _nActiveConnections = 0;
    unsigned int _nActiveSyncConnections = 0;
    unsigned int _nActiveDataTransferConnections = 0;
};
 
} // namespace sgct
 
#endif // __SGCT__NETWORKMANAGER__H__