|
|
@@ -378,10 +378,11 @@ void pkgDPkgPM::DoTerminalPty(int master)
|
|
|
*/
|
|
|
void pkgDPkgPM::ProcessDpkgStatusLine(int OutStatusFd, char *line)
|
|
|
{
|
|
|
+ bool const Debug = _config->FindB("Debug::pkgDPkgProgressReporting",false);
|
|
|
// the status we output
|
|
|
ostringstream status;
|
|
|
|
|
|
- if (_config->FindB("Debug::pkgDPkgProgressReporting",false) == true)
|
|
|
+ if (Debug == true)
|
|
|
std::clog << "got from dpkg '" << line << "'" << std::endl;
|
|
|
|
|
|
|
|
|
@@ -396,6 +397,7 @@ void pkgDPkgPM::ProcessDpkgStatusLine(int OutStatusFd, char *line)
|
|
|
'processing: install: pkg'
|
|
|
'processing: configure: pkg'
|
|
|
'processing: remove: pkg'
|
|
|
+ 'processing: purge: pkg' - but for apt is it a ignored "unknown" action
|
|
|
'processing: trigproc: trigger'
|
|
|
|
|
|
*/
|
|
|
@@ -408,28 +410,28 @@ void pkgDPkgPM::ProcessDpkgStatusLine(int OutStatusFd, char *line)
|
|
|
TokSplitString(':', line, list, sizeof(list)/sizeof(list[0]));
|
|
|
if( list[0] == NULL || list[1] == NULL || list[2] == NULL)
|
|
|
{
|
|
|
- if (_config->FindB("Debug::pkgDPkgProgressReporting",false) == true)
|
|
|
+ if (Debug == true)
|
|
|
std::clog << "ignoring line: not enough ':'" << std::endl;
|
|
|
return;
|
|
|
}
|
|
|
- char *pkg = list[1];
|
|
|
- char *action = _strstrip(list[2]);
|
|
|
+ const char* const pkg = list[1];
|
|
|
+ const char* action = _strstrip(list[2]);
|
|
|
|
|
|
// 'processing' from dpkg looks like
|
|
|
// 'processing: action: pkg'
|
|
|
if(strncmp(list[0], "processing", strlen("processing")) == 0)
|
|
|
{
|
|
|
char s[200];
|
|
|
- char *pkg_or_trigger = _strstrip(list[2]);
|
|
|
- action =_strstrip( list[1]);
|
|
|
+ const char* const pkg_or_trigger = _strstrip(list[2]);
|
|
|
+ action = _strstrip( list[1]);
|
|
|
const std::pair<const char *, const char *> * const iter =
|
|
|
std::find_if(PackageProcessingOpsBegin,
|
|
|
PackageProcessingOpsEnd,
|
|
|
MatchProcessingOp(action));
|
|
|
if(iter == PackageProcessingOpsEnd)
|
|
|
{
|
|
|
- if (_config->FindB("Debug::pkgDPkgProgressReporting",false) == true)
|
|
|
- std::clog << "ignoring unknwon action: " << action << std::endl;
|
|
|
+ if (Debug == true)
|
|
|
+ std::clog << "ignoring unknown action: " << action << std::endl;
|
|
|
return;
|
|
|
}
|
|
|
snprintf(s, sizeof(s), _(iter->second), pkg_or_trigger);
|
|
|
@@ -440,7 +442,7 @@ void pkgDPkgPM::ProcessDpkgStatusLine(int OutStatusFd, char *line)
|
|
|
<< endl;
|
|
|
if(OutStatusFd > 0)
|
|
|
write(OutStatusFd, status.str().c_str(), status.str().size());
|
|
|
- if (_config->FindB("Debug::pkgDPkgProgressReporting",false) == true)
|
|
|
+ if (Debug == true)
|
|
|
std::clog << "send: '" << status.str() << "'" << endl;
|
|
|
return;
|
|
|
}
|
|
|
@@ -453,11 +455,11 @@ void pkgDPkgPM::ProcessDpkgStatusLine(int OutStatusFd, char *line)
|
|
|
<< endl;
|
|
|
if(OutStatusFd > 0)
|
|
|
write(OutStatusFd, status.str().c_str(), status.str().size());
|
|
|
- if (_config->FindB("Debug::pkgDPkgProgressReporting",false) == true)
|
|
|
+ if (Debug == true)
|
|
|
std::clog << "send: '" << status.str() << "'" << endl;
|
|
|
return;
|
|
|
}
|
|
|
- if(strncmp(action,"conffile",strlen("conffile")) == 0)
|
|
|
+ else if(strncmp(action,"conffile",strlen("conffile")) == 0)
|
|
|
{
|
|
|
status << "pmconffile:" << list[1]
|
|
|
<< ":" << (PackagesDone/float(PackagesTotal)*100.0)
|
|
|
@@ -465,12 +467,12 @@ void pkgDPkgPM::ProcessDpkgStatusLine(int OutStatusFd, char *line)
|
|
|
<< endl;
|
|
|
if(OutStatusFd > 0)
|
|
|
write(OutStatusFd, status.str().c_str(), status.str().size());
|
|
|
- if (_config->FindB("Debug::pkgDPkgProgressReporting",false) == true)
|
|
|
+ if (Debug == true)
|
|
|
std::clog << "send: '" << status.str() << "'" << endl;
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
- vector<struct DpkgState> &states = PackageOps[pkg];
|
|
|
+ vector<struct DpkgState> const &states = PackageOps[pkg];
|
|
|
const char *next_action = NULL;
|
|
|
if(PackageOpsDone[pkg] < states.size())
|
|
|
next_action = states[PackageOpsDone[pkg]].state;
|
|
|
@@ -493,15 +495,15 @@ void pkgDPkgPM::ProcessDpkgStatusLine(int OutStatusFd, char *line)
|
|
|
<< endl;
|
|
|
if(OutStatusFd > 0)
|
|
|
write(OutStatusFd, status.str().c_str(), status.str().size());
|
|
|
- if (_config->FindB("Debug::pkgDPkgProgressReporting",false) == true)
|
|
|
+ if (Debug == true)
|
|
|
std::clog << "send: '" << status.str() << "'" << endl;
|
|
|
}
|
|
|
- if (_config->FindB("Debug::pkgDPkgProgressReporting",false) == true)
|
|
|
+ if (Debug == true)
|
|
|
std::clog << "(parsed from dpkg) pkg: " << pkg
|
|
|
<< " action: " << action << endl;
|
|
|
}
|
|
|
-
|
|
|
-// DPkgPM::DoDpkgStatusFd /*{{{*/
|
|
|
+ /*}}}*/
|
|
|
+// DPkgPM::DoDpkgStatusFd /*{{{*/
|
|
|
// ---------------------------------------------------------------------
|
|
|
/*
|
|
|
*/
|
|
|
@@ -538,7 +540,7 @@ void pkgDPkgPM::DoDpkgStatusFd(int statusfd, int OutStatusFd)
|
|
|
dpkgbuf_pos = dpkgbuf+dpkgbuf_pos-p;
|
|
|
}
|
|
|
/*}}}*/
|
|
|
-
|
|
|
+// DPkgPM::OpenLog /*{{{*/
|
|
|
bool pkgDPkgPM::OpenLog()
|
|
|
{
|
|
|
string logdir = _config->FindDir("Dir::Log");
|
|
|
@@ -561,7 +563,8 @@ bool pkgDPkgPM::OpenLog()
|
|
|
}
|
|
|
return true;
|
|
|
}
|
|
|
-
|
|
|
+ /*}}}*/
|
|
|
+// DPkg::CloseLog /*{{{*/
|
|
|
bool pkgDPkgPM::CloseLog()
|
|
|
{
|
|
|
if(term_out)
|
|
|
@@ -578,7 +581,7 @@ bool pkgDPkgPM::CloseLog()
|
|
|
term_out = NULL;
|
|
|
return true;
|
|
|
}
|
|
|
-
|
|
|
+ /*}}}*/
|
|
|
/*{{{*/
|
|
|
// This implements a racy version of pselect for those architectures
|
|
|
// that don't have a working implementation.
|
|
|
@@ -600,7 +603,6 @@ static int racy_pselect(int nfds, fd_set *readfds, fd_set *writefds,
|
|
|
return retval;
|
|
|
}
|
|
|
/*}}}*/
|
|
|
-
|
|
|
// DPkgPM::Go - Run the sequence /*{{{*/
|
|
|
// ---------------------------------------------------------------------
|
|
|
/* This globs the operations and calls dpkg
|
|
|
@@ -617,9 +619,9 @@ bool pkgDPkgPM::Go(int OutStatusFd)
|
|
|
sigset_t sigmask;
|
|
|
sigset_t original_sigmask;
|
|
|
|
|
|
- unsigned int MaxArgs = _config->FindI("Dpkg::MaxArgs",8*1024);
|
|
|
- unsigned int MaxArgBytes = _config->FindI("Dpkg::MaxArgBytes",32*1024);
|
|
|
- bool NoTriggers = _config->FindB("DPkg::NoTriggers",false);
|
|
|
+ unsigned int const MaxArgs = _config->FindI("Dpkg::MaxArgs",8*1024);
|
|
|
+ unsigned int const MaxArgBytes = _config->FindI("Dpkg::MaxArgBytes",32*1024);
|
|
|
+ bool const NoTriggers = _config->FindB("DPkg::NoTriggers",false);
|
|
|
|
|
|
if (RunScripts("DPkg::Pre-Invoke") == false)
|
|
|
return false;
|
|
|
@@ -662,16 +664,16 @@ bool pkgDPkgPM::Go(int OutStatusFd)
|
|
|
// that will be [installed|configured|removed|purged] and add
|
|
|
// them to the PackageOps map (the dpkg states it goes through)
|
|
|
// and the PackageOpsTranslations (human readable strings)
|
|
|
- for (vector<Item>::iterator I = List.begin(); I != List.end();I++)
|
|
|
+ for (vector<Item>::const_iterator I = List.begin(); I != List.end();I++)
|
|
|
{
|
|
|
- string name = (*I).Pkg.Name();
|
|
|
+ string const name = (*I).Pkg.Name();
|
|
|
PackageOpsDone[name] = 0;
|
|
|
for(int i=0; (DpkgStatesOpMap[(*I).Op][i]).state != NULL; i++)
|
|
|
{
|
|
|
PackageOps[name].push_back(DpkgStatesOpMap[(*I).Op][i]);
|
|
|
PackagesTotal++;
|
|
|
}
|
|
|
- }
|
|
|
+ }
|
|
|
|
|
|
stdin_is_dev_null = false;
|
|
|
|
|
|
@@ -679,9 +681,9 @@ bool pkgDPkgPM::Go(int OutStatusFd)
|
|
|
OpenLog();
|
|
|
|
|
|
// this loop is runs once per operation
|
|
|
- for (vector<Item>::iterator I = List.begin(); I != List.end();)
|
|
|
+ for (vector<Item>::const_iterator I = List.begin(); I != List.end();)
|
|
|
{
|
|
|
- vector<Item>::iterator J = I;
|
|
|
+ vector<Item>::const_iterator J = I;
|
|
|
for (; J != List.end() && J->Op == I->Op; J++)
|
|
|
/* nothing */;
|
|
|
|
|
|
@@ -700,7 +702,7 @@ bool pkgDPkgPM::Go(int OutStatusFd)
|
|
|
|
|
|
unsigned int n = 0;
|
|
|
unsigned long Size = 0;
|
|
|
- string Tmp = _config->Find("Dir::Bin::dpkg","dpkg");
|
|
|
+ string const Tmp = _config->Find("Dir::Bin::dpkg","dpkg");
|
|
|
Args[n++] = Tmp.c_str();
|
|
|
Size += strlen(Args[n-1]);
|
|
|
|
|
|
@@ -750,11 +752,11 @@ bool pkgDPkgPM::Go(int OutStatusFd)
|
|
|
|
|
|
case Item::Configure:
|
|
|
Args[n++] = "--configure";
|
|
|
- if (NoTriggers)
|
|
|
+ if (NoTriggers == true)
|
|
|
Args[n++] = "--no-triggers";
|
|
|
Size += strlen(Args[n-1]);
|
|
|
break;
|
|
|
-
|
|
|
+
|
|
|
case Item::Install:
|
|
|
Args[n++] = "--unpack";
|
|
|
Size += strlen(Args[n-1]);
|
|
|
@@ -913,11 +915,9 @@ bool pkgDPkgPM::Go(int OutStatusFd)
|
|
|
int Status = 0;
|
|
|
|
|
|
// we read from dpkg here
|
|
|
- int _dpkgin = fd[0];
|
|
|
+ int const _dpkgin = fd[0];
|
|
|
close(fd[1]); // close the write end of the pipe
|
|
|
|
|
|
- // the result of the waitpid call
|
|
|
- int res;
|
|
|
if(slave > 0)
|
|
|
close(slave);
|
|
|
|
|
|
@@ -925,6 +925,8 @@ bool pkgDPkgPM::Go(int OutStatusFd)
|
|
|
sigemptyset(&sigmask);
|
|
|
sigprocmask(SIG_BLOCK,&sigmask,&original_sigmask);
|
|
|
|
|
|
+ // the result of the waitpid call
|
|
|
+ int res;
|
|
|
int select_ret;
|
|
|
while ((res=waitpid(Child,&Status, WNOHANG)) != Child) {
|
|
|
if(res < 0) {
|
|
|
@@ -991,7 +993,7 @@ bool pkgDPkgPM::Go(int OutStatusFd)
|
|
|
// if it was set to "keep-dpkg-runing" then we won't return
|
|
|
// here but keep the loop going and just report it as a error
|
|
|
// for later
|
|
|
- bool stopOnError = _config->FindB("Dpkg::StopOnError",true);
|
|
|
+ bool const stopOnError = _config->FindB("Dpkg::StopOnError",true);
|
|
|
|
|
|
if(stopOnError)
|
|
|
RunScripts("DPkg::Post-Invoke");
|