Subversion Repositories Games.Carmageddon

#include "pd/net.h"

#include "brender/brender.h"

#include "dr_types.h"

#include "errors.h"

#include "globvrpb.h"

#include "harness/config.h"

#include "harness/hooks.h"

#include "harness/trace.h"

#include "harness/winsock.h"

#include "network.h"

#include "pd/net.h"

#include "pd/sys.h"

#include <ctype.h>

#include <stdlib.h>

#include <string.h>

// dethrace: have switched out IPX implementation for IP

tU32 gNetwork_init_flags;

tPD_net_game_info* gJoinable_games;

int gMatts_PC;

tU16 gSocket_number_pd_format;

//_IPX_ELEMENT gListen_elements[16];

char gLocal_ipx_addr_string[32];

//_IPX_ELEMENT gSend_elements[16];

struct sockaddr_in* gLocal_addr_ipx;

char gReceive_buffer[512];

tPD_net_player_info gRemote_net_player_info;

struct sockaddr_in* gBroadcast_addr_ipx;

tPD_net_player_info gLocal_net_player_info;

char gSend_buffer[512];

tIPX_netnum gNetworks[16];

struct sockaddr_in* gRemote_addr_ipx;

tU8* gSend_packet;

// W32 gListen_segment;

tU8* gSend_packet_ptr;

// W32 gSend_segment;

tU8* gListen_packet;

tU8* gListen_packet_ptr;

size_t gMsg_header_strlen;

int gNumber_of_networks;

int gNumber_of_hosts;

//_IPX_HEADER gLast_received_IPX_header;

tU16 gSocket_number_network_order;

// unsigned short gECB_offset;

tU16 gListen_selector;

tU16 gSend_selector;

struct sockaddr_in gLocal_addr;

struct sockaddr_in gRemote_addr;

struct sockaddr_in gBroadcast_addr;

struct sockaddr_in gLast_received_addr;

int gSocket;

#define MESSAGE_HEADER_STR "CW95MSG"

#define JOINABLE_GAMES_CAPACITY 16

// IDA: void __cdecl ClearupPDNetworkStuff()

void ClearupPDNetworkStuff(void) {

    LOG_TRACE("()");

    NOT_IMPLEMENTED();

}

// IDA: void __usercall MATTMessageCheck(char *pFunction_name@<EAX>, tNet_message *pMessage@<EDX>, int pAlleged_size@<EBX>)

void MATTMessageCheck(char* pFunction_name, tNet_message* pMessage, int pAlleged_size) {

    LOG_TRACE("(\"%s\", %p, %d)", pFunction_name, pMessage, pAlleged_size);

    NOT_IMPLEMENTED();

}

// IDA: int __usercall GetProfileText@<EAX>(char *pDest@<EAX>, int pDest_len@<EDX>, char *pFname@<EBX>, char *pKeyname@<ECX>)

int GetProfileText(char* pDest, int pDest_len, char* pFname, char* pKeyname) {

    //FILE* fp; // Pierre-Marie Baty -- unused variable

    //char in_buf[256]; // Pierre-Marie Baty -- unused variable

    //int i; // Pierre-Marie Baty -- unused variable

    //int j; // Pierre-Marie Baty -- unused variable

    //int len; // Pierre-Marie Baty -- unused variable

    LOG_TRACE("(\"%s\", %d, \"%s\", \"%s\")", pDest, pDest_len, pFname, pKeyname);

    NOT_IMPLEMENTED();

}

// IDA: int __cdecl GetSocketNumberFromProfileFile()

int GetSocketNumberFromProfileFile(void) {

    //char str[256]; // Pierre-Marie Baty -- unused variable

    //int sscanf_res; // Pierre-Marie Baty -- unused variable

    //tU32 socknum; // Pierre-Marie Baty -- unused variable

    LOG_TRACE("()");

    NOT_IMPLEMENTED();

}

