mc/lib/vfs/mc-vfs/smbfs.c

/* Virtual File System: Midnight Commander file system.

   Copyright (C) 1999, 2000, 2001, 2002, 2003, 2004, 2005, 2007
   Free Software Foundation, Inc.

   Written by Wayne Roberts <wroberts1@home.com>, 1997
   Andrew V. Samoilov <sav@bcs.zp.ua> 2002, 2003

   This program is free software; you can redistribute it and/or
   modify it under the terms of the GNU Library General Public License
   as published by the Free Software Foundation; either version 2 of
   the License, or (at your option) any later version.

   This program is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   GNU Library General Public License for more details.

   You should have received a copy of the GNU Library General Public
   License along with this program; if not, write to the Free Software
   Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.  */

/**
 * \file
 * \brief Source: Virtual File System: smb file system
 * \author Wayne Roberts <wroberts1@home.com>
 * \author Andrew V. Samoilov <sav@bcs.zp.ua>
 * \date 1997, 2002, 2003
 *
 * Namespace: exports init_smbfs, smbfs_set_debug(), smbfs_set_debugf()
 */

#include <config.h>

#include <stdio.h>
#include <sys/types.h>

#undef USE_NCURSES              /* Don't include *curses.h */
#undef USE_NCURSESW

#include <string.h>

#include "lib/global.h"
#include "lib/strutil.h"
#include "lib/util.h"
#include "lib/widget.h"         /* message() */

#undef  PACKAGE_BUGREPORT
#undef  PACKAGE_NAME
#undef  PACKAGE_STRING
#undef  PACKAGE_TARNAME
#undef  PACKAGE_VERSION

#include "samba/include/config.h"
/* don't load crap in "samba/include/includes.h" we don't use and which 
   conflicts with definitions in other includes */
#undef HAVE_LIBREADLINE
#define NO_CONFIG_H
#undef VERSION

#include "samba/include/includes.h"

#include "vfs-impl.h"
#include "netutil.h"
#include "utilvfs.h"
#include "smbfs.h"

/*** global variables ****************************************************************************/

extern int DEBUGLEVEL;
extern pstring myhostname;
extern struct in_addr ipzero;
extern pstring global_myname;
extern pstring debugf;
extern FILE *dbf;

/*** file scope macro definitions ****************************************************************/

#define SMBFS_MAX_CONNECTIONS 16

#define HEADER_LEN      6

#define CNV_LANG(s) dos_to_unix(s,False)
#define GNAL_VNC(s) unix_to_dos(s,False)

/* Extract the hostname and username from the path */
/* path is in the form: [user@]hostname/share/remote-dir */
#define smbfs_get_host_and_username(path, host, user, port, pass) \
        vfs_split_url (*path, host, user, port, pass, SMB_PORT, 0)

#define smbfs_lstat smbfs_stat  /* no symlinks on smb filesystem? */

/*** file scope type declarations ****************************************************************/

typedef struct _smbfs_connection smbfs_connection;

typedef struct
{
    struct cli_state *cli;
    int fnum;
    off_t nread;
    uint16 attr;
} smbfs_handle;

typedef struct dir_entry
{
    char *text;
    struct dir_entry *next;
    struct stat my_stat;
    int merrno;
} dir_entry;

typedef struct
{
    gboolean server_list;
    char *dirname;
    char *path;                 /* the dir originally passed to smbfs_opendir */
    smbfs_connection *conn;
    dir_entry *entries;
    dir_entry *current;
} opendir_info;

/*** file scope variables ************************************************************************/

static const char *const IPC = "IPC$";
static const char *const URL_HEADER = "/#smb:";

static int my_errno;
static uint32 err;

/* stuff that is same with each connection */

static mode_t myumask = 0755;
static int smbfs_open_connections = 0;
static gboolean got_user = FALSE;
static gboolean got_pass = FALSE;
static pstring password;
static pstring username;
static struct vfs_class vfs_smbfs_ops;

static struct _smbfs_connection
{
    struct cli_state *cli;
    struct in_addr dest_ip;
    BOOL have_ip;
    char *host;                 /* server name */
    char *service;              /* share name */
    char *domain;
    char *user;
    char *home;
    char *password;
    int port;
    int name_type;
    time_t last_use;
} smbfs_connections[SMBFS_MAX_CONNECTIONS];
/* unique to each connection */

static smbfs_connection *current_bucket;

static GSList *auth_list;

static opendir_info *previous_info, *current_info, *current_share_info, *current_server_info;

static gboolean first_direntry;

/* stat a single file, smbfs_get_remote_stat callback  */
static dir_entry *single_entry;

/*** file scope functions ************************************************************************/
/* --------------------------------------------------------------------------------------------- */

/* modifies *share */
static struct cli_state *smbfs_do_connect (const char *server, char *share);

/* --------------------------------------------------------------------------------------------- */
/* this function allows you to write:
 * char *s = g_strdup("hello, world");
 * s = free_after(g_strconcat(s, s, (char *)0), s);
 */

static inline char *
free_after (char *result, char *string_to_free)
{
    g_free (string_to_free);
    return result;
}

/* --------------------------------------------------------------------------------------------- */

static void
smbfs_auth_free (struct smb_authinfo const *a)
{
    g_free (a->host);
    g_free (a->share);
    g_free (a->domain);
    g_free (a->user);
    wipe_password (a->password);
}

/* --------------------------------------------------------------------------------------------- */

static void
smbfs_auth_free_all (void)
{
    if (auth_list)
    {
        g_slist_foreach (auth_list, (GFunc) smbfs_auth_free, 0);
        g_slist_free (auth_list);
        auth_list = 0;
    }
}

/* --------------------------------------------------------------------------------------------- */

static gint
smbfs_auth_cmp_host_and_share (gconstpointer _a, gconstpointer _b)
{
    struct smb_authinfo const *a = (struct smb_authinfo const *) _a;
    struct smb_authinfo const *b = (struct smb_authinfo const *) _b;

    if (!a->host || !a->share || !b->host || !b->share)
        return 1;
    if (strcmp (a->host, b->host) != 0)
        return 1;
    if (strcmp (a->share, b->share) != 0)
        return 1;
    return 0;
}

/* --------------------------------------------------------------------------------------------- */

static gint
smbfs_auth_cmp_host (gconstpointer _a, gconstpointer _b)
{
    struct smb_authinfo const *a = (struct smb_authinfo const *) _a;
    struct smb_authinfo const *b = (struct smb_authinfo const *) _b;

    if (!a->host || !b->host)
        return 1;
    if (strcmp (a->host, b->host) != 0)
        return 1;
    if (strcmp (a->share, IPC) != 0)
        return 1;
    return 0;
}

/* --------------------------------------------------------------------------------------------- */

static void
smbfs_auth_add (const char *host, const char *share, const char *domain,
                const char *user, const char *pass)
{
    struct smb_authinfo *auth;

    auth = vfs_smb_authinfo_new (host, share, domain, user, pass);

    if (auth != NULL)
        auth_list = g_slist_prepend (auth_list, auth);
}

/* --------------------------------------------------------------------------------------------- */

static void
smbfs_auth_remove (const char *host, const char *share)
{
    struct smb_authinfo data;
    struct smb_authinfo *auth;
    GSList *list;

    data.host = g_strdup (host);
    data.share = g_strdup (share);
    list = g_slist_find_custom (auth_list, &data, smbfs_auth_cmp_host_and_share);
    g_free (data.host);
    g_free (data.share);
    if (!list)
        return;
    auth = list->data;
    auth_list = g_slist_remove (auth_list, auth);
    smbfs_auth_free (auth);
}

/* --------------------------------------------------------------------------------------------- */
/* Set authentication information in bucket. Return 1 if successful, else 0 */
/* Information in auth_list overrides user if pass is NULL. */
/* bucket->host and bucket->service must be valid. */

