35 return m_object.get<rtString>(
"name");
37 Event(rtObjectRef o) : m_object(o)
41 Event(
const char* eventName) : m_object(
new rtMapObject)
43 m_object.set(
"name", eventName);
45 rtObjectRef object()
const
59 , mRemoteReady(
false) {
60 pthread_mutex_init(&mMutex, NULL);
64 pthread_mutex_destroy(&mMutex);
67 rtError setListener(
const char* eventName, rtIFunction* f)
69 return m_emit->setListener(eventName, f);
71 rtError delListener(
const char* eventName, rtIFunction* f)
73 return m_emit->delListener(eventName, f);
75 void remoteObjectReady()
80 rtError send(
Event* event);
84 std::queue<rtObjectRef> mEventQueue;
85 pthread_mutex_t mMutex;
94 pthread_mutex_t mMutex;
100 virtual rtError initRt();
102 static void rtRemoteCallback(
void* ctx);
103 void setStarted(
bool started);
104 void send(
Event* event);
105 rtError setListener(rtString eventName,
const rtFunctionRef& f);
106 rtError delListener(rtString eventName,
const rtFunctionRef& f);
107 void remoteObjectReady();
110 void setDedicatedThreadRunning(
bool running);
111 bool isDedicatedThreadRunning();
112 static void * RtMessageThread(
void * ctx);
113 void ProcessRtItem();