Rev 3079 | Rev 3215 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed
| Rev 3079 | Rev 3109 | ||
|---|---|---|---|
| Line 60... | Line 60... | ||
| 60 | * concurrent VFS operation which modifies the file system namespace. |
60 | * concurrent VFS operation which modifies the file system namespace. |
| 61 | */ |
61 | */ |
| 62 | RWLOCK_INITIALIZE(namespace_rwlock); |
62 | RWLOCK_INITIALIZE(namespace_rwlock); |
| 63 | 63 | ||
| 64 | futex_t rootfs_futex = FUTEX_INITIALIZER; |
64 | futex_t rootfs_futex = FUTEX_INITIALIZER; |
| 65 | vfs_triplet_t rootfs = { |
65 | vfs_pair_t rootfs = { |
| 66 | .fs_handle = 0, |
66 | .fs_handle = 0, |
| 67 | .dev_handle = 0, |
67 | .dev_handle = 0 |
| 68 | .index = 0, |
- | |
| 69 | }; |
68 | }; |
| 70 | 69 | ||
| 71 | static int |
- | |
| 72 | lookup_root(fs_handle_t fs_handle, dev_handle_t dev_handle, |
- | |
| 73 | vfs_lookup_res_t *result) |
- | |
| 74 | { |
- | |
| 75 | vfs_pair_t altroot = { |
- | |
| 76 | .fs_handle = fs_handle, |
- | |
| 77 | .dev_handle = dev_handle, |
- | |
| 78 | }; |
- | |
| 79 | - | ||
| 80 | return vfs_lookup_internal("/", L_DIRECTORY, result, &altroot); |
- | |
| 81 | } |
- | |
| 82 | - | ||
| 83 | void vfs_mount(ipc_callid_t rid, ipc_call_t *request) |
70 | void vfs_mount(ipc_callid_t rid, ipc_call_t *request) |
| 84 | { |
71 | { |
| 85 | dev_handle_t dev_handle; |
72 | dev_handle_t dev_handle; |
| 86 | vfs_node_t *mp_node = NULL; |
73 | vfs_node_t *mp_node = NULL; |
| 87 | int rc; |
74 | int rc; |
| Line 161... | Line 148... | ||
| 161 | 148 | ||
| 162 | /* Deliver the mount point. */ |
149 | /* Deliver the mount point. */ |
| 163 | (void) ipc_data_write_finalize(callid, buf, size); |
150 | (void) ipc_data_write_finalize(callid, buf, size); |
| 164 | buf[size] = '\0'; |
151 | buf[size] = '\0'; |
| 165 | 152 | ||
| 166 | /* |
- | |
| 167 | * Lookup the root node of the filesystem being mounted. |
- | |
| 168 | * In this case, we don't need to take the namespace_futex as the root |
- | |
| 169 | * node cannot be removed. However, we do take a reference to it so |
- | |
| 170 | * that we can track how many times it has been mounted. |
- | |
| 171 | */ |
- | |
| 172 | vfs_lookup_res_t mr_res; |
- | |
| 173 | rc = lookup_root(fs_handle, dev_handle, &mr_res); |
- | |
| 174 | if (rc != EOK) { |
- | |
| 175 | free(buf); |
- | |
| 176 | ipc_answer_0(rid, rc); |
- | |
| 177 | return; |
- | |
| 178 | } |
- | |
| 179 | vfs_node_t *mr_node = vfs_node_get(&mr_res); |
- | |
| 180 | if (!mr_node) { |
- | |
| 181 | free(buf); |
- | |
| 182 | ipc_answer_0(rid, ENOMEM); |
- | |
| 183 | return; |
- | |
| 184 | } |
- | |
| 185 | - | ||
| 186 | /* Finally, we need to resolve the path to the mountpoint. */ |
153 | /* Resolve the path to the mountpoint. */ |
| 187 | vfs_lookup_res_t mp_res; |
154 | vfs_lookup_res_t mp_res; |
| 188 | futex_down(&rootfs_futex); |
155 | futex_down(&rootfs_futex); |
| 189 | if (rootfs.fs_handle) { |
156 | if (rootfs.fs_handle) { |
| 190 | /* We already have the root FS. */ |
157 | /* We already have the root FS. */ |
| 191 | rwlock_write_lock(&namespace_rwlock); |
158 | rwlock_write_lock(&namespace_rwlock); |
| 192 | if ((size == 1) && (buf[0] == '/')) { |
159 | if ((size == 1) && (buf[0] == '/')) { |
| 193 | /* Trying to mount root FS over root FS */ |
160 | /* Trying to mount root FS over root FS */ |
| 194 | rwlock_write_unlock(&namespace_rwlock); |
161 | rwlock_write_unlock(&namespace_rwlock); |
| 195 | futex_up(&rootfs_futex); |
162 | futex_up(&rootfs_futex); |
| 196 | vfs_node_put(mr_node); |
- | |
| 197 | free(buf); |
163 | free(buf); |
| 198 | ipc_answer_0(rid, EBUSY); |
164 | ipc_answer_0(rid, EBUSY); |
| 199 | return; |
165 | return; |
| 200 | } |
166 | } |
| 201 | rc = vfs_lookup_internal(buf, L_DIRECTORY, &mp_res, NULL); |
167 | rc = vfs_lookup_internal(buf, L_DIRECTORY, &mp_res, NULL); |
| 202 | if (rc != EOK) { |
168 | if (rc != EOK) { |
| 203 | /* The lookup failed for some reason. */ |
169 | /* The lookup failed for some reason. */ |
| 204 | rwlock_write_unlock(&namespace_rwlock); |
170 | rwlock_write_unlock(&namespace_rwlock); |
| 205 | futex_up(&rootfs_futex); |
171 | futex_up(&rootfs_futex); |
| 206 | vfs_node_put(mr_node); /* failed -> drop reference */ |
- | |
| 207 | free(buf); |
172 | free(buf); |
| 208 | ipc_answer_0(rid, rc); |
173 | ipc_answer_0(rid, rc); |
| 209 | return; |
174 | return; |
| 210 | } |
175 | } |
| 211 | mp_node = vfs_node_get(&mp_res); |
176 | mp_node = vfs_node_get(&mp_res); |
| 212 | if (!mp_node) { |
177 | if (!mp_node) { |
| 213 | rwlock_write_unlock(&namespace_rwlock); |
178 | rwlock_write_unlock(&namespace_rwlock); |
| 214 | futex_up(&rootfs_futex); |
179 | futex_up(&rootfs_futex); |
| 215 | vfs_node_put(mr_node); /* failed -> drop reference */ |
- | |
| 216 | free(buf); |
180 | free(buf); |
| 217 | ipc_answer_0(rid, ENOMEM); |
181 | ipc_answer_0(rid, ENOMEM); |
| 218 | return; |
182 | return; |
| 219 | } |
183 | } |
| 220 | /* |
184 | /* |
| Line 230... | Line 194... | ||
| 230 | * For this simple, but important case, |
194 | * For this simple, but important case, |
| 231 | * we are almost done. |
195 | * we are almost done. |
| 232 | */ |
196 | */ |
| 233 | free(buf); |
197 | free(buf); |
| 234 | 198 | ||
| 235 | /* Inform the mount point about the root mount. */ |
199 | /* Tell the mountee that it is being mounted. */ |
| 236 | phone = vfs_grab_phone(mr_res.triplet.fs_handle); |
200 | phone = vfs_grab_phone(fs_handle); |
| 237 | rc = async_req_5_0(phone, VFS_MOUNT, |
201 | rc = async_req_1_0(phone, VFS_MOUNTED, |
| 238 | (ipcarg_t) mr_res.triplet.dev_handle, |
- | |
| 239 | (ipcarg_t) mr_res.triplet.index, |
- | |
| 240 | (ipcarg_t) mr_res.triplet.fs_handle, |
- | |
| 241 | (ipcarg_t) mr_res.triplet.dev_handle, |
202 | (ipcarg_t) dev_handle); |
| 242 | (ipcarg_t) mr_res.triplet.index); |
- | |
| 243 | vfs_release_phone(phone); |
203 | vfs_release_phone(phone); |
| 244 | 204 | ||
| 245 | if (rc == EOK) |
205 | if (rc == EOK) { |
| 246 | rootfs = mr_res.triplet; |
206 | rootfs.fs_handle = fs_handle; |
| - | 207 | rootfs.dev_handle = dev_handle; |
|
| 247 | else |
208 | } |
| 248 | vfs_node_put(mr_node); |
- | |
| 249 | 209 | ||
| 250 | futex_up(&rootfs_futex); |
210 | futex_up(&rootfs_futex); |
| 251 | ipc_answer_0(rid, rc); |
211 | ipc_answer_0(rid, rc); |
| 252 | return; |
212 | return; |
| 253 | } else { |
213 | } else { |
| Line 255... | Line 215... | ||
| 255 | * We can't resolve this without the root filesystem |
215 | * We can't resolve this without the root filesystem |
| 256 | * being mounted first. |
216 | * being mounted first. |
| 257 | */ |
217 | */ |
| 258 | futex_up(&rootfs_futex); |
218 | futex_up(&rootfs_futex); |
| 259 | free(buf); |
219 | free(buf); |
| 260 | vfs_node_put(mr_node); /* failed -> drop reference */ |
- | |
| 261 | ipc_answer_0(rid, ENOENT); |
220 | ipc_answer_0(rid, ENOENT); |
| 262 | return; |
221 | return; |
| 263 | } |
222 | } |
| 264 | } |
223 | } |
| 265 | futex_up(&rootfs_futex); |
224 | futex_up(&rootfs_futex); |
| 266 | 225 | ||
| 267 | free(buf); /* The buffer is not needed anymore. */ |
226 | free(buf); /* The buffer is not needed anymore. */ |
| 268 | 227 | ||
| 269 | /* |
228 | /* |
| 270 | * At this point, we have all necessary pieces: file system and device |
229 | * At this point, we have all necessary pieces: file system and device |
| 271 | * handles, and we know the mount point VFS node and also the root node |
230 | * handles, and we know the mount point VFS node. |
| 272 | * of the file system being mounted. |
- | |
| 273 | */ |
231 | */ |
| 274 | 232 | ||
| 275 | /** |
- | |
| 276 | * @todo |
- | |
| 277 | * Add more IPC parameters so that we can send mount mode/flags. |
- | |
| 278 | */ |
- | |
| 279 | phone = vfs_grab_phone(mp_res.triplet.fs_handle); |
233 | phone = vfs_grab_phone(mp_res.triplet.fs_handle); |
| 280 | rc = async_req_5_0(phone, VFS_MOUNT, |
234 | rc = async_req_4_0(phone, VFS_MOUNT, |
| 281 | (ipcarg_t) mp_res.triplet.dev_handle, |
235 | (ipcarg_t) mp_res.triplet.dev_handle, |
| 282 | (ipcarg_t) mp_res.triplet.index, |
236 | (ipcarg_t) mp_res.triplet.index, |
| 283 | (ipcarg_t) mr_res.triplet.fs_handle, |
237 | (ipcarg_t) fs_handle, |
| 284 | (ipcarg_t) mr_res.triplet.dev_handle, |
238 | (ipcarg_t) dev_handle); |
| 285 | (ipcarg_t) mr_res.triplet.index); |
- | |
| 286 | vfs_release_phone(phone); |
239 | vfs_release_phone(phone); |
| 287 | 240 | ||
| 288 | if (rc != EOK) { |
241 | if (rc != EOK) { |
| 289 | /* Mount failed, drop references to mr_node and mp_node. */ |
242 | /* Mount failed, drop reference to mp_node. */ |
| 290 | vfs_node_put(mr_node); |
- | |
| 291 | if (mp_node) |
243 | if (mp_node) |
| 292 | vfs_node_put(mp_node); |
244 | vfs_node_put(mp_node); |
| 293 | } |
245 | } |
| 294 | 246 | ||
| 295 | ipc_answer_0(rid, rc); |
247 | ipc_answer_0(rid, rc); |