##// END OF EJS Templates
moved locking of commit stats into the task itself to remove race conditions when lock was not removed before starting another task.
moved locking of commit stats into the task itself to remove race conditions when lock was not removed before starting another task.

File last commit:

r1228:73434499 default
r1264:0c43c667 beta
Show More
timerproxy.py
28 lines | 845 B | text/x-python | PythonLexer
renamed project to rhodecode
r547 from sqlalchemy.interfaces import ConnectionProxy
import time
let timerproxy use logging module
r1191 import logging
log = logging.getLogger('timerproxy')
renamed project to rhodecode
r547 BLACK, RED, GREEN, YELLOW, BLUE, MAGENTA, CYAN, WHITE = xrange(30, 38)
def color_sql(sql):
COLOR_SEQ = "\033[1;%dm"
COLOR_SQL = YELLOW
normal = '\x1b[0m'
timperproxy will just measure the time of queries, and formatting will be handled by the new sql_formatter of queries from sqlalchemy itself. Updated ini files for new way logging
r1186 return COLOR_SEQ % COLOR_SQL + sql + normal
renamed project to rhodecode
r547
class TimerProxy(ConnectionProxy):
timperproxy will just measure the time of queries, and formatting will be handled by the new sql_formatter of queries from sqlalchemy itself. Updated ini files for new way logging
r1186
renamed project to rhodecode
r547 def __init__(self):
super(TimerProxy, self).__init__()
timperproxy will just measure the time of queries, and formatting will be handled by the new sql_formatter of queries from sqlalchemy itself. Updated ini files for new way logging
r1186
def cursor_execute(self, execute, cursor, statement, parameters,
context, executemany):
renamed project to rhodecode
r547 now = time.time()
try:
let timerproxy use logging module
r1191 log.info(color_sql(">>>>> STARTING QUERY >>>>>"))
renamed project to rhodecode
r547 return execute(cursor, statement, parameters, context)
finally:
total = time.time() - now
let timerproxy use logging module
r1191 log.info(color_sql("<<<<< TOTAL TIME: %f <<<<<" % total))