questions about append_compact_purge.rs example

[stupidstan]

state.last_index一直是0，不会走到70行

[stupidstan]

请问这个用例预期一直不停吗
loop {
for i in 1024
}

[tabokie]

append_compact_purge.rs用例好像不会执行压缩

The compression is done inside engine.write(&batch). More specifically, here:

raft-engine/src/log_batch.rs

Lines 709 to 718 in 7a436ea

	// entries
	let (header_offset, compression_type) = if compression_threshold > 0
	&& self.buf.len() >= LOG_BATCH_HEADER_LEN + compression_threshold
	{
	let buf_len = self.buf.len();
	lz4::append_compress_block(&mut self.buf, LOG_BATCH_HEADER_LEN)?;
	(buf_len - LOG_BATCH_HEADER_LEN, CompressionType::Lz4)
	} else {
	(0, CompressionType::None)
	};

If the data is larger than compression_threshold (8KB by default), the block will be compressed.

state.last_index一直是0，不会走到70行

There's an issue with this example. The state.last_index should be incremented before written via engine.write(&batch).

Feel free to file an PR to fix it.

请问这个用例预期一直不停吗

Yes, you have to manually kill it. Maybe we can do something to improve it later.

[stupidstan]

append_compact_purge.rs用例好像不会执行压缩

The compression is done inside engine.write(&batch). More specifically, here:

raft-engine/src/log_batch.rs

Lines 709 to 718 in 7a436ea

	// entries
	let (header_offset, compression_type) = if compression_threshold > 0
	&& self.buf.len() >= LOG_BATCH_HEADER_LEN + compression_threshold
	{
	let buf_len = self.buf.len();
	lz4::append_compress_block(&mut self.buf, LOG_BATCH_HEADER_LEN)?;
	(buf_len - LOG_BATCH_HEADER_LEN, CompressionType::Lz4)
	} else {
	(0, CompressionType::None)
	};

If the data is larger than compression_threshold (8KB by default), the block will be compressed.

state.last_index一直是0，不会走到70行

There's an issue with this example. The state.last_index should be incremented before written via engine.write(&batch).

Feel free to file an PR to fix it.

请问这个用例预期一直不停吗

Yes, you have to manually kill it. Maybe we can do something to improve it later.

感谢答疑~