Changeset b5cf742a in mainline for uspace/lib/c/generic/iplink_srv.c


Ignore:
Timestamp:
2013-06-28T16:22:42Z (12 years ago)
Author:
Martin Decky <martin@…>
Branches:
lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
Children:
edf0d27
Parents:
e52b4b5
Message:

cstyle (no change in functionality)

File:
1 edited

Legend:

Unmodified
Added
Removed
  • uspace/lib/c/generic/iplink_srv.c

    re52b4b5 rb5cf742a  
    4444    ipc_call_t *call)
    4545{
    46         int rc;
    4746        size_t mtu;
    48 
    49         rc = srv->ops->get_mtu(srv, &mtu);
     47        int rc = srv->ops->get_mtu(srv, &mtu);
    5048        async_answer_1(callid, rc, mtu);
    5149}
     
    7068        iplink_srv_sdu_t sdu;
    7169        int rc;
    72 
     70       
    7371        sdu.lsrc = IPC_GET_ARG1(*call);
    7472        sdu.ldest = IPC_GET_ARG2(*call);
    75 
     73       
    7674        rc = async_data_write_accept(&sdu.data, false, 0, 0, 0, &sdu.size);
    7775        if (rc != EOK) {
     
    7977                return;
    8078        }
    81 
     79       
    8280        rc = srv->ops->send(srv, &sdu);
    8381        free(sdu.data);
     
    9896        iplink_srv_t *srv = (iplink_srv_t *)arg;
    9997        int rc;
    100 
     98       
    10199        fibril_mutex_lock(&srv->lock);
    102100        if (srv->connected) {
     
    105103                return EBUSY;
    106104        }
    107 
     105       
    108106        srv->connected = true;
    109107        fibril_mutex_unlock(&srv->lock);
    110 
     108       
    111109        /* Accept the connection */
    112110        async_answer_0(iid, EOK);
    113 
     111       
    114112        async_sess_t *sess = async_callback_receive(EXCHANGE_SERIALIZE);
    115113        if (sess == NULL)
    116114                return ENOMEM;
    117 
     115       
    118116        srv->client_sess = sess;
    119 
     117       
    120118        rc = srv->ops->open(srv);
    121119        if (rc != EOK)
    122120                return rc;
    123 
     121       
    124122        while (true) {
    125123                ipc_call_t call;
    126124                ipc_callid_t callid = async_get_call(&call);
    127125                sysarg_t method = IPC_GET_IMETHOD(call);
    128 
     126               
    129127                if (!method) {
    130128                        /* The other side has hung up */
     
    135133                        break;
    136134                }
    137 
     135               
    138136                switch (method) {
    139137                case IPLINK_GET_MTU:
     
    153151                }
    154152        }
    155 
     153       
    156154        return srv->ops->close(srv);
    157155}
     
    161159        if (srv->client_sess == NULL)
    162160                return EIO;
    163 
     161       
    164162        async_exch_t *exch = async_exchange_begin(srv->client_sess);
    165 
     163       
    166164        ipc_call_t answer;
    167165        aid_t req = async_send_2(exch, IPLINK_EV_RECV, (sysarg_t) sdu->lsrc,
     
    169167        int rc = async_data_write_start(exch, sdu->data, sdu->size);
    170168        async_exchange_end(exch);
    171 
     169       
    172170        if (rc != EOK) {
    173171                async_forget(req);
    174172                return rc;
    175173        }
    176 
     174       
    177175        sysarg_t retval;
    178176        async_wait_for(req, &retval);
    179177        if (retval != EOK)
    180178                return retval;
    181 
     179       
    182180        return EOK;
    183181}
Note: See TracChangeset for help on using the changeset viewer.