Package org.eclipse.core.runtime

Examples of org.eclipse.core.runtime.IProgressMonitor


   * Test for {@link Utils#getNonNullMonitor(IProgressMonitor)}.
   */
  public void test_getNonNullMonitor() throws Exception {
    // not "null" as argument
    {
      IProgressMonitor monitor = EasyMock.createStrictMock(IProgressMonitor.class);
      assertSame(monitor, Utils.getNonNullMonitor(monitor));
    }
    // "null" as argument
    {
      IProgressMonitor monitor = Utils.getNonNullMonitor(null);
      assertNotNull(monitor);
    }
  }
View Full Code Here


    }

    // Create save block.
    IRunnableWithProgress progressOp = new IRunnableWithProgress() {
      public void run(IProgressMonitor monitor) {
        IProgressMonitor monitorWrap = new EventLoopProgressMonitor(monitor);
        saveable.doSave(monitorWrap);
      }
    };

    // Do the save.
View Full Code Here

    }
   
    // Create save block.
    IRunnableWithProgress progressOp = new IRunnableWithProgress() {
      public void run(IProgressMonitor monitor) {
        IProgressMonitor monitorWrap = new EventLoopProgressMonitor(monitor);
        monitorWrap.beginTask(WorkbenchMessages.Save, dirtyModels.size());
        for (Iterator i = dirtyModels.iterator(); i.hasNext();) {
          Saveable model = (Saveable) i.next();
          // handle case where this model got saved as a result of saving another
          if (!model.isDirty()) {
            monitor.worked(1);
            continue;
          }
          doSaveModel(model, new SubProgressMonitor(monitorWrap, 1),
              window, confirm);
          if (monitor.isCanceled()) {
            break;
          }
        }
        monitorWrap.done();
      }
    };

    // Do the save.
    return runProgressMonitorOperation(WorkbenchMessages.Save, progressOp, window);
View Full Code Here

    }

    // Create save block.
    IRunnableWithProgress progressOp = new IRunnableWithProgress() {
      public void run(IProgressMonitor monitor) {
        IProgressMonitor monitorWrap = new EventLoopProgressMonitor(monitor);
        saveable.doSave(monitorWrap);
      }
    };

    // Do the save.
