00001 /******************************************************************************* 00002 * Copyright (C) 2004 Vintela, Inc. All rights reserved. 00003 * Copyright (C) 2005 Novell, Inc. All rights reserved. 00004 * 00005 * Redistribution and use in source and binary forms, with or without 00006 * modification, are permitted provided that the following conditions are met: 00007 * 00008 * - Redistributions of source code must retain the above copyright notice, 00009 * this list of conditions and the following disclaimer. 00010 * 00011 * - Redistributions in binary form must reproduce the above copyright notice, 00012 * this list of conditions and the following disclaimer in the documentation 00013 * and/or other materials provided with the distribution. 00014 * 00015 * - Neither the name of Vintela, Inc., Novell, Inc., nor the names of its 00016 * contributors may be used to endorse or promote products derived from this 00017 * software without specific prior written permission. 00018 * 00019 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS ``AS IS'' 00020 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 00021 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 00022 * ARE DISCLAIMED. IN NO EVENT SHALL Vintela, Inc., Novell, Inc., OR THE 00023 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 00024 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 00025 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; 00026 * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 00027 * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR 00028 * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF 00029 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 00030 *******************************************************************************/ 00031 00032 00038 #include "blocxx/BLOCXX_config.h" 00039 #include "blocxx/SelectEngine.hpp" 00040 #include "blocxx/Select.hpp" 00041 #include "blocxx/ExceptionIds.hpp" 00042 00043 namespace BLOCXX_NAMESPACE 00044 { 00045 00046 BLOCXX_DEFINE_EXCEPTION_WITH_ID(Select); 00048 void 00049 SelectEngine::addSelectableObject(const SelectableIFCRef& obj, 00050 const SelectableCallbackIFCRef& cb) 00051 { 00052 m_selectableObjs.push_back(obj); 00053 m_callbacks.push_back(cb); 00054 } 00056 void 00057 SelectEngine::go() 00058 { 00059 m_stopFlag = false; 00060 do 00061 { 00062 SelectTypeArray selObjs; 00063 for (size_t i = 0; i < m_selectableObjs.size(); ++i) 00064 { 00065 selObjs.push_back(m_selectableObjs[i]->getSelectObj()); 00066 } 00067 int selected = Select::select(selObjs); 00068 if (selected == Select::SELECT_ERROR) 00069 { 00070 BLOCXX_THROW(SelectException, "Select Error"); 00071 } 00072 else if (selected == Select::SELECT_TIMEOUT 00073 || selected == Select::SELECT_INTERRUPTED) 00074 { 00075 continue; 00076 } 00077 else 00078 { 00079 m_callbacks[selected]->selected(m_selectableObjs[selected]); 00080 } 00081 } while (!m_stopFlag); 00082 } 00084 void 00085 SelectEngine::stop() 00086 { 00087 m_stopFlag = true; 00088 } 00089 00091 SelectEngineStopper::SelectEngineStopper(SelectEngine& engine) 00092 : SelectableCallbackIFC() 00093 , m_engine(engine) 00094 { 00095 } 00096 00098 void 00099 SelectEngineStopper::doSelected(SelectableIFCRef& selectedObject) 00100 { 00101 m_engine.stop(); 00102 } 00103 00104 } // end namespace BLOCXX_NAMESPACE 00105