source: ThirdParty/JobMarket/src/JobMarket/Operations/Workers/ObtainJobOperation.hpp

/*
 * ObtainJobOperation.hpp
 *
 *  Created on: Feb 26, 2012
 *      Author: heber
 */

#ifndef OBTAINJOBOPERATION_HPP_
#define OBTAINJOBOPERATION_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/Operations/AsyncOperation.hpp"
#include "JobMarket/Results/FragmentResult.hpp"

class ObtainJobOperation : public AsyncOperation  {
public:
  /// Constructor for class ObtainJobOperation.
  ObtainJobOperation(Connection &_connection,
      const boost::function<void ()> _callback_on_success = NoOpCallback,
      const boost::function<void ()> _callback_on_failure = NoOpCallback) :
    AsyncOperation(std::string("obtainjob"),_connection, _callback_on_success, _callback_on_failure)
    {}
  /// Destructor for class ObtainJobOperation
  ~ObtainJobOperation() {}

  /** Getter for the obtained job.
   *
   * @return obtained FragmentJob
   */
  FragmentJob::ptr getJob()
  {
    return job;
  }

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

  /// Callback function when job has been received.
  void handle_ReceiveJob(const boost::system::error_code& e);

private:
  /// The data received from the server.
  FragmentJob::ptr job;
};


#endif /* OBTAINJOBOPERATION_HPP_ */