1

/* $Id$ */

     2

     3

#include "../stdafx.h"

     4

     5

#ifdef ENABLE_NETWORK

     6

     7

#include "../openttd.h"

     8

#include "../debug.h"

     9

#include "../gfx_func.h"

    10

#include "../network/network.h"

    11

#include "../console.h"

    12

#include "../variables.h"

    13

#include "../genworld.h"

    14

#include "../fileio.h"

    15

#include "../fios.h"

    16

#include "../blitter/factory.hpp"

    17

#include "../core/alloc_func.hpp"

    19

#include "dedicated_v.h"

    20

    21

#ifdef BEOS_NET_SERVER

    22

#include <net/socket.h>

    23

#endif

    24

    25

#ifdef __OS2__

    26

#	include <sys/time.h> /* gettimeofday */

    27

#	include <sys/types.h>

    28

#	include <unistd.h>

    29

#	include <conio.h>

    30

    31

#	define INCL_DOS

    32

#	include <os2.h>

    33

    34

#	define STDIN 0  /* file descriptor for standard input */

    35

    36

/**

    37

 * Switches OpenTTD to a console app at run-time, instead of a PM app

    38

 * Necessary to see stdout, etc. */

    39

static void OS2_SwitchToConsoleMode()

    40

{

    41

	PPIB pib;

    42

	PTIB tib;

    43

    44

	DosGetInfoBlocks(&tib, &pib);

    45

    46

	// Change flag from PM to VIO

    47

	pib->pib_ultype = 3;

    48

}

    49

#endif

    50

    51

#if defined(UNIX) || defined(PSP)

    52

#	include <sys/time.h> /* gettimeofday */

    53

#	include <sys/types.h>

    54

#	include <unistd.h>

    55

#	include <signal.h>

    56

#	define STDIN 0  /* file descriptor for standard input */

    57

#	if defined(PSP)

    58

#		include <sys/fd_set.h>

    59

#		include <sys/select.h>

    60

#	endif /* PSP */

    61

    62

/* Signal handlers */

    63

static void DedicatedSignalHandler(int sig)

    64

{

    65

	_exit_game = true;

    66

	signal(sig, DedicatedSignalHandler);

    67

}

    68

#endif

    69

    70

#if defined(WIN32)

    71

# include <windows.h> /* GetTickCount */

    72

# if !defined(WINCE)

    73

#  include <conio.h>

    74

# endif

    75

# include <time.h>

    76

# include <tchar.h>

    77

static HANDLE _hInputReady, _hWaitForInputHandling;

    78

static HANDLE _hThread; // Thread to close

    79

static char _win_console_thread_buffer[200];

    80

    81

/* Windows Console thread. Just loop and signal when input has been received */

    82

static void WINAPI CheckForConsoleInput()

    83

{

    84

#if defined(WINCE)

    85

	/* WinCE doesn't support console stuff */

    86

	return;

    87

#else

    88

	DWORD nb;

    89

	HANDLE hStdin = GetStdHandle(STD_INPUT_HANDLE);

    90

	while (true) {

    91

		ReadFile(hStdin, _win_console_thread_buffer, lengthof(_win_console_thread_buffer), &nb, NULL);

    92

		/* Signal input waiting that input is read and wait for it being handled

    93

		 * SignalObjectAndWait() should be used here, but it's unsupported in Win98< */

    94

		SetEvent(_hInputReady);

    95

		WaitForSingleObject(_hWaitForInputHandling, INFINITE);

    96

	}

    97

#endif

    98

}

    99

   100

static void CreateWindowsConsoleThread()

   101

{

   102

	DWORD dwThreadId;

   103

	/* Create event to signal when console input is ready */

   104

	_hInputReady = CreateEvent(NULL, false, false, NULL);

   105

	_hWaitForInputHandling = CreateEvent(NULL, false, false, NULL);

   106

	if (_hInputReady == NULL || _hWaitForInputHandling == NULL) error("Cannot create console event!");

   107

   108

	_hThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)CheckForConsoleInput, NULL, 0, &dwThreadId);

   109

	if (_hThread == NULL) error("Cannot create console thread!");

   110

   111

	DEBUG(driver, 2, "Windows console thread started");

   112

}

   113

   114

