Examples of waitForCompletion()

Examples of com.sun.enterprise.deployment.backend.ClientJarMakerRegistry.waitForCompletion()

162
163
164
165
166
167
168
169
170
171
172
        ClientJarMakerRegistry registry = ClientJarMakerRegistry.getInstance();
       
        if (registry.isRegistered(moduleID)) {
           
            // let's wait until it is finished.
            registry.waitForCompletion(moduleID);
        }
       
        return moduleID + DeploymentImplConstants.ClientJarSuffix;
       
    }
View Full Code Here

Examples of com.sun.management.snmp.manager.SnmpRequest.waitForCompletion()

346
347
348
349
350
351
352
353
354
355
356
      //
      SnmpRequest request = session.snmpSetRequest(null, list);

      // Check for a timeout of the request
      //
      boolean completed = request.waitForCompletion((maxRetries + 1) * timeOut);
      if (completed == false) {
        System.out.println(
                "setRequest() of SNMPSet: Request timed out, " +
                "check reachability of agent.");

View Full Code Here

Examples of com.vmware.aurora.vc.VcTask.waitForCompletion()

88
89
90
91
92
93
94
95
96
97
98
               VcTask task = VcContext.getTaskMgr().execute(new IVcTaskBody() {
                  public VcTask body() throws Exception {
                     return new VcTask(TaskType.DeleteFolder, folder.destroy(), null);
                  }
               });
               task.waitForCompletion();
               return null;
            }
         });
      }
      return null;
View Full Code Here

Examples of freenet.client.FetchWaiter.waitForCompletion()

78
79
80
81
82
83
84
85
86
87
88
        try {
          node.clientCore.clientContext.start(get);
        } catch (PersistenceDisabledException e) {
          // Impossible
        }
        FetchResult res = fw.waitForCompletion();
        return res.asBucket().getInputStream();
      } catch (FetchException e) {
        if ((e.getMode() == FetchExceptionMode.PERMANENT_REDIRECT) || (e.getMode() == FetchExceptionMode.TOO_MANY_PATH_COMPONENTS)) {
          uri = e.newURI;
          continue;
View Full Code Here

Examples of freenet.client.FetchWaiter.waitForCompletion()

360
361
362
363
364
365
366
367
368
369
370
              inserted++;
              try {
                t1 = System.currentTimeMillis();
                FetchWaiter fw = new FetchWaiter(requestContext);
                client.fetch(insertedURIs[j], 32768, fw, fctx);
                fw.waitForCompletion();
                t2 = System.currentTimeMillis();
               
                System.out.println("PULL-TIME FOR BLOCK "+j+": " + (t2 - t1));
                csvLine.add(String.valueOf(t2 - t1));
                pulled++;
View Full Code Here

Examples of freenet.client.FetchWaiter.waitForCompletion()

139
140
141
142
143
144
145
146
147
148
149
  FetchResult fetch(FreenetURI uri, long maxSize, RequestClient clientContext, FetchContext fctx) throws FetchException {
    // For now, just run it blocking.
    FetchWaiter fw = new FetchWaiter(clientContext);
    @SuppressWarnings("unused")
    ClientGetter getter = client.fetch(uri, 1, fw, fctx);
    return fw.waitForCompletion();

  }
  /**
   * Returns a default FetchContext
   * @param maxSize The maximum allowable size of the fetch's result
View Full Code Here

Examples of freenet.client.FetchWaiter.waitForCompletion()

319
320
321
322
323
324
325
326
327
328
329
                FetchContext context = client.getFetchContext();
              FetchWaiter fw = new FetchWaiter((RequestClient)client);
              ClientGetter get = new ClientGetter(fw, uri, context, RequestStarter.INTERACTIVE_PRIORITY_CLASS, null, null, null);
              get.setMetaSnoop(new DumperSnoopMetadata());
                get.start(n.clientCore.clientContext);
          FetchResult result = fw.waitForCompletion();
          ClientMetadata cm = result.getMetadata();
                  outsb.append("Content MIME type: ").append(cm.getMIMEType());
          Bucket data = result.asBucket();
          // FIXME limit it above
          if(data.size() > 32*1024) {
View Full Code Here

Examples of hipi.imagebundle.mapreduce.HipiJob.waitForCompletion()

168
169
170
171
172
173
174
175
176
177
178
    FileInputFormat.setInputPaths(job, new Path(args[0]));
    mkdir(args[1], job.getConfiguration());
    rmdir(args[1] + "/mean-output/", job.getConfiguration());
    FileOutputFormat.setOutputPath(job, new Path(args[1] + "/mean-output/"));

    boolean success = job.waitForCompletion(true);
    return success ? 0 : 1;
  }
 
  public int runCovariance(String[] args) throws Exception {
    HipiJob job = new HipiJob(getConf(), "Covariance");
View Full Code Here

Examples of org.apache.airavata.ws.monitor.Monitor.waitForCompletion()

512
513
514
515
516
517
518
519
520
                        }
                        log.info("No of events: " + eventDataRepo.getEvents().size());
                    }
                });
        experimentMonitor.startMonitoring();
        experimentMonitor.waitForCompletion();
    }

}
View Full Code Here

Examples of org.apache.hadoop.mapred.RunningJob.waitForCompletion()

61
62
63
64
65
66
67
68
69
70
71
        FileInputFormat.setInputPaths(conf, new Path(input));
        FileOutputFormat.setOutputPath(conf, new Path(output));

        RunningJob job = JobClient.runJob(conf);
        while (!job.isComplete()) {
            job.waitForCompletion();
        }
    }

    public static class Step32_CooccurrenceColumnWrapperMapper extends MapReduceBase implements Mapper<LongWritable, Text, Text, IntWritable> {
        private final static Text k = new Text();
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.