Index: uspace/srv/devman/devman.c =================================================================== --- uspace/srv/devman/devman.c (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/devman/devman.c (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -794,4 +794,7 @@ case EOK: dev->state = DEVICE_USABLE; + exch = async_exchange_begin(drv->sess); + async_msg_1(exch, DRIVER_DEV_ADDED, dev->handle); + async_exchange_end(exch); break; case ENOENT: Index: uspace/srv/hw/netif/ne2000/Makefile =================================================================== --- uspace/srv/hw/netif/ne2000/Makefile (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ (revision ) @@ -1,47 +1,0 @@ -# -# Copyright (c) 2005 Martin Decky -# Copyright (c) 2007 Jakub Jermar -# All rights reserved. -# -# Redistribution and use in source and binary forms, with or without -# modification, are permitted provided that the following conditions -# are met: -# -# - Redistributions of source code must retain the above copyright -# notice, this list of conditions and the following disclaimer. -# - Redistributions in binary form must reproduce the above copyright -# notice, this list of conditions and the following disclaimer in the -# documentation and/or other materials provided with the distribution. -# - The name of the author may not be used to endorse or promote products -# derived from this software without specific prior written permission. -# -# THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR -# IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES -# OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. -# IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, -# INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT -# NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, -# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY -# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT -# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF -# THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. -# - -USPACE_PREFIX = ../../../.. -ROOT_PATH = $(USPACE_PREFIX)/.. -LIBS = $(LIBNET_PREFIX)/libnet.a -EXTRA_CFLAGS = -I$(LIBNET_PREFIX)/include - -COMMON_MAKEFILE = $(ROOT_PATH)/Makefile.common -CONFIG_MAKEFILE = $(ROOT_PATH)/Makefile.config - --include $(COMMON_MAKEFILE) --include $(CONFIG_MAKEFILE) - -BINARY = ne2000 - -SOURCES = \ - dp8390.c \ - ne2000.c - -include $(USPACE_PREFIX)/Makefile.common Index: uspace/srv/hw/netif/ne2000/dp8390.c =================================================================== --- uspace/srv/hw/netif/ne2000/dp8390.c (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ (revision ) @@ -1,655 +1,0 @@ -/* - * Copyright (c) 2009 Lukas Mejdrech - * Copyright (c) 2011 Martin Decky - * All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions - * are met: - * - * - Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * - Redistributions in binary form must reproduce the above copyright - * notice, this list of conditions and the following disclaimer in the - * documentation and/or other materials provided with the distribution. - * - The name of the author may not be used to endorse or promote products - * derived from this software without specific prior written permission. - * - * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR - * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES - * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. - * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, - * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT - * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, - * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY - * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT - * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF - * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - */ - -/* - * This code is based upon the NE2000 driver for MINIX, - * distributed according to a BSD-style license. - * - * Copyright (c) 1987, 1997, 2006 Vrije Universiteit - * Copyright (c) 1992, 1994 Philip Homburg - * Copyright (c) 1996 G. Falzoni - * - */ - -/** @addtogroup ne2000 - * @{ - */ - -/** @file - * - * NE2000 (based on DP8390) network interface core implementation. - * Only the basic NE2000 PIO (ISA) interface is supported, remote - * DMA is completely absent from this code for simplicity. - * - */ - -#include -#include -#include -#include -#include -#include -#include -#include "dp8390.h" - -/** Page size */ -#define DP_PAGE 256 - -/** 6 * DP_PAGE >= 1514 bytes */ -#define SQ_PAGES 6 - -/* NE2000 implementation. */ - -/** NE2000 Data Register */ -#define NE2K_DATA 0x0010 - -/** NE2000 Reset register */ -#define NE2K_RESET 0x001f - -/** NE2000 data start */ -#define NE2K_START 0x4000 - -/** NE2000 data size */ -#define NE2K_SIZE 0x4000 - -/** NE2000 retry count */ -#define NE2K_RETRY 0x1000 - -/** NE2000 error messages rate limiting */ -#define NE2K_ERL 10 - -/** Minimum Ethernet packet size in bytes */ -#define ETH_MIN_PACK_SIZE 60 - -/** Maximum Ethernet packet size in bytes */ -#define ETH_MAX_PACK_SIZE_TAGGED 1518 - -/** Type definition of the receive header - * - */ -typedef struct { - /** Copy of RSR */ - uint8_t status; - - /** Pointer to next packet */ - uint8_t next; - - /** Receive Byte Count Low */ - uint8_t rbcl; - - /** Receive Byte Count High */ - uint8_t rbch; -} recv_header_t; - -/** Read a memory block word by word. - * - * @param[in] port Source address. - * @param[out] buf Destination buffer. - * @param[in] size Memory block size in bytes. - * - */ -static void pio_read_buf_16(void *port, void *buf, size_t size) -{ - size_t i; - - for (i = 0; (i << 1) < size; i++) - *((uint16_t *) buf + i) = pio_read_16((ioport16_t *) (port)); -} - -/** Write a memory block word by word. - * - * @param[in] port Destination address. - * @param[in] buf Source buffer. - * @param[in] size Memory block size in bytes. - * - */ -static void pio_write_buf_16(void *port, void *buf, size_t size) -{ - size_t i; - - for (i = 0; (i << 1) < size; i++) - pio_write_16((ioport16_t *) port, *((uint16_t *) buf + i)); -} - -static void ne2k_download(ne2k_t *ne2k, void *buf, size_t addr, size_t size) -{ - size_t esize = size & ~1; - - pio_write_8(ne2k->port + DP_RBCR0, esize & 0xff); - pio_write_8(ne2k->port + DP_RBCR1, (esize >> 8) & 0xff); - pio_write_8(ne2k->port + DP_RSAR0, addr & 0xff); - pio_write_8(ne2k->port + DP_RSAR1, (addr >> 8) & 0xff); - pio_write_8(ne2k->port + DP_CR, CR_DM_RR | CR_PS_P0 | CR_STA); - - if (esize != 0) { - pio_read_buf_16(ne2k->data_port, buf, esize); - size -= esize; - buf += esize; - } - - if (size) { - assert(size == 1); - - uint16_t word = pio_read_16(ne2k->data_port); - memcpy(buf, &word, 1); - } -} - -static void ne2k_upload(ne2k_t *ne2k, void *buf, size_t addr, size_t size) -{ - size_t esize = size & ~1; - - pio_write_8(ne2k->port + DP_RBCR0, esize & 0xff); - pio_write_8(ne2k->port + DP_RBCR1, (esize >> 8) & 0xff); - pio_write_8(ne2k->port + DP_RSAR0, addr & 0xff); - pio_write_8(ne2k->port + DP_RSAR1, (addr >> 8) & 0xff); - pio_write_8(ne2k->port + DP_CR, CR_DM_RW | CR_PS_P0 | CR_STA); - - if (esize != 0) { - pio_write_buf_16(ne2k->data_port, buf, esize); - size -= esize; - buf += esize; - } - - if (size) { - assert(size == 1); - - uint16_t word = 0; - - memcpy(&word, buf, 1); - pio_write_16(ne2k->data_port, word); - } -} - -static void ne2k_init(ne2k_t *ne2k) -{ - unsigned int i; - - /* Reset the ethernet card */ - uint8_t val = pio_read_8(ne2k->port + NE2K_RESET); - usleep(2000); - pio_write_8(ne2k->port + NE2K_RESET, val); - usleep(2000); - - /* Reset the DP8390 */ - pio_write_8(ne2k->port + DP_CR, CR_STP | CR_DM_ABORT); - for (i = 0; i < NE2K_RETRY; i++) { - if (pio_read_8(ne2k->port + DP_ISR) != 0) - break; - } -} - -/** Probe and initialize the network interface. - * - * @param[in,out] ne2k Network interface structure. - * @param[in] port Device address. - * @param[in] irq Device interrupt vector. - * - * @return EOK on success. - * @return EXDEV if the network interface was not recognized. - * - */ -int ne2k_probe(ne2k_t *ne2k, void *port, int irq) -{ - unsigned int i; - - /* General initialization */ - ne2k->port = port; - ne2k->data_port = ne2k->port + NE2K_DATA; - ne2k->irq = irq; - ne2k->probed = false; - ne2k->up = false; - - ne2k_init(ne2k); - - /* Check if the DP8390 is really there */ - uint8_t val = pio_read_8(ne2k->port + DP_CR); - if ((val & (CR_STP | CR_DM_ABORT)) != (CR_STP | CR_DM_ABORT)) - return EXDEV; - - /* Disable the receiver and init TCR and DCR */ - pio_write_8(ne2k->port + DP_RCR, RCR_MON); - pio_write_8(ne2k->port + DP_TCR, TCR_NORMAL); - pio_write_8(ne2k->port + DP_DCR, DCR_WORDWIDE | DCR_8BYTES | DCR_BMS); - - /* Setup a transfer to get the MAC address */ - pio_write_8(ne2k->port + DP_RBCR0, ETH_ADDR << 1); - pio_write_8(ne2k->port + DP_RBCR1, 0); - pio_write_8(ne2k->port + DP_RSAR0, 0); - pio_write_8(ne2k->port + DP_RSAR1, 0); - pio_write_8(ne2k->port + DP_CR, CR_DM_RR | CR_PS_P0 | CR_STA); - - for (i = 0; i < ETH_ADDR; i++) - ne2k->mac[i] = pio_read_16(ne2k->data_port); - - ne2k->probed = true; - return EOK; -} - -/** Start the network interface. - * - * @param[in,out] ne2k Network interface structure. - * - * @return EOK on success. - * @return EXDEV if the network interface is disabled. - * - */ -int ne2k_up(ne2k_t *ne2k) -{ - if (!ne2k->probed) - return EXDEV; - - ne2k_init(ne2k); - - /* - * Setup send queue. Use the first - * SQ_PAGES of NE2000 memory for the send - * buffer. - */ - ne2k->sq.dirty = false; - ne2k->sq.page = NE2K_START / DP_PAGE; - fibril_mutex_initialize(&ne2k->sq_mutex); - fibril_condvar_initialize(&ne2k->sq_cv); - - /* - * Setup receive ring buffer. Use all the rest - * of the NE2000 memory (except the first SQ_PAGES - * reserved for the send buffer) for the receive - * ring buffer. - */ - ne2k->start_page = ne2k->sq.page + SQ_PAGES; - ne2k->stop_page = ne2k->sq.page + NE2K_SIZE / DP_PAGE; - - /* - * Initialization of the DP8390 following the mandatory procedure - * in reference manual ("DP8390D/NS32490D NIC Network Interface - * Controller", National Semiconductor, July 1995, Page 29). - */ - - /* Step 1: */ - pio_write_8(ne2k->port + DP_CR, CR_PS_P0 | CR_STP | CR_DM_ABORT); - - /* Step 2: */ - pio_write_8(ne2k->port + DP_DCR, DCR_WORDWIDE | DCR_8BYTES | DCR_BMS); - - /* Step 3: */ - pio_write_8(ne2k->port + DP_RBCR0, 0); - pio_write_8(ne2k->port + DP_RBCR1, 0); - - /* Step 4: */ - pio_write_8(ne2k->port + DP_RCR, RCR_AB); - - /* Step 5: */ - pio_write_8(ne2k->port + DP_TCR, TCR_INTERNAL); - - /* Step 6: */ - pio_write_8(ne2k->port + DP_BNRY, ne2k->start_page); - pio_write_8(ne2k->port + DP_PSTART, ne2k->start_page); - pio_write_8(ne2k->port + DP_PSTOP, ne2k->stop_page); - - /* Step 7: */ - pio_write_8(ne2k->port + DP_ISR, 0xff); - - /* Step 8: */ - pio_write_8(ne2k->port + DP_IMR, - IMR_PRXE | IMR_PTXE | IMR_RXEE | IMR_TXEE | IMR_OVWE | IMR_CNTE); - - /* Step 9: */ - pio_write_8(ne2k->port + DP_CR, CR_PS_P1 | CR_DM_ABORT | CR_STP); - - pio_write_8(ne2k->port + DP_PAR0, ne2k->mac[0]); - pio_write_8(ne2k->port + DP_PAR1, ne2k->mac[1]); - pio_write_8(ne2k->port + DP_PAR2, ne2k->mac[2]); - pio_write_8(ne2k->port + DP_PAR3, ne2k->mac[3]); - pio_write_8(ne2k->port + DP_PAR4, ne2k->mac[4]); - pio_write_8(ne2k->port + DP_PAR5, ne2k->mac[5]); - - pio_write_8(ne2k->port + DP_MAR0, 0xff); - pio_write_8(ne2k->port + DP_MAR1, 0xff); - pio_write_8(ne2k->port + DP_MAR2, 0xff); - pio_write_8(ne2k->port + DP_MAR3, 0xff); - pio_write_8(ne2k->port + DP_MAR4, 0xff); - pio_write_8(ne2k->port + DP_MAR5, 0xff); - pio_write_8(ne2k->port + DP_MAR6, 0xff); - pio_write_8(ne2k->port + DP_MAR7, 0xff); - - pio_write_8(ne2k->port + DP_CURR, ne2k->start_page + 1); - - /* Step 10: */ - pio_write_8(ne2k->port + DP_CR, CR_PS_P0 | CR_DM_ABORT | CR_STA); - - /* Step 11: */ - pio_write_8(ne2k->port + DP_TCR, TCR_NORMAL); - - /* Reset counters by reading */ - pio_read_8(ne2k->port + DP_CNTR0); - pio_read_8(ne2k->port + DP_CNTR1); - pio_read_8(ne2k->port + DP_CNTR2); - - /* Finish the initialization */ - ne2k->up = true; - return EOK; -} - -/** Stop the network interface. - * - * @param[in,out] ne2k Network interface structure. - * - */ -void ne2k_down(ne2k_t *ne2k) -{ - if ((ne2k->probed) && (ne2k->up)) { - pio_write_8(ne2k->port + DP_CR, CR_STP | CR_DM_ABORT); - ne2k_init(ne2k); - ne2k->up = false; - } -} - -/** Send a frame. - * - * @param[in,out] ne2k Network interface structure. - * @param[in] packet Frame to be sent. - * - */ -void ne2k_send(ne2k_t *ne2k, packet_t *packet) -{ - assert(ne2k->probed); - assert(ne2k->up); - - fibril_mutex_lock(&ne2k->sq_mutex); - - while (ne2k->sq.dirty) - fibril_condvar_wait(&ne2k->sq_cv, &ne2k->sq_mutex); - - void *buf = packet_get_data(packet); - size_t size = packet_get_data_length(packet); - - if ((size < ETH_MIN_PACK_SIZE) || (size > ETH_MAX_PACK_SIZE_TAGGED)) { - fibril_mutex_unlock(&ne2k->sq_mutex); - fprintf(stderr, "%s: Frame dropped (invalid size %zu bytes)\n", - NAME, size); - return; - } - - /* Upload the frame to the ethernet card */ - ne2k_upload(ne2k, buf, ne2k->sq.page * DP_PAGE, size); - ne2k->sq.dirty = true; - ne2k->sq.size = size; - - /* Initialize the transfer */ - pio_write_8(ne2k->port + DP_TPSR, ne2k->sq.page); - pio_write_8(ne2k->port + DP_TBCR0, size & 0xff); - pio_write_8(ne2k->port + DP_TBCR1, (size >> 8) & 0xff); - pio_write_8(ne2k->port + DP_CR, CR_TXP | CR_STA); - - fibril_mutex_unlock(&ne2k->sq_mutex); -} - -static void ne2k_reset(ne2k_t *ne2k) -{ - unsigned int i; - - /* Stop the chip */ - pio_write_8(ne2k->port + DP_CR, CR_STP | CR_DM_ABORT); - pio_write_8(ne2k->port + DP_RBCR0, 0); - pio_write_8(ne2k->port + DP_RBCR1, 0); - - for (i = 0; i < NE2K_RETRY; i++) { - if ((pio_read_8(ne2k->port + DP_ISR) & ISR_RST) != 0) - break; - } - - pio_write_8(ne2k->port + DP_TCR, TCR_1EXTERNAL | TCR_OFST); - pio_write_8(ne2k->port + DP_CR, CR_STA | CR_DM_ABORT); - pio_write_8(ne2k->port + DP_TCR, TCR_NORMAL); - - /* Acknowledge the ISR_RDC (remote DMA) interrupt */ - for (i = 0; i < NE2K_RETRY; i++) { - if ((pio_read_8(ne2k->port + DP_ISR) & ISR_RDC) != 0) - break; - } - - uint8_t val = pio_read_8(ne2k->port + DP_ISR); - pio_write_8(ne2k->port + DP_ISR, val & ~ISR_RDC); - - /* - * Reset the transmit ring. If we were transmitting a frame, - * we pretend that the packet is processed. Higher layers will - * retransmit if the packet wasn't actually sent. - */ - fibril_mutex_lock(&ne2k->sq_mutex); - ne2k->sq.dirty = false; - fibril_mutex_unlock(&ne2k->sq_mutex); -} - -static frame_t *ne2k_receive_frame(ne2k_t *ne2k, uint8_t page, size_t length) -{ - frame_t *frame = (frame_t *) malloc(sizeof(frame_t)); - if (frame == NULL) - return NULL; - - link_initialize(&frame->link); - - frame->packet = netif_packet_get_1(length); - if (frame->packet == NULL) { - free(frame); - return NULL; - } - - void *buf = packet_suffix(frame->packet, length); - bzero(buf, length); - uint8_t last = page + length / DP_PAGE; - - if (last >= ne2k->stop_page) { - size_t left = (ne2k->stop_page - page) * DP_PAGE - - sizeof(recv_header_t); - - ne2k_download(ne2k, buf, page * DP_PAGE + sizeof(recv_header_t), - left); - ne2k_download(ne2k, buf + left, ne2k->start_page * DP_PAGE, - length - left); - } else - ne2k_download(ne2k, buf, page * DP_PAGE + sizeof(recv_header_t), - length); - - ne2k->stats.receive_packets++; - return frame; -} - -static list_t *ne2k_receive(ne2k_t *ne2k) -{ - /* - * Allocate memory for the list of received frames. - * If the allocation fails here we still receive the - * frames from the network, but they will be lost. - */ - list_t *frames = (list_t *) malloc(sizeof(list_t)); - if (frames != NULL) - list_initialize(frames); - - while (true) { - uint8_t boundary = pio_read_8(ne2k->port + DP_BNRY) + 1; - - if (boundary == ne2k->stop_page) - boundary = ne2k->start_page; - - pio_write_8(ne2k->port + DP_CR, CR_PS_P1 | CR_STA); - uint8_t current = pio_read_8(ne2k->port + DP_CURR); - pio_write_8(ne2k->port + DP_CR, CR_PS_P0 | CR_STA); - - if (current == boundary) - /* No more frames to process */ - break; - - recv_header_t header; - size_t size = sizeof(header); - size_t offset = boundary * DP_PAGE; - - /* Get the frame header */ - pio_write_8(ne2k->port + DP_RBCR0, size & 0xff); - pio_write_8(ne2k->port + DP_RBCR1, (size >> 8) & 0xff); - pio_write_8(ne2k->port + DP_RSAR0, offset & 0xff); - pio_write_8(ne2k->port + DP_RSAR1, (offset >> 8) & 0xff); - pio_write_8(ne2k->port + DP_CR, CR_DM_RR | CR_PS_P0 | CR_STA); - - pio_read_buf_16(ne2k->data_port, (void *) &header, size); - - size_t length = - (((size_t) header.rbcl) | (((size_t) header.rbch) << 8)) - size; - uint8_t next = header.next; - - if ((length < ETH_MIN_PACK_SIZE) - || (length > ETH_MAX_PACK_SIZE_TAGGED)) { - fprintf(stderr, "%s: Rant frame (%zu bytes)\n", NAME, length); - next = current; - } else if ((header.next < ne2k->start_page) - || (header.next > ne2k->stop_page)) { - fprintf(stderr, "%s: Malformed next frame %u\n", NAME, - header.next); - next = current; - } else if (header.status & RSR_FO) { - /* - * This is very serious, so we issue a warning and - * reset the buffers. - */ - fprintf(stderr, "%s: FIFO overrun\n", NAME); - ne2k->overruns++; - next = current; - } else if ((header.status & RSR_PRX) && (ne2k->up)) { - if (frames != NULL) { - frame_t *frame = ne2k_receive_frame(ne2k, boundary, length); - if (frame != NULL) - list_append(&frame->link, frames); - } - } - - /* - * Update the boundary pointer - * to the value of the page - * prior to the next packet to - * be processed. - */ - if (next == ne2k->start_page) - next = ne2k->stop_page - 1; - else - next--; - - pio_write_8(ne2k->port + DP_BNRY, next); - } - - return frames; -} - -list_t *ne2k_interrupt(ne2k_t *ne2k, uint8_t isr, uint8_t tsr) -{ - /* List of received frames */ - list_t *frames = NULL; - - if (isr & (ISR_PTX | ISR_TXE)) { - if (isr & ISR_TXE) - ne2k->stats.send_errors++; - else { - if (tsr & TSR_PTX) - ne2k->stats.send_packets++; - - if (tsr & TSR_COL) - ne2k->stats.collisions++; - - if (tsr & TSR_ABT) - ne2k->stats.send_aborted_errors++; - - if (tsr & TSR_CRS) - ne2k->stats.send_carrier_errors++; - - if (tsr & TSR_FU) { - ne2k->underruns++; - if (ne2k->underruns < NE2K_ERL) - fprintf(stderr, "%s: FIFO underrun\n", NAME); - } - - if (tsr & TSR_CDH) { - ne2k->stats.send_heartbeat_errors++; - if (ne2k->stats.send_heartbeat_errors < NE2K_ERL) - fprintf(stderr, "%s: CD heartbeat failure\n", NAME); - } - - if (tsr & TSR_OWC) - ne2k->stats.send_window_errors++; - } - - fibril_mutex_lock(&ne2k->sq_mutex); - - if (ne2k->sq.dirty) { - /* Prepare the buffer for next packet */ - ne2k->sq.dirty = false; - ne2k->sq.size = 0; - - /* Signal a next frame to be sent */ - fibril_condvar_broadcast(&ne2k->sq_cv); - } else { - ne2k->misses++; - if (ne2k->misses < NE2K_ERL) - fprintf(stderr, "%s: Spurious PTX interrupt\n", NAME); - } - - fibril_mutex_unlock(&ne2k->sq_mutex); - } - - if (isr & ISR_RXE) - ne2k->stats.receive_errors++; - - if (isr & ISR_CNT) { - ne2k->stats.receive_crc_errors += - pio_read_8(ne2k->port + DP_CNTR0); - ne2k->stats.receive_frame_errors += - pio_read_8(ne2k->port + DP_CNTR1); - ne2k->stats.receive_missed_errors += - pio_read_8(ne2k->port + DP_CNTR2); - } - - if (isr & ISR_PRX) - frames = ne2k_receive(ne2k); - - if (isr & ISR_RST) { - /* - * The chip is stopped, and all arrived - * frames are delivered. - */ - ne2k_reset(ne2k); - } - - /* Unmask interrupts to be processed in the next round */ - pio_write_8(ne2k->port + DP_IMR, - IMR_PRXE | IMR_PTXE | IMR_RXEE | IMR_TXEE | IMR_OVWE | IMR_CNTE); - - return frames; -} - -/** @} - */ Index: uspace/srv/hw/netif/ne2000/dp8390.h =================================================================== --- uspace/srv/hw/netif/ne2000/dp8390.h (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ (revision ) @@ -1,248 +1,0 @@ -/* - * Copyright (c) 2009 Lukas Mejdrech - * Copyright (c) 2011 Martin Decky - * All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions - * are met: - * - * - Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * - Redistributions in binary form must reproduce the above copyright - * notice, this list of conditions and the following disclaimer in the - * documentation and/or other materials provided with the distribution. - * - The name of the author may not be used to endorse or promote products - * derived from this software without specific prior written permission. - * - * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR - * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES - * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. - * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, - * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT - * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, - * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY - * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT - * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF - * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - */ - -/* - * This code is based upon the NE2000 driver for MINIX, - * distributed according to a BSD-style license. - * - * Copyright (c) 1987, 1997, 2006 Vrije Universiteit - * Copyright (c) 1992, 1994 Philip Homburg - * Copyright (c) 1996 G. Falzoni - * - */ - -/** @addtogroup ne2000 - * @{ - */ - -/** @file - * DP8390 network interface definitions. - */ - -#ifndef __NET_NETIF_DP8390_H__ -#define __NET_NETIF_DP8390_H__ - -#include -#include -#include -#include - -/** Module name */ -#define NAME "ne2000" - -/** Input/output size */ -#define NE2K_IO_SIZE 0x0020 - -/** Ethernet address length */ -#define ETH_ADDR 6 - -/* National Semiconductor DP8390 Network Interface Controller. */ - -/** Page 0, for reading */ -#define DP_CR 0x00 /**< Command Register */ -#define DP_CLDA0 0x01 /**< Current Local DMA Address 0 */ -#define DP_CLDA1 0x02 /**< Current Local DMA Address 1 */ -#define DP_BNRY 0x03 /**< Boundary Pointer */ -#define DP_TSR 0x04 /**< Transmit Status Register */ -#define DP_NCR 0x05 /**< Number of Collisions Register */ -#define DP_FIFO 0x06 /**< FIFO */ -#define DP_ISR 0x07 /**< Interrupt Status Register */ -#define DP_CRDA0 0x08 /**< Current Remote DMA Address 0 */ -#define DP_CRDA1 0x09 /**< Current Remote DMA Address 1 */ -#define DP_RSR 0x0c /**< Receive Status Register */ -#define DP_CNTR0 0x0d /**< Tally Counter 0 */ -#define DP_CNTR1 0x0e /**< Tally Counter 1 */ -#define DP_CNTR2 0x0f /**< Tally Counter 2 */ - -/** Page 0, for writing */ -#define DP_PSTART 0x01 /**< Page Start Register*/ -#define DP_PSTOP 0x02 /**< Page Stop Register */ -#define DP_TPSR 0x04 /**< Transmit Page Start Register */ -#define DP_TBCR0 0x05 /**< Transmit Byte Count Register 0 */ -#define DP_TBCR1 0x06 /**< Transmit Byte Count Register 1 */ -#define DP_RSAR0 0x08 /**< Remote Start Address Register 0 */ -#define DP_RSAR1 0x09 /**< Remote Start Address Register 1 */ -#define DP_RBCR0 0x0a /**< Remote Byte Count Register 0 */ -#define DP_RBCR1 0x0b /**< Remote Byte Count Register 1 */ -#define DP_RCR 0x0c /**< Receive Configuration Register */ -#define DP_TCR 0x0d /**< Transmit Configuration Register */ -#define DP_DCR 0x0e /**< Data Configuration Register */ -#define DP_IMR 0x0f /**< Interrupt Mask Register */ - -/** Page 1, read/write */ -#define DP_PAR0 0x01 /**< Physical Address Register 0 */ -#define DP_PAR1 0x02 /**< Physical Address Register 1 */ -#define DP_PAR2 0x03 /**< Physical Address Register 2 */ -#define DP_PAR3 0x04 /**< Physical Address Register 3 */ -#define DP_PAR4 0x05 /**< Physical Address Register 4 */ -#define DP_PAR5 0x06 /**< Physical Address Register 5 */ -#define DP_CURR 0x07 /**< Current Page Register */ -#define DP_MAR0 0x08 /**< Multicast Address Register 0 */ -#define DP_MAR1 0x09 /**< Multicast Address Register 1 */ -#define DP_MAR2 0x0a /**< Multicast Address Register 2 */ -#define DP_MAR3 0x0b /**< Multicast Address Register 3 */ -#define DP_MAR4 0x0c /**< Multicast Address Register 4 */ -#define DP_MAR5 0x0d /**< Multicast Address Register 5 */ -#define DP_MAR6 0x0e /**< Multicast Address Register 6 */ -#define DP_MAR7 0x0f /**< Multicast Address Register 7 */ - -/* Bits in Command Register */ -#define CR_STP 0x01 /**< Stop (software reset) */ -#define CR_STA 0x02 /**< Start (activate NIC) */ -#define CR_TXP 0x04 /**< Transmit Packet */ -#define CR_DMA 0x38 /**< Mask for DMA control */ -#define CR_DM_NOP 0x00 /**< DMA: No Operation */ -#define CR_DM_RR 0x08 /**< DMA: Remote Read */ -#define CR_DM_RW 0x10 /**< DMA: Remote Write */ -#define CR_DM_SP 0x18 /**< DMA: Send Packet */ -#define CR_DM_ABORT 0x20 /**< DMA: Abort Remote DMA Operation */ -#define CR_PS 0xc0 /**< Mask for Page Select */ -#define CR_PS_P0 0x00 /**< Register Page 0 */ -#define CR_PS_P1 0x40 /**< Register Page 1 */ -#define CR_PS_P2 0x80 /**< Register Page 2 */ -#define CR_PS_T1 0xc0 /**< Test Mode Register Map */ - -/* Bits in Interrupt State Register */ -#define ISR_PRX 0x01 /**< Packet Received with no errors */ -#define ISR_PTX 0x02 /**< Packet Transmitted with no errors */ -#define ISR_RXE 0x04 /**< Receive Error */ -#define ISR_TXE 0x08 /**< Transmit Error */ -#define ISR_OVW 0x10 /**< Overwrite Warning */ -#define ISR_CNT 0x20 /**< Counter Overflow */ -#define ISR_RDC 0x40 /**< Remote DMA Complete */ -#define ISR_RST 0x80 /**< Reset Status */ - -/* Bits in Interrupt Mask Register */ -#define IMR_PRXE 0x01 /**< Packet Received Interrupt Enable */ -#define IMR_PTXE 0x02 /**< Packet Transmitted Interrupt Enable */ -#define IMR_RXEE 0x04 /**< Receive Error Interrupt Enable */ -#define IMR_TXEE 0x08 /**< Transmit Error Interrupt Enable */ -#define IMR_OVWE 0x10 /**< Overwrite Warning Interrupt Enable */ -#define IMR_CNTE 0x20 /**< Counter Overflow Interrupt Enable */ -#define IMR_RDCE 0x40 /**< DMA Complete Interrupt Enable */ - -/* Bits in Data Configuration Register */ -#define DCR_WTS 0x01 /**< Word Transfer Select */ -#define DCR_BYTEWIDE 0x00 /**< WTS: byte wide transfers */ -#define DCR_WORDWIDE 0x01 /**< WTS: word wide transfers */ -#define DCR_BOS 0x02 /**< Byte Order Select */ -#define DCR_LTLENDIAN 0x00 /**< BOS: Little Endian */ -#define DCR_BIGENDIAN 0x02 /**< BOS: Big Endian */ -#define DCR_LAS 0x04 /**< Long Address Select */ -#define DCR_BMS 0x08 /**< Burst Mode Select */ -#define DCR_AR 0x10 /**< Autoinitialize Remote */ -#define DCR_FTS 0x60 /**< Fifo Threshold Select */ -#define DCR_2BYTES 0x00 /**< 2 bytes */ -#define DCR_4BYTES 0x40 /**< 4 bytes */ -#define DCR_8BYTES 0x20 /**< 8 bytes */ -#define DCR_12BYTES 0x60 /**< 12 bytes */ - -/* Bits in Transmit Configuration Register */ -#define TCR_CRC 0x01 /**< Inhibit CRC */ -#define TCR_ELC 0x06 /**< Encoded Loopback Control */ -#define TCR_NORMAL 0x00 /**< ELC: Normal Operation */ -#define TCR_INTERNAL 0x02 /**< ELC: Internal Loopback */ -#define TCR_0EXTERNAL 0x04 /**< ELC: External Loopback LPBK=0 */ -#define TCR_1EXTERNAL 0x06 /**< ELC: External Loopback LPBK=1 */ -#define TCR_ATD 0x08 /**< Auto Transmit Disable */ -#define TCR_OFST 0x10 /**< Collision Offset Enable (be nice) */ - -/* Bits in Interrupt Status Register */ -#define TSR_PTX 0x01 /**< Packet Transmitted (without error) */ -#define TSR_DFR 0x02 /**< Transmit Deferred (reserved) */ -#define TSR_COL 0x04 /**< Transmit Collided */ -#define TSR_ABT 0x08 /**< Transmit Aborted */ -#define TSR_CRS 0x10 /**< Carrier Sense Lost */ -#define TSR_FU 0x20 /**< FIFO Underrun */ -#define TSR_CDH 0x40 /**< CD Heartbeat */ -#define TSR_OWC 0x80 /**< Out of Window Collision */ - -/* Bits in Receive Configuration Register */ -#define RCR_SEP 0x01 /**< Save Errored Packets */ -#define RCR_AR 0x02 /**< Accept Runt Packets */ -#define RCR_AB 0x04 /**< Accept Broadcast */ -#define RCR_AM 0x08 /**< Accept Multicast */ -#define RCR_PRO 0x10 /**< Physical Promiscuous */ -#define RCR_MON 0x20 /**< Monitor Mode */ - -/* Bits in Receive Status Register */ -#define RSR_PRX 0x01 /**< Packet Received Intact */ -#define RSR_CRC 0x02 /**< CRC Error */ -#define RSR_FAE 0x04 /**< Frame Alignment Error */ -#define RSR_FO 0x08 /**< FIFO Overrun */ -#define RSR_MPA 0x10 /**< Missed Packet */ -#define RSR_PHY 0x20 /**< Multicast Address Match */ -#define RSR_DIS 0x40 /**< Receiver Disabled */ -#define RSR_DFR 0x80 /**< In later manuals: Deferring */ - -typedef struct { - /* Device configuration */ - void *port; - void *data_port; - int irq; - uint8_t mac[ETH_ADDR]; - - uint8_t start_page; /**< Ring buffer start page */ - uint8_t stop_page; /**< Ring buffer stop page */ - - /* Send queue */ - struct { - bool dirty; /**< Buffer contains a packet */ - size_t size; /**< Packet size */ - uint8_t page; /**< Starting page of the buffer */ - } sq; - fibril_mutex_t sq_mutex; - fibril_condvar_t sq_cv; - - /* Driver run-time variables */ - bool probed; - bool up; - - /* Device statistics */ - device_stats_t stats; - uint64_t misses; /**< Receive frame misses */ - uint64_t underruns; /**< FIFO underruns */ - uint64_t overruns; /**< FIFO overruns */ -} ne2k_t; - -typedef struct { - link_t link; - packet_t *packet; -} frame_t; - -extern int ne2k_probe(ne2k_t *, void *, int); -extern int ne2k_up(ne2k_t *); -extern void ne2k_down(ne2k_t *); -extern void ne2k_send(ne2k_t *, packet_t *); -extern list_t *ne2k_interrupt(ne2k_t *, uint8_t, uint8_t); - -#endif - -/** @} - */ Index: uspace/srv/hw/netif/ne2000/ne2000.c =================================================================== --- uspace/srv/hw/netif/ne2000/ne2000.c (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ (revision ) @@ -1,410 +1,0 @@ -/* - * Copyright (c) 2009 Lukas Mejdrech - * Copyright (c) 2011 Martin Decky - * All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions - * are met: - * - * - Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * - Redistributions in binary form must reproduce the above copyright - * notice, this list of conditions and the following disclaimer in the - * documentation and/or other materials provided with the distribution. - * - The name of the author may not be used to endorse or promote products - * derived from this software without specific prior written permission. - * - * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR - * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES - * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. - * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, - * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT - * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, - * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY - * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT - * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF - * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - */ - -/** @addtogroup ne2000 - * @{ - */ - -/** @file - * NE2000 network interface implementation. - */ - -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include "dp8390.h" - -/** Return the device from the interrupt call. - * - * @param[in] call The interrupt call. - * - */ -#define IRQ_GET_DEVICE(call) ((device_id_t) IPC_GET_IMETHOD(call)) - -/** Return the ISR from the interrupt call. - * - * @param[in] call The interrupt call. - * - */ -#define IRQ_GET_ISR(call) ((int) IPC_GET_ARG2(call)) - -/** Return the TSR from the interrupt call. - * - * @param[in] call The interrupt call. - * - */ -#define IRQ_GET_TSR(call) ((int) IPC_GET_ARG3(call)) - -static bool irc_service = false; -static async_sess_t *irc_sess = NULL; - -/** NE2000 kernel interrupt command sequence. - * - */ -static irq_cmd_t ne2k_cmds[] = { - { - /* Read Interrupt Status Register */ - .cmd = CMD_PIO_READ_8, - .addr = NULL, - .dstarg = 2 - }, - { - /* Mask supported interrupt causes */ - .cmd = CMD_BTEST, - .value = (ISR_PRX | ISR_PTX | ISR_RXE | ISR_TXE | ISR_OVW | - ISR_CNT | ISR_RDC), - .srcarg = 2, - .dstarg = 3, - }, - { - /* Predicate for accepting the interrupt */ - .cmd = CMD_PREDICATE, - .value = 4, - .srcarg = 3 - }, - { - /* - * Mask future interrupts via - * Interrupt Mask Register - */ - .cmd = CMD_PIO_WRITE_8, - .addr = NULL, - .value = 0 - }, - { - /* Acknowledge the current interrupt */ - .cmd = CMD_PIO_WRITE_A_8, - .addr = NULL, - .srcarg = 3 - }, - { - /* Read Transmit Status Register */ - .cmd = CMD_PIO_READ_8, - .addr = NULL, - .dstarg = 3 - }, - { - .cmd = CMD_ACCEPT - } -}; - -/** NE2000 kernel interrupt code. - * - */ -static irq_code_t ne2k_code = { - sizeof(ne2k_cmds) / sizeof(irq_cmd_t), - ne2k_cmds -}; - -/** Handle the interrupt notification. - * - * This is the interrupt notification function. It is quarantied - * that there is only a single instance of this notification - * function running at one time until the return from the - * ne2k_interrupt() function (where the interrupts are unmasked - * again). - * - * @param[in] iid Interrupt notification identifier. - * @param[in] call Interrupt notification. - * - */ -static void irq_handler(ipc_callid_t iid, ipc_call_t *call) -{ - device_id_t device_id = IRQ_GET_DEVICE(*call); - netif_device_t *device; - async_sess_t *nil_sess; - ne2k_t *ne2k; - - fibril_rwlock_read_lock(&netif_globals.lock); - - nil_sess = netif_globals.nil_sess; - - if (find_device(device_id, &device) == EOK) - ne2k = (ne2k_t *) device->specific; - else - ne2k = NULL; - - fibril_rwlock_read_unlock(&netif_globals.lock); - - if (ne2k != NULL) { - list_t *frames = - ne2k_interrupt(ne2k, IRQ_GET_ISR(*call), IRQ_GET_TSR(*call)); - - if (frames != NULL) { - while (!list_empty(frames)) { - frame_t *frame = list_get_instance( - list_first(frames), frame_t, link); - - list_remove(&frame->link); - nil_received_msg(nil_sess, device_id, frame->packet, - SERVICE_NONE); - free(frame); - } - - free(frames); - } - } -} - -/** Change the network interface state. - * - * @param[in,out] device Network interface. - * @param[in] state New state. - * - */ -static void change_state(netif_device_t *device, device_state_t state) -{ - if (device->state != state) { - device->state = state; - - const char *desc; - switch (state) { - case NETIF_ACTIVE: - desc = "active"; - break; - case NETIF_STOPPED: - desc = "stopped"; - break; - default: - desc = "unknown"; - } - - printf("%s: State changed to %s\n", NAME, desc); - } -} - -int netif_specific_message(ipc_callid_t callid, ipc_call_t *call, - ipc_call_t *answer, size_t *count) -{ - return ENOTSUP; -} - -int netif_get_device_stats(device_id_t device_id, device_stats_t *stats) -{ - if (!stats) - return EBADMEM; - - netif_device_t *device; - int rc = find_device(device_id, &device); - if (rc != EOK) - return rc; - - ne2k_t *ne2k = (ne2k_t *) device->specific; - - memcpy(stats, &ne2k->stats, sizeof(device_stats_t)); - return EOK; -} - -int netif_get_addr_message(device_id_t device_id, measured_string_t *address) -{ - if (!address) - return EBADMEM; - - netif_device_t *device; - int rc = find_device(device_id, &device); - if (rc != EOK) - return rc; - - ne2k_t *ne2k = (ne2k_t *) device->specific; - - address->value = ne2k->mac; - address->length = ETH_ADDR; - return EOK; -} - -int netif_probe_message(device_id_t device_id, int irq, void *io) -{ - netif_device_t *device = - (netif_device_t *) malloc(sizeof(netif_device_t)); - if (!device) - return ENOMEM; - - ne2k_t *ne2k = (ne2k_t *) malloc(sizeof(ne2k_t)); - if (!ne2k) { - free(device); - return ENOMEM; - } - - void *port; - int rc = pio_enable((void *) io, NE2K_IO_SIZE, &port); - if (rc != EOK) { - free(ne2k); - free(device); - return rc; - } - - bzero(device, sizeof(netif_device_t)); - bzero(ne2k, sizeof(ne2k_t)); - - device->device_id = device_id; - device->specific = (void *) ne2k; - device->state = NETIF_STOPPED; - - rc = ne2k_probe(ne2k, port, irq); - if (rc != EOK) { - printf("%s: No ethernet card found at I/O address %p\n", - NAME, port); - free(ne2k); - free(device); - return rc; - } - - rc = netif_device_map_add(&netif_globals.device_map, device->device_id, device); - if (rc != EOK) { - free(ne2k); - free(device); - return rc; - } - - printf("%s: Ethernet card at I/O address %p, IRQ %d, MAC ", - NAME, port, irq); - - unsigned int i; - for (i = 0; i < ETH_ADDR; i++) - printf("%02x%c", ne2k->mac[i], i < 5 ? ':' : '\n'); - - return EOK; -} - -int netif_start_message(netif_device_t *device) -{ - if (device->state != NETIF_ACTIVE) { - ne2k_t *ne2k = (ne2k_t *) device->specific; - - ne2k_cmds[0].addr = ne2k->port + DP_ISR; - ne2k_cmds[3].addr = ne2k->port + DP_IMR; - ne2k_cmds[4].addr = ne2k_cmds[0].addr; - ne2k_cmds[5].addr = ne2k->port + DP_TSR; - - int rc = register_irq(ne2k->irq, device->device_id, - device->device_id, &ne2k_code); - if (rc != EOK) - return rc; - - rc = ne2k_up(ne2k); - if (rc != EOK) { - unregister_irq(ne2k->irq, device->device_id); - return rc; - } - - change_state(device, NETIF_ACTIVE); - - if (irc_service) { - async_exch_t *exch = async_exchange_begin(irc_sess); - async_msg_1(exch, IRC_ENABLE_INTERRUPT, ne2k->irq); - async_exchange_end(exch); - } - } - - return device->state; -} - -int netif_stop_message(netif_device_t *device) -{ - if (device->state != NETIF_STOPPED) { - ne2k_t *ne2k = (ne2k_t *) device->specific; - - ne2k_down(ne2k); - unregister_irq(ne2k->irq, device->device_id); - change_state(device, NETIF_STOPPED); - } - - return device->state; -} - -int netif_send_message(device_id_t device_id, packet_t *packet, - services_t sender) -{ - netif_device_t *device; - int rc = find_device(device_id, &device); - if (rc != EOK) - return rc; - - if (device->state != NETIF_ACTIVE) { - netif_pq_release(packet_get_id(packet)); - return EFORWARD; - } - - ne2k_t *ne2k = (ne2k_t *) device->specific; - - /* - * Process the packet queue - */ - - do { - packet_t *next = pq_detach(packet); - ne2k_send(ne2k, packet); - netif_pq_release(packet_get_id(packet)); - packet = next; - } while (packet); - - return EOK; -} - -int netif_initialize(void) -{ - sysarg_t apic; - sysarg_t i8259; - - if (((sysinfo_get_value("apic", &apic) == EOK) && (apic)) - || ((sysinfo_get_value("i8259", &i8259) == EOK) && (i8259))) - irc_service = true; - - if (irc_service) { - while (!irc_sess) - irc_sess = service_connect_blocking(EXCHANGE_SERIALIZE, - SERVICE_IRC, 0, 0); - } - - async_set_interrupt_received(irq_handler); - - return service_register(SERVICE_NE2000); -} - -int main(int argc, char *argv[]) -{ - /* Start the module */ - return netif_module_start(); -} - -/** @} - */ Index: uspace/srv/loc/loc.c =================================================================== --- uspace/srv/loc/loc.c (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/loc/loc.c (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -1288,6 +1288,8 @@ cat = category_new("virtual"); categ_dir_add_cat(&cdir, cat); - - + + cat = category_new("nic"); + categ_dir_add_cat(&cdir, cat); + return true; } Index: uspace/srv/net/cfg/lo =================================================================== --- uspace/srv/net/cfg/lo (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ (revision ) @@ -1,13 +1,0 @@ -# loopback configuration - -NAME=lo - -NETIF=lo -NIL=nildummy -IL=ip - -IP_CONFIG=static -IP_ADDR=127.0.0.1 -IP_NETMASK=255.0.0.0 - -MTU=15535 Index: uspace/srv/net/cfg/lo.nic =================================================================== --- uspace/srv/net/cfg/lo.nic (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) +++ uspace/srv/net/cfg/lo.nic (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -0,0 +1,13 @@ +# loopback configuration + +NAME=lo + +HWPATH=/virt/lo/port0 +NIL=nildummy +IL=ip + +IP_CONFIG=static +IP_ADDR=127.0.0.1 +IP_NETMASK=255.0.0.0 + +MTU=15535 Index: uspace/srv/net/cfg/ne2k =================================================================== --- uspace/srv/net/cfg/ne2k (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ (revision ) @@ -1,24 +1,0 @@ -# DP8390 (NE2k) configuration - -NAME=ne2k - -NETIF=ne2000 -NIL=eth -IL=ip - -IRQ=5 -IO=300 - -# 8023_2_LSAP, 8023_2_SNAP -ETH_MODE=DIX -ETH_DUMMY=no - -IP_CONFIG=static -IP_ADDR=10.0.2.15 -IP_ROUTING=yes -IP_NETMASK=255.255.255.0 -IP_BROADCAST=10.0.2.255 -IP_GATEWAY=10.0.2.2 -ARP=arp - -MTU=1500 Index: uspace/srv/net/cfg/ne2k.nic =================================================================== --- uspace/srv/net/cfg/ne2k.nic (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) +++ uspace/srv/net/cfg/ne2k.nic (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -0,0 +1,21 @@ +# NE2000 configuration + +NAME=ne2k + +HWPATH=/hw/pci0/00:01.0/ne2000/port0 +NIL=eth +IL=ip + +# 8023_2_LSAP, 8023_2_SNAP +ETH_MODE=DIX +ETH_DUMMY=no + +IP_CONFIG=static +IP_ADDR=10.0.2.15 +IP_ROUTING=yes +IP_NETMASK=255.255.255.240 +IP_BROADCAST=10.0.2.255 +IP_GATEWAY=10.0.2.2 +ARP=arp + +MTU=1492 Index: uspace/srv/net/documentation.txt =================================================================== --- uspace/srv/net/documentation.txt (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ (revision ) @@ -1,201 +1,0 @@ -/** - -\mainpage Networking and TCP/IP Stack for HelenOS system - -\section introduction Introduction - -

-For the microkernel HelenOS a completely new networking stack was designed. -The networking stack was intended to implement current basic standards of the TCP/IP Stack. -Only the minimalistic functionality allowing the stack to function was to be implemented. -The networking stack is written in C. -

-

-Please see -

-
    -
  • \ref build
    • -
  • \ref software
    • -
  • \ref running
    • -
  • \ref testing
    • -
- -\page build Build from sources - -

-To compile the HelenOS from sources (the cross compilers from the build/ directory are recommended): -

-
    -
  1. change the working directory to the HelenOS source directory
    2. -
  2. run # make config
    3. -
  3. check/change the configuration
    4. -
  4. save and exit the configuration tool
    5. -
  5. run # make
    6. -
-

-The image.iso should be created on success. -

- -\page running Running the HelenOS with networking - -\section netstart Starting the networking - -

-After starting the HelenOS boot image in Qemu, the command line appears. -To run Qemu a script contrib/conf/qemu.sh for Linux or contrib/conf/qemu.bat for Windows in the HelenOS source directory can be used. -The provided scripts set the needed arguments: -
-vga std -M isapc -net nic,model=ne2k_isa -net user -redir udp:8080::8080 -redir udp:8081::8081 -boot d -cdrom image.iso
-Additional arguments may be specified on the command line, they override these set. -

- -

-The networking stack is started and initialized by running a command -
# netstart
-The networking stack is then started and configured network interfaces are enabled. -The current configuration is printed out. -Since that networking applications can be run using the command line as well. -

- -\section network Qemu network - -

-In the common mode Qemu creates a simple network with a gateway and settles the guest system in. -The network is 10.0.2.*, the gateway's address 10.0.2.2 and the guest system has 10.0.2.15. -%Even this simple setting was a bit hard to find in the documentation. -Therefore a static configuration is possible and no additional DHCP nor BOOTP implementations are necessary. -On the other hand the guest system is behind a firewall. -Qemu may be configured to forward some ports to the guest system and allows all outgoing traffic except ICMP and ARP protocols, so you can ping only the gateway. -

- -\section applications Applications - -

-A few networking applications are located in the app/ directory. -Common functions for parsing command line arguments and printing textual networking error messages are located in that directory as well. -The networking applications should be built with the libsocket library located in the socket/libsocket.a file. -They can use functions and definitions from the include/socket.h header file which contains socket API and further includes: -

-
    -
  • include/byteorder.h containing byte order manipulation,
    • -
  • include/in.h containing IPv4 socket address structure,
    • -
  • include/in6.h containing IPv6 socket address structure,
    • -
  • include/inet.h containing socket address structure and parsing functions,
    • -
  • include/socket codes.h containing address and protocol families and socket types and option levels, and
    • -
  • include/socket errno.h containing socket and general error codes.
    • -
- -\page software Software prerequisites - -

-The networking and TCP/IP stack is implemented for the ia32 architecture on top of HelenOS 0.4.1 (Escalopino), the most current stable release of HelenOS. -So far the only one operational network interface supported is in Qemu 0.10.2 and newer. -To run Qemu a script contrib/conf/qemu.sh for Linux or contrib/conf/qemu.bat for Windows in the HelenOS source directory can be used. -The qemu and its libraries have to be installed and in the path. -These scripts set all the necessary parameters -with some ports redirected from the local host to the guest system. -For testing purposes at least a low level communication application is recommended, N.E.T., netcat etc. -

-

-In order to build HelenOS and the networking stack from sources a few tools are -required: -

    -
  • binutils in version 2.19.1,
    • -
  • gcc–core in version 4.3.3 11,
    • -
  • gcc–objc in version 4.3.3, and
    • -
  • gcc–g++ in version 4.3.3.
    • -
-

-All these can be downloaded and installed as cross–compilers on Linux using a script contrib/toolchain.sh in the HelenOS source directory. -In addition rats, a static source code analyzer, and Doxygen, a documentation generator, were used. -All development was tracked in the HelenOS subversion repository. -

- - -\page testing Testing scenarios - -

-The scenarios contain the following shortcuts: -

-
    -
  • g for the quest system, HelenOS in Qemu
    • -
  • h for the host system
    • -
  • n for the NET application
    • -
  • e for echo echo application run in HelenOS
    • -
- -\section scenarios Testing scenarios -
    -
  • UDP -
      -
    1. g #netstart
      2. -
    2. h wine net.exe (->n) (or net.exe)
      3. -
    3. n set 127.0.0.1:8080 address and port, BuiltinUDP protocol
      4. -
    4. n send some data (an ARP will be generated and the original packet gets lost)
      5. -
    5. n send some data (the port is unreachable and the packet is discarded)
      6. -
    6. g #echo -p 8080 -c 3 -v (->e)
      7. -
    7. g prints Listening
      8. -
    8. n send some data
      9. -
    9. e prints received data
      10. -
    10. h prints reply
      11. -
    11. n click disconnect
      12. -
    12. n set :8081 port
      13. -
    13. n send some data
      14. -
    14. n click disconnect
      15. -
    15. n set :8080 port
      16. -
    16. count-1 times: -
        -
      1. n send some data
        2. -
      2. e prints received data
        3. -
      3. h prints reply
        4. -
      -
      17. -
    17. e prints Exiting
      18. -
    18. e quits
      19. -
    19. n send some data (the port is unreachable and the packet is discarded)
      20. -
    -
    • -
  • ICMP echo to 10.0.2.2 -
      -
    1. g #netstart
      2. -
    2. g #ping 10.0.2.2 (->p)
      3. -
    3. g prints ARP request for 10.0.2.2
      4. -
    4. g prints ARP reply from 10.0.2.2
      5. -
    5. p prints timeouted
      6. -
    6. p prints round trip time
      7. -
    7. p prints round trip time
      8. -
    8. p quits
      9. -
    -
    • -
  • ICMP echo to 127.0.0.1 -
      -
    1. g #netstart
      2. -
    2. g #ping 127.0.0.1 (->p)
      3. -
    3. p prints round trip time
      4. -
    4. p prints round trip time
      5. -
    5. p prints round trip time
      6. -
    6. p quits
      7. -
    -
    • -
  • ICMP with no internet on the host system (!) -
      -
    1. g #netstart
      2. -
    2. g #ping 123.123.123.3 (->p)
      3. -
    3. g prints ARP request for 10.0.2.2
      4. -
    4. g prints ARP reply from 10.0.2.2
      5. -
    5. p prints timeouted
      6. -
    6. p prints destination unreachable
      7. -
    7. p prints destination unreachable
      8. -
    8. p quits
      9. -
    -
    • -
- -*/ Index: uspace/srv/net/il/arp/arp.c =================================================================== --- uspace/srv/net/il/arp/arp.c (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/net/il/arp/arp.c (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -174,12 +174,6 @@ count); - if (device) { + if (device) arp_clear_device(device); - if (device->addr_data) - free(device->addr_data); - - if (device->broadcast_data) - free(device->broadcast_data); - } } @@ -190,6 +184,6 @@ } -static int arp_clear_address_req(device_id_t device_id, services_t protocol, - measured_string_t *address) +static int arp_clear_address_req(nic_device_id_t device_id, + services_t protocol, measured_string_t *address) { fibril_mutex_lock(&arp_globals.lock); @@ -218,5 +212,5 @@ } -static int arp_clear_device_req(device_id_t device_id) +static int arp_clear_device_req(nic_device_id_t device_id) { fibril_mutex_lock(&arp_globals.lock); @@ -289,5 +283,5 @@ * */ -static int arp_receive_message(device_id_t device_id, packet_t *packet) +static int arp_receive_message(nic_device_id_t device_id, packet_t *packet) { int rc; @@ -365,5 +359,5 @@ memcpy(src_proto, proto->addr->value, header->protocol_length); - memcpy(src_hw, device->addr->value, + memcpy(src_hw, device->addr, device->packet_dimension.addr_len); memcpy(des_hw, trans->hw_addr->value, @@ -393,5 +387,5 @@ * */ -static int arp_mtu_changed_message(device_id_t device_id, size_t mtu) +static int arp_mtu_changed_message(nic_device_id_t device_id, size_t mtu) { fibril_mutex_lock(&arp_globals.lock); @@ -409,4 +403,36 @@ printf("%s: Device %d changed MTU to %zu\n", NAME, device_id, mtu); + return EOK; +} + +static int arp_addr_changed_message(nic_device_id_t device_id) +{ + uint8_t addr_buffer[NIC_MAX_ADDRESS_LENGTH]; + size_t length; + ipc_callid_t data_callid; + if (!async_data_write_receive(&data_callid, &length)) { + async_answer_0(data_callid, EINVAL); + return EINVAL; + } + if (length > NIC_MAX_ADDRESS_LENGTH) { + async_answer_0(data_callid, ELIMIT); + return ELIMIT; + } + if (async_data_write_finalize(data_callid, addr_buffer, length) != EOK) { + return EINVAL; + } + + fibril_mutex_lock(&arp_globals.lock); + + arp_device_t *device = arp_cache_find(&arp_globals.cache, device_id); + if (!device) { + fibril_mutex_unlock(&arp_globals.lock); + return ENOENT; + } + + memcpy(device->addr, addr_buffer, length); + device->addr_len = length; + + fibril_mutex_unlock(&arp_globals.lock); return EOK; } @@ -456,4 +482,7 @@ async_answer_0(iid, (sysarg_t) rc); break; + case NET_IL_ADDR_CHANGED: + rc = arp_addr_changed_message(IPC_GET_DEVICE(*icall)); + async_answer_0(iid, (sysarg_t) rc); default: @@ -483,5 +512,5 @@ * */ -static int arp_device_message(device_id_t device_id, services_t service, +static int arp_device_message(nic_device_id_t device_id, services_t service, services_t protocol, measured_string_t *address) { @@ -586,24 +615,26 @@ /* Get hardware address */ - rc = nil_get_addr_req(device->sess, device_id, &device->addr, - &device->addr_data); - if (rc != EOK) { + int len = nil_get_addr_req(device->sess, device_id, device->addr, + NIC_MAX_ADDRESS_LENGTH); + if (len < 0) { fibril_mutex_unlock(&arp_globals.lock); arp_protos_destroy(&device->protos, free); free(device); - return rc; - } + return len; + } + + device->addr_len = len; /* Get broadcast address */ - rc = nil_get_broadcast_addr_req(device->sess, device_id, - &device->broadcast_addr, &device->broadcast_data); - if (rc != EOK) { - fibril_mutex_unlock(&arp_globals.lock); - free(device->addr); - free(device->addr_data); + len = nil_get_broadcast_addr_req(device->sess, device_id, + device->broadcast_addr, NIC_MAX_ADDRESS_LENGTH); + if (len < 0) { + fibril_mutex_unlock(&arp_globals.lock); arp_protos_destroy(&device->protos, free); free(device); - return rc; - } + return len; + } + + device->broadcast_addr_len = len; rc = arp_cache_add(&arp_globals.cache, device->device_id, @@ -611,8 +642,4 @@ if (rc != EOK) { fibril_mutex_unlock(&arp_globals.lock); - free(device->addr); - free(device->addr_data); - free(device->broadcast_addr); - free(device->broadcast_data); arp_protos_destroy(&device->protos, free); free(device); @@ -640,9 +667,9 @@ } -static int arp_send_request(device_id_t device_id, services_t protocol, +static int arp_send_request(nic_device_id_t device_id, services_t protocol, measured_string_t *target, arp_device_t *device, arp_proto_t *proto) { /* ARP packet content size = header + (address + translation) * 2 */ - size_t length = 8 + 2 * (proto->addr->length + device->addr->length); + size_t length = 8 + 2 * (proto->addr->length + device->addr_len); if (length > device->packet_dimension.content) return ELIMIT; @@ -661,5 +688,5 @@ header->hardware = htons(device->hardware); - header->hardware_length = (uint8_t) device->addr->length; + header->hardware_length = (uint8_t) device->addr_len; header->protocol = htons(protocol_map(device->service, protocol)); header->protocol_length = (uint8_t) proto->addr->length; @@ -667,17 +694,16 @@ length = sizeof(arp_header_t); - - memcpy(((uint8_t *) header) + length, device->addr->value, - device->addr->length); - length += device->addr->length; + memcpy(((uint8_t *) header) + length, device->addr, + device->addr_len); + length += device->addr_len; memcpy(((uint8_t *) header) + length, proto->addr->value, proto->addr->length); length += proto->addr->length; - bzero(((uint8_t *) header) + length, device->addr->length); - length += device->addr->length; + bzero(((uint8_t *) header) + length, device->addr_len); + length += device->addr_len; memcpy(((uint8_t *) header) + length, target->value, target->length); - - int rc = packet_set_addr(packet, (uint8_t *) device->addr->value, - (uint8_t *) device->broadcast_addr->value, device->addr->length); + + int rc = packet_set_addr(packet, device->addr, device->broadcast_addr, + device->addr_len); if (rc != EOK) { pq_release_remote(arp_globals.net_sess, packet_get_id(packet)); @@ -704,5 +730,5 @@ * */ -static int arp_translate_message(device_id_t device_id, services_t protocol, +static int arp_translate_message(nic_device_id_t device_id, services_t protocol, measured_string_t *target, measured_string_t **translation) { Index: uspace/srv/net/il/arp/arp.h =================================================================== --- uspace/srv/net/il/arp/arp.h (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/net/il/arp/arp.h (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -92,13 +92,13 @@ struct arp_device { /** Actual device hardware address. */ - measured_string_t *addr; - /** Actual device hardware address data. */ - uint8_t *addr_data; + uint8_t addr[NIC_MAX_ADDRESS_LENGTH]; + /** Actual device hardware address length. */ + size_t addr_len; /** Broadcast device hardware address. */ - measured_string_t *broadcast_addr; - /** Broadcast device hardware address data. */ - uint8_t *broadcast_data; + uint8_t broadcast_addr[NIC_MAX_ADDRESS_LENGTH]; + /** Broadcast device hardware address length. */ + size_t broadcast_addr_len; /** Device identifier. */ - device_id_t device_id; + nic_device_id_t device_id; /** Hardware type. */ hw_type_t hardware; Index: uspace/srv/net/il/ip/ip.c =================================================================== --- uspace/srv/net/il/ip/ip.c (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/net/il/ip/ip.c (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -482,5 +482,5 @@ } -static int ip_device_req_local(device_id_t device_id, services_t netif) +static int ip_device_req_local(nic_device_id_t device_id, services_t netif) { ip_netif_t *ip_netif; @@ -501,5 +501,5 @@ ip_netif->device_id = device_id; ip_netif->service = netif; - ip_netif->state = NETIF_STOPPED; + ip_netif->state = NIC_STATE_STOPPED; fibril_rwlock_write_lock(&ip_globals.netifs_lock); @@ -594,5 +594,5 @@ while (index >= 0) { netif = ip_netifs_get_index(&ip_globals.netifs, index); - if (netif && (netif->state == NETIF_ACTIVE)) { + if (netif && (netif->state == NIC_STATE_ACTIVE)) { route = ip_netif_find_route(netif, destination); if (route) @@ -1142,5 +1142,5 @@ } -static int ip_send_msg_local(device_id_t device_id, packet_t *packet, +static int ip_send_msg_local(nic_device_id_t device_id, packet_t *packet, services_t sender, services_t error) { @@ -1258,5 +1258,6 @@ * @return ENOENT if device is not found. */ -static int ip_device_state_message(device_id_t device_id, device_state_t state) +static int ip_device_state_message(nic_device_id_t device_id, + nic_device_state_t state) { ip_netif_t *netif; @@ -1272,5 +1273,6 @@ fibril_rwlock_write_unlock(&ip_globals.netifs_lock); - printf("%s: Device %d changed state to %d\n", NAME, device_id, state); + printf("%s: Device %d changed state to '%s'\n", NAME, device_id, + nic_device_state_to_string(state)); return EOK; @@ -1312,5 +1314,5 @@ * tl_received_msg() function. */ -static int ip_deliver_local(device_id_t device_id, packet_t *packet, +static int ip_deliver_local(nic_device_id_t device_id, packet_t *packet, ip_header_t *header, services_t error) { @@ -1413,5 +1415,5 @@ * is disabled. */ -static int ip_process_packet(device_id_t device_id, packet_t *packet) +static int ip_process_packet(nic_device_id_t device_id, packet_t *packet) { ip_header_t *header; @@ -1514,5 +1516,5 @@ * */ -static int ip_packet_size_message(device_id_t device_id, size_t *addr_len, +static int ip_packet_size_message(nic_device_id_t device_id, size_t *addr_len, size_t *prefix, size_t *content, size_t *suffix) { @@ -1572,5 +1574,5 @@ * @return ENOENT if device is not found. */ -static int ip_mtu_changed_message(device_id_t device_id, size_t mtu) +static int ip_mtu_changed_message(nic_device_id_t device_id, size_t mtu) { ip_netif_t *netif; @@ -1629,5 +1631,8 @@ async_answer_0(iid, (sysarg_t) rc); break; - + case NET_IL_ADDR_CHANGED: + async_answer_0(iid, (sysarg_t) EOK); + break; + default: async_answer_0(iid, (sysarg_t) ENOTSUP); @@ -1689,5 +1694,5 @@ } -static int ip_add_route_req_local(device_id_t device_id, in_addr_t address, +static int ip_add_route_req_local(nic_device_id_t device_id, in_addr_t address, in_addr_t netmask, in_addr_t gateway) { @@ -1723,5 +1728,6 @@ } -static int ip_set_gateway_req_local(device_id_t device_id, in_addr_t gateway) +static int ip_set_gateway_req_local(nic_device_id_t device_id, + in_addr_t gateway) { ip_netif_t *netif; @@ -1757,5 +1763,5 @@ * */ -static int ip_received_error_msg_local(device_id_t device_id, +static int ip_received_error_msg_local(nic_device_id_t device_id, packet_t *packet, services_t target, services_t error) { @@ -1818,5 +1824,5 @@ static int ip_get_route_req_local(ip_protocol_t protocol, const struct sockaddr *destination, socklen_t addrlen, - device_id_t *device_id, void **header, size_t *headerlen) + nic_device_id_t *device_id, void **header, size_t *headerlen) { struct sockaddr_in *address_in; @@ -1909,5 +1915,5 @@ size_t suffix; size_t content; - device_id_t device_id; + nic_device_id_t device_id; int rc; Index: uspace/srv/net/il/ip/ip.h =================================================================== --- uspace/srv/net/il/ip/ip.h (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/net/il/ip/ip.h (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -92,5 +92,5 @@ in_addr_t broadcast; /** Device identifier. */ - device_id_t device_id; + nic_device_id_t device_id; /** Indicates whether using DHCP. */ int dhcp; @@ -108,5 +108,5 @@ services_t service; /** Device state. */ - device_state_t state; + nic_device_state_t state; }; Index: uspace/srv/net/net/Makefile =================================================================== --- uspace/srv/net/net/Makefile (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/net/net/Makefile (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -30,6 +30,6 @@ USPACE_PREFIX = ../../.. ROOT_PATH = $(USPACE_PREFIX)/.. -LIBS = $(LIBNET_PREFIX)/libnet.a $(LIBPACKET_PREFIX)/libpacket.a -EXTRA_CFLAGS = -I$(LIBNET_PREFIX)/include -I$(LIBPACKET_PREFIX)/include +LIBS = $(LIBNET_PREFIX)/libnet.a +EXTRA_CFLAGS = -I$(LIBNET_PREFIX)/include COMMON_MAKEFILE = $(ROOT_PATH)/Makefile.common @@ -43,5 +43,6 @@ SOURCES = \ net.c \ - net_standalone.c + net_standalone.c \ + packet_server.c include $(USPACE_PREFIX)/Makefile.common Index: uspace/srv/net/net/net.c =================================================================== --- uspace/srv/net/net/net.c (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/net/net/net.c (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -1,4 +1,5 @@ /* * Copyright (c) 2009 Lukas Mejdrech + * Copyright (c) 2011 Radim Vansa * All rights reserved. * @@ -36,11 +37,14 @@ */ +#include #include #include #include #include +#include #include #include #include +#include #include #include @@ -49,4 +53,5 @@ #include #include +#include #include #include @@ -57,15 +62,18 @@ #include #include -#include #include #include #include +#include +#include +#include +#include #include "net.h" +#include "packet_server.h" /** Networking module name. */ #define NAME "net" -/** File read buffer size. */ -#define BUFFER_SIZE 256 +#define MAX_PATH_LENGTH 1024 /** Networking module global data. */ @@ -109,70 +117,10 @@ /** Generate new system-unique device identifier. * - * @return The system-unique devic identifier. - */ -static device_id_t generate_new_device_id(void) + * @return The system-unique devic identifier. + * + */ +static nic_device_id_t generate_new_device_id(void) { return device_assign_devno(); -} - -static int parse_line(measured_strings_t *configuration, uint8_t *line) -{ - int rc; - - /* From the beginning */ - uint8_t *name = line; - - /* Skip comments and blank lines */ - if ((*name == '#') || (*name == '\0')) - return EOK; - - /* Skip spaces */ - while (isspace(*name)) - name++; - - /* Remember the name start */ - uint8_t *value = name; - - /* Skip the name */ - while (isalnum(*value) || (*value == '_')) - value++; - - if (*value == '=') { - /* Terminate the name */ - *value = '\0'; - } else { - /* Terminate the name */ - *value = '\0'; - - /* Skip until '=' */ - value++; - while ((*value) && (*value != '=')) - value++; - - /* Not found? */ - if (*value != '=') - return EINVAL; - } - - value++; - - /* Skip spaces */ - while (isspace(*value)) - value++; - - /* Create a bulk measured string till the end */ - measured_string_t *setting = - measured_string_create_bulk(value, 0); - if (!setting) - return ENOMEM; - - /* Add the configuration setting */ - rc = measured_strings_add(configuration, name, 0, setting); - if (rc != EOK) { - free(setting); - return rc; - } - - return EOK; } @@ -182,50 +130,27 @@ printf("%s: Reading configuration file %s/%s\n", NAME, directory, filename); - /* Construct the full filename */ - char fname[BUFFER_SIZE]; - if (snprintf(fname, BUFFER_SIZE, "%s/%s", directory, filename) > BUFFER_SIZE) - return EOVERFLOW; - - /* Open the file */ - FILE *cfg = fopen(fname, "r"); - if (!cfg) + cfg_file_t cfg; + int rc = cfg_load_path(directory, filename, &cfg); + if (rc != EOK) + return rc; + + if (cfg_anonymous(&cfg) == NULL) { + cfg_unload(&cfg); return ENOENT; - - /* - * Read the configuration line by line - * until an error or the end of file - */ - unsigned int line_number = 0; - size_t index = 0; - uint8_t line[BUFFER_SIZE]; - - while (!ferror(cfg) && !feof(cfg)) { - int read = fgetc(cfg); - if ((read > 0) && (read != '\n') && (read != '\r')) { - if (index >= BUFFER_SIZE) { - line[BUFFER_SIZE - 1] = '\0'; - fprintf(stderr, "%s: Configuration line %u too " - "long: %s\n", NAME, line_number, (char *) line); - - /* No space left in the line buffer */ - return EOVERFLOW; - } - /* Append the character */ - line[index] = (uint8_t) read; - index++; - } else { - /* On error or new line */ - line[index] = '\0'; - line_number++; - if (parse_line(configuration, line) != EOK) { - fprintf(stderr, "%s: Configuration error on " - "line %u: %s\n", NAME, line_number, (char *) line); - } - - index = 0; - } - } - - fclose(cfg); + } + + cfg_section_foreach(cfg_anonymous(&cfg), link) { + const cfg_entry_t *entry = cfg_entry_instance(link); + + rc = add_configuration(configuration, + (uint8_t *) entry->key, (uint8_t *) entry->value); + if (rc != EOK) { + printf("%s: Error processing configuration\n", NAME); + cfg_unload(&cfg); + return rc; + } + } + + cfg_unload(&cfg); return EOK; } @@ -272,20 +197,9 @@ netifs_initialize(&net_globals.netifs); - char_map_initialize(&net_globals.netif_names); + char_map_initialize(&net_globals.netif_hwpaths); modules_initialize(&net_globals.modules); measured_strings_initialize(&net_globals.configuration); - /* TODO: dynamic configuration */ rc = read_configuration(); - if (rc != EOK) - return rc; - - rc = add_module(NULL, &net_globals.modules, (uint8_t *) LO_NAME, - (uint8_t *) LO_FILENAME, SERVICE_LO, 0, connect_to_service); - if (rc != EOK) - return rc; - - rc = add_module(NULL, &net_globals.modules, (uint8_t *) NE2000_NAME, - (uint8_t *) NE2000_FILENAME, SERVICE_NE2000, 0, connect_to_service); if (rc != EOK) return rc; @@ -331,13 +245,17 @@ return rc; + rc = packet_server_init(); + if (rc != EOK) + goto out; + rc = net_initialize(client_connection); if (rc != EOK) goto out; + rc = startup(); + if (rc != EOK) + goto out; + rc = service_register(SERVICE_NETWORKING); - if (rc != EOK) - goto out; - - rc = startup(); if (rc != EOK) goto out; @@ -364,8 +282,8 @@ */ static int net_get_conf(measured_strings_t *netif_conf, - measured_string_t *configuration, size_t count, uint8_t **data) -{ - if (data) - *data = NULL; + measured_string_t *configuration, size_t count) +{ + if ((!configuration) || (count <= 0)) + return EINVAL; size_t index; @@ -389,28 +307,65 @@ } -static int net_get_conf_req_local(measured_string_t **configuration, - size_t count, uint8_t **data) -{ - if (!configuration || (count <= 0)) - return EINVAL; - - return net_get_conf(NULL, *configuration, count, data); -} - -static int net_get_device_conf_req_local(device_id_t device_id, - measured_string_t **configuration, size_t count, uint8_t **data) -{ - if ((!configuration) || (count == 0)) - return EINVAL; - +static int net_get_device_conf(nic_device_id_t device_id, + measured_string_t *configuration, size_t count) +{ netif_t *netif = netifs_find(&net_globals.netifs, device_id); if (netif) - return net_get_conf(&netif->configuration, *configuration, count, data); + return net_get_conf(&netif->configuration, configuration, count); else - return net_get_conf(NULL, *configuration, count, data); -} - -void net_free_settings(measured_string_t *settings, uint8_t *data) -{ + return net_get_conf(NULL, configuration, count); +} + +static int net_get_devices(measured_string_t **devices, size_t *dev_count) +{ + if (!devices) + return EBADMEM; + + size_t max_count = netifs_count(&net_globals.netifs); + *devices = malloc(max_count * sizeof(measured_string_t)); + if (*devices == NULL) + return ENOMEM; + + size_t count = 0; + for (size_t i = 0; i < max_count; i++) { + netif_t *item = netifs_get_index(&net_globals.netifs, i); + if (item->sess != NULL) { + /* + * Use format "device_id:device_name" + * FIXME: This typecasting looks really ugly + */ + (*devices)[count].length = asprintf( + (char **) &((*devices)[count].value), + NIC_DEVICE_PRINT_FMT ":%s", item->id, + (const char *) item->name); + count++; + } + } + + *dev_count = (size_t) count; + return EOK; +} + +static int net_get_devices_count() +{ + size_t max_count = netifs_count(&net_globals.netifs); + + size_t count = 0; + for (size_t i = 0; i < max_count; i++) { + netif_t *item = netifs_get_index(&net_globals.netifs, i); + if (item->sess != NULL) + count++; + } + + return count; +} + +static void net_free_devices(measured_string_t *devices, size_t count) +{ + size_t i; + for (i = 0; i < count; ++i) + free(devices[i].value); + + free(devices); } @@ -431,75 +386,124 @@ * */ -static int start_device(netif_t *netif) -{ - int rc; - - /* Mandatory netif */ - measured_string_t *setting = - measured_strings_find(&netif->configuration, (uint8_t *) CONF_NETIF, 0); - - netif->driver = get_running_module(&net_globals.modules, setting->value); - if (!netif->driver) { - fprintf(stderr, "%s: Failed to start network interface driver '%s'\n", +static int init_device(netif_t *netif, devman_handle_t handle) +{ + netif->handle = handle; + netif->sess = devman_device_connect(EXCHANGE_SERIALIZE, netif->handle, + IPC_FLAG_BLOCKING); + if (netif->sess == NULL) { + printf("%s: Unable to connect to device\n", NAME); + return EREFUSED; + } + + /* Optional network interface layer */ + measured_string_t *setting = measured_strings_find(&netif->configuration, + (uint8_t *) CONF_NIL, 0); + if (setting) { + netif->nil = get_running_module(&net_globals.modules, + setting->value); + if (!netif->nil) { + printf("%s: Unable to connect to network interface layer '%s'\n", + NAME, setting->value); + return EINVAL; + } + } else + netif->nil = NULL; + + /* Mandatory internet layer */ + setting = measured_strings_find(&netif->configuration, + (uint8_t *) CONF_IL, 0); + netif->il = get_running_module(&net_globals.modules, + setting->value); + if (!netif->il) { + printf("%s: Unable to connect to internet layer '%s'\n", NAME, setting->value); return EINVAL; } - /* Optional network interface layer */ - setting = measured_strings_find(&netif->configuration, (uint8_t *) CONF_NIL, 0); - if (setting) { - netif->nil = get_running_module(&net_globals.modules, setting->value); - if (!netif->nil) { - fprintf(stderr, "%s: Failed to start network interface layer '%s'\n", - NAME, setting->value); - return EINVAL; - } - } else - netif->nil = NULL; - - /* Mandatory internet layer */ - setting = measured_strings_find(&netif->configuration, (uint8_t *) CONF_IL, 0); - netif->il = get_running_module(&net_globals.modules, setting->value); - if (!netif->il) { - fprintf(stderr, "%s: Failed to start internet layer '%s'\n", - NAME, setting->value); - return EINVAL; - } - - /* Hardware configuration */ - setting = measured_strings_find(&netif->configuration, (uint8_t *) CONF_IRQ, 0); - int irq = setting ? strtol((char *) setting->value, NULL, 10) : 0; - - setting = measured_strings_find(&netif->configuration, (uint8_t *) CONF_IO, 0); - uintptr_t io = setting ? strtol((char *) setting->value, NULL, 16) : 0; - - rc = netif_probe_req(netif->driver->sess, netif->id, irq, (void *) io); - if (rc != EOK) - return rc; - /* Network interface layer startup */ - services_t internet_service; + int rc; + services_t nil_service; if (netif->nil) { - setting = measured_strings_find(&netif->configuration, (uint8_t *) CONF_MTU, 0); + setting = measured_strings_find(&netif->configuration, + (uint8_t *) CONF_MTU, 0); if (!setting) setting = measured_strings_find(&net_globals.configuration, (uint8_t *) CONF_MTU, 0); - int mtu = setting ? strtol((char *) setting->value, NULL, 10) : 0; - rc = nil_device_req(netif->nil->sess, netif->id, mtu, - netif->driver->service); + int mtu = setting ? + strtol((const char *) setting->value, NULL, 10) : 0; + rc = nil_device_req(netif->nil->sess, netif->id, + netif->handle, mtu); + if (rc != EOK) { + printf("%s: Unable to start network interface layer\n", + NAME); + return rc; + } + + nil_service = netif->nil->service; + } else + nil_service = -1; + + /* Inter-network layer startup */ + switch (netif->il->service) { + case SERVICE_IP: + rc = ip_device_req(netif->il->sess, netif->id, nil_service); + if (rc != EOK) { + printf("%s: Unable to start internet layer\n", NAME); + return rc; + } + + break; + default: + return ENOENT; + } + + return nic_set_state(netif->sess, NIC_STATE_ACTIVE); +} + +static int net_driver_port_ready(devman_handle_t handle) +{ + char hwpath[MAX_PATH_LENGTH]; + int rc = devman_fun_get_path(handle, hwpath, MAX_PATH_LENGTH); + if (rc != EOK) + return EINVAL; + + int index = char_map_find(&net_globals.netif_hwpaths, + (uint8_t *) hwpath, 0); + if (index == CHAR_MAP_NULL) + return ENOENT; + + netif_t *netif = netifs_get_index(&net_globals.netifs, index); + if (netif == NULL) + return ENOENT; + + rc = init_device(netif, handle); + if (rc != EOK) + return rc; + + /* Increment module usage */ + if (netif->nil) + netif->nil->usage++; + + netif->il->usage++; + + return EOK; +} + +static int net_driver_ready_local(devman_handle_t handle) +{ + devman_handle_t *funs; + size_t count; + int rc = devman_dev_get_functions(handle, &funs, &count); + if (rc != EOK) + return rc; + + for (size_t i = 0; i < count; i++) { + rc = net_driver_port_ready(funs[i]); if (rc != EOK) return rc; - - internet_service = netif->nil->service; - } else - internet_service = netif->driver->service; - - /* Inter-network layer startup */ - rc = ip_device_req(netif->il->sess, netif->id, internet_service); - if (rc != EOK) - return rc; - - return netif_start_req(netif->driver->sess, netif->id); + } + + return EOK; } @@ -519,43 +523,60 @@ static int startup(void) { - const char *conf_files[] = { - "lo", - "ne2k" - }; - size_t count = sizeof(conf_files) / sizeof(char *); int rc; - size_t i; - for (i = 0; i < count; i++) { + DIR *config_dir = opendir(CONF_DIR); + if (config_dir == NULL) + return ENOENT; + + struct dirent *dir_entry; + while ((dir_entry = readdir(config_dir))) { + if (str_cmp(dir_entry->d_name + str_length(dir_entry->d_name) + - str_length(CONF_EXT), CONF_EXT) != 0) + continue; + netif_t *netif = (netif_t *) malloc(sizeof(netif_t)); if (!netif) - return ENOMEM; + continue; + + netif->handle = -1; + netif->sess = NULL; netif->id = generate_new_device_id(); - if (!netif->id) - return EXDEV; + if (!netif->id) { + free(netif); + continue; + } rc = measured_strings_initialize(&netif->configuration); - if (rc != EOK) - return rc; - - /* Read configuration files */ - rc = read_netif_configuration(conf_files[i], netif); if (rc != EOK) { + free(netif); + continue; + } + + rc = read_netif_configuration(dir_entry->d_name, netif); + if (rc != EOK) { + free(netif); + continue; + } + + /* Mandatory name */ + measured_string_t *name = measured_strings_find(&netif->configuration, + (uint8_t *) CONF_NAME, 0); + if (!name) { + printf("%s: Network interface name is missing\n", NAME); measured_strings_destroy(&netif->configuration, free); free(netif); - return rc; - } - - /* Mandatory name */ - measured_string_t *setting = - measured_strings_find(&netif->configuration, (uint8_t *) CONF_NAME, 0); - if (!setting) { - fprintf(stderr, "%s: Network interface name is missing\n", NAME); + continue; + } + + netif->name = name->value; + + /* Mandatory hardware path */ + measured_string_t *hwpath = measured_strings_find( + &netif->configuration, (const uint8_t *) CONF_HWPATH, 0); + if (!hwpath) { measured_strings_destroy(&netif->configuration, free); free(netif); - return EINVAL; - } - netif->name = setting->value; + } /* Add to the netifs map */ @@ -564,40 +585,20 @@ measured_strings_destroy(&netif->configuration, free); free(netif); - return index; + continue; } /* - * Add to the netif names map and start network interfaces + * Add to the hardware paths map and init network interfaces * and needed modules. */ - rc = char_map_add(&net_globals.netif_names, netif->name, 0, - index); + rc = char_map_add(&net_globals.netif_hwpaths, hwpath->value, 0, index); if (rc != EOK) { measured_strings_destroy(&netif->configuration, free); netifs_exclude_index(&net_globals.netifs, index, free); - return rc; - } - - rc = start_device(netif); - if (rc != EOK) { - printf("%s: Ignoring failed interface %s (%s)\n", NAME, - netif->name, str_error(rc)); - measured_strings_destroy(&netif->configuration, free); - netifs_exclude_index(&net_globals.netifs, index, free); continue; } - - /* Increment modules' usage */ - netif->driver->usage++; - if (netif->nil) - netif->nil->usage++; - netif->il->usage++; - - printf("%s: Network interface started (name: %s, id: %d, driver: %s, " - "nil: %s, il: %s)\n", NAME, netif->name, netif->id, - netif->driver->name, netif->nil ? (char *) netif->nil->name : "[none]", - netif->il->name); - } - + } + + closedir(config_dir); return EOK; } @@ -624,4 +625,5 @@ uint8_t *data; int rc; + size_t count; *answer_count = 0; @@ -636,12 +638,11 @@ if (rc != EOK) return rc; - net_get_device_conf_req_local(IPC_GET_DEVICE(*call), &strings, - IPC_GET_COUNT(*call), NULL); - - /* Strings should not contain received data anymore */ - free(data); + + net_get_device_conf(IPC_GET_DEVICE(*call), strings, + IPC_GET_COUNT(*call)); rc = measured_strings_reply(strings, IPC_GET_COUNT(*call)); free(strings); + free(data); return rc; case NET_NET_GET_CONF: @@ -650,17 +651,31 @@ if (rc != EOK) return rc; - net_get_conf_req_local(&strings, IPC_GET_COUNT(*call), NULL); - - /* Strings should not contain received data anymore */ - free(data); + + net_get_conf(NULL, strings, IPC_GET_COUNT(*call)); rc = measured_strings_reply(strings, IPC_GET_COUNT(*call)); free(strings); - return rc; - case NET_NET_STARTUP: - return startup(); - } - - return ENOTSUP; + free(data); + return rc; + case NET_NET_GET_DEVICES_COUNT: + count = (size_t) net_get_devices_count(); + IPC_SET_ARG1(*answer, count); + *answer_count = 1; + return EOK; + case NET_NET_GET_DEVICES: + rc = net_get_devices(&strings, &count); + if (rc != EOK) + return rc; + + rc = measured_strings_reply(strings, count); + net_free_devices(strings, count); + return rc; + case NET_NET_DRIVER_READY: + rc = net_driver_ready_local(IPC_GET_ARG1(*call)); + *answer_count = 0; + return rc; + default: + return ENOTSUP; + } } Index: uspace/srv/net/net/net.h =================================================================== --- uspace/srv/net/net/net.h (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/net/net/net.h (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -1,4 +1,5 @@ /* * Copyright (c) 2009 Lukas Mejdrech + * Copyright (c) 2011 Radim Vansa * All rights reserved. * @@ -45,11 +46,9 @@ #include #include +#include /** @name Modules definitions * @{ */ - -#define NE2000_FILENAME "/srv/ne2000" -#define NE2000_NAME "ne2000" #define ETHERNET_FILENAME "/srv/eth" @@ -58,7 +57,4 @@ #define IP_FILENAME "/srv/ip" #define IP_NAME "ip" - -#define LO_FILENAME "/srv/lo" -#define LO_NAME "lo" #define NILDUMMY_FILENAME "/srv/nildummy" @@ -77,5 +73,5 @@ #define CONF_MTU "MTU" /**< Maximum transmission unit configuration label. */ #define CONF_NAME "NAME" /**< Network interface name configuration label. */ -#define CONF_NETIF "NETIF" /**< Network interface module name configuration label. */ +#define CONF_HWPATH "HWPATH" /**< Network interface hardware pathname label. */ #define CONF_NIL "NIL" /**< Network interface layer module name configuration label. */ @@ -85,4 +81,5 @@ #define CONF_DIR "/cfg/net" /**< Configuration directory. */ #define CONF_GENERAL_FILE "general" /**< General configuration file. */ +#define CONF_EXT ".nic" /**< Extension for NIC's configuration files. */ /** Configuration settings. @@ -98,13 +95,14 @@ */ typedef struct { + uint8_t *name; /**< System-unique network interface name. */ + nic_device_id_t id; /**< System-unique network interface identifier. */ measured_strings_t configuration; /**< Configuration. */ /** Serving network interface driver module index. */ - module_t *driver; + devman_handle_t handle; /**< Handle for devman */ + async_sess_t *sess; /**< Driver session. */ - device_id_t id; /**< System-unique network interface identifier. */ + module_t *nil; /**< Serving link layer module index. */ module_t *il; /**< Serving internet layer module index. */ - uint8_t *name; /**< System-unique network interface name. */ - module_t *nil; /**< Serving link layer module index. */ } netif_t; @@ -124,6 +122,6 @@ modules_t modules; /**< Available modules. */ - /** Network interface structure indices by names. */ - char_map_t netif_names; + /** Network interface structure indices by hardware path. */ + char_map_t netif_hwpaths; /** Present network interfaces. */ Index: uspace/srv/net/net/net_standalone.c =================================================================== --- uspace/srv/net/net/net_standalone.c (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/net/net/net_standalone.c (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -35,6 +35,4 @@ */ -#include "net.h" - #include #include @@ -42,7 +40,7 @@ #include #include - #include -#include +#include "net.h" +#include "packet_server.h" /** Networking module global data. */ @@ -62,5 +60,5 @@ int rc; - task_id_t task_id = net_spawn((uint8_t *) "/srv/ip"); + task_id_t task_id = net_spawn((uint8_t *) IP_FILENAME); if (!task_id) return EINVAL; Index: uspace/srv/net/net/packet_server.c =================================================================== --- uspace/srv/net/net/packet_server.c (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) +++ uspace/srv/net/net/packet_server.c (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -0,0 +1,403 @@ +/* + * Copyright (c) 2009 Lukas Mejdrech + * Copyright (c) 2011 Radim Vansa + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * + * - Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * - Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * - The name of the author may not be used to endorse or promote products + * derived from this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR + * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES + * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. + * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, + * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT + * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY + * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF + * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +/** @addtogroup libpacket + * @{ + */ + +/** @file + * Packet server implementation. + */ + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +#include "packet_server.h" + +#define PACKET_SERVER_PROFILE 1 + +/** Number of queues cacheing the unused packets */ +#define FREE_QUEUES_COUNT 7 +/** Maximum number of packets in each queue */ +#define FREE_QUEUE_MAX_LENGTH 16 + +/** The default address length reserved for new packets. */ +#define DEFAULT_ADDR_LEN 32 + +/** The default prefix reserved for new packets. */ +#define DEFAULT_PREFIX 64 + +/** The default suffix reserved for new packets. */ +#define DEFAULT_SUFFIX 64 + +/** The queue with unused packets */ +typedef struct packet_queue { + packet_t *first; /**< First packet in the queue */ + size_t packet_size; /**< Maximal size of the packets in this queue */ + int count; /**< Length of the queue */ +} packet_queue_t; + +/** Packet server global data. */ +static struct { + /** Safety lock. */ + fibril_mutex_t lock; + /** Free packet queues. */ + packet_queue_t free_queues[FREE_QUEUES_COUNT]; + + /** Total packets allocated. */ + packet_id_t next_id; +} ps_globals = { + .lock = FIBRIL_MUTEX_INITIALIZER(ps_globals.lock), + .free_queues = { + { NULL, PAGE_SIZE, 0}, + { NULL, PAGE_SIZE * 2, 0}, + { NULL, PAGE_SIZE * 4, 0}, + { NULL, PAGE_SIZE * 8, 0}, + { NULL, PAGE_SIZE * 16, 0}, + { NULL, PAGE_SIZE * 32, 0}, + { NULL, PAGE_SIZE * 64, 0}, + }, + .next_id = 1 +}; + +/** Clears and initializes the packet according to the given dimensions. + * + * @param[in] packet The packet to be initialized. + * @param[in] addr_len The source and destination addresses maximal length in + * bytes. + * @param[in] max_prefix The maximal prefix length in bytes. + * @param[in] max_content The maximal content length in bytes. + * @param[in] max_suffix The maximal suffix length in bytes. + */ +static void packet_init(packet_t *packet, + size_t addr_len, size_t max_prefix, size_t max_content, size_t max_suffix) +{ + /* Clear the packet content */ + bzero(((void *) packet) + sizeof(packet_t), + packet->length - sizeof(packet_t)); + + /* Clear the packet header */ + packet->order = 0; + packet->metric = 0; + packet->previous = 0; + packet->next = 0; + packet->offload_info = 0; + packet->offload_mask = 0; + packet->addr_len = 0; + packet->src_addr = sizeof(packet_t); + packet->dest_addr = packet->src_addr + addr_len; + packet->max_prefix = max_prefix; + packet->max_content = max_content; + packet->data_start = packet->dest_addr + addr_len + packet->max_prefix; + packet->data_end = packet->data_start; +} + +/** + * Releases the memory allocated for the packet + * + * @param[in] packet Pointer to the memory where the packet was allocated + */ +static void packet_dealloc(packet_t *packet) +{ + pm_remove(packet); + munmap(packet, packet->length); +} + +/** Creates a new packet of dimensions at least as given. + * + * @param[in] length The total length of the packet, including the header, + * the addresses and the data of the packet. + * @param[in] addr_len The source and destination addresses maximal length in + * bytes. + * @param[in] max_prefix The maximal prefix length in bytes. + * @param[in] max_content The maximal content length in bytes. + * @param[in] max_suffix The maximal suffix length in bytes. + * @return The packet of dimensions at least as given. + * @return NULL if there is not enough memory left. + */ +static packet_t *packet_alloc(size_t length, size_t addr_len, + size_t max_prefix, size_t max_content, size_t max_suffix) +{ + packet_t *packet; + int rc; + + /* Global lock is locked */ + assert(fibril_mutex_is_locked(&ps_globals.lock)); + /* The length is some multiple of PAGE_SIZE */ + assert(!(length & (PAGE_SIZE - 1))); + + packet = (packet_t *) mmap(NULL, length, PROTO_READ | PROTO_WRITE, + MAP_SHARED | MAP_ANONYMOUS, 0, 0); + if (packet == MAP_FAILED) + return NULL; + + /* Using 32bit packet_id the id could overflow */ + packet_id_t pid; + do { + pid = ps_globals.next_id; + ps_globals.next_id++; + } while (!pid || pm_find(pid)); + packet->packet_id = pid; + + packet->length = length; + packet_init(packet, addr_len, max_prefix, max_content, max_suffix); + packet->magic_value = PACKET_MAGIC_VALUE; + rc = pm_add(packet); + if (rc != EOK) { + packet_dealloc(packet); + return NULL; + } + + return packet; +} + +/** Return the packet of dimensions at least as given. + * + * Try to reuse free packets first. + * Create a new packet aligned to the memory page size if none available. + * Lock the global data during its processing. + * + * @param[in] addr_len The source and destination addresses maximal length in + * bytes. + * @param[in] max_prefix The maximal prefix length in bytes. + * @param[in] max_content The maximal content length in bytes. + * @param[in] max_suffix The maximal suffix length in bytes. + * @return The packet of dimensions at least as given. + * @return NULL if there is not enough memory left. + */ +static packet_t *packet_get_local(size_t addr_len, + size_t max_prefix, size_t max_content, size_t max_suffix) +{ + size_t length = ALIGN_UP(sizeof(packet_t) + 2 * addr_len + + max_prefix + max_content + max_suffix, PAGE_SIZE); + + if (length > PACKET_MAX_LENGTH) + return NULL; + + fibril_mutex_lock(&ps_globals.lock); + + packet_t *packet; + unsigned int index; + + for (index = 0; index < FREE_QUEUES_COUNT; index++) { + if ((length > ps_globals.free_queues[index].packet_size) && + (index < FREE_QUEUES_COUNT - 1)) + continue; + + packet = ps_globals.free_queues[index].first; + while (packet_is_valid(packet) && (packet->length < length)) + packet = pm_find(packet->next); + + if (packet_is_valid(packet)) { + ps_globals.free_queues[index].count--; + if (packet == ps_globals.free_queues[index].first) { + ps_globals.free_queues[index].first = pq_detach(packet); + } else { + pq_detach(packet); + } + + packet_init(packet, addr_len, max_prefix, max_content, max_suffix); + fibril_mutex_unlock(&ps_globals.lock); + + return packet; + } + } + + packet = packet_alloc(length, addr_len, + max_prefix, max_content, max_suffix); + + fibril_mutex_unlock(&ps_globals.lock); + + return packet; +} + +/** Release the packet and returns it to the appropriate free packet queue. + * + * @param[in] packet The packet to be released. + * + */ +static void packet_release(packet_t *packet) +{ + int index; + int result; + + assert(fibril_mutex_is_locked(&ps_globals.lock)); + + for (index = 0; (index < FREE_QUEUES_COUNT - 1) && + (packet->length > ps_globals.free_queues[index].packet_size); index++) { + ; + } + + ps_globals.free_queues[index].count++; + result = pq_add(&ps_globals.free_queues[index].first, packet, + packet->length, packet->length); + assert(result == EOK); +} + +/** Releases the packet queue. + * + * @param[in] packet_id The first packet identifier. + * @return EOK on success. + * @return ENOENT if there is no such packet. + */ +static int packet_release_wrapper(packet_id_t packet_id) +{ + packet_t *packet; + + packet = pm_find(packet_id); + if (!packet_is_valid(packet)) + return ENOENT; + + fibril_mutex_lock(&ps_globals.lock); + pq_destroy(packet, packet_release); + fibril_mutex_unlock(&ps_globals.lock); + + return EOK; +} + +/** Shares the packet memory block. + * @param[in] packet The packet to be shared. + * @return EOK on success. + * @return EINVAL if the packet is not valid. + * @return EINVAL if the calling module does not accept the memory. + * @return ENOMEM if the desired and actual sizes differ. + * @return Other error codes as defined for the + * async_share_in_finalize() function. + */ +static int packet_reply(packet_t *packet) +{ + ipc_callid_t callid; + size_t size; + + if (!packet_is_valid(packet)) + return EINVAL; + + if (!async_share_in_receive(&callid, &size)) { + async_answer_0(callid, EINVAL); + return EINVAL; + } + + if (size != packet->length) { + async_answer_0(callid, ENOMEM); + return ENOMEM; + } + + return async_share_in_finalize(callid, packet, + PROTO_READ | PROTO_WRITE); +} + +/** Processes the packet server message. + * + * @param[in] callid The message identifier. + * @param[in] call The message parameters. + * @param[out] answer The message answer parameters. + * @param[out] answer_count The last parameter for the actual answer in the + * answer parameter. + * @return EOK on success. + * @return ENOMEM if there is not enough memory left. + * @return ENOENT if there is no such packet as in the packet + * message parameter. + * @return ENOTSUP if the message is not known. + * @return Other error codes as defined for the + * packet_release_wrapper() function. + */ +int packet_server_message(ipc_callid_t callid, ipc_call_t *call, ipc_call_t *answer, + size_t *answer_count) +{ + packet_t *packet; + + if (!IPC_GET_IMETHOD(*call)) + return EOK; + + *answer_count = 0; + switch (IPC_GET_IMETHOD(*call)) { + case NET_PACKET_CREATE_1: + packet = packet_get_local(DEFAULT_ADDR_LEN, DEFAULT_PREFIX, + IPC_GET_CONTENT(*call), DEFAULT_SUFFIX); + if (!packet) + return ENOMEM; + *answer_count = 2; + IPC_SET_ARG1(*answer, (sysarg_t) packet->packet_id); + IPC_SET_ARG2(*answer, (sysarg_t) packet->length); + return EOK; + + case NET_PACKET_CREATE_4: + packet = packet_get_local( + ((DEFAULT_ADDR_LEN < IPC_GET_ADDR_LEN(*call)) ? + IPC_GET_ADDR_LEN(*call) : DEFAULT_ADDR_LEN), + DEFAULT_PREFIX + IPC_GET_PREFIX(*call), + IPC_GET_CONTENT(*call), + DEFAULT_SUFFIX + IPC_GET_SUFFIX(*call)); + if (!packet) + return ENOMEM; + *answer_count = 2; + IPC_SET_ARG1(*answer, (sysarg_t) packet->packet_id); + IPC_SET_ARG2(*answer, (sysarg_t) packet->length); + return EOK; + + case NET_PACKET_GET: + packet = pm_find(IPC_GET_ID(*call)); + if (!packet_is_valid(packet)) { + return ENOENT; + } + return packet_reply(packet); + + case NET_PACKET_GET_SIZE: + packet = pm_find(IPC_GET_ID(*call)); + if (!packet_is_valid(packet)) + return ENOENT; + IPC_SET_ARG1(*answer, (sysarg_t) packet->length); + *answer_count = 1; + return EOK; + + case NET_PACKET_RELEASE: + return packet_release_wrapper(IPC_GET_ID(*call)); + } + + return ENOTSUP; +} + +int packet_server_init() +{ + return EOK; +} + +/** @} + */ Index: uspace/srv/net/net/packet_server.h =================================================================== --- uspace/srv/net/net/packet_server.h (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) +++ uspace/srv/net/net/packet_server.h (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -0,0 +1,57 @@ +/* + * Copyright (c) 2009 Lukas Mejdrech + * Copyright (c) 2011 Radim Vansa + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * + * - Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * - Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * - The name of the author may not be used to endorse or promote products + * derived from this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR + * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES + * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. + * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, + * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT + * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY + * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF + * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +/** @addtogroup libpacket + * @{ + */ + +/** @file + * Packet server. + * The hosting module has to be compiled with both the packet.c and the + * packet_server.c source files. To function correctly, initialization of the + * packet map by the pm_init() function has to happen at the first place. Then + * the packet messages have to be processed by the packet_server_message() + * function. The packet map should be released by the pm_destroy() function + * during the module termination. + * @see IS_NET_PACKET_MESSAGE() + */ + +#ifndef LIBPACKET_PACKET_SERVER_H_ +#define LIBPACKET_PACKET_SERVER_H_ + +#include + +extern int packet_server_init(void); +extern int packet_server_message(ipc_callid_t, ipc_call_t *, ipc_call_t *, + size_t *); + +#endif + +/** @} + */ Index: uspace/srv/net/netif/lo/Makefile =================================================================== --- uspace/srv/net/netif/lo/Makefile (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ (revision ) @@ -1,46 +1,0 @@ -# -# Copyright (c) 2005 Martin Decky -# Copyright (c) 2007 Jakub Jermar -# All rights reserved. -# -# Redistribution and use in source and binary forms, with or without -# modification, are permitted provided that the following conditions -# are met: -# -# - Redistributions of source code must retain the above copyright -# notice, this list of conditions and the following disclaimer. -# - Redistributions in binary form must reproduce the above copyright -# notice, this list of conditions and the following disclaimer in the -# documentation and/or other materials provided with the distribution. -# - The name of the author may not be used to endorse or promote products -# derived from this software without specific prior written permission. -# -# THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR -# IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES -# OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. -# IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, -# INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT -# NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, -# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY -# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT -# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF -# THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. -# - -USPACE_PREFIX = ../../../.. -ROOT_PATH = $(USPACE_PREFIX)/.. -LIBS = $(LIBNET_PREFIX)/libnet.a -EXTRA_CFLAGS = -I$(LIBNET_PREFIX)/include - -COMMON_MAKEFILE = $(ROOT_PATH)/Makefile.common -CONFIG_MAKEFILE = $(ROOT_PATH)/Makefile.config - --include $(COMMON_MAKEFILE) --include $(CONFIG_MAKEFILE) - -BINARY = lo - -SOURCES = \ - lo.c - -include $(USPACE_PREFIX)/Makefile.common Index: uspace/srv/net/netif/lo/lo.c =================================================================== --- uspace/srv/net/netif/lo/lo.c (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ (revision ) @@ -1,231 +1,0 @@ -/* - * Copyright (c) 2009 Lukas Mejdrech - * All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions - * are met: - * - * - Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * - Redistributions in binary form must reproduce the above copyright - * notice, this list of conditions and the following disclaimer in the - * documentation and/or other materials provided with the distribution. - * - The name of the author may not be used to endorse or promote products - * derived from this software without specific prior written permission. - * - * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR - * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES - * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. - * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, - * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT - * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, - * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY - * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT - * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF - * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - */ - -/** @addtogroup lo - * @{ - */ - -/** @file - * Loopback network interface implementation. - */ - -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include - -/** Default address length. */ -#define DEFAULT_ADDR_LEN 6 - -/** Loopback module name. */ -#define NAME "lo" - -static uint8_t default_addr[DEFAULT_ADDR_LEN] = - {0, 0, 0, 0, 0, 0}; - -int netif_specific_message(ipc_callid_t callid, ipc_call_t *call, - ipc_call_t *answer, size_t *count) -{ - return ENOTSUP; -} - -int netif_get_addr_message(device_id_t device_id, measured_string_t *address) -{ - if (!address) - return EBADMEM; - - address->value = default_addr; - address->length = DEFAULT_ADDR_LEN; - - return EOK; -} - -int netif_get_device_stats(device_id_t device_id, device_stats_t *stats) -{ - if (!stats) - return EBADMEM; - - netif_device_t *device; - int rc = find_device(device_id, &device); - if (rc != EOK) - return rc; - - memcpy(stats, (device_stats_t *) device->specific, - sizeof(device_stats_t)); - - return EOK; -} - -/** Change the loopback state. - * - * @param[in] device The device structure. - * @param[in] state The new device state. - * - * @return New state if changed. - * @return EOK otherwise. - * - */ -static void change_state_message(netif_device_t *device, device_state_t state) -{ - if (device->state != state) { - device->state = state; - - const char *desc; - switch (state) { - case NETIF_ACTIVE: - desc = "active"; - break; - case NETIF_STOPPED: - desc = "stopped"; - break; - default: - desc = "unknown"; - } - - printf("%s: State changed to %s\n", NAME, desc); - } -} - -/** Create and return the loopback network interface structure. - * - * @param[in] device_id New devce identifier. - * @param[out] device Device structure. - * - * @return EOK on success. - * @return EXDEV if one loopback network interface already exists. - * @return ENOMEM if there is not enough memory left. - * - */ -static int lo_create(device_id_t device_id, netif_device_t **device) -{ - if (netif_device_map_count(&netif_globals.device_map) > 0) - return EXDEV; - - *device = (netif_device_t *) malloc(sizeof(netif_device_t)); - if (!*device) - return ENOMEM; - - (*device)->specific = (device_stats_t *) malloc(sizeof(device_stats_t)); - if (!(*device)->specific) { - free(*device); - return ENOMEM; - } - - null_device_stats((device_stats_t *) (*device)->specific); - (*device)->device_id = device_id; - (*device)->state = NETIF_STOPPED; - int index = netif_device_map_add(&netif_globals.device_map, - (*device)->device_id, *device); - - if (index < 0) { - free(*device); - free((*device)->specific); - *device = NULL; - return index; - } - - return EOK; -} - -int netif_initialize(void) -{ - return service_register(SERVICE_LO); -} - -int netif_probe_message(device_id_t device_id, int irq, void *io) -{ - /* Create a new device */ - netif_device_t *device; - int rc = lo_create(device_id, &device); - if (rc != EOK) - return rc; - - printf("%s: Device created (id: %d)\n", NAME, device->device_id); - return EOK; -} - -int netif_send_message(device_id_t device_id, packet_t *packet, services_t sender) -{ - netif_device_t *device; - int rc = find_device(device_id, &device); - if (rc != EOK) - return EOK; - - if (device->state != NETIF_ACTIVE) { - netif_pq_release(packet_get_id(packet)); - return EFORWARD; - } - - packet_t *next = packet; - do { - ((device_stats_t *) device->specific)->send_packets++; - ((device_stats_t *) device->specific)->receive_packets++; - size_t length = packet_get_data_length(next); - ((device_stats_t *) device->specific)->send_bytes += length; - ((device_stats_t *) device->specific)->receive_bytes += length; - next = pq_next(next); - } while (next); - - async_sess_t *nil_sess = netif_globals.nil_sess; - fibril_rwlock_write_unlock(&netif_globals.lock); - - nil_received_msg(nil_sess, device_id, packet, sender); - - fibril_rwlock_write_lock(&netif_globals.lock); - return EOK; -} - -int netif_start_message(netif_device_t *device) -{ - change_state_message(device, NETIF_ACTIVE); - return device->state; -} - -int netif_stop_message(netif_device_t *device) -{ - change_state_message(device, NETIF_STOPPED); - return device->state; -} - -int main(int argc, char *argv[]) -{ - /* Start the module */ - return netif_module_start(); -} - -/** @} - */ Index: uspace/srv/net/nil/eth/eth.c =================================================================== --- uspace/srv/net/nil/eth/eth.c (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/net/nil/eth/eth.c (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -1,4 +1,5 @@ /* * Copyright (c) 2009 Lukas Mejdrech + * Copyright (c) 2011 Radim Vansa * All rights reserved. * @@ -36,4 +37,5 @@ */ +#include #include #include @@ -52,5 +54,4 @@ #include #include -#include #include #include @@ -58,4 +59,5 @@ #include #include +#include #include #include "eth.h" @@ -167,5 +169,5 @@ INT_MAP_IMPLEMENT(eth_protos, eth_proto_t); -int nil_device_state_msg_local(device_id_t device_id, sysarg_t state) +int nil_device_state_msg_local(nic_device_id_t device_id, sysarg_t state) { int index; @@ -196,11 +198,6 @@ fibril_rwlock_write_lock(ð_globals.protos_lock); eth_globals.net_sess = sess; - - eth_globals.broadcast_addr = - measured_string_create_bulk((uint8_t *) "\xFF\xFF\xFF\xFF\xFF\xFF", ETH_ADDR); - if (!eth_globals.broadcast_addr) { - rc = ENOMEM; - goto out; - } + memcpy(eth_globals.broadcast_addr, "\xFF\xFF\xFF\xFF\xFF\xFF", + ETH_ADDR); rc = eth_devices_initialize(ð_globals.devices); @@ -215,4 +212,5 @@ eth_devices_destroy(ð_globals.devices, free); } + out: fibril_rwlock_write_unlock(ð_globals.protos_lock); @@ -222,59 +220,18 @@ } -/** Process IPC messages from the registered device driver modules in an - * infinite loop. - * - * @param[in] iid Message identifier. - * @param[in,out] icall Message parameters. - * @param[in] arg Local argument. - * - */ -static void eth_receiver(ipc_callid_t iid, ipc_call_t *icall, void *arg) -{ - packet_t *packet; - int rc; - - while (true) { - switch (IPC_GET_IMETHOD(*icall)) { - case NET_NIL_DEVICE_STATE: - nil_device_state_msg_local(IPC_GET_DEVICE(*icall), - IPC_GET_STATE(*icall)); - async_answer_0(iid, EOK); - break; - case NET_NIL_RECEIVED: - rc = packet_translate_remote(eth_globals.net_sess, - &packet, IPC_GET_PACKET(*icall)); - if (rc == EOK) - rc = nil_received_msg_local(IPC_GET_DEVICE(*icall), - packet, 0); - - async_answer_0(iid, (sysarg_t) rc); - break; - default: - async_answer_0(iid, (sysarg_t) ENOTSUP); - } - - iid = async_get_call(icall); - } -} - -/** Registers new device or updates the MTU of an existing one. - * - * Determines the device local hardware address. - * - * @param[in] device_id The new device identifier. - * @param[in] service The device driver service. - * @param[in] mtu The device maximum transmission unit. - * @return EOK on success. - * @return EEXIST if the device with the different service exists. - * @return ENOMEM if there is not enough memory left. - * @return Other error codes as defined for the - * net_get_device_conf_req() function. - * @return Other error codes as defined for the - * netif_bind_service() function. - * @return Other error codes as defined for the - * netif_get_addr_req() function. - */ -static int eth_device_message(device_id_t device_id, services_t service, +/** Register new device or updates the MTU of an existing one. + * + * Determine the device local hardware address. + * + * @param[in] device_id New device identifier. + * @param[in] handle Device driver handle. + * @param[in] mtu Device maximum transmission unit. + * + * @return EOK on success. + * @return EEXIST if the device with the different service exists. + * @return ENOMEM if there is not enough memory left. + * + */ +static int eth_device_message(nic_device_id_t device_id, devman_handle_t handle, size_t mtu) { @@ -301,5 +258,5 @@ device = eth_devices_find(ð_globals.devices, device_id); if (device) { - if (device->service != service) { + if (device->handle != handle) { printf("Device %d already exists\n", device->device_id); fibril_rwlock_write_unlock(ð_globals.devices_lock); @@ -340,5 +297,5 @@ device->device_id = device_id; - device->service = service; + device->handle = handle; device->flags = 0; if ((mtu > 0) && (mtu <= ETH_MAX_TAGGED_CONTENT(device->flags))) @@ -377,6 +334,6 @@ /* Bind the device driver */ - device->sess = netif_bind_service(device->service, device->device_id, - SERVICE_ETHERNET, eth_receiver); + device->sess = devman_device_connect(EXCHANGE_SERIALIZE, handle, + IPC_FLAG_BLOCKING); if (device->sess == NULL) { fibril_rwlock_write_unlock(ð_globals.devices_lock); @@ -385,7 +342,8 @@ } + nic_connect_to_nil(device->sess, SERVICE_ETHERNET, device_id); + /* Get hardware address */ - rc = netif_get_addr_req(device->sess, device->device_id, &device->addr, - &device->addr_data); + rc = nic_get_address(device->sess, &device->addr); if (rc != EOK) { fibril_rwlock_write_unlock(ð_globals.devices_lock); @@ -399,16 +357,12 @@ if (index < 0) { fibril_rwlock_write_unlock(ð_globals.devices_lock); - free(device->addr); - free(device->addr_data); free(device); return index; } - printf("%s: Device registered (id: %d, service: %d: mtu: %zu, " - "mac: %02x:%02x:%02x:%02x:%02x:%02x, flags: 0x%x)\n", - NAME, device->device_id, device->service, device->mtu, - device->addr_data[0], device->addr_data[1], - device->addr_data[2], device->addr_data[3], - device->addr_data[4], device->addr_data[5], device->flags); + printf("%s: Device registered (id: %d, handle: %zu: mtu: %zu, " + "mac: " PRIMAC ", flags: 0x%x)\n", NAME, + device->device_id, device->handle, device->mtu, + ARGSMAC(device->addr.address), device->flags); fibril_rwlock_write_unlock(ð_globals.devices_lock); @@ -456,5 +410,5 @@ fcs = (eth_fcs_t *) data + length - sizeof(eth_fcs_t); length -= sizeof(eth_fcs_t); - } else if(type <= ETH_MAX_CONTENT) { + } else if (type <= ETH_MAX_CONTENT) { /* Translate "LSAP" values */ if ((header->lsap.dsap == ETH_LSAP_GLSAP) && @@ -462,5 +416,5 @@ /* Raw packet -- discard */ return NULL; - } else if((header->lsap.dsap == ETH_LSAP_SNAP) && + } else if ((header->lsap.dsap == ETH_LSAP_SNAP) && (header->lsap.ssap == ETH_LSAP_SNAP)) { /* @@ -469,12 +423,10 @@ */ type = ntohs(header->snap.ethertype); - prefix = sizeof(eth_header_t) + - sizeof(eth_header_lsap_t) + + prefix = sizeof(eth_header_t) + sizeof(eth_header_lsap_t) + sizeof(eth_header_snap_t); } else { /* IEEE 802.3 + 802.2 LSAP */ type = lsap_map(header->lsap.dsap); - prefix = sizeof(eth_header_t) + - sizeof(eth_header_lsap_t); + prefix = sizeof(eth_header_t) + sizeof(eth_header_lsap_t); } @@ -506,6 +458,5 @@ } -int nil_received_msg_local(device_id_t device_id, packet_t *packet, - services_t target) +int nil_received_msg_local(nic_device_id_t device_id, packet_t *packet) { eth_proto_t *proto; @@ -523,6 +474,6 @@ flags = device->flags; fibril_rwlock_read_unlock(ð_globals.devices_lock); - fibril_rwlock_read_lock(ð_globals.protos_lock); + do { next = pq_detach(packet); @@ -537,5 +488,5 @@ } packet = next; - } while(packet); + } while (packet); fibril_rwlock_read_unlock(ð_globals.protos_lock); @@ -554,5 +505,5 @@ * @return ENOENT if there is no such device. */ -static int eth_packet_space_message(device_id_t device_id, size_t *addr_len, +static int eth_packet_space_message(nic_device_id_t device_id, size_t *addr_len, size_t *prefix, size_t *content, size_t *suffix) { @@ -579,24 +530,22 @@ } -/** Returns the device hardware address. +/** Send the device hardware address. * * @param[in] device_id The device identifier. * @param[in] type Type of the desired address. - * @param[out] address The device hardware address. * @return EOK on success. * @return EBADMEM if the address parameter is NULL. * @return ENOENT if there no such device. */ -static int eth_addr_message(device_id_t device_id, eth_addr_type_t type, - measured_string_t **address) -{ - eth_device_t *device; - - if (!address) - return EBADMEM; - - if (type == ETH_BROADCAST_ADDR) { - *address = eth_globals.broadcast_addr; - } else { +static int eth_addr_message(nic_device_id_t device_id, eth_addr_type_t type) +{ + eth_device_t *device = NULL; + uint8_t *address; + size_t max_len; + ipc_callid_t callid; + + if (type == ETH_BROADCAST_ADDR) + address = eth_globals.broadcast_addr; + else { fibril_rwlock_read_lock(ð_globals.devices_lock); device = eth_devices_find(ð_globals.devices, device_id); @@ -605,9 +554,30 @@ return ENOENT; } - *address = device->addr; + + address = (uint8_t *) &device->addr.address; + } + + int rc = EOK; + if (!async_data_read_receive(&callid, &max_len)) { + rc = EREFUSED; + goto end; + } + + if (max_len < ETH_ADDR) { + async_data_read_finalize(callid, NULL, 0); + rc = ELIMIT; + goto end; + } + + rc = async_data_read_finalize(callid, address, ETH_ADDR); + if (rc != EOK) + goto end; + +end: + + if (type == ETH_LOCAL_ADDR) fibril_rwlock_read_unlock(ð_globals.devices_lock); - } - - return (*address) ? EOK : ENOENT; + + return rc; } @@ -697,6 +667,14 @@ if (i < 0) return i; + if (i != ETH_ADDR) return EINVAL; + + for (i = 0; i < ETH_ADDR; i++) { + if (src[i]) { + src_addr = src; + break; + } + } length = packet_get_data_length(packet); @@ -722,5 +700,5 @@ memcpy(header_dix->destination_address, dest, ETH_ADDR); src = &header_dix->destination_address[0]; - } else if(IS_8023_2_LSAP(flags)) { + } else if (IS_8023_2_LSAP(flags)) { header_lsap = PACKET_PREFIX(packet, eth_header_lsap_t); if (!header_lsap) @@ -735,5 +713,5 @@ memcpy(header_lsap->header.destination_address, dest, ETH_ADDR); src = &header_lsap->header.destination_address[0]; - } else if(IS_8023_2_SNAP(flags)) { + } else if (IS_8023_2_SNAP(flags)) { header = PACKET_PREFIX(packet, eth_header_snap_t); if (!header) @@ -746,5 +724,5 @@ header->lsap.ctrl = IEEE_8023_2_UI; - for (i = 0; i < 3; ++ i) + for (i = 0; i < 3; i++) header->snap.protocol[i] = 0; @@ -760,5 +738,5 @@ return ENOMEM; - for (i = 0; i < 7; ++ i) + for (i = 0; i < 7; i++) preamble->preamble[i] = ETH_PREAMBLE; @@ -787,5 +765,5 @@ * @return EINVAL if the service parameter is not known. */ -static int eth_send_message(device_id_t device_id, packet_t *packet, +static int eth_send_message(nic_device_id_t device_id, packet_t *packet, services_t sender) { @@ -813,5 +791,5 @@ do { rc = eth_prepare_packet(device->flags, next, - (uint8_t *) device->addr->value, ethertype, device->mtu); + (uint8_t *) &device->addr.address, ethertype, device->mtu); if (rc != EOK) { /* Release invalid packet */ @@ -825,20 +803,61 @@ next = pq_next(next); } - } while(next); + } while (next); /* Send packet queue */ - if (packet) { - netif_send_msg(device->sess, device_id, packet, - SERVICE_ETHERNET); - } - + if (packet) + nic_send_message(device->sess, packet_get_id(packet)); + fibril_rwlock_read_unlock(ð_globals.devices_lock); return EOK; } +static int eth_addr_changed(nic_device_id_t device_id) +{ + nic_address_t address; + size_t length; + ipc_callid_t data_callid; + if (!async_data_write_receive(&data_callid, &length)) { + async_answer_0(data_callid, EINVAL); + return EINVAL; + } + if (length > sizeof (nic_address_t)) { + async_answer_0(data_callid, ELIMIT); + return ELIMIT; + } + if (async_data_write_finalize(data_callid, &address, length) != EOK) { + return EINVAL; + } + + fibril_rwlock_write_lock(ð_globals.devices_lock); + /* An existing device? */ + eth_device_t *device = eth_devices_find(ð_globals.devices, device_id); + if (device) { + printf("Device %d changing address from " PRIMAC " to " PRIMAC "\n", + device_id, ARGSMAC(device->addr.address), ARGSMAC(address.address)); + memcpy(&device->addr, &address, sizeof (nic_address_t)); + fibril_rwlock_write_unlock(ð_globals.devices_lock); + + /* Notify all upper layer modules */ + fibril_rwlock_read_lock(ð_globals.protos_lock); + int index; + for (index = 0; index < eth_protos_count(ð_globals.protos); index++) { + eth_proto_t *proto = eth_protos_get_index(ð_globals.protos, index); + if (proto->sess != NULL) { + il_addr_changed_msg(proto->sess, device->device_id, + ETH_ADDR, address.address); + } + } + + fibril_rwlock_read_unlock(ð_globals.protos_lock); + return EOK; + } else { + return ENOENT; + } +} + int nil_module_message(ipc_callid_t callid, ipc_call_t *call, ipc_call_t *answer, size_t *answer_count) { - measured_string_t *address; packet_t *packet; size_t addrlen; @@ -861,5 +880,5 @@ case NET_NIL_DEVICE: return eth_device_message(IPC_GET_DEVICE(*call), - IPC_GET_SERVICE(*call), IPC_GET_MTU(*call)); + IPC_GET_DEVICE_HANDLE(*call), IPC_GET_MTU(*call)); case NET_NIL_SEND: rc = packet_translate_remote(eth_globals.net_sess, &packet, @@ -867,4 +886,5 @@ if (rc != EOK) return rc; + return eth_send_message(IPC_GET_DEVICE(*call), packet, IPC_GET_SERVICE(*call)); @@ -874,4 +894,5 @@ if (rc != EOK) return rc; + IPC_SET_ADDR(*answer, addrlen); IPC_SET_PREFIX(*answer, prefix); @@ -879,17 +900,40 @@ IPC_SET_SUFFIX(*answer, suffix); *answer_count = 4; + return EOK; case NET_NIL_ADDR: - rc = eth_addr_message(IPC_GET_DEVICE(*call), ETH_LOCAL_ADDR, - &address); + rc = eth_addr_message(IPC_GET_DEVICE(*call), ETH_LOCAL_ADDR); if (rc != EOK) return rc; - return measured_strings_reply(address, 1); + + IPC_SET_ADDR(*answer, ETH_ADDR); + *answer_count = 1; + + return EOK; case NET_NIL_BROADCAST_ADDR: - rc = eth_addr_message(IPC_GET_DEVICE(*call), ETH_BROADCAST_ADDR, - &address); + rc = eth_addr_message(IPC_GET_DEVICE(*call), ETH_BROADCAST_ADDR); if (rc != EOK) - return EOK; - return measured_strings_reply(address, 1); + return rc; + + IPC_SET_ADDR(*answer, ETH_ADDR); + *answer_count = 1; + + return EOK; + case NET_NIL_DEVICE_STATE: + nil_device_state_msg_local(IPC_GET_DEVICE(*call), IPC_GET_STATE(*call)); + async_answer_0(callid, EOK); + return EOK; + case NET_NIL_RECEIVED: + rc = packet_translate_remote(eth_globals.net_sess, &packet, + IPC_GET_ARG2(*call)); + if (rc == EOK) + rc = nil_received_msg_local(IPC_GET_ARG1(*call), packet); + + async_answer_0(callid, (sysarg_t) rc); + return rc; + case NET_NIL_ADDR_CHANGED: + rc = eth_addr_changed(IPC_GET_DEVICE(*call)); + async_answer_0(callid, (sysarg_t) rc); + return rc; } Index: uspace/srv/net/nil/eth/eth.h =================================================================== --- uspace/srv/net/nil/eth/eth.h (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/net/nil/eth/eth.h (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -1,4 +1,5 @@ /* * Copyright (c) 2009 Lukas Mejdrech + * Copyright (c) 2011 Radim Vansa * All rights reserved. * @@ -43,4 +44,5 @@ #include #include +#include /** Ethernet address length. */ @@ -220,7 +222,7 @@ struct eth_device { /** Device identifier. */ - device_id_t device_id; - /** Device driver service. */ - services_t service; + nic_device_id_t device_id; + /** Device handle */ + devman_handle_t handle; /** Driver session. */ async_sess_t *sess; @@ -236,8 +238,5 @@ /** Actual device hardware address. */ - measured_string_t *addr; - - /** Actual device hardware address data. */ - uint8_t *addr_data; + nic_address_t addr; }; @@ -270,5 +269,5 @@ /** Broadcast device hardware address. */ - measured_string_t *broadcast_addr; + uint8_t broadcast_addr[ETH_ADDR]; }; Index: uspace/srv/net/nil/nildummy/nildummy.c =================================================================== --- uspace/srv/net/nil/nildummy/nildummy.c (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/net/nil/nildummy/nildummy.c (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -1,4 +1,5 @@ /* * Copyright (c) 2009 Lukas Mejdrech + * Copyright (c) 2011 Radim Vansa * All rights reserved. * @@ -36,4 +37,5 @@ */ +#include #include #include @@ -50,5 +52,7 @@ #include #include -#include +#include +#include +#include #include #include "nildummy.h" @@ -65,5 +69,5 @@ DEVICE_MAP_IMPLEMENT(nildummy_devices, nildummy_device_t); -int nil_device_state_msg_local(device_id_t device_id, sysarg_t state) +int nil_device_state_msg_local(nic_device_id_t device_id, sysarg_t state) { fibril_rwlock_read_lock(&nildummy_globals.protos_lock); @@ -91,42 +95,4 @@ return rc; -} - -/** Process IPC messages from the registered device driver modules - * - * @param[in] iid Message identifier. - * @param[in,out] icall Message parameters. - * @param[in] arg Local argument. - * - */ -static void nildummy_receiver(ipc_callid_t iid, ipc_call_t *icall, void *arg) -{ - packet_t *packet; - int rc; - - while (true) { - switch (IPC_GET_IMETHOD(*icall)) { - case NET_NIL_DEVICE_STATE: - rc = nil_device_state_msg_local(IPC_GET_DEVICE(*icall), - IPC_GET_STATE(*icall)); - async_answer_0(iid, (sysarg_t) rc); - break; - - case NET_NIL_RECEIVED: - rc = packet_translate_remote(nildummy_globals.net_sess, - &packet, IPC_GET_PACKET(*icall)); - if (rc == EOK) - rc = nil_received_msg_local(IPC_GET_DEVICE(*icall), - packet, 0); - - async_answer_0(iid, (sysarg_t) rc); - break; - - default: - async_answer_0(iid, (sysarg_t) ENOTSUP); - } - - iid = async_get_call(icall); - } } @@ -148,6 +114,6 @@ * */ -static int nildummy_device_message(device_id_t device_id, services_t service, - size_t mtu) +static int nildummy_device_message(nic_device_id_t device_id, + devman_handle_t handle, size_t mtu) { fibril_rwlock_write_lock(&nildummy_globals.devices_lock); @@ -157,8 +123,8 @@ nildummy_devices_find(&nildummy_globals.devices, device_id); if (device) { - if (device->service != service) { - printf("Device %d already exists\n", device->device_id); - fibril_rwlock_write_unlock( - &nildummy_globals.devices_lock); + if (device->handle != handle) { + printf("Device %d exists, handles do not match\n", + device->device_id); + fibril_rwlock_write_unlock(&nildummy_globals.devices_lock); return EEXIST; } @@ -170,6 +136,6 @@ device->mtu = NET_DEFAULT_MTU; - printf("Device %d already exists:\tMTU\t= %zu\n", - device->device_id, device->mtu); + printf("Device %d already exists:\tMTU\t= %zu\n", device->device_id, + device->mtu); fibril_rwlock_write_unlock(&nildummy_globals.devices_lock); @@ -192,13 +158,13 @@ device->device_id = device_id; - device->service = service; + device->handle = handle; if (mtu > 0) device->mtu = mtu; else device->mtu = NET_DEFAULT_MTU; - + /* Bind the device driver */ - device->sess = netif_bind_service(device->service, device->device_id, - SERVICE_ETHERNET, nildummy_receiver); + device->sess = devman_device_connect(EXCHANGE_SERIALIZE, handle, + IPC_FLAG_BLOCKING); if (device->sess == NULL) { fibril_rwlock_write_unlock(&nildummy_globals.devices_lock); @@ -207,7 +173,8 @@ } + nic_connect_to_nil(device->sess, SERVICE_NILDUMMY, device_id); + /* Get hardware address */ - int rc = netif_get_addr_req(device->sess, device->device_id, - &device->addr, &device->addr_data); + int rc = nic_get_address(device->sess, &device->addr); if (rc != EOK) { fibril_rwlock_write_unlock(&nildummy_globals.devices_lock); @@ -215,4 +182,6 @@ return rc; } + + device->addr_len = ETH_ADDR; /* Add to the cache */ @@ -221,12 +190,10 @@ if (index < 0) { fibril_rwlock_write_unlock(&nildummy_globals.devices_lock); - free(device->addr); - free(device->addr_data); free(device); return index; } - printf("%s: Device registered (id: %d, service: %d, mtu: %zu)\n", - NAME, device->device_id, device->service, device->mtu); + printf("%s: Device registered (id: %d, mtu: %zu)\n", NAME, + device->device_id, device->mtu); fibril_rwlock_write_unlock(&nildummy_globals.devices_lock); return EOK; @@ -243,8 +210,7 @@ * */ -static int nildummy_addr_message(device_id_t device_id, - measured_string_t **address) -{ - if (!address) +static int nildummy_addr_message(nic_device_id_t device_id, size_t *addrlen) +{ + if (!addrlen) return EBADMEM; @@ -258,9 +224,28 @@ } - *address = device->addr; + ipc_callid_t callid; + size_t max_len; + if (!async_data_read_receive(&callid, &max_len)) { + fibril_rwlock_read_unlock(&nildummy_globals.devices_lock); + return EREFUSED; + } + + if (max_len < device->addr_len) { + fibril_rwlock_read_unlock(&nildummy_globals.devices_lock); + async_data_read_finalize(callid, NULL, 0); + return ELIMIT; + } + + int rc = async_data_read_finalize(callid, + (uint8_t *) &device->addr.address, device->addr_len); + if (rc != EOK) { + fibril_rwlock_read_unlock(&nildummy_globals.devices_lock); + return rc; + } + + *addrlen = device->addr_len; fibril_rwlock_read_unlock(&nildummy_globals.devices_lock); - - return (*address) ? EOK : ENOENT; + return EOK; } @@ -278,6 +263,6 @@ * */ -static int nildummy_packet_space_message(device_id_t device_id, size_t *addr_len, - size_t *prefix, size_t *content, size_t *suffix) +static int nildummy_packet_space_message(nic_device_id_t device_id, + size_t *addr_len, size_t *prefix, size_t *content, size_t *suffix) { if ((!addr_len) || (!prefix) || (!content) || (!suffix)) @@ -303,6 +288,5 @@ } -int nil_received_msg_local(device_id_t device_id, packet_t *packet, - services_t target) +int nil_received_msg_local(nic_device_id_t device_id, packet_t *packet) { fibril_rwlock_read_lock(&nildummy_globals.protos_lock); @@ -358,5 +342,5 @@ * */ -static int nildummy_send_message(device_id_t device_id, packet_t *packet, +static int nildummy_send_message(nic_device_id_t device_id, packet_t *packet, services_t sender) { @@ -372,6 +356,5 @@ /* Send packet queue */ if (packet) - netif_send_msg(device->sess, device_id, packet, - SERVICE_NILDUMMY); + nic_send_message(device->sess, packet_get_id(packet)); fibril_rwlock_read_unlock(&nildummy_globals.devices_lock); @@ -383,5 +366,4 @@ ipc_call_t *answer, size_t *answer_count) { - measured_string_t *address; packet_t *packet; size_t addrlen; @@ -404,5 +386,5 @@ case NET_NIL_DEVICE: return nildummy_device_message(IPC_GET_DEVICE(*call), - IPC_GET_SERVICE(*call), IPC_GET_MTU(*call)); + IPC_GET_DEVICE_HANDLE(*call), IPC_GET_MTU(*call)); case NET_NIL_SEND: @@ -427,14 +409,26 @@ case NET_NIL_ADDR: - rc = nildummy_addr_message(IPC_GET_DEVICE(*call), &address); + case NET_NIL_BROADCAST_ADDR: + rc = nildummy_addr_message(IPC_GET_DEVICE(*call), &addrlen); if (rc != EOK) return rc; - return measured_strings_reply(address, 1); - - case NET_NIL_BROADCAST_ADDR: - rc = nildummy_addr_message(IPC_GET_DEVICE(*call), &address); - if (rc != EOK) - return rc; - return measured_strings_reply(address, 1); + + IPC_SET_ADDR(*answer, addrlen); + *answer_count = 1; + return rc; + case NET_NIL_DEVICE_STATE: + rc = nil_device_state_msg_local(IPC_GET_DEVICE(*call), + IPC_GET_STATE(*call)); + async_answer_0(callid, (sysarg_t) rc); + return rc; + + case NET_NIL_RECEIVED: + rc = packet_translate_remote(nildummy_globals.net_sess, &packet, + IPC_GET_ARG2(*call)); + if (rc == EOK) + rc = nil_received_msg_local(IPC_GET_ARG1(*call), packet); + + async_answer_0(callid, (sysarg_t) rc); + return rc; } Index: uspace/srv/net/nil/nildummy/nildummy.h =================================================================== --- uspace/srv/net/nil/nildummy/nildummy.h (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/net/nil/nildummy/nildummy.h (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -1,4 +1,5 @@ /* * Copyright (c) 2009 Lukas Mejdrech + * Copyright (c) 2011 Radim Vansa * All rights reserved. * @@ -41,4 +42,5 @@ #include #include +#include #include #include @@ -76,9 +78,7 @@ struct nildummy_device { /** Device identifier. */ - device_id_t device_id; - - /** Device driver service. */ - services_t service; - + nic_device_id_t device_id; + /** Device driver handle. */ + devman_handle_t handle; /** Driver session. */ async_sess_t *sess; @@ -88,8 +88,7 @@ /** Actual device hardware address. */ - measured_string_t *addr; - - /** Actual device hardware address data. */ - uint8_t *addr_data; + nic_address_t addr; + /** Actual device hardware address length. */ + size_t addr_len; }; Index: uspace/srv/net/tl/tcp/tcp.c =================================================================== --- uspace/srv/net/tl/tcp/tcp.c (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/net/tl/tcp/tcp.c (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -169,5 +169,5 @@ static int tcp_release_after_timeout(void *); -static int tcp_process_packet(device_id_t, packet_t *, services_t); +static int tcp_process_packet(nic_device_id_t, packet_t *, services_t); static int tcp_connect_core(socket_core_t *, socket_cores_t *, struct sockaddr *, socklen_t); @@ -177,5 +177,5 @@ size_t); static packet_t *tcp_get_packets_to_send(socket_core_t *, tcp_socket_data_t *); -static void tcp_send_packets(device_id_t, packet_t *); +static void tcp_send_packets(nic_device_id_t, packet_t *); static void tcp_process_acknowledgement(socket_core_t *, tcp_socket_data_t *, @@ -205,5 +205,5 @@ static void tcp_queue_received_end_of_data(socket_core_t *socket); -static int tcp_received_msg(device_id_t, packet_t *, services_t, services_t); +static int tcp_received_msg(nic_device_id_t, packet_t *, services_t, services_t); static int tcp_process_client_messages(async_sess_t *, ipc_callid_t, ipc_call_t); @@ -220,5 +220,5 @@ tcp_globals_t tcp_globals; -int tcp_received_msg(device_id_t device_id, packet_t *packet, +int tcp_received_msg(nic_device_id_t device_id, packet_t *packet, services_t receiver, services_t error) { @@ -238,5 +238,5 @@ } -int tcp_process_packet(device_id_t device_id, packet_t *packet, services_t error) +int tcp_process_packet(nic_device_id_t device_id, packet_t *packet, services_t error) { size_t length; @@ -1251,5 +1251,5 @@ bzero(socket_data, sizeof(*socket_data)); socket_data->state = TCP_SOCKET_INITIAL; - socket_data->device_id = DEVICE_INVALID_ID; + socket_data->device_id = NIC_DEVICE_INVALID_ID; socket_data->window = NET_DEFAULT_TCP_WINDOW; socket_data->treshold = socket_data->window; @@ -1335,5 +1335,5 @@ } if (tl_get_ip_packet_dimension(tcp_globals.ip_sess, - &tcp_globals.dimensions, DEVICE_INVALID_ID, + &tcp_globals.dimensions, NIC_DEVICE_INVALID_ID, &packet_dimension) == EOK) { SOCKET_SET_DATA_FRAGMENT_SIZE(answer, @@ -1651,5 +1651,5 @@ /* Sent packet? */ packet = pq_find(socket_data->outgoing, sequence_number); - printf("retransmit %d\n", packet_get_id(packet)); + printf("retransmit %lu\n", packet_get_id(packet)); if (packet) { pq_get_order(packet, NULL, &data_length); @@ -1790,5 +1790,5 @@ /* Send the packet */ - printf("connecting %d\n", packet_get_id(packet)); + printf("connecting %lu\n", packet_get_id(packet)); tcp_send_packets(socket_data->device_id, packet); @@ -2004,5 +2004,5 @@ } -void tcp_send_packets(device_id_t device_id, packet_t *packet) +void tcp_send_packets(nic_device_id_t device_id, packet_t *packet) { packet_t *next; Index: uspace/srv/net/tl/tcp/tcp.h =================================================================== --- uspace/srv/net/tl/tcp/tcp.h (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/net/tl/tcp/tcp.h (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -182,5 +182,5 @@ /** Device identifier. */ - device_id_t device_id; + nic_device_id_t device_id; /** Index: uspace/srv/net/tl/udp/udp.c =================================================================== --- uspace/srv/net/tl/udp/udp.c (revision f98bec0fb36e6e57e1528afe8951563181f0dbb7) +++ uspace/srv/net/tl/udp/udp.c (revision e2c50e102fd16362a7ce19b5f3ae930df486f779) @@ -124,5 +124,5 @@ * ip_client_process_packet() function. */ -static int udp_process_packet(device_id_t device_id, packet_t *packet, +static int udp_process_packet(nic_device_id_t device_id, packet_t *packet, services_t error) { @@ -322,5 +322,5 @@ * udp_process_packet() function. */ -static int udp_received_msg(device_id_t device_id, packet_t *packet, +static int udp_received_msg(nic_device_id_t device_id, packet_t *packet, services_t receiver, services_t error) { @@ -499,5 +499,5 @@ void *ip_header; size_t headerlen; - device_id_t device_id; + nic_device_id_t device_id; packet_dimension_t *packet_dimension; size_t size; @@ -617,7 +617,6 @@ htons(flip_checksum(compact_checksum(checksum))); free(ip_header); - } else { - device_id = DEVICE_INVALID_ID; - } + } else + device_id = NIC_DEVICE_INVALID_ID; /* Prepare the first packet fragment */ @@ -806,5 +805,5 @@ size = MAX_UDP_FRAGMENT_SIZE; if (tl_get_ip_packet_dimension(udp_globals.ip_sess, - &udp_globals.dimensions, DEVICE_INVALID_ID, + &udp_globals.dimensions, NIC_DEVICE_INVALID_ID, &packet_dimension) == EOK) { if (packet_dimension->content < size)