Package tigase.socks5
Class Socks5ConnectionManager
java.lang.Object
tigase.server.BasicComponent
tigase.server.AbstractMessageReceiver
- All Implemented Interfaces:
tigase.cluster.api.ClusteredComponentIfc
,tigase.conf.Configurable
,tigase.disco.XMPPService
,tigase.kernel.beans.config.ConfigurationChangedAware
,tigase.kernel.beans.Initializable
,tigase.kernel.beans.RegistrarBean
,tigase.net.IOServiceListener<Socks5IOService<?>>
,tigase.server.MessageReceiver
,tigase.server.PacketWriterWithTimeout
,tigase.server.ServerComponent
,tigase.stats.StatisticsContainer
,tigase.stats.StatisticsContainerIfc
,tigase.vhosts.VHostListener
- Direct Known Subclasses:
Socks5ProxyComponent
Class description
- Version:
- 5.2.0, 13/10/15
- Author:
- Andrzej Wójcik
-
Nested Class Summary
Nested classes/interfaces inherited from class tigase.socks5.AbstractConnectionManager
AbstractConnectionManager.PortConfigBean, AbstractConnectionManager.PortsConfigBean
Nested classes/interfaces inherited from class tigase.server.BasicComponent
tigase.server.BasicComponent.ServerInfoVHostItemExtension
Nested classes/interfaces inherited from interface tigase.server.PacketWriterWithTimeout
tigase.server.PacketWriterWithTimeout.Handler
-
Field Summary
Fields inherited from class tigase.socks5.AbstractConnectionManager
net_buffer, NET_BUFFER_HT_PROP_VAL, NET_BUFFER_ST_PROP_VAL, PORT_CLASS_PROP_KEY, PORT_IFC_PROP_KEY, PORT_IFC_PROP_VAL, PORT_KEY, PORT_SOCKET_PROP_KEY, PORT_TYPE_PROP_KEY, PORTS_PROP_KEY, PROP_KEY, services
Fields inherited from class tigase.server.AbstractMessageReceiver
HOUR, INCOMING_FILTERS_PROP_KEY, INCOMING_FILTERS_PROP_VAL, MAX_QUEUE_SIZE_PROP_KEY, MAX_QUEUE_SIZE_PROP_VAL, maxInQueueSize, maxOutQueueSize, maxQueueSize, MINUTE, OUTGOING_FILTERS_PROP_KEY, OUTGOING_FILTERS_PROP_VAL, PACKET_DELIVERY_RETRY_COUNT_PROP_KEY, SCHEDULER_THREADS_PROP_KEY, SECOND
Fields inherited from class tigase.server.BasicComponent
admins, ALL_PROP_KEY, COMMAND_PROP_NODE, scriptCommands, scriptEngineManager, SCRIPTS_DIR_PROP_DEF, SCRIPTS_DIR_PROP_KEY, trusted, vHostManager
Fields inherited from interface tigase.conf.Configurable
ADMINS_PROP_KEY, AMP_CLASS_NAME, AMP_CLUST_CLASS_NAME, AUTH_DOMAIN_POOL_CLASS, AUTH_REPO_DOMAINS_PROP_KEY, AUTH_REPO_PARAMS_NODE, AUTH_REPO_POOL_CLASS, AUTH_REPO_URL_PROP_KEY, BOSH_CLUST_COMP_CLASS_NAME, BOSH_COMP_CLASS_NAME, C2S_CLUST_COMP_CLASS_NAME, C2S_COMP_CLASS_NAME, CL_COMP_CLASS_NAME, CLUSTER_CONECT, CLUSTER_CONTR_CLASS_NAME, CLUSTER_LISTEN, CLUSTER_MODE, CLUSTER_NODES, CLUSTER_NODES_PROP_KEY, COMP_PROT_CLASS_NAME, COMPONENT_ID_PROP_KEY, DEF_AMP_NAME, DEF_BOSH_NAME, DEF_C2S_NAME, DEF_CL_COMP_NAME, DEF_CLUST_CONTR_NAME, DEF_COMP_PROT_NAME, DEF_EVENTBUS_NAME, DEF_EXT_COMP_NAME, DEF_HOSTNAME_PROP_KEY, DEF_MONITOR_NAME, DEF_S2S_NAME, DEF_SM_NAME, DEF_STATS_NAME, DEF_VHOST_MAN_NAME, DEF_WS2S_NAME, DERBY_REPO_CLASS_PROP_VAL, DERBY_REPO_URL_PROP_VAL, DRUPAL_REPO_URL_PROP_VAL, DRUPALWP_REPO_CLASS_PROP_VAL, DUMMY_REPO_CLASS_PROP_VAL, EVENTBUS_CLASS_NAME, EXT_COMP_CLASS_NAME, GEN_ADMINS, GEN_AUTH_DB, GEN_AUTH_DB_URI, GEN_COMP_CLASS, GEN_COMP_NAME, GEN_CONF, GEN_CONFIG, GEN_CONFIG_ALL, GEN_CONFIG_COMP, GEN_CONFIG_CS, GEN_CONFIG_DEF, GEN_CONFIG_SM, GEN_DEBUG, GEN_DEBUG_PACKAGES, GEN_EXT_COMP, GEN_MAX_QUEUE_SIZE, GEN_SCRIPT_DIR, GEN_SM_PLUGINS, GEN_SREC_ADMINS, GEN_SREC_DB, GEN_SREC_DB_URI, GEN_TEST, GEN_TRUSTED, GEN_USER_DB, GEN_USER_DB_URI, GEN_USER_DB_URI_PROP_KEY, GEN_VIRT_HOSTS, HOSTNAMES_PROP_KEY, LIBRESOURCE_REPO_CLASS_PROP_VAL, LIBRESOURCE_REPO_URL_PROP_VAL, MONITOR_CLASS_NAME, MONITOR_CLUST_CLASS_NAME, MONITORING, MYSQL_REPO_CLASS_PROP_VAL, MYSQL_REPO_URL_PROP_VAL, PGSQL_REPO_CLASS_PROP_VAL, PGSQL_REPO_URL_PROP_VAL, ROUTER_COMP_CLASS_NAME, S2S_CLUST_COMP_CLASS_NAME, S2S_COMP_CLASS_NAME, SHARED_AUTH_REPO_PARAMS_PROP_KEY, SHARED_AUTH_REPO_PROP_KEY, SHARED_USER_REPO_PARAMS_PROP_KEY, SHARED_USER_REPO_PROP_KEY, SM_CLUST_COMP_CLASS_NAME, SM_COMP_CLASS_NAME, STANZA_WHITE_CHAR_ACK, STANZA_XMPP_ACK, STATS_CLASS_NAME, STRINGPREP_PROCESSOR, TIGASE_AUTH_REPO_CLASS_PROP_VAL, TIGASE_AUTH_REPO_URL_PROP_VAL, TIGASE_CUSTOM_AUTH_REPO_CLASS_PROP_VAL, TRUSTED_PROP_KEY, USER_DOMAIN_POOL_CLASS, USER_REPO_DOMAINS_PROP_KEY, USER_REPO_PARAMS_NODE, USER_REPO_POOL_CLASS, USER_REPO_POOL_SIZE, USER_REPO_POOL_SIZE_PROP_KEY, USER_REPO_URL_PROP_KEY, VHOST_MAN_CLASS_NAME, VHOST_MAN_CLUST_CLASS_NAME, WS2S_CLASS_NAME, WS2S_CLUST_CLASS_NAME, XML_REPO_CLASS_PROP_VAL, XML_REPO_URL_PROP_VAL, XMPP_STANZA_ACK
Fields inherited from interface tigase.disco.XMPPService
CMD_FEATURES, DEF_FEATURES, INFO_XMLNS, ITEMS_XMLNS
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected Socks5IOService
Returns new instance of servicevoid
getStatistics
(tigase.stats.StatisticsList list) Generates the component statistics.Get stream with specified id from map of registred streamsboolean
Check if there is registered stream with specified idprotected boolean
Returns true if instance should handle high throughtputvoid
packetsReady
(Socks5IOService service) void
registerStream
(String sid, Socks5IOService con) Register stream by creating it and assigning connection to itvoid
serviceStarted
(Socks5IOService<?> serv) Handle service after creationboolean
serviceStopped
(Socks5IOService<?> serv) Handle service after stoppingvoid
socketDataProcessed
(Socks5IOService service) Process stream after each time data from socket is processedvoid
tlsHandshakeCompleted
(Socks5IOService service) void
unregisterStream
(Stream stream) Unregister streamMethods inherited from class tigase.socks5.AbstractConnectionManager
connectWaitingTasks, doForAllServices, everyMinute, getDefaultPorts, getPorts, initializationCompleted, register, releaseListener, start, stop, unregister
Methods inherited from class tigase.server.AbstractMessageReceiver
addOutPacket, addOutPacketNB, addOutPackets, addOutPacketWithTimeout, addOutPacketWithTimeout, addPacket, addPacketNB, addPackets, addRegexRouting, addTimerTask, addTimerTask, addTimerTask, addTimerTaskWithTimeout, addTimerTaskWithTimeout, beanConfigurationChanged, clearRegexRoutings, everyHour, everySecond, getMaxQueueSize, getRegexRoutings, getResourceForPacketWithTimeout, hashCodeForPacket, isInRegexRoutings, newPacketId, processingInThreads, processingOutThreads, processOutPacket, processPacket, processPacket, release, removeRegexRouting, schedulerThreads, setCompId, setIncomingFilters, setName, setOutogingFilters, setParent, setSchedulerThreads_size
Methods inherited from class tigase.server.BasicComponent
addComponentDomain, canCallCommand, canCallCommand, checkCommandAcl, checkCommandAcl, createScriptEngineManager, getComponentId, getComponentInfo, getDefaults, getDefHostName, getDefVHostItem, getDiscoCategory, getDiscoCategoryType, getDiscoDescription, getDiscoExtensionsForm, getDiscoFeatures, getDiscoFeatures, getDiscoInfo, getDiscoItems, getName, getNodesConnected, getNodesConnectedWithLocal, getScriptCommands, getScriptItems, getServiceEntity, getServiceEntityCaps, getVHostItem, handlesLocalDomains, handlesNameSubdomains, handlesNonLocalDomains, initBindings, initialize, isAdmin, isInitializationComplete, isLocalDomain, isLocalDomainOrComponent, isNonAdminCommands, isSubdomain, isTrusted, isTrusted, nodeConnected, nodeDisconnected, onNodeConnected, onNodeDisconnected, processScriptCommand, removeComponentDomain, removeServiceDiscoveryItem, setAdmins, setClusterController, setCommandsACL, setProperties, setScriptsBaseDir, setVHostManager, updateServiceDiscoveryItem, updateServiceDiscoveryItem, updateServiceDiscoveryItem, updateServiceEntity
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface tigase.server.MessageReceiver
getDefHostName
Methods inherited from interface tigase.server.ServerComponent
getComponentId, getComponentInfo, getName, isInitializationComplete
Methods inherited from interface tigase.stats.StatisticsContainerIfc
getName
-
Constructor Details
-
Socks5ConnectionManager
public Socks5ConnectionManager()
-
-
Method Details
-
packetsReady
- Throws:
IOException
-
registerStream
Register stream by creating it and assigning connection to it- Parameters:
sid
-con
-
-
serviceStarted
Description copied from class:AbstractConnectionManager
Handle service after creation- Overrides:
serviceStarted
in classAbstractConnectionManager<Socks5IOService<?>>
-
serviceStopped
Description copied from class:AbstractConnectionManager
Handle service after stopping- Specified by:
serviceStopped
in interfacetigase.net.IOServiceListener<Socks5IOService<?>>
- Overrides:
serviceStopped
in classAbstractConnectionManager<Socks5IOService<?>>
-
socketDataProcessed
Process stream after each time data from socket is processed- Parameters:
service
- is aSocks5IOService
-
tlsHandshakeCompleted
-
unregisterStream
Unregister stream- Parameters:
stream
-
-
getStatistics
public void getStatistics(tigase.stats.StatisticsList list) Generates the component statistics.- Specified by:
getStatistics
in interfacetigase.stats.StatisticsContainerIfc
- Overrides:
getStatistics
in classAbstractConnectionManager<Socks5IOService<?>>
- Parameters:
list
- is a collection to put the component statistics in.
-
getStream
Get stream with specified id from map of registred streams- Parameters:
cid
-- Returns:
-
hasStream
Check if there is registered stream with specified id- Parameters:
cid
-- Returns:
-
getIOServiceInstance
Description copied from class:AbstractConnectionManager
Returns new instance of service- Specified by:
getIOServiceInstance
in classAbstractConnectionManager<Socks5IOService<?>>
- Returns:
- Throws:
IOException
-
isHighThroughput
protected boolean isHighThroughput()Description copied from class:AbstractConnectionManager
Returns true if instance should handle high throughtput- Overrides:
isHighThroughput
in classAbstractConnectionManager<Socks5IOService<?>>
- Returns:
-