dplayx_messages.h File Reference

#include <stdarg.h>
#include "windef.h"
#include "winbase.h"
#include "dplay.h"
#include "rpc.h"
#include "dplay_global.h"
#include "pshpack1.h"
#include "poppack.h"

Include dependency graph for dplayx_messages.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	DPPLAYERINFO
struct	DPLAYI_PACKEDPLAYER
struct	tagDPMSG_SENDENVELOPE
struct	tagDPMSG_SYSMSGENVELOPE
struct	tagDPMSG_ENUMSESSIONSREPLY
struct	tagDPMSG_ENUMSESSIONSREQUEST
struct	tagDPMSG_CREATESESSION
struct	tagDPMSG_REQUESTNEWPLAYERID
struct	tagDPMSG_NEWPLAYERIDREPLY
struct	DPSP_MSG_ADDPLAYERTOGROUP
struct	DPSP_MSG_GROUPDATACHANGED
struct	tagDPMSG_FORWARDADDPLAYER
struct	tagDPMSG_FORWARDADDPLAYERNACK
struct	DPLAYI_SUPERPACKEDPLAYER
struct	DPSP_MSG_PING
struct	DPSP_MSG_ADDFORWARDREPLY
struct	DPSP_MSG_SUPERENUMPLAYERSREPLY
struct	DPSP_MSG_ADDFORWARD
struct	DPSP_MSG_ADDFORWARDACK

Macros
#define	DPMSG_WAIT_5_SECS   5000
#define	DPMSG_WAIT_30_SECS   30000
#define	DPMSG_WAIT_60_SECS   60000
#define	DPMSG_DEFAULT_WAIT_TIME   DPMSG_WAIT_30_SECS
#define	DPMSGCMD_ENUMSESSIONSREPLY   1
#define	DPMSGCMD_ENUMSESSIONSREQUEST   2
#define	DPMSGCMD_GETNAMETABLEREPLY   3 /* Contains all existing players in session */
#define	DPMSGCMD_REQUESTNEWPLAYERID   5
#define	DPMSGCMD_NEWPLAYERIDREPLY   7
#define	DPMSGCMD_CREATESESSION   8 /* Might be a create nameserver or new player msg */
#define	DPMSGCMD_CREATENEWPLAYER   9
#define	DPMSGCMD_SYSTEMMESSAGE   10
#define	DPMSGCMD_DELETEPLAYER   11
#define	DPMSGCMD_DELETEGROUP   12
#define	DPMSGCMD_ADDPLAYERTOGROUP   13
#define	DPMSGCMD_GROUPDATACHANGED   17
#define	DPMSGCMD_FORWARDADDPLAYER   19
#define	DPMSGCMD_PING   22
#define	DPMSGCMD_PINGREPLY   23
#define	DPMSGCMD_FORWARDADDPLAYERNACK   36
#define	DPMSGCMD_SUPERENUMPLAYERSREPLY   41
#define	DPMSGCMD_ADDFORWARD   46
#define	DPMSGCMD_ADDFORWARDACK   47
#define	DPMSGCMD_JUSTENVELOPE   1000
#define	DPMSGCMD_JUSTENVELOPEREPLY   1001
#define	DPMSGVER_DP6   11
#define	DPMSGMAGIC_DPLAYMSG   0x79616c70
#define	DPLAYI_SUPERPACKEDPLAYER_SHORT_NAME_PRESENT   0x001
#define	DPLAYI_SUPERPACKEDPLAYER_LONG_NAME_PRESENT   0x002
#define	DPLAYI_SUPERPACKEDPLAYER_SP_DATA_LENGTH_SIZE(mask)   (((mask) >> 2) & 0x3)
#define	DPLAYI_SUPERPACKEDPLAYER_PLAYER_DATA_LENGTH_SIZE(mask)   (((mask) >> 4) & 0x3)
#define	DPLAYI_SUPERPACKEDPLAYER_PLAYER_COUNT_SIZE(mask)   (((mask) >> 6) & 0x3)
#define	DPLAYI_SUPERPACKEDPLAYER_PARENT_ID_PRESENT   0x100
#define	DPLAYI_SUPERPACKEDPLAYER_SHORTCUT_COUNT_SIZE(mask)   (((mask) >> 9) & 0x3)

Typedefs
typedef struct tagDPMSG_SENDENVELOPE	DPMSG_SENDENVELOPE
typedef struct tagDPMSG_SENDENVELOPE *	LPDPMSG_SENDENVELOPE
typedef const DPMSG_SENDENVELOPE *	LPCDPMSG_SENDENVELOPE
typedef struct tagDPMSG_SYSMSGENVELOPE	DPMSG_SYSMSGENVELOPE
typedef struct tagDPMSG_SYSMSGENVELOPE *	LPDPMSG_SYSMSGENVELOPE
typedef const DPMSG_SYSMSGENVELOPE *	LPCDPMSG_SYSMSGENVELOPE
typedef struct tagDPMSG_ENUMSESSIONSREPLY	DPMSG_ENUMSESSIONSREPLY
typedef struct tagDPMSG_ENUMSESSIONSREPLY *	LPDPMSG_ENUMSESSIONSREPLY
typedef const DPMSG_ENUMSESSIONSREPLY *	LPCDPMSG_ENUMSESSIONSREPLY
typedef struct tagDPMSG_ENUMSESSIONSREQUEST	DPMSG_ENUMSESSIONSREQUEST
typedef struct tagDPMSG_ENUMSESSIONSREQUEST *	LPDPMSG_ENUMSESSIONSREQUEST
typedef const DPMSG_ENUMSESSIONSREQUEST *	LPCDPMSG_ENUMSESSIONSREQUEST
typedef struct tagDPMSG_CREATESESSION	DPMSG_CREATESESSION
typedef struct tagDPMSG_CREATESESSION *	LPDPMSG_CREATESESSION
typedef const DPMSG_CREATESESSION *	LPCDPMSG_CREATESESSION
typedef struct tagDPMSG_REQUESTNEWPLAYERID	DPMSG_REQUESTNEWPLAYERID
typedef struct tagDPMSG_REQUESTNEWPLAYERID *	LPDPMSG_REQUESTNEWPLAYERID
typedef const DPMSG_REQUESTNEWPLAYERID *	LPCDPMSG_REQUESTNEWPLAYERID
typedef struct tagDPMSG_NEWPLAYERIDREPLY	DPMSG_NEWPLAYERIDREPLY
typedef struct tagDPMSG_NEWPLAYERIDREPLY *	LPDPMSG_NEWPLAYERIDREPLY
typedef const DPMSG_NEWPLAYERIDREPLY *	LPCDPMSG_NEWPLAYERIDREPLY
typedef struct tagDPMSG_FORWARDADDPLAYER	DPMSG_FORWARDADDPLAYER
typedef struct tagDPMSG_FORWARDADDPLAYER *	LPDPMSG_FORWARDADDPLAYER
typedef const DPMSG_FORWARDADDPLAYER *	LPCDPMSG_FORWARDADDPLAYER
typedef struct tagDPMSG_FORWARDADDPLAYERNACK	DPMSG_FORWARDADDPLAYERNACK
typedef struct tagDPMSG_FORWARDADDPLAYERNACK *	LPDPMSG_FORWARDADDPLAYERNACK
typedef const DPMSG_FORWARDADDPLAYERNACK *	LPCDPMSG_FORWARDADDPLAYERNACK

