Changeset a7a85d16 in mainline


Ignore:
Timestamp:
2010-10-16T17:16:30Z (14 years ago)
Author:
Jakub Jermar <jakub@…>
Branches:
lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
Children:
668f8cbf, e0e568ff, f14291b
Parents:
ef689ef0 (diff), c62ae1d6 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.
Message:

Merge from lp:~jakub/helenos/net.

Location:
uspace
Files:
41 edited
8 moved

Legend:

Unmodified
Added
Removed

  • uspace/lib/c/include/ipc/arp.h

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup arp
    30  *  @{
     29/** @addtogroup libc
     30 * @{
    3131 */
    3232
    3333/** @file
    34  *  ARP module messages.
    35  *  @see arp_interface.h
     34 * ARP module messages.
     35 * @see arp_interface.h
    3636 */
    3737
    38 #ifndef __NET_ARP_MESSAGES__
    39 #define __NET_ARP_MESSAGES__
     38#ifndef LIBC_ARP_MESSAGES_
     39#define LIBC_ARP_MESSAGES_
    4040
    4141#include <ipc/ipc.h>
    4242#include <ipc/net.h>
    4343
    44 /** ARP module messages.
    45  */
    46 typedef enum{
     44/** ARP module messages. */
     45typedef enum {
    4746        /** Clean cache message.
    48          *  @see arp_clean_cache()
     47         * @see arp_clean_cache()
    4948         */
    5049        NET_ARP_CLEAN_CACHE = NET_ARP_FIRST,
    5150        /** Clear address cache message.
    52          *  @see arp_clear_address_msg()
     51         * @see arp_clear_address_msg()
    5352         */
    5453        NET_ARP_CLEAR_ADDRESS,
    5554        /** Clear device cache message.
    56          *  @see arp_clear_device_req()
     55         * @see arp_clear_device_req()
    5756         */
    5857        NET_ARP_CLEAR_DEVICE,
    5958        /** New device message.
    60          *  @see arp_device_req()
     59         * @see arp_device_req()
    6160         */
    6261        NET_ARP_DEVICE,
    6362        /** Address translation message.
    64          *  @see arp_translate_req()
     63         * @see arp_translate_req()
    6564         */
    6665        NET_ARP_TRANSLATE
    6766} arp_messages;
    6867
    69 /** @name ARP specific message parameters definitions
    70  */
     68/** @name ARP specific message parameters definitions */
    7169/*@{*/
    7270
    7371/** Returns the protocol service message parameter.
    74  *  @param[in] call The message call structure.
     72 * @param[in] call The message call structure.
    7573 */
    7674#define ARP_GET_NETIF(call) \
    77         ({services_t service = (services_t) IPC_GET_ARG2(*call); service;})
     75        ({ \
     76                services_t service = (services_t) IPC_GET_ARG2(*call); \
     77                service; \
     78        })
    7879
    7980/*@}*/

  • uspace/lib/c/include/ipc/il.h

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup net_il
     29/** @addtogroup libc
    3030 * @{
    3131 */
    … …  
    3737 */
    3838
    39 #ifndef __NET_IL_MESSAGES_H__
    40 #define __NET_IL_MESSAGES_H__
     39#ifndef LIBC_IL_MESSAGES_H_
     40#define LIBC_IL_MESSAGES_H_
    4141
    4242#include <ipc/ipc.h>
    4343#include <ipc/net.h>
    4444
    45 /** Internet layer modules messages.
    46  */
     45/** Internet layer modules messages. */
    4746typedef enum {
    4847        /** New device message.
    49          *  @see ip_device_req()
     48         * @see ip_device_req()
    5049         */
    5150        NET_IL_DEVICE = NET_IL_FIRST,
    5251        /** Device state changed message.
    53          *  @see il_device_state_msg()
     52         * @see il_device_state_msg()
    5453         */
    5554        NET_IL_DEVICE_STATE,
    5655        /** Device MTU changed message.
    57          *  @see il_mtu_changed_msg()
     56         * @see il_mtu_changed_msg()
    5857         */
    5958        NET_IL_MTU_CHANGED,
    6059        /** Packet size message.
    61          *  @see il_packet_size_req()
     60         * @see il_packet_size_req()
    6261         */
    6362        NET_IL_PACKET_SPACE,
    6463        /** Packet received message.
    65          *  @see il_received_msg()
     64         * @see il_received_msg()
    6665         */
    6766        NET_IL_RECEIVED,
    6867        /** Packet send message.
    69          *  @see il_send_msg()
     68         * @see il_send_msg()
    7069         */
    7170        NET_IL_SEND
    7271} il_messages;
    7372
    74 /** @name Internetwork layer specific message parameters definitions
    75  *
    76  */
     73/** @name Internetwork layer specific message parameters definitions */
    7774/*@{*/
    7875
    7976/** Return the protocol number message parameter.
    8077 * @param[in] call The message call structure.
    81  *
    8278 */
    83 #define IL_GET_PROTO(call)  (int) IPC_GET_ARG1(*call)
     79#define IL_GET_PROTO(call)      (int) IPC_GET_ARG1(*call)
    8480
    8581/** Return the registering service message parameter.
    8682 * @param[in] call The message call structure.
    87  *
    8883 */
    89 #define IL_GET_SERVICE(call)  (services_t) IPC_GET_ARG2(*call)
     84#define IL_GET_SERVICE(call)    (services_t) IPC_GET_ARG2(*call)
    9085
    9186/*@}*/

  • uspace/lib/c/include/ipc/ip.h

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup ip
    30  *  @{
     29/** @addtogroup libc
     30 * @{
    3131 */
    3232
    3333/** @file
    34  *  IP module messages.
    35  *  @see ip_interface.h
     34 * IP module messages.
     35 * @see ip_interface.h
    3636 */
    3737
    38 #ifndef __NET_IP_MESSAGES_H__
    39 #define __NET_IP_MESSAGES_H__
     38#ifndef LIBC_IP_MESSAGES_H_
     39#define LIBC_IP_MESSAGES_H_
    4040
    4141#include <ipc/ipc.h>
    … …  
    4545#include <net/ip_codes.h>
    4646
    47 /** IP module messages.
    48  */
    49 typedef enum{
     47/** IP module messages. */
     48typedef enum {
    5049        /** Adds the routing entry.
    51          *  @see ip_add_route()
     50         * @see ip_add_route()
    5251         */
    5352        NET_IP_ADD_ROUTE = NET_IP_FIRST,
    5453        /** Gets the actual route information.
    55          *  @see ip_get_route()
     54         * @see ip_get_route()
    5655         */
    5756        NET_IP_GET_ROUTE,
    5857        /** Processes the received error notification.
    59          *  @see ip_received_error_msg()
     58         * @see ip_received_error_msg()
    6059         */
    6160        NET_IP_RECEIVED_ERROR,
    6261        /** Sets the default gateway.
    63          *  @see ip_set_default_gateway()
     62         * @see ip_set_default_gateway()
    6463         */
    6564        NET_IP_SET_GATEWAY
    6665} ip_messages;
    6766
    68 /** @name IP specific message parameters definitions
    69  */
     67/** @name IP specific message parameters definitions */
    7068/*@{*/
    7169
    7270/** Returns the address message parameter.
    73  *  @param[in] call The message call structure.
     71 * @param[in] call The message call structure.
    7472 */
    7573#define IP_GET_ADDRESS(call) \
    76         ({in_addr_t addr; addr.s_addr = IPC_GET_ARG3(*call); addr;})
     74        ({ \
     75                in_addr_t addr; \
     76                addr.s_addr = IPC_GET_ARG3(*call); \
     77                addr; \
     78        })
    7779
    7880/** Returns the gateway message parameter.
    79  *  @param[in] call The message call structure.
     81 * @param[in] call The message call structure.
    8082 */
    8183#define IP_GET_GATEWAY(call) \
    82         ({in_addr_t addr; addr.s_addr = IPC_GET_ARG2(*call); addr;})
     84        ({ \
     85                in_addr_t addr; \
     86                addr.s_addr = IPC_GET_ARG2(*call); \
     87                addr; \
     88        })
    8389
    8490/** Sets the header length in the message answer.
    85  *  @param[out] answer The message answer structure.
     91 * @param[out] answer The message answer structure.
    8692 */
    8793#define IP_SET_HEADERLEN(answer, value) \
    88         {ipcarg_t argument = (ipcarg_t) (value); IPC_SET_ARG2(*answer, argument);}
     94        do { \
     95                ipcarg_t argument = (ipcarg_t) (value); \
     96                IPC_SET_ARG2(*answer, argument); \
     97        } while (0)
    8998
    9099/** Returns the network mask message parameter.
    91  *  @param[in] call The message call structure.
     100 * @param[in] call The message call structure.
    92101 */
    93102#define IP_GET_NETMASK(call) \
    94         ({in_addr_t addr; addr.s_addr = IPC_GET_ARG4(*call); addr;})
     103        ({ \
     104                in_addr_t addr; \
     105                addr.s_addr = IPC_GET_ARG4(*call); \
     106                addr; \
     107        })
    95108
    96109/** Returns the protocol message parameter.
    97  *  @param[in] call The message call structure.
     110 * @param[in] call The message call structure.
    98111 */
    99112#define IP_GET_PROTOCOL(call) \
    100         ({ip_protocol_t protocol = (ip_protocol_t) IPC_GET_ARG1(*call); protocol;})
     113        ({ \
     114                ip_protocol_t protocol = (ip_protocol_t) IPC_GET_ARG1(*call); \
     115                protocol; \
     116        })
    101117
    102118/*@}*/

  • uspace/lib/c/include/ipc/net_net.h

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup net
    30  *  @{
     29/** @addtogroup libc
     30 * @{
    3131 */
    3232
    3333/** @file
    34  *  Networking subsystem central module messages.
    35  *  @see net_interface.h
     34 * Networking subsystem central module messages.
     35 * @see net_interface.h
    3636 */
    3737
    38 #ifndef __NET_NET_MESSAGES_H__
    39 #define __NET_NET_MESSAGES_H__
     38#ifndef LIBC_NET_NET_MESSAGES_H_
     39#define LIBC_NET_NET_MESSAGES_H_
    4040
    4141#include <ipc/ipc.h>
    4242#include <ipc/net.h>
    4343
    44 /** Networking subsystem central module messages.
    45  */
    46 typedef enum{
     44/** Networking subsystem central module messages. */
     45typedef enum {
    4746        /** Returns the general configuration
    48          *  @see net_get_conf_req()
     47         * @see net_get_conf_req()
    4948         */
    5049        NET_NET_GET_CONF = NET_FIRST,
    5150        /** Returns the device specific configuration
    52          *  @see net_get_device_conf_req()
     51         * @see net_get_device_conf_req()
    5352         */
    5453        NET_NET_GET_DEVICE_CONF,
    55         /** Starts the networking stack.
    56          */
     54        /** Starts the networking stack. */
    5755        NET_NET_STARTUP,
    5856} net_messages;

  • uspace/lib/c/include/ipc/netif.h

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup netif
     29/** @addtogroup libc
    3030 * @{
    3131 */
    … …  
    3535 */
    3636
    37 #ifndef __NET_NETIF_MESSAGES_H__
    38 #define __NET_NETIF_MESSAGES_H__
     37#ifndef LIBC_NETIF_MESSAGES_H_
     38#define LIBC_NETIF_MESSAGES_H_
    3939
    4040#include <ipc/ipc.h>
    4141#include <ipc/net.h>
    4242
    43 /** Network interface common module messages.
    44  */
     43/** Network interface common module messages. */
    4544typedef enum {
    4645        /** Probe device message.
    47          *  @see netif_probe_req()
     46         * @see netif_probe_req()
    4847         */
    4948        NET_NETIF_PROBE = NET_NETIF_FIRST,
    5049        /** Send packet message.
    51          *  @see netif_send_msg()
     50         * @see netif_send_msg()
    5251         */
    5352        NET_NETIF_SEND,
    5453        /** Start device message.
    55          *  @see netif_start_req()
     54         * @see netif_start_req()
    5655         */
    5756        NET_NETIF_START,
    5857        /** Get device usage statistics message.
    59          *  @see netif_stats_req()
     58         * @see netif_stats_req()
    6059         */
    6160        NET_NETIF_STATS,
    6261        /** Stop device message.
    63          *  @see netif_stop_req()
     62         * @see netif_stop_req()
    6463         */
    6564        NET_NETIF_STOP,
    6665        /** Get device address message.
    67          *  @see netif_get_addr_req()
     66         * @see netif_get_addr_req()
    6867         */
    6968        NET_NETIF_GET_ADDR,
    7069} netif_messages;
    7170
    72 /** @name Network interface specific message parameters definitions
    73  */
     71/** @name Network interface specific message parameters definitions */
    7472/*@{*/
    7573
    … …  
    7876 */
    7977#define NETIF_GET_IRQ(call) \
    80         ({int irq = (int) IPC_GET_ARG2(*call); irq;})
     78        ({ \
     79                int irq = (int) IPC_GET_ARG2(*call); \
     80                irq; \
     81        })
    8182
    8283/** Return the input/output address message parameter.
    … …  
    8485 */
    8586#define NETIF_GET_IO(call) \
    86         ({int io = (int) IPC_GET_ARG3(*call); io;})
     87        ({ \
     88                int io = (int) IPC_GET_ARG3(*call); \
     89                io; \
     90        })
    8791
    8892/*@}*/

  • uspace/lib/c/include/ipc/nil.h

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup net_nil
     29/** @addtogroup libc
    3030 * @{
    3131 */
    … …  
    3535 */
    3636
    37 #ifndef __NET_NIL_MESSAGES_H__
    38 #define __NET_NIL_MESSAGES_H__
     37#ifndef LIBC_NIL_MESSAGES_H_
     38#define LIBC_NIL_MESSAGES_H_
    3939
    4040#include <ipc/ipc.h>
    4141#include <ipc/net.h>
    4242
    43 /** Network interface layer module messages.
    44  */
     43/** Network interface layer module messages. */
    4544typedef enum {
    4645        /** New device or update MTU message.
    47          *  @see nil_device_req()
     46         * @see nil_device_req()
    4847         */
    4948        NET_NIL_DEVICE = NET_NIL_FIRST,
    5049        /** New device state message.
    51          *  @see nil_device_state_msg()
     50         * @see nil_device_state_msg()
    5251         */
    5352        NET_NIL_DEVICE_STATE,
    5453        /** Received packet queue message.
    55          *  @see nil_received_msg()
     54         * @see nil_received_msg()
    5655         */
    5756        NET_NIL_RECEIVED,
    5857        /** Send packet queue message.
    59          *  @see nil_send_msg()
     58         * @see nil_send_msg()
    6059         */
    6160        NET_NIL_SEND,
    6261        /** Packet size message.
    63          *  @see nil_packet_size_req()
     62         * @see nil_packet_size_req()
    6463         */
    6564        NET_NIL_PACKET_SPACE,
    6665        /** Device local hardware address message.
    67          *  @see nil_get_addr()
     66         * @see nil_get_addr()
    6867         */
    6968        NET_NIL_ADDR,
    7069        /** Device broadcast hardware address message.
    71          *  @see nil_get_broadcast_addr()
     70         * @see nil_get_broadcast_addr()
    7271         */
    7372        NET_NIL_BROADCAST_ADDR,
    7473} nil_messages;
    7574
    76 /** @name Network interface layer specific message parameters definitions
    77  */
     75/** @name Network interface layer specific message parameters definitions */
    7876/*@{*/
    7977
    80 /** Return the protocol service message parameter.
    81  */
     78/** Return the protocol service message parameter. */
    8279#define NIL_GET_PROTO(call) \
    83         ({services_t service = (services_t) IPC_GET_ARG2(*call); service;})
     80        ({ \
     81                services_t service = (services_t) IPC_GET_ARG2(*call); \
     82                service; \
     83        })
    8484
    8585/*@}*/

  • uspace/lib/c/include/ipc/tl.h

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup net_tl
    30  *  @{
     29/** @addtogroup libc
     30 * @{
    3131 */
    3232
    3333/** @file
    34  *  Transport layer modules messages.
    35  *  @see tl_interface.h
     34 * Transport layer modules messages.
     35 * @see tl_interface.h
    3636 */
    3737
    38 #ifndef __NET_TL_MESSAGES_H__
    39 #define __NET_TL_MESSAGES_H__
     38#ifndef LIBC_TL_MESSAGES_H_
     39#define LIBC_TL_MESSAGES_H_
    4040
    4141#include <ipc/ipc.h>
    4242#include <ipc/net.h>
    4343
    44 /** Transport layer modules messages.
    45  */
    46 typedef enum{
     44/** Transport layer modules messages. */
     45typedef enum {
    4746        /** Packet received message.
    48          *  @see tl_received_msg()
     47         * @see tl_received_msg()
    4948         */
    5049        NET_TL_RECEIVED = NET_TL_FIRST

  • uspace/lib/c/include/net/icmp_api.h

    ref689ef0 ra7a85d16  
    4444
    4545#include <adt/measured_strings.h>
    46 #include <net/packet.h>
    4746#include <net/ip_codes.h>
    4847#include <net/icmp_codes.h>

  • uspace/lib/net/adt/module_map.c

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup net
    30  *  @{
     29/** @addtogroup libnet
     30 * @{
    3131 */
    3232
    3333/** @file
    34  *  Character string to module map implementation.
     34 * Character string to module map implementation.
    3535 */
    3636
    … …  
    4949GENERIC_CHAR_MAP_IMPLEMENT(modules, module_t)
    5050
    51 int add_module(module_ref * module, modules_ref modules, const char * name, const char * filename, services_t service, task_id_t task_id, connect_module_t connect_module){
     51/** Adds module to the module map.
     52 *
     53 * @param[out] module   The module structure added.
     54 * @param[in] modules   The module map.
     55 * @param[in] name      The module name.
     56 * @param[in] filename  The full path filename.
     57 * @param[in] service   The module service.
     58 * @param[in] task_id   The module current task identifier. Zero means not
     59 *                      running.
     60 * @param[in] connect_module The module connecting function.
     61 * @returns             EOK on success.
     62 * @returns             ENOMEM if there is not enough memory left.
     63 */
     64int
     65add_module(module_ref *module, modules_ref modules, const char *name,
     66    const char *filename, services_t service, task_id_t task_id,
     67    connect_module_t connect_module)
     68{
    5269        ERROR_DECLARE;
    5370
    … …  
    5572
    5673        tmp_module = (module_ref) malloc(sizeof(module_t));
    57         if(! tmp_module){
     74        if (!tmp_module)
    5875                return ENOMEM;
    59         }
     76
    6077        tmp_module->task_id = task_id;
    6178        tmp_module->phone = 0;
    … …  
    6582        tmp_module->service = service;
    6683        tmp_module->connect_module = connect_module;
    67         if(ERROR_OCCURRED(modules_add(modules, tmp_module->name, 0, tmp_module))){
     84
     85        if (ERROR_OCCURRED(modules_add(modules, tmp_module->name, 0,
     86            tmp_module))) {
    6887                free(tmp_module);
    6988                return ERROR_CODE;
    7089        }
    71         if(module){
     90        if (module)
    7291                *module = tmp_module;
    73         }
     92
    7493        return EOK;
    7594}
    7695
    77 module_ref get_running_module(modules_ref modules, char * name){
     96/** Searches and returns the specified module.
     97 *
     98 * If the module is not running, the module filaname is spawned.
     99 * If the module is not connected, the connect_function is called.
     100 *
     101 * @param[in] modules   The module map.
     102 * @param[in] name      The module name.
     103 * @returns             The running module found. It does not have to be
     104 *                      connected.
     105 * @returns             NULL if there is no such module.
     106 */
     107module_ref get_running_module(modules_ref modules, char *name)
     108{
    78109        module_ref module;
    79110
    80111        module = modules_find(modules, name, 0);
    81         if(! module){
     112        if (!module)
    82113                return NULL;
     114
     115        if (!module->task_id) {
     116                module->task_id = spawn(module->filename);
     117                if (!module->task_id)
     118                        return NULL;
    83119        }
    84         if(! module->task_id){
    85                 module->task_id = spawn(module->filename);
    86                 if(! module->task_id){
    87                         return NULL;
    88                 }
    89         }
    90         if(! module->phone){
     120        if (!module->phone)
    91121                module->phone = module->connect_module(module->service);
    92         }
     122
    93123        return module;
    94124}
    95125
     126/** Starts the given module.
     127 *
     128 * @param[in] fname     The module full or relative path filename.
     129 * @returns             The new module task identifier on success.
     130 * @returns             Zero if there is no such module.
     131 */
    96132task_id_t spawn(const char *fname)
    97133{

  • uspace/lib/net/generic/generic.c

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup net
     29/** @addtogroup libnet
    3030 * @{
    3131 */

  • uspace/lib/net/generic/net_checksum.c

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup net
    30  *  @{
     29/** @addtogroup libnet
     30 * @{
    3131 */
    3232
    3333/** @file
    34  *  General CRC and checksum computation implementation.
     34 * General CRC and checksum computation implementation.
    3535 */
    3636
    … …  
    3939#include <net_checksum.h>
    4040
    41 /** Big-endian encoding CRC divider.
    42  */
    43 #define CRC_DIVIDER_BE  0x04C11DB7
    44 
    45 /** Little-endian encoding CRC divider.
    46  */
    47 #define CRC_DIVIDER_LE  0xEDB88320
    48 
    49 uint16_t compact_checksum(uint32_t sum){
     41/** Big-endian encoding CRC divider. */
     42#define CRC_DIVIDER_BE  0x04c11db7
     43
     44/** Little-endian encoding CRC divider. */
     45#define CRC_DIVIDER_LE  0xedb88320
     46
     47/** Compacts the computed checksum to the 16 bit number adding the carries.
     48 *
     49 * @param[in] sum       Computed checksum.
     50 * @returns             Compacted computed checksum to the 16 bits.
     51 */
     52uint16_t compact_checksum(uint32_t sum)
     53{
    5054        // shorten to the 16 bits
    51         while(sum >> 16){
    52                 sum = (sum &0xFFFF) + (sum >> 16);
    53         }
     55        while (sum >> 16)
     56                sum = (sum & 0xffff) + (sum >> 16);
    5457
    5558        return (uint16_t) sum;
    5659}
    5760
    58 uint32_t compute_checksum(uint32_t seed, uint8_t * data, size_t length){
     61/** Computes sum of the 2 byte fields.
     62 *
     63 * Padds one zero (0) byte if odd.
     64 *
     65 * @param[in] seed      Initial value. Often used as 0 or ~0.
     66 * @param[in] data      Pointer to the beginning of data to process.
     67 * @param[in] length    Length of the data in bytes.
     68 * @returns             The computed checksum of the length bytes of the data.
     69 */
     70uint32_t compute_checksum(uint32_t seed, uint8_t *data, size_t length)
     71{
    5972        size_t index;
    6073
    6174        // sum all the 16 bit fields
    62         for(index = 0; index + 1 < length; index += 2){
     75        for (index = 0; index + 1 < length; index += 2)
    6376                seed += (data[index] << 8) + data[index + 1];
    64         }
    6577
    6678        // last odd byte with zero padding
    67         if(index + 1 == length){
     79        if (index + 1 == length)
    6880                seed += data[index] << 8;
    69         }
    7081
    7182        return seed;
    7283}
    7384
    74 uint32_t compute_crc32_be(uint32_t seed, uint8_t * data, size_t length){
     85/** Computes CRC32 value in the big-endian environment.
     86 *
     87 * @param[in] seed      Initial value. Often used as 0 or ~0.
     88 * @param[in] data      Pointer to the beginning of data to process.
     89 * @param[in] length    Length of the data in bits.
     90 * @returns             The computed CRC32 of the length bits of the data.
     91 */
     92uint32_t compute_crc32_be(uint32_t seed, uint8_t * data, size_t length)
     93{
    7594        size_t index;
    7695
    7796        // process full bytes
    78         while(length >= 8){
     97        while (length >= 8) {
    7998                // add the data
    8099                seed ^= (*data) << 24;
     100               
    81101                // for each added bit
    82                 for(index = 0; index < 8; ++ index){
     102                for (index = 0; index < 8; ++index) {
    83103                        // if the first bit is set
    84                         if(seed &0x80000000){
     104                        if (seed & 0x80000000) {
    85105                                // shift and divide the checksum
    86106                                seed = (seed << 1) ^ ((uint32_t) CRC_DIVIDER_BE);
    87                         }else{
     107                        } else {
    88108                                // shift otherwise
    89109                                seed <<= 1;
    90110                        }
    91111                }
     112               
    92113                // move to the next byte
    93                 ++ data;
     114                ++data;
    94115                length -= 8;
    95116        }
    96117
    97118        // process the odd bits
    98         if(length > 0){
     119        if (length > 0) {
    99120                // add the data with zero padding
    100                 seed ^= ((*data) &(0xFF << (8 - length))) << 24;
     121                seed ^= ((*data) & (0xff << (8 - length))) << 24;
     122               
    101123                // for each added bit
    102                 for(index = 0; index < length; ++ index){
     124                for (index = 0; index < length; ++index) {
    103125                        // if the first bit is set
    104                         if(seed &0x80000000){
     126                        if (seed & 0x80000000) {
    105127                                // shift and divide the checksum
    106128                                seed = (seed << 1) ^ ((uint32_t) CRC_DIVIDER_BE);
    107                         }else{
     129                        } else {
    108130                                // shift otherwise
    109131                                seed <<= 1;
    … …  
    115137}
    116138
    117 uint32_t compute_crc32_le(uint32_t seed, uint8_t * data, size_t length){
     139/** Computes CRC32 value in the little-endian environment.
     140 *
     141 * @param[in] seed      Initial value. Often used as 0 or ~0.
     142 * @param[in] data      Pointer to the beginning of data to process.
     143 * @param[in] length    Length of the data in bits.
     144 * @returns             The computed CRC32 of the length bits of the data.
     145 */
     146uint32_t compute_crc32_le(uint32_t seed, uint8_t * data, size_t length)
     147{
    118148        size_t index;
    119149
    120150        // process full bytes
    121         while(length >= 8){
     151        while (length >= 8) {
    122152                // add the data
    123153                seed ^= (*data);
     154               
    124155                // for each added bit
    125                 for(index = 0; index < 8; ++ index){
     156                for (index = 0; index < 8; ++index) {
    126157                        // if the last bit is set
    127                         if(seed &1){
     158                        if (seed & 1) {
    128159                                // shift and divide the checksum
    129160                                seed = (seed >> 1) ^ ((uint32_t) CRC_DIVIDER_LE);
    130                         }else{
     161                        } else {
    131162                                // shift otherwise
    132163                                seed >>= 1;
    133164                        }
    134165                }
     166               
    135167                // move to the next byte
    136                 ++ data;
     168                ++data;
    137169                length -= 8;
    138170        }
    139171
    140172        // process the odd bits
    141         if(length > 0){
     173        if (length > 0) {
    142174                // add the data with zero padding
    143175                seed ^= (*data) >> (8 - length);
    144                 for(index = 0; index < length; ++ index){
     176               
     177                for (index = 0; index < length; ++index) {
    145178                        // if the last bit is set
    146                         if(seed &1){
     179                        if (seed & 1) {
    147180                                // shift and divide the checksum
    148181                                seed = (seed >> 1) ^ ((uint32_t) CRC_DIVIDER_LE);
    149                         }else{
     182                        } else {
    150183                                // shift otherwise
    151184                                seed >>= 1;
    … …  
    157190}
    158191
    159 uint16_t flip_checksum(uint16_t checksum){
     192/** Returns or flips the checksum if zero.
     193 *
     194 * @param[in] checksum  The computed checksum.
     195 * @returns             The internet protocol header checksum.
     196 * @returns             0xFFFF if the computed checksum is zero.
     197 */
     198uint16_t flip_checksum(uint16_t checksum)
     199{
    160200        // flip, zero is returned as 0xFFFF (not flipped)
    161         checksum = ~ checksum;
     201        checksum = ~checksum;
    162202        return checksum ? checksum : IP_CHECKSUM_ZERO;
    163203}
    164204
    165 uint16_t ip_checksum(uint8_t * data, size_t length){
     205/** Computes the ip header checksum.
     206 *
     207 * To compute the checksum of a new packet, the checksum header field must be
     208 * zero. To check the checksum of a received packet, the checksum may be left
     209 * set. Zero will be returned in this case if valid.
     210 *
     211 * @param[in] data      The header data.
     212 * @param[in] length    The header length in bytes.
     213 * @returns             The internet protocol header checksum.
     214 * @returns             0xFFFF if the computed checksum is zero.
     215 */
     216uint16_t ip_checksum(uint8_t *data, size_t length)
     217{
    166218        // compute, compact and flip the data checksum
    167         return flip_checksum(compact_checksum(compute_checksum(0, data, length)));
     219        return flip_checksum(compact_checksum(compute_checksum(0, data,
     220            length)));
    168221}
    169222

  • uspace/lib/net/generic/net_remote.c

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup net
    30  *  @{
     29/** @addtogroup libnet
     30 * @{
    3131 */
    3232
    3333/** @file
    34  *  Networking interface implementation for remote modules.
    35  *  @see net_interface.h
     34 * Networking interface implementation for remote modules.
     35 * @see net_interface.h
    3636 */
    3737
    3838#include <ipc/services.h>
     39#include <ipc/net_net.h>
    3940
    4041#include <malloc.h>
    … …  
    4546#include <net_interface.h>
    4647#include <adt/measured_strings.h>
    47 #include <net_net_messages.h>
    4848
    49 int net_connect_module(services_t service)
     49/** Connects to the networking module.
     50 *
     51 * @returns             The networking module phone on success.
     52 */
     53int net_connect_module(void)
    5054{
    5155        return connect_to_service(SERVICE_NETWORKING);
    5256}
    5357
    54 void net_free_settings(measured_string_ref settings, char * data)
     58/** Frees the received settings.
     59 *
     60 * @param[in] settings  The received settings.
     61 * @param[in] data      The received settings data.
     62 * @see net_get_device_conf_req()
     63 * @see net_get_conf_req()
     64 */
     65void net_free_settings(measured_string_ref settings, char *data)
    5566{
    5667        if (settings)
    5768                free(settings);
    58 
    5969        if (data)
    6070                free(data);
    6171}
    6272
     73/** Returns the global configuration.
     74 *
     75 * The configuration names are read and the appropriate settings are set
     76 * instead. Call net_free_settings() function to release the returned
     77 * configuration.
     78 *
     79 * @param[in] net_phone The networking module phone.
     80 * @param[in,out] configuration The requested configuration. The names are read
     81 * and the appropriate settings are set instead.
     82 *
     83 * @param[in] count     The configuration entries count.
     84 * @param[in,out] data  The configuration and settings data.
     85 * @returns             EOK on success.
     86 * @returns             EINVAL if the configuration is NULL.
     87 * @returns             EINVAL if the count is zero.
     88 * @returns             Other error codes as defined for the
     89 *                      generic_translate_req() function.
     90 */
    6391int
    64 net_get_conf_req(int net_phone, measured_string_ref * configuration,
    65     size_t count, char ** data)
     92net_get_conf_req(int net_phone, measured_string_ref *configuration,
     93    size_t count, char **data)
    6694{
    6795        return generic_translate_req(net_phone, NET_NET_GET_DEVICE_CONF, 0, 0,
    … …  
    6997}
    7098
     99/** Returns the device specific configuration.
     100 *
     101 * Returns the global configuration if the device specific is not found.
     102 * The configuration names are read and the appropriate settings are set
     103 * instead. Call net_free_settings() function to release the returned
     104 * configuration.
     105 *
     106 * @param[in] net_phone The networking module phone.
     107 * @param[in] device_id The device identifier.
     108 * @param[in,out] configuration The requested device configuration. The names
     109 *                      are read and the appropriate settings are set instead.
     110 * @param[in] count     The configuration entries count.
     111 * @param[in,out] data  The configuration and settings data.
     112 * @returns             EOK on success.
     113 * @returns             EINVAL if the configuration is NULL.
     114 * @returns             EINVAL if the count is zero.
     115 * @returns             Other error codes as defined for the
     116 *                      generic_translate_req() function.
     117 */
    71118int
    72119net_get_device_conf_req(int net_phone, device_id_t device_id,
    73     measured_string_ref * configuration, size_t count, char ** data)
     120    measured_string_ref *configuration, size_t count, char **data)
    74121{
    75122        return generic_translate_req(net_phone, NET_NET_GET_DEVICE_CONF,

  • uspace/lib/net/generic/packet_client.c

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup packet
    30  *  @{
     29/** @addtogroup libnet
     30 * @{
    3131 */
    3232
    3333/** @file
    34  *  Packet client implementation.
     34 * Packet client implementation.
    3535 */
    3636
    … …  
    3838#include <mem.h>
    3939#include <unistd.h>
    40 
    4140#include <sys/mman.h>
    4241
    4342#include <packet_client.h>
     43#include <packet_remote.h>
    4444
    4545#include <net/packet.h>
    4646#include <net/packet_header.h>
    4747
    48 int packet_copy_data(packet_t packet, const void * data, size_t length)
     48/** Copies the specified data to the beginning of the actual packet content.
     49 *
     50 * Pushes the content end if needed.
     51 *
     52 * @param[in] packet    The packet to be filled.
     53 * @param[in] data      The data to be copied.
     54 * @param[in] length    The length of the copied data.
     55 * @returns             EOK on success.
     56 * @returns             EINVAL if the packet is not valid.
     57 * @returns             ENOMEM if there is not enough memory left.
     58 */
     59int packet_copy_data(packet_t packet, const void *data, size_t length)
    4960{
    5061        if (!packet_is_valid(packet))
    … …  
    6172}
    6273
     74/** Allocates the specified space right before the actual packet content and
     75 * returns its pointer.
     76 *
     77 * @param[in] packet    The packet to be used.
     78 * @param[in] length    The space length to be allocated at the beginning of the
     79 *                      packet content.
     80 * @returns             The pointer to the allocated memory.
     81 * @returns             NULL if there is not enough memory left.
     82 */
    6383void *packet_prefix(packet_t packet, size_t length)
    6484{
    … …  
    7393}
    7494
     95/** Allocates the specified space right after the actual packet content and
     96 * returns its pointer.
     97 *
     98 * @param[in] packet    The packet to be used.
     99 * @param[in] length    The space length to be allocated at the end of the
     100 *                       packet content.
     101 * @returns             The pointer to the allocated memory.
     102 * @returns             NULL if there is not enough memory left.
     103 */
    75104void *packet_suffix(packet_t packet, size_t length)
    76105{
    … …  
    84113}
    85114
     115/** Trims the actual packet content by the specified prefix and suffix lengths.
     116 *
     117 * @param[in] packet    The packet to be trimmed.
     118 * @param[in] prefix    The prefix length to be removed from the beginning of
     119 *                      the packet content.
     120 * @param[in] suffix    The suffix length to be removed from the end of the
     121 *                      packet content.
     122 * @returns             EOK on success.
     123 * @returns             EINVAL if the packet is not valid.
     124 * @returns             ENOMEM if there is not enough memory left.
     125 */
    86126int packet_trim(packet_t packet, size_t prefix, size_t suffix)
    87127{
    … …  
    97137}
    98138
     139/** Returns the packet identifier.
     140 *
     141 * @param[in] packet    The packet.
     142 * @returns             The packet identifier.
     143 * @returns             Zero if the packet is not valid.
     144 */
    99145packet_id_t packet_get_id(const packet_t packet)
    100146{
    … …  
    102148}
    103149
    104 int packet_get_addr(const packet_t packet, uint8_t ** src, uint8_t ** dest)
     150/** Returns the stored packet addresses and their length.
     151 *
     152 * @param[in] packet    The packet.
     153 * @param[out] src      The source address. May be NULL if not desired.
     154 * @param[out] dest     The destination address. May be NULL if not desired.
     155 * @returns             The stored addresses length.
     156 * @returns             Zero if the addresses are not present.
     157 * @returns             EINVAL if the packet is not valid.
     158 */
     159int packet_get_addr(const packet_t packet, uint8_t **src, uint8_t **dest)
    105160{
    106161        if (!packet_is_valid(packet))
    … …  
    116171}
    117172
     173/** Returns the packet content length.
     174 *
     175 * @param[in] packet    The packet.
     176 * @returns             The packet content length in bytes.
     177 * @returns             Zero if the packet is not valid.
     178 */
    118179size_t packet_get_data_length(const packet_t packet)
    119180{
    … …  
    124185}
    125186
     187/** Returns the pointer to the beginning of the packet content.
     188 *
     189 * @param[in] packet    The packet.
     190 * @returns             The pointer to the beginning of the packet content.
     191 * @returns             NULL if the packet is not valid.
     192 */
    126193void *packet_get_data(const packet_t packet)
    127194{
    … …  
    132199}
    133200
     201/** Sets the packet addresses.
     202 *
     203 * @param[in] packet    The packet.
     204 * @param[in] src       The new source address. May be NULL.
     205 * @param[in] dest      The new destination address. May be NULL.
     206 * @param[in] addr_len  The addresses length.
     207 * @returns             EOK on success.
     208 * @returns             EINVAL if the packet is not valid.
     209 * @returns             ENOMEM if there is not enough memory left.
     210 */
    134211int
    135 packet_set_addr(packet_t packet, const uint8_t * src, const uint8_t * dest,
     212packet_set_addr(packet_t packet, const uint8_t *src, const uint8_t *dest,
    136213    size_t addr_len)
    137214{
    … …  
    170247}
    171248
     249/** Returns the packet copy.
     250 *
     251 * Copies the addresses, data, order and metric values.
     252 * Does not copy the queue placement.
     253 *
     254 * @param[in] phone     The packet server module phone.
     255 * @param[in] packet    The original packet.
     256 * @returns             The packet copy.
     257 * @returns             NULL on error.
     258 */
    172259packet_t packet_get_copy(int phone, packet_t packet)
    173260{

  • uspace/lib/net/generic/packet_remote.c

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup packet
    30  *  @{
     29/** @addtogroup libnet
     30 * @{
    3131 */
    3232
    3333/** @file
    34  *  Packet client interface implementation for remote modules.
    35  *  @see packet_client.h
     34 * Packet client interface implementation for remote modules.
     35 * @see packet_client.h
    3636 */
    3737
    … …  
    8686}
    8787
     88/** Translates the packet identifier to the packet reference.
     89 *
     90 * Tries to find mapping first.
     91 * Contacts the packet server to share the packet if the mapping is not present.
     92 *
     93 * @param[in] phone     The packet server module phone.
     94 * @param[out] packet   The packet reference.
     95 * @param[in] packet_id The packet identifier.
     96 * @returns             EOK on success.
     97 * @returns             EINVAL if the packet parameter is NULL.
     98 * @returns             Other error codes as defined for the NET_PACKET_GET_SIZE
     99 *                      message.
     100 * @returns             Other error codes as defined for the packet_return()
     101 *                      function.
     102 */
    88103int packet_translate_remote(int phone, packet_ref packet, packet_id_t packet_id)
    89104{
    … …  
    110125}
    111126
     127/** Obtains the packet of the given dimensions.
     128 *
     129 * Contacts the packet server to return the appropriate packet.
     130 *
     131 * @param[in] phone     The packet server module phone.
     132 * @param[in] addr_len  The source and destination addresses maximal length in
     133 *                      bytes.
     134 * @param[in] max_prefix The maximal prefix length in bytes.
     135 * @param[in] max_content The maximal content length in bytes.
     136 * @param[in] max_suffix The maximal suffix length in bytes.
     137 * @returns             The packet reference.
     138 * @returns             NULL on error.
     139 */
    112140packet_t packet_get_4_remote(int phone, size_t max_content, size_t addr_len,
    113141    size_t max_prefix, size_t max_suffix)
    … …  
    133161}
    134162
     163/** Obtains the packet of the given content size.
     164 *
     165 * Contacts the packet server to return the appropriate packet.
     166 *
     167 * @param[in] phone     The packet server module phone.
     168 * @param[in] content   The maximal content length in bytes.
     169 * @returns             The packet reference.
     170 * @returns             NULL on error.
     171 */
    135172packet_t packet_get_1_remote(int phone, size_t content)
    136173{
    … …  
    154191}
    155192
     193/** Releases the packet queue.
     194 *
     195 * All packets in the queue are marked as free for use.
     196 * The packet queue may be one packet only.
     197 * The module should not use the packets after this point until they are
     198 * received or obtained again.
     199 *
     200 * @param[in] phone     The packet server module phone.
     201 * @param[in] packet_id The packet identifier.
     202 */
    156203void pq_release_remote(int phone, packet_id_t packet_id)
    157204{

  • uspace/lib/net/generic/socket_core.c

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup socket
    30  *  @{
     29/** @addtogroup libnet
     30 * @{
    3131 */
    3232
    3333/** @file
    34  *  Socket common core implementation.
    35  */
     34 * Socket common core implementation.
     35 */
     36
     37#include <socket_core.h>
     38#include <packet_client.h>
     39#include <packet_remote.h>
    3640
    3741#include <net/socket_codes.h>
    3842#include <net/in.h>
    3943#include <net/inet.h>
     44#include <net/packet.h>
     45#include <net/modules.h>
    4046
    4147#include <stdint.h>
    … …  
    4652#include <adt/dynamic_fifo.h>
    4753#include <adt/int_map.h>
    48 #include <net/packet.h>
    49 #include <packet_client.h>
    50 #include <packet_remote.h>
    51 #include <net/modules.h>
    52 #include <socket_core.h>
    53 
    54 /** Maximum number of random attempts to find a new socket identifier before switching to the sequence.
    55  */
    56 #define SOCKET_ID_TRIES                                 100
    57 
    58 /** Bound port sockets.
    59  */
    60 struct socket_port{
    61         /** The bound sockets map.
    62          */
     54
     55/**
     56 * Maximum number of random attempts to find a new socket identifier before
     57 * switching to the sequence.
     58 */
     59#define SOCKET_ID_TRIES 100
     60
     61/** Bound port sockets.*/
     62struct socket_port {
     63        /** The bound sockets map. */
    6364        socket_port_map_t map;
    64         /** The bound sockets count.
    65          */
     65        /** The bound sockets count. */
    6666        int count;
    6767};
    … …  
    7474
    7575/** Destroys the socket.
    76  *  If the socket is bound, the port is released.
    77  *  Releases all buffered packets, calls the release function and removes the socket from the local sockets.
    78  *  @param[in] packet_phone The packet server phone to release buffered packets.
    79  *  @param[in] socket The socket to be destroyed.
    80  *  @param[in,out] local_sockets The local sockets to be updated.
    81  *  @param[in,out] global_sockets The global sockets to be updated.
    82  *  @param[in] socket_release The client release callback function.
    83  */
    84 static void socket_destroy_core(int packet_phone, socket_core_ref socket, socket_cores_ref local_sockets, socket_ports_ref global_sockets, void (*socket_release)(socket_core_ref socket)){
     76 *
     77 * If the socket is bound, the port is released.
     78 * Releases all buffered packets, calls the release function and removes the
     79 * socket from the local sockets.
     80 *
     81 * @param[in] packet_phone The packet server phone to release buffered packets.
     82 * @param[in] socket    The socket to be destroyed.
     83 * @param[in,out] local_sockets The local sockets to be updated.
     84 * @param[in,out] global_sockets The global sockets to be updated.
     85 * @param[in] socket_release The client release callback function.
     86 */
     87static void
     88socket_destroy_core(int packet_phone, socket_core_ref socket,
     89    socket_cores_ref local_sockets, socket_ports_ref global_sockets,
     90    void (* socket_release)(socket_core_ref socket))
     91{
    8592        int packet_id;
    8693
    8794        // if bound
    88         if(socket->port){
     95        if (socket->port) {
    8996                // release the port
    9097                socket_port_release(global_sockets, socket);
    9198        }
     99       
    92100        // release all received packets
    93         while((packet_id = dyn_fifo_pop(&socket->received)) >= 0){
     101        while ((packet_id = dyn_fifo_pop(&socket->received)) >= 0)
    94102                pq_release_remote(packet_phone, packet_id);
    95         }
     103
    96104        dyn_fifo_destroy(&socket->received);
    97105        dyn_fifo_destroy(&socket->accepted);
    98         if(socket_release){
     106
     107        if (socket_release)
    99108                socket_release(socket);
    100         }
     109
    101110        socket_cores_exclude(local_sockets, socket->socket_id);
    102111}
    103112
    104 void socket_cores_release(int packet_phone, socket_cores_ref local_sockets, socket_ports_ref global_sockets, void (*socket_release)(socket_core_ref socket)){
    105         if(socket_cores_is_valid(local_sockets)){
    106                 int index;
    107 
    108                 local_sockets->magic = 0;
    109                 for(index = 0; index < local_sockets->next; ++ index){
    110                         if(socket_cores_item_is_valid(&(local_sockets->items[index]))){
    111                                 local_sockets->items[index].magic = 0;
    112                                 if(local_sockets->items[index].value){
    113                                         socket_destroy_core(packet_phone, local_sockets->items[index].value, local_sockets, global_sockets, socket_release);
    114                                         free(local_sockets->items[index].value);
    115                                         local_sockets->items[index].value = NULL;
    116                                 }
     113/** Destroys local sockets.
     114 *
     115 * Releases all buffered packets and calls the release function for each of the
     116 * sockets.
     117 *
     118 * @param[in] packet_phone The packet server phone to release buffered packets.
     119 * @param[in] local_sockets The local sockets to be destroyed.
     120 * @param[in,out] global_sockets The global sockets to be updated.
     121 * @param[in] socket_release The client release callback function.
     122 */
     123void
     124socket_cores_release(int packet_phone, socket_cores_ref local_sockets,
     125    socket_ports_ref global_sockets,
     126    void (* socket_release)(socket_core_ref socket))
     127{
     128        int index;
     129
     130        if (!socket_cores_is_valid(local_sockets))
     131                return;
     132
     133        local_sockets->magic = 0;
     134
     135        for (index = 0; index < local_sockets->next; ++index) {
     136                if (socket_cores_item_is_valid(&local_sockets->items[index])) {
     137                        local_sockets->items[index].magic = 0;
     138
     139                        if (local_sockets->items[index].value) {
     140                                socket_destroy_core(packet_phone,
     141                                    local_sockets->items[index].value,
     142                                    local_sockets, global_sockets,
     143                                    socket_release);
     144                                free(local_sockets->items[index].value);
     145                                local_sockets->items[index].value = NULL;
    117146                        }
    118147                }
    119                 free(local_sockets->items);
    120         }
     148        }
     149
     150        free(local_sockets->items);
    121151}
    122152
    123153/** Adds the socket to a socket port.
    124  *  @param[in,out] socket_port The socket port structure.
    125  *  @param[in] socket The socket to be added.
    126  *  @param[in] key The socket key identifier.
    127  *  @param[in] key_length The socket key length.
    128  *  @returns EOK on success.
    129  *  @returns ENOMEM if there is not enough memory left.
    130  */
    131 static int socket_port_add_core(socket_port_ref socket_port, socket_core_ref socket, const char * key, size_t key_length){
     154 *
     155 * @param[in,out] socket_port The socket port structure.
     156 * @param[in] socket    The socket to be added.
     157 * @param[in] key       The socket key identifier.
     158 * @param[in] key_length The socket key length.
     159 * @returns             EOK on success.
     160 * @returns             ENOMEM if there is not enough memory left.
     161 */
     162static int
     163socket_port_add_core(socket_port_ref socket_port, socket_core_ref socket,
     164    const char *key, size_t key_length)
     165{
    132166        ERROR_DECLARE;
    133167
    134         socket_core_ref * socket_ref;
     168        socket_core_ref *socket_ref;
    135169
    136170        // create a wrapper
    137171        socket_ref = malloc(sizeof(*socket_ref));
    138         if(! socket_ref){
     172        if (!socket_ref)
    139173                return ENOMEM;
    140         }
     174
    141175        *socket_ref = socket;
    142176        // add the wrapper
    143         if(ERROR_OCCURRED(socket_port_map_add(&socket_port->map, key, key_length, socket_ref))){
     177        if (ERROR_OCCURRED(socket_port_map_add(&socket_port->map, key,
     178            key_length, socket_ref))) {
    144179                free(socket_ref);
    145180                return ERROR_CODE;
    146181        }
    147         ++ socket_port->count;
     182       
     183        ++socket_port->count;
    148184        socket->key = key;
    149185        socket->key_length = key_length;
     186       
    150187        return EOK;
    151188}
    152189
    153190/** Binds the socket to the port.
    154  *  The SOCKET_MAP_KEY_LISTENING key identifier is used.
    155  *  @param[in] global_sockets The global sockets to be updated.
    156  *  @param[in] socket The socket to be added.
    157  *  @param[in] port The port number to be bound to.
    158  *  @returns EOK on success.
    159  *  @returns ENOMEM if there is not enough memory left.
    160  *  @returns Other error codes as defined for the socket_ports_add() function.
    161  */
    162 static int socket_bind_insert(socket_ports_ref global_sockets, socket_core_ref socket, int port){
     191 *
     192 * The SOCKET_MAP_KEY_LISTENING key identifier is used.
     193 *
     194 * @param[in] global_sockets The global sockets to be updated.
     195 * @param[in] socket    The socket to be added.
     196 * @param[in] port      The port number to be bound to.
     197 * @returns             EOK on success.
     198 * @returns             ENOMEM if there is not enough memory left.
     199 * @returns             Other error codes as defined for the
     200 *                       socket_ports_add() function.
     201 */
     202static int
     203socket_bind_insert(socket_ports_ref global_sockets, socket_core_ref socket,
     204    int port)
     205{
    163206        ERROR_DECLARE;
    164207
    … …  
    167210        // create a wrapper
    168211        socket_port = malloc(sizeof(*socket_port));
    169         if(! socket_port){
     212        if (!socket_port)
    170213                return ENOMEM;
    171         }
     214
    172215        socket_port->count = 0;
    173         if(ERROR_OCCURRED(socket_port_map_initialize(&socket_port->map))
    174                 || ERROR_OCCURRED(socket_port_add_core(socket_port, socket, SOCKET_MAP_KEY_LISTENING, 0))){
     216        if (ERROR_OCCURRED(socket_port_map_initialize(&socket_port->map)) ||
     217            ERROR_OCCURRED(socket_port_add_core(socket_port, socket,
     218            SOCKET_MAP_KEY_LISTENING, 0))) {
    175219                socket_port_map_destroy(&socket_port->map);
    176220                free(socket_port);
    177221                return ERROR_CODE;
    178222        }
     223       
    179224        // register the incomming port
    180225        ERROR_CODE = socket_ports_add(global_sockets, port, socket_port);
    181         if(ERROR_CODE < 0){
     226        if (ERROR_CODE < 0) {
    182227                socket_port_map_destroy(&socket_port->map);
    183228                free(socket_port);
    184229                return ERROR_CODE;
    185230        }
     231       
    186232        socket->port = port;
    187233        return EOK;
    188234}
    189235
    190 int socket_bind(socket_cores_ref local_sockets, socket_ports_ref global_sockets, int socket_id, void * addr, size_t addrlen, int free_ports_start, int free_ports_end, int last_used_port){
     236/** Binds the socket to the port.
     237 *
     238 * The address port is used if set, a free port is used if not.
     239 *
     240 * @param[in] local_sockets The local sockets to be searched.
     241 * @param[in,out] global_sockets The global sockets to be updated.
     242 * @param[in] socket_id The new socket identifier.
     243 * @param[in] addr      The address to be bound to.
     244 * @param[in] addrlen   The address length.
     245 * @param[in] free_ports_start The minimum free port.
     246 * @param[in] free_ports_end The maximum free port.
     247 * @param[in] last_used_port The last used free port.
     248 * @returns             EOK on success.
     249 * @returns             ENOTSOCK if the socket was not found.
     250 * @returns             EAFNOSUPPORT if the address family is not supported.
     251 * @returns             EADDRINUSE if the port is already in use.
     252 * @returns             Other error codes as defined for the
     253 *                      socket_bind_free_port() function.
     254 * @returns             Other error codes as defined for the
     255 *                      socket_bind_insert() function.
     256 */
     257int
     258socket_bind(socket_cores_ref local_sockets, socket_ports_ref global_sockets,
     259    int socket_id, void *addr, size_t addrlen, int free_ports_start,
     260    int free_ports_end, int last_used_port)
     261{
    191262        socket_core_ref socket;
    192263        socket_port_ref socket_port;
    193         struct sockaddr * address;
    194         struct sockaddr_in * address_in;
    195 
    196         if(addrlen < sizeof(struct sockaddr)){
     264        struct sockaddr *address;
     265        struct sockaddr_in *address_in;
     266
     267        if (addrlen < sizeof(struct sockaddr))
    197268                return EINVAL;
    198         }
     269
    199270        address = (struct sockaddr *) addr;
    200         switch(address->sa_family){
    201                 case AF_INET:
    202                         if(addrlen != sizeof(struct sockaddr_in)){
    203                                 return EINVAL;
    204                         }
    205                         address_in = (struct sockaddr_in *) addr;
    206                         // find the socket
    207                         socket = socket_cores_find(local_sockets, socket_id);
    208                         if(! socket){
    209                                 return ENOTSOCK;
    210                         }
    211                         // bind a free port?
    212                         if(address_in->sin_port <= 0){
    213                                 return socket_bind_free_port(global_sockets, socket, free_ports_start, free_ports_end, last_used_port);
    214                         }
    215                         // try to find the port
    216                         socket_port = socket_ports_find(global_sockets, ntohs(address_in->sin_port));
    217                         if(socket_port){
    218                                 // already used
    219                                 return EADDRINUSE;
    220                         }
    221                         // if bound
    222                         if(socket->port){
    223                                 // release the port
    224                                 socket_port_release(global_sockets, socket);
    225                         }
    226                         socket->port = -1;
    227                         return socket_bind_insert(global_sockets, socket, ntohs(address_in->sin_port));
    228                         break;
     271        switch (address->sa_family) {
     272        case AF_INET:
     273                if (addrlen != sizeof(struct sockaddr_in))
     274                        return EINVAL;
     275               
     276                address_in = (struct sockaddr_in *) addr;
     277                // find the socket
     278                socket = socket_cores_find(local_sockets, socket_id);
     279                if (!socket)
     280                        return ENOTSOCK;
     281               
     282                // bind a free port?
     283                if (address_in->sin_port <= 0)
     284                        return socket_bind_free_port(global_sockets, socket,
     285                             free_ports_start, free_ports_end, last_used_port);
     286               
     287                // try to find the port
     288                socket_port = socket_ports_find(global_sockets,
     289                    ntohs(address_in->sin_port));
     290                if (socket_port) {
     291                        // already used
     292                        return EADDRINUSE;
     293                }
     294               
     295                // if bound
     296                if (socket->port) {
     297                        // release the port
     298                        socket_port_release(global_sockets, socket);
     299                }
     300                socket->port = -1;
     301               
     302                return socket_bind_insert(global_sockets, socket,
     303                    ntohs(address_in->sin_port));
     304               
     305        case AF_INET6:
    229306                // TODO IPv6
    230         }
     307                break;
     308        }
     309       
    231310        return EAFNOSUPPORT;
    232311}
    233312
    234 int socket_bind_free_port(socket_ports_ref global_sockets, socket_core_ref socket, int free_ports_start, int free_ports_end, int last_used_port){
     313/** Binds the socket to a free port.
     314 *
     315 * The first free port is used.
     316 *
     317 * @param[in,out] global_sockets The global sockets to be updated.
     318 * @param[in,out] socket The socket to be bound.
     319 * @param[in] free_ports_start The minimum free port.
     320 * @param[in] free_ports_end The maximum free port.
     321 * @param[in] last_used_port The last used free port.
     322 * @returns             EOK on success.
     323 * @returns             ENOTCONN if no free port was found.
     324 * @returns             Other error codes as defined for the
     325 *                      socket_bind_insert() function.
     326 */
     327int
     328socket_bind_free_port(socket_ports_ref global_sockets, socket_core_ref socket,
     329    int free_ports_start, int free_ports_end, int last_used_port)
     330{
    235331        int index;
    236332
    237333        // from the last used one
    238334        index = last_used_port;
    239         do{
    240                 ++ index;
     335       
     336        do {
     337                ++index;
     338               
    241339                // til the range end
    242                 if(index >= free_ports_end){
     340                if (index >= free_ports_end) {
    243341                        // start from the range beginning
    244342                        index = free_ports_start - 1;
    245                         do{
    246                                 ++ index;
     343                        do {
     344                                ++index;
    247345                                // til the last used one
    248                                 if(index >= last_used_port){
     346                                if (index >= last_used_port) {
    249347                                        // none found
    250348                                        return ENOTCONN;
    251349                                }
    252                         }while(socket_ports_find(global_sockets, index) != NULL);
     350                        } while (socket_ports_find(global_sockets, index));
     351                       
    253352                        // found, break immediately
    254353                        break;
    255354                }
    256         }while(socket_ports_find(global_sockets, index) != NULL);
     355               
     356        } while (socket_ports_find(global_sockets, index));
     357       
    257358        return socket_bind_insert(global_sockets, socket, index);
    258359}
    259360
    260361/** Tries to find a new free socket identifier.
    261  *  @param[in] local_sockets The local sockets to be searched.
    262  *  @param[in] positive A value indicating whether a positive identifier is requested. A negative identifier is requested if set to false.
    263  *      @returns The new socket identifier.
    264  *  @returns ELIMIT if there is no socket identifier available.
    265  */
    266 static int socket_generate_new_id(socket_cores_ref local_sockets, int positive){
     362 *
     363 * @param[in] local_sockets The local sockets to be searched.
     364 * @param[in] positive  A value indicating whether a positive identifier is
     365 *                      requested. A negative identifier is requested if set to
     366 *                      false.
     367 * @returns             The new socket identifier.
     368 * @returns             ELIMIT if there is no socket identifier available.
     369 */
     370static int socket_generate_new_id(socket_cores_ref local_sockets, int positive)
     371{
    267372        int socket_id;
    268373        int count;
    … …  
    270375        count = 0;
    271376//      socket_id = socket_globals.last_id;
    272         do{
    273                 if(count < SOCKET_ID_TRIES){
     377        do {
     378                if (count < SOCKET_ID_TRIES) {
    274379                        socket_id = rand() % INT_MAX;
    275                         ++ count;
    276                 }else if(count == SOCKET_ID_TRIES){
     380                        ++count;
     381                } else if (count == SOCKET_ID_TRIES) {
    277382                        socket_id = 1;
    278                         ++ count;
     383                        ++count;
    279384                // only this branch for last_id
    280                 }else{
    281                         if(socket_id < INT_MAX){
     385                } else {
     386                        if (socket_id < INT_MAX) {
    282387                                ++ socket_id;
    283 /*                      }else if(socket_globals.last_id){
     388/*                      } else if(socket_globals.last_id) {
    284389*                               socket_globals.last_id = 0;
    285390*                               socket_id = 1;
    286 */                      }else{
     391*/                      } else {
    287392                                return ELIMIT;
    288393                        }
    289394                }
    290         }while(socket_cores_find(local_sockets, ((positive ? 1 : -1) * socket_id)));
     395        } while (socket_cores_find(local_sockets,
     396            ((positive ? 1 : -1) * socket_id)));
     397       
    291398//      last_id = socket_id
    292399        return socket_id;
    293400}
    294401
    295 int socket_create(socket_cores_ref local_sockets, int app_phone, void * specific_data, int * socket_id){
     402/** Creates a new socket.
     403 *
     404 * @param[in,out] local_sockets The local sockets to be updated.
     405 * @param[in] app_phone The application phone.
     406 * @param[in] specific_data The socket specific data.
     407 * @param[in,out] socket_id The new socket identifier. A new identifier is
     408 *                      chosen if set to zero or negative. A negative identifier
     409 *                      is chosen if set to negative.
     410 * @returns             EOK on success.
     411 * @returns             EINVAL if the socket_id parameter is NULL.
     412 * @returns             ENOMEM if there is not enough memory left.
     413 */
     414int
     415socket_create(socket_cores_ref local_sockets, int app_phone,
     416    void *specific_data, int *socket_id)
     417{
    296418        ERROR_DECLARE;
    297419
    … …  
    300422        int positive;
    301423
    302         if(! socket_id){
     424        if (!socket_id)
    303425                return EINVAL;
    304         }
     426       
    305427        // store the socket
    306         if(*socket_id <= 0){
     428        if (*socket_id <= 0) {
    307429                positive = (*socket_id == 0);
    308430                *socket_id = socket_generate_new_id(local_sockets, positive);
    309                 if(*socket_id <= 0){
    310                         return * socket_id;
    311                 }
    312                 if(! positive){
     431                if (*socket_id <= 0)
     432                        return *socket_id;
     433                if (!positive)
    313434                        *socket_id *= -1;
    314                 }
    315         }else if(socket_cores_find(local_sockets, * socket_id)){
     435        } else if(socket_cores_find(local_sockets, *socket_id)) {
    316436                return EEXIST;
    317437        }
     438       
    318439        socket = (socket_core_ref) malloc(sizeof(*socket));
    319         if(! socket){
     440        if (!socket)
    320441                return ENOMEM;
    321         }
     442       
    322443        // initialize
    323444        socket->phone = app_phone;
    … …  
    326447        socket->key_length = 0;
    327448        socket->specific_data = specific_data;
    328         if(ERROR_OCCURRED(dyn_fifo_initialize(&socket->received, SOCKET_INITIAL_RECEIVED_SIZE))){
     449        if (ERROR_OCCURRED(dyn_fifo_initialize(&socket->received,
     450            SOCKET_INITIAL_RECEIVED_SIZE))) {
    329451                free(socket);
    330452                return ERROR_CODE;
    331453        }
    332         if(ERROR_OCCURRED(dyn_fifo_initialize(&socket->accepted, SOCKET_INITIAL_ACCEPTED_SIZE))){
     454        if (ERROR_OCCURRED(dyn_fifo_initialize(&socket->accepted,
     455            SOCKET_INITIAL_ACCEPTED_SIZE))) {
    333456                dyn_fifo_destroy(&socket->received);
    334457                free(socket);
    335458                return ERROR_CODE;
    336459        }
    337         socket->socket_id = * socket_id;
     460        socket->socket_id = *socket_id;
    338461        res = socket_cores_add(local_sockets, socket->socket_id, socket);
    339         if(res < 0){
     462        if (res < 0) {
    340463                dyn_fifo_destroy(&socket->received);
    341464                dyn_fifo_destroy(&socket->accepted);
    … …  
    343466                return res;
    344467        }
     468       
    345469        return EOK;
    346470}
    347471
    348 int socket_destroy(int packet_phone, int socket_id, socket_cores_ref local_sockets, socket_ports_ref global_sockets, void (*socket_release)(socket_core_ref socket)){
     472/** Destroys the socket.
     473 *
     474 * If the socket is bound, the port is released.
     475 * Releases all buffered packets, calls the release function and removes the
     476 * socket from the local sockets.
     477 *
     478 * @param[in] packet_phone The packet server phone to release buffered packets.
     479 * @param[in] socket_id The socket identifier.
     480 * @param[in,out] local_sockets The local sockets to be updated.
     481 * @param[in,out] global_sockets The global sockets to be updated.
     482 * @param[in] socket_release The client release callback function.
     483 * @returns             EOK on success.
     484 * @returns             ENOTSOCK if the socket is not found.
     485 */
     486int
     487socket_destroy(int packet_phone, int socket_id, socket_cores_ref local_sockets,
     488    socket_ports_ref global_sockets,
     489    void (*socket_release)(socket_core_ref socket))
     490{
    349491        socket_core_ref socket;
    350492        int accepted_id;
    … …  
    352494        // find the socket
    353495        socket = socket_cores_find(local_sockets, socket_id);
    354         if(! socket){
     496        if (!socket)
    355497                return ENOTSOCK;
    356         }
     498       
    357499        // destroy all accepted sockets
    358         while((accepted_id = dyn_fifo_pop(&socket->accepted)) >= 0){
    359                 socket_destroy(packet_phone, accepted_id, local_sockets, global_sockets, socket_release);
    360         }
    361         socket_destroy_core(packet_phone, socket, local_sockets, global_sockets, socket_release);
     500        while ((accepted_id = dyn_fifo_pop(&socket->accepted)) >= 0)
     501                socket_destroy(packet_phone, accepted_id, local_sockets,
     502                    global_sockets, socket_release);
     503       
     504        socket_destroy_core(packet_phone, socket, local_sockets, global_sockets,
     505            socket_release);
     506       
    362507        return EOK;
    363508}
    364509
    365 int socket_reply_packets(packet_t packet, size_t * length){
     510/** Replies the packet or the packet queue data to the application via the
     511 * socket.
     512 *
     513 * Uses the current message processing fibril.
     514 *
     515 * @param[in] packet    The packet to be transfered.
     516 * @param[out] length   The total data length.
     517 * @returns             EOK on success.
     518 * @returns             EBADMEM if the length parameter is NULL.
     519 * @returns             ENOMEM if there is not enough memory left.
     520 * @returns             Other error codes as defined for the data_reply()
     521 *                      function.
     522 */
     523int socket_reply_packets(packet_t packet, size_t *length)
     524{
    366525        ERROR_DECLARE;
    367526
    368527        packet_t next_packet;
    369528        size_t fragments;
    370         size_t * lengths;
     529        size_t *lengths;
    371530        size_t index;
    372531
    373         if(! length){
     532        if (!length)
    374533                return EBADMEM;
    375         }
     534
    376535        next_packet = pq_next(packet);
    377         if(! next_packet){
     536        if (!next_packet) {
    378537                // write all if only one fragment
    379                 ERROR_PROPAGATE(data_reply(packet_get_data(packet), packet_get_data_length(packet)));
     538                ERROR_PROPAGATE(data_reply(packet_get_data(packet),
     539                    packet_get_data_length(packet)));
    380540                // store the total length
    381541                *length = packet_get_data_length(packet);
    382         }else{
     542        } else {
    383543                // count the packet fragments
    384544                fragments = 1;
    385545                next_packet = pq_next(packet);
    386                 while((next_packet = pq_next(next_packet))){
    387                         ++ fragments;
    388                 }
     546                while ((next_packet = pq_next(next_packet)))
     547                        ++fragments;
     548               
    389549                // compute and store the fragment lengths
    390                 lengths = (size_t *) malloc(sizeof(size_t) * fragments + sizeof(size_t));
    391                 if(! lengths){
     550                lengths = (size_t *) malloc(sizeof(size_t) * fragments +
     551                    sizeof(size_t));
     552                if (!lengths)
    392553                        return ENOMEM;
    393                 }
     554               
    394555                lengths[0] = packet_get_data_length(packet);
    395556                lengths[fragments] = lengths[0];
    396557                next_packet = pq_next(packet);
    397                 for(index = 1; index < fragments; ++ index){
     558               
     559                for (index = 1; index < fragments; ++index) {
    398560                        lengths[index] = packet_get_data_length(next_packet);
    399561                        lengths[fragments] += lengths[index];
    400562                        next_packet = pq_next(packet);
    401                 }while(next_packet);
     563                }
     564               
    402565                // write the fragment lengths
    403                 ERROR_PROPAGATE(data_reply(lengths, sizeof(int) * (fragments + 1)));
     566                if (ERROR_OCCURRED(data_reply(lengths,
     567                    sizeof(int) * (fragments + 1)))) {
     568                        free(lengths);
     569                        return ERROR_CODE;
     570                }
    404571                next_packet = packet;
     572               
    405573                // write the fragments
    406                 for(index = 0; index < fragments; ++ index){
    407                         ERROR_PROPAGATE(data_reply(packet_get_data(next_packet), lengths[index]));
     574                for (index = 0; index < fragments; ++index) {
     575                        ERROR_CODE = data_reply(packet_get_data(next_packet),
     576                            lengths[index]);
     577                        if (ERROR_OCCURRED(ERROR_CODE)) {
     578                                free(lengths);
     579                                return ERROR_CODE;
     580                        }
    408581                        next_packet = pq_next(next_packet);
    409                 }while(next_packet);
     582                }
     583               
    410584                // store the total length
    411585                *length = lengths[fragments];
    412586                free(lengths);
    413587        }
     588       
    414589        return EOK;
    415590}
    416591
    417 socket_core_ref socket_port_find(socket_ports_ref global_sockets, int port, const char * key, size_t key_length){
     592/** Finds the bound port socket.
     593 *
     594 * @param[in] global_sockets The global sockets to be searched.
     595 * @param[in] port      The port number.
     596 * @param[in] key       The socket key identifier.
     597 * @param[in] key_length The socket key length.
     598 * @returns             The found socket.
     599 * @returns             NULL if no socket was found.
     600 */
     601socket_core_ref
     602socket_port_find(socket_ports_ref global_sockets, int port, const char *key,
     603    size_t key_length)
     604{
    418605        socket_port_ref socket_port;
    419         socket_core_ref * socket_ref;
     606        socket_core_ref *socket_ref;
    420607
    421608        socket_port = socket_ports_find(global_sockets, port);
    422         if(socket_port && (socket_port->count > 0)){
    423                 socket_ref = socket_port_map_find(&socket_port->map, key, key_length);
    424                 if(socket_ref){
    425                         return * socket_ref;
    426                 }
    427         }
     609        if (socket_port && (socket_port->count > 0)) {
     610                socket_ref = socket_port_map_find(&socket_port->map, key,
     611                    key_length);
     612                if (socket_ref)
     613                        return *socket_ref;
     614        }
     615       
    428616        return NULL;
    429617}
    430618
    431 void socket_port_release(socket_ports_ref global_sockets, socket_core_ref socket){
     619/** Releases the socket port.
     620 *
     621 * If the socket is bound the port entry is released.
     622 * If there are no more port entries the port is release.
     623 *
     624 * @param[in] global_sockets The global sockets to be updated.
     625 * @param[in] socket    The socket to be unbound.
     626 */
     627void
     628socket_port_release(socket_ports_ref global_sockets, socket_core_ref socket)
     629{
    432630        socket_port_ref socket_port;
    433         socket_core_ref * socket_ref;
    434 
    435         if(socket->port){
    436                 // find ports
    437                 socket_port = socket_ports_find(global_sockets, socket->port);
    438                 if(socket_port){
    439                         // find the socket
    440                         socket_ref = socket_port_map_find(&socket_port->map, socket->key, socket->key_length);
    441                         if(socket_ref){
    442                                 -- socket_port->count;
    443                                 // release if empty
    444                                 if(socket_port->count <= 0){
    445                                         // destroy the map
    446                                         socket_port_map_destroy(&socket_port->map);
    447                                         // release the port
    448                                         socket_ports_exclude(global_sockets, socket->port);
    449                                 }else{
    450                                         // remove
    451                                         socket_port_map_exclude(&socket_port->map, socket->key, socket->key_length);
    452                                 }
     631        socket_core_ref *socket_ref;
     632
     633        if (!socket->port)
     634                return;
     635       
     636        // find ports
     637        socket_port = socket_ports_find(global_sockets, socket->port);
     638        if (socket_port) {
     639                // find the socket
     640                socket_ref = socket_port_map_find(&socket_port->map,
     641                    socket->key, socket->key_length);
     642               
     643                if (socket_ref) {
     644                        --socket_port->count;
     645                       
     646                        // release if empty
     647                        if (socket_port->count <= 0) {
     648                                // destroy the map
     649                                socket_port_map_destroy(&socket_port->map);
     650                                // release the port
     651                                socket_ports_exclude(global_sockets,
     652                                    socket->port);
     653                        } else {
     654                                // remove
     655                                socket_port_map_exclude(&socket_port->map,
     656                                    socket->key, socket->key_length);
    453657                        }
    454658                }
    455                 socket->port = 0;
    456                 socket->key = NULL;
    457                 socket->key_length = 0;
    458         }
    459 }
    460 
    461 int socket_port_add(socket_ports_ref global_sockets, int port, socket_core_ref socket, const char * key, size_t key_length){
     659        }
     660       
     661        socket->port = 0;
     662        socket->key = NULL;
     663        socket->key_length = 0;
     664}
     665
     666/** Adds the socket to an already bound port.
     667 *
     668 * @param[in] global_sockets The global sockets to be updated.
     669 * @param[in] port      The port number to be bound to.
     670 * @param[in] socket    The socket to be added.
     671 * @param[in] key       The socket key identifier.
     672 * @param[in] key_length The socket key length.
     673 * @returns             EOK on success.
     674 * @returns             ENOENT if the port is not already used.
     675 * @returns             Other error codes as defined for the
     676 *                      socket_port_add_core() function.
     677 */
     678int
     679socket_port_add(socket_ports_ref global_sockets, int port,
     680    socket_core_ref socket, const char *key, size_t key_length)
     681{
    462682        ERROR_DECLARE;
    463683
    … …  
    466686        // find ports
    467687        socket_port = socket_ports_find(global_sockets, port);
    468         if(! socket_port){
     688        if (!socket_port)
    469689                return ENOENT;
    470         }
     690       
    471691        // add the socket
    472         ERROR_PROPAGATE(socket_port_add_core(socket_port, socket, key, key_length));
     692        ERROR_PROPAGATE(socket_port_add_core(socket_port, socket, key,
     693            key_length));
     694       
    473695        socket->port = port;
    474696        return EOK;

  • uspace/lib/net/il/arp_remote.c

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup arp
    30  *  @{
     29/** @addtogroup libnet
     30 * @{
    3131 */
    3232
    3333/** @file
    34  *  ARP interface implementation for remote modules.
    35  *  @see arp_interface.h
     34 * ARP interface implementation for remote modules.
     35 * @see arp_interface.h
    3636 */
    3737
    3838#include <arp_interface.h>
    39 #include <arp_messages.h>
    4039#include <generic.h>
    4140
    … …  
    4443#include <ipc/ipc.h>
    4544#include <ipc/services.h>
     45#include <ipc/arp.h>
    4646
    4747#include <net/modules.h>
    … …  
    4949#include <adt/measured_strings.h>
    5050
    51 int arp_connect_module(services_t service){
    52         if(service != SERVICE_ARP){
     51/** Connects to the ARP module.
     52 *
     53 * @param service       The ARP module service. Ignored parameter.
     54 * @returns             The ARP module phone on success.
     55 */
     56int arp_connect_module(services_t service)
     57{
     58        if (service != SERVICE_ARP)
    5359                return EINVAL;
    54         }
     60
    5561        return connect_to_service(SERVICE_ARP);
    5662}
    5763
    58 int arp_clean_cache_req(int arp_phone){
     64/** Cleans the cache.
     65 *
     66 * @param[in] arp_phone The ARP module phone used for (semi)remote calls.
     67 * @returns             EOK on success.
     68 */
     69int arp_clean_cache_req(int arp_phone)
     70{
    5971        return (int) async_req_0_0(arp_phone, NET_ARP_CLEAN_CACHE);
    6072}
    6173
    62 int arp_clear_address_req(int arp_phone, device_id_t device_id, services_t protocol, measured_string_ref address){
     74/** Clears the given protocol address from the cache.
     75 *
     76 * @param[in] arp_phone The ARP module phone used for (semi)remote calls.
     77 * @param[in] device_id The device identifier.
     78 * @param[in] protocol  The requesting protocol service.
     79 * @param[in] address   The protocol address to be cleared.
     80 * @returns             EOK on success.
     81 * @returns             ENOENT if the mapping is not found.
     82 */
     83int
     84arp_clear_address_req(int arp_phone, device_id_t device_id, services_t protocol,
     85    measured_string_ref address)
     86{
    6387        aid_t message_id;
    6488        ipcarg_t result;
    6589
    66         message_id = async_send_2(arp_phone, NET_ARP_CLEAR_ADDRESS, (ipcarg_t) device_id, protocol, NULL);
     90        message_id = async_send_2(arp_phone, NET_ARP_CLEAR_ADDRESS,
     91            (ipcarg_t) device_id, protocol, NULL);
    6792        measured_strings_send(arp_phone, address, 1);
    6893        async_wait_for(message_id, &result);
     94
    6995        return (int) result;
    7096}
    7197
    72 int arp_clear_device_req(int arp_phone, device_id_t device_id){
    73         return (int) async_req_1_0(arp_phone, NET_ARP_CLEAR_DEVICE, (ipcarg_t) device_id);
     98/** Clears the device cache.
     99 *
     100 * @param[in] arp_phone The ARP module phone used for (semi)remote calls.
     101 * @param[in] device_id The device identifier.
     102 * @returns             EOK on success.
     103 * @returns             ENOENT if the device is not found.
     104 */
     105int arp_clear_device_req(int arp_phone, device_id_t device_id)
     106{
     107        return (int) async_req_1_0(arp_phone, NET_ARP_CLEAR_DEVICE,
     108            (ipcarg_t) device_id);
    74109}
    75110
    76 int arp_device_req(int arp_phone, device_id_t device_id, services_t protocol, services_t netif, measured_string_ref address){
     111/** Registers the new device and the requesting protocol service.
     112 *
     113 * Connects to the network interface layer service.
     114 * Determines the device broadcast address, its address lengths and packet size.
     115 *
     116 * @param[in] arp_phone The ARP module phone used for (semi)remote calls.
     117 * @param[in] device_id The new device identifier.
     118 * @param[in] protocol  The requesting protocol service.
     119 * @param[in] netif     The underlying device network interface layer service.
     120 * @param[in] address   The local requesting protocol address of the device.
     121 * @returns             EOK on success.
     122 * @returns             EEXIST if the device is already used.
     123 * @returns             ENOMEM if there is not enough memory left.
     124 * @returns             ENOENT if the network interface service is not known.
     125 * @returns             EREFUSED if the network interface service is not
     126 *                      responding.
     127 * @returns             Other error codes as defined for the
     128 *                      nil_packet_get_size() function.
     129 * @returns             Other error codes as defined for the nil_get_addr()
     130 *                      function.
     131 * @returns             Other error codes as defined for the
     132 *                      nil_get_broadcast_addr() function.
     133 */
     134int arp_device_req(int arp_phone, device_id_t device_id, services_t protocol,
     135    services_t netif, measured_string_ref address)
     136{
    77137        aid_t message_id;
    78138        ipcarg_t result;
    79139
    80         message_id = async_send_3(arp_phone, NET_ARP_DEVICE, (ipcarg_t) device_id, protocol, netif, NULL);
     140        message_id = async_send_3(arp_phone, NET_ARP_DEVICE,
     141            (ipcarg_t) device_id, protocol, netif, NULL);
    81142        measured_strings_send(arp_phone, address, 1);
    82143        async_wait_for(message_id, &result);
     144
    83145        return (int) result;
    84146}
    85147
    86 task_id_t arp_task_get_id(void){
    87         return 0;
    88 }
    89 
    90 int arp_translate_req(int arp_phone, device_id_t device_id, services_t protocol, measured_string_ref address, measured_string_ref * translation, char ** data){
    91         return generic_translate_req(arp_phone, NET_ARP_TRANSLATE, device_id, protocol, address, 1, translation, data);
     148/** Translates the given protocol address to the network interface address.
     149 *
     150 * Broadcasts the ARP request if the mapping is not found.
     151 * Allocates and returns the needed memory block as the data parameter.
     152 *
     153 * @param[in] arp_phone The ARP module phone used for (semi)remote calls.
     154 * @param[in] device_id The device identifier.
     155 * @param[in] protocol  The requesting protocol service.
     156 * @param[in] address   The local requesting protocol address.
     157 * @param[out] translation The translation of the local protocol address.
     158 * @param[out] data     The allocated raw translation data container.
     159 * @returns             EOK on success.
     160 * @returns             EINVAL if the address parameter is NULL.
     161 * @returns             EBADMEM if the translation or the data parameters are
     162 *                      NULL.
     163 * @returns             ENOENT if the mapping is not found.
     164 */
     165int
     166arp_translate_req(int arp_phone, device_id_t device_id, services_t protocol,
     167    measured_string_ref address, measured_string_ref *translation, char **data)
     168{
     169        return generic_translate_req(arp_phone, NET_ARP_TRANSLATE, device_id,
     170            protocol, address, 1, translation, data);
    92171}
    93172

  • uspace/lib/net/il/ip_client.c

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup ip
    30  *  @{
     29/** @addtogroup libnet
     30 * @{
    3131 */
    3232
    3333/** @file
    34  *  IP client interface implementation.
    35  *  @see ip_client.h
     34 * IP client interface implementation.
     35 * @see ip_client.h
    3636 */
    3737
    … …  
    4545#include <net/packet.h>
    4646
    47 size_t ip_client_header_length(packet_t packet){
     47/** Returns the IP header length.
     48 *
     49 * @param[in] packet    The packet.
     50 * @returns             The IP header length in bytes.
     51 * @returns             Zero if there is no IP header.
     52 */
     53size_t ip_client_header_length(packet_t packet)
     54{
    4855        ip_header_ref header;
    4956
    5057        header = (ip_header_ref) packet_get_data(packet);
    51         if((! header)
    52                 || (packet_get_data_length(packet) < sizeof(ip_header_t))){
     58        if (!header || (packet_get_data_length(packet) < sizeof(ip_header_t)))
    5359                return 0;
    54         }
     60
    5561        return IP_HEADER_LENGTH(header);
    5662}
    5763
    58 int ip_client_get_pseudo_header(ip_protocol_t protocol, struct sockaddr * src, socklen_t srclen, struct sockaddr * dest, socklen_t destlen, size_t data_length, void **header, size_t * headerlen){
     64/** Constructs the IPv4 pseudo header.
     65 *
     66 * @param[in] protocol  The transport protocol.
     67 * @param[in] src       The source address.
     68 * @param[in] srclen    The source address length.
     69 * @param[in] dest      The destination address.
     70 * @param[in] destlen   The destination address length.
     71 * @param[in] data_length The data length to be set.
     72 * @param[out] header   The constructed IPv4 pseudo header.
     73 * @param[out] headerlen The length of the IP pseudo header in bytes.
     74 * @returns             EOK on success.
     75 * @returns             EBADMEM if the header and/or the headerlen parameter is
     76 *                      NULL.
     77 * @returns             EINVAL if the source address and/or the destination
     78 *                      address parameter is NULL.
     79 * @returns             EINVAL if the source address length is less than struct
     80 *                      sockaddr length.
     81 * @returns             EINVAL if the source address length differs from the
     82 *                      destination address length.
     83 * @returns             EINVAL if the source address family differs from the
     84 *                      destination family.
     85 * @returns             EAFNOSUPPORT if the address family is not supported.
     86 * @returns             ENOMEM if there is not enough memory left.
     87 */
     88int
     89ip_client_get_pseudo_header(ip_protocol_t protocol, struct sockaddr *src,
     90    socklen_t srclen, struct sockaddr *dest, socklen_t destlen,
     91    size_t data_length, void **header, size_t *headerlen)
     92{
    5993        ipv4_pseudo_header_ref header_in;
    60         struct sockaddr_in * address_in;
    61 
    62         if(!(header && headerlen)){
     94        struct sockaddr_in *address_in;
     95
     96        if (!header || !headerlen)
    6397                return EBADMEM;
    64         }
    65         if(!(src && dest && (srclen > 0) && ((size_t) srclen >= sizeof(struct sockaddr)) && (srclen == destlen) && (src->sa_family == dest->sa_family))){
     98
     99        if (!src || !dest || srclen <= 0 ||
     100            (((size_t) srclen < sizeof(struct sockaddr))) ||
     101            (srclen != destlen) || (src->sa_family != dest->sa_family)) {
    66102                return EINVAL;
    67103        }
    68104
    69         switch(src->sa_family){
    70                 case AF_INET:
    71                         if(srclen != sizeof(struct sockaddr_in)){
    72                                 return EINVAL;
    73                         }
    74                         *headerlen = sizeof(*header_in);
    75                         header_in = (ipv4_pseudo_header_ref) malloc(*headerlen);
    76                         if(! header_in){
    77                                 return ENOMEM;
    78                         }
    79                         bzero(header_in, * headerlen);
    80                         address_in = (struct sockaddr_in *) dest;
    81                         header_in->destination_address = address_in->sin_addr.s_addr;
    82                         address_in = (struct sockaddr_in *) src;
    83                         header_in->source_address = address_in->sin_addr.s_addr;
    84                         header_in->protocol = protocol;
    85                         header_in->data_length = htons(data_length);
    86                         *header = header_in;
    87                         return EOK;
    88                 // TODO IPv6
    89 /*              case AF_INET6:
    90                         if(addrlen != sizeof(struct sockaddr_in6)){
    91                                 return EINVAL;
    92                         }
    93                         address_in6 = (struct sockaddr_in6 *) addr;
    94                         return EOK;
    95 */              default:
    96                         return EAFNOSUPPORT;
    97         }
    98 }
    99 
    100 int ip_client_prepare_packet(packet_t packet, ip_protocol_t protocol, ip_ttl_t ttl, ip_tos_t tos, int dont_fragment, size_t ipopt_length){
     105        switch (src->sa_family) {
     106        case AF_INET:
     107                if (srclen != sizeof(struct sockaddr_in))
     108                        return EINVAL;
     109               
     110                *headerlen = sizeof(*header_in);
     111                header_in = (ipv4_pseudo_header_ref) malloc(*headerlen);
     112                if (!header_in)
     113                        return ENOMEM;
     114
     115                bzero(header_in, *headerlen);
     116                address_in = (struct sockaddr_in *) dest;
     117                header_in->destination_address = address_in->sin_addr.s_addr;
     118                address_in = (struct sockaddr_in *) src;
     119                header_in->source_address = address_in->sin_addr.s_addr;
     120                header_in->protocol = protocol;
     121                header_in->data_length = htons(data_length);
     122                *header = header_in;
     123                return EOK;
     124
     125        // TODO IPv6
     126/*      case AF_INET6:
     127                if (addrlen != sizeof(struct sockaddr_in6))
     128                        return EINVAL;
     129
     130                address_in6 = (struct sockaddr_in6 *) addr;
     131                return EOK;
     132*/
     133
     134        default:
     135                return EAFNOSUPPORT;
     136        }
     137}
     138
     139/** Prepares the packet to be transfered via IP.
     140 *
     141 * The IP header is prefixed.
     142 *
     143 * @param[in,out] packet The packet to be prepared.
     144 * @param[in] protocol  The transport protocol.
     145 * @param[in] ttl       The time to live counter. The IPDEFTTL is set if zero.
     146 * @param[in] tos       The type of service.
     147 * @param[in] dont_fragment The value indicating whether fragmentation is
     148 *                      disabled.
     149 * @param[in] ipopt_length The prefixed IP options length in bytes.
     150 * @returns             EOK on success.
     151 * @returns             ENOMEM if there is not enough memory left in the packet.
     152 */
     153int
     154ip_client_prepare_packet(packet_t packet, ip_protocol_t protocol, ip_ttl_t ttl,
     155    ip_tos_t tos, int dont_fragment, size_t ipopt_length)
     156{
    101157        ip_header_ref header;
    102         uint8_t * data;
     158        uint8_t *data;
    103159        size_t padding;
    104160
    … …  
    106162        // multiple of 4 bytes
    107163        padding =  ipopt_length % 4;
    108         if(padding){
     164        if (padding) {
    109165                padding = 4 - padding;
    110166                ipopt_length += padding;
    … …  
    113169        // prefix the header
    114170        data = (uint8_t *) packet_prefix(packet, sizeof(ip_header_t) + padding);
    115         if(! data){
     171        if (!data)
    116172                return ENOMEM;
    117         }
    118173
    119174        // add the padding
    120         while(padding --){
     175        while (padding--)
    121176                data[sizeof(ip_header_t) + padding] = IPOPT_NOOP;
    122         }
    123177
    124178        // set the header
    125179        header = (ip_header_ref) data;
    126         header->header_length = IP_COMPUTE_HEADER_LENGTH(sizeof(ip_header_t) + ipopt_length);
    127         header->ttl = (ttl ? ttl : IPDEFTTL); //(((ttl) <= MAXTTL) ? ttl : MAXTTL) : IPDEFTTL;
     180        header->header_length = IP_COMPUTE_HEADER_LENGTH(sizeof(ip_header_t) +
     181            ipopt_length);
     182        header->ttl = (ttl ? ttl : IPDEFTTL);
    128183        header->tos = tos;
    129184        header->protocol = protocol;
    130185
    131         if(dont_fragment){
     186        if (dont_fragment)
    132187                header->flags = IPFLAG_DONT_FRAGMENT;
    133         }
     188
    134189        return EOK;
    135190}
    136191
    137 int ip_client_process_packet(packet_t packet, ip_protocol_t * protocol, ip_ttl_t * ttl, ip_tos_t * tos, int * dont_fragment, size_t * ipopt_length){
     192/** Processes the received IP packet.
     193 *
     194 * Fills set header fields.
     195 * Returns the prefixed IP header length.
     196 *
     197 * @param[in] packet    The received packet.
     198 * @param[out] protocol The transport protocol. May be NULL if not desired.
     199 * @param[out] ttl      The time to live counter. May be NULL if not desired.
     200 * @param[out] tos      The type of service. May be NULL if not desired.
     201 * @param[out] dont_fragment The value indicating whether the fragmentation is
     202 *                      disabled. May be NULL if not desired.
     203 * @param[out] ipopt_length The IP options length in bytes. May be NULL if not
     204 *                      desired.
     205 * @returns             The prefixed IP header length in bytes on success.
     206 * @returns             ENOMEM if the packet is too short to contain the IP
     207 *                      header.
     208 */
     209int
     210ip_client_process_packet(packet_t packet, ip_protocol_t *protocol,
     211    ip_ttl_t *ttl, ip_tos_t *tos, int *dont_fragment, size_t *ipopt_length)
     212{
    138213        ip_header_ref header;
    139214
    140215        header = (ip_header_ref) packet_get_data(packet);
    141         if((! header)
    142                 || (packet_get_data_length(packet) < sizeof(ip_header_t))){
     216        if (!header || (packet_get_data_length(packet) < sizeof(ip_header_t)))
    143217                return ENOMEM;
    144         }
    145 
    146         if(protocol){
     218
     219        if (protocol)
    147220                *protocol = header->protocol;
    148         }
    149         if(ttl){
     221        if (ttl)
    150222                *ttl = header->ttl;
    151         }
    152         if(tos){
     223        if (tos)
    153224                *tos = header->tos;
    154         }
    155         if(dont_fragment){
    156                 *dont_fragment = header->flags &IPFLAG_DONT_FRAGMENT;
    157         }
    158         if(ipopt_length){
     225        if (dont_fragment)
     226                *dont_fragment = header->flags & IPFLAG_DONT_FRAGMENT;
     227        if (ipopt_length) {
    159228                *ipopt_length = IP_HEADER_LENGTH(header) - sizeof(ip_header_t);
    160229                return sizeof(ip_header_t);
    161         }else{
     230        } else {
    162231                return IP_HEADER_LENGTH(header);
    163232        }
    164233}
    165234
    166 int ip_client_set_pseudo_header_data_length(void *header, size_t headerlen, size_t data_length){
     235/** Updates the IPv4 pseudo header data length field.
     236 *
     237 * @param[in,out] header The IPv4 pseudo header to be updated.
     238 * @param[in] headerlen The length of the IP pseudo header in bytes.
     239 * @param[in] data_length The data length to be set.
     240 * @returns             EOK on success.
     241 * @returns             EBADMEM if the header parameter is NULL.
     242 * @returns             EINVAL if the headerlen parameter is not IPv4 pseudo
     243 *                      header length.
     244 */
     245int
     246ip_client_set_pseudo_header_data_length(void *header, size_t headerlen,
     247    size_t data_length)
     248{
    167249        ipv4_pseudo_header_ref header_in;
    168250
    169         if(! header){
     251        if (!header)
    170252                return EBADMEM;
    171         }
    172 
    173         if(headerlen == sizeof(ipv4_pseudo_header_t)){
     253
     254        if (headerlen == sizeof(ipv4_pseudo_header_t)) {
    174255                header_in = (ipv4_pseudo_header_ref) header;
    175256                header_in->data_length = htons(data_length);
    176257                return EOK;
    177258        // TODO IPv6
    178         }else{
     259        } else {
    179260                return EINVAL;
    180261        }

  • uspace/lib/net/il/ip_remote.c

    ref689ef0 ra7a85d16  
    4242#include <ip_remote.h>
    4343#include <ip_interface.h>
    44 #include <ip_messages.h>
    45 #include <il_messages.h>
    4644#include <packet_client.h>
    4745#include <generic.h>
    4846
    4947#include <ipc/services.h>
     48#include <ipc/il.h>
     49#include <ipc/ip.h>
    5050
    5151#include <net/modules.h>

  • uspace/lib/net/include/adt/module_map.h

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup net
    30  *  @{
     29/** @addtogroup libnet
     30 * @{
    3131 */
    3232
    3333/** @file
    34  *  Character string to module map.
     34 * Character string to module map.
    3535 */
    3636
    37 #ifndef __NET_MODULES_MAP_H__
    38 #define __NET_MODULES_MAP_H__
     37#ifndef LIBNET_MODULES_MAP_H_
     38#define LIBNET_MODULES_MAP_H_
    3939
    4040#include <task.h>
    41 
    4241#include <ipc/services.h>
    43 
    4442#include <net/modules.h>
    45 
    4643#include <adt/generic_char_map.h>
    4744
    4845/** Type definition of the module structure.
    49  *  @see module_struct
     46 * @see module_struct
    5047 */
    51 typedef struct module_struct    module_t;
     48typedef struct module_struct module_t;
    5249
    5350/** Type definition of the module structure pointer.
    54  *  @see module_struct
     51 * @see module_struct
    5552 */
    56 typedef module_t *                              module_ref;
     53typedef module_t *module_ref;
    5754
    5855/** Module map.
    59  *  Sorted by module names.
    60  *  @see generic_char_map.h
     56 * Sorted by module names.
     57 * @see generic_char_map.h
    6158 */
    6259GENERIC_CHAR_MAP_DECLARE(modules, module_t)
    6360
    64 /** Module structure.
    65  */
    66 struct  module_struct{
    67         /** Module task identifier if running.
    68          */
     61/** Module structure. */
     62struct module_struct {
     63        /** Module task identifier if running. */
    6964        task_id_t task_id;
    70         /** Module service identifier.
    71          */
     65        /** Module service identifier. */
    7266        services_t service;
    73         /** Module phone if running and connected.
    74          */
     67        /** Module phone if running and connected. */
    7568        int phone;
    76         /** Usage counter.
    77          */
     69        /** Usage counter. */
    7870        int usage;
    79         /** Module name.
    80          */
    81         const char * name;
    82         /** Module full path filename.
    83          */
    84         const char * filename;
    85         /** Connecting function.
    86          */
    87         connect_module_t * connect_module;
     71        /** Module name. */
     72        const char *name;
     73        /** Module full path filename. */
     74        const char *filename;
     75        /** Connecting function. */
     76        connect_module_t *connect_module;
    8877};
    8978
    90 /** Adds module to the module map.
    91  *  @param[out] module The module structure added.
    92  *  @param[in] modules The module map.
    93  *  @param[in] name The module name.
    94  *  @param[in] filename The full path filename.
    95  *  @param[in] service The module service.
    96  *  @param[in] task_id The module current task identifier. Zero (0) means not running.
    97  *  @param[in] connect_module The module connecting function.
    98  *  @returns EOK on success.
    99  *  @returns ENOMEM if there is not enough memory left.
    100  */
    101 int add_module(module_ref * module, modules_ref modules, const char * name, const char * filename, services_t service, task_id_t task_id, connect_module_t * connect_module);
    102 
    103 /** Searches and returns the specified module.
    104  *  If the module is not running, the module filaname is spawned.
    105  *  If the module is not connected, the connect_function is called.
    106  *  @param[in] modules The module map.
    107  *  @param[in] name The module name.
    108  *  @returns The running module found. It does not have to be connected.
    109  *  @returns NULL if there is no such module.
    110  */
    111 module_ref get_running_module(modules_ref modules, char * name);
    112 
    113 /** Starts the given module.
    114  *  @param[in] fname The module full or relative path filename.
    115  *  @returns The new module task identifier on success.
    116  *  @returns 0 if there is no such module.
    117  */
    118 task_id_t spawn(const char * fname);
     79extern int add_module(module_ref *, modules_ref, const char *, const char *,
     80    services_t, task_id_t, connect_module_t *);
     81extern module_ref get_running_module(modules_ref, char *);
     82extern task_id_t spawn(const char *);
    11983
    12084#endif

  • uspace/lib/net/include/arp_interface.h

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup arp
    30  *  @{
     29/** @addtogroup libnet
     30 * @{
    3131 */
    3232
    33 #ifndef __NET_ARP_INTERFACE_H__
    34 #define __NET_ARP_INTERFACE_H__
     33#ifndef LIBNET_ARP_INTERFACE_H_
     34#define LIBNET_ARP_INTERFACE_H_
    3535
    3636#include <adt/measured_strings.h>
    … …  
    4343
    4444/** @name ARP module interface
    45  *  This interface is used by other modules.
     45 * This interface is used by other modules.
    4646 */
    4747/*@{*/
    4848
    49 /** Registers the new device and the requesting protocol service.
    50  *  Connects to the network interface layer service.
    51  *  Determines the device broadcast address, its address lengths and packet size.
    52  *  @param[in] arp_phone The ARP module phone used for (semi)remote calls.
    53  *  @param[in] device_id The new device identifier.
    54  *  @param[in] protocol The requesting protocol service.
    55  *  @param[in] netif The underlying device network interface layer service.
    56  *  @param[in] address The local requesting protocol address of the device.
    57  *  @returns EOK on success.
    58  *  @returns EEXIST if the device is already used.
    59  *  @returns ENOMEM if there is not enough memory left.
    60  *  @returns ENOENT if the network interface service is not known.
    61  *  @returns EREFUSED if the network interface service is not responding.
    62  *  @returns Other error codes as defined for the nil_packet_get_size() function.
    63  *  @returns Other error codes as defined for the nil_get_addr() function.
    64  *  @returns Other error codes as defined for the nil_get_broadcast_addr() function.
    65  */
    66 extern int arp_device_req(int arp_phone, device_id_t device_id, services_t protocol, services_t netif, measured_string_ref address);
    67 
    68 /** Translates the given protocol address to the network interface address.
    69  *  Broadcasts the ARP request if the mapping is not found.
    70  *  Allocates and returns the needed memory block as the data parameter.
    71  *  @param[in] arp_phone The ARP module phone used for (semi)remote calls.
    72  *  @param[in] device_id The device identifier.
    73  *  @param[in] protocol The requesting protocol service.
    74  *  @param[in] address The local requesting protocol address.
    75  *  @param[out] translation The translation of the local protocol address.
    76  *  @param[out] data The allocated raw translation data container.
    77  *  @returns EOK on success.
    78  *  @returns EINVAL if the address parameter is NULL.
    79  *  @returns EBADMEM if the translation or the data parameters are NULL.
    80  *  @returns ENOENT if the mapping is not found.
    81  */
    82 extern int arp_translate_req(int arp_phone, device_id_t device_id, services_t protocol, measured_string_ref address, measured_string_ref * translation, char ** data);
    83 
    84 /** Clears the device cache.
    85  *  @param[in] arp_phone The ARP module phone used for (semi)remote calls.
    86  *  @param[in] device_id The device identifier.
    87  *  @returns EOK on success.
    88  *  @returns ENOENT if the device is not found.
    89  */
    90 extern int arp_clear_device_req(int arp_phone, device_id_t device_id);
    91 
    92 /** Clears the given protocol address from the cache.
    93  *  @param[in] arp_phone The ARP module phone used for (semi)remote calls.
    94  *  @param[in] device_id The device identifier.
    95  *  @param[in] protocol The requesting protocol service.
    96  *  @param[in] address The protocol address to be cleared.
    97  *  @returns EOK on success.
    98  *  @returns ENOENT if the mapping is not found.
    99  */
    100 extern int arp_clear_address_req(int arp_phone, device_id_t device_id, services_t protocol, measured_string_ref address);
    101 
    102 /** Cleans the cache.
    103  *  @param[in] arp_phone The ARP module phone used for (semi)remote calls.
    104  *  @returns EOK on success.
    105  */
    106 extern int arp_clean_cache_req(int arp_phone);
    107 
    108 /** Connects to the ARP module.
    109  *  @param service The ARP module service. Ignored parameter.
    110  *  @returns The ARP module phone on success.
    111  */
    112 extern int arp_connect_module(services_t service);
    113 
    114 /** Returns the ARP task identifier.
    115  *  @returns 0 if called by the remote module.
    116  */
    117 extern task_id_t arp_task_get_id(void);
     49extern int arp_device_req(int, device_id_t, services_t, services_t,
     50    measured_string_ref);
     51extern int arp_translate_req(int, device_id_t, services_t, measured_string_ref,
     52    measured_string_ref *, char **);
     53extern int arp_clear_device_req(int, device_id_t);
     54extern int arp_clear_address_req(int, device_id_t, services_t,
     55    measured_string_ref);
     56extern int arp_clean_cache_req(int);
     57extern int arp_connect_module(services_t);
    11858
    11959/*@}*/

  • uspace/lib/net/include/generic.h

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup net
     29/** @addtogroup libnet
    3030 * @{
    3131 */
    … …  
    3535 */
    3636
    37 #ifndef NET_GENERIC_H_
    38 #define NET_GENERIC_H_
     37#ifndef LIBNET_GENERIC_H_
     38#define LIBNET_GENERIC_H_
    3939
    4040#include <async.h>

  • uspace/lib/net/include/il_interface.h

    ref689ef0 ra7a85d16  
    4242
    4343#include <ipc/services.h>
     44#include <ipc/il.h>
    4445
    4546#include <net/device.h>
    4647#include <net/packet.h>
    47 #include <il_messages.h>
    4848
    4949#include <packet_client.h>

  • uspace/lib/net/include/ip_client.h

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup ip
    30  *  @{
     29/** @addtogroup libnet
     30 * @{
    3131 */
    3232
    3333/** @file
    34  *  IP client interface.
     34 * IP client interface.
    3535 */
    3636
    37 #ifndef __NET_IP_CLIENT_H__
    38 #define __NET_IP_CLIENT_H__
     37#ifndef LIBNET_IP_CLIENT_H_
     38#define LIBNET_IP_CLIENT_H_
    3939
    4040#include <net/socket_codes.h>
    … …  
    4545#include <ip_interface.h>
    4646
    47 /** Prepares the packet to be transfered via IP.
    48  *  The IP header is prefixed.
    49  *  @param[in,out] packet The packet to be prepared.
    50  *  @param[in] protocol The transport protocol.
    51  *  @param[in] ttl The time to live counter. The IPDEFTTL is set if zero (0).
    52  *  @param[in] tos The type of service.
    53  *  @param[in] dont_fragment The value indicating whether fragmentation is disabled.
    54  *  @param[in] ipopt_length The prefixed IP options length in bytes.
    55  *  @returns EOK on success.
    56  *  @returns ENOMEM if there is not enough memory left in the packet.
    57  */
    58 extern int ip_client_prepare_packet(packet_t packet, ip_protocol_t protocol, ip_ttl_t ttl, ip_tos_t tos, int dont_fragment, size_t ipopt_length);
    59 
    60 /** Processes the received IP packet.
    61  *  Fills set header fields.
    62  *  Returns the prefixed IP header length.
    63  *  @param[in] packet The received packet.
    64  *  @param[out] protocol The transport protocol. May be NULL if not desired.
    65  *  @param[out] ttl The time to live counter. May be NULL if not desired.
    66  *  @param[out] tos The type of service. May be NULL if not desired.
    67  *  @param[out] dont_fragment The value indicating whether the fragmentation is disabled. May be NULL if not desired.
    68  *  @param[out] ipopt_length The IP options length in bytes. May be NULL if not desired.
    69  *  @returns The prefixed IP header length in bytes on success.
    70  *  @returns ENOMEM if the packet is too short to contain the IP header.
    71  */
    72 extern int ip_client_process_packet(packet_t packet, ip_protocol_t * protocol, ip_ttl_t * ttl, ip_tos_t * tos, int * dont_fragment, size_t * ipopt_length);
    73 
    74 /** Returns the IP header length.
    75  *  @param[in] packet The packet.
    76  *  @returns The IP header length in bytes.
    77  *  @returns Zero (0) if there is no IP header.
    78  */
    79 extern size_t ip_client_header_length(packet_t packet);
    80 
    81 /** Updates the IPv4 pseudo header data length field.
    82  *  @param[in,out] header The IPv4 pseudo header to be updated.
    83  *  @param[in] headerlen The length of the IP pseudo header in bytes.
    84  *  @param[in] data_length The data length to be set.
    85  *  @returns EOK on success.
    86  *  @returns EBADMEM if the header parameter is NULL.
    87  *  @returns EINVAL if the headerlen parameter is not IPv4 pseudo header length.
    88  */
    89 extern int ip_client_set_pseudo_header_data_length(void *header, size_t headerlen, size_t data_length);
    90 
    91 /** Constructs the IPv4 pseudo header.
    92  *  @param[in] protocol The transport protocol.
    93  *  @param[in] src The source address.
    94  *  @param[in] srclen The source address length.
    95  *  @param[in] dest The destination address.
    96  *  @param[in] destlen The destination address length.
    97  *  @param[in] data_length The data length to be set.
    98  *  @param[out] header The constructed IPv4 pseudo header.
    99  *  @param[out] headerlen The length of the IP pseudo header in bytes.
    100  *  @returns EOK on success.
    101  *  @returns EBADMEM if the header and/or the headerlen parameter is NULL.
    102  *  @returns EINVAL if the source address and/or the destination address parameter is NULL.
    103  *  @returns EINVAL if the source address length is less than struct sockaddr length.
    104  *  @returns EINVAL if the source address length differs from the destination address length.
    105  *  @returns EINVAL if the source address family differs from the destination family.
    106  *  @returns EAFNOSUPPORT if the address family is not supported.
    107  *  @returns ENOMEM if there is not enough memory left.
    108  */
    109 extern int ip_client_get_pseudo_header(ip_protocol_t protocol, struct sockaddr * src, socklen_t srclen, struct sockaddr * dest, socklen_t destlen, size_t data_length, void **header, size_t * headerlen);
     47extern int ip_client_prepare_packet(packet_t, ip_protocol_t, ip_ttl_t, ip_tos_t,
     48    int, size_t);
     49extern int ip_client_process_packet(packet_t, ip_protocol_t *, ip_ttl_t *,
     50    ip_tos_t *, int *, size_t *);
     51extern size_t ip_client_header_length(packet_t);
     52extern int ip_client_set_pseudo_header_data_length(void *, size_t, size_t);
     53extern int ip_client_get_pseudo_header(ip_protocol_t, struct sockaddr *,
     54    socklen_t, struct sockaddr *, socklen_t, size_t, void **, size_t *);
    11055
    11156// TODO ipopt manipulation

  • uspace/lib/net/include/net_checksum.h

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup net
    30  *  @{
     29/** @addtogroup libnet
     30 * @{
    3131 */
    3232
    3333/** @file
    34  *  General CRC and checksum computation.
     34 * General CRC and checksum computation.
    3535 */
    3636
    37 #ifndef __NET_CHECKSUM_H__
    38 #define __NET_CHECKSUM_H__
     37#ifndef LIBNET_CHECKSUM_H_
     38#define LIBNET_CHECKSUM_H_
    3939
    4040#include <byteorder.h>
    41 
    4241#include <sys/types.h>
    4342
    4443/** IP checksum value for computed zero checksum.
    45  *  Zero is returned as 0xFFFF (not flipped)
     44 * Zero is returned as 0xFFFF (not flipped)
    4645 */
    47 #define IP_CHECKSUM_ZERO                        0xFFFFu
     46#define IP_CHECKSUM_ZERO        0xffffU
    4847
    49 /**     Computes CRC32 value.
    50  *  @param[in] seed Initial value. Often used as 0 or ~0.
    51  *  @param[in] data Pointer to the beginning of data to process.
    52  *  @param[in] length Length of the data in bits.
    53  *  @returns The computed CRC32 of the length bits of the data.
    54  */
    5548#ifdef ARCH_IS_BIG_ENDIAN
    56         #define compute_crc32(seed, data, length)       compute_crc32_be(seed, (uint8_t *) data, length)
     49#define compute_crc32(seed, data, length) \
     50        compute_crc32_be(seed, (uint8_t *) data, length)
    5751#else
    58         #define compute_crc32(seed, data, length)       compute_crc32_le(seed, (uint8_t *) data, length)
     52#define compute_crc32(seed, data, length) \
     53        compute_crc32_le(seed, (uint8_t *) data, length)
    5954#endif
    6055
    61 /**     Computes CRC32 value in the little-endian environment.
    62  *  @param[in] seed Initial value. Often used as 0 or ~0.
    63  *  @param[in] data Pointer to the beginning of data to process.
    64  *  @param[in] length Length of the data in bits.
    65  *  @returns The computed CRC32 of the length bits of the data.
    66  */
    67 extern uint32_t compute_crc32_le(uint32_t seed, uint8_t * data, size_t length);
    68 
    69 /**     Computes CRC32 value in the big-endian environment.
    70  *  @param[in] seed Initial value. Often used as 0 or ~0.
    71  *  @param[in] data Pointer to the beginning of data to process.
    72  *  @param[in] length Length of the data in bits.
    73  *  @returns The computed CRC32 of the length bits of the data.
    74  */
    75 extern uint32_t compute_crc32_be(uint32_t seed, uint8_t * data, size_t length);
    76 
    77 /** Computes sum of the 2 byte fields.
    78  *  Padds one zero (0) byte if odd.
    79  *  @param[in] seed Initial value. Often used as 0 or ~0.
    80  *  @param[in] data Pointer to the beginning of data to process.
    81  *  @param[in] length Length of the data in bytes.
    82  *  @returns The computed checksum of the length bytes of the data.
    83  */
    84 extern uint32_t compute_checksum(uint32_t seed, uint8_t * data, size_t length);
    85 
    86 /** Compacts the computed checksum to the 16 bit number adding the carries.
    87  *  @param[in] sum Computed checksum.
    88  *  @returns Compacted computed checksum to the 16 bits.
    89  */
    90 extern uint16_t compact_checksum(uint32_t sum);
    91 
    92 /** Returns or flips the checksum if zero.
    93  *  @param[in] checksum The computed checksum.
    94  *  @returns The internet protocol header checksum.
    95  *  @returns 0xFFFF if the computed checksum is zero.
    96  */
    97 extern uint16_t flip_checksum(uint16_t checksum);
    98 
    99 /** Computes the ip header checksum.
    100  *  To compute the checksum of a new packet, the checksum header field must be zero.
    101  *  To check the checksum of a received packet, the checksum may be left set.
    102  *  The zero (0) value will be returned in this case if valid.
    103  *  @param[in] data The header data.
    104  *  @param[in] length The header length in bytes.
    105  *  @returns The internet protocol header checksum.
    106  *  @returns 0xFFFF if the computed checksum is zero.
    107  */
    108 extern uint16_t ip_checksum(uint8_t * data, size_t length);
     56extern uint32_t compute_crc32_le(uint32_t, uint8_t *, size_t);
     57extern uint32_t compute_crc32_be(uint32_t, uint8_t *, size_t);
     58extern uint32_t compute_checksum(uint32_t, uint8_t *, size_t);
     59extern uint16_t compact_checksum(uint32_t);
     60extern uint16_t flip_checksum(uint16_t);
     61extern uint16_t ip_checksum(uint8_t *, size_t);
    10962
    11063#endif

  • uspace/lib/net/include/net_interface.h

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup net
     29/** @addtogroup libnet
    3030 *  @{
    3131 */
    3232
    33 #ifndef __NET_NET_INTERFACE_H__
    34 #define __NET_NET_INTERFACE_H__
     33#ifndef LIBNET_NET_INTERFACE_H_
     34#define LIBNET_NET_INTERFACE_H_
    3535
    3636#include <ipc/services.h>
    … …  
    4040
    4141/** @name Networking module interface
    42  *  This interface is used by other modules.
     42 * This interface is used by other modules.
    4343 */
    4444/*@{*/
    4545
    46 /** Returns the device specific configuration.
    47  *  Returns the global configuration if the device specific is not found.
    48  *  The configuration names are read and the appropriate settings are set instead.
    49  *  Call net_free_settings() function to release the returned configuration.
    50  *  @param[in] net_phone The networking module phone.
    51  *  @param[in] device_id The device identifier.
    52  *  @param[in,out] configuration The requested device configuration. The names are read and the appropriate settings are set instead.
    53  *  @param[in] count The configuration entries count.
    54  *  @param[in,out] data The configuration and settings data.
    55  *  @returns EOK on success.
    56  *  @returns EINVAL if the configuration is NULL.
    57  *  @returns EINVAL if the count is zero (0).
    58  *  @returns Other error codes as defined for the generic_translate_req() function.
    59  */
    60 extern int net_get_device_conf_req(int net_phone, device_id_t device_id, measured_string_ref * configuration, size_t count, char ** data);
    61 
    62 /** Returns the global configuration.
    63  *  The configuration names are read and the appropriate settings are set instead.
    64  *  Call net_free_settings() function to release the returned configuration.
    65  *  @param[in] net_phone The networking module phone.
    66  *  @param[in,out] configuration The requested configuration. The names are read and the appropriate settings are set instead.
    67  *  @param[in] count The configuration entries count.
    68  *  @param[in,out] data The configuration and settings data.
    69  *  @returns EOK on success.
    70  *  @returns EINVAL if the configuration is NULL.
    71  *  @returns EINVAL if the count is zero (0).
    72  *  @returns Other error codes as defined for the generic_translate_req() function.
    73  */
    74 extern int net_get_conf_req(int net_phone, measured_string_ref * configuration, size_t count, char ** data);
    75 
    76 /** Frees the received settings.
    77  *  @param[in] settings The received settings.
    78  *  @param[in] data The received settings data.
    79  *  @see net_get_device_conf_req()
    80  *  @see net_get_conf_req()
    81  */
    82 extern void net_free_settings(measured_string_ref settings, char * data);
    83 
    84 /** Connects to the networking module.
    85  *  @param service The networking module service. Ignored parameter.
    86  *  @returns The networking module phone on success.
    87  */
    88 extern int net_connect_module(services_t service);
     46extern int net_get_device_conf_req(int, device_id_t, measured_string_ref *,
     47    size_t, char **);
     48extern int net_get_conf_req(int, measured_string_ref *, size_t, char **);
     49extern void net_free_settings(measured_string_ref, char *);
     50extern int net_connect_module(void);
    8951
    9052/*@}*/

  • uspace/lib/net/include/nil_interface.h

    ref689ef0 ra7a85d16  
    3838
    3939#include <ipc/ipc.h>
     40#include <ipc/nil.h>
    4041
    4142#include <generic.h>
    42 #include <nil_messages.h>
    4343#include <nil_remote.h>
    4444

  • uspace/lib/net/include/packet_client.h

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup packet
     29/** @addtogroup libnet
    3030 *  @{
    3131 */
    3232
    3333/** @file
    34  *  Packet client.
    35  *  The hosting module has to be compiled with both the packet.c and the packet_client.c source files.
    36  *  To function correctly, initialization of the packet map by the pm_init() function has to happen at the first place.
    37  *  The module should not send the packet messages to the packet server but use the functions provided.
    38  *  The packet map should be released by the pm_destroy() function during the module termination.
    39  *  The packets and the packet queues can't be locked at all.
    40  *  The processing modules should process them sequentially -&nbsp;by passing the packets to the next module and stopping using the passed ones.
    41  *  @see packet.h
     34 * Packet client.
     35 *
     36 * To function correctly, initialization of the packet map by the pm_init()
     37 * function has to happen at the first place. The module should not send the
     38 * packet messages to the packet server but use the functions provided. The
     39 * packet map should be released by the pm_destroy() function during the module
     40 * termination. The packets and the packet queues can't be locked at all. The
     41 * processing modules should process them sequentially - by passing the packets
     42 * to the next module and stopping using the passed ones.
     43 *
     44 * @see packet.h
    4245 */
    4346
    44 #ifndef __NET_PACKET_CLIENT_H__
    45 #define __NET_PACKET_CLIENT_H__
     47#ifndef LIBNET_PACKET_CLIENT_H_
     48#define LIBNET_PACKET_CLIENT_H_
    4649
    4750#include <net/packet.h>
    4851
    49 /** @name Packet client interface
    50  */
     52/** @name Packet client interface */
    5153/*@{*/
    5254
    53 /** Allocates the specified type right before the actual packet content and returns its pointer.
    54  *  The wrapper of the packet_prepend() function.
    55  *  @param[in] packet The packet to be used.
    56  *  @param[in] type The type to be allocated at the beginning of the packet content.
    57  *  @returns The typed pointer to the allocated memory.
    58  *  @returns NULL if the packet is not valid.
    59  *  @returns NULL if there is not enough memory left.
     55/** Allocates the specified type right before the actual packet content and
     56 * returns its pointer.
     57 *
     58 * The wrapper of the packet_prepend() function.
     59 *
     60 * @param[in] packet    The packet to be used.
     61 * @param[in] type      The type to be allocated at the beginning of the packet
     62 *                      content.
     63 * @returns             The typed pointer to the allocated memory.
     64 * @returns             NULL if the packet is not valid.
     65 * @returns             NULL if there is not enough memory left.
    6066 */
    61 #define PACKET_PREFIX(packet, type)     (type *) packet_prefix((packet), sizeof(type))
     67#define PACKET_PREFIX(packet, type) \
     68        (type *) packet_prefix((packet), sizeof(type))
    6269
    63 /** Allocates the specified type right after the actual packet content and returns its pointer.
    64  *  The wrapper of the packet_append() function.
    65  *  @param[in] packet The packet to be used.
    66  *  @param[in] type The type to be allocated at the end of the packet content.
    67  *  @returns The typed pointer to the allocated memory.
    68  *  @returns NULL if the packet is not valid.
    69  *  @returns NULL if there is not enough memory left.
     70/** Allocates the specified type right after the actual packet content and
     71 * returns its pointer.
     72 *
     73 * The wrapper of the packet_append() function.
     74 *
     75 * @param[in] packet    The packet to be used.
     76 * @param[in] type      The type to be allocated at the end of the packet
     77 *                      content.
     78 * @returns             The typed pointer to the allocated memory.
     79 * @returns             NULL if the packet is not valid.
     80 * @returns             NULL if there is not enough memory left.
    7081 */
    71 #define PACKET_SUFFIX(packet, type)     (type *) packet_suffix((packet), sizeof(type))
     82#define PACKET_SUFFIX(packet, type) \
     83        (type *) packet_suffix((packet), sizeof(type))
    7284
    7385/** Trims the actual packet content by the specified prefix and suffix types.
    74  *  The wrapper of the packet_trim() function.
    75  *  @param[in] packet The packet to be trimmed.
    76  *  @param[in] prefix The type of the prefix to be removed from the beginning of the packet content.
    77  *  @param[in] suffix The type of the suffix to be removed from the end of the packet content.
    78  *  @returns EOK on success.
    79  *  @returns EINVAL if the packet is not valid.
    80  *  @returns ENOMEM if there is not enough memory left.
     86 *
     87 * The wrapper of the packet_trim() function.
     88 *
     89 * @param[in] packet    The packet to be trimmed.
     90 * @param[in] prefix    The type of the prefix to be removed from the beginning
     91 *                      of the packet content.
     92 * @param[in] suffix    The type of the suffix to be removed from the end of
     93 *                      the packet content.
     94 * @returns             EOK on success.
     95 * @returns             EINVAL if the packet is not valid.
     96 * @returns             ENOMEM if there is not enough memory left.
    8197 */
    82 #define PACKET_TRIM(packet, prefix, suffix)     packet_trim((packet), sizeof(prefix), sizeof(suffix))
     98#define PACKET_TRIM(packet, prefix, suffix) \
     99        packet_trim((packet), sizeof(prefix), sizeof(suffix))
    83100
    84 /** Allocates the specified space right before the actual packet content and returns its pointer.
    85  *  @param[in] packet The packet to be used.
    86  *  @param[in] length The space length to be allocated at the beginning of the packet content.
    87  *  @returns The pointer to the allocated memory.
    88  *  @returns NULL if there is not enough memory left.
    89  */
    90 extern void * packet_prefix(packet_t packet, size_t length);
    91 
    92 /** Allocates the specified space right after the actual packet content and returns its pointer.
    93  *  @param[in] packet The packet to be used.
    94  *  @param[in] length The space length to be allocated at the end of the packet content.
    95  *  @returns The pointer to the allocated memory.
    96  *  @returns NULL if there is not enough memory left.
    97  */
    98 extern void * packet_suffix(packet_t packet, size_t length);
    99 
    100 /** Trims the actual packet content by the specified prefix and suffix lengths.
    101  *  @param[in] packet The packet to be trimmed.
    102  *  @param[in] prefix The prefix length to be removed from the beginning of the packet content.
    103  *  @param[in] suffix The suffix length to be removed from the end of the packet content.
    104  *  @returns EOK on success.
    105  *  @returns EINVAL if the packet is not valid.
    106  *  @returns ENOMEM if there is not enough memory left.
    107  */
    108 extern int packet_trim(packet_t packet, size_t prefix, size_t suffix);
    109 
    110 /** Copies the specified data to the beginning of the actual packet content.
    111  *  Pushes the content end if needed.
    112  *  @param[in] packet The packet to be filled.
    113  *  @param[in] data The data to be copied.
    114  *  @param[in] length The length of the copied data.
    115  *  @returns EOK on success.
    116  *  @returns EINVAL if the packet is not valid.
    117  *  @returns ENOMEM if there is not enough memory left.
    118  */
    119 extern int packet_copy_data(packet_t packet, const void * data, size_t length);
    120 
    121 /** Returns the packet identifier.
    122  *  @param[in] packet The packet.
    123  *  @returns The packet identifier.
    124  *  @returns Zero (0) if the packet is not valid.
    125  */
    126 extern packet_id_t packet_get_id(const packet_t packet);
    127 
    128 /** Returns the packet content length.
    129  *  @param[in] packet The packet.
    130  *  @returns The packet content length in bytes.
    131  *  @returns Zero (0) if the packet is not valid.
    132  */
    133 extern size_t packet_get_data_length(const packet_t packet);
    134 
    135 /** Returns the pointer to the beginning of the packet content.
    136  *  @param[in] packet The packet.
    137  *  @returns The pointer to the beginning of the packet content.
    138  *  @returns NULL if the packet is not valid.
    139  */
    140 extern void * packet_get_data(const packet_t packet);
    141 
    142 /** Returns the stored packet addresses and their length.
    143  *  @param[in] packet The packet.
    144  *  @param[out] src The source address. May be NULL if not desired.
    145  *  @param[out] dest The destination address. May be NULL if not desired.
    146  *  @returns The stored addresses length.
    147  *  @returns Zero (0) if the addresses are not present.
    148  *  @returns EINVAL if the packet is not valid.
    149  */
    150 extern int packet_get_addr(const packet_t packet, uint8_t ** src, uint8_t ** dest);
    151 
    152 /** Sets the packet addresses.
    153  *  @param[in] packet The packet.
    154  *  @param[in] src The new source address. May be NULL.
    155  *  @param[in] dest The new destination address. May be NULL.
    156  *  @param[in] addr_len The addresses length.
    157  *  @returns EOK on success.
    158  *  @returns EINVAL if the packet is not valid.
    159  *  @returns ENOMEM if there is not enough memory left.
    160  */
    161 extern int packet_set_addr(packet_t packet, const uint8_t * src, const uint8_t * dest, size_t addr_len);
    162 
    163 /** Translates the packet identifier to the packet reference.
    164  *  Tries to find mapping first.
    165  *  Contacts the packet server to share the packet if the mapping is not present.
    166  *  @param[in] phone The packet server module phone.
    167  *  @param[out] packet The packet reference.
    168  *  @param[in] packet_id The packet identifier.
    169  *  @returns EOK on success.
    170  *  @returns EINVAL if the packet parameter is NULL.
    171  *  @returns Other error codes as defined for the NET_PACKET_GET_SIZE message.
    172  *  @returns Other error codes as defined for the packet_return() function.
    173  */
    174 extern int packet_translate_remote(int phone, packet_ref packet, packet_id_t packet_id);
    175 
    176 /** Obtains the packet of the given dimensions.
    177  *  Contacts the packet server to return the appropriate packet.
    178  *  @param[in] phone The packet server module phone.
    179  *  @param[in] addr_len The source and destination addresses maximal length in bytes.
    180  *  @param[in] max_prefix The maximal prefix length in bytes.
    181  *  @param[in] max_content The maximal content length in bytes.
    182  *  @param[in] max_suffix The maximal suffix length in bytes.
    183  *  @returns The packet reference.
    184  *  @returns NULL on error.
    185  */
    186 extern packet_t packet_get_4_remote(int phone, size_t max_content, size_t addr_len, size_t max_prefix, size_t max_suffix);
    187 
    188 /** Obtains the packet of the given content size.
    189  *  Contacts the packet server to return the appropriate packet.
    190  *  @param[in] phone The packet server module phone.
    191  *  @param[in] content The maximal content length in bytes.
    192  *  @returns The packet reference.
    193  *  @returns NULL on error.
    194  */
    195 extern packet_t packet_get_1_remote(int phone, size_t content);
    196 
    197 /** Releases the packet queue.
    198  *  All packets in the queue are marked as free for use.
    199  *  The packet queue may be one packet only.
    200  *  The module should not use the packets after this point until they are received or obtained again.
    201  *  @param[in] phone The packet server module phone.
    202  *  @param[in] packet_id The packet identifier.
    203  */
    204 extern void pq_release_remote(int phone, packet_id_t packet_id);
    205 
    206 /** Returns the packet copy.
    207  *  Copies the addresses, data, order and metric values.
    208  *  Does not copy the queue placement.
    209  *  @param[in] phone The packet server module phone.
    210  *  @param[in] packet The original packet.
    211  *  @returns The packet copy.
    212  *  @returns NULL on error.
    213  */
     101extern void *packet_prefix(packet_t, size_t);
     102extern void *packet_suffix(packet_t, size_t);
     103extern int packet_trim(packet_t, size_t, size_t);
     104extern int packet_copy_data(packet_t, const void *, size_t);
     105extern packet_id_t packet_get_id(const packet_t);
     106extern size_t packet_get_data_length(const packet_t);
     107extern void *packet_get_data(const packet_t);
     108extern int packet_get_addr(const packet_t, uint8_t **, uint8_t **);
     109extern int packet_set_addr(packet_t, const uint8_t *, const uint8_t *, size_t);
    214110extern packet_t packet_get_copy(int phone, packet_t packet);
    215111

  • uspace/lib/net/include/packet_remote.h

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup packet
     29/** @addtogroup libnet
    3030 * @{
    3131 */
    3232
    33 #ifndef __NET_PACKET_REMOTE_H__
    34 #define __NET_PACKET_REMOTE_H__
     33#ifndef LIBNET_PACKET_REMOTE_H_
     34#define LIBNET_PACKET_REMOTE_H_
    3535
    3636#include <net/packet.h>
     37#include <sys/types.h>
    3738
    3839extern int packet_translate_remote(int, packet_ref, packet_id_t);

  • uspace/lib/net/include/socket_core.h

    ref689ef0 ra7a85d16  
    2727 */
    2828
    29 /** @addtogroup socket
     29/** @addtogroup libnet
    3030 *  @{
    3131 */
    3232
    3333/** @file
    34  *  Socket common core.
     34 * Socket common core.
    3535 */
    3636
    37 #ifndef __NET_SOCKET_CORE_H__
    38 #define __NET_SOCKET_CORE_H__
     37#ifndef LIBNET_SOCKET_CORE_H_
     38#define LIBNET_SOCKET_CORE_H_
    3939
    4040#include <sys/types.h>
    41 
    42 #include <net/in.h>
    43 #include <net/device.h>
    4441#include <adt/generic_char_map.h>
    4542#include <adt/dynamic_fifo.h>
    4643#include <adt/int_map.h>
     44#include <net/in.h>
     45#include <net/device.h>
    4746#include <net/packet.h>
    4847
    49 /** Initial size of the received packet queue.
    50  */
     48/** Initial size of the received packet queue. */
    5149#define SOCKET_INITIAL_RECEIVED_SIZE    4
    5250
    53 /** Maximum size of the received packet queue.
    54  */
    55 #define SOCKET_MAX_RECEIVED_SIZE                0
     51/** Maximum size of the received packet queue. */
     52#define SOCKET_MAX_RECEIVED_SIZE        0
    5653
    57 /** Initial size of the sockets for acceptance queue.
    58  */
     54/** Initial size of the sockets for acceptance queue. */
    5955#define SOCKET_INITIAL_ACCEPTED_SIZE    1
    6056
    61 /** Maximum size of the sockets for acceptance queue.
    62  */
    63 #define SOCKET_MAX_ACCEPTEDED_SIZE              0
     57/** Maximum size of the sockets for acceptance queue. */
     58#define SOCKET_MAX_ACCEPTEDED_SIZE      0
    6459
    65 /** Listening sockets' port map key.
    66  */
     60/** Listening sockets' port map key. */
    6761#define SOCKET_MAP_KEY_LISTENING        "L"
    6862
    6963/** Type definition of the socket core.
    70  *  @see socket_core
     64 * @see socket_core
    7165 */
    72 typedef struct socket_core      socket_core_t;
     66typedef struct socket_core socket_core_t;
    7367
    7468/** Type definition of the socket core pointer.
    75  *  @see socket_core
     69 * @see socket_core
    7670 */
    77 typedef socket_core_t * socket_core_ref;
     71typedef socket_core_t *socket_core_ref;
    7872
    7973/** Type definition of the socket port.
    80  *  @see socket_port
     74 * @see socket_port
    8175 */
    82 typedef struct socket_port      socket_port_t;
     76typedef struct socket_port socket_port_t;
    8377
    8478/** Type definition of the socket port pointer.
    85  *  @see socket_port
     79 * @see socket_port
    8680 */
    87 typedef socket_port_t * socket_port_ref;
     81typedef socket_port_t *socket_port_ref;
    8882
    89 /** Socket core.
    90  */
    91 struct socket_core{
    92         /** Socket identifier.
    93          */
     83/** Socket core. */
     84struct socket_core {
     85        /** Socket identifier. */
    9486        int socket_id;
    95         /** Client application phone.
    96          */
     87        /** Client application phone. */
    9788        int phone;
    98         /** Bound port.
    99          */
     89        /** Bound port. */
    10090        int port;
    101         /** Received packets queue.
    102          */
     91        /** Received packets queue. */
    10392        dyn_fifo_t received;
    104         /** Sockets for acceptance queue.
    105          */
     93        /** Sockets for acceptance queue. */
    10694        dyn_fifo_t accepted;
    107         /** Protocol specific data.
    108          */
    109         void * specific_data;
    110         /** Socket ports map key.
    111          */
    112         const char * key;
    113         /** Length of the Socket ports map key.
    114          */
     95        /** Protocol specific data. */
     96        void *specific_data;
     97        /** Socket ports map key. */
     98        const char *key;
     99        /** Length of the Socket ports map key. */
    115100        size_t key_length;
    116101};
    117102
    118103/** Sockets map.
    119  *  The key is the socket identifier.
     104 * The key is the socket identifier.
    120105 */
    121106INT_MAP_DECLARE(socket_cores, socket_core_t);
    122107
    123108/** Bount port sockets map.
    124  *  The listening socket has the SOCKET_MAP_KEY_LISTENING key identifier whereas the other use the remote addresses.
     109 *
     110 * The listening socket has the SOCKET_MAP_KEY_LISTENING key identifier whereas
     111 * the other use the remote addresses.
    125112 */
    126113GENERIC_CHAR_MAP_DECLARE(socket_port_map, socket_core_ref);
    127114
    128115/** Ports map.
    129  *  The key is the port number.
     116 * The key is the port number.
    130117 */
    131118INT_MAP_DECLARE(socket_ports, socket_port_t);
    132119
    133 /** Destroys local sockets.
    134  *  Releases all buffered packets and calls the release function for each of the sockets.
    135  *  @param[in] packet_phone The packet server phone to release buffered packets.
    136  *  @param[in] local_sockets The local sockets to be destroyed.
    137  *  @param[in,out] global_sockets The global sockets to be updated.
    138  *  @param[in] socket_release The client release callback function.
    139  */
    140 extern void socket_cores_release(int packet_phone, socket_cores_ref local_sockets, socket_ports_ref global_sockets, void (*socket_release)(socket_core_ref socket));
    141 
    142 /** Binds the socket to the port.
    143  *  The address port is used if set, a free port is used if not.
    144  *  @param[in] local_sockets The local sockets to be searched.
    145  *  @param[in,out] global_sockets The global sockets to be updated.
    146  *  @param[in] socket_id The new socket identifier.
    147  *  @param[in] addr The address to be bound to.
    148  *  @param[in] addrlen The address length.
    149  *  @param[in] free_ports_start The minimum free port.
    150  *  @param[in] free_ports_end The maximum free port.
    151  *  @param[in] last_used_port The last used free port.
    152  *  @returns EOK on success.
    153  *  @returns ENOTSOCK if the socket was not found.
    154  *  @returns EAFNOSUPPORT if the address family is not supported.
    155  *  @returns EADDRINUSE if the port is already in use.
    156  *  @returns Other error codes as defined for the socket_bind_free_port() function.
    157  *  @returns Other error codes as defined for the socket_bind_insert() function.
    158  */
    159 extern int socket_bind(socket_cores_ref local_sockets, socket_ports_ref global_sockets, int socket_id, void * addr, size_t addrlen, int free_ports_start, int free_ports_end, int last_used_port);
    160 
    161 /** Binds the socket to a free port.
    162  *  The first free port is used.
    163  *  @param[in,out] global_sockets The global sockets to be updated.
    164  *  @param[in,out] socket The socket to be bound.
    165  *  @param[in] free_ports_start The minimum free port.
    166  *  @param[in] free_ports_end The maximum free port.
    167  *  @param[in] last_used_port The last used free port.
    168  *  @returns EOK on success.
    169  *  @returns ENOTCONN if no free port was found.
    170  *  @returns Other error codes as defined for the socket_bind_insert() function.
    171  */
    172 extern int socket_bind_free_port(socket_ports_ref global_sockets, socket_core_ref socket, int free_ports_start, int free_ports_end, int last_used_port);
    173 
    174 /** Creates a new socket.
    175  *  @param[in,out] local_sockets The local sockets to be updated.
    176  *  @param[in] app_phone The application phone.
    177  *  @param[in] specific_data The socket specific data.
    178  *  @param[in,out] socket_id The new socket identifier. A new identifier is chosen if set to zero (0) or negative. A negative identifier is chosen if set to negative.
    179  *  @returns EOK on success.
    180  *  @returns EINVAL if the socket_id parameter is NULL.
    181  *  @returns ENOMEM if there is not enough memory left.
    182  */
    183 extern int socket_create(socket_cores_ref local_sockets, int app_phone, void * specific_data, int * socket_id);
    184 
    185 /** Destroys the socket.
    186  *  If the socket is bound, the port is released.
    187  *  Releases all buffered packets, calls the release function and removes the socket from the local sockets.
    188  *  @param[in] packet_phone The packet server phone to release buffered packets.
    189  *  @param[in] socket_id The socket identifier.
    190  *  @param[in,out] local_sockets The local sockets to be updated.
    191  *  @param[in,out] global_sockets The global sockets to be updated.
    192  *  @param[in] socket_release The client release callback function.
    193  *  @returns EOK on success.
    194  *  @returns ENOTSOCK if the socket is not found.
    195  */
    196 extern int socket_destroy(int packet_phone, int socket_id, socket_cores_ref local_sockets, socket_ports_ref global_sockets, void (*socket_release)(socket_core_ref socket));
    197 
    198 /** Replies the packet or the packet queue data to the application via the socket.
    199  *  Uses the current message processing fibril.
    200  *  @param[in] packet The packet to be transfered.
    201  *  @param[out] length The total data length.
    202  *  @returns EOK on success.
    203  *  @returns EBADMEM if the length parameter is NULL.
    204  *  @returns ENOMEM if there is not enough memory left.
    205  *  @returns Other error codes as defined for the data_reply() function.
    206  */
    207 extern int socket_reply_packets(packet_t packet, size_t * length);
    208 
    209 /** Finds the bound port socket.
    210  *  @param[in] global_sockets The global sockets to be searched.
    211  *  @param[in] port The port number.
    212  *  @param[in] key The socket key identifier.
    213  *  @param[in] key_length The socket key length.
    214  *  @returns The found socket.
    215  *  @returns NULL if no socket was found.
    216  */
    217 extern socket_core_ref socket_port_find(socket_ports_ref global_sockets, int port, const char * key, size_t key_length);
    218 
    219 /** Releases the socket port.
    220  *  If the socket is bound the port entry is released.
    221  *  If there are no more port entries the port is release.
    222  *  @param[in] global_sockets The global sockets to be updated.
    223  *  @param[in] socket The socket to be unbound.
    224  */
    225 extern void socket_port_release(socket_ports_ref global_sockets, socket_core_ref socket);
    226 
    227 /** Adds the socket to an already bound port.
    228  *  @param[in] global_sockets The global sockets to be updated.
    229  *  @param[in] port The port number to be bound to.
    230  *  @param[in] socket The socket to be added.
    231  *  @param[in] key The socket key identifier.
    232  *  @param[in] key_length The socket key length.
    233  *  @returns EOK on success.
    234  *  @returns ENOENT if the port is not already used.
    235  *  @returns Other error codes as defined for the socket_port_add_core() function.
    236  */
    237 extern int socket_port_add(socket_ports_ref global_sockets, int port, socket_core_ref socket, const char * key, size_t key_length);
     120extern void socket_cores_release(int, socket_cores_ref, socket_ports_ref,
     121    void (*)(socket_core_ref));
     122extern int socket_bind(socket_cores_ref, socket_ports_ref, int, void *, size_t,
     123    int, int, int);
     124extern int socket_bind_free_port(socket_ports_ref, socket_core_ref, int, int,
     125    int);
     126extern int socket_create(socket_cores_ref, int, void *, int *);
     127extern int socket_destroy(int, int, socket_cores_ref, socket_ports_ref,
     128    void (*)(socket_core_ref));
     129extern int socket_reply_packets(packet_t, size_t *);
     130extern socket_core_ref socket_port_find(socket_ports_ref, int, const char *,
     131    size_t);
     132extern void socket_port_release(socket_ports_ref, socket_core_ref);
     133extern int socket_port_add(socket_ports_ref, int, socket_core_ref,
     134    const char *, size_t);
    238135
    239136#endif

  • uspace/lib/net/include/tl_interface.h

    ref689ef0 ra7a85d16  
    4040#include <async.h>
    4141#include <ipc/services.h>
     42#include <ipc/tl.h>
    4243
    4344#include <generic.h>
    … …  
    4546#include <net/packet.h>
    4647#include <packet_client.h>
    47 #include <tl_messages.h>
    4848
    4949/** @name Transport layer module interface

  • uspace/lib/net/netif/netif_local.c

    ref689ef0 ra7a85d16  
    4242#include <ipc/ipc.h>
    4343#include <ipc/services.h>
     44#include <ipc/netif.h>
    4445#include <err.h>
    4546
    … …  
    5354#include <nil_interface.h>
    5455#include <netif_local.h>
    55 #include <netif_messages.h>
    5656#include <netif_interface.h>
    5757

  • uspace/lib/net/netif/netif_remote.c

    ref689ef0 ra7a85d16  
    3636
    3737#include <ipc/services.h>
     38#include <ipc/netif.h>
    3839
    3940#include <net/modules.h>
    … …  
    4344#include <net/device.h>
    4445#include <netif_remote.h>
    45 #include <netif_messages.h>
    4646#include <generic.h>
    4747

  • uspace/lib/net/nil/nil_remote.c

    ref689ef0 ra7a85d16  
    3838#include <nil_remote.h>
    3939#include <nil_interface.h>
    40 #include <nil_messages.h>
    4140#include <generic.h>
    4241#include <net/device.h>
    4342#include <net/packet.h>
    4443#include <packet_client.h>
     44
     45#include <ipc/nil.h>
    4546
    4647/** Notify the network interface layer about the device state change.

  • uspace/srv/net/il/arp/arp.c

    ref689ef0 ra7a85d16  
    4646#include <ipc/services.h>
    4747#include <ipc/net.h>
     48#include <ipc/arp.h>
     49#include <ipc/il.h>
    4850#include <byteorder.h>
    4951#include <err.h>
    … …  
    5860#include <packet_client.h>
    5961#include <packet_remote.h>
    60 #include <il_messages.h>
    6162#include <il_interface.h>
    6263#include <il_local.h>
    63 #include <arp_messages.h>
    6464
    6565#include "arp.h"
    … …  
    534534        }
    535535        return EOK;
    536 }
    537 
    538 task_id_t arp_task_get_id(void){
    539         return task_get_id();
    540536}
    541537

  • uspace/srv/net/il/arp/arp_module.c

    ref689ef0 ra7a85d16  
    8080       
    8181        async_set_client_connection(client_connection);
    82         arp_globals.net_phone = net_connect_module(SERVICE_NETWORKING);
     82        arp_globals.net_phone = net_connect_module();
    8383        ERROR_PROPAGATE(pm_init());
    8484       

  • uspace/srv/net/il/ip/ip.c

    ref689ef0 ra7a85d16  
    4545#include <ipc/services.h>
    4646#include <ipc/net.h>
     47#include <ipc/nil.h>
     48#include <ipc/il.h>
     49#include <ipc/ip.h>
    4750#include <sys/types.h>
    4851#include <byteorder.h>
    … …  
    7174#include <packet_client.h>
    7275#include <packet_remote.h>
    73 #include <nil_messages.h>
    74 #include <il_messages.h>
    7576#include <il_local.h>
    76 #include <ip_local.h>
    7777
    7878#include "ip.h"
    7979#include "ip_header.h"
    80 #include "ip_messages.h"
    8180#include "ip_module.h"
     81#include "ip_local.h"
    8282
    8383/** IP module name.
    … …  
    423423        ip_globals.client_connection = client_connection;
    424424        ERROR_PROPAGATE(modules_initialize(&ip_globals.modules));
    425         ERROR_PROPAGATE(add_module(NULL, &ip_globals.modules, ARP_NAME, ARP_FILENAME, SERVICE_ARP, arp_task_get_id(), arp_connect_module));
     425        ERROR_PROPAGATE(add_module(NULL, &ip_globals.modules, ARP_NAME, ARP_FILENAME, SERVICE_ARP, 0, arp_connect_module));
    426426        fibril_rwlock_write_unlock(&ip_globals.lock);
    427427        return EOK;

  • uspace/srv/net/il/ip/ip_local.h

    ref689ef0 ra7a85d16  
    3131 */
    3232
    33 #ifndef __NET_IP_LOCAL_H__
    34 #define __NET_IP_LOCAL_H__
     33#ifndef NET_IP_LOCAL_H_
     34#define NET_IP_LOCAL_H_
    3535
    3636#include <async.h>

  • uspace/srv/net/il/ip/ip_module.c

    ref689ef0 ra7a85d16  
    7979       
    8080        async_set_client_connection(client_connection);
    81         ip_globals.net_phone = net_connect_module(SERVICE_NETWORKING);
     81        ip_globals.net_phone = net_connect_module();
    8282        ERROR_PROPAGATE(pm_init());
    8383       

  • uspace/srv/net/net/net.c

    ref689ef0 ra7a85d16  
    4646
    4747#include <ipc/ipc.h>
     48#include <ipc/services.h>
    4849#include <ipc/net.h>
    49 #include <ipc/services.h>
     50#include <ipc/net_net.h>
     51#include <ipc/il.h>
    5052
    5153#include <net/modules.h>
    … …  
    5557#include <adt/module_map.h>
    5658#include <net/packet.h>
    57 #include <il_messages.h>
    5859#include <netif_remote.h>
    5960#include <net/device.h>
    … …  
    6162#include <net_interface.h>
    6263#include <ip_interface.h>
    63 #include <net_net_messages.h>
    6464
    6565#include "net.h"

  • uspace/srv/net/netif/lo/lo.c

    ref689ef0 ra7a85d16  
    4343#include <ipc/ipc.h>
    4444#include <ipc/services.h>
     45#include <ipc/nil.h>
    4546
    4647#include <net/modules.h>
    … …  
    4950#include <net/device.h>
    5051#include <nil_interface.h>
    51 #include <nil_messages.h>
    5252#include <netif_interface.h>
    5353#include <netif_local.h>

  • uspace/srv/net/netstart/netstart.c

    ref689ef0 ra7a85d16  
    4848#include <ipc/ipc.h>
    4949#include <ipc/services.h>
     50#include <ipc/net_net.h>
    5051
    5152#include <net/modules.h>
    52 #include <net_net_messages.h>
    5353
    5454#include "self_test.h"

  • uspace/srv/net/nil/eth/eth_module.c

    ref689ef0 ra7a85d16  
    6363       
    6464        async_set_client_connection(client_connection);
    65         int net_phone = net_connect_module(SERVICE_NETWORKING);
     65        int net_phone = net_connect_module();
    6666        ERROR_PROPAGATE(pm_init());
    6767       

  • uspace/srv/net/nil/nildummy/nildummy_module.c

    ref689ef0 ra7a85d16  
    7171       
    7272        async_set_client_connection(client_connection);
    73         int net_phone = net_connect_module(SERVICE_NETWORKING);
     73        int net_phone = net_connect_module();
    7474        ERROR_PROPAGATE(pm_init());
    7575       

  • uspace/srv/net/tl/icmp/icmp.c

    ref689ef0 ra7a85d16  
    4545#include <ipc/services.h>
    4646#include <ipc/net.h>
     47#include <ipc/tl.h>
    4748#include <ipc/icmp.h>
    4849#include <sys/time.h>
    … …  
    6970#include <ip_interface.h>
    7071#include <net_interface.h>
    71 #include <tl_messages.h>
    7272#include <tl_interface.h>
    7373#include <tl_local.h>

  • uspace/srv/net/tl/icmp/icmp_module.c

    ref689ef0 ra7a85d16  
    6969
    7070        async_set_client_connection(client_connection);
    71         icmp_globals.net_phone = net_connect_module(SERVICE_NETWORKING);
     71        icmp_globals.net_phone = net_connect_module();
    7272        if(icmp_globals.net_phone < 0){
    7373                return icmp_globals.net_phone;

  • uspace/srv/net/tl/tcp/tcp.c

    ref689ef0 ra7a85d16  
    4848#include <ipc/services.h>
    4949#include <ipc/net.h>
     50#include <ipc/tl.h>
    5051#include <ipc/socket.h>
    5152
    … …  
    6869#include <socket_core.h>
    6970#include <tl_common.h>
    70 #include <tl_messages.h>
    7171#include <tl_local.h>
    7272#include <tl_interface.h>

  • uspace/srv/net/tl/tcp/tcp_module.c

    ref689ef0 ra7a85d16  
    7171       
    7272        async_set_client_connection(client_connection);
    73         tcp_globals.net_phone = net_connect_module(SERVICE_NETWORKING);
     73        tcp_globals.net_phone = net_connect_module();
    7474        ERROR_PROPAGATE(pm_init());
    7575       

  • uspace/srv/net/tl/udp/udp.c

    ref689ef0 ra7a85d16  
    4343#include <ipc/services.h>
    4444#include <ipc/net.h>
     45#include <ipc/tl.h>
    4546#include <ipc/socket.h>
    4647#include <errno.h>
    … …  
    6768#include <tl_local.h>
    6869#include <tl_interface.h>
    69 #include <tl_messages.h>
    7070
    7171#include "udp.h"

  • uspace/srv/net/tl/udp/udp_module.c

    ref689ef0 ra7a85d16  
    6969
    7070        async_set_client_connection(client_connection);
    71         udp_globals.net_phone = net_connect_module(SERVICE_NETWORKING);
     71        udp_globals.net_phone = net_connect_module();
    7272        if(udp_globals.net_phone < 0){
    7373                return udp_globals.net_phone;
Note: See TracChangeset for help on using the changeset viewer.