00001 //------------------------------------------------------------------------------ 00002 // Copyright (c) 2011-2012 by European Organization for Nuclear Research (CERN) 00003 // Author: Lukasz Janyst <ljanyst@cern.ch> 00004 //------------------------------------------------------------------------------ 00005 // XRootD is free software: you can redistribute it and/or modify 00006 // it under the terms of the GNU Lesser General Public License as published by 00007 // the Free Software Foundation, either version 3 of the License, or 00008 // (at your option) any later version. 00009 // 00010 // XRootD is distributed in the hope that it will be useful, 00011 // but WITHOUT ANY WARRANTY; without even the implied warranty of 00012 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 00013 // GNU General Public License for more details. 00014 // 00015 // You should have received a copy of the GNU Lesser General Public License 00016 // along with XRootD. If not, see <http://www.gnu.org/licenses/>. 00017 //------------------------------------------------------------------------------ 00018 00019 #ifndef __XRD_CL_IN_QUEUE_HH__ 00020 #define __XRD_CL_IN_QUEUE_HH__ 00021 00022 #include <XrdSys/XrdSysPthread.hh> 00023 #include <map> 00024 #include <utility> 00025 #include "XrdCl/XrdClXRootDResponses.hh" 00026 #include "XrdCl/XrdClPostMasterInterfaces.hh" 00027 00028 namespace XrdCl 00029 { 00030 class Message; 00031 00032 //---------------------------------------------------------------------------- 00034 //---------------------------------------------------------------------------- 00035 class InQueue 00036 { 00037 public: 00038 //------------------------------------------------------------------------ 00040 //------------------------------------------------------------------------ 00041 bool AddMessage( Message *msg ); 00042 00043 //------------------------------------------------------------------------ 00048 //------------------------------------------------------------------------ 00049 void AddMessageHandler( IncomingMsgHandler *handler, time_t expires ); 00050 00051 //------------------------------------------------------------------------ 00060 //------------------------------------------------------------------------ 00061 IncomingMsgHandler *GetHandlerForMessage( Message *msg, 00062 time_t &expires, 00063 uint16_t &action ); 00064 00065 //------------------------------------------------------------------------ 00067 //------------------------------------------------------------------------ 00068 void ReAddMessageHandler( IncomingMsgHandler *handler, time_t expires ); 00069 00070 //------------------------------------------------------------------------ 00072 //------------------------------------------------------------------------ 00073 void RemoveMessageHandler( IncomingMsgHandler *handler ); 00074 00075 //------------------------------------------------------------------------ 00077 //------------------------------------------------------------------------ 00078 void ReportStreamEvent( IncomingMsgHandler::StreamEvent event, 00079 XRootDStatus status ); 00080 00081 //------------------------------------------------------------------------ 00083 //------------------------------------------------------------------------ 00084 void ReportTimeout( time_t now = 0 ); 00085 00086 private: 00087 00088 //------------------------------------------------------------------------ 00097 //------------------------------------------------------------------------ 00098 bool DiscardMessage(Message* msg, uint16_t& sid) const; 00099 00100 typedef std::pair<IncomingMsgHandler *, time_t> HandlerAndExpire; 00101 typedef std::map<uint16_t, HandlerAndExpire> HandlerMap; 00102 typedef std::map<uint16_t, Message*> MessageMap; 00103 MessageMap pMessages; 00104 HandlerMap pHandlers; 00105 XrdSysRecMutex pMutex; 00106 }; 00107 } 00108 00109 #endif // __XRD_CL_IN_QUEUE_HH__