1

/* $Id$ */

     2

     3

#ifdef ENABLE_NETWORK

     4

     5

#include "../../stdafx.h"

     6

#include "../../debug.h"

     7

#include "os_abstraction.h"

     8

#include "core.h"

     9

#include "packet.h"

    10

    11

/**

    12

 * @file core.cpp Functions used to initialize/shut down the core network

    13

 */

    14

    15

#ifdef __MORPHOS__

    16

/* the library base is required here */

    17

struct Library *SocketBase = NULL;

    18

#endif

    19

    20

/**

    21

 * Initializes the network core (as that is needed for some platforms

    22

 * @return true if the core has been initialized, false otherwise

    23

 */

    24

bool NetworkCoreInitialize(void)

    25

{

    26

#if defined(__MORPHOS__) || defined(__AMIGA__)

    27

	/*

    28

	 *  IMPORTANT NOTE: SocketBase needs to be initialized before we use _any_

    29

	 *  network related function, else: crash.

    30

	 */

    31

	DEBUG(net, 3, "[core] loading bsd socket library");

    32

	SocketBase = OpenLibrary("bsdsocket.library", 4);

    33

	if (SocketBase == NULL) {

    34

		DEBUG(net, 0, "[core] can't open bsdsocket.library version 4, network unavailable");

    35

		return false;

    36

	}

    37

    38

#if defined(__AMIGA__)

    39

	/* for usleep() implementation (only required for legacy AmigaOS builds) */

    40

	TimerPort = CreateMsgPort();

    41

	if (TimerPort != NULL) {

    42

		TimerRequest = (struct timerequest*)CreateIORequest(TimerPort, sizeof(struct timerequest);

    43

		if (TimerRequest != NULL) {

    44

			if (OpenDevice("timer.device", UNIT_MICROHZ, (struct IORequest*)TimerRequest, 0) == 0) {

    45

				TimerBase = TimerRequest->tr_node.io_Device;

    46

				if (TimerBase == NULL) {

    47

					/* free ressources... */

    48

					DEBUG(net, 0, "[core] can't initialize timer, network unavailable");

    49

					return false;

    50

				}

    51

			}

    52

		}

    53

	}

    54

#endif // __AMIGA__

    55

#endif // __MORPHOS__ / __AMIGA__

    56

    57

/* Let's load the network in windows */

    58

#ifdef WIN32

    59

	{

    60

		WSADATA wsa;

    61

		DEBUG(net, 3, "[core] loading windows socket library");

    62

		if (WSAStartup(MAKEWORD(2, 0), &wsa) != 0) {

    63

			DEBUG(net, 0, "[core] WSAStartup failed, network unavailable");

    64

			return false;

    65

		}

    66

	}

    67

#endif /* WIN32 */

    68

    69

	return true;

    70

}

    71

    72

/**

    73

 * Shuts down the network core (as that is needed for some platforms

    74

 */

    75

void NetworkCoreShutdown(void)

    76

{

    77

#if defined(__MORPHOS__) || defined(__AMIGA__)

    78

	/* free allocated resources */

    79

#if defined(__AMIGA__)

    80

	if (TimerBase    != NULL) CloseDevice((struct IORequest*)TimerRequest); // XXX This smells wrong

    81

	if (TimerRequest != NULL) DeleteIORequest(TimerRequest);

    82

	if (TimerPort    != NULL) DeleteMsgPort(TimerPort);

    83

#endif

    84

    85

	if (SocketBase != NULL) CloseLibrary(SocketBase);

    86

#endif

    87

    88

#if defined(WIN32)

    89

	WSACleanup();

    90

#endif

    91

}

    92

    93

    94

/**

    95

 * Serializes the GRFIdentifier (GRF ID and MD5 checksum) to the packet

    96

 * @param p   the packet to write the data to

    97

 * @param grf the GRFIdentifier to serialize

    98

 */

    99

void NetworkSocketHandler::Send_GRFIdentifier(Packet *p, const GRFIdentifier *grf)

   100

{

   101

	uint j;

   103

	for (j = 0; j < sizeof(grf->md5sum); j++) {

   105

	}

   106

}

   107

   108

/**

   109

 * Deserializes the GRFIdentifier (GRF ID and MD5 checksum) from the packet

   110

 * @param p   the packet to read the data from

   111

 * @param grf the GRFIdentifier to deserialize

   112

 */

   113

void NetworkSocketHandler::Recv_GRFIdentifier(Packet *p, GRFIdentifier *grf)

   114

{

   115

	uint j;

   117

	for (j = 0; j < sizeof(grf->md5sum); j++) {

   119

	}

   120

}

   121

   122

#endif /* ENABLE_NETWORK */