Mass conversion to better log.debug use
authorJack Miller <jack@codezen.org>
Fri, 5 Jun 2015 00:50:35 +0000 (19:50 -0500)
committerJack Miller <jack@codezen.org>
Fri, 5 Jun 2015 01:09:30 +0000 (20:09 -0500)
Pass the format arguments to log.debug so we avoid the CPU hit
formatting strings we won't use.

canto_next/canto_backend.py
canto_next/config.py
canto_next/feed.py
canto_next/fetch.py
canto_next/protocol.py
canto_next/rwlock.py
canto_next/storage.py
plugins/sync-inoreader.py
plugins/sync-rsync.py
plugins/sync.py

index b58bed1..b0f0ddc 100644 (file)
@@ -164,7 +164,7 @@ class CantoBackend(PluginHandler, CantoServer):
 
         config.parse(False, change)
 
-        log.debug("config.errors = %s" % config.errors)
+        log.debug("config.errors = %s", config.errors)
 
         if config.errors:
             self.write(originating_socket, "ERRORS", config.errors)
@@ -356,11 +356,11 @@ class CantoBackend(PluginHandler, CantoServer):
 
             if filt == None:
                 if key in self.socket_transforms[socket]:
-                    log.debug("Unsetting socket transform %s:%s" % (socket, key))
+                    log.debug("Unsetting socket transform %s:%s", socket, key)
                     del self.socket_transforms[socket][key]
                 continue
 
-            log.debug("Setting socket transform: %s:%s = %s" % (socket, key, filt))
+            log.debug("Setting socket transform: %s:%s = %s", socket, key, filt)
             self.socket_transforms[socket][key] = filt
 
     # AUTOATTR [ attrs ... ] -> Follow up each items request with
@@ -519,7 +519,7 @@ class CantoBackend(PluginHandler, CantoServer):
     @write_lock(watch_lock)
     def cmd_watchtags(self, socket, args):
         for tag in args:
-            log.debug("socket %s watching tag %s" % (socket, tag))
+            log.debug("socket %s watching tag %s", socket, tag)
             if tag in self.watches["tags"]:
                 self.watches["tags"][tag].append(socket)
             else:
index 147e1d8..9427611 100644 (file)
@@ -147,7 +147,7 @@ class CantoConfig():
         c.close()
 
         log.info("Read %s" % self.filename)
-        log.debug("Parsed into: %s" % self.json)
+        log.debug("Parsed into: %s", self.json)
 
     def error(self, ident, val, error):
         if ident in self.errors:
@@ -380,8 +380,8 @@ class CantoConfig():
                     type(current[key]) == list:
 
                 log.debug("Deleting items from list lists:")
-                log.debug("\\%s" % deletions[key])
-                log.debug("\\%s" % current[key])
+                log.debug("\\%s", deletions[key])
+                log.debug("\\%s", current[key])
 
                 for item in deletions[key]:
                     if item in current[key]:
@@ -418,8 +418,8 @@ class CantoConfig():
                     current[key] = change[key]
                 else:
                     log.debug("Merging lists:")
-                    log.debug("\\%s" % change[key])
-                    log.debug("\\%s" % current[key])
+                    log.debug("\\%s", change[key])
+                    log.debug("\\%s", current[key])
 
                     # Any items not in change are prepended.  This allows the
                     # simple n-item append to work as expected, it allows the
index c1189bd..8380133 100644 (file)
@@ -236,11 +236,11 @@ class CantoFeed(PluginHandler):
 
                         for user_tag in d_item[a]:
                             if user_tag not in attributes[item][a]:
-                                log.debug("set removing tag: %s - %s" % (user_tag, item))
+                                log.debug("set removing tag: %s - %s", user_tag, item)
                                 alltags.remove_tag(item, user_tag)
                         for user_tag in attributes[item][a]:
                             if user_tag not in d_item[a]:
-                                log.debug("set adding tag: %s - %s" % (user_tag, item))
+                                log.debug("set adding tag: %s - %s", user_tag, item)
                                 alltags.add_tag(item, user_tag)
 
                     d_item[a] = attributes[item][a]
@@ -273,11 +273,11 @@ class CantoFeed(PluginHandler):
 
         if self.URL not in self.shelf:
             # Stub empty feed
-            log.debug("Previous content not found for %s." % self.URL)
+            log.debug("Previous content not found for %s.", self.URL)
             old_contents = {"entries" : []}
         else:
             old_contents = self.shelf[self.URL]
