breeze/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-02-08 01:33:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix grammar

Browse Source
This commit is contained in:
XieHan
2022-09-18 02:05:18 +08:00
parent aadea466d6
commit 06bb8869a2
3 changed files with 24 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/protocol/KafkaMessage.cc
View File

@@ -1222,8 +1222,8 @@ int KafkaMessage::parse_message_set(void **buf, size_t *size,
record->timestamp = timestamp;
record->offset = offset;
record->toppar = toppar->get_raw_ptr();
record->key_is_move = 1;
record->value_is_move = 1;
record->key_is_moved = 1;
record->value_is_moved = 1;
record->value = payload;
record->value_len = payload_len;
list_add_tail(kafka_record->get_list(), record_list);
@@ -1375,8 +1375,8 @@ int KafkaMessage::parse_message_record(void **buf, size_t *size,
return -1;
}
header->key_is_move = 1;
header->value_is_move = 1;
header->key_is_moved = 1;
header->value_is_moved = 1;
list_add_tail(&header->list, &record->header_list);
}
@@ -1474,8 +1474,8 @@ int KafkaMessage::parse_record_batch(void **buf, size_t *size,
KafkaRecord *record = new KafkaRecord;
record->set_offset(hdr.base_offset);
record->set_timestamp(hdr.base_timestamp);
record->get_raw_ptr()->key_is_move = 1;
record->get_raw_ptr()->value_is_move = 1;
record->get_raw_ptr()->key_is_moved = 1;
record->get_raw_ptr()->value_is_moved = 1;
record->get_raw_ptr()->toppar = toppar->get_raw_ptr();
switch (parse_message_record(&p, &n, record->get_raw_ptr()))

20
src/protocol/kafka_parser.c
View File

@@ -462,18 +462,18 @@ void kafka_record_header_init(kafka_record_header_t *header)
{
header->key = NULL;
header->key_len = 0;
header->key_is_move = 0;
header->key_is_moved = 0;
header->value = NULL;
header->value_len = 0;
header->value_is_move = 0;
header->value_is_moved = 0;
}
void kafka_record_header_deinit(kafka_record_header_t *header)
{
if (!header->key_is_move)
if (!header->key_is_moved)
free(header->key);
if (!header->value_is_move)
if (!header->value_is_moved)
free(header->value);
}
@@ -481,10 +481,10 @@ void kafka_record_init(kafka_record_t *record)
{
record->key = NULL;
record->key_len = 0;
record->key_is_move = 0;
record->key_is_moved = 0;
record->value = NULL;
record->value_len = 0;
record->value_is_move = 0;
record->value_is_moved = 0;
record->timestamp = 0;
record->offset = 0;
INIT_LIST_HEAD(&record->header_list);
@@ -497,10 +497,10 @@ void kafka_record_deinit(kafka_record_t *record)
struct list_head *tmp, *pos;
kafka_record_header_t *header;
if (!record->key_is_move)
if (!record->key_is_moved)
free(record->key);
if (!record->value_is_move)
if (!record->value_is_moved)
free(record->value);
list_for_each_safe(pos, tmp, &record->header_list)
@@ -570,12 +570,12 @@ void kafka_block_init(kafka_block_t *block)
{
block->buf = NULL;
block->len = 0;
block->is_move = 0;
block->is_moved = 0;
}
void kafka_block_deinit(kafka_block_t *block)
{
if (!block->is_move)
if (!block->is_moved)
free(block->buf);
}

16
src/protocol/kafka_parser.h
View File

@@ -202,9 +202,9 @@ enum
enum
{
KAFKA_TIMESTAMP_EARLIEST = -2,
KAFKA_TIMESTAMP_LATEST = -1,
KAFKA_TIMESTAMP_UNINIT = 0,
KAFKA_TIMESTAMP_EARLIEST = -2,
KAFKA_TIMESTAMP_LATEST = -1,
KAFKA_TIMESTAMP_UNINIT = 0,
};
enum
@@ -354,20 +354,20 @@ typedef struct __kafka_record_header
struct list_head list;
void *key;
size_t key_len;
int key_is_move;
int key_is_moved;
void *value;
size_t value_len;
int value_is_move;
int value_is_moved;
} kafka_record_header_t;
typedef struct __kafka_record
{
void *key;
size_t key_len;
int key_is_move;
int key_is_moved;
void *value;
size_t value_len;
int value_is_move;
int value_is_moved;
long long timestamp;
long long offset;
struct list_head header_list;
@@ -417,7 +417,7 @@ typedef struct __kafka_block
{
void *buf;
size_t len;
int is_move;
int is_moved;
} kafka_block_t;