diff options
| -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() | ||