Functions
DWORD	CreateLobbyMessageReceptionThread (HANDLE hNotifyEvent, HANDLE hStart, HANDLE hDeath, HANDLE hConnRead)
DWORD	DP_MSG_ComputeMessageSize (SGBUFFER *buffers, DWORD bufferCount)
HRESULT	DP_MSG_SendRequestPlayerId (IDirectPlayImpl *This, DWORD dwFlags, LPDPID lpdipidAllocatedId)
HRESULT	DP_MSG_ReadPackedPlayer (char *data, DWORD *offset, DWORD maxSize, DPPLAYERINFO *playerInfo)
HRESULT	DP_MSG_ForwardPlayerCreation (IDirectPlayImpl *This, DPID dpidServer, WCHAR *password)
HRESULT	DP_MSG_SendCreatePlayer (IDirectPlayImpl *This, DPID toId, DPID id, DWORD flags, DPNAME *name, void *playerData, DWORD playerDataSize, DPID systemPlayerId)
HRESULT	DP_MSG_SendAddPlayerToGroup (IDirectPlayImpl *This, DPID toId, DPID playerId, DPID groupId)
HRESULT	DP_MSG_SendPingReply (IDirectPlayImpl *This, DPID toId, DPID fromId, DWORD tickCount)
HRESULT	DP_MSG_SendAddForwardAck (IDirectPlayImpl *This, DPID id)
void	DP_MSG_ReplyReceived (IDirectPlayImpl *This, WORD wCommandId, LPCVOID lpMsgBody, DWORD dwMsgBodySize, const void *msgHeader)
void	DP_MSG_ToSelf (IDirectPlayImpl *This, DPID dpidSelf)

Macro Definition Documentation

DPLAYI_SUPERPACKEDPLAYER_LONG_NAME_PRESENT

#define DPLAYI_SUPERPACKEDPLAYER_LONG_NAME_PRESENT   0x002

Definition at line 288 of file dplayx_messages.h.

DPLAYI_SUPERPACKEDPLAYER_PARENT_ID_PRESENT

#define DPLAYI_SUPERPACKEDPLAYER_PARENT_ID_PRESENT   0x100

Definition at line 292 of file dplayx_messages.h.

DPLAYI_SUPERPACKEDPLAYER_PLAYER_COUNT_SIZE

#define DPLAYI_SUPERPACKEDPLAYER_PLAYER_COUNT_SIZE

(

mask

)

(((mask) >> 6) & 0x3)

Definition at line 291 of file dplayx_messages.h.

DPLAYI_SUPERPACKEDPLAYER_PLAYER_DATA_LENGTH_SIZE

#define DPLAYI_SUPERPACKEDPLAYER_PLAYER_DATA_LENGTH_SIZE

(

mask

)

(((mask) >> 4) & 0x3)

Definition at line 290 of file dplayx_messages.h.

DPLAYI_SUPERPACKEDPLAYER_SHORT_NAME_PRESENT

#define DPLAYI_SUPERPACKEDPLAYER_SHORT_NAME_PRESENT   0x001

Definition at line 287 of file dplayx_messages.h.

DPLAYI_SUPERPACKEDPLAYER_SHORTCUT_COUNT_SIZE

#define DPLAYI_SUPERPACKEDPLAYER_SHORTCUT_COUNT_SIZE

(

mask

)

(((mask) >> 9) & 0x3)

Definition at line 293 of file dplayx_messages.h.

DPLAYI_SUPERPACKEDPLAYER_SP_DATA_LENGTH_SIZE

#define DPLAYI_SUPERPACKEDPLAYER_SP_DATA_LENGTH_SIZE

(

mask

)

(((mask) >> 2) & 0x3)

Definition at line 289 of file dplayx_messages.h.

DPMSG_DEFAULT_WAIT_TIME

#define DPMSG_DEFAULT_WAIT_TIME   DPMSG_WAIT_30_SECS

Definition at line 74 of file dplayx_messages.h.

DPMSG_WAIT_30_SECS

#define DPMSG_WAIT_30_SECS   30000

Definition at line 72 of file dplayx_messages.h.

DPMSG_WAIT_5_SECS

#define DPMSG_WAIT_5_SECS   5000

Definition at line 71 of file dplayx_messages.h.

DPMSG_WAIT_60_SECS

#define DPMSG_WAIT_60_SECS   60000

Definition at line 73 of file dplayx_messages.h.

DPMSGCMD_ADDFORWARD

#define DPMSGCMD_ADDFORWARD   46

Definition at line 121 of file dplayx_messages.h.

DPMSGCMD_ADDFORWARDACK

