diff options
author | brian avery <avery.brian@gmail.com> | 2016-02-29 10:49:49 -0800 |
---|---|---|
committer | Richard Purdie <richard.purdie@linuxfoundation.org> | 2016-03-02 22:41:23 +0000 |
commit | a7d1b95c96950326f0c0b09ec901abd57a27b38e (patch) | |
tree | 994c9c4f0981379e1025e072792a8175f7baf653 /bitbake/lib | |
parent | a9dc72f08bf5bdd898fba429729acee0e7305838 (diff) | |
download | poky-a7d1b95c96950326f0c0b09ec901abd57a27b38e.tar.gz |
bitbake: ui: remove the puccho ui
This ui does not work in master, nor has it been updated for several years.
[YOCTO #9178]
(Bitbake rev: 9fad1d13eed1f725971e6d12d3977cd31e07019a)
Signed-off-by: brian avery <avery.brian@gmail.com>
Signed-off-by: Richard Purdie <richard.purdie@linuxfoundation.org>
Diffstat (limited to 'bitbake/lib')
-rw-r--r-- | bitbake/lib/bb/ui/crumbs/buildmanager.py | 455 | ||||
-rw-r--r-- | bitbake/lib/bb/ui/puccho.py | 425 |
2 files changed, 0 insertions, 880 deletions
diff --git a/bitbake/lib/bb/ui/crumbs/buildmanager.py b/bitbake/lib/bb/ui/crumbs/buildmanager.py deleted file mode 100644 index e858d75e4c..0000000000 --- a/bitbake/lib/bb/ui/crumbs/buildmanager.py +++ /dev/null | |||
@@ -1,455 +0,0 @@ | |||
1 | # | ||
2 | # BitBake Graphical GTK User Interface | ||
3 | # | ||
4 | # Copyright (C) 2008 Intel Corporation | ||
5 | # | ||
6 | # Authored by Rob Bradford <rob@linux.intel.com> | ||
7 | # | ||
8 | # This program is free software; you can redistribute it and/or modify | ||
9 | # it under the terms of the GNU General Public License version 2 as | ||
10 | # published by the Free Software Foundation. | ||
11 | # | ||
12 | # This program is distributed in the hope that it will be useful, | ||
13 | # but WITHOUT ANY WARRANTY; without even the implied warranty of | ||
14 | # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | ||
15 | # GNU General Public License for more details. | ||
16 | # | ||
17 | # You should have received a copy of the GNU General Public License along | ||
18 | # with this program; if not, write to the Free Software Foundation, Inc., | ||
19 | # 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. | ||
20 | |||
21 | import gtk | ||
22 | import gobject | ||
23 | import threading | ||
24 | import os | ||
25 | import datetime | ||
26 | import time | ||
27 | |||
28 | class BuildConfiguration: | ||
29 | """ Represents a potential *or* historic *or* concrete build. It | ||
30 | encompasses all the things that we need to tell bitbake to do to make it | ||
31 | build what we want it to build. | ||
32 | |||
33 | It also stored the metadata URL and the set of possible machines (and the | ||
34 | distros / images / uris for these. Apart from the metdata URL these are | ||
35 | not serialised to file (since they may be transient). In some ways this | ||
36 | functionality might be shifted to the loader class.""" | ||
37 | |||
38 | def __init__ (self): | ||
39 | self.metadata_url = None | ||
40 | |||
41 | # Tuple of (distros, image, urls) | ||
42 | self.machine_options = {} | ||
43 | |||
44 | self.machine = None | ||
45 | self.distro = None | ||
46 | self.image = None | ||
47 | self.urls = [] | ||
48 | self.extra_urls = [] | ||
49 | self.extra_pkgs = [] | ||
50 | |||
51 | def get_machines_model (self): | ||
52 | model = gtk.ListStore (gobject.TYPE_STRING) | ||
53 | for machine in self.machine_options.keys(): | ||
54 | model.append ([machine]) | ||
55 | |||
56 | return model | ||
57 | |||
58 | def get_distro_and_images_models (self, machine): | ||
59 | distro_model = gtk.ListStore (gobject.TYPE_STRING) | ||
60 | |||
61 | for distro in self.machine_options[machine][0]: | ||
62 | distro_model.append ([distro]) | ||
63 | |||
64 | image_model = gtk.ListStore (gobject.TYPE_STRING) | ||
65 | |||
66 | for image in self.machine_options[machine][1]: | ||
67 | image_model.append ([image]) | ||
68 | |||
69 | return (distro_model, image_model) | ||
70 | |||
71 | def get_repos (self): | ||
72 | self.urls = self.machine_options[self.machine][2] | ||
73 | return self.urls | ||
74 | |||
75 | # It might be a lot lot better if we stored these in like, bitbake conf | ||
76 | # file format. | ||
77 | @staticmethod | ||
78 | def load_from_file (filename): | ||
79 | |||
80 | conf = BuildConfiguration() | ||
81 | with open(filename, "r") as f: | ||
82 | for line in f: | ||
83 | data = line.split (";")[1] | ||
84 | if (line.startswith ("metadata-url;")): | ||
85 | conf.metadata_url = data.strip() | ||
86 | continue | ||
87 | if (line.startswith ("url;")): | ||
88 | conf.urls += [data.strip()] | ||
89 | continue | ||
90 | if (line.startswith ("extra-url;")): | ||
91 | conf.extra_urls += [data.strip()] | ||
92 | continue | ||
93 | if (line.startswith ("machine;")): | ||
94 | conf.machine = data.strip() | ||
95 | continue | ||
96 | if (line.startswith ("distribution;")): | ||
97 | conf.distro = data.strip() | ||
98 | continue | ||
99 | if (line.startswith ("image;")): | ||
100 | conf.image = data.strip() | ||
101 | continue | ||
102 | |||
103 | return conf | ||
104 | |||
105 | # Serialise to a file. This is part of the build process and we use this | ||
106 | # to be able to repeat a given build (using the same set of parameters) | ||
107 | # but also so that we can include the details of the image / machine / | ||
108 | # distro in the build manager tree view. | ||
109 | def write_to_file (self, filename): | ||
110 | f = open (filename, "w") | ||
111 | |||
112 | lines = [] | ||
113 | |||
114 | if (self.metadata_url): | ||
115 | lines += ["metadata-url;%s\n" % (self.metadata_url)] | ||
116 | |||
117 | for url in self.urls: | ||
118 | lines += ["url;%s\n" % (url)] | ||
119 | |||
120 | for url in self.extra_urls: | ||
121 | lines += ["extra-url;%s\n" % (url)] | ||
122 | |||
123 | if (self.machine): | ||
124 | lines += ["machine;%s\n" % (self.machine)] | ||
125 | |||
126 | if (self.distro): | ||
127 | lines += ["distribution;%s\n" % (self.distro)] | ||
128 | |||
129 | if (self.image): | ||
130 | lines += ["image;%s\n" % (self.image)] | ||
131 | |||
132 | f.writelines (lines) | ||
133 | f.close () | ||
134 | |||
135 | class BuildResult(gobject.GObject): | ||
136 | """ Represents an historic build. Perhaps not successful. But it includes | ||
137 | things such as the files that are in the directory (the output from the | ||
138 | build) as well as a deserialised BuildConfiguration file that is stored in | ||
139 | ".conf" in the directory for the build. | ||
140 | |||
141 | This is GObject so that it can be included in the TreeStore.""" | ||
142 | |||
143 | (STATE_COMPLETE, STATE_FAILED, STATE_ONGOING) = \ | ||
144 | (0, 1, 2) | ||
145 | |||
146 | def __init__ (self, parent, identifier): | ||
147 | gobject.GObject.__init__ (self) | ||
148 | self.date = None | ||
149 | |||
150 | self.files = [] | ||
151 | self.status = None | ||
152 | self.identifier = identifier | ||
153 | self.path = os.path.join (parent, identifier) | ||
154 | |||
155 | # Extract the date, since the directory name is of the | ||
156 | # format build-<year><month><day>-<ordinal> we can easily | ||
157 | # pull it out. | ||
158 | # TODO: Better to stat a file? | ||
159 | (_, date, revision) = identifier.split ("-") | ||
160 | print(date) | ||
161 | |||
162 | year = int (date[0:4]) | ||
163 | month = int (date[4:6]) | ||
164 | day = int (date[6:8]) | ||
165 | |||
166 | self.date = datetime.date (year, month, day) | ||
167 | |||
168 | self.conf = None | ||
169 | |||
170 | # By default builds are STATE_FAILED unless we find a "complete" file | ||
171 | # in which case they are STATE_COMPLETE | ||
172 | self.state = BuildResult.STATE_FAILED | ||
173 | for file in os.listdir (self.path): | ||
174 | if (file.startswith (".conf")): | ||
175 | conffile = os.path.join (self.path, file) | ||
176 | self.conf = BuildConfiguration.load_from_file (conffile) | ||
177 | elif (file.startswith ("complete")): | ||
178 | self.state = BuildResult.STATE_COMPLETE | ||
179 | else: | ||
180 | self.add_file (file) | ||
181 | |||
182 | def add_file (self, file): | ||
183 | # Just add the file for now. Don't care about the type. | ||
184 | self.files += [(file, None)] | ||
185 | |||
186 | class BuildManagerModel (gtk.TreeStore): | ||
187 | """ Model for the BuildManagerTreeView. This derives from gtk.TreeStore | ||
188 | but it abstracts nicely what the columns mean and the setup of the columns | ||
189 | in the model. """ | ||
190 | |||
191 | (COL_IDENT, COL_DESC, COL_MACHINE, COL_DISTRO, COL_BUILD_RESULT, COL_DATE, COL_STATE) = \ | ||
192 | (0, 1, 2, 3, 4, 5, 6) | ||
193 | |||
194 | def __init__ (self): | ||
195 | gtk.TreeStore.__init__ (self, | ||
196 | gobject.TYPE_STRING, | ||
197 | gobject.TYPE_STRING, | ||
198 | gobject.TYPE_STRING, | ||
199 | gobject.TYPE_STRING, | ||
200 | gobject.TYPE_OBJECT, | ||
201 | gobject.TYPE_INT64, | ||
202 | gobject.TYPE_INT) | ||
203 | |||
204 | class BuildManager (gobject.GObject): | ||
205 | """ This class manages the historic builds that have been found in the | ||
206 | "results" directory but is also used for starting a new build.""" | ||
207 | |||
208 | __gsignals__ = { | ||
209 | 'population-finished' : (gobject.SIGNAL_RUN_LAST, | ||
210 | gobject.TYPE_NONE, | ||
211 | ()), | ||
212 | 'populate-error' : (gobject.SIGNAL_RUN_LAST, | ||
213 | gobject.TYPE_NONE, | ||
214 | ()) | ||
215 | } | ||
216 | |||
217 | def update_build_result (self, result, iter): | ||
218 | # Convert the date into something we can sort by. | ||
219 | date = long (time.mktime (result.date.timetuple())) | ||
220 | |||
221 | # Add a top level entry for the build | ||
222 | |||
223 | self.model.set (iter, | ||
224 | BuildManagerModel.COL_IDENT, result.identifier, | ||
225 | BuildManagerModel.COL_DESC, result.conf.image, | ||
226 | BuildManagerModel.COL_MACHINE, result.conf.machine, | ||
227 | BuildManagerModel.COL_DISTRO, result.conf.distro, | ||
228 | BuildManagerModel.COL_BUILD_RESULT, result, | ||
229 | BuildManagerModel.COL_DATE, date, | ||
230 | BuildManagerModel.COL_STATE, result.state) | ||
231 | |||
232 | # And then we use the files in the directory as the children for the | ||
233 | # top level iter. | ||
234 | for file in result.files: | ||
235 | self.model.append (iter, (None, file[0], None, None, None, date, -1)) | ||
236 | |||
237 | # This function is called as an idle by the BuildManagerPopulaterThread | ||
238 | def add_build_result (self, result): | ||
239 | gtk.gdk.threads_enter() | ||
240 | self.known_builds += [result] | ||
241 | |||
242 | self.update_build_result (result, self.model.append (None)) | ||
243 | |||
244 | gtk.gdk.threads_leave() | ||
245 | |||
246 | def notify_build_finished (self): | ||
247 | # This is a bit of a hack. If we have a running build running then we | ||
248 | # will have a row in the model in STATE_ONGOING. Find it and make it | ||
249 | # as if it was a proper historic build (well, it is completed now....) | ||
250 | |||
251 | # We need to use the iters here rather than the Python iterator | ||
252 | # interface to the model since we need to pass it into | ||
253 | # update_build_result | ||
254 | |||
255 | iter = self.model.get_iter_first() | ||
256 | |||
257 | while (iter): | ||
258 | (ident, state) = self.model.get(iter, | ||
259 | BuildManagerModel.COL_IDENT, | ||
260 | BuildManagerModel.COL_STATE) | ||
261 | |||
262 | if state == BuildResult.STATE_ONGOING: | ||
263 | result = BuildResult (self.results_directory, ident) | ||
264 | self.update_build_result (result, iter) | ||
265 | iter = self.model.iter_next(iter) | ||
266 | |||
267 | def notify_build_succeeded (self): | ||
268 | # Write the "complete" file so that when we create the BuildResult | ||
269 | # object we put into the model | ||
270 | |||
271 | complete_file_path = os.path.join (self.cur_build_directory, "complete") | ||
272 | f = file (complete_file_path, "w") | ||
273 | f.close() | ||
274 | self.notify_build_finished() | ||
275 | |||
276 | def notify_build_failed (self): | ||
277 | # Without a "complete" file then this will mark the build as failed: | ||
278 | self.notify_build_finished() | ||
279 | |||
280 | # This function is called as an idle | ||
281 | def emit_population_finished_signal (self): | ||
282 | gtk.gdk.threads_enter() | ||
283 | self.emit ("population-finished") | ||
284 | gtk.gdk.threads_leave() | ||
285 | |||
286 | class BuildManagerPopulaterThread (threading.Thread): | ||
287 | def __init__ (self, manager, directory): | ||
288 | threading.Thread.__init__ (self) | ||
289 | self.manager = manager | ||
290 | self.directory = directory | ||
291 | |||
292 | def run (self): | ||
293 | # For each of the "build-<...>" directories .. | ||
294 | |||
295 | if os.path.exists (self.directory): | ||
296 | for directory in os.listdir (self.directory): | ||
297 | |||
298 | if not directory.startswith ("build-"): | ||
299 | continue | ||
300 | |||
301 | build_result = BuildResult (self.directory, directory) | ||
302 | self.manager.add_build_result (build_result) | ||
303 | |||
304 | gobject.idle_add (BuildManager.emit_population_finished_signal, | ||
305 | self.manager) | ||
306 | |||
307 | def __init__ (self, server, results_directory): | ||
308 | gobject.GObject.__init__ (self) | ||
309 | |||
310 | # The builds that we've found from walking the result directory | ||
311 | self.known_builds = [] | ||
312 | |||
313 | # Save out the bitbake server, we need this for issuing commands to | ||
314 | # the cooker: | ||
315 | self.server = server | ||
316 | |||
317 | # The TreeStore that we use | ||
318 | self.model = BuildManagerModel () | ||
319 | |||
320 | # The results directory is where we create (and look for) the | ||
321 | # build-<xyz>-<n> directories. We need to populate ourselves from | ||
322 | # directory | ||
323 | self.results_directory = results_directory | ||
324 | self.populate_from_directory (self.results_directory) | ||
325 | |||
326 | def populate_from_directory (self, directory): | ||
327 | thread = BuildManager.BuildManagerPopulaterThread (self, directory) | ||
328 | thread.start() | ||
329 | |||
330 | # Come up with the name for the next build ident by combining "build-" | ||
331 | # with the date formatted as yyyymmdd and then an ordinal. We do this by | ||
332 | # an optimistic algorithm incrementing the ordinal if we find that it | ||
333 | # already exists. | ||
334 | def get_next_build_ident (self): | ||
335 | today = datetime.date.today () | ||
336 | datestr = str (today.year) + str (today.month) + str (today.day) | ||
337 | |||
338 | revision = 0 | ||
339 | test_name = "build-%s-%d" % (datestr, revision) | ||
340 | test_path = os.path.join (self.results_directory, test_name) | ||
341 | |||
342 | while (os.path.exists (test_path)): | ||
343 | revision += 1 | ||
344 | test_name = "build-%s-%d" % (datestr, revision) | ||
345 | test_path = os.path.join (self.results_directory, test_name) | ||
346 | |||
347 | return test_name | ||
348 | |||
349 | # Take a BuildConfiguration and then try and build it based on the | ||
350 | # parameters of that configuration. S | ||
351 | def do_build (self, conf): | ||
352 | server = self.server | ||
353 | |||
354 | # Work out the build directory. Note we actually create the | ||
355 | # directories here since we need to write the ".conf" file. Otherwise | ||
356 | # we could have relied on bitbake's builder thread to actually make | ||
357 | # the directories as it proceeds with the build. | ||
358 | ident = self.get_next_build_ident () | ||
359 | build_directory = os.path.join (self.results_directory, | ||
360 | ident) | ||
361 | self.cur_build_directory = build_directory | ||
362 | os.makedirs (build_directory) | ||
363 | |||
364 | conffile = os.path.join (build_directory, ".conf") | ||
365 | conf.write_to_file (conffile) | ||
366 | |||
367 | # Add a row to the model representing this ongoing build. It's kinda a | ||
368 | # fake entry. If this build completes or fails then this gets updated | ||
369 | # with the real stuff like the historic builds | ||
370 | date = long (time.time()) | ||
371 | self.model.append (None, (ident, conf.image, conf.machine, conf.distro, | ||
372 | None, date, BuildResult.STATE_ONGOING)) | ||
373 | try: | ||
374 | server.runCommand(["setVariable", "BUILD_IMAGES_FROM_FEEDS", 1]) | ||
375 | server.runCommand(["setVariable", "MACHINE", conf.machine]) | ||
376 | server.runCommand(["setVariable", "DISTRO", conf.distro]) | ||
377 | server.runCommand(["setVariable", "PACKAGE_CLASSES", "package_ipk"]) | ||
378 | server.runCommand(["setVariable", "BBFILES", \ | ||
379 | """${OEROOT}/meta/packages/*/*.bb ${OEROOT}/meta-moblin/packages/*/*.bb"""]) | ||
380 | server.runCommand(["setVariable", "TMPDIR", "${OEROOT}/build/tmp"]) | ||
381 | server.runCommand(["setVariable", "IPK_FEED_URIS", \ | ||
382 | " ".join(conf.get_repos())]) | ||
383 | server.runCommand(["setVariable", "DEPLOY_DIR_IMAGE", | ||
384 | build_directory]) | ||
385 | server.runCommand(["buildTargets", [conf.image], "rootfs"]) | ||
386 | |||
387 | except Exception as e: | ||
388 | print(e) | ||
389 | |||
390 | class BuildManagerTreeView (gtk.TreeView): | ||
391 | """ The tree view for the build manager. This shows the historic builds | ||
392 | and so forth. """ | ||
393 | |||
394 | # We use this function to control what goes in the cell since we store | ||
395 | # the date in the model as seconds since the epoch (for sorting) and so we | ||
396 | # need to make it human readable. | ||
397 | def date_format_custom_cell_data_func (self, col, cell, model, iter): | ||
398 | date = model.get (iter, BuildManagerModel.COL_DATE)[0] | ||
399 | datestr = time.strftime("%A %d %B %Y", time.localtime(date)) | ||
400 | cell.set_property ("text", datestr) | ||
401 | |||
402 | # This format function controls what goes in the cell. We use this to map | ||
403 | # the integer state to a string and also to colourise the text | ||
404 | def state_format_custom_cell_data_fun (self, col, cell, model, iter): | ||
405 | state = model.get (iter, BuildManagerModel.COL_STATE)[0] | ||
406 | |||
407 | if (state == BuildResult.STATE_ONGOING): | ||
408 | cell.set_property ("text", "Active") | ||
409 | cell.set_property ("foreground", "#000000") | ||
410 | elif (state == BuildResult.STATE_FAILED): | ||
411 | cell.set_property ("text", "Failed") | ||
412 | cell.set_property ("foreground", "#ff0000") | ||
413 | elif (state == BuildResult.STATE_COMPLETE): | ||
414 | cell.set_property ("text", "Complete") | ||
415 | cell.set_property ("foreground", "#00ff00") | ||
416 | else: | ||
417 | cell.set_property ("text", "") | ||
418 | |||
419 | def __init__ (self): | ||
420 | gtk.TreeView.__init__(self) | ||
421 | |||
422 | # Misc descriptiony thing | ||
423 | renderer = gtk.CellRendererText () | ||
424 | col = gtk.TreeViewColumn (None, renderer, | ||
425 | text=BuildManagerModel.COL_DESC) | ||
426 | self.append_column (col) | ||
427 | |||
428 | # Machine | ||
429 | renderer = gtk.CellRendererText () | ||
430 | col = gtk.TreeViewColumn ("Machine", renderer, | ||
431 | text=BuildManagerModel.COL_MACHINE) | ||
432 | self.append_column (col) | ||
433 | |||
434 | # distro | ||
435 | renderer = gtk.CellRendererText () | ||
436 | col = gtk.TreeViewColumn ("Distribution", renderer, | ||
437 | text=BuildManagerModel.COL_DISTRO) | ||
438 | self.append_column (col) | ||
439 | |||
440 | # date (using a custom function for formatting the cell contents it | ||
441 | # takes epoch -> human readable string) | ||
442 | renderer = gtk.CellRendererText () | ||
443 | col = gtk.TreeViewColumn ("Date", renderer, | ||
444 | text=BuildManagerModel.COL_DATE) | ||
445 | self.append_column (col) | ||
446 | col.set_cell_data_func (renderer, | ||
447 | self.date_format_custom_cell_data_func) | ||
448 | |||
449 | # For status. | ||
450 | renderer = gtk.CellRendererText () | ||
451 | col = gtk.TreeViewColumn ("Status", renderer, | ||
452 | text = BuildManagerModel.COL_STATE) | ||
453 | self.append_column (col) | ||
454 | col.set_cell_data_func (renderer, | ||
455 | self.state_format_custom_cell_data_fun) | ||
diff --git a/bitbake/lib/bb/ui/puccho.py b/bitbake/lib/bb/ui/puccho.py deleted file mode 100644 index 3ce4590c16..0000000000 --- a/bitbake/lib/bb/ui/puccho.py +++ /dev/null | |||
@@ -1,425 +0,0 @@ | |||
1 | # | ||
2 | # BitBake Graphical GTK User Interface | ||
3 | # | ||
4 | # Copyright (C) 2008 Intel Corporation | ||
5 | # | ||
6 | # Authored by Rob Bradford <rob@linux.intel.com> | ||
7 | # | ||
8 | # This program is free software; you can redistribute it and/or modify | ||
9 | # it under the terms of the GNU General Public License version 2 as | ||
10 | # published by the Free Software Foundation. | ||
11 | # | ||
12 | # This program is distributed in the hope that it will be useful, | ||
13 | # but WITHOUT ANY WARRANTY; without even the implied warranty of | ||
14 | # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | ||
15 | # GNU General Public License for more details. | ||
16 | # | ||
17 | # You should have received a copy of the GNU General Public License along | ||
18 | # with this program; if not, write to the Free Software Foundation, Inc., | ||
19 | # 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. | ||
20 | |||
21 | import gtk | ||
22 | import gobject | ||
23 | import gtk.glade | ||
24 | import threading | ||
25 | import urllib2 | ||
26 | import os | ||
27 | import contextlib | ||
28 | |||
29 | from bb.ui.crumbs.buildmanager import BuildManager, BuildConfiguration | ||
30 | from bb.ui.crumbs.buildmanager import BuildManagerTreeView | ||
31 | |||
32 | from bb.ui.crumbs.runningbuild import RunningBuild, RunningBuildTreeView | ||
33 | |||
34 | # The metadata loader is used by the BuildSetupDialog to download the | ||
35 | # available options to populate the dialog | ||
36 | class MetaDataLoader(gobject.GObject): | ||
37 | """ This class provides the mechanism for loading the metadata (the | ||
38 | fetching and parsing) from a given URL. The metadata encompasses details | ||
39 | on what machines are available. The distribution and images available for | ||
40 | the machine and the the uris to use for building the given machine.""" | ||
41 | __gsignals__ = { | ||
42 | 'success' : (gobject.SIGNAL_RUN_LAST, | ||
43 | gobject.TYPE_NONE, | ||
44 | ()), | ||
45 | 'error' : (gobject.SIGNAL_RUN_LAST, | ||
46 | gobject.TYPE_NONE, | ||
47 | (gobject.TYPE_STRING,)) | ||
48 | } | ||
49 | |||
50 | # We use these little helper functions to ensure that we take the gdk lock | ||
51 | # when emitting the signal. These functions are called as idles (so that | ||
52 | # they happen in the gtk / main thread's main loop. | ||
53 | def emit_error_signal (self, remark): | ||
54 | gtk.gdk.threads_enter() | ||
55 | self.emit ("error", remark) | ||
56 | gtk.gdk.threads_leave() | ||
57 | |||
58 | def emit_success_signal (self): | ||
59 | gtk.gdk.threads_enter() | ||
60 | self.emit ("success") | ||
61 | gtk.gdk.threads_leave() | ||
62 | |||
63 | def __init__ (self): | ||
64 | gobject.GObject.__init__ (self) | ||
65 | |||
66 | class LoaderThread(threading.Thread): | ||
67 | """ This class provides an asynchronous loader for the metadata (by | ||
68 | using threads and signals). This is useful since the metadata may be | ||
69 | at a remote URL.""" | ||
70 | class LoaderImportException (Exception): | ||
71 | pass | ||
72 | |||
73 | def __init__(self, loader, url): | ||
74 | threading.Thread.__init__ (self) | ||
75 | self.url = url | ||
76 | self.loader = loader | ||
77 | |||
78 | def run (self): | ||
79 | result = {} | ||
80 | try: | ||
81 | with contextlib.closing (urllib2.urlopen (self.url)) as f: | ||
82 | # Parse the metadata format. The format is.... | ||
83 | # <machine>;<default distro>|<distro>...;<default image>|<image>...;<type##url>|... | ||
84 | for line in f: | ||
85 | components = line.split(";") | ||
86 | if (len (components) < 4): | ||
87 | raise MetaDataLoader.LoaderThread.LoaderImportException | ||
88 | machine = components[0] | ||
89 | distros = components[1].split("|") | ||
90 | images = components[2].split("|") | ||
91 | urls = components[3].split("|") | ||
92 | |||
93 | result[machine] = (distros, images, urls) | ||
94 | |||
95 | # Create an object representing this *potential* | ||
96 | # configuration. It can become concrete if the machine, distro | ||
97 | # and image are all chosen in the UI | ||
98 | configuration = BuildConfiguration() | ||
99 | configuration.metadata_url = self.url | ||
100 | configuration.machine_options = result | ||
101 | self.loader.configuration = configuration | ||
102 | |||
103 | # Emit that we've actually got a configuration | ||
104 | gobject.idle_add (MetaDataLoader.emit_success_signal, | ||
105 | self.loader) | ||
106 | |||
107 | except MetaDataLoader.LoaderThread.LoaderImportException as e: | ||
108 | gobject.idle_add (MetaDataLoader.emit_error_signal, self.loader, | ||
109 | "Repository metadata corrupt") | ||
110 | except Exception as e: | ||
111 | gobject.idle_add (MetaDataLoader.emit_error_signal, self.loader, | ||
112 | "Unable to download repository metadata") | ||
113 | print(e) | ||
114 | |||
115 | def try_fetch_from_url (self, url): | ||
116 | # Try and download the metadata. Firing a signal if successful | ||
117 | thread = MetaDataLoader.LoaderThread(self, url) | ||
118 | thread.start() | ||
119 | |||
120 | class BuildSetupDialog (gtk.Dialog): | ||
121 | RESPONSE_BUILD = 1 | ||
122 | |||
123 | # A little helper method that just sets the states on the widgets based on | ||
124 | # whether we've got good metadata or not. | ||
125 | def set_configurable (self, configurable): | ||
126 | if (self.configurable == configurable): | ||
127 | return | ||
128 | |||
129 | self.configurable = configurable | ||
130 | for widget in self.conf_widgets: | ||
131 | widget.set_sensitive (configurable) | ||
132 | |||
133 | if not configurable: | ||
134 | self.machine_combo.set_active (-1) | ||
135 | self.distribution_combo.set_active (-1) | ||
136 | self.image_combo.set_active (-1) | ||
137 | |||
138 | # GTK widget callbacks | ||
139 | def refresh_button_clicked (self, button): | ||
140 | # Refresh button clicked. | ||
141 | |||
142 | url = self.location_entry.get_chars (0, -1) | ||
143 | self.loader.try_fetch_from_url(url) | ||
144 | |||
145 | def repository_entry_editable_changed (self, entry): | ||
146 | if (len (entry.get_chars (0, -1)) > 0): | ||
147 | self.refresh_button.set_sensitive (True) | ||
148 | else: | ||
149 | self.refresh_button.set_sensitive (False) | ||
150 | self.clear_status_message() | ||
151 | |||
152 | # If we were previously configurable we are no longer since the | ||
153 | # location entry has been changed | ||
154 | self.set_configurable (False) | ||
155 | |||
156 | def machine_combo_changed (self, combobox): | ||
157 | active_iter = combobox.get_active_iter() | ||
158 | |||
159 | if not active_iter: | ||
160 | return | ||
161 | |||
162 | model = combobox.get_model() | ||
163 | |||
164 | if model: | ||
165 | chosen_machine = model.get (active_iter, 0)[0] | ||
166 | |||
167 | (distros_model, images_model) = \ | ||
168 | self.loader.configuration.get_distro_and_images_models (chosen_machine) | ||
169 | |||
170 | self.distribution_combo.set_model (distros_model) | ||
171 | self.image_combo.set_model (images_model) | ||
172 | |||
173 | # Callbacks from the loader | ||
174 | def loader_success_cb (self, loader): | ||
175 | self.status_image.set_from_icon_name ("info", | ||
176 | gtk.ICON_SIZE_BUTTON) | ||
177 | self.status_image.show() | ||
178 | self.status_label.set_label ("Repository metadata successfully downloaded") | ||
179 | |||
180 | # Set the models on the combo boxes based on the models generated from | ||
181 | # the configuration that the loader has created | ||
182 | |||
183 | # We just need to set the machine here, that then determines the | ||
184 | # distro and image options. Cunning huh? :-) | ||
185 | |||
186 | self.configuration = self.loader.configuration | ||
187 | model = self.configuration.get_machines_model () | ||
188 | self.machine_combo.set_model (model) | ||
189 | |||
190 | self.set_configurable (True) | ||
191 | |||
192 | def loader_error_cb (self, loader, message): | ||
193 | self.status_image.set_from_icon_name ("error", | ||
194 | gtk.ICON_SIZE_BUTTON) | ||
195 | self.status_image.show() | ||
196 | self.status_label.set_text ("Error downloading repository metadata") | ||
197 | for widget in self.conf_widgets: | ||
198 | widget.set_sensitive (False) | ||
199 | |||
200 | def clear_status_message (self): | ||
201 | self.status_image.hide() | ||
202 | self.status_label.set_label ( | ||
203 | """<i>Enter the repository location and press _Refresh</i>""") | ||
204 | |||
205 | def __init__ (self): | ||
206 | gtk.Dialog.__init__ (self) | ||
207 | |||
208 | # Cancel | ||
209 | self.add_button (gtk.STOCK_CANCEL, gtk.RESPONSE_CANCEL) | ||
210 | |||
211 | # Build | ||
212 | button = gtk.Button ("_Build", None, True) | ||
213 | image = gtk.Image () | ||
214 | image.set_from_stock (gtk.STOCK_EXECUTE, gtk.ICON_SIZE_BUTTON) | ||
215 | button.set_image (image) | ||
216 | self.add_action_widget (button, BuildSetupDialog.RESPONSE_BUILD) | ||
217 | button.show_all () | ||
218 | |||
219 | # Pull in *just* the table from the Glade XML data. | ||
220 | gxml = gtk.glade.XML (os.path.dirname(__file__) + "/crumbs/puccho.glade", | ||
221 | root = "build_table") | ||
222 | table = gxml.get_widget ("build_table") | ||
223 | self.vbox.pack_start (table, True, False, 0) | ||
224 | |||
225 | # Grab all the widgets that we need to turn on/off when we refresh... | ||
226 | self.conf_widgets = [] | ||
227 | self.conf_widgets += [gxml.get_widget ("machine_label")] | ||
228 | self.conf_widgets += [gxml.get_widget ("distribution_label")] | ||
229 | self.conf_widgets += [gxml.get_widget ("image_label")] | ||
230 | self.conf_widgets += [gxml.get_widget ("machine_combo")] | ||
231 | self.conf_widgets += [gxml.get_widget ("distribution_combo")] | ||
232 | self.conf_widgets += [gxml.get_widget ("image_combo")] | ||
233 | |||
234 | # Grab the status widgets | ||
235 | self.status_image = gxml.get_widget ("status_image") | ||
236 | self.status_label = gxml.get_widget ("status_label") | ||
237 | |||
238 | # Grab the refresh button and connect to the clicked signal | ||
239 | self.refresh_button = gxml.get_widget ("refresh_button") | ||
240 | self.refresh_button.connect ("clicked", self.refresh_button_clicked) | ||
241 | |||
242 | # Grab the location entry and connect to editable::changed | ||
243 | self.location_entry = gxml.get_widget ("location_entry") | ||
244 | self.location_entry.connect ("changed", | ||
245 | self.repository_entry_editable_changed) | ||
246 | |||
247 | # Grab the machine combo and hook onto the changed signal. This then | ||
248 | # allows us to populate the distro and image combos | ||
249 | self.machine_combo = gxml.get_widget ("machine_combo") | ||
250 | self.machine_combo.connect ("changed", self.machine_combo_changed) | ||
251 | |||
252 | # Setup the combo | ||
253 | cell = gtk.CellRendererText() | ||
254 | self.machine_combo.pack_start(cell, True) | ||
255 | self.machine_combo.add_attribute(cell, 'text', 0) | ||
256 | |||
257 | # Grab the distro and image combos. We need these to populate with | ||
258 | # models once the machine is chosen | ||
259 | self.distribution_combo = gxml.get_widget ("distribution_combo") | ||
260 | cell = gtk.CellRendererText() | ||
261 | self.distribution_combo.pack_start(cell, True) | ||
262 | self.distribution_combo.add_attribute(cell, 'text', 0) | ||
263 | |||
264 | self.image_combo = gxml.get_widget ("image_combo") | ||
265 | cell = gtk.CellRendererText() | ||
266 | self.image_combo.pack_start(cell, True) | ||
267 | self.image_combo.add_attribute(cell, 'text', 0) | ||
268 | |||
269 | # Put the default descriptive text in the status box | ||
270 | self.clear_status_message() | ||
271 | |||
272 | # Mark as non-configurable, this is just greys out the widgets the | ||
273 | # user can't yet use | ||
274 | self.configurable = False | ||
275 | self.set_configurable(False) | ||
276 | |||
277 | # Show the table | ||
278 | table.show_all () | ||
279 | |||
280 | # The loader and some signals connected to it to update the status | ||
281 | # area | ||
282 | self.loader = MetaDataLoader() | ||
283 | self.loader.connect ("success", self.loader_success_cb) | ||
284 | self.loader.connect ("error", self.loader_error_cb) | ||
285 | |||
286 | def update_configuration (self): | ||
287 | """ A poorly named function but it updates the internal configuration | ||
288 | from the widgets. This can make that configuration concrete and can | ||
289 | thus be used for building """ | ||
290 | # Extract the chosen machine from the combo | ||
291 | model = self.machine_combo.get_model() | ||
292 | active_iter = self.machine_combo.get_active_iter() | ||
293 | if (active_iter): | ||
294 | self.configuration.machine = model.get(active_iter, 0)[0] | ||
295 | |||
296 | # Extract the chosen distro from the combo | ||
297 | model = self.distribution_combo.get_model() | ||
298 | active_iter = self.distribution_combo.get_active_iter() | ||
299 | if (active_iter): | ||
300 | self.configuration.distro = model.get(active_iter, 0)[0] | ||
301 | |||
302 | # Extract the chosen image from the combo | ||
303 | model = self.image_combo.get_model() | ||
304 | active_iter = self.image_combo.get_active_iter() | ||
305 | if (active_iter): | ||
306 | self.configuration.image = model.get(active_iter, 0)[0] | ||
307 | |||
308 | # This function operates to pull events out from the event queue and then push | ||
309 | # them into the RunningBuild (which then drives the RunningBuild which then | ||
310 | # pushes through and updates the progress tree view.) | ||
311 | # | ||
312 | # TODO: Should be a method on the RunningBuild class | ||
313 | def event_handle_timeout (eventHandler, build): | ||
314 | # Consume as many messages as we can ... | ||
315 | event = eventHandler.getEvent() | ||
316 | while event: | ||
317 | build.handle_event (event) | ||
318 | event = eventHandler.getEvent() | ||
319 | return True | ||
320 | |||
321 | class MainWindow (gtk.Window): | ||
322 | |||
323 | # Callback that gets fired when the user hits a button in the | ||
324 | # BuildSetupDialog. | ||
325 | def build_dialog_box_response_cb (self, dialog, response_id): | ||
326 | conf = None | ||
327 | if (response_id == BuildSetupDialog.RESPONSE_BUILD): | ||
328 | dialog.update_configuration() | ||
329 | print(dialog.configuration.machine, dialog.configuration.distro, \ | ||
330 | dialog.configuration.image) | ||
331 | conf = dialog.configuration | ||
332 | |||
333 | dialog.destroy() | ||
334 | |||
335 | if conf: | ||
336 | self.manager.do_build (conf) | ||
337 | |||
338 | def build_button_clicked_cb (self, button): | ||
339 | dialog = BuildSetupDialog () | ||
340 | |||
341 | # For some unknown reason Dialog.run causes nice little deadlocks ... :-( | ||
342 | dialog.connect ("response", self.build_dialog_box_response_cb) | ||
343 | dialog.show() | ||
344 | |||
345 | def __init__ (self): | ||
346 | gtk.Window.__init__ (self) | ||
347 | |||
348 | # Pull in *just* the main vbox from the Glade XML data and then pack | ||
349 | # that inside the window | ||
350 | gxml = gtk.glade.XML (os.path.dirname(__file__) + "/crumbs/puccho.glade", | ||
351 | root = "main_window_vbox") | ||
352 | vbox = gxml.get_widget ("main_window_vbox") | ||
353 | self.add (vbox) | ||
354 | |||
355 | # Create the tree views for the build manager view and the progress view | ||
356 | self.build_manager_view = BuildManagerTreeView() | ||
357 | self.running_build_view = RunningBuildTreeView() | ||
358 | |||
359 | # Grab the scrolled windows that we put the tree views into | ||
360 | self.results_scrolledwindow = gxml.get_widget ("results_scrolledwindow") | ||
361 | self.progress_scrolledwindow = gxml.get_widget ("progress_scrolledwindow") | ||
362 | |||
363 | # Put the tree views inside ... | ||
364 | self.results_scrolledwindow.add (self.build_manager_view) | ||
365 | self.progress_scrolledwindow.add (self.running_build_view) | ||
366 | |||
367 | # Hook up the build button... | ||
368 | self.build_button = gxml.get_widget ("main_toolbutton_build") | ||
369 | self.build_button.connect ("clicked", self.build_button_clicked_cb) | ||
370 | |||
371 | # I'm not very happy about the current ownership of the RunningBuild. I have | ||
372 | # my suspicions that this object should be held by the BuildManager since we | ||
373 | # care about the signals in the manager | ||
374 | |||
375 | def running_build_succeeded_cb (running_build, manager): | ||
376 | # Notify the manager that a build has succeeded. This is necessary as part | ||
377 | # of the 'hack' that we use for making the row in the model / view | ||
378 | # representing the ongoing build change into a row representing the | ||
379 | # completed build. Since we know only one build can be running a time then | ||
380 | # we can handle this. | ||
381 | |||
382 | # FIXME: Refactor all this so that the RunningBuild is owned by the | ||
383 | # BuildManager. It can then hook onto the signals directly and drive | ||
384 | # interesting things it cares about. | ||
385 | manager.notify_build_succeeded () | ||
386 | print("build succeeded") | ||
387 | |||
388 | def running_build_failed_cb (running_build, manager): | ||
389 | # As above | ||
390 | print("build failed") | ||
391 | manager.notify_build_failed () | ||
392 | |||
393 | def main (server, eventHandler): | ||
394 | # Initialise threading... | ||
395 | gobject.threads_init() | ||
396 | gtk.gdk.threads_init() | ||
397 | |||
398 | main_window = MainWindow () | ||
399 | main_window.show_all () | ||
400 | |||
401 | # Set up the build manager stuff in general | ||
402 | builds_dir = os.path.join (os.getcwd(), "results") | ||
403 | manager = BuildManager (server, builds_dir) | ||
404 | main_window.build_manager_view.set_model (manager.model) | ||
405 | |||
406 | # Do the running build setup | ||
407 | running_build = RunningBuild () | ||
408 | main_window.running_build_view.set_model (running_build.model) | ||
409 | running_build.connect ("build-succeeded", running_build_succeeded_cb, | ||
410 | manager) | ||
411 | running_build.connect ("build-failed", running_build_failed_cb, manager) | ||
412 | |||
413 | # We need to save the manager into the MainWindow so that the toolbar | ||
414 | # button can use it. | ||
415 | # FIXME: Refactor ? | ||
416 | main_window.manager = manager | ||
417 | |||
418 | # Use a timeout function for probing the event queue to find out if we | ||
419 | # have a message waiting for us. | ||
420 | gobject.timeout_add (200, | ||
421 | event_handle_timeout, | ||
422 | eventHandler, | ||
423 | running_build) | ||
424 | |||
425 | gtk.main() | ||