00001 // OSB library ************************************************ -*- C++ -*- 00006 /* 00007 AUTHOR(S): Stephan Broennimann (vb) 00008 00009 RCS information 00010 $Name: OSB_060808 $ 00011 $Revision: 1.7 $ 00012 00013 License 00014 OSB rating and billing library for communication networks 00015 Copyright (C) 2004, 2005, 2006 OSB systems 00016 00017 This file may be distributed and/or modify under the terms of the 00018 GNU General Public License (GPL) as published by the Free Software 00019 Foundation which is provided in the file LICENSE.GPL included in the 00020 packaging of this file. 00021 00022 The file is distributed in the hope that it will be useful, but WITHOUT 00023 ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or 00024 FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License 00025 for more details. 00026 00027 Holders of a OSB Commercial License may use this file under the terms 00028 and conditions of this commercial license. 00029 */ 00030 #ifndef _RQSTHREAD_H_ 00031 #define _RQSTHREAD_H_ 00032 00033 // ************************************************************************ 00034 // included header files 00035 // + standard includes 00036 #include <map> 00037 00038 // + libraries 00039 #include <osbid.h> 00040 #include <osbthread.h> 00041 #include <period.h> 00042 #include <requesthandler.h> 00043 00044 // + local headers 00045 00046 // + class declarations 00047 00048 // ************************************************************************ 00049 // forward declarations 00050 00051 // ************************************************************************ 00052 // type definitions 00053 00054 // ************************************************************************ 00055 // class definitions 00062 class RqsThread : public OSB_APP::ThreadBase { 00064 typedef OSB_LIB::RequestHandler::Result SrqResult; 00066 typedef OSB_LIB::Id<OSB_LIB::StatusRequest> SrqId; 00067 public: 00069 typedef std::map<SrqResult, long> Stats; 00070 00071 private: 00080 void threadFunction(); 00081 00088 bool processOnce(); 00089 00091 SrqResult processReq( 00092 const OSB_DB::Session& session, 00093 OSB_LIB::RequestHandler& rh, 00094 OSB_LIB::StatusRequest& request 00095 ); 00096 00098 void reset(); 00099 00100 private: 00102 OSB_LIB::Period period_; 00104 SrqId maxProcessed_; 00105 00107 Stats stats_; 00109 OSB_LIB::DateTime resetTime_; 00110 00112 int idleSleep_; 00114 int deltaReset_; 00115 }; // class RqsThread 00116 00117 // ************************************************************************ 00118 // inline definitions 00119 #endif // #ifndef _RQSTHREAD_H_