00001 /***************************** License ********************************** 00002 00003 Copyright (C) 2008 by Communicative Machines 00004 http://www.cmlabs.com All rights reserved. 00005 00006 This library is free software; you can redistribute it and/or 00007 modify it under the terms of the GNU Lesser General Public 00008 License as published by the Free Software Foundation; either 00009 version 2.1 of the License, or (at your option) any later version. 00010 00011 This library is distributed in the hope that it will be useful, 00012 but WITHOUT ANY WARRANTY; without even the implied warranty of 00013 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 00014 Lesser General Public License for more details. 00015 00016 You should have received a copy of the GNU Lesser General Public 00017 License along with this library; if not, write to the Free Software 00018 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA 00019 00020 ************************************************************************/ 00021 00022 00023 // RequestQueue.h: interface for the RequestQueue class. 00024 // 00025 ////////////////////////////////////////////////////////////////////// 00026 00027 #if !defined(AFX_REQUESTQUEUE_H__241F10F8_5316_43DB_84CE_F0E4D414BC58__INCLUDED_) 00028 #define AFX_REQUESTQUEUE_H__241F10F8_5316_43DB_84CE_F0E4D414BC58__INCLUDED_ 00029 00030 #if _MSC_VER > 1000 00031 #pragma once 00032 #endif // _MSC_VER > 1000 00033 00034 #include "Object.h" 00035 #include "Queue.h" 00036 00037 namespace cmlabs { 00038 00039 class RequestQueue : public Object 00040 { 00041 public: 00042 RequestQueue(); 00043 virtual ~RequestQueue(); 00044 00045 // Requesting side 00046 00047 Object* clone() const {return NULL;} 00048 JString enterRequest(JString req); 00049 JString waitForReply(JString id, long ms); 00050 //! Get total size of payload 00051 virtual unsigned long getPayloadSize() const; 00052 00053 00054 // Replying side 00055 00056 bool isEmpty(); 00057 int getCount(); 00058 00059 JString waitForNewRequestID(int ms); 00060 JString getRequest(JString id); 00061 bool reply(JString id, JString rep); 00062 00063 bool unitTest(); 00064 00065 protected: 00066 00067 Queue* inQueue; 00068 Queue* outQueue; 00069 00070 }; 00071 00072 } // namespace cmlabs 00073 00074 #endif // !defined(AFX_REQUESTQUEUE_H__241F10F8_5316_43DB_84CE_F0E4D414BC58__INCLUDED_)
1.5.6