Ticket #1211: 0001-let-the-logger-do-the-formatting.patch

File 0001-let-the-logger-do-the-formatting.patch, 14.2 KB (added by sascha_silbe, 15 years ago)

let the logger do the formatting

  • src/carquinyol/datastore.py 

    From e555903564cffb1a206606d9e7c8848e3bc99efa Mon Sep 17 00:00:00 2001
From: Sascha Silbe <sascha@silbe.org>
Date: Wed, 19 Aug 2009 16:00:22 +0200
Subject: [PATCH] let the logger do the formatting

---
 src/carquinyol/datastore.py  |   41 +++++++++++++++++++----------------------
 src/carquinyol/filestore.py  |   20 ++++++++++----------
 src/carquinyol/indexstore.py |    3 +--
 src/carquinyol/migration.py  |   10 ++++------
 src/carquinyol/optimizer.py  |   14 +++++++-------
 5 files changed, 41 insertions(+), 47 deletions(-)

diff --git a/src/carquinyol/datastore.py b/src/carquinyol/datastore.py
index 41b16b5..dc2e167 100644
    a b class DataStore(dbus.service.Object): 
    7171        try:
    7272            self._index_store.open_index()
    7373        except Exception:
    74             logging.error('Failed to open index, will rebuild\n%s' \
    75                     % traceback.format_exc())
     74            logging.exception('Failed to open index, will rebuild')
    7675            layout_manager.index_updated = False
    7776            self._index_store.remove_index()
    7877            self._index_store.open_index()
    … … class DataStore(dbus.service.Object): 
    8786
    8887    def _rebuild_index(self):
    8988        uids = layoutmanager.get_instance().find_all()
    90         logging.debug('Going to update the index with uids %r' % uids)
     89        logging.debug('Going to update the index with uids %r', uids)
    9190        gobject.idle_add(lambda: self.__rebuild_index_cb(uids),
    9291                            priority=gobject.PRIORITY_LOW)
    9392
    … … class DataStore(dbus.service.Object): 
    9594        if uids:
    9695            uid = uids.pop()
    9796
    98             logging.debug('Updating entry %r in index. %d to go.' % \
    99                           (uid, len(uids)))
     97            logging.debug('Updating entry %r in index. %d to go.', uid,
     98                len(uids))
    10099
    101100            if not self._index_store.contains(uid):
    102101                try:
    103102                    props = self._metadata_store.retrieve(uid)
    104103                    self._index_store.store(uid, props)
    105104                except Exception:
    106                     logging.error('Error processing %r\n%s.' \
    107                             % (uid, traceback.format_exc()))
     105                    logging.exception('Error processing %r', uid)
    108106
    109107        if not uids:
    110108            logging.debug('Finished updating index.')
    … … class DataStore(dbus.service.Object): 
    114112            return True
    115113
    116114    def _create_completion_cb(self, async_cb, async_err_cb, uid, exc=None):
    117         logger.debug("_create_completion_cb(%r, %r, %r, %r)" % \
    118             (async_cb, async_err_cb, uid, exc))
     115        logger.debug('_create_completion_cb(%r, %r, %r, %r)', async_cb,
     116            async_err_cb, uid, exc)
    119117        if exc is not None:
    120118            async_err_cb(exc)
    121119            return
    122120
    123121        self.Created(uid)
    124122        self._optimizer.optimize(uid)
    125         logger.debug("created %s" % uid)
     123        logger.debug('created %s', uid)
    126124        async_cb(uid)
    127125
    128126    @dbus.service.method(DS_DBUS_INTERFACE,
    … … class DataStore(dbus.service.Object): 
    133131    def create(self, props, file_path, transfer_ownership,
    134132               async_cb, async_err_cb):
    135133        uid = str(uuid.uuid4())
    136         logging.debug('datastore.create %r' % uid)
     134        logging.debug('datastore.create %r', uid)
    137135
    138136        if not props.get('timestamp', ''):
    139137            props['timestamp'] = int(time.time())
    … … class DataStore(dbus.service.Object): 
    151149        pass
    152150
    153151    def _update_completion_cb(self, async_cb, async_err_cb, uid, exc=None):
    154         logger.debug("_update_completion_cb() called with %r / %r, exc %r" % \
    155             (async_cb, async_err_cb, exc))
     152        logger.debug('_update_completion_cb() called with %r / %r, exc %r',
     153            async_cb, async_err_cb, exc)
    156154        if exc is not None:
    157155            async_err_cb(exc)
    158156            return
    159157
    160158        self.Updated(uid)
    161159        self._optimizer.optimize(uid)
    162         logger.debug("updated %s" % uid)
     160        logger.debug('updated %s', uid)
    163161        async_cb()
    164162
    165163    @dbus.service.method(DS_DBUS_INTERFACE,
    … … class DataStore(dbus.service.Object): 
    169167             byte_arrays=True)
    170168    def update(self, uid, props, file_path, transfer_ownership,
    171169               async_cb, async_err_cb):
    172         logging.debug('datastore.update %r' % uid)
     170        logging.debug('datastore.update %r', uid)
    173171
    174172        if not props.get('timestamp', ''):
    175173            props['timestamp'] = int(time.time())
    … … class DataStore(dbus.service.Object): 
    194192             in_signature='a{sv}as',
    195193             out_signature='aa{sv}u')
    196194    def find(self, query, properties):
    197         logging.debug('datastore.find %r' % query)
     195        logging.debug('datastore.find %r', query)
    198196        t = time.time()
    199197
    200198        if layoutmanager.get_instance().index_updated:
    201199            try:
    202200                uids, count = self._index_store.find(query)
    203201            except Exception:
    204                 logging.error('Failed to query index, will rebuild\n%s' \
    205                         % traceback.format_exc())
     202                logging.exception('Failed to query index, will rebuild')
    206203                layoutmanager.get_instance().index_updated = False
    207204                self._index_store.close_index()
    208205                self._index_store.remove_index()
    … … class DataStore(dbus.service.Object): 
    231228            metadata = self._metadata_store.retrieve(uid, properties)
    232229            entries.append(metadata)
    233230
    234         logger.debug('find(): %r' % (time.time() - t))
     231        logger.debug('find(): %r', time.time() - t)
    235232
    236233        return entries, count
    237234
    … … class DataStore(dbus.service.Object): 
    255252             out_signature='s',
    256253             sender_keyword='sender')
    257254    def get_filename(self, uid, sender=None):
    258         logging.debug('datastore.get_filename %r' % uid)
     255        logging.debug('datastore.get_filename %r', uid)
    259256        user_id = dbus.Bus().get_unix_user(sender)
    260257        extension = self._get_extension(uid)
    261258        return self._file_store.retrieve(uid, user_id, extension)
    … … class DataStore(dbus.service.Object): 
    270267                         in_signature='s',
    271268                         out_signature='a{sv}')
    272269    def get_properties(self, uid):
    273         logging.debug('datastore.get_properties %r' % uid)
     270        logging.debug('datastore.get_properties %r', uid)
    274271        metadata = self._metadata_store.retrieve(uid)
    275272        return metadata
    276273
    … … class DataStore(dbus.service.Object): 
    302299        os.removedirs(entry_path)
    303300
    304301        self.Deleted(uid)
    305         logger.debug("deleted %s" % uid)
     302        logger.debug('deleted %s', uid)
    306303
    307304    @dbus.service.signal(DS_DBUS_INTERFACE, signature="s")
    308305    def Deleted(self, uid):

  • src/carquinyol/filestore.py 

    diff --git a/src/carquinyol/filestore.py b/src/carquinyol/filestore.py
