Examples of DiskManager


Examples of lighthouse.files.DiskManager

            e.printStackTrace();
            fail("Uncaught exception");
        });
        gate = new AffinityExecutor.Gate();
        executor = new AffinityExecutor.ServiceAffinityExecutor("test thread");
        diskManager = new DiskManager(executor);
        backend = new LighthouseBackend(CLIENT, peerGroup, blockChain, pledgingWallet, diskManager, executor);
        backend.setMinPeersForUTXOQuery(1);
        backend.setMaxJitterSeconds(0);

        // Wait to start up.
View Full Code Here

Examples of lighthouse.files.DiskManager

        injectedPledge = pledge;
        backend.shutdown();
        executor.service.shutdown();
        executor.service.awaitTermination(5, TimeUnit.SECONDS);
        executor = new AffinityExecutor.ServiceAffinityExecutor("test thread 2");
        diskManager = new DiskManager(executor);
        writeProjectToDisk();
        backend = new LighthouseBackend(CLIENT, peerGroup, blockChain, pledgingWallet, diskManager, executor);

        // Let's watch out for pledges from the server.
        ObservableSet<LHProtos.Pledge> pledges = backend.mirrorOpenPledges(project, gate);
View Full Code Here

Examples of lighthouse.files.DiskManager

    }

    public LighthouseBackend(Mode mode, PeerGroup peerGroup, AbstractBlockChain chain, PledgingWallet wallet, AffinityExecutor.ServiceAffinityExecutor executor) {
        // The disk manager should only auto load projects in server mode where we install/change them by dropping them
        // into the server directory. But in client mode we always want explicit import.
        this(mode, peerGroup, chain, wallet, new DiskManager(executor), executor);
    }
View Full Code Here

