* \file rpmio/rpmio_internal.h
*/
-
-#include <rpmio.h>
-#include <rpmurl.h>
-
-#include <beecrypt/types.h>
-#include <rpmpgp.h>
-#include <rpmsw.h>
-
-/* Drag in the beecrypt includes. */
-#include <beecrypt/beecrypt.h>
-#include <beecrypt/base64.h>
-#include <beecrypt/dsa.h>
-#include <beecrypt/endianness.h>
-#include <beecrypt/md5.h>
-#include <beecrypt/mp.h>
-#include <beecrypt/rsa.h>
-#include <beecrypt/rsapk.h>
-#include <beecrypt/sha1.h>
-
-/** \ingroup rpmio
- * Values parsed from OpenPGP signature/pubkey packet(s).
- */
-struct pgpDigParams_s {
-/*@only@*/ /*@null@*/
- const char * userid;
-/*@only@*/ /*@null@*/
- const byte * hash;
- const char * params[4];
- byte tag;
-
- byte version; /*!< version number. */
- byte time[4]; /*!< time that the key was created. */
- byte pubkey_algo; /*!< public key algorithm. */
-
- byte hash_algo;
- byte sigtype;
- byte hashlen;
- byte signhash16[2];
- byte signid[8];
- byte saved;
-#define PGPDIG_SAVED_TIME (1 << 0)
-#define PGPDIG_SAVED_ID (1 << 1)
-
-};
-
-/** \ingroup rpmio
- * Container for values parsed from an OpenPGP signature and public key.
- */
-struct pgpDig_s {
- struct pgpDigParams_s signature;
- struct pgpDigParams_s pubkey;
-
- size_t nbytes; /*!< No. bytes of plain text. */
-
-/*@only@*/ /*@null@*/
- DIGEST_CTX sha1ctx; /*!< (dsa) sha1 hash context. */
-/*@only@*/ /*@null@*/
- DIGEST_CTX hdrsha1ctx; /*!< (dsa) header sha1 hash context. */
-/*@only@*/ /*@null@*/
- void * sha1; /*!< (dsa) V3 signature hash. */
- size_t sha1len; /*!< (dsa) V3 signature hash length. */
-
-/*@only@*/ /*@null@*/
- DIGEST_CTX md5ctx; /*!< (rsa) md5 hash context. */
-#ifdef NOTYET
-/*@only@*/ /*@null@*/
- DIGEST_CTX hdrmd5ctx; /*!< (rsa) header md5 hash context. */
-#endif
-/*@only@*/ /*@null@*/
- void * md5; /*!< (rsa) V3 signature hash. */
- size_t md5len; /*!< (rsa) V3 signature hash length. */
-
- /* DSA parameters. */
- mp32barrett p;
- mp32barrett q;
- mp32number g;
- mp32number y;
- mp32number hm;
- mp32number r;
- mp32number s;
-
- /* RSA parameters. */
- rsapk rsa_pk;
- mp32number m;
- mp32number c;
- mp32number rsahm;
-};
-
-/** \ingroup rpmio
- */
-typedef struct _FDSTACK_s {
- FDIO_t io;
-/*@dependent@*/ void * fp;
- int fdno;
-} FDSTACK_t;
-
-/** \ingroup rpmio
- * Identify per-desciptor I/O operation statistics.
- */
-typedef enum fdOpX_e {
- FDSTAT_READ = 0, /*!< Read statistics index. */
- FDSTAT_WRITE = 1, /*!< Write statistics index. */
- FDSTAT_SEEK = 2, /*!< Seek statistics index. */
- FDSTAT_CLOSE = 3, /*!< Close statistics index */
- FDSTAT_DIGEST = 4, /*!< Digest statistics index. */
- FDSTAT_MAX = 5
-} fdOpX;
-
-/** \ingroup rpmio
- * Cumulative statistics for a descriptor.
- */
-typedef /*@abstract@*/ struct {
- struct rpmop_s ops[FDSTAT_MAX]; /*!< Cumulative statistics. */
-} * FDSTAT_t;
-
-/** \ingroup rpmio
- */
-typedef struct _FDDIGEST_s {
- pgpHashAlgo hashalgo;
- DIGEST_CTX hashctx;
-} * FDDIGEST_t;
-
-/** \ingroup rpmio
- * The FD_t File Handle data structure.
- */
-struct _FD_s {
-/*@refs@*/
- int nrefs;
- int flags;
-#define RPMIO_DEBUG_IO 0x40000000
-#define RPMIO_DEBUG_REFS 0x20000000
- int magic;
-#define FDMAGIC 0x04463138
- int nfps;
- FDSTACK_t fps[8];
- int urlType; /* ufdio: */
-
-/*@dependent@*/
- void * url; /* ufdio: URL info */
- int rd_timeoutsecs; /* ufdRead: per FD_t timer */
- ssize_t bytesRemain; /* ufdio: */
- ssize_t contentLength; /* ufdio: */
- int persist; /* ufdio: */
- int wr_chunked; /* ufdio: */
-
- int syserrno; /* last system errno encountered */
-/*@observer@*/
- const void *errcookie; /* gzdio/bzdio/ufdio: */
-
- FDSTAT_t stats; /* I/O statistics */
-
- int ndigests;
-#define FDDIGEST_MAX 4
- struct _FDDIGEST_s digests[FDDIGEST_MAX];
-
- int ftpFileDoneNeeded; /* ufdio: (FTP) */
- unsigned int firstFree; /* fadio: */
- long int fileSize; /* fadio: */
- long int fd_cpioPos; /* cpio: */
-};
-/*@access FD_t@*/
-
-#define FDSANE(fd) assert(fd && fd->magic == FDMAGIC)
-
-/*@-redecl@*/
-/*@unchecked@*/
-extern int _rpmio_debug;
-/*@=redecl@*/
-
-/*@-redecl@*/
-/*@unchecked@*/
-extern int _ftp_debug;
-/*@=redecl@*/
-
-#define DBG(_f, _m, _x) \
- if ((_rpmio_debug | ((_f) ? ((FD_t)(_f))->flags : 0)) & (_m)) fprintf _x
-
-#if defined(__LCLINT__XXX)
-#define DBGIO(_f, _x)
-#define DBGREFS(_f, _x)
-#else
-#define DBGIO(_f, _x) DBG((_f), RPMIO_DEBUG_IO, _x)
-#define DBGREFS(_f, _x) DBG((_f), RPMIO_DEBUG_REFS, _x)
-#endif
+#include <rpm/rpmio.h>
+#include <rpm/rpmpgp.h>
#ifdef __cplusplus
extern "C" {
#endif
-/** \ingroup rpmio
- */
-int fdFgets(FD_t fd, char * buf, size_t len)
- /*@globals errno, fileSystem @*/
- /*@modifies *buf, fd, errno, fileSystem @*/;
-
-/** \ingroup rpmio
- */
-/*@null@*/ FD_t ftpOpen(const char *url, /*@unused@*/ int flags,
- /*@unused@*/ mode_t mode, /*@out@*/ urlinfo *uret)
- /*@globals fileSystem, internalState @*/
- /*@modifies *uret, fileSystem, internalState @*/;
-
-/** \ingroup rpmio
- */
-int ftpReq(FD_t data, const char * ftpCmd, const char * ftpArg)
- /*@globals fileSystem, internalState @*/
- /*@modifies data, fileSystem, internalState @*/;
-
-/** \ingroup rpmio
- */
-int ftpCmd(const char * cmd, const char * url, const char * arg2)
- /*@globals fileSystem, internalState @*/
- /*@modifies fileSystem, internalState @*/;
-
-/** \ingroup rpmio
- */
-int ufdClose( /*@only@*/ void * cookie)
- /*@globals fileSystem, internalState @*/
- /*@modifies cookie, fileSystem, internalState @*/;
-
-/** \ingroup rpmio
- */
-/*@unused@*/ static inline
-/*@null@*/ FDIO_t fdGetIo(FD_t fd)
- /*@*/
-{
- FDSANE(fd);
-/*@-boundsread@*/
- return fd->fps[fd->nfps].io;
-/*@=boundsread@*/
-}
-
-/** \ingroup rpmio
- */
-/*@-nullstate@*/ /* FIX: io may be NULL */
-/*@unused@*/ static inline
-void fdSetIo(FD_t fd, /*@kept@*/ /*@null@*/ FDIO_t io)
- /*@modifies fd @*/
-{
- FDSANE(fd);
-/*@-boundswrite@*/
- /*@-assignexpose@*/
- fd->fps[fd->nfps].io = io;
- /*@=assignexpose@*/
-/*@=boundswrite@*/
-}
-/*@=nullstate@*/
-
-/** \ingroup rpmio
- */
-/*@unused@*/ static inline
-/*@exposed@*/ /*@dependent@*/ /*@null@*/ FILE * fdGetFILE(FD_t fd)
- /*@*/
-{
- FDSANE(fd);
-/*@-boundsread@*/
- /*@+voidabstract@*/
- return ((FILE *)fd->fps[fd->nfps].fp);
- /*@=voidabstract@*/
-/*@=boundsread@*/
-}
-
-/** \ingroup rpmio
- */
-/*@unused@*/ static inline
-/*@exposed@*/ /*@dependent@*/ /*@null@*/ void * fdGetFp(FD_t fd)
- /*@*/
-{
- FDSANE(fd);
-/*@-boundsread@*/
- return fd->fps[fd->nfps].fp;
-/*@=boundsread@*/
-}
-
-/** \ingroup rpmio
- */
-/*@-nullstate@*/ /* FIX: fp may be NULL */
-/*@unused@*/ static inline
-void fdSetFp(FD_t fd, /*@kept@*/ /*@null@*/ void * fp)
- /*@modifies fd @*/
-{
- FDSANE(fd);
-/*@-boundswrite@*/
- /*@-assignexpose@*/
- fd->fps[fd->nfps].fp = fp;
- /*@=assignexpose@*/
-/*@=boundswrite@*/
-}
-/*@=nullstate@*/
-
-/** \ingroup rpmio
- */
-/*@unused@*/ static inline
-int fdGetFdno(FD_t fd)
- /*@*/
-{
- FDSANE(fd);
-/*@-boundsread@*/
- return fd->fps[fd->nfps].fdno;
-/*@=boundsread@*/
-}
-
-/** \ingroup rpmio
- */
-/*@unused@*/ static inline
-void fdSetFdno(FD_t fd, int fdno)
- /*@modifies fd @*/
-{
- FDSANE(fd);
-/*@-boundswrite@*/
- fd->fps[fd->nfps].fdno = fdno;
-/*@=boundswrite@*/
-}
-
-/** \ingroup rpmio
- */
-/*@unused@*/ static inline
-void fdSetContentLength(FD_t fd, ssize_t contentLength)
- /*@modifies fd @*/
-{
- FDSANE(fd);
- fd->contentLength = fd->bytesRemain = contentLength;
-}
-
-/** \ingroup rpmio
- */
-/*@unused@*/ static inline
-void fdPush(FD_t fd, FDIO_t io, void * fp, int fdno)
- /*@modifies fd @*/
-{
- FDSANE(fd);
- if (fd->nfps >= (sizeof(fd->fps)/sizeof(fd->fps[0]) - 1))
- return;
- fd->nfps++;
- fdSetIo(fd, io);
- fdSetFp(fd, fp);
- fdSetFdno(fd, fdno);
-}
-
-/** \ingroup rpmio
- */
-/*@unused@*/ static inline
-void fdPop(FD_t fd)
- /*@modifies fd @*/
-{
- FDSANE(fd);
- if (fd->nfps < 0) return;
- fdSetIo(fd, NULL);
- fdSetFp(fd, NULL);
- fdSetFdno(fd, -1);
- fd->nfps--;
-}
-
-/** \ingroup rpmio
- */
-/*@unused@*/ static inline /*@null@*/
-rpmop fdstat_op(/*@null@*/ FD_t fd, fdOpX opx)
- /*@*/
-{
- rpmop op = NULL;
-
-/*@-boundsread@*/
- if (fd != NULL && fd->stats != NULL && opx >= 0 && opx < FDSTAT_MAX)
- op = fd->stats->ops + opx;
-/*@=boundsread@*/
- return op;
-}
-
-/** \ingroup rpmio
- */
-/*@unused@*/ static inline
-void fdstat_enter(/*@null@*/ FD_t fd, int opx)
- /*@globals internalState @*/
- /*@modifies internalState @*/
-{
- if (fd == NULL) return;
- if (fd->stats != NULL)
- (void) rpmswEnter(fdstat_op(fd, opx), 0);
-}
-
-/** \ingroup rpmio
- */
-/*@unused@*/ static inline
-void fdstat_exit(/*@null@*/ FD_t fd, int opx, ssize_t rc)
- /*@globals internalState @*/
- /*@modifies fd, internalState @*/
-{
- if (fd == NULL) return;
- if (rc == -1)
- fd->syserrno = errno;
- else if (rc > 0 && fd->bytesRemain > 0)
- fd->bytesRemain -= rc;
- if (fd->stats != NULL)
- (void) rpmswExit(fdstat_op(fd, opx), rc);
-}
-
-/** \ingroup rpmio
- */
-/*@-boundsread@*/
-/*@unused@*/ static inline
-void fdstat_print(/*@null@*/ FD_t fd, const char * msg, FILE * fp)
- /*@globals fileSystem @*/
- /*@modifies *fp, fileSystem @*/
-{
- static int usec_scale = (1000*1000);
- int opx;
-
- if (fd == NULL || fd->stats == NULL) return;
- for (opx = 0; opx < 4; opx++) {
- rpmop op = &fd->stats->ops[opx];
- if (op->count <= 0) continue;
- switch (opx) {
- case FDSTAT_READ:
- if (msg) fprintf(fp, "%s:", msg);
- fprintf(fp, "%8d reads, %8ld total bytes in %d.%06d secs\n",
- op->count, (long)op->bytes,
- (int)(op->usecs/usec_scale), (int)(op->usecs%usec_scale));
- /*@switchbreak@*/ break;
- case FDSTAT_WRITE:
- if (msg) fprintf(fp, "%s:", msg);
- fprintf(fp, "%8d writes, %8ld total bytes in %d.%06d secs\n",
- op->count, (long)op->bytes,
- (int)(op->usecs/usec_scale), (int)(op->usecs%usec_scale));
- /*@switchbreak@*/ break;
- case FDSTAT_SEEK:
- /*@switchbreak@*/ break;
- case FDSTAT_CLOSE:
- /*@switchbreak@*/ break;
- }
- }
-}
-/*@=boundsread@*/
-
-/** \ingroup rpmio
- */
-/*@unused@*/ static inline
-void fdSetSyserrno(FD_t fd, int syserrno, /*@kept@*/ const void * errcookie)
- /*@modifies fd @*/
-{
- FDSANE(fd);
- fd->syserrno = syserrno;
- /*@-assignexpose@*/
- fd->errcookie = errcookie;
- /*@=assignexpose@*/
-}
-
-/** \ingroup rpmio
- */
-/*@unused@*/ static inline
-int fdGetRdTimeoutSecs(FD_t fd)
- /*@*/
-{
- FDSANE(fd);
- return fd->rd_timeoutsecs;
-}
-
-/** \ingroup rpmio
- */
-/*@unused@*/ static inline
-long int fdGetCpioPos(FD_t fd)
- /*@*/
-{
- FDSANE(fd);
- return fd->fd_cpioPos;
-}
-
-/** \ingroup rpmio
- */
-/*@unused@*/ static inline
-void fdSetCpioPos(FD_t fd, long int cpioPos)
- /*@modifies fd @*/
-{
- FDSANE(fd);
- fd->fd_cpioPos = cpioPos;
-}
-
-/** \ingroup rpmio
- */
-/*@mayexit@*/ /*@unused@*/ static inline
-FD_t c2f(/*@null@*/ void * cookie)
- /*@*/
-{
- /*@-castexpose@*/
- FD_t fd = (FD_t) cookie;
- /*@=castexpose@*/
- FDSANE(fd);
- /*@-refcounttrans -retalias@*/ return fd; /*@=refcounttrans =retalias@*/
-}
+void fdSetBundle(FD_t fd, rpmDigestBundle bundle);
+rpmDigestBundle fdGetBundle(FD_t fd, int create);
/** \ingroup rpmio
* Attach digest to fd.
*/
-/*@unused@*/ static inline
-void fdInitDigest(FD_t fd, pgpHashAlgo hashalgo, int flags)
- /*@globals internalState @*/
- /*@modifies fd, internalState @*/
-{
- FDDIGEST_t fddig = fd->digests + fd->ndigests;
- if (fddig != (fd->digests + FDDIGEST_MAX)) {
- fd->ndigests++;
- fddig->hashalgo = hashalgo;
- fdstat_enter(fd, FDSTAT_DIGEST);
- fddig->hashctx = rpmDigestInit(hashalgo, flags);
- fdstat_exit(fd, FDSTAT_DIGEST, 0);
- }
-}
-
-/** \ingroup rpmio
- * Update digest(s) attached to fd.
- */
-/*@unused@*/ static inline
-void fdUpdateDigests(FD_t fd, const unsigned char * buf, ssize_t buflen)
- /*@globals internalState @*/
- /*@modifies fd, internalState @*/
-{
- int i;
+void fdInitDigest(FD_t fd, int hashalgo, rpmDigestFlags flags);
- if (buf != NULL && buflen > 0)
- for (i = fd->ndigests - 1; i >= 0; i--) {
- FDDIGEST_t fddig = fd->digests + i;
- if (fddig->hashctx == NULL)
- continue;
- fdstat_enter(fd, FDSTAT_DIGEST);
- (void) rpmDigestUpdate(fddig->hashctx, buf, buflen);
- fdstat_exit(fd, FDSTAT_DIGEST, buflen);
- }
-}
+void fdInitDigestID(FD_t fd, int hashalgo, int id, rpmDigestFlags flags);
/** \ingroup rpmio
*/
-/*@unused@*/ static inline
-void fdFiniDigest(FD_t fd, pgpHashAlgo hashalgo,
- /*@null@*/ /*@out@*/ void ** datap,
- /*@null@*/ /*@out@*/ size_t * lenp,
- int asAscii)
- /*@globals internalState @*/
- /*@modifies fd, *datap, *lenp, internalState @*/
-{
- int imax = -1;
- int i;
+void fdFiniDigest(FD_t fd, int id,
+ void ** datap,
+ size_t * lenp,
+ int asAscii);
- for (i = fd->ndigests - 1; i >= 0; i--) {
- FDDIGEST_t fddig = fd->digests + i;
- if (fddig->hashctx == NULL)
- continue;
- if (i > imax) imax = i;
- if (fddig->hashalgo != hashalgo)
- continue;
- fdstat_enter(fd, FDSTAT_DIGEST);
- (void) rpmDigestFinal(fddig->hashctx, datap, lenp, asAscii);
- fdstat_exit(fd, FDSTAT_DIGEST, 0);
- fddig->hashctx = NULL;
- break;
- }
-/*@-boundswrite@*/
- if (i < 0) {
- if (datap) *datap = NULL;
- if (lenp) *lenp = 0;
- }
-/*@=boundswrite@*/
-
- fd->ndigests = imax;
- if (i < imax)
- fd->ndigests++; /* convert index to count */
-}
-
-/*@-shadow@*/
-/** \ingroup rpmio
- */
-/*@unused@*/ static inline
-int fdFileno(/*@null@*/ void * cookie)
- /*@*/
-{
- FD_t fd;
- if (cookie == NULL) return -2;
- fd = c2f(cookie);
-/*@-boundsread@*/
- return fd->fps[0].fdno;
-/*@=boundsread@*/
-}
-/*@=shadow@*/
+DIGEST_CTX fdDupDigest(FD_t fd, int id);
/**
* Read an entire file into a buffer.
* @return 0 on success
*/
int rpmioSlurp(const char * fn,
- /*@out@*/ const unsigned char ** bp, /*@out@*/ ssize_t * blenp)
- /*@globals fileSystem, internalState @*/
- /*@modifies *bp, *blenp, fileSystem, internalState @*/;
+ uint8_t ** bp, ssize_t * blenp);
#ifdef __cplusplus
}
projects / platform / upstream / rpm.git / blobdiff