equal
deleted
inserted
replaced
1136 else: |
1136 else: |
1137 fc = _ThreadSafeFileChunker |
1137 fc = _ThreadSafeFileChunker |
1138 data_queue = _DataQueue() |
1138 data_queue = _DataQueue() |
1139 raw_data = util.chunkbuffer(data_queue) |
1139 raw_data = util.chunkbuffer(data_queue) |
1140 |
1140 |
1141 # XXX we will drop this extra filechunkiter layer soon |
|
1142 part_content = util.filechunkiter(fp) |
|
1143 w = threading.Thread( |
1141 w = threading.Thread( |
1144 target=data_queue.fill_from, |
1142 target=data_queue.fill_from, |
1145 args=(part_content,), |
1143 args=(fp,), |
1146 ) |
1144 ) |
1147 workers.append(w) |
1145 workers.append(w) |
1148 w.start() |
1146 w.start() |
1149 files = _v2_parse_files( |
1147 files = _v2_parse_files( |
1150 repo, |
1148 repo, |