simon987/sist2
1
0
Fork 0
mirror of https://github.com/simon987/sist2.git synced 2025-04-20 02:36:43 +00:00
Code Issues Projects Releases Wiki Activity

Fix some memory leaks

Browse Source
This commit is contained in:
simon987 2023-04-15 11:54:56 -04:00
parent 7baaca5078
commit ebc9468251
1 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/index/elastic.c
View File

@ -64,20 +64,16 @@ void print_json(cJSON *document, const char id_str[SIST_DOC_ID_LEN]) {
cJSON_Delete(line); cJSON_Delete(line);
} }
void index_json_func(job_t *job) {
elastic_index_line(job->bulk_line);
}
void delete_document(const char *document_id) { void delete_document(const char *document_id) {
es_bulk_line_t *bulk_line = malloc(sizeof(es_bulk_line_t)); es_bulk_line_t bulk_line;
bulk_line->type = ES_BULK_LINE_DELETE; bulk_line.type = ES_BULK_LINE_DELETE;
bulk_line->next = NULL; bulk_line.next = NULL;
strcpy(bulk_line->doc_id, document_id); strcpy(bulk_line.doc_id, document_id);
tpool_add_work(IndexCtx.pool, &(job_t) { tpool_add_work(IndexCtx.pool, &(job_t) {
.type = JOB_BULK_LINE, .type = JOB_BULK_LINE,
.bulk_line = bulk_line, .bulk_line = &bulk_line,
}); });
} }
@ -99,6 +95,7 @@ void index_json(cJSON *document, const char doc_id[SIST_DOC_ID_LEN]) {
.type = JOB_BULK_LINE, .type = JOB_BULK_LINE,
.bulk_line = bulk_line, .bulk_line = bulk_line,
}); });
free(bulk_line);
} }
void execute_update_script(const char *script, int async, const char index_id[SIST_INDEX_ID_LEN]) { void execute_update_script(const char *script, int async, const char index_id[SIST_INDEX_ID_LEN]) {