| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 1 | /* | 
|  | 2 | * Copyright (C) 2010 The Android Open Source Project | 
|  | 3 | * | 
|  | 4 | * Licensed under the Apache License, Version 2.0 (the "License"); | 
|  | 5 | * you may not use this file except in compliance with the License. | 
|  | 6 | * You may obtain a copy of the License at | 
|  | 7 | * | 
|  | 8 | *      http://www.apache.org/licenses/LICENSE-2.0 | 
|  | 9 | * | 
|  | 10 | * Unless required by applicable law or agreed to in writing, software | 
|  | 11 | * distributed under the License is distributed on an "AS IS" BASIS, | 
|  | 12 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | 
|  | 13 | * See the License for the specific language governing permissions and | 
|  | 14 | * limitations under the License. | 
|  | 15 | */ | 
|  | 16 |  | 
|  | 17 | #include <stdio.h> | 
|  | 18 | #include <stdlib.h> | 
|  | 19 | #include <string.h> | 
|  | 20 | #include <unistd.h> | 
|  | 21 | #include <errno.h> | 
|  | 22 | #include <fcntl.h> | 
|  | 23 | #include <sys/mount.h> | 
|  | 24 | #include <sys/stat.h> | 
| Mike Lockwood | 4553b08 | 2010-08-16 14:14:44 -0400 | [diff] [blame] | 25 | #include <sys/statfs.h> | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 26 | #include <sys/uio.h> | 
|  | 27 | #include <dirent.h> | 
| Mike Lockwood | 1bedb73 | 2011-01-13 13:38:42 -0500 | [diff] [blame] | 28 | #include <ctype.h> | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 29 |  | 
| Brian Swetland | b14a2c6 | 2010-08-12 18:21:12 -0700 | [diff] [blame] | 30 | #include <private/android_filesystem_config.h> | 
|  | 31 |  | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 32 | #include "fuse.h" | 
|  | 33 |  | 
|  | 34 | /* README | 
|  | 35 | * | 
|  | 36 | * What is this? | 
|  | 37 | * | 
|  | 38 | * sdcard is a program that uses FUSE to emulate FAT-on-sdcard style | 
|  | 39 | * directory permissions (all files are given fixed owner, group, and | 
|  | 40 | * permissions at creation, owner, group, and permissions are not | 
|  | 41 | * changeable, symlinks and hardlinks are not createable, etc. | 
|  | 42 | * | 
|  | 43 | * usage:  sdcard <path> <uid> <gid> | 
|  | 44 | * | 
|  | 45 | * It must be run as root, but will change to uid/gid as soon as it | 
| Mike Lockwood | 4553b08 | 2010-08-16 14:14:44 -0400 | [diff] [blame] | 46 | * mounts a filesystem on /mnt/sdcard.  It will refuse to run if uid or | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 47 | * gid are zero. | 
|  | 48 | * | 
|  | 49 | * | 
|  | 50 | * Things I believe to be true: | 
|  | 51 | * | 
|  | 52 | * - ops that return a fuse_entry (LOOKUP, MKNOD, MKDIR, LINK, SYMLINK, | 
|  | 53 | * CREAT) must bump that node's refcount | 
|  | 54 | * - don't forget that FORGET can forget multiple references (req->nlookup) | 
|  | 55 | * - if an op that returns a fuse_entry fails writing the reply to the | 
|  | 56 | * kernel, you must rollback the refcount to reflect the reference the | 
|  | 57 | * kernel did not actually acquire | 
|  | 58 | * | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 59 | */ | 
|  | 60 |  | 
|  | 61 | #define FUSE_TRACE 0 | 
|  | 62 |  | 
|  | 63 | #if FUSE_TRACE | 
|  | 64 | #define TRACE(x...) fprintf(stderr,x) | 
|  | 65 | #else | 
|  | 66 | #define TRACE(x...) do {} while (0) | 
|  | 67 | #endif | 
|  | 68 |  | 
|  | 69 | #define ERROR(x...) fprintf(stderr,x) | 
|  | 70 |  | 
|  | 71 | #define FUSE_UNKNOWN_INO 0xffffffff | 
|  | 72 |  | 
| Mike Lockwood | 4553b08 | 2010-08-16 14:14:44 -0400 | [diff] [blame] | 73 | #define MOUNT_POINT "/mnt/sdcard" | 
|  | 74 |  | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 75 | struct handle { | 
|  | 76 | struct node *node; | 
|  | 77 | int fd; | 
|  | 78 | }; | 
|  | 79 |  | 
|  | 80 | struct dirhandle { | 
|  | 81 | struct node *node; | 
|  | 82 | DIR *d; | 
|  | 83 | }; | 
|  | 84 |  | 
|  | 85 | struct node { | 
|  | 86 | __u64 nid; | 
|  | 87 | __u64 gen; | 
|  | 88 |  | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 89 | struct node *next;          /* per-dir sibling list */ | 
|  | 90 | struct node *child;         /* first contained file by this dir */ | 
|  | 91 | struct node *all;           /* global node list */ | 
|  | 92 | struct node *parent;        /* containing directory */ | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 93 |  | 
|  | 94 | __u32 refcount; | 
|  | 95 | __u32 namelen; | 
|  | 96 |  | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 97 | char *name; | 
| Mike Lockwood | 575a2bb | 2011-01-23 14:46:30 -0800 | [diff] [blame] | 98 | /* If non-null, this is the real name of the file in the underlying storage. | 
|  | 99 | * This may differ from the field "name" only by case. | 
|  | 100 | * strlen(actual_name) will always equal strlen(name), so it is safe to use | 
|  | 101 | * namelen for both fields. | 
|  | 102 | */ | 
|  | 103 | char *actual_name; | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 104 | }; | 
|  | 105 |  | 
|  | 106 | struct fuse { | 
|  | 107 | __u64 next_generation; | 
|  | 108 | __u64 next_node_id; | 
|  | 109 |  | 
|  | 110 | int fd; | 
|  | 111 |  | 
|  | 112 | struct node *all; | 
|  | 113 |  | 
|  | 114 | struct node root; | 
|  | 115 | char rootpath[1024]; | 
|  | 116 | }; | 
|  | 117 |  | 
| Mike Lockwood | 1bedb73 | 2011-01-13 13:38:42 -0500 | [diff] [blame] | 118 | static unsigned uid = -1; | 
|  | 119 | static unsigned gid = -1; | 
| Mike Lockwood | 4f35e62 | 2011-01-12 14:39:44 -0500 | [diff] [blame] | 120 |  | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 121 | #define PATH_BUFFER_SIZE 1024 | 
|  | 122 |  | 
| Mike Lockwood | 575a2bb | 2011-01-23 14:46:30 -0800 | [diff] [blame] | 123 | #define NO_CASE_SENSITIVE_MATCH 0 | 
|  | 124 | #define CASE_SENSITIVE_MATCH 1 | 
| Mike Lockwood | b94d320 | 2011-01-17 21:06:26 -0800 | [diff] [blame] | 125 |  | 
| Paul Eastham | f43219e | 2010-09-21 17:14:31 -0700 | [diff] [blame] | 126 | /* | 
|  | 127 | * Get the real-life absolute path to a node. | 
|  | 128 | *   node: start at this node | 
|  | 129 | *   buf: storage for returned string | 
|  | 130 | *   name: append this string to path if set | 
|  | 131 | */ | 
| Mike Lockwood | 575a2bb | 2011-01-23 14:46:30 -0800 | [diff] [blame] | 132 | char *do_node_get_path(struct node *node, char *buf, const char *name, int match_case_insensitive) | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 133 | { | 
| Mike Lockwood | 575a2bb | 2011-01-23 14:46:30 -0800 | [diff] [blame] | 134 | struct node *in_node = node; | 
|  | 135 | const char *in_name = name; | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 136 | char *out = buf + PATH_BUFFER_SIZE - 1; | 
|  | 137 | int len; | 
|  | 138 | out[0] = 0; | 
|  | 139 |  | 
|  | 140 | if (name) { | 
|  | 141 | len = strlen(name); | 
|  | 142 | goto start; | 
|  | 143 | } | 
|  | 144 |  | 
|  | 145 | while (node) { | 
| Mike Lockwood | 575a2bb | 2011-01-23 14:46:30 -0800 | [diff] [blame] | 146 | name = (node->actual_name ? node->actual_name : node->name); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 147 | len = node->namelen; | 
|  | 148 | node = node->parent; | 
|  | 149 | start: | 
|  | 150 | if ((len + 1) > (out - buf)) | 
|  | 151 | return 0; | 
|  | 152 | out -= len; | 
|  | 153 | memcpy(out, name, len); | 
| Mike Lockwood | 575a2bb | 2011-01-23 14:46:30 -0800 | [diff] [blame] | 154 | /* avoid double slash at beginning of path */ | 
|  | 155 | if (out[0] != '/') { | 
|  | 156 | out --; | 
|  | 157 | out[0] = '/'; | 
|  | 158 | } | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 159 | } | 
|  | 160 |  | 
| Mike Lockwood | 575a2bb | 2011-01-23 14:46:30 -0800 | [diff] [blame] | 161 | /* If we are searching for a file within node (rather than computing node's path) | 
|  | 162 | * and fail, then we need to look for a case insensitive match. | 
|  | 163 | */ | 
|  | 164 | if (in_name && match_case_insensitive && access(out, F_OK) != 0) { | 
|  | 165 | char *path, buffer[PATH_BUFFER_SIZE]; | 
|  | 166 | DIR* dir; | 
|  | 167 | struct dirent* entry; | 
|  | 168 | path = do_node_get_path(in_node, buffer, NULL, NO_CASE_SENSITIVE_MATCH); | 
|  | 169 | dir = opendir(path); | 
|  | 170 | if (!dir) { | 
|  | 171 | ERROR("opendir %s failed: %s", path, strerror(errno)); | 
|  | 172 | return out; | 
|  | 173 | } | 
|  | 174 |  | 
|  | 175 | while ((entry = readdir(dir))) { | 
|  | 176 | if (!strcasecmp(entry->d_name, in_name)) { | 
|  | 177 | /* we have a match - replace the name */ | 
|  | 178 | len = strlen(in_name); | 
|  | 179 | memcpy(buf + PATH_BUFFER_SIZE - len - 1, entry->d_name, len); | 
|  | 180 | break; | 
|  | 181 | } | 
|  | 182 | } | 
|  | 183 | closedir(dir); | 
|  | 184 | } | 
|  | 185 |  | 
|  | 186 | return out; | 
|  | 187 | } | 
|  | 188 |  | 
|  | 189 | char *node_get_path(struct node *node, char *buf, const char *name) | 
|  | 190 | { | 
|  | 191 | /* We look for case insensitive matches by default */ | 
|  | 192 | return do_node_get_path(node, buf, name, CASE_SENSITIVE_MATCH); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 193 | } | 
|  | 194 |  | 
|  | 195 | void attr_from_stat(struct fuse_attr *attr, struct stat *s) | 
|  | 196 | { | 
|  | 197 | attr->ino = s->st_ino; | 
|  | 198 | attr->size = s->st_size; | 
|  | 199 | attr->blocks = s->st_blocks; | 
| Mike Lockwood | 4553b08 | 2010-08-16 14:14:44 -0400 | [diff] [blame] | 200 | attr->atime = s->st_atime; | 
|  | 201 | attr->mtime = s->st_mtime; | 
|  | 202 | attr->ctime = s->st_ctime; | 
|  | 203 | attr->atimensec = s->st_atime_nsec; | 
|  | 204 | attr->mtimensec = s->st_mtime_nsec; | 
|  | 205 | attr->ctimensec = s->st_ctime_nsec; | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 206 | attr->mode = s->st_mode; | 
|  | 207 | attr->nlink = s->st_nlink; | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 208 |  | 
| Brian Swetland | b14a2c6 | 2010-08-12 18:21:12 -0700 | [diff] [blame] | 209 | /* force permissions to something reasonable: | 
|  | 210 | * world readable | 
|  | 211 | * writable by the sdcard group | 
|  | 212 | */ | 
|  | 213 | if (attr->mode & 0100) { | 
|  | 214 | attr->mode = (attr->mode & (~0777)) | 0775; | 
|  | 215 | } else { | 
|  | 216 | attr->mode = (attr->mode & (~0777)) | 0664; | 
|  | 217 | } | 
|  | 218 |  | 
|  | 219 | /* all files owned by root.sdcard */ | 
|  | 220 | attr->uid = 0; | 
|  | 221 | attr->gid = AID_SDCARD_RW; | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 222 | } | 
|  | 223 |  | 
|  | 224 | int node_get_attr(struct node *node, struct fuse_attr *attr) | 
|  | 225 | { | 
|  | 226 | int res; | 
|  | 227 | struct stat s; | 
|  | 228 | char *path, buffer[PATH_BUFFER_SIZE]; | 
|  | 229 |  | 
|  | 230 | path = node_get_path(node, buffer, 0); | 
|  | 231 | res = lstat(path, &s); | 
|  | 232 | if (res < 0) { | 
|  | 233 | ERROR("lstat('%s') errno %d\n", path, errno); | 
|  | 234 | return -1; | 
|  | 235 | } | 
|  | 236 |  | 
|  | 237 | attr_from_stat(attr, &s); | 
|  | 238 | attr->ino = node->nid; | 
|  | 239 |  | 
|  | 240 | return 0; | 
|  | 241 | } | 
|  | 242 |  | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 243 | static void add_node_to_parent(struct node *node, struct node *parent) { | 
|  | 244 | node->parent = parent; | 
|  | 245 | node->next = parent->child; | 
|  | 246 | parent->child = node; | 
| Paul Eastham | 77085c5 | 2011-01-04 21:06:03 -0800 | [diff] [blame] | 247 | parent->refcount++; | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 248 | } | 
|  | 249 |  | 
| Mike Lockwood | 575a2bb | 2011-01-23 14:46:30 -0800 | [diff] [blame] | 250 | /* Check to see if our parent directory already has a file with a name | 
|  | 251 | * that differs only by case.  If we find one, store it in the actual_name | 
|  | 252 | * field so node_get_path will map it to this file in the underlying storage. | 
|  | 253 | */ | 
|  | 254 | static void node_find_actual_name(struct node *node) | 
|  | 255 | { | 
|  | 256 | char *path, buffer[PATH_BUFFER_SIZE]; | 
|  | 257 | const char *node_name = node->name; | 
|  | 258 | DIR* dir; | 
|  | 259 | struct dirent* entry; | 
|  | 260 |  | 
|  | 261 | if (!node->parent) return; | 
|  | 262 |  | 
|  | 263 | path = node_get_path(node->parent, buffer, 0); | 
|  | 264 | dir = opendir(path); | 
|  | 265 | if (!dir) { | 
|  | 266 | ERROR("opendir %s failed: %s", path, strerror(errno)); | 
|  | 267 | return; | 
|  | 268 | } | 
|  | 269 |  | 
|  | 270 | while ((entry = readdir(dir))) { | 
|  | 271 | const char *test_name = entry->d_name; | 
|  | 272 | if (strcmp(test_name, node_name) && !strcasecmp(test_name, node_name)) { | 
|  | 273 | /* we have a match - differs but only by case */ | 
|  | 274 | node->actual_name = strdup(test_name); | 
|  | 275 | if (!node->actual_name) { | 
|  | 276 | ERROR("strdup failed - out of memory\n"); | 
|  | 277 | exit(1); | 
|  | 278 | } | 
|  | 279 | break; | 
|  | 280 | } | 
|  | 281 | } | 
|  | 282 | closedir(dir); | 
|  | 283 | } | 
|  | 284 |  | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 285 | struct node *node_create(struct node *parent, const char *name, __u64 nid, __u64 gen) | 
|  | 286 | { | 
|  | 287 | struct node *node; | 
|  | 288 | int namelen = strlen(name); | 
|  | 289 |  | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 290 | node = calloc(1, sizeof(struct node)); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 291 | if (node == 0) { | 
|  | 292 | return 0; | 
|  | 293 | } | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 294 | node->name = malloc(namelen + 1); | 
|  | 295 | if (node->name == 0) { | 
|  | 296 | free(node); | 
|  | 297 | return 0; | 
|  | 298 | } | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 299 |  | 
|  | 300 | node->nid = nid; | 
|  | 301 | node->gen = gen; | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 302 | add_node_to_parent(node, parent); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 303 | memcpy(node->name, name, namelen + 1); | 
|  | 304 | node->namelen = namelen; | 
| Mike Lockwood | 575a2bb | 2011-01-23 14:46:30 -0800 | [diff] [blame] | 305 | node_find_actual_name(node); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 306 | return node; | 
|  | 307 | } | 
|  | 308 |  | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 309 | static char *rename_node(struct node *node, const char *name) | 
|  | 310 | { | 
|  | 311 | node->namelen = strlen(name); | 
|  | 312 | char *newname = realloc(node->name, node->namelen + 1); | 
|  | 313 | if (newname == 0) | 
|  | 314 | return 0; | 
|  | 315 | node->name = newname; | 
|  | 316 | memcpy(node->name, name, node->namelen + 1); | 
| Mike Lockwood | 575a2bb | 2011-01-23 14:46:30 -0800 | [diff] [blame] | 317 | node_find_actual_name(node); | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 318 | return node->name; | 
|  | 319 | } | 
|  | 320 |  | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 321 | void fuse_init(struct fuse *fuse, int fd, const char *path) | 
|  | 322 | { | 
|  | 323 | fuse->fd = fd; | 
|  | 324 | fuse->next_node_id = 2; | 
|  | 325 | fuse->next_generation = 0; | 
|  | 326 |  | 
|  | 327 | fuse->all = &fuse->root; | 
|  | 328 |  | 
|  | 329 | fuse->root.nid = FUSE_ROOT_ID; /* 1 */ | 
|  | 330 | fuse->root.next = 0; | 
|  | 331 | fuse->root.child = 0; | 
|  | 332 | fuse->root.parent = 0; | 
|  | 333 |  | 
|  | 334 | fuse->root.all = 0; | 
|  | 335 | fuse->root.refcount = 2; | 
|  | 336 |  | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 337 | fuse->root.name = 0; | 
|  | 338 | rename_node(&fuse->root, path); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 339 | } | 
|  | 340 |  | 
|  | 341 | static inline void *id_to_ptr(__u64 nid) | 
|  | 342 | { | 
|  | 343 | return (void *) nid; | 
|  | 344 | } | 
|  | 345 |  | 
|  | 346 | static inline __u64 ptr_to_id(void *ptr) | 
|  | 347 | { | 
|  | 348 | return (__u64) ptr; | 
|  | 349 | } | 
|  | 350 |  | 
|  | 351 |  | 
|  | 352 | struct node *lookup_by_inode(struct fuse *fuse, __u64 nid) | 
|  | 353 | { | 
|  | 354 | if (nid == FUSE_ROOT_ID) { | 
|  | 355 | return &fuse->root; | 
|  | 356 | } else { | 
|  | 357 | return id_to_ptr(nid); | 
|  | 358 | } | 
|  | 359 | } | 
|  | 360 |  | 
|  | 361 | struct node *lookup_child_by_name(struct node *node, const char *name) | 
|  | 362 | { | 
|  | 363 | for (node = node->child; node; node = node->next) { | 
|  | 364 | if (!strcmp(name, node->name)) { | 
|  | 365 | return node; | 
|  | 366 | } | 
|  | 367 | } | 
|  | 368 | return 0; | 
|  | 369 | } | 
|  | 370 |  | 
|  | 371 | struct node *lookup_child_by_inode(struct node *node, __u64 nid) | 
|  | 372 | { | 
|  | 373 | for (node = node->child; node; node = node->next) { | 
|  | 374 | if (node->nid == nid) { | 
|  | 375 | return node; | 
|  | 376 | } | 
|  | 377 | } | 
|  | 378 | return 0; | 
|  | 379 | } | 
|  | 380 |  | 
| Paul Eastham | 77085c5 | 2011-01-04 21:06:03 -0800 | [diff] [blame] | 381 | static void dec_refcount(struct node *node) { | 
|  | 382 | if (node->refcount > 0) { | 
|  | 383 | node->refcount--; | 
|  | 384 | TRACE("dec_refcount %p(%s) -> %d\n", node, node->name, node->refcount); | 
|  | 385 | } else { | 
|  | 386 | ERROR("Zero refcnt %p\n", node); | 
|  | 387 | } | 
|  | 388 | } | 
|  | 389 |  | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 390 | static struct node *remove_child(struct node *parent, __u64 nid) | 
|  | 391 | { | 
|  | 392 | struct node *prev = 0; | 
|  | 393 | struct node *node; | 
|  | 394 |  | 
|  | 395 | for (node = parent->child; node; node = node->next) { | 
|  | 396 | if (node->nid == nid) { | 
|  | 397 | if (prev) { | 
|  | 398 | prev->next = node->next; | 
|  | 399 | } else { | 
|  | 400 | parent->child = node->next; | 
|  | 401 | } | 
|  | 402 | node->next = 0; | 
|  | 403 | node->parent = 0; | 
| Paul Eastham | 77085c5 | 2011-01-04 21:06:03 -0800 | [diff] [blame] | 404 | dec_refcount(parent); | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 405 | return node; | 
|  | 406 | } | 
|  | 407 | prev = node; | 
|  | 408 | } | 
|  | 409 | return 0; | 
|  | 410 | } | 
|  | 411 |  | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 412 | struct node *node_lookup(struct fuse *fuse, struct node *parent, const char *name, | 
|  | 413 | struct fuse_attr *attr) | 
|  | 414 | { | 
|  | 415 | int res; | 
|  | 416 | struct stat s; | 
|  | 417 | char *path, buffer[PATH_BUFFER_SIZE]; | 
|  | 418 | struct node *node; | 
|  | 419 |  | 
|  | 420 | path = node_get_path(parent, buffer, name); | 
|  | 421 | /* XXX error? */ | 
|  | 422 |  | 
|  | 423 | res = lstat(path, &s); | 
|  | 424 | if (res < 0) | 
|  | 425 | return 0; | 
|  | 426 |  | 
|  | 427 | node = lookup_child_by_name(parent, name); | 
|  | 428 | if (!node) { | 
|  | 429 | node = node_create(parent, name, fuse->next_node_id++, fuse->next_generation++); | 
|  | 430 | if (!node) | 
|  | 431 | return 0; | 
|  | 432 | node->nid = ptr_to_id(node); | 
|  | 433 | node->all = fuse->all; | 
|  | 434 | fuse->all = node; | 
|  | 435 | } | 
|  | 436 |  | 
|  | 437 | attr_from_stat(attr, &s); | 
|  | 438 | attr->ino = node->nid; | 
|  | 439 |  | 
|  | 440 | return node; | 
|  | 441 | } | 
|  | 442 |  | 
|  | 443 | void node_release(struct node *node) | 
|  | 444 | { | 
|  | 445 | TRACE("RELEASE %p (%s) rc=%d\n", node, node->name, node->refcount); | 
| Paul Eastham | 77085c5 | 2011-01-04 21:06:03 -0800 | [diff] [blame] | 446 | dec_refcount(node); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 447 | if (node->refcount == 0) { | 
|  | 448 | if (node->parent->child == node) { | 
|  | 449 | node->parent->child = node->parent->child->next; | 
|  | 450 | } else { | 
|  | 451 | struct node *node2; | 
|  | 452 |  | 
|  | 453 | node2 = node->parent->child; | 
|  | 454 | while (node2->next != node) | 
|  | 455 | node2 = node2->next; | 
|  | 456 | node2->next = node->next; | 
|  | 457 | } | 
|  | 458 |  | 
|  | 459 | TRACE("DESTROY %p (%s)\n", node, node->name); | 
|  | 460 |  | 
|  | 461 | node_release(node->parent); | 
|  | 462 |  | 
|  | 463 | node->parent = 0; | 
|  | 464 | node->next = 0; | 
|  | 465 |  | 
|  | 466 | /* TODO: remove debugging - poison memory */ | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 467 | memset(node->name, 0xef, node->namelen); | 
|  | 468 | free(node->name); | 
| Mike Lockwood | 575a2bb | 2011-01-23 14:46:30 -0800 | [diff] [blame] | 469 | free(node->actual_name); | 
| Paul Eastham | 77085c5 | 2011-01-04 21:06:03 -0800 | [diff] [blame] | 470 | memset(node, 0xfc, sizeof(*node)); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 471 | free(node); | 
|  | 472 | } | 
|  | 473 | } | 
|  | 474 |  | 
|  | 475 | void fuse_status(struct fuse *fuse, __u64 unique, int err) | 
|  | 476 | { | 
|  | 477 | struct fuse_out_header hdr; | 
|  | 478 | hdr.len = sizeof(hdr); | 
|  | 479 | hdr.error = err; | 
|  | 480 | hdr.unique = unique; | 
|  | 481 | if (err) { | 
|  | 482 | //        ERROR("*** %d ***\n", err); | 
|  | 483 | } | 
|  | 484 | write(fuse->fd, &hdr, sizeof(hdr)); | 
|  | 485 | } | 
|  | 486 |  | 
|  | 487 | void fuse_reply(struct fuse *fuse, __u64 unique, void *data, int len) | 
|  | 488 | { | 
|  | 489 | struct fuse_out_header hdr; | 
|  | 490 | struct iovec vec[2]; | 
|  | 491 | int res; | 
|  | 492 |  | 
|  | 493 | hdr.len = len + sizeof(hdr); | 
|  | 494 | hdr.error = 0; | 
|  | 495 | hdr.unique = unique; | 
|  | 496 |  | 
|  | 497 | vec[0].iov_base = &hdr; | 
|  | 498 | vec[0].iov_len = sizeof(hdr); | 
|  | 499 | vec[1].iov_base = data; | 
|  | 500 | vec[1].iov_len = len; | 
|  | 501 |  | 
|  | 502 | res = writev(fuse->fd, vec, 2); | 
|  | 503 | if (res < 0) { | 
|  | 504 | ERROR("*** REPLY FAILED *** %d\n", errno); | 
|  | 505 | } | 
|  | 506 | } | 
|  | 507 |  | 
|  | 508 | void lookup_entry(struct fuse *fuse, struct node *node, | 
|  | 509 | const char *name, __u64 unique) | 
|  | 510 | { | 
|  | 511 | struct fuse_entry_out out; | 
|  | 512 |  | 
|  | 513 | memset(&out, 0, sizeof(out)); | 
|  | 514 |  | 
|  | 515 | node = node_lookup(fuse, node, name, &out.attr); | 
|  | 516 | if (!node) { | 
|  | 517 | fuse_status(fuse, unique, -ENOENT); | 
|  | 518 | return; | 
|  | 519 | } | 
|  | 520 |  | 
|  | 521 | node->refcount++; | 
|  | 522 | //    fprintf(stderr,"ACQUIRE %p (%s) rc=%d\n", node, node->name, node->refcount); | 
|  | 523 | out.nodeid = node->nid; | 
|  | 524 | out.generation = node->gen; | 
|  | 525 | out.entry_valid = 10; | 
|  | 526 | out.attr_valid = 10; | 
|  | 527 |  | 
|  | 528 | fuse_reply(fuse, unique, &out, sizeof(out)); | 
|  | 529 | } | 
|  | 530 |  | 
|  | 531 | void handle_fuse_request(struct fuse *fuse, struct fuse_in_header *hdr, void *data, unsigned len) | 
|  | 532 | { | 
|  | 533 | struct node *node; | 
|  | 534 |  | 
|  | 535 | if ((len < sizeof(*hdr)) || (hdr->len != len)) { | 
|  | 536 | ERROR("malformed header\n"); | 
|  | 537 | return; | 
|  | 538 | } | 
|  | 539 |  | 
|  | 540 | len -= hdr->len; | 
|  | 541 |  | 
|  | 542 | if (hdr->nodeid) { | 
|  | 543 | node = lookup_by_inode(fuse, hdr->nodeid); | 
|  | 544 | if (!node) { | 
|  | 545 | fuse_status(fuse, hdr->unique, -ENOENT); | 
|  | 546 | return; | 
|  | 547 | } | 
|  | 548 | } else { | 
|  | 549 | node = 0; | 
|  | 550 | } | 
|  | 551 |  | 
|  | 552 | switch (hdr->opcode) { | 
|  | 553 | case FUSE_LOOKUP: { /* bytez[] -> entry_out */ | 
|  | 554 | TRACE("LOOKUP %llx %s\n", hdr->nodeid, (char*) data); | 
|  | 555 | lookup_entry(fuse, node, (char*) data, hdr->unique); | 
|  | 556 | return; | 
|  | 557 | } | 
|  | 558 | case FUSE_FORGET: { | 
|  | 559 | struct fuse_forget_in *req = data; | 
|  | 560 | TRACE("FORGET %llx (%s) #%lld\n", hdr->nodeid, node->name, req->nlookup); | 
|  | 561 | /* no reply */ | 
|  | 562 | while (req->nlookup--) | 
|  | 563 | node_release(node); | 
|  | 564 | return; | 
|  | 565 | } | 
|  | 566 | case FUSE_GETATTR: { /* getattr_in -> attr_out */ | 
|  | 567 | struct fuse_getattr_in *req = data; | 
|  | 568 | struct fuse_attr_out out; | 
|  | 569 |  | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 570 | TRACE("GETATTR flags=%x fh=%llx\n", req->getattr_flags, req->fh); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 571 |  | 
|  | 572 | memset(&out, 0, sizeof(out)); | 
|  | 573 | node_get_attr(node, &out.attr); | 
|  | 574 | out.attr_valid = 10; | 
|  | 575 |  | 
|  | 576 | fuse_reply(fuse, hdr->unique, &out, sizeof(out)); | 
|  | 577 | return; | 
|  | 578 | } | 
|  | 579 | case FUSE_SETATTR: { /* setattr_in -> attr_out */ | 
|  | 580 | struct fuse_setattr_in *req = data; | 
|  | 581 | struct fuse_attr_out out; | 
| Paul Eastham | f43219e | 2010-09-21 17:14:31 -0700 | [diff] [blame] | 582 | char *path, buffer[PATH_BUFFER_SIZE]; | 
|  | 583 | int res = 0; | 
|  | 584 |  | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 585 | TRACE("SETATTR fh=%llx id=%llx valid=%x\n", | 
|  | 586 | req->fh, hdr->nodeid, req->valid); | 
|  | 587 |  | 
| Paul Eastham | f43219e | 2010-09-21 17:14:31 -0700 | [diff] [blame] | 588 | /* XXX: incomplete implementation -- truncate only.  chmod/chown | 
|  | 589 | * should NEVER be implemented. */ | 
|  | 590 |  | 
|  | 591 | path = node_get_path(node, buffer, 0); | 
|  | 592 | if (req->valid & FATTR_SIZE) | 
|  | 593 | res = truncate(path, req->size); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 594 |  | 
|  | 595 | memset(&out, 0, sizeof(out)); | 
|  | 596 | node_get_attr(node, &out.attr); | 
|  | 597 | out.attr_valid = 10; | 
| Paul Eastham | f43219e | 2010-09-21 17:14:31 -0700 | [diff] [blame] | 598 |  | 
|  | 599 | if (res) | 
|  | 600 | fuse_status(fuse, hdr->unique, -errno); | 
|  | 601 | else | 
|  | 602 | fuse_reply(fuse, hdr->unique, &out, sizeof(out)); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 603 | return; | 
|  | 604 | } | 
|  | 605 | //    case FUSE_READLINK: | 
|  | 606 | //    case FUSE_SYMLINK: | 
|  | 607 | case FUSE_MKNOD: { /* mknod_in, bytez[] -> entry_out */ | 
|  | 608 | struct fuse_mknod_in *req = data; | 
|  | 609 | char *path, buffer[PATH_BUFFER_SIZE]; | 
|  | 610 | char *name = ((char*) data) + sizeof(*req); | 
|  | 611 | int res; | 
| Mike Lockwood | 51b3a2d | 2011-01-12 07:35:46 -0500 | [diff] [blame] | 612 |  | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 613 | TRACE("MKNOD %s @ %llx\n", name, hdr->nodeid); | 
|  | 614 | path = node_get_path(node, buffer, name); | 
|  | 615 |  | 
|  | 616 | req->mode = (req->mode & (~0777)) | 0664; | 
|  | 617 | res = mknod(path, req->mode, req->rdev); /* XXX perm?*/ | 
|  | 618 | if (res < 0) { | 
|  | 619 | fuse_status(fuse, hdr->unique, -errno); | 
|  | 620 | } else { | 
|  | 621 | lookup_entry(fuse, node, name, hdr->unique); | 
|  | 622 | } | 
|  | 623 | return; | 
|  | 624 | } | 
|  | 625 | case FUSE_MKDIR: { /* mkdir_in, bytez[] -> entry_out */ | 
|  | 626 | struct fuse_mkdir_in *req = data; | 
|  | 627 | struct fuse_entry_out out; | 
|  | 628 | char *path, buffer[PATH_BUFFER_SIZE]; | 
|  | 629 | char *name = ((char*) data) + sizeof(*req); | 
|  | 630 | int res; | 
| Mike Lockwood | 51b3a2d | 2011-01-12 07:35:46 -0500 | [diff] [blame] | 631 |  | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 632 | TRACE("MKDIR %s @ %llx 0%o\n", name, hdr->nodeid, req->mode); | 
|  | 633 | path = node_get_path(node, buffer, name); | 
|  | 634 |  | 
|  | 635 | req->mode = (req->mode & (~0777)) | 0775; | 
|  | 636 | res = mkdir(path, req->mode); | 
|  | 637 | if (res < 0) { | 
|  | 638 | fuse_status(fuse, hdr->unique, -errno); | 
|  | 639 | } else { | 
|  | 640 | lookup_entry(fuse, node, name, hdr->unique); | 
|  | 641 | } | 
|  | 642 | return; | 
|  | 643 | } | 
|  | 644 | case FUSE_UNLINK: { /* bytez[] -> */ | 
|  | 645 | char *path, buffer[PATH_BUFFER_SIZE]; | 
|  | 646 | int res; | 
|  | 647 | TRACE("UNLINK %s @ %llx\n", (char*) data, hdr->nodeid); | 
|  | 648 | path = node_get_path(node, buffer, (char*) data); | 
|  | 649 | res = unlink(path); | 
|  | 650 | fuse_status(fuse, hdr->unique, res ? -errno : 0); | 
|  | 651 | return; | 
|  | 652 | } | 
|  | 653 | case FUSE_RMDIR: { /* bytez[] -> */ | 
|  | 654 | char *path, buffer[PATH_BUFFER_SIZE]; | 
|  | 655 | int res; | 
|  | 656 | TRACE("RMDIR %s @ %llx\n", (char*) data, hdr->nodeid); | 
|  | 657 | path = node_get_path(node, buffer, (char*) data); | 
|  | 658 | res = rmdir(path); | 
|  | 659 | fuse_status(fuse, hdr->unique, res ? -errno : 0); | 
|  | 660 | return; | 
|  | 661 | } | 
|  | 662 | case FUSE_RENAME: { /* rename_in, oldname, newname ->  */ | 
|  | 663 | struct fuse_rename_in *req = data; | 
|  | 664 | char *oldname = ((char*) data) + sizeof(*req); | 
|  | 665 | char *newname = oldname + strlen(oldname) + 1; | 
|  | 666 | char *oldpath, oldbuffer[PATH_BUFFER_SIZE]; | 
|  | 667 | char *newpath, newbuffer[PATH_BUFFER_SIZE]; | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 668 | struct node *target; | 
|  | 669 | struct node *newparent; | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 670 | int res; | 
|  | 671 |  | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 672 | TRACE("RENAME %s->%s @ %llx\n", oldname, newname, hdr->nodeid); | 
|  | 673 |  | 
|  | 674 | target = lookup_child_by_name(node, oldname); | 
|  | 675 | if (!target) { | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 676 | fuse_status(fuse, hdr->unique, -ENOENT); | 
|  | 677 | return; | 
|  | 678 | } | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 679 | oldpath = node_get_path(node, oldbuffer, oldname); | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 680 |  | 
|  | 681 | newparent = lookup_by_inode(fuse, req->newdir); | 
|  | 682 | if (!newparent) { | 
|  | 683 | fuse_status(fuse, hdr->unique, -ENOENT); | 
|  | 684 | return; | 
|  | 685 | } | 
| Mike Lockwood | 575a2bb | 2011-01-23 14:46:30 -0800 | [diff] [blame] | 686 | if (newparent == node) { | 
|  | 687 | /* Special case for renaming a file where destination | 
|  | 688 | * is same path differing only by case. | 
|  | 689 | * In this case we don't want to look for a case insensitive match. | 
|  | 690 | * This allows commands like "mv foo FOO" to work as expected. | 
|  | 691 | */ | 
|  | 692 | newpath = do_node_get_path(newparent, newbuffer, newname, NO_CASE_SENSITIVE_MATCH); | 
|  | 693 | } else { | 
|  | 694 | newpath = node_get_path(newparent, newbuffer, newname); | 
|  | 695 | } | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 696 |  | 
|  | 697 | if (!remove_child(node, target->nid)) { | 
|  | 698 | ERROR("RENAME remove_child not found"); | 
|  | 699 | fuse_status(fuse, hdr->unique, -ENOENT); | 
|  | 700 | return; | 
|  | 701 | } | 
|  | 702 | if (!rename_node(target, newname)) { | 
|  | 703 | fuse_status(fuse, hdr->unique, -ENOMEM); | 
|  | 704 | return; | 
|  | 705 | } | 
|  | 706 | add_node_to_parent(target, newparent); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 707 |  | 
|  | 708 | res = rename(oldpath, newpath); | 
| Paul Eastham | 11ccdb3 | 2010-10-14 11:04:26 -0700 | [diff] [blame] | 709 | TRACE("RENAME result %d\n", res); | 
|  | 710 |  | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 711 | fuse_status(fuse, hdr->unique, res ? -errno : 0); | 
|  | 712 | return; | 
|  | 713 | } | 
|  | 714 | //    case FUSE_LINK: | 
|  | 715 | case FUSE_OPEN: { /* open_in -> open_out */ | 
|  | 716 | struct fuse_open_in *req = data; | 
|  | 717 | struct fuse_open_out out; | 
|  | 718 | char *path, buffer[PATH_BUFFER_SIZE]; | 
|  | 719 | struct handle *h; | 
|  | 720 |  | 
|  | 721 | h = malloc(sizeof(*h)); | 
|  | 722 | if (!h) { | 
|  | 723 | fuse_status(fuse, hdr->unique, -ENOMEM); | 
|  | 724 | return; | 
|  | 725 | } | 
|  | 726 |  | 
|  | 727 | path = node_get_path(node, buffer, 0); | 
|  | 728 | TRACE("OPEN %llx '%s' 0%o fh=%p\n", hdr->nodeid, path, req->flags, h); | 
|  | 729 | h->fd = open(path, req->flags); | 
|  | 730 | if (h->fd < 0) { | 
|  | 731 | ERROR("ERROR\n"); | 
|  | 732 | fuse_status(fuse, hdr->unique, errno); | 
|  | 733 | free(h); | 
|  | 734 | return; | 
|  | 735 | } | 
|  | 736 | out.fh = ptr_to_id(h); | 
|  | 737 | out.open_flags = 0; | 
|  | 738 | out.padding = 0; | 
|  | 739 | fuse_reply(fuse, hdr->unique, &out, sizeof(out)); | 
|  | 740 | return; | 
|  | 741 | } | 
|  | 742 | case FUSE_READ: { /* read_in -> byte[] */ | 
|  | 743 | char buffer[128 * 1024]; | 
|  | 744 | struct fuse_read_in *req = data; | 
|  | 745 | struct handle *h = id_to_ptr(req->fh); | 
|  | 746 | int res; | 
|  | 747 | TRACE("READ %p(%d) %u@%llu\n", h, h->fd, req->size, req->offset); | 
|  | 748 | if (req->size > sizeof(buffer)) { | 
|  | 749 | fuse_status(fuse, hdr->unique, -EINVAL); | 
|  | 750 | return; | 
|  | 751 | } | 
| Kenny Root | 9074977 | 2011-01-11 15:38:31 -0800 | [diff] [blame] | 752 | res = pread64(h->fd, buffer, req->size, req->offset); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 753 | if (res < 0) { | 
|  | 754 | fuse_status(fuse, hdr->unique, errno); | 
|  | 755 | return; | 
|  | 756 | } | 
|  | 757 | fuse_reply(fuse, hdr->unique, buffer, res); | 
|  | 758 | return; | 
|  | 759 | } | 
|  | 760 | case FUSE_WRITE: { /* write_in, byte[write_in.size] -> write_out */ | 
|  | 761 | struct fuse_write_in *req = data; | 
|  | 762 | struct fuse_write_out out; | 
|  | 763 | struct handle *h = id_to_ptr(req->fh); | 
|  | 764 | int res; | 
|  | 765 | TRACE("WRITE %p(%d) %u@%llu\n", h, h->fd, req->size, req->offset); | 
| Kenny Root | 9074977 | 2011-01-11 15:38:31 -0800 | [diff] [blame] | 766 | res = pwrite64(h->fd, ((char*) data) + sizeof(*req), req->size, req->offset); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 767 | if (res < 0) { | 
|  | 768 | fuse_status(fuse, hdr->unique, errno); | 
|  | 769 | return; | 
|  | 770 | } | 
|  | 771 | out.size = res; | 
|  | 772 | fuse_reply(fuse, hdr->unique, &out, sizeof(out)); | 
|  | 773 | goto oops; | 
|  | 774 | } | 
| Mike Lockwood | 4553b08 | 2010-08-16 14:14:44 -0400 | [diff] [blame] | 775 | case FUSE_STATFS: { /* getattr_in -> attr_out */ | 
|  | 776 | struct statfs stat; | 
|  | 777 | struct fuse_statfs_out out; | 
|  | 778 | int res; | 
|  | 779 |  | 
|  | 780 | TRACE("STATFS\n"); | 
|  | 781 |  | 
|  | 782 | if (statfs(fuse->root.name, &stat)) { | 
|  | 783 | fuse_status(fuse, hdr->unique, -errno); | 
|  | 784 | return; | 
|  | 785 | } | 
|  | 786 |  | 
|  | 787 | memset(&out, 0, sizeof(out)); | 
|  | 788 | out.st.blocks = stat.f_blocks; | 
|  | 789 | out.st.bfree = stat.f_bfree; | 
|  | 790 | out.st.bavail = stat.f_bavail; | 
|  | 791 | out.st.files = stat.f_files; | 
|  | 792 | out.st.ffree = stat.f_ffree; | 
|  | 793 | out.st.bsize = stat.f_bsize; | 
|  | 794 | out.st.namelen = stat.f_namelen; | 
|  | 795 | out.st.frsize = stat.f_frsize; | 
|  | 796 | fuse_reply(fuse, hdr->unique, &out, sizeof(out)); | 
|  | 797 | return; | 
|  | 798 | } | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 799 | case FUSE_RELEASE: { /* release_in -> */ | 
|  | 800 | struct fuse_release_in *req = data; | 
|  | 801 | struct handle *h = id_to_ptr(req->fh); | 
|  | 802 | TRACE("RELEASE %p(%d)\n", h, h->fd); | 
|  | 803 | close(h->fd); | 
|  | 804 | free(h); | 
|  | 805 | fuse_status(fuse, hdr->unique, 0); | 
|  | 806 | return; | 
|  | 807 | } | 
|  | 808 | //    case FUSE_FSYNC: | 
|  | 809 | //    case FUSE_SETXATTR: | 
|  | 810 | //    case FUSE_GETXATTR: | 
|  | 811 | //    case FUSE_LISTXATTR: | 
|  | 812 | //    case FUSE_REMOVEXATTR: | 
|  | 813 | case FUSE_FLUSH: | 
|  | 814 | fuse_status(fuse, hdr->unique, 0); | 
|  | 815 | return; | 
|  | 816 | case FUSE_OPENDIR: { /* open_in -> open_out */ | 
|  | 817 | struct fuse_open_in *req = data; | 
|  | 818 | struct fuse_open_out out; | 
|  | 819 | char *path, buffer[PATH_BUFFER_SIZE]; | 
|  | 820 | struct dirhandle *h; | 
|  | 821 |  | 
|  | 822 | h = malloc(sizeof(*h)); | 
|  | 823 | if (!h) { | 
|  | 824 | fuse_status(fuse, hdr->unique, -ENOMEM); | 
|  | 825 | return; | 
|  | 826 | } | 
|  | 827 |  | 
|  | 828 | path = node_get_path(node, buffer, 0); | 
|  | 829 | TRACE("OPENDIR %llx '%s'\n", hdr->nodeid, path); | 
|  | 830 | h->d = opendir(path); | 
|  | 831 | if (h->d == 0) { | 
|  | 832 | ERROR("ERROR\n"); | 
|  | 833 | fuse_status(fuse, hdr->unique, -errno); | 
|  | 834 | free(h); | 
|  | 835 | return; | 
|  | 836 | } | 
|  | 837 | out.fh = ptr_to_id(h); | 
|  | 838 | fuse_reply(fuse, hdr->unique, &out, sizeof(out)); | 
|  | 839 | return; | 
|  | 840 | } | 
|  | 841 | case FUSE_READDIR: { | 
|  | 842 | struct fuse_read_in *req = data; | 
|  | 843 | char buffer[8192]; | 
|  | 844 | struct fuse_dirent *fde = (struct fuse_dirent*) buffer; | 
|  | 845 | struct dirent *de; | 
|  | 846 | struct dirhandle *h = id_to_ptr(req->fh); | 
|  | 847 | TRACE("READDIR %p\n", h); | 
|  | 848 | de = readdir(h->d); | 
|  | 849 | if (!de) { | 
|  | 850 | fuse_status(fuse, hdr->unique, 0); | 
|  | 851 | return; | 
|  | 852 | } | 
|  | 853 | fde->ino = FUSE_UNKNOWN_INO; | 
|  | 854 | fde->off = 0; | 
|  | 855 | fde->type = de->d_type; | 
|  | 856 | fde->namelen = strlen(de->d_name); | 
|  | 857 | memcpy(fde->name, de->d_name, fde->namelen + 1); | 
|  | 858 | fuse_reply(fuse, hdr->unique, fde, | 
|  | 859 | FUSE_DIRENT_ALIGN(sizeof(struct fuse_dirent) + fde->namelen)); | 
|  | 860 | return; | 
|  | 861 | } | 
|  | 862 | case FUSE_RELEASEDIR: { /* release_in -> */ | 
|  | 863 | struct fuse_release_in *req = data; | 
|  | 864 | struct dirhandle *h = id_to_ptr(req->fh); | 
|  | 865 | TRACE("RELEASEDIR %p\n",h); | 
|  | 866 | closedir(h->d); | 
|  | 867 | free(h); | 
|  | 868 | fuse_status(fuse, hdr->unique, 0); | 
|  | 869 | return; | 
|  | 870 | } | 
|  | 871 | //    case FUSE_FSYNCDIR: | 
|  | 872 | case FUSE_INIT: { /* init_in -> init_out */ | 
|  | 873 | struct fuse_init_in *req = data; | 
|  | 874 | struct fuse_init_out out; | 
|  | 875 |  | 
|  | 876 | TRACE("INIT ver=%d.%d maxread=%d flags=%x\n", | 
|  | 877 | req->major, req->minor, req->max_readahead, req->flags); | 
|  | 878 |  | 
|  | 879 | out.major = FUSE_KERNEL_VERSION; | 
|  | 880 | out.minor = FUSE_KERNEL_MINOR_VERSION; | 
|  | 881 | out.max_readahead = req->max_readahead; | 
| Mike Lockwood | fc1a13b | 2010-08-20 10:29:29 -0400 | [diff] [blame] | 882 | out.flags = FUSE_ATOMIC_O_TRUNC; | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 883 | out.max_background = 32; | 
|  | 884 | out.congestion_threshold = 32; | 
|  | 885 | out.max_write = 256 * 1024; | 
|  | 886 |  | 
|  | 887 | fuse_reply(fuse, hdr->unique, &out, sizeof(out)); | 
|  | 888 | return; | 
|  | 889 | } | 
|  | 890 | default: { | 
|  | 891 | struct fuse_out_header h; | 
|  | 892 | ERROR("NOTIMPL op=%d uniq=%llx nid=%llx\n", | 
|  | 893 | hdr->opcode, hdr->unique, hdr->nodeid); | 
|  | 894 |  | 
|  | 895 | oops: | 
|  | 896 | h.len = sizeof(h); | 
|  | 897 | h.error = -ENOSYS; | 
|  | 898 | h.unique = hdr->unique; | 
|  | 899 | write(fuse->fd, &h, sizeof(h)); | 
|  | 900 | break; | 
|  | 901 | } | 
|  | 902 | } | 
|  | 903 | } | 
|  | 904 |  | 
|  | 905 | void handle_fuse_requests(struct fuse *fuse) | 
|  | 906 | { | 
|  | 907 | unsigned char req[256 * 1024 + 128]; | 
|  | 908 | int len; | 
|  | 909 |  | 
|  | 910 | for (;;) { | 
|  | 911 | len = read(fuse->fd, req, 8192); | 
|  | 912 | if (len < 0) { | 
|  | 913 | if (errno == EINTR) | 
|  | 914 | continue; | 
|  | 915 | ERROR("handle_fuse_requests: errno=%d\n", errno); | 
|  | 916 | return; | 
|  | 917 | } | 
|  | 918 | handle_fuse_request(fuse, (void*) req, (void*) (req + sizeof(struct fuse_in_header)), len); | 
|  | 919 | } | 
|  | 920 | } | 
|  | 921 |  | 
| Mike Lockwood | 4f35e62 | 2011-01-12 14:39:44 -0500 | [diff] [blame] | 922 | static int usage() | 
|  | 923 | { | 
| Mike Lockwood | 1bedb73 | 2011-01-13 13:38:42 -0500 | [diff] [blame] | 924 | ERROR("usage: sdcard [-l -f] <path> <uid> <gid>\n\n\t-l force file names to lower case when creating new files\n\t-f fix up file system before starting (repairs bad file name case and group ownership)\n"); | 
| Mike Lockwood | 4f35e62 | 2011-01-12 14:39:44 -0500 | [diff] [blame] | 925 | return -1; | 
|  | 926 | } | 
|  | 927 |  | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 928 | int main(int argc, char **argv) | 
|  | 929 | { | 
|  | 930 | struct fuse fuse; | 
|  | 931 | char opts[256]; | 
|  | 932 | int fd; | 
|  | 933 | int res; | 
| Mike Lockwood | 4f35e62 | 2011-01-12 14:39:44 -0500 | [diff] [blame] | 934 | const char *path = NULL; | 
| Mike Lockwood | 4f35e62 | 2011-01-12 14:39:44 -0500 | [diff] [blame] | 935 | int i; | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 936 |  | 
| Mike Lockwood | 4f35e62 | 2011-01-12 14:39:44 -0500 | [diff] [blame] | 937 | for (i = 1; i < argc; i++) { | 
|  | 938 | char* arg = argv[i]; | 
| Mike Lockwood | 575a2bb | 2011-01-23 14:46:30 -0800 | [diff] [blame] | 939 | if (!path) | 
|  | 940 | path = arg; | 
|  | 941 | else if (uid == -1) | 
|  | 942 | uid = strtoul(arg, 0, 10); | 
|  | 943 | else if (gid == -1) | 
|  | 944 | gid = strtoul(arg, 0, 10); | 
|  | 945 | else { | 
|  | 946 | ERROR("too many arguments\n"); | 
|  | 947 | return usage(); | 
| Mike Lockwood | 4f35e62 | 2011-01-12 14:39:44 -0500 | [diff] [blame] | 948 | } | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 949 | } | 
|  | 950 |  | 
| Mike Lockwood | 4f35e62 | 2011-01-12 14:39:44 -0500 | [diff] [blame] | 951 | if (!path) { | 
|  | 952 | ERROR("no path specified\n"); | 
|  | 953 | return usage(); | 
|  | 954 | } | 
|  | 955 | if (uid <= 0 || gid <= 0) { | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 956 | ERROR("uid and gid must be nonzero\n"); | 
| Mike Lockwood | 4f35e62 | 2011-01-12 14:39:44 -0500 | [diff] [blame] | 957 | return usage(); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 958 | } | 
|  | 959 |  | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 960 | /* cleanup from previous instance, if necessary */ | 
| Mike Lockwood | 4553b08 | 2010-08-16 14:14:44 -0400 | [diff] [blame] | 961 | umount2(MOUNT_POINT, 2); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 962 |  | 
|  | 963 | fd = open("/dev/fuse", O_RDWR); | 
|  | 964 | if (fd < 0){ | 
|  | 965 | ERROR("cannot open fuse device (%d)\n", errno); | 
|  | 966 | return -1; | 
|  | 967 | } | 
|  | 968 |  | 
|  | 969 | sprintf(opts, "fd=%i,rootmode=40000,default_permissions,allow_other," | 
|  | 970 | "user_id=%d,group_id=%d", fd, uid, gid); | 
|  | 971 |  | 
| Mike Lockwood | 4553b08 | 2010-08-16 14:14:44 -0400 | [diff] [blame] | 972 | res = mount("/dev/fuse", MOUNT_POINT, "fuse", MS_NOSUID | MS_NODEV, opts); | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 973 | if (res < 0) { | 
|  | 974 | ERROR("cannot mount fuse filesystem (%d)\n", errno); | 
|  | 975 | return -1; | 
|  | 976 | } | 
|  | 977 |  | 
|  | 978 | if (setgid(gid) < 0) { | 
|  | 979 | ERROR("cannot setgid!\n"); | 
|  | 980 | return -1; | 
|  | 981 | } | 
|  | 982 | if (setuid(uid) < 0) { | 
|  | 983 | ERROR("cannot setuid!\n"); | 
|  | 984 | return -1; | 
|  | 985 | } | 
|  | 986 |  | 
| Brian Swetland | 03ee947 | 2010-08-12 18:01:08 -0700 | [diff] [blame] | 987 | fuse_init(&fuse, fd, path); | 
|  | 988 |  | 
|  | 989 | umask(0); | 
|  | 990 | handle_fuse_requests(&fuse); | 
|  | 991 |  | 
|  | 992 | return 0; | 
|  | 993 | } |