fix for #188

[free-mc.git] / 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.  */

/* 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 */
#include "../src/global.h"
#include "../src/tty.h"         /* enable/disable interrupt key */
#include "../src/wtools.h"      /* message() */
#include "../src/main.h"        /* print_vfs_message */
#include "utilvfs.h"

#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 <string.h>

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

#define SMBFS_MAX_CONNECTIONS 16
static const char * const IPC = "IPC$";
static const char * const URL_HEADER = "/#smb:";
#define HEADER_LEN      6

static int my_errno;
static uint32 err;

/* stuff that is same with each connection */
extern int DEBUGLEVEL;
extern pstring myhostname;
extern struct in_addr ipzero;
static mode_t myumask = 0755;
extern pstring global_myname;
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 */

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

typedef struct _smbfs_connection smbfs_connection;
static smbfs_connection *current_bucket;

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

static GSList *auth_list;

/* 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 *password)
{
    struct smb_authinfo *auth = g_new (struct smb_authinfo, 1);
    
    if (!auth)
        return;

    /* Don't check for NULL, g_strdup already does. */
    auth->host = g_strdup (host);
    auth->share = g_strdup (share);
    auth->domain = g_strdup (domain);
    auth->user = g_strdup (user);
    auth->password = g_strdup (password);
    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)
{
    extern pstring debugf;
    extern FILE *dbf;
    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)
{
    int 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,
                NULL);
            (*func)(path);
            g_free (path);
        }
    }
}

#define CNV_LANG(s) dos_to_unix(s,False)
#define GNAL_VNC(s) unix_to_dos(s,False)
/* 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, int count)
{
    smbfs_handle *info = (smbfs_handle *) data;
        int n;

        DEBUG(3, ("smbfs_read(fnum:%d, nread:%d, count:%d)\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, int nbyte)
{
    smbfs_handle *info = (smbfs_handle *) data;
        int n;

        DEBUG(3, ("smbfs_write(fnum:%d, nread:%d, nbyte:%d)\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", g_strerror(my_errno)));
    return my_errno;
}

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;

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

static gboolean first_direntry;

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\n "), 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", g_strerror(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, int owner, int 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:%d)\n", path, buf,
            (int) 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? */
}

/* 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)

/***************************************************** 
        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, smbfs_get_remote_stat callback  */
static dir_entry *single_entry;

/* 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);
}

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

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, int mode, int dev)
{
    (void) me;

        DEBUG(3, ("smbfs_mknod(path:%s, mode:%d, dev:%d)\n", path, mode, 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, i;

    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))) {
        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, int 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, int 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;
}

void
init_smbfs (void)
{
    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);
}