Changes in uspace/lib/fs/libfs.c [ffa2c8ef:228e490] in mainline


Ignore:
File:
1 edited

Legend:

Unmodified
Added
Removed

  • uspace/lib/fs/libfs.c

    rffa2c8ef r228e490  
    4040#include <errno.h>
    4141#include <async.h>
     42#include <ipc/ipc.h>
    4243#include <as.h>
    4344#include <assert.h>
    … …  
    5758#define answer_and_return(rid, rc) \
    5859        do { \
    59                 async_answer_0((rid), (rc)); \
     60                ipc_answer_0((rid), (rc)); \
    6061                return; \
    6162        } while (0)
    … …  
    101102         * Ask VFS for callback connection.
    102103         */
    103         async_connect_to_me(vfs_phone, 0, 0, 0, conn);
     104        ipc_connect_to_me(vfs_phone, 0, 0, 0, &reg->vfs_phonehash);
    104105       
    105106        /*
    … …  
    126127        async_wait_for(req, NULL);
    127128        reg->fs_handle = (int) IPC_GET_ARG1(answer);
     129       
     130        /*
     131         * Create a connection fibril to handle the callback connection.
     132         */
     133        async_new_connection(reg->vfs_phonehash, 0, NULL, conn);
    128134       
    129135        /*
    … …  
    159165        if ((IPC_GET_IMETHOD(call) != IPC_M_CONNECTION_CLONE) ||
    160166            (mountee_phone < 0)) {
    161                 async_answer_0(callid, EINVAL);
    162                 async_answer_0(rid, EINVAL);
     167                ipc_answer_0(callid, EINVAL);
     168                ipc_answer_0(rid, EINVAL);
    163169                return;
    164170        }
    165171       
    166172        /* Acknowledge the mountee_phone */
    167         async_answer_0(callid, EOK);
     173        ipc_answer_0(callid, EOK);
    168174       
    169175        fs_node_t *fn;
    170176        res = ops->node_get(&fn, mp_devmap_handle, mp_fs_index);
    171177        if ((res != EOK) || (!fn)) {
    172                 async_hangup(mountee_phone);
     178                ipc_hangup(mountee_phone);
    173179                async_data_write_void(combine_rc(res, ENOENT));
    174                 async_answer_0(rid, combine_rc(res, ENOENT));
     180                ipc_answer_0(rid, combine_rc(res, ENOENT));
    175181                return;
    176182        }
    177183       
    178184        if (fn->mp_data.mp_active) {
    179                 async_hangup(mountee_phone);
     185                ipc_hangup(mountee_phone);
    180186                (void) ops->node_put(fn);
    181187                async_data_write_void(EBUSY);
    182                 async_answer_0(rid, EBUSY);
     188                ipc_answer_0(rid, EBUSY);
    183189                return;
    184190        }
    … …  
    186192        rc = async_req_0_0(mountee_phone, IPC_M_CONNECT_ME);
    187193        if (rc != EOK) {
    188                 async_hangup(mountee_phone);
     194                ipc_hangup(mountee_phone);
    189195                (void) ops->node_put(fn);
    190196                async_data_write_void(rc);
    191                 async_answer_0(rid, rc);
     197                ipc_answer_0(rid, rc);
    192198                return;
    193199        }
    … …  
    207213         * Do not release the FS node so that it stays in memory.
    208214         */
    209         async_answer_3(rid, rc, IPC_GET_ARG1(answer), IPC_GET_ARG2(answer),
     215        ipc_answer_3(rid, rc, IPC_GET_ARG1(answer), IPC_GET_ARG2(answer),
    210216            IPC_GET_ARG3(answer));
    211217}
    … …  
    220226        res = ops->node_get(&fn, mp_devmap_handle, mp_fs_index);
    221227        if ((res != EOK) || (!fn)) {
    222                 async_answer_0(rid, combine_rc(res, ENOENT));
     228                ipc_answer_0(rid, combine_rc(res, ENOENT));
    223229                return;
    224230        }
    … …  
    229235        if (!fn->mp_data.mp_active) {
    230236                (void) ops->node_put(fn);
    231                 async_answer_0(rid, EINVAL);
     237                ipc_answer_0(rid, EINVAL);
    232238                return;
    233239        }
    … …  
    243249         */
    244250        if (res == EOK) {
    245                 async_hangup(fn->mp_data.phone);
     251                ipc_hangup(fn->mp_data.phone);
    246252                fn->mp_data.mp_active = false;
    247253                fn->mp_data.fs_handle = 0;
    … …  
    253259
    254260        (void) ops->node_put(fn);
    255         async_answer_0(rid, res);
     261        ipc_answer_0(rid, res);
    256262}
    257263
    … …  
    293299       
    294300        if (cur->mp_data.mp_active) {
    295                 async_forward_slow(rid, cur->mp_data.phone, VFS_OUT_LOOKUP,
     301                ipc_forward_slow(rid, cur->mp_data.phone, VFS_OUT_LOOKUP,
    296302                    next, last, cur->mp_data.devmap_handle, lflag, index,
    297303                    IPC_FF_ROUTE_FROM_ME);
    … …  
    317323                        if (len + 1 == NAME_MAX) {
    318324                                /* Component length overflow */
    319                                 async_answer_0(rid, ENAMETOOLONG);
     325                                ipc_answer_0(rid, ENAMETOOLONG);
    320326                                goto out;
    321327                        }
    … …  
    351357                                next--;
    352358                       
    353                         async_forward_slow(rid, tmp->mp_data.phone,
     359                        ipc_forward_slow(rid, tmp->mp_data.phone,
    354360                            VFS_OUT_LOOKUP, next, last, tmp->mp_data.devmap_handle,
    355361                            lflag, index, IPC_FF_ROUTE_FROM_ME);
    … …  
    365371                        if (next <= last) {
    366372                                /* There are unprocessed components */
    367                                 async_answer_0(rid, ENOENT);
     373                                ipc_answer_0(rid, ENOENT);
    368374                                goto out;
    369375                        }
    … …  
    373379                                /* Request to create a new link */
    374380                                if (!ops->is_directory(cur)) {
    375                                         async_answer_0(rid, ENOTDIR);
     381                                        ipc_answer_0(rid, ENOTDIR);
    376382                                        goto out;
    377383                                }
    … …  
    391397                                                if (lflag & L_CREATE)
    392398                                                        (void) ops->destroy(fn);
    393                                                 async_answer_0(rid, rc);
     399                                                ipc_answer_0(rid, rc);
    394400                                        } else {
    395401                                                aoff64_t size = ops->size_get(fn);
    396                                                 async_answer_5(rid, fs_handle,
     402                                                ipc_answer_5(rid, fs_handle,
    397403                                                    devmap_handle,
    398404                                                    ops->index_get(fn),
    … …  
    403409                                        }
    404410                                } else
    405                                         async_answer_0(rid, ENOSPC);
     411                                        ipc_answer_0(rid, ENOSPC);
    406412                               
    407413                                goto out;
    408414                        }
    409415                       
    410                         async_answer_0(rid, ENOENT);
     416                        ipc_answer_0(rid, ENOENT);
    411417                        goto out;
    412418                }
    … …  
    434440                if (lflag & (L_CREATE | L_LINK)) {
    435441                        if (!ops->is_directory(cur)) {
    436                                 async_answer_0(rid, ENOTDIR);
     442                                ipc_answer_0(rid, ENOTDIR);
    437443                                goto out;
    438444                        }
    … …  
    443449                                if (ops->plb_get_char(next) == '/') {
    444450                                        /* More than one component */
    445                                         async_answer_0(rid, ENOENT);
     451                                        ipc_answer_0(rid, ENOENT);
    446452                                        goto out;
    447453                                }
    … …  
    449455                                if (len + 1 == NAME_MAX) {
    450456                                        /* Component length overflow */
    451                                         async_answer_0(rid, ENAMETOOLONG);
     457                                        ipc_answer_0(rid, ENAMETOOLONG);
    452458                                        goto out;
    453459                                }
    … …  
    473479                                        if (lflag & L_CREATE)
    474480                                                (void) ops->destroy(fn);
    475                                         async_answer_0(rid, rc);
     481                                        ipc_answer_0(rid, rc);
    476482                                } else {
    477483                                        aoff64_t size = ops->size_get(fn);
    478                                         async_answer_5(rid, fs_handle,
     484                                        ipc_answer_5(rid, fs_handle,
    479485                                            devmap_handle,
    480486                                            ops->index_get(fn),
    … …  
    485491                                }
    486492                        } else
    487                                 async_answer_0(rid, ENOSPC);
     493                                ipc_answer_0(rid, ENOSPC);
    488494                       
    489495                        goto out;
    490496                }
    491497               
    492                 async_answer_0(rid, ENOENT);
     498                ipc_answer_0(rid, ENOENT);
    493499                goto out;
    494500        }
    … …  
    503509                if (rc == EOK) {
    504510                        aoff64_t size = ops->size_get(cur);
    505                         async_answer_5(rid, fs_handle, devmap_handle,
     511                        ipc_answer_5(rid, fs_handle, devmap_handle,
    506512                            ops->index_get(cur), LOWER32(size), UPPER32(size),
    507513                            old_lnkcnt);
    508514                } else
    509                         async_answer_0(rid, rc);
     515                        ipc_answer_0(rid, rc);
    510516               
    511517                goto out;
    … …  
    514520        if (((lflag & (L_CREATE | L_EXCLUSIVE)) == (L_CREATE | L_EXCLUSIVE)) ||
    515521            (lflag & L_LINK)) {
    516                 async_answer_0(rid, EEXIST);
     522                ipc_answer_0(rid, EEXIST);
    517523                goto out;
    518524        }
    519525       
    520526        if ((lflag & L_FILE) && (ops->is_directory(cur))) {
    521                 async_answer_0(rid, EISDIR);
     527                ipc_answer_0(rid, EISDIR);
    522528                goto out;
    523529        }
    524530       
    525531        if ((lflag & L_DIRECTORY) && (ops->is_file(cur))) {
    526                 async_answer_0(rid, ENOTDIR);
     532                ipc_answer_0(rid, ENOTDIR);
    527533                goto out;
    528534        }
    529535
    530536        if ((lflag & L_ROOT) && par) {
    531                 async_answer_0(rid, EINVAL);
     537                ipc_answer_0(rid, EINVAL);
    532538                goto out;
    533539        }
    … …  
    541547                if (rc == EOK) {
    542548                        aoff64_t size = ops->size_get(cur);
    543                         async_answer_5(rid, fs_handle, devmap_handle,
     549                        ipc_answer_5(rid, fs_handle, devmap_handle,
    544550                            ops->index_get(cur), LOWER32(size), UPPER32(size),
    545551                            ops->lnkcnt_get(cur));
    546552                } else
    547                         async_answer_0(rid, rc);
     553                        ipc_answer_0(rid, rc);
    548554               
    549555        } else
    550                 async_answer_0(rid, rc);
     556                ipc_answer_0(rid, rc);
    551557       
    552558out:
    … …  
    577583            (size != sizeof(struct stat))) {
    578584                ops->node_put(fn);
    579                 async_answer_0(callid, EINVAL);
    580                 async_answer_0(rid, EINVAL);
     585                ipc_answer_0(callid, EINVAL);
     586                ipc_answer_0(rid, EINVAL);
    581587                return;
    582588        }
    … …  
    597603       
    598604        async_data_read_finalize(callid, &stat, sizeof(struct stat));
    599         async_answer_0(rid, EOK);
     605        ipc_answer_0(rid, EOK);
    600606}
    601607
    … …  
    619625       
    620626        if (fn == NULL) {
    621                 async_answer_0(rid, ENOENT);
     627                ipc_answer_0(rid, ENOENT);
    622628                return;
    623629        }
    … …  
    625631        rc = ops->node_open(fn);
    626632        aoff64_t size = ops->size_get(fn);
    627         async_answer_4(rid, rc, LOWER32(size), UPPER32(size), ops->lnkcnt_get(fn),
     633        ipc_answer_4(rid, rc, LOWER32(size), UPPER32(size), ops->lnkcnt_get(fn),
    628634            (ops->is_file(fn) ? L_FILE : 0) | (ops->is_directory(fn) ? L_DIRECTORY : 0));
    629635       
Note: See TracChangeset for help on using the changeset viewer.