Changeset 79ae36dd in mainline for uspace/srv/bd


Ignore:
Timestamp:
2011-06-08T19:01:55Z (15 years ago)
Author:
Martin Decky <martin@…>
Branches:
lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
Children:
0eff68e
Parents:
764d71e
Message:

new async framework with integrated exchange tracking

  • strict isolation between low-level IPC and high-level async framework with integrated exchange tracking
    • each IPC connection is represented by an async_sess_t structure
    • each IPC exchange is represented by an async_exch_t structure
    • exchange management is either based on atomic messages (EXCHANGE_ATOMIC), locking (EXCHANGE_SERIALIZE) or connection cloning (EXCHANGE_CLONE)
  • async_obsolete: temporary compatibility layer to keep old async clients working (several pieces of code are currently broken, but only non-essential functionality)
  • IPC_M_PHONE_HANGUP is now method no. 0 (for elegant boolean evaluation)
  • IPC_M_DEBUG_ALL has been renamed to IPC_M_DEBUG
  • IPC_M_PING has been removed (VFS protocol now has VFS_IN_PING)
  • console routines in libc have been rewritten for better abstraction
  • additional use for libc-private header files (FILE structure opaque to the client)
  • various cstyle changes (typos, indentation, missing externs in header files, improved comments, etc.)
Location:
uspace/srv/bd
Files:
6 edited

Legend:

Unmodified
Added
Removed

  • uspace/srv/bd/ata_bd/ata_bd.c

    r764d71e r79ae36dd  
    317317        (void) async_share_out_finalize(callid, fs_va);
    318318
    319         while (1) {
     319        while (true) {
    320320                callid = async_get_call(&call);
    321321                method = IPC_GET_IMETHOD(call);
    322                 switch (method) {
    323                 case IPC_M_PHONE_HUNGUP:
     322               
     323                if (!method) {
    324324                        /* The other side has hung up. */
    325325                        async_answer_0(callid, EOK);
    326326                        return;
     327                }
     328               
     329                switch (method) {
    327330                case BD_READ_BLOCKS:
    328331                        ba = MERGE_LOUP32(IPC_GET_ARG1(call),

  • uspace/srv/bd/file_bd/file_bd.c

    r764d71e r79ae36dd  
    198198        (void) async_share_out_finalize(callid, fs_va);
    199199
    200         while (1) {
     200        while (true) {
    201201                callid = async_get_call(&call);
    202202                method = IPC_GET_IMETHOD(call);
    203                 switch (method) {
    204                 case IPC_M_PHONE_HUNGUP:
     203               
     204                if (!method) {
    205205                        /* The other side has hung up. */
    206206                        async_answer_0(callid, EOK);
    207207                        return;
     208                }
     209               
     210                switch (method) {
    208211                case BD_READ_BLOCKS:
    209212                        ba = MERGE_LOUP32(IPC_GET_ARG1(call),

  • uspace/srv/bd/gxe_bd/gxe_bd.c

    r764d71e r79ae36dd  
    201201        (void) async_share_out_finalize(callid, fs_va);
    202202
    203         while (1) {
     203        while (true) {
    204204                callid = async_get_call(&call);
    205205                method = IPC_GET_IMETHOD(call);
    206                 switch (method) {
    207                 case IPC_M_PHONE_HUNGUP:
     206               
     207                if (!method) {
    208208                        /* The other side has hung up. */
    209209                        async_answer_0(callid, EOK);
    210210                        return;
     211                }
     212               
     213                switch (method) {
    211214                case BD_READ_BLOCKS:
    212215                        ba = MERGE_LOUP32(IPC_GET_ARG1(call),

  • uspace/srv/bd/part/guid_part/guid_part.c

    r764d71e r79ae36dd  
    139139        }
    140140
    141         rc = block_init(indev_handle, 2048);
     141        rc = block_init(EXCHANGE_SERIALIZE, indev_handle, 2048);
    142142        if (rc != EOK)  {
    143143                printf(NAME ": could not init libblock.\n");
    … …  
    356356        (void) async_share_out_finalize(callid, fs_va);
    357357
    358         while (1) {
     358        while (true) {
    359359                callid = async_get_call(&call);
    360360                method = IPC_GET_IMETHOD(call);
    361                 switch (method) {
    362                 case IPC_M_PHONE_HUNGUP:
     361               
     362                if (!method) {
    363363                        /* The other side has hung up. */
    364364                        async_answer_0(callid, EOK);
    365365                        return;
     366                }
     367               
     368                switch (method) {
    366369                case BD_READ_BLOCKS:
    367370                        ba = MERGE_LOUP32(IPC_GET_ARG1(call),

  • uspace/srv/bd/part/mbr_part/mbr_part.c

    r764d71e r79ae36dd  
    190190        }
    191191
    192         rc = block_init(indev_handle, 2048);
     192        rc = block_init(EXCHANGE_SERIALIZE, indev_handle, 2048);
    193193        if (rc != EOK)  {
    194194                printf(NAME ": could not init libblock.\n");
    … …  
    437437                callid = async_get_call(&call);
    438438                method = IPC_GET_IMETHOD(call);
    439                 switch (method) {
    440                 case IPC_M_PHONE_HUNGUP:
     439               
     440                if (!method) {
    441441                        /* The other side has hung up. */
    442442                        async_answer_0(callid, EOK);
    443443                        return;
     444                }
     445               
     446                switch (method) {
    444447                case BD_READ_BLOCKS:
    445448                        ba = MERGE_LOUP32(IPC_GET_ARG1(call),

  • uspace/srv/bd/rd/rd.c

    r764d71e r79ae36dd  
    123123        while (true) {
    124124                callid = async_get_call(&call);
    125                 switch (IPC_GET_IMETHOD(call)) {
    126                 case IPC_M_PHONE_HUNGUP:
     125               
     126                if (!IPC_GET_IMETHOD(call)) {
    127127                        /*
    128128                         * The other side has hung up.
    129                          * Answer the message and exit the fibril.
     129                         * Exit the fibril.
    130130                         */
    131131                        async_answer_0(callid, EOK);
    132132                        return;
     133                }
     134               
     135                switch (IPC_GET_IMETHOD(call)) {
    133136                case BD_READ_BLOCKS:
    134137                        ba = MERGE_LOUP32(IPC_GET_ARG1(call),
    … …  
    243246                return false;
    244247        }
    245 
     248       
    246249        fibril_rwlock_initialize(&rd_lock);
    247250       
    … …  
    258261        printf("%s: Accepting connections\n", NAME);
    259262        async_manager();
    260 
     263       
    261264        /* Never reached */
    262265        return 0;
Note: See TracChangeset for help on using the changeset viewer.