Package com.biglybt.plugin.net.buddy
Class BuddyPluginBuddy
java.lang.Object
com.biglybt.plugin.net.buddy.BuddyPluginBuddy
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprotected class
protected class
protected class
(package private) static interface
static interface
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate boolean
private boolean
private boolean
private static final int
private static final int
private List<BuddyPluginBuddy.buddyConnection>
private int
private long
private InetSocketAddress
private BuddyPluginBuddy.buddyMessage
private boolean
private boolean
private boolean
private long
private long
private String
private long
private int
private long
private InetSocketAddress
private InetSocketAddress
private long
private static final int
private static final int
private int
private int
private int
private int
private List<BuddyPluginBuddy.buddyMessage>
private String
private int
private int
private String
private boolean
private int
private AESemaphore
private BuddyPluginBuddyMessageHandler
private BuddyPluginNetwork
private long
private long
private boolean
private String
private String
private Object
private static final int
private static final int
private static final int
private long
private int
private int
private static final boolean
private int
private int
private boolean
private boolean
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
BuddyPluginBuddy
(BuddyPluginNetwork _plugin_network, long _created_time, int _subsystem, boolean _authorised, String _pk, String _nick_name, String _my_name, int _version, String _rss_local_cats, String _rss_remote_cats, int _last_status_seq, long _last_time_online, List<Long> _recent_ygm, boolean _is_transient) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
addConnection
(BuddyPluginNetwork.DDBDetails _ddb_details, GenericMessageConnection _connection) void
addLocalAuthorisedRSSTagOrCategory
(String category) private boolean
addressesEqual
(InetSocketAddress ias1, InetSocketAddress ias2) protected boolean
addYGMMarker
(long marker) protected void
protected void
buddyConnectionEstablished
(boolean outgoing) protected void
buddyMessageFragmentReceived
(int num_received, int total) protected void
buddyMessageReceived
(int size) protected void
buddyMessageSent
(int size, boolean record_active) protected boolean
catsIdentical
(Set<String> c1, Set<String> c2) protected String
catsToString
(Set<String> cats) protected void
protected void
decrypt
(byte[] payload) protected void
destroy()
void
protected void
encrypt
(byte[] payload) int
int
protected long
getIP()
long
protected long
protected int
long
getLatestIP
(boolean v4) int
int
getName()
int
protected BuddyPluginNetwork
void
protected byte[]
protected String
getSubscriptionURL
(String cat) int
int
int
getUserData
(Object key) int
protected void
incomingConnection
(BuddyPluginNetwork.DDBDetails _ddb_details, GenericMessageConnection _connection) boolean
protected boolean
boolean
protected boolean
isIdle()
boolean
isLocalRSSTagOrCategoryAuthorised
(String category) boolean
isOnline
(boolean is_connected) boolean
boolean
isRemoteRSSTagOrCategoryAuthorised
(String category) boolean
boolean
protected void
protected void
protected void
protected void
logMessage
(String str) protected GenericMessageConnection
protected void
protected void
void
ping()
readConfigFile
(File name) protected void
receivedCloseRequest
(Map request) void
remove()
protected void
void
removeLocalAuthorisedRSSTagOrCategory
(String category) retrieveMessages
(int type) protected void
sendCloseRequest
(boolean restarting) protected void
void
sendMessage
(int subsystem, Map content, int timeout_millis, BuddyPluginBuddyReplyListener listener) protected void
sendMessageSupport
(Map content, int subsystem, int timeout_millis, BuddyPluginBuddyReplyListener original_listener) private void
setAddress
(InetSocketAddress address) protected void
setAuthorised
(boolean _a) protected void
setCachedStatus
(InetSocketAddress _ip, int _tcp_port, int _udp_port) protected void
setInitialStatus
(long now, int num_buddies) protected void
void
setLocalAuthorisedRSSTagsOrCategories
(String new_cats) void
setLocalAuthorisedRSSTagsOrCategories
(Set<String> new_cats) void
void
protected void
setOnlineStatus
(int s) protected void
setRemoteAuthorisedRSSTagsOrCategories
(Set<String> new_cats) protected void
setSubsystem
(int _s) void
setTransient
(boolean b) void
setUserData
(Object key, Object value) protected void
setVersion
(int v) protected boolean
protected void
statusCheckComplete
(BuddyPluginNetwork.DDBDetails _ddb_details, long _post_time, InetSocketAddress _ias, int _tcp_port, int _udp_port, String _nick_name, int _online_status, int _status_seq, int _version) protected void
protected boolean
storeMessage
(int type, Map msg) stringToCats
(String str) void
boolean
verify
(byte[] payload, byte[] signature) boolean
writeConfigFile
(File name, Map data)
-
Field Details
-
TRACE
private static final boolean TRACE- See Also:
-
CONNECTION_IDLE_TIMEOUT
private static final int CONNECTION_IDLE_TIMEOUT- See Also:
-
CONNECTION_KEEP_ALIVE
private static final int CONNECTION_KEEP_ALIVE- See Also:
-
MAX_ACTIVE_CONNECTIONS
private static final int MAX_ACTIVE_CONNECTIONS- See Also:
-
MAX_QUEUED_MESSAGES
private static final int MAX_QUEUED_MESSAGES- See Also:
-
RT_REQUEST_DATA
private static final int RT_REQUEST_DATA- See Also:
-
RT_REPLY_DATA
private static final int RT_REPLY_DATA- See Also:
-
RT_REPLY_ERROR
private static final int RT_REPLY_ERROR- See Also:
-
plugin_network
-
created_time
private long created_time -
subsystem
private int subsystem -
authorised
private boolean authorised -
public_key
-
nick_name
-
my_name
-
recent_ygm
-
is_transient
private boolean is_transient -
last_status_seq
private int last_status_seq -
post_time
private long post_time -
current_ip
-
latest_ipv4
-
latest_ipv6
-
tcp_port
private int tcp_port -
udp_port
private int udp_port -
online_status
private int online_status -
version
private int version -
online
private boolean online -
last_time_online
private long last_time_online -
status_check_count
private long status_check_count -
last_status_check_time
private long last_status_check_time -
check_active
private boolean check_active -
connections
-
messages
-
current_message
-
next_connection_id
private int next_connection_id -
next_message_id
private int next_message_id -
ygm_active
private boolean ygm_active -
ygm_pending
private boolean ygm_pending -
latest_ygm_time
private long latest_ygm_time -
last_message_received
-
offline_seq_set
-
message_out_count
private int message_out_count -
message_in_count
private int message_in_count -
message_out_bytes
private int message_out_bytes -
message_in_bytes
private int message_in_bytes -
received_frag_details
-
persistent_msg_handler
-
user_data
-
keep_alive_outstanding
private boolean keep_alive_outstanding -
last_connect_attempt
private volatile long last_connect_attempt -
consec_connect_fails
private volatile int consec_connect_fails -
last_auto_reconnect
private long last_auto_reconnect -
rss_lock
-
rss_local_cats
-
rss_remote_cats
-
rss_cats_read
-
profile_info
-
profile_info_outstanding
private boolean profile_info_outstanding -
profile_info_last
private long profile_info_last -
outgoing_connect_sem
-
closing
private volatile boolean closing -
destroyed
private volatile boolean destroyed
-
-
Constructor Details
-
BuddyPluginBuddy
protected BuddyPluginBuddy(BuddyPluginNetwork _plugin_network, long _created_time, int _subsystem, boolean _authorised, String _pk, String _nick_name, String _my_name, int _version, String _rss_local_cats, String _rss_remote_cats, int _last_status_seq, long _last_time_online, List<Long> _recent_ygm, boolean _is_transient)
-
-
Method Details
-
getPluginNetwork
-
isPublicNetwork
public boolean isPublicNetwork() -
setInitialStatus
protected void setInitialStatus(long now, int num_buddies) -
getPlugin
-
getMessageHandler
-
persistentDispatchPending
protected void persistentDispatchPending() -
checkPersistentDispatch
protected void checkPersistentDispatch() -
persistentDispatch
protected void persistentDispatch() -
readConfigFile
-
writeConfigFile
-
getCreatedTime
protected long getCreatedTime() -
getSubsystem
public int getSubsystem() -
setSubsystem
protected void setSubsystem(int _s) -
isAuthorised
public boolean isAuthorised() -
setAuthorised
protected void setAuthorised(boolean _a) -
isTransient
public boolean isTransient() -
setTransient
public void setTransient(boolean b) -
getPublicKey
-
getRawPublicKey
protected byte[] getRawPublicKey() -
getShortString
-
getNickName
-
getVersion
public int getVersion() -
setVersion
protected void setVersion(int v) -
getLocalAuthorisedRSSTagsOrCategoriesAsString
-
getLocalAuthorisedRSSTagsOrCategories
-
addLocalAuthorisedRSSTagOrCategory
-
removeLocalAuthorisedRSSTagOrCategory
-
setLocalAuthorisedRSSTagsOrCategories
-
setLocalAuthorisedRSSTagsOrCategories
-
getRemoteAuthorisedRSSTagsOrCategories
-
getRemoteAuthorisedRSSTagsOrCategoriesAsString
-
setRemoteAuthorisedRSSTagsOrCategories
-
isLocalRSSTagOrCategoryAuthorised
-
isRemoteRSSTagOrCategoryAuthorised
-
localRSSTagOrCategoryRead
-
getLocalReadTagsOrCategoriesAsString
-
getSubscriptionURL
-
subscribeToCategory
- Throws:
BuddyPluginException
-
isSubscribedToCategory
-
catsToString
-
catsIdentical
-
stringToCats
-
getOnlineStatus
public int getOnlineStatus() -
setOnlineStatus
protected void setOnlineStatus(int s) -
getName
-
getMyName
-
setMyName
-
remove
public void remove() -
getIP
-
getLatestIP
-
getAdjustedIP
-
getAdjustedIPs
-
getTCPPort
public int getTCPPort() -
getUDPPort
public int getUDPPort() -
isOnline
public boolean isOnline(boolean is_connected) -
isIdle
protected boolean isIdle() -
getLastTimeOnline
public long getLastTimeOnline() -
getProfileInfo
-
encrypt
- Throws:
BuddyPluginException
-
decrypt
- Throws:
BuddyPluginException
-
verify
- Throws:
BuddyPluginException
-
storeMessage
-
retrieveMessages
-
setMessagePending
- Throws:
BuddyPluginException
-
getLastMessagePending
public long getLastMessagePending() -
addYGMMarker
protected boolean addYGMMarker(long marker) -
setLastMessageReceived
-
getLastMessageReceived
-
getYGMMarkers
-
getLastStatusSeq
protected int getLastStatusSeq() -
buddyConnectionEstablished
protected void buddyConnectionEstablished(boolean outgoing) -
buddyMessageSent
protected void buddyMessageSent(int size, boolean record_active) -
buddyMessageReceived
protected void buddyMessageReceived(int size) -
buddyMessageFragmentReceived
protected void buddyMessageFragmentReceived(int num_received, int total) -
getMessageInFragmentDetails
-
getMessageInCount
public int getMessageInCount() -
getMessageOutCount
public int getMessageOutCount() -
getBytesInCount
public int getBytesInCount() -
getBytesOutCount
public int getBytesOutCount() -
isConnected
public boolean isConnected() -
buddyActive
protected void buddyActive() -
ping
- Throws:
BuddyPluginException
-
sendCloseRequest
protected void sendCloseRequest(boolean restarting) -
receivedCloseRequest
-
sendMessage
public void sendMessage(int subsystem, Map content, int timeout_millis, BuddyPluginBuddyReplyListener listener) throws BuddyPluginException - Throws:
BuddyPluginException
-
sendMessageSupport
protected void sendMessageSupport(Map content, int subsystem, int timeout_millis, BuddyPluginBuddyReplyListener original_listener) throws BuddyPluginException - Throws:
BuddyPluginException
-
dispatchMessage
protected void dispatchMessage() -
removeConnection
-
getLastStatusCheckTime
protected long getLastStatusCheckTime() -
statusCheckActive
protected boolean statusCheckActive() -
statusCheckStarts
protected boolean statusCheckStarts() -
statusCheckFailed
protected void statusCheckFailed() -
setAddress
-
addressesEqual
-
setCachedStatus
-
statusCheckComplete
protected void statusCheckComplete(BuddyPluginNetwork.DDBDetails _ddb_details, long _post_time, InetSocketAddress _ias, int _tcp_port, int _udp_port, String _nick_name, int _online_status, int _status_seq, int _version) -
checkTimeouts
protected void checkTimeouts() -
sendKeepAlive
protected void sendKeepAlive() -
getConnectionsString
-
disconnect
public void disconnect() -
isClosing
protected boolean isClosing() -
destroy
protected void destroy() -
logMessage
-
outgoingConnection
- Throws:
BuddyPluginException
-
incomingConnection
protected void incomingConnection(BuddyPluginNetwork.DDBDetails _ddb_details, GenericMessageConnection _connection) throws BuddyPluginException - Throws:
BuddyPluginException
-
addConnection
protected void addConnection(BuddyPluginNetwork.DDBDetails _ddb_details, GenericMessageConnection _connection) throws BuddyPluginException - Throws:
BuddyPluginException
-
setUserData
-
getUserData
-
log
-
log
-
getString
-