javax.swing.ProgressMonitorInputStream的实例源码

项目：zencash-swing-wallet-ui    文件：ProvingKeyFetcher.java   

private static boolean checkSHA256(File provingKey,Component parent) throws IOException {
    MessageDigest sha256;
    try {
        sha256 = MessageDigest.getInstance("SHA-256");
    } catch (NoSuchAlgorithmException impossible) {
        throw new IOException(impossible);
    }
    try (InputStream is = new BufferedInputStream(new FileInputStream(provingKey))) {
        ProgressMonitorInputStream pmis = new ProgressMonitorInputStream(parent,"Verifying proving key",is);
        pmis.getProgressMonitor().setMaximum(PROVING_KEY_SIZE);
        pmis.getProgressMonitor().setMillisToPopup(10);
        DigestInputStream dis = new DigestInputStream(pmis,sha256);
        byte [] temp = new byte[0x1 << 13];
        while(dis.read(temp) >= 0);
        byte [] digest = sha256.digest();
        return SHA256.equalsIgnoreCase(DatatypeConverter.printHexBinary(digest));
    }
}

项目：komodoGUI    文件：ProvingKeyFetcher.java   

private static boolean checkSHA256(File provingKey,Component parent) throws IOException {
    MessageDigest sha256;
    try {
        sha256 = MessageDigest.getInstance("SHA-256");
    } catch (NoSuchAlgorithmException impossible) {
        throw new RuntimeException(impossible);
    }
    try (InputStream is = new BufferedInputStream(new FileInputStream(provingKey))) {
        ProgressMonitorInputStream pmis = new ProgressMonitorInputStream(parent,sha256);
        byte [] temp = new byte[0x1 << 13];
        while(dis.read(temp) >= 0);
        byte [] digest = sha256.digest();
        return SHA256.equalsIgnoreCase(DatatypeConverter.printHexBinary(digest));
    }
}

项目：serverwiz    文件：GithubFile.java   

public void download() throws Exception {
    if (!downloadNeeded) { return; }
    logger.info("Downloading: "+this.downloadUrl);
    if (!DEBUG) {
        this.mkdir();
        URL url = new URL(this.downloadUrl);
        URLConnection urlConn = url.openConnection();
        urlConn.setConnectTimeout(10000);
        urlConn.setReadTimeout(10000);
        InputStream is = urlConn.getInputStream();
        ProgressMonitorInputStream pim = new ProgressMonitorInputStream(null,"Downloading "+ downloadUrl,is);
        logger.info("File Size: "+this.remoteFileSize);
        pim.getProgressMonitor().setMaximum((int) this.remoteFileSize);
        pim.getProgressMonitor().setMillisToDecidetoPopup(500);
        logger.info("Starting Download...");
        Files.copy(pim,localFile.toPath(),StandardcopyOption.REPLACE_EXISTING);
    }
}

项目：Animator    文件：FlashThread.java   

@Override
public Void doInBackground() {
    String rawString = configManager.getRawString();
    try {
        stream = new ProgressMonitorInputStream(null,(Object) "Flashing",new ByteArrayInputStream(rawString
                        .getBytes(HacklaceConfigManager.HACKLACE_CHARSET)));
        ProgressMonitor progressMonitor = stream.getProgressMonitor();
        progressMonitor.setMaximum(rawString.length());
        progressMonitor.setProgress(0);
        progressMonitor.setMillisToPopup(0);
        animatorGui.setCursor(Cursor
                .getPredefinedCursor(Cursor.WAIT_CURSOR));
        flashExporter.write(stream);
    } catch (Exception ex) {
        JOptionPane.showMessageDialog(null,"Error flashing hacklace: "
                + ex,"Error",JOptionPane.ERROR_MESSAGE);
    }
    return null;
}

项目：org.datagr4m    文件：BinaryFiles.java   

/** Performs loading a serialized java object by poping a progress monitor.*/
@SuppressWarnings("unchecked")
public static <O> O load(String filename,Component parentComponent,String message) throws IOException,ClassNotFoundException {
    final FileInputStream fis = new FileInputStream(filename);
    final ObjectInputStream in;

    if(parentComponent!=null){
        final ProgressMonitorInputStream pm = new ProgressMonitorInputStream(parentComponent,message,fis);
        in = new ObjectInputStream(pm);
    }
    else{
        in = new ObjectInputStream(fis);
    }

    O r = (O) in.readobject();
    in.close();
    fis.close();
    return r;
}

