NetworkConnectionManager.h

#ifndef WRENCH_NETWORKCONNECTIONMANAGER_H
#define WRENCH_NETWORKCONNECTIONMANAGER_H


#include <string>
#include <deque>
#include "wrench/services/storage/simple/NetworkConnection.h"

namespace wrench {

    /***********************/
    /***********************/

    class NetworkConnectionManager {

    public:
        NetworkConnectionManager(unsigned long max_num_data_connections);

        void addConnection(std::unique_ptr<NetworkConnection> connection);

        std::pair<std::unique_ptr<NetworkConnection>, bool> waitForNetworkConnection();


    private:
        unsigned long max_num_data_connections;

        void startQueuedDataConnections();

        std::deque<std::unique_ptr<NetworkConnection>> queued_data_connections;
        std::vector<std::unique_ptr<NetworkConnection>> running_data_connections;
        std::unique_ptr<NetworkConnection> running_control_connection = nullptr;


    };

    /***********************/
    /***********************/
};


#endif //WRENCH_NETWORKCONNECTIONMANAGER_H