1 |
commit: b60aa29c76d44975a20ef6206473aa266947e225 |
2 |
Author: André Erdmann <dywi <AT> mailerd <DOT> de> |
3 |
AuthorDate: Fri Feb 21 23:00:06 2014 +0000 |
4 |
Commit: André Erdmann <dywi <AT> mailerd <DOT> de> |
5 |
CommitDate: Sat Feb 22 14:23:12 2014 +0000 |
6 |
URL: http://git.overlays.gentoo.org/gitweb/?p=proj/R_overlay.git;a=commit;h=b60aa29c |
7 |
|
8 |
roverlay/depres, rule reader: properly count files |
9 |
|
10 |
fix a small bug that affects logging only where |
11 |
SimpleDependencyRuleReader.read() always reports a file count of 0. |
12 |
|
13 |
Also, remove an unnecessary "self._pool_add is [not] None" check. |
14 |
|
15 |
--- |
16 |
roverlay/depres/simpledeprule/reader.py | 16 +++++++--------- |
17 |
roverlay/depres/simpledeprule/rulemaker.py | 5 +++++ |
18 |
roverlay/util/mapreader.py | 10 ++++++++++ |
19 |
3 files changed, 22 insertions(+), 9 deletions(-) |
20 |
|
21 |
diff --git a/roverlay/depres/simpledeprule/reader.py b/roverlay/depres/simpledeprule/reader.py |
22 |
index 22f3cf3..3cdc7cf 100644 |
23 |
--- a/roverlay/depres/simpledeprule/reader.py |
24 |
+++ b/roverlay/depres/simpledeprule/reader.py |
25 |
@@ -36,8 +36,6 @@ class SimpleDependencyRuleReader ( object ): |
26 |
|
27 |
self._pool_add = pool_add |
28 |
self._when_done = when_done |
29 |
- |
30 |
- self._fcount = 0 |
31 |
# --- end of __init__ (...) --- |
32 |
|
33 |
def read ( self, files_or_dirs ): |
34 |
@@ -52,17 +50,17 @@ class SimpleDependencyRuleReader ( object ): |
35 |
"Read method is for resolver, but pool_add is None." |
36 |
) |
37 |
|
38 |
+ self._rmaker.file_count = 0 |
39 |
self.read_files ( files_or_dirs ) |
40 |
|
41 |
rule_count, pools = self._rmaker.done ( as_pool=True ) |
42 |
self.logger.debug ( "Read {} rules in {} files.".format ( |
43 |
- rule_count, self._fcount |
44 |
+ rule_count, self._rmaker.file_count |
45 |
) ) |
46 |
- if self._pool_add is not None: |
47 |
- for p in pools: self._pool_add ( p ) |
48 |
|
49 |
- if self._when_done is not None: |
50 |
- self._when_done() |
51 |
- else: |
52 |
- return pools |
53 |
+ for p in pools: |
54 |
+ self._pool_add ( p ) |
55 |
+ |
56 |
+ if self._when_done is not None: |
57 |
+ self._when_done() |
58 |
# --- end of read (...) --- |
59 |
|
60 |
diff --git a/roverlay/depres/simpledeprule/rulemaker.py b/roverlay/depres/simpledeprule/rulemaker.py |
61 |
index 5daf058..8a4acc5 100644 |
62 |
--- a/roverlay/depres/simpledeprule/rulemaker.py |
63 |
+++ b/roverlay/depres/simpledeprule/rulemaker.py |
64 |
@@ -47,6 +47,7 @@ class SimpleRuleMaker ( roverlay.util.mapreader.MapFileParser ): |
65 |
self.deptype_kw = 'deptype' |
66 |
self._deptype = deptype.ALL |
67 |
self._deptype_once = deptype.NONE |
68 |
+ self.file_count = 0 |
69 |
# --- end of __init__ (...) --- |
70 |
|
71 |
def has_context ( self ): |
72 |
@@ -62,6 +63,10 @@ class SimpleRuleMaker ( roverlay.util.mapreader.MapFileParser ): |
73 |
self._deptype_once = deptype.NONE |
74 |
# --- end of read_lines_begin (...) --- |
75 |
|
76 |
+ def read_file_done ( self, filepath ): |
77 |
+ self.file_count += 1 |
78 |
+ # --- end of read_file_done (...) --- |
79 |
+ |
80 |
def make_result ( self, as_pool=False ): |
81 |
rule_count = len ( self._items ) |
82 |
if as_pool: |
83 |
|
84 |
diff --git a/roverlay/util/mapreader.py b/roverlay/util/mapreader.py |
85 |
index 36f4ba7..9ee0944 100644 |
86 |
--- a/roverlay/util/mapreader.py |
87 |
+++ b/roverlay/util/mapreader.py |
88 |
@@ -150,8 +150,17 @@ class MapFileParser ( object ): |
89 |
return ret |
90 |
# --- end of read_lines (...) --- |
91 |
|
92 |
+ def read_file_begin ( self, filepath ): |
93 |
+ pass |
94 |
+ # --- end of read_file_begin (...) --- |
95 |
+ |
96 |
+ def read_file_done ( self, filepath ): |
97 |
+ pass |
98 |
+ # --- end of read_file_done (...) --- |
99 |
+ |
100 |
def read_file ( self, filepath, handle_compressed=True ): |
101 |
ret = None |
102 |
+ self.read_file_begin ( filepath ) |
103 |
try: |
104 |
if handle_compressed: |
105 |
ret = self.read_lines ( |
106 |
@@ -166,6 +175,7 @@ class MapFileParser ( object ): |
107 |
) |
108 |
raise |
109 |
|
110 |
+ self.read_file_done ( filepath ) |
111 |
return ret |
112 |
# --- end of read_file (...) --- |