src/msw/dde.cpp

   1 /////////////////////////////////////////////////////////////////////////////
   2 // Name:        msw/dde.cpp
   3 // Purpose:     DDE classes
   4 // Author:      Julian Smart
   5 // Modified by:
   6 // Created:     01/02/97
   7 // RCS-ID:      $Id$
   8 // Copyright:   (c) Julian Smart and Markus Holzem
   9 // Licence:     wxWindows licence
  10 /////////////////////////////////////////////////////////////////////////////
  11
  12 // ============================================================================
  13 // declarations
  14 // ============================================================================
  15
  16 // ----------------------------------------------------------------------------
  17 // headers
  18 // ----------------------------------------------------------------------------
  19
  20 #ifdef __GNUG__
  21     #pragma implementation "dde.h"
  22 #endif
  23
  24 // For compilers that support precompilation, includes "wx.h".
  25 #include "wx/wxprec.h"
  26
  27 #ifdef __BORLANDC__
  28     #pragma hdrstop
  29 #endif
  30
  31 #if wxUSE_IPC
  32
  33 #ifndef WX_PRECOMP
  34     #include "wx/utils.h"
  35     #include "wx/app.h"
  36 #endif
  37
  38 #include "wx/module.h"
  39 #include "wx/dde.h"
  40 #include "wx/intl.h"
  41
  42
  43 #include "wx/msw/private.h"
  44
  45 #include <string.h>
  46 #include <windows.h>
  47 #include <ddeml.h>
  48
  49 #if defined(__TWIN32__) || defined(__GNUWIN32_OLD__)
  50     #include "wx/msw/gnuwin32/extra.h"
  51 #endif
  52
  53 // some compilers headers don't define this one (mingw32)
  54 #ifndef DMLERR_NO_ERROR
  55     #define DMLERR_NO_ERROR (0)
  56
  57     // this one is also missing from some mingw32 headers, but there is no way
  58     // to test for it (I know of) - the test for DMLERR_NO_ERROR works for me,
  59     // but is surely not the right thing to do
  60     extern "C"
  61     HDDEDATA STDCALL DdeClientTransaction(LPBYTE pData,
  62                                           DWORD cbData,
  63                                           HCONV hConv,
  64                                           HSZ hszItem,
  65                                           UINT wFmt,
  66                                           UINT wType,
  67                                           DWORD dwTimeout,
  68                                           LPDWORD pdwResult);
  69 #endif // no DMLERR_NO_ERROR
  70
  71 // ----------------------------------------------------------------------------
  72 // macros and constants
  73 // ----------------------------------------------------------------------------
  74
  75 #ifdef __WIN32__
  76     #define _EXPORT
  77 #else
  78     #define _EXPORT _export
  79 #endif
  80
  81 #if wxUSE_UNICODE
  82     #define DDE_CP      CP_WINUNICODE
  83 #else
  84     #define DDE_CP      CP_WINANSI
  85 #endif
  86
  87 #define GetHConv()       ((HCONV)m_hConv)
  88
  89 // default timeout for DDE operations (5sec)
  90 #define DDE_TIMEOUT     5000
  91
  92 // ----------------------------------------------------------------------------
  93 // private functions
  94 // ----------------------------------------------------------------------------
  95
  96 static wxDDEConnection *DDEFindConnection(HCONV hConv);
  97 static void DDEDeleteConnection(HCONV hConv);
  98 static wxDDEServer *DDEFindServer(const wxString& s);
  99
 100 extern "C" HDDEDATA EXPENTRY _EXPORT _DDECallback(WORD wType,
 101                                                   WORD wFmt,
 102                                                   HCONV hConv,
 103                                                   HSZ hsz1,
 104                                                   HSZ hsz2,
 105                                                   HDDEDATA hData,
 106                                                   DWORD lData1,
 107                                                   DWORD lData2);
 108
 109 // Add topic name to atom table before using in conversations
 110 static HSZ DDEAddAtom(const wxString& string);
 111 static HSZ DDEGetAtom(const wxString& string);
 112
 113 // string handles
 114 static HSZ DDEAtomFromString(const wxString& s);
 115 static wxString DDEStringFromAtom(HSZ hsz);
 116
 117 // error handling
 118 static wxString DDEGetErrorMsg(UINT error);
 119 static void DDELogError(const wxString& s, UINT error = DMLERR_NO_ERROR);
 120
 121 // ----------------------------------------------------------------------------
 122 // global variables
 123 // ----------------------------------------------------------------------------
 124
 125 static DWORD DDEIdInst = 0L;
 126 static wxDDEConnection *DDECurrentlyConnecting = NULL;
 127
 128 static wxList wxAtomTable(wxKEY_STRING);
 129 static wxList wxDDEClientObjects;
 130 static wxList wxDDEServerObjects;
 131
 132 char *DDEDefaultIPCBuffer = NULL;
 133 int DDEDefaultIPCBufferSize = 0;
 134 static bool DDEInitialized = FALSE;
 135
 136 // ----------------------------------------------------------------------------
 137 // private classes
 138 // ----------------------------------------------------------------------------
 139
 140 // A module to allow DDE cleanup without calling these functions
 141 // from app.cpp or from the user's application.
 142
 143 class wxDDEModule : public wxModule
 144 {
 145 public:
 146     wxDDEModule() {}
 147     bool OnInit() { return TRUE; }
 148     void OnExit() { wxDDECleanUp(); }
 149
 150 private:
 151     DECLARE_DYNAMIC_CLASS(wxDDEModule)
 152 };
 153
 154 // ----------------------------------------------------------------------------
 155 // wxWin macros
 156 // ----------------------------------------------------------------------------
 157
 158 IMPLEMENT_DYNAMIC_CLASS(wxDDEServer, wxServerBase)
 159 IMPLEMENT_DYNAMIC_CLASS(wxDDEClient, wxClientBase)
 160 IMPLEMENT_CLASS(wxDDEConnection, wxConnectionBase)
 161 IMPLEMENT_DYNAMIC_CLASS(wxDDEModule, wxModule)
 162
 163 // ============================================================================
 164 // implementation
 165 // ============================================================================
 166
 167 // ----------------------------------------------------------------------------
 168 // initialization and cleanup
 169 // ----------------------------------------------------------------------------
 170
 171 extern void wxDDEInitialize()
 172 {
 173     if ( !DDEInitialized )
 174     {
 175         // Should insert filter flags
 176         PFNCALLBACK callback = (PFNCALLBACK)
 177             MakeProcInstance((FARPROC)_DDECallback, wxGetInstance());
 178         UINT rc = DdeInitialize(&DDEIdInst, callback, APPCLASS_STANDARD, 0L);
 179         if ( rc != DMLERR_NO_ERROR )
 180         {
 181             DDELogError(_T("Failed to initialize DDE"), rc);
 182         }
 183         else
 184         {
 185             DDEInitialized = TRUE;
 186         }
 187     }
 188 }
 189
 190 void wxDDECleanUp()
 191 {
 192     if ( DDEIdInst != 0 )
 193     {
 194         DdeUninitialize(DDEIdInst);
 195         DDEIdInst = 0;
 196     }
 197
 198     delete [] DDEDefaultIPCBuffer;
 199 }
 200
 201 // ----------------------------------------------------------------------------
 202 // functions working with the global connection list(s)
 203 // ----------------------------------------------------------------------------
 204
 205 // Global find connection
 206 static wxDDEConnection *DDEFindConnection(HCONV hConv)
 207 {
 208   wxNode *node = wxDDEServerObjects.First();
 209   wxDDEConnection *found = NULL;
 210   while (node && !found)
 211   {
 212     wxDDEServer *object = (wxDDEServer *)node->Data();
 213     found = object->FindConnection((WXHCONV) hConv);
 214     node = node->Next();
 215   }
 216   if (found)
 217       return found;
 218
 219   node = wxDDEClientObjects.First();
 220   while (node && !found)
 221   {
 222     wxDDEClient *object = (wxDDEClient *)node->Data();
 223     found = object->FindConnection((WXHCONV) hConv);
 224     node = node->Next();
 225   }
 226   return found;
 227 }
 228
 229 // Global delete connection
 230 static void DDEDeleteConnection(HCONV hConv)
 231 {
 232   wxNode *node = wxDDEServerObjects.First();
 233   bool found = FALSE;
 234   while (node && !found)
 235   {
 236     wxDDEServer *object = (wxDDEServer *)node->Data();
 237     found = object->DeleteConnection((WXHCONV) hConv);
 238     node = node->Next();
 239   }
 240   if (found)
 241     return;
 242
 243   node = wxDDEClientObjects.First();
 244   while (node && !found)
 245   {
 246     wxDDEClient *object = (wxDDEClient *)node->Data();
 247     found = object->DeleteConnection((WXHCONV) hConv);
 248     node = node->Next();
 249   }
 250 }
 251
 252 // Find a server from a service name
 253 static wxDDEServer *DDEFindServer(const wxString& s)
 254 {
 255   wxNode *node = wxDDEServerObjects.First();
 256   wxDDEServer *found = NULL;
 257   while (node && !found)
 258   {
 259     wxDDEServer *object = (wxDDEServer *)node->Data();
 260
 261     if (object->GetServiceName() == s)
 262       found = object;
 263     else node = node->Next();
 264   }
 265   return found;
 266 }
 267
 268 // ----------------------------------------------------------------------------
 269 // wxDDEServer
 270 // ----------------------------------------------------------------------------
 271
 272 wxDDEServer::wxDDEServer()
 273 {
 274     wxDDEInitialize();
 275
 276     wxDDEServerObjects.Append(this);
 277 }
 278
 279 bool wxDDEServer::Create(const wxString& server)
 280 {
 281     m_serviceName = server;
 282
 283     if ( !DdeNameService(DDEIdInst, DDEAtomFromString(server), (HSZ)NULL, DNS_REGISTER) )
 284     {
 285         DDELogError(wxString::Format(_("Failed to register DDE server '%s'"),
 286                                      server.c_str()));
 287
 288         return FALSE;
 289     }
 290
 291     return TRUE;
 292 }
 293
 294 wxDDEServer::~wxDDEServer()
 295 {
 296     if ( !!m_serviceName )
 297     {
 298         if ( !DdeNameService(DDEIdInst, DDEAtomFromString(m_serviceName),
 299                              (HSZ)NULL, DNS_UNREGISTER) )
 300         {
 301             DDELogError(wxString::Format(_("Failed to unregister DDE server '%s'"),
 302                                          m_serviceName.c_str()));
 303         }
 304     }
 305
 306     wxDDEServerObjects.DeleteObject(this);
 307
 308     wxNode *node = m_connections.First();
 309     while (node)
 310     {
 311         wxDDEConnection *connection = (wxDDEConnection *)node->Data();
 312         wxNode *next = node->Next();
 313         connection->OnDisconnect(); // May delete the node implicitly
 314         node = next;
 315     }
 316
 317     // If any left after this, delete them
 318     node = m_connections.First();
 319     while (node)
 320     {
 321         wxDDEConnection *connection = (wxDDEConnection *)node->Data();
 322         wxNode *next = node->Next();
 323         delete connection;
 324         node = next;
 325     }
 326 }
 327
 328 wxConnectionBase *wxDDEServer::OnAcceptConnection(const wxString& /* topic */)
 329 {
 330     return new wxDDEConnection;
 331 }
 332
 333 wxDDEConnection *wxDDEServer::FindConnection(WXHCONV conv)
 334 {
 335     wxNode *node = m_connections.First();
 336     wxDDEConnection *found = NULL;
 337     while (node && !found)
 338     {
 339         wxDDEConnection *connection = (wxDDEConnection *)node->Data();
 340         if (connection->m_hConv == conv)
 341             found = connection;
 342         else node = node->Next();
 343     }
 344     return found;
 345 }
 346
 347 // Only delete the entry in the map, not the actual connection
 348 bool wxDDEServer::DeleteConnection(WXHCONV conv)
 349 {
 350     wxNode *node = m_connections.First();
 351     bool found = FALSE;
 352     while (node && !found)
 353     {
 354         wxDDEConnection *connection = (wxDDEConnection *)node->Data();
 355         if (connection->m_hConv == conv)
 356         {
 357             found = TRUE;
 358             delete node;
 359         }
 360         else node = node->Next();
 361     }
 362     return found;
 363 }
 364
 365 // ----------------------------------------------------------------------------
 366 // wxDDEClient
 367 // ----------------------------------------------------------------------------
 368
 369 wxDDEClient::wxDDEClient()
 370 {
 371     wxDDEInitialize();
 372
 373     wxDDEClientObjects.Append(this);
 374 }
 375
 376 wxDDEClient::~wxDDEClient()
 377 {
 378     wxDDEClientObjects.DeleteObject(this);
 379     wxNode *node = m_connections.First();
 380     while (node)
 381     {
 382         wxDDEConnection *connection = (wxDDEConnection *)node->Data();
 383         delete connection;  // Deletes the node implicitly (see ~wxDDEConnection)
 384         node = m_connections.First();
 385     }
 386 }
 387
 388 bool wxDDEClient::ValidHost(const wxString& /* host */)
 389 {
 390     return TRUE;
 391 }
 392
 393 wxConnectionBase *wxDDEClient::MakeConnection(const wxString& WXUNUSED(host),
 394                                               const wxString& server,
 395                                               const wxString& topic)
 396 {
 397     HCONV hConv = DdeConnect(DDEIdInst, DDEAtomFromString(server), DDEAtomFromString(topic),
 398                              (PCONVCONTEXT)NULL);
 399     if ( !hConv )
 400     {
 401         DDELogError(wxString::Format(_("Failed to create connection to server '%s' on topic '%s'"),
 402                                      server.c_str(), topic.c_str()));
 403     }
 404     else
 405     {
 406         wxDDEConnection *connection = (wxDDEConnection*) OnMakeConnection();
 407         if (connection)
 408         {
 409             connection->m_hConv = (WXHCONV) hConv;
 410             connection->m_topicName = topic;
 411             connection->m_client = this;
 412             m_connections.Append(connection);
 413             return connection;
 414         }
 415     }
 416
 417     return (wxConnectionBase*) NULL;
 418 }
 419
 420 wxConnectionBase *wxDDEClient::OnMakeConnection()
 421 {
 422     return new wxDDEConnection;
 423 }
 424
 425 wxDDEConnection *wxDDEClient::FindConnection(WXHCONV conv)
 426 {
 427     wxNode *node = m_connections.First();
 428     wxDDEConnection *found = NULL;
 429     while (node && !found)
 430     {
 431         wxDDEConnection *connection = (wxDDEConnection *)node->Data();
 432         if (connection->m_hConv == conv)
 433             found = connection;
 434         else node = node->Next();
 435     }
 436     return found;
 437 }
 438
 439 // Only delete the entry in the map, not the actual connection
 440 bool wxDDEClient::DeleteConnection(WXHCONV conv)
 441 {
 442     wxNode *node = m_connections.First();
 443     bool found = FALSE;
 444     while (node && !found)
 445     {
 446         wxDDEConnection *connection = (wxDDEConnection *)node->Data();
 447         if (connection->m_hConv == conv)
 448         {
 449             found = TRUE;
 450             delete node;
 451         }
 452         else node = node->Next();
 453     }
 454     return found;
 455 }
 456
 457 // ----------------------------------------------------------------------------
 458 // wxDDEConnection
 459 // ----------------------------------------------------------------------------
 460
 461 wxDDEConnection::wxDDEConnection(char *buffer, int size)
 462 {
 463     if (buffer == NULL)
 464     {
 465         if (DDEDefaultIPCBuffer == NULL)
 466             DDEDefaultIPCBuffer = new char[DDEDefaultIPCBufferSize];
 467         m_bufPtr = DDEDefaultIPCBuffer;
 468         m_bufSize = DDEDefaultIPCBufferSize;
 469     }
 470     else
 471     {
 472         m_bufPtr = buffer;
 473         m_bufSize = size;
 474     }
 475
 476     m_client = NULL;
 477     m_server = NULL;
 478
 479     m_hConv = 0;
 480     m_sendingData = NULL;
 481 }
 482
 483 wxDDEConnection::wxDDEConnection()
 484 {
 485     m_hConv = 0;
 486     m_sendingData = NULL;
 487     m_server = NULL;
 488     m_client = NULL;
 489     if (DDEDefaultIPCBuffer == NULL)
 490         DDEDefaultIPCBuffer = new char[DDEDefaultIPCBufferSize];
 491
 492     m_bufPtr = DDEDefaultIPCBuffer;
 493     m_bufSize = DDEDefaultIPCBufferSize;
 494 }
 495
 496 wxDDEConnection::~wxDDEConnection()
 497 {
 498     if (m_server)
 499         m_server->GetConnections().DeleteObject(this);
 500     else
 501         m_client->GetConnections().DeleteObject(this);
 502 }
 503
 504 // Calls that CLIENT can make
 505 bool wxDDEConnection::Disconnect()
 506 {
 507     DDEDeleteConnection(GetHConv());
 508
 509     bool ok = DdeDisconnect(GetHConv()) != 0;
 510     if ( !ok )
 511     {
 512         DDELogError(_T("Failed to disconnect from DDE server gracefully"));
 513     }
 514
 515     return ok;
 516 }
 517
 518 bool wxDDEConnection::Execute(const wxChar *data, int size, wxIPCFormat format)
 519 {
 520     DWORD result;
 521     if (size < 0)
 522     {
 523         size = wxStrlen(data) + 1;
 524     }
 525
 526     bool ok = DdeClientTransaction((LPBYTE)data, size,
 527                                     GetHConv(),
 528                                     NULL,
 529                                     format,
 530                                     XTYP_EXECUTE,
 531                                     DDE_TIMEOUT,
 532                                     &result) != 0;
 533
 534     if ( !ok )
 535     {
 536         DDELogError(_T("DDE execute request failed"));
 537     }
 538
 539     return ok;
 540 }
 541
 542 char *wxDDEConnection::Request(const wxString& item, int *size, wxIPCFormat format)
 543 {
 544     DWORD result;
 545     HSZ atom = DDEGetAtom(item);
 546
 547     HDDEDATA returned_data = DdeClientTransaction(NULL, 0,
 548                                                   GetHConv(),
 549                                                   atom, format,
 550                                                   XTYP_REQUEST,
 551                                                   DDE_TIMEOUT,
 552                                                   &result);
 553     if ( !returned_data )
 554     {
 555         DDELogError(_T("DDE data request failed"));
 556
 557         return NULL;
 558     }
 559
 560     DWORD len = DdeGetData(returned_data, (LPBYTE)m_bufPtr, m_bufSize, 0);
 561
 562     DdeFreeDataHandle(returned_data);
 563
 564     if (size)
 565         *size = (int)len;
 566
 567     return m_bufPtr;
 568 }
 569
 570 bool wxDDEConnection::Poke(const wxString& item, wxChar *data, int size, wxIPCFormat format)
 571 {
 572     DWORD result;
 573     if (size < 0)
 574     {
 575         size = wxStrlen(data) + 1;
 576     }
 577
 578     HSZ item_atom = DDEGetAtom(item);
 579     bool ok = DdeClientTransaction((LPBYTE)data, size,
 580                                    GetHConv(),
 581                                    item_atom, format,
 582                                    XTYP_POKE,
 583                                    DDE_TIMEOUT,
 584                                    &result) != 0;
 585     if ( !ok )
 586     {
 587         DDELogError(_("DDE poke request failed"));
 588     }
 589
 590     return ok;
 591 }
 592
 593 bool wxDDEConnection::StartAdvise(const wxString& item)
 594 {
 595     DWORD result;
 596     HSZ atom = DDEGetAtom(item);
 597
 598     bool ok = DdeClientTransaction(NULL, 0,
 599                                    GetHConv(),
 600                                    atom, CF_TEXT,
 601                                    XTYP_ADVSTART,
 602                                    DDE_TIMEOUT,
 603                                    &result) != 0;
 604     if ( !ok )
 605     {
 606         DDELogError(_("Failed to establish an advise loop with DDE server"));
 607     }
 608
 609     return ok;
 610 }
 611
 612 bool wxDDEConnection::StopAdvise(const wxString& item)
 613 {
 614     DWORD result;
 615     HSZ atom = DDEGetAtom(item);
 616
 617     bool ok = DdeClientTransaction(NULL, 0,
 618                                    GetHConv(),
 619                                    atom, CF_TEXT,
 620                                    XTYP_ADVSTOP,
 621                                    DDE_TIMEOUT,
 622                                    &result) != 0;
 623     if ( !ok )
 624     {
 625         DDELogError(_("Failed to terminate the advise loop with DDE server"));
 626     }
 627
 628     return ok;
 629 }
 630
 631 // Calls that SERVER can make
 632 bool wxDDEConnection::Advise(const wxString& item,
 633                              wxChar *data,
 634                              int size,
 635                              wxIPCFormat format)
 636 {
 637     if (size < 0)
 638     {
 639         size = wxStrlen(data) + 1;
 640     }
 641
 642     HSZ item_atom = DDEGetAtom(item);
 643     HSZ topic_atom = DDEGetAtom(m_topicName);
 644     m_sendingData = data;
 645     m_dataSize = size;
 646     m_dataType = format;
 647
 648     bool ok = DdePostAdvise(DDEIdInst, topic_atom, item_atom) != 0;
 649     if ( !ok )
 650     {
 651         DDELogError(_("Failed to send DDE advise notification"));
 652     }
 653
 654     return ok;
 655 }
 656
 657 bool wxDDEConnection::OnDisconnect()
 658 {
 659     delete this;
 660     return TRUE;
 661 }
 662
 663 // ----------------------------------------------------------------------------
 664 // _DDECallback
 665 // ----------------------------------------------------------------------------
 666
 667 #define DDERETURN HDDEDATA
 668
 669 HDDEDATA EXPENTRY _EXPORT
 670 _DDECallback(WORD wType,
 671              WORD wFmt,
 672              HCONV hConv,
 673              HSZ hsz1,
 674              HSZ hsz2,
 675              HDDEDATA hData,
 676              DWORD WXUNUSED(lData1),
 677              DWORD WXUNUSED(lData2))
 678 {
 679     switch (wType)
 680     {
 681         case XTYP_CONNECT:
 682             {
 683                 wxString topic = DDEStringFromAtom(hsz1),
 684                          srv = DDEStringFromAtom(hsz2);
 685                 wxDDEServer *server = DDEFindServer(srv);
 686                 if (server)
 687                 {
 688                     wxDDEConnection *connection =
 689                         (wxDDEConnection*) server->OnAcceptConnection(topic);
 690                     if (connection)
 691                     {
 692                         connection->m_server = server;
 693                         server->GetConnections().Append(connection);
 694                         connection->m_hConv = 0;
 695                         connection->m_topicName = topic;
 696                         DDECurrentlyConnecting = connection;
 697                         return (DDERETURN)(DWORD)TRUE;
 698                     }
 699                 }
 700                 break;
 701             }
 702
 703         case XTYP_CONNECT_CONFIRM:
 704             {
 705                 if (DDECurrentlyConnecting)
 706                 {
 707                     DDECurrentlyConnecting->m_hConv = (WXHCONV) hConv;
 708                     DDECurrentlyConnecting = NULL;
 709                     return (DDERETURN)(DWORD)TRUE;
 710                 }
 711                 break;
 712             }
 713
 714         case XTYP_DISCONNECT:
 715             {
 716                 wxDDEConnection *connection = DDEFindConnection(hConv);
 717                 if (connection && connection->OnDisconnect())
 718                 {
 719                     DDEDeleteConnection(hConv);  // Delete mapping: hConv => connection
 720                     return (DDERETURN)(DWORD)TRUE;
 721                 }
 722                 break;
 723             }
 724
 725         case XTYP_EXECUTE:
 726             {
 727                 wxDDEConnection *connection = DDEFindConnection(hConv);
 728
 729                 if (connection)
 730                 {
 731                     DWORD len = DdeGetData(hData,
 732                                            (LPBYTE)connection->m_bufPtr,
 733                                            connection->m_bufSize,
 734                                            0);
 735                     DdeFreeDataHandle(hData);
 736                     if ( connection->OnExecute(connection->m_topicName,
 737                                                connection->m_bufPtr,
 738                                                (int)len,
 739                                                (wxIPCFormat) wFmt) )
 740                     {
 741                         return (DDERETURN)(DWORD)DDE_FACK;
 742                     }
 743                 }
 744
 745                 return (DDERETURN)DDE_FNOTPROCESSED;
 746             }
 747
 748         case XTYP_REQUEST:
 749             {
 750                 wxDDEConnection *connection = DDEFindConnection(hConv);
 751
 752                 if (connection)
 753                 {
 754                     wxString item_name = DDEStringFromAtom(hsz2);
 755
 756                     int user_size = -1;
 757                     char *data = connection->OnRequest(connection->m_topicName,
 758                                                        item_name,
 759                                                        &user_size,
 760                                                        (wxIPCFormat) wFmt);
 761                     if (data)
 762                     {
 763                         if (user_size < 0)
 764                             user_size = wxStrlen((wxChar*)data) + 1;
 765
 766                         HDDEDATA handle = DdeCreateDataHandle(DDEIdInst,
 767                                                               (LPBYTE)data,
 768                                                               user_size,
 769                                                               0,
 770                                                               hsz2,
 771                                                               wFmt,
 772                                                               0);
 773                         return (DDERETURN)handle;
 774                     }
 775                 }
 776                 break;
 777             }
 778
 779         case XTYP_POKE:
 780             {
 781                 wxDDEConnection *connection = DDEFindConnection(hConv);
 782
 783                 if (connection)
 784                 {
 785                     wxString item_name = DDEStringFromAtom(hsz2);
 786
 787                     DWORD len = DdeGetData(hData,
 788                                            (LPBYTE)connection->m_bufPtr,
 789                                            connection->m_bufSize,
 790                                            0);
 791                     DdeFreeDataHandle(hData);
 792
 793                     connection->OnPoke(connection->m_topicName,
 794                                        item_name,
 795                                        (wxChar*)connection->m_bufPtr,
 796                                        (int)len,
 797                                        (wxIPCFormat) wFmt);
 798
 799                     return (DDERETURN)DDE_FACK;
 800                 }
 801                 else
 802                 {
 803                     return (DDERETURN)DDE_FNOTPROCESSED;
 804                 }
 805             }
 806
 807         case XTYP_ADVSTART:
 808             {
 809                 wxDDEConnection *connection = DDEFindConnection(hConv);
 810
 811                 if (connection)
 812                 {
 813                     wxString item_name = DDEStringFromAtom(hsz2);
 814
 815                     return (DDERETURN)connection->
 816                                 OnStartAdvise(connection->m_topicName, item_name);
 817                 }
 818
 819                 break;
 820             }
 821
 822         case XTYP_ADVSTOP:
 823             {
 824                 wxDDEConnection *connection = DDEFindConnection(hConv);
 825
 826                 if (connection)
 827                 {
 828                     wxString item_name = DDEStringFromAtom(hsz2);
 829
 830                     return (DDERETURN)connection->
 831                         OnStopAdvise(connection->m_topicName, item_name);
 832                 }
 833
 834                 break;
 835             }
 836
 837         case XTYP_ADVREQ:
 838             {
 839                 wxDDEConnection *connection = DDEFindConnection(hConv);
 840
 841                 if (connection && connection->m_sendingData)
 842                 {
 843                     HDDEDATA data = DdeCreateDataHandle
 844                                     (
 845                                         DDEIdInst,
 846                                         (LPBYTE)connection->m_sendingData,
 847                                         connection->m_dataSize,
 848                                         0,
 849                                         hsz2,
 850                                         connection->m_dataType,
 851                                         0
 852                                     );
 853
 854                     connection->m_sendingData = NULL;
 855
 856                     return (DDERETURN)data;
 857                 }
 858
 859                 break;
 860             }
 861
 862         case XTYP_ADVDATA:
 863             {
 864                 wxDDEConnection *connection = DDEFindConnection(hConv);
 865
 866                 if (connection)
 867                 {
 868                     wxString item_name = DDEStringFromAtom(hsz2);
 869
 870                     DWORD len = DdeGetData(hData,
 871                                            (LPBYTE)connection->m_bufPtr,
 872                                            connection->m_bufSize,
 873                                            0);
 874                     DdeFreeDataHandle(hData);
 875                     if ( connection->OnAdvise(connection->m_topicName,
 876                                               item_name,
 877                                               connection->m_bufPtr,
 878                                               (int)len,
 879                                               (wxIPCFormat) wFmt) )
 880                     {
 881                         return (DDERETURN)(DWORD)DDE_FACK;
 882                     }
 883                 }
 884
 885                 return (DDERETURN)DDE_FNOTPROCESSED;
 886             }
 887     }
 888
 889     return (DDERETURN)0;
 890 }
 891
 892 // ----------------------------------------------------------------------------
 893 // DDE strings and atoms
 894 // ----------------------------------------------------------------------------
 895
 896 // Atom table stuff
 897 static HSZ DDEAddAtom(const wxString& string)
 898 {
 899     HSZ atom = DDEAtomFromString(string);
 900     wxAtomTable.Append(string, (wxObject *)atom);
 901     return atom;
 902 }
 903
 904 static HSZ DDEGetAtom(const wxString& string)
 905 {
 906     wxNode *node = wxAtomTable.Find(string);
 907     if (node)
 908         return (HSZ)node->Data();
 909     else
 910     {
 911         DDEAddAtom(string);
 912         return (HSZ)(wxAtomTable.Find(string)->Data());
 913     }
 914 }
 915
 916 // atom <-> strings
 917 static HSZ DDEAtomFromString(const wxString& s)
 918 {
 919     wxASSERT_MSG( DDEIdInst, _T("DDE not initialized") );
 920
 921     HSZ hsz = DdeCreateStringHandle(DDEIdInst, (wxChar*) s.c_str(), DDE_CP);
 922     if ( !hsz )
 923     {
 924         DDELogError(_("Failed to create DDE string"));
 925     }
 926
 927     return hsz;
 928 }
 929
 930 static wxString DDEStringFromAtom(HSZ hsz)
 931 {
 932     // all DDE strings are normally limited to 255 bytes
 933     static const size_t len = 256;
 934
 935     wxString s;
 936     (void)DdeQueryString(DDEIdInst, hsz, s.GetWriteBuf(len), len, DDE_CP);
 937     s.UngetWriteBuf();
 938
 939     return s;
 940 }
 941
 942 // ----------------------------------------------------------------------------
 943 // error handling
 944 // ----------------------------------------------------------------------------
 945
 946 static void DDELogError(const wxString& s, UINT error)
 947 {
 948     if ( !error )
 949     {
 950         error = DdeGetLastError(DDEIdInst);
 951     }
 952
 953     wxLogError(s + _T(": ") + DDEGetErrorMsg(error));
 954 }
 955
 956 static wxString DDEGetErrorMsg(UINT error)
 957 {
 958     wxString err;
 959     switch ( error )
 960     {
 961         case DMLERR_NO_ERROR:
 962             err = _("no DDE error.");
 963             break;
 964
 965         case DMLERR_ADVACKTIMEOUT:
 966             err = _("a request for a synchronous advise transaction has timed out.");
 967             break;
 968         case DMLERR_BUSY:
 969             err = _("the response to the transaction caused the DDE_FBUSY bit to be set.");
 970             break;
 971         case DMLERR_DATAACKTIMEOUT:
 972             err = _("a request for a synchronous data transaction has timed out.");
 973             break;
 974         case DMLERR_DLL_NOT_INITIALIZED:
 975             err = _("a DDEML function was called without first calling the DdeInitialize function,\nor an invalid instance identifier\nwas passed to a DDEML function.");
 976             break;
 977         case DMLERR_DLL_USAGE:
 978             err = _("an application initialized as APPCLASS_MONITOR has\nattempted to perform a DDE transaction,\nor an application initialized as APPCMD_CLIENTONLY has \nattempted to perform server transactions.");
 979             break;
 980         case DMLERR_EXECACKTIMEOUT:
 981             err = _("a request for a synchronous execute transaction has timed out.");
 982             break;
 983         case DMLERR_INVALIDPARAMETER:
 984             err = _("a parameter failed to be validated by the DDEML.");
 985             break;
 986         case DMLERR_LOW_MEMORY:
 987             err = _("a DDEML application has created a prolonged race condition.");
 988             break;
 989         case DMLERR_MEMORY_ERROR:
 990             err = _("a memory allocation failed.");
 991             break;
 992         case DMLERR_NO_CONV_ESTABLISHED:
 993             err = _("a client's attempt to establish a conversation has failed.");
 994             break;
 995         case DMLERR_NOTPROCESSED:
 996             err = _("a transaction failed.");
 997             break;
 998         case DMLERR_POKEACKTIMEOUT:
 999             err = _("a request for a synchronous poke transaction has timed out.");
1000             break;
1001         case DMLERR_POSTMSG_FAILED:
1002             err = _("an internal call to the PostMessage function has failed. ");
1003             break;
1004         case DMLERR_REENTRANCY:
1005             err = _("reentrancy problem.");
1006             break;
1007         case DMLERR_SERVER_DIED:
1008             err = _("a server-side transaction was attempted on a conversation\nthat was terminated by the client, or the server\nterminated before completing a transaction.");
1009             break;
1010         case DMLERR_SYS_ERROR:
1011             err = _("an internal error has occurred in the DDEML.");
1012             break;
1013         case DMLERR_UNADVACKTIMEOUT:
1014             err = _("a request to end an advise transaction has timed out.");
1015             break;
1016         case DMLERR_UNFOUND_QUEUE_ID:
1017             err = _("an invalid transaction identifier was passed to a DDEML function.\nOnce the application has returned from an XTYP_XACT_COMPLETE callback,\nthe transaction identifier for that callback is no longer valid.");
1018             break;
1019         default:
1020             err.Printf(_("Unknown DDE error %08x"), error);
1021     }
1022
1023     return err;
1024 }
1025
1026 #endif
1027   // wxUSE_IPC