void processData(const data& packet)
{
  // First, let's run the data through the analyzer to determine 
  // the priority it should be running at.
  int priority = _analyzer->analyzePriority(data);
  // Get the Current object, and set the priority
  CORBA::Object_var object = _orb->resolve_initial_references("RTCurrent");
  RTCORBA::Current_var current = RTCORBA::Current::_narrow(object);
  current->the_priority(priority);
  // Send the data off to the router
  sensorRouter->routeData(data);
}

Example 1: Modifying a thread's priority before sending it.

Back to Article