Function CalHash

phxqueue/consumer/hblock.cpp:307–319

}

static size_t CalHash(const vector<comm::proto::AddrScale> &addr_scales) {
    size_t h = crc32(0, Z_NULL, 0);
    for (auto &&addr_scale : addr_scales) {
        int port = addr_scale.addr().port();
        int paxos_port = addr_scale.addr().paxos_port();
        int scale = addr_scale.scale();
        h = crc32(h, (const unsigned char *)addr_scale.addr().ip().c_str(), addr_scale.addr().ip().length());
        h = crc32(h, (const unsigned char *)&port, sizeof(int));
        h = crc32(h, (const unsigned char *)&paxos_port, sizeof(int));
        h = crc32(h, (const unsigned char *)&scale, sizeof(int));
    }
    return h;
}

comm::RetCode HeartBeatLock::GetAddrScale(SubID2AddrScales &sub_id2addr_scales) {
    QLVerb("start");