-/*@-type@*/ /* LCL: function typedefs */
/** \ingroup rpmio
* \file rpmio/rpmrpc.c
*/
#include "system.h"
+
+#if defined(HAVE_PTHREAD_H) && !defined(__LCLINT__)
#include <pthread.h>
+#endif
+
#include <rpmio_internal.h>
-#include <popt.h>
#include "ugid.h"
#include "debug.h"
+/*@access DIR@*/
/*@access FD_t@*/
/*@access urlinfo@*/
-/*@-redecl@*/
-extern int _ftp_debug;
-/*@=redecl@*/
-
-/*@-redecl@*/
-extern int _rpmio_debug;
-/*@=redecl@*/
-
/* =============================================================== */
static int ftpMkdir(const char * path, /*@unused@*/ mode_t mode)
- /*@globals fileSystem @*/
- /*@modifies fileSystem @*/
+ /*@globals fileSystem, internalState @*/
+ /*@modifies fileSystem, internalState @*/
{
int rc;
if ((rc = ftpCmd("MKD", path, NULL)) != 0)
}
static int ftpChdir(const char * path)
- /*@globals fileSystem @*/
- /*@modifies fileSystem @*/
+ /*@globals fileSystem, internalState @*/
+ /*@modifies fileSystem, internalState @*/
{
return ftpCmd("CWD", path, NULL);
}
static int ftpRmdir(const char * path)
- /*@globals fileSystem @*/
- /*@modifies fileSystem @*/
+ /*@globals fileSystem, internalState @*/
+ /*@modifies fileSystem, internalState @*/
{
return ftpCmd("RMD", path, NULL);
}
static int ftpRename(const char * oldpath, const char * newpath)
- /*@globals fileSystem @*/
- /*@modifies fileSystem @*/
+ /*@globals fileSystem, internalState @*/
+ /*@modifies fileSystem, internalState @*/
{
int rc;
if ((rc = ftpCmd("RNFR", oldpath, NULL)) != 0)
}
static int ftpUnlink(const char * path)
- /*@globals fileSystem @*/
- /*@modifies fileSystem @*/
+ /*@globals fileSystem, internalState @*/
+ /*@modifies fileSystem, internalState @*/
{
return ftpCmd("DELE", path, NULL);
}
/*@unchecked@*/
static int column_ptr [MAXCOLS]; /* Index from 0 to the starting positions of the columns */
+/*@-boundswrite@*/
static int
vfs_split_text (char *p)
/*@globals columns, column_ptr @*/
}
return numcols;
}
+/*@=boundswrite@*/
+/*@-boundsread@*/
static int
is_num (int idx)
/*@*/
return 0;
return 1;
}
+/*@=boundsread@*/
+/*@-boundsread@*/
static int
is_dos_date(/*@null@*/ const char *str)
/*@*/
return 1;
return 0;
}
+/*@=boundsread@*/
static int
is_week (/*@null@*/ const char * str, /*@out@*/ struct tm * tim)
return res;
}
+/*@-boundswrite@*/
static int vfs_parse_filedate(int idx, /*@out@*/ time_t *t)
/*@modifies *t @*/
{ /* This thing parses from idx in columns[] array */
*t = 0;
return idx;
}
+/*@=boundswrite@*/
+/*@-boundswrite@*/
static int
vfs_parse_ls_lga (char * p, /*@out@*/ struct stat * st,
/*@out@*/ const char ** filename,
g_free (p_copy);
return 0;
}
+/*@=boundswrite@*/
typedef enum {
DO_FTP_STAT = 1,
#define alloca_strdup(_s) strcpy(alloca(strlen(_s)+1), (_s))
+/*@-boundswrite@*/
/*@-mods@*/
static int ftpNLST(const char * url, ftpSysCall_t ftpSysCall,
/*@out@*/ /*@null@*/ struct stat * st,
/*@out@*/ /*@null@*/ char * rlbuf, size_t rlbufsiz)
- /*@globals fileSystem @*/
- /*@modifies *st, *rlbuf, fileSystem @*/
+ /*@globals fileSystem, internalState @*/
+ /*@modifies *st, *rlbuf, fileSystem, internalState @*/
{
FD_t fd;
const char * path;
/* XXX FIXME: realloc ftpBuf if < ~128 chars remain */
if ((ftpBufAlloced - bufLength) < (1024+80)) {
ftpBufAlloced <<= 2;
+ assert(ftpBufAlloced < (8*1024*1024));
ftpBuf = xrealloc(ftpBuf, ftpBufAlloced);
}
s = se = ftpBuf + bufLength;
return rc;
}
/*@=mods@*/
+/*@=boundswrite@*/
+
+static const char * statstr(const struct stat * st,
+ /*@returned@*/ /*@out@*/ char * buf)
+ /*@modifies *buf @*/
+{
+ sprintf(buf,
+ "*** dev %x ino %x mode %0o nlink %d uid %d gid %d rdev %x size %x\n",
+ (unsigned)st->st_dev,
+ (unsigned)st->st_ino,
+ st->st_mode,
+ (unsigned)st->st_nlink,
+ st->st_uid,
+ st->st_gid,
+ (unsigned)st->st_rdev,
+ (unsigned)st->st_size);
+ return buf;
+}
+
+/*@unchecked@*/
+static int ftp_st_ino = 0xdead0000;
static int ftpStat(const char * path, /*@out@*/ struct stat *st)
- /*@globals fileSystem @*/
- /*@modifies *st, fileSystem @*/
+ /*@globals fileSystem, internalState @*/
+ /*@modifies *st, fileSystem, internalState @*/
{
+ char buf[1024];
int rc;
rc = ftpNLST(path, DO_FTP_STAT, st, NULL, 0);
+ /* XXX fts(3) needs/uses st_ino, make something up for now. */
+ /*@-mods@*/
+ if (st->st_ino == 0)
+ st->st_ino = ftp_st_ino++;
+ /*@=mods@*/
if (_ftp_debug)
-fprintf(stderr, "*** ftpStat(%s) rc %d\n", path, rc);
+fprintf(stderr, "*** ftpStat(%s) rc %d\n%s", path, rc, statstr(st, buf));
return rc;
}
static int ftpLstat(const char * path, /*@out@*/ struct stat *st)
- /*@globals fileSystem @*/
- /*@modifies *st, fileSystem @*/
+ /*@globals fileSystem, internalState @*/
+ /*@modifies *st, fileSystem, internalState @*/
{
+ char buf[1024];
int rc;
rc = ftpNLST(path, DO_FTP_LSTAT, st, NULL, 0);
+ /* XXX fts(3) needs/uses st_ino, make something up for now. */
+ /*@-mods@*/
+ if (st->st_ino == 0)
+ st->st_ino = ftp_st_ino++;
+ /*@=mods@*/
if (_ftp_debug)
-fprintf(stderr, "*** ftpLstat(%s) rc %d\n", path, rc);
+fprintf(stderr, "*** ftpLstat(%s) rc %d\n%s\n", path, rc, statstr(st, buf));
return rc;
}
static int ftpReadlink(const char * path, /*@out@*/ char * buf, size_t bufsiz)
- /*@globals fileSystem @*/
- /*@modifies *buf, fileSystem @*/
+ /*@globals fileSystem, internalState @*/
+ /*@modifies *buf, fileSystem, internalState @*/
{
int rc;
rc = ftpNLST(path, DO_FTP_READLINK, NULL, buf, bufsiz);
size_t size; /* Total valid data in the block. */
size_t offset; /* Current offset into the block. */
off_t filepos; /* Position of next entry to read. */
+#if defined(HAVE_PTHREAD_H) && !defined(__LCLINT__)
pthread_mutex_t lock; /* Mutex lock for this structure. */
+#endif
};
+#if !defined(DT_DIR)
+# define DT_UNKNOWN 0
+# define DT_FIFO 1
+# define DT_CHR 2
+# define DT_DIR 4
+# define DT_BLK 6
+# define DT_REG 8
+# define DT_LNK 10
+# define DT_SOCK 12
+# define DT_WHT 14
+typedef struct __dirstream * FTPDIR;
+#else
+typedef DIR * FTPDIR;
+#endif
+
+/*@unchecked@*/
static int ftpmagicdir = 0x8440291;
#define ISFTPMAGIC(_dir) (!memcmp((_dir), &ftpmagicdir, sizeof(ftpmagicdir)))
+/*@-boundswrite@*/
+/*@-type@*/ /* FIX: abstract DIR */
+/*@null@*/
static DIR * ftpOpendir(const char * path)
+ /*@globals fileSystem, internalState @*/
+ /*@modifies fileSystem, internalState @*/
{
- DIR * dir;
+ FTPDIR mydir;
struct dirent * dp;
size_t nb;
const char * s, * sb, * se;
switch (c) {
case '/':
sb = se;
- break;
+ /*@switchbreak@*/ break;
case '\r':
if (sb == NULL) {
for (sb = se; sb > s && sb[-1] != ' '; sb--)
- ;
+ {};
}
ac++;
nb += (se - sb);
if (*se == '\n') se++;
sb = NULL;
s = se;
- break;
+ /*@switchbreak@*/ break;
default:
- break;
+ /*@switchbreak@*/ break;
}
}
- nb += sizeof(*dir) + sizeof(*dp) + ((ac + 1) * sizeof(*av)) + (ac + 1);
- dir = xcalloc(1, nb);
- dp = (struct dirent *) (dir + 1);
+ nb += sizeof(*mydir) + sizeof(*dp) + ((ac + 1) * sizeof(*av)) + (ac + 1);
+ mydir = xcalloc(1, nb);
+ /*@-abstract@*/
+ dp = (struct dirent *) (mydir + 1);
av = (const char **) (dp + 1);
dt = (char *) (av + (ac + 1));
t = (char *) (dt + ac + 1);
+ /*@=abstract@*/
- dir->fd = ftpmagicdir;
- dir->data = (char *) dp;
- dir->allocation = nb;
- dir->size = ac;
- dir->offset = -1;
- dir->filepos = 0;
+ mydir->fd = ftpmagicdir;
+/*@-usereleased@*/
+ mydir->data = (char *) dp;
+/*@=usereleased@*/
+ mydir->allocation = nb;
+ mydir->size = ac;
+ mydir->offset = -1;
+ mydir->filepos = 0;
ac = 0;
+ /*@-dependenttrans -unrecog@*/
dt[ac] = DT_DIR; av[ac++] = t; t = stpcpy(t, "."); t++;
dt[ac] = DT_DIR; av[ac++] = t; t = stpcpy(t, ".."); t++;
+ /*@=dependenttrans =unrecog@*/
sb = NULL;
s = se = ftpBuf;
while ((c = *se) != '\0') {
switch (c) {
case '/':
sb = se;
- break;
+ /*@switchbreak@*/ break;
case '\r':
+ /*@-dependenttrans@*/
av[ac] = t;
+ /*@=dependenttrans@*/
if (sb == NULL) {
+ /*@-unrecog@*/
switch(*s) {
- case 'p': dt[ac] = DT_FIFO; break;
- case 'c': dt[ac] = DT_CHR; break;
- case 'd': dt[ac] = DT_DIR; break;
- case 'b': dt[ac] = DT_BLK; break;
- case '-': dt[ac] = DT_REG; break;
- case 'l': dt[ac] = DT_LNK; break;
- case 's': dt[ac] = DT_SOCK; break;
- default: dt[ac] = DT_UNKNOWN; break;
+ case 'p':
+ dt[ac] = DT_FIFO;
+ /*@innerbreak@*/ break;
+ case 'c':
+ dt[ac] = DT_CHR;
+ /*@innerbreak@*/ break;
+ case 'd':
+ dt[ac] = DT_DIR;
+ /*@innerbreak@*/ break;
+ case 'b':
+ dt[ac] = DT_BLK;
+ /*@innerbreak@*/ break;
+ case '-':
+ dt[ac] = DT_REG;
+ /*@innerbreak@*/ break;
+ case 'l':
+ dt[ac] = DT_LNK;
+ /*@innerbreak@*/ break;
+ case 's':
+ dt[ac] = DT_SOCK;
+ /*@innerbreak@*/ break;
+ default:
+ dt[ac] = DT_UNKNOWN;
+ /*@innerbreak@*/ break;
}
+ /*@=unrecog@*/
for (sb = se; sb > s && sb[-1] != ' '; sb--)
- ;
+ {};
}
ac++;
t = stpncpy(t, sb, (se - sb));
if (*se == '\n') se++;
sb = NULL;
s = se;
- break;
+ /*@switchbreak@*/ break;
default:
- break;
+ /*@switchbreak@*/ break;
}
}
av[ac] = NULL;
- return dir;
+/*@-kepttrans@*/
+ return (DIR *) mydir;
+/*@=kepttrans@*/
}
+/*@=boundswrite@*/
+/*@dependent@*/ /*@null@*/
static struct dirent * ftpReaddir(DIR * dir)
+ /*@globals fileSystem @*/
+ /*@modifies fileSystem @*/
{
+ FTPDIR mydir = (FTPDIR)dir;
struct dirent * dp;
const char ** av;
unsigned char * dt;
int ac;
int i;
- if (dir == NULL || !ISFTPMAGIC(dir) || dir->data == NULL) {
+ /*@+voidabstract@*/
+ if (mydir == NULL || !ISFTPMAGIC(mydir) || mydir->data == NULL) {
/* XXX TODO: EBADF errno. */
return NULL;
}
+ /*@=voidabstract@*/
- dp = (struct dirent *) dir->data;
+ dp = (struct dirent *) mydir->data;
av = (const char **) (dp + 1);
- ac = dir->size;
+ ac = mydir->size;
dt = (char *) (av + (ac + 1));
- i = dir->offset + 1;
+ i = mydir->offset + 1;
+/*@-boundsread@*/
if (i < 0 || i >= ac || av[i] == NULL)
return NULL;
+/*@=boundsread@*/
- dir->offset = i;
+ mydir->offset = i;
/* XXX glob(3) uses REAL_DIR_ENTRY(dp) test on d_ino */
dp->d_ino = i + 1; /* W2DO? */
- dp->d_off = 0; /* W2DO? */
dp->d_reclen = 0; /* W2DO? */
+
+#if !defined(hpux) && !defined(sun)
+ dp->d_off = 0; /* W2DO? */
+/*@-boundsread@*/
dp->d_type = dt[i];
+/*@=boundsread@*/
+#endif
strncpy(dp->d_name, av[i], sizeof(dp->d_name));
+/*@+voidabstract@*/
if (_ftp_debug)
-fprintf(stderr, "*** ftpReaddir(%p) %p \"%s\"\n", dir, dp, dp->d_name);
+fprintf(stderr, "*** ftpReaddir(%p) %p \"%s\"\n", (void *)mydir, dp, dp->d_name);
+/*@=voidabstract@*/
return dp;
}
+/*@=type@*/
-static int ftpClosedir(DIR * dir)
+static int ftpClosedir(/*@only@*/ DIR * dir)
+ /*@globals fileSystem @*/
+ /*@modifies dir, fileSystem @*/
{
+ FTPDIR mydir = (FTPDIR)dir;
+
+ /*@+voidabstract@*/
if (_ftp_debug)
-fprintf(stderr, "*** ftpClosedir(%p)\n", dir);
- if (dir == NULL || !ISFTPMAGIC(dir)) {
+fprintf(stderr, "*** ftpClosedir(%p)\n", (void *)mydir);
+ if (mydir == NULL || !ISFTPMAGIC(mydir)) {
/* XXX TODO: EBADF errno. */
return -1;
}
- free((void *)dir);
- dir = NULL;
+ free((void *)mydir);
+ /*@=voidabstract@*/
+ mydir = NULL;
return 0;
}
return -2;
/*@notreached@*/ break;
}
+/*@-compdef@*/
return readlink(path, buf, bufsiz);
+/*@=compdef@*/
}
int Access(const char * path, int amode)
/*@=castfcnptr@*/
switch (ut) {
case URL_IS_FTP:
+/*@-type@*/
pglob->gl_closedir = Closedir;
pglob->gl_readdir = Readdir;
pglob->gl_opendir = Opendir;
pglob->gl_lstat = Lstat;
pglob->gl_stat = Stat;
+/*@=type@*/
flags |= GLOB_ALTDIRFUNC;
break;
case URL_IS_HTTP: /* XXX WRONG WRONG WRONG */
return closedir(dir);
}
/*@=voidabstract@*/
-/*@=type@*/
projects / platform / upstream / rpm.git / blobdiff