]> git.saurik.com Git - apt.git/blob - apt-pkg/deb/dpkgpm.cc
* apt-pkg/deb/dpkgpm.cc:
[apt.git] / apt-pkg / deb / dpkgpm.cc
1 // -*- mode: cpp; mode: fold -*-
2 // Description /*{{{*/
3 // $Id: dpkgpm.cc,v 1.28 2004/01/27 02:25:01 mdz Exp $
4 /* ######################################################################
5
6 DPKG Package Manager - Provide an interface to dpkg
7
8 ##################################################################### */
9 /*}}}*/
10 // Includes /*{{{*/
11 #include <apt-pkg/dpkgpm.h>
12 #include <apt-pkg/error.h>
13 #include <apt-pkg/configuration.h>
14 #include <apt-pkg/depcache.h>
15 #include <apt-pkg/pkgrecords.h>
16 #include <apt-pkg/strutl.h>
17 #include <apt-pkg/fileutl.h>
18 #include <apt-pkg/cachefile.h>
19
20 #include <unistd.h>
21 #include <stdlib.h>
22 #include <fcntl.h>
23 #include <sys/select.h>
24 #include <sys/stat.h>
25 #include <sys/types.h>
26 #include <sys/wait.h>
27 #include <signal.h>
28 #include <errno.h>
29 #include <string.h>
30 #include <stdio.h>
31 #include <string.h>
32 #include <algorithm>
33 #include <sstream>
34 #include <map>
35 #include <pwd.h>
36 #include <grp.h>
37
38 #include <termios.h>
39 #include <unistd.h>
40 #include <sys/ioctl.h>
41 #include <pty.h>
42
43 #include <config.h>
44 #include <apti18n.h>
45 /*}}}*/
46
47 using namespace std;
48
49 namespace
50 {
51 // Maps the dpkg "processing" info to human readable names. Entry 0
52 // of each array is the key, entry 1 is the value.
53 const std::pair<const char *, const char *> PackageProcessingOps[] = {
54 std::make_pair("install", N_("Installing %s")),
55 std::make_pair("configure", N_("Configuring %s")),
56 std::make_pair("remove", N_("Removing %s")),
57 std::make_pair("purge", N_("Completely removing %s")),
58 std::make_pair("disappear", N_("Noting disappearance of %s")),
59 std::make_pair("trigproc", N_("Running post-installation trigger %s"))
60 };
61
62 const std::pair<const char *, const char *> * const PackageProcessingOpsBegin = PackageProcessingOps;
63 const std::pair<const char *, const char *> * const PackageProcessingOpsEnd = PackageProcessingOps + sizeof(PackageProcessingOps) / sizeof(PackageProcessingOps[0]);
64
65 // Predicate to test whether an entry in the PackageProcessingOps
66 // array matches a string.
67 class MatchProcessingOp
68 {
69 const char *target;
70
71 public:
72 MatchProcessingOp(const char *the_target)
73 : target(the_target)
74 {
75 }
76
77 bool operator()(const std::pair<const char *, const char *> &pair) const
78 {
79 return strcmp(pair.first, target) == 0;
80 }
81 };
82 }
83
84 /* helper function to ionice the given PID
85
86 there is no C header for ionice yet - just the syscall interface
87 so we use the binary from util-linux
88 */
89 static bool
90 ionice(int PID)
91 {
92 if (!FileExists("/usr/bin/ionice"))
93 return false;
94 pid_t Process = ExecFork();
95 if (Process == 0)
96 {
97 char buf[32];
98 snprintf(buf, sizeof(buf), "-p%d", PID);
99 const char *Args[4];
100 Args[0] = "/usr/bin/ionice";
101 Args[1] = "-c3";
102 Args[2] = buf;
103 Args[3] = 0;
104 execv(Args[0], (char **)Args);
105 }
106 return ExecWait(Process, "ionice");
107 }
108
109 // DPkgPM::pkgDPkgPM - Constructor /*{{{*/
110 // ---------------------------------------------------------------------
111 /* */
112 pkgDPkgPM::pkgDPkgPM(pkgDepCache *Cache)
113 : pkgPackageManager(Cache), dpkgbuf_pos(0),
114 term_out(NULL), history_out(NULL), PackagesDone(0), PackagesTotal(0)
115 {
116 }
117 /*}}}*/
118 // DPkgPM::pkgDPkgPM - Destructor /*{{{*/
119 // ---------------------------------------------------------------------
120 /* */
121 pkgDPkgPM::~pkgDPkgPM()
122 {
123 }
124 /*}}}*/
125 // DPkgPM::Install - Install a package /*{{{*/
126 // ---------------------------------------------------------------------
127 /* Add an install operation to the sequence list */
128 bool pkgDPkgPM::Install(PkgIterator Pkg,string File)
129 {
130 if (File.empty() == true || Pkg.end() == true)
131 return _error->Error("Internal Error, No file name for %s",Pkg.Name());
132
133 // If the filename string begins with DPkg::Chroot-Directory, return the
134 // substr that is within the chroot so dpkg can access it.
135 string const chrootdir = _config->FindDir("DPkg::Chroot-Directory","/");
136 if (chrootdir != "/" && File.find(chrootdir) == 0)
137 {
138 size_t len = chrootdir.length();
139 if (chrootdir.at(len - 1) == '/')
140 len--;
141 List.push_back(Item(Item::Install,Pkg,File.substr(len)));
142 }
143 else
144 List.push_back(Item(Item::Install,Pkg,File));
145
146 return true;
147 }
148 /*}}}*/
149 // DPkgPM::Configure - Configure a package /*{{{*/
150 // ---------------------------------------------------------------------
151 /* Add a configure operation to the sequence list */
152 bool pkgDPkgPM::Configure(PkgIterator Pkg)
153 {
154 if (Pkg.end() == true)
155 return false;
156
157 List.push_back(Item(Item::Configure, Pkg));
158
159 // Use triggers for config calls if we configure "smart"
160 // as otherwise Pre-Depends will not be satisfied, see #526774
161 if (_config->FindB("DPkg::TriggersPending", false) == true)
162 List.push_back(Item(Item::TriggersPending, PkgIterator()));
163
164 return true;
165 }
166 /*}}}*/
167 // DPkgPM::Remove - Remove a package /*{{{*/
168 // ---------------------------------------------------------------------
169 /* Add a remove operation to the sequence list */
170 bool pkgDPkgPM::Remove(PkgIterator Pkg,bool Purge)
171 {
172 if (Pkg.end() == true)
173 return false;
174
175 if (Purge == true)
176 List.push_back(Item(Item::Purge,Pkg));
177 else
178 List.push_back(Item(Item::Remove,Pkg));
179 return true;
180 }
181 /*}}}*/
182 // DPkgPM::SendV2Pkgs - Send version 2 package info /*{{{*/
183 // ---------------------------------------------------------------------
184 /* This is part of the helper script communication interface, it sends
185 very complete information down to the other end of the pipe.*/
186 bool pkgDPkgPM::SendV2Pkgs(FILE *F)
187 {
188 fprintf(F,"VERSION 2\n");
189
190 /* Write out all of the configuration directives by walking the
191 configuration tree */
192 const Configuration::Item *Top = _config->Tree(0);
193 for (; Top != 0;)
194 {
195 if (Top->Value.empty() == false)
196 {
197 fprintf(F,"%s=%s\n",
198 QuoteString(Top->FullTag(),"=\"\n").c_str(),
199 QuoteString(Top->Value,"\n").c_str());
200 }
201
202 if (Top->Child != 0)
203 {
204 Top = Top->Child;
205 continue;
206 }
207
208 while (Top != 0 && Top->Next == 0)
209 Top = Top->Parent;
210 if (Top != 0)
211 Top = Top->Next;
212 }
213 fprintf(F,"\n");
214
215 // Write out the package actions in order.
216 for (vector<Item>::iterator I = List.begin(); I != List.end(); ++I)
217 {
218 if(I->Pkg.end() == true)
219 continue;
220
221 pkgDepCache::StateCache &S = Cache[I->Pkg];
222
223 fprintf(F,"%s ",I->Pkg.Name());
224 // Current version
225 if (I->Pkg->CurrentVer == 0)
226 fprintf(F,"- ");
227 else
228 fprintf(F,"%s ",I->Pkg.CurrentVer().VerStr());
229
230 // Show the compare operator
231 // Target version
232 if (S.InstallVer != 0)
233 {
234 int Comp = 2;
235 if (I->Pkg->CurrentVer != 0)
236 Comp = S.InstVerIter(Cache).CompareVer(I->Pkg.CurrentVer());
237 if (Comp < 0)
238 fprintf(F,"> ");
239 if (Comp == 0)
240 fprintf(F,"= ");
241 if (Comp > 0)
242 fprintf(F,"< ");
243 fprintf(F,"%s ",S.InstVerIter(Cache).VerStr());
244 }
245 else
246 fprintf(F,"> - ");
247
248 // Show the filename/operation
249 if (I->Op == Item::Install)
250 {
251 // No errors here..
252 if (I->File[0] != '/')
253 fprintf(F,"**ERROR**\n");
254 else
255 fprintf(F,"%s\n",I->File.c_str());
256 }
257 if (I->Op == Item::Configure)
258 fprintf(F,"**CONFIGURE**\n");
259 if (I->Op == Item::Remove ||
260 I->Op == Item::Purge)
261 fprintf(F,"**REMOVE**\n");
262
263 if (ferror(F) != 0)
264 return false;
265 }
266 return true;
267 }
268 /*}}}*/
269 // DPkgPM::RunScriptsWithPkgs - Run scripts with package names on stdin /*{{{*/
270 // ---------------------------------------------------------------------
271 /* This looks for a list of scripts to run from the configuration file
272 each one is run and is fed on standard input a list of all .deb files
273 that are due to be installed. */
274 bool pkgDPkgPM::RunScriptsWithPkgs(const char *Cnf)
275 {
276 Configuration::Item const *Opts = _config->Tree(Cnf);
277 if (Opts == 0 || Opts->Child == 0)
278 return true;
279 Opts = Opts->Child;
280
281 unsigned int Count = 1;
282 for (; Opts != 0; Opts = Opts->Next, Count++)
283 {
284 if (Opts->Value.empty() == true)
285 continue;
286
287 // Determine the protocol version
288 string OptSec = Opts->Value;
289 string::size_type Pos;
290 if ((Pos = OptSec.find(' ')) == string::npos || Pos == 0)
291 Pos = OptSec.length();
292 OptSec = "DPkg::Tools::Options::" + string(Opts->Value.c_str(),Pos);
293
294 unsigned int Version = _config->FindI(OptSec+"::Version",1);
295
296 // Create the pipes
297 int Pipes[2];
298 if (pipe(Pipes) != 0)
299 return _error->Errno("pipe","Failed to create IPC pipe to subprocess");
300 SetCloseExec(Pipes[0],true);
301 SetCloseExec(Pipes[1],true);
302
303 // Purified Fork for running the script
304 pid_t Process = ExecFork();
305 if (Process == 0)
306 {
307 // Setup the FDs
308 dup2(Pipes[0],STDIN_FILENO);
309 SetCloseExec(STDOUT_FILENO,false);
310 SetCloseExec(STDIN_FILENO,false);
311 SetCloseExec(STDERR_FILENO,false);
312
313 if (_config->FindDir("DPkg::Chroot-Directory","/") != "/")
314 {
315 std::cerr << "Chrooting into "
316 << _config->FindDir("DPkg::Chroot-Directory")
317 << std::endl;
318 if (chroot(_config->FindDir("DPkg::Chroot-Directory","/").c_str()) != 0)
319 _exit(100);
320 }
321
322 const char *Args[4];
323 Args[0] = "/bin/sh";
324 Args[1] = "-c";
325 Args[2] = Opts->Value.c_str();
326 Args[3] = 0;
327 execv(Args[0],(char **)Args);
328 _exit(100);
329 }
330 close(Pipes[0]);
331 FILE *F = fdopen(Pipes[1],"w");
332 if (F == 0)
333 return _error->Errno("fdopen","Faild to open new FD");
334
335 // Feed it the filenames.
336 if (Version <= 1)
337 {
338 for (vector<Item>::iterator I = List.begin(); I != List.end(); ++I)
339 {
340 // Only deal with packages to be installed from .deb
341 if (I->Op != Item::Install)
342 continue;
343
344 // No errors here..
345 if (I->File[0] != '/')
346 continue;
347
348 /* Feed the filename of each package that is pending install
349 into the pipe. */
350 fprintf(F,"%s\n",I->File.c_str());
351 if (ferror(F) != 0)
352 break;
353 }
354 }
355 else
356 SendV2Pkgs(F);
357
358 fclose(F);
359
360 // Clean up the sub process
361 if (ExecWait(Process,Opts->Value.c_str()) == false)
362 return _error->Error("Failure running script %s",Opts->Value.c_str());
363 }
364
365 return true;
366 }
367 /*}}}*/
368 // DPkgPM::DoStdin - Read stdin and pass to slave pty /*{{{*/
369 // ---------------------------------------------------------------------
370 /*
371 */
372 void pkgDPkgPM::DoStdin(int master)
373 {
374 unsigned char input_buf[256] = {0,};
375 ssize_t len = read(0, input_buf, sizeof(input_buf));
376 if (len)
377 write(master, input_buf, len);
378 else
379 stdin_is_dev_null = true;
380 }
381 /*}}}*/
382 // DPkgPM::DoTerminalPty - Read the terminal pty and write log /*{{{*/
383 // ---------------------------------------------------------------------
384 /*
385 * read the terminal pty and write log
386 */
387 void pkgDPkgPM::DoTerminalPty(int master)
388 {
389 unsigned char term_buf[1024] = {0,0, };
390
391 ssize_t len=read(master, term_buf, sizeof(term_buf));
392 if(len == -1 && errno == EIO)
393 {
394 // this happens when the child is about to exit, we
395 // give it time to actually exit, otherwise we run
396 // into a race so we sleep for half a second.
397 struct timespec sleepfor = { 0, 500000000 };
398 nanosleep(&sleepfor, NULL);
399 return;
400 }
401 if(len <= 0)
402 return;
403 write(1, term_buf, len);
404 if(term_out)
405 fwrite(term_buf, len, sizeof(char), term_out);
406 }
407 /*}}}*/
408 // DPkgPM::ProcessDpkgStatusBuf /*{{{*/
409 // ---------------------------------------------------------------------
410 /*
411 */
412 void pkgDPkgPM::ProcessDpkgStatusLine(int OutStatusFd, char *line)
413 {
414 bool const Debug = _config->FindB("Debug::pkgDPkgProgressReporting",false);
415 // the status we output
416 ostringstream status;
417
418 if (Debug == true)
419 std::clog << "got from dpkg '" << line << "'" << std::endl;
420
421
422 /* dpkg sends strings like this:
423 'status: <pkg>: <pkg qstate>'
424 errors look like this:
425 'status: /var/cache/apt/archives/krecipes_0.8.1-0ubuntu1_i386.deb : error : trying to overwrite `/usr/share/doc/kde/HTML/en/krecipes/krectip.png', which is also in package krecipes-data
426 and conffile-prompt like this
427 'status: conffile-prompt: conffile : 'current-conffile' 'new-conffile' useredited distedited
428
429 Newer versions of dpkg sent also:
430 'processing: install: pkg'
431 'processing: configure: pkg'
432 'processing: remove: pkg'
433 'processing: purge: pkg'
434 'processing: disappear: pkg'
435 'processing: trigproc: trigger'
436
437 */
438 char* list[6];
439 // dpkg sends multiline error messages sometimes (see
440 // #374195 for a example. we should support this by
441 // either patching dpkg to not send multiline over the
442 // statusfd or by rewriting the code here to deal with
443 // it. for now we just ignore it and not crash
444 TokSplitString(':', line, list, sizeof(list)/sizeof(list[0]));
445 if( list[0] == NULL || list[1] == NULL || list[2] == NULL)
446 {
447 if (Debug == true)
448 std::clog << "ignoring line: not enough ':'" << std::endl;
449 return;
450 }
451 const char* const pkg = list[1];
452 const char* action = _strstrip(list[2]);
453
454 // 'processing' from dpkg looks like
455 // 'processing: action: pkg'
456 if(strncmp(list[0], "processing", strlen("processing")) == 0)
457 {
458 char s[200];
459 const char* const pkg_or_trigger = _strstrip(list[2]);
460 action = _strstrip( list[1]);
461 const std::pair<const char *, const char *> * const iter =
462 std::find_if(PackageProcessingOpsBegin,
463 PackageProcessingOpsEnd,
464 MatchProcessingOp(action));
465 if(iter == PackageProcessingOpsEnd)
466 {
467 if (Debug == true)
468 std::clog << "ignoring unknown action: " << action << std::endl;
469 return;
470 }
471 snprintf(s, sizeof(s), _(iter->second), pkg_or_trigger);
472
473 status << "pmstatus:" << pkg_or_trigger
474 << ":" << (PackagesDone/float(PackagesTotal)*100.0)
475 << ":" << s
476 << endl;
477 if(OutStatusFd > 0)
478 write(OutStatusFd, status.str().c_str(), status.str().size());
479 if (Debug == true)
480 std::clog << "send: '" << status.str() << "'" << endl;
481
482 if (strncmp(action, "disappear", strlen("disappear")) == 0)
483 handleDisappearAction(pkg_or_trigger);
484 return;
485 }
486
487 if(strncmp(action,"error",strlen("error")) == 0)
488 {
489 // urgs, sometime has ":" in its error string so that we
490 // end up with the error message split between list[3]
491 // and list[4], e.g. the message:
492 // "failed in buffer_write(fd) (10, ret=-1): backend dpkg-deb ..."
493 // concat them again
494 if( list[4] != NULL )
495 list[3][strlen(list[3])] = ':';
496
497 status << "pmerror:" << list[1]
498 << ":" << (PackagesDone/float(PackagesTotal)*100.0)
499 << ":" << list[3]
500 << endl;
501 if(OutStatusFd > 0)
502 write(OutStatusFd, status.str().c_str(), status.str().size());
503 if (Debug == true)
504 std::clog << "send: '" << status.str() << "'" << endl;
505 pkgFailures++;
506 WriteApportReport(list[1], list[3]);
507 return;
508 }
509 else if(strncmp(action,"conffile",strlen("conffile")) == 0)
510 {
511 status << "pmconffile:" << list[1]
512 << ":" << (PackagesDone/float(PackagesTotal)*100.0)
513 << ":" << list[3]
514 << endl;
515 if(OutStatusFd > 0)
516 write(OutStatusFd, status.str().c_str(), status.str().size());
517 if (Debug == true)
518 std::clog << "send: '" << status.str() << "'" << endl;
519 return;
520 }
521
522 vector<struct DpkgState> const &states = PackageOps[pkg];
523 const char *next_action = NULL;
524 if(PackageOpsDone[pkg] < states.size())
525 next_action = states[PackageOpsDone[pkg]].state;
526 // check if the package moved to the next dpkg state
527 if(next_action && (strcmp(action, next_action) == 0))
528 {
529 // only read the translation if there is actually a next
530 // action
531 const char *translation = _(states[PackageOpsDone[pkg]].str);
532 char s[200];
533 snprintf(s, sizeof(s), translation, pkg);
534
535 // we moved from one dpkg state to a new one, report that
536 PackageOpsDone[pkg]++;
537 PackagesDone++;
538 // build the status str
539 status << "pmstatus:" << pkg
540 << ":" << (PackagesDone/float(PackagesTotal)*100.0)
541 << ":" << s
542 << endl;
543 if(OutStatusFd > 0)
544 write(OutStatusFd, status.str().c_str(), status.str().size());
545 if (Debug == true)
546 std::clog << "send: '" << status.str() << "'" << endl;
547 }
548 if (Debug == true)
549 std::clog << "(parsed from dpkg) pkg: " << pkg
550 << " action: " << action << endl;
551 }
552 /*}}}*/
553 // DPkgPM::handleDisappearAction /*{{{*/
554 void pkgDPkgPM::handleDisappearAction(string const &pkgname)
555 {
556 // record the package name for display and stuff later
557 disappearedPkgs.insert(pkgname);
558
559 pkgCache::PkgIterator Pkg = Cache.FindPkg(pkgname);
560 if (unlikely(Pkg.end() == true))
561 return;
562 // the disappeared package was auto-installed - nothing to do
563 if ((Cache[Pkg].Flags & pkgCache::Flag::Auto) == pkgCache::Flag::Auto)
564 return;
565 pkgCache::VerIterator PkgVer = Cache[Pkg].InstVerIter(Cache);
566 if (unlikely(PkgVer.end() == true))
567 return;
568 /* search in the list of dependencies for (Pre)Depends,
569 check if this dependency has a Replaces on our package
570 and if so transfer the manual installed flag to it */
571 for (pkgCache::DepIterator Dep = PkgVer.DependsList(); Dep.end() != true; ++Dep)
572 {
573 if (Dep->Type != pkgCache::Dep::Depends &&
574 Dep->Type != pkgCache::Dep::PreDepends)
575 continue;
576 pkgCache::PkgIterator Tar = Dep.TargetPkg();
577 if (unlikely(Tar.end() == true))
578 continue;
579 // the package is already marked as manual
580 if ((Cache[Tar].Flags & pkgCache::Flag::Auto) != pkgCache::Flag::Auto)
581 continue;
582 pkgCache::VerIterator TarVer = Cache[Tar].InstVerIter(Cache);
583 if (TarVer.end() == true)
584 continue;
585 for (pkgCache::DepIterator Rep = TarVer.DependsList(); Rep.end() != true; ++Rep)
586 {
587 if (Rep->Type != pkgCache::Dep::Replaces)
588 continue;
589 if (Pkg != Rep.TargetPkg())
590 continue;
591 // okay, they are strongly connected - transfer manual-bit
592 if (Debug == true)
593 std::clog << "transfer manual-bit from disappeared »" << pkgname << "« to »" << Tar.FullName() << "«" << std::endl;
594 Cache[Tar].Flags &= ~Flag::Auto;
595 break;
596 }
597 }
598 }
599 /*}}}*/
600 // DPkgPM::DoDpkgStatusFd /*{{{*/
601 // ---------------------------------------------------------------------
602 /*
603 */
604 void pkgDPkgPM::DoDpkgStatusFd(int statusfd, int OutStatusFd)
605 {
606 char *p, *q;
607 int len;
608
609 len=read(statusfd, &dpkgbuf[dpkgbuf_pos], sizeof(dpkgbuf)-dpkgbuf_pos);
610 dpkgbuf_pos += len;
611 if(len <= 0)
612 return;
613
614 // process line by line if we have a buffer
615 p = q = dpkgbuf;
616 while((q=(char*)memchr(p, '\n', dpkgbuf+dpkgbuf_pos-p)) != NULL)
617 {
618 *q = 0;
619 ProcessDpkgStatusLine(OutStatusFd, p);
620 p=q+1; // continue with next line
621 }
622
623 // now move the unprocessed bits (after the final \n that is now a 0x0)
624 // to the start and update dpkgbuf_pos
625 p = (char*)memrchr(dpkgbuf, 0, dpkgbuf_pos);
626 if(p == NULL)
627 return;
628
629 // we are interessted in the first char *after* 0x0
630 p++;
631
632 // move the unprocessed tail to the start and update pos
633 memmove(dpkgbuf, p, p-dpkgbuf);
634 dpkgbuf_pos = dpkgbuf+dpkgbuf_pos-p;
635 }
636 /*}}}*/
637 // DPkgPM::WriteHistoryTag /*{{{*/
638 void pkgDPkgPM::WriteHistoryTag(string const &tag, string value)
639 {
640 size_t const length = value.length();
641 if (length == 0)
642 return;
643 // poor mans rstrip(", ")
644 if (value[length-2] == ',' && value[length-1] == ' ')
645 value.erase(length - 2, 2);
646 fprintf(history_out, "%s: %s\n", tag.c_str(), value.c_str());
647 } /*}}}*/
648 // DPkgPM::OpenLog /*{{{*/
649 bool pkgDPkgPM::OpenLog()
650 {
651 string const logdir = _config->FindDir("Dir::Log");
652 if(CreateAPTDirectoryIfNeeded(logdir, logdir) == false)
653 // FIXME: use a better string after freeze
654 return _error->Error(_("Directory '%s' missing"), logdir.c_str());
655
656 // get current time
657 char timestr[200];
658 time_t const t = time(NULL);
659 struct tm const * const tmp = localtime(&t);
660 strftime(timestr, sizeof(timestr), "%F %T", tmp);
661
662 // open terminal log
663 string const logfile_name = flCombine(logdir,
664 _config->Find("Dir::Log::Terminal"));
665 if (!logfile_name.empty())
666 {
667 term_out = fopen(logfile_name.c_str(),"a");
668 if (term_out == NULL)
669 return _error->WarningE("OpenLog", _("Could not open file '%s'"), logfile_name.c_str());
670 setvbuf(term_out, NULL, _IONBF, 0);
671 SetCloseExec(fileno(term_out), true);
672 struct passwd *pw;
673 struct group *gr;
674 pw = getpwnam("root");
675 gr = getgrnam("adm");
676 if (pw != NULL && gr != NULL)
677 chown(logfile_name.c_str(), pw->pw_uid, gr->gr_gid);
678 chmod(logfile_name.c_str(), 0644);
679 fprintf(term_out, "\nLog started: %s\n", timestr);
680 }
681
682 // write your history
683 string const history_name = flCombine(logdir,
684 _config->Find("Dir::Log::History"));
685 if (!history_name.empty())
686 {
687 history_out = fopen(history_name.c_str(),"a");
688 if (history_out == NULL)
689 return _error->WarningE("OpenLog", _("Could not open file '%s'"), history_name.c_str());
690 chmod(history_name.c_str(), 0644);
691 fprintf(history_out, "\nStart-Date: %s\n", timestr);
692 string remove, purge, install, reinstall, upgrade, downgrade;
693 for (pkgCache::PkgIterator I = Cache.PkgBegin(); I.end() == false; ++I)
694 {
695 enum { CANDIDATE, CANDIDATE_AUTO, CURRENT_CANDIDATE, CURRENT } infostring;
696 string *line = NULL;
697 #define HISTORYINFO(X, Y) { line = &X; infostring = Y; }
698 if (Cache[I].NewInstall() == true)
699 HISTORYINFO(install, CANDIDATE_AUTO)
700 else if (Cache[I].ReInstall() == true)
701 HISTORYINFO(reinstall, CANDIDATE)
702 else if (Cache[I].Upgrade() == true)
703 HISTORYINFO(upgrade, CURRENT_CANDIDATE)
704 else if (Cache[I].Downgrade() == true)
705 HISTORYINFO(downgrade, CURRENT_CANDIDATE)
706 else if (Cache[I].Delete() == true)
707 HISTORYINFO((Cache[I].Purge() ? purge : remove), CURRENT)
708 else
709 continue;
710 #undef HISTORYINFO
711 line->append(I.FullName(false)).append(" (");
712 switch (infostring) {
713 case CANDIDATE: line->append(Cache[I].CandVersion); break;
714 case CANDIDATE_AUTO:
715 line->append(Cache[I].CandVersion);
716 if ((Cache[I].Flags & pkgCache::Flag::Auto) == pkgCache::Flag::Auto)
717 line->append(", automatic");
718 break;
719 case CURRENT_CANDIDATE: line->append(Cache[I].CurVersion).append(", ").append(Cache[I].CandVersion); break;
720 case CURRENT: line->append(Cache[I].CurVersion); break;
721 }
722 line->append("), ");
723 }
724 if (_config->Exists("Commandline::AsString") == true)
725 WriteHistoryTag("Commandline", _config->Find("Commandline::AsString"));
726 WriteHistoryTag("Install", install);
727 WriteHistoryTag("Reinstall", reinstall);
728 WriteHistoryTag("Upgrade", upgrade);
729 WriteHistoryTag("Downgrade",downgrade);
730 WriteHistoryTag("Remove",remove);
731 WriteHistoryTag("Purge",purge);
732 fflush(history_out);
733 }
734
735 return true;
736 }
737 /*}}}*/
738 // DPkg::CloseLog /*{{{*/
739 bool pkgDPkgPM::CloseLog()
740 {
741 char timestr[200];
742 time_t t = time(NULL);
743 struct tm *tmp = localtime(&t);
744 strftime(timestr, sizeof(timestr), "%F %T", tmp);
745
746 if(term_out)
747 {
748 fprintf(term_out, "Log ended: ");
749 fprintf(term_out, "%s", timestr);
750 fprintf(term_out, "\n");
751 fclose(term_out);
752 }
753 term_out = NULL;
754
755 if(history_out)
756 {
757 if (disappearedPkgs.empty() == false)
758 {
759 string disappear;
760 for (std::set<std::string>::const_iterator d = disappearedPkgs.begin();
761 d != disappearedPkgs.end(); ++d)
762 {
763 pkgCache::PkgIterator P = Cache.FindPkg(*d);
764 disappear.append(*d);
765 if (P.end() == true)
766 disappear.append(", ");
767 else
768 disappear.append(" (").append(Cache[P].CurVersion).append("), ");
769 }
770 WriteHistoryTag("Disappeared", disappear);
771 }
772 if (dpkg_error.empty() == false)
773 fprintf(history_out, "Error: %s\n", dpkg_error.c_str());
774 fprintf(history_out, "End-Date: %s\n", timestr);
775 fclose(history_out);
776 }
777 history_out = NULL;
778
779 return true;
780 }
781 /*}}}*/
782 /*{{{*/
783 // This implements a racy version of pselect for those architectures
784 // that don't have a working implementation.
785 // FIXME: Probably can be removed on Lenny+1
786 static int racy_pselect(int nfds, fd_set *readfds, fd_set *writefds,
787 fd_set *exceptfds, const struct timespec *timeout,
788 const sigset_t *sigmask)
789 {
790 sigset_t origmask;
791 struct timeval tv;
792 int retval;
793
794 tv.tv_sec = timeout->tv_sec;
795 tv.tv_usec = timeout->tv_nsec/1000;
796
797 sigprocmask(SIG_SETMASK, sigmask, &origmask);
798 retval = select(nfds, readfds, writefds, exceptfds, &tv);
799 sigprocmask(SIG_SETMASK, &origmask, 0);
800 return retval;
801 }
802 /*}}}*/
803 // DPkgPM::Go - Run the sequence /*{{{*/
804 // ---------------------------------------------------------------------
805 /* This globs the operations and calls dpkg
806 *
807 * If it is called with "OutStatusFd" set to a valid file descriptor
808 * apt will report the install progress over this fd. It maps the
809 * dpkg states a package goes through to human readable (and i10n-able)
810 * names and calculates a percentage for each step.
811 */
812 bool pkgDPkgPM::Go(int OutStatusFd)
813 {
814 fd_set rfds;
815 struct timespec tv;
816 sigset_t sigmask;
817 sigset_t original_sigmask;
818
819 unsigned int const MaxArgs = _config->FindI("Dpkg::MaxArgs",8*1024);
820 unsigned int const MaxArgBytes = _config->FindI("Dpkg::MaxArgBytes",32*1024);
821 bool const NoTriggers = _config->FindB("DPkg::NoTriggers", false);
822
823 if (RunScripts("DPkg::Pre-Invoke") == false)
824 return false;
825
826 if (RunScriptsWithPkgs("DPkg::Pre-Install-Pkgs") == false)
827 return false;
828
829 // support subpressing of triggers processing for special
830 // cases like d-i that runs the triggers handling manually
831 bool const SmartConf = (_config->Find("PackageManager::Configure", "all") != "all");
832 bool const TriggersPending = _config->FindB("DPkg::TriggersPending", false);
833 if (_config->FindB("DPkg::ConfigurePending", SmartConf) == true)
834 List.push_back(Item(Item::ConfigurePending, PkgIterator()));
835
836 // map the dpkg states to the operations that are performed
837 // (this is sorted in the same way as Item::Ops)
838 static const struct DpkgState DpkgStatesOpMap[][7] = {
839 // Install operation
840 {
841 {"half-installed", N_("Preparing %s")},
842 {"unpacked", N_("Unpacking %s") },
843 {NULL, NULL}
844 },
845 // Configure operation
846 {
847 {"unpacked",N_("Preparing to configure %s") },
848 {"half-configured", N_("Configuring %s") },
849 { "installed", N_("Installed %s")},
850 {NULL, NULL}
851 },
852 // Remove operation
853 {
854 {"half-configured", N_("Preparing for removal of %s")},
855 {"half-installed", N_("Removing %s")},
856 {"config-files", N_("Removed %s")},
857 {NULL, NULL}
858 },
859 // Purge operation
860 {
861 {"config-files", N_("Preparing to completely remove %s")},
862 {"not-installed", N_("Completely removed %s")},
863 {NULL, NULL}
864 },
865 };
866
867 // init the PackageOps map, go over the list of packages that
868 // that will be [installed|configured|removed|purged] and add
869 // them to the PackageOps map (the dpkg states it goes through)
870 // and the PackageOpsTranslations (human readable strings)
871 for (vector<Item>::const_iterator I = List.begin(); I != List.end(); ++I)
872 {
873 if((*I).Pkg.end() == true)
874 continue;
875
876 string const name = (*I).Pkg.Name();
877 PackageOpsDone[name] = 0;
878 for(int i=0; (DpkgStatesOpMap[(*I).Op][i]).state != NULL; ++i)
879 {
880 PackageOps[name].push_back(DpkgStatesOpMap[(*I).Op][i]);
881 PackagesTotal++;
882 }
883 }
884
885 stdin_is_dev_null = false;
886
887 // create log
888 OpenLog();
889
890 // Generate the base argument list for dpkg
891 std::vector<const char *> Args;
892 unsigned long StartSize = 0;
893 string const Tmp = _config->Find("Dir::Bin::dpkg","dpkg");
894 Args.push_back(Tmp.c_str());
895 StartSize += Tmp.length();
896
897 // Stick in any custom dpkg options
898 Configuration::Item const *Opts = _config->Tree("DPkg::Options");
899 if (Opts != 0)
900 {
901 Opts = Opts->Child;
902 for (; Opts != 0; Opts = Opts->Next)
903 {
904 if (Opts->Value.empty() == true)
905 continue;
906 Args.push_back(Opts->Value.c_str());
907 StartSize += Opts->Value.length();
908 }
909 }
910 size_t const BaseArgs = Args.size();
911
912 // this loop is runs once per operation
913 for (vector<Item>::const_iterator I = List.begin(); I != List.end();)
914 {
915 // Do all actions with the same Op in one run
916 vector<Item>::const_iterator J = I;
917 if (TriggersPending == true)
918 for (; J != List.end(); ++J)
919 {
920 if (J->Op == I->Op)
921 continue;
922 if (J->Op != Item::TriggersPending)
923 break;
924 vector<Item>::const_iterator T = J + 1;
925 if (T != List.end() && T->Op == I->Op)
926 continue;
927 break;
928 }
929 else
930 for (; J != List.end() && J->Op == I->Op; ++J)
931 /* nothing */;
932
933 // keep track of allocated strings for multiarch package names
934 std::vector<char *> Packages;
935
936 // start with the baseset of arguments
937 unsigned long Size = StartSize;
938 Args.erase(Args.begin() + BaseArgs, Args.end());
939
940 // Now check if we are within the MaxArgs limit
941 //
942 // this code below is problematic, because it may happen that
943 // the argument list is split in a way that A depends on B
944 // and they are in the same "--configure A B" run
945 // - with the split they may now be configured in different
946 // runs
947 if (J - I > (signed)MaxArgs)
948 {
949 J = I + MaxArgs;
950 Args.reserve(MaxArgs + 10);
951 }
952 else
953 {
954 Args.reserve((J - I) + 10);
955 }
956
957
958 int fd[2];
959 pipe(fd);
960
961 #define ADDARG(X) Args.push_back(X); Size += strlen(X)
962 #define ADDARGC(X) Args.push_back(X); Size += sizeof(X) - 1
963
964 ADDARGC("--status-fd");
965 char status_fd_buf[20];
966 snprintf(status_fd_buf,sizeof(status_fd_buf),"%i", fd[1]);
967 ADDARG(status_fd_buf);
968
969 switch (I->Op)
970 {
971 case Item::Remove:
972 ADDARGC("--force-depends");
973 ADDARGC("--force-remove-essential");
974 ADDARGC("--remove");
975 break;
976
977 case Item::Purge:
978 ADDARGC("--force-depends");
979 ADDARGC("--force-remove-essential");
980 ADDARGC("--purge");
981 break;
982
983 case Item::Configure:
984 ADDARGC("--configure");
985 break;
986
987 case Item::ConfigurePending:
988 ADDARGC("--configure");
989 ADDARGC("--pending");
990 break;
991
992 case Item::TriggersPending:
993 ADDARGC("--triggers-only");
994 ADDARGC("--pending");
995 break;
996
997 case Item::Install:
998 ADDARGC("--unpack");
999 ADDARGC("--auto-deconfigure");
1000 break;
1001 }
1002
1003 if (NoTriggers == true && I->Op != Item::TriggersPending &&
1004 I->Op != Item::ConfigurePending)
1005 {
1006 ADDARGC("--no-triggers");
1007 }
1008 #undef ADDARGC
1009
1010 // Write in the file or package names
1011 if (I->Op == Item::Install)
1012 {
1013 for (;I != J && Size < MaxArgBytes; ++I)
1014 {
1015 if (I->File[0] != '/')
1016 return _error->Error("Internal Error, Pathname to install is not absolute '%s'",I->File.c_str());
1017 Args.push_back(I->File.c_str());
1018 Size += I->File.length();
1019 }
1020 }
1021 else
1022 {
1023 string const nativeArch = _config->Find("APT::Architecture");
1024 unsigned long const oldSize = I->Op == Item::Configure ? Size : 0;
1025 for (;I != J && Size < MaxArgBytes; ++I)
1026 {
1027 if((*I).Pkg.end() == true)
1028 continue;
1029 if (I->Op == Item::Configure && disappearedPkgs.find(I->Pkg.Name()) != disappearedPkgs.end())
1030 continue;
1031 if (I->Pkg.Arch() == nativeArch || !strcmp(I->Pkg.Arch(), "all"))
1032 {
1033 char const * const name = I->Pkg.Name();
1034 ADDARG(name);
1035 }
1036 else
1037 {
1038 char * const fullname = strdup(I->Pkg.FullName(false).c_str());
1039 Packages.push_back(fullname);
1040 ADDARG(fullname);
1041 }
1042 }
1043 // skip configure action if all sheduled packages disappeared
1044 if (oldSize == Size)
1045 continue;
1046 }
1047 #undef ADDARG
1048
1049 J = I;
1050
1051 if (_config->FindB("Debug::pkgDPkgPM",false) == true)
1052 {
1053 for (std::vector<const char *>::const_iterator a = Args.begin();
1054 a != Args.end(); ++a)
1055 clog << *a << ' ';
1056 clog << endl;
1057 continue;
1058 }
1059 Args.push_back(NULL);
1060
1061 cout << flush;
1062 clog << flush;
1063 cerr << flush;
1064
1065 /* Mask off sig int/quit. We do this because dpkg also does when
1066 it forks scripts. What happens is that when you hit ctrl-c it sends
1067 it to all processes in the group. Since dpkg ignores the signal
1068 it doesn't die but we do! So we must also ignore it */
1069 sighandler_t old_SIGQUIT = signal(SIGQUIT,SIG_IGN);
1070 sighandler_t old_SIGINT = signal(SIGINT,SIG_IGN);
1071
1072 // ignore SIGHUP as well (debian #463030)
1073 sighandler_t old_SIGHUP = signal(SIGHUP,SIG_IGN);
1074
1075 struct termios tt;
1076 struct winsize win;
1077 int master = -1;
1078 int slave = -1;
1079
1080 // if tcgetattr does not return zero there was a error
1081 // and we do not do any pty magic
1082 if (tcgetattr(0, &tt) == 0)
1083 {
1084 ioctl(0, TIOCGWINSZ, (char *)&win);
1085 if (openpty(&master, &slave, NULL, &tt, &win) < 0)
1086 {
1087 const char *s = _("Can not write log, openpty() "
1088 "failed (/dev/pts not mounted?)\n");
1089 fprintf(stderr, "%s",s);
1090 if(term_out)
1091 fprintf(term_out, "%s",s);
1092 master = slave = -1;
1093 } else {
1094 struct termios rtt;
1095 rtt = tt;
1096 cfmakeraw(&rtt);
1097 rtt.c_lflag &= ~ECHO;
1098 rtt.c_lflag |= ISIG;
1099 // block SIGTTOU during tcsetattr to prevent a hang if
1100 // the process is a member of the background process group
1101 // http://www.opengroup.org/onlinepubs/000095399/functions/tcsetattr.html
1102 sigemptyset(&sigmask);
1103 sigaddset(&sigmask, SIGTTOU);
1104 sigprocmask(SIG_BLOCK,&sigmask, &original_sigmask);
1105 tcsetattr(0, TCSAFLUSH, &rtt);
1106 sigprocmask(SIG_SETMASK, &original_sigmask, 0);
1107 }
1108 }
1109
1110 // Fork dpkg
1111 pid_t Child;
1112 _config->Set("APT::Keep-Fds::",fd[1]);
1113 // send status information that we are about to fork dpkg
1114 if(OutStatusFd > 0) {
1115 ostringstream status;
1116 status << "pmstatus:dpkg-exec:"
1117 << (PackagesDone/float(PackagesTotal)*100.0)
1118 << ":" << _("Running dpkg")
1119 << endl;
1120 write(OutStatusFd, status.str().c_str(), status.str().size());
1121 }
1122 Child = ExecFork();
1123
1124 // This is the child
1125 if (Child == 0)
1126 {
1127 if(slave >= 0 && master >= 0)
1128 {
1129 setsid();
1130 ioctl(slave, TIOCSCTTY, 0);
1131 close(master);
1132 dup2(slave, 0);
1133 dup2(slave, 1);
1134 dup2(slave, 2);
1135 close(slave);
1136 }
1137 close(fd[0]); // close the read end of the pipe
1138
1139 if (_config->FindDir("DPkg::Chroot-Directory","/") != "/")
1140 {
1141 std::cerr << "Chrooting into "
1142 << _config->FindDir("DPkg::Chroot-Directory")
1143 << std::endl;
1144 if (chroot(_config->FindDir("DPkg::Chroot-Directory","/").c_str()) != 0)
1145 _exit(100);
1146 }
1147
1148 if (chdir(_config->FindDir("DPkg::Run-Directory","/").c_str()) != 0)
1149 _exit(100);
1150
1151 if (_config->FindB("DPkg::FlushSTDIN",true) == true && isatty(STDIN_FILENO))
1152 {
1153 int Flags,dummy;
1154 if ((Flags = fcntl(STDIN_FILENO,F_GETFL,dummy)) < 0)
1155 _exit(100);
1156
1157 // Discard everything in stdin before forking dpkg
1158 if (fcntl(STDIN_FILENO,F_SETFL,Flags | O_NONBLOCK) < 0)
1159 _exit(100);
1160
1161 while (read(STDIN_FILENO,&dummy,1) == 1);
1162
1163 if (fcntl(STDIN_FILENO,F_SETFL,Flags & (~(long)O_NONBLOCK)) < 0)
1164 _exit(100);
1165 }
1166
1167 /* No Job Control Stop Env is a magic dpkg var that prevents it
1168 from using sigstop */
1169 putenv((char *)"DPKG_NO_TSTP=yes");
1170 execvp(Args[0], (char**) &Args[0]);
1171 cerr << "Could not exec dpkg!" << endl;
1172 _exit(100);
1173 }
1174
1175 // apply ionice
1176 if (_config->FindB("DPkg::UseIoNice", false) == true)
1177 ionice(Child);
1178
1179 // clear the Keep-Fd again
1180 _config->Clear("APT::Keep-Fds",fd[1]);
1181
1182 // Wait for dpkg
1183 int Status = 0;
1184
1185 // we read from dpkg here
1186 int const _dpkgin = fd[0];
1187 close(fd[1]); // close the write end of the pipe
1188
1189 if(slave > 0)
1190 close(slave);
1191
1192 // setups fds
1193 sigemptyset(&sigmask);
1194 sigprocmask(SIG_BLOCK,&sigmask,&original_sigmask);
1195
1196 /* free vectors (and therefore memory) as we don't need the included data anymore */
1197 for (std::vector<char *>::const_iterator p = Packages.begin();
1198 p != Packages.end(); ++p)
1199 free(*p);
1200 Packages.clear();
1201
1202 // the result of the waitpid call
1203 int res;
1204 int select_ret;
1205 while ((res=waitpid(Child,&Status, WNOHANG)) != Child) {
1206 if(res < 0) {
1207 // FIXME: move this to a function or something, looks ugly here
1208 // error handling, waitpid returned -1
1209 if (errno == EINTR)
1210 continue;
1211 RunScripts("DPkg::Post-Invoke");
1212
1213 // Restore sig int/quit
1214 signal(SIGQUIT,old_SIGQUIT);
1215 signal(SIGINT,old_SIGINT);
1216 signal(SIGHUP,old_SIGHUP);
1217 return _error->Errno("waitpid","Couldn't wait for subprocess");
1218 }
1219
1220 // wait for input or output here
1221 FD_ZERO(&rfds);
1222 if (master >= 0 && !stdin_is_dev_null)
1223 FD_SET(0, &rfds);
1224 FD_SET(_dpkgin, &rfds);
1225 if(master >= 0)
1226 FD_SET(master, &rfds);
1227 tv.tv_sec = 1;
1228 tv.tv_nsec = 0;
1229 select_ret = pselect(max(master, _dpkgin)+1, &rfds, NULL, NULL,
1230 &tv, &original_sigmask);
1231 if (select_ret < 0 && (errno == EINVAL || errno == ENOSYS))
1232 select_ret = racy_pselect(max(master, _dpkgin)+1, &rfds, NULL,
1233 NULL, &tv, &original_sigmask);
1234 if (select_ret == 0)
1235 continue;
1236 else if (select_ret < 0 && errno == EINTR)
1237 continue;
1238 else if (select_ret < 0)
1239 {
1240 perror("select() returned error");
1241 continue;
1242 }
1243
1244 if(master >= 0 && FD_ISSET(master, &rfds))
1245 DoTerminalPty(master);
1246 if(master >= 0 && FD_ISSET(0, &rfds))
1247 DoStdin(master);
1248 if(FD_ISSET(_dpkgin, &rfds))
1249 DoDpkgStatusFd(_dpkgin, OutStatusFd);
1250 }
1251 close(_dpkgin);
1252
1253 // Restore sig int/quit
1254 signal(SIGQUIT,old_SIGQUIT);
1255 signal(SIGINT,old_SIGINT);
1256 signal(SIGHUP,old_SIGHUP);
1257
1258 if(master >= 0)
1259 {
1260 tcsetattr(0, TCSAFLUSH, &tt);
1261 close(master);
1262 }
1263
1264 // Check for an error code.
1265 if (WIFEXITED(Status) == 0 || WEXITSTATUS(Status) != 0)
1266 {
1267 // if it was set to "keep-dpkg-runing" then we won't return
1268 // here but keep the loop going and just report it as a error
1269 // for later
1270 bool const stopOnError = _config->FindB("Dpkg::StopOnError",true);
1271
1272 if(stopOnError)
1273 RunScripts("DPkg::Post-Invoke");
1274
1275 if (WIFSIGNALED(Status) != 0 && WTERMSIG(Status) == SIGSEGV)
1276 strprintf(dpkg_error, "Sub-process %s received a segmentation fault.",Args[0]);
1277 else if (WIFEXITED(Status) != 0)
1278 strprintf(dpkg_error, "Sub-process %s returned an error code (%u)",Args[0],WEXITSTATUS(Status));
1279 else
1280 strprintf(dpkg_error, "Sub-process %s exited unexpectedly",Args[0]);
1281
1282 if(dpkg_error.size() > 0)
1283 _error->Error("%s", dpkg_error.c_str());
1284
1285 if(stopOnError)
1286 {
1287 CloseLog();
1288 return false;
1289 }
1290 }
1291 }
1292 CloseLog();
1293
1294 if (RunScripts("DPkg::Post-Invoke") == false)
1295 return false;
1296
1297 if (_config->FindB("Debug::pkgDPkgPM",false) == false)
1298 {
1299 std::string const oldpkgcache = _config->FindFile("Dir::cache::pkgcache");
1300 if (oldpkgcache.empty() == false && RealFileExists(oldpkgcache) == true &&
1301 unlink(oldpkgcache.c_str()) == 0)
1302 {
1303 std::string const srcpkgcache = _config->FindFile("Dir::cache::srcpkgcache");
1304 if (srcpkgcache.empty() == false && RealFileExists(srcpkgcache) == true)
1305 {
1306 _error->PushToStack();
1307 pkgCacheFile CacheFile;
1308 CacheFile.BuildCaches(NULL, true);
1309 _error->RevertToStack();
1310 }
1311 }
1312 }
1313
1314 Cache.writeStateFile(NULL);
1315 return true;
1316 }
1317 /*}}}*/
1318 // pkgDpkgPM::Reset - Dump the contents of the command list /*{{{*/
1319 // ---------------------------------------------------------------------
1320 /* */
1321 void pkgDPkgPM::Reset()
1322 {
1323 List.erase(List.begin(),List.end());
1324 }
1325 /*}}}*/
1326 // pkgDpkgPM::WriteApportReport - write out error report pkg failure /*{{{*/
1327 // ---------------------------------------------------------------------
1328 /* */
1329 void pkgDPkgPM::WriteApportReport(const char *pkgpath, const char *errormsg)
1330 {
1331 string pkgname, reportfile, srcpkgname, pkgver, arch;
1332 string::size_type pos;
1333 FILE *report;
1334
1335 if (_config->FindB("Dpkg::ApportFailureReport", false) == false)
1336 {
1337 std::clog << "configured to not write apport reports" << std::endl;
1338 return;
1339 }
1340
1341 // only report the first errors
1342 if(pkgFailures > _config->FindI("APT::Apport::MaxReports", 3))
1343 {
1344 std::clog << _("No apport report written because MaxReports is reached already") << std::endl;
1345 return;
1346 }
1347
1348 // check if its not a follow up error
1349 const char *needle = dgettext("dpkg", "dependency problems - leaving unconfigured");
1350 if(strstr(errormsg, needle) != NULL) {
1351 std::clog << _("No apport report written because the error message indicates its a followup error from a previous failure.") << std::endl;
1352 return;
1353 }
1354
1355 // do not report disk-full failures
1356 if(strstr(errormsg, strerror(ENOSPC)) != NULL) {
1357 std::clog << _("No apport report written because the error message indicates a disk full error") << std::endl;
1358 return;
1359 }
1360
1361 // do not report out-of-memory failures
1362 if(strstr(errormsg, strerror(ENOMEM)) != NULL) {
1363 std::clog << _("No apport report written because the error message indicates a out of memory error") << std::endl;
1364 return;
1365 }
1366
1367 // do not report dpkg I/O errors
1368 // XXX - this message is localized, but this only matches the English version. This is better than nothing.
1369 if(strstr(errormsg, "short read in buffer_copy (")) {
1370 std::clog << _("No apport report written because the error message indicates a dpkg I/O error") << std::endl;
1371 return;
1372 }
1373
1374 // get the pkgname and reportfile
1375 pkgname = flNotDir(pkgpath);
1376 pos = pkgname.find('_');
1377 if(pos != string::npos)
1378 pkgname = pkgname.substr(0, pos);
1379
1380 // find the package versin and source package name
1381 pkgCache::PkgIterator Pkg = Cache.FindPkg(pkgname);
1382 if (Pkg.end() == true)
1383 return;
1384 pkgCache::VerIterator Ver = Cache.GetCandidateVer(Pkg);
1385 if (Ver.end() == true)
1386 return;
1387 pkgver = Ver.VerStr() == NULL ? "unknown" : Ver.VerStr();
1388 pkgRecords Recs(Cache);
1389 pkgRecords::Parser &Parse = Recs.Lookup(Ver.FileList());
1390 srcpkgname = Parse.SourcePkg();
1391 if(srcpkgname.empty())
1392 srcpkgname = pkgname;
1393
1394 // if the file exists already, we check:
1395 // - if it was reported already (touched by apport).
1396 // If not, we do nothing, otherwise
1397 // we overwrite it. This is the same behaviour as apport
1398 // - if we have a report with the same pkgversion already
1399 // then we skip it
1400 reportfile = flCombine("/var/crash",pkgname+".0.crash");
1401 if(FileExists(reportfile))
1402 {
1403 struct stat buf;
1404 char strbuf[255];
1405
1406 // check atime/mtime
1407 stat(reportfile.c_str(), &buf);
1408 if(buf.st_mtime > buf.st_atime)
1409 return;
1410
1411 // check if the existing report is the same version
1412 report = fopen(reportfile.c_str(),"r");
1413 while(fgets(strbuf, sizeof(strbuf), report) != NULL)
1414 {
1415 if(strstr(strbuf,"Package:") == strbuf)
1416 {
1417 char pkgname[255], version[255];
1418 if(sscanf(strbuf, "Package: %s %s", pkgname, version) == 2)
1419 if(strcmp(pkgver.c_str(), version) == 0)
1420 {
1421 fclose(report);
1422 return;
1423 }
1424 }
1425 }
1426 fclose(report);
1427 }
1428
1429 // now write the report
1430 arch = _config->Find("APT::Architecture");
1431 report = fopen(reportfile.c_str(),"w");
1432 if(report == NULL)
1433 return;
1434 if(_config->FindB("DPkgPM::InitialReportOnly",false) == true)
1435 chmod(reportfile.c_str(), 0);
1436 else
1437 chmod(reportfile.c_str(), 0600);
1438 fprintf(report, "ProblemType: Package\n");
1439 fprintf(report, "Architecture: %s\n", arch.c_str());
1440 time_t now = time(NULL);
1441 fprintf(report, "Date: %s" , ctime(&now));
1442 fprintf(report, "Package: %s %s\n", pkgname.c_str(), pkgver.c_str());
1443 fprintf(report, "SourcePackage: %s\n", srcpkgname.c_str());
1444 fprintf(report, "ErrorMessage:\n %s\n", errormsg);
1445
1446 // ensure that the log is flushed
1447 if(term_out)
1448 fflush(term_out);
1449
1450 // attach terminal log it if we have it
1451 string logfile_name = _config->FindFile("Dir::Log::Terminal");
1452 if (!logfile_name.empty())
1453 {
1454 FILE *log = NULL;
1455 char buf[1024];
1456
1457 fprintf(report, "DpkgTerminalLog:\n");
1458 log = fopen(logfile_name.c_str(),"r");
1459 if(log != NULL)
1460 {
1461 while( fgets(buf, sizeof(buf), log) != NULL)
1462 fprintf(report, " %s", buf);
1463 fclose(log);
1464 }
1465 }
1466
1467 // log the ordering
1468 const char *ops_str[] = {"Install", "Configure","Remove","Purge"};
1469 fprintf(report, "AptOrdering:\n");
1470 for (vector<Item>::iterator I = List.begin(); I != List.end(); ++I)
1471 fprintf(report, " %s: %s\n", (*I).Pkg.Name(), ops_str[(*I).Op]);
1472
1473 // attach dmesg log (to learn about segfaults)
1474 if (FileExists("/bin/dmesg"))
1475 {
1476 FILE *log = NULL;
1477 char buf[1024];
1478
1479 fprintf(report, "Dmesg:\n");
1480 log = popen("/bin/dmesg","r");
1481 if(log != NULL)
1482 {
1483 while( fgets(buf, sizeof(buf), log) != NULL)
1484 fprintf(report, " %s", buf);
1485 pclose(log);
1486 }
1487 }
1488
1489 // attach df -l log (to learn about filesystem status)
1490 if (FileExists("/bin/df"))
1491 {
1492 FILE *log = NULL;
1493 char buf[1024];
1494
1495 fprintf(report, "Df:\n");
1496 log = popen("/bin/df -l","r");
1497 if(log != NULL)
1498 {
1499 while( fgets(buf, sizeof(buf), log) != NULL)
1500 fprintf(report, " %s", buf);
1501 pclose(log);
1502 }
1503 }
1504
1505 fclose(report);
1506
1507 }
1508 /*}}}*/