diff options
Diffstat (limited to 'extensions/source/plugin/inc/plugin/unx/mediator.hxx')
| -rw-r--r-- | extensions/source/plugin/inc/plugin/unx/mediator.hxx | 183 |
1 files changed, 183 insertions, 0 deletions
diff --git a/extensions/source/plugin/inc/plugin/unx/mediator.hxx b/extensions/source/plugin/inc/plugin/unx/mediator.hxx new file mode 100644 index 000000000000..e1a7f59b5dee --- /dev/null +++ b/extensions/source/plugin/inc/plugin/unx/mediator.hxx @@ -0,0 +1,183 @@ +/************************************************************************* + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * Copyright 2000, 2010 Oracle and/or its affiliates. + * + * OpenOffice.org - a multi-platform office productivity suite + * + * This file is part of OpenOffice.org. + * + * OpenOffice.org is free software: you can redistribute it and/or modify + * it under the terms of the GNU Lesser General Public License version 3 + * only, as published by the Free Software Foundation. + * + * OpenOffice.org is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU Lesser General Public License version 3 for more details + * (a copy is included in the LICENSE file that accompanied this code). + * + * You should have received a copy of the GNU Lesser General Public License + * version 3 along with OpenOffice.org. If not, see + * <http://www.openoffice.org/license.html> + * for a copy of the LGPLv3 License. + * + ************************************************************************/ +#ifndef _MEDIATOR_HXX +#define _MEDIATOR_HXX + +#include <string.h> +#include <stdarg.h> +#include <tools/string.hxx> +#include <tools/link.hxx> +#include <vos/pipe.hxx> +#include <vos/mutex.hxx> +#include <vos/conditn.hxx> +#include <vos/thread.hxx> +#if OSL_DEBUG_LEVEL > 1 +#include <stdio.h> +#endif + +#include <vector> + +struct MediatorMessage +{ + ULONG m_nID; + ULONG m_nBytes; + char* m_pBytes; + char* m_pRun; + + MediatorMessage() : m_nID( 0 ), m_nBytes( 0 ), + m_pBytes( NULL ), m_pRun( NULL ) {} + MediatorMessage( ULONG nID, ULONG nBytes, char* pBytes ) : + m_nID( nID ),m_nBytes( nBytes ), m_pRun( NULL ) + { + m_pBytes = new char[ m_nBytes ]; + memcpy( m_pBytes, pBytes, (size_t)m_nBytes ); + } + + ~MediatorMessage() + { + if( m_pBytes ) + delete [] m_pBytes; + } + + void Set( ULONG nBytes, char* pBytes ) + { + if( m_pBytes ) + delete [] m_pBytes; + m_nBytes = nBytes; + m_pBytes = new char[ m_nBytes ]; + memcpy( m_pBytes, pBytes, (size_t)m_nBytes ); + } + + ULONG ExtractULONG(); + char* GetString(); + UINT32 GetUINT32(); + void* GetBytes( ULONG& ); + void* GetBytes() { ULONG nBytes; return GetBytes( nBytes ); } + + void Rewind() { m_pRun = NULL; } +}; + +class MediatorListener; + +class Mediator +{ + friend class MediatorListener; +protected: + int m_nSocket; + + std::vector<MediatorMessage*> m_aMessageQueue; + vos::OMutex m_aQueueMutex; + vos::OMutex m_aSendMutex; + // only one thread can send a message at any given time + vos::OCondition m_aNewMessageCdtn; + MediatorListener* m_pListener; + // thread to fill the queue + + ULONG m_nCurrentID; + // will be constantly increased with each message sent + bool m_bValid; + + Link m_aConnectionLostHdl; + Link m_aNewMessageHdl; +public: + Mediator( int nSocket ); + ~Mediator(); + + // mark mediator as invalid. No more messages will be processed, + // SendMessage, WaitForMessage, TransactMessage will return immediatly + // with error + void invalidate() { m_bValid = false; } + + ULONG SendMessage( ULONG nBytes, const char* pBytes, ULONG nMessageID = 0 ); + ULONG SendMessage( const ByteString& rMessage, ULONG nMessageID = 0 ) + { + return SendMessage( rMessage.Len(), rMessage.GetBuffer(), nMessageID ); + } + + BOOL WaitForMessage( ULONG nTimeOut = 5000 ); + // timeout in ms + // TRUE: Message came in + // FALSE: timed out + // if timeout is set, WaitForMessage will wait even if there are messages + // in the queue + + virtual MediatorMessage* WaitForAnswer( ULONG nMessageID ); + // wait for an answer message ( ID >= 1 << 24 ) + // the message will be removed from the queue and returned + + MediatorMessage* TransactMessage( ULONG nBytes, char* pBytes ); + // sends a message and waits for an answer + + MediatorMessage* GetNextMessage( BOOL bWait = FALSE ); + + + Link SetConnectionLostHdl( const Link& rLink ) + { + Link aRet = m_aConnectionLostHdl; + m_aConnectionLostHdl = rLink; + return aRet; + } + + Link SetNewMessageHdl( const Link& rLink ) + { + Link aRet = m_aNewMessageHdl; + m_aNewMessageHdl = rLink; + return aRet; + } +}; + +class MediatorListener : public vos:: OThread +{ + friend class Mediator; + private: + Mediator* m_pMediator; + ::vos::OMutex m_aMutex; + + MediatorListener( Mediator* ); + ~MediatorListener(); + + virtual void run(); + virtual void onTerminated(); +}; + +inline void medDebug( int condition, const char* pFormat, ... ) +{ +#if OSL_DEBUG_LEVEL > 1 + if( condition ) + { + va_list ap; + va_start( ap, pFormat ); + vfprintf( stderr, pFormat, ap ); + va_end( ap ); + } +#else + (void)condition; + (void)pFormat; +#endif +} + +#endif // _MEDIATOR_HXX |