static int
smbfs_bucket_set_authinfo (smbfs_connection * bucket,
                           const char *domain, const char *user, const char *pass,
                           int fallback_to_host)
{
    struct smb_authinfo data;
    struct smb_authinfo *auth;
    GSList *list;

    if (domain && user && pass)
    {
        g_free (bucket->domain);
        g_free (bucket->user);
        g_free (bucket->password);
        bucket->domain = g_strdup (domain);
        bucket->user = g_strdup (user);
        bucket->password = g_strdup (pass);
        smbfs_auth_remove (bucket->host, bucket->service);
        smbfs_auth_add (bucket->host, bucket->service, domain, user, pass);
        return 1;
    }

    data.host = bucket->host;
    data.share = bucket->service;
    list = g_slist_find_custom (auth_list, &data, smbfs_auth_cmp_host_and_share);
    if (!list && fallback_to_host)
        list = g_slist_find_custom (auth_list, &data, smbfs_auth_cmp_host);
    if (list)
    {
        auth = list->data;
        bucket->domain = g_strdup (auth->domain);
        bucket->user = g_strdup (auth->user);
        bucket->password = g_strdup (auth->password);
        return 1;
    }

    if (got_pass)
    {
        bucket->domain = g_strdup (lp_workgroup ());
        bucket->user = g_strdup (got_user ? username : user);
        bucket->password = g_strdup (password);
        return 1;
    }

    auth = vfs_smb_get_authinfo (bucket->host,
                                 bucket->service, (domain ? domain : lp_workgroup ()), user);
    if (auth)
    {
        g_free (bucket->domain);
        g_free (bucket->user);
        g_free (bucket->password);
        bucket->domain = g_strdup (auth->domain);
        bucket->user = g_strdup (auth->user);
        bucket->password = g_strdup (auth->password);
        smbfs_auth_remove (bucket->host, bucket->service);
        auth_list = g_slist_prepend (auth_list, auth);
        return 1;
    }
    return 0;
}

/* --------------------------------------------------------------------------------------------- */

void
smbfs_set_debug (int arg)
{
    DEBUGLEVEL = arg;
}

/* --------------------------------------------------------------------------------------------- */

void
smbfs_set_debugf (const char *filename)
{
    if (DEBUGLEVEL > 0)
    {
        FILE *outfile = fopen (filename, "w");
        if (outfile)
        {
            setup_logging ("", True);   /* No needs for timestamp for each message */
            dbf = outfile;
            setbuf (dbf, NULL);
            pstrcpy (debugf, filename);
        }
    }
}

/* --------------------------------------------------------------------------------------------- */
/********************** The callbacks ******************************/

static int
smbfs_init (struct vfs_class *me)
{
    const char *servicesf = CONFIGDIR PATH_SEP_STR "smb.conf";

    /*  DEBUGLEVEL = 4; */

    TimeInit ();
    charset_initialise ();

    DEBUG (3, ("smbfs_init(%s)\n", me->name));

    if (!get_myname (myhostname, NULL))
        DEBUG (0, ("Failed to get my hostname.\n"));

    if (!lp_load (servicesf, True, False, False))
        DEBUG (0, ("Cannot load %s - run testparm to debug it\n", servicesf));

    codepage_initialise (lp_client_code_page ());

    load_interfaces ();

    myumask = umask (0);
    umask (myumask);
    myumask = ~myumask;

    if (getenv ("USER"))
    {
        char *p;

        pstrcpy (username, getenv ("USER"));
        got_user = TRUE;
        DEBUG (3, ("smbfs_init(): $USER:%s\n", username));
        if ((p = strchr (username, '%')))
        {
            *p = 0;
            pstrcpy (password, p + 1);
            got_pass = TRUE;
            memset (strchr (getenv ("USER"), '%') + 1, 'X', strlen (password));
            DEBUG (3, ("smbfs_init(): $USER%%pass: %s%%%s\n", username, password));
        }
        strupper (username);
    }
    if (getenv ("PASSWD"))
    {
        pstrcpy (password, getenv ("PASSWD"));
        got_pass = TRUE;
    }
    return 1;
}

/* --------------------------------------------------------------------------------------------- */

static void
smbfs_fill_names (struct vfs_class *me, fill_names_f func)
{
    size_t i;
    char *path;

    (void) me;

    for (i = 0; i < SMBFS_MAX_CONNECTIONS; i++)
    {
        if (smbfs_connections[i].cli)
        {
            path = g_strconcat (URL_HEADER,
                                smbfs_connections[i].user, "@",
                                smbfs_connections[i].host,
                                "/", smbfs_connections[i].service, (char *) NULL);
            (*func) (path);
            g_free (path);
        }
    }
}

/* --------------------------------------------------------------------------------------------- */
/* does same as do_get() in client.c */
/* called from vfs.c:1080, count = buffer size */

static ssize_t
smbfs_read (void *data, char *buffer, size_t count)
{
    smbfs_handle *info = (smbfs_handle *) data;
    ssize_t n;

    DEBUG (3, ("smbfs_read(fnum:%d, nread:%d, count:%zu)\n", info->fnum, (int) info->nread, count));
    n = cli_read (info->cli, info->fnum, buffer, info->nread, count);
    if (n > 0)
        info->nread += n;
    return n;
}

/* --------------------------------------------------------------------------------------------- */

