Replace tabs with spaces. Remove trailing white spaces.
authorRazvan Deaconescu <razvan.deaconescu@cs.pub.ro>
Tue, 16 Aug 2011 15:42:27 +0000 (18:42 +0300)
committerRazvan Deaconescu <razvan.deaconescu@cs.pub.ro>
Tue, 16 Aug 2011 17:53:37 +0000 (20:53 +0300)
ppf/db/DatabaseAccess.py
ppf/db/DatabaseCommander.py
ppf/db/DatabaseWriter.py

index fd117d8..527a02e 100644 (file)
@@ -18,16 +18,16 @@ class DatabaseAccess:
                         arguments
     """
     operators={'eq':'=', 'neq':'<>', 'gt':'>', 'gte':'>=', 'lt':'<', 'lte':'<=', 'lk':'LIKE'}
-    
+
     def __init__ (self, dbname):
         self.dbname = dbname
 
     def connect(self):
-       if not os.path.isfile(self.dbname):
-               return False
+        if not os.path.isfile(self.dbname):
+            return False
         self.conn = sqlite3.connect(self.dbname)
         self.cursor = self.conn.cursor()
-       return True
+        return True
 
     def disconnect(self):
         self.cursor.close()
@@ -218,19 +218,19 @@ class DatabaseAccess:
             if cs_id == -1:
                 self.cursor.execute("select * from status_messages")
             else:
-               values = (cs_id, )
-               query = "select * from status_messages where cs_id=? and "
-               
-               if restrictArray:
-                   for (key, value, op) in restrictArray:
-                       query += "%s %s ? and " % (key, self.operators[op]) 
-                       values += (value, )
-               
-               query = query.strip('and ')
-               print query, values
-               self.cursor.execute(query, values)
-               
-           if show == True:
+                values = (cs_id, )
+                query = "select * from status_messages where cs_id=? and "
+
+                if restrictArray:
+                    for (key, value, op) in restrictArray:
+                        query += "%s %s ? and " % (key, self.operators[op]) 
+                        values += (value, )
+
+                query = query.strip('and ')
+                print query, values
+                self.cursor.execute(query, values)
+
+            if show == True:
                 for row in self.cursor:
                     print row
             else:
@@ -259,24 +259,24 @@ class DatabaseAccess:
 
     def insert_verbose_messages(self, cs_id, timestamp, direction, peer_ip, peer_port, message_type, _index, begin, length, listen_port):
         self.insert_verbose_messages_row([cs_id, timestamp, direction, peer_ip, peer_port, message_type, _index, begin, length, listen_port])
-    
+
     def select_verbose_messages(self, show = True, cs_id = -1, restrictArray=None):
         try:
             if cs_id == -1:
                 self.cursor.execute("select * from verbose_messages")
             else:
-               values = (cs_id, )
-               query = "select * from verbose_messages where cs_id=? and "
-               if restrictArray:
-                   for (key, value, op) in restrictArray:
-                       query += "%s %s ? and " % (key, self.operators[op]) 
-                       values += (value, )
-               
-               query = query.strip('and ')
-               #print query, values
-               self.cursor.execute(query, values)
-               
-           if show == True:
+                values = (cs_id, )
+                query = "select * from verbose_messages where cs_id=? and "
+                if restrictArray:
+                    for (key, value, op) in restrictArray:
+                        query += "%s %s ? and " % (key, self.operators[op]) 
+                        values += (value, )
+
+                query = query.strip('and ')
+                #print query, values
+                self.cursor.execute(query, values)
+
+            if show == True:
                 for row in self.cursor:
                     print row
             else:
index f5678ba..c1dbaf6 100644 (file)
@@ -113,7 +113,7 @@ def read_swarms(dbc, sep = None):
         line = sys.stdin.readline().strip()
         if line:
             message_array = line.split(sep)
-            
+
             swarm_name = message_array[0].strip()
             filesize = int(message_array[1].strip())
             purpose = message_array[2].strip()
@@ -131,7 +131,7 @@ def read_client_sessions(dbc, sep = None):
         line = sys.stdin.readline().strip()
         if line:
             message_array = line.split(sep)
-            
+
             swarm_id = int(message_array[0].strip())
             client_name = message_array[1].strip()
             system_os = message_array[2].strip()
index 8d6a272..1be3737 100644 (file)
@@ -79,7 +79,7 @@ def read_status_messages(dbw, sep = None):
         line = sys.stdin.readline().strip()
         if line:
             message_array = line.split(sep)
-            
+
             cs_id = int(message_array[0].strip())
             timestamp = message_array[1].strip().split(' ')
             date = timestamp[0]