(self, data, newline=True, console=True, content_type=None)
| 72 | self._lock = threading.Lock() |
| 73 | |
| 74 | def _write(self, data, newline=True, console=True, content_type=None): |
| 75 | text = "%s%s" % (data, "\n" if newline else " ") |
| 76 | |
| 77 | if conf.api: |
| 78 | dataToStdout(data, contentType=content_type, status=CONTENT_STATUS.COMPLETE) |
| 79 | |
| 80 | elif console: |
| 81 | dataToStdout(text) |
| 82 | |
| 83 | if self._outputFP: |
| 84 | multiThreadMode = kb.multiThreadMode |
| 85 | if multiThreadMode: |
| 86 | self._lock.acquire() |
| 87 | |
| 88 | try: |
| 89 | self._outputFP.write(text) |
| 90 | except IOError as ex: |
| 91 | errMsg = "error occurred while writing to log file ('%s')" % getSafeExString(ex) |
| 92 | raise SqlmapGenericException(errMsg) |
| 93 | |
| 94 | if multiThreadMode: |
| 95 | self._lock.release() |
| 96 | |
| 97 | kb.dataOutputFlag = True |
| 98 | |
| 99 | def flush(self): |
| 100 | if self._outputFP: |
no test coverage detected