bridges/source/remote/urp/urp_bridgeimpl.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: urp_bridgeimpl.cxx,v $
  10  * $Revision: 1.13 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 // MARKER(update_precomp.py): autogen include statement, do not remove
  32 #include "precompiled_bridges.hxx"
  33 #include <osl/thread.h>
  34 #include <bridges/remote/helper.hxx>
  35
  36 #include <algorithm>
  37
  38 #include "urp_bridgeimpl.hxx"
  39
  40 using namespace ::rtl;
  41 using namespace ::osl;
  42 using namespace ::com::sun::star::uno;
  43 namespace bridges_urp
  44 {
  45
  46 template < class t >
  47 inline t mymin( const t & val1, const t & val2 )
  48 {
  49     return val1 < val2 ? val1 : val2;
  50 }
  51
  52 /***********
  53  * urp_BridgeImpl
  54  ***********/
  55 urp_BridgeImpl::urp_BridgeImpl( sal_Int32 nCacheSize , sal_uInt32 nInitialMarshalerSize ) :
  56     m_blockMarshaler( this , nInitialMarshalerSize , ::bridges_remote::remote_retrieveOidFromProxy),
  57     m_nMarshaledMessages( 0 ),
  58     m_oidCacheOut( (sal_uInt16)nCacheSize ),
  59     m_tidCacheOut( (sal_uInt16)nCacheSize ),
  60     m_typeCacheOut( (sal_uInt16)nCacheSize )
  61 {
  62     m_pOidIn = new OUString[ nCacheSize ];
  63     m_pTidIn = new ByteSequence[ nCacheSize ];
  64     m_pTypeIn = new Type[ nCacheSize ];
  65     m_nRemoteThreads = 0;
  66 }
  67
  68 urp_BridgeImpl::~urp_BridgeImpl()
  69 {
  70     delete [] m_pOidIn;
  71     delete [] m_pTidIn;
  72     delete [] m_pTypeIn;
  73 }
  74
  75
  76 void urp_BridgeImpl::applyProtocolChanges( const Properties &props )
  77 {
  78     if( m_properties.nTypeCacheSize != props.nTypeCacheSize )
  79     {
  80         if( props.nTypeCacheSize == 0 )
  81         {
  82             delete [] m_pTypeIn;
  83             m_pTypeIn = 0;
  84         }
  85         else
  86         {
  87             Type *pNew = new Type[props.nTypeCacheSize];
  88             sal_Int32 i;
  89             sal_Int32 iMin = mymin( m_properties.nTypeCacheSize , props.nTypeCacheSize );
  90             for( i = 0; i < iMin ; i ++ )
  91             {
  92                 pNew[i] = m_pTypeIn[i];
  93             }
  94             delete [] m_pTypeIn;
  95             m_pTypeIn = pNew;
  96         }
  97         OSL_ASSERT( props.nTypeCacheSize <= 0xffff );
  98         m_properties.nTypeCacheSize = props.nTypeCacheSize;
  99         m_typeCacheOut.resize( (sal_uInt16)props.nTypeCacheSize );
 100     }
 101
 102      if( m_properties.nOidCacheSize != props.nOidCacheSize )
 103      {
 104          if( 0 == props.nOidCacheSize )
 105          {
 106              delete [] m_pOidIn;
 107              m_pOidIn = 0;
 108          }
 109          else
 110          {
 111              OUString *pNew = new OUString[props.nOidCacheSize];
 112              sal_Int32 i;
 113              sal_Int32 iMin = mymin( m_properties.nOidCacheSize , props.nOidCacheSize );
 114              for( i = 0; i < iMin ; i ++ )
 115              {
 116                  pNew[i] = m_pOidIn[i];
 117              }
 118              delete [] m_pOidIn;
 119              m_pOidIn = pNew;
 120          }
 121         OSL_ASSERT( props.nOidCacheSize <= 0xffff );
 122          m_oidCacheOut.resize( (sal_uInt16)props.nOidCacheSize );
 123          m_properties.nOidCacheSize = props.nOidCacheSize;
 124      }
 125
 126      if( m_properties.nTidCacheSize != props.nTidCacheSize )
 127      {
 128          if( 0 == props.nTidCacheSize )
 129          {
 130              delete [] m_pTidIn;
 131             m_pTidIn = 0;
 132          }
 133          else
 134          {
 135              ByteSequence *pNew = new ByteSequence[props.nTidCacheSize];
 136              sal_Int32 i;
 137              sal_Int32 iMin = mymin( m_properties.nTidCacheSize , props.nTidCacheSize );
 138              for( i = 0; i < iMin ; i ++ )
 139              {
 140                  pNew[i] = m_pTidIn[i];
 141              }
 142              delete [] m_pTidIn;
 143              m_pTidIn = pNew;
 144          }
 145         OSL_ASSERT( props.nTidCacheSize <= 0xffff );
 146          m_tidCacheOut.resize( (sal_uInt16)props.nTidCacheSize );
 147          m_properties.nTidCacheSize = props.nTidCacheSize;
 148      }
 149
 150      if( m_properties.sVersion != props.sVersion )
 151      {
 152         m_properties.sVersion = props.sVersion;
 153      }
 154
 155     if( m_properties.nFlushBlockSize != props.nFlushBlockSize )
 156     {
 157         m_properties.nFlushBlockSize = props.nFlushBlockSize;
 158     }
 159
 160     if( m_properties.nOnewayTimeoutMUSEC != props.nOnewayTimeoutMUSEC )
 161     {
 162         m_properties.nOnewayTimeoutMUSEC = props.nOnewayTimeoutMUSEC;
 163     }
 164
 165     if( props.bClearCache )
 166     {
 167         if( m_properties.nTypeCacheSize )
 168         {
 169             delete [] m_pTypeIn;
 170             m_pTypeIn = new Type[m_properties.nTypeCacheSize];
 171             m_typeCacheOut.clear();
 172         }
 173         m_lastInType = Type();
 174         m_lastOutType = Type();
 175
 176         if( m_properties.nOidCacheSize )
 177         {
 178             delete [] m_pOidIn;
 179             m_pOidIn = new OUString[ m_properties.nOidCacheSize];
 180             m_oidCacheOut.clear();
 181         }
 182         m_lastOutOid = OUString();
 183         m_lastInOid = OUString();
 184
 185         if( m_properties.nTidCacheSize )
 186         {
 187             delete [] m_pTidIn;
 188             m_pTidIn = new ByteSequence[m_properties.nTidCacheSize];
 189             m_tidCacheOut.clear();
 190         }
 191         m_lastInTid = ByteSequence();
 192         m_lastOutTid = ByteSequence();
 193     }
 194
 195     if( m_properties.bNegotiate != props.bNegotiate )
 196     {
 197         m_properties.bNegotiate = props.bNegotiate;
 198     }
 199
 200     if( m_properties.bForceSynchronous != props.bForceSynchronous )
 201     {
 202         m_properties.bForceSynchronous = props.bForceSynchronous;
 203     }
 204
 205     m_properties.bCurrentContext = props.bCurrentContext;
 206 }
 207
 208 void urp_BridgeImpl::addError( char const *pError )
 209 {
 210     OUString message = OUString( RTL_CONSTASCII_USTRINGPARAM( "(tid=" ) );
 211     message += OUString::valueOf( (sal_Int32 ) osl_getThreadIdentifier( 0 ) );
 212     message += OUString::createFromAscii( ") " );
 213     message += OUString::createFromAscii( pError );
 214     MutexGuard guard( m_errorListMutex );
 215     m_lstErrors.push_back( message );
 216 }
 217
 218 void urp_BridgeImpl::addError( const OUString & error )
 219 {
 220     OUString message = OUString( RTL_CONSTASCII_USTRINGPARAM( "(tid=" ) );
 221     message += OUString::valueOf( (sal_Int32 ) osl_getThreadIdentifier( 0 ) );
 222     message += OUString::createFromAscii( ") " );
 223     message += error;
 224     MutexGuard guard( m_errorListMutex );
 225     m_lstErrors.push_back( message );
 226 }
 227
 228 void urp_BridgeImpl::dumpErrors( FILE * f)
 229 {
 230     MutexGuard guard( m_errorListMutex );
 231     for( ::std::list< OUString >::iterator ii = m_lstErrors.begin() ;
 232          ii != m_lstErrors.end() ;
 233          ++ii )
 234     {
 235         OString o = OUStringToOString( *ii , RTL_TEXTENCODING_UTF8 );
 236         fprintf( f,  "%s\n" , o.getStr() );
 237     }
 238 }
 239
 240 OUString urp_BridgeImpl::getErrorsAsString( )
 241 {
 242     MutexGuard guard( m_errorListMutex );
 243     OUString ret;
 244     for( ::std::list< OUString >::iterator ii = m_lstErrors.begin() ;
 245          ii != m_lstErrors.end() ;
 246          ++ii )
 247     {
 248         ret += *ii;
 249     }
 250     return ret;
 251 }
 252
 253 }