static void CloseWindowsConsoleThread()

   115

{

   116

	CloseHandle(_hThread);

   117

	CloseHandle(_hInputReady);

   118

	CloseHandle(_hWaitForInputHandling);

   119

	DEBUG(driver, 2, "Windows console thread shut down");

   120

}

   121

   122

#endif

   123

   124

   125

static void *_dedicated_video_mem;

   126

   127

extern bool SafeSaveOrLoad(const char *filename, int mode, int newgm, Subdirectory subdir);

   128

extern void SwitchMode(int new_mode);

   129

   130

static FVideoDriver_Dedicated iFVideoDriver_Dedicated;

   131

   132

   133

const char *VideoDriver_Dedicated::Start(const char * const *parm)

   134

{

   135

	int bpp = BlitterFactoryBase::GetCurrentBlitter()->GetScreenDepth();

   136

	if (bpp == 0) _dedicated_video_mem = NULL;

   137

	else          _dedicated_video_mem = MallocT<byte>(_cur_resolution[0] * _cur_resolution[1] * (bpp / 8));

   138

   139

	_screen.width = _screen.pitch = _cur_resolution[0];

   140

	_screen.height = _cur_resolution[1];

   141

   142

	SetDebugString("net=6");

   143

   144

#if defined(WINCE)

   145

	/* WinCE doesn't support console stuff */

   146

#elif defined(WIN32)

   147

	// For win32 we need to allocate a console (debug mode does the same)

   148

	CreateConsole();

   149

	CreateWindowsConsoleThread();

   150

	SetConsoleTitle(_T("OpenTTD Dedicated Server"));

   151

#endif

   152

   153

#ifdef __OS2__

   154

	// For OS/2 we also need to switch to console mode instead of PM mode

   155

	OS2_SwitchToConsoleMode();

   156

#endif

   157

   158

	DEBUG(driver, 1, "Loading dedicated server");

   159

	return NULL;

   160

}

   161

   162

void VideoDriver_Dedicated::Stop()

   163

{

   164

#ifdef WIN32

   165

	CloseWindowsConsoleThread();

   166

#endif

   167

	free(_dedicated_video_mem);

   168

}

   169

   170

void VideoDriver_Dedicated::MakeDirty(int left, int top, int width, int height) {}

   171

bool VideoDriver_Dedicated::ChangeResolution(int w, int h) { return false; }

   172

bool VideoDriver_Dedicated::ToggleFullscreen(bool fs) { return false; }

   173

   174

#if defined(UNIX) || defined(__OS2__) || defined(PSP)

   175

static bool InputWaiting()

   176

{

   177

	struct timeval tv;

   178

	fd_set readfds;

   179

   180

	tv.tv_sec = 0;

   181

	tv.tv_usec = 1;

   182

   183

	FD_ZERO(&readfds);

   184

	FD_SET(STDIN, &readfds);

   185

   186

	/* don't care about writefds and exceptfds: */

   187

	return select(STDIN + 1, &readfds, NULL, NULL, &tv) > 0;

   188

}

   189

   190

static uint32 GetTime()

   191

{

   192

	struct timeval tim;

   193

   194

	gettimeofday(&tim, NULL);

   195

	return tim.tv_usec / 1000 + tim.tv_sec * 1000;

   196

}

   197

   198

#else

   199

   200

static bool InputWaiting()

   201

{

   202

	return WaitForSingleObject(_hInputReady, 1) == WAIT_OBJECT_0;

   203

}

   204

   205

static uint32 GetTime()

   206

{

   207

	return GetTickCount();

   208

}

   209

   210

#endif

   211

   212

static void DedicatedHandleKeyInput()

   213