// tU32 EthernetAddressToU32(SOCKADDR_IPX_* pAddr_ipx) {

//     LOG_TRACE("(%p)", pAddr_ipx);

//     NOT_IMPLEMENTED();

// }

void NetNowIPXLocalTarget2String(char* pString, struct sockaddr_in* pSock_addr_ipx) {

    LOG_TRACE("(\"%s\", %p)", pString, pSock_addr_ipx);

    char portbuf[10];

    inet_ntop(AF_INET, &pSock_addr_ipx->sin_addr, pString, 32);

    sprintf(portbuf, ":%d", ntohs(pSock_addr_ipx->sin_port));

    strcat(pString, portbuf);

}

// IDA: int __usercall GetMessageTypeFromMessage@<EAX>(char *pMessage_str@<EAX>)

int GetMessageTypeFromMessage(char* pMessage_str) {

    char* real_msg;

    int msg_type_int;

    LOG_TRACE("(\"%s\")", pMessage_str);

    real_msg = &pMessage_str[4];

    msg_type_int = 0;

    // FIXME: "CW95MSG" value is used in and depends on platform

    if (strncmp(real_msg, MESSAGE_HEADER_STR, gMsg_header_strlen) == 0) {

        if (isdigit(real_msg[gMsg_header_strlen])) {

            msg_type_int = real_msg[gMsg_header_strlen] - '0';

        }

        if (msg_type_int != 0 && msg_type_int < 3) {

            return msg_type_int;

        }

    }

    return 999;

}

int SameEthernetAddress(struct sockaddr_in* pAddr_ipx1, struct sockaddr_in* pAddr_ipx2) {

    LOG_TRACE("(%p, %p)", pAddr_ipx1, pAddr_ipx2);

    return memcmp(pAddr_ipx1, pAddr_ipx2, sizeof(struct sockaddr_in)) == 0;

}

/*SOCKADDR_IPX_* */ void* GetIPXAddrFromPlayerID(tPlayer_ID pPlayer_id) {

    //int i; // Pierre-Marie Baty -- unused variable

    //tU8* nodenum; // Pierre-Marie Baty -- unused variable

    NOT_IMPLEMENTED();

}

// IDA: void __usercall MakeMessageToSend(int pMessage_type@<EAX>)

void MakeMessageToSend(int pMessage_type) {

    LOG_TRACE("(%d)", pMessage_type);

#ifdef DETHRACE_FIX_BUGS

    sprintf(gSend_buffer, "XXXX%s%1d", MESSAGE_HEADER_STR, pMessage_type);

#else

    sprintf(gSend_buffer, "XXXX%s%0.1d", MESSAGE_HEADER_STR, pMessage_type);

#endif

}

// IDA: int __cdecl ReceiveHostResponses()

