UNLOZE/sm-ext-socket
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Updated for 1.11 windows build & added methodmap

Browse Source
This commit is contained in:
JoinedSenses
2019-11-05 22:35:12 -05:00
parent ed6bf7a12b
commit f50c08038b
11 changed files with 847 additions and 104 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Socket.h
+28 -31
View File
@@ -1,7 +1,6 @@
#ifndef INC_SEXT_SOCKET_H
#define INC_SEXT_SOCKET_H
#pragma once
#include <stdint.h>
#include <cstdint>
#include <string>
#include <queue>
#include <boost/asio.hpp>
@@ -16,60 +15,58 @@ class SocketHandler;
template <class SocketType>
class Socket {
public:
Socket(SM_SocketType st, typename SocketType::socket* asioSocket = NULL);
Socket(SM_SocketType st, typename SocketType::socket *asioSocket = nullptr);
~Socket();
bool IsOpen();
bool Bind(const char* hostname, uint16_t port, bool async = true);
bool Connect(const char* hostname, uint16_t port, bool async = true);
bool Bind(const char *hostname, uint16_t port, bool async = true);
bool Connect(const char *hostname, uint16_t port, bool async = true);
bool Disconnect();
bool Listen();
bool Send(const std::string& data, bool async = true);
bool SendTo(const std::string& data, const char* hostname, uint16_t port, bool async = true);
bool SetOption(SM_SocketOption so, int value, bool lock=true);
bool Send(const std::string &data, bool async = true);
bool SendTo(const std::string &data, const char *hostname, uint16_t port, bool async = true);
bool SetOption(SM_SocketOption so, int value, bool lock = true);
IPluginFunction* connectCallback;
IPluginFunction* incomingCallback;
IPluginFunction* receiveCallback;
IPluginFunction* sendqueueEmptyCallback;
IPluginFunction* disconnectCallback;
IPluginFunction* errorCallback;
IPluginFunction *connectCallback;
IPluginFunction *incomingCallback;
IPluginFunction *receiveCallback;
IPluginFunction *sendqueueEmptyCallback;
IPluginFunction *disconnectCallback;
IPluginFunction *errorCallback;
int32_t smHandle;
int32_t smCallbackArg;
volatile unsigned int sendQueueLength;
private:
void ReceiveHandler(char* buf, size_t bufferSize, size_t bytes, const boost::system::error_code&, boost::shared_lock<boost::shared_mutex>*);
void ReceiveHandler(char *buf, size_t bufferSize, size_t bytes, const boost::system::error_code &, boost::shared_lock<boost::shared_mutex> *);
void BindPostResolveHandler(typename SocketType::resolver*, typename SocketType::resolver::iterator, const boost::system::error_code&, boost::shared_lock<boost::shared_mutex>*);
void BindPostResolveHandler(typename SocketType::resolver *, typename SocketType::resolver::iterator, const boost::system::error_code &, boost::shared_lock<boost::shared_mutex> *);
void ConnectPostResolveHandler(typename SocketType::resolver*, typename SocketType::resolver::iterator, const boost::system::error_code&, boost::shared_lock<boost::shared_mutex>*);
void ConnectPostConnectHandler(typename SocketType::resolver*, typename SocketType::resolver::iterator, const boost::system::error_code&, boost::shared_lock<boost::shared_mutex>*);
void ConnectPostResolveHandler(typename SocketType::resolver *, typename SocketType::resolver::iterator, const boost::system::error_code &, boost::shared_lock<boost::shared_mutex> *);
void ConnectPostConnectHandler(typename SocketType::resolver *, typename SocketType::resolver::iterator, const boost::system::error_code &, boost::shared_lock<boost::shared_mutex> *);
void ListenIncomingHandler(boost::asio::ip::tcp::socket* newAsioSocket, const boost::system::error_code&, boost::shared_lock<boost::shared_mutex>*);
void ListenIncomingHandler(boost::asio::ip::tcp::socket *newAsioSocket, const boost::system::error_code &, boost::shared_lock<boost::shared_mutex> *);
void SendPostSendHandler(char* buf, size_t bytes, const boost::system::error_code& err, boost::shared_lock<boost::shared_mutex>*);
void SendPostSendHandler(char *buf, size_t bytes, const boost::system::error_code &err, boost::shared_lock<boost::shared_mutex> *);
void SendToPostResolveHandler(typename SocketType::resolver*, typename SocketType::resolver::iterator, char* buf, size_t bufLen, const boost::system::error_code&, boost::shared_lock<boost::shared_mutex>*);
void SendToPostSendHandler(typename SocketType::resolver*, typename SocketType::resolver::iterator, char* buf, size_t bufLen, size_t bytesTransferred, const boost::system::error_code&, boost::shared_lock<boost::shared_mutex>*);
void SendToPostResolveHandler(typename SocketType::resolver *, typename SocketType::resolver::iterator, char *buf, size_t bufLen, const boost::system::error_code &, boost::shared_lock<boost::shared_mutex> *);
void SendToPostSendHandler(typename SocketType::resolver *, typename SocketType::resolver::iterator, char *buf, size_t bufLen, size_t bytesTransferred, const boost::system::error_code &, boost::shared_lock<boost::shared_mutex> *);
//void InitializeResolver();
void InitializeSocket();
SM_SocketType sm_sockettype;
std::queue<SocketOption*> socketOptionQueue;
std::queue<SocketOption *> socketOptionQueue;
typename SocketType::socket* socket;
typename SocketType::socket *socket;
boost::mutex socketMutex;
//typename SocketType::resolver* resolver;
typename SocketType::endpoint* localEndpoint;
boost::mutex* localEndpointMutex;
boost::asio::ip::tcp::acceptor* tcpAcceptor;
boost::mutex* tcpAcceptorMutex;
typename SocketType::endpoint *localEndpoint;
boost::mutex *localEndpointMutex;
boost::asio::ip::tcp::acceptor *tcpAcceptor;
boost::mutex *tcpAcceptorMutex;
boost::shared_mutex handlerMutex;
};
#endif