View Full Code Here

        this.projects = projects;
    }

    @Override
    protected IStatus run(IProgressMonitor monitor) {
        IProgressMonitor mon = monitor;
        if (mon == null) {
            mon = new NullProgressMonitor();
        }

        try {
            Collection<Project> projects = Activator.getWorkspace().getAllProjects();

            mon.beginTask(Messages.workspaceReleaseJob, projects.size() * 2);

            List<Project> orderedProjects = getBuildOrder(mon, Activator.getWorkspace());
            if (mon.isCanceled()) {
                return Status.CANCEL_STATUS;
            }

            final List<ProjectDiff> projectDiffs = new ArrayList<ProjectDiff>();
            mon.setTaskName(Messages.processingProjects);
            for (Project project : orderedProjects) {
                IProject eProject = ReleaseUtils.getProject(project);
                if (!isIncluded(eProject)) {
                    mon.worked(1);
                    continue;
                }
                if ("".equals(project.getProperty(Constants.RELEASEREPO, null))) {
                    mon.worked(1);
                    continue;
                }
                if (eProject == null || !eProject.isOpen() || !eProject.isAccessible()) {
                    mon.worked(1);
                    continue;
                }
                List<Builder> builders = project.getBuilder(null).getSubBuilders();
                List<Baseline> jarDiffs = null;
                for (Builder b : builders) {
                    mon.subTask(String.format(Messages.processingProject, b.getBsn()));

                    Baseline jarDiff = DiffHelper.createBaseline(project, b.getBsn());
                    if (jarDiff != null) {
                        if (jarDiffs == null) {
                            jarDiffs = new ArrayList<Baseline>();
                        }
                        jarDiffs.add(jarDiff);
                    }
                }
                if (jarDiffs != null && jarDiffs.size() > 0) {
                    projectDiffs.add(new ProjectDiff(project, jarDiffs));
                }
                if (mon.isCanceled()) {
                    return Status.CANCEL_STATUS;
                }
                mon.worked(1);
            }

            if (projectDiffs.size() == 0) {
                Runnable runnable = new Runnable() {
                    @Override
View Full Code Here

        this.projects = projects;
    }

  @Override
  protected IStatus run(IProgressMonitor monitor) {
    IProgressMonitor mon = monitor;
    if (mon == null) {
      mon = new NullProgressMonitor();
    }

    try {
      Collection<Project> projects = Activator.getWorkspace()
          .getAllProjects();

      mon.beginTask(Messages.workspaceReleaseJob, projects.size() * 2);

      List<Project> orderedProjects = getBuildOrder(mon,
          Activator.getWorkspace());
      if (mon.isCanceled()) {
        return Status.CANCEL_STATUS;
      }

      final List<ProjectDiff> projectDiffs = new ArrayList<ProjectDiff>();
      mon.setTaskName(Messages.processingProjects);
      for (Project project : orderedProjects) {
        IProject eProject = ReleaseUtils.getProject(project);
                if (!isIncluded(eProject)) {
                    mon.worked(1);
                    continue;
                }
        if (eProject == null || !eProject.isOpen() || !eProject.isAccessible()) {
                  mon.worked(1);
          continue;
        }
        List<Builder> builders = project.getBuilder(null)
            .getSubBuilders();
        List<Baseline> jarDiffs = null;
        for (Builder b : builders) {
          mon.subTask(String.format(Messages.processingProject, b.getBsn()));

          Baseline jarDiff = DiffHelper.createBaseline(project,
              b.getBsn());
          if (jarDiff != null) {
            if (jarDiffs == null) {
              jarDiffs = new ArrayList<Baseline>();
            }
            jarDiffs.add(jarDiff);
          }
        }
        if (jarDiffs != null && jarDiffs.size() > 0) {
          projectDiffs.add(new ProjectDiff(project, jarDiffs));
        }
        if (mon.isCanceled()) {
          return Status.CANCEL_STATUS;
        }
        mon.worked(1);
      }

      if (projectDiffs.size() == 0) {
        Runnable runnable = new Runnable() {
          public void run() {
View Full Code Here

    model = new DiagramModel(project);

    final IDiagram modelRef = model;

    // Creating the model
    IProgressMonitor pm = Job.getJobManager().createProgressGroup();
    pm.beginTask("Compute Model", IProgressMonitor.UNKNOWN);
    final ILock lock = Job.getJobManager().newLock();
    Job createModeJob = new Job("Create Model") {
      /**
       * @see org.eclipse.core.runtime.jobs.Job#run(org.eclipse.core.runtime.IProgressMonitor)
       */
      @Override
      protected IStatus run(IProgressMonitor monitor) {
        try {
          lock.acquire();
          //                return ModelFactory.computeBottomUpDependenciesModel(modelRef, monitor);
          return ModelFactory.computeModel(modelRef, dependenciesProvider, monitor);
        } finally {
          lock.release();
        }
      }
    };
    createModeJob.setUser(true);
    createModeJob.setProgressGroup(pm, IProgressMonitor.UNKNOWN);
    createModeJob.setThread(new Thread());
    createModeJob.schedule();

    // Creates job : Computing model connection's costs
    final IDiagram workingModel = model;
    Job simplifyModelJob = new Job("Simplify Model") {
      /**
       * @see org.eclipse.core.runtime.jobs.Job#run(org.eclipse.core.runtime.IProgressMonitor)
       */
      @Override
      protected IStatus run(IProgressMonitor monitor) {
        try {
          lock.acquire();
          // IStatus computePathCostSatus = Status.OK_STATUS;
          IStatus computePathCostSatus = ModelFactory.computePathCost(workingModel, monitor);
          if (!Status.OK_STATUS.equals(computePathCostSatus)) {
            return computePathCostSatus;
          }

          IStatus editorStatus = null;
          // Open Editor within UI thread.
          if (Display.getCurrent() == null) {
            // Not in UI Thread
            class OpenEditor implements Runnable {
              IStatus status;

              public void run() {
                status = openEditor(workingModel);
              }
            }

            Display display = PlatformUI.getWorkbench().getDisplay();
            OpenEditor openEditor = new OpenEditor();
            display.syncExec(openEditor);
            editorStatus = openEditor.status;
          } else {
            // In UI Thread
            editorStatus = openEditor(workingModel);
          }
          monitor.done();
          return editorStatus;
        } finally {
          lock.release();
        }
      }
    };
    simplifyModelJob.setUser(true);
    simplifyModelJob.setProgressGroup(pm, IProgressMonitor.UNKNOWN);
    simplifyModelJob.setThread(new Thread());
    simplifyModelJob.schedule();

    pm.done();
  }
View Full Code Here

        // TODO: the style objects need access to preference system
        final Layer theLayer = layer;

        ICatalog localCatalog = local;
        ID layerResourceID = layer.getResourceID();
        IProgressMonitor monitor = ProgressManager.instance().get();
        List<IResolve> resolves = localCatalog.find(layerResourceID, monitor);
        if (resolves.isEmpty()) {
            // Identifier lookup is being inconsistent; this often happens when code trips up over
            // converting URLs to and from Files
            throw new IOException("Could not find " + layerResourceID + " in local catalog");
View Full Code Here

                    UndoableMapCommand c=null;
                    try{
                        c=behaviour.getCommand(handler, event, eventType);
                        if( c==null )
                            continue;
                        IProgressMonitor submonitor = new SubProgressMonitor(monitor, 10);
                        c.setMap(getMap());
                        if (c instanceof PostDeterminedEffectCommand) {
                            PostDeterminedEffectCommand command = (PostDeterminedEffectCommand) c;
                            if( command.execute(submonitor) )
                                commandsRan.add(command);
                        }else{
                        c.run(submonitor);
                        commandsRan.add(c);
                        }
                        submonitor.done();
                    }catch(Exception e){
                        behaviour.handleError(handler, e, c);
                    }
                }
            }
        }else{
            monitor.beginTask(getName(), commandsRan.size()*12);
            monitor.worked(2);
            for( UndoableMapCommand command : commandsRan ) {
                command.setMap(getMap());
                IProgressMonitor submonitor = new SubProgressMonitor(monitor, 10);
                if (command instanceof PostDeterminedEffectCommand) {
                    ((PostDeterminedEffectCommand)command).execute(submonitor);
                }else{
                    command.run(submonitor);
                }
                submonitor.done();
            }
        }
        monitor.done();
        return !commandsRan.isEmpty();
    }
View Full Code Here

    public void rollback( IProgressMonitor monitor ) throws Exception {
        monitor.beginTask(getName(), commandsRan.size()*12);
        monitor.worked(2);
        for( UndoableMapCommand command : commandsRan ) {
            command.setMap(getMap());
            IProgressMonitor submonitor = new SubProgressMonitor(monitor, 10);
            command.rollback(submonitor);
            submonitor.done();
        }
    }
View Full Code Here

TOP

Related Classes of org.eclipse.core.runtime.IProgressMonitor

Copyright © 2018 www.massapicom. 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.