1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
/** \ingroup rpmio
* \file rpmio/tufdio.c
*/
#include "system.h"
#include <stdarg.h>
#include <err.h>
#include <rpm/rpmurl.h>
#include <rpm/rpmio.h>
#include "debug.h"
extern int _url_debug;
extern int _rpmio_debug;
const char *tmpdir = "/tmp";
const char *dio_xxxxxx = "/dio.XXXXXX";
#define DIO_XXXXXX strdup(dio_xxxxxx)
const char *fio_xxxxxx = "/fio.XXXXXX";
#define FIO_XXXXXX strdup(fio_xxxxxx)
static const char * xstrconcat(const char * arg, ...)
{
const char *s;
char *t, *te;
size_t nt = 0;
va_list ap;
if (arg == NULL) return xstrdup("");
va_start(ap, arg);
for (s = arg; s != NULL; s = va_arg(ap, const char *))
nt += strlen(s);
va_end(ap);
te = t = xmalloc(nt+1);
va_start(ap, arg);
for (s = arg; s != NULL; s = va_arg(ap, const char *))
te = stpcpy(te, s);
va_end(ap);
*te = '\0';
return t;
}
static int doFIO(const char *ofn, const char *rfmode, const char *wfmode)
{
FD_t fd;
int rc = 0;
char buf[8192];
if ((fd = Fopen(ofn, wfmode)) == NULL)
warn("Fopen: write %s (%s) %s\n", wfmode, rfmode, ofn);
else if ((rc = Fwrite(ofn, sizeof(ofn[0]), strlen(ofn), fd)) != strlen(ofn))
warn("Fwrite: write %s (%s) %s\n", wfmode, rfmode, ofn);
else if ((rc = Fclose(fd)) != 0)
warn("Fclose: write %s (%s) %s\n", wfmode, rfmode, ofn);
else if ((fd = Fopen(ofn, rfmode)) == NULL)
warn("Fopen: read %s (%s) %s\n", rfmode, wfmode, ofn);
else if ((rc = Fread(buf, sizeof(buf[0]), sizeof(buf), fd)) != strlen(ofn))
warn("Fread: read %s (%s) %s\n", rfmode, wfmode, ofn);
else if ((rc = Fclose(fd)) != 0)
warn("Fclose: read %s (%s) %s\n", rfmode, wfmode, ofn);
else if (strcmp(ofn, buf))
warn("Compare: write(%s) \"%s\" != read(%s) \"%s\" for %s\n", wfmode, ofn, rfmode, buf, ofn);
else
rc = 0;
if (unlink(ofn) != 0)
warn("Unlink: write(%s) read(%s) for %s\n", wfmode, rfmode, ofn);
return rc;
}
static int doFile(const char * url, const char * odn, const char * ndn)
{
const char * ofn = xstrconcat(odn, mktemp(FIO_XXXXXX), NULL);
const char * nfn = xstrconcat(ndn, mktemp(FIO_XXXXXX), NULL);
FD_t fd;
int rc;
if ((fd = Fopen(ofn, "r.ufdio")) != NULL)
err(1, "Fopen: r !exists %s fail\n", ofn);
rc = doFIO(ofn, "r.ufdio", "w.ufdio");
rc = doFIO(nfn, "r.ufdio", "w.ufdio");
return rc;
}
static int doDir(const char *url)
{
const char * odn = xstrconcat(url, tmpdir, mktemp(DIO_XXXXXX), NULL);
const char * ndn = xstrconcat(url, tmpdir, mktemp(DIO_XXXXXX), NULL);
doFile(url, odn, ndn);
return 0;
}
static int doUrl(const char *url)
{
int rc;
rc = doDir(url);
return rc;
}
int main (int argc, char * argv[])
{
int rc;
_url_debug = -1;
_rpmio_debug = -1;
if (argc != 2) {
fprintf(stderr, "%s: url ...\n", argv[0]);
exit(1);
}
rc = doUrl(argv[1]);
return 0;
}
|
