]>
Commit | Line | Data |
---|---|---|
1 | /* | |
2 | */ | |
3 | #include<config.h> | |
4 | ||
5 | #include<apt-pkg/init.h> | |
6 | #include<apt-pkg/error.h> | |
7 | #include<apt-pkg/cdromutl.h> | |
8 | #include<apt-pkg/strutl.h> | |
9 | #include<apt-pkg/cdrom.h> | |
10 | #include<apt-pkg/aptconfiguration.h> | |
11 | #include<apt-pkg/configuration.h> | |
12 | #include<apt-pkg/fileutl.h> | |
13 | ||
14 | #include<sstream> | |
15 | #include<fstream> | |
16 | #include <sys/stat.h> | |
17 | #include <fcntl.h> | |
18 | #include <dirent.h> | |
19 | #include <unistd.h> | |
20 | #include <stdio.h> | |
21 | #include <algorithm> | |
22 | #include <dlfcn.h> | |
23 | ||
24 | #include "indexcopy.h" | |
25 | ||
26 | #include<apti18n.h> | |
27 | ||
28 | using namespace std; | |
29 | ||
30 | // FindPackages - Find the package files on the CDROM /*{{{*/ | |
31 | // --------------------------------------------------------------------- | |
32 | /* We look over the cdrom for package files. This is a recursive | |
33 | search that short circuits when it his a package file in the dir. | |
34 | This speeds it up greatly as the majority of the size is in the | |
35 | binary-* sub dirs. */ | |
36 | bool pkgCdrom::FindPackages(string CD, | |
37 | vector<string> &List, | |
38 | vector<string> &SList, | |
39 | vector<string> &SigList, | |
40 | vector<string> &TransList, | |
41 | string &InfoDir, pkgCdromStatus *log, | |
42 | unsigned int Depth) | |
43 | { | |
44 | static ino_t Inodes[9]; | |
45 | DIR *D; | |
46 | ||
47 | // if we have a look we "pulse" now | |
48 | if(log) | |
49 | log->Update(); | |
50 | ||
51 | if (Depth >= 7) | |
52 | return true; | |
53 | ||
54 | if (CD[CD.length()-1] != '/') | |
55 | CD += '/'; | |
56 | ||
57 | if (chdir(CD.c_str()) != 0) | |
58 | return _error->Errno("chdir","Unable to change to %s",CD.c_str()); | |
59 | ||
60 | // Look for a .disk subdirectory | |
61 | if (DirectoryExists(".disk") == true) | |
62 | { | |
63 | if (InfoDir.empty() == true) | |
64 | InfoDir = CD + ".disk/"; | |
65 | } | |
66 | ||
67 | // Don't look into directories that have been marked to ingore. | |
68 | if (RealFileExists(".aptignr") == true) | |
69 | return true; | |
70 | ||
71 | /* Check _first_ for a signature file as apt-cdrom assumes that all files | |
72 | under a Packages/Source file are in control of that file and stops | |
73 | the scanning | |
74 | */ | |
75 | if (RealFileExists("Release.gpg") == true || RealFileExists("InRelease") == true) | |
76 | { | |
77 | SigList.push_back(CD); | |
78 | } | |
79 | ||
80 | /* Aha! We found some package files. We assume that everything under | |
81 | this dir is controlled by those package files so we don't look down | |
82 | anymore */ | |
83 | std::vector<APT::Configuration::Compressor> const compressor = APT::Configuration::getCompressors(); | |
84 | for (std::vector<APT::Configuration::Compressor>::const_iterator c = compressor.begin(); | |
85 | c != compressor.end(); ++c) | |
86 | { | |
87 | if (RealFileExists(std::string("Packages").append(c->Extension).c_str()) == false) | |
88 | continue; | |
89 | ||
90 | if (_config->FindB("Debug::aptcdrom",false) == true) | |
91 | std::clog << "Found Packages in " << CD << std::endl; | |
92 | List.push_back(CD); | |
93 | ||
94 | // Continue down if thorough is given | |
95 | if (_config->FindB("APT::CDROM::Thorough",false) == false) | |
96 | return true; | |
97 | break; | |
98 | } | |
99 | for (std::vector<APT::Configuration::Compressor>::const_iterator c = compressor.begin(); | |
100 | c != compressor.end(); ++c) | |
101 | { | |
102 | if (RealFileExists(std::string("Sources").append(c->Extension).c_str()) == false) | |
103 | continue; | |
104 | ||
105 | if (_config->FindB("Debug::aptcdrom",false) == true) | |
106 | std::clog << "Found Sources in " << CD << std::endl; | |
107 | SList.push_back(CD); | |
108 | ||
109 | // Continue down if thorough is given | |
110 | if (_config->FindB("APT::CDROM::Thorough",false) == false) | |
111 | return true; | |
112 | break; | |
113 | } | |
114 | ||
115 | // see if we find translation indices | |
116 | if (DirectoryExists("i18n") == true) | |
117 | { | |
118 | D = opendir("i18n"); | |
119 | for (struct dirent *Dir = readdir(D); Dir != 0; Dir = readdir(D)) | |
120 | { | |
121 | if(strncmp(Dir->d_name, "Translation-", strlen("Translation-")) != 0) | |
122 | continue; | |
123 | string file = Dir->d_name; | |
124 | for (std::vector<APT::Configuration::Compressor>::const_iterator c = compressor.begin(); | |
125 | c != compressor.end(); ++c) | |
126 | { | |
127 | string fileext = flExtension(file); | |
128 | if (file == fileext) | |
129 | fileext.clear(); | |
130 | else if (fileext.empty() == false) | |
131 | fileext = "." + fileext; | |
132 | ||
133 | if (c->Extension == fileext) | |
134 | { | |
135 | if (_config->FindB("Debug::aptcdrom",false) == true) | |
136 | std::clog << "Found translation " << Dir->d_name << " in " << CD << "i18n/" << std::endl; | |
137 | file.erase(file.size() - fileext.size()); | |
138 | TransList.push_back(CD + "i18n/" + file); | |
139 | break; | |
140 | } | |
141 | } | |
142 | } | |
143 | closedir(D); | |
144 | } | |
145 | ||
146 | D = opendir("."); | |
147 | if (D == 0) | |
148 | return _error->Errno("opendir","Unable to read %s",CD.c_str()); | |
149 | ||
150 | // Run over the directory | |
151 | for (struct dirent *Dir = readdir(D); Dir != 0; Dir = readdir(D)) | |
152 | { | |
153 | // Skip some files.. | |
154 | if (strcmp(Dir->d_name,".") == 0 || | |
155 | strcmp(Dir->d_name,"..") == 0 || | |
156 | //strcmp(Dir->d_name,"source") == 0 || | |
157 | strcmp(Dir->d_name,".disk") == 0 || | |
158 | strcmp(Dir->d_name,"experimental") == 0 || | |
159 | strcmp(Dir->d_name,"binary-all") == 0 || | |
160 | strcmp(Dir->d_name,"debian-installer") == 0) | |
161 | continue; | |
162 | ||
163 | // See if the name is a sub directory | |
164 | struct stat Buf; | |
165 | if (stat(Dir->d_name,&Buf) != 0) | |
166 | continue; | |
167 | ||
168 | if (S_ISDIR(Buf.st_mode) == 0) | |
169 | continue; | |
170 | ||
171 | unsigned int I; | |
172 | for (I = 0; I != Depth; I++) | |
173 | if (Inodes[I] == Buf.st_ino) | |
174 | break; | |
175 | if (I != Depth) | |
176 | continue; | |
177 | ||
178 | // Store the inodes weve seen | |
179 | Inodes[Depth] = Buf.st_ino; | |
180 | ||
181 | // Descend | |
182 | if (FindPackages(CD + Dir->d_name,List,SList,SigList,TransList,InfoDir,log,Depth+1) == false) | |
183 | break; | |
184 | ||
185 | if (chdir(CD.c_str()) != 0) | |
186 | { | |
187 | _error->Errno("chdir","Unable to change to %s", CD.c_str()); | |
188 | closedir(D); | |
189 | return false; | |
190 | } | |
191 | }; | |
192 | ||
193 | closedir(D); | |
194 | ||
195 | return !_error->PendingError(); | |
196 | } | |
197 | /*}}}*/ | |
198 | // Score - We compute a 'score' for a path /*{{{*/ | |
199 | // --------------------------------------------------------------------- | |
200 | /* Paths are scored based on how close they come to what I consider | |
201 | normal. That is ones that have 'dist' 'stable' 'testing' will score | |
202 | higher than ones without. */ | |
203 | int pkgCdrom::Score(string Path) | |
204 | { | |
205 | int Res = 0; | |
206 | if (Path.find("stable/") != string::npos) | |
207 | Res += 29; | |
208 | if (Path.find("/binary-") != string::npos) | |
209 | Res += 20; | |
210 | if (Path.find("testing/") != string::npos) | |
211 | Res += 28; | |
212 | if (Path.find("unstable/") != string::npos) | |
213 | Res += 27; | |
214 | if (Path.find("/dists/") != string::npos) | |
215 | Res += 40; | |
216 | if (Path.find("/main/") != string::npos) | |
217 | Res += 20; | |
218 | if (Path.find("/contrib/") != string::npos) | |
219 | Res += 20; | |
220 | if (Path.find("/non-free/") != string::npos) | |
221 | Res += 20; | |
222 | if (Path.find("/non-US/") != string::npos) | |
223 | Res += 20; | |
224 | if (Path.find("/source/") != string::npos) | |
225 | Res += 10; | |
226 | if (Path.find("/debian/") != string::npos) | |
227 | Res -= 10; | |
228 | ||
229 | // check for symlinks in the patch leading to the actual file | |
230 | // a symlink gets a big penalty | |
231 | struct stat Buf; | |
232 | string statPath = flNotFile(Path); | |
233 | string cdromPath = _config->FindDir("Acquire::cdrom::mount"); | |
234 | while(statPath != cdromPath && statPath != "./") { | |
235 | statPath.resize(statPath.size()-1); // remove the trailing '/' | |
236 | if (lstat(statPath.c_str(),&Buf) == 0) { | |
237 | if(S_ISLNK(Buf.st_mode)) { | |
238 | Res -= 60; | |
239 | break; | |
240 | } | |
241 | } | |
242 | statPath = flNotFile(statPath); // descent | |
243 | } | |
244 | ||
245 | return Res; | |
246 | } | |
247 | /*}}}*/ | |
248 | // DropBinaryArch - Dump dirs with a string like /binary-<foo>/ /*{{{*/ | |
249 | // --------------------------------------------------------------------- | |
250 | /* Here we drop everything that is not this machines arch */ | |
251 | bool pkgCdrom::DropBinaryArch(vector<string> &List) | |
252 | { | |
253 | ||
254 | for (unsigned int I = 0; I < List.size(); I++) | |
255 | { | |
256 | const char *Str = List[I].c_str(); | |
257 | const char *Start, *End; | |
258 | if ((Start = strstr(Str,"/binary-")) == 0) | |
259 | continue; | |
260 | ||
261 | // Between Start and End is the architecture | |
262 | Start += 8; | |
263 | if ((End = strstr(Start,"/")) != 0 && Start != End && | |
264 | APT::Configuration::checkArchitecture(string(Start, End)) == true) | |
265 | continue; // okay, architecture is accepted | |
266 | ||
267 | // not accepted -> Erase it | |
268 | List.erase(List.begin() + I); | |
269 | --I; // the next entry is at the same index after the erase | |
270 | } | |
271 | ||
272 | return true; | |
273 | } | |
274 | /*}}}*/ | |
275 | // DropTranslation - Dump unwanted Translation-<lang> files /*{{{*/ | |
276 | // --------------------------------------------------------------------- | |
277 | /* Here we drop everything that is not configured in Acquire::Languages */ | |
278 | bool pkgCdrom::DropTranslation(vector<string> &List) | |
279 | { | |
280 | for (unsigned int I = 0; I < List.size(); I++) | |
281 | { | |
282 | const char *Start; | |
283 | if ((Start = strstr(List[I].c_str(), "/Translation-")) == NULL) | |
284 | continue; | |
285 | Start += strlen("/Translation-"); | |
286 | ||
287 | if (APT::Configuration::checkLanguage(Start, true) == true) | |
288 | continue; | |
289 | ||
290 | // not accepted -> Erase it | |
291 | List.erase(List.begin() + I); | |
292 | --I; // the next entry is at the same index after the erase | |
293 | } | |
294 | ||
295 | return true; | |
296 | } | |
297 | /*}}}*/ | |
298 | // DropRepeats - Drop repeated files resulting from symlinks /*{{{*/ | |
299 | // --------------------------------------------------------------------- | |
300 | /* Here we go and stat every file that we found and strip dup inodes. */ | |
301 | bool pkgCdrom::DropRepeats(vector<string> &List,const char *Name) | |
302 | { | |
303 | bool couldFindAllFiles = true; | |
304 | // Get a list of all the inodes | |
305 | ino_t *Inodes = new ino_t[List.size()]; | |
306 | for (unsigned int I = 0; I != List.size(); ++I) | |
307 | { | |
308 | struct stat Buf; | |
309 | bool found = false; | |
310 | ||
311 | std::vector<APT::Configuration::Compressor> const compressor = APT::Configuration::getCompressors(); | |
312 | for (std::vector<APT::Configuration::Compressor>::const_iterator c = compressor.begin(); | |
313 | c != compressor.end(); ++c) | |
314 | { | |
315 | std::string filename = std::string(List[I]).append(Name).append(c->Extension); | |
316 | if (stat(filename.c_str(), &Buf) != 0) | |
317 | continue; | |
318 | Inodes[I] = Buf.st_ino; | |
319 | found = true; | |
320 | break; | |
321 | } | |
322 | ||
323 | if (found == false) | |
324 | { | |
325 | _error->Errno("stat","Failed to stat %s%s",List[I].c_str(), Name); | |
326 | couldFindAllFiles = false; | |
327 | Inodes[I] = 0; | |
328 | } | |
329 | } | |
330 | ||
331 | // Look for dups | |
332 | for (unsigned int I = 0; I != List.size(); I++) | |
333 | { | |
334 | if (Inodes[I] == 0) | |
335 | continue; | |
336 | for (unsigned int J = I+1; J < List.size(); J++) | |
337 | { | |
338 | // No match | |
339 | if (Inodes[J] == 0 || Inodes[J] != Inodes[I]) | |
340 | continue; | |
341 | ||
342 | // We score the two paths.. and erase one | |
343 | int ScoreA = Score(List[I]); | |
344 | int ScoreB = Score(List[J]); | |
345 | if (ScoreA < ScoreB) | |
346 | { | |
347 | List[I] = string(); | |
348 | break; | |
349 | } | |
350 | ||
351 | List[J] = string(); | |
352 | } | |
353 | } | |
354 | delete[] Inodes; | |
355 | ||
356 | // Wipe erased entries | |
357 | for (unsigned int I = 0; I < List.size();) | |
358 | { | |
359 | if (List[I].empty() == false) | |
360 | I++; | |
361 | else | |
362 | List.erase(List.begin()+I); | |
363 | } | |
364 | ||
365 | return couldFindAllFiles; | |
366 | } | |
367 | /*}}}*/ | |
368 | // ReduceSourceList - Takes the path list and reduces it /*{{{*/ | |
369 | // --------------------------------------------------------------------- | |
370 | /* This takes the list of source list expressed entires and collects | |
371 | similar ones to form a single entry for each dist */ | |
372 | void pkgCdrom::ReduceSourcelist(string CD,vector<string> &List) | |
373 | { | |
374 | sort(List.begin(),List.end()); | |
375 | ||
376 | // Collect similar entries | |
377 | for (vector<string>::iterator I = List.begin(); I != List.end(); ++I) | |
378 | { | |
379 | // Find a space.. | |
380 | string::size_type Space = (*I).find(' '); | |
381 | if (Space == string::npos) | |
382 | continue; | |
383 | string::size_type SSpace = (*I).find(' ',Space + 1); | |
384 | if (SSpace == string::npos) | |
385 | continue; | |
386 | ||
387 | string Word1 = string(*I,Space,SSpace-Space); | |
388 | string Prefix = string(*I,0,Space); | |
389 | string Component = string(*I,SSpace); | |
390 | for (vector<string>::iterator J = List.begin(); J != I; ++J) | |
391 | { | |
392 | // Find a space.. | |
393 | string::size_type Space2 = (*J).find(' '); | |
394 | if (Space2 == string::npos) | |
395 | continue; | |
396 | string::size_type SSpace2 = (*J).find(' ',Space2 + 1); | |
397 | if (SSpace2 == string::npos) | |
398 | continue; | |
399 | ||
400 | if (string(*J,0,Space2) != Prefix) | |
401 | continue; | |
402 | if (string(*J,Space2,SSpace2-Space2) != Word1) | |
403 | continue; | |
404 | ||
405 | string Component2 = string(*J, SSpace2) + " "; | |
406 | if (Component2.find(Component + " ") == std::string::npos) | |
407 | *J += Component; | |
408 | I->clear(); | |
409 | } | |
410 | } | |
411 | ||
412 | // Wipe erased entries | |
413 | for (unsigned int I = 0; I < List.size();) | |
414 | { | |
415 | if (List[I].empty() == false) | |
416 | I++; | |
417 | else | |
418 | List.erase(List.begin()+I); | |
419 | } | |
420 | } | |
421 | /*}}}*/ | |
422 | // WriteDatabase - Write the CDROM Database file /*{{{*/ | |
423 | // --------------------------------------------------------------------- | |
424 | /* We rewrite the configuration class associated with the cdrom database. */ | |
425 | bool pkgCdrom::WriteDatabase(Configuration &Cnf) | |
426 | { | |
427 | string DFile = _config->FindFile("Dir::State::cdroms"); | |
428 | string NewFile = DFile + ".new"; | |
429 | ||
430 | unlink(NewFile.c_str()); | |
431 | ofstream Out(NewFile.c_str()); | |
432 | if (!Out) | |
433 | return _error->Errno("ofstream::ofstream", | |
434 | "Failed to open %s.new",DFile.c_str()); | |
435 | ||
436 | /* Write out all of the configuration directives by walking the | |
437 | configuration tree */ | |
438 | Cnf.Dump(Out, NULL, "%f \"%v\";\n", false); | |
439 | ||
440 | Out.close(); | |
441 | ||
442 | if (FileExists(DFile) == true) | |
443 | rename(DFile.c_str(), string(DFile + '~').c_str()); | |
444 | if (rename(NewFile.c_str(),DFile.c_str()) != 0) | |
445 | return _error->Errno("rename","Failed to rename %s.new to %s", | |
446 | DFile.c_str(),DFile.c_str()); | |
447 | ||
448 | return true; | |
449 | } | |
450 | /*}}}*/ | |
451 | // WriteSourceList - Write an updated sourcelist /*{{{*/ | |
452 | // --------------------------------------------------------------------- | |
453 | /* This reads the old source list and copies it into the new one. It | |
454 | appends the new CDROM entires just after the first block of comments. | |
455 | This places them first in the file. It also removes any old entries | |
456 | that were the same. */ | |
457 | bool pkgCdrom::WriteSourceList(string Name,vector<string> &List,bool Source) | |
458 | { | |
459 | if (List.empty() == true) | |
460 | return true; | |
461 | ||
462 | string File = _config->FindFile("Dir::Etc::sourcelist"); | |
463 | ||
464 | // Open the stream for reading | |
465 | ifstream F((FileExists(File)?File.c_str():"/dev/null"), | |
466 | ios::in ); | |
467 | if (!F != 0) | |
468 | return _error->Errno("ifstream::ifstream","Opening %s",File.c_str()); | |
469 | ||
470 | string NewFile = File + ".new"; | |
471 | unlink(NewFile.c_str()); | |
472 | ofstream Out(NewFile.c_str()); | |
473 | if (!Out) | |
474 | return _error->Errno("ofstream::ofstream", | |
475 | "Failed to open %s.new",File.c_str()); | |
476 | ||
477 | // Create a short uri without the path | |
478 | string ShortURI = "cdrom:[" + Name + "]/"; | |
479 | string ShortURI2 = "cdrom:" + Name + "/"; // For Compatibility | |
480 | ||
481 | string Type; | |
482 | if (Source == true) | |
483 | Type = "deb-src"; | |
484 | else | |
485 | Type = "deb"; | |
486 | ||
487 | char Buffer[300]; | |
488 | int CurLine = 0; | |
489 | bool First = true; | |
490 | while (F.eof() == false) | |
491 | { | |
492 | F.getline(Buffer,sizeof(Buffer)); | |
493 | CurLine++; | |
494 | if (F.fail() && !F.eof()) | |
495 | return _error->Error(_("Line %u too long in source list %s."), | |
496 | CurLine,File.c_str()); | |
497 | _strtabexpand(Buffer,sizeof(Buffer)); | |
498 | _strstrip(Buffer); | |
499 | ||
500 | // Comment or blank | |
501 | if (Buffer[0] == '#' || Buffer[0] == 0) | |
502 | { | |
503 | Out << Buffer << endl; | |
504 | continue; | |
505 | } | |
506 | ||
507 | if (First == true) | |
508 | { | |
509 | for (vector<string>::iterator I = List.begin(); I != List.end(); ++I) | |
510 | { | |
511 | string::size_type Space = (*I).find(' '); | |
512 | if (Space == string::npos) | |
513 | return _error->Error("Internal error"); | |
514 | Out << Type << " cdrom:[" << Name << "]/" << string(*I,0,Space) << | |
515 | " " << string(*I,Space+1) << endl; | |
516 | } | |
517 | } | |
518 | First = false; | |
519 | ||
520 | // Grok it | |
521 | string cType; | |
522 | string URI; | |
523 | const char *C = Buffer; | |
524 | if (ParseQuoteWord(C,cType) == false || | |
525 | ParseQuoteWord(C,URI) == false) | |
526 | { | |
527 | Out << Buffer << endl; | |
528 | continue; | |
529 | } | |
530 | ||
531 | // Emit lines like this one | |
532 | if (cType != Type || (string(URI,0,ShortURI.length()) != ShortURI && | |
533 | string(URI,0,ShortURI.length()) != ShortURI2)) | |
534 | { | |
535 | Out << Buffer << endl; | |
536 | continue; | |
537 | } | |
538 | } | |
539 | ||
540 | // Just in case the file was empty | |
541 | if (First == true) | |
542 | { | |
543 | for (vector<string>::iterator I = List.begin(); I != List.end(); ++I) | |
544 | { | |
545 | string::size_type Space = (*I).find(' '); | |
546 | if (Space == string::npos) | |
547 | return _error->Error("Internal error"); | |
548 | ||
549 | Out << "deb cdrom:[" << Name << "]/" << string(*I,0,Space) << | |
550 | " " << string(*I,Space+1) << endl; | |
551 | } | |
552 | } | |
553 | ||
554 | Out.close(); | |
555 | ||
556 | rename(File.c_str(),string(File + '~').c_str()); | |
557 | if (rename(NewFile.c_str(),File.c_str()) != 0) | |
558 | return _error->Errno("rename","Failed to rename %s.new to %s", | |
559 | File.c_str(),File.c_str()); | |
560 | ||
561 | return true; | |
562 | } | |
563 | /*}}}*/ | |
564 | bool pkgCdrom::Ident(string &ident, pkgCdromStatus *log) /*{{{*/ | |
565 | { | |
566 | stringstream msg; | |
567 | ||
568 | // Startup | |
569 | string CDROM = _config->FindDir("Acquire::cdrom::mount"); | |
570 | if (CDROM[0] == '.') | |
571 | CDROM= SafeGetCWD() + '/' + CDROM; | |
572 | ||
573 | if (log != NULL) | |
574 | { | |
575 | msg.str(""); | |
576 | ioprintf(msg, _("Using CD-ROM mount point %s\nMounting CD-ROM\n"), | |
577 | CDROM.c_str()); | |
578 | log->Update(msg.str()); | |
579 | } | |
580 | if (MountCdrom(CDROM) == false) | |
581 | return _error->Error("Failed to mount the cdrom."); | |
582 | ||
583 | // Hash the CD to get an ID | |
584 | if (log != NULL) | |
585 | log->Update(_("Identifying.. ")); | |
586 | ||
587 | ||
588 | if (IdentCdrom(CDROM,ident) == false) | |
589 | { | |
590 | ident = ""; | |
591 | return false; | |
592 | } | |
593 | ||
594 | if (log != NULL) | |
595 | { | |
596 | msg.str(""); | |
597 | ioprintf(msg, "[%s]\n",ident.c_str()); | |
598 | log->Update(msg.str()); | |
599 | } | |
600 | ||
601 | // Read the database | |
602 | Configuration Database; | |
603 | string DFile = _config->FindFile("Dir::State::cdroms"); | |
604 | if (FileExists(DFile) == true) | |
605 | { | |
606 | if (ReadConfigFile(Database,DFile) == false) | |
607 | return _error->Error("Unable to read the cdrom database %s", | |
608 | DFile.c_str()); | |
609 | } | |
610 | if (log != NULL) | |
611 | { | |
612 | msg.str(""); | |
613 | ioprintf(msg, _("Stored label: %s\n"), | |
614 | Database.Find("CD::"+ident).c_str()); | |
615 | log->Update(msg.str()); | |
616 | } | |
617 | ||
618 | // Unmount and finish | |
619 | if (_config->FindB("APT::CDROM::NoMount",false) == false) | |
620 | { | |
621 | if (log != NULL) | |
622 | log->Update(_("Unmounting CD-ROM...\n"), STEP_LAST); | |
623 | UnmountCdrom(CDROM); | |
624 | } | |
625 | ||
626 | return true; | |
627 | } | |
628 | /*}}}*/ | |
629 | bool pkgCdrom::Add(pkgCdromStatus *log) /*{{{*/ | |
630 | { | |
631 | stringstream msg; | |
632 | ||
633 | // Startup | |
634 | string CDROM = _config->FindDir("Acquire::cdrom::mount"); | |
635 | if (CDROM[0] == '.') | |
636 | CDROM= SafeGetCWD() + '/' + CDROM; | |
637 | ||
638 | if(log != NULL) | |
639 | { | |
640 | log->SetTotal(STEP_LAST); | |
641 | msg.str(""); | |
642 | ioprintf(msg, _("Using CD-ROM mount point %s\n"), CDROM.c_str()); | |
643 | log->Update(msg.str(), STEP_PREPARE); | |
644 | } | |
645 | ||
646 | // Read the database | |
647 | Configuration Database; | |
648 | string DFile = _config->FindFile("Dir::State::cdroms"); | |
649 | if (FileExists(DFile) == true) | |
650 | { | |
651 | if (ReadConfigFile(Database,DFile) == false) | |
652 | return _error->Error("Unable to read the cdrom database %s", | |
653 | DFile.c_str()); | |
654 | } | |
655 | ||
656 | // Unmount the CD and get the user to put in the one they want | |
657 | if (_config->FindB("APT::CDROM::NoMount",false) == false) | |
658 | { | |
659 | if(log != NULL) | |
660 | log->Update(_("Unmounting CD-ROM\n"), STEP_UNMOUNT); | |
661 | UnmountCdrom(CDROM); | |
662 | ||
663 | if(log != NULL) | |
664 | { | |
665 | log->Update(_("Waiting for disc...\n"), STEP_WAIT); | |
666 | if(!log->ChangeCdrom()) { | |
667 | // user aborted | |
668 | return false; | |
669 | } | |
670 | } | |
671 | ||
672 | // Mount the new CDROM | |
673 | if(log != NULL) | |
674 | log->Update(_("Mounting CD-ROM...\n"), STEP_MOUNT); | |
675 | ||
676 | if (MountCdrom(CDROM) == false) | |
677 | return _error->Error("Failed to mount the cdrom."); | |
678 | } | |
679 | ||
680 | // Hash the CD to get an ID | |
681 | if(log != NULL) | |
682 | log->Update(_("Identifying.. "), STEP_IDENT); | |
683 | string ID; | |
684 | if (IdentCdrom(CDROM,ID) == false) | |
685 | { | |
686 | if (log != NULL) | |
687 | log->Update("\n"); | |
688 | return false; | |
689 | } | |
690 | if(log != NULL) | |
691 | { | |
692 | log->Update("["+ID+"]\n"); | |
693 | log->Update(_("Scanning disc for index files..\n"),STEP_SCAN); | |
694 | } | |
695 | ||
696 | // Get the CD structure | |
697 | vector<string> List; | |
698 | vector<string> SourceList; | |
699 | vector<string> SigList; | |
700 | vector<string> TransList; | |
701 | string StartDir = SafeGetCWD(); | |
702 | string InfoDir; | |
703 | if (FindPackages(CDROM,List,SourceList, SigList,TransList,InfoDir,log) == false) | |
704 | { | |
705 | if (log != NULL) | |
706 | log->Update("\n"); | |
707 | return false; | |
708 | } | |
709 | ||
710 | if (chdir(StartDir.c_str()) != 0) | |
711 | return _error->Errno("chdir","Unable to change to %s", StartDir.c_str()); | |
712 | ||
713 | if (_config->FindB("Debug::aptcdrom",false) == true) | |
714 | { | |
715 | cout << "I found (binary):" << endl; | |
716 | for (vector<string>::iterator I = List.begin(); I != List.end(); ++I) | |
717 | cout << *I << endl; | |
718 | cout << "I found (source):" << endl; | |
719 | for (vector<string>::iterator I = SourceList.begin(); I != SourceList.end(); ++I) | |
720 | cout << *I << endl; | |
721 | cout << "I found (Signatures):" << endl; | |
722 | for (vector<string>::iterator I = SigList.begin(); I != SigList.end(); ++I) | |
723 | cout << *I << endl; | |
724 | } | |
725 | ||
726 | //log->Update(_("Cleaning package lists..."), STEP_CLEAN); | |
727 | ||
728 | // Fix up the list | |
729 | DropBinaryArch(List); | |
730 | DropRepeats(List,"Packages"); | |
731 | DropRepeats(SourceList,"Sources"); | |
732 | // FIXME: We ignore stat() errors here as we usually have only one of those in use | |
733 | // This has little potencial to drop 'valid' stat() errors as we know that one of these | |
734 | // files need to exist, but it would be better if we would check it here | |
735 | _error->PushToStack(); | |
736 | DropRepeats(SigList,"Release.gpg"); | |
737 | DropRepeats(SigList,"InRelease"); | |
738 | _error->RevertToStack(); | |
739 | DropRepeats(TransList,""); | |
740 | if (_config->FindB("APT::CDROM::DropTranslation", true) == true) | |
741 | DropTranslation(TransList); | |
742 | if(log != NULL) { | |
743 | msg.str(""); | |
744 | ioprintf(msg, _("Found %zu package indexes, %zu source indexes, " | |
745 | "%zu translation indexes and %zu signatures\n"), | |
746 | List.size(), SourceList.size(), TransList.size(), | |
747 | SigList.size()); | |
748 | log->Update(msg.str(), STEP_SCAN); | |
749 | } | |
750 | ||
751 | if (List.empty() == true && SourceList.empty() == true) | |
752 | { | |
753 | if (_config->FindB("APT::CDROM::NoMount",false) == false) | |
754 | UnmountCdrom(CDROM); | |
755 | return _error->Error(_("Unable to locate any package files, perhaps this is not a Debian Disc or the wrong architecture?")); | |
756 | } | |
757 | ||
758 | // Check if the CD is in the database | |
759 | string Name; | |
760 | if (Database.Exists("CD::" + ID) == false || | |
761 | _config->FindB("APT::CDROM::Rename",false) == true) | |
762 | { | |
763 | // Try to use the CDs label if at all possible | |
764 | if (InfoDir.empty() == false && | |
765 | FileExists(InfoDir + "/info") == true) | |
766 | { | |
767 | ifstream F(string(InfoDir + "/info").c_str()); | |
768 | if (!F == 0) | |
769 | getline(F,Name); | |
770 | ||
771 | if (Name.empty() == false) | |
772 | { | |
773 | // Escape special characters | |
774 | string::iterator J = Name.begin(); | |
775 | for (; J != Name.end(); ++J) | |
776 | if (*J == '"' || *J == ']' || *J == '[') | |
777 | *J = '_'; | |
778 | ||
779 | if(log != NULL) | |
780 | { | |
781 | msg.str(""); | |
782 | ioprintf(msg, _("Found label '%s'\n"), Name.c_str()); | |
783 | log->Update(msg.str()); | |
784 | } | |
785 | Database.Set("CD::" + ID + "::Label",Name); | |
786 | } | |
787 | } | |
788 | ||
789 | if (_config->FindB("APT::CDROM::Rename",false) == true || | |
790 | Name.empty() == true) | |
791 | { | |
792 | if(log == NULL) | |
793 | { | |
794 | if (_config->FindB("APT::CDROM::NoMount",false) == false) | |
795 | UnmountCdrom(CDROM); | |
796 | return _error->Error("No disc name found and no way to ask for it"); | |
797 | } | |
798 | ||
799 | while(true) { | |
800 | if(!log->AskCdromName(Name)) { | |
801 | // user canceld | |
802 | return false; | |
803 | } | |
804 | cout << "Name: '" << Name << "'" << endl; | |
805 | ||
806 | if (Name.empty() == false && | |
807 | Name.find('"') == string::npos && | |
808 | Name.find('[') == string::npos && | |
809 | Name.find(']') == string::npos) | |
810 | break; | |
811 | log->Update(_("That is not a valid name, try again.\n")); | |
812 | } | |
813 | } | |
814 | } | |
815 | else | |
816 | Name = Database.Find("CD::" + ID); | |
817 | ||
818 | // Escape special characters | |
819 | string::iterator J = Name.begin(); | |
820 | for (; J != Name.end(); ++J) | |
821 | if (*J == '"' || *J == ']' || *J == '[') | |
822 | *J = '_'; | |
823 | ||
824 | Database.Set("CD::" + ID,Name); | |
825 | if(log != NULL) | |
826 | { | |
827 | msg.str(""); | |
828 | ioprintf(msg, _("This disc is called: \n'%s'\n"), Name.c_str()); | |
829 | log->Update(msg.str()); | |
830 | log->Update(_("Copying package lists..."), STEP_COPY); | |
831 | } | |
832 | // take care of the signatures and copy them if they are ok | |
833 | // (we do this before PackageCopy as it modifies "List" and "SourceList") | |
834 | SigVerify SignVerify; | |
835 | SignVerify.CopyAndVerify(CDROM, Name, SigList, List, SourceList); | |
836 | ||
837 | // Copy the package files to the state directory | |
838 | PackageCopy Copy; | |
839 | SourceCopy SrcCopy; | |
840 | TranslationsCopy TransCopy; | |
841 | if (Copy.CopyPackages(CDROM,Name,List, log) == false || | |
842 | SrcCopy.CopyPackages(CDROM,Name,SourceList, log) == false || | |
843 | TransCopy.CopyTranslations(CDROM,Name,TransList, log) == false) | |
844 | return false; | |
845 | ||
846 | // reduce the List so that it takes less space in sources.list | |
847 | ReduceSourcelist(CDROM,List); | |
848 | ReduceSourcelist(CDROM,SourceList); | |
849 | ||
850 | // Write the database and sourcelist | |
851 | if (_config->FindB("APT::cdrom::NoAct",false) == false) | |
852 | { | |
853 | if (WriteDatabase(Database) == false) | |
854 | return false; | |
855 | ||
856 | if(log != NULL) | |
857 | log->Update(_("Writing new source list\n"), STEP_WRITE); | |
858 | if (WriteSourceList(Name,List,false) == false || | |
859 | WriteSourceList(Name,SourceList,true) == false) | |
860 | return false; | |
861 | } | |
862 | ||
863 | // Print the sourcelist entries | |
864 | if(log != NULL) | |
865 | log->Update(_("Source list entries for this disc are:\n")); | |
866 | ||
867 | for (vector<string>::iterator I = List.begin(); I != List.end(); ++I) | |
868 | { | |
869 | string::size_type Space = (*I).find(' '); | |
870 | if (Space == string::npos) | |
871 | { | |
872 | if (_config->FindB("APT::CDROM::NoMount",false) == false) | |
873 | UnmountCdrom(CDROM); | |
874 | return _error->Error("Internal error"); | |
875 | } | |
876 | ||
877 | if(log != NULL) | |
878 | { | |
879 | msg.str(""); | |
880 | msg << "deb cdrom:[" << Name << "]/" << string(*I,0,Space) << | |
881 | " " << string(*I,Space+1) << endl; | |
882 | log->Update(msg.str()); | |
883 | } | |
884 | } | |
885 | ||
886 | for (vector<string>::iterator I = SourceList.begin(); I != SourceList.end(); ++I) | |
887 | { | |
888 | string::size_type Space = (*I).find(' '); | |
889 | if (Space == string::npos) | |
890 | { | |
891 | if (_config->FindB("APT::CDROM::NoMount",false) == false) | |
892 | UnmountCdrom(CDROM); | |
893 | return _error->Error("Internal error"); | |
894 | } | |
895 | ||
896 | if(log != NULL) { | |
897 | msg.str(""); | |
898 | msg << "deb-src cdrom:[" << Name << "]/" << string(*I,0,Space) << | |
899 | " " << string(*I,Space+1) << endl; | |
900 | log->Update(msg.str()); | |
901 | } | |
902 | } | |
903 | ||
904 | // Unmount and finish | |
905 | if (_config->FindB("APT::CDROM::NoMount",false) == false) { | |
906 | if (log != NULL) | |
907 | log->Update(_("Unmounting CD-ROM...\n"), STEP_LAST); | |
908 | UnmountCdrom(CDROM); | |
909 | } | |
910 | ||
911 | return true; | |
912 | } | |
913 | /*}}}*/ | |
914 | pkgUdevCdromDevices::pkgUdevCdromDevices() /*{{{*/ | |
915 | : libudev_handle(NULL) | |
916 | { | |
917 | ||
918 | } | |
919 | /*}}}*/ | |
920 | ||
921 | bool | |
922 | pkgUdevCdromDevices::Dlopen() /*{{{*/ | |
923 | { | |
924 | // alread open | |
925 | if(libudev_handle != NULL) | |
926 | return true; | |
927 | ||
928 | // see if we can get libudev | |
929 | void *h = ::dlopen("libudev.so.0", RTLD_LAZY); | |
930 | if(h == NULL) | |
931 | return false; | |
932 | ||
933 | // get the pointers to the udev structs | |
934 | libudev_handle = h; | |
935 | udev_new = (udev* (*)(void)) dlsym(h, "udev_new"); | |
936 | udev_enumerate_add_match_property = (int (*)(udev_enumerate*, const char*, const char*))dlsym(h, "udev_enumerate_add_match_property"); | |
937 | udev_enumerate_add_match_sysattr = (int (*)(udev_enumerate*, const char*, const char*))dlsym(h, "udev_enumerate_add_match_sysattr"); | |
938 | udev_enumerate_scan_devices = (int (*)(udev_enumerate*))dlsym(h, "udev_enumerate_scan_devices"); | |
939 | udev_enumerate_get_list_entry = (udev_list_entry* (*)(udev_enumerate*))dlsym(h, "udev_enumerate_get_list_entry"); | |
940 | udev_device_new_from_syspath = (udev_device* (*)(udev*, const char*))dlsym(h, "udev_device_new_from_syspath"); | |
941 | udev_enumerate_get_udev = (udev* (*)(udev_enumerate*))dlsym(h, "udev_enumerate_get_udev"); | |
942 | udev_list_entry_get_name = (const char* (*)(udev_list_entry*))dlsym(h, "udev_list_entry_get_name"); | |
943 | udev_device_get_devnode = (const char* (*)(udev_device*))dlsym(h, "udev_device_get_devnode"); | |
944 | udev_enumerate_new = (udev_enumerate* (*)(udev*))dlsym(h, "udev_enumerate_new"); | |
945 | udev_list_entry_get_next = (udev_list_entry* (*)(udev_list_entry*))dlsym(h, "udev_list_entry_get_next"); | |
946 | udev_device_get_property_value = (const char* (*)(udev_device *, const char *))dlsym(h, "udev_device_get_property_value"); | |
947 | ||
948 | return true; | |
949 | } | |
950 | /*}}}*/ | |
951 | /*{{{*/ | |
952 | // convenience interface, this will just call ScanForRemovable | |
953 | vector<CdromDevice> | |
954 | pkgUdevCdromDevices::Scan() | |
955 | { | |
956 | bool CdromOnly = _config->FindB("APT::cdrom::CdromOnly", true); | |
957 | return ScanForRemovable(CdromOnly); | |
958 | }; | |
959 | /*}}}*/ | |
960 | /*{{{*/ | |
961 | vector<CdromDevice> | |
962 | pkgUdevCdromDevices::ScanForRemovable(bool CdromOnly) | |
963 | { | |
964 | vector<CdromDevice> cdrom_devices; | |
965 | struct udev_enumerate *enumerate; | |
966 | struct udev_list_entry *l, *devices; | |
967 | struct udev *udev_ctx; | |
968 | ||
969 | if(libudev_handle == NULL) | |
970 | return cdrom_devices; | |
971 | ||
972 | udev_ctx = udev_new(); | |
973 | enumerate = udev_enumerate_new (udev_ctx); | |
974 | if (CdromOnly) | |
975 | udev_enumerate_add_match_property(enumerate, "ID_CDROM", "1"); | |
976 | else { | |
977 | udev_enumerate_add_match_sysattr(enumerate, "removable", "1"); | |
978 | } | |
979 | ||
980 | udev_enumerate_scan_devices (enumerate); | |
981 | devices = udev_enumerate_get_list_entry (enumerate); | |
982 | for (l = devices; l != NULL; l = udev_list_entry_get_next (l)) | |
983 | { | |
984 | CdromDevice cdrom; | |
985 | struct udev_device *udevice; | |
986 | udevice = udev_device_new_from_syspath (udev_enumerate_get_udev (enumerate), udev_list_entry_get_name (l)); | |
987 | if (udevice == NULL) | |
988 | continue; | |
989 | const char* devnode = udev_device_get_devnode(udevice); | |
990 | ||
991 | // try fstab_dir first | |
992 | string mountpath; | |
993 | const char* mp = udev_device_get_property_value(udevice, "FSTAB_DIR"); | |
994 | if (mp) | |
995 | mountpath = string(mp); | |
996 | else | |
997 | mountpath = FindMountPointForDevice(devnode); | |
998 | ||
999 | // fill in the struct | |
1000 | cdrom.DeviceName = string(devnode); | |
1001 | if (mountpath != "") { | |
1002 | cdrom.MountPath = mountpath; | |
1003 | string s = string(mountpath); | |
1004 | cdrom.Mounted = IsMounted(s); | |
1005 | } else { | |
1006 | cdrom.Mounted = false; | |
1007 | cdrom.MountPath = ""; | |
1008 | } | |
1009 | cdrom_devices.push_back(cdrom); | |
1010 | } | |
1011 | return cdrom_devices; | |
1012 | } | |
1013 | /*}}}*/ | |
1014 | ||
1015 | pkgUdevCdromDevices::~pkgUdevCdromDevices() /*{{{*/ | |
1016 | { | |
1017 | if (libudev_handle != NULL) | |
1018 | dlclose(libudev_handle); | |
1019 | } | |
1020 | /*}}}*/ |