OperationThread.h

//-*-C++-*-
/***************************************************************************
 *
 *   Copyright (C) 2010 - 2011 by Willem van Straten
 *   Licensed under the Academic Free License version 2.1
 *
 ***************************************************************************/
 
#ifndef __OperationThread_h
#define __OperationThread_h
 
#include "dsp/Operation.h"
#include "ThreadContext.h"
 
namespace dsp
{
 
 
  class OperationThread : public Operation
  {
 
  public:
 
    OperationThread (Operation* = 0);
 
    ~OperationThread();
 
    void append_operation (Operation* op);
 
    void reserve ();
 
    void prepare ();
 
    void add_extensions (Extensions* ext);
 
    void operation ();
 
    void combine (const Operation*);
 
    void report () const;
 
    uint64_t bytes_storage() const override;
 
    uint64_t bytes_scratch () const override;
 
    void reset ();
 
    class Wait;
 
    Wait * get_wait();
 
    unsigned get_nop() const { return operations.size(); }
    Operation* get_op (unsigned i) { return operations.at(i); }
 
  protected:
 
    static void* operation_thread (void*);
 
    void thread ();
 
    std::vector< Reference::To<Operation> > operations;
 
    ThreadContext* context;
    pthread_t id;
 
    enum State { Idle, Active, Quit };
    State state;
    
  };
 
  class OperationThread::Wait : public Operation
  {
 
  public:
 
    Wait (OperationThread* parent);
    void operation ();
 
    uint64_t bytes_storage() const override { return 0; }
    uint64_t bytes_scratch () const override { return 0; }
 
    OperationThread* get_parent() const { return parent; }
 
  protected:
 
    Reference::To<OperationThread,false> parent;
  };
}
 
#endif