diff --git a/storage/storage_disk_recovery.c b/storage/storage_disk_recovery.c index 2646891..9c5445c 100644 --- a/storage/storage_disk_recovery.c +++ b/storage/storage_disk_recovery.c @@ -1117,7 +1117,7 @@ int storage_disk_recovery_start(const int store_path_index) } result = storage_do_fetch_binlog(pStorageConn, store_path_index); - tracker_disconnect_server_ex(pStorageConn, result != 0); + tracker_disconnect_server(pStorageConn, true); if (result != 0) { return result; diff --git a/storage/storage_service.c b/storage/storage_service.c index 77bffb6..0a734eb 100644 --- a/storage/storage_service.c +++ b/storage/storage_service.c @@ -4268,6 +4268,7 @@ static int storage_server_do_fetch_one_path_binlog( \ if ((result=storage_reader_init(NULL, pReader)) != 0) { storage_reader_destroy(pReader); + free(pReader); return result; }