/cygdrive/d/src/svn/vrut/trunk/modules/scripting/jshandler.cpp

Go to the documentation of this file.

/*
 * $Id: $
 *
 * Description  : Scripting module.
 * Author       : Jakub Zelenka <mail: jakub.zelenka@gmail.com>
 *
 * Purpose      :
 *     Scripting synchronizer.
 */

#include <iostream>

#include "jshandler.h"
#include "jsscripting.h"
#include "jsenvironment.h"

using namespace VRUT;
using namespace std;

JSHandler::JSHandler(JSScriptingModule *_module)
{
       module = _module;
       jsEnv = new JSEnvironment(this);
}

JSHandler::~JSHandler()
{
       delete jsEnv;
}

bool JSHandler::Sleep(unsigned long milis)
{
       unsigned long t;
       if (milis > TIMEOUT_SLEEP)
       {
              t = milis % TIMEOUT_SLEEP;
              int steps = milis / TIMEOUT_SLEEP;
              for (int i = 0; i < steps; i++)
              {
                     wxThread::Sleep(TIMEOUT_SLEEP);
                     if (IsEnd())
                            return false;
              }
       }
       else
              t = milis;

       if (t)
              wxThread::Sleep(t);

       return true;
}

wxCommandEvent *JSHandler::WaitForEvent(Event::EVENT_TYPE type, unsigned long milis, bool waitFromNow)
{
       wxCommandEvent *pevt = NULL;
       MessageQueueError err;
       size_t size;

       if (waitFromNow)
       {
              size = module->evtQueue.GetSize();
              for (unsigned i = 0; i < size; i++)
              {
                     wxCommandEvent evt1 = module->evtQueue.ReceiveTimeout(0, err);
                     if (err)
                            return NULL;
                     ProcessEvent(evt1);
              }
       }

       bool unlimited = (milis == 0);
       while (unlimited || milis > 0)
       {
              size = module->evtQueue.GetSize();
              for (unsigned i = 0; i < size; i++)
              {
                     wxCommandEvent evt2 = module->evtQueue.ReceiveTimeout(0, err);
                     //cout << "event: " << int(evt2.GetEventType()) << endl;
                     if (err)
                            return NULL;
                     if (evt2.GetEventType() == type)
                            return new wxCommandEvent(evt2);
                     ProcessEvent(evt2);
              }

              wxThread::Sleep(TIMEOUT_WAITING);
              if (IsEnd())
                     return NULL;

              if (!unlimited)
                     milis -= TIMEOUT_WAITING;
       }

       return NULL;
}

void JSHandler::PostEvent(wxCommandEvent & evt)
{
       module->PostEvent(evt);
}

void JSHandler::PostToKernel(wxCommandEvent & evt)
{
       module->PostToKernel(evt);
}

void JSHandler::ProcessEvent(wxCommandEvent & evt)
{
       if (evt.GetEventType() == Event::EVT_PARAM_SET)
       {
              if (IS_PARAM(evt, module->sceneParamID))
              {
                     long val;
                     if (((wxString *) evt.GetClientData())->AfterFirst('=').ToLong(&val) && val >= 0)
                            module->sceneID = (SCENE_ID) val;
                     else
                            module->sceneID = SCENE_ID_NONE;
              }
              else if (IS_PARAM(evt, module->runParamID))
                     executions.push(RunData(module->scriptPath, module->sceneID));
              else
                     UPDATE_PARAM_FROM_EVENT_STRING(module->pathParamID, module->scriptPath, evt);
       }
}

bool JSHandler::RunScript()
{
       if (executions.empty())
              return false;
       RunData data = executions.front();
       executions.pop();
       jsEnv->RunScript(module->kernel, data.scriptPath.ToAscii(), data.sceneID);
       return true;
}

bool JSHandler::IsEnd()
{
       return module->TestExit();
}

---