int ReceiveHostResponses(void) {

    char str[256];

    int i;

    int already_registered;

    LOG_TRACE("()");

    char addr_string[32];

    unsigned int sa_len;

    int wsa_error;

    sa_len = sizeof(gRemote_addr);

    while (1) {

        if (recvfrom(gSocket, gReceive_buffer, sizeof(gReceive_buffer), 0, (struct sockaddr*)&gRemote_addr, &sa_len) == -1) {

            break;

        }

        NetNowIPXLocalTarget2String(addr_string, gRemote_addr_ipx);

        dr_dprintf("ReceiveHostResponses(): Received string '%s' from %s", gReceive_buffer, addr_string);

        if (SameEthernetAddress(gLocal_addr_ipx, gRemote_addr_ipx)) {

            dr_dprintf("*** Discounting the above 'cos we sent it ***");

            continue;

        }

        if (GetMessageTypeFromMessage(gReceive_buffer) != 2) {

            dr_dprintf("*** Discounting the above 'cos it's not a host reply ***");

            continue;

        }

        dr_dprintf("*** It's a host reply! ***");

        already_registered = 0;

        for (i = 0; i < gNumber_of_hosts; i++) {

            if (SameEthernetAddress(&gJoinable_games[i].addr_in, gRemote_addr_ipx)) {

                already_registered = 1;

                break;

            }

        }

        if (already_registered) {

            dr_dprintf("That game already registered");

            gJoinable_games[i].last_response = PDGetTotalTime();

        } else {

            dr_dprintf("Adding joinable game to slot #%d", gNumber_of_hosts);

            gJoinable_games[gNumber_of_hosts].addr_in = *gRemote_addr_ipx;

            gJoinable_games[gNumber_of_hosts].last_response = PDGetTotalTime();

            gNumber_of_hosts++;

            dr_dprintf("Number of games found so far: %d", gNumber_of_hosts);

        }

        if (gNumber_of_hosts) {

            dr_dprintf("Currently registered net games:");

            for (i = 0; i < gNumber_of_hosts; i++) {

                NetNowIPXLocalTarget2String(str, &gJoinable_games[i].addr_in);

                dr_dprintf("%d: Host addr %s", i, str);

            }

        }

    }

    wsa_error = WSAGetLastError() != WSAEWOULDBLOCK;

    if (wsa_error == 0) {

        return 1;

    }

    dr_dprintf("ReceiveHostResponses(): Error on recvfrom() - WSAGetLastError=%d", wsa_error);

    return 0;

}

// IDA: int __cdecl BroadcastMessage()

int BroadcastMessage(void) {

    int i;

    int errors;

    char broadcast_addr_string[32];

    //char* real_msg; // Pierre-Marie Baty -- unused variable

    LOG_TRACE("()");

    errors = 0;

    for (i = 0; i < gNumber_of_networks; i++) {

        //*(_DWORD*)gBroadcast_addr_ipx->sa_netnum = gNetworks[i];

        NetNowIPXLocalTarget2String(broadcast_addr_string, gBroadcast_addr_ipx);

        dr_dprintf("Broadcasting on address '%s'", broadcast_addr_string);

        if (sendto(gSocket, gSend_buffer, strlen(gSend_buffer) + 1, 0, (struct sockaddr*)&gBroadcast_addr, sizeof(gBroadcast_addr)) == -1) {

            dr_dprintf("BroadcastMessage(): Error on sendto() - WSAGetLastError=%d", WSAGetLastError());

            errors = 1;

        }

    }

    return errors == 0;

}

// IDA: int __cdecl PDNetInitialise()

