lib/vfs/direntry.c

   1 /*
   2    Directory cache support
   3
   4    Copyright (C) 1998, 2011
   5    The Free Software Foundation, Inc.
   6
   7    Written by:
   8    Pavel Machek <pavel@ucw.cz>, 1998
   9
  10    This file is part of the Midnight Commander.
  11
  12    The Midnight Commander is free software: you can redistribute it
  13    and/or modify it under the terms of the GNU General Public License as
  14    published by the Free Software Foundation, either version 3 of the License,
  15    or (at your option) any later version.
  16
  17    The Midnight Commander is distributed in the hope that it will be useful,
  18    but WITHOUT ANY WARRANTY; without even the implied warranty of
  19    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  20    GNU General Public License for more details.
  21
  22    You should have received a copy of the GNU General Public License
  23    along with this program.  If not, see <http://www.gnu.org/licenses/>.
  24
  25    \warning Paths here do _not_ begin with '/', so root directory of
  26    archive/site is simply "".
  27  */
  28
  29 /** \file
  30  *  \brief Source: directory cache support
  31  *
  32  *  So that you do not have copy of this in each and every filesystem.
  33  *
  34  *  Very loosely based on tar.c from midnight and archives.[ch] from
  35  *  avfs by Miklos Szeredi (mszeredi@inf.bme.hu)
  36  *
  37  *  Unfortunately, I was unable to keep all filesystems
  38  *  uniform. tar-like filesystems use tree structure where each
  39  *  directory has pointers to its subdirectories. We can do this
  40  *  because we have full information about our archive.
  41  *
  42  *  At ftp-like filesystems, situation is a little bit different. When
  43  *  you cd /usr/src/linux/drivers/char, you do _not_ want /usr,
  44  *  /usr/src, /usr/src/linux and /usr/src/linux/drivers to be
  45  *  listed. That means that we do not have complete information, and if
  46  *  /usr is symlink to /4, we will not know. Also we have to time out
  47  *  entries and things would get messy with tree-like approach. So we
  48  *  do different trick: root directory is completely special and
  49  *  completely fake, it contains entries such as 'usr', 'usr/src', ...,
  50  *  and we'll try to use custom find_entry function.
  51  *
  52  *  \author Pavel Machek <pavel@ucw.cz>
  53  *  \date 1998
  54  *
  55  */
  56
  57 #include <config.h>
  58
  59 #include <errno.h>
  60 #include <fcntl.h>              /* include fcntl.h -> sys/fcntl.h only       */
  61                                 /* includes fcntl.h see IEEE Std 1003.1-2008 */
  62 #include <time.h>
  63 #include <sys/time.h>           /* gettimeofday() */
  64 #include <inttypes.h>           /* uintmax_t */
  65 #include <stdarg.h>
  66
  67 #include "lib/global.h"
  68
  69 #include "lib/tty/tty.h"        /* enable/disable interrupt key */
  70 #include "lib/util.h"           /* custom_canonicalize_pathname() */
  71 #if 0
  72 #include "lib/widget.h"         /* message() */
  73 #endif
  74
  75 #include "vfs.h"
  76 #include "utilvfs.h"
  77 #include "xdirentry.h"
  78 #include "gc.h"                 /* vfs_rmstamp */
  79
  80 /*** global variables ****************************************************************************/
  81
  82 /*** file scope macro definitions ****************************************************************/
  83
  84 #define CALL(x) if (MEDATA->x) MEDATA->x
  85
  86 /*** file scope type declarations ****************************************************************/
  87
  88 struct dirhandle
  89 {
  90     GList *cur;
  91     struct vfs_s_inode *dir;
  92 };
  93
  94 /*** file scope variables ************************************************************************/
  95
  96 static volatile int total_inodes = 0, total_entries = 0;
  97
  98 /*** file scope functions ************************************************************************/
  99 /* --------------------------------------------------------------------------------------------- */
 100
 101 static int
 102 vfs_s_entry_compare (const void *a, const void *b)
 103 {
 104     const struct vfs_s_entry *e = (const struct vfs_s_entry *) a;
 105     const char *name = (const char *) b;
 106
 107     return strcmp (e->name, name);
 108 }
 109
 110 /* --------------------------------------------------------------------------------------------- */
 111
 112 /* We were asked to create entries automagically */
 113
 114 static struct vfs_s_entry *
 115 vfs_s_automake (struct vfs_class *me, struct vfs_s_inode *dir, char *path, int flags)
 116 {
 117     struct vfs_s_entry *res;
 118     char *sep;
 119
 120     sep = strchr (path, PATH_SEP);
 121     if (sep != NULL)
 122         *sep = '\0';
 123
 124     res = vfs_s_generate_entry (me, path, dir, flags & FL_MKDIR ? (0777 | S_IFDIR) : 0777);
 125     vfs_s_insert_entry (me, dir, res);
 126
 127     if (sep != NULL)
 128         *sep = PATH_SEP;
 129
 130     return res;
 131 }
 132
 133 /* --------------------------------------------------------------------------------------------- */
 134 /* If the entry is a symlink, find the entry for its target */
 135
 136 static struct vfs_s_entry *
 137 vfs_s_resolve_symlink (struct vfs_class *me, struct vfs_s_entry *entry, int follow)
 138 {
 139     char *linkname;
 140     char *fullname = NULL;
 141     struct vfs_s_entry *target;
 142
 143     if (follow == LINK_NO_FOLLOW)
 144         return entry;
 145     if (follow == 0)
 146         ERRNOR (ELOOP, NULL);
 147     if (!entry)
 148         ERRNOR (ENOENT, NULL);
 149     if (!S_ISLNK (entry->ino->st.st_mode))
 150         return entry;
 151
 152     linkname = entry->ino->linkname;
 153     if (linkname == NULL)
 154         ERRNOR (EFAULT, NULL);
 155
 156     /* make full path from relative */
 157     if (*linkname != PATH_SEP)
 158     {
 159         char *fullpath = vfs_s_fullpath (me, entry->dir);
 160         if (fullpath)
 161         {
 162             fullname = g_strconcat (fullpath, "/", linkname, (char *) NULL);
 163             linkname = fullname;
 164             g_free (fullpath);
 165         }
 166     }
 167
 168     target = (MEDATA->find_entry) (me, entry->dir->super->root, linkname, follow - 1, 0);
 169     g_free (fullname);
 170     return target;
 171 }
 172
 173 /* --------------------------------------------------------------------------------------------- */
 174 /*
 175  * Follow > 0: follow links, serves as loop protect,
 176  *       == -1: do not follow links
 177  */
 178
 179 static struct vfs_s_entry *
 180 vfs_s_find_entry_tree (struct vfs_class *me, struct vfs_s_inode *root,
 181                        const char *a_path, int follow, int flags)
 182 {
 183     size_t pseg;
 184     struct vfs_s_entry *ent = NULL;
 185     char *const pathref = g_strdup (a_path);
 186     char *path = pathref;
 187
 188     /* canonicalize as well, but don't remove '../' from path */
 189     custom_canonicalize_pathname (path, CANON_PATH_ALL & (~CANON_PATH_REMDOUBLEDOTS));
 190
 191     while (root != NULL)
 192     {
 193         GList *iter;
 194
 195         while (*path == PATH_SEP)       /* Strip leading '/' */
 196             path++;
 197
 198         if (path[0] == '\0')
 199         {
 200             g_free (pathref);
 201             return ent;
 202         }
 203
 204         for (pseg = 0; path[pseg] != '\0' && path[pseg] != PATH_SEP; pseg++)
 205             ;
 206
 207         for (iter = root->subdir; iter != NULL; iter = g_list_next (iter))
 208         {
 209             ent = (struct vfs_s_entry *) iter->data;
 210             if (strlen (ent->name) == pseg && strncmp (ent->name, path, pseg) == 0)
 211                 /* FOUND! */
 212                 break;
 213         }
 214
 215         ent = iter != NULL ? (struct vfs_s_entry *) iter->data : NULL;
 216
 217         if (ent == NULL && (flags & (FL_MKFILE | FL_MKDIR)) != 0)
 218             ent = vfs_s_automake (me, root, path, flags);
 219         if (ent == NULL)
 220         {
 221             me->verrno = ENOENT;
 222             goto cleanup;
 223         }
 224
 225         path += pseg;
 226         /* here we must follow leading directories always;
 227            only the actual file is optional */
 228         ent = vfs_s_resolve_symlink (me, ent,
 229                                      strchr (path, PATH_SEP) != NULL ? LINK_FOLLOW : follow);
 230         if (ent == NULL)
 231             goto cleanup;
 232         root = ent->ino;
 233     }
 234   cleanup:
 235     g_free (pathref);
 236     return NULL;
 237 }
 238
 239 /* --------------------------------------------------------------------------------------------- */
 240
 241 static struct vfs_s_entry *
 242 vfs_s_find_entry_linear (struct vfs_class *me, struct vfs_s_inode *root,
 243                          const char *a_path, int follow, int flags)
 244 {
 245     struct vfs_s_entry *ent = NULL;
 246     char *const path = g_strdup (a_path);
 247     struct vfs_s_entry *retval = NULL;
 248     GList *iter;
 249
 250     if (root->super->root != root)
 251         vfs_die ("We have to use _real_ root. Always. Sorry.");
 252
 253     /* canonicalize as well, but don't remove '../' from path */
 254     custom_canonicalize_pathname (path, CANON_PATH_ALL & (~CANON_PATH_REMDOUBLEDOTS));
 255
 256     if ((flags & FL_DIR) == 0)
 257     {
 258         char *dirname, *name;
 259         struct vfs_s_inode *ino;
 260
 261         dirname = g_path_get_dirname (path);
 262         name = g_path_get_basename (path);
 263         ino = vfs_s_find_inode (me, root->super, dirname, follow, flags | FL_DIR);
 264         retval = vfs_s_find_entry_tree (me, ino, name, follow, flags);
 265         g_free (dirname);
 266         g_free (name);
 267         g_free (path);
 268         return retval;
 269     }
 270
 271     iter = g_list_find_custom (root->subdir, path, (GCompareFunc) vfs_s_entry_compare);
 272     ent = iter != NULL ? (struct vfs_s_entry *) iter->data : NULL;
 273
 274     if (ent != NULL && !MEDATA->dir_uptodate (me, ent->ino))
 275     {
 276 #if 1
 277         vfs_print_message (_("Directory cache expired for %s"), path);
 278 #endif
 279         vfs_s_free_entry (me, ent);
 280         ent = NULL;
 281     }
 282
 283     if (ent == NULL)
 284     {
 285         struct vfs_s_inode *ino;
 286
 287         ino = vfs_s_new_inode (me, root->super, vfs_s_default_stat (me, S_IFDIR | 0755));
 288         ent = vfs_s_new_entry (me, path, ino);
 289         if (MEDATA->dir_load (me, ino, path) == -1)
 290         {
 291             vfs_s_free_entry (me, ent);
 292             g_free (path);
 293             return NULL;
 294         }
 295
 296         vfs_s_insert_entry (me, root, ent);
 297
 298         iter = g_list_find_custom (root->subdir, path, (GCompareFunc) vfs_s_entry_compare);
 299         ent = iter != NULL ? (struct vfs_s_entry *) iter->data : NULL;
 300     }
 301     if (ent == NULL)
 302         vfs_die ("find_linear: success but directory is not there\n");
 303
 304 #if 0
 305     if (!vfs_s_resolve_symlink (me, ent, follow))
 306     {
 307         g_free (path);
 308         return NULL;
 309     }
 310 #endif
 311     g_free (path);
 312     return ent;
 313 }
 314
 315 /* --------------------------------------------------------------------------------------------- */
 316 /* Ook, these were functions around directory entries / inodes */
 317 /* -------------------------------- superblock games -------------------------- */
 318
 319 static struct vfs_s_super *
 320 vfs_s_new_super (struct vfs_class *me)
 321 {
 322     struct vfs_s_super *super;
 323
 324     super = g_new0 (struct vfs_s_super, 1);
 325     super->me = me;
 326     return super;
 327 }
 328
 329 /* --------------------------------------------------------------------------------------------- */
 330
 331 static inline void
 332 vfs_s_insert_super (struct vfs_class *me, struct vfs_s_super *super)
 333 {
 334     MEDATA->supers = g_list_prepend (MEDATA->supers, super);
 335 }
 336
 337 /* --------------------------------------------------------------------------------------------- */
 338
 339 static void
 340 vfs_s_free_super (struct vfs_class *me, struct vfs_s_super *super)
 341 {
 342     if (super->root != NULL)
 343     {
 344         vfs_s_free_inode (me, super->root);
 345         super->root = NULL;
 346     }
 347
 348 #if 0
 349     /* FIXME: We currently leak small ammount of memory, sometimes. Fix it if you can. */
 350     if (super->ino_usage)
 351         message (D_ERROR, "Direntry warning",
 352                  "Super ino_usage is %d, memory leak", super->ino_usage);
 353
 354     if (super->want_stale)
 355         message (D_ERROR, "Direntry warning", "%s", "Super has want_stale set");
 356 #endif
 357
 358     MEDATA->supers = g_list_remove (MEDATA->supers, super);
 359
 360     CALL (free_archive) (me, super);
 361 #ifdef ENABLE_VFS_NET
 362     vfs_path_element_free (super->path_element);
 363 #endif
 364     g_free (super->name);
 365     g_free (super);
 366 }
 367
 368 /* --------------------------------------------------------------------------------------------- */
 369 /* Support of archives */
 370 /* ------------------------ readdir & friends ----------------------------- */
 371
 372 static struct vfs_s_inode *
 373 vfs_s_inode_from_path (const vfs_path_t * vpath, int flags)
 374 {
 375     struct vfs_s_super *super;
 376     struct vfs_s_inode *ino;
 377     const char *q;
 378     const vfs_path_element_t *path_element;
 379
 380     q = vfs_s_get_path (vpath, &super, 0);
 381     if (q == NULL)
 382         return NULL;
 383
 384     path_element = vfs_path_get_by_index (vpath, -1);
 385
 386     ino =
 387         vfs_s_find_inode (path_element->class, super, q,
 388                           flags & FL_FOLLOW ? LINK_FOLLOW : LINK_NO_FOLLOW, flags & ~FL_FOLLOW);
 389     if ((!ino) && (!*q))
 390         /* We are asking about / directory of ftp server: assume it exists */
 391         ino =
 392             vfs_s_find_inode (path_element->class, super, q,
 393                               flags & FL_FOLLOW ? LINK_FOLLOW :
 394                               LINK_NO_FOLLOW, FL_DIR | (flags & ~FL_FOLLOW));
 395     return ino;
 396 }
 397
 398 /* --------------------------------------------------------------------------------------------- */
 399
 400 static void *
 401 vfs_s_opendir (const vfs_path_t * vpath)
 402 {
 403     struct vfs_s_inode *dir;
 404     struct dirhandle *info;
 405     const vfs_path_element_t *path_element;
 406
 407     path_element = vfs_path_get_by_index (vpath, -1);
 408
 409     dir = vfs_s_inode_from_path (vpath, FL_DIR | FL_FOLLOW);
 410     if (dir == NULL)
 411         return NULL;
 412     if (!S_ISDIR (dir->st.st_mode))
 413     {
 414         path_element->class->verrno = ENOTDIR;
 415         return NULL;
 416     }
 417
 418     dir->st.st_nlink++;
 419 #if 0
 420     if (dir->subdir == NULL)    /* This can actually happen if we allow empty directories */
 421     {
 422         path_element->class->verrno = EAGAIN;
 423         return NULL;
 424     }
 425 #endif
 426     info = g_new (struct dirhandle, 1);
 427     info->cur = dir->subdir;
 428     info->dir = dir;
 429
 430     return info;
 431 }
 432
 433 /* --------------------------------------------------------------------------------------------- */
 434
 435 static void *
 436 vfs_s_readdir (void *data)
 437 {
 438     static union vfs_dirent dir;
 439     struct dirhandle *info = (struct dirhandle *) data;
 440     const char *name;
 441
 442     if (info->cur == NULL || info->cur->data == NULL)
 443         return NULL;
 444
 445     name = ((struct vfs_s_entry *) info->cur->data)->name;
 446     if (name != NULL)
 447         g_strlcpy (dir.dent.d_name, name, MC_MAXPATHLEN);
 448     else
 449         vfs_die ("Null in structure-cannot happen");
 450
 451     compute_namelen (&dir.dent);
 452     info->cur = g_list_next (info->cur);
 453
 454     return (void *) &dir;
 455 }
 456
 457 /* --------------------------------------------------------------------------------------------- */
 458
 459 static int
 460 vfs_s_closedir (void *data)
 461 {
 462     struct dirhandle *info = (struct dirhandle *) data;
 463     struct vfs_s_inode *dir = info->dir;
 464
 465     vfs_s_free_inode (dir->super->me, dir);
 466     g_free (data);
 467     return 0;
 468 }
 469
 470 /* --------------------------------------------------------------------------------------------- */
 471
 472 static int
 473 vfs_s_chdir (const vfs_path_t * vpath)
 474 {
 475     void *data;
 476
 477     data = vfs_s_opendir (vpath);
 478     if (data == NULL)
 479         return -1;
 480     vfs_s_closedir (data);
 481     return 0;
 482 }
 483
 484 /* --------------------------------------------------------------------------------------------- */
 485 /* --------------------------- stat and friends ---------------------------- */
 486
 487 static int
 488 vfs_s_internal_stat (const vfs_path_t * vpath, struct stat *buf, int flag)
 489 {
 490     struct vfs_s_inode *ino;
 491
 492     ino = vfs_s_inode_from_path (vpath, flag);
 493     if (ino == NULL)
 494         return -1;
 495     *buf = ino->st;
 496     return 0;
 497 }
 498
 499 /* --------------------------------------------------------------------------------------------- */
 500
 501 static int
 502 vfs_s_stat (const vfs_path_t * vpath, struct stat *buf)
 503 {
 504     return vfs_s_internal_stat (vpath, buf, FL_FOLLOW);
 505 }
 506
 507 /* --------------------------------------------------------------------------------------------- */
 508
 509 static int
 510 vfs_s_lstat (const vfs_path_t * vpath, struct stat *buf)
 511 {
 512     return vfs_s_internal_stat (vpath, buf, FL_NONE);
 513 }
 514
 515 /* --------------------------------------------------------------------------------------------- */
 516
 517 static int
 518 vfs_s_fstat (void *fh, struct stat *buf)
 519 {
 520     *buf = FH->ino->st;
 521     return 0;
 522 }
 523
 524 /* --------------------------------------------------------------------------------------------- */
 525
 526 static int
 527 vfs_s_readlink (const vfs_path_t * vpath, char *buf, size_t size)
 528 {
 529     struct vfs_s_inode *ino;
 530     size_t len;
 531     const vfs_path_element_t *path_element;
 532
 533     path_element = vfs_path_get_by_index (vpath, -1);
 534
 535     ino = vfs_s_inode_from_path (vpath, 0);
 536     if (!ino)
 537         return -1;
 538
 539     if (!S_ISLNK (ino->st.st_mode))
 540     {
 541         path_element->class->verrno = EINVAL;
 542         return -1;
 543     }
 544
 545     if (ino->linkname == NULL)
 546     {
 547         path_element->class->verrno = EFAULT;
 548         return -1;
 549     }
 550
 551     len = strlen (ino->linkname);
 552     if (size < len)
 553         len = size;
 554     /* readlink() does not append a NUL character to buf */
 555     memcpy (buf, ino->linkname, len);
 556     return len;
 557 }
 558
 559 /* --------------------------------------------------------------------------------------------- */
 560
 561 static ssize_t
 562 vfs_s_read (void *fh, char *buffer, size_t count)
 563 {
 564     int n;
 565     struct vfs_class *me = FH_SUPER->me;
 566
 567     if (FH->linear == LS_LINEAR_PREOPEN)
 568     {
 569         if (!MEDATA->linear_start (me, FH, FH->pos))
 570             return -1;
 571     }
 572
 573     if (FH->linear == LS_LINEAR_CLOSED)
 574         vfs_die ("linear_start() did not set linear_state!");
 575
 576     if (FH->linear == LS_LINEAR_OPEN)
 577         return MEDATA->linear_read (me, FH, buffer, count);
 578
 579     if (FH->handle != -1)
 580     {
 581         n = read (FH->handle, buffer, count);
 582         if (n < 0)
 583             me->verrno = errno;
 584         return n;
 585     }
 586     vfs_die ("vfs_s_read: This should not happen\n");
 587     return -1;
 588 }
 589
 590 /* --------------------------------------------------------------------------------------------- */
 591
 592 static ssize_t
 593 vfs_s_write (void *fh, const char *buffer, size_t count)
 594 {
 595     int n;
 596     struct vfs_class *me = FH_SUPER->me;
 597
 598     if (FH->linear)
 599         vfs_die ("no writing to linear files, please");
 600
 601     FH->changed = 1;
 602     if (FH->handle != -1)
 603     {
 604         n = write (FH->handle, buffer, count);
 605         if (n < 0)
 606             me->verrno = errno;
 607         return n;
 608     }
 609     vfs_die ("vfs_s_write: This should not happen\n");
 610     return 0;
 611 }
 612
 613 /* --------------------------------------------------------------------------------------------- */
 614
 615 static off_t
 616 vfs_s_lseek (void *fh, off_t offset, int whence)
 617 {
 618     off_t size = FH->ino->st.st_size;
 619
 620     if (FH->linear == LS_LINEAR_OPEN)
 621         vfs_die ("cannot lseek() after linear_read!");
 622
 623     if (FH->handle != -1)
 624     {                           /* If we have local file opened, we want to work with it */
 625         off_t retval = lseek (FH->handle, offset, whence);
 626         if (retval == -1)
 627             FH->ino->super->me->verrno = errno;
 628         return retval;
 629     }
 630
 631     switch (whence)
 632     {
 633     case SEEK_CUR:
 634         offset += FH->pos;
 635         break;
 636     case SEEK_END:
 637         offset += size;
 638         break;
 639     }
 640     if (offset < 0)
 641         FH->pos = 0;
 642     else if (offset < size)
 643         FH->pos = offset;
 644     else
 645         FH->pos = size;
 646     return FH->pos;
 647 }
 648
 649 /* --------------------------------------------------------------------------------------------- */
 650
 651 static int
 652 vfs_s_close (void *fh)
 653 {
 654     int res = 0;
 655     struct vfs_class *me = FH_SUPER->me;
 656
 657     FH_SUPER->fd_usage--;
 658     if (!FH_SUPER->fd_usage)
 659         vfs_stamp_create (me, FH_SUPER);
 660
 661     if (FH->linear == LS_LINEAR_OPEN)
 662         MEDATA->linear_close (me, fh);
 663     if (MEDATA->fh_close)
 664         res = MEDATA->fh_close (me, fh);
 665     if ((MEDATA->flags & VFS_S_USETMP) && FH->changed && MEDATA->file_store)
 666     {
 667         char *s = vfs_s_fullpath (me, FH->ino);
 668         if (!s)
 669             res = -1;
 670         else
 671         {
 672             res = MEDATA->file_store (me, fh, s, FH->ino->localname);
 673             g_free (s);
 674         }
 675         vfs_s_invalidate (me, FH_SUPER);
 676     }
 677     if (FH->handle != -1)
 678         close (FH->handle);
 679
 680     vfs_s_free_inode (me, FH->ino);
 681     if (MEDATA->fh_free_data != NULL)
 682         MEDATA->fh_free_data (fh);
 683     g_free (fh);
 684     return res;
 685 }
 686
 687 /* --------------------------------------------------------------------------------------------- */
 688
 689 static void
 690 vfs_s_print_stats (const char *fs_name, const char *action,
 691                    const char *file_name, off_t have, off_t need)
 692 {
 693     static const char *i18n_percent_transf_format = NULL;
 694     static const char *i18n_transf_format = NULL;
 695
 696     if (i18n_percent_transf_format == NULL)
 697     {
 698         i18n_percent_transf_format = "%s: %s: %s %3d%% (%" PRIuMAX " %s";
 699         i18n_transf_format = "%s: %s: %s %" PRIuMAX " %s";
 700     }
 701
 702     if (need)
 703         vfs_print_message (i18n_percent_transf_format, fs_name, action,
 704                            file_name, (int) ((double) have * 100 / need), (uintmax_t) have,
 705                            _("bytes transferred"));
 706     else
 707         vfs_print_message (i18n_transf_format, fs_name, action, file_name, (uintmax_t) have,
 708                            _("bytes transferred"));
 709 }
 710
 711 /* --------------------------------------------------------------------------------------------- */
 712 /* ------------------------------- mc support ---------------------------- */
 713
 714 static void
 715 vfs_s_fill_names (struct vfs_class *me, fill_names_f func)
 716 {
 717     GList *iter;
 718
 719     for (iter = MEDATA->supers; iter != NULL; iter = g_list_next (iter))
 720     {
 721         const struct vfs_s_super *super = (const struct vfs_s_super *) iter->data;
 722         char *name;
 723
 724         name = g_strconcat (super->name, "/", me->prefix, VFS_PATH_URL_DELIMITER,
 725                             /* super->current_dir->name, */ (char *) NULL);
 726         func (name);
 727         g_free (name);
 728     }
 729 }
 730
 731 /* --------------------------------------------------------------------------------------------- */
 732
 733 static int
 734 vfs_s_ferrno (struct vfs_class *me)
 735 {
 736     return me->verrno;
 737 }
 738
 739 /* --------------------------------------------------------------------------------------------- */
 740 /**
 741  * Get local copy of the given file.  We reuse the existing file cache
 742  * for remote filesystems.  Archives use standard VFS facilities.
 743  */
 744
 745 static vfs_path_t *
 746 vfs_s_getlocalcopy (const vfs_path_t * vpath)
 747 {
 748     vfs_file_handler_t *fh;
 749     vfs_path_t *local = NULL;
 750
 751     if (vpath == NULL)
 752         return NULL;
 753
 754     fh = vfs_s_open (vpath, O_RDONLY, 0);
 755
 756     if (fh != NULL)
 757     {
 758         const struct vfs_class *me;
 759
 760         me = vfs_path_get_by_index (vpath, -1)->class;
 761         if ((MEDATA->flags & VFS_S_USETMP) != 0 && (fh->ino != NULL))
 762             local = vfs_path_from_str_flags (fh->ino->localname, VPF_NO_CANON);
 763
 764         vfs_s_close (fh);
 765     }
 766
 767     return local;
 768 }
 769
 770 /* --------------------------------------------------------------------------------------------- */
 771 /**
 772  * Return the local copy.  Since we are using our cache, we do nothing -
 773  * the cache will be removed when the archive is closed.
 774  */
 775
 776 static int
 777 vfs_s_ungetlocalcopy (const vfs_path_t * vpath, const vfs_path_t * local, gboolean has_changed)
 778 {
 779     (void) vpath;
 780     (void) local;
 781     (void) has_changed;
 782     return 0;
 783 }
 784
 785 /* --------------------------------------------------------------------------------------------- */
 786
 787 static int
 788 vfs_s_setctl (const vfs_path_t * vpath, int ctlop, void *arg)
 789 {
 790     const vfs_path_element_t *path_element;
 791
 792     path_element = vfs_path_get_by_index (vpath, -1);
 793
 794     switch (ctlop)
 795     {
 796     case VFS_SETCTL_STALE_DATA:
 797         {
 798             struct vfs_s_inode *ino;
 799
 800             ino = vfs_s_inode_from_path (vpath, 0);
 801             if (ino == NULL)
 802                 return 0;
 803             if (arg)
 804                 ino->super->want_stale = 1;
 805             else
 806             {
 807                 ino->super->want_stale = 0;
 808                 vfs_s_invalidate (path_element->class, ino->super);
 809             }
 810             return 1;
 811         }
 812     case VFS_SETCTL_LOGFILE:
 813         ((struct vfs_s_subclass *) path_element->class->data)->logfile = fopen ((char *) arg, "w");
 814         return 1;
 815     case VFS_SETCTL_FLUSH:
 816         ((struct vfs_s_subclass *) path_element->class->data)->flush = 1;
 817         return 1;
 818     }
 819     return 0;
 820 }
 821
 822 /* --------------------------------------------------------------------------------------------- */
 823 /* ----------------------------- Stamping support -------------------------- */
 824
 825 static vfsid
 826 vfs_s_getid (const vfs_path_t * vpath)
 827 {
 828     struct vfs_s_super *archive = NULL;
 829     const char *p;
 830
 831     p = vfs_s_get_path (vpath, &archive, FL_NO_OPEN);
 832     if (p == NULL)
 833         return NULL;
 834
 835     return (vfsid) archive;
 836 }
 837
 838 /* --------------------------------------------------------------------------------------------- */
 839
 840 static int
 841 vfs_s_nothingisopen (vfsid id)
 842 {
 843     (void) id;
 844     /* Our data structures should survive free of superblock at any time */
 845     return 1;
 846 }
 847
 848 /* --------------------------------------------------------------------------------------------- */
 849
 850 static void
 851 vfs_s_free (vfsid id)
 852 {
 853     vfs_s_free_super (((struct vfs_s_super *) id)->me, (struct vfs_s_super *) id);
 854 }
 855
 856 /* --------------------------------------------------------------------------------------------- */
 857
 858 static int
 859 vfs_s_dir_uptodate (struct vfs_class *me, struct vfs_s_inode *ino)
 860 {
 861     struct timeval tim;
 862
 863     if (MEDATA->flush)
 864     {
 865         MEDATA->flush = 0;
 866         return 0;
 867     }
 868
 869     gettimeofday (&tim, NULL);
 870     if (tim.tv_sec < ino->timestamp.tv_sec)
 871         return 1;
 872     return 0;
 873 }
 874
 875
 876 /* --------------------------------------------------------------------------------------------- */
 877 /*** public functions ****************************************************************************/
 878 /* --------------------------------------------------------------------------------------------- */
 879
 880 struct vfs_s_inode *
 881 vfs_s_new_inode (struct vfs_class *me, struct vfs_s_super *super, struct stat *initstat)
 882 {
 883     struct vfs_s_inode *ino;
 884
 885     ino = g_try_new0 (struct vfs_s_inode, 1);
 886     if (ino == NULL)
 887         return NULL;
 888
 889     if (initstat)
 890         ino->st = *initstat;
 891     ino->super = super;
 892     ino->st.st_nlink = 0;
 893     ino->st.st_ino = MEDATA->inode_counter++;
 894     ino->st.st_dev = MEDATA->rdev;
 895
 896     super->ino_usage++;
 897     total_inodes++;
 898
 899     CALL (init_inode) (me, ino);
 900
 901     return ino;
 902 }
 903
 904 /* --------------------------------------------------------------------------------------------- */
 905
 906 void
 907 vfs_s_free_inode (struct vfs_class *me, struct vfs_s_inode *ino)
 908 {
 909     if (ino == NULL)
 910         vfs_die ("Don't pass NULL to me");
 911
 912     /* ==0 can happen if freshly created entry is deleted */
 913     if (ino->st.st_nlink > 1)
 914     {
 915         ino->st.st_nlink--;
 916         return;
 917     }
 918
 919     while (ino->subdir != NULL)
 920         vfs_s_free_entry (me, (struct vfs_s_entry *) ino->subdir->data);
 921
 922     CALL (free_inode) (me, ino);
 923     g_free (ino->linkname);
 924     if ((MEDATA->flags & VFS_S_USETMP) != 0 && ino->localname != NULL)
 925     {
 926         unlink (ino->localname);
 927         g_free (ino->localname);
 928     }
 929     total_inodes--;
 930     ino->super->ino_usage--;
 931     g_free (ino);
 932 }
 933
 934 /* --------------------------------------------------------------------------------------------- */
 935
 936 struct vfs_s_entry *
 937 vfs_s_new_entry (struct vfs_class *me, const char *name, struct vfs_s_inode *inode)
 938 {
 939     struct vfs_s_entry *entry;
 940
 941     entry = g_new0 (struct vfs_s_entry, 1);
 942     total_entries++;
 943
 944     entry->name = g_strdup (name);
 945     entry->ino = inode;
 946     entry->ino->ent = entry;
 947     CALL (init_entry) (me, entry);
 948
 949     return entry;
 950 }
 951
 952
 953 /* --------------------------------------------------------------------------------------------- */
 954
 955 void
 956 vfs_s_free_entry (struct vfs_class *me, struct vfs_s_entry *ent)
 957 {
 958     if (ent->dir != NULL)
 959         ent->dir->subdir = g_list_remove (ent->dir->subdir, ent);
 960
 961     g_free (ent->name);
 962     /* ent->name = NULL; */
 963
 964     if (ent->ino != NULL)
 965     {
 966         ent->ino->ent = NULL;
 967         vfs_s_free_inode (me, ent->ino);
 968     }
 969
 970     total_entries--;
 971     g_free (ent);
 972 }
 973
 974 /* --------------------------------------------------------------------------------------------- */
 975
 976 void
 977 vfs_s_insert_entry (struct vfs_class *me, struct vfs_s_inode *dir, struct vfs_s_entry *ent)
 978 {
 979     (void) me;
 980
 981     ent->dir = dir;
 982
 983     ent->ino->st.st_nlink++;
 984     dir->subdir = g_list_append (dir->subdir, ent);
 985 }
 986
 987 /* --------------------------------------------------------------------------------------------- */
 988
 989 struct stat *
 990 vfs_s_default_stat (struct vfs_class *me, mode_t mode)
 991 {
 992     static struct stat st;
 993     int myumask;
 994
 995     (void) me;
 996
 997     myumask = umask (022);
 998     umask (myumask);
 999     mode &= ~myumask;
1000
1001     st.st_mode = mode;
1002     st.st_ino = 0;
1003     st.st_dev = 0;
1004     st.st_rdev = 0;
1005     st.st_uid = getuid ();
1006     st.st_gid = getgid ();
1007     st.st_size = 0;
1008     st.st_mtime = st.st_atime = st.st_ctime = time (NULL);
1009
1010     return &st;
1011 }
1012
1013 /* --------------------------------------------------------------------------------------------- */
1014
1015 struct vfs_s_entry *
1016 vfs_s_generate_entry (struct vfs_class *me, const char *name, struct vfs_s_inode *parent,
1017                       mode_t mode)
1018 {
1019     struct vfs_s_inode *inode;
1020     struct stat *st;
1021
1022     st = vfs_s_default_stat (me, mode);
1023     inode = vfs_s_new_inode (me, parent->super, st);
1024
1025     return vfs_s_new_entry (me, name, inode);
1026 }
1027
1028 /* --------------------------------------------------------------------------------------------- */
1029
1030 struct vfs_s_inode *
1031 vfs_s_find_inode (struct vfs_class *me, const struct vfs_s_super *super,
1032                   const char *path, int follow, int flags)
1033 {
1034     struct vfs_s_entry *ent;
1035
1036     if (((MEDATA->flags & VFS_S_REMOTE) == 0) && (*path == '\0'))
1037         return super->root;
1038
1039     ent = (MEDATA->find_entry) (me, super->root, path, follow, flags);
1040     return (ent != NULL) ? ent->ino : NULL;
1041 }
1042
1043 /* --------------------------------------------------------------------------------------------- */
1044 /* Ook, these were functions around directory entries / inodes */
1045 /* -------------------------------- superblock games -------------------------- */
1046 /**
1047  * get path from last VFS-element and create corresponding superblock
1048  *
1049  * @param vpath source path object
1050  * @param archive pointer to object for store newly created superblock
1051  * @param flags flags
1052  *
1053  * @return path from last VFS-element
1054  */
1055 const char *
1056 vfs_s_get_path (const vfs_path_t * vpath, struct vfs_s_super **archive, int flags)
1057 {
1058     GList *iter;
1059     const char *retval;
1060     int result = -1;
1061     struct vfs_s_super *super;
1062     void *cookie = NULL;
1063     const vfs_path_element_t *path_element;
1064     vfs_path_t *vpath_archive;
1065     struct vfs_s_subclass *subclass;
1066
1067     path_element = vfs_path_get_by_index (vpath, -1);
1068     subclass = ((struct vfs_s_subclass *) path_element->class->data);
1069
1070     if (subclass == NULL)
1071         return NULL;
1072
1073     vpath_archive = vfs_path_clone (vpath);
1074     vfs_path_remove_element_by_index (vpath_archive, -1);
1075
1076     retval = (path_element->path != NULL) ? path_element->path : "";
1077
1078     if (subclass->archive_check != NULL)
1079     {
1080         cookie = subclass->archive_check (vpath_archive);
1081         if (cookie == NULL)
1082         {
1083             vfs_path_free (vpath_archive);
1084             return NULL;
1085         }
1086     }
1087
1088     for (iter = subclass->supers; iter != NULL; iter = g_list_next (iter))
1089     {
1090         int i;
1091
1092         super = (struct vfs_s_super *) iter->data;
1093
1094         /* 0 == other, 1 == same, return it, 2 == other but stop scanning */
1095         i = subclass->archive_same (path_element, super, vpath_archive, cookie);
1096         if (i != 0)
1097         {
1098             if (i == 1)
1099                 goto return_success;
1100             break;
1101         }
1102     }
1103
1104     if (flags & FL_NO_OPEN)
1105     {
1106         path_element->class->verrno = EIO;
1107         vfs_path_free (vpath_archive);
1108         return NULL;
1109     }
1110
1111     super = vfs_s_new_super (path_element->class);
1112     if (subclass->open_archive != NULL)
1113         result = subclass->open_archive (super, vpath_archive, path_element);
1114     if (result == -1)
1115     {
1116         vfs_s_free_super (path_element->class, super);
1117         path_element->class->verrno = EIO;
1118         vfs_path_free (vpath_archive);
1119         return NULL;
1120     }
1121     if (!super->name)
1122         vfs_die ("You have to fill name\n");
1123     if (!super->root)
1124         vfs_die ("You have to fill root inode\n");
1125
1126     vfs_s_insert_super (path_element->class, super);
1127     vfs_stamp_create (path_element->class, super);
1128
1129   return_success:
1130     *archive = super;
1131     vfs_path_free (vpath_archive);
1132     return retval;
1133 }
1134
1135 /* --------------------------------------------------------------------------------------------- */
1136
1137 void
1138 vfs_s_invalidate (struct vfs_class *me, struct vfs_s_super *super)
1139 {
1140     if (!super->want_stale)
1141     {
1142         vfs_s_free_inode (me, super->root);
1143         super->root = vfs_s_new_inode (me, super, vfs_s_default_stat (me, S_IFDIR | 0755));
1144     }
1145 }
1146
1147 /* --------------------------------------------------------------------------------------------- */
1148
1149 char *
1150 vfs_s_fullpath (struct vfs_class *me, struct vfs_s_inode *ino)
1151 {
1152     if (!ino->ent)
1153         ERRNOR (EAGAIN, NULL);
1154
1155     if ((MEDATA->flags & VFS_S_USETMP) == 0)
1156     {
1157         /* archives */
1158         char *newpath;
1159         char *path = g_strdup (ino->ent->name);
1160         while (1)
1161         {
1162             ino = ino->ent->dir;
1163             if (ino == ino->super->root)
1164                 break;
1165             newpath = g_strconcat (ino->ent->name, "/", path, (char *) NULL);
1166             g_free (path);
1167             path = newpath;
1168         }
1169         return path;
1170     }
1171
1172     /* remote systems */
1173     if ((!ino->ent->dir) || (!ino->ent->dir->ent))
1174         return g_strdup (ino->ent->name);
1175
1176     return g_strconcat (ino->ent->dir->ent->name, PATH_SEP_STR, ino->ent->name, (char *) NULL);
1177 }
1178
1179 /* --------------------------------------------------------------------------------------------- */
1180 /* --------------------------- stat and friends ---------------------------- */
1181
1182 void *
1183 vfs_s_open (const vfs_path_t * vpath, int flags, mode_t mode)
1184 {
1185     int was_changed = 0;
1186     vfs_file_handler_t *fh;
1187     struct vfs_s_super *super;
1188     const char *q;
1189     struct vfs_s_inode *ino;
1190     const vfs_path_element_t *path_element;
1191
1192     path_element = vfs_path_get_by_index (vpath, -1);
1193
1194     q = vfs_s_get_path (vpath, &super, 0);
1195     if (q == NULL)
1196         return NULL;
1197     ino = vfs_s_find_inode (path_element->class, super, q, LINK_FOLLOW, FL_NONE);
1198     if (ino && ((flags & (O_CREAT | O_EXCL)) == (O_CREAT | O_EXCL)))
1199     {
1200         path_element->class->verrno = EEXIST;
1201         return NULL;
1202     }
1203     if (!ino)
1204     {
1205         char *dirname, *name;
1206         struct vfs_s_entry *ent;
1207         struct vfs_s_inode *dir;
1208         int tmp_handle;
1209
1210         /* If the filesystem is read-only, disable file creation */
1211         if (!(flags & O_CREAT) || !(path_element->class->write))
1212             return NULL;
1213
1214         dirname = g_path_get_dirname (q);
1215         name = g_path_get_basename (q);
1216         dir = vfs_s_find_inode (path_element->class, super, dirname, LINK_FOLLOW, FL_DIR);
1217         if (dir == NULL)
1218         {
1219             g_free (dirname);
1220             g_free (name);
1221             return NULL;
1222         }
1223         ent = vfs_s_generate_entry (path_element->class, name, dir, 0755);
1224         ino = ent->ino;
1225         vfs_s_insert_entry (path_element->class, dir, ent);
1226         if ((VFSDATA (path_element)->flags & VFS_S_USETMP) != 0)
1227         {
1228             vfs_path_t *tmp_vpath;
1229
1230             tmp_handle = vfs_mkstemps (&tmp_vpath, path_element->class->name, name);
1231             ino->localname = vfs_path_to_str (tmp_vpath);
1232             vfs_path_free (tmp_vpath);
1233             if (tmp_handle == -1)
1234             {
1235                 g_free (dirname);
1236                 g_free (name);
1237                 return NULL;
1238             }
1239
1240             close (tmp_handle);
1241         }
1242         g_free (dirname);
1243         g_free (name);
1244         was_changed = 1;
1245     }
1246
1247     if (S_ISDIR (ino->st.st_mode))
1248     {
1249         path_element->class->verrno = EISDIR;
1250         return NULL;
1251     }
1252
1253     fh = g_new (vfs_file_handler_t, 1);
1254     fh->pos = 0;
1255     fh->ino = ino;
1256     fh->handle = -1;
1257     fh->changed = was_changed;
1258     fh->linear = 0;
1259     fh->data = NULL;
1260
1261     if (IS_LINEAR (flags))
1262     {
1263         if (VFSDATA (path_element)->linear_start)
1264         {
1265             vfs_print_message (_("Starting linear transfer..."));
1266             fh->linear = LS_LINEAR_PREOPEN;
1267         }
1268     }
1269     else
1270     {
1271         struct vfs_s_subclass *s;
1272
1273         s = VFSDATA (path_element);
1274         if (s->fh_open != NULL && s->fh_open (path_element->class, fh, flags, mode) != 0)
1275         {
1276             if (s->fh_free_data != NULL)
1277                 s->fh_free_data (fh);
1278             g_free (fh);
1279             return NULL;
1280         }
1281     }
1282
1283     if ((VFSDATA (path_element)->flags & VFS_S_USETMP) != 0 && fh->ino->localname != NULL)
1284     {
1285         fh->handle = open (fh->ino->localname, NO_LINEAR (flags), mode);
1286         if (fh->handle == -1)
1287         {
1288             g_free (fh);
1289             path_element->class->verrno = errno;
1290             return NULL;
1291         }
1292     }
1293
1294     /* i.e. we had no open files and now we have one */
1295     vfs_rmstamp (path_element->class, (vfsid) super);
1296     super->fd_usage++;
1297     fh->ino->st.st_nlink++;
1298     return fh;
1299 }
1300
1301 /* --------------------------------------------------------------------------------------------- */
1302
1303 int
1304 vfs_s_retrieve_file (struct vfs_class *me, struct vfs_s_inode *ino)
1305 {
1306     /* If you want reget, you'll have to open file with O_LINEAR */
1307     off_t total = 0;
1308     char buffer[8192];
1309     int handle, n;
1310     off_t stat_size = ino->st.st_size;
1311     vfs_file_handler_t fh;
1312     vfs_path_t *tmp_vpath;
1313
1314     if ((MEDATA->flags & VFS_S_USETMP) == 0)
1315         return -1;
1316
1317     memset (&fh, 0, sizeof (fh));
1318
1319     fh.ino = ino;
1320     fh.handle = -1;
1321
1322     handle = vfs_mkstemps (&tmp_vpath, me->name, ino->ent->name);
1323     ino->localname = vfs_path_to_str (tmp_vpath);
1324     vfs_path_free (tmp_vpath);
1325     if (handle == -1)
1326     {
1327         me->verrno = errno;
1328         goto error_4;
1329     }
1330
1331     if (!MEDATA->linear_start (me, &fh, 0))
1332         goto error_3;
1333
1334     /* Clear the interrupt status */
1335     tty_got_interrupt ();
1336     tty_enable_interrupt_key ();
1337
1338     while ((n = MEDATA->linear_read (me, &fh, buffer, sizeof (buffer))))
1339     {
1340         int t;
1341         if (n < 0)
1342             goto error_1;
1343
1344         total += n;
1345         vfs_s_print_stats (me->name, _("Getting file"), ino->ent->name, total, stat_size);
1346
1347         if (tty_got_interrupt ())
1348             goto error_1;
1349
1350         t = write (handle, buffer, n);
1351         if (t != n)
1352         {
1353             if (t == -1)
1354                 me->verrno = errno;
1355             goto error_1;
1356         }
1357     }
1358     MEDATA->linear_close (me, &fh);
1359     close (handle);
1360
1361     tty_disable_interrupt_key ();
1362     g_free (fh.data);
1363     return 0;
1364
1365   error_1:
1366     MEDATA->linear_close (me, &fh);
1367   error_3:
1368     tty_disable_interrupt_key ();
1369     close (handle);
1370     unlink (ino->localname);
1371   error_4:
1372     g_free (ino->localname);
1373     ino->localname = NULL;
1374     g_free (fh.data);
1375     return -1;
1376 }
1377
1378 /* --------------------------------------------------------------------------------------------- */
1379 /* ----------------------------- Stamping support -------------------------- */
1380
1381 /* Initialize one of our subclasses - fill common functions */
1382 void
1383 vfs_s_init_class (struct vfs_class *vclass, struct vfs_s_subclass *sub)
1384 {
1385     vclass->data = sub;
1386     vclass->fill_names = vfs_s_fill_names;
1387     vclass->open = vfs_s_open;
1388     vclass->close = vfs_s_close;
1389     vclass->read = vfs_s_read;
1390     if (!(sub->flags & VFS_S_READONLY))
1391     {
1392         vclass->write = vfs_s_write;
1393     }
1394     vclass->opendir = vfs_s_opendir;
1395     vclass->readdir = vfs_s_readdir;
1396     vclass->closedir = vfs_s_closedir;
1397     vclass->stat = vfs_s_stat;
1398     vclass->lstat = vfs_s_lstat;
1399     vclass->fstat = vfs_s_fstat;
1400     vclass->readlink = vfs_s_readlink;
1401     vclass->chdir = vfs_s_chdir;
1402     vclass->ferrno = vfs_s_ferrno;
1403     vclass->lseek = vfs_s_lseek;
1404     vclass->getid = vfs_s_getid;
1405     vclass->nothingisopen = vfs_s_nothingisopen;
1406     vclass->free = vfs_s_free;
1407     if ((sub->flags & VFS_S_USETMP) != 0)
1408     {
1409         vclass->getlocalcopy = vfs_s_getlocalcopy;
1410         vclass->ungetlocalcopy = vfs_s_ungetlocalcopy;
1411         sub->find_entry = vfs_s_find_entry_linear;
1412     }
1413     else if ((sub->flags & VFS_S_REMOTE) != 0)
1414         sub->find_entry = vfs_s_find_entry_linear;
1415     else
1416         sub->find_entry = vfs_s_find_entry_tree;
1417     vclass->setctl = vfs_s_setctl;
1418     sub->dir_uptodate = vfs_s_dir_uptodate;
1419 }
1420
1421 /* --------------------------------------------------------------------------------------------- */
1422 /** Find VFS id for given directory name */
1423
1424 vfsid
1425 vfs_getid (const vfs_path_t * vpath)
1426 {
1427     const vfs_path_element_t *path_element;
1428
1429     path_element = vfs_path_get_by_index (vpath, -1);
1430     if (!vfs_path_element_valid (path_element) || path_element->class->getid == NULL)
1431         return NULL;
1432
1433     return (*path_element->class->getid) (vpath);
1434 }
1435
1436 /* --------------------------------------------------------------------------------------------- */
1437 /* ----------- Utility functions for networked filesystems  -------------- */
1438
1439 #ifdef ENABLE_VFS_NET
1440 int
1441 vfs_s_select_on_two (int fd1, int fd2)
1442 {
1443     fd_set set;
1444     struct timeval time_out;
1445     int v;
1446     int maxfd = (fd1 > fd2 ? fd1 : fd2) + 1;
1447
1448     time_out.tv_sec = 1;
1449     time_out.tv_usec = 0;
1450     FD_ZERO (&set);
1451     FD_SET (fd1, &set);
1452     FD_SET (fd2, &set);
1453     v = select (maxfd, &set, 0, 0, &time_out);
1454     if (v <= 0)
1455         return v;
1456     if (FD_ISSET (fd1, &set))
1457         return 1;
1458     if (FD_ISSET (fd2, &set))
1459         return 2;
1460     return -1;
1461 }
1462
1463 /* --------------------------------------------------------------------------------------------- */
1464
1465 int
1466 vfs_s_get_line (struct vfs_class *me, int sock, char *buf, int buf_len, char term)
1467 {
1468     FILE *logfile = MEDATA->logfile;
1469     int i;
1470     char c;
1471
1472     for (i = 0; i < buf_len - 1; i++, buf++)
1473     {
1474         if (read (sock, buf, sizeof (char)) <= 0)
1475             return 0;
1476         if (logfile)
1477         {
1478             size_t ret1;
1479             int ret2;
1480             ret1 = fwrite (buf, 1, 1, logfile);
1481             ret2 = fflush (logfile);
1482         }
1483         if (*buf == term)
1484         {
1485             *buf = 0;
1486             return 1;
1487         }
1488     }
1489
1490     /* Line is too long - terminate buffer and discard the rest of line */
1491     *buf = 0;
1492     while (read (sock, &c, sizeof (c)) > 0)
1493     {
1494         if (logfile)
1495         {
1496             size_t ret1;
1497             int ret2;
1498             ret1 = fwrite (&c, 1, 1, logfile);
1499             ret2 = fflush (logfile);
1500         }
1501         if (c == '\n')
1502             return 1;
1503     }
1504     return 0;
1505 }
1506
1507 /* --------------------------------------------------------------------------------------------- */
1508
1509 int
1510 vfs_s_get_line_interruptible (struct vfs_class *me, char *buffer, int size, int fd)
1511 {
1512     int n;
1513     int i;
1514
1515     (void) me;
1516
1517     tty_enable_interrupt_key ();
1518     for (i = 0; i < size - 1; i++)
1519     {
1520         n = read (fd, buffer + i, 1);
1521         tty_disable_interrupt_key ();
1522         if (n == -1 && errno == EINTR)
1523         {
1524             buffer[i] = 0;
1525             return EINTR;
1526         }
1527         if (n == 0)
1528         {
1529             buffer[i] = 0;
1530             return 0;
1531         }
1532         if (buffer[i] == '\n')
1533         {
1534             buffer[i] = 0;
1535             return 1;
1536         }
1537     }
1538     buffer[size - 1] = 0;
1539     return 0;
1540 }
1541 #endif /* ENABLE_VFS_NET */
1542
1543 /* --------------------------------------------------------------------------------------------- */
1544 /**
1545  * Normalize filenames start position
1546  */
1547
1548 void
1549 vfs_s_normalize_filename_leading_spaces (struct vfs_s_inode *root_inode, size_t final_num_spaces)
1550 {
1551     GList *iter;
1552
1553     for (iter = root_inode->subdir; iter != NULL; iter = g_list_next (iter))
1554     {
1555         struct vfs_s_entry *entry = (struct vfs_s_entry *) iter->data;
1556         if ((size_t) entry->ino->data_offset > final_num_spaces)
1557         {
1558             char *source_name = entry->name;
1559             char *spacer = g_strnfill (entry->ino->data_offset - final_num_spaces, ' ');
1560             entry->name = g_strdup_printf ("%s%s", spacer, source_name);
1561             g_free (spacer);
1562             g_free (source_name);
1563         }
1564         entry->ino->data_offset = -1;
1565     }
1566 }
1567
1568 /* --------------------------------------------------------------------------------------------- */