#define DPMSGCMD_ADDFORWARDACK   47

Definition at line 122 of file dplayx_messages.h.

DPMSGCMD_ADDPLAYERTOGROUP

#define DPMSGCMD_ADDPLAYERTOGROUP   13

Definition at line 108 of file dplayx_messages.h.

DPMSGCMD_CREATENEWPLAYER

#define DPMSGCMD_CREATENEWPLAYER   9

Definition at line 104 of file dplayx_messages.h.

DPMSGCMD_CREATESESSION

#define DPMSGCMD_CREATESESSION   8 /* Might be a create nameserver or new player msg */

Definition at line 103 of file dplayx_messages.h.

DPMSGCMD_DELETEGROUP

#define DPMSGCMD_DELETEGROUP   12

Definition at line 107 of file dplayx_messages.h.

DPMSGCMD_DELETEPLAYER

#define DPMSGCMD_DELETEPLAYER   11

Definition at line 106 of file dplayx_messages.h.

DPMSGCMD_ENUMSESSIONSREPLY

#define DPMSGCMD_ENUMSESSIONSREPLY   1

Definition at line 96 of file dplayx_messages.h.

DPMSGCMD_ENUMSESSIONSREQUEST

#define DPMSGCMD_ENUMSESSIONSREQUEST   2

Definition at line 97 of file dplayx_messages.h.

DPMSGCMD_FORWARDADDPLAYER

#define DPMSGCMD_FORWARDADDPLAYER   19

Definition at line 112 of file dplayx_messages.h.

DPMSGCMD_FORWARDADDPLAYERNACK

#define DPMSGCMD_FORWARDADDPLAYERNACK   36

Definition at line 117 of file dplayx_messages.h.

DPMSGCMD_GETNAMETABLEREPLY

#define DPMSGCMD_GETNAMETABLEREPLY   3 /* Contains all existing players in session */

Definition at line 98 of file dplayx_messages.h.

DPMSGCMD_GROUPDATACHANGED

#define DPMSGCMD_GROUPDATACHANGED   17

Definition at line 110 of file dplayx_messages.h.

DPMSGCMD_JUSTENVELOPE

#define DPMSGCMD_JUSTENVELOPE   1000

Definition at line 124 of file dplayx_messages.h.

DPMSGCMD_JUSTENVELOPEREPLY

#define DPMSGCMD_JUSTENVELOPEREPLY   1001

Definition at line 125 of file dplayx_messages.h.

DPMSGCMD_NEWPLAYERIDREPLY

#define DPMSGCMD_NEWPLAYERIDREPLY   7

Definition at line 102 of file dplayx_messages.h.

DPMSGCMD_PING

#define DPMSGCMD_PING   22

Definition at line 114 of file dplayx_messages.h.

DPMSGCMD_PINGREPLY

#define DPMSGCMD_PINGREPLY   23

Definition at line 115 of file dplayx_messages.h.

DPMSGCMD_REQUESTNEWPLAYERID

#define DPMSGCMD_REQUESTNEWPLAYERID   5

Definition at line 100 of file dplayx_messages.h.

DPMSGCMD_SUPERENUMPLAYERSREPLY

#define DPMSGCMD_SUPERENUMPLAYERSREPLY   41

Definition at line 119 of file dplayx_messages.h.

DPMSGCMD_SYSTEMMESSAGE

#define DPMSGCMD_SYSTEMMESSAGE   10

Definition at line 105 of file dplayx_messages.h.

DPMSGMAGIC_DPLAYMSG

#define DPMSGMAGIC_DPLAYMSG   0x79616c70

Definition at line 133 of file dplayx_messages.h.

DPMSGVER_DP6

#define DPMSGVER_DP6   11

Definition at line 130 of file dplayx_messages.h.

Typedef Documentation

DPMSG_CREATESESSION

typedef struct tagDPMSG_CREATESESSION DPMSG_CREATESESSION

DPMSG_ENUMSESSIONSREPLY

typedef struct tagDPMSG_ENUMSESSIONSREPLY DPMSG_ENUMSESSIONSREPLY

DPMSG_ENUMSESSIONSREQUEST

typedef struct tagDPMSG_ENUMSESSIONSREQUEST DPMSG_ENUMSESSIONSREQUEST

DPMSG_FORWARDADDPLAYER

typedef struct tagDPMSG_FORWARDADDPLAYER DPMSG_FORWARDADDPLAYER

DPMSG_FORWARDADDPLAYERNACK

typedef struct tagDPMSG_FORWARDADDPLAYERNACK DPMSG_FORWARDADDPLAYERNACK

DPMSG_NEWPLAYERIDREPLY

typedef struct tagDPMSG_NEWPLAYERIDREPLY DPMSG_NEWPLAYERIDREPLY

DPMSG_REQUESTNEWPLAYERID

typedef struct tagDPMSG_REQUESTNEWPLAYERID DPMSG_REQUESTNEWPLAYERID

DPMSG_SENDENVELOPE

typedef struct tagDPMSG_SENDENVELOPE DPMSG_SENDENVELOPE

DPMSG_SYSMSGENVELOPE

typedef struct tagDPMSG_SYSMSGENVELOPE DPMSG_SYSMSGENVELOPE

LPCDPMSG_CREATESESSION

typedef const DPMSG_CREATESESSION* LPCDPMSG_CREATESESSION

Definition at line 211 of file dplayx_messages.h.

LPCDPMSG_ENUMSESSIONSREPLY

typedef const DPMSG_ENUMSESSIONSREPLY* LPCDPMSG_ENUMSESSIONSREPLY

Definition at line 185 of file dplayx_messages.h.

LPCDPMSG_ENUMSESSIONSREQUEST

typedef const DPMSG_ENUMSESSIONSREQUEST* LPCDPMSG_ENUMSESSIONSREQUEST

Definition at line 199 of file dplayx_messages.h.

LPCDPMSG_FORWARDADDPLAYER

typedef const DPMSG_FORWARDADDPLAYER* LPCDPMSG_FORWARDADDPLAYER