{

   214

	static char input_line[200] = "";

   215

   216

	if (!InputWaiting()) return;

   217

   218

	if (_exit_game) return;

   219

   220

#if defined(UNIX) || defined(__OS2__) || defined(PSP)

   221

	if (fgets(input_line, lengthof(input_line), stdin) == NULL) return;

   222

#else

   223

	/* Handle console input, and singal console thread, it can accept input again */

   224

	strncpy(input_line, _win_console_thread_buffer, lengthof(input_line));

   225

	SetEvent(_hWaitForInputHandling);

   226

#endif

   227

   228

	/* XXX - strtok() does not 'forget' \n\r if it is the first character! */

   229

	strtok(input_line, "\r\n"); // Forget about the final \n (or \r)

   230

	{ /* Remove any special control characters */

   231

		uint i;

   232

		for (i = 0; i < lengthof(input_line); i++) {

   233

			if (input_line[i] == '\n' || input_line[i] == '\r') // cut missed beginning '\0'

   234

				input_line[i] = '\0';

   235

   236

			if (input_line[i] == '\0')

   237

				break;

   238

   239

			if (!IsInsideMM(input_line[i], ' ', 256))

   240

				input_line[i] = ' ';

   241

		}

   242

	}

   243

   244

	IConsoleCmdExec(input_line); // execute command

   245

}

   246

   247

void VideoDriver_Dedicated::MainLoop()

   248

{

   249

	uint32 cur_ticks = GetTime();

   250

	uint32 next_tick = cur_ticks + 30;

   251

   252

	/* Signal handlers */

   253

#if defined(UNIX) || defined(PSP)

   254

	signal(SIGTERM, DedicatedSignalHandler);

   255

	signal(SIGINT, DedicatedSignalHandler);

   256

	signal(SIGQUIT, DedicatedSignalHandler);

   257

#endif

   258

   259

	// Load the dedicated server stuff

   260

	_is_network_server = true;

   261

	_network_dedicated = true;

   262

	_network_playas = PLAYER_SPECTATOR;

   263

	_local_player = PLAYER_SPECTATOR;

   264

   265

	/* If SwitchMode is SM_LOAD, it means that the user used the '-g' options */

   266

	if (_switch_mode != SM_LOAD) {

   267

		StartNewGameWithoutGUI(GENERATE_NEW_SEED);

   268

		SwitchMode(_switch_mode);

   269

		_switch_mode = SM_NONE;

   270

	} else {

   271

		_switch_mode = SM_NONE;

   272

		/* First we need to test if the savegame can be loaded, else we will end up playing the

   273

		 *  intro game... */

   274

		if (!SafeSaveOrLoad(_file_to_saveload.name, _file_to_saveload.mode, GM_NORMAL, BASE_DIR)) {

   275

			/* Loading failed, pop out.. */

   276

			DEBUG(net, 0, "Loading requested map failed, aborting");

   277

			_networking = false;

   278

		} else {

   279

			/* We can load this game, so go ahead */

   280

			SwitchMode(SM_LOAD);

   281

		}

   282

	}

   283

   284

	// Done loading, start game!

   285

   286

	if (!_networking) {

   287

		DEBUG(net, 0, "Dedicated server could not be started, aborting");

   288

		return;

   289

	}

   290

   291

	while (!_exit_game) {

   292

		uint32 prev_cur_ticks = cur_ticks; // to check for wrapping

   293

		InteractiveRandom(); // randomness

   294

   295

		if (!_dedicated_forks)

   296

			DedicatedHandleKeyInput();

   297

   298

		cur_ticks = GetTime();

   299

		if (cur_ticks >= next_tick || cur_ticks < prev_cur_ticks) {

   300

			next_tick = cur_ticks + 30;

   301

   302

			GameLoop();

   303

			_screen.dst_ptr = _dedicated_video_mem;

   304

			UpdateWindows();

   305

		}

   306

		CSleep(1);

   307

	}

   308

}

   309

   310

#endif /* ENABLE_NETWORK */