Strip trailing whitespace

Author: kata198

nonblock/BackgroundRead.py

@@ -3,7 +3,7 @@
 
     read.py Contains pure-python functions for non-blocking reads in python
 
-	
+
 '''
 # vim: ts=4 sw=4 expandtab
 
@@ -27,7 +27,7 @@ def bgread(stream, blockSizeLimit=65535, pollTime=.03, closeStream=True):
                 If None, the stream will be read from until there is no more available data (not closed, but you've read all that's been flushed to straem). This is okay for smaller datasets, but this number effectively controls the amount of CPU time spent in I/O on this stream VS everything else in your application. The default of 65535 bytes is a fair amount of data.
 
             @param pollTime <float> - Default .03 (30ms) After all available data has been read from the stream, wait this many seconds before checking again for more data.
-                
+
                 A low number here means a high priority, i.e. more cycles will be devoted to checking and collecting the background data. Since this is a non-blocking read, this value is the "block", which will return execution context to the remainder of the application. The default of 100ms should be fine in most cases. If it's really idle data collection, you may want to try a value of 1 second.
 
             @param closeStream <bool> - Default True. If True, the "close" method on the stream object will be called when the other side has closed and all data has been read.
@@ -84,7 +84,7 @@ class BackgroundReadData(object):
             data - A calculated property, which is a bytes/str (depending on stream mode). It is the joining of all the read blocks, and contains all the data read to-date.
 
             isFinished - starts False, and becomes True after all data has been read from the stream. Will remain False if there is an exception raised during I/O
-            
+
             error - starts None, and is set to any exception that is raised during reading (which will also terminate the thread)
     '''
 
@@ -109,7 +109,7 @@ def data(self):
         '''
 
         return self.emptyStr.join(self.blocks)
-        
+
 
 
 

nonblock/BackgroundWrite.py

@@ -46,7 +46,7 @@ def bgwrite(fileObj, data, closeWhenFinished=False, chainAfter=None, ioPrio=4):
 
             @return - BackgroundWriteProcess - An object representing the state of this operation. @see BackgroundWriteProcess
     '''
-        
+
     thread = BackgroundWriteProcess(fileObj, data, closeWhenFinished, chainAfter, ioPrio)
     thread.start()
 
@@ -82,7 +82,7 @@ class BackgroundIOPriority(object):
 
     def __init__(self, chainPollTime, defaultChunkSize, bandwidthPct, numChunksRateSmoothing=5):
         '''
-            __init__ - Create a BackgroundIOPriority. 
+            __init__ - Create a BackgroundIOPriority.
 
             Some terms: throughput - Bandwidth out (Megs per second)
                         interactivity - CPU time available for other tasks (calculations, other I/O, etc)
@@ -102,16 +102,16 @@ def __init__(self, chainPollTime, defaultChunkSize, bandwidthPct, numChunksRateS
               max bandwidth, i.e. the max rate of the I/O device, but the amount of available bandwidth available to this application. For example,
               if this is given "100%", no throttling is performed. If this is given "80%", then it calculates the average time to write a single chunk,
               ( see #numChunksRateSmoothing for how many chunks are used in evaluating this average ), and sleeps for then 20% of that time at the end
-              of every chunk. 
+              of every chunk.
 
             @param numChunksRateSmoothing - integer >= 1 , Default 5. This is the number of chunks which are used in calculating the current throughput rate.
               See #bandwidthPct for the other half of the story. The higher this number, the more "fair" your application will be against a constant
               rate of I/O by other applications, but the less able it may be to play fair when the external I/O is spiking.
 
               Also, consider that this is related to the #defaultChunkSize, as it is not a constant period of time. The default of "5" should be okay,
               but you may want to tune it if you use really large or really small chunk sizes.
-            
-            
+
+
             An "interactivity score" is defined to be (number of calculations) / (time to write data).
         '''
 
@@ -133,7 +133,7 @@ def __setitem__(self, key, value):
         if key in BackgroundIOPriority.__slots__:
             return setattr(self, key, value)
         raise KeyError('Unknown key: %s\n' %(key,))
-        
+
 
 _SIZE_MEG = 1024 * 1024
 
@@ -275,15 +275,15 @@ def run(self):
             shouldRecalculate = lambda i, numChunksRateSmoothing, firstPass : False
         else:
             shouldRecalculate = lambda i, numChunksRateSmoothing, firstPass : firstPass or i == numChunksRateSmoothing
-            
+
 
         while len(self.remainingData) > 0:
 
             # pop, write, flush
             nextData = self.remainingData.popleft()
             fileObj.write(nextData)
             doFlush(fileObj)
-            
+
             dataWritten += len(nextData)
             if sleepTime:
                 sleepBefore = time.time()
@@ -292,9 +292,9 @@ def run(self):
 
                 sleepAfter = time.time()
                 timeSlept += (sleepAfter - sleepBefore)
- 
+
             if shouldRecalculate(i, numChunksRateSmoothing, firstPass) is True:
-                # if not sleeptime, we are on first 
+                # if not sleeptime, we are on first
                 # We've completed a full period, time for charity
                 after = time.time()
 

nonblock/common.py

@@ -18,7 +18,7 @@ def detect_stream_mode(stream):
         elif 't' in stream.mode:
             return str
 
-    # Read a zero-length string off the device 
+    # Read a zero-length string off the device
     if hasattr(stream, 'read'):
         zeroStr = stream.read(0)
         if type(zeroStr) is str:

nonblock/read.py

@@ -3,7 +3,7 @@
 
     read.py Contains pure-python functions for non-blocking reads in python
 
-	
+
 '''
 # vim: ts=4 sw=4 expandtab