int PDNetInitialise(void) {

    //tU32 timenow; // Pierre-Marie Baty -- unused variable

    //char profile_string[32]; // Pierre-Marie Baty -- unused variable

    //char key_name[32]; // Pierre-Marie Baty -- unused variable

    //int sscanf_res; // Pierre-Marie Baty -- unused variable

    //int i; // Pierre-Marie Baty -- unused variable

    //tU32 netnum; // Pierre-Marie Baty -- unused variable

    //char str[256]; // Pierre-Marie Baty -- unused variable

    //int mess_num; // Pierre-Marie Baty -- unused variable

    struct linger so_linger;

    unsigned int sa_len;

    WSADATA wsadata;

    LOG_TRACE("()");

    sa_len = sizeof(struct sockaddr_in);

    dr_dprintf("PDNetInitialise()");

    int ipx_socket_num = 12286;

    // Dont bother to handle network.ini

    // if (gWin32_should_load_network_ini) {

    //     if (GetPrivateProfileStringA(

    //             "Network",

    //             "IPXSocket",

    //             Default,

    //             (LPSTR)ReturnedString,

    //             0x20u,

    //             gNetwork_profile_fname)) {

    //         v11 = sscanf(ReturnedString, "%x", &v9);

    //         if (v11) {

    //             if (v11 != -1) {

    //                 dr_dprintf("New IPX socket %4.4x", v9);

    //                 ipx_socket_num = sub_454930(v9);

    //             }

    //         }

    //     }

    // }

    gLocal_addr_ipx = &gLocal_addr;

    gRemote_addr_ipx = &gRemote_addr;

    gBroadcast_addr_ipx = &gBroadcast_addr;

    memset(&gLocal_addr, 0, sizeof(struct sockaddr_in));

    memset(&gRemote_addr, 0, sizeof(struct sockaddr_in));

    memset(&gBroadcast_addr, 0, sizeof(struct sockaddr_in));

    // gLocal_addr_ipx->sa_family = AF_IPX;

    // gRemote_addr_ipx->sa_family = AF_IPX;

    // gBroadcast_addr_ipx->sa_family = AF_IPX;

    // gLocal_addr_ipx->sa_socket = ipx_socket_num;

    // gRemote_addr_ipx->sa_socket = ipx_socket_num;

    // gBroadcast_addr_ipx->sa_socket = ipx_socket_num;

    // // IPX broadcast

    // gBroadcast_addr_ipx->sa_nodenum[0] = -1;

    // gBroadcast_addr_ipx->sa_nodenum[1] = -1;

    // gBroadcast_addr_ipx->sa_nodenum[2] = -1;

    // gBroadcast_addr_ipx->sa_nodenum[3] = -1;

    // gBroadcast_addr_ipx->sa_nodenum[4] = -1;

    // gBroadcast_addr_ipx->sa_nodenum[5] = -1;

    gLocal_addr.sin_family = AF_INET;

    gLocal_addr.sin_port = htons(12286);

    gLocal_addr.sin_addr.s_addr = INADDR_ANY;

    gRemote_addr.sin_family = AF_INET;

    gRemote_addr.sin_port = htons(12286);

    gBroadcast_addr.sin_family = AF_INET;

    gBroadcast_addr.sin_port = htons(12286);

    // original code was using MAKEWORD(1, 1)

    if (WSAStartup(MAKEWORD(2, 2), &wsadata) == -1) {

        dr_dprintf("PDNetInitialise(): WSAStartup() failed");

        return -1;

    }

    // gSocket = socket(6, 2, 1000);

    gSocket = socket(AF_INET, SOCK_DGRAM, 0);

    if (gSocket == -1) {

        dr_dprintf("PDNetInitialise(): Failed to create socket - WSAGetLastError=%d", WSAGetLastError());

        WSACleanup();

        return -1;

    }

    int broadcast = 1;

    setsockopt(gSocket, SOL_SOCKET, SO_BROADCAST, (void *) &broadcast, sizeof(broadcast)); // Pierre-Marie Baty -- added portable type cast

    so_linger.l_onoff = 1;

    so_linger.l_linger = 0;

    setsockopt(gSocket, SOL_SOCKET, SO_LINGER, (void *) &so_linger, sizeof(so_linger)); // Pierre-Marie Baty -- added portable type cast

    unsigned long nobio = 1;

    if (ioctlsocket(gSocket, FIONBIO, &nobio) == -1) {

        dr_dprintf("Error on ioctlsocket() - WSAGetLastError=%d", WSAGetLastError());

        closesocket(gSocket);

        WSACleanup();

        return -1;

    }

    if (harness_game_config.no_bind == 0) {

        if (bind(gSocket, (struct sockaddr*)&gLocal_addr, sizeof(gLocal_addr)) == -1) {

            dr_dprintf("Error on bind() - WSAGetLastError=%d", WSAGetLastError());

            closesocket(gSocket);

            WSACleanup();

            return -1;

        }

    }

    int res = getsockname(gSocket, (struct sockaddr*)&gLocal_addr, &sa_len);

    NetNowIPXLocalTarget2String(gLocal_ipx_addr_string, gLocal_addr_ipx);

    // gNetworks[0] = *(tIPX_netnum*)gLocal_addr_ipx->sa_netnum;

    gNumber_of_networks = 1;

    // if (gWin32_should_load_network_ini) {

    //     for (i = 1; i <= 15; ++i) {

    //         sprintf(KeyName, "%s%d", "Network", i);

    //         if (GetPrivateProfileStringA(

    //                 "Network",

    //                 KeyName,

    //                 Default,

    //                 (LPSTR)ReturnedString,

    //                 0x20u,

    //                 gNetwork_profile_fname)) {

    //             v11 = sscanf(ReturnedString, "%x", &network_nbr);

    //             if (v11) {

    //                 if (v11 != -1) {

    //                     dr_dprintf("Found network number '%x' in INI file", network_nbr);

    //                     gNetworks[gNumber_of_networks].bNetwork[0] = HIBYTE(network_nbr);

    //                     gNetworks[gNumber_of_networks].bNetwork[1] = (network_nbr & 0xFF0000u) >> 16;

    //                     gNetworks[gNumber_of_networks].bNetwork[2] = BYTE1(network_nbr);

    //                     gNetworks[gNumber_of_networks].bNetwork[3] = network_nbr;

    //                     if (gNetworks[gNumber_of_networks].bNetwork[0] != gLocal_addr_ipx->sa_netnum[0]

    //                         || gNetworks[gNumber_of_networks].bNetwork[1] != gLocal_addr_ipx->sa_netnum[1]

    //                         || gNetworks[gNumber_of_networks].bNetwork[2] != gLocal_addr_ipx->sa_netnum[2]

    //                         || gNetworks[gNumber_of_networks].bNetwork[3] != gLocal_addr_ipx->sa_netnum[3]) {

    //                         ++gNumber_of_networks;

    //                     }

    //                 }

    //             }

    //         }

    //     }

    //     dr_dprintf("Total networks = %d", gNumber_of_networks);

    // }

    // byte_536440 = *gLocal_addr_ipx;

    dr_dprintf("Socket bound OK; local address is '%s'", gLocal_ipx_addr_string);

    gMsg_header_strlen = 7;

    if (strstr(gLocal_ipx_addr_string, "00a0240f9fac")) {

        gMatts_PC = 1;

    }

    return 0;

}