Definition at line 266 of file dplayx_messages.h.

LPCDPMSG_FORWARDADDPLAYERNACK

typedef const DPMSG_FORWARDADDPLAYERNACK* LPCDPMSG_FORWARDADDPLAYERNACK

Definition at line 276 of file dplayx_messages.h.

LPCDPMSG_NEWPLAYERIDREPLY

typedef const DPMSG_NEWPLAYERIDREPLY* LPCDPMSG_NEWPLAYERIDREPLY

Definition at line 235 of file dplayx_messages.h.

LPCDPMSG_REQUESTNEWPLAYERID

typedef const DPMSG_REQUESTNEWPLAYERID* LPCDPMSG_REQUESTNEWPLAYERID

Definition at line 221 of file dplayx_messages.h.

LPCDPMSG_SENDENVELOPE

typedef const DPMSG_SENDENVELOPE* LPCDPMSG_SENDENVELOPE

Definition at line 145 of file dplayx_messages.h.

LPCDPMSG_SYSMSGENVELOPE

typedef const DPMSG_SYSMSGENVELOPE* LPCDPMSG_SYSMSGENVELOPE

Definition at line 155 of file dplayx_messages.h.

LPDPMSG_CREATESESSION

typedef struct tagDPMSG_CREATESESSION * LPDPMSG_CREATESESSION

LPDPMSG_ENUMSESSIONSREPLY

typedef struct tagDPMSG_ENUMSESSIONSREPLY * LPDPMSG_ENUMSESSIONSREPLY

LPDPMSG_ENUMSESSIONSREQUEST

typedef struct tagDPMSG_ENUMSESSIONSREQUEST * LPDPMSG_ENUMSESSIONSREQUEST

LPDPMSG_FORWARDADDPLAYER

typedef struct tagDPMSG_FORWARDADDPLAYER * LPDPMSG_FORWARDADDPLAYER

LPDPMSG_FORWARDADDPLAYERNACK

typedef struct tagDPMSG_FORWARDADDPLAYERNACK * LPDPMSG_FORWARDADDPLAYERNACK

LPDPMSG_NEWPLAYERIDREPLY

typedef struct tagDPMSG_NEWPLAYERIDREPLY * LPDPMSG_NEWPLAYERIDREPLY

LPDPMSG_REQUESTNEWPLAYERID

typedef struct tagDPMSG_REQUESTNEWPLAYERID * LPDPMSG_REQUESTNEWPLAYERID

LPDPMSG_SENDENVELOPE

typedef struct tagDPMSG_SENDENVELOPE * LPDPMSG_SENDENVELOPE

LPDPMSG_SYSMSGENVELOPE

typedef struct tagDPMSG_SYSMSGENVELOPE * LPDPMSG_SYSMSGENVELOPE

Function Documentation

CreateLobbyMessageReceptionThread()

DWORD CreateLobbyMessageReceptionThread	(	HANDLE	hNotifyEvent,
		HANDLE	hStart,
		HANDLE	hDeath,
		HANDLE	hConnRead
	)

Definition at line 57 of file dplayx_messages.c.

{
  DWORD           dwMsgThreadId;
  LPMSGTHREADINFO lpThreadInfo;
  HANDLE          hThread;
 
  lpThreadInfo = malloc( sizeof( *lpThreadInfo ) );
  if( lpThreadInfo == NULL )
  {
    return 0;
  }
 
  /* The notify event may or may not exist. Depends if async comm or not */
  if( hNotifyEvent &&
      !DuplicateHandle( GetCurrentProcess(), hNotifyEvent,
                        GetCurrentProcess(), &lpThreadInfo->hNotifyEvent,
                        0, FALSE, DUPLICATE_SAME_ACCESS ) )
  {
    ERR( "Unable to duplicate event handle\n" );
    goto error;
  }
 
  /* These 3 handles don't need to be duplicated because we don't keep a
   * reference to them where they're created. They're created specifically
   * for the message thread
   */
  lpThreadInfo->hStart       = hStart;
  lpThreadInfo->hDeath       = hDeath;
  lpThreadInfo->hSettingRead = hConnRead;
 
  hThread = CreateThread( NULL,                  /* Security attribs */
                          0,                     /* Stack */
                          DPL_MSG_ThreadMain,    /* Msg reception function */
                          lpThreadInfo,          /* Msg reception func parameter */
                          0,                     /* Flags */
                          &dwMsgThreadId         /* Updated with thread id */
                        );
  if ( hThread == NULL )
  {
    ERR( "Unable to create msg thread\n" );
    goto error;
  }
 
  CloseHandle(hThread);
 
  return dwMsgThreadId;
 
error:
 
  free( lpThreadInfo );
 
  return 0;
}

Referenced by IDirectPlayLobby3AImpl_RunApplication().

DP_MSG_ComputeMessageSize()

DWORD DP_MSG_ComputeMessageSize	(	SGBUFFER *	buffers,
		DWORD	bufferCount
	)

Definition at line 222 of file dplayx_messages.c.

{
  DWORD size = 0;
  DWORD i;
  for ( i = 0; i < bufferCount; ++i )
    size += buffers[ i ].len;
  return size;
}

Referenced by DP_MSG_ForwardPlayerCreation(), DP_MSG_SendAddForwardAck(), DP_MSG_SendAddPlayerToGroup(), DP_MSG_SendCreatePlayer(), DP_MSG_SendPingReply(), DP_MSG_SendRequestPlayerId(), DP_MSG_ToSelf(), and IDirectPlay4Impl_SendEx().

DP_MSG_ForwardPlayerCreation()

HRESULT DP_MSG_ForwardPlayerCreation	(	IDirectPlayImpl *	This,
		DPID	dpidServer,
		WCHAR *	password
	)

Definition at line 550 of file dplayx_messages.c.