-            log.debug("Fetched previous content for %s." % self.URL)
+            log.debug("Fetched previous content for %s.", self.URL)
 
         # BEWARE: At this point, update_contents could either be
         # fresh from feedparser or fresh from disk, so it's possible that the
@@ -331,7 +331,7 @@ class CantoFeed(PluginHandler):
                             continue
                         if key == "canto-tags":
                             for user_tag in olditem[key]:
-                                log.debug("index adding user tag: %s - %s" % (user_tag,item["id"]))
+                                log.debug("index adding user tag: %s - %s", (user_tag,item["id"]))
                                 tags_to_add.append((cacheitem["id"], user_tag))
                             item[key] = olditem[key]
                         elif key.startswith("canto"):
@@ -369,10 +369,10 @@ class CantoFeed(PluginHandler):
                 if keep_all:
                     pass
                 elif (ref_time - item_time) < self.keep_time:
-                    log.debug("Item not over keep_time (%d): %s" %
+                    log.debug("Item not over keep_time (%d): %s"
                             (self.keep_time, olditem["id"]))
                 elif self.keep_unread and "read" not in item_state:
-                    log.debug("Keeping unread item: %s\n" % olditem["id"])
+                    log.debug("Keeping unread item: %s\n", olditem["id"])
                 else:
                     log.debug("Discarding: %s", olditem["id"])
                     continue
index a54d419..67e9906 100644 (file)
@@ -120,7 +120,7 @@ class CantoFetchThread(PluginHandler, Thread):
 
         update_contents = json.loads(json.dumps(update_contents))
 
-        log.debug("Parsed %s" % self.feed.URL)
+        log.debug("Parsed %s", self.feed.URL)
 
         # Allow DaemonFetchThreadPlugins to do any sort of fetch stuff
         # before the thread is marked as complete.
@@ -169,7 +169,7 @@ class CantoFetch():
 
             thread = CantoFetchThread(feed, fromdisk)
             thread.start()
-            log.debug("Started thread for feed %s" % feed.URL)
+            log.debug("Started thread for feed %s", feed.URL)
             self.threads.append((thread, feed.URL))
 
     def reap(self, force=False):
index 44d30d8..a63fa6e 100644 (file)
@@ -212,7 +212,7 @@ class CantoSocket:
         except:
             log.error("Failed to parse message: %s" % message)
         else:
-            log.debug("\n\nRead:\n%s" % json.dumps((cmd, args), indent=4, sort_keys=True))
+            log.debug("\n\nRead:\n%s", json.dumps((cmd, args), indent=4, sort_keys=True))
             return (cmd, args)
 
     # Reads from a connection, returns:
@@ -245,7 +245,7 @@ class CantoSocket:
         except select.error as e:
             if e.args[0] == errno.EINTR:
                 return
-            log.debug("Raising error: %s" % e[1])
+            log.debug("Raising error: %s", e[1])
             raise
 
         if timeout and not p:
@@ -253,7 +253,7 @@ class CantoSocket:
 
         e = p[0][1]
 
-        log.debug("E: %d" % e)
+        log.debug("E: %d", e)
         if e & select.POLLERR:
             log.debug("Read ERR")
             return select.POLLHUP
@@ -296,7 +296,7 @@ class CantoSocket:
         return r
 
     def _do_write(self, conn, cmd, args):
-        log.debug("\n\nWrite:\n%s\n" % json.dumps((cmd, args), indent=4, sort_keys=True))
+        log.debug("\n\nWrite:\n%s\n", json.dumps((cmd, args), indent=4, sort_keys=True))
 
         message = json.dumps((cmd, args)) + PROTO_TERMINATOR
 
@@ -354,7 +354,7 @@ class CantoSocket:
                     return select.POLLHUP
 
                 tosend = tosend[sent:]
-                log.debug("Sent %d bytes." % sent)
+                log.debug("Sent %d bytes.", sent)
 
     def disconnected(self, conn):
         pass
index 2773522..5621147 100644 (file)
@@ -95,8 +95,8 @@ class RWLock(object):
         while self.readers > 0:
             if current_thread().ident in [ x[0] for x in self.reader_stacks ]:
                 if not warned:
-                    log.debug("WARN: %s holds read, trying to get write on %s" %
-                            (current_thread().ident, self.name))
+                    log.debug("WARN: %s holds read, trying to get write on %s"
+                            current_thread().ident, self.name)
                     warned = True
 
                 # Break the deadlock if we're the last reader
index 09ea839..84113a7 100644 (file)
@@ -83,7 +83,7 @@ class CantoShelf():
 
         self.index = list(self.shelf.keys())
 
-        log.debug("Shelf opened: %s" % self.shelf)
+        log.debug("Shelf opened: %s", self.shelf)
 
     def __setitem__(self, name, value):
         self.cache[name] = value
index d3bb82c..2a6df28 100644 (file)
@@ -83,7 +83,7 @@ def ino_get_auth():
 
 authorization = ino_get_auth()
 
-log.debug("authorization: %s" % authorization)
+log.debug("authorization: %s", authorization)
 
 # XXX : Needs to handle errors / reauth
 
@@ -94,7 +94,7 @@ def inoreader_req(path, query = {}):
     r = requests.get(BASE_URL + path, params=query, headers=headers)
 
     if r.status_code != 200:
-        log.debug("STATUS %s" % r.status_code)
+        log.debug("STATUS %s", r.status_code)
         log.debug(r.headers)
         log.debug(r.text)
 
@@ -219,7 +219,7 @@ class CantoFeedInoReader(DaemonFeedPlugin):
             #    r = inoreader_req(content_path, query).json()
             #    ino_entries.extend(r["items"])
         except Exception as e:
-            log.debug("EXCEPT: %s" % traceback.format_exc(e))
+            log.debug("EXCEPT: %s", traceback.format_exc(e))
 
         for ino_entry in ino_entries:
             for canto_entry in newcontent["entries"]:
@@ -251,7 +251,7 @@ class CantoFeedInoReader(DaemonFeedPlugin):
 
                 cat = category.split("/", 3)
                 if len(cat) < 4:
-                    log.debug("Weird category? %s" % cat)
+                    log.debug("Weird category? %s", cat)
                     continue
 
                 if cat[2] == "state":
@@ -341,7 +341,7 @@ def on_daemon_serving():
             if c_feed["url"] == url:
                 break
         else:
-            log.debug("New feed: %s" % url)
+            log.debug("New feed: %s", url)
             call_hook("daemon_set_configs", [ None, { "feeds" : [ { "name" : name, "url" : url } ] } ])
 
     for c_feed in config.json["feeds"]:
@@ -351,7 +351,7 @@ def on_daemon_serving():
             if sub["url"] == url:
                 break
         else:
-            log.debug("Old feed: %s" % url)
+            log.debug("Old feed: %s", url)
             call_hook("daemon_del_configs", [ None, { "feeds" : [ c_feed ] } ] )
 
 on_hook("daemon_serving", on_daemon_serving)
index 842acd1..af4a1f1 100644 (file)
@@ -59,14 +59,14 @@ def rsync_to(target, fname):
         log.warn("Unknown file to sync: %s" % target)
         return
 
-    log.debug("Syncto cmd: %s" % (cmd,))
-
+    log.debug("Syncto cmd: %s", cmd)
+    
     try:
         out = subprocess.check_output(cmd)
     except Exception as e:
         log.warn("Command %s : %s" % (cmd, e))
     else:
-        log.debug("Syncto output: %s" % out)
+        log.debug("Syncto output: %s", out)
 
 def rsync_from(target, fname):
     if target in targets:
@@ -75,14 +75,14 @@ def rsync_from(target, fname):
         log.warn("Unknown file to sync: %s" % target)
         return
 
-    log.debug("Syncfrom cmd: %s" % (cmd,))
+    log.debug("Syncfrom cmd: %s", cmd)
 
     try:
         out = subprocess.check_output(cmd)
     except Exception as e:
         log.warn("Command %s : %s" % (cmd, e))
     else:
-        log.debug("Syncfrom output: %s" % out)
+        log.debug("Syncfrom output: %s", out)
 
 if ENABLED:
     on_hook("daemon_syncfrom", rsync_from)
index d7188d7..f5abfa5 100644 (file)
@@ -85,7 +85,7 @@ class CantoFileSync(DaemonBackendPlugin):
     # our current shelf.
 
     def time_diff(self, path):
-        log.debug("Checking if %s is older than our shelf." % path)
+        log.debug("Checking if %s is older than our shelf.", path)
 
         try:
             s = shelve.open(path, 'r')