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
|
// -*- mode: cpp; mode: fold -*-
// Description /*{{{*/
// $Id: gzip.cc,v 1.7 1999/01/27 02:48:53 jgg Exp $
/* ######################################################################
GZip method - Take a file URI in and decompress it into the target
file.
##################################################################### */
/*}}}*/
// Include Files /*{{{*/
#include <apt-pkg/fileutl.h>
#include <apt-pkg/error.h>
#include <apt-pkg/acquire-method.h>
#include <apt-pkg/strutl.h>
#include <sys/stat.h>
#include <unistd.h>
#include <utime.h>
#include <wait.h>
#include <stdio.h>
/*}}}*/
class GzipMethod : public pkgAcqMethod
{
virtual bool Fetch(FetchItem *Itm);
public:
GzipMethod() : pkgAcqMethod("1.0",SingleInstance | SendConfig) {};
};
// GzipMethod::Fetch - Decompress the passed URI /*{{{*/
// ---------------------------------------------------------------------
/* */
bool GzipMethod::Fetch(FetchItem *Itm)
{
URI Get = Itm->Uri;
FetchResult Res;
Res.Filename = Itm->DestFile;
URIStart(Res);
// Open the source and destintation files
FileFd From(Get.Path,FileFd::ReadOnly);
FileFd To(Itm->DestFile,FileFd::WriteEmpty);
To.EraseOnFailure();
if (_error->PendingError() == true)
return false;
// Fork gzip
int Process = fork();
if (Process < 0)
return _error->Errno("fork","Couldn't fork gzip");
// The child
if (Process == 0)
{
dup2(From.Fd(),STDIN_FILENO);
dup2(To.Fd(),STDOUT_FILENO);
From.Close();
To.Close();
SetCloseExec(STDIN_FILENO,false);
SetCloseExec(STDOUT_FILENO,false);
const char *Args[3];
Args[0] = _config->Find("Dir::bin::gzip","gzip").c_str();
Args[1] = "-d";
Args[2] = 0;
execvp(Args[0],(char **)Args);
exit(100);
}
From.Close();
// Wait for gzip to finish
int Status;
if (waitpid(Process,&Status,0) != Process)
{
To.OpFail();
return _error->Errno("wait","Waiting for gzip failed");
}
if (WIFEXITED(Status) == 0 || WEXITSTATUS(Status) != 0)
{
To.OpFail();
return _error->Error("gzip failed, perhaps the disk is full or the directory permissions are wrong.");
}
To.Close();
// Transfer the modification times
struct stat Buf;
if (stat(Get.Path.c_str(),&Buf) != 0)
return _error->Errno("stat","Failed to stat");
struct utimbuf TimeBuf;
TimeBuf.actime = Buf.st_atime;
TimeBuf.modtime = Buf.st_mtime;
if (utime(Itm->DestFile.c_str(),&TimeBuf) != 0)
return _error->Errno("utime","Failed to set modification time");
// Return a Done response
Res.LastModified = Buf.st_mtime;
URIDone(Res);
return true;
}
/*}}}*/
int main()
{
GzipMethod Mth;
return Mth.Run();
}
|
