Changeset 77f0a1d in mainline for uspace/srv


Ignore:
Timestamp:
2018-03-22T22:54:52Z (8 years ago)
Author:
Jakub Jermar <jakub@…>
Branches:
lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
Children:
eed4139
Parents:
a46e56b
Message:

Get rid of rid in favor of req_handle

Location:
uspace/srv
Files:
5 edited

Legend:

Unmodified
Added
Removed
  • uspace/srv/clipboard/clipboard.c

    ra46e56b r77f0a1d  
    4747static service_id_t svc_id;
    4848
    49 static void clip_put_data(cap_call_handle_t rid, ipc_call_t *request)
     49static void clip_put_data(cap_call_handle_t req_handle, ipc_call_t *request)
    5050{
    5151        char *data;
     
    6565
    6666                fibril_mutex_unlock(&clip_mtx);
    67                 async_answer_0(rid, EOK);
     67                async_answer_0(req_handle, EOK);
    6868                break;
    6969        case CLIPBOARD_TAG_DATA:
    7070                rc = async_data_write_accept((void **) &data, false, 0, 0, 0, &size);
    7171                if (rc != EOK) {
    72                         async_answer_0(rid, rc);
     72                        async_answer_0(req_handle, rc);
    7373                        break;
    7474                }
     
    8484
    8585                fibril_mutex_unlock(&clip_mtx);
    86                 async_answer_0(rid, EOK);
     86                async_answer_0(req_handle, EOK);
    8787                break;
    8888        default:
    89                 async_answer_0(rid, EINVAL);
    90         }
    91 }
    92 
    93 static void clip_get_data(cap_call_handle_t rid, ipc_call_t *request)
     89                async_answer_0(req_handle, EINVAL);
     90        }
     91}
     92
     93static void clip_get_data(cap_call_handle_t req_handle, ipc_call_t *request)
    9494{
    9595        fibril_mutex_lock(&clip_mtx);
     
    103103                if (!async_data_read_receive(&chandle, &size)) {
    104104                        async_answer_0(chandle, EINVAL);
    105                         async_answer_0(rid, EINVAL);
     105                        async_answer_0(req_handle, EINVAL);
    106106                        break;
    107107                }
     
    110110                        /* So far we only understand binary data */
    111111                        async_answer_0(chandle, EOVERFLOW);
    112                         async_answer_0(rid, EOVERFLOW);
     112                        async_answer_0(req_handle, EOVERFLOW);
    113113                        break;
    114114                }
     
    117117                        /* The client expects different size of data */
    118118                        async_answer_0(chandle, EOVERFLOW);
    119                         async_answer_0(rid, EOVERFLOW);
     119                        async_answer_0(req_handle, EOVERFLOW);
    120120                        break;
    121121                }
     
    123123                errno_t retval = async_data_read_finalize(chandle, clip_data, size);
    124124                if (retval != EOK) {
    125                         async_answer_0(rid, retval);
    126                         break;
    127                 }
    128 
    129                 async_answer_0(rid, EOK);
     125                        async_answer_0(req_handle, retval);
     126                        break;
     127                }
     128
     129                async_answer_0(req_handle, EOK);
    130130                break;
    131131        default:
     
    134134                 * data from the clipbard
    135135                 */
    136                 async_answer_0(rid, EINVAL);
     136                async_answer_0(req_handle, EINVAL);
    137137                break;
    138138        }
     
    141141}
    142142
    143 static void clip_content(cap_call_handle_t rid, ipc_call_t *request)
     143static void clip_content(cap_call_handle_t req_handle, ipc_call_t *request)
    144144{
    145145        fibril_mutex_lock(&clip_mtx);
     
    149149
    150150        fibril_mutex_unlock(&clip_mtx);
    151         async_answer_2(rid, EOK, (sysarg_t) size, (sysarg_t) tag);
    152 }
    153 
    154 static void clip_connection(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg)
     151        async_answer_2(req_handle, EOK, (sysarg_t) size, (sysarg_t) tag);
     152}
     153
     154static void clip_connection(cap_call_handle_t icall_handle, ipc_call_t *icall,
     155    void *arg)
    155156{
    156157        /* Accept connection */
  • uspace/srv/loader/main.c

    ra46e56b r77f0a1d  
    9090static bool connected = false;
    9191
    92 static void ldr_get_taskid(cap_call_handle_t rid, ipc_call_t *request)
     92static void ldr_get_taskid(cap_call_handle_t req_handle, ipc_call_t *request)
    9393{
    9494        cap_call_handle_t chandle;
     
    100100        if (!async_data_read_receive(&chandle, &len)) {
    101101                async_answer_0(chandle, EINVAL);
    102                 async_answer_0(rid, EINVAL);
     102                async_answer_0(req_handle, EINVAL);
    103103                return;
    104104        }
     
    108108
    109109        async_data_read_finalize(chandle, &task_id, len);
    110         async_answer_0(rid, EOK);
     110        async_answer_0(req_handle, EOK);
    111111}
    112112
    113113/** Receive a call setting the current working directory.
    114114 *
    115  * @param rid
    116  * @param request
    117  */
    118 static void ldr_set_cwd(cap_call_handle_t rid, ipc_call_t *request)
     115 * @param req_handle
     116 * @param request
     117 */
     118static void ldr_set_cwd(cap_call_handle_t req_handle, ipc_call_t *request)
    119119{
    120120        char *buf;
     
    128128        }
    129129
    130         async_answer_0(rid, rc);
     130        async_answer_0(req_handle, rc);
    131131}
    132132
    133133/** Receive a call setting the program to execute.
    134134 *
    135  * @param rid
    136  * @param request
    137  */
    138 static void ldr_set_program(cap_call_handle_t rid, ipc_call_t *request)
     135 * @param req_handle
     136 * @param request
     137 */
     138static void ldr_set_program(cap_call_handle_t req_handle, ipc_call_t *request)
    139139{
    140140        cap_call_handle_t write_chandle;
    141141        size_t namesize;
    142142        if (!async_data_write_receive(&write_chandle, &namesize)) {
    143                 async_answer_0(rid, EINVAL);
     143                async_answer_0(req_handle, EINVAL);
    144144                return;
    145145        }
     
    148148        errno_t rc = async_data_write_finalize(write_chandle, name, namesize);
    149149        if (rc != EOK) {
    150                 async_answer_0(rid, EINVAL);
     150                async_answer_0(req_handle, EINVAL);
    151151                return;
    152152        }
     
    155155        rc = vfs_receive_handle(true, &file);
    156156        if (rc != EOK) {
    157                 async_answer_0(rid, EINVAL);
     157                async_answer_0(req_handle, EINVAL);
    158158                return;
    159159        }
     
    161161        progname = name;
    162162        program_fd = file;
    163         async_answer_0(rid, EOK);
     163        async_answer_0(req_handle, EOK);
    164164}
    165165
    166166/** Receive a call setting arguments of the program to execute.
    167167 *
    168  * @param rid
    169  * @param request
    170  */
    171 static void ldr_set_args(cap_call_handle_t rid, ipc_call_t *request)
     168 * @param req_handle
     169 * @param request
     170 */
     171static void ldr_set_args(cap_call_handle_t req_handle, ipc_call_t *request)
    172172{
    173173        char *buf;
     
    194194                if (_argv == NULL) {
    195195                        free(buf);
    196                         async_answer_0(rid, ENOMEM);
     196                        async_answer_0(req_handle, ENOMEM);
    197197                        return;
    198198                }
     
    226226        }
    227227
    228         async_answer_0(rid, rc);
     228        async_answer_0(req_handle, rc);
    229229}
    230230
    231231/** Receive a call setting inbox files of the program to execute.
    232232 *
    233  * @param rid
    234  * @param request
    235  */
    236 static void ldr_add_inbox(cap_call_handle_t rid, ipc_call_t *request)
     233 * @param req_handle
     234 * @param request
     235 */
     236static void ldr_add_inbox(cap_call_handle_t req_handle, ipc_call_t *request)
    237237{
    238238        if (inbox_entries == INBOX_MAX_ENTRIES) {
    239                 async_answer_0(rid, ERANGE);
     239                async_answer_0(req_handle, ERANGE);
    240240                return;
    241241        }
     
    244244        size_t namesize;
    245245        if (!async_data_write_receive(&write_chandle, &namesize)) {
    246                 async_answer_0(rid, EINVAL);
     246                async_answer_0(req_handle, EINVAL);
    247247                return;
    248248        }
     
    251251        errno_t rc = async_data_write_finalize(write_chandle, name, namesize);
    252252        if (rc != EOK) {
    253                 async_answer_0(rid, EINVAL);
     253                async_answer_0(req_handle, EINVAL);
    254254                return;
    255255        }
     
    258258        rc = vfs_receive_handle(true, &file);
    259259        if (rc != EOK) {
    260                 async_answer_0(rid, EINVAL);
     260                async_answer_0(req_handle, EINVAL);
    261261                return;
    262262        }
     
    272272        inbox[inbox_entries].file = file;
    273273        inbox_entries++;
    274         async_answer_0(rid, EOK);
     274        async_answer_0(req_handle, EOK);
    275275}
    276276
    277277/** Load the previously selected program.
    278278 *
    279  * @param rid
     279 * @param req_handle
    280280 * @param request
    281281 * @return 0 on success, !0 on error.
    282282 */
    283 static int ldr_load(cap_call_handle_t rid, ipc_call_t *request)
     283static int ldr_load(cap_call_handle_t req_handle, ipc_call_t *request)
    284284{
    285285        int rc = elf_load(program_fd, &prog_info);
    286286        if (rc != EE_OK) {
    287287                DPRINTF("Failed to load executable for '%s'.\n", progname);
    288                 async_answer_0(rid, EINVAL);
     288                async_answer_0(req_handle, EINVAL);
    289289                return 1;
    290290        }
     
    300300        pcb.inbox_entries = inbox_entries;
    301301
    302         async_answer_0(rid, EOK);
     302        async_answer_0(req_handle, EOK);
    303303        return 0;
    304304}
     
    306306/** Run the previously loaded program.
    307307 *
    308  * @param rid
     308 * @param req_handle
    309309 * @param request
    310310 * @return 0 on success, !0 on error.
    311311 */
    312 static __attribute__((noreturn)) void ldr_run(cap_call_handle_t rid,
     312static __attribute__((noreturn)) void ldr_run(cap_call_handle_t req_handle,
    313313    ipc_call_t *request)
    314314{
     
    320320        /* Run program */
    321321        DPRINTF("Reply OK\n");
    322         async_answer_0(rid, EOK);
     322        async_answer_0(req_handle, EOK);
    323323        DPRINTF("Jump to entry point at %p\n", pcb.entry);
    324324        entry_point_jmp(prog_info.finfo.entry, &pcb);
     
    332332 * to execute the loaded program).
    333333 */
    334 static void ldr_connection(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg)
     334static void ldr_connection(cap_call_handle_t icall_handle, ipc_call_t *icall,
     335    void *arg)
    335336{
    336337        /* Already have a connection? */
  • uspace/srv/vfs/vfs_ipc.c

    ra46e56b r77f0a1d  
    3535#include <vfs/canonify.h>
    3636
    37 static void vfs_in_clone(cap_call_handle_t rid, ipc_call_t *request)
     37static void vfs_in_clone(cap_call_handle_t req_handle, ipc_call_t *request)
    3838{
    3939        int oldfd = IPC_GET_ARG1(*request);
     
    4343        int outfd = -1;
    4444        errno_t rc = vfs_op_clone(oldfd, newfd, desc, &outfd);
    45         async_answer_1(rid, rc, outfd);
    46 }
    47 
    48 static void vfs_in_fsprobe(cap_call_handle_t rid, ipc_call_t *request)
     45        async_answer_1(req_handle, rc, outfd);
     46}
     47
     48static void vfs_in_fsprobe(cap_call_handle_t req_handle, ipc_call_t *request)
    4949{
    5050        service_id_t service_id = (service_id_t) IPC_GET_ARG1(*request);
     
    6262            FS_NAME_MAXLEN, 0, NULL);
    6363        if (rc != EOK) {
    64                 async_answer_0(rid, rc);
     64                async_answer_0(req_handle, rc);
    6565                return;
    6666        }
    6767
    6868        rc = vfs_op_fsprobe(fs_name, service_id, &info);
    69         async_answer_0(rid, rc);
     69        async_answer_0(req_handle, rc);
    7070        if (rc != EOK)
    7171                goto out;
     
    8383}
    8484
    85 static void vfs_in_fstypes(cap_call_handle_t rid, ipc_call_t *request)
     85static void vfs_in_fstypes(cap_call_handle_t req_handle, ipc_call_t *request)
    8686{
    8787        cap_call_handle_t chandle;
     
    9292        rc = vfs_get_fstypes(&fstypes);
    9393        if (rc != EOK) {
    94                 async_answer_0(rid, ENOMEM);
     94                async_answer_0(req_handle, ENOMEM);
    9595                return;
    9696        }
    9797
    9898        /* Send size of the data */
    99         async_answer_1(rid, EOK, fstypes.size);
     99        async_answer_1(req_handle, EOK, fstypes.size);
    100100
    101101        /* Now we should get a read request */
     
    111111}
    112112
    113 static void vfs_in_mount(cap_call_handle_t rid, ipc_call_t *request)
     113static void vfs_in_mount(cap_call_handle_t req_handle, ipc_call_t *request)
    114114{
    115115        int mpfd = IPC_GET_ARG1(*request);
     
    132132            MAX_MNTOPTS_LEN, 0, NULL);
    133133        if (rc != EOK) {
    134                 async_answer_0(rid, rc);
     134                async_answer_0(req_handle, rc);
    135135                return;
    136136        }
     
    143143        if (rc != EOK) {
    144144                free(opts);
    145                 async_answer_0(rid, rc);
     145                async_answer_0(req_handle, rc);
    146146                return;
    147147        }
     
    150150        rc = vfs_op_mount(mpfd, service_id, flags, instance, opts, fs_name,
    151151             &outfd);
    152         async_answer_1(rid, rc, outfd);
     152        async_answer_1(req_handle, rc, outfd);
    153153
    154154        free(opts);
     
    156156}
    157157
    158 static void vfs_in_open(cap_call_handle_t rid, ipc_call_t *request)
     158static void vfs_in_open(cap_call_handle_t req_handle, ipc_call_t *request)
    159159{
    160160        int fd = IPC_GET_ARG1(*request);
     
    162162
    163163        errno_t rc = vfs_op_open(fd, mode);
    164         async_answer_0(rid, rc);
    165 }
    166 
    167 static void vfs_in_put(cap_call_handle_t rid, ipc_call_t *request)
     164        async_answer_0(req_handle, rc);
     165}
     166
     167static void vfs_in_put(cap_call_handle_t req_handle, ipc_call_t *request)
    168168{
    169169        int fd = IPC_GET_ARG1(*request);
    170170        errno_t rc = vfs_op_put(fd);
    171         async_answer_0(rid, rc);
    172 }
    173 
    174 static void vfs_in_read(cap_call_handle_t rid, ipc_call_t *request)
     171        async_answer_0(req_handle, rc);
     172}
     173
     174static void vfs_in_read(cap_call_handle_t req_handle, ipc_call_t *request)
    175175{
    176176        int fd = IPC_GET_ARG1(*request);
     
    180180        size_t bytes = 0;
    181181        errno_t rc = vfs_op_read(fd, pos, &bytes);
    182         async_answer_1(rid, rc, bytes);
    183 }
    184 
    185 static void vfs_in_rename(cap_call_handle_t rid, ipc_call_t *request)
     182        async_answer_1(req_handle, rc, bytes);
     183}
     184
     185static void vfs_in_rename(cap_call_handle_t req_handle, ipc_call_t *request)
    186186{
    187187        /* The common base directory. */
     
    219219
    220220out:
    221         async_answer_0(rid, rc);
     221        async_answer_0(req_handle, rc);
    222222
    223223        if (old)
     
    227227}
    228228
    229 static void vfs_in_resize(cap_call_handle_t rid, ipc_call_t *request)
     229static void vfs_in_resize(cap_call_handle_t req_handle, ipc_call_t *request)
    230230{
    231231        int fd = IPC_GET_ARG1(*request);
    232232        int64_t size = MERGE_LOUP32(IPC_GET_ARG2(*request), IPC_GET_ARG3(*request));
    233233        errno_t rc = vfs_op_resize(fd, size);
    234         async_answer_0(rid, rc);
    235 }
    236 
    237 static void vfs_in_stat(cap_call_handle_t rid, ipc_call_t *request)
     234        async_answer_0(req_handle, rc);
     235}
     236
     237static void vfs_in_stat(cap_call_handle_t req_handle, ipc_call_t *request)
    238238{
    239239        int fd = IPC_GET_ARG1(*request);
    240240        errno_t rc = vfs_op_stat(fd);
    241         async_answer_0(rid, rc);
    242 }
    243 
    244 static void vfs_in_statfs(cap_call_handle_t rid, ipc_call_t *request)
     241        async_answer_0(req_handle, rc);
     242}
     243
     244static void vfs_in_statfs(cap_call_handle_t req_handle, ipc_call_t *request)
    245245{
    246246        int fd = (int) IPC_GET_ARG1(*request);
    247247
    248248        errno_t rc = vfs_op_statfs(fd);
    249         async_answer_0(rid, rc);
    250 }
    251 
    252 static void vfs_in_sync(cap_call_handle_t rid, ipc_call_t *request)
     249        async_answer_0(req_handle, rc);
     250}
     251
     252static void vfs_in_sync(cap_call_handle_t req_handle, ipc_call_t *request)
    253253{
    254254        int fd = IPC_GET_ARG1(*request);
    255255        errno_t rc = vfs_op_sync(fd);
    256         async_answer_0(rid, rc);
    257 }
    258 
    259 static void vfs_in_unlink(cap_call_handle_t rid, ipc_call_t *request)
     256        async_answer_0(req_handle, rc);
     257}
     258
     259static void vfs_in_unlink(cap_call_handle_t req_handle, ipc_call_t *request)
    260260{
    261261        int parentfd = IPC_GET_ARG1(*request);
     
    267267                rc = vfs_op_unlink(parentfd, expectfd, path);
    268268
    269         async_answer_0(rid, rc);
    270 }
    271 
    272 static void vfs_in_unmount(cap_call_handle_t rid, ipc_call_t *request)
     269        async_answer_0(req_handle, rc);
     270}
     271
     272static void vfs_in_unmount(cap_call_handle_t req_handle, ipc_call_t *request)
    273273{
    274274        int mpfd = IPC_GET_ARG1(*request);
    275275        errno_t rc = vfs_op_unmount(mpfd);
    276         async_answer_0(rid, rc);
    277 }
    278 
    279 static void vfs_in_wait_handle(cap_call_handle_t rid, ipc_call_t *request)
     276        async_answer_0(req_handle, rc);
     277}
     278
     279static void vfs_in_wait_handle(cap_call_handle_t req_handle, ipc_call_t *request)
    280280{
    281281        bool high_fd = IPC_GET_ARG1(*request);
    282282        int fd = -1;
    283283        errno_t rc = vfs_op_wait_handle(high_fd, &fd);
    284         async_answer_1(rid, rc, fd);
    285 }
    286 
    287 static void vfs_in_walk(cap_call_handle_t rid, ipc_call_t *request)
     284        async_answer_1(req_handle, rc, fd);
     285}
     286
     287static void vfs_in_walk(cap_call_handle_t req_handle, ipc_call_t *request)
    288288{
    289289        /*
     
    301301                free(path);
    302302        }
    303         async_answer_1(rid, rc, fd);
    304 }
    305 
    306 static void vfs_in_write(cap_call_handle_t rid, ipc_call_t *request)
     303        async_answer_1(req_handle, rc, fd);
     304}
     305
     306static void vfs_in_write(cap_call_handle_t req_handle, ipc_call_t *request)
    307307{
    308308        int fd = IPC_GET_ARG1(*request);
     
    312312        size_t bytes = 0;
    313313        errno_t rc = vfs_op_write(fd, pos, &bytes);
    314         async_answer_1(rid, rc, bytes);
     314        async_answer_1(req_handle, rc, bytes);
    315315}
    316316
  • uspace/srv/vfs/vfs_pager.c

    ra46e56b r77f0a1d  
    4242#include <as.h>
    4343
    44 void vfs_page_in(cap_call_handle_t rid, ipc_call_t *request)
     44void vfs_page_in(cap_call_handle_t req_handle, ipc_call_t *request)
    4545{
    4646        aoff64_t offset = IPC_GET_ARG1(*request);
     
    5555
    5656        if (page == AS_MAP_FAILED) {
    57                 async_answer_0(rid, ENOMEM);
     57                async_answer_0(req_handle, ENOMEM);
    5858                return;
    5959        }
     
    7878        } while (total < page_size);
    7979
    80         async_answer_1(rid, rc, (sysarg_t) page);
     80        async_answer_1(req_handle, rc, (sysarg_t) page);
    8181
    8282        /*
  • uspace/srv/vfs/vfs_register.c

    ra46e56b r77f0a1d  
    108108/** VFS_REGISTER protocol function.
    109109 *
    110  * @param rid     Hash of the call with the request.
    111  * @param request Call structure with the request.
    112  *
    113  */
    114 void vfs_register(cap_call_handle_t rid, ipc_call_t *request)
     110 * @param req_handle  Call handle of the request.
     111 * @param request     Call structure with the request.
     112 *
     113 */
     114void vfs_register(cap_call_handle_t req_handle, ipc_call_t *request)
    115115{
    116116        dprintf("Processing VFS_REGISTER request received from %zx.\n",
     
    124124                dprintf("Failed to deliver the VFS info into our AS, rc=%d.\n",
    125125                    rc);
    126                 async_answer_0(rid, rc);
     126                async_answer_0(req_handle, rc);
    127127                return;
    128128        }
     
    134134        if (!fs_info) {
    135135                dprintf("Could not allocate memory for FS info.\n");
    136                 async_answer_0(rid, ENOMEM);
     136                async_answer_0(req_handle, ENOMEM);
    137137                return;
    138138        }
     
    146146        if (!vfs_info_sane(&fs_info->vfs_info)) {
    147147                free(fs_info);
    148                 async_answer_0(rid, EINVAL);
     148                async_answer_0(req_handle, EINVAL);
    149149                return;
    150150        }
     
    163163                fibril_mutex_unlock(&fs_list_lock);
    164164                free(fs_info);
    165                 async_answer_0(rid, EEXIST);
     165                async_answer_0(req_handle, EEXIST);
    166166                return;
    167167        }
     
    184184                fibril_mutex_unlock(&fs_list_lock);
    185185                free(fs_info);
    186                 async_answer_0(rid, EINVAL);
     186                async_answer_0(req_handle, EINVAL);
    187187                return;
    188188        }
     
    203203                free(fs_info);
    204204                async_answer_0(chandle, EINVAL);
    205                 async_answer_0(rid, EINVAL);
     205                async_answer_0(req_handle, EINVAL);
    206206                return;
    207207        }
     
    217217                free(fs_info);
    218218                async_answer_0(chandle, EINVAL);
    219                 async_answer_0(rid, EINVAL);
     219                async_answer_0(req_handle, EINVAL);
    220220                return;
    221221        }
     
    235235         */
    236236        fs_info->fs_handle = (fs_handle_t) atomic_postinc(&fs_handle_next);
    237         async_answer_1(rid, EOK, (sysarg_t) fs_info->fs_handle);
     237        async_answer_1(req_handle, EOK, (sysarg_t) fs_info->fs_handle);
    238238
    239239        fibril_condvar_broadcast(&fs_list_cv);
Note: See TracChangeset for help on using the changeset viewer.