12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003 |
- /* Virtual File System: Midnight Commander file system.
- Copyright (C) 1999, 2000, 2001, 2002, 2003, 2004, 2005, 2007
- Free Software Foundation, Inc.
- Written by Wayne Roberts <wroberts1@home.com>, 1997
- Andrew V. Samoilov <sav@bcs.zp.ua> 2002, 2003
- This program is free software; you can redistribute it and/or
- modify it under the terms of the GNU Library General Public License
- as published by the Free Software Foundation; either version 2 of
- the License, or (at your option) any later version.
- This program is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- GNU Library General Public License for more details.
- You should have received a copy of the GNU Library General Public
- License along with this program; if not, write to the Free Software
- Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. */
- /**
- * \file
- * \brief Source: Virtual File System: smb file system
- * \author Wayne Roberts <wroberts1@home.com>
- * \author Andrew V. Samoilov <sav@bcs.zp.ua>
- * \date 1997, 2002, 2003
- *
- * Namespace: exports init_smbfs, smbfs_set_debug(), smbfs_set_debugf()
- */
- #include <config.h>
- #include <stdio.h>
- #include <sys/types.h>
- #undef USE_NCURSES /* Don't include *curses.h */
- #undef USE_NCURSESW
- #include "../src/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 <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 *param_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 (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,
- 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);
- }
|