~smaioli/azureus/ubuntu-experimental

Logger.log(new LogEvent(torrent, LOGID, LogEvent.LT_INFORMATION, "redirection of http announce [" + tracker_url[0] + "] to udp failed, will retry in " + autoUDPprobeEvery + " announces"));

1154

}

1155

}else if (failure_reason == null && udp_probe){

1127

1156

1128

} else if (failure_reason == null && udp_probe)

1129

{

1130

1157

TRTrackerUtils.setUDPProbeResult(reqUrl, true);

1131

if (Logger.isEnabled())

1158

1159

if (Logger.isEnabled()){

1132

1160

Logger.log(new LogEvent(torrent, LOGID, LogEvent.LT_INFORMATION, "redirection of http announce [" + tracker_url[0] + "] to udp successful"));

1161

}

1162

1133

1163

autoUDPprobeEvery = 1;

1134

1164

}

1135

1165

}

1136

1166

1137

1167

announceCount++;

1138

1168

1139

if ( udpAnnounceURL == null)

1169

if ( udpAnnounceURL == null){

1170

1140

1171

failure_reason = announceHTTP( tracker_url, reqUrl, message );

1172

}

1141

1173

1142

// if we've got some kind of response then return it

1143

if ( message.size() > 0 )

1174

// if we've got some kind of response then return it

1175

1176

if ( message.size() > 0 ){

1177

1144

1178

return( message.toByteArray());

1145

1179

}

1146

1180

1147

1181

if ( failure_reason == null ){

1182

1148

1183

failure_reason = "No data received from tracker";

1149

1184

}

1150

1151

1152

1185

}catch( SSLException e ){

1153

1186

1154

1187

// e.printStackTrace();

1419

1452

announceUDP(

1420

1453

URL reqUrl,

1421

1454

ByteArrayOutputStream message,

1422

boolean do_auth_test)

1455

boolean is_probe )

1423

1456

1424

1457

throws IOException

1425

1458

{

1459

long timeout = is_probe?10000:PRUDPPacket.DEFAULT_UDP_TIMEOUT;

1460

1426

1461

reqUrl = TRTrackerUtils.adjustURLForHosting( reqUrl );

1427

1462

1428

1463

String failure_reason = null;

1430

1465

PasswordAuthentication auth = null;

1431

1466

1432

1467

try{

1433

if (do_auth_test && UrlUtils.queryHasParameter(reqUrl.getQuery(), "auth", false)) {

1468

if ( (!is_probe) && UrlUtils.queryHasParameter(reqUrl.getQuery(), "auth", false)) {

1434

1469

auth = SESecurityManager.getPasswordAuthentication( UDP_REALM, reqUrl );

1435

1470

}

1436

1471

1444

1479

1445

1480

PRUDPPacket connect_request = new PRUDPPacketRequestConnect();

1446

1481

1447

PRUDPPacket reply = handler.sendAndReceive( auth, connect_request, destination );

1482

PRUDPPacket reply = handler.sendAndReceive( auth, connect_request, destination, timeout );

1448

1483

1449

1484

if ( reply.getAction() == PRUDPPacketTracker.ACT_REPLY_CONNECT ){

1450

1485

2903

2938

throw( new IOException( "peers missing from response" ));

2904

2939

}

2905

2940

}else if (!metaData.containsKey("peers6")){

2906

// we got nothing useful under peers and no peers6 either

2941

2942

// we got nothing useful under peers and no peers6 either

2943

2907

2944

throw( new IOException( "peers missing from response" ));

2908

2945

}

2909

2946

2910

2947

2911

2948

final byte[] v6peers = (byte[])metaData.get("peers6");

2912

if (v6peers != null)

2913

{

2914

// 16 bytes for v6 + 2 bytes for port

2949

2950

if ( v6peers != null ){

2951

2952

// 16 bytes for v6 + 2 bytes for port

2953

2915

2954

final int entry_size = 18;

2916

2917

2955

2918

2956

final byte[] rawAddr = new byte[16];

2919

2957

2920

for (int i = 0; i <= v6peers.length - entry_size; i += entry_size)

2921

{

2922

System.arraycopy(v6peers, i, rawAddr, 0, 16);

2958

for (int i=0; i<v6peers.length; i+=entry_size ){

2959

2960

System.arraycopy( v6peers, i, rawAddr, 0, 16 );

2961

2923

2962

String ip = InetAddress.getByAddress(rawAddr).getHostAddress();

2924

int tcp_port = rawAddr[i+16] * 256 + rawAddr[i+17];

2925

if (tcp_port < 0 || tcp_port > 65535)

2926

{

2927

if (Logger.isEnabled())

2963

2964

int po1 = 0xFF & v6peers[i+16];

2965

int po2 = 0xFF & v6peers[i+17];

2966

2967

int tcp_port = po1*256 + po2;

2968

2969

if (tcp_port < 0 || tcp_port > 65535){

2970

2971

if (Logger.isEnabled()){

2972

2928

2973

Logger.log(new LogEvent(torrent, LOGID, LogEvent.LT_ERROR, "Invalid compactv6 peer port given: " + ip + ": " + tcp_port));

2974

}

2975

2929

2976

continue;

2930

2977

}

2931

byte[] peer_peer_id = getAnonymousPeerId(ip, tcp_port);

2978

2979

byte[] peer_peer_id = getAnonymousPeerId( ip, tcp_port );

2980

2932

2981

short protocol = DownloadAnnounceResultPeer.PROTOCOL_NORMAL;

2982

2933

2983

TRTrackerAnnouncerResponsePeerImpl peer = new TRTrackerAnnouncerResponsePeerImpl(PEPeerSource.PS_BT_TRACKER, peer_peer_id, ip, tcp_port, 0, 0, protocol, TRTrackerAnnouncer.AZ_TRACKER_VERSION_1, (short) 0);

2934

if (Logger.isEnabled())

2984

2985

if (Logger.isEnabled()){

2986

2935

2987

Logger.log(new LogEvent(torrent, LOGID, "COMPACTv6 PEER: " + peer.getString()));

2988

}

2989

2936

2990

valid_meta_peers.add(peer);

2937

2991

}

2938

2992

}

Older »