| 1 | /* | 
|---|
| 2 | * linux/fs/seq_file.c | 
|---|
| 3 | * | 
|---|
| 4 | * helper functions for making synthetic files from sequences of records. | 
|---|
| 5 | * initial implementation -- AV, Oct 2001. | 
|---|
| 6 | */ | 
|---|
| 7 |  | 
|---|
| 8 | #include <linux/fs.h> | 
|---|
| 9 | #include <linux/export.h> | 
|---|
| 10 | #include <linux/seq_file.h> | 
|---|
| 11 | #include <linux/vmalloc.h> | 
|---|
| 12 | #include <linux/slab.h> | 
|---|
| 13 | #include <linux/mm.h> | 
|---|
| 14 | #include <linux/printk.h> | 
|---|
| 15 | #include <linux/mutex.h> | 
|---|
| 16 | #include <linux/gfp.h> | 
|---|
| 17 | #include <linux/err.h> | 
|---|
| 18 | #include <linux/kernel.h> | 
|---|
| 19 |  | 
|---|
| 20 | #include <asm/uaccess.h> | 
|---|
| 21 | #include <asm/page.h> | 
|---|
| 22 |  | 
|---|
| 23 | #define SEEK_SET        0       /* seek relative to beginning of file */ | 
|---|
| 24 | #define SEEK_CUR        1       /* seek relative to current file position */ | 
|---|
| 25 | #define SEEK_END        2       /* seek relative to end of file */ | 
|---|
| 26 | #define SEEK_DATA       3       /* seek to the next data */ | 
|---|
| 27 | #define SEEK_HOLE       4       /* seek to the next hole */ | 
|---|
| 28 | #define SEEK_MAX        SEEK_HOLE | 
|---|
| 29 |  | 
|---|
| 30 | static void *seq_buf_alloc(unsigned long size) | 
|---|
| 31 | { | 
|---|
| 32 | void *buf; | 
|---|
| 33 | gfp_t gfp = GFP_KERNEL; | 
|---|
| 34 |  | 
|---|
| 35 | /* | 
|---|
| 36 | * For high order allocations, use __GFP_NORETRY to avoid oom-killing - | 
|---|
| 37 | * it's better to fall back to vmalloc() than to kill things.  For small | 
|---|
| 38 | * allocations, just use GFP_KERNEL which will oom kill, thus no need | 
|---|
| 39 | * for vmalloc fallback. | 
|---|
| 40 | */ | 
|---|
| 41 | if (size > PAGE_SIZE) | 
|---|
| 42 | gfp |= __GFP_NORETRY | __GFP_NOWARN; | 
|---|
| 43 | buf = kmalloc(size, gfp); | 
|---|
| 44 | if (!buf && size > PAGE_SIZE) | 
|---|
| 45 | buf = vmalloc(size); | 
|---|
| 46 | return buf; | 
|---|
| 47 | } | 
|---|
| 48 |  | 
|---|
| 49 | /** | 
|---|
| 50 | *      seq_open -      initialize sequential file | 
|---|
| 51 | *      @file: file we initialize | 
|---|
| 52 | *      @op: method table describing the sequence | 
|---|
| 53 | * | 
|---|
| 54 | *      seq_open() sets @file, associating it with a sequence described | 
|---|
| 55 | *      by @op.  @op->start() sets the iterator up and returns the first | 
|---|
| 56 | *      element of sequence. @op->stop() shuts it down.  @op->next() | 
|---|
| 57 | *      returns the next element of sequence.  @op->show() prints element | 
|---|
| 58 | *      into the buffer.  In case of error ->start() and ->next() return | 
|---|
| 59 | *      ERR_PTR(error).  In the end of sequence they return %NULL. ->show() | 
|---|
| 60 | *      returns 0 in case of success and negative number in case of error. | 
|---|
| 61 | *      Returning SEQ_SKIP means "discard this element and move on". | 
|---|
| 62 | *      Note: seq_open() will allocate a struct seq_file and store its | 
|---|
| 63 | *      pointer in @file->private_data. This pointer should not be modified. | 
|---|
| 64 | */ | 
|---|
| 65 | int seq_open(struct file *file, const struct seq_operations *op) | 
|---|
| 66 | { | 
|---|
| 67 | struct seq_file *p; | 
|---|
| 68 |  | 
|---|
| 69 | WARN_ON(file->private_data); | 
|---|
| 70 |  | 
|---|
| 71 | p = kzalloc(sizeof(*p), GFP_KERNEL); | 
|---|
| 72 | if (!p) | 
|---|
| 73 | return -ENOMEM; | 
|---|
| 74 |  | 
|---|
| 75 | file->private_data = p; | 
|---|
| 76 |  | 
|---|
| 77 | mutex_init(&p->lock); | 
|---|
| 78 | p->op = op; | 
|---|
| 79 |  | 
|---|
| 80 | // No refcounting: the lifetime of 'p' is constrained | 
|---|
| 81 | // to the lifetime of the file. | 
|---|
| 82 | p->file = file; | 
|---|
| 83 |  | 
|---|
| 84 | /* | 
|---|
| 85 | * Wrappers around seq_open(e.g. swaps_open) need to be | 
|---|
| 86 | * aware of this. If they set f_version themselves, they | 
|---|
| 87 | * should call seq_open first and then set f_version. | 
|---|
| 88 | */ | 
|---|
| 89 | file->f_version = 0; | 
|---|
| 90 |  | 
|---|
| 91 | /* | 
|---|
| 92 | * seq_files support lseek() and pread().  They do not implement | 
|---|
| 93 | * write() at all, but we clear FMODE_PWRITE here for historical | 
|---|
| 94 | * reasons. | 
|---|
| 95 | * | 
|---|
| 96 | * If a client of seq_files a) implements file.write() and b) wishes to | 
|---|
| 97 | * support pwrite() then that client will need to implement its own | 
|---|
| 98 | * file.open() which calls seq_open() and then sets FMODE_PWRITE. | 
|---|
| 99 | */ | 
|---|
| 100 | file->f_mode &= ~FMODE_PWRITE; | 
|---|
| 101 | return 0; | 
|---|
| 102 | } | 
|---|
| 103 |  | 
|---|
| 104 | static int traverse(struct seq_file *m, loff_t offset) | 
|---|
| 105 | { | 
|---|
| 106 | loff_t pos = 0, index; | 
|---|
| 107 | int error = 0; | 
|---|
| 108 | void *p; | 
|---|
| 109 |  | 
|---|
| 110 | m->version = 0; | 
|---|
| 111 | index = 0; | 
|---|
| 112 | m->count = m->from = 0; | 
|---|
| 113 | if (!offset) { | 
|---|
| 114 | m->index = index; | 
|---|
| 115 | return 0; | 
|---|
| 116 | } | 
|---|
| 117 | if (!m->buf) { | 
|---|
| 118 | m->buf = seq_buf_alloc(m->size = PAGE_SIZE); | 
|---|
| 119 | if (!m->buf) | 
|---|
| 120 | return -ENOMEM; | 
|---|
| 121 | } | 
|---|
| 122 | p = m->op->start(m, &index); | 
|---|
| 123 | while (p) { | 
|---|
| 124 | error = PTR_ERR(p); | 
|---|
| 125 | if (IS_ERR(p)) | 
|---|
| 126 | break; | 
|---|
| 127 | error = m->op->show(m, p); | 
|---|
| 128 | if (error < 0) | 
|---|
| 129 | break; | 
|---|
| 130 | if (error) { | 
|---|
| 131 | error = 0; | 
|---|
| 132 | m->count = 0; | 
|---|
| 133 | } | 
|---|
| 134 | if (seq_has_overflowed(m)) | 
|---|
| 135 | goto Eoverflow; | 
|---|
| 136 | if (pos + m->count > offset) { | 
|---|
| 137 | m->from = offset - pos; | 
|---|
| 138 | m->count -= m->from; | 
|---|
| 139 | m->index = index; | 
|---|
| 140 | break; | 
|---|
| 141 | } | 
|---|
| 142 | pos += m->count; | 
|---|
| 143 | m->count = 0; | 
|---|
| 144 | if (pos == offset) { | 
|---|
| 145 | index++; | 
|---|
| 146 | m->index = index; | 
|---|
| 147 | break; | 
|---|
| 148 | } | 
|---|
| 149 | p = m->op->next(m, p, &index); | 
|---|
| 150 | } | 
|---|
| 151 | m->op->stop(m, p); | 
|---|
| 152 | m->index = index; | 
|---|
| 153 | return error; | 
|---|
| 154 |  | 
|---|
| 155 | Eoverflow: | 
|---|
| 156 | m->op->stop(m, p); | 
|---|
| 157 | kvfree(m->buf); | 
|---|
| 158 | m->count = 0; | 
|---|
| 159 | m->buf = seq_buf_alloc(m->size <<= 1); | 
|---|
| 160 | return !m->buf ? -ENOMEM : -EAGAIN; | 
|---|
| 161 | } | 
|---|
| 162 |  | 
|---|
| 163 | /** | 
|---|
| 164 | *      seq_read -      ->read() method for sequential files. | 
|---|
| 165 | *      @file: the file to read from | 
|---|
| 166 | *      @buf: the buffer to read to | 
|---|
| 167 | *      @size: the maximum number of bytes to read | 
|---|
| 168 | *      @ppos: the current position in the file | 
|---|
| 169 | * | 
|---|
| 170 | *      Ready-made ->f_op->read() | 
|---|
| 171 | */ | 
|---|
| 172 | ssize_t seq_read(struct file *file, char __user *buf, size_t size, loff_t *ppos) | 
|---|
| 173 | { | 
|---|
| 174 | struct seq_file *m = file->private_data; | 
|---|
| 175 | size_t copied = 0; | 
|---|
| 176 | loff_t pos; | 
|---|
| 177 | size_t n; | 
|---|
| 178 | void *p; | 
|---|
| 179 | int err = 0; | 
|---|
| 180 |  | 
|---|
| 181 | mutex_lock(&m->lock); | 
|---|
| 182 |  | 
|---|
| 183 | /* | 
|---|
| 184 | * seq_file->op->..m_start/m_stop/m_next may do special actions | 
|---|
| 185 | * or optimisations based on the file->f_version, so we want to | 
|---|
| 186 | * pass the file->f_version to those methods. | 
|---|
| 187 | * | 
|---|
| 188 | * seq_file->version is just copy of f_version, and seq_file | 
|---|
| 189 | * methods can treat it simply as file version. | 
|---|
| 190 | * It is copied in first and copied out after all operations. | 
|---|
| 191 | * It is convenient to have it as  part of structure to avoid the | 
|---|
| 192 | * need of passing another argument to all the seq_file methods. | 
|---|
| 193 | */ | 
|---|
| 194 | m->version = file->f_version; | 
|---|
| 195 |  | 
|---|
| 196 | /* Don't assume *ppos is where we left it */ | 
|---|
| 197 | if (*ppos != m->read_pos) { | 
|---|
| 198 | while ((err = traverse(m, *ppos)) == -EAGAIN) | 
|---|
| 199 | ; | 
|---|
| 200 | if (err) { | 
|---|
| 201 | /* With prejudice... */ | 
|---|
| 202 | m->read_pos = 0; | 
|---|
| 203 | m->version = 0; | 
|---|
| 204 | m->index = 0; | 
|---|
| 205 | m->count = 0; | 
|---|
| 206 | goto Done; | 
|---|
| 207 | } else { | 
|---|
| 208 | m->read_pos = *ppos; | 
|---|
| 209 | } | 
|---|
| 210 | } | 
|---|
| 211 |  | 
|---|
| 212 | /* grab buffer if we didn't have one */ | 
|---|
| 213 | if (!m->buf) { | 
|---|
| 214 | m->buf = seq_buf_alloc(m->size = PAGE_SIZE); | 
|---|
| 215 | if (!m->buf) | 
|---|
| 216 | goto Enomem; | 
|---|
| 217 | } | 
|---|
| 218 | /* if not empty - flush it first */ | 
|---|
| 219 | if (m->count) { | 
|---|
| 220 | n = min(m->count, size); | 
|---|
| 221 | err = copy_to_user(buf, m->buf + m->from, n); | 
|---|
| 222 | if (err) | 
|---|
| 223 | goto Efault; | 
|---|
| 224 | m->count -= n; | 
|---|
| 225 | m->from += n; | 
|---|
| 226 | size -= n; | 
|---|
| 227 | buf += n; | 
|---|
| 228 | copied += n; | 
|---|
| 229 | if (!m->count) { | 
|---|
| 230 | m->from = 0; | 
|---|
| 231 | m->index++; | 
|---|
| 232 | } | 
|---|
| 233 | if (!size) | 
|---|
| 234 | goto Done; | 
|---|
| 235 | } | 
|---|
| 236 | /* we need at least one record in buffer */ | 
|---|
| 237 | pos = m->index; | 
|---|
| 238 | p = m->op->start(m, &pos); | 
|---|
| 239 | while (1) { | 
|---|
| 240 | err = PTR_ERR(p); | 
|---|
| 241 | if (!p || IS_ERR(p)) | 
|---|
| 242 | break; | 
|---|
| 243 | err = m->op->show(m, p); | 
|---|
| 244 | if (err < 0) | 
|---|
| 245 | break; | 
|---|
| 246 | if (err) | 
|---|
| 247 | m->count = 0; | 
|---|
| 248 | if (!m->count) { | 
|---|
| 249 | p = m->op->next(m, p, &pos); | 
|---|
| 250 | m->index = pos; | 
|---|
| 251 | continue; | 
|---|
| 252 | } | 
|---|
| 253 | if (m->count < m->size) | 
|---|
| 254 | goto Fill; | 
|---|
| 255 | m->op->stop(m, p); | 
|---|
| 256 | kvfree(m->buf); | 
|---|
| 257 | m->count = 0; | 
|---|
| 258 | m->buf = seq_buf_alloc(m->size <<= 1); | 
|---|
| 259 | if (!m->buf) | 
|---|
| 260 | goto Enomem; | 
|---|
| 261 | m->version = 0; | 
|---|
| 262 | pos = m->index; | 
|---|
| 263 | p = m->op->start(m, &pos); | 
|---|
| 264 | } | 
|---|
| 265 | m->op->stop(m, p); | 
|---|
| 266 | m->count = 0; | 
|---|
| 267 | goto Done; | 
|---|
| 268 | Fill: | 
|---|
| 269 | /* they want more? let's try to get some more */ | 
|---|
| 270 | while (m->count < size) { | 
|---|
| 271 | size_t offs = m->count; | 
|---|
| 272 | loff_t next = pos; | 
|---|
| 273 | p = m->op->next(m, p, &next); | 
|---|
| 274 | if (!p || IS_ERR(p)) { | 
|---|
| 275 | err = PTR_ERR(p); | 
|---|
| 276 | break; | 
|---|
| 277 | } | 
|---|
| 278 | err = m->op->show(m, p); | 
|---|
| 279 | if (seq_has_overflowed(m) || err) { | 
|---|
| 280 | m->count = offs; | 
|---|
| 281 | if (err <= 0) | 
|---|
| 282 | break; | 
|---|
| 283 | } | 
|---|
| 284 | pos = next; | 
|---|
| 285 | } | 
|---|
| 286 | m->op->stop(m, p); | 
|---|
| 287 | n = min(m->count, size); | 
|---|
| 288 | err = copy_to_user(buf, m->buf, n); | 
|---|
| 289 | if (err) | 
|---|
| 290 | goto Efault; | 
|---|
| 291 | copied += n; | 
|---|
| 292 | m->count -= n; | 
|---|
| 293 | if (m->count) | 
|---|
| 294 | m->from = n; | 
|---|
| 295 | else | 
|---|
| 296 | pos++; | 
|---|
| 297 | m->index = pos; | 
|---|
| 298 | Done: | 
|---|
| 299 | if (!copied) | 
|---|
| 300 | copied = err; | 
|---|
| 301 | else { | 
|---|
| 302 | *ppos += copied; | 
|---|
| 303 | m->read_pos += copied; | 
|---|
| 304 | } | 
|---|
| 305 | file->f_version = m->version; | 
|---|
| 306 | mutex_unlock(&m->lock); | 
|---|
| 307 | return copied; | 
|---|
| 308 | Enomem: | 
|---|
| 309 | err = -ENOMEM; | 
|---|
| 310 | goto Done; | 
|---|
| 311 | Efault: | 
|---|
| 312 | err = -EFAULT; | 
|---|
| 313 | goto Done; | 
|---|
| 314 | } | 
|---|
| 315 |  | 
|---|
| 316 | /** | 
|---|
| 317 | *      seq_lseek -     ->llseek() method for sequential files. | 
|---|
| 318 | *      @file: the file in question | 
|---|
| 319 | *      @offset: new position | 
|---|
| 320 | *      @whence: 0 for absolute, 1 for relative position | 
|---|
| 321 | * | 
|---|
| 322 | *      Ready-made ->f_op->llseek() | 
|---|
| 323 | */ | 
|---|
| 324 | loff_t seq_lseek(struct file *file, loff_t offset, int whence) | 
|---|
| 325 | { | 
|---|
| 326 | struct seq_file *m = file->private_data; | 
|---|
| 327 | loff_t retval = -EINVAL; | 
|---|
| 328 |  | 
|---|
| 329 | mutex_lock(&m->lock); | 
|---|
| 330 | m->version = file->f_version; | 
|---|
| 331 | switch (whence) { | 
|---|
| 332 | case SEEK_CUR: | 
|---|
| 333 | offset += file->f_pos; | 
|---|
| 334 | case SEEK_SET: | 
|---|
| 335 | if (offset < 0) | 
|---|
| 336 | break; | 
|---|
| 337 | retval = offset; | 
|---|
| 338 | if (offset != m->read_pos) { | 
|---|
| 339 | while ((retval = traverse(m, offset)) == -EAGAIN) | 
|---|
| 340 | ; | 
|---|
| 341 | if (retval) { | 
|---|
| 342 | /* with extreme prejudice... */ | 
|---|
| 343 | file->f_pos = 0; | 
|---|
| 344 | m->read_pos = 0; | 
|---|
| 345 | m->version = 0; | 
|---|
| 346 | m->index = 0; | 
|---|
| 347 | m->count = 0; | 
|---|
| 348 | } else { | 
|---|
| 349 | m->read_pos = offset; | 
|---|
| 350 | retval = file->f_pos = offset; | 
|---|
| 351 | } | 
|---|
| 352 | } else { | 
|---|
| 353 | file->f_pos = offset; | 
|---|
| 354 | } | 
|---|
| 355 | } | 
|---|
| 356 | file->f_version = m->version; | 
|---|
| 357 | mutex_unlock(&m->lock); | 
|---|
| 358 | return retval; | 
|---|
| 359 | } | 
|---|
| 360 |  | 
|---|
| 361 | /** | 
|---|
| 362 | *      seq_release -   free the structures associated with sequential file. | 
|---|
| 363 | *      @file: file in question | 
|---|
| 364 | *      @inode: its inode | 
|---|
| 365 | * | 
|---|
| 366 | *      Frees the structures associated with sequential file; can be used | 
|---|
| 367 | *      as ->f_op->release() if you don't have private data to destroy. | 
|---|
| 368 | */ | 
|---|
| 369 | int seq_release(struct inode *inode, struct file *file) | 
|---|
| 370 | { | 
|---|
| 371 | struct seq_file *m = file->private_data; | 
|---|
| 372 | kvfree(m->buf); | 
|---|
| 373 | kfree(m); | 
|---|
| 374 | return 0; | 
|---|
| 375 | } | 
|---|
| 376 |  | 
|---|
| 377 | static void *single_start(struct seq_file *p, loff_t *pos) | 
|---|
| 378 | { | 
|---|
| 379 | return NULL + (*pos == 0); | 
|---|
| 380 | } | 
|---|
| 381 |  | 
|---|
| 382 | static void *single_next(struct seq_file *p, void *v, loff_t *pos) | 
|---|
| 383 | { | 
|---|
| 384 | ++*pos; | 
|---|
| 385 | return NULL; | 
|---|
| 386 | } | 
|---|
| 387 |  | 
|---|
| 388 | static void single_stop(struct seq_file *p, void *v) | 
|---|
| 389 | { | 
|---|
| 390 | } | 
|---|
| 391 |  | 
|---|
| 392 | int single_open(struct file *file, int (*show)(struct seq_file *, void *), | 
|---|
| 393 | void *data) | 
|---|
| 394 | { | 
|---|
| 395 | struct seq_operations *op = kmalloc(sizeof(*op), GFP_KERNEL); | 
|---|
| 396 | int res = -ENOMEM; | 
|---|
| 397 |  | 
|---|
| 398 | if (op) { | 
|---|
| 399 | op->start = single_start; | 
|---|
| 400 | op->next = single_next; | 
|---|
| 401 | op->stop = single_stop; | 
|---|
| 402 | op->show = show; | 
|---|
| 403 | res = seq_open(file, op); | 
|---|
| 404 | if (!res) | 
|---|
| 405 | ((struct seq_file *)file->private_data)->private = data; | 
|---|
| 406 | else | 
|---|
| 407 | kfree(op); | 
|---|
| 408 | } | 
|---|
| 409 | return res; | 
|---|
| 410 | } | 
|---|
| 411 |  | 
|---|
| 412 | int single_open_size(struct file *file, int (*show)(struct seq_file *, void *), | 
|---|
| 413 | void *data, size_t size) | 
|---|
| 414 | { | 
|---|
| 415 | char *buf = seq_buf_alloc(size); | 
|---|
| 416 | int ret; | 
|---|
| 417 | if (!buf) | 
|---|
| 418 | return -ENOMEM; | 
|---|
| 419 | ret = single_open(file, show, data); | 
|---|
| 420 | if (ret) { | 
|---|
| 421 | kvfree(buf); | 
|---|
| 422 | return ret; | 
|---|
| 423 | } | 
|---|
| 424 | ((struct seq_file *)file->private_data)->buf = buf; | 
|---|
| 425 | ((struct seq_file *)file->private_data)->size = size; | 
|---|
| 426 | return 0; | 
|---|
| 427 | } | 
|---|
| 428 |  | 
|---|
| 429 | int single_release(struct inode *inode, struct file *file) | 
|---|
| 430 | { | 
|---|
| 431 | const struct seq_operations *op = ((struct seq_file *)file->private_data)->op; | 
|---|
| 432 | int res = seq_release(inode, file); | 
|---|
| 433 | kfree(op); | 
|---|
| 434 | return res; | 
|---|
| 435 | } | 
|---|