1 // -*- mode: cpp; mode: fold -*-
3 // $Id: acqprogress.cc,v 1.24 2003/04/27 01:56:48 doogie Exp $
4 /* ######################################################################
6 Acquire Progress - Command line progress meter
8 ##################################################################### */
10 // Include files /*{{{*/
13 #include <apt-pkg/acquire.h>
14 #include <apt-pkg/acquire-item.h>
15 #include <apt-pkg/acquire-worker.h>
16 #include <apt-pkg/configuration.h>
17 #include <apt-pkg/strutl.h>
18 #include <apt-pkg/error.h>
20 #include <apt-private/acqprogress.h>
33 // AcqTextStatus::AcqTextStatus - Constructor /*{{{*/
34 // ---------------------------------------------------------------------
36 AcqTextStatus::AcqTextStatus(unsigned int &ScreenWidth
,unsigned int const Quiet
) :
37 pkgAcquireStatus(), ScreenWidth(ScreenWidth
), ID(0), Quiet(Quiet
)
40 // testcases use it to disable pulses without disabling other user messages
41 if (Quiet
== 0 && _config
->FindB("quiet::NoUpdate", false) == true)
45 // AcqTextStatus::Start - Downloading has started /*{{{*/
46 // ---------------------------------------------------------------------
48 void AcqTextStatus::Start()
50 pkgAcquireStatus::Start();
55 // AcqTextStatus::IMSHit - Called when an item got a HIT response /*{{{*/
56 // ---------------------------------------------------------------------
58 void AcqTextStatus::IMSHit(pkgAcquire::ItemDesc
&Itm
)
64 cout
<< '\r' << BlankLine
<< '\r';
66 cout
<< _("Hit ") << Itm
.Description
;
67 if (Itm
.Owner
->FileSize
!= 0)
68 cout
<< " [" << SizeToStr(Itm
.Owner
->FileSize
) << "B]";
73 // AcqTextStatus::Fetch - An item has started to download /*{{{*/
74 // ---------------------------------------------------------------------
75 /* This prints out the short description and the expected size */
76 void AcqTextStatus::Fetch(pkgAcquire::ItemDesc
&Itm
)
79 if (Itm
.Owner
->Complete
== true)
88 cout
<< '\r' << BlankLine
<< '\r';
90 cout
<< _("Get:") << Itm
.Owner
->ID
<< ' ' << Itm
.Description
;
91 if (Itm
.Owner
->FileSize
!= 0)
92 cout
<< " [" << SizeToStr(Itm
.Owner
->FileSize
) << "B]";
96 // AcqTextStatus::Done - Completed a download /*{{{*/
97 // ---------------------------------------------------------------------
98 /* We don't display anything... */
99 void AcqTextStatus::Done(pkgAcquire::ItemDesc
&/*Itm*/)
104 // AcqTextStatus::Fail - Called when an item fails to download /*{{{*/
105 // ---------------------------------------------------------------------
106 /* We print out the error text */
107 void AcqTextStatus::Fail(pkgAcquire::ItemDesc
&Itm
)
112 // Ignore certain kinds of transient failures (bad code)
113 if (Itm
.Owner
->Status
== pkgAcquire::Item::StatIdle
)
117 cout
<< '\r' << BlankLine
<< '\r';
119 if (Itm
.Owner
->Status
== pkgAcquire::Item::StatDone
)
121 cout
<< _("Ign ") << Itm
.Description
<< endl
;
125 cout
<< _("Err ") << Itm
.Description
<< endl
;
126 cout
<< " " << Itm
.Owner
->ErrorText
<< endl
;
132 // AcqTextStatus::Stop - Finished downloading /*{{{*/
133 // ---------------------------------------------------------------------
134 /* This prints out the bytes downloaded and the overall average line
136 void AcqTextStatus::Stop()
138 pkgAcquireStatus::Stop();
143 cout
<< '\r' << BlankLine
<< '\r' << flush
;
145 if (FetchedBytes
!= 0 && _error
->PendingError() == false)
146 ioprintf(cout
,_("Fetched %sB in %s (%sB/s)\n"),
147 SizeToStr(FetchedBytes
).c_str(),
148 TimeToStr(ElapsedTime
).c_str(),
149 SizeToStr(CurrentCPS
).c_str());
152 // AcqTextStatus::Pulse - Regular event pulse /*{{{*/
153 // ---------------------------------------------------------------------
154 /* This draws the current progress. Each line has an overall percent
155 meter and a per active item status meter along with an overall
156 bandwidth and ETA indicator. */
157 bool AcqTextStatus::Pulse(pkgAcquire
*Owner
)
159 pkgAcquireStatus::Pulse(Owner
);
164 enum {Long
= 0,Medium
,Short
} Mode
= Medium
;
166 char Buffer
[sizeof(BlankLine
)];
167 char *End
= Buffer
+ sizeof(Buffer
);
169 if (ScreenWidth
>= sizeof(Buffer
))
170 ScreenWidth
= sizeof(Buffer
)-1;
172 // Put in the percent done
173 sprintf(S
,"%.0f%%",((CurrentBytes
+ CurrentItems
)*100.0)/(TotalBytes
+TotalItems
));
176 for (pkgAcquire::Worker
*I
= Owner
->WorkersBegin(); I
!= 0;
177 I
= Owner
->WorkerStep(I
))
181 // There is no item running
182 if (I
->CurrentItem
== 0)
184 if (I
->Status
.empty() == false)
186 snprintf(S
,End
-S
," [%s]",I
->Status
.c_str());
195 // Add in the short description
196 if (I
->CurrentItem
->Owner
->ID
!= 0)
197 snprintf(S
,End
-S
," [%lu %s",I
->CurrentItem
->Owner
->ID
,
198 I
->CurrentItem
->ShortDesc
.c_str());
200 snprintf(S
,End
-S
," [%s",I
->CurrentItem
->ShortDesc
.c_str());
203 // Show the short mode string
204 if (I
->CurrentItem
->Owner
->Mode
!= 0)
206 snprintf(S
,End
-S
," %s",I
->CurrentItem
->Owner
->Mode
);
210 // Add the current progress
212 snprintf(S
,End
-S
," %llu",I
->CurrentSize
);
215 if (Mode
== Medium
|| I
->TotalSize
== 0)
216 snprintf(S
,End
-S
," %sB",SizeToStr(I
->CurrentSize
).c_str());
220 // Add the total size and percent
221 if (I
->TotalSize
> 0 && I
->CurrentItem
->Owner
->Complete
== false)
224 snprintf(S
,End
-S
," %.0f%%",
225 (I
->CurrentSize
*100.0)/I
->TotalSize
);
227 snprintf(S
,End
-S
,"/%sB %.0f%%",SizeToStr(I
->TotalSize
).c_str(),
228 (I
->CurrentSize
*100.0)/I
->TotalSize
);
231 snprintf(S
,End
-S
,"]");
236 snprintf(S
,End
-S
,_(" [Working]"));
238 /* Put in the ETA and cps meter, block off signals to prevent strangeness
240 sigset_t Sigs
,OldSigs
;
242 sigaddset(&Sigs
,SIGWINCH
);
243 sigprocmask(SIG_BLOCK
,&Sigs
,&OldSigs
);
248 unsigned long long ETA
= (TotalBytes
- CurrentBytes
)/CurrentCPS
;
249 sprintf(Tmp
," %sB/s %s",SizeToStr(CurrentCPS
).c_str(),TimeToStr(ETA
).c_str());
250 unsigned int Len
= strlen(Buffer
);
251 unsigned int LenT
= strlen(Tmp
);
252 if (Len
+ LenT
< ScreenWidth
)
254 memset(Buffer
+ Len
,' ',ScreenWidth
- Len
);
255 strcpy(Buffer
+ ScreenWidth
- LenT
,Tmp
);
258 Buffer
[ScreenWidth
] = 0;
259 BlankLine
[ScreenWidth
] = 0;
260 sigprocmask(SIG_SETMASK
,&OldSigs
,0);
262 // Draw the current status
263 if (_config
->FindB("Apt::Color", false) == true)
264 cout
<< _config
->Find("APT::Color::Yellow");
265 if (strlen(Buffer
) == strlen(BlankLine
))
266 cout
<< '\r' << Buffer
<< flush
;
268 cout
<< '\r' << BlankLine
<< '\r' << Buffer
<< flush
;
269 if (_config
->FindB("Apt::Color", false) == true)
270 cout
<< _config
->Find("APT::Color::Neutral") << flush
;
272 memset(BlankLine
,' ',strlen(Buffer
));
273 BlankLine
[strlen(Buffer
)] = 0;
280 // AcqTextStatus::MediaChange - Media need to be swapped /*{{{*/
281 // ---------------------------------------------------------------------
282 /* Prompt for a media swap */
283 bool AcqTextStatus::MediaChange(string Media
,string Drive
)
285 // If we do not output on a terminal and one of the options to avoid user
286 // interaction is given, we assume that no user is present who could react
287 // on your media change request
288 if (isatty(STDOUT_FILENO
) != 1 && Quiet
>= 2 &&
289 (_config
->FindB("APT::Get::Assume-Yes",false) == true ||
290 _config
->FindB("APT::Get::Force-Yes",false) == true ||
291 _config
->FindB("APT::Get::Trivial-Only",false) == true))
296 cout
<< '\r' << BlankLine
<< '\r';
297 ioprintf(cout
,_("Media change: please insert the disc labeled\n"
299 "in the drive '%s' and press enter\n"),
300 Media
.c_str(),Drive
.c_str());
304 while (C
!= '\n' && C
!= '\r')
306 int len
= read(STDIN_FILENO
,&C
,1);
307 if(C
== 'c' || len
<= 0)