Merge branch 'develop'

headphones/db.py

@@ -28,8 +28,6 @@ import headphones
 
 from headphones import logger
 
-db_lock = threading.Lock()
-
 def dbFilename(filename="headphones.db"):
 
     return os.path.join(headphones.DATA_DIR, filename)
@@ -56,38 +54,36 @@ class DBConnection:
         self.connection.row_factory = sqlite3.Row
         
     def action(self, query, args=None):
-    
-        with db_lock:
 
-            if query == None:
-                return
-                
-            sqlResult = None
-            attempt = 0
+        if query == None:
+            return
             
-            while attempt < 5:
-                try:
-                    if args == None:
-                        #logger.debug(self.filename+": "+query)
-                        sqlResult = self.connection.execute(query)
-                    else:
-                        #logger.debug(self.filename+": "+query+" with args "+str(args))
-                        sqlResult = self.connection.execute(query, args)
-                    self.connection.commit()
-                    break
-                except sqlite3.OperationalError, e:
-                    if "unable to open database file" in e.message or "database is locked" in e.message:
-                        logger.warn('Database Error: %s' % e)
-                        attempt += 1
-                        time.sleep(1)
-                    else:
-                        logger.error('Database error: %s' % e)
-                        raise
-                except sqlite3.DatabaseError, e:
-                    logger.error('Fatal Error executing %s :: %s' % (query, e))
+        sqlResult = None
+        attempt = 0
+        
+        while attempt < 5:
+            try:
+                if args == None:
+                    #logger.debug(self.filename+": "+query)
+                    sqlResult = self.connection.execute(query)
+                else:
+                    #logger.debug(self.filename+": "+query+" with args "+str(args))
+                    sqlResult = self.connection.execute(query, args)
+                self.connection.commit()
+                break
+            except sqlite3.OperationalError, e:
+                if "unable to open database file" in e.message or "database is locked" in e.message:
+                    logger.warn('Database Error: %s' % e)
+                    attempt += 1
+                    time.sleep(1)
+                else:
+                    logger.error('Database error: %s' % e)
                     raise
-            
-            return sqlResult
+            except sqlite3.DatabaseError, e:
+                logger.error('Fatal Error executing %s :: %s' % (query, e))
+                raise
+        
+        return sqlResult
     
     def select(self, query, args=None):
     

headphones/searcher_rutracker.py

@@ -123,8 +123,8 @@ class Rutracker():
                 urls.append(url)
                 
             # Seeders
-             
-            for link in soup.find_all('td', attrs={'class' : 'row4 seedmed'}): 
+
+            for link in soup.find_all('b', attrs={'class' : 'seedmed'}):
                 seeder = link.get_text()
                 seeders.append(seeder)