| OLD | NEW |
| 1 # Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 # Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 # Use of this source code is governed by a BSD-style license that can be | 2 # Use of this source code is governed by a BSD-style license that can be |
| 3 # found in the LICENSE file. | 3 # found in the LICENSE file. |
| 4 | 4 |
| 5 """Generic utils.""" | 5 """Generic utils.""" |
| 6 | 6 |
| 7 import codecs | 7 import codecs |
| 8 import cStringIO | 8 import cStringIO |
| 9 import datetime | 9 import datetime |
| 10 import logging | 10 import logging |
| (...skipping 758 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 769 if task.start and task.finish: | 769 if task.start and task.finish: |
| 770 elapsed = ' (Elapsed: %s)' % ( | 770 elapsed = ' (Elapsed: %s)' % ( |
| 771 str(task.finish - task.start).partition('.')[0]) | 771 str(task.finish - task.start).partition('.')[0]) |
| 772 else: | 772 else: |
| 773 elapsed = '' | 773 elapsed = '' |
| 774 return """ | 774 return """ |
| 775 %s%s%s | 775 %s%s%s |
| 776 ---------------------------------------- | 776 ---------------------------------------- |
| 777 %s | 777 %s |
| 778 ----------------------------------------""" % ( | 778 ----------------------------------------""" % ( |
| 779 task.name, comment, task.outbuf.getvalue().strip(), elapsed) | 779 task.name, comment, elapsed, task.outbuf.getvalue().strip()) |
| 780 | 780 |
| 781 def flush(self, *args, **kwargs): | 781 def flush(self, *args, **kwargs): |
| 782 """Runs all enqueued items until all are executed.""" | 782 """Runs all enqueued items until all are executed.""" |
| 783 kwargs['work_queue'] = self | 783 kwargs['work_queue'] = self |
| 784 self.last_subproc_output = self.last_join = datetime.datetime.now() | 784 self.last_subproc_output = self.last_join = datetime.datetime.now() |
| 785 self.ready_cond.acquire() | 785 self.ready_cond.acquire() |
| 786 try: | 786 try: |
| 787 while True: | 787 while True: |
| 788 # Check for task to run first, then wait. | 788 # Check for task to run first, then wait. |
| 789 while True: | 789 while True: |
| (...skipping 287 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1077 def DefaultIndexPackConfig(url=''): | 1077 def DefaultIndexPackConfig(url=''): |
| 1078 """Return reasonable default values for configuring git-index-pack. | 1078 """Return reasonable default values for configuring git-index-pack. |
| 1079 | 1079 |
| 1080 Experiments suggest that higher values for pack.threads don't improve | 1080 Experiments suggest that higher values for pack.threads don't improve |
| 1081 performance.""" | 1081 performance.""" |
| 1082 cache_limit = DefaultDeltaBaseCacheLimit() | 1082 cache_limit = DefaultDeltaBaseCacheLimit() |
| 1083 result = ['-c', 'core.deltaBaseCacheLimit=%s' % cache_limit] | 1083 result = ['-c', 'core.deltaBaseCacheLimit=%s' % cache_limit] |
| 1084 if url in THREADED_INDEX_PACK_BLACKLIST: | 1084 if url in THREADED_INDEX_PACK_BLACKLIST: |
| 1085 result.extend(['-c', 'pack.threads=1']) | 1085 result.extend(['-c', 'pack.threads=1']) |
| 1086 return result | 1086 return result |
| OLD | NEW |