equal
deleted
inserted
replaced
222 } |
222 } |
223 } |
223 } |
224 (results, true) |
224 (results, true) |
225 }) |
225 }) |
226 |
226 |
227 def make_entry(session_name: String, args: Protocol.Export.Args, body: Bytes): Unit = { |
227 def make_entry(session_name: String, args0: Protocol.Export.Args, body: Bytes): Unit = { |
228 if (!progress.stopped && !body.is_empty) { |
228 if (!progress.stopped && !body.is_empty) { |
|
229 val args = if (db.is_server) args0.copy(compress = false) else args0 |
229 consumer.send(Export.make_entry(session_name, args, body, cache) -> args.strict) |
230 consumer.send(Export.make_entry(session_name, args, body, cache) -> args.strict) |
230 } |
231 } |
231 } |
232 } |
232 |
233 |
233 def shutdown(close: Boolean = false): List[String] = { |
234 def shutdown(close: Boolean = false): List[String] = { |