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 |