Examples of PeerManager

Examples of org.gudy.azureus2.plugins.peers.PeerManager

430
431
432
433
434
435
436
437
438
439
440
          });
      }else{
       
          // fix up newly added peers to current peer manager
       
        PeerManager  existing_pm = download.getPeerManager();
       
        if ( existing_pm != null ){
         
          for (int i=0;i<peers.size();i++){
           
View Full Code Here

Examples of org.gudy.azureus2.plugins.peers.PeerManager

515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
 
          for (int i=0;i<downloads.length;i++){
           
            Download  download = downloads[i];
           
            PeerManager pm = download.getPeerManager();
           
            if ( pm == null ){
             
              continue;
            }
           
            Peer[]   peers = pm.getPeers();
           
            for (int j=0;j<peers.length;j++){
             
              Peer  p = peers[j];
             
View Full Code Here

Examples of org.gudy.azureus2.plugins.peers.PeerManager

449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
                    if ( !testDownload.isForceStart()){
                     
                      testDownload.setForceStart( true );
                    }
                   
                    PeerManager pm = testDownload.getPeerManager();
                   
                    if ( pm != null ){
                     
                      Peer[] peers = pm.getPeers();
                     
                      for ( int i=0;i<peers.length;i++){
                       
                        Peer peer = peers[i];
                       
View Full Code Here

Examples of org.gudy.azureus2.plugins.peers.PeerManager

268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
           
            download_ok = true;
           
          }else{
           
            PeerManager pm = download.getPeerManager();
           
            if ( pm != null ){
             
              PeerManagerStats stats = pm.getStats();
             
              int connected_seeds   = stats.getConnectedSeeds();
              int connected_leechers  = stats.getConnectedLeechers();
             
             
View Full Code Here

Examples of org.gudy.azureus2.plugins.peers.PeerManager

1614
1615
1616
1617
1618
1619
1620
1621
1622
1623
1624
1625
1626
1627
1628
1629
1630
1631
1632
1633
       
        public void
        peerManagerAdded(
          PEPeerManager  manager )
        {
          PeerManager pm = PeerManagerImpl.getPeerManager( manager);
         
          listener.peerManagerAdded( DownloadImpl.this, pm );
        }
       
        public void
        peerManagerRemoved(
          PEPeerManager  manager )
        {
          PeerManager pm = PeerManagerImpl.getPeerManager( manager);
         
          listener.peerManagerRemoved( DownloadImpl.this, pm );

        }
       
View Full Code Here

Examples of org.gudy.azureus2.plugins.peers.PeerManager

1806
1807
1808
1809
1810
1811
1812
1813
1814
1815
1816
1817
1818
1819
   }
  
  public DiskManager
  getDiskManager()
  {
    PeerManager  pm = getPeerManager();
   
    if ( pm != null ){
     
      return( pm.getDiskManager());
    }
   
    return( null );
  }
View Full Code Here

Examples of org.gudy.azureus2.plugins.peers.PeerManager

626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
    if ( download.isComplete() && is_seed ){
     
      return( is_seed?1:0 );
    }
   
    PeerManager  peer_manager = download.getPeerManager();
   
    if ( peer_manager != null ){ 
     
      String  peer_ip      = inst.getInternalAddress().getHostAddress();
      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 );
  }
View Full Code Here

Examples of org.gudy.azureus2.plugins.peers.PeerManager

364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
           
            log( "Expanding ok bloom to " + new_size + " entries" );
           
            BloomFilter new_ok_bloom   = BloomFilterFactory.createAddOnly( new_size );
 
            PeerManager pm = download.getPeerManager();
           
            if ( pm != null ){
             
              Peer[] peers = pm.getPeers();
             
              for (int i=0;i<peers.length;i++){
               
                byte[]  peer_key = getKey( peers[i] );
               
View Full Code Here

Examples of org.gudy.azureus2.plugins.peers.PeerManager

445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
       
        boolean  gone_async = false;
       
        try{
         
          PeerManager pm = download.getPeerManager();
         
          if ( pm != null ){
           
            Peer[] peers = pm.getPeers();
           
            final List  to_check = new ArrayList();
           
            for (int i=0;i<peers.length;i++){
             
View Full Code Here

Examples of org.gudy.azureus2.plugins.peers.PeerManager

154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
    //System.out.println(downloads[i].getName() + "  Peers: " + peers.length);

    if(peers !=null){
      for(int j = 0; j < peers.length; j++){

        PeerManager manager = peers[j].getManager();

        try {
          if(manager != null){

/*                        //-----Data Mining-----\\
            TotalPeerContainer tpc = Plugin.totalPeer_set.getTotalPeerContainer(new IP(peers[j].getIp()));
            if(tpc != null){
              PeerStats ps = peers[j].getStats();
              tpc.setAllByPeerStats(ps);
              tpc.setPercentDone((peers[j].getPercentDoneInThousandNotation()));

            }*/
            //--Looking for escaped seeds---\\
            if(Plugin.getPluginInterface().getPluginconfig().getPluginBooleanParameter("Stuffer_Block_Seeder",false)){
              if(peers[j].isSeed() || peers[j].getPercentDoneInThousandNotation() == 1000){
                String color = Plugin.getPluginInterface().getPluginconfig().getPluginStringParameter("Stuffer_Block_Seeder_Color","r255g0b0");
                System.out.println("Escaped Seeder: " + peers[j].getPercentDoneInThousandNotation());
                if(!color.equalsIgnoreCase("null")){
                  String peerID = BlockIPUtils.getPeerID(peers[j].getId());
                  String clientName = peers[j].getClient();
                  // peer.setSnubbed(true);
                  BlockIPUtils.makeIPFilterRule(peers[j].getIp(),"Escaped Seeder: " + peerID,clientName + " Escaped Seeder",manager.getDownload().getName(), color);
                  Constants.SEEDER_CLIENT_BLOCKS++;
                  Plugin.getTab2().renumberMOD_Seeder(false, true);
                }
              }
            }

            //-----Look for Escaped peers----\\
            String peerClient = peers[j].getClient();
            String color = BlockIPUtils.mainRuleRun(peerClient,manager.isSuperSeeding(), manager.getDownload().getState());
            if(!color.equalsIgnoreCase("null")){
              String peerID = BlockIPUtils.getPeerID(peers[j].getId());
              BlockIPUtils.makeIPFilterRule(peers[j].getIp(),"ESCAPED: " + peerID,peerClient,manager.getDownload().getName(), color);
            }
          }
        } catch (DownloadException e) {
          e.printStackTrace();
        }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.