Examples of wasSuspected()

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

440
441
442
443
444
445
446
447
448
449
450
      }
      List<Object> retval = new ArrayList<Object>(rsps.size());
      for (Address dest : dests)
      {
         Rsp rsp = rsps.get(dest);
         if (rsp == null || (rsp.wasSuspected() && !rsp.wasReceived()))
         {
            // The corresponding member has left
            retval.add(new MemberHasLeftException("No response for the member " + dest
               + ", this member has probably left the cluster."));
         }
View Full Code Here

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

440
441
442
443
444
445
446
447
448
449
450
      }
      List<Object> retval = new ArrayList<Object>(rsps.size());
      for (Address dest : dests)
      {
         Rsp rsp = rsps.get(dest);
         if (rsp == null || (rsp.wasSuspected() && !rsp.wasReceived()))
         {
            // The corresponding member has left
            retval.add(new MemberHasLeftException("No response for the member " + dest
               + ", this member has probably left the cluster."));
         }
View Full Code Here

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

448
449
450
451
452
453
454
455
456
457
458
      }
      List<Object> retval = new ArrayList<Object>(rsps.size());
      for (Address dest : dests)
      {
         Rsp rsp = rsps.get(dest);
         if (rsp == null || (rsp.wasSuspected() && !rsp.wasReceived()))
         {
            // The corresponding member has left
            retval.add(new MemberHasLeftException("No response for the member " + dest
               + ", this member has probably left the cluster."));
         }
View Full Code Here

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

122
123
124
125
126
127
128
129
130
131
132
        rsps=disp2.callRemoteMethods(null, "getCurrentTime", null, (Class[])null, GroupRequest.GET_ALL, 10000);
        System.out.println(">> rsps:\n" + rsps);
        assertEquals(2, rsps.size());
        for(Map.Entry<Address, Rsp> entry: rsps.entrySet()) {
            Rsp rsp=entry.getValue();
            assertFalse(rsp.wasSuspected());
            assertTrue(rsp.wasReceived());
        }

        c1.setReceiver(null);
        c2.setReceiver(null);
View Full Code Here

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

597
598
599
600
601
602
603
604
605
606
607
        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()

122
123
124
125
126
127
128
129
130
131
132
        rl.addRsp(new IpAddress(6666), new Integer(322649));
        assertEquals(6, rl.size());
        Rsp rsp=(Rsp)rl.get(new IpAddress(6666));
        assertNotNull(rsp);
        assertTrue(rsp.wasReceived());
        assertFalse(rsp.wasSuspected());
        assertEquals(new Integer(322649), rsp.getValue());
    }

    public void testAddRsp2() {
        rl.addRsp(a1, new Integer(322649));
View Full Code Here

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

132
133
134
135
136
137
138
139
140
141
142
        rl.addRsp(a1, new Integer(322649));
        assertEquals(5, rl.size());
        Rsp rsp=(Rsp)rl.get(a1);
        assertNotNull(rsp);
        assertTrue(rsp.wasReceived());
        assertFalse(rsp.wasSuspected());
        assertEquals(new Integer(322649), rsp.getValue());
    }

    public void testNumSuspectedMembers() {
        assertEquals(2, rl.numSuspectedMembers());
View Full Code Here

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

238
239
240
241
242
243
244
245
246
247
248
        // all responses
        System.out.println("responses:\n" + rsps);
        for(Map.Entry<Address,Rsp> entry: rsps.entrySet()) {
            Rsp rsp=entry.getValue();
            assertTrue("response from " + entry.getKey() + " was not received", rsp.wasReceived());
            assertFalse(rsp.wasSuspected());
        }
    }


    /**
 
View Full Code Here

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

105
106
107
108
109
110
111
112
113
114
115
        assertEquals(2, rsps.size());
        for(Iterator it=rsps.values().iterator(); it.hasNext();) {
            Rsp rsp=(Rsp)it.next();
            assertNull(rsp.getValue());
            assertTrue(rsp.wasReceived());
            assertFalse(rsp.wasSuspected());
        }

        rsps=disp.callRemoteMethods(null, "methodB", null, (Class[])null, GroupRequest.GET_ALL, 0);
        assertEquals(2, rsps.size());
        for(Iterator it=rsps.values().iterator(); it.hasNext();) {
View Full Code Here

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

115
116
117
118
119
120
121
122
123
124
125
        for(Iterator it=rsps.values().iterator(); it.hasNext();) {
            Rsp rsp=(Rsp)it.next();
            assertNotNull(rsp.getValue());
            assertEquals(Boolean.TRUE, rsp.getValue());
            assertTrue(rsp.wasReceived());
            assertFalse(rsp.wasSuspected());
        }


        rsps=disp.callRemoteMethods(null, "methodC", null, (Class[])null, GroupRequest.GET_ALL, 0);
        assertEquals(2, rsps.size());
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.