diff options
Diffstat (limited to 'rotord/rotor.h')
| -rwxr-xr-x | rotord/rotor.h | 73 |
1 files changed, 52 insertions, 21 deletions
diff --git a/rotord/rotor.h b/rotord/rotor.h index ac4532a..4a0c540 100755 --- a/rotord/rotor.h +++ b/rotord/rotor.h @@ -48,11 +48,11 @@ bool Same_frame(float time1, float time2); 2 main questions authentication - how authentication to renderer or just session? -files - where +files - where generated images & movies where? -nb where a signal enters a channel comp input - it is duplicated - +nb where a signal enters a channel comp input - it is duplicated + next - Poco create thread 1st - create thread and return id - create method to kill it @@ -60,12 +60,27 @@ next - Poco create thread sql stuff +messaging - http factory includes a poco notication center +when it creates the rotor session it registers it +session messages are posted thus and consumed + */ #include <unordered_map> +#include <deque> #include "Poco/UUID.h" #include "Poco/UUIDGenerator.h" +#include "Poco/Notification.h" +#include "Poco/NotificationCenter.h" +#include "Poco/Observer.h" +#include "Poco/ThreadPool.h" +#include "Poco/Thread.h" +#include "Poco/Runnable.h" +#include "Poco/Mutex.h" +#include "Poco/Random.h" +#include "Poco/AutoPtr.h" +#include <iostream> using Poco::UUID; using Poco::UUIDGenerator; @@ -76,9 +91,10 @@ using Poco::UUIDGenerator; #define ROTOR_RENDERING 3 namespace Rotor { + //forward declaration class Node; - + class Render_status{ public: int id; @@ -89,36 +105,51 @@ namespace Rotor { int num_performances; int num_clips; }; - class Render_context: public Poco::Task{ //Poco task object - //manages a 'patchbay' - //high level interfaces for the wizard - //and low level interface onto the graph + class Render_context: public Poco::Task { //Poco task object + //manages a 'patchbay' + //high level interfaces for the wizard + //and low level interface onto the graph public: Render_context(const std::string& name): Task(name) { }; void runTask() { - while (!isCancelled()) sleep(1); + while (!isCancelled()) { + mutex.lock(); + if (work_queue.size()){ + std::string out=name()+": "+work_queue[0]+"\n"; + printf(out.c_str()); + work_queue.pop_front(); + } + mutex.unlock(); + sleep(100); + } printf("Rotor: stopping thread\n"); - + } + void add_queue(std::string item) { + mutex.lock(); + work_queue.push_back(item); + mutex.unlock(); } Render_status get_status(); - void cancel(); //interrupt locking process - int make_preview(int nodeID, float time); //starts a frame preview - returns status code - how to retrieve? + void cancel(); //interrupt locking process + int make_preview(int nodeID, float time); //starts a frame preview - returns status code - how to retrieve? int load_graph(Poco::UUID uid); - UUID save_graph(); //returns UUID of saved graph + UUID save_graph(); //returns UUID of saved graph int load_audio(string filename); Render_requirements get_requirements(); - int load_video(int num,string filename); //can be performance or clip - + int load_video(int num,string filename); //can be performance or clip + private: int status; - float progress; //for a locking process: audio analysis or rendering - - }; + float progress; //for a locking process: audio analysis or rendering + std::deque<std::string> work_queue; + + Poco::Mutex mutex; //access to notification queue + }; class Input{ public: Node* connection; - + }; class Image_input: public Input{ public: @@ -155,7 +186,7 @@ namespace Rotor { Image* get_output(float time){ //sample implementation gather_inputs(time); //do something with the inputs - + //and then return ((Image_node*)image_inputs[0].connection)->image; } @@ -175,4 +206,4 @@ namespace Rotor { /* coding style Types begin with a capital, use underscore as a seperator -*/
\ No newline at end of file +*/ |