X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FPassiveQueue.cc;h=144c30e7d12e21697a54eefa9ccba367e43f66a2;hb=6927c87144ca23845065e3c23e37c75f5f059cf3;hp=7ce0b6ce48e243836518847a985d17baec5b45e6;hpb=f73fa16ed5abdce272ac77f8b8b9ef2b9922c266;p=senf.git diff --git a/PPI/PassiveQueue.cc b/PPI/PassiveQueue.cc index 7ce0b6c..144c30e 100644 --- a/PPI/PassiveQueue.cc +++ b/PPI/PassiveQueue.cc @@ -1,8 +1,8 @@ // $Id$ // -// Copyright (C) 2007 -// Fraunhofer Institute for Open Communication Systems (FOKUS) -// Competence Center NETwork research (NET), St. Augustin, GERMANY +// Copyright (C) 2007 +// Fraunhofer Institute for Open Communication Systems (FOKUS) +// Competence Center NETwork research (NET), St. Augustin, GERMANY // Stefan Bund // // This program is free software; you can redistribute it and/or modify @@ -38,9 +38,10 @@ //////////////////////////////////////// // private members -prefix_ void senf::ppi::module::PassiveQueue::init() +prefix_ void senf::ppi::module::PassiveQueue::v_init() { - output.throttle(); + if (!input) + output.throttle(); } prefix_ void senf::ppi::module::PassiveQueue::onInput() @@ -50,7 +51,7 @@ prefix_ void senf::ppi::module::PassiveQueue::onInput() prefix_ void senf::ppi::module::PassiveQueue::onOutput() { - if (input) + if (input) output(input()); if (!input) output.throttle();