Examples of org.gudy.azureus2.core3.disk.DiskManager

      updatePiecesInfo(false);     
    }
   
   
   
    DiskManager dm = manager.getDiskManager();
   
    String  remaining;
    String  eta      = DisplayFormatters.formatETA(manager.getStats().getETA());
   
    if ( dm != null ){
     
      long  rem = dm.getRemainingExcludingDND();
     
      String  data_rem = DisplayFormatters.formatByteCountToKiBEtc( rem );
     
      // append data length unless we have an eta value and none left
      
View Full Code Here

Examples of org.gudy.azureus2.core3.disk.DiskManager

        return;
 
      if (piecesImage == null || piecesImage.isDisposed())
        return;
     
      DiskManager  dm = manager.getDiskManager();

      boolean valid = !bForce;
     
        boolean[] new_pieces = new boolean[manager.getNbPieces()];
           
      if ( dm != null ){
                   
          DiskManagerPiece[]  dm_pieces = dm.getPieces();
         
       for (int i=0;i<pieces.length;i++){
              
         new_pieces[i] = dm_pieces[i].isDone();
         }
View Full Code Here

Examples of org.gudy.azureus2.core3.disk.DiskManager

  public void refresh(TableCell cell) {
    DiskManagerFileInfo fileInfo   = (DiskManagerFileInfo)cell.getDataSource();
 
    //   dm may be null if this is a skeleton file view
 
    DiskManager      dm      = fileInfo==null?null:fileInfo.getDiskManager();
 
    int remaining = 0;
   
    if( fileInfo != null && dm != null ) {
      int start = fileInfo.getFirstPieceNumber();
      int end = start + fileInfo.getNbPieces();
      DiskManagerPiece[] pieces = dm.getPieces();
      for( int i = start; i < end; i++ ) {
        if( !pieces[ i ].isDone() )  remaining++;
      }
    }else{
   
View Full Code Here

Examples of org.gudy.azureus2.core3.disk.DiskManager

      if (args.size() < 2) {
        ci.out.println("> Command 'hack': Not enough parameters for subcommand 'file'.");
        return false;
      }
      try {
        DiskManager disk = dm.getDiskManager();
        DiskManagerFileInfo files[] = disk.getFiles();
        int file = Integer.parseInt((String) args.get(0));
        String c = (String) args.get(1);
        if (c.equalsIgnoreCase("normal") || c.equalsIgnoreCase("n")) {
          files[file - 1].setSkipped(false);
          files[file - 1].setPriority(0);
View Full Code Here

Examples of org.gudy.azureus2.core3.disk.DiskManager

      return;
    }

    PEPeerManager pm = dlm.getPeerManager();

    DiskManager dm = dlm.getDiskManager();

    if (pm == null || dm == null) {
      GC gc = new GC(pieceInfoCanvas);
      gc.fillRectangle(bounds);
      gc.dispose();
      topLabel.setText("");

      return;
    }

    int iNumCols = bounds.width / BLOCK_SIZE;
    int iNeededHeight = (((dm.getNbPieces() - 1) / iNumCols) + 1) * BLOCK_SIZE;

    if (img != null && !img.isDisposed()) {
      Rectangle imgBounds = img.getBounds();
      if (imgBounds.width != bounds.width || imgBounds.height != iNeededHeight) {
        oldBlockInfo = null;
        img.dispose();
        img = null;
      }
    }

    DiskManagerPiece[] dm_pieces = dm.getPieces();

    PEPiece[] currentDLPieces = pm.getPieces();
    byte[] uploadingPieces = new byte[dm_pieces.length];

    // find upload pieces
View Full Code Here

Examples of org.gudy.azureus2.core3.disk.DiskManager

      final int y1 = newHeight - borderWidth - 1;
     
      if (x1 < 10 || y1 < 3)
        return;
     
      final DiskManager manager = fileInfo.getDiskManager();
      // we want to run through the image part once one the transition from with a disk manager (running)
      // to without a disk manager (stopped) in order to clear the pieces view
      boolean running = manager != null;
      boolean hasGraphic = false;
      Graphic graphic = cell.getGraphic();
      if (graphic instanceof UISWTGraphic) {
        Image img = ((UISWTGraphic) graphic).getImage();
        hasGraphic = img != null && !img.isDisposed();
      }
      final boolean bImageBufferValid = (lastPercentDone == percentDone)
          && cell.isValid() && bNoRed && running == was_running && hasGraphic;
     
      if (bImageBufferValid)
        return;
     
      was_running = running;
      lastPercentDone = percentDone;
      Image piecesImage = null;
     
      if (graphic instanceof UISWTGraphic)
        piecesImage = ((UISWTGraphic) graphic).getImage();
      if (piecesImage != null && !piecesImage.isDisposed())
        piecesImage.dispose();
     
      if (!running) {
        cell.setGraphic(null);
        return;
      }
     
      piecesImage = new Image(SWTThread.getInstance().getDisplay(), newWidth, newHeight);
      final GC gcImage = new GC(piecesImage);
     
      // dm may be null if this is a skeleton file view
      DownloadManager download_manager = fileInfo.getDownloadManager();
      PEPeerManager peer_manager = download_manager == null ? null : download_manager.getPeerManager();
      PEPiece[] pe_pieces = peer_manager == null ? null : peer_manager.getPieces();
      final long now = SystemTime.getCurrentTime();
     
      if (fileInfo != null && manager != null)
      {
        if (percentDone == 1000)
        {
          gcImage.setForeground(Colors.blues[Colors.BLUES_DARKEST]);
          gcImage.setBackground(Colors.blues[Colors.BLUES_DARKEST]);
          gcImage.fillRectangle(1, 1, newWidth - 2, newHeight - 2);
        } else
        {
          final int firstPiece = fileInfo.getFirstPieceNumber();
          final int nbPieces = fileInfo.getNbPieces();
          final DiskManagerPiece[] dm_pieces = manager.getPieces();
          bNoRed = true;
          for (int i = 0; i < newWidth; i++)
          {
            final int a0 = (i * nbPieces) / newWidth;
            int a1 = ((i + 1) * nbPieces) / newWidth;
View Full Code Here

Examples of org.gudy.azureus2.core3.disk.DiskManager

    if ( download_manager == null ){
     
      return;
    }
   
    DiskManager    disk_manager = download_manager.getDiskManager();
    PEPeerManager  peer_manager = download_manager.getPeerManager();

    if (disk_manager == null || peer_manager == null ){
     
      return;
    }
   
    DiskManagerPiece[]   dm_pieces = disk_manager.getPieces();
    PEPiece[]      pe_pieces = peer_manager.getPieces();
   
    int  first_piece = file.getFirstPieceNumber();
    int  num_pieces  = file.getNbPieces();
   
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.