source: src/Fragmentation/Automation/Operations/Workers/SubmitResultOperation.hpp@ 50d095

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

#ifndef SUBMITRESULTOPERATION_HPP_
#define SUBMITRESULTOPERATION_HPP_

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


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

#include "Connection.hpp"

#include "Jobs/FragmentJob.hpp"
#include "Operations/AsyncOperation.hpp"
#include "Results/FragmentResult.hpp"
#include "WorkerAddress.hpp"

class SubmitResultOperation : public AsyncOperation  {
public:
  /// Constructor for class SubmitResultOperation.
  SubmitResultOperation(Connection &_connection, const WorkerAddress &_address) :
    AsyncOperation(std::string("submitresult"),_connection),
    result( new FragmentResult(JobId::NoJob, std::string("EmptyResult")) ),
    address(_address),
    exitflag(OkFlag)
  {}
  /// Destructor for class SubmitResultOperation
  ~SubmitResultOperation() {}

  /** Sets the result to submit.
   *
   * @param _result result to submit
   */
  void setResult(FragmentResult::ptr &_result)
  {
    result.reset();
    result = _result;
  }

public:
  enum {
    OkFlag = 0,
    ErrorFlag = 1
  };

  /** Returns the flag of the handled operation.
   *
   */
  size_t getFlag() const
  {
    return exitflag;
  }

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 address has been sent and result is about to.
  void handle_SendChoice(const boost::system::error_code& e);

  /// Callback function when result has been sent.
  void handle_SendResult(const boost::system::error_code& e);

  /// Callback function when result has been sent.
  void handle_FinishOperation(const boost::system::error_code& e);

private:
  // static entity of an empty result
  FragmentResult::ptr result;

  //!> address for listener
  WorkerAddress address;

  /// exit flag
  size_t exitflag;
};


#endif /* SUBMITRESULTOPERATION_HPP_ */