mirror/OpenSpace
1
0
Fork 0
mirror of https://github.com/OpenSpace/OpenSpace.git synced 2026-01-06 03:29:44 -06:00
Code Issues Packages Projects Releases Wiki Activity

created a send que for messages and a thread to handle sending

Browse Source
This commit is contained in:
Joakim Kilby
2015-07-01 09:55:13 +02:00
parent 0b3552ea09
commit d6cb939474
2 changed files with 51 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
include/openspace/network/parallelconnection.h
View File

@@ -129,6 +129,8 @@ namespace openspace{
void sendScript(const std::string script);
void queMessage(std::vector<char> message);
enum MessageTypes{
Authentication=0,
Initialization,
@@ -199,6 +201,8 @@ namespace openspace{
int receiveData(_SOCKET & socket, std::vector<char> &buffer, int length, int flags);
void sendLoop();
uint32_t _passCode;
std::string _port;
std::string _address;
@@ -206,11 +210,12 @@ namespace openspace{
_SOCKET _clientSocket;
std::thread *_connectionThread;
std::thread *_broadcastThread;
std::thread *_sendThread;
std::atomic<bool> _isHost;
std::atomic<bool> _isConnected;
std::atomic<bool> _isListening;
std::vector<std::string> _executedScripts;
std::mutex _executedScriptsMutex;
std::vector<std::vector<char>> _sendBuffer;
std::mutex _sendBufferMutex;
};
} // namespace network