{
  LPVOID                   lpMsg;
  DPMSG_FORWARDADDPLAYER   msgBody;
  DWORD                    dwMsgSize;
  DPLAYI_PACKEDPLAYER      playerInfo;
  void                    *spPlayerData;
  DWORD                    spPlayerDataSize;
  void                    *msgHeader;
  HRESULT                  hr;
 
  hr = IDirectPlaySP_GetSPPlayerData( This->dp2->spData.lpISP, dpidServer,
                                      &spPlayerData, &spPlayerDataSize, DPSET_REMOTE );
  if( FAILED( hr ) )
    return hr;
 
  msgBody.envelope.dwMagic    = DPMSGMAGIC_DPLAYMSG;
  msgBody.envelope.wCommandId = DPMSGCMD_FORWARDADDPLAYER;
  msgBody.envelope.wVersion   = DPMSGVER_DP6;
  msgBody.toId                = 0;
  msgBody.playerId            = dpidServer;
  msgBody.groupId             = 0;
  msgBody.createOffset        = sizeof( msgBody );
  msgBody.passwordOffset      = sizeof( msgBody ) + sizeof( playerInfo ) + spPlayerDataSize;
 
  playerInfo.size             = sizeof( playerInfo ) + spPlayerDataSize;
  playerInfo.flags            = DPLAYI_PLAYER_SYSPLAYER | DPLAYI_PLAYER_PLAYERLOCAL;
  playerInfo.id               = dpidServer;
  playerInfo.shortNameLength  = 0;
  playerInfo.longNameLength   = 0;
  playerInfo.spDataLength     = spPlayerDataSize;
  playerInfo.playerDataLength = 0;
  playerInfo.playerCount      = 0;
  playerInfo.systemPlayerId   = dpidServer;
  playerInfo.fixedSize        = sizeof( playerInfo );
  playerInfo.version          = DPMSGVER_DP6;
  playerInfo.parentId         = 0;
 
  /* Send the message */
  {
    WORD replyCommands[] = { DPMSGCMD_GETNAMETABLEREPLY, DPMSGCMD_SUPERENUMPLAYERSREPLY,
                             DPMSGCMD_FORWARDADDPLAYERNACK };
    SGBUFFER buffers[ 6 ] = { 0 };
    DPSP_SENDEXDATA data = { 0 };
 
    buffers[ 0 ].len = This->dp2->spData.dwSPHeaderSize;
    buffers[ 1 ].len = sizeof( msgBody );
    buffers[ 1 ].pData = (UCHAR *) &msgBody;
    buffers[ 2 ].len = sizeof( playerInfo );
    buffers[ 2 ].pData = (UCHAR *) &playerInfo;
    buffers[ 3 ].len = spPlayerDataSize;
    buffers[ 3 ].pData = (UCHAR *) spPlayerData;
    buffers[ 4 ].len = (password ? (lstrlenW( password ) + 1) : 1) * sizeof( WCHAR );
    buffers[ 4 ].pData = (UCHAR *) (password ? password : L"");
    buffers[ 5 ].len = sizeof( This->dp2->lpSessionDesc->dwReserved1 );
    buffers[ 5 ].pData = (UCHAR *) &This->dp2->lpSessionDesc->dwReserved1;
 
    data.lpISP          = This->dp2->spData.lpISP;
    data.dwFlags        = DPSEND_GUARANTEED;
    data.idPlayerTo     = 0; /* Name server */
    data.idPlayerFrom   = dpidServer; /* Sending from session server */
    data.lpSendBuffers  = buffers;
    data.cBuffers       = ARRAYSIZE( buffers );
    data.dwMessageSize  = DP_MSG_ComputeMessageSize( data.lpSendBuffers, data.cBuffers );
    data.bSystemMessage = TRUE; /* Allow reply to be sent */
 
    TRACE( "Sending forward player request with 0x%08lx\n", dpidServer );
 
    hr = DP_MSG_ExpectReply( This, &data,
                             DPMSG_WAIT_60_SECS,
                             replyCommands, ARRAYSIZE( replyCommands ),
                             &lpMsg, &dwMsgSize, &msgHeader );
  }
 
  /* Need to examine the data and extract the new player id */
  if( lpMsg != NULL )
  {
    DPMSG_SENDENVELOPE *envelope;
 
    if( dwMsgSize < sizeof( DPMSG_SENDENVELOPE ) )
    {
      free( msgHeader );
      free( lpMsg );
      return DPERR_GENERIC;
    }
    envelope = (DPMSG_SENDENVELOPE *) lpMsg;
 
    if( envelope->wCommandId == DPMSGCMD_SUPERENUMPLAYERSREPLY )
    {
      DPSP_MSG_SUPERENUMPLAYERSREPLY *enumPlayersReply;
      DWORD offset;
      int i;
 
      if( dwMsgSize < sizeof( DPSP_MSG_SUPERENUMPLAYERSREPLY ) )
      {
        free( msgHeader );
        free( lpMsg );
        return DPERR_GENERIC;
      }
      enumPlayersReply = (DPSP_MSG_SUPERENUMPLAYERSREPLY *) envelope;
 
      offset = enumPlayersReply->packedOffset;
      for( i = 0; i < enumPlayersReply->playerCount; ++i )
      {
        DPPLAYERINFO playerInfo;
 
        hr = DP_MSG_ReadSuperPackedPlayer( (char *) enumPlayersReply, &offset, dwMsgSize,
                                           &playerInfo );
        if( FAILED( hr ) )
        {
          free( msgHeader );
          free( lpMsg );
          return hr;
        }
 
        if ( playerInfo.id == dpidServer )
          continue;
 
        hr = DP_CreatePlayer( This, msgHeader, &playerInfo.id, &playerInfo.name,
            playerInfo.playerData, playerInfo.playerDataLength, playerInfo.spData,
            playerInfo.spDataLength, playerInfo.flags & ~DPLAYI_PLAYER_PLAYERLOCAL, NULL,
            NULL, FALSE );
        if( FAILED( hr ) )
        {
          free( msgHeader );
          free( lpMsg );
          return hr;
        }
      }
      for( i = 0; i < enumPlayersReply->groupCount; ++i )
      {
        DPPLAYERINFO playerInfo;
        int j;
 
        hr = DP_MSG_ReadSuperPackedPlayer( (char *) enumPlayersReply, &offset, dwMsgSize,
                                           &playerInfo );
        if( FAILED( hr ) )
        {
          free( msgHeader );
          free( lpMsg );
          return hr;
        }
 
        hr = DP_CreateGroup( This, msgHeader, &playerInfo.id, &playerInfo.name,
                             playerInfo.playerData, playerInfo.playerDataLength,
                             playerInfo.flags & ~DPLAYI_PLAYER_PLAYERLOCAL, playerInfo.parentId,
                             FALSE );
        if( FAILED( hr ) )
        {
          free( msgHeader );
          free( lpMsg );
          return hr;
        }
 
        for( j = 0; j < playerInfo.playerCount; ++j )
        {
          hr = DP_AddPlayerToGroup( This, playerInfo.id, playerInfo.playerIds[ j ] );
          if( FAILED( hr ) )
          {
            free( msgHeader );
            free( lpMsg );
            return hr;
          }
        }
      }
    }
    else if( envelope->wCommandId == DPMSGCMD_GETNAMETABLEREPLY )
    {
      FIXME( "Name Table reply received: stub\n" );
    }
    else if( envelope->wCommandId == DPMSGCMD_FORWARDADDPLAYERNACK )
    {
      DPSP_MSG_ADDFORWARDREPLY *addForwardReply;
 
      if( dwMsgSize < sizeof( DPSP_MSG_ADDFORWARDREPLY ) )
      {
        free( msgHeader );
        free( lpMsg );
        return DPERR_GENERIC;
      }
      addForwardReply = (DPSP_MSG_ADDFORWARDREPLY *) envelope;
 
      hr = addForwardReply->error;
 
      free( msgHeader );
      free( lpMsg );
 
      return hr;
    }
    free( msgHeader );
    free( lpMsg );
  }
 
  return hr;
}

