From 613c31fcf3866dcdb996727cea29e68ac20121e1 Mon Sep 17 00:00:00 2001 From: YuQing <384681@qq.com> Date: Mon, 18 Apr 2022 08:59:07 +0800 Subject: [PATCH] sf_binlog_writer_change_order_by check if versioned writer --- src/sf_binlog_writer.c | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/src/sf_binlog_writer.c b/src/sf_binlog_writer.c index a0d0bed..bd25949 100644 --- a/src/sf_binlog_writer.c +++ b/src/sf_binlog_writer.c @@ -471,6 +471,15 @@ int sf_binlog_writer_change_order_by(SFBinlogWriterInfo *writer, return EINVAL; } + if (order_by == SF_BINLOG_WRITER_TYPE_ORDER_BY_VERSION) { + if (writer->version_ctx.ring.slots == NULL) { + logError("file: "__FILE__", line: %d, " + "the writer is NOT versioned writer, can't " + "set order by to %d!", __LINE__, order_by); + return EINVAL; + } + } + if ((buffer=sf_binlog_writer_alloc_versioned_buffer_ex(writer, order_by, order_by, SF_BINLOG_BUFFER_TYPE_CHANGE_ORDER_TYPE)) == NULL) {