ref: 2053768a9251cbd4c731681a3e1e04c800ad21f4
dir: /src/net_io.c/
// // Copyright(C) 2005-2014 Simon Howard // // This program is free software; you can redistribute it and/or // modify it under the terms of the GNU General Public License // as published by the Free Software Foundation; either version 2 // of the License, or (at your option) any later version. // // This program is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU General Public License for more details. // // DESCRIPTION: // Network packet I/O. Base layer for sending/receiving packets, // through the network module system // #include <stdio.h> #include "i_system.h" #include "net_defs.h" #include "net_io.h" #include "z_zone.h" #define MAX_MODULES 16 struct _net_context_s { net_module_t *modules[MAX_MODULES]; int num_modules; }; net_addr_t net_broadcast_addr; net_context_t *NET_NewContext(void) { net_context_t *context; context = Z_Malloc(sizeof(net_context_t), PU_STATIC, 0); context->num_modules = 0; return context; } void NET_AddModule(net_context_t *context, net_module_t *module) { if (context->num_modules >= MAX_MODULES) { I_Error("NET_AddModule: No more modules for context"); } context->modules[context->num_modules] = module; ++context->num_modules; } net_addr_t *NET_ResolveAddress(net_context_t *context, const char *addr) { int i; net_addr_t *result; for (i=0; i<context->num_modules; ++i) { result = context->modules[i]->ResolveAddress(addr); if (result != NULL) { NET_ReferenceAddress(result); return result; } } return NULL; } void NET_SendPacket(net_addr_t *addr, net_packet_t *packet) { addr->module->SendPacket(addr, packet); } void NET_SendBroadcast(net_context_t *context, net_packet_t *packet) { int i; for (i=0; i<context->num_modules; ++i) { context->modules[i]->SendPacket(&net_broadcast_addr, packet); } } boolean NET_RecvPacket(net_context_t *context, net_addr_t **addr, net_packet_t **packet) { int i; // check all modules for new packets for (i=0; i<context->num_modules; ++i) { if (context->modules[i]->RecvPacket(addr, packet)) { NET_ReferenceAddress(*addr); return true; } } return false; } // Note: this prints into a static buffer, calling again overwrites // the first result char *NET_AddrToString(net_addr_t *addr) { static char buf[128]; addr->module->AddrToString(addr, buf, sizeof(buf) - 1); return buf; } void NET_ReferenceAddress(net_addr_t *addr) { if (addr == NULL) { return; } ++addr->refcount; //printf("%s: +refcount=%d\n", NET_AddrToString(addr), addr->refcount); } void NET_ReleaseAddress(net_addr_t *addr) { if (addr == NULL) { return; } --addr->refcount; //printf("%s: -refcount=%d\n", NET_AddrToString(addr), addr->refcount); if (addr->refcount <= 0) { addr->module->FreeAddress(addr); } }