List of updateProcessTree() Examples

Examples of updateProcessTree()

org.apache.hadoop.yarn.util.ProcfsBasedProcessTree.updateProcessTree()
Update process-tree with latest state. If the root-process is not alive, tree will be empty.
org.apache.hadoop.yarn.util.ResourceCalculatorProcessTree.updateProcessTree()
Update the process-tree with latest state. Each call to this function should increment the age of the running processes that already exist in the process tree. Age is used other API's of the interface.

Examples of org.apache.hadoop.yarn.util.ProcfsBasedProcessTree.updateProcessTree()

                  test.isProcessTreeOverLimit(pTree, "dummyId", limit));


      // the tree rooted at 200 is initially below limit.
      pTree = new ProcfsBasedProcessTree("200",
                                          procfsRootDir.getAbsolutePath());
      pTree.updateProcessTree();
      assertFalse("tree rooted at 200 shouldn't be over limit " +
                    "after one iteration.",
                  test.isProcessTreeOverLimit(pTree, "dummyId", limit));
      // second iteration - now the tree has been over limit twice,
      // hence it should be declared over limit.

View Full Code Here

Examples of org.apache.hadoop.yarn.util.ProcfsBasedProcessTree.updateProcessTree()

      assertFalse("tree rooted at 200 shouldn't be over limit " +
                    "after one iteration.",
                  test.isProcessTreeOverLimit(pTree, "dummyId", limit));
      // second iteration - now the tree has been over limit twice,
      // hence it should be declared over limit.
      pTree.updateProcessTree();
      assertTrue(
          "tree rooted at 200 should be over limit after 2 iterations",
                  test.isProcessTreeOverLimit(pTree, "dummyId", limit));


      // the tree rooted at 600 is never over limit.

View Full Code Here

Examples of org.apache.hadoop.yarn.util.ProcfsBasedProcessTree.updateProcessTree()

                  test.isProcessTreeOverLimit(pTree, "dummyId", limit));


      // the tree rooted at 600 is never over limit.
      pTree = new ProcfsBasedProcessTree("600",
                                            procfsRootDir.getAbsolutePath());
      pTree.updateProcessTree();
      assertFalse("tree rooted at 600 should never be over limit.",
                    test.isProcessTreeOverLimit(pTree, "dummyId", limit));


      // another iteration does not make any difference.
      pTree.updateProcessTree();

View Full Code Here

Examples of org.apache.hadoop.yarn.util.ProcfsBasedProcessTree.updateProcessTree()

      pTree.updateProcessTree();
      assertFalse("tree rooted at 600 should never be over limit.",
                    test.isProcessTreeOverLimit(pTree, "dummyId", limit));


      // another iteration does not make any difference.
      pTree.updateProcessTree();
      assertFalse("tree rooted at 600 should never be over limit.",
                    test.isProcessTreeOverLimit(pTree, "dummyId", limit));
    } finally {
      FileUtil.fullyDelete(procfsRootDir);
    }

View Full Code Here

Examples of org.apache.hadoop.yarn.util.ProcfsBasedProcessTree.updateProcessTree()

    Thread t = new RogueTaskThread();
    t.start();
    String pid = getRogueTaskPID();
    LOG.info("Root process pid: " + pid);
    ProcfsBasedProcessTree p = createProcessTree(pid);
    p.updateProcessTree(); // initialize
    LOG.info("ProcessTree: " + p.toString());


    File leaf = new File(lowestDescendant);
    //wait till lowest descendant process of Rougue Task starts execution
    while (!leaf.exists()) {

View Full Code Here

Examples of org.apache.hadoop.yarn.util.ProcfsBasedProcessTree.updateProcessTree()

      } catch (InterruptedException ie) {
        break;
      }
    }


    p.updateProcessTree(); // reconstruct
    LOG.info("ProcessTree: " + p.toString());


    // Get the process-tree dump
    String processTreeDump = p.getProcessTreeDump();

View Full Code Here

Examples of org.apache.hadoop.yarn.util.ProcfsBasedProcessTree.updateProcessTree()

    } catch (InterruptedException ie) {
      LOG.info("Interrupted while joining RogueTaskThread.");
    }


    // ProcessTree is gone now. Any further calls should be sane.
    p.updateProcessTree();
    Assert.assertFalse("ProcessTree must have been gone", isAlive(pid));
    Assert.assertTrue("Cumulative vmem for the gone-process is "
        + p.getCumulativeVmem() + " . It should be zero.", p
        .getCumulativeVmem() == 0);
    Assert.assertTrue(p.toString().equals("[ ]"));

View Full Code Here

Examples of org.apache.hadoop.yarn.util.ProcfsBasedProcessTree.updateProcessTree()


      // crank up the process tree class.
      ProcfsBasedProcessTree processTree =
          createProcessTree("100", procfsRootDir.getAbsolutePath());
      // build the process tree.
      processTree.updateProcessTree();


      // verify cumulative memory
      Assert.assertEquals("Cumulative virtual memory does not match", 600000L,
                   processTree.getCumulativeVmem());

View Full Code Here

Examples of org.apache.hadoop.yarn.util.ProcfsBasedProcessTree.updateProcessTree()

      procInfos[1] = new ProcessStatInfo(new String[]
          {"200", "proc2", "100", "100", "100", "200000", "200", "3000", "500"});
      writeStatFiles(procfsRootDir, pids, procInfos);


      // build the process tree.
      processTree.updateProcessTree();


      // verify cumulative cpu time again
      cumuCpuTime = ProcfsBasedProcessTree.JIFFY_LENGTH_IN_MILLIS > 0 ?
             9400L * ProcfsBasedProcessTree.JIFFY_LENGTH_IN_MILLIS : 0L;
      Assert.assertEquals("Cumulative cpu time does not match",

View Full Code Here

Examples of org.apache.hadoop.yarn.util.ProcfsBasedProcessTree.updateProcessTree()


      // crank up the process tree class.
      ProcfsBasedProcessTree processTree =
          createProcessTree("100", procfsRootDir.getAbsolutePath());
      // build the process tree.
      processTree.updateProcessTree();


      // verify cumulative memory
      Assert.assertEquals("Cumulative memory does not match",
                   700000L, processTree.getCumulativeVmem());

View Full Code Here

0 1 2 3 4

TOP

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.