项目：tda    文件：TDA.java   

private void addDumpStream(InputStream inputStream,String file,boolean withLogfile) {
    final InputStream parseFileStream = new ProgressMonitorInputStream(this,"Parsing " + file,inputStream);

    //Create the nodes.
    if(!runningAsJConsolePlugin || topNodes.size() == 0) {
        topNodes.add(new DefaultMutableTreeNode(new Logfile(file)));
    }
    final DefaultMutableTreeNode top = (DefaultMutableTreeNode) topNodes.get(topNodes.size()-1);

    if ((!withLogfile && logFile == null) || isLogfileSizeOk(file)) {
        logFile = new DefaultMutableTreeNode(new LogFileContent(file));
        if(!runningAsVisualVMPlugin) {
            top.add(logFile);
        }
    }
    setFileOpen(true);

    final SwingWorker worker = new SwingWorker() {

                public Object construct() {
                    synchronized (syncObject) {
                        int divider = topSplitPane.getDividerLocation();
                        addThreadDumps(top,parseFileStream);
                        createTree();
                        tree.expandRow(1);

                        topSplitPane.setDividerLocation(divider);
                    }

                    return null;
                }
            };
    worker.start();
}

项目：thread-dump-analysis    文件：TDA.java   

private void addDumpStream(InputStream inputStream,parseFileStream);
                        createTree();
                        tree.expandRow(1);

                        topSplitPane.setDividerLocation(divider);
                    }

                    return null;
                }
            };
    worker.start();
}

项目：synergynet3.1    文件：RGBReader.java   

/** Creates a new instance of LRGBReader */
public RGBReader(InputStream in)
{
    __in = new ProgressMonitorInputStream(null,"Reading...",in);
    __in.getProgressMonitor().setMillisToDecidetoPopup(0);
    __in.getProgressMonitor().setMillisToPopup(0);
}

项目：otroslogviewer    文件：XMLDecoder.java   

/**
 * Decodes a File into a Vector of LoggingEvents.
 *
 * @param url the url of a file containing events to decode
 * @return Vector of LoggingEvents
 * @throws IOException if IO error during processing.
 */
public Vector decode(final URL url) throws IOException {
  LineNumberReader reader;
  if (owner != null) {
    reader = new LineNumberReader(new InputStreamReader(new ProgressMonitorInputStream(owner,"Loading " + url,url.openStream())));
  } else {
    reader = new LineNumberReader(new InputStreamReader(url.openStream()));
  }

  Vector v = new Vector();

  String line;
  Vector events;
  try {
    while ((line = reader.readLine()) != null) {
      StringBuilder buffer = new StringBuilder(line);
      for (int i = 0; i < 1000; i++) {
        buffer.append(reader.readLine()).append("\n");
      }
      events = decodeEvents(buffer.toString());
      if (events != null) {
        v.addAll(events);
      }
    }
  } finally {
    partialEvent = null;
    try {
      if (reader != null) {
        reader.close();
      }
    } catch (Exception e) {
      e.printstacktrace();
    }
  }
  return v;
}

项目：swift-explorer    文件：FileUtils.java   

public static InputStream getInputStreamWithProgressMonitor(InputStream input,String message)
{
    if (input == null)
        return null ;
    Frame owner = null;
    if (parentComponent == null) 
        owner = SwingUtils.tryFindSuitableFrameOwner () ;
    InputStream in = new BufferedInputStream(
            new ProgressMonitorInputStream(
                    (parentComponent == null) ? (owner) : (parentComponent),input));
    return in;
}

项目：xmpptrace    文件：Database.java   

/**
 * Reads xmppdump formatted data from the given file,and loads it into the
 * embedded database.  Does not clear any pre-existing contents.
 * @param f File to be loaded.
 */
public void loadFromFile(final File f)
{
    try
    {
        // funnel file reads through a progress monitor
        final ProgressMonitorInputStream pmis = new ProgressMonitorInputStream(
                xmpptrace.view.XmppTraceFrame.getInstance(),"Reading " + f.getName() + "...",new FileInputStream(f));     
        pmis.getProgressMonitor().setMillisToPopup(0);

        // do the file loading on background thread so progmon will show
        new Thread() 
        {
            public void run()
            {
                // create a parser on an input stream from the file
                if (f.getName().endsWith(".pcap"))
                {
                    Database.this.readPacketsFromStream(
                            new TcpDumpStreamParser(pmis));
                }
                else
                {
                    Database.this.readPacketsFromStream(
                            new XmppDumpStreamParser(pmis));
                }
            }
        }.start();
    }
    catch (IOException e)
    {
        e.printstacktrace();
    }
}

