From 8b00d67febf133e89f6a0bfabc41feed555dc4a9 Mon Sep 17 00:00:00 2001 From: chai Date: Sat, 12 Jan 2019 21:48:33 +0800 Subject: =?UTF-8?q?*=E5=8E=BB=E6=8E=89=E6=96=87=E4=BB=B6=E5=89=8D=E7=BC=80?= =?UTF-8?q?je=5F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/libjin/net/je_net_manager.cpp | 24 ----- src/libjin/net/je_net_manager.h | 48 ---------- src/libjin/net/je_socket.cpp | 190 -------------------------------------- src/libjin/net/je_socket.h | 146 ----------------------------- src/libjin/net/net_manager.cpp | 24 +++++ src/libjin/net/net_manager.h | 48 ++++++++++ src/libjin/net/socket.cpp | 190 ++++++++++++++++++++++++++++++++++++++ src/libjin/net/socket.h | 146 +++++++++++++++++++++++++++++ 8 files changed, 408 insertions(+), 408 deletions(-) delete mode 100644 src/libjin/net/je_net_manager.cpp delete mode 100644 src/libjin/net/je_net_manager.h delete mode 100644 src/libjin/net/je_socket.cpp delete mode 100644 src/libjin/net/je_socket.h create mode 100644 src/libjin/net/net_manager.cpp create mode 100644 src/libjin/net/net_manager.h create mode 100644 src/libjin/net/socket.cpp create mode 100644 src/libjin/net/socket.h (limited to 'src/libjin/net') diff --git a/src/libjin/net/je_net_manager.cpp b/src/libjin/net/je_net_manager.cpp deleted file mode 100644 index 553f9cb..0000000 --- a/src/libjin/net/je_net_manager.cpp +++ /dev/null @@ -1,24 +0,0 @@ -#include "je_net_manager.h" - -namespace JinEngine -{ - namespace Net - { - - bool NetManager::startSystem(const SettingBase* setting) - { - #ifdef _WIN32 - #if jin_net == jin_net_tekcos - tk_init(); - #endif - #endif - return true; - } - - void NetManager::quitSystem() - { - - } - - } // namespace Net -} // namespace JinEngine \ No newline at end of file diff --git a/src/libjin/net/je_net_manager.h b/src/libjin/net/je_net_manager.h deleted file mode 100644 index 1271e37..0000000 --- a/src/libjin/net/je_net_manager.h +++ /dev/null @@ -1,48 +0,0 @@ -#ifndef __JE_NET_H__ -#define __JE_NET_H__ -#include "../core/je_configuration.h" -#if defined(jin_net) - -#include "../common/je_subsystem.hpp" - -#include "je_socket.h" - -namespace JinEngine -{ - namespace Net - { - - /// - /// - /// - class NetManager : public Subsystem - { - public: - /// - /// - /// - NetManager() {}; - - /// - /// - /// - ~NetManager() {}; - - /// - /// - /// - bool startSystem(const SettingBase* setting) override; - - /// - /// - /// - void quitSystem() override; - - }; - - } // namespace Net -} // namespace JinEngine - -#endif // defined(jin_net) - -#endif // __JE_NET_H__ \ No newline at end of file diff --git a/src/libjin/net/je_socket.cpp b/src/libjin/net/je_socket.cpp deleted file mode 100644 index 68f9aed..0000000 --- a/src/libjin/net/je_socket.cpp +++ /dev/null @@ -1,190 +0,0 @@ -#include "je_socket.h" - -namespace JinEngine -{ - namespace Net - { - Socket::Socket(const Socket& socket) - : mHandle(socket.mHandle) - , mType(socket.mType) - { - } - - Socket::Socket(const SocketInformation& info) - : mType(info.type) - { - if (mType == SocketType::TCP) - { - tk_IPaddress ip; - ip.host = info.address; - ip.port = info.port; - mHandle.tcpHandle = tk_tcp_open(ip); - } - else if (mType == SocketType::UDP) - { - mHandle.udpHandle = tk_udp_open(info.port); - } - } - - Socket::Socket(SocketType type, const char* address, unsigned short port) - { - mType = type; - if (mType == SocketType::TCP) - { - tk_IPaddress ip; - #if jin_net == jin_net_tekcos - ip.host = tk_strtohl(address); - ip.port = port; - mHandle.tcpHandle = tk_tcp_open(ip); - #endif - } - else if (mType == SocketType::UDP) - { - mHandle.udpHandle = tk_udp_open(port); - } - } - - Socket::Socket(SocketType type, unsigned int address, unsigned short port) - { - mType = type; - if (mType == SocketType::TCP) - { - tk_IPaddress ip; - ip.host = address; - ip.port = port; - mHandle.tcpHandle = tk_tcp_open(ip); - } - else if (mType == SocketType::UDP) - { - mHandle.udpHandle = tk_udp_open(port); - } - } - - Socket::Socket(SocketType type, unsigned short port) - { - mType = type; - if (mType == SocketType::TCP) - { - tk_IPaddress ip; - ip.host = 0; - ip.port = port; - mHandle.tcpHandle = tk_tcp_open(ip); - } - else if (mType == SocketType::UDP) - { - mHandle.udpHandle = tk_udp_open(port); - } - } - - #if jin_net == jin_net_tekcos - - Socket::Socket(const tk_TCPsocket& tcphandle) - { - mHandle.tcpHandle = tcphandle; - } - - Socket::Socket(const tk_UDPsocket& udphandle) - { - mHandle.udpHandle = udphandle; - } - - #endif // jin_net == jin_net_tekcos - - Socket::~Socket() - { - } - - void Socket::configureBlocking(bool blocking) - { - if (mType != SocketType::TCP) - return; - #if jin_net == jin_net_tekcos - if (blocking) - tk_tcp_blocking(&mHandle.tcpHandle); - else - tk_tcp_nonblocking(&mHandle.tcpHandle); - #endif - } - - Socket* Socket::accept() - { - if (mType != SocketType::TCP) - return nullptr; - Socket* client; - #if jin_net == jin_net_tekcos - tk_TCPsocket socket = tk_tcp_accept(&mHandle.tcpHandle); - client = new Socket(socket); - #endif - return client; - } - - int Socket::receive(char* buffer, int size) - { - if (mType != SocketType::TCP) - return 0; - #if jin_net == jin_net_tekcos - int len; - tk_tcp_recv(&mHandle.tcpHandle, buffer, size, &len); - return len; - #endif - } - - int Socket::send(char* buffer, int size) - { - if (mType != SocketType::TCP) - return 0; - #if jin_net == jin_net_tekcos - int len; - tk_tcp_send(&mHandle.tcpHandle, buffer, size, &len); - return len; - #endif - } - - void Socket::sendTo(char* buffer, int size, unsigned int address, unsigned int port) - { - if (mType != SocketType::UDP) - return; - #if jin_net == jin_net_tekcos - tk_UDPpack pack; - pack.data = buffer; - pack.len = size; - pack.ip.host = address; - pack.ip.port = port; - tk_udp_sendto(&mHandle.udpHandle, &pack); - #endif - } - - int Socket::receiveFrom(char* buffer, int size, unsigned int address, unsigned int port) - { - if (mType != SocketType::UDP) - return 0; - int len; - #if jin_net == jin_net_tekcos - tk_UDPpack pack; - pack.data = buffer; - pack.len = size; - pack.ip.host = address; - pack.ip.port = port; - tk_udp_recvfrom(&mHandle.udpHandle, &pack); - return pack.len; - #endif - } - - void Socket::close() - { - if (mType == SocketType::TCP) - { - #if jin_net == jin_net_tekcos - tk_tcp_close(&mHandle.tcpHandle); - #endif - } - else if (mType == SocketType::UDP) - { - #if jin_net == jin_net_tekcos - tk_udp_close(&mHandle.udpHandle); - #endif - } - } - - } // namespace Net -} // namespace JinEngine \ No newline at end of file diff --git a/src/libjin/net/je_socket.h b/src/libjin/net/je_socket.h deleted file mode 100644 index 00e91de..0000000 --- a/src/libjin/net/je_socket.h +++ /dev/null @@ -1,146 +0,0 @@ -#ifndef __JE_NET_SOCKET_H__ -#define __JE_NET_SOCKET_H__ -#include "../core/je_configuration.h" -#if defined(jin_net) - -#include "../common/je_object.h" - -#include "tekcos/tekcos.h" - -namespace JinEngine -{ - namespace Net - { - - /// - /// - /// - enum SocketType - { - TCP, - UDP - }; - - /// - /// - /// - struct SocketInformation - { - unsigned int address; - unsigned short port; - SocketType type; - }; - - /// - /// - /// - class Socket : public Object - { - public: - - /// - /// - /// - Socket() {}; - - /// - /// - /// - Socket(const Socket& socket); - - /// - /// - /// - Socket(const SocketInformation& socketInformation); - - /// - /// - /// - Socket(SocketType type, unsigned short port); - - /// - /// - /// - Socket(SocketType type, unsigned int address, unsigned short port); - - /// - /// - /// - Socket(SocketType type, const char* address, unsigned short port); - - /// - /// - /// - ~Socket(); - - /// - /// - /// - void configureBlocking(bool bocking); - - /// - /// - /// - Socket* accept(); - - /// - /// - /// - int receive(char* buffer, int size); - - /// - /// - /// - int send(char* buffer, int size); - - /// - /// - /// - void sendTo(char* buffer, int size, unsigned int address, unsigned int port); - - /// - /// - /// - int receiveFrom(char* buffer, int size, unsigned int address, unsigned int port); - - /// - /// - /// - void close(); - - protected: - #if jin_net == jin_net_tekcos - - /// - /// - /// - Socket(const tk_TCPsocket& tcpHandle); - - /// - /// - /// - Socket(const tk_UDPsocket& udpHandle); - - /// - /// - /// - union - { - tk_TCPsocket tcpHandle; - tk_UDPsocket udpHandle; - } mHandle; - #endif - - /// - /// - /// - SocketType mType; - - }; - - } // namespace Net -} // namespace JinEngine - -#endif // defined(jin_net) - -#endif // __JE_NET_SOCKET_H__ \ No newline at end of file diff --git a/src/libjin/net/net_manager.cpp b/src/libjin/net/net_manager.cpp new file mode 100644 index 0000000..632219c --- /dev/null +++ b/src/libjin/net/net_manager.cpp @@ -0,0 +1,24 @@ +#include "net_manager.h" + +namespace JinEngine +{ + namespace Net + { + + bool NetManager::startSystem(const SettingBase* setting) + { + #ifdef _WIN32 + #if jin_net == jin_net_tekcos + tk_init(); + #endif + #endif + return true; + } + + void NetManager::quitSystem() + { + + } + + } // namespace Net +} // namespace JinEngine \ No newline at end of file diff --git a/src/libjin/net/net_manager.h b/src/libjin/net/net_manager.h new file mode 100644 index 0000000..36238f8 --- /dev/null +++ b/src/libjin/net/net_manager.h @@ -0,0 +1,48 @@ +#ifndef __JE_NET_H__ +#define __JE_NET_H__ +#include "../core/configuration.h" +#if defined(jin_net) + +#include "../common/subsystem.hpp" + +#include "socket.h" + +namespace JinEngine +{ + namespace Net + { + + /// + /// + /// + class NetManager : public Subsystem + { + public: + /// + /// + /// + NetManager() {}; + + /// + /// + /// + ~NetManager() {}; + + /// + /// + /// + bool startSystem(const SettingBase* setting) override; + + /// + /// + /// + void quitSystem() override; + + }; + + } // namespace Net +} // namespace JinEngine + +#endif // defined(jin_net) + +#endif // __JE_NET_H__ \ No newline at end of file diff --git a/src/libjin/net/socket.cpp b/src/libjin/net/socket.cpp new file mode 100644 index 0000000..3d59a57 --- /dev/null +++ b/src/libjin/net/socket.cpp @@ -0,0 +1,190 @@ +#include "socket.h" + +namespace JinEngine +{ + namespace Net + { + Socket::Socket(const Socket& socket) + : mHandle(socket.mHandle) + , mType(socket.mType) + { + } + + Socket::Socket(const SocketInformation& info) + : mType(info.type) + { + if (mType == SocketType::TCP) + { + tk_IPaddress ip; + ip.host = info.address; + ip.port = info.port; + mHandle.tcpHandle = tk_tcp_open(ip); + } + else if (mType == SocketType::UDP) + { + mHandle.udpHandle = tk_udp_open(info.port); + } + } + + Socket::Socket(SocketType type, const char* address, unsigned short port) + { + mType = type; + if (mType == SocketType::TCP) + { + tk_IPaddress ip; + #if jin_net == jin_net_tekcos + ip.host = tk_strtohl(address); + ip.port = port; + mHandle.tcpHandle = tk_tcp_open(ip); + #endif + } + else if (mType == SocketType::UDP) + { + mHandle.udpHandle = tk_udp_open(port); + } + } + + Socket::Socket(SocketType type, unsigned int address, unsigned short port) + { + mType = type; + if (mType == SocketType::TCP) + { + tk_IPaddress ip; + ip.host = address; + ip.port = port; + mHandle.tcpHandle = tk_tcp_open(ip); + } + else if (mType == SocketType::UDP) + { + mHandle.udpHandle = tk_udp_open(port); + } + } + + Socket::Socket(SocketType type, unsigned short port) + { + mType = type; + if (mType == SocketType::TCP) + { + tk_IPaddress ip; + ip.host = 0; + ip.port = port; + mHandle.tcpHandle = tk_tcp_open(ip); + } + else if (mType == SocketType::UDP) + { + mHandle.udpHandle = tk_udp_open(port); + } + } + + #if jin_net == jin_net_tekcos + + Socket::Socket(const tk_TCPsocket& tcphandle) + { + mHandle.tcpHandle = tcphandle; + } + + Socket::Socket(const tk_UDPsocket& udphandle) + { + mHandle.udpHandle = udphandle; + } + + #endif // jin_net == jin_net_tekcos + + Socket::~Socket() + { + } + + void Socket::configureBlocking(bool blocking) + { + if (mType != SocketType::TCP) + return; + #if jin_net == jin_net_tekcos + if (blocking) + tk_tcp_blocking(&mHandle.tcpHandle); + else + tk_tcp_nonblocking(&mHandle.tcpHandle); + #endif + } + + Socket* Socket::accept() + { + if (mType != SocketType::TCP) + return nullptr; + Socket* client; + #if jin_net == jin_net_tekcos + tk_TCPsocket socket = tk_tcp_accept(&mHandle.tcpHandle); + client = new Socket(socket); + #endif + return client; + } + + int Socket::receive(char* buffer, int size) + { + if (mType != SocketType::TCP) + return 0; + #if jin_net == jin_net_tekcos + int len; + tk_tcp_recv(&mHandle.tcpHandle, buffer, size, &len); + return len; + #endif + } + + int Socket::send(char* buffer, int size) + { + if (mType != SocketType::TCP) + return 0; + #if jin_net == jin_net_tekcos + int len; + tk_tcp_send(&mHandle.tcpHandle, buffer, size, &len); + return len; + #endif + } + + void Socket::sendTo(char* buffer, int size, unsigned int address, unsigned int port) + { + if (mType != SocketType::UDP) + return; + #if jin_net == jin_net_tekcos + tk_UDPpack pack; + pack.data = buffer; + pack.len = size; + pack.ip.host = address; + pack.ip.port = port; + tk_udp_sendto(&mHandle.udpHandle, &pack); + #endif + } + + int Socket::receiveFrom(char* buffer, int size, unsigned int address, unsigned int port) + { + if (mType != SocketType::UDP) + return 0; + int len; + #if jin_net == jin_net_tekcos + tk_UDPpack pack; + pack.data = buffer; + pack.len = size; + pack.ip.host = address; + pack.ip.port = port; + tk_udp_recvfrom(&mHandle.udpHandle, &pack); + return pack.len; + #endif + } + + void Socket::close() + { + if (mType == SocketType::TCP) + { + #if jin_net == jin_net_tekcos + tk_tcp_close(&mHandle.tcpHandle); + #endif + } + else if (mType == SocketType::UDP) + { + #if jin_net == jin_net_tekcos + tk_udp_close(&mHandle.udpHandle); + #endif + } + } + + } // namespace Net +} // namespace JinEngine \ No newline at end of file diff --git a/src/libjin/net/socket.h b/src/libjin/net/socket.h new file mode 100644 index 0000000..1562272 --- /dev/null +++ b/src/libjin/net/socket.h @@ -0,0 +1,146 @@ +#ifndef __JE_NET_SOCKET_H__ +#define __JE_NET_SOCKET_H__ +#include "../core/configuration.h" +#if defined(jin_net) + +#include "../common/object.h" + +#include "tekcos/tekcos.h" + +namespace JinEngine +{ + namespace Net + { + + /// + /// + /// + enum SocketType + { + TCP, + UDP + }; + + /// + /// + /// + struct SocketInformation + { + unsigned int address; + unsigned short port; + SocketType type; + }; + + /// + /// + /// + class Socket : public Object + { + public: + + /// + /// + /// + Socket() {}; + + /// + /// + /// + Socket(const Socket& socket); + + /// + /// + /// + Socket(const SocketInformation& socketInformation); + + /// + /// + /// + Socket(SocketType type, unsigned short port); + + /// + /// + /// + Socket(SocketType type, unsigned int address, unsigned short port); + + /// + /// + /// + Socket(SocketType type, const char* address, unsigned short port); + + /// + /// + /// + ~Socket(); + + /// + /// + /// + void configureBlocking(bool bocking); + + /// + /// + /// + Socket* accept(); + + /// + /// + /// + int receive(char* buffer, int size); + + /// + /// + /// + int send(char* buffer, int size); + + /// + /// + /// + void sendTo(char* buffer, int size, unsigned int address, unsigned int port); + + /// + /// + /// + int receiveFrom(char* buffer, int size, unsigned int address, unsigned int port); + + /// + /// + /// + void close(); + + protected: + #if jin_net == jin_net_tekcos + + /// + /// + /// + Socket(const tk_TCPsocket& tcpHandle); + + /// + /// + /// + Socket(const tk_UDPsocket& udpHandle); + + /// + /// + /// + union + { + tk_TCPsocket tcpHandle; + tk_UDPsocket udpHandle; + } mHandle; + #endif + + /// + /// + /// + SocketType mType; + + }; + + } // namespace Net +} // namespace JinEngine + +#endif // defined(jin_net) + +#endif // __JE_NET_SOCKET_H__ \ No newline at end of file -- cgit v1.1-26-g67d0