pika_heartbeat_thread.h

// Copyright (c) 2015-present, Qihoo, Inc.  All rights reserved.
// This source code is licensed under the BSD-style license found in the
// LICENSE file in the root directory of this source tree. An additional grant
// of patent rights can be found in the PATENTS file in the same directory.

#ifndef PIKA_HEARTBEAT_THREAD_H_
#define PIKA_HEARTBEAT_THREAD_H_

#include "pika_heartbeat_conn.h"
#include "../third/pink/include/holy_thread.h"

// TODO: 17/3/4 by zmyer
class PikaHeartbeatThread : public pink::HolyThread<PikaHeartbeatConn> {
public:
    PikaHeartbeatThread(std::string &ip, int port, int cron_interval = 0);

    PikaHeartbeatThread(std::set<std::string> &ip, int port, int cron_interval = 0);

    virtual ~PikaHeartbeatThread();

    virtual void CronHandle();

    virtual bool AccessHandle(std::string &ip_port);

    bool FindSlave(int fd); //hb_fd
};

#endif