'Incrementally update host state from a RequestSpec object.'

def consume_from_request(self, spec_obj):

    @utils.synchronized(self._lock_name)
    @set_update_time_on_success
    def _locked(self, spec_obj):
        self._locked_consume_from_request(spec_obj)
    return _locked(self, spec_obj)
