TakeV/dxx-rebirth
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity
dxx-rebirth/main/old/winmodem.c
Bradley Bell 9bd1ba7c47 This commit was generated by cvs2svn to compensate for changes in r2, 
which included commits to RCS files with non-trunk default branches.
2001-01-19 03:30:16 +00:00

2569 lines
55 KiB
C
Raw Blame History

/*
THE COMPUTER CODE CONTAINED HEREIN IS THE SOLE PROPERTY OF PARALLAX
SOFTWARE CORPORATION ("PARALLAX"). PARALLAX, IN DISTRIBUTING THE CODE TO
END-USERS, AND SUBJECT TO ALL OF THE TERMS AND CONDITIONS HEREIN, GRANTS A
ROYALTY-FREE, PERPETUAL LICENSE TO SUCH END-USERS FOR USE BY SUCH END-USERS
IN USING, DISPLAYING, AND CREATING DERIVATIVE WORKS THEREOF, SO LONG AS
SUCH USE, DISPLAY OR CREATION IS FOR NON-COMMERCIAL, ROYALTY OR REVENUE
FREE PURPOSES. IN NO EVENT SHALL THE END-USER USE THE COMPUTER CODE
CONTAINED HEREIN FOR REVENUE-BEARING PURPOSES. THE END-USER UNDERSTANDS
AND AGREES TO THE TERMS HEREIN AND ACCEPTS THE SAME BY USE OF THIS FILE.
COPYRIGHT 1993-1999 PARALLAX SOFTWARE CORPORATION. ALL RIGHTS RESERVED.
*/
#pragma off (unreferenced)
static char rcsid[] = "$Id: winmodem.c,v 1.1.1.1 2001-01-19 03:30:14 bradleyb Exp $";
#pragma on (unreferenced)
#ifdef NETWORK
#include "desw.h"
#include "win\comm.h"
#include "win\xtapi.h"
#include <stdio.h>
#include <stdlib.h>
#include <dos.h>
//#include <conio.h>
#include <string.h>
#include <time.h>
#include <io.h>
#include "game.h"
#include "scores.h"
#include "modem.h"
#include "object.h"
#include "player.h"
#include "laser.h"
#include "error.h"
#include "collide.h"
#include "endlevel.h"
#include "network.h"
#include "mono.h"
#include "gauges.h"
#include "newmenu.h"
#include "menu.h"
#include "gamesave.h"
#include "netmisc.h"
#include "cntrlcen.h"
#include "multi.h"
#include "timer.h"
#include "text.h"
#include "pcx.h"
#include "palette.h"
#include "sounds.h"
#include "digi.h"
#include "multibot.h"
#include "args.h"
#define MIN_COMM_GAP 8000
#define INIT_STRING_LEN 20
#define LEN_PHONE_NUM_OLD 15
#define LEN_PHONE_NUM 30
#define LEN_PHONE_NAME 12
#define NUM_PHONE_NUM 8
#define COM1 1
#define COM2 2
#define COM3 3
#define COM4 4
// How many times to repeat 'reliable' messages
#define EOR_MARK 0xaa
#define COM_PROCESS_NORMAL 0
#define COM_PROCESS_ENDLEVEL 1
#define COM_PROCESS_SYNC 2
#define COM_PROCESS_MENU 3
#define SELECTION_STARTGAME 1
#define SELECTION_NO_START 2
#define SELECTION_YES_START 3
#define SELECTION_STARTGAME_ABORT 4
#define SELECTION_CLOSE_LINK 5
// Code to support modem/null-modem play
// Program determined variables for serial play
typedef struct com_sync_pack {
char type;
byte proto_version;
long sync_time;
byte level_num;
char difficulty;
char game_mode;
char callsign[CALLSIGN_LEN+1];
short kills[2];
ushort seg_checksum;
byte sync_id;
char mission_name[9];
short killed;
byte game_flags;
short DoMegas:1;
short DoSmarts:1;
short DoFusions:1;
short DoHelix:1;
short DoPhoenix:1;
short DoAfterburner:1;
short DoInvulnerability:1;
short DoCloak:1;
short DoGauss:1;
short DoVulcan:1;
short DoPlasma:1;
short DoOmega:1;
short DoSuperLaser:1;
short DoProximity:1;
short DoSpread:1;
short DoSmartMine:1;
short DoFlash:1;
short DoGuided:1;
short DoEarthShaker:1;
short DoMercury:1;
short Allow_marker_view:1;
short RefusePlayers:1;
short AlwaysLighting:1;
short DoAmmoRack:1;
short DoConverter:1;
short DoHeadlight:1;
char dummy[3]; // Extra space for checksum & sequence number
} com_sync_pack;
int default_base[4] = { 0x3f8, 0x2f8, 0x3e8, 0x2e8 };
int default_irq[4] = { 4, 3, 4, 3 };
COMM_OBJ Comm;
BOOL ModemDetect = FALSE;
int com_device = 0;
int serial_active;
int com_baud_rate = 0;
//--unused-- int sync_time = 0;
int com_open = 0;
int got_sync = 0;
int other_got_sync = 0;
int carrier_on = 0;
long com_type = -1; /* What type of UART is available */
static long synccnt;
static ubyte rx_seqnum = 0xff;
static ubyte tx_seqnum = 0;
int OtherPlayer; // Player num for modem opponent
int com_process_mode = COM_PROCESS_NORMAL;
int master = -1; // Am I the master or is the other guy the master?
com_sync_pack my_sync, other_sync;
int start_level_num;
int com_custom_port = -1;
int com_custom_irq = -1;
int com_custom_base = -1;
int other_menu_choice = 0;
int chars_sent = 0;
// Com buffers
static char syncbuffer[MAX_MULTI_MESSAGE_LEN+4];
static char sendbuf[MAX_MULTI_MESSAGE_LEN+4]; // +4 because of +1 for null and +3 for checksum/sequence
// Serial setup variables
int com_port_num = -1;
int com_speed = -1;
char modem_init_string[INIT_STRING_LEN+1];
char phone_num[NUM_PHONE_NUM+1][LEN_PHONE_NUM+1];
char phone_name[NUM_PHONE_NUM][LEN_PHONE_NAME+1];
#define MAX_MODEMS 200
#define MODEM_NAME_LEN 22
char ModemNames[MAX_MODEMS][MODEM_NAME_LEN+1],ModemStrings[MAX_MODEMS][INIT_STRING_LEN+1]; // for init strings
char ModemInitString[INIT_STRING_LEN+1];
fix SerialLastMessage = 0;
/* Function prototypes for functions not exported through modem.h */
void modem_main_menu(int modem);
void modem_dialout(int modem);
void modem_hangup();
void modem_answer(int modem);
void modem_wait_for_connect(int nitems, newmenu_item *menus, int *key, int citem);
void modem_wait_for_ring(int nitems, newmenu_item *menus, int *key, int citem);
int serial_link_menu(int port);
void serial_link_start();
int com_game_menu(void);
void com_start_game(void);
void com_menu_poll(int nitems, newmenu_item *menus, int *key, int citem);
int com_sync(int id);
void com_sync_poll(int nitem, newmenu_item *menus, int *key, int citem);
int GetModemList(void);
/*
* Functions
*/
#if !defined(NDEBUG) && !defined(NMONO)
void
com_dump_string(char *string)
{
mprintf((0, "%s\n", string));
}
#else
#define com_dump_string()
#endif
int
com_enable()
{
if (com_open)
return 0;
rx_seqnum = 0xff;
tx_seqnum = 0;
Comm.baud = com_speed;
if (!comm_open_connection(&Comm)) {
nm_messagebox(TXT_ERROR, 1, TXT_OK, "Failed to open COM port.");
comm_close_connection(&Comm);
return -1;
}
comm_set_dtr(&Comm, 1);
if ( FindArg( "-ctsrts" ) || FindArg( "-rtscts" ) )
comm_set_rtscts(&Comm, 1); // Now used for null-modem as well
else
comm_set_rtscts(&Comm, 0);
com_open = 1;
master = -1;
mprintf((0, "Comm object created.\n"));
comm_dump_info(&Comm);
return 0;
}
void
com_disable()
{
// close the com port and free associated structures.
if (!com_open)
return;
comm_close_connection(&Comm);
com_open = 0;
master = -1;
#ifndef NDEBUG
mprintf((0, "Comm object released.\n"));
#endif
}
void
com_abort(void)
{
// this is the safest way to get out of some modem/serial negotiation
// and back to the main menu. Use this whenever this have gone too far
// awry to repair.
com_disable();
N_players = 0;
change_playernum_to(0);
Viewer = ConsoleObject = &Objects[0];
Game_mode = GM_GAME_OVER; // Force main menu selection
}
void
com_hangup(void)
{
// Close the serial link
com_send_choice(SELECTION_CLOSE_LINK);
com_abort();
modem_hangup();
}
void
com_carrier_lost(void)
{
// Carrier lost, inform and abort
if (multi_in_menu > 0)
{
multi_leave_menu = 1;
return;
}
Function_mode = FMODE_MENU;
multi_quit_game = 1;
nm_messagebox(NULL, 1, TXT_OK, TXT_CARRIER_LOST);
com_abort();
modem_hangup();
}
extern ubyte Cockpit_mode_save; // From object.c
com_reset_game(void)
{
int i;
// Reset various parameters before starting a new game
N_players = 2;
for (i = 0; i < N_players; i++)
{
Players[i].connected = 1;
}
// master = -1;
multi_new_game(); // Reset kill list, among other things
Control_center_destroyed = 0;
Endlevel_sequence = 0;
// Yes, this really IS as ugly as it gets, kids...
if (Cockpit_mode == CM_LETTERBOX || Cockpit_mode == CM_REAR_VIEW)
{
select_cockpit(Cockpit_mode_save);
}
}
// WE SHOULD CHANGE THIS TO BE MORE WINDOW LIKE?
void
com_save_settings(void)
{
FILE *settings;
int i;
if ( (settings = fopen("serial.cfg", "wb")) == NULL)
goto error;
if (fwrite(&com_speed, sizeof(int), 1, settings) != 1)
goto error;
if (fwrite(&com_port_num, sizeof(int), 1, settings) != 1)
goto error;
if (fwrite(modem_init_string, 1, INIT_STRING_LEN+1, settings) != INIT_STRING_LEN+1)
goto error;
for (i = 0; i < NUM_PHONE_NUM; i++)
{
if (fwrite(phone_num[i], 1, LEN_PHONE_NUM+1, settings) != LEN_PHONE_NUM+1)
goto error;
if (fwrite(phone_name[i], 1, LEN_PHONE_NAME+1, settings) != LEN_PHONE_NAME+1)
goto error;
}
if (fwrite(&com_custom_port, sizeof(int), 1, settings) != 1)
goto error;
if (fwrite(&com_custom_irq, sizeof(int), 1, settings) != 1)
goto error;
if (fwrite(&com_custom_base, sizeof(int), 1, settings) != 1)
goto error;
// 100 % success!
fclose(settings);
return;
error:
nm_messagebox(NULL, 1, TXT_OK, TXT_ERROR_SERIAL_CFG);
if (settings) {
fclose(settings);
unlink("serial.cfg");
}
return;
}
void
com_load_settings(void)
{
FILE *settings;
int i, cfg_size;
if ((settings = fopen("serial.cfg", "rb")) == NULL)
goto defaults;
cfg_size = filelength(fileno(settings));
// Read the data from the file
if (fread(&com_speed, sizeof(int), 1, settings) != 1)
goto error;
if (! ((com_speed == 9600) || (com_speed == 19200) || (com_speed == 38400)) )
goto error;
mprintf((0, "Here?"));
/* Not really used for Windows version */
if (fread(&com_port_num, sizeof(int), 1, settings) != 1)
goto error;
if ( (com_port_num < COM1) || (com_port_num > COM4) )
goto error;
mprintf((0, "Here?"));
/* Not really used for Windows version */
if (fread(modem_init_string, 1, INIT_STRING_LEN+1, settings) != INIT_STRING_LEN+1)
goto error;
modem_init_string[INIT_STRING_LEN] = '\0';
mprintf((0, "Here?"));
/* Used in Windows version */
if (cfg_size <= 273 ) { // Old 15 char LEN_PHONE_NUM's
mprintf(( 1, "Reading old pre 1.1 phone.cfg\n" ));
for (i = 0; i < NUM_PHONE_NUM; i++)
{
if (fread(phone_num[i], 1, LEN_PHONE_NUM_OLD+1, settings) != LEN_PHONE_NUM_OLD+1)
goto error;
phone_num[i][LEN_PHONE_NUM_OLD] = '\0';
if (fread(phone_name[i], 1, LEN_PHONE_NAME+1, settings) != LEN_PHONE_NAME+1)
goto error;
phone_name[i][LEN_PHONE_NAME] = '\0';
}
} else { // Normal Phone nums
for (i = 0; i < NUM_PHONE_NUM; i++)
{
if (fread(phone_num[i], 1, LEN_PHONE_NUM+1, settings) != LEN_PHONE_NUM+1)
goto error;
phone_num[i][LEN_PHONE_NUM] = '\0';
if (fread(phone_name[i], 1, LEN_PHONE_NAME+1, settings) != LEN_PHONE_NAME+1)
goto error;
phone_name[i][LEN_PHONE_NAME] = '\0';
}
}
mprintf((0, "Here?"));
/* Not really used in Windows version */
if (fread(&com_custom_port, sizeof(int), 1, settings) != 1) {
mprintf((0, "Reading old file format for serial.cfg.\n"));
goto close;
}
if ( (com_custom_port < -1) || (com_custom_port > COM4) )
goto error;
if (fread(&com_custom_irq, sizeof(int), 1, settings) != 1)
goto error;
//!! if ( (com_custom_port < -1) || (com_custom_port > IRQ15) )
//!! goto error;
if (fread(&com_custom_base, sizeof(int), 1, settings) != 1)
goto error;
if (com_custom_base < -1)
goto error;
mprintf((0, "Here?"));
//Everything was A-Ok!
close:
fclose(settings);
return;
error:
nm_messagebox(NULL, 1, TXT_OK, TXT_ERR_SER_SETTINGS);
defaults:
// Return some defaults
com_speed = CBR_19200;
/* Here so we can save them back to config file. */
strcpy(modem_init_string, "ATZ");
com_port_num = COM2;
com_custom_port = -1;
for (i = 0; i < NUM_PHONE_NUM; i++)
{
phone_num[i][0] = '\0';
strcpy(phone_name[i], TXT_EMPTY);
}
if (settings)
fclose(settings);
return;
}
void
serial_leave_game(void)
{
#ifndef NDEBUG
mprintf((0, "Called serial_leave_game.\n"));
#endif
// com_abort();
serial_sync_abort(0); // Just in case the other guy is in sync mode
Game_mode |= GM_GAME_OVER;
Function_mode = FMODE_MENU;
}
void
com_send_data(char *ptr, int len, int repeat)
{
int i;
// Take the raw packet data specified by ptr and append the sequence
// number and checksum, and pass it to com_send_ptr
if (!com_open)
return;
if (Game_mode & GM_MODEM)
{
i = comm_get_cd(&Comm);
if (i == 0) {
mprintf((0, "CARRIER LOST!\n"));
com_abort();
modem_hangup();
}
}
len += 3; // Checksum data is 3 bytes
*(ubyte *)(ptr+(len-3)) = (tx_seqnum+1)%256;
tx_seqnum = (tx_seqnum+1)%256;
*(ushort *)(ptr+(len-2)) = netmisc_calc_checksum(ptr, len-2);
com_send_ptr(ptr, len);
if (repeat>0)
for (i = 0; i < repeat; i++)
com_send_ptr(ptr, len);
}
com_send_ptr(char *ptr, int len)
{
register int count;
register char dat;
for (count = 0, dat=ptr[0]; count < len; dat=ptr[++count])
{
comm_write_char(&Comm, dat);
if (dat == EOR_MARK)
comm_write_char(&Comm, EOR_MARK); // double in-band endmarkers
}
comm_write_char(&Comm, EOR_MARK);
comm_write_char(&Comm, 0);
chars_sent += len;
}
void
com_flush()
{
// Get rid of all waiting data in the serial buffer
int i = 0;
if (!com_open)
return;
mprintf((0, "COM FLUSH:"));
while (comm_read_char_timed(&Comm, 100) >= 0)
i++;
mprintf((0, "%d characters.\n", i));
}
int
com_getchar()
{
register int i;
static int eor_recv = 0;
// return values:
// -1 = Nothing in buffer
// -2 = End of record
if (!com_open)
return(-1);
i = comm_read_char(&Comm);;
// mprintf((0, "%d", i));
if (i == COMM_BUF_EMPTY)
return (-1);
if ((i == EOR_MARK) || eor_recv)
{
if (!eor_recv)
i = comm_read_char(&Comm);
if (i == COMM_BUF_EMPTY)
{
// Assert(eor_recv == 0);
eor_recv = 1;
return(-1);
}
else if (i == EOR_MARK)
{
eor_recv = 0;
return(EOR_MARK); // Doubled EOR returns the character
}
else
{
#ifndef NDEBUG
if (i != 0) {
mprintf((0, "EOR followed by unexpected value %d.\n", i));
}
#endif
eor_recv = 0;
return(-2);
}
}
return(i);
}
#define SERIAL_IDLE_TIMEOUT F1_0*10
void
com_do_frame(void)
{
static fix last_comm_time = 0;
static int last_pos_skipped = 0;
int rval = 0;
if (Endlevel_sequence || (com_process_mode==COM_PROCESS_ENDLEVEL)) { // Only recieve during endlevel
int old_Endlevel_sequence = Endlevel_sequence;
Endlevel_sequence = 1;
com_process_input();
Endlevel_sequence = old_Endlevel_sequence;
return;
}
last_comm_time += FrameTime;
if ((last_comm_time > MIN_COMM_GAP) || Network_laser_fired)
{
#ifndef SHAREWARE
if ((Game_mode & GM_MULTI_ROBOTS) && !last_pos_skipped) {
rval = multi_send_robot_frame(0);
}
if (rval && !Network_laser_fired)
{
last_pos_skipped = 1;
goto skippos;
}
#endif
last_pos_skipped = 0;
multi_send_position(Players[Player_num].objnum);
multi_send_fire(); // Will return w/o sending if we haven't fired
skippos:
// mprintf((0, "%d chars sent, %f cps.\n", chars_sent, f2fl(fixdiv((chars_sent*F1_0),last_comm_time)) ));
chars_sent = 0;
last_comm_time = 0;
}
com_process_input();
if (!Control_center_destroyed && (Function_mode == FMODE_GAME) && (SerialLastMessage+SERIAL_IDLE_TIMEOUT < GameTime))
{
SerialLastMessage = 0x7fffffff-SERIAL_IDLE_TIMEOUT; // Give no further warnings until next message arrives!
nm_messagebox(TXT_WARNING, 1, TXT_OK, TXT_CONNECT_LOST, Players[OtherPlayer].callsign);
}
return;
}
int
com_check_message(char *checkbuf, int len)
{
ushort check;
int seqnum;
//mprintf ((0,"TYPE=%d!\n",checkbuf[0]));
if (len < 4)
{
mprintf((0, "message type %d too short to be a real message!\n", checkbuf[0]));
goto error;
}
if (checkbuf[0] > MULTI_MAX_TYPE)
{
mprintf((0, "message type %d out of range.\n", checkbuf[0]));
goto error;
}
if ( (len-3) != message_length[checkbuf[0]])
{
mprintf((0, "id:%d message length %d != %d.\n",checkbuf[0], len-3, message_length[checkbuf[0]]));
goto error;
}
check = netmisc_calc_checksum(checkbuf, len-2);
if (check != *(ushort *)(checkbuf+(len-2)))
{
#ifndef NDEBUG
mprintf((0, "error in message type %d, length %d, checksum %d != %d\n", checkbuf[0], len, check, *(ushort *)(checkbuf+(len-2))));
#endif
goto error;
}
seqnum = checkbuf[(len-3)];
if (seqnum == rx_seqnum)
{
// mprintf ((0,"returning due to bad checksum! type=%d seq=%d rx=%d\n",checkbuf[0],seqnum,rx_seqnum));
return -1;
}
if (seqnum != (rx_seqnum+1)%256)
{
#ifndef NDEBUG
mprintf((0, "Warning, missed 1 or more messages.\n"));
#endif
}
rx_seqnum = seqnum;
//mprintf((0, "message type %d len %d OK!\n", checkbuf[0], len));
return 0;
error:
mprintf((1,"Line status: %d.\n", comm_get_line_status(&Comm)));
comm_clear_line_status(&Comm);
Int3();
return -1;
}
void
com_process_menu(char *buf, int len)
{
char text[80];
len = len;
mprintf((0, "com_process_menu: type %d.\n", buf[0]));
switch(buf[0])
{
case MULTI_MESSAGE:
sprintf(text, "%s %s\n'%s'", Players[OtherPlayer].callsign, TXT_SAYS, buf+2);
nm_messagebox(NULL, 1, TXT_OK, text);
break;
case MULTI_MENU_CHOICE:
other_menu_choice = buf[1];
mprintf((0, "Other menu choice = %d.\n", other_menu_choice));
break;
case MULTI_BEGIN_SYNC:
// If we get a sync at the menu, send an abort sync, we're not ready yet!
serial_sync_abort(0);
break;
}
}
void
com_process_input(void)
{
// Read all complete messages from the serial buffer and process
// the contents. Messages are read into global array snycbuffer.
static int len = 0;
int entry_com_mode = com_process_mode;
register int dat;
if (!com_open)
return;
nextmessage:
if (Game_mode & GM_MODEM)
{
if (!comm_get_cd(&Comm))
com_carrier_lost();
}
if (!com_open) {
if (!multi_in_menu) {
multi_quit_game = 1;
}
else {
multi_leave_menu = 1;
}
}
if (com_process_mode != entry_com_mode)
{
mprintf((0, "Exiting com_process_input due to mode switch.\n"));
return;
}
while ( (len <= MAX_MULTI_MESSAGE_LEN) && (dat = com_getchar()) > -1) // Returns -1 when serial pipe empty
{
syncbuffer[len++] = dat;
}
if ((dat == -2) || (len > MAX_MULTI_MESSAGE_LEN)) // Returns -2 when end of message reached
{
// End of message
SerialLastMessage = GameTime;
if (!com_check_message(syncbuffer, len))
{
switch(com_process_mode)
{
case COM_PROCESS_NORMAL:
case COM_PROCESS_ENDLEVEL:
multi_process_data(syncbuffer, len); break;
case COM_PROCESS_MENU:
if (!Endlevel_sequence) com_process_menu(syncbuffer, len); break;
case COM_PROCESS_SYNC:
if (!Endlevel_sequence) com_process_sync(syncbuffer, len); break;
default:
Int3(); // Bad com_process_mode switch set!
}
}
else mprintf ((0,"Huh?\n"));
len = 0;
goto nextmessage;
}
if (dat == -3) // Returns -3 when carrier lost
{
com_abort();
len = 0;
}
return ;
}
int
com_connect()
{
Network_status=0;
my_sync.type = MULTI_BEGIN_SYNC;
my_sync.difficulty = 0;
memcpy(my_sync.callsign, Players[Player_num].callsign, CALLSIGN_LEN+1);
my_sync.seg_checksum = 0;
my_sync.game_mode = Game_mode;
my_sync.level_num = 0;
#ifndef NDEBUG
mprintf((0, "com_connect()\n"));
#endif
if(com_sync(-1))
return(-1); // Failure in sync
if (master == -1)
{
#ifndef NDEBUG
mprintf((0, "My rand = %d, other rand = %d.\n", my_sync.sync_time, other_sync.sync_time));
#endif
// Figure out who is the master
if (my_sync.sync_time > other_sync.sync_time)
{
mprintf((0, "Swtiching player to master.\n"));
master=1;
change_playernum_to(0);
}
else if (my_sync.sync_time < other_sync.sync_time)
{
mprintf((0, "Switching player to slave.\n"));
master = 0;
change_playernum_to(1);
}
else
return(-1); // Didn't sync properly, try again
}
// Copy the remote sync data into local variables
OtherPlayer = (Player_num+1)%2;
mprintf((0, "Other player is #%d.\n", OtherPlayer));
memcpy(Players[OtherPlayer].callsign, other_sync.callsign, CALLSIGN_LEN+1);
return(0);
}
// ----------------------------------------------------------------------------
// COM MENU SYSTEM
// ----------------------------------------------------------------------------
#define ADD_ITEM(t,value,key) do { m[num_options].type=NM_TYPE_MENU; menu_choice[num_options]=value; m[num_options].text=t; num_options++; } while (0)
#define SUBTITLE_LEN 192
#define MENU_XTAPI_DEVICE 0
#define MENU_COMM_DEVICE 2
#define MENU_SERIAL_GAME_START 5
#define MENU_SEND_MESSAGE 6
#define MENU_SERIAL_CLOSE 7
#define MENU_MODEM_HANGUP 8
static TapiDevice *tapiDevices=NULL;
static int xtapiCurrentModem = -1;
static int numTapiDevs = 0;
extern void nm_draw_background1(char * filename);
void com_main_menu(void)
{
newmenu_item m[12];
int menu_choice[12];
int device_type[6]; // 0 = serial, 1 = modem
char buf[64];
int i, num_options=0, choice;
int sel;
int retval;
if (com_speed == -1)
com_load_settings();
// setjmp(LeaveGame);
nm_draw_background1(Menu_pcx_name);
com_process_mode = COM_PROCESS_MENU;
if (Game_mode & GM_SERIAL) { // HACK to get menu system working
Assert(Comm.port >= 1 && Comm.port <= 4);
mprintf((0, "WINMODEM: Going to serial link menu!\n"));
sel = MENU_COMM_DEVICE + (Comm.port-1);
goto skip_to_com_submenus;
}
else if (Game_mode & GM_MODEM) {
Assert(xtapiCurrentModem != -1);
mprintf((0, "WINMODEM: Going to modem menu!\n"));
sel = xtapiCurrentModem;
goto skip_to_com_submenus;
}
// Get devices for TAPI.
retval = xtapi_init(WINAPP_NAME, &numTapiDevs);
if (retval == XTAPI_NODEVICES) {
return;
}
else if (retval == XTAPI_APPCONFLICT) {
return;
}
else if (retval == XTAPI_INCOMPATIBLE_VERSION) {
return;
}
if (numTapiDevs > 2) numTapiDevs = 2;
if (numTapiDevs == 0) tapiDevices = NULL;
else {
tapiDevices = (TapiDevice *)malloc(numTapiDevs*sizeof(TapiDevice));
if (!tapiDevices)
Error("Unable to allocate memory for com_main_menu.");
retval = xtapi_enumdevices(tapiDevices, numTapiDevs);
if (retval != XTAPI_SUCCESS) {
return;
}
}
com_menu_redraw:
num_options = 0;
for (i = 0; i < numTapiDevs; i++)
{
if (tapiDevices[i].type == XTAPI_MODEM_DEVICE) {
sprintf(buf, "Modem (%d baud)", tapiDevices[i].max_baud);
device_type[i] = 1;
}
else {
sprintf(buf, "Unsupported device (%d baud)", tapiDevices[i].max_baud);
device_type[i] = 2;
}
m[i].type=NM_TYPE_MENU; menu_choice[i]=MENU_XTAPI_DEVICE+i;
m[i].text=buf; num_options++;
}
device_type[num_options] = 0;
m[num_options].type=NM_TYPE_MENU; menu_choice[num_options]=MENU_COMM_DEVICE;
m[num_options].text="Direct to Com 1"; num_options++;
device_type[num_options] = 0;
m[num_options].type=NM_TYPE_MENU; menu_choice[num_options]=MENU_COMM_DEVICE+1;
m[num_options].text="Direct to Com 2"; num_options++;
device_type[num_options] = 0;
m[num_options].type=NM_TYPE_MENU; menu_choice[num_options]=MENU_COMM_DEVICE+2;
m[num_options].text="Direct to Com 3"; num_options++;
device_type[num_options] = 0;
m[num_options].type=NM_TYPE_MENU; menu_choice[num_options]=MENU_COMM_DEVICE+3;
m[num_options].text="Direct to Com 4"; num_options++;
choice = newmenu_do1(NULL, "Select Serial Device", num_options, m, NULL, 0);
if (choice == -1) {
if (tapiDevices) free(tapiDevices);
xtapi_shutdown();
return;
}
else if (choice < -1) {
return;
}
sel = menu_choice[choice];
skip_to_com_submenus:
switch (sel)
{
case MENU_XTAPI_DEVICE:
case MENU_XTAPI_DEVICE+1:
// start a xtapi game
modem_main_menu(sel);
if (Function_mode == FMODE_GAME) return;
break;
case MENU_COMM_DEVICE:
case MENU_COMM_DEVICE+1:
case MENU_COMM_DEVICE+2:
case MENU_COMM_DEVICE+3:
// start a serial game
mprintf((0, "Selected a null-modem game.\n"));
if (!serial_link_menu(sel-MENU_COMM_DEVICE+1))
goto com_menu_redraw;
mprintf((0, "WINMODEM: starting game...\n"));
return;
}
// Freeing XTAPI
if (tapiDevices) free(tapiDevices);
xtapi_shutdown();
nm_draw_background1(Menu_pcx_name);
}
// if 1, then we are starting a game
// if 0, then not.
int com_game_menu(void)
{
newmenu_item m[12];
int menu_choice[12];
int num_options = 0;
int choice=0;
char subtitle[SUBTITLE_LEN];
setjmp(LeaveGame);
com_game_menu_redraw:
num_options = 0;
ADD_ITEM(TXT_START_GAME, MENU_SERIAL_GAME_START, KEY_S);
ADD_ITEM(TXT_SEND_MESSAGEP, MENU_SEND_MESSAGE, KEY_S);
if (Game_mode & GM_MODEM)
ADD_ITEM(TXT_HANGUP_MODEM, MENU_MODEM_HANGUP, KEY_H);
if (Game_mode & GM_SERIAL)
ADD_ITEM(TXT_CLOSE_LINK, MENU_MODEM_HANGUP, KEY_C);
m[num_options].type=NM_TYPE_TEXT; m[num_options].text=""; num_options++;
if (Game_mode & GM_SERIAL)
sprintf(subtitle, "%s\n\n%s %s\n%s", TXT_SERIAL_GAME, TXT_SERIAL, TXT_LINK_ACTIVE, Players[OtherPlayer].callsign);
else if (Game_mode & GM_MODEM)
sprintf(subtitle, "%s\n\n%d %s %s\n%s", TXT_SERIAL_GAME, com_baud_rate, TXT_BAUD, TXT_LINK_ACTIVE, Players[OtherPlayer].callsign);
else {
mprintf((1, "Game mode isn't set correctly.\n"));
Int3();
}
multi_leave_menu = 0;
Assert(strlen(subtitle) < SUBTITLE_LEN);
choice = newmenu_do1(NULL, subtitle, num_options, m, com_menu_poll, 0);
if (choice == -1)
{
m[0].text = TXT_YES; m[1].text = TXT_NO;
m[0].type = m[1].type = NM_TYPE_MENU;
choice = newmenu_do1(NULL, TXT_EXIT_WILL_CLOSE, 2, m, com_menu_poll, 0);
if (choice == 0)
{
com_send_choice(SELECTION_CLOSE_LINK);
com_hangup();
return 0;
}
if ((choice == -2) && (other_menu_choice))
com_process_other_menu_choice();
goto com_game_menu_redraw;
}
if (choice == -2)
{
// Menu poll loop caused a re-draw
if (other_menu_choice == SELECTION_STARTGAME)
com_ready_to_start();
else if (other_menu_choice == SELECTION_CLOSE_LINK)
{
nm_messagebox(NULL, 1, TXT_OK, TXT_CLOSED_LINK);
com_hangup();
mprintf((0, "Leaving modem game (hanging up)...\n"));
}
if (Function_mode == FMODE_GAME) {
mprintf((0, "We think we're still in a modem game!.\n"));
return 1;
}
if (!com_open) {
mprintf((0, "At this point we're taking off..\n"));
Game_mode = GM_GAME_OVER;
return 0;
}
goto com_game_menu_redraw;
}
comm_dump_info(&Comm);
if (choice > -1)
{
// old_game_mode=Game_mode;
switch (menu_choice[choice])
{
case MENU_SERIAL_GAME_START:
com_start_game();
if (Function_mode != FMODE_GAME)
goto com_game_menu_redraw;
return 1;
case MENU_SEND_MESSAGE:
multi_send_message_dialog();
if (Network_message_reciever != -1)
multi_send_message();
multi_sending_message = 0;
goto com_game_menu_redraw;
break;
case MENU_MODEM_HANGUP:
com_hangup();
return 0;
default:
mprintf((1, "Bad com_game_menu choice\n"));
Int3();
return 0;
}
}
return 0;
}
/*
* Serial Link/Null Modem Functions
*/
// 1 = starting game
// 0 = no game.
int serial_link_menu(int port)
{
/* This menu will give a listing of possible com_speeds. The default will
be given, but the user should be given the option to change to a lower
speed
*/
newmenu_item mm[8];
int com_max_setting, loc, i, mmn, menu_link;
int com_speed_setting;
int com_speeds[5] = {
CBR_9600, CBR_19200, CBR_38400, CBR_57600, CBR_115200
};
char *com_speeds_text[5] = {
"9600", "19200", "38400", "57600", "115200"
};
// HACK to get menu system working when leaving serial game to
// get to correct modem.
if (Game_mode & GM_SERIAL) {
mprintf((0, "WINMODEM:Go directly to com_game menu.\n"));
goto skip_to_game_menu;
}
else mprintf((0, "WINMODEM:Not going directly to com_game menu.\n"));
/* First check what speed the selected port is set to */
if (com_open) com_disable();
memset(&Comm, 0, sizeof(COMM_OBJ));
Comm.port = port;
Comm.baud = com_speed;
if (!comm_open_connection(&Comm)) {
nm_messagebox(TXT_ERROR, 1, TXT_OK, "Unable to open selected COM port");
return 0;
}
switch(Comm.baud)
{
case CBR_9600: com_max_setting = 1; break;
case CBR_19200: com_max_setting = 2; break;
case CBR_38400: com_max_setting = 3; break;
default:
mprintf((0, "COM%d baud = %d\n", Comm.port, Comm.baud));
if (Comm.baud > CBR_38400) com_max_setting = 3;
else {
nm_messagebox(TXT_ERROR, 1, TXT_OK, "Your serial system must be\n capable of at least 9600 baud.");
com_max_setting = -1;
}
}
comm_close_connection(&Comm);
if (com_max_setting == -1) return 0;
/* Create menu */
setup_serial_menu:
loc = 0;
mm[0].type=NM_TYPE_TEXT; mm[0].text = TXT_BAUD_RATE; loc++;
for (i = 0; i < 3; i++) // Limit to 38.4K
{
mm[i+1].type=NM_TYPE_RADIO; mm[i+1].value=(i==(com_max_setting-1));
mm[i+1].text=com_speeds_text[i]; mm[i+1].group=1; loc++;
}
mm[loc].type=NM_TYPE_TEXT; mm[loc].text = ""; loc++;
menu_link = loc;
mm[loc].type=NM_TYPE_MENU; mm[loc].text = "Establish Link"; loc++;
mmn = newmenu_do1(NULL, TXT_SERIAL_SETTINGS, loc, mm, NULL, menu_link);
/* Take care of selection */
if (mmn > -1) {
for (i = 0; i < 3; i++)
if (mm[i+1].value) {
com_speed_setting = com_speeds[i];
break;
}
if(menu_link != mmn) goto setup_serial_menu;
}
else return 0;
com_speed = com_speed_setting;
// com_enable();
serial_link_start(); // We should be in GM_SERIAL after this
com_save_settings();
skip_to_game_menu:
if (Game_mode & GM_SERIAL) {
if (com_game_menu()) return 1;
else return 0;
}
else return 0;
}
void serial_link_start(void)
{
if (!serial_active)
{
nm_messagebox(TXT_ERROR, 1, TXT_OK, TXT_NO_SERIAL_OPT);
return;
}
com_enable(); // Open COM port as configured
if (!com_open)
return;
N_players = 2;
synccnt = 0;
srand(clock());
my_sync.sync_time = rand();
mprintf((0, "My rand set to %d.\n", my_sync.sync_time));
if (!com_connect())
{
Game_mode |= GM_SERIAL;
digi_play_sample(SOUND_HUD_MESSAGE, F1_0);
}
else
{
nm_messagebox(NULL, 1, TXT_OK, "%s\n%s", TXT_ERROR, TXT_FAILED_TO_NEGOT);
com_abort();
}
}
/*
* modem class functions
*/
void modem_main_menu(int modem)
{
newmenu_item m[6];
int num_options;
int choice=0;
if (Game_mode & GM_MODEM) {
mprintf((0, "WINMODEM:Going directly to com_game_menu.\n"));
com_game_menu();
return;
}
modem_menu_redraw:
num_options=0;
m[num_options].type=NM_TYPE_MENU; m[num_options].text="Dial"; num_options++;
m[num_options].type=NM_TYPE_MENU; m[num_options].text="Answer"; num_options++;
m[num_options].type=NM_TYPE_TEXT; m[num_options].text=""; num_options++;
choice = newmenu_do1(NULL, "Modem Options", num_options, m, NULL, 0);
if (choice > -1) {
switch (choice)
{
case 0:
modem_dialout(modem);
if (Game_mode & GM_MODEM) com_game_menu();
if (Function_mode == FMODE_GAME) return;
break;
case 1:
modem_answer(modem);
if (Game_mode & GM_MODEM) com_game_menu();
if (Function_mode == FMODE_GAME) return;
break;
}
}
else if (choice == -1) return;
goto modem_menu_redraw;
}
void modem_hangup()
{
if (xtapiCurrentModem > -1) {
mprintf((0, "WINMODEM: Hanging up..\n"));
com_disable();
xtapi_device_hangup();
xtapi_unlock(&tapiDevices[xtapiCurrentModem]);
xtapiCurrentModem = -1;
mprintf((0, "WINMODEM: Complete!\n"));
}
}
void modem_dialout(int modem)
{
newmenu_item m[5];
int choice, retval;
// At this point, xtapi is initialized, so we just need to get a number
// and dial out.
if (!serial_active)
{
nm_messagebox(TXT_ERROR, 1, TXT_OK, TXT_NO_SERIAL_OPT);
return;
}
retval = xtapi_lock(&tapiDevices[modem]);
if (retval != XTAPI_SUCCESS) {
mprintf((1, "Failed to lock down an XTAPI device.\n"));
Int3();
}
if (com_open)
return;
xtapiCurrentModem = modem; // Modem controls com functions
redial:
// Select a number to dial
if ((choice = modem_dial_menu()) == -1) {
modem_hangup();
return;
}
if (strlen(phone_num[choice]) == 0)
{
nm_messagebox(NULL, 1, TXT_OK, TXT_NO_PHONENUM);
goto redial;
}
// dial the number
show_boxed_message(TXT_RESET_MODEM);
retval = xtapi_device_dialout(phone_num[choice]);
if (retval != XTAPI_SUCCESS) {
clear_boxed_message();
nm_messagebox(NULL, 1, TXT_OK, "Unable to initiate dialing!");
mprintf((1, "XTAPI: err %d\n", retval));
modem_hangup();
return;
}
clear_boxed_message();
m[0].type=NM_TYPE_TEXT; m[0].text="Initializing\n";
m[1].type=NM_TYPE_TEXT; m[1].text=TXT_ESC_ABORT;
//repeat:
choice = newmenu_do(NULL, TXT_WAITING_FOR_ANS, 2, m, modem_wait_for_connect);
if (choice != -2) {
modem_hangup();
return;
}
// We are now connected to the other modem
N_players = 2;
my_sync.sync_time=32000;
// -- commented out by mk, 2/21/96 -- master = 1; // The person who dialed is the master of the connection
change_playernum_to(0);
if (!com_connect())
{
Game_mode |= GM_MODEM;
digi_play_sample(SOUND_HUD_MESSAGE, F1_0);
}
else {
modem_hangup();
}
}
void modem_answer(int modem)
{
newmenu_item m[5];
int choice, retval;
// At this point, xtapi is initialized, so we just need to get a number
// and dial out.
if (!serial_active)
{
nm_messagebox(TXT_ERROR, 1, TXT_OK, TXT_NO_SERIAL_OPT);
return;
}
retval = xtapi_lock(&tapiDevices[modem]);
if (retval != XTAPI_SUCCESS) {
mprintf((1, "Failed to lock down an XTAPI device.\n"));
Int3();
}
if (com_open)
return;
xtapiCurrentModem = modem; // Modem controls com functions
// start up modem and wait for connect
show_boxed_message(TXT_RESET_MODEM);
retval = xtapi_device_dialin();
if (retval != XTAPI_SUCCESS) {
clear_boxed_message();
nm_messagebox(NULL, 1, TXT_OK, "Unable to initialize modem.");
mprintf((1, "XTAPI: err %d\n", retval));
modem_hangup();
return;
}
clear_boxed_message();
// wait for a ring first.
modem_answer_redraw:
m[0].type=NM_TYPE_TEXT; m[0].text=TXT_ESC_ABORT;
choice = newmenu_do(NULL, TXT_WAITING_FOR_CALL, 1, m, modem_wait_for_ring);
if (choice == -1) {
modem_hangup();
return;
}
if (choice != -2)
goto modem_answer_redraw;
// Now answer the phone and wait for carrier
retval = xtapi_device_answer();
carrier_on = 0;
choice = newmenu_do(NULL, TXT_WAITING_FOR_CARR, 1, m, modem_wait_for_connect);
if (choice != -2) {
modem_hangup();
return;
}
// We are now connected to the other modem
// We are now connected to the other modem
N_players = 2;
my_sync.sync_time=0;
//master = 0;
change_playernum_to(1);
if (!com_connect())
{
Game_mode |= GM_MODEM;
digi_play_sample(SOUND_HUD_MESSAGE, F1_0);
}
else {
modem_hangup();
}
}
void modem_wait_for_connect(int nitems, newmenu_item *menus, int *key, int citem)
{
uint modem_state;
int retval;
menus = menus;
nitems = nitems;
citem = citem;
retval = xtapi_device_poll_callstate(&modem_state);
if (retval != XTAPI_SUCCESS) {
return;
}
switch (modem_state)
{
case XTAPI_LINE_DIALING:
menus[0].text = "Dialing\n";
menus[0].redraw = 1;
return;
case XTAPI_LINE_PROCEEDING:
case XTAPI_LINE_RINGBACK:
menus[0].text = "Calling\n";
menus[0].redraw = 1;
return;
case XTAPI_LINE_BUSY:
nm_messagebox(NULL, 1, TXT_OK, "Got a busy signal.");
*key = -3;
return;
case XTAPI_LINE_FEEDBACK:
nm_messagebox(NULL, 1, TXT_OK, "Unable to connect.");
*key = -3;
return;
case XTAPI_LINE_DISCONNECTED:
nm_messagebox(NULL, 1, TXT_OK, "Disconnected!");
*key = -3;
return;
case XTAPI_LINE_CONNECTED:
// perform connection scheme: we should create a comm object!
xtapi_device_create_comm_object(&Comm);
rx_seqnum = 0xff;
tx_seqnum = 0;
com_open = 1;
mprintf((0, "Connect at %d baud.\n", Comm.baud));
if (Comm.baud < CBR_9600) {
nm_messagebox(NULL, 1, TXT_OK, TXT_BAUD_GREATER_9600);
*key = -3;
return;
}
else {
com_baud_rate = Comm.baud;
*key = -2;
return;
}
break;
case XTAPI_LINE_IDLE:
menus[0].text = "Idle\n";
menus[0].redraw = 1;
*key = -3;
return;
case XTAPI_LINE_DIALTONE:
menus[0].text = "Dialtone\n";
menus[0].redraw = 1;
return;
case 0: break;
default:
mprintf((0, "xtapi undefined call state.\n"));
}
return;
}
void modem_wait_for_ring(int nitems, newmenu_item *menus, int *key, int citem)
{
uint modem_state;
int result;
menus = menus;
nitems = nitems;
citem = citem;
result = xtapi_device_poll_callstate(&modem_state);
if (modem_state == XTAPI_LINE_RINGING) {
mprintf((0, "Line is ringing. Answering...\n"));
result = xtapi_device_answer();
if (result != XTAPI_SUCCESS) return;
*key = -2;
}
}
void modem_edit_phonebook(newmenu_item *m)
{
int choice, choice2;
newmenu_item menu[5];
char text[2][25];
int default_choice = 0;
m[NUM_PHONE_NUM].text = TXT_SAVE;
menu[0].text = TXT_NAME; menu[0].type = NM_TYPE_TEXT;
menu[1].type = NM_TYPE_INPUT; menu[1].text = text[0]; menu[1].text_len = LEN_PHONE_NAME;
menu[2].text = TXT_PHONE_NUM; menu[2].type = NM_TYPE_TEXT;
menu[3].type = NM_TYPE_INPUT; menu[3].text = text[1]; menu[3].text_len = LEN_PHONE_NUM;
menu[4].text = TXT_ACCEPT; menu[4].type = NM_TYPE_MENU;
menu:
choice = newmenu_do1(NULL, TXT_SEL_NUMBER_EDIT, NUM_PHONE_NUM+1, m, NULL, default_choice);
if (choice == -1)
{
com_load_settings();
return;
}
if (choice == NUM_PHONE_NUM)
{
// Finished
com_save_settings();
return;
}
default_choice = 1;
edit:
// Edit an entry
strcpy(menu[1].text, phone_name[choice]);
strcpy(menu[3].text, phone_num[choice]);
choice2 = newmenu_do1(NULL, TXT_EDIT_PHONE_ENTRY, 5, menu, NULL, default_choice);
if (choice2 != -1)
{
strcpy(phone_name[choice], menu[1].text);
strcpy(phone_num[choice], menu[3].text);
sprintf(m[choice].text, "%d. %s \t", choice+1, phone_name[choice]);
add_phone_number(m[choice].text, phone_num[choice] );
}
if (choice2 != 4)
{
default_choice += 2; if (default_choice > 4) default_choice = 4;
goto edit;
}
default_choice = NUM_PHONE_NUM;
goto menu;
}
void add_phone_number( char * src, char * num )
{
char p;
int l;
l = strlen(num);
if ( l<15) {
strcat( src, num );
return;
}
p = num[15];
num[15] = 0;
strcat( src, num );
num[15] = p;
strcat( src, "..." );
}
int modem_dial_menu(void)
{
newmenu_item m[NUM_PHONE_NUM+2];
char menu_text[NUM_PHONE_NUM][80];
int choice = 0;
int i;
menu:
for (i = 0; i < NUM_PHONE_NUM; i++)
{
m[i].text = menu_text[i];
sprintf(m[i].text, "%d. %s \t", i+1, phone_name[i]);
add_phone_number(m[i].text, phone_num[i] );
m[i].type = NM_TYPE_MENU;
}
strcat(m[i-1].text, "\n");
m[NUM_PHONE_NUM].type = NM_TYPE_MENU;
m[NUM_PHONE_NUM].text = TXT_MANUAL_ENTRY;
m[NUM_PHONE_NUM+1].text = TXT_EDIT_PHONEBOOK;
m[NUM_PHONE_NUM+1].type = NM_TYPE_MENU;
choice = newmenu_do1(NULL, TXT_SEL_NUMBER_DIAL, NUM_PHONE_NUM+2, m, NULL, 0);
if (choice == -1)
return -1; // user abort
if (choice == NUM_PHONE_NUM+1)
{
// Edit phonebook
modem_edit_phonebook(m);
goto menu;
}
if (choice == NUM_PHONE_NUM)
{
// Manual entry
newmenu_item m2[1];
m2[0].type = NM_TYPE_INPUT; m2[0].text = phone_num[NUM_PHONE_NUM]; m2[0].text_len = LEN_PHONE_NUM;
choice = newmenu_do(NULL, TXT_ENTER_NUMBER_DIAL, 1, m2, NULL);
if (choice == -1)
goto menu;
else
return NUM_PHONE_NUM;
}
// A phone number was chosen
return(choice);
}
/*
* COM functions
*/
void
com_menu_poll(int nitems, newmenu_item *menus, int *key, int citem)
{
// Watch the serial stream if we are connected and take appropriate actions
int old_game_mode;
menus = menus;
citem = citem;
nitems = nitems;
com_process_mode = COM_PROCESS_MENU;
old_game_mode = Game_mode;
other_menu_choice = 0;
com_process_input();
if ((old_game_mode != Game_mode) || other_menu_choice || (com_process_mode != COM_PROCESS_MENU))
*key = -2;
if (multi_leave_menu)
*key = -2;
}
void
com_send_choice(int choice)
{
sendbuf[0] = (char)MULTI_MENU_CHOICE;
sendbuf[1] = (char)choice;
com_send_data(sendbuf, 2, 1);
}
void
com_ready_to_start(void)
{
newmenu_item m[2];
int choice;
m[0].type = m[1].type = NM_TYPE_MENU;
m[0].text = TXT_YES;
m[1].text = TXT_NO;
choice = newmenu_do1(NULL, TXT_READY_DESCENT, 2, m, com_menu_poll, 0 );
if (choice == 0)
{
// Yes
com_send_choice(SELECTION_YES_START);
other_menu_choice = SELECTION_STARTGAME;
com_start_game();
}
else
{
com_send_choice(SELECTION_NO_START);
}
}
void
com_process_other_menu_choice(void)
{
if (other_menu_choice == SELECTION_STARTGAME)
com_ready_to_start();
else if (other_menu_choice == SELECTION_CLOSE_LINK)
{
nm_messagebox(NULL, 1, TXT_OK, TXT_CLOSED_LINK);
com_hangup();
}
}
// Handshaking to start a serial game, 2 players only
int com_start_game_menu(void)
{
newmenu_item m[15];
char level[5];
int choice = 0;
int opt, diff_opt, mode_opt, options_opt,allow_opt,extraopts_opt;
char level_text[32];
#ifndef SHAREWARE
int new_mission_num, anarchy_only = 0;
new_mission_num = multi_choose_mission(&anarchy_only);
if (new_mission_num < 0)
return 0;
strcpy(my_sync.mission_name, Mission_list[new_mission_num].filename);
#endif
sprintf(level, "1");
Game_mode &= ~GM_MULTI_COOP;
Game_mode &= ~GM_MULTI_ROBOTS;
Game_mode &= ~GM_CAPTURE;
Netgame.game_flags = 0;
SetAllAllowablesTo(1);
sprintf(level_text, "%s (1-%d)", TXT_LEVEL_, Last_level);
// if (Last_secret_level < -1)
// sprintf(level_text+strlen(level_text)-1, ", S1-S%d)", -Last_secret_level);
// else if (Last_secret_level == -1)
// sprintf(level_text+strlen(level_text)-1, ", S1)");
Assert(strlen(level_text) < 32);
// Put up menu for user choices controlling gameplay
newmenu:
opt = 0;
m[opt].type = NM_TYPE_TEXT; m[opt].text = level_text; opt++;
m[opt].type = NM_TYPE_INPUT; m[opt].text_len = 4; m[opt].text = level; opt++;
m[opt].type = NM_TYPE_TEXT; m[opt].text = TXT_MODE;
mode_opt = opt;
m[opt].type = NM_TYPE_RADIO; m[opt].text = TXT_ANARCHY; m[opt].value=!(Game_mode & GM_MULTI_ROBOTS); m[opt].group = 0; opt++;
m[opt].type = NM_TYPE_RADIO; m[opt].text = TXT_ANARCHY_W_ROBOTS; m[opt].value=(!(Game_mode & GM_MULTI_COOP) && (Game_mode & GM_MULTI_ROBOTS)); m[opt].group = 0; opt++;
m[opt].type = NM_TYPE_RADIO; m[opt].text = TXT_COOPERATIVE; m[opt].value=(Game_mode & GM_MULTI_COOP);m[opt].group = 0; opt++;
m[opt].type = NM_TYPE_RADIO; m[opt].text = "Capture the Flag"; m[opt].value=(Game_mode & GM_CAPTURE); m[opt].group = 0; opt++;
diff_opt = opt;
m[opt].type = NM_TYPE_SLIDER; m[opt].text = TXT_DIFFICULTY; m[opt].value = Player_default_difficulty; m[opt].min_value = 0; m[opt].max_value = (NDL-1); opt++;
m[opt].type = NM_TYPE_TEXT; m[opt].text = " "; opt ++;
extraopts_opt=opt;
m[opt].type = NM_TYPE_CHECK; m[opt].text = "Marker camera views"; m[opt].value=Netgame.Allow_marker_view; opt++;
m[opt].type = NM_TYPE_CHECK; m[opt].text = "Indestructable lights"; m[opt].value=Netgame.AlwaysLighting; opt++;
allow_opt=opt;
m[opt].type = NM_TYPE_MENU; m[opt].text = "Choose objects allowed"; opt++;
#ifndef SHAREWARE
options_opt = opt;
// m[opt].type = NM_TYPE_CHECK; m[opt].text = TXT_SHOW_IDS; m[opt].value=0; opt++;
m[opt].type = NM_TYPE_CHECK; m[opt].text = TXT_SHOW_ON_MAP; m[opt].value=0; opt++;
#endif
Assert(opt <= 12);
GetChoice:
choice = newmenu_do1(NULL, TXT_SERIAL_GAME_SETUP, opt, m, NULL, 1);
if (choice > -1)
{
if (choice==allow_opt)
{
network_set_power();
goto GetChoice;
}
Netgame.Allow_marker_view=m[extraopts_opt].value;
Netgame.AlwaysLighting=m[extraopts_opt+1].value;
if (m[mode_opt].value)
Game_mode &= ~(GM_MULTI_COOP | GM_MULTI_ROBOTS);
#ifdef SHAREWARE
else {
nm_messagebox(NULL, 1, TXT_OK, TXT_ONLY_ANARCHY);
goto newmenu;
}
#else
else if (anarchy_only) {
if (m[mode_opt+3].value)
Game_mode |= (GM_CAPTURE);
else
{
nm_messagebox(NULL, 1, TXT_OK, TXT_ANARCHY_ONLY_MISSION);
goto newmenu;
}
}
else if (m[mode_opt+1].value)
{
Game_mode &= ~GM_MULTI_COOP;
Game_mode |= GM_MULTI_ROBOTS;
}
else if (m[mode_opt+2].value)
Game_mode |= (GM_MULTI_COOP | GM_MULTI_ROBOTS);
else if (m[mode_opt+3].value)
Game_mode |= (GM_CAPTURE);
// if (m[options_opt].value)
// Netgame.game_flags |= NETGAME_FLAG_SHOW_ID;
if (m[options_opt].value)
Netgame.game_flags |= NETGAME_FLAG_SHOW_MAP;
if (!strnicmp(level, "s", 1))
start_level_num = -atoi(level+1);
else
#endif
start_level_num = atoi(level);
if ((start_level_num < 1) || (start_level_num > Last_level))
{
nm_messagebox(TXT_ERROR, 1, TXT_OK, TXT_LEVEL_OUT_RANGE);
sprintf(level, "1");
goto newmenu;
}
Difficulty_level = m[diff_opt].value;
return(1); // Go for game!
}
return 0; // No game
}
int
com_ask_to_start()
{
// Ask the other player if its OK to start now
newmenu_item m[1];
int choice;
com_send_choice(SELECTION_STARTGAME);
m[0].type = NM_TYPE_TEXT; m[0].text = TXT_ESC_ABORT;
menu:
choice = newmenu_do(NULL, TXT_WAIT_FOR_OK, 1, m, com_menu_poll);
if (choice == -1)
{
com_send_choice(SELECTION_STARTGAME_ABORT);
return(0);
}
if (choice == -2)
{
if (other_menu_choice == SELECTION_YES_START)
return(1);
else if (other_menu_choice == SELECTION_STARTGAME)
{
com_send_choice(SELECTION_YES_START);
return(1);
}
else
return(0);
}
goto menu;
}
void
com_start_game()
{
// Start a serial game after being linked
mprintf((0, "Entered com_start_game\n"));
com_reset_game();
if (! ( (Game_mode & GM_MODEM) || (Game_mode & GM_SERIAL) ) )
return;
Assert (master != -1);
if (other_menu_choice != SELECTION_STARTGAME)
{
if (!com_ask_to_start())
return;
}
if (master == 1) // Master chooses options
{
if (com_start_game_menu())
{
OtherPlayer = 1;
change_playernum_to(0);
my_sync.level_num = start_level_num;
my_sync.difficulty = Difficulty_level;
my_sync.game_mode = Game_mode;
if (Game_mode & GM_CAPTURE)
my_sync.game_mode |=GM_UNKNOWN;
memcpy(my_sync.callsign, Players[Player_num].callsign, CALLSIGN_LEN+1);
my_sync.sync_time = control_invul_time;
my_sync.game_flags = Netgame.game_flags;
Netgame.control_invul_time = control_invul_time;
memcpy ((&my_sync.game_flags)+1,(&Netgame.team_vector)+1,4);
com_sync(0);
if (Game_mode & GM_CAPTURE)
my_sync.game_mode &=GM_UNKNOWN;
}
}
else // Slave
{
OtherPlayer = 0;
change_playernum_to(1);
memcpy(my_sync.callsign, Players[Player_num].callsign, CALLSIGN_LEN+1);
my_sync.level_num = 1;
com_sync(0);
if (com_process_mode == COM_PROCESS_NORMAL)
{
Difficulty_level = other_sync.difficulty;
start_level_num = other_sync.level_num;
Game_mode = other_sync.game_mode;
if (Game_mode & GM_UNKNOWN) // Super HACK! Out of bit fields, doubling up
{
Game_mode &=~GM_UNKNOWN;
Game_mode |=GM_CAPTURE;
}
memcpy ((&Netgame.team_vector)+1,(&other_sync.game_flags)+1,4);
#ifndef SHAREWARE
Netgame.game_flags = other_sync.game_flags;
Netgame.control_invul_time = other_sync.sync_time;
if (!load_mission_by_name(other_sync.mission_name))
{
mprintf((0, "Mission not found: %s!\n", other_sync.mission_name));
nm_messagebox(NULL, 1, TXT_OK, TXT_MISSION_NOT_FOUND);
my_sync.sync_id = start_level_num;
serial_sync_abort(0);
return;
}
#endif
}
}
if (com_process_mode != COM_PROCESS_NORMAL)
return;
memcpy(Players[OtherPlayer].callsign, other_sync.callsign, CALLSIGN_LEN+1);
Function_mode = FMODE_GAME;
Game_mode &= ~GM_GAME_OVER;
Show_kill_list = 1;
init_player_stats_game();
init_player_stats_level(0);
// Assert(start_level_num > 0);
Assert((start_level_num >= Last_secret_level) && (start_level_num <= Last_level));
StartNewLevel(start_level_num, 0);
}
//
// Syncronization functions
//
void
serial_sync_abort(int val)
{
// Send "I got Sync but it was no good!" packet
sendbuf[0] = (char)MULTI_END_SYNC;
sendbuf[1] = Player_num;
sendbuf[2] = (char)val; // Indicated failure
//#ifndef SHAREWARE
sendbuf[3] = my_sync.sync_id;
com_send_data(sendbuf, 4, 1);
//#else
// com_send_data(sendbuf, 3, 1);
//#endif
}
int
com_level_sync(void)
{
// Send between-level sync stuff
mprintf((0, "entered com_level_sync()\n"));
Function_mode = FMODE_MENU; // Prevent the game loop from running during the menus!
// At this point, the new level is loaded but the extra objects or players have not
// been removed
my_sync.level_num = Current_level_num;
my_sync.seg_checksum = netmisc_calc_checksum(Segments, (Highest_segment_index+1) * sizeof(segment));
my_sync.kills[0] = kill_matrix[Player_num][0];
my_sync.kills[1] = kill_matrix[Player_num][1];
my_sync.proto_version = MULTI_PROTO_VERSION;
//#ifndef SHAREWARE
my_sync.killed = Players[Player_num].net_killed_total;
//#endif
srand(clock());
if (Game_mode & GM_MULTI_COOP)
my_sync.difficulty = Player_num;
else
my_sync.difficulty = rand()%MAX_NUM_NET_PLAYERS; // My starting position
if (com_sync(Current_level_num))
{
com_process_mode = COM_PROCESS_MENU;
nm_messagebox(TXT_ERROR, 1, TXT_OK, TXT_NEGOTIATION_FAIL );
longjmp(LeaveGame, 0);
}
if (my_sync.level_num != other_sync.level_num)
{
// Fatal error
nm_messagebox(TXT_ERROR, 1, TXT_OK, "%s %d\n%s %d", TXT_FATAL_ERROR_LEVEL, my_sync.level_num, TXT_OTHER_LEVEL, other_sync.level_num);
longjmp(LeaveGame, 0);
}
if (my_sync.seg_checksum != other_sync.seg_checksum)
{
// Checksum failure
mprintf((1, "My check %d, other check %d.\n", my_sync.seg_checksum, other_sync.seg_checksum));
nm_messagebox(TXT_ERROR, 1, TXT_OK, "%s %d %s %s%s", TXT_YOUR_LEVEL, my_sync.level_num, TXT_LVL_NO_MATCH, other_sync.callsign, TXT_CHECK_VERSION);
longjmp(LeaveGame, 0);
}
if (my_sync.proto_version != other_sync.proto_version)
{
// Version mismatch
nm_messagebox(TXT_ERROR, 1, TXT_OK, TXT_DESCENT_NO_MATCH);
longjmp(LeaveGame, 0);
}
mprintf((0, "My pos = %d, other pos = %d.\n", my_sync.difficulty, other_sync.difficulty));
if ((other_sync.difficulty == my_sync.difficulty) && !master)
{
// If we chose the same position and I am the slave, choose another
my_sync.difficulty = (my_sync.difficulty+1) % MAX_NUM_NET_PLAYERS;
}
Objects[Players[OtherPlayer].objnum].pos = Player_init[other_sync.difficulty].pos;
Objects[Players[OtherPlayer].objnum].orient = Player_init[other_sync.difficulty].orient;
obj_relink(Players[OtherPlayer].objnum,Player_init[other_sync.difficulty].segnum);
Objects[Players[OtherPlayer].objnum].type = OBJ_PLAYER;
Objects[Players[Player_num].objnum].pos = Player_init[my_sync.difficulty].pos;
Objects[Players[Player_num].objnum].orient = Player_init[my_sync.difficulty].orient;
obj_relink(Players[Player_num].objnum, Player_init[my_sync.difficulty].segnum);
Objects[Players[Player_num].objnum].type = OBJ_PLAYER;
SerialLastMessage = GameTime;
kill_matrix[OtherPlayer][0] = other_sync.kills[0];
kill_matrix[OtherPlayer][1] = other_sync.kills[1];
Players[Player_num].net_kills_total = kill_matrix[Player_num][OtherPlayer] - kill_matrix[Player_num][Player_num];
Players[OtherPlayer].net_kills_total = kill_matrix[OtherPlayer][Player_num] - kill_matrix[OtherPlayer][OtherPlayer];
// Players[Player_num].net_killed_total = kill_matrix[0][Player_num] + kill_matrix[1][Player_num];
// Players[OtherPlayer].net_killed_total = kill_matrix[0][OtherPlayer] + kill_matrix[1][OtherPlayer];
Players[OtherPlayer].net_killed_total = other_sync.killed;
Players[OtherPlayer].connected = Players[Player_num].connected = 1;
Assert(N_players == 2);
Assert(Player_num != OtherPlayer);
gr_palette_fade_out(gr_palette, 32, 0);
Function_mode = FMODE_GAME;
com_process_mode = COM_PROCESS_NORMAL;
multi_sort_kill_list();
return(0);
}
void
com_send_end_sync(void)
{
// Send "I got Sync" packet
sendbuf[0] = (char)MULTI_END_SYNC;
sendbuf[1] = Player_num;
sendbuf[2] = 1; // Indicates success
//#ifndef SHAREWARE
sendbuf[3] = my_sync.sync_id;
com_send_data(sendbuf, 4, 2);
//#else
// com_send_data(sendbuf, 3, 2);
// #endif
}
void
com_send_begin_sync(void)
{
mprintf((0, "Sending my sync.\n"));
com_send_data((char *)&my_sync, sizeof(com_sync_pack)-3, 1);
}
void
com_process_end_sync(byte *buf)
{
// Process incoming end-sync packet
if (buf[2] != 1) {
com_process_mode = COM_PROCESS_MENU;
return;
}
//#ifndef SHAREWARE
if (buf[3] == my_sync.sync_id)
//#endif
other_got_sync = 1;
}
void
com_process_sync(char *buf, int len)
{
mprintf ((0,"Processing sync!"));
len = len;
switch(buf[0])
{
case MULTI_END_SYNC:
{
com_process_end_sync(buf);
break;
}
case MULTI_BEGIN_SYNC:
{
mprintf((0, "Incoming begin_sync message.\n"));
if (got_sync)
break;
memcpy(&other_sync, buf, sizeof(com_sync_pack)-3);
//#ifndef SHAREWARE
if (other_sync.sync_id != my_sync.sync_id)
{
mprintf((0, "Other sync invalid id, %d != %d.\n", other_sync.sync_id, my_sync.sync_id));
}
else
//#endif
{
mprintf((0, "got other sync size %d.\n", sizeof(com_sync_pack)-3));
got_sync = 1;
com_send_end_sync();
}
break;
}
} // switch
if (got_sync && other_got_sync)
{
// OK to start game
mprintf((1, "Starting game.\n"));
got_sync = 0;
other_got_sync = 0;
com_process_mode = COM_PROCESS_NORMAL;
}
}
void
com_send_sync(void)
{
// Send sync information, depending on the situation
if (!other_got_sync)
{
com_send_begin_sync();
}
if (got_sync)
{
com_send_end_sync();
}
}
void com_sync_poll(int nitems, newmenu_item *menus, int *key, int citem)
{
static fix t1 = 0;
menus = menus;
nitems = nitems;
citem = citem;
if (!com_open)
{
*key = -3;
return;
}
if (timer_get_approx_seconds() > t1+F1_0)
{
com_send_sync();
t1 = timer_get_approx_seconds();
}
Assert(com_process_mode == COM_PROCESS_SYNC);
com_process_input();
if (com_process_mode == COM_PROCESS_NORMAL)
{
*key = -2;
com_send_sync();
mprintf((0, "Sync finished.\n"));
return;
}
if (com_process_mode == COM_PROCESS_MENU)
{
*key = -3;
mprintf((0, "Sync denied by other side.\n"));
return;
}
return;
}
int
com_sync(int id)
{
// How to handle the end of the level and start of the next level
// returns 0 for success or 1 for failure
int choice;
newmenu_item m[3];
//@@int pcx_error;
mprintf((0, "Entered com_sync\n"));
//@@gr_set_current_canvas(NULL);
//@@pcx_error = pcx_read_bitmap(Menu_pcx_name, &grd_curcanv->cv_bitmap,grd_curcanv->cv_bitmap.bm_type,NULL);
//@@Assert(pcx_error == PCX_ERROR_NONE);
com_process_mode = COM_PROCESS_SYNC;
got_sync = other_got_sync = 0;
com_flush();
com_flush();
//#ifndef SHAREWARE
my_sync.sync_id = id;
//#endif
m[0].type=NM_TYPE_TEXT; m[0].text=TXT_ESC_ABORT;
m[1].type = m[2].type = NM_TYPE_MENU;
m[1].text = TXT_YES;
m[2].text = TXT_NO;
repeat:
choice = newmenu_do(NULL, TXT_WAIT_OPPONENT, 1, m, com_sync_poll);
if (choice == -1)
{
choice = newmenu_do1(NULL, TXT_SURE_ABORT_SYNC, 2, m+1, com_sync_poll, 1);
if (choice == -1)
choice = 1;
if (choice == 0)
choice = -1;
}
if ((choice == -1) || (choice == -3)) {
return(-1);
}
else if (choice != -2)
goto repeat;
return(0);
}
void
com_endlevel(int *secret)
{
// What do we do between levels?
Function_mode = FMODE_MENU;
gr_palette_fade_out(gr_palette, 32, 0);
my_sync.level_num = multi_goto_secret;
if (com_sync(-3))
{
com_process_mode = COM_PROCESS_MENU;
nm_messagebox(TXT_ERROR, 1, TXT_OK, TXT_NEGOTIATION_FAIL);
longjmp(LeaveGame, 0);
}
com_process_mode = COM_PROCESS_ENDLEVEL;
if ((multi_goto_secret == 1) || (other_sync.level_num == 1))
*secret = 1;
else
*secret = 0;
multi_goto_secret = 0;
return;
}
#endif
int ReadModemList ()
{
int num=0,i=0,namemode=1;
FILE *MyFile;
char c;
if ((MyFile=fopen ("modem.lst","rb"))==NULL)
return (0);
ModemNames[num][0] = ModemStrings[num][0] = 0;
while (!feof(MyFile))
{
c=fgetc (MyFile);
mprintf ((0,"%c",c));
if (c=='$')
{
fclose (MyFile);
return (num);
}
else if (c==13)
;
else if (c==10)
{
ModemStrings[num][i]=0;
namemode=1;
i=0;
if (strlen(ModemNames[num]) && strlen(ModemStrings[num]))
num++;
if (num >= MAX_MODEMS)
break; //too many! abort!
ModemNames[num][0] = ModemStrings[num][0] = 0;
}
else if (c==';')
{
while (fgetc(MyFile)!=10)
;
namemode=1;
i=0;
}
else if (c=='=' && namemode)
{
ModemNames[num][i]=0;
namemode=0;
i=0;
}
else
{
if (namemode)
{
if (i<MODEM_NAME_LEN)
ModemNames[num][i++]=c;
}
else
{
if (i<INIT_STRING_LEN)
ModemStrings[num][i++]=c;
}
}
} // end while
ModemStrings[num][i]=0; //terminate in case no final newline
fclose (MyFile);
return (num);
}
void com_choose_string ()
{
int num,i,choice;
newmenu_item m[MAX_MODEMS];
if ((num=ReadModemList())==0)
{
nm_messagebox ("Error",1,TXT_OK,"No valid modem file found!");
return;
}
mprintf ((0,"Number of strings=%d\n",num));
for (i=0;i<num;i++)
{
m[i].type = NM_TYPE_MENU; m[i].text = &ModemNames[i];
mprintf ((0,"Text(%d)=%s\n",i,ModemNames[i]));
}
choice = newmenu_do(NULL, "Choose a modem", num, m, NULL);
if (choice<0)
return;
strcpy (ModemInitString,ModemStrings[choice]);
}
Reference in a new issue View git blame Copy permalink