Package org.jgroups.util

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

518
519
520
521
522
523
524
525
526
527
528
        final int num_total=requests.size();

        Rsp rsp;
        for(Iterator it=requests.values().iterator(); it.hasNext();) {
            rsp=(Rsp)it.next();
            if(rsp.wasReceived()) {
                num_received++;
            }
            else {
                if(rsp.wasSuspected()) {
                    num_suspected++;
View Full Code Here
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
454
455
456
457
458
459
460
461
462
463
464
         {
            // The corresponding member has left
            retval.add(new MemberHasLeftException("No response for the member " + dest
               + ", this member has probably left the cluster."));
         }
         else if (!rsp.wasReceived())
         {
            retval.add(new RPCException("Replication timeout for " + rsp.getSender() + ", rsp=" + rsp));
         }
         else
         {
View Full Code Here
4448
4449
4450
4451
4452
4453
4454
4455
4456
4457
4458
      retval = new ArrayList(rsps.size());
      for (int i = 0; i < rsps.size(); i++)
      {
         rsp = (Rsp) rsps.elementAt(i);
         if (rsp.wasSuspected() || !rsp.wasReceived())
         {
            CacheException ex;
            if (rsp.wasSuspected())
            {
               ex = new SuspectException("Response suspected: " + rsp);
View Full Code Here
297
298
299
300
301
302
303
304
305
306
307
                return;

            Rsp rsp=requests.get(sender);
            if(rsp == null)
                return;
            if(!rsp.wasReceived()) {
                boolean responseReceived =(rsp_filter == null) || rsp_filter.isAcceptable(response_value, sender);
                rsp.setValue(response_value);
                rsp.setReceived(responseReceived);
                if(log.isTraceEnabled())
                    log.trace(new StringBuilder("received response for request ").append(req_id)
View Full Code Here
4420
4421
4422
4423
4424
4425
4426
4427
4428
4429
4430
      retval = new ArrayList(rsps.size());
      for (int i = 0; i < rsps.size(); i++)
      {
         rsp = (Rsp) rsps.elementAt(i);
         if (rsp.wasSuspected() || !rsp.wasReceived())
         {
            CacheException ex;
            if (rsp.wasSuspected())
            {
               ex = new SuspectException("Response suspected: " + rsp);
View Full Code Here
4433
4434
4435
4436
4437
4438
4439
4440
4441
4442
4443
      retval = new ArrayList(rsps.size());
      for (int i = 0; i < rsps.size(); i++)
      {
         rsp = (Rsp) rsps.elementAt(i);
         if (rsp.wasSuspected() || !rsp.wasReceived())
         {
            CacheException ex;
            if (rsp.wasSuspected())
            {
               ex = new SuspectException("Response suspected: " + rsp);
View Full Code Here
589
590
591
592
593
594
595
596
597
598
599
        }
        rsp=(Rsp)rsp_list.elementAt(0);
        if(rsp.wasSuspected()) {
            throw new SuspectedException(dest);
        }
        if(!rsp.wasReceived()) {
            throw new TimeoutException("timeout sending message to " + dest);
        }
        return rsp.getValue();
    }
View Full Code Here
297
298
299
300
301
302
303
304
305
306
307
                return;

            Rsp rsp=requests.get(sender);
            if(rsp == null)
                return;
            if(!rsp.wasReceived()) {
                boolean responseReceived =(rsp_filter == null) || rsp_filter.isAcceptable(response_value, sender);
                rsp.setValue(response_value);
                rsp.setReceived(responseReceived);
                if(log.isTraceEnabled())
                    log.trace(new StringBuilder("received response for request ").append(req_id)
View Full Code Here
179
180
181
182
183
184
185
186
187
188
189
/*     */
/* 253 */         while (iter.hasNext())
/*     */         {
/* 255 */           Rsp rsp = (Rsp)iter.next();
/*     */
/* 257 */           if (!rsp.wasReceived())
/*     */           {
/* 259 */             throw new IllegalStateException(this + " response not received from " + rsp.getSender() + " - there may be others");
/*     */           }
/*     */         }
/*     */       }
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.