Examples of org.voltcore.messaging.SiteFailureForwardMessage

                    e.getValue());
        }
    }


    protected void addForwardCandidate(SiteFailureForwardMessage sffm) {
        SiteFailureForwardMessage prev = m_forwardCandidates.get(sffm.m_reportingHSId);


        if (prev != null && prev.m_survivors.size() < sffm.m_survivors.size()) return;


        m_forwardCandidates.put(sffm.m_reportingHSId, sffm);
    }

                    || m_failedSites.containsAll(sfm.getFailedSites())) continue;


                updateFailedSitesLedger(hsIds, sfm);


                m_seeker.add(sfm);
                addForwardCandidate(new SiteFailureForwardMessage(sfm));


                m_recoveryLog.info("Agreement, Received " + sfm);


            } else if (m.getSubject() == Subject.SITE_FAILURE_FORWARD.getId()) {


                SiteFailureForwardMessage fsfm = (SiteFailureForwardMessage)m;


                addForwardCandidate(fsfm);


                if (   !hsIds.contains(fsfm.m_sourceHSId)
                    || m_seeker.getSurvivors().contains(fsfm.m_reportingHSId)
                    || m_failedSites.contains(fsfm.m_reportingHSId)
                    || m_failedSites.containsAll(fsfm.getFailedSites())) continue;


                m_seeker.add(fsfm);


                m_recoveryLog.info("Agreement, Received forward " + fsfm);

Related Classes of org.voltcore.messaging.SiteFailureForwardMessage

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.