---

Pipeline.h

Go to the documentation of this file.

#ifndef __PIPELINE_H__
#define __PIPELINE_H__

#include <vector>
using namespace std;

#include "vpControl.h"

#include "InputObject.h"
#include "MidiInput.h"
#include "JoystickInput.h"

#include "OutputObject.h"
#include "NetOutput.h"

#define PIPELINE_THREAD_INTERVAL  10
  

class Pipeline
{
private:
    vpHash  *controlMap;
    
    vector<InputObject *>   inputObjects;

    vector<OutputObject *>  outputObjects;

    HANDLE  inputMutex;

    HANDLE  outputMutex;

    HANDLE  threadHandle;

    DWORD   threadID;

    bool    isRunning;

public:

    Pipeline(vpHash *controlMap);

    ~Pipeline();


    unsigned int addInputObject(InputObject *input);


    unsigned int addOutputObject(OutputObject *output);

    DWORD threadProc();

    void threadBegin();
    
    void threadEnd();
};

static DWORD WINAPI pipelineThreadProc(Pipeline *instance);

#endif /* __PIPELINE_H__ */

---