Changeset 936835e in mainline for uspace/srv/net/tl/udp/udp.c


Ignore:
Timestamp:
2010-03-07T15:35:32Z (15 years ago)
Author:
Lukas Mejdrech <lukasmejdrech@…>
Branches:
lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
Children:
836dd794
Parents:
aadf01e (diff), b5cbff4 (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 mainline changes, revision 311

File:
1 edited

Legend:

Unmodified
Added
Removed

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

    raadf01e r936835e  
    418418        struct sockaddr * addr;
    419419        size_t addrlen;
    420         fibril_rwlock_t lock;
    421420        ipc_call_t answer;
    422421        int answer_count;
    … …  
    433432
    434433        socket_cores_initialize(&local_sockets);
    435         fibril_rwlock_initialize(&lock);
    436434
    437435        while(keep_on_going){
    … …  
    453451                                break;
    454452                        case NET_SOCKET:
    455                                 fibril_rwlock_write_lock(&lock);
    456453                                *SOCKET_SET_SOCKET_ID(answer) = SOCKET_GET_SOCKET_ID(call);
    457454                                res = socket_create(&local_sockets, app_phone, NULL, SOCKET_SET_SOCKET_ID(answer));
    458                                 fibril_rwlock_write_unlock(&lock);
    459455                                if(res == EOK){
    460456                                        if(tl_get_ip_packet_dimension(udp_globals.ip_phone, &udp_globals.dimensions, DEVICE_INVALID_ID, &packet_dimension) == EOK){
    … …  
    469465                                res = data_receive((void **) &addr, &addrlen);
    470466                                if(res == EOK){
    471                                         fibril_rwlock_read_lock(&lock);
    472467                                        fibril_rwlock_write_lock(&udp_globals.lock);
    473468                                        res = socket_bind(&local_sockets, &udp_globals.sockets, SOCKET_GET_SOCKET_ID(call), addr, addrlen, UDP_FREE_PORTS_START, UDP_FREE_PORTS_END, udp_globals.last_used_port);
    474469                                        fibril_rwlock_write_unlock(&udp_globals.lock);
    475                                         fibril_rwlock_read_unlock(&lock);
    476470                                        free(addr);
    477471                                }
    … …  
    480474                                res = data_receive((void **) &addr, &addrlen);
    481475                                if(res == EOK){
    482                                         fibril_rwlock_read_lock(&lock);
    483476                                        fibril_rwlock_write_lock(&udp_globals.lock);
    484477                                        res = udp_sendto_message(&local_sockets, SOCKET_GET_SOCKET_ID(call), addr, addrlen, SOCKET_GET_DATA_FRAGMENTS(call), SOCKET_SET_DATA_FRAGMENT_SIZE(answer), SOCKET_GET_FLAGS(call));
    … …  
    488481                                                answer_count = 2;
    489482                                        }
    490                                         fibril_rwlock_read_unlock(&lock);
    491483                                        free(addr);
    492484                                }
    493485                                break;
    494486                        case NET_SOCKET_RECVFROM:
    495                                 fibril_rwlock_read_lock(&lock);
    496487                                fibril_rwlock_write_lock(&udp_globals.lock);
    497488                                res = udp_recvfrom_message(&local_sockets, SOCKET_GET_SOCKET_ID(call), SOCKET_GET_FLAGS(call), &addrlen);
    498489                                fibril_rwlock_write_unlock(&udp_globals.lock);
    499                                 fibril_rwlock_read_unlock(&lock);
    500490                                if(res > 0){
    501491                                        *SOCKET_SET_READ_DATA_LENGTH(answer) = res;
    … …  
    506496                                break;
    507497                        case NET_SOCKET_CLOSE:
    508                                 fibril_rwlock_write_lock(&lock);
    509498                                fibril_rwlock_write_lock(&udp_globals.lock);
    510499                                res = socket_destroy(udp_globals.net_phone, SOCKET_GET_SOCKET_ID(call), &local_sockets, &udp_globals.sockets, NULL);
    511500                                fibril_rwlock_write_unlock(&udp_globals.lock);
    512                                 fibril_rwlock_write_unlock(&lock);
    513501                                break;
    514502                        case NET_SOCKET_GETSOCKOPT:
Note: See TracChangeset for help on using the changeset viewer.