Referenced by DP_SecureOpen().

DP_MSG_ReadPackedPlayer()

HRESULT DP_MSG_ReadPackedPlayer	(	char *	data,
		DWORD *	offset,
		DWORD	maxSize,
		DPPLAYERINFO *	playerInfo
	)

Definition at line 376 of file dplayx_messages.c.

{
  DPLAYI_PACKEDPLAYER *packedPlayer;
  DWORD offset = *inoutOffset;
  HRESULT hr;
 
  memset( playerInfo, 0, sizeof( DPPLAYERINFO ) );
 
  if( maxSize - offset < sizeof( DPLAYI_PACKEDPLAYER ) )
    return DPERR_GENERIC;
  packedPlayer = (DPLAYI_PACKEDPLAYER *) &data[ offset ];
  offset += sizeof( DPLAYI_PACKEDPLAYER );
 
  playerInfo->flags = packedPlayer->flags;
  playerInfo->id = packedPlayer->id;
  playerInfo->versionOrSystemPlayerId = packedPlayer->version;
  playerInfo->playerDataLength = packedPlayer->playerDataLength;
  playerInfo->spDataLength = packedPlayer->spDataLength;
  playerInfo->playerCount = packedPlayer->playerCount;
  playerInfo->parentId = packedPlayer->parentId;
 
  if( packedPlayer->shortNameLength )
  {
    hr = DP_MSG_ReadSizedString( data, &offset, maxSize, packedPlayer->shortNameLength,
                                 &playerInfo->name.lpszShortName );
    if( FAILED( hr ) )
      return hr;
  }
 
  if( packedPlayer->longNameLength )
  {
    hr = DP_MSG_ReadSizedString( data, &offset, maxSize, packedPlayer->longNameLength,
                                 &playerInfo->name.lpszLongName );
    if( FAILED( hr ) )
      return hr;
  }
 
  if( playerInfo->spDataLength )
  {
    if( maxSize - offset < playerInfo->spDataLength )
      return DPERR_GENERIC;
    playerInfo->spData = &data[ offset ];
    offset += playerInfo->spDataLength;
  }
 
  if( playerInfo->playerDataLength )
  {
    if( maxSize - offset < playerInfo->playerDataLength )
      return DPERR_GENERIC;
    playerInfo->playerData = &data[ offset ];
    offset += playerInfo->playerDataLength;
  }
 
  if( playerInfo->playerCount )
  {
    if( UINT_MAX / sizeof( DPID ) < playerInfo->playerCount )
      return DPERR_GENERIC;
    if( maxSize - offset < playerInfo->playerCount * sizeof( DPID ) )
      return DPERR_GENERIC;
    playerInfo->playerIds = (DPID *) &data[ offset ];
    offset += playerInfo->playerCount * sizeof( DPID );
  }
 
  *inoutOffset = offset;
 
  return S_OK;
}

Referenced by DP_HandleMessage().

DP_MSG_ReplyReceived()

void DP_MSG_ReplyReceived	(	IDirectPlayImpl *	This,
		WORD	wCommandId,
		LPCVOID	lpMsgBody,
		DWORD	dwMsgBodySize,
		const void *	msgHeader
	)

DP_MSG_SendAddForwardAck()

HRESULT DP_MSG_SendAddForwardAck	(	IDirectPlayImpl *	This,
		DPID	id
	)

Definition at line 918 of file dplayx_messages.c.

