home *** CD-ROM | disk | FTP | other *** search
/ The Net: Ultimate Internet Guide / WWLCD1.ISO / mac / SiteBldr / DIRECTX2 / SDK / SAMPLES / IKLOWNS / CGREMOTE.CPP < prev    next >
Encoding:
C/C++ Source or Header  |  1996-05-28  |  22.8 KB  |  835 lines  |  [TEXT/hscd]
  1. /*===========================================================================*\
  2. |
  3. |  File:        cgremote.cpp
  4. |
  5. |  Description:
  6. |   Routines to send and receive remote actions for controlling objects
  7. |   on remote machines.  Uses DirectPlay for transferring data.
  8. |       
  9. |-----------------------------------------------------------------------------
  10. |
  11. |  Copyright (C) 1995-1996 Microsoft Corporation.  All Rights Reserved.
  12. |
  13. |  Written by Moss Bay Engineering, Inc. under contract to Microsoft Corporation
  14. |
  15. \*===========================================================================*/
  16.  
  17. /**************************************************************************
  18.  
  19.     (C) Copyright 1995-1996 Microsoft Corp.  All rights reserved.
  20.  
  21.     You have a royalty-free right to use, modify, reproduce and 
  22.     distribute the Sample Files (and/or any modified version) in 
  23.     any way you find useful, provided that you agree that 
  24.     Microsoft has no warranty obligations or liability for any 
  25.     Sample Application Files which are modified. 
  26.  
  27.     we do not recomend you base your game on IKlowns, start with one of
  28.     the other simpler sample apps in the GDK
  29.  
  30.  **************************************************************************/
  31.  
  32. //** include files **
  33. #include <stdlib.h>
  34. #ifndef __WATCOMC__
  35. #define WIN32_LEAN_AND_MEAN
  36. #endif
  37. #include <windows.h>
  38. #include <windowsx.h>
  39. #include <mmsystem.h>
  40. #include "cgglobl.h" // For ghInst for dialog box
  41. #include "cgrsrce.h"
  42. #include "dplay.h"
  43. #include "cglevel.h"
  44. #include "cgremote.h"
  45. #include "strrec.h"
  46.  
  47. #include <stdarg.h>
  48. #include <stdio.h>
  49.  
  50. static void InitReceivePoll( void );
  51.  
  52. // [johnhall]
  53. // hack -- get GENERIC_CHAR_INFO from cgkrusty.cpp
  54. typedef signed char SCHAR;
  55.  
  56. typedef struct 
  57. {
  58.     LONG    posx;
  59.     LONG    posy;
  60.     SCHAR   state;
  61.     SCHAR   velx;
  62.     SCHAR   vely;
  63.     SCHAR   curZ;
  64. } GENERIC_CHAR_INFO;
  65.  
  66. //** local definitions **
  67. // structure to be used to pass remote actions across the link
  68. typedef struct _GAMEMESSAGE {
  69.     BYTE                    Action;     // action code
  70.     BYTE            NumBytes;   // size of data 
  71.     REMOTE_OBJECT       RemObj;     // unique object id
  72.     char            Data[1];    // action specific data
  73. } GAMEMESSAGE, *PGAMEMESSAGE;
  74.  
  75.  
  76. //** external functions **
  77.  
  78. //** external data **
  79. // KLUDGE:
  80. CGameLevel  *gCurLevel=NULL;
  81.  
  82. //** public data **
  83. //** private data **
  84. static  IDirectPlay *lpIDC=NULL;    // DirectPlay Object
  85. static  DPID    dcoID=0;        // our DirectPlay ID
  86. static  HANDLE  dphEvent = NULL;
  87.  
  88. static BOOL fAbort = FALSE; // Abort flag for RemoteConnect()
  89.  
  90. //** public functions **
  91. //** private functions **
  92. static DWORD RequestThreadProc(void *Dummy);
  93. static BOOL CALLBACK AbortDlgProc( HWND hWnd, UINT uMsg, WPARAM wParam, LPARAM lParam );
  94.  
  95.  
  96. #define DP_BROADCAST_ID  0
  97.  
  98. // ----------------------------------------------------------
  99. // CreateRemotePeer - create a new character across all peers
  100. // ----------------------------------------------------------
  101. REMOTE_OBJECT *CreateRemotePeers(
  102.     char    *name,      // name of object as per level->Add() 
  103.     DWORD   InstanceID  // unique instance ID of object type
  104. )
  105. {
  106.     // Gotta have a DCO object to do this!
  107.     if (lpIDC == NULL)
  108.     {
  109.         return(NULL);
  110.     }
  111.  
  112.     // Setup a message and an unique obect id
  113.     char *pBuffer = NULL;
  114.     DWORD lenBuff;
  115.     PGAMEMESSAGE    pGameMsg;
  116.     REMOTE_OBJECT *pObj = new REMOTE_OBJECT;
  117.     memset(pObj, 0, sizeof(REMOTE_OBJECT));
  118.  
  119.     // Make buffer big enough to hold game message plus
  120.     // leading non-system-char byte
  121.     lenBuff = sizeof(GAMEMESSAGE);
  122.     pBuffer = new char[lenBuff];
  123.     pGameMsg = (PGAMEMESSAGE)&pBuffer[0];
  124.  
  125.     // Fill in object id info so that this object is unique across
  126.     // all machines
  127.     pObj->OwnerID = (BYTE) dcoID;
  128.     pObj->InstanceID = (BYTE) InstanceID;
  129.     lstrcpyn(pObj->ObjectID, name, MAX_OBJ_NAME);
  130.     memcpy(&pGameMsg->RemObj, pObj, sizeof(REMOTE_OBJECT));
  131.  
  132.     pGameMsg->Action = (BYTE) CREATE_OBJECT;
  133.  
  134.     // Broadcast it to everyone in the group.
  135.     lpIDC->Send( dcoID,  // From
  136.                  DP_BROADCAST_ID,
  137.                  0,
  138.                  (LPSTR)pBuffer,
  139.                  lenBuff);  
  140.  
  141.     // Delete buffer, once sent
  142.     delete []pBuffer;
  143.  
  144.     return(pObj);
  145. }   
  146.  
  147.  
  148.  
  149.  
  150.  
  151. // ----------------------------------------------------------
  152. // SendRemoteAction - broadcast an action to remote peers
  153. // ----------------------------------------------------------
  154. BOOL SendRemoteAction(
  155.     REMOTE_OBJECT   *pObj,      // unique object id
  156.     ACTION      Action,     // action code 
  157.     void        *Data,      // action data
  158.     DWORD       nDataSize   // size of action data
  159. )
  160. {
  161.     PGAMEMESSAGE    gameMsg;
  162.     char *pBuffer;
  163.     DWORD lenBuff;
  164.       //   char chBuffer[128];
  165.  
  166.  
  167.  
  168.     // Gotta have a valid DirectPlay object
  169.     if (lpIDC == NULL)
  170.     {
  171.         return(NULL);
  172.     }
  173.  
  174.     // Allocate the GAME buffer with room for data,
  175.     // plus room at the beginning for a non-sytem-message char
  176.     lenBuff = sizeof(GAMEMESSAGE) + nDataSize; 
  177.     pBuffer = new char [lenBuff]; 
  178.     // Now point gameMsg at the rest of the buffer
  179.     gameMsg = (PGAMEMESSAGE)&pBuffer[0];
  180.  
  181.     // Copy the action code and data to message buffer
  182.     gameMsg->Action = Action;
  183.     memcpy(&gameMsg->RemObj, pObj, sizeof(REMOTE_OBJECT));
  184.     gameMsg->NumBytes = (BYTE) nDataSize;
  185.     memcpy(gameMsg->Data, Data, nDataSize);
  186. #if 0
  187.         wsprintf( chBuffer, "%d (10%s) %d %d %d",
  188.             gameMsg->Action,
  189.             gameMsg->RemObj.ObjectID,
  190.             gameMsg->RemObj.InstanceID,
  191.             gameMsg->RemObj.OwnerID,
  192.             gameMsg->NumBytes);
  193.         OutputDebugString(chBuffer);
  194.         if (nDataSize == sizeof(GENERIC_CHAR_INFO))
  195.         {
  196.             GENERIC_CHAR_INFO *pci;
  197.             pci = (GENERIC_CHAR_INFO *) Data;
  198.             wsprintf( chBuffer,"; %d %d %d %d %d %d",
  199.                 pci->state,
  200.                 pci->posx,
  201.                 pci->posy,
  202.                 pci->velx,
  203.                 pci->vely,
  204.                 pci->curZ);
  205.             OutputDebugString(chBuffer);
  206.         }
  207.         OutputDebugString("\r\n");
  208. #endif
  209.  
  210.     // Broadcast the action to all peers
  211.     lpIDC->Send(dcoID, // from
  212.                 DP_BROADCAST_ID, // to
  213.                 0,
  214.                 pBuffer,
  215.                 lenBuff);   
  216.     delete []pBuffer;
  217.     return(TRUE);
  218. }   
  219.  
  220. // ----------------------------------------------------------
  221. // DestroyRemotePeer - Tell remote peers to kill an object
  222. // ----------------------------------------------------------
  223. BOOL DestroyRemotePeer(
  224.     REMOTE_OBJECT *pObj     // unique object id
  225. )
  226. {
  227.     PGAMEMESSAGE    gameMsg;
  228.     char *pBuffer = NULL;
  229.     DWORD lenBuff;
  230.  
  231.     if (pObj == NULL)
  232.         return(TRUE);
  233.  
  234.     // Allocate a buffer for the GAME buffer with roon for data,
  235.     // plus an extra character at the beginning to be the non-system
  236.     // message char.
  237.     lenBuff = sizeof(GAMEMESSAGE)+1; 
  238.     pBuffer = new char [lenBuff];
  239.  
  240.     // Point the game message pointer at the rest of the buffer
  241.     gameMsg = (PGAMEMESSAGE)&pBuffer[0];
  242.  
  243.     // Format a destroy message
  244.     memcpy(&gameMsg->RemObj, pObj, sizeof(REMOTE_OBJECT));
  245.     gameMsg->RemObj.OwnerID = (BYTE) dcoID;
  246.     gameMsg->NumBytes = 0;
  247.     gameMsg->Action = (BYTE) DESTROY_OBJECT;
  248.  
  249.     // Broadcast the destroy message to all peers
  250.     lpIDC->Send( dcoID, 
  251.                  DP_BROADCAST_ID,
  252.                  0,
  253.                  pBuffer,
  254.                  lenBuff);  
  255.     // Delete buffer
  256.     delete []pBuffer;
  257.  
  258.     // Don't need the object id anymore
  259.     delete pObj;
  260.     return(TRUE);
  261. }   
  262.  
  263. // -----------------------------------------------------------------
  264. // RemoteConnect - establish an active connection with remotes
  265. // -----------------------------------------------------------------
  266.  
  267. BOOL FAR PASCAL EnumSession(
  268.         LPDPSESSIONDESC lpDPGameDesc,
  269.         LPVOID pContext,
  270.         LPDWORD pTimeOut,
  271.         DWORD dwFlags )
  272. {
  273.     LONG iIndex;
  274.     HWND hWnd = (HWND) pContext;
  275.  
  276.     if( dwFlags == DPESC_TIMEDOUT )
  277.     {
  278.     return FALSE;
  279.     }
  280.  
  281.     iIndex = SendMessage(hWnd, LB_ADDSTRING, 0, (LPARAM) lpDPGameDesc->szSessionName);
  282.     if (iIndex != LB_ERR)
  283.         SendMessage(hWnd, LB_SETITEMDATA, iIndex, (LPARAM) lpDPGameDesc->dwSession);
  284.  
  285.     SetFocus(hWnd);
  286.     SendMessage(hWnd, LB_SETCURSEL, 0, 0);
  287.     return(TRUE);
  288.  
  289. }
  290.  
  291. BOOL FAR PASCAL EnumSP(LPGUID lpGuid, LPSTR lpDesc,
  292.             DWORD dwMajor, DWORD dwMinor, LPVOID lpv)
  293. {
  294.     LONG iIndex;
  295.     HWND hWnd = (HWND) lpv;
  296.  
  297.     iIndex = SendMessage(hWnd, LB_ADDSTRING, 0, (LPARAM) lpDesc);
  298.     if (iIndex != LB_ERR)
  299.         SendMessage(hWnd, LB_SETITEMDATA, iIndex, (LPARAM) lpGuid);
  300.  
  301.     SetFocus(hWnd);
  302.     SendMessage(hWnd, LB_SETCURSEL, 0, 0);
  303.     return(TRUE);
  304. }
  305.  
  306.  
  307.  
  308. BOOL CALLBACK DlgProcQCreate (HWND hDlg, UINT msg, WPARAM wParam, LPARAM lParam)
  309. {
  310.     switch (msg)
  311.     {
  312.     case WM_COMMAND:
  313.         switch(wParam)
  314.         {
  315.         case IDC_CREATE:
  316.             EndDialog(hDlg, 1);
  317.             return(TRUE);
  318.  
  319.         case IDC_CONNECT:
  320.             EndDialog(hDlg, 2);
  321.             return(TRUE);
  322.  
  323.         case IDCANCEL:
  324.             EndDialog(hDlg, -1);
  325.             return(TRUE);
  326.         }
  327.         break;
  328.  
  329.     }
  330.     return(FALSE);
  331. }
  332. BOOL CALLBACK DlgProcChooseProvider (HWND hDlg, UINT msg, WPARAM wParam, LPARAM lParam)
  333. {
  334.     LPGUID  lpGuid;
  335.     static  LONG    iIndex;
  336.     static  HWND hWndCtl;
  337.  
  338.     switch (msg)
  339.     {
  340.     case WM_INITDIALOG:
  341.  
  342.         hWndCtl = GetDlgItem(hDlg, IDC_LIST1);
  343.         if (hWndCtl == NULL)
  344.         {
  345.             EndDialog(hDlg, TRUE);
  346.             return(TRUE);
  347.         }
  348.         DirectPlayEnumerate(EnumSP, (LPVOID) hWndCtl);
  349.         SetFocus(hWndCtl);
  350.         SendMessage(hWndCtl, LB_SETCURSEL, 0, 0);
  351.         return(FALSE);
  352.  
  353.     case WM_COMMAND:
  354.  
  355.         switch( HIWORD(wParam))
  356.         {
  357.         case LBN_SELCHANGE:
  358.             iIndex = SendMessage((HWND) lParam, LB_GETCURSEL, 0, 0);
  359.             hWndCtl = (HWND) lParam;
  360.             return(FALSE);
  361.  
  362.         case LBN_DBLCLK:
  363.             iIndex = SendMessage((HWND) lParam, LB_GETCURSEL, 0, 0);
  364.             if (iIndex != LB_ERR)
  365.             {
  366.                 lpGuid = (LPGUID) SendMessage((HWND) lParam, LB_GETITEMDATA, iIndex, 0);
  367.                 DirectPlayCreate(lpGuid, &lpIDC, NULL);
  368.                 EndDialog(hDlg, TRUE);
  369.                 return(TRUE);
  370.             }
  371.             break;
  372.  
  373.         case 0:
  374.             if (LOWORD(wParam) == IDOK)
  375.             {
  376.                 if (iIndex != LB_ERR)
  377.                 {
  378.                     lpGuid = (LPGUID) SendMessage(hWndCtl, LB_GETITEMDATA, iIndex, 0);
  379.                     if (lpGuid)
  380.                     {
  381.                         DirectPlayCreate(lpGuid, &lpIDC, NULL);
  382.                         EndDialog(hDlg, TRUE);
  383.                     }
  384.                     else
  385.                         EndDialog(hDlg, FALSE);
  386.                     return(TRUE);
  387.                 }
  388.             }
  389.             else if (LOWORD(wParam) == IDCANCEL)
  390.             {
  391.                 EndDialog(hDlg, FALSE);
  392.                 return(TRUE);
  393.             }
  394.             break;
  395.  
  396.         }
  397.     }
  398.     return (FALSE);
  399. }
  400.  
  401. LPGUID g_lpGuid;
  402.  
  403. BOOL CALLBACK DlgProcSelSession (HWND hDlg, UINT msg, WPARAM wParam, LPARAM lParam)
  404. {
  405.     static  LONG    iIndex;
  406.     static  HWND hWndCtl;
  407.     DPSESSIONDESC dpDesc;
  408.     HRESULT hr = DP_OK + 10;
  409.  
  410.     switch (msg)
  411.     {
  412.     case WM_INITDIALOG:
  413.  
  414.         hWndCtl = GetDlgItem(hDlg, IDC_LB_SESSION);
  415.         if (hWndCtl == NULL)
  416.         {
  417.             EndDialog(hDlg, TRUE);
  418.             return(TRUE);
  419.         }
  420.         memset(&dpDesc, 0x00, sizeof(DPSESSIONDESC));
  421.         dpDesc.dwSize = sizeof(dpDesc);
  422.         dpDesc.guidSession = *g_lpGuid;
  423.         lpIDC->EnumSessions(&dpDesc, 5000, EnumSession, (LPVOID) hWndCtl, 0 );
  424.  
  425.         SetFocus(hWndCtl);
  426.         return(FALSE);
  427.  
  428.     case WM_COMMAND:
  429.  
  430.         switch( HIWORD(wParam))
  431.         {
  432.         case LBN_SELCHANGE:
  433.             iIndex = SendMessage((HWND) lParam, LB_GETCURSEL, 0, 0);
  434.             hWndCtl = (HWND) lParam;
  435.             return(FALSE);
  436.  
  437.         case 0:
  438.             if (LOWORD(wParam) == IDCANCEL)
  439.             {
  440.                 lpIDC->Close();
  441.                 lpIDC->Release();
  442.                 lpIDC = NULL;
  443.                 EndDialog(hDlg, FALSE);
  444.                 return(TRUE);
  445.             }
  446.             //
  447.             // Fall Through.
  448.             //
  449.         case LBN_DBLCLK:
  450.             if (HIWORD(wParam) == LBN_DBLCLK)
  451.             {
  452.                 hWndCtl = (HWND) lParam;
  453.                 iIndex = SendMessage(hWndCtl, LB_GETCURSEL, 0, 0);
  454.             }
  455.  
  456.             if (iIndex != LB_ERR)
  457.             {
  458.                 memset(&dpDesc, 0x00, sizeof(DPSESSIONDESC));
  459.                 dpDesc.dwSize       = sizeof(dpDesc);
  460.                 dpDesc.guidSession  = *g_lpGuid;
  461.                 dpDesc.dwFlags      = DPOPEN_OPENSESSION;
  462.                 dpDesc.dwSession    = SendMessage((HWND) hWndCtl, LB_GETITEMDATA, iIndex, 0);
  463.                 hr = lpIDC->Open(&dpDesc);
  464.  
  465.                 if (hr != DP_OK)
  466.                 {
  467.                     lpIDC->Close();
  468.                     lpIDC->Release();
  469.                     lpIDC = NULL;
  470.                     EndDialog(hDlg, FALSE);
  471.                 }
  472.  
  473.                 EndDialog(hDlg, TRUE);
  474.                 return(TRUE);
  475.  
  476.             }
  477.         }
  478.     }
  479.     return (FALSE);
  480. }
  481.  
  482. INT GetProvider()
  483. {
  484.  
  485.   return(DialogBox (NULL, (LPCTSTR) IDD_CHOOSEPROVIDER, NULL, (DLGPROC) DlgProcChooseProvider));
  486. }
  487.  
  488. INT CreateGame()
  489. {
  490.   return(DialogBox (NULL, (LPCTSTR) IDD_Q_CREATE, NULL, (DLGPROC) DlgProcQCreate));
  491.     
  492. }
  493.  
  494. INT GetGame()
  495. {
  496.  
  497.   return(DialogBox (NULL, (LPCTSTR) IDD_SELSESSION, NULL, (DLGPROC) DlgProcSelSession));
  498. }
  499.  
  500.  
  501.  
  502. BOOL RemoteCreate(REFGUID pGuid, LPSTR FullName, LPSTR NickName)
  503. {
  504.     HRESULT hr;
  505.     DPSESSIONDESC dpDesc;
  506.  
  507.     // Be sure we aren't already initialized.
  508.     if (lpIDC != NULL)
  509.     {
  510.         return( FALSE );
  511.     }
  512.  
  513.     GetProvider();
  514.  
  515.     if (lpIDC == NULL)
  516.         return(FALSE);
  517.  
  518.     switch( CreateGame())
  519.     {
  520.     case 1:             // Create
  521.         memset(&dpDesc, 0x00, sizeof(DPSESSIONDESC));
  522.         dpDesc.dwSize = sizeof(dpDesc);
  523.         dpDesc.dwMaxPlayers = 10;
  524.         dpDesc.dwFlags = DPOPEN_CREATESESSION;
  525.         dpDesc.guidSession = pGuid;
  526.         strcpy( dpDesc.szSessionName, FullName);
  527.         
  528.         if ((hr = lpIDC->Open(&dpDesc)) != DP_OK)
  529.         {
  530.             lpIDC->Release();
  531.             lpIDC = NULL;
  532.             return(FALSE);
  533.         }
  534.         
  535.         break;
  536.  
  537.     case 2:             // Connect
  538.         g_lpGuid = (LPGUID) &pGuid;
  539.  
  540.         GetGame();
  541.  
  542.         if (lpIDC == NULL)
  543.             return(FALSE);
  544.  
  545.         break;
  546.  
  547.     default:
  548.         return(FALSE);
  549.     }
  550.  
  551.     if ((hr = lpIDC->CreatePlayer(&dcoID, NickName,
  552.                                   "IKlowns Player", &dphEvent)) != DP_OK)
  553.     {
  554.         lpIDC->Close();
  555.         lpIDC->Release();
  556.         lpIDC = NULL;
  557.         return(FALSE);
  558.     }
  559.     
  560.     
  561.     InitReceivePoll();
  562.     return(TRUE);
  563.  
  564. }
  565.  
  566.  
  567. // -----------------------------------------------------------------
  568. // SetCurrentLevel - set pointer to current level object
  569. // -----------------------------------------------------------------
  570. void SetCurrentLevel(
  571.     void    *newLevel
  572. )
  573. {
  574.     gCurLevel = (CGameLevel *)newLevel;
  575. }
  576.  
  577. // ----------------------------------------------------------
  578. // CreateNewCharacter - create a new game object!
  579. // ----------------------------------------------------------
  580. void CreateNewCharacter(
  581.     REMOTE_OBJECT *pObj // unique object id
  582. )
  583. {
  584.     char dataBuf[256];
  585.     char graphicsBuf[256];
  586.  
  587.     // Get specific data on object from profile
  588.     // NOTE: This means we hit the disk.  For performance,
  589.     // it would be better if objects could be created based
  590.     // on an in memory object so that we don't ever have to
  591.     // hit the disk!
  592.  
  593.  
  594.     GetPrivateProfileString(
  595.             gCurLevel->GetLevelName(),
  596.             "Graphics",
  597.             "",
  598.             graphicsBuf,
  599.             sizeof( graphicsBuf ),
  600.             gCurLevel->GetProfileName()
  601.             );
  602.  
  603.     GetPrivateProfileString(
  604.             graphicsBuf,
  605.             pObj->ObjectID,
  606.             "",
  607.             dataBuf,
  608.             sizeof( dataBuf ),
  609.             gCurLevel->GetProfileName()
  610.             );
  611.  
  612.     // parse the data string into fields
  613.     CStringRecord fields( dataBuf, "," );
  614.  
  615.     if (fields.GetNumFields() >= 5)
  616.     {
  617.         // Add the object to the game list!
  618.         gCurLevel->Add(pObj->ObjectID,
  619.             atoi(fields[1]), 
  620.             atoi(fields[3]),
  621.             atoi(fields[4]),
  622.             (void *)pObj);
  623.     }
  624. }
  625.  
  626. // ----------------------------------------------------------
  627. // ProcessIncomingActions - Parse received messages & queue them
  628. // ----------------------------------------------------------
  629. BOOL ProcessIncomingActions(
  630.     REMOTE_OBJECT *pObj,    // unique object id
  631.     ACTION action,      // action code
  632.     void *Data,     // action data
  633.     DWORD nDataSize     // sizeof action data
  634. )
  635. {
  636.     CLinkedList *ActionList;
  637.     BOOL        fQueuedUp = FALSE;
  638.         // char            chBuffer[128];
  639.  
  640.         // wsprintf( chBuffer, "IncomingAction %d size %d\r\n", action, nDataSize);
  641.         // OutputDebugString(chBuffer);
  642.  
  643.     // Guard against activity occurring before we are ready!
  644.     if (gCurLevel == NULL)
  645.         return(FALSE);
  646.  
  647.     // Don't do anything about our own requests
  648.     if (pObj->OwnerID == dcoID)
  649.         return(FALSE);
  650.         
  651.     // Figure out what to do with this message
  652.     switch (action) {
  653.  
  654.     // Need to create a brand new object locally
  655.         case CREATE_OBJECT: {
  656.  
  657.                 // OutputDebugString("CreateObject \r\n");
  658.         // Create a game character
  659.         if (!FindRemoteObjectEntry(pObj))
  660.         {
  661.                         // OutputDebugString("CreateNewCharacter \r\n");
  662.             CreateNewCharacter(pObj);
  663.         }
  664.                 // OutputDebugString("Leave CreateObject \r\n");
  665.         break;
  666.     }
  667.  
  668.     // Time to destroy the object!
  669.     case DESTROY_OBJECT:    {
  670.         REMOTE_DATA *pRemoteEntry = FindRemoteObjectEntry(pObj);
  671.  
  672.                 // OutputDebugString("DestroyObject \r\n");
  673.         // Need to tell level object to remove the character!
  674.         if (pRemoteEntry != NULL)
  675.             gCurLevel->Remove((CGameGraphic *)pRemoteEntry->Data);
  676.  
  677.         break;
  678.     }
  679.  
  680.     // Must be some character specific action
  681.     default:{
  682.  
  683.         // Get action list for this object
  684.         ActionList = GetRemoteObjectQueue(pObj);
  685.  
  686.         // No action list -> a new object, so try to create it.
  687.         if (ActionList == NULL)
  688.         {
  689.             CreateNewCharacter(pObj);
  690.             ActionList = GetRemoteObjectQueue(pObj);
  691.             if (ActionList == NULL)
  692.                 return(FALSE);
  693.         }
  694.  
  695.         // Place this action onto the queue
  696.                 // OutputDebugString("QueueRemoteAction \r\n");
  697.         QueueRemoteAction(ActionList, action, Data, nDataSize);
  698.         fQueuedUp = TRUE;
  699.         break;
  700.     }
  701.     }
  702.     return(fQueuedUp);
  703. }
  704.  
  705. // ----------------------------------------------------------
  706. // ReleaseRemoteData - free remote buffer
  707. // ----------------------------------------------------------
  708. void ReleaseRemoteData(
  709.     LPVOID  pData       // ptr to app data portion
  710. )
  711. {
  712.     PGAMEMESSAGE    pMsg;   // desired pointer
  713.     int     iDiff;  // difference between the two
  714.  
  715.     // Pretend we got passed in the proper ptr
  716.     pMsg = (PGAMEMESSAGE)pData;
  717.  
  718.     // Calculate the difference between what we got
  719.     // and what we need.
  720.     iDiff = (LPBYTE)(&pMsg->Data) - (LPBYTE)(pMsg);
  721.  
  722.     // Adjust accordingly and free the message!
  723.     pMsg = (PGAMEMESSAGE)((LPBYTE)pMsg - iDiff);
  724.     delete pMsg;
  725. }
  726.  
  727. #define MAX_BUFFER_SIZE (sizeof(GAMEMESSAGE)+512)
  728.  
  729.  
  730.  
  731.  
  732. static char *pBuffer = NULL;
  733. static DWORD lenBuff = MAX_BUFFER_SIZE; 
  734.  
  735. static void InitReceivePoll( void )
  736. {
  737.     // We allocate a buffer to receive into first,
  738.     // which may have to cope with system messages,
  739.     // before copying the real message to the buffer to pass
  740.     // to the game
  741.     pBuffer = new char[ lenBuff ];
  742.  
  743. }
  744.  
  745. void PollForRemoteReceive( void )
  746. {
  747.     DPID        fromID, dcoReceiveID;
  748.     DWORD       nBytes;
  749.     PGAMEMESSAGE    pMsg;
  750.     int         i;
  751.     const       int MAX_MESSAGES = 16;
  752.     BOOL        fCheckForMore = TRUE;
  753.  
  754.     // Paranoia check
  755.     if ( lpIDC )
  756.     {
  757.         // We try to receive MAX_MESSAGES at a time so that
  758.         // a backlog doesn't build up.  If we run out of messages,
  759.         // we stop looking for them.
  760.  
  761.         for( i = 0; i < MAX_MESSAGES && fCheckForMore ; i++ )
  762.         {
  763.             HRESULT status;
  764.             nBytes = lenBuff;
  765.             status = lpIDC->Receive(
  766.                         &fromID,
  767.                         &dcoReceiveID,
  768.                         DPRECEIVE_ALL,
  769.                         pBuffer,
  770.                         &nBytes);
  771.             switch( status )
  772.             {
  773.             case DP_OK:
  774.                 if ( fromID == 0 )
  775.                 {
  776.                     // We do not in fact utilise the system
  777.                     // messages during the game.
  778.                 }
  779.                 else
  780.                 {
  781.                     // User message - we copy the buffer minus the
  782.                     // user message byte to the game buffer, then 
  783.                     // pass it on.
  784.         
  785.                     // Allocate buffer for game message
  786.                     pMsg = (PGAMEMESSAGE)new char [MAX_BUFFER_SIZE];
  787.                     memcpy( pMsg, &pBuffer[0], nBytes );
  788.         
  789.                 if (!ProcessIncomingActions(&pMsg->RemObj, pMsg->Action,
  790.                                 pMsg->Data, nBytes))
  791.                         delete pMsg;
  792.                 }
  793.             break;
  794.  
  795.             default:
  796.                 // Error condition of some kind - we just stop
  797.                 // checking for now
  798.                 fCheckForMore = FALSE;
  799.                 break;
  800.             }
  801.         }
  802.     }
  803. }
  804.  
  805.  
  806. BOOL CALLBACK AbortDlgProc( HWND hWnd, UINT uMsg, WPARAM wParam, LPARAM lParam )
  807. {
  808.     WORD wID, wNotifyCode;
  809.     BOOL retVal = 0;
  810.  
  811.     switch( uMsg )
  812.     {
  813.         case WM_INITDIALOG:
  814.             // We didn't set focus
  815.             retVal = 1;
  816.             break;
  817.         case WM_COMMAND:
  818.             wID = LOWORD( wParam );
  819.             wNotifyCode = HIWORD( wParam );
  820.             switch ( wID )
  821.             {
  822.                 case IDCANCEL:
  823.                     if ( BN_CLICKED == wNotifyCode ) {
  824.                         fAbort = TRUE;
  825.                         retVal = 1;
  826.                     }
  827.                     break;
  828.                 default:
  829.                     break;
  830.             }   
  831.             break;
  832.     }
  833.     return( retVal );
  834. }
  835.