Changes in uspace/srv/vfs/vfs_ops.c [286286c:27b76ca] in mainline
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/vfs/vfs_ops.c
r286286c r27b76ca 54 54 55 55 /* Forward declarations of static functions. */ 56 static int vfs_truncate_internal(fs_handle_t, service_id_t, fs_index_t,56 static int vfs_truncate_internal(fs_handle_t, devmap_handle_t, fs_index_t, 57 57 aoff64_t); 58 58 … … 65 65 vfs_pair_t rootfs = { 66 66 .fs_handle = 0, 67 . service_id= 067 .devmap_handle = 0 68 68 }; 69 69 70 static void vfs_mount_internal(ipc_callid_t rid, service_id_t service_id,70 static void vfs_mount_internal(ipc_callid_t rid, devmap_handle_t devmap_handle, 71 71 fs_handle_t fs_handle, char *mp, char *opts) 72 72 { … … 125 125 exch = vfs_exchange_grab(fs_handle); 126 126 msg = async_send_1(exch, VFS_OUT_MOUNTED, 127 (sysarg_t) service_id, &answer);127 (sysarg_t) devmap_handle, &answer); 128 128 /* Send the mount options */ 129 129 rc = async_data_write_start(exch, (void *)opts, … … 146 146 147 147 rindex = (fs_index_t) IPC_GET_ARG1(answer); 148 rsize = (aoff64_t) MERGE_LOUP32(IPC_GET_ARG2(answer), 149 IPC_GET_ARG3(answer)); 148 rsize = (aoff64_t) MERGE_LOUP32(IPC_GET_ARG2(answer), IPC_GET_ARG3(answer)); 150 149 rlnkcnt = (unsigned) IPC_GET_ARG4(answer); 151 150 152 151 mr_res.triplet.fs_handle = fs_handle; 153 mr_res.triplet. service_id = service_id;152 mr_res.triplet.devmap_handle = devmap_handle; 154 153 mr_res.triplet.index = rindex; 155 154 mr_res.size = rsize; … … 158 157 159 158 rootfs.fs_handle = fs_handle; 160 rootfs. service_id = service_id;159 rootfs.devmap_handle = devmap_handle; 161 160 162 161 /* Add reference to the mounted root. */ … … 179 178 180 179 /* 181 * At this point, we have all necessary pieces: file system handle182 * and service ID, and we know the mount point VFS node.180 * At this point, we have all necessary pieces: file system and device 181 * handles, and we know the mount point VFS node. 183 182 */ 184 183 … … 188 187 exch = vfs_exchange_grab(mp_res.triplet.fs_handle); 189 188 msg = async_send_4(exch, VFS_OUT_MOUNT, 190 (sysarg_t) mp_res.triplet. service_id,189 (sysarg_t) mp_res.triplet.devmap_handle, 191 190 (sysarg_t) mp_res.triplet.index, 192 191 (sysarg_t) fs_handle, 193 (sysarg_t) service_id, &answer);192 (sysarg_t) devmap_handle, &answer); 194 193 195 194 /* Send connection */ … … 225 224 } 226 225 227 /* 228 * Wait for the answer before releasing the exchange to avoid deadlock 229 * in case the answer depends on further calls to the same file system. 230 * Think of a case when mounting a FS on a file_bd backed by a file on 231 * the same FS. 232 */ 226 vfs_exchange_release(exch); 233 227 async_wait_for(msg, &rc); 234 vfs_exchange_release(exch);235 228 236 229 if (rc == EOK) { … … 241 234 242 235 mr_res.triplet.fs_handle = fs_handle; 243 mr_res.triplet. service_id = service_id;236 mr_res.triplet.devmap_handle = devmap_handle; 244 237 mr_res.triplet.index = rindex; 245 238 mr_res.size = rsize; … … 262 255 void vfs_mount(ipc_callid_t rid, ipc_call_t *request) 263 256 { 264 service_id_t service_id;257 devmap_handle_t devmap_handle; 265 258 266 259 /* … … 269 262 * in the request. 270 263 */ 271 service_id = (service_id_t) IPC_GET_ARG1(*request);264 devmap_handle = (devmap_handle_t) IPC_GET_ARG1(*request); 272 265 273 266 /* … … 277 270 278 271 /* 279 * Instance number is passed as ARG3.280 * /281 unsigned int instance = IPC_GET_ARG3(*request);282 272 * For now, don't make use of ARG3, but it can be used to 273 * carry mount options in the future. 274 */ 275 283 276 /* We want the client to send us the mount point. */ 284 277 char *mp; … … 336 329 fs_handle_t fs_handle; 337 330 recheck: 338 fs_handle = fs_name_to_handle( instance,fs_name, false);331 fs_handle = fs_name_to_handle(fs_name, false); 339 332 if (!fs_handle) { 340 333 if (flags & IPC_FLAG_BLOCKING) { … … 357 350 358 351 /* Do the mount */ 359 vfs_mount_internal(rid, service_id, fs_handle, mp, opts);352 vfs_mount_internal(rid, devmap_handle, fs_handle, mp, opts); 360 353 free(mp); 361 354 free(fs_name); … … 416 409 */ 417 410 if (vfs_nodes_refcount_sum_get(mr_node->fs_handle, 418 mr_node-> service_id) != 2) {411 mr_node->devmap_handle) != 2) { 419 412 fibril_rwlock_write_unlock(&namespace_rwlock); 420 413 vfs_node_put(mr_node); … … 437 430 exch = vfs_exchange_grab(mr_node->fs_handle); 438 431 rc = async_req_1_0(exch, VFS_OUT_UNMOUNTED, 439 mr_node-> service_id);432 mr_node->devmap_handle); 440 433 vfs_exchange_release(exch); 441 434 … … 448 441 449 442 rootfs.fs_handle = 0; 450 rootfs. service_id= 0;443 rootfs.devmap_handle = 0; 451 444 } else { 452 445 … … 477 470 exch = vfs_exchange_grab(mp_node->fs_handle); 478 471 rc = async_req_2_0(exch, VFS_OUT_UNMOUNT, 479 mp_node-> service_id, mp_node->index);472 mp_node->devmap_handle, mp_node->index); 480 473 vfs_exchange_release(exch); 481 474 … … 582 575 if (node->size) { 583 576 rc = vfs_truncate_internal(node->fs_handle, 584 node-> service_id, node->index, 0);577 node->devmap_handle, node->index, 0); 585 578 if (rc) { 586 579 fibril_rwlock_write_unlock(&node->contents_rwlock); … … 646 639 aid_t msg; 647 640 ipc_call_t answer; 648 msg = async_send_2(fs_exch, VFS_OUT_SYNC, file->node-> service_id,641 msg = async_send_2(fs_exch, VFS_OUT_SYNC, file->node->devmap_handle, 649 642 file->node->index, &answer); 650 643 … … 731 724 if (read) { 732 725 rc = async_data_read_forward_4_1(fs_exch, VFS_OUT_READ, 733 file->node-> service_id, file->node->index,726 file->node->devmap_handle, file->node->index, 734 727 LOWER32(file->pos), UPPER32(file->pos), &answer); 735 728 } else { … … 738 731 739 732 rc = async_data_write_forward_4_1(fs_exch, VFS_OUT_WRITE, 740 file->node-> service_id, file->node->index,733 file->node->devmap_handle, file->node->index, 741 734 LOWER32(file->pos), UPPER32(file->pos), &answer); 742 735 } … … 869 862 } 870 863 871 int vfs_truncate_internal(fs_handle_t fs_handle, service_id_t service_id,864 int vfs_truncate_internal(fs_handle_t fs_handle, devmap_handle_t devmap_handle, 872 865 fs_index_t index, aoff64_t size) 873 866 { 874 867 async_exch_t *exch = vfs_exchange_grab(fs_handle); 875 868 sysarg_t rc = async_req_4_0(exch, VFS_OUT_TRUNCATE, 876 (sysarg_t) service_id, (sysarg_t) index, LOWER32(size),869 (sysarg_t) devmap_handle, (sysarg_t) index, LOWER32(size), 877 870 UPPER32(size)); 878 871 vfs_exchange_release(exch); … … 897 890 fibril_rwlock_write_lock(&file->node->contents_rwlock); 898 891 rc = vfs_truncate_internal(file->node->fs_handle, 899 file->node-> service_id, file->node->index, size);892 file->node->devmap_handle, file->node->index, size); 900 893 if (rc == EOK) 901 894 file->node->size = size; … … 931 924 932 925 aid_t msg; 933 msg = async_send_3(exch, VFS_OUT_STAT, file->node-> service_id,926 msg = async_send_3(exch, VFS_OUT_STAT, file->node->devmap_handle, 934 927 file->node->index, true, NULL); 935 928 async_forward_fast(callid, exch, 0, 0, 0, IPC_FF_ROUTE_FROM_ME); … … 984 977 985 978 aid_t msg; 986 msg = async_send_3(exch, VFS_OUT_STAT, node-> service_id,979 msg = async_send_3(exch, VFS_OUT_STAT, node->devmap_handle, 987 980 node->index, false, NULL); 988 981 async_forward_fast(callid, exch, 0, 0, 0, IPC_FF_ROUTE_FROM_ME); … … 1161 1154 /* Check whether linking to the same file system instance. */ 1162 1155 if ((old_node->fs_handle != new_par_lr.triplet.fs_handle) || 1163 (old_node-> service_id != new_par_lr.triplet.service_id)) {1156 (old_node->devmap_handle != new_par_lr.triplet.devmap_handle)) { 1164 1157 fibril_rwlock_write_unlock(&namespace_rwlock); 1165 1158 vfs_node_put(old_node);
Note:
See TracChangeset
for help on using the changeset viewer.