ZNC
trunk
|
Base Csock implementation to be used by modules. More...
#include <Socket.h>
Public Types | |
enum | ETConn { OUTBOUND = 0 , LISTENER = 1 , INBOUND = 2 } |
enum | EFRead { READ_EOF = 0 , READ_ERR = -1 , READ_EAGAIN = -2 , READ_CONNREFUSED = -3 , READ_TIMEDOUT = -4 } |
enum | EFSelect { SEL_OK = 0 , SEL_TIMEOUT = -1 , SEL_EAGAIN = -2 , SEL_ERR = -3 } |
enum | ESSLMethod { TLS = 0 , SSL23 = TLS , SSL2 = 2 , SSL3 = 3 , TLS1 = 4 , TLS11 = 5 , TLS12 = 6 } |
enum | EDisableProtocol { EDP_None = 0 , EDP_SSLv2 = 1 , EDP_SSLv3 = 2 , EDP_TLSv1 = 4 , EDP_TLSv1_1 = 8 , EDP_TLSv1_2 = 16 , EDP_SSL = (EDP_SSLv2|EDP_SSLv3) } |
enum | ECONState { CST_START = 0 , CST_DNS = CST_START , CST_BINDVHOST = 1 , CST_DESTDNS = 2 , CST_CONNECT = 3 , CST_CONNECTSSL = 4 , CST_OK = 5 } |
enum | ECloseType { CLT_DONT = 0 , CLT_NOW = 1 , CLT_AFTERWRITE = 2 , CLT_DEREFERENCE = 3 } |
enum | { TMO_READ = 1 , TMO_WRITE = 2 , TMO_ACCEPT = 4 , TMO_ALL = TMO_READ|TMO_WRITE|TMO_ACCEPT } |
this timeout isn't just connection timeout, but also timeout on NOT recieving data, to disable this set it to 0 then the normal TCP timeout will apply (basically TCP will kill a dead connection) Set the timeout, set to 0 to never timeout More... | |
enum | EDNSLType { DNS_VHOST , DNS_DEST } |
Public Member Functions | |
CSocket (CModule *pModule) | |
ctor More... | |
CSocket (CModule *pModule, const CString &sHostname, unsigned short uPort, int iTimeout=60) | |
ctor More... | |
virtual | ~CSocket () |
CSocket (const CSocket &)=delete | |
CSocket & | operator= (const CSocket &)=delete |
void | ReachedMaxBuffer () override |
This defaults to closing the socket, feel free to override. More... | |
void | SockError (int iErrno, const CString &sDescription) override |
bool | ConnectionFrom (const CString &sHost, unsigned short uPort) override |
This limits the global connections from this IP to defeat DoS attacks, feel free to override. The ACL used is provided by the main interface. More... | |
bool | Connect (const CString &sHostname, unsigned short uPort, bool bSSL=false, unsigned int uTimeout=60) |
Ease of use Connect, assigns to the manager and is subsequently tracked. More... | |
bool | Listen (unsigned short uPort, bool bSSL, unsigned int uTimeout=0) |
Ease of use Listen, assigned to the manager and is subsequently tracked. More... | |
CModule * | GetModule () const |
CString | t_s (const CString &sEnglish, const CString &sContext="") const |
CInlineFormatMessage | t_f (const CString &sEnglish, const CString &sContext="") const |
CInlineFormatMessage | t_p (const CString &sEnglish, const CString &sEnglishes, int iNum, const CString &sContext) const |
CDelayedTranslation | t_d (const CString &sEnglish, const CString &sContext="") const |
virtual bool | Connect () |
Create the connection, this is used by the socket manager, and shouldn't be called directly by the user. More... | |
virtual bool | Listen (uint16_t iPort, int iMaxConns=SOMAXCONN, const CS_STRING &sBindHost="", uint32_t iTimeout=0, bool bDetach=false) |
Listens for connections. More... | |
int | ConvertAddress (const struct sockaddr_storage *pAddr, socklen_t iAddrLen, CString &sIP, u_short *piPort) const override |
virtual int | ConvertAddress (const struct sockaddr_storage *pAddr, socklen_t iAddrLen, CS_STRING &sIP, uint16_t *piPort) const |
retrieve name info (numeric only) for a given sockaddr_storage More... | |
int | VerifyPeerCertificate (int iPreVerify, X509_STORE_CTX *pStoreCTX) override |
this is hooked in via SSL_set_verify, and be default it just returns 1 meaning success More... | |
void | SSLHandShakeFinished () override |
called once the SSL handshake is complete, this is triggered via SSL_CB_HANDSHAKE_DONE in SSL_set_info_callback() More... | |
bool | CheckSSLCert (X509 *pCert) |
virtual void | SSLCertError (X509 *pCert) |
bool | SNIConfigureClient (CString &sHostname) override |
virtual bool | SNIConfigureClient (CS_STRING &sHostname) |
called to configure the SNI client More... | |
CString | GetSSLPeerFingerprint (X509 *pCert=nullptr) const |
void | SetHostToVerifySSL (const CString &sHost) |
void | SetSSLTrustedPeerFingerprints (const SCString &ssFPs) |
void | SetTrustAllCerts (bool bTrustAll) |
bool | GetTrustAllCerts () const |
void | SetTrustPKI (bool bTrustPKI) |
bool | GetTrustPKI () const |
void | SetEncoding (const CString &) |
void | SetEncoding (const CS_STRING &sEncoding) |
virtual CString | GetRemoteIP () const |
virtual Csock * | GetSockObj (const CS_STRING &sHostname, uint16_t iPort) |
override this for accept sockets More... | |
virtual void | Dereference () |
in the event you pass this class to Copy(), you MUST call this function or on the original Csock other wise bad side effects will happen (double deletes, weird sock closures, etc) if you call this function and have not handled the internal pointers, other bad things can happend (memory leaks, fd leaks, etc) the whole point of this function is to allow this class to go away without shutting down More... | |
virtual void | Copy (const Csock &cCopy) |
use this to copy a sock from one to the other, override it if you have special needs in the event of a copy More... | |
Csock & | operator<< (const CS_STRING &s) |
Csock & | operator<< (std::ostream &(*io)(std::ostream &)) |
Csock & | operator<< (int32_t i) |
Csock & | operator<< (uint32_t i) |
Csock & | operator<< (int64_t i) |
Csock & | operator<< (uint64_t i) |
Csock & | operator<< (float i) |
Csock & | operator<< (double i) |
virtual bool | ConnectUnix (const CS_STRING &sPath) |
Connect to a UNIX socket. More... | |
virtual bool | ListenUnix (const CS_STRING &sBindFile, int iMaxConns=SOMAXCONN, uint32_t iTimeout=0) |
Listens for connections on an UNIX socket. More... | |
virtual bool | Listen (uint16_t iPort, int iMaxConns=SOMAXCONN, const CS_STRING &sBindHost="", uint32_t iTimeout=0, bool bDetach=false) |
Listens for connections. More... | |
virtual cs_sock_t | Accept (CS_STRING &sHost, uint16_t &iRPort) |
Accept an inbound connection, this is used internally. More... | |
virtual bool | AcceptSSL () |
Accept an inbound SSL connection, this is used internally and called after Accept. More... | |
virtual bool | SSLClientSetup () |
This sets up the SSL Client, this is used internally. More... | |
virtual bool | SSLServerSetup () |
This sets up the SSL Server, this is used internally. More... | |
virtual bool | ConnectSSL () |
Create the SSL connection. More... | |
bool | StartTLS () |
start a TLS connection on an existing plain connection More... | |
virtual bool | Write (const char *data, size_t len) |
Write data to the socket. More... | |
virtual bool | Write (const CS_STRING &sData) |
Write a text string to the socket. More... | |
virtual cs_ssize_t | Read (char *data, size_t len) |
Read from the socket Just pass in a pointer, big enough to hold len bytes. More... | |
CS_STRING | GetLocalIP () const |
virtual bool | IsConnected () const |
Tells you if the socket is connected. More... | |
virtual void | SetIsConnected (bool b) |
Sets the sock, telling it its connected (internal use only) More... | |
cs_sock_t & | GetRSock () |
returns a reference to the sock More... | |
const cs_sock_t & | GetRSock () const |
void | SetRSock (cs_sock_t iSock) |
cs_sock_t & | GetWSock () |
const cs_sock_t & | GetWSock () const |
void | SetWSock (cs_sock_t iSock) |
void | SetSock (cs_sock_t iSock) |
cs_sock_t & | GetSock () |
const cs_sock_t & | GetSock () const |
void | CallSockError (int iErrno, const CS_STRING &sDescription="") |
calls SockError, if sDescription is not set, then strerror is used to pull out a default description More... | |
virtual void | ResetTimer () |
resets the time counter, this is virtual in the event you need an event on the timer being Reset More... | |
void | PauseRead () |
will pause/unpause reading on this socket More... | |
void | UnPauseRead () |
bool | IsReadPaused () const |
void | SetTimeout (int iTimeout, uint32_t iTimeoutType=TMO_ALL) |
Currently this uses the same value for all timeouts, and iTimeoutType merely states which event will be checked for timeouts. More... | |
void | SetTimeoutType (uint32_t iTimeoutType) |
int | GetTimeout () const |
uint32_t | GetTimeoutType () const |
virtual bool | CheckTimeout (time_t iNow) |
returns true if the socket has timed out More... | |
virtual void | PushBuff (const char *data, size_t len, bool bStartAtZero=false) |
pushes data up on the buffer, if a line is ready it calls the ReadLine event More... | |
CS_STRING & | GetInternalReadBuffer () |
This gives access to the internal read buffer, if your not going to use ReadLine(), then you may want to clear this out (if its binary data and not many '\n') More... | |
CS_STRING & | GetInternalWriteBuffer () |
This gives access to the internal write buffer. More... | |
void | SetMaxBufferThreshold (uint32_t iThreshold) |
sets the max buffered threshold when EnableReadLine() is enabled More... | |
uint32_t | GetMaxBufferThreshold () const |
int | GetType () const |
Returns the connection type from enum eConnType. More... | |
void | SetType (int iType) |
const CS_STRING & | GetSockName () const |
Returns a reference to the socket name. More... | |
void | SetSockName (const CS_STRING &sName) |
const CS_STRING & | GetHostName () const |
Returns a reference to the host name. More... | |
void | SetHostName (const CS_STRING &sHostname) |
uint64_t | GetStartTime () const |
Gets the starting time of this socket. More... | |
void | ResetStartTime () |
Resets the start time. More... | |
uint64_t | GetBytesRead () const |
Gets the amount of data read during the existence of the socket. More... | |
void | ResetBytesRead () |
uint64_t | GetBytesWritten () const |
Gets the amount of data written during the existence of the socket. More... | |
void | ResetBytesWritten () |
double | GetAvgRead (uint64_t iSample=1000) const |
Get Avg Read Speed in sample milliseconds (default is 1000 milliseconds or 1 second) More... | |
double | GetAvgWrite (uint64_t iSample=1000) const |
Get Avg Write Speed in sample milliseconds (default is 1000 milliseconds or 1 second) More... | |
uint16_t | GetRemotePort () const |
Returns the remote port. More... | |
uint16_t | GetLocalPort () const |
Returns the local port. More... | |
uint16_t | GetPort () const |
Returns the port. More... | |
void | SetPort (uint16_t iPort) |
void | Close (ECloseType eCloseType=CLT_NOW) |
just mark us as closed, the parent can pick it up More... | |
ECloseType | GetCloseType () const |
returns int of type to close More... | |
bool | IsClosed () const |
void | NonBlockingIO () |
Use this to change your fd's to blocking or none blocking. More... | |
bool | GetSSL () const |
Return true if this socket is using ssl. Note this does not mean the SSL state is finished, but simply that its configured to use ssl. More... | |
void | SetSSL (bool b) |
void | DisableSSLProtocols (u_int uDisableOpts) |
bitwise setter, More... | |
void | DisableSSLCompression () |
allow disabling compression More... | |
void | FollowSSLCipherServerPreference () |
select the ciphers in server-preferred order More... | |
void | SetCipher (const CS_STRING &sCipher) |
Set the cipher type ( openssl cipher [to see ciphers available] ) More... | |
const CS_STRING & | GetCipher () const |
void | SetDHParamLocation (const CS_STRING &sDHParamFile) |
Set the pem file location. More... | |
const CS_STRING & | GetDHParamLocation () const |
void | SetKeyLocation (const CS_STRING &sKeyFile) |
const CS_STRING & | GetKeyLocation () const |
void | SetPemLocation (const CS_STRING &sPemFile) |
const CS_STRING & | GetPemLocation () const |
void | SetPemPass (const CS_STRING &sPassword) |
const CS_STRING & | GetPemPass () const |
void | SetSSLMethod (int iMethod) |
Set the SSL method type. More... | |
int | GetSSLMethod () const |
void | SetSSLObject (SSL *ssl, bool bDeleteExisting=false) |
SSL * | GetSSLObject () const |
void | SetCTXObject (SSL_CTX *sslCtx, bool bDeleteExisting=false) |
SSL_SESSION * | GetSSLSession () const |
void | SetCertVerifyCB (FPCertVerifyCB pFP) |
setting this to NULL will allow the default openssl verification process kick in More... | |
bool | HasWriteBuffer () const |
Get the send buffer. More... | |
void | ClearWriteBuffer () |
bool | SslIsEstablished () const |
is SSL_accept finished ? is the ssl properly finished (from write no error) More... | |
bool | ConnectInetd (bool bIsSSL=false, const CS_STRING &sHostname="") |
Use this to bind this socket to inetd. More... | |
bool | ConnectFD (int iReadFD, int iWriteFD, const CS_STRING &sName, bool bIsSSL=false, ETConn eDirection=INBOUND) |
Tie this guy to an existing real file descriptor. More... | |
X509 * | GetX509 () const |
Get the peer's X509 cert. More... | |
CS_STRING | GetPeerPubKey () const |
Returns the peer's public key. More... | |
long | GetPeerFingerprint (CS_STRING &sFP) const |
Returns the peer's certificate finger print. More... | |
uint32_t | GetRequireClientCertFlags () const |
void | SetRequiresClientCert (bool bRequiresCert) |
legacy, deprecated More... | |
void | SetRequireClientCertFlags (uint32_t iRequireClientCertFlags) |
bitwise flags, 0 means don't require cert, SSL_VERIFY_PEER verifies peers, SSL_VERIFY_FAIL_IF_NO_PEER_CERT will cause the connection to fail if no cert More... | |
virtual void | SetParentSockName (const CS_STRING &sParentName) |
Set The INBOUND Parent sockname. More... | |
const CS_STRING & | GetParentSockName () const |
virtual void | SetRate (uint32_t iBytes, uint64_t iMilliseconds) |
sets the rate at which we can send data More... | |
uint32_t | GetRateBytes () const |
uint64_t | GetRateTime () const |
virtual void | Connected () |
Connected event. More... | |
virtual void | Disconnected () |
Disconnected event. More... | |
virtual void | Timeout () |
Sock Timed out event. More... | |
virtual void | ReadData (const char *data, size_t len) |
Ready to read data event. More... | |
virtual void | ReadLine (const CS_STRING &sLine) |
Ready to Read a full line event. More... | |
void | EnableReadLine () |
set the value of m_bEnableReadLine to true, we don't want to store a buffer for ReadLine, unless we want it More... | |
void | DisableReadLine () |
bool | HasReadLine () const |
returns the value of m_bEnableReadLine, if ReadLine is enabled More... | |
virtual void | SockError (int iErrno, const CS_STRING &sDescription) |
A sock error occured event. More... | |
virtual bool | ConnectionFrom (const CS_STRING &sHost, uint16_t iPort) |
Incoming Connection Event return false and the connection will fail default returns true. More... | |
virtual void | Listening (const CS_STRING &sBindIP, uint16_t uPort) |
called when type is LISTENER and the listening port is up and running More... | |
virtual void | ConnectionRefused () |
Connection Refused Event. More... | |
virtual void | ReadPaused () |
This gets called every iteration of CSocketManager::Select() if the socket is ReadPaused. More... | |
virtual void | SSLFinishSetup (SSL *pSSL) |
Gets called immediatly after the m_ssl member is setup and initialized, useful if you need to assign anything to this ssl session via SSL_set_ex_data. More... | |
virtual bool | SNIConfigureServer (const CS_STRING &sHostname, CS_STRING &sPemFile, CS_STRING &sPemPass) |
gets called when a SNI request is sent, and used to configure a SNI session More... | |
SSL_CTX * | SetupServerCTX () |
creates a new SSL_CTX based on the setup of this sock More... | |
time_t | GetTimeSinceLastDataTransaction (time_t iNow=0) const |
return how long it has been (in seconds) since the last read or successful write More... | |
time_t | GetLastCheckTimeout () const |
time_t | GetNextCheckTimeout (time_t iNow=0) const |
Returns the time when CheckTimeout() should be called next. More... | |
virtual int | GetPending () const |
return the data imediatly ready for read More... | |
ECONState | GetConState () const |
returns the current connection state More... | |
void | SetConState (ECONState eState) |
sets the connection state to eState More... | |
bool | CreateSocksFD () |
grabs fd's for the sockets More... | |
void | CloseSocksFD () |
puts the socks back to the state they were prior to calling CreateSocksFD More... | |
const CS_STRING & | GetBindHost () const |
void | SetBindHost (const CS_STRING &sBindHost) |
int | DNSLookup (EDNSLType eDNSLType) |
dns lookup More... | |
bool | SetupVHost () |
this is only used on outbound connections, listeners bind in a different spot More... | |
bool | GetIPv6 () const |
void | SetIPv6 (bool b) |
void | SetAFRequire (CSSockAddr::EAFRequire iAFRequire) |
bool | AllowWrite (uint64_t &iNOW) const |
returns true if this socket can write its data, primarily used with rate shaping, initialize iNOW to 0 and it sets it on the first call More... | |
void | SetSkipConnect (bool b) |
virtual int | GetAddrInfo (const CS_STRING &sHostname, CSSockAddr &csSockAddr) |
override this call with your own DNS lookup method if you have one. More... | |
int | GetMaxConns () const |
returns the number of max pending connections when type is LISTENER More... | |
CS_STRING | GetEncoding () const |
virtual void | IcuExtToUCallback (UConverterToUnicodeArgs *toArgs, const char *codeUnits, int32_t length, UConverterCallbackReason reason, UErrorCode *err) |
virtual void | IcuExtFromUCallback (UConverterFromUnicodeArgs *fromArgs, const UChar *codeUnits, int32_t length, UChar32 codePoint, UConverterCallbackReason reason, UErrorCode *err) |
void | CleanupCrons () |
void | CleanupFDMonitors () |
const std::vector< CCron * > & | GetCrons () const |
returns a const reference to the crons associated to this socket More... | |
virtual void | Cron () |
This has a garbage collecter, and is used internall to call the jobs. More... | |
virtual void | AddCron (CCron *pcCron) |
insert a newly created cron More... | |
virtual void | DelCron (const CS_STRING &sName, bool bDeleteAll=true, bool bCaseSensitive=true) |
deletes a cron by name More... | |
virtual void | DelCron (uint32_t iPos) |
delete cron by idx More... | |
virtual void | DelCronByAddr (CCron *pcCron) |
delete cron by address More... | |
void | CheckFDs (const std::map< cs_sock_t, short > &miiReadyFds) |
void | AssignFDs (std::map< cs_sock_t, short > &miiReadyFds, struct timeval *tvtimeout) |
void | MonitorFD (CSMonitorFD *pMonitorFD) |
add an FD set to monitor More... | |
Protected Types | |
enum | { errnoBadSSLCert = 12569 } |
Static Protected Member Functions | |
static CString | t_s (const CString &sEnglish, const CString &sContext="") |
static CInlineFormatMessage | t_f (const CString &sEnglish, const CString &sContext="") |
static CInlineFormatMessage | t_p (const CString &sEnglish, const CString &sEnglishes, int iNum, const CString &sContext="") |
static CDelayedTranslation | t_d (const CString &sEnglish, const CString &sContext="") |
Protected Attributes | |
CModule * | m_pModule |
pointer to the module that this sock instance belongs to More... | |
std::vector< CCron * > | m_vcCrons |
std::vector< CSMonitorFD * > | m_vcMonitorFD |
Base Csock implementation to be used by modules.
By all means, this class should be used as a base for sockets originating from modules. It handles removing instances of itself from the module as it unloads, and simplifies use in general.
|
inherited |
|
inherited |
Enumerator | |
---|---|
CLT_DONT | don't close DER |
CLT_NOW | close immediatly |
CLT_AFTERWRITE | close after finishing writing the buffer |
CLT_DEREFERENCE | used after copy in Csock::Dereference() to cleanup a sock thats being shutdown |
|
inherited |
|
inherited |
|
inherited |
|
inherited |
|
inherited |
|
inherited |
|
inherited |
CSocket::CSocket | ( | CModule * | pModule | ) |
ctor
pModule | the module this sock instance is associated to |
CSocket::CSocket | ( | CModule * | pModule, |
const CString & | sHostname, | ||
unsigned short | uPort, | ||
int | iTimeout = 60 |
||
) |
ctor
pModule | the module this sock instance is associated to |
sHostname | the hostname being connected to |
uPort | the port being connected to |
iTimeout | the timeout period for this specific sock |
|
virtual |
|
delete |
Accept an inbound connection, this is used internally.
|
virtualinherited |
Accept an inbound SSL connection, this is used internally and called after Accept.
|
virtualinherited |
insert a newly created cron
|
inherited |
returns true if this socket can write its data, primarily used with rate shaping, initialize iNOW to 0 and it sets it on the first call
|
inherited |
|
inherited |
calls SockError, if sDescription is not set, then strerror is used to pull out a default description
iErrno | the errno to send |
sDescription | the description of the error that occurred |
|
inherited |
|
inherited |
|
virtualinherited |
returns true if the socket has timed out
|
inherited |
|
inherited |
|
inherited |
|
inherited |
just mark us as closed, the parent can pick it up
Referenced by CExecSock::Kill().
|
inherited |
puts the socks back to the state they were prior to calling CreateSocksFD
|
virtual |
Create the connection, this is used by the socket manager, and shouldn't be called directly by the user.
Reimplemented from Csock.
bool CSocket::Connect | ( | const CString & | sHostname, |
unsigned short | uPort, | ||
bool | bSSL = false , |
||
unsigned int | uTimeout = 60 |
||
) |
Ease of use Connect, assigns to the manager and is subsequently tracked.
|
inlinevirtualinherited |
|
inherited |
Tie this guy to an existing real file descriptor.
Referenced by CExecSock::Execute().
|
inherited |
Use this to bind this socket to inetd.
|
inlinevirtualinherited |
Incoming Connection Event return false and the connection will fail default returns true.
|
override |
This limits the global connections from this IP to defeat DoS attacks, feel free to override. The ACL used is provided by the main interface.
|
inlinevirtualinherited |
|
virtualinherited |
Create the SSL connection.
This is used by the socket manager, and shouldn't be called directly by the user.
|
virtualinherited |
Connect to a UNIX socket.
sPath | the path to the UNIX socket. |
|
virtualinherited |
retrieve name info (numeric only) for a given sockaddr_storage
pAddr | the sockaddr_storage |
iAddrLen | the length |
sIP | filled with the IP from getnameinfo |
piPort | if not null, filled with the port |
In the event you want to do additional work before or after getnameinfo is called, you can override this and do just that. One example is in the event that an ipv6 ip is a mapped ipv4 mapped, you can check like so.
|
overrideinherited |
|
virtualinherited |
use this to copy a sock from one to the other, override it if you have special needs in the event of a copy
|
inherited |
grabs fd's for the sockets
|
virtualinherited |
This has a garbage collecter, and is used internall to call the jobs.
|
virtualinherited |
deletes a cron by name
sName | the name of the cron |
bDeleteAll | delete all crons that match sName |
bCaseSensitive | use strcmp or strcasecmp |
|
virtualinherited |
delete cron by idx
|
virtualinherited |
delete cron by address
|
virtualinherited |
in the event you pass this class to Copy(), you MUST call this function or on the original Csock other wise bad side effects will happen (double deletes, weird sock closures, etc) if you call this function and have not handled the internal pointers, other bad things can happend (memory leaks, fd leaks, etc) the whole point of this function is to allow this class to go away without shutting down
|
inherited |
|
inlineinherited |
allow disabling compression
|
inlineinherited |
bitwise setter,
|
inlinevirtualinherited |
|
inherited |
dns lookup
|
inherited |
set the value of m_bEnableReadLine to true, we don't want to store a buffer for ReadLine, unless we want it
|
inlineinherited |
select the ciphers in server-preferred order
|
virtualinherited |
override this call with your own DNS lookup method if you have one.
By default this function is blocking
sHostname | the hostname to resolve |
csSockAddr | the destination sock address info |
|
inherited |
Get Avg Read Speed in sample milliseconds (default is 1000 milliseconds or 1 second)
|
inherited |
Get Avg Write Speed in sample milliseconds (default is 1000 milliseconds or 1 second)
|
inlineinherited |
|
inherited |
Gets the amount of data read during the existence of the socket.
|
inherited |
Gets the amount of data written during the existence of the socket.
|
inherited |
|
inlineinherited |
returns int of type to close
|
inlineinherited |
returns the current connection state
|
inlineinherited |
returns a const reference to the crons associated to this socket
|
inherited |
|
inlineinherited |
|
inherited |
Returns a reference to the host name.
|
inherited |
This gives access to the internal read buffer, if your not going to use ReadLine(), then you may want to clear this out (if its binary data and not many '\n')
|
inherited |
This gives access to the internal write buffer.
If you want to check if the send queue fills up, check here.
|
inlineinherited |
|
inherited |
|
inlineinherited |
|
inherited |
|
inherited |
Returns the local port.
|
inherited |
|
inlineinherited |
returns the number of max pending connections when type is LISTENER
CModule* CSocket::GetModule | ( | ) | const |
|
inherited |
Returns the time when CheckTimeout() should be called next.
|
inherited |
|
inherited |
Returns the peer's certificate finger print.
|
inherited |
Returns the peer's public key.
|
inherited |
|
inherited |
|
virtualinherited |
return the data imediatly ready for read
|
inherited |
Returns the port.
|
inherited |
|
inherited |
|
inlinevirtualinherited |
Reimplemented in CHTTPSock.
References Csock::GetRemoteIP().
|
inherited |
Returns the remote port.
|
inherited |
|
inherited |
returns a reference to the sock
Referenced by CExecSock::~CExecSock().
|
inherited |
|
inherited |
|
inherited |
|
inherited |
Returns a reference to the socket name.
override this for accept sockets
|
inherited |
Return true if this socket is using ssl. Note this does not mean the SSL state is finished, but simply that its configured to use ssl.
|
inherited |
|
inherited |
|
inherited |
|
inherited |
|
inherited |
Gets the starting time of this socket.
|
inherited |
|
inherited |
|
inherited |
return how long it has been (in seconds) since the last read or successful write
|
inlineinherited |
|
inlineinherited |
|
inherited |
Returns the connection type from enum eConnType.
|
inherited |
Referenced by CExecSock::~CExecSock().
|
inherited |
|
inherited |
Get the peer's X509 cert.
it is up to you, the caller to call X509_free() on this object
|
inlineinherited |
returns the value of m_bEnableReadLine, if ReadLine is enabled
|
inherited |
Get the send buffer.
|
virtualinherited |
Reimplemented in CIRCSocket.
|
virtualinherited |
Reimplemented in CIRCSocket.
|
inlineinherited |
|
virtualinherited |
Tells you if the socket is connected.
|
inherited |
virtual bool Csock::Listen |
Listens for connections.
iPort | the port to listen on |
iMaxConns | the maximum amount of pending connections to allow |
sBindHost | the vhost on which to listen |
iTimeout | if no connections come in by this timeout, the listener is closed |
bDetach | don't block waiting for port to come up, instead detach and return immediately |
|
virtualinherited |
Listens for connections.
iPort | the port to listen on |
iMaxConns | the maximum amount of pending connections to allow |
sBindHost | the vhost on which to listen |
iTimeout | if no connections come in by this timeout, the listener is closed |
bDetach | don't block waiting for port to come up, instead detach and return immediately |
bool CSocket::Listen | ( | unsigned short | uPort, |
bool | bSSL, | ||
unsigned int | uTimeout = 0 |
||
) |
Ease of use Listen, assigned to the manager and is subsequently tracked.
|
inlinevirtualinherited |
called when type is LISTENER and the listening port is up and running
sBindIP | the IP that is being bound to. Empty if no bind restriction |
uPort | the listening port |
|
virtualinherited |
Listens for connections on an UNIX socket.
sBindFile | the socket on which to listen |
iMaxConns | the maximum amount of pending connections to allow |
iTimeout | if no connections come in by this timeout, the listener is closed |
|
inlineinherited |
add an FD set to monitor
|
inherited |
Use this to change your fd's to blocking or none blocking.
|
inherited |
|
inherited |
|
inherited |
|
inherited |
|
inherited |
|
inherited |
|
inherited |
|
inherited |
will pause/unpause reading on this socket
|
virtualinherited |
pushes data up on the buffer, if a line is ready it calls the ReadLine event
|
overridevirtual |
This defaults to closing the socket, feel free to override.
Reimplemented from Csock.
|
virtualinherited |
Read from the socket Just pass in a pointer, big enough to hold len bytes.
data | the buffer to read into |
len | the size of the buffer |
|
inlinevirtualinherited |
Ready to read data event.
Reimplemented in CHTTPSock.
|
inlinevirtualinherited |
Ready to Read a full line event.
If encoding is provided, this is guaranteed to be UTF-8
|
inlinevirtualinherited |
This gets called every iteration of CSocketManager::Select() if the socket is ReadPaused.
|
inherited |
|
inherited |
|
inherited |
Resets the start time.
|
virtualinherited |
resets the time counter, this is virtual in the event you need an event on the timer being Reset
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
setting this to NULL will allow the default openssl verification process kick in
|
inherited |
Set the cipher type ( openssl cipher [to see ciphers available] )
|
inlineinherited |
sets the connection state to eState
|
inherited |
|
inherited |
Set the pem file location.
|
inherited |
|
inherited |
|
inherited |
|
inlineinherited |
|
inlineinherited |
|
virtualinherited |
Sets the sock, telling it its connected (internal use only)
|
inherited |
|
inherited |
sets the max buffered threshold when EnableReadLine() is enabled
|
virtualinherited |
Set The INBOUND Parent sockname.
|
inherited |
|
inherited |
|
inherited |
|
virtualinherited |
sets the rate at which we can send data
iBytes | the amount of bytes we can write |
iMilliseconds | the amount of time we have to rate to iBytes |
|
inlineinherited |
bitwise flags, 0 means don't require cert, SSL_VERIFY_PEER verifies peers, SSL_VERIFY_FAIL_IF_NO_PEER_CERT will cause the connection to fail if no cert
|
inherited |
legacy, deprecated
|
inherited |
Referenced by CExecSock::~CExecSock().
|
inlineinherited |
|
inherited |
|
inherited |
|
inherited |
|
inherited |
Set the SSL method type.
|
inherited |
|
inlineinherited |
|
inherited |
Currently this uses the same value for all timeouts, and iTimeoutType merely states which event will be checked for timeouts.
|
inherited |
|
inlineinherited |
|
inlineinherited |
|
inherited |
|
inherited |
creates a new SSL_CTX based on the setup of this sock
|
inherited |
this is only used on outbound connections, listeners bind in a different spot
|
inherited |
Referenced by CExecSock::~CExecSock().
|
virtualinherited |
called to configure the SNI client
sHostname,the | hostname to configure SNI with, you can fill this with GetHostname() if its a valid hostname and not an OP |
|
overrideinherited |
|
inlinevirtualinherited |
gets called when a SNI request is sent, and used to configure a SNI session
sHostname | the hostname sent from the client |
sPemFile | fill this with the location to the pemfile |
sPemPass | fill this with the pemfile password if there is one |
|
inlinevirtualinherited |
A sock error occured event.
|
override |
|
inlinevirtualinherited |
Reimplemented in CIRCSock.
|
virtualinherited |
This sets up the SSL Client, this is used internally.
|
inlinevirtualinherited |
Gets called immediatly after the m_ssl member is setup and initialized, useful if you need to assign anything to this ssl session via SSL_set_ex_data.
|
overridevirtualinherited |
called once the SSL handshake is complete, this is triggered via SSL_CB_HANDSHAKE_DONE in SSL_set_info_callback()
This is a spot where you can look at the finished peer certifificate ... IE
X509 * pCert = GetX509(); char szName[256]; memset( szName, '\0', 256 ); X509_NAME_get_text_by_NID ( X509_get_subject_name( pCert ), NID_commonName, szName, 255 ); cerr << "Name! " << szName << endl; X509_free( pCert );
Reimplemented from Csock.
|
inherited |
is SSL_accept finished ? is the ssl properly finished (from write no error)
|
virtualinherited |
This sets up the SSL Server, this is used internally.
|
inherited |
start a TLS connection on an existing plain connection
|
staticprotectedinherited |
CDelayedTranslation CSocket::t_d | ( | const CString & | sEnglish, |
const CString & | sContext = "" |
||
) | const |
|
staticprotectedinherited |
CInlineFormatMessage CSocket::t_f | ( | const CString & | sEnglish, |
const CString & | sContext = "" |
||
) | const |
CInlineFormatMessage CSocket::t_p | ( | const CString & | sEnglish, |
const CString & | sEnglishes, | ||
int | iNum, | ||
const CString & | sContext | ||
) | const |
|
staticprotectedinherited |
|
staticprotectedinherited |
|
inlinevirtualinherited |
|
inherited |
|
overridevirtualinherited |
this is hooked in via SSL_set_verify, and be default it just returns 1 meaning success
iPreVerify | the pre-verification status as determined by openssl internally |
pStoreCTX | the X509_STORE_CTX containing the certificate |
This may get called multiple times, for example with a chain certificate which is fairly typical with certificates from godaddy, freessl, etc. Additionally, openssl does not do any host verification, they leave that up to the you. One easy way to deal with this is to wait for SSLHandShakeFinished() and examine the peer certificate
Reimplemented from Csock.
|
virtualinherited |
Write data to the socket.
If not all of the data is sent, it will be stored on an internal buffer, and tried again with next call to Write if the socket is blocking, it will send everything, its ok to check ernno after this (nothing else is processed)
data | the data to send |
len | the length of data |
|
virtualinherited |
Write a text string to the socket.
Encoding is used, if set
sData | the string to send; if encoding is provided, sData should be UTF-8 and will be encoded |
|
protected |
pointer to the module that this sock instance belongs to
|
protectedinherited |
|
protectedinherited |