406407408409410411412413414415416
user_data.put( PEER_KEY, download ); user_data.put( Peer.PR_PRIORITY_CONNECTION, new Boolean( true )); c_pm.addPeer( ip.getHostAddress(), tcp_port, udp_port, true, user_data ); } } } protected void
12461247124812491250125112521253125412551256
Map user_data = new LightHashMap(); user_data.put( Peer.PR_PRIORITY_CONNECTION, new Boolean( true )); pm.addPeer( service_ip, transfer.getDataPort(), 0, false, user_data ); if ( count[0] < 3 ){ final AERunnable target = this;
20582059206020612062206320642065206620672068
Map<Object,Object> user_data = new HashMap<Object,Object>(); user_data.put( Peer.PR_PRIORITY_CONNECTION, new Boolean( true )); pm.addPeer( peer.getAddress(), peer.getPort(), peer.getUDPPort(), peer.getProtocol() == DownloadAnnounceResultPeer.PROTOCOL_CRYPT, user_data );
636637638639640641642643644645646
int peer_tcp_port = inst.getTCPListenPort(); int peer_udp_port = inst.getUDPListenPort(); log.log( " " + download.getName() + ": Injecting peer " + peer_ip + ":" + peer_tcp_port + "/" + peer_udp_port); peer_manager.addPeer( peer_ip, peer_tcp_port, peer_udp_port, false ); } return( is_seed?3:2 ); }