Changeset fb4d788 in mainline for uspace/lib


Ignore:
Timestamp:
2015-07-28T11:28:14Z (10 years ago)
Author:
Maurizio Lombardi <m.lombardi85@…>
Branches:
lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
Children:
6accc5cf
Parents:
df2bce32 (diff), 47726b5e (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 the mainline

Location:
uspace/lib
Files:
8 added
17 deleted
31 edited
5 moved

Legend:

Unmodified
Added
Removed

  • uspace/lib/c/Makefile

    rdf2bce32 rfb4d788  
    9797        generic/futex.c \
    9898        generic/inet/addr.c \
     99        generic/inet/endpoint.c \
     100        generic/inet/tcp.c \
     101        generic/inet/udp.c \
    99102        generic/inet.c \
    100103        generic/inetcfg.c \
    … …  
    137140        generic/adt/list.c \
    138141        generic/adt/hash_table.c \
    139         generic/adt/dynamic_fifo.c \
    140         generic/adt/char_map.c \
    141142        generic/adt/prodcons.c \
    142143        generic/time.c \
    … …  
    145146        generic/vfs/vfs.c \
    146147        generic/vfs/canonify.c \
    147         generic/net/inet.c \
    148         generic/net/socket_client.c \
    149         generic/net/socket_parse.c \
    150148        generic/setjmp.c \
    151149        generic/stack.c \

  • uspace/lib/c/generic/fibril.c

    rdf2bce32 rfb4d788  
    5757/**
    5858 * This futex serializes access to ready_list,
    59  * serialized_list and manager_list.
     59 * manager_list and fibril_list.
    6060 */
    6161static futex_t fibril_futex = FUTEX_INITIALIZER;
    6262
    6363static LIST_INITIALIZE(ready_list);
    64 static LIST_INITIALIZE(serialized_list);
    6564static LIST_INITIALIZE(manager_list);
    6665static LIST_INITIALIZE(fibril_list);
    67 
    68 /** Number of threads that are executing a manager fibril. */
    69 static int threads_in_manager;
    70 
    71 /**
    72  * Number of threads that are executing a manager fibril
    73  * and are serialized. Protected by async_futex.
    74  */
    75 static int serialized_threads;
    76 
    77 /** Fibril-local count of serialization. If > 0, we must not preempt */
    78 static fibril_local int serialization_count;
    7966
    8067/** Function that spans the whole life-cycle of a fibril.
    … …  
    9683        fibril->retval = fibril->func(fibril->arg);
    9784       
     85        futex_down(&async_futex);
    9886        fibril_switch(FIBRIL_FROM_DEAD);
    9987        /* Not reached */
    … …  
    126114       
    127115        fibril->waits_for = NULL;
     116
     117        futex_lock(&fibril_futex);
    128118        list_append(&fibril->all_link, &fibril_list);
     119        futex_unlock(&fibril_futex);
    129120       
    130121        return fibril;
    131122}
    132123
    133 void fibril_teardown(fibril_t *fibril)
    134 {
     124void fibril_teardown(fibril_t *fibril, bool locked)
     125{       
     126        if (!locked)
     127                futex_lock(&fibril_futex);
    135128        list_remove(&fibril->all_link);
     129        if (!locked)
     130                futex_unlock(&fibril_futex);
    136131        tls_free(fibril->tcb);
    137132        free(fibril);
    … …  
    140135/** Switch from the current fibril.
    141136 *
    142  * If calling with FIBRIL_TO_MANAGER parameter, the async_futex should be
    143  * held.
     137 * If stype is FIBRIL_TO_MANAGER or FIBRIL_FROM_DEAD, the async_futex must
     138 * be held.
    144139 *
    145140 * @param stype Switch type. One of FIBRIL_PREEMPT, FIBRIL_TO_MANAGER,
    … …  
    153148int fibril_switch(fibril_switch_type_t stype)
    154149{
    155         int retval = 0;
    156        
    157         futex_lock(&fibril_futex);
    158        
    159         if (stype == FIBRIL_PREEMPT && list_empty(&ready_list))
    160                 goto ret_0;
    161        
    162         if (stype == FIBRIL_FROM_MANAGER) {
    163                 if ((list_empty(&ready_list)) && (list_empty(&serialized_list)))
    164                         goto ret_0;
    165                
    166                 /*
    167                  * Do not preempt if there is not enough threads to run the
    168                  * ready fibrils which are not serialized.
    169                  */
    170                 if ((list_empty(&serialized_list)) &&
    171                     (threads_in_manager <= serialized_threads)) {
    172                         goto ret_0;
     150        futex_lock(&fibril_futex);
     151
     152        switch (stype) {
     153        case FIBRIL_PREEMPT:
     154        case FIBRIL_FROM_MANAGER:
     155                if (list_empty(&ready_list)) {
     156                        futex_unlock(&fibril_futex);
     157                        return 0;
    173158                }
    174         }
    175        
    176         /* If we are going to manager and none exists, create it */
    177         if ((stype == FIBRIL_TO_MANAGER) || (stype == FIBRIL_FROM_DEAD)) {
     159                break;
     160        case FIBRIL_TO_MANAGER:
     161        case FIBRIL_FROM_DEAD:
     162                /* Make sure the async_futex is held. */
     163                assert((atomic_signed_t) async_futex.val.count <= 0);
     164
     165                /* If we are going to manager and none exists, create it */
    178166                while (list_empty(&manager_list)) {
    179167                        futex_unlock(&fibril_futex);
    … …  
    181169                        futex_lock(&fibril_futex);
    182170                }
     171                break;
    183172        }
    184173       
    … …  
    188177                /* Save current state */
    189178                if (!context_save(&srcf->ctx)) {
    190                         if (serialization_count)
    191                                 srcf->flags &= ~FIBRIL_SERIALIZED;
    192                        
    193179                        if (srcf->clean_after_me) {
    194180                                /*
    … …  
    208194                                        as_area_destroy(stack);
    209195                                }
    210                                 fibril_teardown(srcf->clean_after_me);
     196                                fibril_teardown(srcf->clean_after_me, true);
    211197                                srcf->clean_after_me = NULL;
    212198                        }
    … …  
    215201                }
    216202               
    217                 /* Save myself to the correct run list */
    218                 if (stype == FIBRIL_PREEMPT)
     203                /* Put the current fibril into the correct run list */
     204                switch (stype) {
     205                case FIBRIL_PREEMPT:
    219206                        list_append(&srcf->link, &ready_list);
    220                 else if (stype == FIBRIL_FROM_MANAGER) {
     207                        break;
     208                case FIBRIL_FROM_MANAGER:
    221209                        list_append(&srcf->link, &manager_list);
    222                         threads_in_manager--;
    223                 } else {
     210                        break;
     211                default:
     212                        assert(stype == FIBRIL_TO_MANAGER);
     213
    224214                        /*
    225                          * If stype == FIBRIL_TO_MANAGER, don't put ourselves to
    226                          * any list, we should already be somewhere, or we will
    227                          * be lost.
     215                         * Don't put the current fibril into any list, it should
     216                         * already be somewhere, or it will be lost.
    228217                         */
     218                        break;
    229219                }
    230220        }
    231221       
     222        fibril_t *dstf;
     223
    232224        /* Choose a new fibril to run */
    233         fibril_t *dstf;
    234         if ((stype == FIBRIL_TO_MANAGER) || (stype == FIBRIL_FROM_DEAD)) {
     225        switch (stype) {
     226        case FIBRIL_TO_MANAGER:
     227        case FIBRIL_FROM_DEAD:
    235228                dstf = list_get_instance(list_first(&manager_list), fibril_t,
    236229                    link);
    237                 if (serialization_count && stype == FIBRIL_TO_MANAGER) {
    238                         serialized_threads++;
    239                         srcf->flags |= FIBRIL_SERIALIZED;
    240                 }
    241                 threads_in_manager++;
    242230               
    243231                if (stype == FIBRIL_FROM_DEAD)
    244232                        dstf->clean_after_me = srcf;
    245         } else {
    246                 if (!list_empty(&serialized_list)) {
    247                         dstf = list_get_instance(list_first(&serialized_list),
    248                             fibril_t, link);
    249                         serialized_threads--;
    250                 } else {
    251                         dstf = list_get_instance(list_first(&ready_list),
    252                             fibril_t, link);
    253                 }
    254         }
     233                break;
     234        default:
     235                dstf = list_get_instance(list_first(&ready_list), fibril_t,
     236                    link);
     237                break;
     238        }
     239
    255240        list_remove(&dstf->link);
    256241       
    … …  
    265250        context_restore(&dstf->ctx);
    266251        /* not reached */
    267        
    268 ret_0:
    269         futex_unlock(&fibril_futex);
    270         return retval;
    271252}
    272253
    … …  
    294275            AS_AREA_LATE_RESERVE);
    295276        if (fibril->stack == (void *) -1) {
    296                 fibril_teardown(fibril);
     277                fibril_teardown(fibril, false);
    297278                return 0;
    298279        }
    … …  
    321302       
    322303        as_area_destroy(fibril->stack);
    323         fibril_teardown(fibril);
     304        fibril_teardown(fibril, false);
    324305}
    325306
    … …  
    335316       
    336317        futex_lock(&fibril_futex);
    337        
    338         if ((fibril->flags & FIBRIL_SERIALIZED))
    339                 list_append(&fibril->link, &serialized_list);
    340         else
    341                 list_append(&fibril->link, &ready_list);
    342        
     318        list_append(&fibril->link, &ready_list);
    343319        futex_unlock(&fibril_futex);
    344320}
    … …  
    363339{
    364340        futex_lock(&fibril_futex);
    365        
    366341        if (!list_empty(&manager_list))
    367342                list_remove(list_first(&manager_list));
    368        
    369343        futex_unlock(&fibril_futex);
    370344}
    … …  
    380354}
    381355
    382 /** Disable preemption
    383  *
    384  * If the fibril wants to send several message in a row and does not want to be
    385  * preempted, it should start async_serialize_start() in the beginning of
    386  * communication and async_serialize_end() in the end. If it is a true
    387  * multithreaded application, it should protect the communication channel by a
    388  * futex as well.
    389  *
    390  */
    391 void fibril_inc_sercount(void)
    392 {
    393         serialization_count++;
    394 }
    395 
    396 /** Restore the preemption counter to the previous state. */
    397 void fibril_dec_sercount(void)
    398 {
    399         serialization_count--;
    400 }
    401 
    402 int fibril_get_sercount(void)
    403 {
    404         return serialization_count;
    405 }
    406 
    407356/** @}
    408357 */

  • uspace/lib/c/generic/fibril_synch.c

    rdf2bce32 rfb4d788  
    105105        fibril_t *f = (fibril_t *) fibril_get_id();
    106106
    107         if (fibril_get_sercount() != 0)
    108                 abort();
    109 
    110107        futex_down(&async_futex);
    111108        if (fm->counter-- <= 0) {
    … …  
    197194        fibril_t *f = (fibril_t *) fibril_get_id();
    198195       
    199         if (fibril_get_sercount() != 0)
    200                 abort();
    201 
    202196        futex_down(&async_futex);
    203197        if (frw->writers) {
    … …  
    224218        fibril_t *f = (fibril_t *) fibril_get_id();
    225219       
    226         if (fibril_get_sercount() != 0)
    227                 abort();
    228 
    229220        futex_down(&async_futex);
    230221        if (frw->writers || frw->readers) {
    … …  
    461452                        if (rc == ETIMEOUT && timer->state == fts_active) {
    462453                                timer->state = fts_fired;
    463                                 timer->handler_running = true;
     454                                timer->handler_fid = fibril_get_id();
    464455                                fibril_mutex_unlock(timer->lockp);
    465456                                timer->fun(timer->arg);
    466457                                fibril_mutex_lock(timer->lockp);
    467                                 timer->handler_running = false;
     458                                timer->handler_fid = 0;
    468459                        }
    469460                        break;
    … …  
    477468        /* Acknowledge timer fibril has finished cleanup. */
    478469        timer->state = fts_clean;
     470        fibril_condvar_broadcast(&timer->cv);
    479471        fibril_mutex_unlock(timer->lockp);
    480         free(timer);
    481472
    482473        return 0;
    … …  
    525516        timer->state = fts_cleanup;
    526517        fibril_condvar_broadcast(&timer->cv);
     518
     519        /* Wait for timer fibril to terminate */
     520        while (timer->state != fts_clean)
     521                fibril_condvar_wait(&timer->cv, timer->lockp);
    527522        fibril_mutex_unlock(timer->lockp);
     523
     524        free(timer);
    528525}
    529526
    … …  
    608605        assert(fibril_mutex_is_locked(timer->lockp));
    609606
    610         while (timer->handler_running)
     607        while (timer->handler_fid != 0) {
     608                if (timer->handler_fid == fibril_get_id()) {
     609                        printf("Deadlock detected.\n");
     610                        stacktrace_print();
     611                        printf("Fibril %zx is trying to clear timer %p from "
     612                            "inside its handler %p.\n",
     613                            fibril_get_id(), timer, timer->fun);
     614                        abort();
     615                }
     616
    611617                fibril_condvar_wait(&timer->cv, timer->lockp);
     618        }
    612619
    613620        old_state = timer->state;

  • uspace/lib/c/generic/getopt.c

    rdf2bce32 rfb4d788  
    9595 * Compute the greatest common divisor of a and b.
    9696 */
    97 static int
    98 gcd(a, b)
    99         int a;
    100         int b;
     97static int gcd(int a, int b)
    10198{
    10299        int c;
    103 
     100       
    104101        c = a % b;
    105102        while (c != 0) {
    … …  
    108105                c = a % b;
    109106        }
    110            
     107       
    111108        return b;
    112109}
    … …  
    117114 * in each block).
    118115 */
    119 static void
    120 permute_args(panonopt_start, panonopt_end, opt_end, nargv)
    121         int panonopt_start;
    122         int panonopt_end;
    123         int opt_end;
    124         char **nargv;
     116static void permute_args(int panonopt_start, int panonopt_end, int opt_end,
     117    char **nargv)
    125118{
    126119        int cstart, cyclelen, i, j, ncycle, nnonopts, nopts, pos;
    … …  
    157150 *  Returns -2 if -- is found (can be long option or end of options marker).
    158151 */
    159 static int
    160 getopt_internal(nargc, nargv, options)
    161         int nargc;
    162         char **nargv;
    163         const char *options;
     152static int getopt_internal(int nargc, char **nargv, const char *options)
    164153{
    165154        const char *oli;                                /* option letter list index */
    … …  
    299288 *      Parse argc/argv argument vector.
    300289 */
    301 int
    302 getopt(nargc, nargv, options)
    303         int nargc;
    304         char * const *nargv;
    305         const char *options;
     290int getopt(int nargc, char * const *nargv, const char *options)
    306291{
    307292        int retval;
    … …  
    332317 *      Parse argc/argv argument vector.
    333318 */
    334 int
    335 getopt_long(nargc, nargv, options, long_options, idx)
    336         int nargc;
    337         char * const *nargv;
    338         const char *options;
    339         const struct option *long_options;
    340         int *idx;
     319int getopt_long(int nargc, char * const *nargv, const char *options,
     320    const struct option *long_options, int *idx)
    341321{
    342322        int retval;

  • uspace/lib/c/generic/inet.c

    rdf2bce32 rfb4d788  
    177177       
    178178        dgram.tos = IPC_GET_ARG1(*icall);
     179        dgram.iplink = IPC_GET_ARG2(*icall);
    179180       
    180181        ipc_callid_t callid;

  • uspace/lib/c/generic/inet/addr.c

    rdf2bce32 rfb4d788  
    11/*
    22 * Copyright (c) 2013 Jiri Svoboda
     3 * Copyright (c) 2013 Martin Decky
    34 * All rights reserved.
    45 *
    … …  
    3637#include <errno.h>
    3738#include <unistd.h>
    38 #include <net/socket_codes.h>
    3939#include <inet/addr.h>
    40 #include <net/inet.h>
    4140#include <stdio.h>
    4241#include <malloc.h>
    … …  
    4443
    4544#define INET_PREFIXSTRSIZE  5
     45
     46#define INET6_ADDRSTRLEN (8 * 4 + 7 + 1)
    4647
    4748#if !(defined(__BE__) ^ defined(__LE__))
    … …  
    180181}
    181182
    182 /** Determine address version.
    183  *
    184  * @param text Address in common notation.
    185  * @param af   Place to store address version.
    186  *
    187  * @return EOK on success, EINVAL if input is not in valid format.
    188  *
    189  */
    190 static int inet_addr_version(const char *text, ip_ver_t *ver)
    191 {
    192         char *dot = str_chr(text, '.');
    193         if (dot != NULL) {
    194                 *ver = ip_v4;
    195                 return EOK;
    196         }
    197 
    198         char *collon = str_chr(text, ':');
    199         if (collon != NULL) {
    200                 *ver = ip_v6;
    201                 return EOK;
    202         }
    203 
    204         return EINVAL;
    205 }
    206 
    207 static int ipver_af(ip_ver_t ver)
    208 {
    209         switch (ver) {
    210         case ip_any:
    211                 return AF_NONE;
    212         case ip_v4:
    213                 return AF_INET;
    214         case ip_v6:
    215                 return AF_INET6;
    216         default:
    217                 assert(false);
    218                 return EINVAL;
    219         }
    220 }
    221 
    222 ip_ver_t ipver_from_af(int af)
    223 {
    224         switch (af) {
    225         case AF_NONE:
    226                 return ip_any;
    227         case AF_INET:
    228                 return ip_v4;
    229         case AF_INET6:
    230                 return ip_v6;
    231         default:
    232                 assert(false);
    233                 return EINVAL;
    234         }
    235 }
    236 
    237183void inet_naddr_addr(const inet_naddr_t *naddr, inet_addr_t *addr)
    238184{
    … …  
    288234        if (naddr->version != addr->version)
    289235                return 0;
    290        
     236
    291237        switch (naddr->version) {
    292238        case ip_v4:
    … …  
    315261                if (naddr->prefix > 128)
    316262                        return 0;
    317                
     263
    318264                size_t pos = 0;
    319265                for (size_t i = 0; i < 16; i++) {
    … …  
    321267                        if (naddr->prefix < pos)
    322268                                break;
    323                        
     269
    324270                        if (naddr->prefix - pos > 8) {
    325271                                /* Comparison without masking */
    … …  
    333279                                        return 0;
    334280                        }
    335                        
     281
    336282                        pos += 8;
    337283                }
    338                
     284
    339285                return 1;
    340286        default:
    … …  
    343289}
    344290
     291static int inet_addr_parse_v4(const char *str, inet_addr_t *raddr,
     292    int *prefix)
     293{
     294        uint32_t a = 0;
     295        uint8_t b;
     296        char *cur = (char *)str;
     297        size_t i = 0;
     298
     299        while (i < 4) {
     300                int rc = str_uint8_t(cur, (const char **)&cur, 10, false, &b);
     301                if (rc != EOK)
     302                        return rc;
     303
     304                a = (a << 8) + b;
     305
     306                i++;
     307
     308                if (*cur == '\0' || *cur == '/')
     309                        break;
     310
     311                if (*cur != '.')
     312                        return EINVAL;
     313
     314                if (i < 4)
     315                        cur++;
     316        }
     317
     318        if (prefix != NULL) {
     319                if (*cur != '/')
     320                        return EINVAL;
     321                cur++;
     322
     323                *prefix = strtoul(cur, &cur, 10);
     324                if (*prefix > 32)
     325                        return EINVAL;
     326        }
     327
     328        if (i != 4 || (*cur != '\0'))
     329                return EINVAL;
     330
     331        raddr->version = ip_v4;
     332        raddr->addr = a;
     333
     334        return EOK;
     335}
     336
     337static int inet_addr_parse_v6(const char *str, inet_addr_t *raddr, int *prefix)
     338{
     339        uint8_t data[16];
     340
     341        memset(data, 0, 16);
     342
     343        const char *cur = str;
     344        size_t i = 0;
     345        size_t wildcard_pos = (size_t) -1;
     346        size_t wildcard_size = 0;
     347
     348        /* Handle initial wildcard */
     349        if ((str[0] == ':') && (str[1] == ':')) {
     350                cur = str + 2;
     351                wildcard_pos = 0;
     352                wildcard_size = 16;
     353
     354                /* Handle the unspecified address */
     355                if (*cur == '\0')
     356                        goto success;
     357        }
     358
     359        while (i < 16) {
     360                uint16_t bioctet;
     361                int rc = str_uint16_t(cur, &cur, 16, false, &bioctet);
     362                if (rc != EOK)
     363                        return rc;
     364
     365                data[i] = (bioctet >> 8) & 0xff;
     366                data[i + 1] = bioctet & 0xff;
     367
     368                if (wildcard_pos != (size_t) -1) {
     369                        if (wildcard_size < 2)
     370                                return EINVAL;
     371
     372                        wildcard_size -= 2;
     373                }
     374
     375                i += 2;
     376
     377                if (*cur != ':')
     378                        break;
     379
     380                if (i < 16) {
     381                        cur++;
     382
     383                        /* Handle wildcard */
     384                        if (*cur == ':') {
     385                                if (wildcard_pos != (size_t) -1)
     386                                        return EINVAL;
     387
     388                                wildcard_pos = i;
     389                                wildcard_size = 16 - i;
     390                                cur++;
     391
     392                                if (*cur == '\0' || *cur == '/')
     393                                        break;
     394                        }
     395                }
     396        }
     397
     398        if (prefix != NULL) {
     399                if (*cur != '/')
     400                        return EINVAL;
     401                cur++;
     402
     403                *prefix = strtoul(cur, (char **)&cur, 10);
     404                if (*prefix > 128)
     405                        return EINVAL;
     406        }
     407
     408        if (*cur != '\0')
     409                return EINVAL;
     410
     411        /* Create wildcard positions */
     412        if ((wildcard_pos != (size_t) -1) && (wildcard_size > 0)) {
     413                size_t wildcard_shift = 16 - wildcard_size;
     414
     415                for (i = wildcard_pos + wildcard_shift; i > wildcard_pos; i--) {
     416                        size_t j = i - 1;
     417                        data[j + wildcard_size] = data[j];
     418                        data[j] = 0;
     419                }
     420        }
     421
     422success:
     423        raddr->version = ip_v6;
     424        memcpy(raddr->addr6, data, 16);
     425        return EOK;
     426}
     427
    345428/** Parse node address.
    346429 *
    … …  
    353436int inet_addr_parse(const char *text, inet_addr_t *addr)
    354437{
    355         int rc = inet_addr_version(text, &addr->version);
    356         if (rc != EOK)
    357                 return rc;
    358        
    359         uint8_t buf[16];
    360         rc = inet_pton(ipver_af(addr->version), text, buf);
    361         if (rc != EOK)
    362                 return rc;
    363        
    364         switch (addr->version) {
    365         case ip_v4:
    366                 addr->addr = (buf[0] << 24) | (buf[1] << 16) | (buf[2] << 8) |
    367                     buf[3];
    368                 break;
    369         case ip_v6:
    370                 memcpy(addr->addr6, buf, 16);
    371                 break;
    372         default:
    373                 return EINVAL;
    374         }
    375        
    376         return EOK;
     438        int rc;
     439
     440        rc = inet_addr_parse_v4(text, addr, NULL);
     441        if (rc == EOK)
     442                return EOK;
     443
     444        rc = inet_addr_parse_v6(text, addr, NULL);
     445        if (rc == EOK)
     446                return EOK;
     447
     448        return EINVAL;
    377449}
    378450
    … …  
    387459int inet_naddr_parse(const char *text, inet_naddr_t *naddr)
    388460{
    389         char *slash = str_chr(text, '/');
    390         if (slash == NULL)
    391                 return EINVAL;
    392        
    393         *slash = 0;
    394        
    395         int rc = inet_addr_version(text, &naddr->version);
    396         if (rc != EOK)
    397                 return rc;
    398        
    399         uint8_t buf[16];
    400         rc = inet_pton(ipver_af(naddr->version), text, buf);
    401         *slash = '/';
    402        
    403         if (rc != EOK)
    404                 return rc;
    405        
    406         slash++;
    407         uint8_t prefix;
    408        
    409         switch (naddr->version) {
    410         case ip_v4:
    411                 prefix = strtoul(slash, &slash, 10);
    412                 if (prefix > 32)
     461        int rc;
     462        inet_addr_t addr;
     463        int prefix;
     464
     465        rc = inet_addr_parse_v4(text, &addr, &prefix);
     466        if (rc == EOK) {
     467                inet_addr_naddr(&addr, prefix, naddr);
     468                return EOK;
     469        }
     470
     471        rc = inet_addr_parse_v6(text, &addr, &prefix);
     472        if (rc == EOK) {
     473                inet_addr_naddr(&addr, prefix, naddr);
     474                return EOK;
     475        }
     476
     477        return EINVAL;
     478}
     479
     480static int inet_addr_format_v4(addr32_t addr, char **bufp)
     481{
     482        int rc;
     483
     484        rc = asprintf(bufp, "%u.%u.%u.%u", (addr >> 24) & 0xff,
     485            (addr >> 16) & 0xff, (addr >> 8) & 0xff, addr & 0xff);
     486        if (rc < 0)
     487                return ENOMEM;
     488
     489        return EOK;
     490}
     491
     492static int inet_addr_format_v6(const addr128_t addr, char **bufp)
     493{
     494        *bufp = (char *) malloc(INET6_ADDRSTRLEN);
     495        if (*bufp == NULL)
     496                return ENOMEM;
     497
     498        /* Find the longest zero subsequence */
     499
     500        uint16_t zeroes[8];
     501        uint16_t bioctets[8];
     502
     503        for (size_t i = 8; i > 0; i--) {
     504                size_t j = i - 1;
     505
     506                bioctets[j] = (addr[j << 1] << 8) | addr[(j << 1) + 1];
     507
     508                if (bioctets[j] == 0) {
     509                        zeroes[j] = 1;
     510                        if (j < 7)
     511                                zeroes[j] += zeroes[j + 1];
     512                } else
     513                        zeroes[j] = 0;
     514        }
     515
     516        size_t wildcard_pos = (size_t) -1;
     517        size_t wildcard_size = 0;
     518
     519        for (size_t i = 0; i < 8; i++) {
     520                if (zeroes[i] > wildcard_size) {
     521                        wildcard_pos = i;
     522                        wildcard_size = zeroes[i];
     523                }
     524        }
     525
     526        char *cur = *bufp;
     527        size_t rest = INET6_ADDRSTRLEN;
     528        bool tail_zero = false;
     529        int ret;
     530
     531        for (size_t i = 0; i < 8; i++) {
     532                if ((i == wildcard_pos) && (wildcard_size > 1)) {
     533                        ret = snprintf(cur, rest, ":");
     534                        i += wildcard_size - 1;
     535                        tail_zero = true;
     536                } else if (i == 0) {
     537                        ret = snprintf(cur, rest, "%" PRIx16, bioctets[i]);
     538                        tail_zero = false;
     539                } else {
     540                        ret = snprintf(cur, rest, ":%" PRIx16, bioctets[i]);
     541                        tail_zero = false;
     542                }
     543
     544                if (ret < 0)
    413545                        return EINVAL;
    414                
    415                 naddr->addr = (buf[0] << 24) | (buf[1] << 16) | (buf[2] << 8) |
    416                     buf[3];
    417                 naddr->prefix = prefix;
    418                
    419                 break;
    420         case ip_v6:
    421                 prefix = strtoul(slash, &slash, 10);
    422                 if (prefix > 128)
    423                         return EINVAL;
    424                
    425                 memcpy(naddr->addr6, buf, 16);
    426                 naddr->prefix = prefix;
    427                
    428                 break;
    429         default:
    430                 return ENOTSUP;
    431         }
    432        
     546
     547                cur += ret;
     548                rest -= ret;
     549        }
     550
     551        if (tail_zero)
     552                (void) snprintf(cur, rest, ":");
     553
    433554        return EOK;
    434555}
    … …  
    446567int inet_addr_format(const inet_addr_t *addr, char **bufp)
    447568{
    448         int rc = 0;
    449        
     569        int rc;
     570
     571        rc = ENOTSUP;
     572
    450573        switch (addr->version) {
    451574        case ip_any:
    452575                rc = asprintf(bufp, "none");
     576                if (rc < 0)
     577                        return ENOMEM;
     578                rc = EOK;
    453579                break;
    454580        case ip_v4:
    455                 rc = asprintf(bufp, "%u.%u.%u.%u", (addr->addr >> 24) & 0xff,
    456                     (addr->addr >> 16) & 0xff, (addr->addr >> 8) & 0xff,
    457                     addr->addr & 0xff);
     581                rc = inet_addr_format_v4(addr->addr, bufp);
    458582                break;
    459583        case ip_v6:
    460                 *bufp = (char *) malloc(INET6_ADDRSTRLEN);
    461                 if (*bufp == NULL)
    462                         return ENOMEM;
    463                
    464                 return inet_ntop(AF_INET6, addr->addr6, *bufp, INET6_ADDRSTRLEN);
    465         default:
    466                 return ENOTSUP;
    467         }
    468        
    469         if (rc < 0)
    470                 return ENOMEM;
    471        
    472         return EOK;
     584                rc = inet_addr_format_v6(addr->addr6, bufp);
     585                break;
     586        }
     587
     588        return rc;
    473589}
    474590
    … …  
    485601int inet_naddr_format(const inet_naddr_t *naddr, char **bufp)
    486602{
    487         int rc = 0;
    488         char prefix[INET_PREFIXSTRSIZE];
    489        
     603        int rc;
     604        char *astr;
     605
     606        rc = ENOTSUP;
     607
    490608        switch (naddr->version) {
    491609        case ip_any:
    492610                rc = asprintf(bufp, "none");
     611                if (rc < 0)
     612                        return ENOMEM;
     613                rc = EOK;
    493614                break;
    494615        case ip_v4:
    495                 rc = asprintf(bufp, "%" PRIu8 ".%" PRIu8 ".%" PRIu8 ".%" PRIu8
    496                     "/%" PRIu8, (naddr->addr >> 24) & 0xff,
    497                     (naddr->addr >> 16) & 0xff, (naddr->addr >> 8) & 0xff,
    498                     naddr->addr & 0xff, naddr->prefix);
    499                 break;
    500         case ip_v6:
    501                 *bufp = (char *) malloc(INET6_ADDRSTRLEN + INET_PREFIXSTRSIZE);
    502                 if (*bufp == NULL)
     616                rc = inet_addr_format_v4(naddr->addr, &astr);
     617                if (rc != EOK)
    503618                        return ENOMEM;
    504                
    505                 rc = inet_ntop(AF_INET6, naddr->addr6, *bufp,
    506                     INET6_ADDRSTRLEN + INET_PREFIXSTRSIZE);
    507                 if (rc != EOK) {
    508                         free(*bufp);
    509                         return rc;
    510                 }
    511                
    512                 rc = snprintf(prefix, INET_PREFIXSTRSIZE, "/%" PRIu8,
    513                     naddr->prefix);
     619
     620                rc = asprintf(bufp, "%s/%" PRIu8, astr, naddr->prefix);
    514621                if (rc < 0) {
    515                         free(*bufp);
     622                        free(astr);
    516623                        return ENOMEM;
    517624                }
    518                
    519                 str_append(*bufp, INET6_ADDRSTRLEN + INET_PREFIXSTRSIZE, prefix);
    520                
    521                 break;
    522         default:
    523                 return ENOTSUP;
    524         }
    525        
    526         if (rc < 0)
    527                 return ENOMEM;
    528        
    529         return EOK;
     625
     626                rc = EOK;
     627                break;
     628        case ip_v6:
     629                rc = inet_addr_format_v6(naddr->addr6, &astr);
     630                if (rc != EOK)
     631                        return ENOMEM;
     632
     633                rc = asprintf(bufp, "%s/%" PRIu8, astr, naddr->prefix);
     634                if (rc < 0) {
     635                        free(astr);
     636                        return ENOMEM;
     637                }
     638
     639                rc = EOK;
     640                break;
     641        }
     642
     643        return rc;
    530644}
    531645
    … …  
    586700}
    587701
    588 void inet_sockaddr_in_addr(const sockaddr_in_t *sockaddr_in, inet_addr_t *addr)
    589 {
    590         addr->version = ip_v4;
    591         addr->addr = uint32_t_be2host(sockaddr_in->sin_addr.s_addr);
    592 }
    593 
    594702void inet_addr_set6(addr128_t v6, inet_addr_t *addr)
    595703{
    … …  
    605713}
    606714
    607 void inet_sockaddr_in6_addr(const sockaddr_in6_t *sockaddr_in6,
    608     inet_addr_t *addr)
    609 {
    610         addr->version = ip_v6;
    611         addr128_t_be2host(sockaddr_in6->sin6_addr.s6_addr, addr->addr6);
    612 }
    613 
    614 uint16_t inet_addr_sockaddr_in(const inet_addr_t *addr,
    615     sockaddr_in_t *sockaddr_in, sockaddr_in6_t *sockaddr_in6)
    616 {
    617         switch (addr->version) {
    618         case ip_v4:
    619                 if (sockaddr_in != NULL) {
    620                         sockaddr_in->sin_family = AF_INET;
    621                         sockaddr_in->sin_addr.s_addr = host2uint32_t_be(addr->addr);
    622                 }
    623                 break;
    624         case ip_v6:
    625                 if (sockaddr_in6 != NULL) {
    626                         sockaddr_in6->sin6_family = AF_INET6;
    627                         host2addr128_t_be(addr->addr6, sockaddr_in6->sin6_addr.s6_addr);
    628                 }
    629                 break;
    630         default:
    631                 assert(false);
    632                 break;
    633         }
    634 
    635         return ipver_af(addr->version);
    636 }
    637 
    638 int inet_addr_sockaddr(const inet_addr_t *addr, uint16_t port,
    639     sockaddr_t **nsockaddr, socklen_t *naddrlen)
    640 {
    641         sockaddr_in_t *sa4;
    642         sockaddr_in6_t *sa6;
    643 
    644         switch (addr->version) {
    645         case ip_v4:
    646                 sa4 = calloc(1, sizeof(sockaddr_in_t));
    647                 if (sa4 == NULL)
    648                         return ENOMEM;
    649 
    650                 sa4->sin_family = AF_INET;
    651                 sa4->sin_port = host2uint16_t_be(port);
    652                 sa4->sin_addr.s_addr = host2uint32_t_be(addr->addr);
    653                 if (nsockaddr != NULL)
    654                         *nsockaddr = (sockaddr_t *)sa4;
    655                 if (naddrlen != NULL)
    656                         *naddrlen = sizeof(*sa4);
    657                 break;
    658         case ip_v6:
    659                 sa6 = calloc(1, sizeof(sockaddr_in6_t));
    660                 if (sa6 == NULL)
    661                         return ENOMEM;
    662 
    663                 sa6->sin6_family = AF_INET6;
    664                 sa6->sin6_port = host2uint16_t_be(port);
    665                 host2addr128_t_be(addr->addr6, sa6->sin6_addr.s6_addr);
    666                 if (nsockaddr != NULL)
    667                         *nsockaddr = (sockaddr_t *)sa6;
    668                 if (naddrlen != NULL)
    669                         *naddrlen = sizeof(*sa6);
    670                 break;
    671         default:
    672                 assert(false);
    673                 break;
    674         }
    675 
    676         return EOK;
    677 }
    678 
    679715/** @}
    680716 */

  • uspace/lib/c/generic/inet/endpoint.c

    rdf2bce32 rfb4d788  
    11/*
    2  * Copyright (c) 2009 Lukas Mejdrech
     2 * Copyright (c) 2015 Jiri Svoboda
    33 * All rights reserved.
    44 *
    … …  
    2727 */
    2828
    29 /** @addtogroup socket
     29/** @addtogroup libc
    3030 * @{
    3131 */
    32 
    33 /** @file
    34  * Command-line argument parsing functions related to networking.
     32/** @file Internet endpoint
    3533 */
    3634
    37 extern int socket_parse_address_family(const char *, int *);
    38 extern int socket_parse_protocol_family(const char *, int *);
    39 extern int socket_parse_socket_type(const char *, int *);
     35#include <inet/endpoint.h>
     36#include <mem.h>
     37
     38void inet_ep_init(inet_ep_t *ep)
     39{
     40        memset(ep, 0, sizeof(*ep));
     41}
     42
     43void inet_ep2_init(inet_ep2_t *ep2)
     44{
     45        memset(ep2, 0, sizeof(*ep2));
     46}
    4047
    4148/** @}

  • uspace/lib/c/generic/iplink.c

    rdf2bce32 rfb4d788  
    4747static void iplink_cb_conn(ipc_callid_t iid, ipc_call_t *icall, void *arg);
    4848
    49 int iplink_open(async_sess_t *sess, iplink_ev_ops_t *ev_ops,
     49int iplink_open(async_sess_t *sess, iplink_ev_ops_t *ev_ops, void *arg,
    5050    iplink_t **riplink)
    5151{
    … …  
    5656        iplink->sess = sess;
    5757        iplink->ev_ops = ev_ops;
     58        iplink->arg = arg;
    5859       
    5960        async_exch_t *exch = async_exchange_begin(sess);
    … …  
    234235       
    235236        return (int) retval;
     237}
     238
     239void *iplink_get_userptr(iplink_t *iplink)
     240{
     241        return iplink->arg;
    236242}
    237243

  • uspace/lib/c/generic/irq.c

    rdf2bce32 rfb4d788  
    3535#include <ipc/irq.h>
    3636#include <libc.h>
     37#include <stdlib.h>
     38#include <macros.h>
     39
     40static irq_cmd_t default_cmds[] = {
     41        {
     42                .cmd = CMD_ACCEPT
     43        }
     44};
     45
     46static const irq_code_t default_ucode = {
     47        0,
     48        NULL,
     49        ARRAY_SIZE(default_cmds),
     50        default_cmds
     51};
    3752
    3853/** Subscribe to IRQ notification.
    … …  
    4964    const irq_code_t *ucode)
    5065{
     66        if (ucode == NULL)
     67                ucode = &default_ucode;
     68       
    5169        return __SYSCALL4(SYS_IPC_IRQ_SUBSCRIBE, inr, devno, method,
    5270            (sysarg_t) ucode);

  • uspace/lib/c/generic/libc.c

    rdf2bce32 rfb4d788  
    122122                __stdio_done();
    123123                task_retval(status);
    124                 fibril_teardown(__tcb_get()->fibril_data);
     124                fibril_teardown(__tcb_get()->fibril_data, false);
    125125        }
    126126       

  • uspace/lib/c/generic/thread.c

    rdf2bce32 rfb4d788  
    8888#endif
    8989       
    90         fibril_teardown(fibril);
     90        fibril_teardown(fibril, false);
    9191       
    9292        thread_exit(0);

  • uspace/lib/c/include/async.h

    rdf2bce32 rfb4d788  
    108108
    109109#define async_manager() \
    110         fibril_switch(FIBRIL_TO_MANAGER)
     110        do { \
     111                futex_down(&async_futex); \
     112                fibril_switch(FIBRIL_FROM_DEAD); \
     113        } while (0)
    111114
    112115#define async_get_call(data) \

  • uspace/lib/c/include/errno.h

    rdf2bce32 rfb4d788  
    6868#define ENAK (-303)
    6969
    70 /** An API function is called while another blocking function is in progress. */
    71 #define EINPROGRESS  (-10036)
    72 
    73 /** The socket identifier is not valid. */
    74 #define ENOTSOCK  (-10038)
    75 
    76 /** The destination address required. */
    77 #define EDESTADDRREQ  (-10039)
    78 
    79 /** Protocol is not supported.  */
    80 #define EPROTONOSUPPORT  (-10043)
    81 
    82 /** Socket type is not supported. */
    83 #define ESOCKTNOSUPPORT  (-10044)
    84 
    85 /** Protocol family is not supported. */
    86 #define EPFNOSUPPORT  (-10046)
    87 
    88 /** Address family is not supported. */
    89 #define EAFNOSUPPORT  (-10047)
    90 
    91 /** Address is already in use. */
    92 #define EADDRINUSE  (-10048)
    93 
    94 /** The socket is not connected or bound. */
    95 #define ENOTCONN  (-10057)
    96 
    97 #define ECONNREFUSED  (-10058)
    98 
    99 #define ECONNABORTED  (-10059)
    100 
    10170/** The requested operation was not performed. Try again later. */
    10271#define EAGAIN  (-11002)
    103 
    104 /** No data. */
    105 #define NO_DATA (-11004)
    10672
    10773#endif

  • uspace/lib/c/include/fibril.h

    rdf2bce32 rfb4d788  
    4747        } while (0)
    4848
    49 #define FIBRIL_SERIALIZED  1
    50 #define FIBRIL_WRITER      2
     49#define FIBRIL_WRITER   1
    5150
    5251struct fibril;
    … …  
    9493extern void fibril_destroy(fid_t fid);
    9594extern fibril_t *fibril_setup(void);
    96 extern void fibril_teardown(fibril_t *f);
     95extern void fibril_teardown(fibril_t *f, bool locked);
    9796extern int fibril_switch(fibril_switch_type_t stype);
    9897extern void fibril_add_ready(fid_t fid);

  • uspace/lib/c/include/fibril_synch.h

    rdf2bce32 rfb4d788  
    135135        fid_t fibril;
    136136        fibril_timer_state_t state;
    137         bool handler_running;
     137        /** FID of fibril executing handler or 0 if handler is not running */
     138        fid_t handler_fid;
    138139
    139140        suseconds_t delay;

  • uspace/lib/c/include/inet/addr.h

    rdf2bce32 rfb4d788  
    3737
    3838#include <stdint.h>
    39 #include <net/in.h>
    40 #include <net/in6.h>
    41 #include <net/socket.h>
    4239
    4340typedef uint32_t addr32_t;
    … …  
    126123extern void inet_addr_set(addr32_t, inet_addr_t *);
    127124extern void inet_naddr_set(addr32_t, uint8_t, inet_naddr_t *);
    128 extern void inet_sockaddr_in_addr(const sockaddr_in_t *, inet_addr_t *);
    129125
    130126extern void inet_addr_set6(addr128_t, inet_addr_t *);
    131127extern void inet_naddr_set6(addr128_t, uint8_t, inet_naddr_t *);
    132 extern void inet_sockaddr_in6_addr(const sockaddr_in6_t *, inet_addr_t *);
    133 
    134 extern uint16_t inet_addr_sockaddr_in(const inet_addr_t *, sockaddr_in_t *,
    135     sockaddr_in6_t *);
    136 
    137 extern ip_ver_t ipver_from_af(int af);
    138 extern int inet_addr_sockaddr(const inet_addr_t *, uint16_t, sockaddr_t **,
    139     socklen_t *);
    140128
    141129#endif

  • uspace/lib/c/include/inet/endpoint.h

    rdf2bce32 rfb4d788  
    11/*
    2  * Copyright (c) 2009 Lukas Mejdrech
     2 * Copyright (c) 2015 Jiri Svoboda
    33 * All rights reserved.
    44 *
    … …  
    2828
    2929/** @addtogroup libc
    30  *  @{
     30 * @{
     31 */
     32/** @file
    3133 */
    3234
    33 /** @file
    34  *  Character string to integer map.
     35#ifndef LIBC_INET_ASSOC_H_
     36#define LIBC_INET_ASSOC_H_
     37
     38#include <stdint.h>
     39#include <inet/addr.h>
     40#include <loc.h>
     41
     42/** Internet port number ranges
     43 *
     44 * Port number ranges per RFC 6335 section 6 (Port Number Ranges.
     45 * Technically port zero is a system port. But since it is reserved,
     46 * we will use it as a special value denoting no port is specified
     47 * and we will exclude it from the system port range to disallow
     48 * ever assigning it.
    3549 */
    36 
    37 #ifndef LIBC_CHAR_MAP_H_
    38 #define LIBC_CHAR_MAP_H_
    39 
    40 #include <libarch/types.h>
    41 
    42 /** Invalid assigned value used also if an&nbsp;entry does not exist. */
    43 #define CHAR_MAP_NULL  (-1)
    44 
    45 /** Type definition of the character string to integer map.
    46  *  @see char_map
    47  */
    48 typedef struct char_map char_map_t;
    49 
    50 /** Character string to integer map item.
    51  *
    52  * This structure recursivelly contains itself as a character by character tree.
    53  * The actually mapped character string consists of all the parent characters
    54  * and the actual one.
    55  */
    56 struct char_map {
    57         /** Actually mapped character. */
    58         uint8_t c;
    59         /** Stored integral value. */
    60         int value;
    61         /** Next character array size. */
    62         int size;
    63         /** First free position in the next character array. */
    64         int next;
    65         /** Next character array. */
    66         char_map_t **items;
    67         /** Consistency check magic value. */
    68         int magic;
     50enum inet_port_ranges {
     51        /** Special value meaning no specific port */
     52        inet_port_any = 0,
     53        /** Lowest system port (a.k.a. well known port) */
     54        inet_port_sys_lo = 1,
     55        /** Highest system port (a.k.a. well known port) */
     56        inet_port_sys_hi = 1023,
     57        /** Lowest user port (a.k.a. registered port) */
     58        inet_port_user_lo = 1024,
     59        /** Highest user port (a.k.a. registered port) */
     60        inet_port_user_hi = 49151,
     61        /** Lowest dynamic port (a.k.a. private or ephemeral port) */
     62        inet_port_dyn_lo = 49152,
     63        /** Highest dynamic port (a.k.a. private or ephemeral port) */
     64        inet_port_dyn_hi = 65535
    6965};
    7066
    71 extern int char_map_initialize(char_map_t *);
    72 extern void char_map_destroy(char_map_t *);
    73 extern int char_map_exclude(char_map_t *, const uint8_t *, size_t);
    74 extern int char_map_add(char_map_t *, const uint8_t *, size_t, const int);
    75 extern int char_map_find(const char_map_t *, const uint8_t *, size_t);
    76 extern int char_map_update(char_map_t *, const uint8_t *, size_t, const int);
     67/** Internet endpoint (address-port pair), a.k.a. socket */
     68typedef struct {
     69        inet_addr_t addr;
     70        uint16_t port;
     71} inet_ep_t;
     72
     73/** Internet endpoint pair */
     74typedef struct {
     75        service_id_t local_link;
     76        inet_ep_t local;
     77        inet_ep_t remote;
     78} inet_ep2_t;
     79
     80extern void inet_ep_init(inet_ep_t *);
     81extern void inet_ep2_init(inet_ep2_t *);
    7782
    7883#endif

  • uspace/lib/c/include/inet/iplink.h

    rdf2bce32 rfb4d788  
    4444        async_sess_t *sess;
    4545        struct iplink_ev_ops *ev_ops;
     46        void *arg;
    4647} iplink_t;
    4748
    … …  
    8182} iplink_ev_ops_t;
    8283
    83 extern int iplink_open(async_sess_t *, iplink_ev_ops_t *, iplink_t **);
     84extern int iplink_open(async_sess_t *, iplink_ev_ops_t *, void *, iplink_t **);
    8485extern void iplink_close(iplink_t *);
    8586extern int iplink_send(iplink_t *, iplink_sdu_t *);
    … …  
    9091extern int iplink_get_mac48(iplink_t *, addr48_t *);
    9192extern int iplink_set_mac48(iplink_t *, addr48_t);
     93extern void *iplink_get_userptr(iplink_t *);
    9294
    9395#endif

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

    rdf2bce32 rfb4d788  
    4949        SERVICE_IRC        = FOURCC('i', 'r', 'c', ' '),
    5050        SERVICE_CLIPBOARD  = FOURCC('c', 'l', 'i', 'p'),
    51         SERVICE_UDP        = FOURCC('u', 'd', 'p', ' '),
    52         SERVICE_TCP        = FOURCC('t', 'c', 'p', ' ')
    5351} services_t;
    5452
    … …  
    6159#define SERVICE_NAME_INETPING6  "net/inetping6"
    6260#define SERVICE_NAME_NETCONF    "net/netconf"
     61#define SERVICE_NAME_UDP        "net/udp"
     62#define SERVICE_NAME_TCP        "net/tcp"
    6363
    6464#endif

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

    rdf2bce32 rfb4d788  
    11/*
    2  * Copyright (c) 2009 Lukas Mejdrech
     2 * Copyright (c) 2015 Jiri Svobda
    33 * All rights reserved.
    44 *
    … …  
    2727 */
    2828
    29 /** @addtogroup libc
    30  *  @{
     29/** @addtogroup libcipc
     30 * @{
     31 */
     32/** @file
    3133 */
    3234
    33 /** @file
    34  * Internet protocol numbers according to the on-line IANA - Assigned Protocol
    35  * numbers:
    36  *
    37  * http://www.iana.org/assignments/protocol-numbers/protocol-numbers.xml
    38  */
     35#ifndef LIBC_IPC_UDP_H_
     36#define LIBC_IPC_UDP_H_
    3937
    40 #ifndef LIBC_IP_PROTOCOLS_H_
    41 #define LIBC_IP_PROTOCOLS_H_
     38#include <ipc/common.h>
    4239
    43 /** @name IP protocols definitions */
    44 /*@{*/
     40typedef enum {
     41        UDP_CALLBACK_CREATE = IPC_FIRST_USER_METHOD,
     42        UDP_ASSOC_CREATE,
     43        UDP_ASSOC_DESTROY,
     44        UDP_ASSOC_SEND_MSG,
     45        UDP_RMSG_INFO,
     46        UDP_RMSG_READ,
     47        UDP_RMSG_DISCARD
     48} udp_request_t;
    4549
    46 #define IPPROTO_ICMP    1
    47 #define IPPROTO_TCP     6
    48 #define IPPROTO_UDP     17
    49 #define IPPROTO_ICMPV6  58
    50 
    51 /*@}*/
     50typedef enum {
     51        UDP_EV_DATA = IPC_FIRST_USER_METHOD
     52} udp_event_t;
    5253
    5354#endif

  • uspace/lib/c/include/malloc.h

    rdf2bce32 rfb4d788  
    4444extern void *memalign(const size_t align, const size_t size)
    4545    __attribute__((malloc));
    46 extern void *realloc(const void *addr, const size_t size);
     46extern void *realloc(const void *addr, const size_t size)
     47    __attribute__((warn_unused_result));
    4748extern void free(const void *addr);
    4849extern void *heap_check(void);

  • uspace/lib/c/include/mem.h

    rdf2bce32 rfb4d788  
    4040
    4141extern void *memset(void *, int, size_t)
     42    __attribute__((nonnull(1)))
    4243    ATTRIBUTE_OPTIMIZE("-fno-tree-loop-distribute-patterns");
    4344extern void *memcpy(void *, const void *, size_t)
     45    __attribute__((nonnull(1, 2)))
    4446    ATTRIBUTE_OPTIMIZE("-fno-tree-loop-distribute-patterns");
    45 extern void *memmove(void *, const void *, size_t);
    46 extern int memcmp(const void *, const void *, size_t);
     47extern void *memmove(void *, const void *, size_t)
     48    __attribute__((nonnull(1, 2)));
     49extern int memcmp(const void *, const void *, size_t)
     50    __attribute__((nonnull(1, 2)));
    4751
    4852#endif

  • uspace/lib/c/include/task.h

    rdf2bce32 rfb4d788  
    6060extern int task_spawn(task_id_t *, task_wait_t *, const char *path, int,
    6161    va_list ap);
    62 extern int task_spawnl(task_id_t *, task_wait_t *, const char *path, ...);
     62extern int task_spawnl(task_id_t *, task_wait_t *, const char *path, ...)
     63    __attribute__((sentinel));
    6364
    6465extern int task_setup_wait(task_id_t, task_wait_t *);

  • uspace/lib/drv/generic/interrupt.c

    rdf2bce32 rfb4d788  
    4444#include "private/driver.h"
    4545
    46 static irq_cmd_t default_cmds[] = {
    47         {
    48                 .cmd = CMD_ACCEPT
    49         }
    50 };
    51 
    52 static const irq_code_t default_pseudocode = {
    53         0,
    54         NULL,
    55         ARRAY_SIZE(default_cmds),
    56         default_cmds
    57 };
    58 
    5946int register_interrupt_handler(ddf_dev_t *dev, int irq,
    6047    interrupt_handler_t *handler, const irq_code_t *pseudocode)

  • uspace/lib/http/include/http/http.h

    rdf2bce32 rfb4d788  
    3737#define HTTP_HTTP_H_
    3838
    39 #include <net/socket.h>
    4039#include <adt/list.h>
    4140#include <inet/addr.h>
     41#include <inet/tcp.h>
    4242
    4343#include "receive-buffer.h"
    … …  
    4848        inet_addr_t addr;
    4949
    50         bool connected;
    51         int conn_sd;
    52        
     50        tcp_t *tcp;
     51        tcp_conn_t *conn;
     52
    5353        size_t buffer_size;
    5454        receive_buffer_t recv_buffer;

  • uspace/lib/http/src/http.c

    rdf2bce32 rfb4d788  
    3434 */
    3535
     36#include <errno.h>
    3637#include <stdio.h>
    3738#include <stdlib.h>
    … …  
    3940#include <macros.h>
    4041
    41 #include <net/socket.h>
    4242#include <inet/dnsr.h>
     43#include <inet/tcp.h>
    4344
    4445#include <http/http.h>
    … …  
    4849{
    4950        http_t *http = client_data;
    50         return recv(http->conn_sd, buf, buf_size, 0);
     51        size_t nrecv;
     52        int rc;
     53
     54        rc = tcp_conn_recv_wait(http->conn, buf, buf_size, &nrecv);
     55        if (rc != EOK)
     56                return rc;
     57
     58        return nrecv;
    5159}
    5260
    … …  
    7785int http_connect(http_t *http)
    7886{
    79         if (http->connected)
     87        if (http->conn != NULL)
    8088                return EBUSY;
    8189       
    … …  
    95103        }
    96104       
    97         struct sockaddr *saddr;
    98         socklen_t saddrlen;
     105        inet_ep2_t epp;
    99106       
    100         rc = inet_addr_sockaddr(&http->addr, http->port, &saddr, &saddrlen);
    101         if (rc != EOK) {
    102                 assert(rc == ENOMEM);
    103                 return ENOMEM;
    104         }
     107        inet_ep2_init(&epp);
     108        epp.remote.addr = http->addr;
     109        epp.remote.port = http->port;
    105110       
    106         http->conn_sd = socket(saddr->sa_family, SOCK_STREAM, 0);
    107         if (http->conn_sd < 0)
    108                 return http->conn_sd;
     111        rc = tcp_create(&http->tcp);
     112        if (rc != EOK)
     113                return rc;
    109114       
    110         rc = connect(http->conn_sd, saddr, saddrlen);
    111         free(saddr);
     115        rc = tcp_conn_create(http->tcp, &epp, NULL, NULL, &http->conn);
     116        if (rc != EOK)
     117                return rc;
     118       
     119        rc = tcp_conn_wait_connected(http->conn);
     120        if (rc != EOK)
     121                return rc;
    112122       
    113123        return rc;
    … …  
    116126int http_close(http_t *http)
    117127{
    118         if (!http->connected)
     128        if (http->conn == NULL)
    119129                return EINVAL;
    120130       
    121         return closesocket(http->conn_sd);
     131        tcp_conn_destroy(http->conn);
     132        tcp_destroy(http->tcp);
     133        return EOK;
    122134}
    123135

  • uspace/lib/http/src/request.c

    rdf2bce32 rfb4d788  
    3434 */
    3535
     36#include <errno.h>
    3637#include <stdio.h>
    3738#include <stdlib.h>
    … …  
    3940#include <macros.h>
    4041
    41 #include <net/socket.h>
     42#include <inet/tcp.h>
    4243
    4344#include <http/http.h>
    … …  
    149150                return rc;
    150151       
    151         rc = send(http->conn_sd, buf, buf_size, 0);
     152        rc = tcp_conn_send(http->conn, buf, buf_size);
    152153        free(buf);
    153154       

  • uspace/lib/ieee80211/src/ieee80211.c

    rdf2bce32 rfb4d788  
    718718 *
    719719 */
    720 ieee80211_dev_t *ieee80211_device_create()
     720ieee80211_dev_t *ieee80211_device_create(void)
    721721{
    722722        return calloc(1, sizeof(ieee80211_dev_t));

  • uspace/lib/nettl/Makefile

    rdf2bce32 rfb4d788  
    11#
    2 # Copyright (c) 2005 Martin Decky
    3 # Copyright (c) 2007 Jakub Jermar
     2# Copyright (c) 2015 Jiri Svoboda
    43# All rights reserved.
    54#
    … …  
    3029USPACE_PREFIX = ../..
    3130EXTRA_CFLAGS = -Iinclude
    32 LIBRARY = libnet
     31LIBRARY = libnettl
    3332
    3433SOURCES = \
    35         tl/socket_core.c
     34        src/amap.c \
     35        src/portrng.c
    3636
    3737include $(USPACE_PREFIX)/Makefile.common

  • uspace/lib/nettl/include/nettl/portrng.h

    rdf2bce32 rfb4d788  
    11/*
    2  * Copyright (c) 2009 Lukas Mejdrech
     2 * Copyright (c) 2015 Jiri Svoboda
    33 * All rights reserved.
    44 *
    … …  
    2727 */
    2828
    29 /** @addtogroup nettest
     29/** @addtogroup libnettl
    3030 * @{
    3131 */
    32 
    33 /** @file
    34  * Networking test support functions.
     32/**
     33 * @file Port range allocator.
    3534 */
    3635
    37 #ifndef NET_TEST_
    38 #define NET_TEST_
     36#ifndef LIBNETTL_PORTRNG_H_
     37#define LIBNETTL_PORTRNG_H_
    3938
    40 #include <net/socket.h>
     39#include <stdbool.h>
     40#include <stdint.h>
    4141
    42 extern void print_mark(unsigned int);
    43 extern int sockets_create(int, int *, unsigned int, uint16_t, sock_type_t);
    44 extern int sockets_close(int, int *, unsigned int);
    45 extern int sockets_connect(int, int *, unsigned int, struct sockaddr *,
    46     socklen_t);
    47 extern int sockets_sendto(int, int *, unsigned int, struct sockaddr *,
    48     socklen_t, char *, size_t, unsigned int, sock_type_t);
    49 extern int sockets_recvfrom(int, int *, unsigned int, struct sockaddr *,
    50     socklen_t *, char *, size_t, unsigned int);
    51 extern int sockets_sendto_recvfrom(int, int *, unsigned int, struct sockaddr *,
    52     socklen_t *, char *, size_t, unsigned int, sock_type_t);
     42/** Allocated port */
     43typedef struct {
     44        /** Link to portrng_t.used */
     45        link_t lprng;
     46        /** Port number */
     47        uint16_t pn;
     48        /** User argument */
     49        void *arg;
     50} portrng_port_t;
     51
     52typedef struct {
     53        list_t used; /* of portrng_port_t */
     54} portrng_t;
     55
     56typedef enum {
     57        pf_allow_system = 0x1
     58} portrng_flags_t;
     59
     60extern int portrng_create(portrng_t **);
     61extern void portrng_destroy(portrng_t *);
     62extern int portrng_alloc(portrng_t *, uint16_t, void *,
     63    portrng_flags_t, uint16_t *);
     64extern int portrng_find_port(portrng_t *, uint16_t, void **);
     65extern void portrng_free_port(portrng_t *, uint16_t);
     66extern bool portrng_empty(portrng_t *);
    5367
    5468#endif
    … …  
    5670/** @}
    5771 */
    58 

  • uspace/lib/pcut/src/run.c

    rdf2bce32 rfb4d788  
    7373static int default_suite_initialized = 0;
    7474
    75 static void init_default_suite_when_needed() {
    76         if (default_suite_initialized) {
     75static void init_default_suite_when_needed(void)
     76{
     77        if (default_suite_initialized)
    7778                return;
    78         }
     79       
    7980        default_suite.id = -1;
    8081        default_suite.kind = PCUT_KIND_TESTSUITE;
    … …  
    9192 * @return Always a valid test suite item.
    9293 */
    93 static pcut_item_t *pcut_find_parent_suite(pcut_item_t *it) {
     94static pcut_item_t *pcut_find_parent_suite(pcut_item_t *it)
     95{
    9496        while (it != NULL) {
    95                 if (it->kind == PCUT_KIND_TESTSUITE) {
     97                if (it->kind == PCUT_KIND_TESTSUITE)
    9698                        return it;
    97                 }
     99               
    98100                it = it->previous;
    99101        }
     102       
    100103        init_default_suite_when_needed();
    101104        return &default_suite;
    … …  
    106109 * @param func Function to run (can be NULL).
    107110 */
    108 static void run_setup_teardown(pcut_setup_func_t func) {
    109         if (func != NULL) {
     111static void run_setup_teardown(pcut_setup_func_t func)
     112{
     113        if (func != NULL)
    110114                func();
    111         }
    112115}
    113116
    … …  
    119122 * @param outcome Outcome of the current test.
    120123 */
    121 static void leave_test(int outcome) {
     124static void leave_test(int outcome)
     125{
    122126        PCUT_DEBUG("leave_test(outcome=%d), will_exit=%s", outcome,
    123                 leave_means_exit ? "yes" : "no");
    124         if (leave_means_exit) {
     127            leave_means_exit ? "yes" : "no");
     128        if (leave_means_exit)
    125129                exit(outcome);
    126         }
    127 
     130       
    128131#ifndef PCUT_NO_LONG_JUMP
    129132        longjmp(start_test_jump, 1);
    … …  
    138141 * @param message Message describing the failure.
    139142 */
    140 void pcut_failed_assertion(const char *message) {
     143void pcut_failed_assertion(const char *message)
     144{
    141145        static const char *prev_message = NULL;
     146       
    142147        /*
    143148         * The assertion failed. We need to abort the current test,
    … …  
    145150         * include running the tear-down routine.
    146151         */
    147         if (print_test_error) {
     152        if (print_test_error)
    148153                pcut_print_fail_message(message);
    149         }
    150 
     154       
    151155        if (execute_teardown_on_failure) {
    152156                execute_teardown_on_failure = 0;
    153157                prev_message = message;
    154158                run_setup_teardown(current_suite->teardown_func);
    155 
     159               
    156160                /* Tear-down was okay. */
    157161                if (report_test_result) {
    … …  
    165169                }
    166170        }
    167 
     171       
    168172        prev_message = NULL;
    169 
     173       
    170174        leave_test(TEST_OUTCOME_FAIL); /* No return. */
    171175}
    … …  
    176180 * @return Error status (zero means success).
    177181 */
    178 static int run_test(pcut_item_t *test) {
     182static int run_test(pcut_item_t *test)
     183{
    179184        /*
    180185         * Set here as the returning point in case of test failure.
    … …  
    182187         * test execution.
    183188         */
     189       
    184190#ifndef PCUT_NO_LONG_JUMP
    185191        int test_finished = setjmp(start_test_jump);
    186         if (test_finished) {
     192        if (test_finished)
    187193                return 1;
    188         }
    189194#endif
    190 
    191         if (report_test_result) {
     195       
     196        if (report_test_result)
    192197                pcut_report_test_start(test);
    193         }
    194 
     198       
    195199        current_suite = pcut_find_parent_suite(test);
    196200        current_test = test;
    197 
     201       
    198202        pcut_hook_before_test(test);
    199 
     203       
    200204        /*
    201205         * If anything goes wrong, execute the tear-down function
    … …  
    203207         */
    204208        execute_teardown_on_failure = 1;
    205 
     209       
    206210        /*
    207211         * Run the set-up function.
    208212         */
    209213        run_setup_teardown(current_suite->setup_func);
    210 
     214       
    211215        /*
    212216         * The setup function was performed, it is time to run
    … …  
    214218         */
    215219        test->test_func();
    216 
     220       
    217221        /*
    218222         * Finally, run the tear-down function. We need to clear
    … …  
    221225        execute_teardown_on_failure = 0;
    222226        run_setup_teardown(current_suite->teardown_func);
    223 
     227       
    224228        /*
    225229         * If we got here, it means everything went well with
    226230         * this test.
    227231         */
    228         if (report_test_result) {
     232        if (report_test_result)
    229233                pcut_report_test_done(current_test, TEST_OUTCOME_PASS,
    230                         NULL, NULL, NULL);
    231         }
    232 
     234                    NULL, NULL, NULL);
     235       
    233236        return 0;
    234237}
    … …  
    242245 * @return Error status (zero means success).
    243246 */
    244 int pcut_run_test_forked(pcut_item_t *test) {
    245         int rc;
    246 
     247int pcut_run_test_forked(pcut_item_t *test)
     248{
    247249        report_test_result = 0;
    248250        print_test_error = 1;
    249251        leave_means_exit = 1;
    250 
    251         rc = run_test(test);
    252 
     252       
     253        int rc = run_test(test);
     254       
    253255        current_test = NULL;
    254256        current_suite = NULL;
    255 
     257       
    256258        return rc;
    257259}
    … …  
    265267 * @return Error status (zero means success).
    266268 */
    267 int pcut_run_test_single(pcut_item_t *test) {
    268         int rc;
    269 
     269int pcut_run_test_single(pcut_item_t *test)
     270{
    270271        report_test_result = 1;
    271272        print_test_error = 0;
    272273        leave_means_exit = 0;
    273 
    274         rc = run_test(test);
    275 
     274       
     275        int rc = run_test(test);
     276       
    276277        current_test = NULL;
    277278        current_suite = NULL;
    278 
     279       
    279280        return rc;
    280281}
    … …  
    285286 * @return Timeout in seconds.
    286287 */
    287 int pcut_get_test_timeout(pcut_item_t *test) {
     288int pcut_get_test_timeout(pcut_item_t *test)
     289{
    288290        int timeout = PCUT_DEFAULT_TEST_TIMEOUT;
    289291        pcut_extra_t *extras = test->extras;
    290 
    291 
     292       
    292293        while (extras->type != PCUT_EXTRA_LAST) {
    293                 if (extras->type == PCUT_EXTRA_TIMEOUT) {
     294                if (extras->type == PCUT_EXTRA_TIMEOUT)
    294295                        timeout = extras->timeout;
    295                 }
     296               
    296297                extras++;
    297298        }
    298 
     299       
    299300        return timeout;
    300301}

  • uspace/lib/posix/include/posix/errno.h

    rdf2bce32 rfb4d788  
    6969extern int *__posix_errno(void);
    7070
    71 #define __TOP_ERRNO (-NO_DATA)
     71#define __TOP_ERRNO (-EAGAIN)
    7272
    7373enum {
    7474        POSIX_E2BIG = __TOP_ERRNO + 1,
    7575        POSIX_EACCES = __TOP_ERRNO + 2,
    76         POSIX_EADDRINUSE = -EADDRINUSE,
    7776        POSIX_EADDRNOTAVAIL = -EADDRNOTAVAIL,
    78         POSIX_EAFNOSUPPORT = -EAFNOSUPPORT,
    7977        POSIX_EAGAIN = -EAGAIN,
    8078        POSIX_EALREADY = __TOP_ERRNO + 3,
    … …  
    8886        POSIX_ECONNRESET = __TOP_ERRNO + 9,
    8987        POSIX_EDEADLK = __TOP_ERRNO + 10,
    90         POSIX_EDESTADDRREQ = -EDESTADDRREQ,
    9188        POSIX_EDOM = __TOP_ERRNO + 11,
    9289        POSIX_EDQUOT = __TOP_ERRNO + 12,
    … …  
    9794        POSIX_EIDRM = __TOP_ERRNO + 16,
    9895        POSIX_EILSEQ = __TOP_ERRNO + 17,
    99         POSIX_EINPROGRESS = -EINPROGRESS,
    10096        POSIX_EINTR = -EINTR,
    10197        POSIX_EINVAL = -EINVAL,
    … …  
    114110        POSIX_ENFILE = __TOP_ERRNO + 25,
    115111        POSIX_ENOBUFS = __TOP_ERRNO + 26,
    116         POSIX_ENODATA = -NO_DATA,
    117112        POSIX_ENODEV = __TOP_ERRNO + 27,
    118113        POSIX_ENOENT = -ENOENT,
    … …  
    127122        POSIX_ENOSTR = __TOP_ERRNO + 34,
    128123        POSIX_ENOSYS = __TOP_ERRNO + 35,
    129         POSIX_ENOTCONN = -ENOTCONN,
    130124        POSIX_ENOTDIR = -ENOTDIR,
    131125        POSIX_ENOTEMPTY = -ENOTEMPTY,
    132126        POSIX_ENOTRECOVERABLE = __TOP_ERRNO + 36,
    133         POSIX_ENOTSOCK = -ENOTSOCK,
    134127        POSIX_ENOTSUP = -ENOTSUP,
    135128        POSIX_ENOTTY = __TOP_ERRNO + 37,
    … …  
    141134        POSIX_EPIPE = __TOP_ERRNO + 41,
    142135        POSIX_EPROTO = __TOP_ERRNO + 42,
    143         POSIX_EPROTONOSUPPORT = -EPROTONOSUPPORT,
    144136        POSIX_EPROTOTYPE = __TOP_ERRNO + 43,
    145137        POSIX_ERANGE = -ERANGE,
    … …  
    153145        POSIX_EWOULDBLOCK = __TOP_ERRNO + 51,
    154146        POSIX_EXDEV = -EXDEV,
     147        POSIX_EINPROGRESS = __TOP_ERRNO + 52,
     148        POSIX_ENOTSOCK = __TOP_ERRNO + 53,
     149        POSIX_EDESTADDRREQ = __TOP_ERRNO + 54,
     150        POSIX_EPROTONOSUPPORT = __TOP_ERRNO + 55,
     151        POSIX_EAFNOSUPPORT = __TOP_ERRNO + 56,
     152        POSIX_EADDRINUSE = __TOP_ERRNO + 57,
     153        POSIX_ENOTCONN = __TOP_ERRNO + 58,
     154        POSIX_ENODATA = __TOP_ERRNO + 59,
    155155};
    156156

  • uspace/lib/posix/include/posix/stdlib.h

    rdf2bce32 rfb4d788  
    116116
    117117/* Memory Allocation */
    118 extern void *__POSIX_DEF__(malloc)(size_t size);
    119 extern void *__POSIX_DEF__(calloc)(size_t nelem, size_t elsize);
    120 extern void *__POSIX_DEF__(realloc)(void *ptr, size_t size);
     118extern void *__POSIX_DEF__(malloc)(size_t size)
     119    __attribute__((malloc));
     120extern void *__POSIX_DEF__(calloc)(size_t nelem, size_t elsize)
     121    __attribute__((malloc));
     122extern void *__POSIX_DEF__(realloc)(void *ptr, size_t size)
     123    __attribute__((warn_unused_result));
    121124extern void __POSIX_DEF__(free)(void *ptr);
    122125

  • uspace/lib/posix/include/posix/string.h

    rdf2bce32 rfb4d788  
    6767/* From mem.h */
    6868// #define bzero(ptr, len)  memset((ptr), 0, (len))
    69 extern void *memset(void *, int, size_t);
    70 extern void *memcpy(void *, const void *, size_t);
    71 extern void *memmove(void *, const void *, size_t);
     69extern void *memset(void *, int, size_t)
     70    __attribute__((nonnull(1)));
     71extern void *memcpy(void *, const void *, size_t)
     72    __attribute__((nonnull(1, 2)));
     73extern void *memmove(void *, const void *, size_t)
     74    __attribute__((nonnull(1, 2)));
    7275
    7376

  • uspace/lib/posix/source/signal.c

    rdf2bce32 rfb4d788  
    382382 * Raise all unblocked previously queued signals.
    383383 */
    384 static void _dequeue_unblocked_signals()
     384static void _dequeue_unblocked_signals(void)
    385385{
    386386        link_t *iterator = _signal_queue.head.next;

  • uspace/lib/usbdev/src/hub.c

    rdf2bce32 rfb4d788  
    151151 * @retval EADDRNOTAVAIL Failed retrieving free address from host controller.
    152152 * @retval EBUSY Failed reserving default USB address.
    153  * @retval ENOTCONN Problem connecting to the host controller via USB pipe.
     153 * @retval ENXIO Problem connecting to the host controller via USB pipe.
    154154 * @retval ESTALL Problem communication with device (either SET_ADDRESS
    155155 *      request or requests for descriptors when creating match ids).
    … …  
    184184            &dev_conn, hc_conn, USB_ADDRESS_DEFAULT);
    185185        if (rc != EOK) {
    186                 rc = ENOTCONN;
     186                rc = ENXIO;
    187187                goto leave_release_free_address;
    188188        }
    … …  
    192192        rc = usb_pipe_initialize_default_control(&ctrl_pipe, &dev_conn);
    193193        if (rc != EOK) {
    194                 rc = ENOTCONN;
     194                rc = ENXIO;
    195195                goto leave_release_free_address;
    196196        }
    … …  
    217217        rc = usb_pipe_register(&ctrl_pipe, 0);
    218218        if (rc != EOK) {
    219                 rc = ENOTCONN;
     219                rc = ENXIO;
    220220                goto leave_release_default_address;
    221221        }
    … …  
    278278        if (rc != EOK) {
    279279                /* The child function is already created. */
    280                 rc = EDESTADDRREQ;
     280                rc = EIO;
    281281                goto leave_release_free_address;
    282282        }
Note: See TracChangeset for help on using the changeset viewer.