renamed osparallelconnection to parallel connection. Updated all files and CMakeLists to use new name.

started rebase work on parallel connection

include/openspace/network/parallelconnection.h

@@ -0,0 +1,225 @@
+/*****************************************************************************************
+ *                                                                                       *
+ * OpenSpace                                                                             *
+ *                                                                                       *
+ * Copyright (c) 2014-2015                                                               *
+ *                                                                                       *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of this  *
+ * software and associated documentation files (the "Software"), to deal in the Software *
+ * without restriction, including without limitation the rights to use, copy, modify,    *
+ * merge, publish, distribute, sublicense, and/or sell copies of the Software, and to    *
+ * permit persons to whom the Software is furnished to do so, subject to the following   *
+ * conditions:                                                                           *
+ *                                                                                       *
+ * The above copyright notice and this permission notice shall be included in all copies *
+ * or substantial portions of the Software.                                              *
+ *                                                                                       *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED,   *
+ * INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A         *
+ * PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT    *
+ * HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF  *
+ * CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE  *
+ * OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.                                         *
+ ****************************************************************************************/
+
+#ifndef __PARALLELCONNECTION_H__
+#define __PARALLELCONNECTION_H__
+
+//openspace includes
+#include <openspace/scripting/scriptengine.h>
+#include <openspace/util/powerscaledcoordinate.h>
+
+//glm includes
+#include <glm/gtx/quaternion.hpp>
+
+//std includes
+#include <string>
+#include <vector>
+#include <atomic>
+#include <thread>
+#include <sstream>
+#include <mutex>
+
+#ifdef __WIN32__
+#ifndef WIN32_LEAN_AND_MEAN
+#define WIN32_LEAN_AND_MEAN
+#endif
+#include <windows.h>
+#include <winsock2.h>
+#include <ws2tcpip.h>
+#endif
+
+#if defined(__WIN32__) || defined(__MING32__) || defined(__MING64__)
+typedef size_t _SOCKET;
+#else
+typedef int _SOCKET;
+#include <netdb.h>
+#endif
+
+namespace openspace{
+    
+    namespace network{
+        
+        struct StreamDataKeyframe{
+            glm::quat _viewRotationQuat;
+            psc _position;
+            double _timeStamp;
+            
+            void serialize(std::vector<char> &buffer){
+                //add position
+                buffer.insert(buffer.end(), reinterpret_cast<char*>(&_position), reinterpret_cast<char*>(&_position) + sizeof(_position));
+                
+                //add orientation
+                buffer.insert(buffer.end(), reinterpret_cast<char*>(&_viewRotationQuat), reinterpret_cast<char*>(&_viewRotationQuat) + sizeof(_viewRotationQuat));
+                
+                //add timestamp
+                buffer.insert(buffer.end(), reinterpret_cast<char*>(&_timeStamp), reinterpret_cast<char*>(&_timeStamp) + sizeof(_timeStamp));
+            };
+            
+            void deserialize(const std::vector<char> &buffer){
+                int offset = 0;
+                int size = 0;
+                
+                //position
+                size = sizeof(_position);
+                memcpy(&_position, buffer.data() + offset, size);
+                offset += size;
+                
+                //orientation
+                size = sizeof(_viewRotationQuat);
+                memcpy(&_viewRotationQuat, buffer.data() + offset, size);
+                offset += size;
+                
+                //timestamp
+                size = sizeof(_timeStamp);
+                memcpy(&_timeStamp, buffer.data() + offset, size);
+            };
+        };
+
+        class ParallelConnection{
+        public:
+            
+            ParallelConnection();
+            
+            ~ParallelConnection();
+            
+            void clientConnect();
+            
+            void disconnect();
+            
+            void setPort(const std::string &port);
+            
+            std::string port();
+            
+            void setAddress(const std::string &address);
+            
+            std::string address();
+            
+            void setName(const std::string& name);
+            
+            std::string name();
+            
+            void setSocket(_SOCKET socket);
+            
+            _SOCKET clientSocket();
+            
+            void setHost(bool host);
+            
+            bool isHost();
+            
+            bool isRunning();
+            
+            void requestHostship();
+
+			void setPassword(const std::string &password);
+            
+            void sendScript(const std::string script);
+            
+            enum MessageTypes{
+                Authentication=0,
+                Initialization,
+                StreamData,
+                Script,
+                HostInfo,
+                InitializationRequest,
+                HostshipRequest
+            };
+            
+            /**
+             * Returns the Lua library that contains all Lua functions available to affect the
+             * remote OS parallel connection. The functions contained are
+             * -
+             * \return The Lua library that contains all Lua functions available to affect the
+             * interaction
+             */
+            static scripting::ScriptEngine::LuaLibrary luaLibrary();
+            
+        protected:
+            
+        private:
+			//@TODO change this into the ghoul hasher for client AND server
+			uint32_t hash(const std::string &val){
+				uint32_t hashVal = 0, i;
+				size_t len = val.length();
+
+				for (hashVal = i = 0; i < len; ++i){
+					hashVal += val.c_str()[i];
+					hashVal += (hashVal << 10);
+					hashVal ^= (hashVal >> 6);
+				}
+
+				hashVal += (hashVal << 3);
+				hashVal ^= (hashVal >> 11);
+				hashVal += (hashVal << 15);
+
+				return hashVal;
+			};
+            
+            void writeHeader(std::vector<char> &buffer);
+
+			void closeSocket();
+
+			bool initNetworkAPI();
+
+			void connection(addrinfo *info);
+
+			void authenticate();
+
+			void communicate();
+
+			void delegateDecoding(int type);
+
+			void decodeAuthenticationMessage();
+
+			void decodeInitializationMessage();
+
+			void decodeDataMessage();
+            
+            void decodeScript();
+
+			void decodeHostInfoMessage();
+			
+			void decodeInitializationRequestMessage();
+
+			void broadcast();
+            
+            int headerSize();
+
+            int receiveData(_SOCKET & socket, std::vector<char> &buffer, int length, int flags);
+            
+            int _headerSize;
+			uint32_t _passCode;
+            std::string _port;
+            std::string _address;
+            std::string _name;
+            _SOCKET _clientSocket;
+            std::thread *_connectionThread;
+			std::thread *_broadcastThread;
+            std::atomic<bool> _isRunning;
+            std::atomic<bool> _isHost;
+        };
+    } // namespace network
+    
+} // namespace openspace
+
+#endif // __OSPARALLELCONNECTION_H__