doer.h

Go to the documentation of this file.

 
#ifndef DOER_H_
#define DOER_H_
 
#include <cstddef>
 
#include "concurrent_queue_wrapper.h"
#include "concurrentqueue.h"
#include "config.h"
#include "message.h"
#include "utils.h"
 
class Doer {
 public:
  virtual bool TryLaunch(
      moodycamel::ConcurrentQueue<EventData>& task_queue,
      moodycamel::ConcurrentQueue<EventData>& complete_task_queue,
      moodycamel::ProducerToken* worker_ptok) {
    EventData req_event;
    if (task_queue.try_dequeue(req_event)) {
      // We will enqueue one response event containing results for all
      // request tags in the request event
      EventData resp_event;
      resp_event.num_tags_ = req_event.num_tags_;
 
      for (size_t i = 0; i < req_event.num_tags_; i++) {
        EventData resp_i = Launch(req_event.tags_[i]);
        RtAssert(resp_i.num_tags_ == 1, "Invalid num_tags in resp");
        resp_event.tags_[i] = resp_i.tags_[0];
        resp_event.event_type_ = resp_i.event_type_;
      }
 
      TryEnqueueFallback(&complete_task_queue, worker_ptok, resp_event);
      return true;
    }
    return false;
  }
 
  virtual EventData Launch(size_t tag) {
    unused(tag);
    RtAssert(false, "Doer: Launch(tag) not implemented");
    return EventData();
  }
 
  virtual EventData Launch(size_t tag, EventType event_type) {
    unused(tag);
    unused(event_type);
    RtAssert(false, "Doer: Launch(tag, event_type) not implemented");
    return EventData();
  }
 
 protected:
  Doer(Config* in_config, int in_tid) : cfg_(in_config), tid_(in_tid) {}
  virtual ~Doer() = default;
 
  Config* cfg_;
  int tid_;  // Thread ID of this Doer
};
#endif  // DOER_H_