public class CIDConnections extends Object
Constructor and Description |
---|
CIDConnections(CID cid,
S2SConnectionHandlerIfc<S2SIOService> handler,
S2SConnectionSelector selector,
int maxInConns,
int maxOutConns,
int maxOutConnsPerIP,
long max_waiting_time)
Constructs ...
|
Modifier and Type | Method and Description |
---|---|
void |
addDBKey(String sessId,
String key)
Method description
|
void |
addIncoming(S2SIOService serv)
Method description
|
void |
connectionAuthenticated(S2SIOService serv,
CID cid)
Method description
|
void |
connectionAuthenticated(String sessionId,
CID cid)
Method description
|
void |
connectionStopped(S2SIOService serv)
Method description
|
String |
getDBKey(String key_sessionId)
Method description
|
int |
getDBKeysCount()
Method description
|
int |
getIncomingCount()
Method description
|
int |
getIncomingTLSCount()
Method description
|
int |
getMaxOutConns()
Method description
|
int |
getMaxOutConnsPerIP()
Method description
|
int |
getOutgoingCount()
Method description
|
int |
getOutgoingHandshakingCount()
Method description
|
boolean |
getOutgoingInProgress()
Method description
|
int |
getOutgoingTLSCount()
Method description
|
S2SConnection |
getS2SConnectionForSessionId(String sessionId)
Method description
|
int |
getWaitingControlCount()
Method description
|
int |
getWaitingCount()
Method description
|
void |
reconnectionFailed(Map<String,Object> port_props)
Method description
|
void |
resetOutgoingInProgress()
Method description
|
boolean |
sendControlPacket(String sessionId,
Packet packet)
Method description
|
void |
sendHandshakingOnly(Packet verify_req)
Method description
|
void |
sendPacket(Packet packet)
Method description
|
static void |
setOutgoingOpenThreadsSize(int size) |
public CIDConnections(CID cid, S2SConnectionHandlerIfc<S2SIOService> handler, S2SConnectionSelector selector, int maxInConns, int maxOutConns, int maxOutConnsPerIP, long max_waiting_time)
cid
- handler
- selector
- maxInConns
- maxOutConns
- maxOutConnsPerIP
- max_waiting_time
- public static void setOutgoingOpenThreadsSize(int size)
public void resetOutgoingInProgress()
public boolean getOutgoingInProgress()
public void addDBKey(String sessId, String key)
sessId
- key
- public void addIncoming(S2SIOService serv)
serv
- public void connectionAuthenticated(S2SIOService serv, CID cid)
serv
- public void connectionAuthenticated(String sessionId, CID cid)
sessionId
- public void connectionStopped(S2SIOService serv)
serv
- public String getDBKey(String key_sessionId)
key_sessionId
- public int getDBKeysCount()
public int getIncomingCount()
public int getIncomingTLSCount()
public int getMaxOutConns()
public int getMaxOutConnsPerIP()
public int getOutgoingCount()
public int getOutgoingHandshakingCount()
public int getOutgoingTLSCount()
public S2SConnection getS2SConnectionForSessionId(String sessionId)
sessionId
- public int getWaitingControlCount()
public int getWaitingCount()
public void reconnectionFailed(Map<String,Object> port_props)
port_props
- public boolean sendControlPacket(String sessionId, Packet packet)
sessionId
- packet
- public void sendHandshakingOnly(Packet verify_req)
verify_req
- public void sendPacket(Packet packet)
packet
- Copyright © 2019 "Tigase, Inc.". All rights reserved.