source: ThirdParty/JobMarket/src/JobMarket/Operations/Servers/CheckAliveWorkerOperation.hpp

/*
 * CheckAliveWorkerOperation.hpp
 *
 *  Created on: Sep 05, 2012
 *      Author: heber
 */

#ifndef FRAGMENTCONTROLLER_CHECKALIVEWORKEROPERATION_HPP_
#define FRAGMENTCONTROLLER_CHECKALIVEWORKEROPERATION_HPP_

// include config.h
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

#include <boost/asio.hpp>
#include <string>
#include <vector>

#include "JobMarket/Connection.hpp"

#include "JobMarket/Jobs/FragmentJob.hpp"
#include "JobMarket/Jobs/SystemCommandJob.hpp"
#include "JobMarket/Operations/AsyncOperation.hpp"
#include "JobMarket/WorkerAddress.hpp"

class CheckAliveWorkerOperation : public AsyncOperation  {
public:
  /** Constructor for class CheckAliveWorkerOperation.
   *
   * @param _connection connection for operation
   */
  CheckAliveWorkerOperation(Connection &_connection,
      const boost::function<void (const WorkerAddress )> _checkAddress,
      const boost::function<void ()> _callback_on_success = NoOpCallback,
      const boost::function<void ()> _callback_on_failure = NoOpCallback) :
    AsyncOperation(std::string("checkaliveworker"),_connection, _callback_on_success, _callback_on_failure),
    address("127.0.0.1", "0"),
    checkAddress(_checkAddress)
  {}
//  /** Constructor for class CheckAliveWorkerOperation.
//   *
//   * @param _connection connection for operation
//   * @param _job job to send to worker
//   */
//  CheckAliveWorkerOperation(Connection &_connection) :
//    AsyncOperation(std::string("checkaliveworker"),_connection),
//    address("127.0.0.1", "0")
//  {}
  /// Destructor for class CheckAliveWorkerOperation
  ~CheckAliveWorkerOperation() {}

public:
  // virtual function pointer to the connection handler
  virtual void handle_connect(const boost::system::error_code& e,
      boost::asio::ip::tcp::resolver::iterator endpoint_iterator);

  // handler function when after sending choice to receive alive signal
  void handle_ReceiveAddress(const boost::system::error_code& e);

  // handler function when after having received worker's address
  void handle_CheckAddress(const boost::system::error_code& e);

private:
  //!> address of worker as its alive signal
  WorkerAddress address;

  //!> callback function to check address
  boost::function<void (const WorkerAddress )> checkAddress;
};

#endif /* FRAGMENTCONTROLLER_CHECKALIVEWORKEROPERATION_HPP_ */