{
  SGBUFFER buffers[ 2 ] = { 0 };
  DPSP_MSG_ADDFORWARDACK msg;
  DPSP_SENDEXDATA sendData;
  HRESULT hr;
 
  msg.envelope.dwMagic = DPMSGMAGIC_DPLAYMSG;
  msg.envelope.wCommandId = DPMSGCMD_ADDFORWARDACK;
  msg.envelope.wVersion = DPMSGVER_DP6;
  msg.id = id;
 
  buffers[ 0 ].len = This->dp2->spData.dwSPHeaderSize;
  buffers[ 0 ].pData = NULL;
  buffers[ 1 ].len = sizeof( msg );
  buffers[ 1 ].pData = (UCHAR *)&msg;
 
  sendData.lpISP = This->dp2->spData.lpISP;
  sendData.dwFlags = DPSEND_GUARANTEED;
  sendData.idPlayerTo = 0;
  sendData.idPlayerFrom = This->dp2->systemPlayerId;
  sendData.lpSendBuffers = buffers;
  sendData.cBuffers = ARRAYSIZE( buffers );
  sendData.dwMessageSize = DP_MSG_ComputeMessageSize( sendData.lpSendBuffers, sendData.cBuffers );
  sendData.dwPriority = 0;
  sendData.dwTimeout = 0;
  sendData.lpDPContext = NULL;
  sendData.lpdwSPMsgID = NULL;
  sendData.bSystemMessage = TRUE;
 
  hr = (*This->dp2->spData.lpCB->SendEx)( &sendData );
  if( FAILED( hr ) )
  {
    ERR( "Send failed: %s\n", DPLAYX_HresultToString( hr ) );
    return hr;
  }
 
  return DP_OK;
}

Referenced by DP_HandleMessage().

DP_MSG_SendAddPlayerToGroup()

HRESULT DP_MSG_SendAddPlayerToGroup	(	IDirectPlayImpl *	This,
		DPID	toId,
		DPID	playerId,
		DPID	groupId
	)

Definition at line 834 of file dplayx_messages.c.

{
  DPSP_SENDTOGROUPEXDATA sendData;
  DPSP_MSG_ADDPLAYERTOGROUP msg;
  SGBUFFER buffers[ 2 ] = { 0 };
  HRESULT hr;
 
  msg.envelope.dwMagic = DPMSGMAGIC_DPLAYMSG;
  msg.envelope.wCommandId = DPMSGCMD_ADDPLAYERTOGROUP;
  msg.envelope.wVersion = DPMSGVER_DP6;
  msg.toId = 0;
  msg.playerId = playerId;
  msg.groupId = groupId;
  msg.createOffset = 0;
  msg.passwordOffset = 0;
 
  buffers[ 0 ].len = This->dp2->spData.dwSPHeaderSize;
  buffers[ 0 ].pData = NULL;
  buffers[ 1 ].len = sizeof( msg );
  buffers[ 1 ].pData = (UCHAR *)&msg;
 
  sendData.lpISP = This->dp2->spData.lpISP;
  sendData.dwFlags = DPSEND_GUARANTEED;
  sendData.idGroupTo = toId;
  sendData.idPlayerFrom = This->dp2->systemPlayerId;
  sendData.lpSendBuffers = buffers;
  sendData.cBuffers = ARRAYSIZE( buffers );
  sendData.dwMessageSize = DP_MSG_ComputeMessageSize( sendData.lpSendBuffers, sendData.cBuffers );
  sendData.dwPriority = 0;
  sendData.dwTimeout = 0;
  sendData.lpDPContext = NULL;
  sendData.lpdwSPMsgID = NULL;
 
  hr = (*This->dp2->spData.lpCB->SendToGroupEx)( &sendData );
  if( FAILED( hr ) )
  {
    ERR( "SendToGroupEx failed: %s\n", DPLAYX_HresultToString( hr ) );
    return hr;
  }
 
  return DP_OK;
}

Referenced by IDirectPlay4Impl_AddPlayerToGroup().

DP_MSG_SendCreatePlayer()

HRESULT DP_MSG_SendCreatePlayer	(	IDirectPlayImpl *	This,
		DPID	toId,
		DPID	id,
		DWORD	flags,
		DPNAME *	name,
		void *	playerData,
		DWORD	playerDataSize,
		DPID	systemPlayerId
	)

Definition at line 746 of file dplayx_messages.c.

{
  DPSP_SENDTOGROUPEXDATA sendData;
  DPLAYI_PACKEDPLAYER playerInfo;
  SGBUFFER buffers[ 8 ] = { 0 };
  UCHAR reserved[ 6 ] = { 0 };
  DWORD shortNameLength = 0;
  DWORD longNameLength = 0;
  DPMSG_CREATESESSION msg;
  DWORD spPlayerDataSize;
  void *spPlayerData;
  HRESULT hr;
 
  hr = IDirectPlaySP_GetSPPlayerData( This->dp2->spData.lpISP, id, &spPlayerData, &spPlayerDataSize,
                                      DPSET_REMOTE );
  if( FAILED( hr ) )
    return hr;
 
  if ( name->lpszShortName )
    shortNameLength = ( lstrlenW( name->lpszShortName ) + 1 ) * sizeof( WCHAR );
 
  if ( name->lpszLongName )
    longNameLength = ( lstrlenW( name->lpszLongName ) + 1 ) * sizeof( WCHAR );
 
  msg.envelope.dwMagic = DPMSGMAGIC_DPLAYMSG;
  msg.envelope.wCommandId = DPMSGCMD_CREATESESSION;
  msg.envelope.wVersion = DPMSGVER_DP6;
  msg.toId = 0;
  msg.playerId = id;
  msg.groupId = 0;
  msg.createOffset = sizeof( DPMSG_CREATESESSION );
  msg.passwordOffset = 0;
 
  playerInfo.size = sizeof( DPLAYI_PACKEDPLAYER ) + shortNameLength + longNameLength
                  + spPlayerDataSize + playerDataSize;
  playerInfo.flags = flags;
  playerInfo.id = id;
  playerInfo.shortNameLength = shortNameLength;
  playerInfo.longNameLength = longNameLength;
  playerInfo.spDataLength = spPlayerDataSize;
  playerInfo.playerDataLength = playerDataSize;
  playerInfo.playerCount = 0;
  playerInfo.systemPlayerId = systemPlayerId;
  playerInfo.fixedSize = sizeof( DPLAYI_PACKEDPLAYER );
  playerInfo.version = DPMSGVER_DP6;
  playerInfo.parentId = 0;
 
  buffers[ 0 ].len = This->dp2->spData.dwSPHeaderSize;
  buffers[ 0 ].pData = NULL;
  buffers[ 1 ].len = sizeof( msg );
  buffers[ 1 ].pData = (UCHAR *)&msg;
  buffers[ 2 ].len = sizeof( playerInfo );
  buffers[ 2 ].pData = (UCHAR *)&playerInfo;
  buffers[ 3 ].len = shortNameLength;
  buffers[ 3 ].pData = (UCHAR *)name->lpszShortName;
  buffers[ 4 ].len = longNameLength;
  buffers[ 4 ].pData = (UCHAR *)name->lpszLongName;
  buffers[ 5 ].len = spPlayerDataSize;
  buffers[ 5 ].pData = spPlayerData;
  buffers[ 6 ].len = playerDataSize;
  buffers[ 6 ].pData = playerData;
  buffers[ 7 ].len = sizeof( reserved );
  buffers[ 7 ].pData = reserved;
 
  sendData.lpISP = This->dp2->spData.lpISP;
  sendData.dwFlags = DPSEND_GUARANTEED;
  sendData.idGroupTo = toId;
  sendData.idPlayerFrom = This->dp2->systemPlayerId;
  sendData.lpSendBuffers = buffers;
  sendData.cBuffers = ARRAYSIZE( buffers );
  sendData.dwMessageSize = DP_MSG_ComputeMessageSize( sendData.lpSendBuffers, sendData.cBuffers );
  sendData.dwPriority = 0;
  sendData.dwTimeout = 0;
  sendData.lpDPContext = NULL;
  sendData.lpdwSPMsgID = NULL;
 
  hr = (*This->dp2->spData.lpCB->SendToGroupEx)( &sendData );
  if( FAILED( hr ) )
  {
    ERR( "SendToGroupEx failed: %s\n", DPLAYX_HresultToString( hr ) );
    return hr;
  }
 
  return DP_OK;
}

