svl/source/svdde/ddecli.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  *
   9  * This file incorporates work covered by the following license notice:
  10  *
  11  *   Licensed to the Apache Software Foundation (ASF) under one or more
  12  *   contributor license agreements. See the NOTICE file distributed
  13  *   with this work for additional information regarding copyright
  14  *   ownership. The ASF licenses this file to you under the Apache
  15  *   License, Version 2.0 (the "License"); you may not use this file
  16  *   except in compliance with the License. You may obtain a copy of
  17  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  18  */
  19
  20
  21 #define UNICODE
  22 #include <string.h>
  23 #include <algorithm>
  24 #include "ddeimp.hxx"
  25 #include <svl/svdde.hxx>
  26
  27 #include <osl/thread.h>
  28 #include <tools/debug.hxx>
  29 #include <tools/solarmutex.hxx>
  30 #include <osl/mutex.hxx>
  31
  32 DdeInstData* ImpInitInstData()
  33 {
  34     DdeInstData* pData = new DdeInstData;
  35
  36     DdeInstData** ppInst = (DdeInstData**)GetAppData( SHL_SVDDE );
  37     *ppInst = pData;
  38     return pData;
  39 }
  40
  41 void ImpDeinitInstData()
  42 {
  43     DdeInstData** ppInst = (DdeInstData**)GetAppData( SHL_SVDDE );
  44     delete (*ppInst);
  45     *ppInst = 0;
  46 }
  47
  48
  49 struct DdeImp
  50 {
  51     HCONV   hConv;
  52     long    nStatus;
  53 };
  54
  55 // --- DdeInternat::CliCallback() ----------------------------------
  56
  57 HDDEDATA CALLBACK DdeInternal::CliCallback( WORD nCode, WORD nCbType,
  58                                             HCONV hConv, HSZ, HSZ hText2,
  59                                             HDDEDATA hData, DWORD nInfo1, DWORD )
  60 {
  61     HDDEDATA nRet = DDE_FNOTPROCESSED;
  62     const std::vector<DdeConnection*> &rAll = DdeConnection::GetConnections();
  63     DdeConnection*      self = 0;
  64
  65     DdeInstData* pInst = ImpGetInstData();
  66     DBG_ASSERT(pInst,"SVDDE:No instance data");
  67
  68     for ( size_t i = 0; i < rAll.size(); ++i)
  69     {
  70         self = rAll[i];
  71
  72         if ( self->pImp->hConv == hConv )
  73             break;
  74     }
  75
  76     if( self )
  77     {
  78         bool bFound = false;
  79         std::vector<DdeTransaction*>::iterator iter;
  80         for( iter = self->aTransactions.begin(); iter != self->aTransactions.end(); ++iter )
  81         {
  82             switch( nCode )
  83             {
  84             case XTYP_XACT_COMPLETE:
  85                 if( (DWORD)(*iter)->nId == nInfo1 )
  86                 {
  87                     nCode = (*iter)->nType & (XCLASS_MASK | XTYP_MASK);
  88                     (*iter)->bBusy = false;
  89                     (*iter)->Done( 0 != hData );
  90                     bFound = true;
  91                 }
  92                 break;
  93
  94             case XTYP_DISCONNECT:
  95                 self->pImp->hConv = DdeReconnect( hConv );
  96                 self->pImp->nStatus = self->pImp->hConv
  97                     ? DMLERR_NO_ERROR
  98                     : DdeGetLastError( pInst->hDdeInstCli );
  99                 iter = self->aTransactions.end();
 100                 nRet = 0;
 101                 bFound = true;
 102                 break;
 103
 104             case XTYP_ADVDATA:
 105                 bFound = *(*iter)->pName == hText2;
 106                 break;
 107             }
 108             if( bFound )
 109                 break;
 110         }
 111
 112         if( iter != self->aTransactions.end() )
 113         {
 114             switch( nCode )
 115             {
 116             case XTYP_ADVDATA:
 117                 if( !hData )
 118                 {
 119                     static_cast<DdeLink*>(*iter)->Notify();
 120                     nRet = (HDDEDATA)DDE_FACK;
 121                     break;
 122                 }
 123                 // kein break;
 124
 125             case XTYP_REQUEST:
 126                 if( !hData && XTYP_REQUEST == nCode )
 127                 {
 128
 129                 }
 130
 131                 DdeData d;
 132                 d.pImp->hData = hData;
 133                 d.pImp->nFmt  = DdeData::GetInternalFormat( nCbType );
 134                 d.Lock();
 135                 (*iter)->Data( &d );
 136                 nRet = (HDDEDATA)DDE_FACK;
 137                 break;
 138             }
 139         }
 140     }
 141     return nRet;
 142 }
 143
 144 // --- DdeConnection::DdeConnection() ------------------------------
 145
 146 DdeConnection::DdeConnection( const OUString& rService, const OUString& rTopic )
 147 {
 148     pImp = new DdeImp;
 149     pImp->nStatus  = DMLERR_NO_ERROR;
 150     pImp->hConv    = NULL;
 151
 152     DdeInstData* pInst = ImpGetInstData();
 153     if( !pInst )
 154         pInst = ImpInitInstData();
 155     pInst->nRefCount++;
 156     pInst->nInstanceCli++;
 157     if ( !pInst->hDdeInstCli )
 158     {
 159         pImp->nStatus = DdeInitialize( &pInst->hDdeInstCli,
 160                                        (PFNCALLBACK)DdeInternal::CliCallback,
 161                                        APPCLASS_STANDARD | APPCMD_CLIENTONLY |
 162                                        CBF_FAIL_ALLSVRXACTIONS |
 163                                        CBF_SKIP_REGISTRATIONS  |
 164                                        CBF_SKIP_UNREGISTRATIONS, 0L );
 165     }
 166
 167     pService = new DdeString( pInst->hDdeInstCli, rService );
 168     pTopic   = new DdeString( pInst->hDdeInstCli, rTopic );
 169
 170     if ( pImp->nStatus == DMLERR_NO_ERROR )
 171     {
 172         pImp->hConv = DdeConnect( pInst->hDdeInstCli,*pService,*pTopic, NULL);
 173         if( !pImp->hConv )
 174             pImp->nStatus = DdeGetLastError( pInst->hDdeInstCli );
 175     }
 176
 177     pInst->aConnections.push_back( this );
 178 }
 179
 180 // --- DdeConnection::~DdeConnection() -----------------------------
 181
 182 DdeConnection::~DdeConnection()
 183 {
 184     if ( pImp->hConv )
 185         DdeDisconnect( pImp->hConv );
 186
 187     delete pService;
 188     delete pTopic;
 189
 190     DdeInstData* pInst = ImpGetInstData();
 191     DBG_ASSERT(pInst,"SVDDE:No instance data");
 192
 193     std::vector<DdeConnection*>::iterator it(std::find(pInst->aConnections.begin(),
 194                                                         pInst->aConnections.end(),
 195                                                         this));
 196     if (it != pInst->aConnections.end())
 197         pInst->aConnections.erase(it);
 198
 199     pInst->nInstanceCli--;
 200     pInst->nRefCount--;
 201     if ( !pInst->nInstanceCli && pInst->hDdeInstCli )
 202     {
 203         if( DdeUninitialize( pInst->hDdeInstCli ) )
 204         {
 205             pInst->hDdeInstCli = 0;
 206             if( pInst->nRefCount == 0 )
 207                 ImpDeinitInstData();
 208         }
 209     }
 210     delete pImp;
 211 }
 212
 213 // --- DdeConnection::IsConnected() --------------------------------
 214
 215 bool DdeConnection::IsConnected()
 216 {
 217     CONVINFO c;
 218     c.cb = sizeof( c );
 219     if ( DdeQueryConvInfo( pImp->hConv, QID_SYNC, &c ) )
 220         return true;
 221     else
 222     {
 223         DdeInstData* pInst = ImpGetInstData();
 224         pImp->hConv = DdeReconnect( pImp->hConv );
 225         pImp->nStatus = pImp->hConv ? DMLERR_NO_ERROR : DdeGetLastError( pInst->hDdeInstCli );
 226         return pImp->nStatus == DMLERR_NO_ERROR;
 227     }
 228 }
 229
 230 // --- DdeConnection::GetServiceName() -----------------------------
 231
 232 const OUString DdeConnection::GetServiceName()
 233 {
 234     return pService->toOUString();
 235 }
 236
 237 // --- DdeConnection::GetTopicName() -------------------------------
 238
 239 const OUString DdeConnection::GetTopicName()
 240 {
 241     return pTopic->toOUString();
 242 }
 243
 244 // --- DdeConnection::GetConvId() ----------------------------------
 245
 246 sal_IntPtr DdeConnection::GetConvId()
 247 {
 248     return (sal_IntPtr)pImp->hConv;
 249 }
 250
 251 const std::vector<DdeConnection*>& DdeConnection::GetConnections()
 252 {
 253     DdeInstData* pInst = ImpGetInstData();
 254     DBG_ASSERT(pInst,"SVDDE:No instance data");
 255     return pInst->aConnections;
 256 }
 257
 258 // --- DdeTransaction::DdeTransaction() ----------------------------
 259
 260 DdeTransaction::DdeTransaction( DdeConnection& d, const OUString& rItemName,
 261                                 long n )
 262     : rDde( d )
 263 {
 264     DdeInstData* pInst = ImpGetInstData();
 265     pName = new DdeString( pInst->hDdeInstCli, rItemName );
 266     nTime = n;
 267     nId   = 0;
 268     nType = 0;
 269     bBusy = false;
 270
 271     rDde.aTransactions.push_back( this );
 272 }
 273
 274 // --- DdeTransaction::~DdeTransaction() ---------------------------
 275
 276 DdeTransaction::~DdeTransaction()
 277 {
 278     if ( nId && rDde.pImp->hConv )
 279     {
 280         DdeInstData* pInst = ImpGetInstData();
 281         DdeAbandonTransaction( pInst->hDdeInstCli, rDde.pImp->hConv, nId );
 282     }
 283
 284     delete pName;
 285     rDde.aTransactions.erase(std::remove(rDde.aTransactions.begin(),
 286                                          rDde.aTransactions.end(),this));
 287 }
 288
 289 // --- DdeTransaction::Execute() -----------------------------------
 290
 291 void DdeTransaction::Execute()
 292 {
 293     HSZ     hItem = *pName;
 294     void*   pData = (void*)(const void *)aDdeData;
 295     DWORD   nData = (DWORD)(long)aDdeData;
 296     sal_uLong   nIntFmt = aDdeData.pImp->nFmt;
 297     UINT    nExtFmt  = DdeData::GetExternalFormat( nIntFmt );
 298     DdeInstData* pInst = ImpGetInstData();
 299
 300     if ( nType == XTYP_EXECUTE )
 301         hItem = NULL;
 302     if ( nType != XTYP_EXECUTE && nType != XTYP_POKE )
 303     {
 304         pData = NULL;
 305         nData = 0L;
 306     }
 307     if ( nTime )
 308     {
 309         HDDEDATA hData = DdeClientTransaction( (unsigned char*)pData,
 310                                                nData, rDde.pImp->hConv,
 311                                                hItem, nExtFmt, (UINT)nType,
 312                                                (DWORD)nTime, (DWORD FAR*)NULL );
 313
 314         rDde.pImp->nStatus = DdeGetLastError( pInst->hDdeInstCli );
 315         if( hData && nType == XTYP_REQUEST )
 316         {
 317             {
 318                 DdeData d;
 319                 d.pImp->hData = hData;
 320                 d.pImp->nFmt = nIntFmt;
 321                 d.Lock();
 322                 Data( &d );
 323             }
 324             DdeFreeDataHandle( hData );
 325         }
 326     }
 327     else
 328     {
 329         if ( nId && rDde.pImp->hConv )
 330             DdeAbandonTransaction( pInst->hDdeInstCli, rDde.pImp->hConv, nId);
 331         nId = 0;
 332         bBusy = true;
 333         HDDEDATA hRet = DdeClientTransaction( (unsigned char*)pData, nData,
 334                                             rDde.pImp->hConv, hItem, nExtFmt,
 335                                             (UINT)nType, TIMEOUT_ASYNC,
 336                                             (DWORD FAR *) ((long*) &nId) );
 337         rDde.pImp->nStatus = hRet ? DMLERR_NO_ERROR
 338                                   : DdeGetLastError( pInst->hDdeInstCli );
 339     }
 340 }
 341
 342 // --- DdeTransaction::GetName() -----------------------------------
 343
 344 const OUString DdeTransaction::GetName() const
 345 {
 346     return pName->toOUString();
 347 }
 348
 349 // --- DdeTransaction::Data() --------------------------------------
 350
 351
 352 void DdeTransaction::Data( const DdeData* p )
 353 {
 354     if ( ::tools::SolarMutex::Acquire() )
 355     {
 356         aData.Call( (void*)p );
 357         ::tools::SolarMutex::Release();
 358     }
 359 }
 360
 361 // --- DdeTransaction::Done() --------------------------------------
 362
 363 void DdeTransaction::Done( bool bDataValid )
 364 {
 365     const sal_uIntPtr nDataValid(bDataValid);
 366     aDone.Call( reinterpret_cast<void*>(nDataValid) );
 367 }
 368
 369 // --- DdeLink::DdeLink() ------------------------------------------
 370
 371 DdeLink::DdeLink( DdeConnection& d, const OUString& aItemName, long n )
 372     : DdeTransaction (d, aItemName, n)
 373 {
 374 }
 375
 376 // --- DdeLink::~DdeLink() -----------------------------------------
 377
 378 DdeLink::~DdeLink()
 379 {
 380     nType = (sal_uInt16)XTYP_ADVSTOP;
 381     nTime = 0;
 382 }
 383
 384 // --- DdeLink::Notify() -----------------------------------------
 385
 386 void DdeLink::Notify()
 387 {
 388     aNotify.Call( NULL );
 389 }
 390
 391 // --- DdeRequest::DdeRequest() ------------------------------------
 392
 393 DdeRequest::DdeRequest( DdeConnection& d, const OUString& i, long n )
 394     : DdeTransaction( d, i, n )
 395 {
 396     nType = XTYP_REQUEST;
 397 }
 398
 399 // --- DdeWarmLink::DdeWarmLink() ----------------------------------
 400
 401 DdeWarmLink::DdeWarmLink( DdeConnection& d, const OUString& i, long n )
 402     : DdeLink( d, i, n )
 403 {
 404     nType = XTYP_ADVSTART | XTYPF_NODATA;
 405 }
 406
 407 // --- DdeHotLink::DdeHotLink() ------------------------------------
 408
 409 DdeHotLink::DdeHotLink( DdeConnection& d, const OUString& i, long n )
 410     : DdeLink( d, i, n )
 411 {
 412     nType = XTYP_ADVSTART;
 413 }
 414
 415 // --- DdePoke::DdePoke() ------------------------------------------
 416
 417 DdePoke::DdePoke( DdeConnection& d, const OUString& i, const char* p,
 418                   long l, sal_uLong f, long n )
 419     : DdeTransaction( d, i, n )
 420 {
 421     aDdeData = DdeData( p, l, f );
 422     nType = XTYP_POKE;
 423 }
 424
 425 // --- DdePoke::DdePoke() ------------------------------------------
 426
 427 DdePoke::DdePoke( DdeConnection& d, const OUString& i, const OUString& rData,
 428                   long n )
 429     : DdeTransaction( d, i, n )
 430 {
 431     aDdeData = DdeData( (void*) rData.getStr(), sizeof(sal_Unicode) * (rData.getLength()), CF_TEXT );
 432     nType = XTYP_POKE;
 433 }
 434
 435 // --- DdePoke::DdePoke() ------------------------------------------
 436
 437 DdePoke::DdePoke( DdeConnection& d, const OUString& i, const DdeData& rData,
 438                   long n )
 439     : DdeTransaction( d, i, n )
 440 {
 441     aDdeData = rData;
 442     nType = XTYP_POKE;
 443 }
 444
 445 // --- DdeExecute::DdeExecute() ------------------------------------
 446
 447 DdeExecute::DdeExecute( DdeConnection& d, const OUString& rData, long n )
 448     : DdeTransaction( d, OUString(), n )
 449 {
 450     aDdeData = DdeData( (void*)rData.getStr(), sizeof(sal_Unicode) * (rData.getLength() + 1), CF_TEXT );
 451     nType = XTYP_EXECUTE;
 452 }
 453
 454 // --- DdeConnection::GetError() -----------------------------------
 455
 456 long DdeConnection::GetError()
 457 {
 458     return pImp->nStatus;
 459 }
 460
 461 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */