Examples of wasSuspected()

Examples of org.jgroups.util.Rsp.wasSuspected()

586
587
588
589
590
591
592
593
594
595
596
        if(rsp_list.size() > 1) {
            if(log.isWarnEnabled())
                log.warn("response list contains more that 1 response; returning first response !");
        }
        rsp=(Rsp)rsp_list.elementAt(0);
        if(rsp.wasSuspected()) {
            throw new SuspectedException(dest);
        }
        if(!rsp.wasReceived()) {
            throw new TimeoutException("timeout sending message to " + dest);
        }
View Full Code Here

Examples of org.jgroups.util.Rsp.wasSuspected()

568
569
570
571
572
573
574
575
576
577
578
        if(rsp_list.size() > 1) {
            if(log.isWarnEnabled())
                log.warn("response list contains more that 1 response; returning first response !");
        }
        rsp=(Rsp)rsp_list.elementAt(0);
        if(rsp.wasSuspected()) {
            throw new SuspectedException(dest);
        }
        if(!rsp.wasReceived()) {
            throw new TimeoutException();
        }
View Full Code Here

Examples of org.jgroups.util.Rsp.wasSuspected()

137
138
139
140
141
142
143
144
145
146
147
        rl.addRsp(tmp, new Integer(322649));
        Assert.assertEquals(6, rl.size());
        Rsp rsp=rl.get(tmp);
        assert rsp != null;
        assert rsp.wasReceived();
        assert !(rsp.wasSuspected());
        Assert.assertEquals(new Integer(322649), rsp.getValue());
    }


    public void testAddRsp2() {
View Full Code Here

Examples of org.jgroups.util.Rsp.wasSuspected()

148
149
150
151
152
153
154
155
156
157
158
        rl.addRsp(a1, new Integer(322649));
        Assert.assertEquals(5, rl.size());
        Rsp rsp=rl.get(a1);
        assert rsp != null;
        assert rsp.wasReceived();
        assert !(rsp.wasSuspected());
        Assert.assertEquals(new Integer(322649), rsp.getValue());
    }


    public void testNumSuspectedMembers() {
View Full Code Here

Examples of org.jgroups.util.Rsp.wasSuspected()

86
87
88
89
90
91
92
93
94
95
96
        assert rsps.size() == 2;
        for(Iterator<Rsp> it=rsps.values().iterator(); it.hasNext();) {
            Rsp rsp=it.next();
            assert rsp.getValue() == null;
            assertTrue(rsp.wasReceived());
            assertFalse(rsp.wasSuspected());
        }

        rsps=disp.callRemoteMethods(null, "methodB", null, null, new RequestOptions(ResponseMode.GET_ALL, 0));
        assertEquals(2, rsps.size());
        for(Iterator<Rsp> it=rsps.values().iterator(); it.hasNext();) {
View Full Code Here

Examples of org.jgroups.util.Rsp.wasSuspected()

96
97
98
99
100
101
102
103
104
105
106
        for(Iterator<Rsp> it=rsps.values().iterator(); it.hasNext();) {
            Rsp rsp=it.next();
            assertNotNull(rsp.getValue());
            assertEquals(Boolean.TRUE, rsp.getValue());
            assertTrue(rsp.wasReceived());
            assertFalse(rsp.wasSuspected());
        }


        rsps=disp.callRemoteMethods(null, "methodC", null, null, new RequestOptions(ResponseMode.GET_ALL, 0));
        assertEquals(2, rsps.size());
View Full Code Here

Examples of org.jgroups.util.Rsp.wasSuspected()

107
108
109
110
111
112
113
114
115
116
117
        for(Iterator<Rsp> it=rsps.values().iterator(); it.hasNext();) {
            Rsp rsp=it.next();
            assertNull(rsp.getValue());
            assertNotNull(rsp.getException());
            assertTrue(rsp.wasReceived());
            assertFalse(rsp.wasSuspected());
        }

        disp.setRequestMarshaller(null);
        disp.setResponseMarshaller(null);
        disp2.setRequestMarshaller(null);
View Full Code Here

Examples of org.jgroups.util.Rsp.wasSuspected()

497
498
499
500
501
502
503
504
505
506
507
        // all responses
        System.out.println("responses:\n" + rsps);
        for(Map.Entry<Address,Rsp<Object>> entry: rsps.entrySet()) {
            Rsp rsp=entry.getValue();
            Util.assertTrue("response from " + entry.getKey() + " was not received", rsp.wasReceived());
            Util.assertFalse(rsp.wasSuspected());
        }
    }


    /**
 
View Full Code Here

Examples of org.jgroups.util.Rsp.wasSuspected()

656
657
658
659
660
661
662
663
664
665
666
        if(rsp_list.size() > 1) {
            if(log.isWarnEnabled())
                log.warn("response list contains more that 1 response; returning first response !");
        }
        rsp=(Rsp)rsp_list.elementAt(0);
        if(rsp.wasSuspected()) {
            throw new SuspectedException(dest);
        }
        if(!rsp.wasReceived()) {
            throw new TimeoutException("timeout sending message to " + dest);
        }
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.