Package tigase.socks5
Class Socks5IOService<RefObject>
java.lang.Object
tigase.net.IOService<RefObject>
tigase.socks5.Socks5IOService<RefObject>
- All Implemented Interfaces:
Callable<tigase.net.IOService<?>>
,tigase.io.TLSEventHandler
,tigase.util.IOListener
public class Socks5IOService<RefObject>
extends tigase.net.IOService<RefObject>
- Author:
- andrzej
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic enum
All possible states of Socks5 connection -
Field Summary
Fields inherited from class tigase.net.IOService
cb, CERT_CHECK_RESULT, CERT_REQUIRED_DOMAIN, decoder, encoder, HOSTNAME_KEY, LOCAL_CERT_CHECK_RESULT, partialCharacterBytes, PORT_TYPE_PROP_KEY, SESSION_ID_KEY, SSL_PROTOCOLS_KEY
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
activate()
Activate servicetigase.net.IOService<?>
call()
void
int
Get all bytes received by this serviceint
Get all bytes sent by this servicetigase.xmpp.jid.JID
getJID()
Returns jid of client connected by this serviceReturns Socks5 connectionType (Requester/Target)getState()
Returns current state of serviceint
hashCode()
Custom hashCode for better distribution Sender and recipient thread should be processed on same threadprotected void
Handles data from socketvoid
protected ByteBuffer
protected int
void
Set ConnectionManagervoid
setSocks5ConnectionType
(Socks5ConnectionType connectionType) Set Socks5 connection type (Requester or Target connection)void
Set stream assigned with this serviceboolean
void
writeBytes
(ByteBuffer buf) protected void
Methods inherited from class tigase.net.IOService
accept, byteOrder, checkBufferLimit, connectionType, debug, debug, getBuffOverflow, getBytesReceived, getBytesSent, getCertificateContainer, getConnectionId, getDataReceiver, getIO, getLastTransferTime, getLocalAddress, getLocalCertificate, getLocalPort, getPeerCertificate, getReadCounters, getRefObject, getRemoteAddress, getSessionData, getSocketChannel, getSocketInputSize, getStatistics, getTlsUniqueId, getTotalBuffOverflow, getTotalBytesReceived, getTotalBytesSent, getUniqueId, getWriteCounters, handleMalformedInput, handshakeCompleted, isConnected, isInputBufferEmpty, isSocketServiceReady, readCompleted, readData, setBufferLimit, setCertificateContainer, setConnectionId, setDataReceiver, setIOServiceListener, setRefObject, setSessionData, setSocketServiceReady, setSslContextContainer, setX509TrustManagers, startSSL, startTLS, startZLib, stop, toString, waitingToSend, waitingToSendSize
-
Field Details
-
transferInProgress
-
-
Constructor Details
-
Socks5IOService
public Socks5IOService()
-
-
Method Details
-
activate
public boolean activate()Activate service- Returns:
-
setConnectionManager
Set ConnectionManager- Parameters:
manager
-
-
setStream
Set stream assigned with this service- Parameters:
stream
-
-
getJID
public tigase.xmpp.jid.JID getJID()Returns jid of client connected by this service- Returns:
-
getState
Returns current state of service- Returns:
-
getSocks5ConnectionType
Returns Socks5 connectionType (Requester/Target)- Returns:
-
setSocks5ConnectionType
Set Socks5 connection type (Requester or Target connection)- Parameters:
connectionType
-
-
getBytesReceived
public int getBytesReceived()Get all bytes received by this service- Returns:
-
getBytesSent
public int getBytesSent()Get all bytes sent by this service- Returns:
-
processWaitingPackets
- Specified by:
processWaitingPackets
in classtigase.net.IOService<RefObject>
- Throws:
IOException
-
waitingToRead
public boolean waitingToRead()- Overrides:
waitingToRead
in classtigase.net.IOService<RefObject>
-
call
- Specified by:
call
in interfaceCallable<RefObject>
- Overrides:
call
in classtigase.net.IOService<RefObject>
- Throws:
IOException
-
writeBytes
- Overrides:
writeBytes
in classtigase.net.IOService<RefObject>
-
forceStop
public void forceStop()- Overrides:
forceStop
in classtigase.net.IOService<RefObject>
-
hashCode
public int hashCode()Custom hashCode for better distribution Sender and recipient thread should be processed on same thread -
readBytes
- Overrides:
readBytes
in classtigase.net.IOService<RefObject>
- Throws:
IOException
-
writeData
- Overrides:
writeData
in classtigase.net.IOService<RefObject>
-
processSocketData
Handles data from socket- Specified by:
processSocketData
in classtigase.net.IOService<RefObject>
- Throws:
IOException
-
receivedPackets
protected int receivedPackets()- Specified by:
receivedPackets
in classtigase.net.IOService<RefObject>
-