34 #ifndef _QORE_QORE_SOCKET_OBJECT_H 36 #define _QORE_QORE_SOCKET_OBJECT_H 38 #include <qore/QoreSocket.h> 39 #include <qore/AbstractPrivateData.h> 40 #include <qore/QoreThreadLock.h> 49 friend class my_socket_priv;
50 friend struct qore_httpclient_priv;
57 DLLLOCAL
virtual ~QoreSocketObject();
60 DLLEXPORT QoreSocketObject();
63 DLLEXPORT
virtual void deref();
65 DLLEXPORT
int connect(
const char* name,
int timeout_ms,
ExceptionSink* xsink = NULL);
66 DLLEXPORT
int connectINET(
const char* host,
int port,
int timeout_ms,
ExceptionSink* xsink = NULL);
67 DLLEXPORT
int connectINET2(
const char* host,
const char* service,
int family,
int sock_type,
int protocol,
int timeout_ms = -1,
ExceptionSink* xsink = NULL);
68 DLLEXPORT
int connectUNIX(
const char* p,
int socktype,
int protocol,
ExceptionSink* xsink = NULL);
69 DLLEXPORT
int connectSSL(
const char* name,
int timeout_ms,
ExceptionSink* xsink);
70 DLLEXPORT
int connectINETSSL(
const char* host,
int port,
int timeout_ms,
ExceptionSink* xsink);
71 DLLEXPORT
int connectINET2SSL(
const char* host,
const char* service,
int family,
int sock_type,
int protocol,
int timeout_ms = -1,
ExceptionSink* xsink = NULL);
72 DLLEXPORT
int connectUNIXSSL(
const char* p,
int socktype,
int protocol,
ExceptionSink* xsink);
74 DLLEXPORT
int bind(
const char* name,
bool reuseaddr =
false);
76 DLLEXPORT
int bind(
int port,
bool reuseaddr =
false);
78 DLLEXPORT
int bind(
const char* iface,
int port,
bool reuseaddr =
false);
80 DLLEXPORT
int bindUNIX(
const char* name,
int socktype,
int protocol,
ExceptionSink* xsink);
81 DLLEXPORT
int bindINET(
const char* name,
const char* service,
bool reuseaddr,
int family,
int socktype,
int protocol,
ExceptionSink* xsink);
84 DLLEXPORT
int getPort();
87 DLLEXPORT QoreSocketObject *accept(
int timeout_ms,
ExceptionSink* xsink);
88 DLLEXPORT QoreSocketObject *acceptSSL(
int timeout_ms,
ExceptionSink* xsink);
90 DLLEXPORT
int listen(
int backlog);
92 DLLEXPORT
int send(
const char* buf,
int size);
93 DLLEXPORT
int send(
const char* buf,
int size,
int timeout_ms,
ExceptionSink* xsink);
103 DLLEXPORT
int send(
int fd,
int size = -1);
105 DLLEXPORT
int sendi1(
char b,
int timeout_ms,
ExceptionSink* xsink);
106 DLLEXPORT
int sendi2(
short b,
int timeout_ms,
ExceptionSink* xsink);
107 DLLEXPORT
int sendi4(
int b,
int timeout_ms,
ExceptionSink* xsink);
109 DLLEXPORT
int sendi2LSB(
short b,
int timeout_ms,
ExceptionSink* xsink);
110 DLLEXPORT
int sendi4LSB(
int b,
int timeout_ms,
ExceptionSink* xsink);
124 DLLEXPORT
int recv(
int fd,
int size,
int timeout);
139 DLLEXPORT
int sendHTTPMessage(
ExceptionSink* xsink,
QoreHashNode* info,
const char* method,
const char* path,
const char* http_version,
const QoreHashNode* headers,
const void* ptr,
int size,
int source,
int timeout_ms);
144 DLLEXPORT
int sendHTTPResponse(
ExceptionSink* xsink,
int code,
const char* desc,
const char* http_version,
const QoreHashNode* headers,
const void* ptr,
int size,
int source,
int timeout_ms);
168 DLLEXPORT
int setSendTimeout(
int ms);
169 DLLEXPORT
int setRecvTimeout(
int ms);
170 DLLEXPORT
int getSendTimeout();
171 DLLEXPORT
int getRecvTimeout();
172 DLLEXPORT
int close();
173 DLLEXPORT
int shutdown();
175 DLLEXPORT
const char* getSSLCipherName();
176 DLLEXPORT
const char* getSSLCipherVersion();
177 DLLEXPORT
bool isSecure();
178 DLLEXPORT
long verifyPeerCertificate();
179 DLLEXPORT
int getSocket();
182 DLLEXPORT
bool isDataAvailable(
ExceptionSink* xsink,
int timeout = 0);
183 DLLEXPORT
bool isWriteFinished(
ExceptionSink* xsink,
int timeout = 0);
184 DLLEXPORT
bool isOpen()
const;
189 DLLEXPORT
int setNoDelay(
int nodelay);
190 DLLEXPORT
int getNoDelay();
191 DLLEXPORT
void setEventQueue(Queue *cbq,
ExceptionSink* xsink);
198 DLLEXPORT
void upgradeClientToSSL(
int timeout_ms,
ExceptionSink* xsink);
199 DLLEXPORT
void upgradeServerToSSL(
int timeout_ms,
ExceptionSink* xsink);
204 DLLEXPORT
void clearStats();
205 DLLEXPORT
bool pendingHttpChunkedBody()
const;
206 DLLEXPORT
void setSslVerifyMode(
int mode);
207 DLLEXPORT
int getSslVerifyMode()
const;
208 DLLEXPORT
void acceptAllCertificates(
bool accept_all =
true);
209 DLLEXPORT
bool getAcceptAllCertificates()
const;
212 #endif // _QORE_QORE_SOCKET_OBJECT_H defines string encoding functions in Qore
Definition: QoreEncoding.h:85
a helper class for getting socket origination information
Definition: QoreSocket.h:73
represents an X509 certificate, reference-counted, dynamically-allocated only
Definition: QoreSSLCertificate.h:42
This is the hash or associative list container type in Qore, dynamically allocated only...
Definition: QoreHashNode.h:50
the base class for all data to be used as private data of Qore objects
Definition: AbstractPrivateData.h:44
The base class for all value and parse types in Qore expression trees.
Definition: AbstractQoreNode.h:54
provides access to a private key data structure for SSL connections
Definition: QoreSSLPrivateKey.h:40
Interface for private data of output streams.
Definition: OutputStream.h:44
Qore's string type supported by the QoreEncoding class.
Definition: QoreString.h:82
Qore's string value type, reference counted, dynamically-allocated only.
Definition: QoreStringNode.h:50
virtual DLLLOCAL void deref()
decrements the reference count of the object without the possibility of throwing a Qore-language exce...
Definition: AbstractPrivateData.h:67
provides access to sockets using Qore data structures
Definition: QoreSocket.h:126
the implementation of Qore's object data type, reference counted, dynamically-allocated only ...
Definition: QoreObject.h:62
container for holding Qore-language exception information and also for registering a "thread_exit" ca...
Definition: ExceptionSink.h:47
long long int64
64bit integer type, cannot use int64_t here since it breaks the API on some 64-bit systems due to equ...
Definition: common.h:241
intptr_t qore_offset_t
used for offsets that could be negative
Definition: common.h:77
base class for resolved call references
Definition: CallReferenceNode.h:130
holds arbitrary binary data
Definition: BinaryNode.h:41