← Back to branch summary

~ubuntu-branches/ubuntu/maverick/landscape-client/maverick

« back to all changes in this revision

Viewing changes to landscape/broker/broker.py

  • Committer: Bazaar Package Importer
  • Author(s): Free Ekanayaka
  • Date: 2010-04-07 16:27:45 UTC
  • mfrom: (1.1.14 upstream) (24.1.1 karmic-proposed)
  • Revision ID: james.westby@ubuntu.com-20100407162745-oeyoppvl0qyvii55
Tags: 1.5.0-0ubuntu0.10.04.0
https://launchpad.net/bugs/557244
https://launchpad.net/bugs/542215
https://launchpad.net/bugs/554007
https://launchpad.net/bugs/546531
https://launchpad.net/bugs/351927
https://launchpad.net/bugs/503384
https://launchpad.net/bugs/522688
* New upstream version (LP: #557244)
  - Fix package-changer running before smart-update has completed (LP: #542215)
  - Report the version of Eucalyptus used to generate topology data (LP: #554007)
  - Enable the Eucalyptus plugin by default, if supported (LP: #546531)
  - Use a whitelist of allowed filesystem types to instead of a blacklist (LP: #351927)
  - Report the update-manager logs to the server (LP: #503384)
  - Turn off Curl's DNS caching for requests. (LP: #522688)

Show diffs side-by-side

added added

removed removed

Lines of Context:
landscape/broker/broker.py
70
70
            # convert them back to Nones.
71
71
            self.server_uuid_changed(old_uuid or "", new_uuid or "")
72
72
        reactor.call_on("server-uuid-changed", server_uuid_changed)
 
73
        reactor.call_on("package-data-changed", self.package_data_changed)
73
74
        reactor.call_on("resynchronize-clients", self.resynchronize)
74
75
        self.broker_started()
75
76
 
149
150
        return self.exchange.send(message, urgent=urgent)
150
151
 
151
152
    @method(IFACE_NAME)
 
153
    def fire_event(self, event_type):
 
154
        """Fire an event in the broker reactor."""
 
155
        self.reactor.fire(event_type)
 
156
 
 
157
    @method(IFACE_NAME)
152
158
    def is_message_pending(self, message_id):
153
159
        return self.message_store.is_pending(message_id)
154
160
 
193
199
    def server_uuid_changed(self, old_uuid, new_uuid):
194
200
        pass
195
201
 
 
202
    @signal(IFACE_NAME)
 
203
    def package_data_changed(self):
 
204
        """Fire a package-data-changed event in the reactor of each client."""
 
205
 
196
206
    @method(IFACE_NAME)
197
207
    def register_client_accepted_message_type(self, type):
198
208
        self.exchange.register_client_accepted_message_type(type)