// IDA: int __cdecl PDNetShutdown()

int PDNetShutdown(void) {

    LOG_TRACE("()");

    dr_dprintf("PDNetShutdown()");

    if (gSocket != -1) {

        closesocket(gSocket);

    }

    gSocket = -1;

    return 0;

}

// IDA: void __cdecl PDNetStartProducingJoinList()

void PDNetStartProducingJoinList(void) {

    LOG_TRACE("()");

    dr_dprintf("PDNetStartProducingJoinList()");

    gNumber_of_hosts = 0;

    gJoinable_games = BrMemAllocate(sizeof(tPD_net_game_info) * JOINABLE_GAMES_CAPACITY, 0x80u);

    if (gJoinable_games == NULL) {

        PDFatalError("Can't allocate memory for joinable games");

    }

}

// IDA: void __cdecl PDNetEndJoinList()

void PDNetEndJoinList(void) {

    LOG_TRACE("()");

    dr_dprintf("PDNetEndJoinList()");

    if (gJoinable_games) {

        BrMemFree(gJoinable_games);

    }

    gJoinable_games = NULL;

}

// IDA: int __usercall PDNetGetNextJoinGame@<EAX>(tNet_game_details *pGame@<EAX>, int pIndex@<EDX>)

int PDNetGetNextJoinGame(tNet_game_details* pGame, int pIndex) {

    static tU32 next_broadcast_time = 0;

    int i;

    int j;

    int number_of_hosts_has_changed;

    //char str[256]; // Pierre-Marie Baty -- unused variable

    LOG_TRACE9("(%p, %d)", pGame, pIndex);

    dr_dprintf("PDNetGetNextJoinGame(): pIndex is %d", pIndex);

    if (pIndex == 0) {

        do {

            number_of_hosts_has_changed = 0;

            for (i = 0; i < gNumber_of_hosts; i++) {

                if (gJoinable_games[i].last_response + 10000 < (tU32) PDGetTotalTime()) { // Pierre-Marie Baty -- added type cast

                    number_of_hosts_has_changed = 1;

                    for (j = i; j < gNumber_of_hosts - 1; j++) {

                        memcpy(&gJoinable_games[j], &gJoinable_games[j + 1], sizeof(tPD_net_game_info));

                    }

                }

            }

            if (number_of_hosts_has_changed) {

                gNumber_of_hosts--;

            }

        } while (number_of_hosts_has_changed);

        if ((tU32) PDGetTotalTime() > next_broadcast_time) { // Pierre-Marie Baty -- added type cast

            next_broadcast_time = PDGetTotalTime() + 3000;

            MakeMessageToSend(1);

            if (BroadcastMessage() == 0) {

                dr_dprintf("PDNetGetNextJoinGame(): Error on BroadcastMessage()");

            }

        }

    }

    ReceiveHostResponses();

    if (gNumber_of_hosts <= pIndex) {

        return 0;

    }

    dr_dprintf("PDNetGetNextJoinGame(): Adding game.");

    memcpy(&pGame->pd_net_info.addr_in, &gJoinable_games[pIndex].addr_in, sizeof(pGame->pd_net_info.addr_in));

    return 1;

}

