3030from lib .core .exception import sqlmapValueException
3131from lib .core .replication import Replication
3232from lib .core .settings import BLANK
33- from lib .core .settings import BUFFERED_LOG_SIZE
3433from lib .core .settings import NULL
3534from lib .core .settings import TRIM_STDOUT_DUMP_SIZE
3635from lib .core .settings import UNICODE_ENCODING
@@ -45,7 +44,6 @@ class Dump:
4544 def __init__ (self ):
4645 self ._outputFile = None
4746 self ._outputFP = None
48- self ._outputBP = None
4947 self ._lock = threading .Lock ()
5048
5149 def _write (self , data , n = True , console = True ):
@@ -56,41 +54,27 @@ def _write(self, data, n=True, console=True):
5654 if kb .get ("multiThreadMode" ):
5755 self ._lock .acquire ()
5856
59- self ._outputBP .write (text )
60-
61- if self ._outputBP .tell () > BUFFERED_LOG_SIZE :
62- self .flush ()
57+ self ._outputFP .write (text )
6358
6459 if kb .get ("multiThreadMode" ):
6560 self ._lock .release ()
6661
6762 kb .dataOutputFlag = True
6863
69- def flush (self ):
70- if self ._outputBP and self ._outputFP and self ._outputBP .tell () > 0 :
71- _ = self ._outputBP .getvalue ()
72- self ._outputBP .truncate (0 )
73- self ._outputFP .write (_ )
74-
7564 def _formatString (self , inpStr ):
7665 return restoreDumpMarkedChars (getUnicode (inpStr ))
7766
7867 def setOutputFile (self ):
7968 self ._outputFile = "%s%slog" % (conf .outputPath , os .sep )
8069 self ._outputFP = codecs .open (self ._outputFile , "ab" , UNICODE_ENCODING )
81- self ._outputBP = StringIO .StringIO ()
8270
8371 def getOutputFile (self ):
84- self .flush ()
8572 return self ._outputFile
8673
8774 def string (self , header , data , sort = True ):
8875 if isinstance (data , (list , tuple , set )):
8976 self .lister (header , data , sort )
90-
91- return
92-
93- if data :
77+ elif data :
9478 data = self ._formatString (getUnicode (data ))
9579
9680 if data [- 1 ] == '\n ' :
0 commit comments