1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
|
# progress.py - progress reporting classes
#
# Copyright (c) 2005-2009 Canonical
#
# Author: Michael Vogt <michael.vogt@ubuntu.com>
#
# This program is free software; you can redistribute it and/or
# modify it under the terms of the GNU General Public License as
# published by the Free Software Foundation; either version 2 of the
# License, or (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program; if not, write to the Free Software
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
# USA
"""Deprecated progress reporting classes.
This module provides classes for compatibility with python-apt 0.7. They are
completely deprecated and should not be used anymore.
"""
import os
import sys
import apt_pkg
from apt.deprecation import AttributeDeprecatedBy, function_deprecated_by
import warnings
from apt.progress import base, text
__all__ = []
class OpProgress(base.OpProgress):
"""Abstract class to implement reporting on cache opening."""
subOp = AttributeDeprecatedBy('subop')
Op = AttributeDeprecatedBy('op')
class OpTextProgress(OpProgress, text.OpProgress):
"""A simple text based cache open reporting class."""
class FetchProgress(object):
"""Report the download/fetching progress."""
# download status constants
(dlDone, dlQueued, dlFailed, dlHit, dlIgnored) = range(5)
dlStatusStr = {dlDone: "Done", dlQueued: "Queued", dlFailed: "Failed",
dlHit: "Hit", dlIgnored: "Ignored"}
def __init__(self):
self.eta = 0.0
self.percent = 0.0
# Make checking easier
self.currentBytes = 0
self.currentItems = 0
self.totalBytes = 0
self.totalItems = 0
self.currentCPS = 0
warnings.warn("FetchProgress() is deprecated.", DeprecationWarning)
def start(self):
"""Called when the fetching starts."""
def stop(self):
"""Called when all files have been fetched."""
def updateStatus(self, uri, descr, short_descr, status):
"""Called when the status of an item changes.
This happens eg. when the downloads fails or is completed.
"""
def update_status_full(self, uri, descr, short_descr, status, file_size,
partial_size):
"""Called when the status of an item changes.
This happens eg. when the downloads fails or is completed. This
version include information on current filesize and partial size
"""
def pulse(self):
"""Called periodically to update the user interface.
Return True to continue or False to cancel.
"""
self.percent = (((self.currentBytes + self.currentItems) * 100.0) /
float(self.totalBytes + self.totalItems))
if self.currentCPS > 0:
self.eta = ((self.totalBytes - self.currentBytes) /
float(self.currentCPS))
return True
def pulse_items(self, items):
"""Called periodically to update the user interface.
This function includes details about the items being fetched
Return True to continue or False to cancel.
"""
self.percent = (((self.currentBytes + self.currentItems) * 100.0) /
float(self.totalBytes + self.totalItems))
if self.currentCPS > 0:
self.eta = ((self.totalBytes - self.currentBytes) /
float(self.currentCPS))
return True
def mediaChange(self, medium, drive):
"""react to media change events."""
class TextFetchProgress(FetchProgress):
""" Ready to use progress object for terminal windows """
def __init__(self):
FetchProgress.__init__(self)
self.items = {}
def updateStatus(self, uri, descr, short_descr, status):
"""Called when the status of an item changes.
This happens eg. when the downloads fails or is completed.
"""
if status != self.dlQueued:
print "\r%s %s" % (self.dlStatusStr[status], descr)
self.items[uri] = status
def pulse(self):
"""Called periodically to update the user interface.
Return True to continue or False to cancel.
"""
FetchProgress.pulse(self)
if self.currentCPS > 0:
s = "[%2.f%%] %sB/s %s" % (self.percent,
apt_pkg.size_to_str(int(self.currentCPS)),
apt_pkg.time_to_str(int(self.eta)))
else:
s = "%2.f%% [Working]" % (self.percent)
print "\r%s" % (s),
sys.stdout.flush()
return True
def stop(self):
"""Called when all files have been fetched."""
print "\rDone downloading "
def mediaChange(self, medium, drive):
"""react to media change events."""
print ("Media change: please insert the disc labeled "
"'%s' in the drive '%s' and press enter") % (medium, drive)
return raw_input() not in ('c', 'C')
class CdromProgress(base.CdromProgress):
"""Report the cdrom add progress.
This class has been replaced by apt_pkg.CdromProgress.
"""
_basetype = base.CdromProgress
askCdromName = function_deprecated_by(_basetype.ask_cdrom_name)
changeCdrom = function_deprecated_by(_basetype.change_cdrom)
del _basetype
class DumbInstallProgress(base.InstallProgress):
"""Report the install progress.
Subclass this class to implement install progress reporting.
"""
startUpdate = function_deprecated_by(base.InstallProgress.start_update)
finishUpdate = function_deprecated_by(base.InstallProgress.finish_update)
updateInterface = function_deprecated_by(
base.InstallProgress.update_interface)
class InstallProgress(DumbInstallProgress, base.InstallProgress):
"""An InstallProgress that is pretty useful.
It supports the attributes 'percent' 'status' and callbacks for the dpkg
errors and conffiles and status changes.
"""
selectTimeout = AttributeDeprecatedBy('select_timeout')
statusChange = function_deprecated_by(base.InstallProgress.status_change)
waitChild = function_deprecated_by(base.InstallProgress.wait_child)
class DpkgInstallProgress(InstallProgress):
"""Progress handler for a local Debian package installation."""
def run(self, debfile):
"""Start installing the given Debian package."""
# Deprecated stuff
self.debfile = debfile
self.debname = os.path.basename(debfile).split("_")[0]
return base.InstallProgress(self, debfile)
|