index 0e018bd..71d6344 100644
    a b class FileStore(object): 
    4545                raise ValueError('No file at %r' % file_path)
    4646            if transfer_ownership:
    4747                try:
    48                     logging.debug('FileStore moving from %r to %r' % \
    49                                   (file_path, destination_path))
     48                    logging.debug('FileStore moving from %r to %r', file_path,
     49                        destination_path)
    5050                    os.rename(file_path, destination_path)
    5151                    completion_cb()
    5252                except OSError, e:
    … … class FileStore(object): 
    7272        """Start copying a file asynchronously.
    7373
    7474        """
    75         logging.debug('FileStore copying from %r to %r' % \
    76                       (file_path, destination_path))
     75        logging.debug('FileStore copying from %r to %r', file_path,
     76            destination_path)
    7777        async_copy = AsyncCopy(file_path, destination_path, completion_cb)
    7878        async_copy.start()
    7979
    … … class FileStore(object): 
    8585        """
    8686        file_path = layoutmanager.get_instance().get_data_path(uid)
    8787        if not os.path.exists(file_path):
    88             logging.debug('Entry %r doesnt have any file' % uid)
     88            logging.debug('Entry %r doesnt have any file', uid)
    8989            return ''
    9090
    9191        use_instance_dir = os.path.exists('/etc/olpc-security') and \
    … … class FileStore(object): 
    158158        existing_file = layoutmanager.get_instance().get_data_path(existing_uid)
    159159        new_file = layoutmanager.get_instance().get_data_path(new_uid)
    160160
    161         logging.debug('removing %r' % new_file)
     161        logging.debug('removing %r', new_file)
    162162        os.remove(new_file)
    163163
    164         logging.debug('hard linking %r -> %r' % (new_file, existing_file))
     164        logging.debug('hard linking %r -> %r', new_file, existing_file)
    165165        os.link(existing_file, new_file)
    166166
    167167
    … … class AsyncCopy(object): 
    193193            # error writing data to file?
    194194            if count < len(data):
    195195                logging.error('AC: Error writing %s -> %s: wrote less than '
    196                         'expected' % (self.src, self.dest))
     196                        'expected', self.src, self.dest)
    197197                self._cleanup()
    198198                self.completion(RuntimeError(
    199199                        'Error writing data to destination file'))
    … … class AsyncCopy(object): 
    207207                self.completion(None)
    208208                return False
    209209        except Exception, err:
    210             logging.error("AC: Error copying %s -> %s: %r" % \
    211                     (self.src, self.dest, err))
     210            logging.error('AC: Error copying %s -> %s: %r', self.src, self.
     211                dest, err)
    212212            self._cleanup()
    213213            self.completion(err)
    214214            return False

  • src/carquinyol/indexstore.py 

    diff --git a/src/carquinyol/indexstore.py b/src/carquinyol/indexstore.py
index 06a41e0..6a70aee 100644
    a b class IndexStore(object): 
    304304
    305305    def _flush(self, force=False):
    306306        """Called after any database mutation"""
    307         logging.debug('IndexStore.flush: %r %r' %
    308             (force, self._pending_writes))
     307        logging.debug('IndexStore.flush: %r %r', force, self._pending_writes)
    309308
    310309        if self._flush_timeout is not None:
    311310            gobject.source_remove(self._flush_timeout)

  • src/carquinyol/migration.py 

    diff --git a/src/carquinyol/migration.py b/src/carquinyol/migration.py
index ed82558..95ee391 100644
    a b def migrate_from_0(): 
    4343        if ext != '.metadata':
    4444            continue
    4545
    46         logging.debug('Migrating entry %r' % uid)
     46        logging.debug('Migrating entry %r', uid)
    4747        try:
    4848            _migrate_metadata(root_path, old_root_path, uid)
    4949            _migrate_file(root_path, old_root_path, uid)
    5050            _migrate_preview(root_path, old_root_path, uid)
    5151        except Exception:
    52             logging.error('Error while migrating entry %r: %s\n' % \
    53                           (uid, traceback.format_exc()))
     52            logging.exception('Error while migrating entry %r', uid)
    5453
    5554    # Just be paranoid, it's cheap.
    5655    if old_root_path.endswith('datastore/store'):
    … … def _migrate_metadata(root_path, old_root_path, uid): 
    8685            finally:
    8786                f.close()
    8887        except Exception:
    89             logging.error(
    90                     'Error while migrating property %s of entry %s: %s\n' % \
    91                     (key, uid, traceback.format_exc()))
     88            logging.exception(
     89                    'Error while migrating property %s of entry %s', key, uid)
    9290
    9391
    9492def _migrate_file(root_path, old_root_path, uid):

  • src/carquinyol/optimizer.py 

    diff --git a/src/carquinyol/optimizer.py b/src/carquinyol/optimizer.py
index 6cb1374..2b6ce29 100644
    a b class Optimizer(object): 
    4242
    4343        queue_path = layoutmanager.get_instance().get_queue_path()
    4444        open(os.path.join(queue_path, uid), 'w').close()
    45         logging.debug('optimize %r' % os.path.join(queue_path, uid))
     45        logging.debug('optimize %r', os.path.join(queue_path, uid))
    4646
    4747        if self._enqueue_checksum_id is None:
    4848            self._enqueue_checksum_id = \
    … … class Optimizer(object): 
    6262        checksum_entry_path = os.path.join(checksum_path, uid)
    6363
    6464        if os.path.exists(checksum_entry_path):
    65             logging.debug('remove %r' % checksum_entry_path)
     65            logging.debug('remove %r', checksum_entry_path)
    6666            os.remove(checksum_entry_path)
    6767
    6868        if os.path.exists(checksum_path):
    6969            try:
    7070                os.rmdir(checksum_path)
    71                 logging.debug('removed %r' % checksum_path)
     71                logging.debug('removed %r', checksum_path)
    7272            except OSError, e:
    7373                if e.errno != errno.ENOTEMPTY:
    7474                    raise
    … … class Optimizer(object): 
    9696        """
    9797        checksums_dir = layoutmanager.get_instance().get_checksums_dir()
    9898        checksum_path = os.path.join(checksums_dir, checksum)
    99         logging.debug('create dir %r' % checksum_path)
     99        logging.debug('create dir %r', checksum_path)
    100100        os.mkdir(checksum_path)
    101101
    102102    def _add_checksum_entry(self, uid, checksum):
    … … class Optimizer(object): 
    106106        checksums_dir = layoutmanager.get_instance().get_checksums_dir()
    107107        checksum_path = os.path.join(checksums_dir, checksum)
    108108
    109         logging.debug('touch %r' % os.path.join(checksum_path, uid))
     109        logging.debug('touch %r', os.path.join(checksum_path, uid))
    110110        open(os.path.join(checksum_path, uid), 'w').close()
    111111
    112112    def _already_linked(self, uid, checksum):
    … … class Optimizer(object): 
    128128        queue = os.listdir(queue_path)
    129129        if queue:
    130130            uid = queue[0]
    131             logging.debug('_process_entry_cb processing %r' % uid)
     131            logging.debug('_process_entry_cb processing %r', uid)
    132132
    133133            file_in_entry_path = self._file_store.get_file_path(uid)
    134134            if not os.path.exists(file_in_entry_path):
    135                 logging.info('non-existent entry in queue: %r' % uid)
     135                logging.info('non-existent entry in queue: %r', uid)
    136136            else:
    137137                checksum = self._calculate_md5sum(file_in_entry_path)
    138138                self._metadata_store.set_property(uid, 'checksum', checksum)