// IDA: void __usercall PDNetDisposeGameDetails(tNet_game_details *pDetails@<EAX>)

void PDNetDisposeGameDetails(tNet_game_details* pDetails) {

    LOG_TRACE("(%p)", pDetails);

    NOT_IMPLEMENTED();

}

// IDA: int __usercall PDNetHostGame@<EAX>(tNet_game_details *pDetails@<EAX>, char *pHost_name@<EDX>, void **pHost_address@<EBX>)

int PDNetHostGame(tNet_game_details* pDetails, char* pHost_name, void** pHost_address) {

    LOG_TRACE("(%p, \"%s\", %p)", pDetails, pHost_name, pHost_address);

    dr_dprintf("PDNetHostGame()");

    *pHost_address = &gLocal_addr;

    return 1;

}

// IDA: int __usercall PDNetJoinGame@<EAX>(tNet_game_details *pDetails@<EAX>, char *pPlayer_name@<EDX>)

int PDNetJoinGame(tNet_game_details* pDetails, char* pPlayer_name) {

    LOG_TRACE("(%p, \"%s\")", pDetails, pPlayer_name);

    dr_dprintf("PDNetJoinGame()");

    return 0;

}

// IDA: void __usercall PDNetLeaveGame(tNet_game_details *pDetails@<EAX>)

void PDNetLeaveGame(tNet_game_details* pDetails) {

    LOG_TRACE("(%p)", pDetails);

    dr_dprintf("PDNetLeaveGame()");

}

// IDA: void __usercall PDNetHostFinishGame(tNet_game_details *pDetails@<EAX>)

void PDNetHostFinishGame(tNet_game_details* pDetails) {

    LOG_TRACE("(%p)", pDetails);

    dr_dprintf("PDNetHostFinishGame()");

}

// IDA: tU32 __usercall PDNetExtractGameID@<EAX>(tNet_game_details *pDetails@<EAX>)

tU32 PDNetExtractGameID(tNet_game_details* pDetails) {

    LOG_TRACE("(%p)", pDetails);

    dr_dprintf("PDNetExtractGameID()");

    return ntohs(pDetails->pd_net_info.addr_in.sin_port); // PDGetTotalTime();

}

// IDA: tPlayer_ID __usercall PDNetExtractPlayerID@<EAX>(tNet_game_details *pDetails@<EAX>)

tPlayer_ID PDNetExtractPlayerID(tNet_game_details* pDetails) {

    LOG_TRACE("(%p)", pDetails);

    dr_dprintf("PDNetExtractPlayerID()");

    return ntohs(gLocal_addr_ipx->sin_port);

}

// IDA: void __usercall PDNetObtainSystemUserName(char *pName@<EAX>, int pMax_length@<EDX>)

