123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989 |
- /* Virtual File System: Midnight Commander file system.
- Copyright (C) 1999, 2000, 2001, 2002, 2003, 2004, 2005, 2007
- Free Software Foundation, Inc.
- Written by Wayne Roberts <wroberts1@home.com>, 1997
- Andrew V. Samoilov <sav@bcs.zp.ua> 2002, 2003
- This program is free software; you can redistribute it and/or
- modify it under the terms of the GNU Library General Public License
- as published by the Free Software Foundation; either version 2 of
- the License, or (at your option) any later version.
- This program is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- GNU Library General Public License for more details.
- You should have received a copy of the GNU Library General Public
- License along with this program; if not, write to the Free Software
- Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. */
- /* Namespace: exports init_smbfs, smbfs_set_debug(), smbfs_set_debugf() */
- #include <config.h>
- #include <stdio.h>
- #include <sys/types.h>
- #undef USE_NCURSES /* Don't include *curses.h */
- #include "../src/global.h"
- #include "../src/tty.h" /* enable/disable interrupt key */
- #include "../src/wtools.h" /* message() */
- #include "../src/main.h" /* print_vfs_message */
- #include "utilvfs.h"
- #undef PACKAGE_BUGREPORT
- #undef PACKAGE_NAME
- #undef PACKAGE_STRING
- #undef PACKAGE_TARNAME
- #undef PACKAGE_VERSION
- #include "samba/include/config.h"
- /* don't load crap in "samba/include/includes.h" we don't use and which
- conflicts with definitions in other includes */
- #undef HAVE_LIBREADLINE
- #define NO_CONFIG_H
- #undef VERSION
- #include "samba/include/includes.h"
- #include <string.h>
- #include "vfs.h"
- #include "vfs-impl.h"
- #include "smbfs.h"
- #define SMBFS_MAX_CONNECTIONS 16
- static const char * const IPC = "IPC$";
- static const char * const URL_HEADER = "/#smb:";
- #define HEADER_LEN 6
- static int my_errno;
- static uint32 err;
- /* stuff that is same with each connection */
- extern int DEBUGLEVEL;
- extern pstring myhostname;
- extern struct in_addr ipzero;
- static mode_t myumask = 0755;
- extern pstring global_myname;
- static int smbfs_open_connections = 0;
- static gboolean got_user = FALSE;
- static gboolean got_pass = FALSE;
- static pstring password;
- static pstring username;
- static struct vfs_class vfs_smbfs_ops;
- static struct _smbfs_connection {
- struct cli_state *cli;
- struct in_addr dest_ip;
- BOOL have_ip;
- char *host; /* server name */
- char *service; /* share name */
- char *domain;
- char *user;
- char *home;
- char *password;
- int port;
- int name_type;
- time_t last_use;
- } smbfs_connections [SMBFS_MAX_CONNECTIONS];
- /* unique to each connection */
- /* modifies *share */
- static struct cli_state * smbfs_do_connect (const char *server, char *share);
- typedef struct _smbfs_connection smbfs_connection;
- static smbfs_connection *current_bucket;
- typedef struct {
- struct cli_state *cli;
- int fnum;
- off_t nread;
- uint16 attr;
- } smbfs_handle;
- static GSList *auth_list;
- /* this function allows you to write:
- * char *s = g_strdup("hello, world");
- * s = free_after(g_strconcat(s, s, (char *)0), s);
- */
- static inline char *
- free_after (char *result, char *string_to_free)
- {
- g_free(string_to_free);
- return result;
- }
- static void
- smbfs_auth_free (struct smb_authinfo const *a)
- {
- g_free (a->host);
- g_free (a->share);
- g_free (a->domain);
- g_free (a->user);
- wipe_password (a->password);
- }
- static void
- smbfs_auth_free_all (void)
- {
- if (auth_list) {
- g_slist_foreach (auth_list, (GFunc)smbfs_auth_free, 0);
- g_slist_free (auth_list);
- auth_list = 0;
- }
- }
- static gint
- smbfs_auth_cmp_host_and_share (gconstpointer _a, gconstpointer _b)
- {
- struct smb_authinfo const *a = (struct smb_authinfo const *)_a;
- struct smb_authinfo const *b = (struct smb_authinfo const *)_b;
- if (!a->host || !a->share || !b->host || !b->share)
- return 1;
- if (strcmp (a->host, b->host) != 0)
- return 1;
- if (strcmp (a->share, b->share) != 0)
- return 1;
- return 0;
- }
- static gint
- smbfs_auth_cmp_host (gconstpointer _a, gconstpointer _b)
- {
- struct smb_authinfo const *a = (struct smb_authinfo const *)_a;
- struct smb_authinfo const *b = (struct smb_authinfo const *)_b;
- if (!a->host || !b->host)
- return 1;
- if (strcmp (a->host, b->host) != 0)
- return 1;
- if (strcmp (a->share, IPC) != 0)
- return 1;
- return 0;
- }
- static void
- smbfs_auth_add (const char *host, const char *share, const char *domain,
- const char *user, const char *password)
- {
- struct smb_authinfo *auth = g_new (struct smb_authinfo, 1);
-
- if (!auth)
- return;
- /* Don't check for NULL, g_strdup already does. */
- auth->host = g_strdup (host);
- auth->share = g_strdup (share);
- auth->domain = g_strdup (domain);
- auth->user = g_strdup (user);
- auth->password = g_strdup (password);
- auth_list = g_slist_prepend (auth_list, auth);
- }
- static void
- smbfs_auth_remove (const char *host, const char *share)
- {
- struct smb_authinfo data;
- struct smb_authinfo *auth;
- GSList *list;
- data.host = g_strdup (host);
- data.share = g_strdup (share);
- list = g_slist_find_custom (auth_list,
- &data,
- smbfs_auth_cmp_host_and_share);
- g_free (data.host);
- g_free (data.share);
- if (!list)
- return;
- auth = list->data;
- auth_list = g_slist_remove (auth_list, auth);
- smbfs_auth_free (auth);
- }
- /* Set authentication information in bucket. Return 1 if successful, else 0 */
- /* Information in auth_list overrides user if pass is NULL. */
- /* bucket->host and bucket->service must be valid. */
- static int
- smbfs_bucket_set_authinfo (smbfs_connection *bucket,
- const char *domain, const char *user, const char *pass,
- int fallback_to_host)
- {
- struct smb_authinfo data;
- struct smb_authinfo *auth;
- GSList *list;
- if (domain && user && pass) {
- g_free (bucket->domain);
- g_free (bucket->user);
- g_free (bucket->password);
- bucket->domain = g_strdup (domain);
- bucket->user = g_strdup (user);
- bucket->password = g_strdup (pass);
- smbfs_auth_remove (bucket->host, bucket->service);
- smbfs_auth_add (bucket->host, bucket->service,
- domain, user, pass);
- return 1;
- }
- data.host = bucket->host;
- data.share = bucket->service;
- list = g_slist_find_custom (auth_list, &data, smbfs_auth_cmp_host_and_share);
- if (!list && fallback_to_host)
- list = g_slist_find_custom (auth_list, &data, smbfs_auth_cmp_host);
- if (list) {
- auth = list->data;
- bucket->domain = g_strdup (auth->domain);
- bucket->user = g_strdup (auth->user);
- bucket->password = g_strdup (auth->password);
- return 1;
- }
- if (got_pass) {
- bucket->domain = g_strdup (lp_workgroup ());
- bucket->user = g_strdup (got_user ? username : user);
- bucket->password = g_strdup (password);
- return 1;
- }
- auth = vfs_smb_get_authinfo (bucket->host,
- bucket->service,
- (domain ? domain : lp_workgroup ()),
- user);
- if (auth) {
- g_free (bucket->domain);
- g_free (bucket->user);
- g_free (bucket->password);
- bucket->domain = g_strdup (auth->domain);
- bucket->user = g_strdup (auth->user);
- bucket->password = g_strdup (auth->password);
- smbfs_auth_remove (bucket->host, bucket->service);
- auth_list = g_slist_prepend (auth_list, auth);
- return 1;
- }
- return 0;
- }
- void
- smbfs_set_debug (int arg)
- {
- DEBUGLEVEL = arg;
- }
- void
- smbfs_set_debugf (const char *filename)
- {
- extern pstring debugf;
- extern FILE *dbf;
- if (DEBUGLEVEL > 0) {
- FILE *outfile = fopen (filename, "w");
- if (outfile) {
- setup_logging ("", True); /* No needs for timestamp for each message */
- dbf = outfile;
- setbuf (dbf, NULL);
- pstrcpy (debugf, filename);
- }
- }
- }
- /********************** The callbacks ******************************/
- static int
- smbfs_init (struct vfs_class * me)
- {
- const char *servicesf = CONFIGDIR PATH_SEP_STR "smb.conf";
- /* DEBUGLEVEL = 4; */
- TimeInit ();
- charset_initialise ();
- DEBUG (3, ("smbfs_init(%s)\n", me->name));
- if (!get_myname (myhostname, NULL))
- DEBUG (0, ("Failed to get my hostname.\n"));
- if (!lp_load (servicesf, True, False, False))
- DEBUG (0, ("Cannot load %s - run testparm to debug it\n", servicesf));
- codepage_initialise (lp_client_code_page ());
- load_interfaces ();
- myumask = umask (0);
- umask (myumask);
- myumask = ~myumask;
- if (getenv ("USER")) {
- char *p;
- pstrcpy (username, getenv ("USER"));
- got_user = TRUE;
- DEBUG (3, ("smbfs_init(): $USER:%s\n", username));
- if ((p = strchr (username, '%'))) {
- *p = 0;
- pstrcpy (password, p + 1);
- got_pass = TRUE;
- memset (strchr (getenv ("USER"), '%') + 1, 'X', strlen (password));
- DEBUG (3, ("smbfs_init(): $USER%%pass: %s%%%s\n",
- username, password));
- }
- strupper (username);
- }
- if (getenv ("PASSWD")) {
- pstrcpy (password, getenv ("PASSWD"));
- got_pass = TRUE;
- }
- return 1;
- }
- static void
- smbfs_fill_names (struct vfs_class *me, fill_names_f func)
- {
- int i;
- char *path;
- (void) me;
- for (i = 0; i < SMBFS_MAX_CONNECTIONS; i++) {
- if (smbfs_connections [i].cli) {
- path = g_strconcat (URL_HEADER,
- smbfs_connections[i].user, "@",
- smbfs_connections[i].host,
- "/", smbfs_connections[i].service,
- NULL);
- (*func)(path);
- g_free (path);
- }
- }
- }
- #define CNV_LANG(s) dos_to_unix(s,False)
- #define GNAL_VNC(s) unix_to_dos(s,False)
- /* does same as do_get() in client.c */
- /* called from vfs.c:1080, count = buffer size */
- static int
- 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 int
- 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 (1, 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 (1, 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 int
- 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 (1, 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 (1, 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 (1, 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 (1, 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 (1, 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 (1, 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);
- }
|