项目：findbugs-all-the-bugs    文件：AbstractSwingGuiCallback.java   

public InputStream getProgressMonitorInputStream(InputStream in,int length,String msg) {
    ProgressMonitorInputStream pmin = new ProgressMonitorInputStream(parent,msg,in);
    ProgressMonitor pm = pmin.getProgressMonitor();

    if (length > 0)
        pm.setMaximum(length);
    return pmin;
}

项目：geomapapp    文件：OtherDBInputDialog.java   

public void loadExcelFile(File f){
    try {
        int length = (int)f.length();
        jdialog d = new jdialog((Frame)null,"Loading File");
        JPanel p = new JPanel(new BorderLayout());
        p.setBorder(BorderFactory.createEmptyBorder(1,1,1));
        d.setLocationRelativeto(null);
        JProgressBar pb = new JProgressBar(0,length);
        p.add(new JLabel("Loading " + (length / 1000) + " kb file"),BorderLayout.norTH);
        p.add(pb);
        d.getContentPane().add(p);
        d.pack();
        d.setDefaultCloSEOperation(jdialog.disPOSE_ON_CLOSE);
        d.setVisible(true); 
        d.setAlwaysOnTop(true);

        Workbook wb = Workbook.getWorkbook(new ProgressMonitorInputStream(this,"Loading",new FileInputStream(f)));
        if (wb.getNumberOfSheets()==0)return;
        Sheet s = wb.getSheet(0);
        StringBuffer sb = new StringBuffer();
        for (int i = 0; i < s.getRows(); i++) {
            for (int j = 0; j < s.getColumns(); j++)
            {
                    if (s.getCell(j,i).getType() == CellType.NUMBER && !s.getCell(j,i).getContents().matches("\\d*"))
                    {
                        pb.setValue(pb.getValue()+ 16);
                        pb.repaint();
                        sb.append(((NumberCell)s.getCell(j,i)).getValue()+"\t");
                    }
                    else
                    {
                        pb.setValue(pb.getValue() + 2*s.getCell(j,i).getContents().length() + 36);
                        pb.repaint();
                        sb.append(s.getCell(j,i).getContents()+"\t");
                    }
            }
            sb.append("\n");
        }
        name.setText(f.getName().substring(0,f.getName().lastIndexOf('.')));
        input.setText(sb.toString());
        wb.close();
        d.dispose();

    } catch (Exception e) {
        JOptionPane.showMessageDialog(null,"Error loading file:\n"+e.getMessage(),JOptionPane.ERROR_MESSAGE);
        return;
    }
}

项目：pentedb    文件：PlunkHttpLoader.java   

public Vector loadVenueData(Component parent) throws Exception {

        headers = null;
        Socket s = null;
        ProgressMonitor progress = null;
        Vector venues = null;

        try
        {
            StallInputStream stallInput = new StallInputStream();

            ProgressMonitorInputStream pmis = new ProgressMonitorInputStream(
                    parent,"Loading filter data from pente.org",stallInput);
            progress = pmis.getProgressMonitor();
            progress.setNote("Connecting to pente.org...");
            progress.setMillisToDecidetoPopup(1);
            progress.setMillisToPopup(1);
            progress.setMaximum(15000);

            StringBuffer paramsBuffer = new StringBuffer();
            StringBuffer requestBuffer = createHttpRequest(paramsBuffer,"/venues");

            int len = 0;

            s = getHttpResponseSocket(requestBuffer);
            progress.setProgress(2000);
            progress.setNote("Downloading from pente.org...");

            // read past the http headers to the data
            InputStream in = s.getInputStream();
            String contentLength = getHeader("content-length:",in);
            if (contentLength != null) {
                len = Integer.parseInt(contentLength);
            }
//            for (int i = 0; i < len; i++) {
//              int b = in.read();
//              if (b == -1) {
//                  System.out.println("error");
//              }
//            }

            progress.setMaximum(len);
            stallInput.setInputStream(in);

            ObjectInputStream objectIn = new ObjectInputStream(pmis);
            venues = (Vector) objectIn.readobject();

        } catch (Exception e) {
            if (s != null) {
                s.close();
                s = null;
            }
            if (!(e instanceof InterruptedException) && !(progress == null || !progress.isCanceled())) {
                throw e;
            }
        }

        return venues;
    }