/* 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 , 1997 Andrew V. Samoilov 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 * \author Andrew V. Samoilov * \date 1997, 2002, 2003 * * Namespace: exports init_smbfs, smbfs_set_debug(), smbfs_set_debugf() */ #include #include #include #undef USE_NCURSES /* Don't include *curses.h */ #undef USE_NCURSESW #include "lib/global.h" #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 #include "vfs.h" #include "vfs-impl.h" #include "smbfs.h" #include "netutil.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 *param_password) { struct smb_authinfo *auth = g_try_new (struct smb_authinfo, 1); if (auth == NULL) 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 (param_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; } extern pstring debugf; extern FILE *dbf; 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) { 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, (char *) 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", unix_error_string (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", 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, 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) { 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); }