ref: 8bc57f30c05c0bdb3ee44d99679b4195051d00fa
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, char *addr) { int i; net_addr_t *result; result = NULL; for (i=0; i<context->num_modules; ++i) { result = context->modules[i]->ResolveAddress(addr); if (result != NULL) { break; } } return result; } 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)) { 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_FreeAddress(net_addr_t *addr) { addr->module->FreeAddress(addr); }