void PDNetObtainSystemUserName(char* pName, int pMax_length) {

    int result;

    char* found;

    dr_dprintf("PDNetObtainSystemUserName()");

    result = gethostname(pName, pMax_length);

    if (result == 0) {

    }

    while (1) {

        found = strpbrk(pName, "_=(){}[]<>!$%^&*/:@~;'#,?\\|`\"");

        if (found == NULL) {

            break;

        }

        *found = '-';

    }

}

// IDA: int __usercall PDNetSendMessageToPlayer@<EAX>(tNet_game_details *pDetails@<EAX>, tNet_message *pMessage@<EDX>, tPlayer_ID pPlayer@<EBX>)

int PDNetSendMessageToPlayer(tNet_game_details* pDetails, tNet_message* pMessage, tPlayer_ID pPlayer) {

    //char str[256]; // Pierre-Marie Baty -- unused variable

    // SOCKADDR_IPX_* remote_addr_ipx;

    LOG_TRACE("(%p, %p, %d)", pDetails, pMessage, pPlayer);

    NOT_IMPLEMENTED();

}

// IDA: int __usercall PDNetSendMessageToAllPlayers@<EAX>(tNet_game_details *pDetails@<EAX>, tNet_message *pMessage@<EDX>)

int PDNetSendMessageToAllPlayers(tNet_game_details* pDetails, tNet_message* pMessage) {

    //char str[256]; // Pierre-Marie Baty -- unused variable

    int i;

    LOG_TRACE("(%p, %p)", pDetails, pMessage);

    for (i = 0; i < gNumber_of_net_players; ++i) {

        if (i == gThis_net_player_index) {

            continue;

        }

        if (sendto(gSocket, (const char*)pMessage, pMessage->overall_size, 0, (struct sockaddr*)&gNet_players[i].pd_net_info.addr_in, sizeof(gNet_players[i].pd_net_info.addr_in)) == -1) {

            dr_dprintf("PDNetSendMessageToAllPlayers(): Error on sendto() - WSAGetLastError=%d", WSAGetLastError());

            NetDisposeMessage(pDetails, pMessage);

            return 1;

        }

    }

    NetDisposeMessage(pDetails, pMessage);

    return 0;

}

// IDA: tNet_message* __usercall PDNetGetNextMessage@<EAX>(tNet_game_details *pDetails@<EAX>, void **pSender_address@<EDX>)

tNet_message* PDNetGetNextMessage(tNet_game_details* pDetails, void** pSender_address) {

    char* receive_buffer;

    char str[256];

    int msg_type;

    LOG_TRACE("(%p, %p)", pDetails, pSender_address);

    char addr_str[32];

    unsigned int sa_len;

    int res;

    tNet_message* msg;

    sa_len = sizeof(gRemote_addr);

    msg = NetAllocateMessage(512);

    receive_buffer = (char*)msg;

    res = recvfrom(gSocket, receive_buffer, 512, 0, (struct sockaddr*)&gRemote_addr, &sa_len);

    res = res != -1;

    if (res == 0) {

        res = WSAGetLastError() != WSAEWOULDBLOCK;

        if (res) {

            sprintf(str, "PDNetGetNextMessage(): Error on recvfrom() - WSAGetLastError=%d", res);

            PDFatalError(str);

        }

    } else {

        NetNowIPXLocalTarget2String(addr_str, gRemote_addr_ipx);

        if (!SameEthernetAddress(gLocal_addr_ipx, gRemote_addr_ipx)) {

            msg_type = GetMessageTypeFromMessage(receive_buffer);

            switch (msg_type) {

            case 1:

                if (gNet_mode == eNet_mode_host) {

                    dr_dprintf("PDNetGetNextMessage(): Received '%s' from '%s', replying to joiner", receive_buffer, addr_str);

                    MakeMessageToSend(2);

                    if (sendto(gSocket, gSend_buffer, strlen(gSend_buffer) + 1, 0, (struct sockaddr*)&gRemote_addr, sizeof(gRemote_addr)) == -1) {

                        dr_dprintf("PDNetGetNextMessage(): Error on sendto() - WSAGetLastError=%d", WSAGetLastError());

                    }

                }

                break;

            case 2:

                // no-op

                break;

            default:

                dr_dprintf("PDNetGetNextMessage(): res is %d, received message type %d from '%s', passing up", res, msg->contents.header.type, addr_str);

                memcpy(&gLast_received_addr, gRemote_addr_ipx, sizeof(gLast_received_addr));

                *pSender_address = &gLast_received_addr;

                return msg;

            }

        }

    }

    msg->guarantee_number = 0;

    NetDisposeMessage(pDetails, msg);

    return 0;

}

