Examples of AgentProcessMap

Examples of com.netflix.priam.agent.process.AgentProcessMap

32
33
34
35
36
37
38
39
40
41
42
        MockStorage storage = new MockStorage();
        storage.setValue(configuration, ProcessTask.ROW_KEY, "localhost", commandTab.toString());

        MockNodeStatus nodeStatus = new MockNodeStatus();
        AgentProcessManager processManager = new AgentProcessManager(new AgentProcessMap(AgentProcessMap.buildDefaultMap()), configuration, nodeStatus);
        ProcessTask processTask = new ProcessTask(configuration, processManager, storage);
        processTask.execute();

        Assert.assertTrue(nodeStatus.getFlushLatch().await(5, TimeUnit.SECONDS));
View Full Code Here

Examples of com.netflix.priam.agent.process.AgentProcessMap

62
63
64
65
66
67
68
69
70
71
72
    @Test
    public void testIncorrectArguments() throws Exception
    {
        MockAgentConfiguration configuration = new MockAgentConfiguration("localhost");
        MockNodeStatus nodeStatus = new MockNodeStatus();
        AgentProcessManager processManager = new AgentProcessManager(new AgentProcessMap(AgentProcessMap.buildDefaultMap()), configuration, nodeStatus);
        try
        {
            processManager.startProcess("remove-node", "x", new String[0]);
            Assert.fail();
        }
View Full Code Here

Examples of com.netflix.priam.agent.process.AgentProcessMap

87
88
89
90
91
92
93
94
95
96
97
        nodeStatus.setInfo(testInfo);

        MockStorage storage = new MockStorage();

        MockAgentConfiguration configuration = new MockAgentConfiguration("localhost");
        AgentProcessManager processManager = new AgentProcessManager(new AgentProcessMap(AgentProcessMap.buildDefaultMap()), configuration, nodeStatus);
        try
        {
            AgentTask agentTask = new AgentTask(configuration, processManager, nodeStatus, storage);
            agentTask.execute();
View Full Code Here

Examples of com.netflix.priam.agent.process.AgentProcessMap

125
126
127
128
129
130
131
132
133
134
135
        MockStorage storage = new MockStorage();
        storage.setValue(configuration, ProcessTask.ROW_KEY, "localhost", commandTab.toString());

        MockNodeStatus nodeStatus = new MockNodeStatus();
        AgentProcessManager processManager = new AgentProcessManager(new AgentProcessMap(AgentProcessMap.buildDefaultMap()), configuration, nodeStatus);
        ProcessTask processTask = new ProcessTask(configuration, processManager, storage);
        processTask.execute();
        Assert.assertTrue(processManager.closeAndWaitForCompletion(5, TimeUnit.SECONDS));

        Assert.assertEquals(nodeStatus.getOperations().size(), 1);
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.