// se llenaba.
// (2) Puede ser que se invoque mas de una vez.
//--------------------------------------------------------------------------------------------
-void timex::TickConsumer::initialize()
+void anna::timex::TickConsumer::initialize()
throw(RuntimeException) {
if(a_pipe [0] != -1) // (2)
return;
setfd(a_pipe [0]);
}
-void timex::TickConsumer::apply()
+void anna::timex::TickConsumer::apply()
throw(RuntimeException) {
char buffer [256];
}
}
-void timex::TickConsumer::finalize()
+void anna::timex::TickConsumer::finalize()
throw() {
if(a_timeController.a_tickProducer)
a_timeController.a_tickProducer->requestStop();
* Asi que cada proceso debe tener su propia copia del pipe, para que cada uno lleve independientemente
* el control de tiempos.
*/
-void timex::TickConsumer::clone()
+void anna::timex::TickConsumer::clone()
throw(RuntimeException) {
close(a_pipe [0]);
close(a_pipe [1]);
a_timeController.a_tickProducer->setfd(a_pipe [1]);
}
-std::string timex::TickConsumer::asString() const
+std::string anna::timex::TickConsumer::asString() const
throw() {
string result("timex::TickConsumer { ");
result += Handler::asString();