// IDA: tNet_message* __usercall PDNetAllocateMessage@<EAX>(tU32 pSize@<EAX>, tS32 pSize_decider@<EDX>)

tNet_message* PDNetAllocateMessage(tU32 pSize, tS32 pSize_decider) {

    LOG_TRACE("(%d, %d)", pSize, pSize_decider);

    NOT_IMPLEMENTED();

}

// IDA: void __usercall PDNetDisposeMessage(tNet_game_details *pDetails@<EAX>, tNet_message *pMessage@<EDX>)

void PDNetDisposeMessage(tNet_game_details* pDetails, tNet_message* pMessage) {

    LOG_TRACE("(%p, %p)", pDetails, pMessage);

    NOT_IMPLEMENTED();

}

// IDA: void __usercall PDNetSetPlayerSystemInfo(tNet_game_player_info *pPlayer@<EAX>, void *pSender_address@<EDX>)

void PDNetSetPlayerSystemInfo(tNet_game_player_info* pPlayer, void* pSender_address) {

    LOG_TRACE("(%p, %p)", pPlayer, pSender_address);

    dr_dprintf("PDNetSetPlayerSystemInfo()");

    memcpy(&pPlayer->pd_net_info, pSender_address, sizeof(pPlayer->pd_net_info));

}

// IDA: void __usercall PDNetDisposePlayer(tNet_game_player_info *pPlayer@<EAX>)

void PDNetDisposePlayer(tNet_game_player_info* pPlayer) {

    LOG_TRACE("(%p)", pPlayer);

    NOT_IMPLEMENTED();

}

// IDA: int __usercall PDNetSendMessageToAddress@<EAX>(tNet_game_details *pDetails@<EAX>, tNet_message *pMessage@<EDX>, void *pAddress@<EBX>)

int PDNetSendMessageToAddress(tNet_game_details* pDetails, tNet_message* pMessage, void* pAddress) {

    char str[256];

    LOG_TRACE("(%p, %p, %p)", pDetails, pMessage, pAddress);

    NetNowIPXLocalTarget2String(str, (struct sockaddr_in*)pAddress);

    if (pDetails->pd_net_info.addr_in.sin_port == 0) {

        int i = 0;

    }

    if (sendto(gSocket, (const char*)pMessage, pMessage->overall_size, 0, (const struct sockaddr*)pAddress, sizeof(struct sockaddr)) == -1) {

        dr_dprintf("PDNetSendMessageToAddress(): Error on sendto() - WSAGetLastError=%d", WSAGetLastError());

        NetDisposeMessage(pDetails, pMessage);

        return 1;

    }

    NetDisposeMessage(pDetails, pMessage);

    return 0;

}

// IDA: int __usercall PDNetInitClient@<EAX>(tNet_game_details *pDetails@<EAX>)

int PDNetInitClient(tNet_game_details* pDetails) {

    LOG_TRACE("(%p)", pDetails);

    NOT_IMPLEMENTED();

}

// IDA: int __cdecl PDNetGetHeaderSize()

int PDNetGetHeaderSize(void) {

    LOG_TRACE("()");

    return 0;

}