Games/Doom/aros_net_local.c

   1 #include <exec/exec.h>
   2 #include <proto/exec.h>
   3 #include <clib/alib_protos.h>
   4
   5 #define DEBUG 0
   6 #include <aros/debug.h>
   7
   8 #include "d_net.h"
   9 #include "doomstat.h"
  10 #include "m_argv.h"
  11 #include "i_system.h"
  12
  13 #include "aros_netspecial.h"
  14 #include "aros_net_local.h"
  15
  16 /****************************************************************************/
  17
  18 arosnetdriver_t local_netdriver =
  19 {
  20     "Local",
  21     "-netlocal",
  22     AROSNetLocal_InitNetwork,
  23     AROSNetLocal_CleanupNetwork,
  24     AROSNetLocal_NetCmd
  25 };
  26
  27 /****************************************************************************/
  28
  29 static struct ComPort   *comport;
  30 static struct ComMsg    sendmsg, *getmsg;
  31 static struct ComMsg    fastmsg[NUM_FASTMSG];
  32 static struct MsgPort   fastmsg_freeport;
  33 static struct MsgPort   *sendport[MAX_PLAYERS];
  34 static WORD             playerid_to_node[MAX_PLAYERS];
  35 static WORD             playerid;
  36
  37 /****************************************************************************/
  38
  39 boolean AROSNetLocal_InitNetwork(void)
  40 {
  41     int i,i2,i3;
  42     int netgame=0;
  43
  44     i = M_CheckParm ("-netlocal");
  45
  46     netgame = 1;
  47
  48     // parse player number and host list
  49     doomcom->consoleplayer = consoleplayer = playerid = myargv[i + 1][0] - '1';
  50
  51     doomcom->numnodes = 1; // this node for sure
  52
  53     i++;
  54     while (++i < myargc && myargv[i][0] != '-')
  55     {
  56         doomcom->numnodes++;
  57     }
  58
  59     doomcom->id = DOOMCOM_ID;
  60     doomcom->numplayers = doomcom->numnodes;
  61
  62     Forbid();
  63     if (!(comport = (struct ComPort *)FindSemaphore(COMNAME)))
  64     {
  65         comport = AllocVec(sizeof(struct ComPort), MEMF_PUBLIC | MEMF_CLEAR);
  66         if (!comport)
  67         {
  68             Permit();
  69             I_Error("AROS_Net_Local: Out of memory!");
  70         }
  71
  72         InitSemaphore(&comport->sem);
  73         comport->sem.ss_Link.ln_Name = COMNAME;
  74         comport->sem.ss_Link.ln_Pri = -128;
  75
  76         comport->pool = CreatePool(MEMF_PUBLIC, sizeof(struct ComMsg) * 20,
  77                                                 sizeof(struct ComMsg) * 20);
  78         if (!comport->pool)
  79         {
  80             Permit();
  81             FreeVec(comport);comport=0;
  82
  83             I_Error("AROS_Net_Local: Out of memory!");
  84         }
  85
  86         AddSemaphore(&comport->sem);
  87
  88         for(i = 0;i < MAX_PLAYERS; i++)
  89         {
  90             comport->playerport[i].msgport.mp_Node.ln_Type = NT_MSGPORT;
  91             comport->playerport[i].msgport.mp_Flags        = PA_IGNORE;
  92             comport->playerport[i].msgport.mp_SigBit       = 0;
  93             comport->playerport[i].msgport.mp_SigTask      = NULL;
  94
  95             NewList(&comport->playerport[i].msgport.mp_MsgList);
  96         }
  97     }
  98
  99     if (comport->playerport[playerid].inuse)
 100     {
 101         Permit();
 102         I_Error("AROS_Net_Local: ComPort %ld already in use!\n", playerid + 1);
 103     }
 104
 105     comport->playerport[playerid].inuse = TRUE;
 106     comport->users++;
 107
 108     Permit();
 109
 110     sendmsg.playerid = playerid;
 111
 112     for(i = 0;i < doomcom->numplayers; i++)
 113     {
 114         playerid_to_node[i] = -1;
 115     }
 116
 117     i2 = 1;i3 = 1;
 118     for(i = 0;i < doomcom->numplayers; i++)
 119     {
 120         if (i != playerid)
 121         {
 122             D(bug("Player: %d   playerid_to_node[%d] = %d\n",playerid,i,i2));
 123             playerid_to_node[i] = i2++;
 124
 125             D(bug("Player: %d   sendport[%d] = %d\n",playerid,i3,i));
 126             sendport[i3++] = &comport->playerport[i].msgport;
 127
 128         }
 129     }
 130
 131     fastmsg_freeport.mp_Node.ln_Type = NT_MSGPORT;
 132     fastmsg_freeport.mp_Flags = PA_IGNORE;
 133     NewList(&fastmsg_freeport.mp_MsgList);
 134
 135     for(i = 0;i < NUM_FASTMSG; i++)
 136     {
 137         fastmsg[i].msg.mn_Node.ln_Type = NT_MESSAGE;
 138         fastmsg[i].msg.mn_ReplyPort    = &fastmsg_freeport;
 139         fastmsg[i].msg.mn_Length       = sizeof(struct ComMsg);
 140
 141         PutMsg(&fastmsg_freeport, &fastmsg[i].msg);
 142     }
 143
 144     return true;
 145 }
 146
 147 /****************************************************************************/
 148
 149 void AROSNetLocal_NetCmd (void)
 150 {
 151     if (doomcom->command == CMD_SEND) {
 152         AROSNetLocal_NetSend ();
 153     } else if (doomcom->command == CMD_GET) {
 154         AROSNetLocal_NetGet ();
 155     } else
 156         I_Error ("AROS_Net_Local: Bad net cmd: %i\n",doomcom->command);
 157 }
 158
 159 /****************************************************************************/
 160
 161 void AROSNetLocal_NetSend(void)
 162 {
 163     /* static int counter = 0; */
 164
 165     struct ComMsg *msg = (struct ComMsg *)GetMsg(&fastmsg_freeport);
 166     /* no msg free ==> let's allocate one */
 167
 168     if (!msg) return;
 169
 170 /*    {
 171         Forbid();
 172         msg = AllocPooled(comport->pool,sizeof(struct ComMsg));
 173         Permit();
 174
 175         if (!msg) I_Error("AROS_Net_Local: Could not alloc ComMsg!");
 176         msg->flags = CMF_ALLOCED;
 177         msg->pool = comport->pool;
 178     }
 179 */
 180
 181     D(bug("Player %d (%06d): send to %d\n",playerid,counter++,doomcom->remotenode));
 182
 183     msg->dd = *netbuffer;
 184
 185     msg->datalen = doomcom->datalength;
 186     msg->playerid = playerid;
 187
 188     PutMsg(sendport[doomcom->remotenode], &msg->msg);
 189 }
 190
 191 /****************************************************************************/
 192
 193 void AROSNetLocal_NetGet(void)
 194 {
 195
 196     getmsg = (struct ComMsg *)GetMsg(&comport->playerport[playerid].msgport);
 197
 198     if (!getmsg)
 199     {
 200         doomcom->remotenode = -1; // no packet
 201         return;
 202     }
 203
 204     D(bug("player %d: -------- netget %d (node = %d)\n",
 205                 playerid,
 206                 getmsg->playerid,
 207                 playerid_to_node[getmsg->playerid]));
 208
 209     doomcom->remotenode = playerid_to_node[getmsg->playerid];
 210     doomcom->datalength = getmsg->datalen;
 211
 212     if (doomcom->remotenode < 0 || doomcom->remotenode >= MAX_PLAYERS)
 213     {
 214         doomcom->remotenode = - 1;
 215     } else {
 216         *netbuffer = getmsg->dd;
 217     }
 218
 219     if (getmsg->flags & CMF_ALLOCED)
 220     {
 221         Forbid();
 222         FreePooled(getmsg->pool, getmsg, sizeof(struct ComMsg));
 223         Permit();
 224     }
 225     else if (!(getmsg->flags & CMF_DEAD))
 226     {
 227         ReplyMsg(&getmsg->msg);
 228     }
 229
 230 }
 231
 232 /****************************************************************************/
 233
 234 void AROSNetLocal_CleanupNetwork(void)
 235 {
 236     WORD i;
 237
 238     Forbid();
 239
 240     comport->playerport[playerid].inuse = FALSE;
 241     comport->users--;
 242
 243     /* Make sure sent fastmsg's are not replied back */
 244
 245     for(i = 0;i < NUM_FASTMSG; i++)
 246     {
 247         fastmsg[i].flags |= CMF_DEAD;
 248     }
 249
 250     if (comport->users == 0)
 251     {
 252         RemSemaphore(&comport->sem);
 253     }
 254
 255     Permit();
 256 }
 257
 258 /****************************************************************************/