Package org.gridgain.grid.spi.failover.always

Examples of org.gridgain.grid.spi.failover.always.GridAlwaysFailoverSpi.failover()

48
49
50
51
52
53
54
55
56
57
58
        GridNode node = new GridTestNode(UUID.randomUUID());

        nodes.add(node);

        node = spi.failover(new GridFailoverTestContext(new GridTestTaskSession(), new GridTestJobResult(node)), nodes);

        assert node == null;
    }

    /**
 
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
        nodes.add(new GridTestNode(UUID.randomUUID()));
        nodes.add(new GridTestNode(UUID.randomUUID()));

        GridComputeJobResult jobRes = new GridTestJobResult(nodes.get(0));

        GridNode node = spi.failover(new GridFailoverTestContext(new GridTestTaskSession(), jobRes), nodes);

        assert node != null;
        assert node.equals(nodes.get(1));

        checkFailedNodes(jobRes, 1);
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
        nodes.add(new GridTestNode(UUID.randomUUID()));

        GridComputeJobResult jobRes = new GridTestJobResult(nodes.get(0));

        // First attempt.
        GridNode node = spi.failover(new GridFailoverTestContext(new GridTestTaskSession(), jobRes), nodes);

        assert node != null;
        assert node.equals(nodes.get(1));

        checkFailedNodes(jobRes, 1);
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
        assert node.equals(nodes.get(1));

        checkFailedNodes(jobRes, 1);

        // Second attempt (exceeds default max attempts of 1).
        node = spi.failover(new GridFailoverTestContext(new GridTestTaskSession(), jobRes), nodes);

        assert node == null;

        checkFailedNodes(jobRes, 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.