119 if t=='progress_percent': |
119 if t=='progress_percent': |
120 current=safe_get_int(status, 'current') |
120 current=safe_get_int(status, 'current') |
121 total=safe_get_int(status, 'total') |
121 total=safe_get_int(status, 'total') |
122 if current is not None and total is not None: |
122 if current is not None and total is not None: |
123 with self.lock: |
123 with self.lock: |
124 self.current_operation.progress_current=current |
124 self.current_operation['progress_current']=current |
125 self.current_operation.progress_total=total |
125 self.current_operation['progress_total']=total |
126 status, callback=self.__status_unlocked() |
126 status, callback=self.__status_unlocked() |
127 |
127 |
128 elif t=='archive_progress': |
128 elif t=='archive_progress': |
129 original_size=safe_get_int(status, 'original_size') |
129 original_size=safe_get_int(status, 'original_size') |
130 compressed_size=safe_get_int(status, 'compressed_size') |
130 compressed_size=safe_get_int(status, 'compressed_size') |
131 deduplicated_size=safe_get_int(status, 'deduplicated_size') |
131 deduplicated_size=safe_get_int(status, 'deduplicated_size') |
132 if original_size is not None and original_size is not None and deduplicated_size is not None: |
132 if original_size is not None and original_size is not None and deduplicated_size is not None: |
133 with self.lock: |
133 with self.lock: |
134 self.current_operation.original_size=original_size |
134 self.current_operation['original_size']=original_size |
135 self.current_operation.compressed_size=compressed_size |
135 self.current_operation['compressed_size']=compressed_size |
136 self.current_operation.deduplicated_size=deduplicated_size |
136 self.current_operation['deduplicated_size']=deduplicated_size |
137 status, callback=self.__status_unlocked() |
137 status, callback=self.__status_unlocked() |
138 |
138 |
139 elif t=='progress_message': |
139 elif t=='progress_message': |
140 pass |
140 pass |
141 |
141 |