static ssize_t
smbfs_write (void *data, const char *buf, size_t nbyte)
{
    smbfs_handle *info = (smbfs_handle *) data;
    ssize_t n;

    DEBUG (3, ("smbfs_write(fnum:%d, nread:%d, nbyte:%zu)\n",
               info->fnum, (int) info->nread, nbyte));
    n = cli_write (info->cli, info->fnum, 0, buf, info->nread, nbyte);
    if (n > 0)
        info->nread += n;
    return n;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_close (void *data)
{
    smbfs_handle *info = (smbfs_handle *) data;
    DEBUG (3, ("smbfs_close(fnum:%d)\n", info->fnum));

    /* FIXME: Why too different cli have the same outbuf
     * if file is copied to share
     */
    if (info->cli->outbuf == NULL)
    {
        my_errno = EINVAL;
        return -1;
    }
#if 0
    /* if imlementing archive_level:    add rname to smbfs_handle */
    if (archive_level >= 2 && (inf->attr & aARCH))
    {
        cli_setatr (info->cli, rname, info->attr & ~(uint16) aARCH, 0);
    }
#endif
    return (cli_close (info->cli, info->fnum) == True) ? 0 : -1;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_errno (struct vfs_class *me)
{
    (void) me;

    DEBUG (3, ("smbfs_errno: %s\n", unix_error_string (my_errno)));
    return my_errno;
}

/* --------------------------------------------------------------------------------------------- */

static dir_entry *
smbfs_new_dir_entry (const char *name)
{
    static int inode_counter;
    dir_entry *new_entry;
    new_entry = g_new0 (dir_entry, 1);
    new_entry->text = dos_to_unix (g_strdup (name), 1);

    if (first_direntry)
    {
        current_info->entries = new_entry;
        first_direntry = FALSE;
    }
    else
    {
        current_info->current->next = new_entry;
    }
    current_info->current = new_entry;
    new_entry->my_stat.st_ino = inode_counter++;

    return new_entry;
}

/* --------------------------------------------------------------------------------------------- */
/* browse for shares on server */

static void
smbfs_browsing_helper (const char *name, uint32 type, const char *comment, void *state)
{
    const char *typestr = "";
    dir_entry *new_entry = smbfs_new_dir_entry (name);

    (void) state;

    switch (type)
    {
    case STYPE_DISKTREE:
        typestr = "Disk";
        /*      show this as dir        */
        new_entry->my_stat.st_mode =
            (S_IFDIR | S_IRUSR | S_IRGRP | S_IROTH | S_IXUSR | S_IXGRP | S_IXOTH) & myumask;
        break;
    case STYPE_PRINTQ:
        typestr = "Printer";
        break;
    case STYPE_DEVICE:
        typestr = "Device";
        break;
    case STYPE_IPC:
        typestr = "IPC";
        break;
    }
    DEBUG (3, ("\t%-15.15s%-10.10s%s\n", name, typestr, comment));
}

/* --------------------------------------------------------------------------------------------- */

static void
smbfs_loaddir_helper (file_info * finfo, const char *mask, void *entry)
{
    dir_entry *new_entry = (dir_entry *) entry;
    time_t t = finfo->mtime;    /* the time is assumed to be passed as GMT */

    (void) mask;

#if 0                           /* I want to see dot files */
    if (finfo->mode & aHIDDEN)
        return;                 /* don't bother with hidden files, "~$" screws up mc */
#endif
    if (!entry)
        new_entry = smbfs_new_dir_entry (finfo->name);

    new_entry->my_stat.st_size = finfo->size;
    new_entry->my_stat.st_mtime = finfo->mtime;
    new_entry->my_stat.st_atime = finfo->atime;
    new_entry->my_stat.st_ctime = finfo->ctime;
    new_entry->my_stat.st_uid = finfo->uid;
    new_entry->my_stat.st_gid = finfo->gid;

    new_entry->my_stat.st_mode =        /*  rw-rw-rw */
        S_IRUSR | S_IRGRP | S_IROTH | S_IWUSR | S_IWGRP | S_IWOTH;

    /*  if (finfo->mode & aVOLID);   nothing similar in real world */
    if (finfo->mode & aDIR)
        new_entry->my_stat.st_mode |=   /* drwxrwxrwx */
            S_IFDIR | S_IXUSR | S_IXGRP | S_IXOTH;
    else
        new_entry->my_stat.st_mode |= S_IFREG;  /* if not dir, regular file? */
    /*  if (finfo->mode & aARCH);   DOS archive     */
    /*  if (finfo->mode & aHIDDEN); like a dot file? */
    /*  if (finfo->mode & aSYSTEM); like a kernel? */
    if (finfo->mode & aRONLY)
        new_entry->my_stat.st_mode &= ~(S_IWUSR | S_IWGRP | S_IWOTH);
    new_entry->my_stat.st_mode &= myumask;

    DEBUG (entry ? 3 : 6, ("  %-30s%7.7s%8.0f  %s",
                           CNV_LANG (finfo->name),
                           attrib_string (finfo->mode),
                           (double) finfo->size, asctime (LocalTime (&t))));
}

/* --------------------------------------------------------------------------------------------- */
/* takes "/foo/bar/file" and gives malloced "\\foo\\bar\\file" */

static char *
smbfs_convert_path (const char *remote_file, gboolean trailing_asterik)
{
    const char *p, *my_remote;
    char *result;

    my_remote = remote_file;
    if (strncmp (my_remote, URL_HEADER, HEADER_LEN) == 0)
    {                           /* if passed directly */
        my_remote += HEADER_LEN;
        if (*my_remote == '/')  /* from server browsing */
            my_remote++;
        p = strchr (my_remote, '/');
        if (p)
            my_remote = p + 1;  /* advance to end of server name */
    }

    if (*my_remote == '/')
        my_remote++;            /* strip off leading '/' */
    p = strchr (my_remote, '/');
    if (p)
        my_remote = p;          /* strip off share/service name */
    /* create remote filename as understood by smb clientgen */
    result = g_strconcat (my_remote, trailing_asterik ? "/*" : "", (char *) NULL);
    unix_to_dos (result, /* inplace = */ 1);    /* code page conversion */
    str_replace (result, '/', '\\');
    return result;
}

/* --------------------------------------------------------------------------------------------- */

static void
smbfs_srv_browsing_helper (const char *name, uint32 m, const char *comment, void *state)
{
    dir_entry *new_entry = smbfs_new_dir_entry (name);

    (void) m;
    (void) state;

    /* show this as dir */
    new_entry->my_stat.st_mode =
        (S_IFDIR | S_IRUSR | S_IRGRP | S_IROTH | S_IXUSR | S_IXGRP | S_IXOTH) & myumask;

    DEBUG (3, ("\t%-16.16s     %s\n", name, comment));
}

/* --------------------------------------------------------------------------------------------- */

static BOOL
smbfs_reconnect (smbfs_connection * conn, int *retries)
{
    char *host;
    DEBUG (3, ("RECONNECT\n"));

    if (*(conn->host) == 0)
        host = g_strdup (conn->cli->desthost);  /* server browsing */
    else
        host = g_strdup (conn->host);

    cli_shutdown (conn->cli);

    if (!(conn->cli = smbfs_do_connect (host, conn->service)))
    {
        message (D_ERROR, MSG_ERROR, _("reconnect to %s failed"), conn->host);
        g_free (host);
        return False;
    }
    g_free (host);
    if (++(*retries) == 2)
        return False;
    return True;
}

/* --------------------------------------------------------------------------------------------- */

static BOOL
smbfs_send (struct cli_state *cli)
{
    size_t len;
    size_t nwritten = 0;
    ssize_t ret;

    len = smb_len (cli->outbuf) + 4;

    while (nwritten < len)
    {
        ret = write_socket (cli->fd, cli->outbuf + nwritten, len - nwritten);
        if (ret <= 0)
        {
            if (errno == EPIPE)
                return False;
        }
        else
            nwritten += ret;
    }

    return True;
}

/* --------------------------------------------------------------------------------------------- */
/****************************************************************************
See if server has cut us off by checking for EPIPE when writing.
Taken from cli_chkpath()
****************************************************************************/

static BOOL
smbfs_chkpath (struct cli_state *cli, const char *path, BOOL send_only)
{
    fstring path2;
    char *p;

    fstrcpy (path2, path);
    unix_to_dos (path2, 1);
    trim_string (path2, NULL, "\\");
    if (!*path2)
        *path2 = '\\';

    memset (cli->outbuf, '\0', smb_size);
    set_message (cli->outbuf, 0, 4 + strlen (path2), True);
    SCVAL (cli->outbuf, smb_com, SMBchkpth);
    SSVAL (cli->outbuf, smb_tid, cli->cnum);

    cli->rap_error = 0;
    cli->nt_error = 0;
    SSVAL (cli->outbuf, smb_pid, cli->pid);
    SSVAL (cli->outbuf, smb_uid, cli->vuid);
    SSVAL (cli->outbuf, smb_mid, cli->mid);
    if (cli->protocol > PROTOCOL_CORE)
    {
        SCVAL (cli->outbuf, smb_flg, 0x8);
        SSVAL (cli->outbuf, smb_flg2, 0x1);
    }

    p = smb_buf (cli->outbuf);
    *p++ = 4;
    fstrcpy (p, path2);

    if (!smbfs_send (cli))
    {
        DEBUG (3, ("smbfs_chkpath: couldnt send\n"));
        return False;
    }
    if (send_only)
    {
        client_receive_smb (cli->fd, cli->inbuf, cli->timeout);
        DEBUG (3, ("smbfs_chkpath: send only OK\n"));
        return True;            /* just testing for EPIPE */
    }
    if (!client_receive_smb (cli->fd, cli->inbuf, cli->timeout))
    {
        DEBUG (3, ("smbfs_chkpath: receive error\n"));
        return False;
    }
    if ((my_errno = cli_error (cli, NULL, NULL, NULL)))
    {
        if (my_errno == 20 || my_errno == 13)
            return True;        /* ignore if 'not a directory' error */
        DEBUG (3, ("smbfs_chkpath: cli_error: %s\n", unix_error_string (my_errno)));
        return False;
    }

    return True;
}

/* --------------------------------------------------------------------------------------------- */

#if 1
static int
smbfs_fs (const char *text)
{
    const char *p = text;
    int count = 0;

    while ((p = strchr (p, '/')) != NULL)
    {
        count++;
        p++;
    }
    if (count == 1)
        return strlen (text);
    return count;
}
#endif

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_loaddir (opendir_info * smbfs_info)
{
    uint16 attribute = aDIR | aSYSTEM | aHIDDEN;
    int servlen = strlen (smbfs_info->conn->service);
    const char *info_dirname = smbfs_info->dirname;
    char *my_dirname;

    DEBUG (3, ("smbfs_loaddir: dirname:%s\n", info_dirname));
    first_direntry = TRUE;

    if (current_info)
    {
        DEBUG (3, ("smbfs_loaddir: new:'%s', cached:'%s'\n", info_dirname, current_info->dirname));
        /* if new desired dir is longer than cached in current_info */
        if (smbfs_fs (info_dirname) > smbfs_fs (current_info->dirname))
        {
            DEBUG (3, ("saving to previous_info\n"));
            previous_info = current_info;
        }
    }

    current_info = smbfs_info;

    if (strcmp (info_dirname, "/") == 0)
    {
        if (!strcmp (smbfs_info->path, URL_HEADER))
        {
            DEBUG (6, ("smbfs_loaddir: browsing %s\n", IPC));
            /* browse for servers */
            if (!cli_NetServerEnum
                (smbfs_info->conn->cli, smbfs_info->conn->domain,
                 SV_TYPE_ALL, smbfs_srv_browsing_helper, NULL))
                return 0;
            else
                current_server_info = smbfs_info;
            smbfs_info->server_list = TRUE;
        }
        else
        {
            /* browse for shares */
            if (cli_RNetShareEnum (smbfs_info->conn->cli, smbfs_browsing_helper, NULL) < 1)
                return 0;
            else
                current_share_info = smbfs_info;
        }
        goto done;
    }

    /* do regular directory listing */
    if (strncmp (smbfs_info->conn->service, info_dirname + 1, servlen) == 0)
    {
        /* strip share name from dir */
        my_dirname = g_strdup (info_dirname + servlen);
        *my_dirname = '/';
        my_dirname = free_after (smbfs_convert_path (my_dirname, TRUE), my_dirname);
    }
    else
        my_dirname = smbfs_convert_path (info_dirname, TRUE);

    DEBUG (6, ("smbfs_loaddir: service: %s\n", smbfs_info->conn->service));
    DEBUG (6, ("smbfs_loaddir: cli->share: %s\n", smbfs_info->conn->cli->share));
    DEBUG (6, ("smbfs_loaddir: calling cli_list with mask %s\n", my_dirname));
    /* do file listing: cli_list returns number of files */
    if (cli_list (smbfs_info->conn->cli, my_dirname, attribute, smbfs_loaddir_helper, NULL) < 0)
    {
        /* cli_list returns -1 if directory empty or cannot read socket */
        my_errno = cli_error (smbfs_info->conn->cli, NULL, &err, NULL);
        g_free (my_dirname);
        return 0;
    }
    if (*(my_dirname) == 0)
        smbfs_info->dirname = smbfs_info->conn->service;
    g_free (my_dirname);
    /*      do_dskattr();   */

  done:
    /*      current_info->parent = smbfs_info->dirname;     */

    smbfs_info->current = smbfs_info->entries;
    return 1;                   /* 1 = ok */
}

/* --------------------------------------------------------------------------------------------- */

#ifdef SMBFS_FREE_DIR
static void
smbfs_free_dir (dir_entry * de)
{
    if (!de)
        return;

    smbfs_free_dir (de->next);
    g_free (de->text);
    g_free (de);
}
#endif

/* --------------------------------------------------------------------------------------------- */
/* The readdir routine loads the complete directory */
/* It's too slow to ask the server each time */
/* It now also sends the complete lstat information for each file */

static void *
smbfs_readdir (void *info)
{
    static union vfs_dirent smbfs_readdir_data;
    static char *const dirent_dest = smbfs_readdir_data.dent.d_name;
    opendir_info *smbfs_info = (opendir_info *) info;

    DEBUG (4, ("smbfs_readdir(%s)\n", smbfs_info->dirname));

    if (!smbfs_info->entries)
        if (!smbfs_loaddir (smbfs_info))
            return NULL;

    if (smbfs_info->current == 0)
    {                           /* reached end of dir entries */
        DEBUG (3, ("smbfs_readdir: smbfs_info->current = 0\n"));
#ifdef	SMBFS_FREE_DIR
        smbfs_free_dir (smbfs_info->entries);
        smbfs_info->entries = 0;
#endif
        return NULL;
    }
    g_strlcpy (dirent_dest, smbfs_info->current->text, MC_MAXPATHLEN);
    smbfs_info->current = smbfs_info->current->next;

    compute_namelen (&smbfs_readdir_data.dent);

    return &smbfs_readdir_data;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_closedir (void *info)
{
    opendir_info *smbfs_info = (opendir_info *) info;
    /*    dir_entry *p, *q; */

    DEBUG (3, ("smbfs_closedir(%s)\n", smbfs_info->dirname));
    /*      CLOSE HERE */

    /*    for (p = smbfs_info->entries; p;){
       q = p;
       p = p->next;
       g_free (q->text);
       g_free (q);
       }
       g_free (info);       */
    return 0;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_chmod (struct vfs_class *me, const char *path, int mode)
{
    (void) me;

    DEBUG (3, ("smbfs_chmod(path:%s, mode:%d)\n", path, mode));
    /*      my_errno = EOPNOTSUPP;
       return -1;   *//* cannot chmod on smb filesystem */
    return 0;                   /* make mc happy */
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_chown (struct vfs_class *me, const char *path, uid_t owner, gid_t group)
{
    (void) me;

    DEBUG (3, ("smbfs_chown(path:%s, owner:%d, group:%d)\n", path, owner, group));
    my_errno = EOPNOTSUPP;      /* ready for your labotomy? */
    return -1;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_utime (struct vfs_class *me, const char *path, struct utimbuf *times)
{
    (void) me;
    (void) times;

    DEBUG (3, ("smbfs_utime(path:%s)\n", path));
    my_errno = EOPNOTSUPP;
    return -1;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_readlink (struct vfs_class *me, const char *path, char *buf, size_t size)
{
    (void) me;

    DEBUG (3, ("smbfs_readlink(path:%s, buf:%s, size:%zu)\n", path, buf, size));
    my_errno = EOPNOTSUPP;
    return -1;                  /* no symlinks on smb filesystem? */
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_symlink (struct vfs_class *me, const char *n1, const char *n2)
{
    (void) me;

    DEBUG (3, ("smbfs_symlink(n1:%s, n2:%s)\n", n1, n2));
    my_errno = EOPNOTSUPP;
    return -1;                  /* no symlinks on smb filesystem? */
}

/* --------------------------------------------------------------------------------------------- */
/*****************************************************
        return a connection to a SMB server
        current_bucket needs to be set before calling
*******************************************************/

static struct cli_state *
smbfs_do_connect (const char *server, char *share)
{
    struct cli_state *c;
    struct nmb_name called, calling;
    struct in_addr ip;

    DEBUG (3, ("smbfs_do_connect(%s, %s)\n", server, share));
    if (*share == '\\')
    {
        server = share + 2;
        share = strchr (server, '\\');
        if (!share)
            return NULL;
        *share = 0;
        share++;
    }

    make_nmb_name (&calling, global_myname, 0x0);
    make_nmb_name (&called, server, current_bucket->name_type);

    for (;;)
    {

        ip = (current_bucket->have_ip) ? current_bucket->dest_ip : ipzero;

        /* have to open a new connection */
        if (!(c = cli_initialise (NULL)))
        {
            my_errno = ENOMEM;
            return NULL;
        }

        pwd_init (&(c->pwd));   /* should be moved into cli_initialise()? */
        pwd_set_cleartext (&(c->pwd), current_bucket->password);

        if ((cli_set_port (c, current_bucket->port) == 0) || !cli_connect (c, server, &ip))
        {
            DEBUG (1, ("Connection to %s failed\n", server));
            break;
        }

        if (!cli_session_request (c, &calling, &called))
        {
            my_errno = cli_error (c, NULL, &err, NULL);
            DEBUG (1, ("session request to %s failed\n", called.name));
            cli_shutdown (c);
            if (strcmp (called.name, "*SMBSERVER"))
            {
                make_nmb_name (&called, "*SMBSERVER", 0x20);
                continue;
            }
            return NULL;
        }

        DEBUG (3, (" session request ok\n"));

        if (!cli_negprot (c))
        {
            DEBUG (1, ("protocol negotiation failed\n"));
            break;
        }

        if (!cli_session_setup (c, current_bucket->user,
                                current_bucket->password, strlen (current_bucket->password),
                                current_bucket->password, strlen (current_bucket->password),
                                current_bucket->domain))
        {
            DEBUG (1, ("session setup failed: %s\n", cli_errstr (c)));
            smbfs_auth_remove (server, share);
            break;
        }

        if (*c->server_domain || *c->server_os || *c->server_type)
            DEBUG (5, ("Domain=[%s] OS=[%s] Server=[%s]\n",
                       c->server_domain, c->server_os, c->server_type));

        DEBUG (3, (" session setup ok\n"));

        if (!cli_send_tconX (c, share, "?????",
                             current_bucket->password, strlen (current_bucket->password) + 1))
        {
            DEBUG (1, ("%s: tree connect failed: %s\n", share, cli_errstr (c)));
            break;
        }

        DEBUG (3, (" tconx ok\n"));

        my_errno = 0;
        return c;
    }

    my_errno = cli_error (c, NULL, &err, NULL);
    cli_shutdown (c);
    return NULL;

}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_get_master_browser (char **host)
{
    static char so_broadcast[] = "SO_BROADCAST";
    int count;
    struct in_addr *ip_list, bcast_addr;

    /* does port = 137 for win95 master browser? */
    int fd = open_socket_in (SOCK_DGRAM, 0, 3,
                             interpret_addr (lp_socket_address ()), True);
    if (fd == -1)
        return 0;
    set_socket_options (fd, so_broadcast);
    ip_list = iface_bcast (ipzero);
    bcast_addr = *ip_list;
    if ((ip_list = name_query (fd, "\01\02__MSBROWSE__\02", 1, True,
                               True, bcast_addr, &count, NULL)))
    {
        if (!count)
            return 0;
        /* just return first master browser */
        *host = g_strdup (inet_ntoa (ip_list[0]));
        return 1;
    }
    return 0;
}

/* --------------------------------------------------------------------------------------------- */

static void
smbfs_free_bucket (smbfs_connection * bucket)
{
    g_free (bucket->host);
    g_free (bucket->service);
    g_free (bucket->domain);
    g_free (bucket->user);
    wipe_password (bucket->password);
    g_free (bucket->home);
    memset (bucket, 0, sizeof (smbfs_connection));
}

/* --------------------------------------------------------------------------------------------- */

static smbfs_connection *
smbfs_get_free_bucket (void)
{
    int i;

    for (i = 0; i < SMBFS_MAX_CONNECTIONS; i++)
        if (!smbfs_connections[i].cli)
            return &smbfs_connections[i];

    {                           /* search for most dormant connection */
        int oldest = 0;         /* index */
        time_t oldest_time = smbfs_connections[0].last_use;
        for (i = 1; i < SMBFS_MAX_CONNECTIONS; i++)
        {
            if (smbfs_connections[i].last_use < oldest_time)
            {
                oldest_time = smbfs_connections[i].last_use;
                oldest = i;
            }
        }
        cli_shutdown (smbfs_connections[oldest].cli);
        smbfs_free_bucket (&smbfs_connections[oldest]);
        return &smbfs_connections[oldest];
    }

    /* This can't happend, since we have checked for max connections before */
    vfs_die ("Internal error: smbfs_get_free_bucket");
    return 0;                   /* shut up, stupid gcc */
}

/* --------------------------------------------------------------------------------------------- */
/* This routine keeps track of open connections */
/* Returns a connected socket to host */

static smbfs_connection *
smbfs_open_link (char *host, char *path, const char *user, int *port, char *this_pass)
{
    int i;
    smbfs_connection *bucket;
    pstring service;
    struct in_addr *dest_ip = NULL;

    DEBUG (3, ("smbfs_open_link(host:%s, path:%s)\n", host, path));

    if (strcmp (host, path) == 0)       /* if host & path are same: */
        pstrcpy (service, IPC); /* setup for browse */
    else
    {                           /* get share name from path, path starts with server name */
        char *p;
        if ((p = strchr (path, '/')))   /* get share aka                            */
            pstrcpy (service, ++p);     /* service name from path               */
        else
            pstrcpy (service, "");
        /* now check for trailing directory/filenames   */
        p = strchr (service, '/');
        if (p)
            *p = 0;             /* cut off dir/files: sharename only */
        if (!*service)
            pstrcpy (service, IPC);     /* setup for browse */
        DEBUG (6, ("smbfs_open_link: service from path:%s\n", service));
    }

    if (got_user)
        user = username;        /* global from getenv */

    /* Is the link actually open? */
    for (i = 0; i < SMBFS_MAX_CONNECTIONS; i++)
    {
        if (!smbfs_connections[i].cli)
            continue;
        if ((strcmp (host, smbfs_connections[i].host) == 0) &&
            (strcmp (user, smbfs_connections[i].user) == 0) &&
            (strcmp (service, smbfs_connections[i].service) == 0))
        {
            int retries = 0;
            BOOL inshare = (*host != 0 && *path != 0 && strchr (path, '/'));
            /* check if this connection has died */
            while (!smbfs_chkpath (smbfs_connections[i].cli, "\\", !inshare))
            {
                if (!smbfs_reconnect (&smbfs_connections[i], &retries))
                    return 0;
            }
            DEBUG (6, ("smbfs_open_link: returning smbfs_connection[%d]\n", i));
            current_bucket = &smbfs_connections[i];
            smbfs_connections[i].last_use = time (NULL);
            return &smbfs_connections[i];
        }
        /* connection not found, find if we have ip for new connection */
        if (strcmp (host, smbfs_connections[i].host) == 0)
            dest_ip = &smbfs_connections[i].cli->dest_ip;
    }

    /* make new connection */
    bucket = smbfs_get_free_bucket ();
    bucket->name_type = 0x20;
    bucket->home = 0;
    bucket->port = *port;
    bucket->have_ip = False;
    if (dest_ip)
    {
        bucket->have_ip = True;
        bucket->dest_ip = *dest_ip;
    }
    current_bucket = bucket;

    bucket->user = g_strdup (user);
    bucket->service = g_strdup (service);

    if (!(*host))
    {                           /* if blank host name, browse for servers */
        if (!smbfs_get_master_browser (&host))  /* set host to ip of master browser */
            return 0;           /* could not find master browser? */
        g_free (host);
        bucket->host = g_strdup ("");   /* blank host means master browser */
    }
    else
        bucket->host = g_strdup (host);

    if (!smbfs_bucket_set_authinfo (bucket, 0,  /* domain currently not used */
                                    user, this_pass, 1))
        return 0;

    /* connect to share */
    while (!(bucket->cli = smbfs_do_connect (host, service)))
    {

        if (my_errno != EPERM)
            return 0;
        message (D_ERROR, MSG_ERROR, _("Authentication failed"));

        /* authentication failed, try again */
        smbfs_auth_remove (bucket->host, bucket->service);
        if (!smbfs_bucket_set_authinfo (bucket, bucket->domain, bucket->user, 0, 0))
            return 0;

    }

    smbfs_open_connections++;
    DEBUG (3, ("smbfs_open_link:smbfs_open_connections: %d\n", smbfs_open_connections));
    return bucket;
}

/* --------------------------------------------------------------------------------------------- */

static char *
smbfs_get_path (smbfs_connection ** sc, const char *path)
{
    char *user, *host, *remote_path, *pass;
    int port = SMB_PORT;

    DEBUG (3, ("smbfs_get_path(%s)\n", path));
    if (strncmp (path, URL_HEADER, HEADER_LEN))
        return NULL;
    path += HEADER_LEN;

    if (*path == '/')           /* '/' leading server name */
        path++;                 /* probably came from server browsing */

    if ((remote_path = smbfs_get_host_and_username (&path, &host, &user, &port, &pass)))
        if ((*sc = smbfs_open_link (host, remote_path, user, &port, pass)) == NULL)
        {
            g_free (remote_path);
            remote_path = NULL;
        }
    g_free (host);
    g_free (user);
    if (pass)
        wipe_password (pass);

    if (!remote_path)
        return NULL;

    /* NOTE: tildes are deprecated. See ftpfs.c */
    {
        int f = !strcmp (remote_path, "/~");
        if (f || !strncmp (remote_path, "/~/", 3))
        {
            char *s;
            s = concat_dir_and_file ((*sc)->home, remote_path + 3 - f);
            g_free (remote_path);
            return s;
        }
    }
    return remote_path;
}

/* --------------------------------------------------------------------------------------------- */

#if 0
static int
is_error (int result, int errno_num)
{
    if (!(result == -1))
        return my_errno = 0;
    else
        my_errno = errno_num;
    return 1;
}
#endif

/* --------------------------------------------------------------------------------------------- */

static void *
smbfs_opendir (struct vfs_class *me, const char *dirname)
{
    opendir_info *smbfs_info;
    smbfs_connection *sc;
    char *remote_dir;

    (void) me;

    DEBUG (3, ("smbfs_opendir(dirname:%s)\n", dirname));

    if (!(remote_dir = smbfs_get_path (&sc, dirname)))
        return NULL;

    /* FIXME: where freed? */
    smbfs_info = g_new (opendir_info, 1);
    smbfs_info->server_list = FALSE;
    smbfs_info->path = g_strdup (dirname);      /* keep original */
    smbfs_info->dirname = remote_dir;
    smbfs_info->conn = sc;
    smbfs_info->entries = 0;
    smbfs_info->current = 0;

    return smbfs_info;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_fake_server_stat (const char *server_url, const char *path, struct stat *buf)
{
    dir_entry *dentry;
    const char *p;

    (void) server_url;

    if ((p = strrchr (path, '/')))
        path = p + 1;           /* advance until last '/' */

    if (!current_info->entries)
    {
        if (!smbfs_loaddir (current_info))      /* browse host */
            return -1;
    }

    if (current_info->server_list == True)
    {
        dentry = current_info->entries;
        DEBUG (4, ("fake stat for SERVER \"%s\"\n", path));
        while (dentry)
        {
            if (strcmp (dentry->text, path) == 0)
            {
                DEBUG (4, ("smbfs_fake_server_stat: %s:%4o\n",
                           dentry->text, (int) dentry->my_stat.st_mode));
                memcpy (buf, &dentry->my_stat, sizeof (struct stat));
                return 0;
            }
            dentry = dentry->next;
        }
    }
    my_errno = ENOENT;
    return -1;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_fake_share_stat (const char *server_url, const char *path, struct stat *buf)
{
    dir_entry *dentry;
    if (strlen (path) < strlen (server_url))
        return -1;

    if (!current_share_info)
    {                           /* Server was not stat()ed */
        /* Make sure there is such share at server */
        smbfs_connection *sc;
        char *p;
        p = smbfs_get_path (&sc, path);
        g_free (p);
        if (p)
        {
            memset (buf, 0, sizeof (*buf));
            /*      show this as dir        */
            buf->st_mode =
                (S_IFDIR | S_IRUSR | S_IRGRP | S_IROTH | S_IXUSR | S_IXGRP | S_IXOTH) & myumask;
            return 0;
        }
        return -1;
    }

    path += strlen (server_url);        /* we only want share name */
    path++;

    if (*path == '/')           /* '/' leading server name */
        path++;                 /* probably came from server browsing */

    if (!current_share_info->entries)
    {
        if (!smbfs_loaddir (current_share_info))        /* browse host */
            return -1;
    }
    dentry = current_share_info->entries;
    DEBUG (3, ("smbfs_fake_share_stat: %s on %s\n", path, server_url));
    while (dentry)
    {
        if (strcmp (dentry->text, path) == 0)
        {
            DEBUG (6, ("smbfs_fake_share_stat: %s:%4o\n",
                       dentry->text, (int) dentry->my_stat.st_mode));
            memcpy (buf, &dentry->my_stat, sizeof (struct stat));
            return 0;
        }
        dentry = dentry->next;
    }
    my_errno = ENOENT;
    return -1;
}

/* --------------------------------------------------------------------------------------------- */
/* stat a single file */

static int
smbfs_get_remote_stat (smbfs_connection * sc, const char *path, struct stat *buf)
{
    uint16 attribute = aDIR | aSYSTEM | aHIDDEN;
    char *mypath;

    DEBUG (3, ("smbfs_get_remote_stat(): mypath:%s\n", path));

    mypath = smbfs_convert_path (path, FALSE);

#if 0                           /* single_entry is never free()d now.  And only my_stat is used */
    single_entry = g_new (dir_entry, 1);

    single_entry->text = dos_to_unix (g_strdup (finfo->name), 1);

    single_entry->next = 0;
#endif
    if (!single_entry)
        single_entry = g_new0 (dir_entry, 1);

    if (cli_list (sc->cli, mypath, attribute, smbfs_loaddir_helper, single_entry) < 1)
    {
        my_errno = ENOENT;
        g_free (mypath);
        return -1;              /* cli_list returns number of files */
    }

    memcpy (buf, &single_entry->my_stat, sizeof (struct stat));

    /* don't free here, use for smbfs_fstat() */
    /*      g_free(single_entry->text);
       g_free(single_entry);        */
    g_free (mypath);
    return 0;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_search_dir_entry (dir_entry * dentry, const char *text, struct stat *buf)
{
    while (dentry)
    {
        if (strcmp (text, dentry->text) == 0)
        {
            memcpy (buf, &dentry->my_stat, sizeof (struct stat));
            memcpy (&single_entry->my_stat, &dentry->my_stat, sizeof (struct stat));
            return 0;
        }
        dentry = dentry->next;
    }
    return -1;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_get_stat_info (smbfs_connection * sc, const char *path, struct stat *buf)
{
    char *p;
#if 0
    dir_entry *dentry = current_info->entries;
#endif
    const char *mypath = path;

    mypath++;                   /* cut off leading '/' */
    if ((p = strrchr (mypath, '/')))
        mypath = p + 1;         /* advance until last file/dir name */
    DEBUG (3, ("smbfs_get_stat_info: mypath:%s, current_info->dirname:%s\n",
               mypath, current_info->dirname));
#if 0
    if (!dentry)
    {
        DEBUG (1, ("No dir entries (empty dir) cached:'%s', wanted:'%s'\n",
                   current_info->dirname, path));
        return -1;
    }
#endif
    if (!single_entry)          /* when found, this will be written too */
        single_entry = g_new (dir_entry, 1);
    if (smbfs_search_dir_entry (current_info->entries, mypath, buf) == 0)
    {
        return 0;
    }
    /* now try to identify mypath as PARENT dir */
    {
        char *mdp;
        char *mydir;
        mdp = mydir = g_strdup (current_info->dirname);
        if ((p = strrchr (mydir, '/')))
            *p = 0;             /* advance util last '/' */
        if ((p = strrchr (mydir, '/')))
            mydir = p + 1;      /* advance util last '/' */
        if (strcmp (mydir, mypath) == 0)
        {                       /* fake a stat for ".." */
            memset (buf, 0, sizeof (struct stat));
            buf->st_mode = (S_IFDIR | S_IRUSR | S_IRGRP | S_IROTH) & myumask;
            memcpy (&single_entry->my_stat, buf, sizeof (struct stat));
            g_free (mdp);
            DEBUG (1, ("	PARENT:found in %s\n", current_info->dirname));
            return 0;
        }
        g_free (mdp);
    }
    /* now try to identify as CURRENT dir? */
    {
        char *dnp = current_info->dirname;
        DEBUG (6, ("smbfs_get_stat_info: is %s current dir? this dir is: %s\n",
                   mypath, current_info->dirname));
        if (*dnp == '/')
            dnp++;
        else
        {
            return -1;
        }
        if (strcmp (mypath, dnp) == 0)
        {
            memset (buf, 0, sizeof (struct stat));
            buf->st_mode = (S_IFDIR | S_IRUSR | S_IRGRP | S_IROTH) & myumask;
            memcpy (&single_entry->my_stat, buf, sizeof (struct stat));
            DEBUG (1, ("	CURRENT:found in %s\n", current_info->dirname));
            return 0;
        }
    }
    DEBUG (3, ("'%s' not found in current_info '%s'\n", path, current_info->dirname));
    /* try to find this in the PREVIOUS listing */
    if (previous_info)
    {
        if (smbfs_search_dir_entry (previous_info->entries, mypath, buf) == 0)
            return 0;
        DEBUG (3, ("'%s' not found in previous_info '%s'\n", path, previous_info->dirname));
    }
    /* try to find this in the SHARE listing */
    if (current_share_info)
    {
        if (smbfs_search_dir_entry (current_share_info->entries, mypath, buf) == 0)
            return 0;
        DEBUG (3, ("'%s' not found in share_info '%s'\n", path, current_share_info->dirname));
    }
    /* try to find this in the SERVER listing */
    if (current_server_info)
    {
        if (smbfs_search_dir_entry (current_server_info->entries, mypath, buf) == 0)
            return 0;
        DEBUG (3, ("'%s' not found in server_info '%s'\n", path, current_server_info->dirname));
    }
    /* nothing found. get stat file info from server */
    return smbfs_get_remote_stat (sc, path, buf);
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_chdir (struct vfs_class *me, const char *path)
{
    char *remote_dir;
    smbfs_connection *sc;

    (void) me;

    DEBUG (3, ("smbfs_chdir(path:%s)\n", path));
    if (!(remote_dir = smbfs_get_path (&sc, path)))
        return -1;
    g_free (remote_dir);

    return 0;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_loaddir_by_name (struct vfs_class *me, const char *path)
{
    void *info;
    char *mypath, *p;

    mypath = g_strdup (path);
    p = strrchr (mypath, '/');

    if (p > mypath)
        *p = 0;
    DEBUG (6, ("smbfs_loaddir_by_name(%s)\n", mypath));
    smbfs_chdir (me, mypath);
    info = smbfs_opendir (me, mypath);
    g_free (mypath);
    if (!info)
        return -1;
    smbfs_readdir (info);
    smbfs_loaddir (info);
    return 0;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_stat (struct vfs_class *me, const char *path, struct stat *buf)
{
    smbfs_connection *sc;
    pstring server_url;
    char *service, *pp, *at;
    const char *p;

    DEBUG (3, ("smbfs_stat(path:%s)\n", path));

    if (!current_info)
    {
        DEBUG (1, ("current_info = NULL: "));
        if (smbfs_loaddir_by_name (me, path) < 0)
            return -1;
    }

    /* check if stating server */
    p = path;
    if (strncmp (p, URL_HEADER, HEADER_LEN))
    {
        DEBUG (1, ("'%s' doesnt start with '%s' (length %d)\n", p, URL_HEADER, HEADER_LEN));
        return -1;
    }

    p += HEADER_LEN;
    if (*p == '/')
        p++;

    pp = strchr (p, '/');       /* advance past next '/' */
    at = strchr (p, '@');
    pstrcpy (server_url, URL_HEADER);
    if (at && at < pp)
    {                           /* user@server */
        char *z = &(server_url[sizeof (server_url) - 1]);
        const char *s = p;

        at = &(server_url[HEADER_LEN]) + (at - p + 1);
        if (z > at)
            z = at;
        at = &(server_url[HEADER_LEN]);
        while (at < z)
            *at++ = *s++;
        *z = 0;
    }
    pstrcat (server_url, current_bucket->host);

    if (!pp)
    {
        if (!current_info->server_list)
        {
            if (smbfs_loaddir_by_name (me, path) < 0)
                return -1;
        }
        return smbfs_fake_server_stat (server_url, path, buf);
    }

    if (!strchr (++pp, '/'))
    {
        return smbfs_fake_share_stat (server_url, path, buf);
    }

    /* stating inside share at this point */
    if (!(service = smbfs_get_path (&sc, path)))        /* connects if necessary */
        return -1;
    {
        int hostlen = strlen (current_bucket->host);
        char *ppp = service + strlen (service) - hostlen;
        char *sp = server_url + strlen (server_url) - hostlen;

        if (strcmp (sp, ppp) == 0)
        {
            /* make server name appear as directory */
            DEBUG (1, ("smbfs_stat: showing server as directory\n"));
            memset (buf, 0, sizeof (struct stat));
            buf->st_mode = (S_IFDIR | S_IRUSR | S_IRGRP | S_IROTH) & myumask;
            g_free (service);
            return 0;
        }
    }
    /* check if current_info is in share requested */
    p = service;
    pp = strchr (p, '/');
    if (pp)
    {
        p = ++pp;               /* advance past server name */
        pp = strchr (p, '/');
    }
    if (pp)
        *pp = 0;                /* cut off everthing after service name */
    else
        p = IPC;                /* browsing for services */
    pp = current_info->dirname;
    if (*pp == '/')
        pp++;
    if (strncmp (p, pp, strlen (p)) != 0)
    {
        DEBUG (6, ("desired '%s' is not loaded, we have '%s'\n", p, pp));
        if (smbfs_loaddir_by_name (me, path) < 0)
        {
            g_free (service);
            return -1;
        }
        DEBUG (6, ("loaded dir: '%s'\n", current_info->dirname));
    }
    g_free (service);
    /* stat dirs & files under shares now */
    return smbfs_get_stat_info (sc, path, buf);
}

/* --------------------------------------------------------------------------------------------- */

static off_t
smbfs_lseek (void *data, off_t offset, int whence)
{
    smbfs_handle *info = (smbfs_handle *) data;
    size_t size;

    DEBUG (3,
           ("smbfs_lseek(info->nread => %d, offset => %d, whence => %d) \n",
            (int) info->nread, (int) offset, whence));

    switch (whence)
    {
    case SEEK_SET:
        info->nread = offset;
        break;
    case SEEK_CUR:
        info->nread += offset;
        break;
    case SEEK_END:
        if (!cli_qfileinfo (info->cli, info->fnum,
                            NULL, &size, NULL, NULL, NULL,
                            NULL, NULL) &&
            !cli_getattrE (info->cli, info->fnum, NULL, &size, NULL, NULL, NULL))
        {
            errno = EINVAL;
            return -1;
        }
        info->nread = size + offset;
        break;
    }

    return info->nread;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_mknod (struct vfs_class *me, const char *path, mode_t mode, dev_t dev)
{
    (void) me;

    DEBUG (3, ("smbfs_mknod(path:%s, mode:%d, dev:%u)\n", path, mode, (unsigned int) dev));
    my_errno = EOPNOTSUPP;
    return -1;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_mkdir (struct vfs_class *me, const char *path, mode_t mode)
{
    smbfs_connection *sc;
    char *remote_file;
    char *cpath;

    (void) me;

    DEBUG (3, ("smbfs_mkdir(path:%s, mode:%d)\n", path, (int) mode));
    if ((remote_file = smbfs_get_path (&sc, path)) == 0)
        return -1;
    g_free (remote_file);
    cpath = smbfs_convert_path (path, FALSE);

    if (!cli_mkdir (sc->cli, cpath))
    {
        my_errno = cli_error (sc->cli, NULL, &err, NULL);
        message (D_ERROR, MSG_ERROR, _("Error %s creating directory %s"),
                 cli_errstr (sc->cli), CNV_LANG (cpath));
        g_free (cpath);
        return -1;
    }
    g_free (cpath);
    return 0;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_rmdir (struct vfs_class *me, const char *path)
{
    smbfs_connection *sc;
    char *remote_file;
    char *cpath;

    (void) me;

    DEBUG (3, ("smbfs_rmdir(path:%s)\n", path));
    if ((remote_file = smbfs_get_path (&sc, path)) == 0)
        return -1;
    g_free (remote_file);
    cpath = smbfs_convert_path (path, FALSE);

    if (!cli_rmdir (sc->cli, cpath))
    {
        my_errno = cli_error (sc->cli, NULL, &err, NULL);
        message (D_ERROR, MSG_ERROR, _("Error %s removing directory %s"),
                 cli_errstr (sc->cli), CNV_LANG (cpath));
        g_free (cpath);
        return -1;
    }

    g_free (cpath);
    return 0;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_link (struct vfs_class *me, const char *p1, const char *p2)
{
    (void) me;

    DEBUG (3, ("smbfs_link(p1:%s, p2:%s)\n", p1, p2));
    my_errno = EOPNOTSUPP;
    return -1;
}

/* --------------------------------------------------------------------------------------------- */

static void
smbfs_free (vfsid id)
{
    DEBUG (3, ("smbfs_free(%p)\n", id));
    smbfs_auth_free_all ();
}

/* --------------------------------------------------------------------------------------------- */
/* Gives up on a socket and reopens the connection, the child own the socket
 * now
 */

static void
smbfs_forget (const char *path)
{
    char *host, *user, *p;
    int port;

    if (strncmp (path, URL_HEADER, HEADER_LEN))
        return;

    DEBUG (3, ("smbfs_forget(path:%s)\n", path));

    path += 6;
    if (path[0] == '/' && path[1] == '/')
        path += 2;

    if ((p = smbfs_get_host_and_username (&path, &host, &user, &port, NULL)))
    {
        size_t i;

        g_free (p);

        for (i = 0; i < SMBFS_MAX_CONNECTIONS; i++)
        {
            if (smbfs_connections[i].cli
                && (strcmp (host, smbfs_connections[i].host) == 0)
                && (strcmp (user, smbfs_connections[i].user) == 0)
                && (port == smbfs_connections[i].port))
            {

                /* close socket: the child owns it now */
                cli_shutdown (smbfs_connections[i].cli);

                /* reopen the connection */
                smbfs_connections[i].cli = smbfs_do_connect (host, smbfs_connections[i].service);
            }
        }
    }
    g_free (host);
    g_free (user);
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_setctl (struct vfs_class *me, const char *path, int ctlop, void *arg)
{
    (void) me;
    (void) arg;

    DEBUG (3, ("smbfs_setctl(path:%s, ctlop:%d)\n", path, ctlop));
    switch (ctlop)
    {
    case VFS_SETCTL_FORGET:
        smbfs_forget (path);
        return 0;
    }
    return 0;
}

/* --------------------------------------------------------------------------------------------- */

static smbfs_handle *
smbfs_open_readwrite (smbfs_handle * remote_handle, char *rname, int flags, mode_t mode)
{
    size_t size;

    (void) mode;

    if (flags & O_TRUNC)        /* if it exists truncate to zero */
        DEBUG (3, ("smbfs_open: O_TRUNC\n"));

    remote_handle->fnum =
#if 1                           /* Don't play with flags, it is cli_open() headache */
        cli_open (remote_handle->cli, rname, flags, DENY_NONE);
#else /* What's a reasons to has this code ? */
        cli_open (remote_handle->cli, rname, ((flags & O_CREAT)
                                              || (flags ==
                                                  (O_WRONLY | O_APPEND))) ?
                  flags : O_RDONLY, DENY_NONE);
#endif
    if (remote_handle->fnum == -1)
    {
        message (D_ERROR, MSG_ERROR, _("%s opening remote file %s"),
                 cli_errstr (remote_handle->cli), CNV_LANG (rname));
        DEBUG (1, ("smbfs_open(rname:%s) error:%s\n", rname, cli_errstr (remote_handle->cli)));
        my_errno = cli_error (remote_handle->cli, NULL, &err, NULL);
        return NULL;
    }

    if (flags & O_CREAT)
        return remote_handle;

    if (!cli_qfileinfo (remote_handle->cli, remote_handle->fnum,
                        &remote_handle->attr, &size, NULL, NULL, NULL, NULL,
                        NULL)
        && !cli_getattrE (remote_handle->cli, remote_handle->fnum,
                          &remote_handle->attr, &size, NULL, NULL, NULL))
    {
        message (D_ERROR, MSG_ERROR, "getattrib: %s", cli_errstr (remote_handle->cli));
        DEBUG (1, ("smbfs_open(rname:%s) getattrib:%s\n", rname, cli_errstr (remote_handle->cli)));
        my_errno = cli_error (remote_handle->cli, NULL, &err, NULL);
        cli_close (remote_handle->cli, remote_handle->fnum);
        return NULL;
    }

    if ((flags == (O_WRONLY | O_APPEND))        /* file.c:copy_file_file() -> do_append */
        && smbfs_lseek (remote_handle, 0, SEEK_END) == -1)
    {
        cli_close (remote_handle->cli, remote_handle->fnum);
        return NULL;
    }

    return remote_handle;
}

/* --------------------------------------------------------------------------------------------- */

static void *
smbfs_open (struct vfs_class *me, const char *file, int flags, mode_t mode)
{
    char *remote_file;
    void *ret;
    smbfs_connection *sc;
    smbfs_handle *remote_handle;

    (void) me;

    DEBUG (3, ("smbfs_open(file:%s, flags:%d, mode:%o)\n", file, flags, mode));

    if (!(remote_file = smbfs_get_path (&sc, file)))
        return 0;

    remote_file = free_after (smbfs_convert_path (remote_file, FALSE), remote_file);

    remote_handle = g_new (smbfs_handle, 2);
    remote_handle->cli = sc->cli;
    remote_handle->nread = 0;

    ret = smbfs_open_readwrite (remote_handle, remote_file, flags, mode);

    g_free (remote_file);
    if (!ret)
        g_free (remote_handle);

    return ret;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_unlink (struct vfs_class *me, const char *path)
{
    smbfs_connection *sc;
    char *remote_file;

    (void) me;

    if ((remote_file = smbfs_get_path (&sc, path)) == 0)
        return -1;

    remote_file = free_after (smbfs_convert_path (remote_file, FALSE), remote_file);

    if (!cli_unlink (sc->cli, remote_file))
    {
        message (D_ERROR, MSG_ERROR, _("%s removing remote file %s"),
                 cli_errstr (sc->cli), CNV_LANG (remote_file));
        g_free (remote_file);
        return -1;
    }
    g_free (remote_file);
    return 0;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_rename (struct vfs_class *me, const char *a, const char *b)
{
    smbfs_connection *sc;
    char *ra, *rb;
    int retval;

    (void) me;

    if ((ra = smbfs_get_path (&sc, a)) == 0)
        return -1;

    if ((rb = smbfs_get_path (&sc, b)) == 0)
    {
        g_free (ra);
        return -1;
    }

    ra = free_after (smbfs_convert_path (ra, FALSE), ra);
    rb = free_after (smbfs_convert_path (rb, FALSE), rb);

    retval = cli_rename (sc->cli, ra, rb);

    g_free (ra);
    g_free (rb);

    if (!retval)
    {
        message (D_ERROR, MSG_ERROR, _("%s renaming files\n"), cli_errstr (sc->cli));
        return -1;
    }
    return 0;
}

/* --------------------------------------------------------------------------------------------- */

static int
smbfs_fstat (void *data, struct stat *buf)
{
    smbfs_handle *remote_handle = (smbfs_handle *) data;

    DEBUG (3, ("smbfs_fstat(fnum:%d)\n", remote_handle->fnum));

    /* use left over from previous smbfs_get_remote_stat, if available */
    if (single_entry)
        memcpy (buf, &single_entry->my_stat, sizeof (struct stat));
    else
    {                           /* single_entry not set up: bug */
        my_errno = EFAULT;
        return -EFAULT;
    }
    return 0;
}

/* --------------------------------------------------------------------------------------------- */
/*** public functions ****************************************************************************/
/* --------------------------------------------------------------------------------------------- */

smb_authinfo *
vfs_smb_authinfo_new (const char *host, const char *share, const char *domain,
                      const char *user, const char *pass)
{
    smb_authinfo *auth;

    auth = g_try_new (struct smb_authinfo, 1);

    if (auth != NULL)
    {
        auth->host = g_strdup (host);
        auth->share = g_strdup (share);
        auth->domain = g_strdup (domain);
        auth->user = g_strdup (user);
        auth->password = g_strdup (pass);
    }

    return auth;
}

/* --------------------------------------------------------------------------------------------- */

void
init_smbfs (void)
{
    tcp_init ();

    vfs_smbfs_ops.name = "smbfs";
    vfs_smbfs_ops.prefix = "smb:";
    vfs_smbfs_ops.flags = VFSF_NOLINKS;
    vfs_smbfs_ops.init = smbfs_init;
    vfs_smbfs_ops.fill_names = smbfs_fill_names;
    vfs_smbfs_ops.open = smbfs_open;
    vfs_smbfs_ops.close = smbfs_close;
    vfs_smbfs_ops.read = smbfs_read;
    vfs_smbfs_ops.write = smbfs_write;
    vfs_smbfs_ops.opendir = smbfs_opendir;
    vfs_smbfs_ops.readdir = smbfs_readdir;
    vfs_smbfs_ops.closedir = smbfs_closedir;
    vfs_smbfs_ops.stat = smbfs_stat;
    vfs_smbfs_ops.lstat = smbfs_lstat;
    vfs_smbfs_ops.fstat = smbfs_fstat;
    vfs_smbfs_ops.chmod = smbfs_chmod;
    vfs_smbfs_ops.chown = smbfs_chown;
    vfs_smbfs_ops.utime = smbfs_utime;
    vfs_smbfs_ops.readlink = smbfs_readlink;
    vfs_smbfs_ops.symlink = smbfs_symlink;
    vfs_smbfs_ops.link = smbfs_link;
    vfs_smbfs_ops.unlink = smbfs_unlink;
    vfs_smbfs_ops.rename = smbfs_rename;
    vfs_smbfs_ops.chdir = smbfs_chdir;
    vfs_smbfs_ops.ferrno = smbfs_errno;
    vfs_smbfs_ops.lseek = smbfs_lseek;
    vfs_smbfs_ops.mknod = smbfs_mknod;
    vfs_smbfs_ops.free = smbfs_free;
    vfs_smbfs_ops.mkdir = smbfs_mkdir;
    vfs_smbfs_ops.rmdir = smbfs_rmdir;
    vfs_smbfs_ops.setctl = smbfs_setctl;
    vfs_register_class (&vfs_smbfs_ops);
}

/* --------------------------------------------------------------------------------------------- */