1*cdf0e10cSrcweir /************************************************************************* 2*cdf0e10cSrcweir * 3*cdf0e10cSrcweir * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. 4*cdf0e10cSrcweir * 5*cdf0e10cSrcweir * Copyright 2000, 2010 Oracle and/or its affiliates. 6*cdf0e10cSrcweir * 7*cdf0e10cSrcweir * OpenOffice.org - a multi-platform office productivity suite 8*cdf0e10cSrcweir * 9*cdf0e10cSrcweir * This file is part of OpenOffice.org. 10*cdf0e10cSrcweir * 11*cdf0e10cSrcweir * OpenOffice.org is free software: you can redistribute it and/or modify 12*cdf0e10cSrcweir * it under the terms of the GNU Lesser General Public License version 3 13*cdf0e10cSrcweir * only, as published by the Free Software Foundation. 14*cdf0e10cSrcweir * 15*cdf0e10cSrcweir * OpenOffice.org is distributed in the hope that it will be useful, 16*cdf0e10cSrcweir * but WITHOUT ANY WARRANTY; without even the implied warranty of 17*cdf0e10cSrcweir * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 18*cdf0e10cSrcweir * GNU Lesser General Public License version 3 for more details 19*cdf0e10cSrcweir * (a copy is included in the LICENSE file that accompanied this code). 20*cdf0e10cSrcweir * 21*cdf0e10cSrcweir * You should have received a copy of the GNU Lesser General Public License 22*cdf0e10cSrcweir * version 3 along with OpenOffice.org. If not, see 23*cdf0e10cSrcweir * <http://www.openoffice.org/license.html> 24*cdf0e10cSrcweir * for a copy of the LGPLv3 License. 25*cdf0e10cSrcweir * 26*cdf0e10cSrcweir ************************************************************************/ 27*cdf0e10cSrcweir 28*cdf0e10cSrcweir // MARKER(update_precomp.py): autogen include statement, do not remove 29*cdf0e10cSrcweir #include "precompiled_automation.hxx" 30*cdf0e10cSrcweir #include <stdio.h> 31*cdf0e10cSrcweir #if OSL_DEBUG_LEVEL > 1 32*cdf0e10cSrcweir #define DEBUGPRINTF(x) { printf(x); fflush( stdout ); } 33*cdf0e10cSrcweir #else 34*cdf0e10cSrcweir #define DEBUGPRINTF(x) 35*cdf0e10cSrcweir #endif 36*cdf0e10cSrcweir #include <tools/debug.hxx> 37*cdf0e10cSrcweir #include <vcl/svapp.hxx> 38*cdf0e10cSrcweir #include <vos/socket.hxx> 39*cdf0e10cSrcweir #include <tools/stream.hxx> 40*cdf0e10cSrcweir #include <vcl/timer.hxx> 41*cdf0e10cSrcweir #include <tools/fsys.hxx> 42*cdf0e10cSrcweir 43*cdf0e10cSrcweir #include <automation/communi.hxx> 44*cdf0e10cSrcweir 45*cdf0e10cSrcweir 46*cdf0e10cSrcweir /* Um den Destruktor protected zu machen wurde unten das delete entfernt. 47*cdf0e10cSrcweir Die Methode wird ohnehin hucht benutzt. 48*cdf0e10cSrcweir // delete *((AE*)pData+n); 49*cdf0e10cSrcweir */ 50*cdf0e10cSrcweir 51*cdf0e10cSrcweir #undef SV_IMPL_PTRARR_SORT 52*cdf0e10cSrcweir #define SV_IMPL_PTRARR_SORT( nm,AE )\ 53*cdf0e10cSrcweir _SV_IMPL_SORTAR_ALG( nm,AE )\ 54*cdf0e10cSrcweir void nm::DeleteAndDestroy( sal_uInt16 nP, sal_uInt16 nL ) { \ 55*cdf0e10cSrcweir if( nL ) {\ 56*cdf0e10cSrcweir DBG_ASSERT( nP < nA && nP + nL <= nA, "ERR_VAR_DEL" );\ 57*cdf0e10cSrcweir for( sal_uInt16 n=nP; n < nP + nL; n++ ) \ 58*cdf0e10cSrcweir DBG_ERROR("Das Element der Liste wurde nicht gel�scht"); \ 59*cdf0e10cSrcweir SvPtrarr::Remove( nP, nL ); \ 60*cdf0e10cSrcweir } \ 61*cdf0e10cSrcweir } \ 62*cdf0e10cSrcweir _SV_SEEK_PTR( nm, AE ) 63*cdf0e10cSrcweir 64*cdf0e10cSrcweir 65*cdf0e10cSrcweir 66*cdf0e10cSrcweir 67*cdf0e10cSrcweir SV_IMPL_PTRARR_SORT( CommunicationLinkList, CommunicationLink* ); 68*cdf0e10cSrcweir 69*cdf0e10cSrcweir vos::OMutex *pMPostUserEvent=NULL; // Notwendig, da nicht threadfest 70*cdf0e10cSrcweir 71*cdf0e10cSrcweir CommunicationLinkViaSocket::CommunicationLinkViaSocket( CommunicationManager *pMan, vos::OStreamSocket *pSocket ) 72*cdf0e10cSrcweir : SimpleCommunicationLinkViaSocket( pMan, pSocket ) 73*cdf0e10cSrcweir , nConnectionClosedEventId( 0 ) 74*cdf0e10cSrcweir , nDataReceivedEventId( 0 ) 75*cdf0e10cSrcweir , bShutdownStarted( sal_False ) 76*cdf0e10cSrcweir , bDestroying( sal_False ) 77*cdf0e10cSrcweir { 78*cdf0e10cSrcweir SetPutDataReceivedHdl(LINK( this, CommunicationLinkViaSocket, PutDataReceivedHdl )); 79*cdf0e10cSrcweir if ( !pMPostUserEvent ) 80*cdf0e10cSrcweir pMPostUserEvent = new vos::OMutex; 81*cdf0e10cSrcweir // this is necassary to prevent the running thread from sending the close event 82*cdf0e10cSrcweir // before the open event has been sent. 83*cdf0e10cSrcweir StartCallback(); 84*cdf0e10cSrcweir 85*cdf0e10cSrcweir create(); 86*cdf0e10cSrcweir } 87*cdf0e10cSrcweir 88*cdf0e10cSrcweir CommunicationLinkViaSocket::~CommunicationLinkViaSocket() 89*cdf0e10cSrcweir { 90*cdf0e10cSrcweir bDestroying = sal_True; 91*cdf0e10cSrcweir StopCommunication(); 92*cdf0e10cSrcweir while ( nConnectionClosedEventId || nDataReceivedEventId ) 93*cdf0e10cSrcweir GetpApp()->Yield(); 94*cdf0e10cSrcweir { 95*cdf0e10cSrcweir vos::OGuard aGuard( aMConnectionClosed ); 96*cdf0e10cSrcweir if ( nConnectionClosedEventId ) 97*cdf0e10cSrcweir { 98*cdf0e10cSrcweir GetpApp()->RemoveUserEvent( nConnectionClosedEventId ); 99*cdf0e10cSrcweir nConnectionClosedEventId = 0; 100*cdf0e10cSrcweir INFO_MSG( CByteString("Event gel�scht"), 101*cdf0e10cSrcweir CByteString( "ConnectionClosedEvent aus Queue gel�scht"), 102*cdf0e10cSrcweir CM_MISC, NULL ); 103*cdf0e10cSrcweir } 104*cdf0e10cSrcweir } 105*cdf0e10cSrcweir { 106*cdf0e10cSrcweir vos::OGuard aGuard( aMDataReceived ); 107*cdf0e10cSrcweir if ( nDataReceivedEventId ) 108*cdf0e10cSrcweir { 109*cdf0e10cSrcweir GetpApp()->RemoveUserEvent( nDataReceivedEventId ); 110*cdf0e10cSrcweir nDataReceivedEventId = 0; 111*cdf0e10cSrcweir delete GetServiceData(); 112*cdf0e10cSrcweir INFO_MSG( CByteString("Event gel�scht"), 113*cdf0e10cSrcweir CByteString( "DataReceivedEvent aus Queue gel�scht"), 114*cdf0e10cSrcweir CM_MISC, NULL ); 115*cdf0e10cSrcweir } 116*cdf0e10cSrcweir } 117*cdf0e10cSrcweir } 118*cdf0e10cSrcweir 119*cdf0e10cSrcweir sal_Bool CommunicationLinkViaSocket::ShutdownCommunication() 120*cdf0e10cSrcweir { 121*cdf0e10cSrcweir if ( isRunning() ) 122*cdf0e10cSrcweir { 123*cdf0e10cSrcweir 124*cdf0e10cSrcweir terminate(); 125*cdf0e10cSrcweir if ( GetStreamSocket() ) 126*cdf0e10cSrcweir GetStreamSocket()->shutdown(); 127*cdf0e10cSrcweir 128*cdf0e10cSrcweir if ( GetStreamSocket() ) // Mal wieder nach oben verschoben, da sonst nicht vom Read runtergesprungen wird. 129*cdf0e10cSrcweir GetStreamSocket()->close(); 130*cdf0e10cSrcweir 131*cdf0e10cSrcweir resume(); // So da� das run auch die Schleife verlassen kann 132*cdf0e10cSrcweir 133*cdf0e10cSrcweir join(); 134*cdf0e10cSrcweir 135*cdf0e10cSrcweir vos::OStreamSocket *pTempSocket = GetStreamSocket(); 136*cdf0e10cSrcweir SetStreamSocket( NULL ); 137*cdf0e10cSrcweir delete pTempSocket; 138*cdf0e10cSrcweir 139*cdf0e10cSrcweir // ConnectionClosed(); Wird am Ende des Thread gerufen 140*cdf0e10cSrcweir 141*cdf0e10cSrcweir } 142*cdf0e10cSrcweir else 143*cdf0e10cSrcweir { 144*cdf0e10cSrcweir join(); 145*cdf0e10cSrcweir } 146*cdf0e10cSrcweir 147*cdf0e10cSrcweir return sal_True; 148*cdf0e10cSrcweir } 149*cdf0e10cSrcweir 150*cdf0e10cSrcweir sal_Bool CommunicationLinkViaSocket::StopCommunication() 151*cdf0e10cSrcweir { 152*cdf0e10cSrcweir if ( !bShutdownStarted ) 153*cdf0e10cSrcweir { 154*cdf0e10cSrcweir return SimpleCommunicationLinkViaSocket::StopCommunication(); 155*cdf0e10cSrcweir } 156*cdf0e10cSrcweir else 157*cdf0e10cSrcweir { 158*cdf0e10cSrcweir WaitForShutdown(); 159*cdf0e10cSrcweir return sal_True; 160*cdf0e10cSrcweir } 161*cdf0e10cSrcweir } 162*cdf0e10cSrcweir 163*cdf0e10cSrcweir 164*cdf0e10cSrcweir IMPL_LINK( CommunicationLinkViaSocket, ShutdownLink, void*, EMPTYARG ) 165*cdf0e10cSrcweir { 166*cdf0e10cSrcweir if ( !IsCommunicationError() ) 167*cdf0e10cSrcweir ShutdownCommunication(); 168*cdf0e10cSrcweir return 0; 169*cdf0e10cSrcweir } 170*cdf0e10cSrcweir 171*cdf0e10cSrcweir 172*cdf0e10cSrcweir void CommunicationLinkViaSocket::WaitForShutdown() 173*cdf0e10cSrcweir { 174*cdf0e10cSrcweir if ( !bShutdownStarted ) 175*cdf0e10cSrcweir { 176*cdf0e10cSrcweir aShutdownTimer.SetTimeout( 30000 ); // Should be 30 Seconds 177*cdf0e10cSrcweir aShutdownTimer.SetTimeoutHdl( LINK( this, CommunicationLinkViaSocket, ShutdownLink ) ); 178*cdf0e10cSrcweir aShutdownTimer.Start(); 179*cdf0e10cSrcweir bShutdownStarted = sal_True; 180*cdf0e10cSrcweir } 181*cdf0e10cSrcweir if ( bDestroying ) 182*cdf0e10cSrcweir { 183*cdf0e10cSrcweir while ( pMyManager && aShutdownTimer.IsActive() ) 184*cdf0e10cSrcweir { 185*cdf0e10cSrcweir if ( IsCommunicationError() ) 186*cdf0e10cSrcweir return; 187*cdf0e10cSrcweir GetpApp()->Yield(); 188*cdf0e10cSrcweir } 189*cdf0e10cSrcweir ShutdownCommunication(); 190*cdf0e10cSrcweir } 191*cdf0e10cSrcweir } 192*cdf0e10cSrcweir 193*cdf0e10cSrcweir sal_Bool CommunicationLinkViaSocket::IsCommunicationError() 194*cdf0e10cSrcweir { 195*cdf0e10cSrcweir return !isRunning() || SimpleCommunicationLinkViaSocket::IsCommunicationError(); 196*cdf0e10cSrcweir } 197*cdf0e10cSrcweir 198*cdf0e10cSrcweir void CommunicationLinkViaSocket::run() 199*cdf0e10cSrcweir { 200*cdf0e10cSrcweir sal_Bool bWasError = sal_False; 201*cdf0e10cSrcweir while ( schedule() && !bWasError && GetStreamSocket() ) 202*cdf0e10cSrcweir { 203*cdf0e10cSrcweir if ( bWasError |= !DoReceiveDataStream() ) 204*cdf0e10cSrcweir continue; 205*cdf0e10cSrcweir 206*cdf0e10cSrcweir TimeValue sNochEins = {0, 1000000}; 207*cdf0e10cSrcweir while ( schedule() && bIsInsideCallback ) // solange der letzte Callback nicht beendet ist 208*cdf0e10cSrcweir sleep( sNochEins ); 209*cdf0e10cSrcweir SetNewPacketAsCurrent(); 210*cdf0e10cSrcweir StartCallback(); 211*cdf0e10cSrcweir { 212*cdf0e10cSrcweir vos::OGuard aGuard( aMDataReceived ); 213*cdf0e10cSrcweir vos::OGuard aGuard2( *pMPostUserEvent ); 214*cdf0e10cSrcweir mlPutDataReceived.Call(this); 215*cdf0e10cSrcweir } 216*cdf0e10cSrcweir } 217*cdf0e10cSrcweir TimeValue sNochEins = {0, 1000000}; 218*cdf0e10cSrcweir while ( schedule() && bIsInsideCallback ) // solange der letzte Callback nicht beendet ist 219*cdf0e10cSrcweir sleep( sNochEins ); 220*cdf0e10cSrcweir 221*cdf0e10cSrcweir StartCallback(); 222*cdf0e10cSrcweir { 223*cdf0e10cSrcweir vos::OGuard aGuard( aMConnectionClosed ); 224*cdf0e10cSrcweir vos::OGuard aGuard2( *pMPostUserEvent ); 225*cdf0e10cSrcweir nConnectionClosedEventId = GetpApp()->PostUserEvent( LINK( this, CommunicationLinkViaSocket, ConnectionClosed ) ); 226*cdf0e10cSrcweir } 227*cdf0e10cSrcweir } 228*cdf0e10cSrcweir 229*cdf0e10cSrcweir sal_Bool CommunicationLinkViaSocket::DoTransferDataStream( SvStream *pDataStream, CMProtocol nProtocol ) 230*cdf0e10cSrcweir { 231*cdf0e10cSrcweir if ( !isRunning() ) 232*cdf0e10cSrcweir return sal_False; 233*cdf0e10cSrcweir 234*cdf0e10cSrcweir return SimpleCommunicationLinkViaSocket::DoTransferDataStream( pDataStream, nProtocol ); 235*cdf0e10cSrcweir } 236*cdf0e10cSrcweir 237*cdf0e10cSrcweir /// Dies ist ein virtueller Link!!! 238*cdf0e10cSrcweir long CommunicationLinkViaSocket::ConnectionClosed( void* EMPTYARG ) 239*cdf0e10cSrcweir { 240*cdf0e10cSrcweir { 241*cdf0e10cSrcweir vos::OGuard aGuard( aMConnectionClosed ); 242*cdf0e10cSrcweir nConnectionClosedEventId = 0; // Achtung!! alles andere mu� oben gemacht werden. 243*cdf0e10cSrcweir } 244*cdf0e10cSrcweir ShutdownCommunication(); 245*cdf0e10cSrcweir return CommunicationLink::ConnectionClosed( ); 246*cdf0e10cSrcweir } 247*cdf0e10cSrcweir 248*cdf0e10cSrcweir /// Dies ist ein virtueller Link!!! 249*cdf0e10cSrcweir long CommunicationLinkViaSocket::DataReceived( void* EMPTYARG ) 250*cdf0e10cSrcweir { 251*cdf0e10cSrcweir { 252*cdf0e10cSrcweir vos::OGuard aGuard( aMDataReceived ); 253*cdf0e10cSrcweir nDataReceivedEventId = 0; // Achtung!! alles andere mu� oben gemacht werden. 254*cdf0e10cSrcweir } 255*cdf0e10cSrcweir return CommunicationLink::DataReceived( ); 256*cdf0e10cSrcweir } 257*cdf0e10cSrcweir 258*cdf0e10cSrcweir IMPL_LINK( CommunicationLinkViaSocket, PutDataReceivedHdl, CommunicationLinkViaSocket*, EMPTYARG ) 259*cdf0e10cSrcweir { 260*cdf0e10cSrcweir nDataReceivedEventId = GetpApp()->PostUserEvent( LINK( this, CommunicationLink, DataReceived ) ); 261*cdf0e10cSrcweir return 0; 262*cdf0e10cSrcweir } 263*cdf0e10cSrcweir 264*cdf0e10cSrcweir 265*cdf0e10cSrcweir 266*cdf0e10cSrcweir MultiCommunicationManager::MultiCommunicationManager( sal_Bool bUseMultiChannel ) 267*cdf0e10cSrcweir : CommunicationManager( bUseMultiChannel ) 268*cdf0e10cSrcweir , bGracefullShutdown( sal_True ) 269*cdf0e10cSrcweir { 270*cdf0e10cSrcweir ActiveLinks = new CommunicationLinkList; 271*cdf0e10cSrcweir InactiveLinks = new CommunicationLinkList; 272*cdf0e10cSrcweir } 273*cdf0e10cSrcweir 274*cdf0e10cSrcweir MultiCommunicationManager::~MultiCommunicationManager() 275*cdf0e10cSrcweir { 276*cdf0e10cSrcweir StopCommunication(); 277*cdf0e10cSrcweir 278*cdf0e10cSrcweir if ( bGracefullShutdown ) // first try to collect all callbacks for closing channels 279*cdf0e10cSrcweir { 280*cdf0e10cSrcweir Timer aTimeout; 281*cdf0e10cSrcweir aTimeout.SetTimeout( 40000 ); 282*cdf0e10cSrcweir aTimeout.Start(); 283*cdf0e10cSrcweir sal_uInt16 nLinkCount = 0; 284*cdf0e10cSrcweir sal_uInt16 nNewLinkCount = 0; 285*cdf0e10cSrcweir while ( aTimeout.IsActive() ) 286*cdf0e10cSrcweir { 287*cdf0e10cSrcweir GetpApp()->Yield(); 288*cdf0e10cSrcweir nNewLinkCount = GetCommunicationLinkCount(); 289*cdf0e10cSrcweir if ( nNewLinkCount == 0 ) 290*cdf0e10cSrcweir aTimeout.Stop(); 291*cdf0e10cSrcweir if ( nNewLinkCount != nLinkCount ) 292*cdf0e10cSrcweir { 293*cdf0e10cSrcweir aTimeout.Start(); 294*cdf0e10cSrcweir nLinkCount = nNewLinkCount; 295*cdf0e10cSrcweir } 296*cdf0e10cSrcweir } 297*cdf0e10cSrcweir } 298*cdf0e10cSrcweir 299*cdf0e10cSrcweir // Alles weghauen, was nicht rechtzeitig auf die B�ume gekommen ist 300*cdf0e10cSrcweir // Was bei StopCommunication �brig geblieben ist, da es sich asynchron austragen wollte 301*cdf0e10cSrcweir sal_uInt16 i = ActiveLinks->Count(); 302*cdf0e10cSrcweir while ( i-- ) 303*cdf0e10cSrcweir { 304*cdf0e10cSrcweir CommunicationLinkRef rTempLink = ActiveLinks->GetObject( i ); 305*cdf0e10cSrcweir ActiveLinks->Remove( i ); 306*cdf0e10cSrcweir rTempLink->InvalidateManager(); 307*cdf0e10cSrcweir rTempLink->ReleaseReference(); 308*cdf0e10cSrcweir } 309*cdf0e10cSrcweir delete ActiveLinks; 310*cdf0e10cSrcweir 311*cdf0e10cSrcweir /// Die Links zwischen ConnectionClosed und Destruktor. 312*cdf0e10cSrcweir /// Hier NICHT gerefcounted, da sie sich sonst im Kreis festhaten w�rden, 313*cdf0e10cSrcweir /// da die Links sich erst in ihrem Destruktor austragen 314*cdf0e10cSrcweir i = InactiveLinks->Count(); 315*cdf0e10cSrcweir while ( i-- ) 316*cdf0e10cSrcweir { 317*cdf0e10cSrcweir CommunicationLinkRef rTempLink = InactiveLinks->GetObject( i ); 318*cdf0e10cSrcweir InactiveLinks->Remove( i ); 319*cdf0e10cSrcweir rTempLink->InvalidateManager(); 320*cdf0e10cSrcweir } 321*cdf0e10cSrcweir delete InactiveLinks; 322*cdf0e10cSrcweir } 323*cdf0e10cSrcweir 324*cdf0e10cSrcweir sal_Bool MultiCommunicationManager::StopCommunication() 325*cdf0e10cSrcweir { 326*cdf0e10cSrcweir // Alle Verbindungen abbrechen 327*cdf0e10cSrcweir // ConnectionClosed entfernt die Links aus der Liste. Je nach Implementation syncron 328*cdf0e10cSrcweir // oder asyncron. Daher Von oben nach unten Abr�umen, so da� sich nichts verschiebt. 329*cdf0e10cSrcweir sal_uInt16 i = ActiveLinks->Count(); 330*cdf0e10cSrcweir int nFail = 0; 331*cdf0e10cSrcweir while ( i ) 332*cdf0e10cSrcweir { 333*cdf0e10cSrcweir if ( !ActiveLinks->GetObject(i-1)->StopCommunication() ) 334*cdf0e10cSrcweir nFail++; // Hochz�hlen, da Verbindung sich nicht (sofort) beenden l�sst. 335*cdf0e10cSrcweir i--; 336*cdf0e10cSrcweir } 337*cdf0e10cSrcweir 338*cdf0e10cSrcweir return nFail == 0; 339*cdf0e10cSrcweir } 340*cdf0e10cSrcweir 341*cdf0e10cSrcweir sal_Bool MultiCommunicationManager::IsLinkValid( CommunicationLink* pCL ) 342*cdf0e10cSrcweir { 343*cdf0e10cSrcweir if ( ActiveLinks->Seek_Entry( pCL ) ) 344*cdf0e10cSrcweir return sal_True; 345*cdf0e10cSrcweir else 346*cdf0e10cSrcweir return sal_False; 347*cdf0e10cSrcweir } 348*cdf0e10cSrcweir 349*cdf0e10cSrcweir sal_uInt16 MultiCommunicationManager::GetCommunicationLinkCount() 350*cdf0e10cSrcweir { 351*cdf0e10cSrcweir return ActiveLinks->Count(); 352*cdf0e10cSrcweir } 353*cdf0e10cSrcweir 354*cdf0e10cSrcweir CommunicationLinkRef MultiCommunicationManager::GetCommunicationLink( sal_uInt16 nNr ) 355*cdf0e10cSrcweir { 356*cdf0e10cSrcweir return ActiveLinks->GetObject( nNr ); 357*cdf0e10cSrcweir } 358*cdf0e10cSrcweir 359*cdf0e10cSrcweir void MultiCommunicationManager::CallConnectionOpened( CommunicationLink* pCL ) 360*cdf0e10cSrcweir { 361*cdf0e10cSrcweir CommunicationLinkRef rHold(pCL); // H�lt den Zeiger bis zum Ende des calls 362*cdf0e10cSrcweir ActiveLinks->C40_PTR_INSERT(CommunicationLink, pCL); 363*cdf0e10cSrcweir rHold->AddRef(); 364*cdf0e10cSrcweir 365*cdf0e10cSrcweir CommunicationManager::CallConnectionOpened( pCL ); 366*cdf0e10cSrcweir } 367*cdf0e10cSrcweir 368*cdf0e10cSrcweir void MultiCommunicationManager::CallConnectionClosed( CommunicationLink* pCL ) 369*cdf0e10cSrcweir { 370*cdf0e10cSrcweir CommunicationLinkRef rHold(pCL); // H�lt denm Zeiger bis zum Ende des calls 371*cdf0e10cSrcweir 372*cdf0e10cSrcweir CommunicationManager::CallConnectionClosed( pCL ); 373*cdf0e10cSrcweir 374*cdf0e10cSrcweir sal_uInt16 nPos; 375*cdf0e10cSrcweir if ( ActiveLinks->Seek_Entry( pCL, &nPos ) ) 376*cdf0e10cSrcweir { 377*cdf0e10cSrcweir InactiveLinks->C40_PTR_INSERT(CommunicationLink, pCL); // Ohne Reference 378*cdf0e10cSrcweir ActiveLinks->Remove( nPos ); 379*cdf0e10cSrcweir } 380*cdf0e10cSrcweir pCL->ReleaseReference(); 381*cdf0e10cSrcweir 382*cdf0e10cSrcweir bIsCommunicationRunning = ActiveLinks->Count() > 0; 383*cdf0e10cSrcweir // delete pCL; 384*cdf0e10cSrcweir #if OSL_DEBUG_LEVEL > 1 385*cdf0e10cSrcweir rHold->bFlag = sal_True; 386*cdf0e10cSrcweir #endif 387*cdf0e10cSrcweir } 388*cdf0e10cSrcweir 389*cdf0e10cSrcweir void MultiCommunicationManager::DestroyingLink( CommunicationLink *pCL ) 390*cdf0e10cSrcweir { 391*cdf0e10cSrcweir sal_uInt16 nPos; 392*cdf0e10cSrcweir if ( InactiveLinks->Seek_Entry( pCL, &nPos ) ) 393*cdf0e10cSrcweir InactiveLinks->Remove( nPos ); 394*cdf0e10cSrcweir pCL->InvalidateManager(); 395*cdf0e10cSrcweir } 396*cdf0e10cSrcweir 397*cdf0e10cSrcweir 398*cdf0e10cSrcweir 399*cdf0e10cSrcweir CommunicationManagerClient::CommunicationManagerClient( sal_Bool bUseMultiChannel ) 400*cdf0e10cSrcweir : MultiCommunicationManager( bUseMultiChannel ) 401*cdf0e10cSrcweir { 402*cdf0e10cSrcweir ByteString aApplication("Something inside "); 403*cdf0e10cSrcweir aApplication.Append( ByteString( DirEntry( Application::GetAppFileName() ).GetName(), gsl_getSystemTextEncoding() ) ); 404*cdf0e10cSrcweir SetApplication( aApplication ); 405*cdf0e10cSrcweir } 406*cdf0e10cSrcweir 407*cdf0e10cSrcweir 408*cdf0e10cSrcweir 409*cdf0e10cSrcweir CommunicationManagerServerViaSocket::CommunicationManagerServerViaSocket( sal_uLong nPort, sal_uInt16 nMaxCon, sal_Bool bUseMultiChannel ) 410*cdf0e10cSrcweir : CommunicationManagerServer( bUseMultiChannel ) 411*cdf0e10cSrcweir , nPortToListen( nPort ) 412*cdf0e10cSrcweir , nMaxConnections( nMaxCon ) 413*cdf0e10cSrcweir , pAcceptThread( NULL ) 414*cdf0e10cSrcweir { 415*cdf0e10cSrcweir } 416*cdf0e10cSrcweir 417*cdf0e10cSrcweir CommunicationManagerServerViaSocket::~CommunicationManagerServerViaSocket() 418*cdf0e10cSrcweir { 419*cdf0e10cSrcweir StopCommunication(); 420*cdf0e10cSrcweir } 421*cdf0e10cSrcweir 422*cdf0e10cSrcweir sal_Bool CommunicationManagerServerViaSocket::StartCommunication() 423*cdf0e10cSrcweir { 424*cdf0e10cSrcweir if ( !pAcceptThread ) 425*cdf0e10cSrcweir pAcceptThread = new CommunicationManagerServerAcceptThread( this, nPortToListen, nMaxConnections ); 426*cdf0e10cSrcweir return sal_True; 427*cdf0e10cSrcweir } 428*cdf0e10cSrcweir 429*cdf0e10cSrcweir 430*cdf0e10cSrcweir sal_Bool CommunicationManagerServerViaSocket::StopCommunication() 431*cdf0e10cSrcweir { 432*cdf0e10cSrcweir // Erst den Acceptor anhalten 433*cdf0e10cSrcweir delete pAcceptThread; 434*cdf0e10cSrcweir pAcceptThread = NULL; 435*cdf0e10cSrcweir 436*cdf0e10cSrcweir // Dann alle Verbindungen kappen 437*cdf0e10cSrcweir return CommunicationManagerServer::StopCommunication(); 438*cdf0e10cSrcweir } 439*cdf0e10cSrcweir 440*cdf0e10cSrcweir 441*cdf0e10cSrcweir void CommunicationManagerServerViaSocket::AddConnection( CommunicationLink *pNewConnection ) 442*cdf0e10cSrcweir { 443*cdf0e10cSrcweir CallConnectionOpened( pNewConnection ); 444*cdf0e10cSrcweir } 445*cdf0e10cSrcweir 446*cdf0e10cSrcweir 447*cdf0e10cSrcweir CommunicationManagerServerAcceptThread::CommunicationManagerServerAcceptThread( CommunicationManagerServerViaSocket* pServer, sal_uLong nPort, sal_uInt16 nMaxCon ) 448*cdf0e10cSrcweir : pMyServer( pServer ) 449*cdf0e10cSrcweir , pAcceptorSocket( NULL ) 450*cdf0e10cSrcweir , nPortToListen( nPort ) 451*cdf0e10cSrcweir , nMaxConnections( nMaxCon ) 452*cdf0e10cSrcweir , nAddConnectionEventId( 0 ) 453*cdf0e10cSrcweir , xmNewConnection( NULL ) 454*cdf0e10cSrcweir { 455*cdf0e10cSrcweir if ( !pMPostUserEvent ) 456*cdf0e10cSrcweir pMPostUserEvent = new vos::OMutex; 457*cdf0e10cSrcweir create(); 458*cdf0e10cSrcweir } 459*cdf0e10cSrcweir 460*cdf0e10cSrcweir 461*cdf0e10cSrcweir CommunicationManagerServerAcceptThread::~CommunicationManagerServerAcceptThread() 462*cdf0e10cSrcweir { 463*cdf0e10cSrcweir #ifndef aUNX // Weil das Accept nicht abgebrochen werden kann, so terminiert wenigstens das Prog 464*cdf0e10cSrcweir // #62855# pl: gilt auch bei anderen Unixen 465*cdf0e10cSrcweir // die richtige Loesung waere natuerlich, etwas auf die pipe zu schreiben, 466*cdf0e10cSrcweir // was der thread als Abbruchbedingung erkennt 467*cdf0e10cSrcweir // oder wenigstens ein kill anstatt join 468*cdf0e10cSrcweir terminate(); 469*cdf0e10cSrcweir if ( pAcceptorSocket ) 470*cdf0e10cSrcweir pAcceptorSocket->close(); // Dann das Accept unterbrechen 471*cdf0e10cSrcweir 472*cdf0e10cSrcweir join(); // Warten bis fertig 473*cdf0e10cSrcweir 474*cdf0e10cSrcweir if ( pAcceptorSocket ) 475*cdf0e10cSrcweir { 476*cdf0e10cSrcweir delete pAcceptorSocket; 477*cdf0e10cSrcweir pAcceptorSocket = NULL; 478*cdf0e10cSrcweir } 479*cdf0e10cSrcweir #else 480*cdf0e10cSrcweir DEBUGPRINTF ("Destructor CommunicationManagerServerAcceptThread �bersprungen!!!! (wegen Solaris BUG)\n"); 481*cdf0e10cSrcweir #endif 482*cdf0e10cSrcweir { 483*cdf0e10cSrcweir vos::OGuard aGuard( aMAddConnection ); 484*cdf0e10cSrcweir if ( nAddConnectionEventId ) 485*cdf0e10cSrcweir { 486*cdf0e10cSrcweir GetpApp()->RemoveUserEvent( nAddConnectionEventId ); 487*cdf0e10cSrcweir nAddConnectionEventId = 0; 488*cdf0e10cSrcweir CommunicationLinkRef xNewConnection = GetNewConnection(); 489*cdf0e10cSrcweir INFO_MSG( CByteString("Event gel�scht"), 490*cdf0e10cSrcweir CByteString( "AddConnectionEvent aus Queue gel�scht"), 491*cdf0e10cSrcweir CM_MISC, xNewConnection ); 492*cdf0e10cSrcweir xNewConnection->InvalidateManager(); 493*cdf0e10cSrcweir xNewConnection.Clear(); // sollte das Objekt hier l�schen 494*cdf0e10cSrcweir } 495*cdf0e10cSrcweir } 496*cdf0e10cSrcweir } 497*cdf0e10cSrcweir 498*cdf0e10cSrcweir void CommunicationManagerServerAcceptThread::run() 499*cdf0e10cSrcweir { 500*cdf0e10cSrcweir if ( !nPortToListen ) 501*cdf0e10cSrcweir return; 502*cdf0e10cSrcweir 503*cdf0e10cSrcweir pAcceptorSocket = new vos::OAcceptorSocket(); 504*cdf0e10cSrcweir vos::OInetSocketAddr Addr; 505*cdf0e10cSrcweir Addr.setPort( nPortToListen ); 506*cdf0e10cSrcweir pAcceptorSocket->setReuseAddr( 1 ); 507*cdf0e10cSrcweir if ( !pAcceptorSocket->bind( Addr ) ) 508*cdf0e10cSrcweir { 509*cdf0e10cSrcweir return; 510*cdf0e10cSrcweir } 511*cdf0e10cSrcweir if ( !pAcceptorSocket->listen( nMaxConnections ) ) 512*cdf0e10cSrcweir { 513*cdf0e10cSrcweir return; 514*cdf0e10cSrcweir } 515*cdf0e10cSrcweir 516*cdf0e10cSrcweir 517*cdf0e10cSrcweir vos::OStreamSocket *pStreamSocket = NULL; 518*cdf0e10cSrcweir 519*cdf0e10cSrcweir while ( schedule() ) 520*cdf0e10cSrcweir { 521*cdf0e10cSrcweir pStreamSocket = new vos::OStreamSocket; 522*cdf0e10cSrcweir switch ( pAcceptorSocket->acceptConnection( *pStreamSocket ) ) 523*cdf0e10cSrcweir { 524*cdf0e10cSrcweir case vos::ISocketTypes::TResult_Ok: 525*cdf0e10cSrcweir { 526*cdf0e10cSrcweir pStreamSocket->setTcpNoDelay( 1 ); 527*cdf0e10cSrcweir 528*cdf0e10cSrcweir TimeValue sNochEins = {0, 100}; 529*cdf0e10cSrcweir while ( schedule() && xmNewConnection.Is() ) // Solange die letzte Connection nicht abgeholt wurde warten wir 530*cdf0e10cSrcweir sleep( sNochEins ); 531*cdf0e10cSrcweir xmNewConnection = new CommunicationLinkViaSocket( pMyServer, pStreamSocket ); 532*cdf0e10cSrcweir xmNewConnection->StartCallback(); 533*cdf0e10cSrcweir { 534*cdf0e10cSrcweir vos::OGuard aGuard( aMAddConnection ); 535*cdf0e10cSrcweir vos::OGuard aGuard2( *pMPostUserEvent ); 536*cdf0e10cSrcweir nAddConnectionEventId = GetpApp()->PostUserEvent( LINK( this, CommunicationManagerServerAcceptThread, AddConnection ) ); 537*cdf0e10cSrcweir } 538*cdf0e10cSrcweir } 539*cdf0e10cSrcweir break; 540*cdf0e10cSrcweir case vos::ISocketTypes::TResult_TimedOut: 541*cdf0e10cSrcweir delete pStreamSocket; 542*cdf0e10cSrcweir pStreamSocket = NULL; 543*cdf0e10cSrcweir break; 544*cdf0e10cSrcweir case vos::ISocketTypes::TResult_Error: 545*cdf0e10cSrcweir delete pStreamSocket; 546*cdf0e10cSrcweir pStreamSocket = NULL; 547*cdf0e10cSrcweir break; 548*cdf0e10cSrcweir 549*cdf0e10cSrcweir case vos::ISocketTypes::TResult_Interrupted: 550*cdf0e10cSrcweir case vos::ISocketTypes::TResult_InProgress: 551*cdf0e10cSrcweir break; // -Wall not handled... 552*cdf0e10cSrcweir } 553*cdf0e10cSrcweir } 554*cdf0e10cSrcweir } 555*cdf0e10cSrcweir 556*cdf0e10cSrcweir 557*cdf0e10cSrcweir IMPL_LINK( CommunicationManagerServerAcceptThread, AddConnection, void*, EMPTYARG ) 558*cdf0e10cSrcweir { 559*cdf0e10cSrcweir { 560*cdf0e10cSrcweir vos::OGuard aGuard( aMAddConnection ); 561*cdf0e10cSrcweir nAddConnectionEventId = 0; 562*cdf0e10cSrcweir } 563*cdf0e10cSrcweir pMyServer->AddConnection( xmNewConnection ); 564*cdf0e10cSrcweir xmNewConnection.Clear(); 565*cdf0e10cSrcweir return 1; 566*cdf0e10cSrcweir } 567*cdf0e10cSrcweir 568*cdf0e10cSrcweir 569*cdf0e10cSrcweir #define GETSET(aVar, KeyName, Dafault) \ 570*cdf0e10cSrcweir aVar = aConf.ReadKey(KeyName,"No Entry"); \ 571*cdf0e10cSrcweir if ( aVar == "No Entry" ) \ 572*cdf0e10cSrcweir { \ 573*cdf0e10cSrcweir aVar = Dafault; \ 574*cdf0e10cSrcweir aConf.WriteKey(KeyName, aVar); \ 575*cdf0e10cSrcweir } 576*cdf0e10cSrcweir 577*cdf0e10cSrcweir 578*cdf0e10cSrcweir CommunicationManagerClientViaSocket::CommunicationManagerClientViaSocket( ByteString aHost, sal_uLong nPort, sal_Bool bUseMultiChannel ) 579*cdf0e10cSrcweir : CommunicationManagerClient( bUseMultiChannel ) 580*cdf0e10cSrcweir , aHostToTalk( aHost ) 581*cdf0e10cSrcweir , nPortToTalk( nPort ) 582*cdf0e10cSrcweir { 583*cdf0e10cSrcweir } 584*cdf0e10cSrcweir 585*cdf0e10cSrcweir CommunicationManagerClientViaSocket::CommunicationManagerClientViaSocket( sal_Bool bUseMultiChannel ) 586*cdf0e10cSrcweir : CommunicationManagerClient( bUseMultiChannel ) 587*cdf0e10cSrcweir , aHostToTalk( "" ) 588*cdf0e10cSrcweir , nPortToTalk( 0 ) 589*cdf0e10cSrcweir { 590*cdf0e10cSrcweir } 591*cdf0e10cSrcweir 592*cdf0e10cSrcweir CommunicationManagerClientViaSocket::~CommunicationManagerClientViaSocket() 593*cdf0e10cSrcweir { 594*cdf0e10cSrcweir } 595*cdf0e10cSrcweir 596*cdf0e10cSrcweir 597