Referenced by DP_IF_CreatePlayer().

DP_MSG_SendPingReply()

HRESULT DP_MSG_SendPingReply	(	IDirectPlayImpl *	This,
		DPID	toId,
		DPID	fromId,
		DWORD	tickCount
	)

Definition at line 877 of file dplayx_messages.c.

{
  SGBUFFER buffers[ 2 ] = { 0 };
  DPSP_SENDEXDATA sendData;
  DPSP_MSG_PING msg;
  HRESULT hr;
 
  msg.envelope.dwMagic = DPMSGMAGIC_DPLAYMSG;
  msg.envelope.wCommandId = DPMSGCMD_PINGREPLY;
  msg.envelope.wVersion = DPMSGVER_DP6;
  msg.fromId = fromId;
  msg.tickCount = tickCount;
 
  buffers[ 0 ].len = This->dp2->spData.dwSPHeaderSize;
  buffers[ 0 ].pData = NULL;
  buffers[ 1 ].len = sizeof( msg );
  buffers[ 1 ].pData = (UCHAR *)&msg;
 
  sendData.lpISP = This->dp2->spData.lpISP;
  sendData.dwFlags = 0;
  sendData.idPlayerTo = toId;
  sendData.idPlayerFrom = This->dp2->systemPlayerId;
  sendData.lpSendBuffers = buffers;
  sendData.cBuffers = ARRAYSIZE( buffers );
  sendData.dwMessageSize = DP_MSG_ComputeMessageSize( sendData.lpSendBuffers, sendData.cBuffers );
  sendData.dwPriority = 0;
  sendData.dwTimeout = 0;
  sendData.lpDPContext = NULL;
  sendData.lpdwSPMsgID = NULL;
  sendData.bSystemMessage = TRUE;
 
  hr = (*This->dp2->spData.lpCB->SendEx)( &sendData );
  if( FAILED( hr ) )
  {
    ERR( "Send failed: %s\n", DPLAYX_HresultToString( hr ) );
    return hr;
  }
 
  return DP_OK;
}

Referenced by DP_HandleMessage().

DP_MSG_SendRequestPlayerId()

HRESULT DP_MSG_SendRequestPlayerId	(	IDirectPlayImpl *	This,
		DWORD	dwFlags,
		LPDPID	lpdipidAllocatedId
	)

DP_MSG_ToSelf()

void DP_MSG_ToSelf	(	IDirectPlayImpl *	This,
		DPID	dpidSelf
	)

Definition at line 1046 of file dplayx_messages.c.

{
  LPVOID                   lpMsg;
  void                    *msgHeader;
  DPMSG_SENDENVELOPE       msgBody;
  DWORD                    dwMsgSize;
 
  /* Compose dplay message envelope */
  msgBody.dwMagic    = DPMSGMAGIC_DPLAYMSG;
  msgBody.wCommandId = DPMSGCMD_JUSTENVELOPE;
  msgBody.wVersion   = DPMSGVER_DP6;
 
  /* Send the message to ourselves */
  {
    WORD replyCommand = DPMSGCMD_JUSTENVELOPE;
    SGBUFFER buffers[ 2 ] = { 0 };
    DPSP_SENDEXDATA data = { 0 };
 
    buffers[ 0 ].len = This->dp2->spData.dwSPHeaderSize;
    buffers[ 1 ].len = sizeof( msgBody );
    buffers[ 1 ].pData = (UCHAR *) &msgBody;
 
    data.lpISP          = This->dp2->spData.lpISP;
    data.dwFlags        = 0;
    data.idPlayerTo     = dpidSelf; /* Sending to session server */
    data.idPlayerFrom   = 0; /* Sending from session server */
    data.lpSendBuffers  = buffers;
    data.cBuffers       = ARRAYSIZE( buffers );
    data.dwMessageSize  = DP_MSG_ComputeMessageSize( data.lpSendBuffers, data.cBuffers );
    data.bSystemMessage = TRUE; /* Allow reply to be sent */
 
    DP_MSG_ExpectReply( This, &data,
                        DPMSG_WAIT_5_SECS,
                        &replyCommand, 1,
                        &lpMsg, &dwMsgSize, &msgHeader );
  }
}

Referenced by DP_HandleMessage().