H1K0-dev/tanabata
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(dbms): clear response when request requires no data

Browse Source
This commit is contained in:
Masahiko AMANO 2023-01-29 16:17:07 +03:00
parent bf4e127908
commit 6f3ac78fd0
1 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
tdbms/server/tdbms-server.c
View File

@ -388,6 +388,7 @@ int execute(char *request, char **response) {
if (db_count == UINT16_MAX || tdb != NULL) { if (db_count == UINT16_MAX || tdb != NULL) {
return 1; return 1;
} }
**response = 0;
db_count++; db_count++;
db_list = reallocarray(db_list, db_count, sizeof(TDB)); db_list = reallocarray(db_list, db_count, sizeof(TDB));
tdb = db_list + db_count - 1; tdb = db_list + db_count - 1;
@ -404,12 +405,14 @@ int execute(char *request, char **response) {
if (tanabata == NULL) { if (tanabata == NULL) {
return 1; return 1;
} }
**response = 0;
return tanabata_open(tanabata, tdb->path); return tanabata_open(tanabata, tdb->path);
} }
if (request_code == trc_db_save) { if (request_code == trc_db_save) {
if (tanabata == NULL) { if (tanabata == NULL) {
return 1; return 1;
} }
**response = 0;
if (strlen(request_body) > 0) { if (strlen(request_body) > 0) {
return tanabata_dump(tanabata, request_body); return tanabata_dump(tanabata, request_body);
} }
@ -419,6 +422,7 @@ int execute(char *request, char **response) {
if (tdb == NULL) { if (tdb == NULL) {
return 1; return 1;
} }
**response = 0;
buffer = request_body; buffer = request_body;
off_t offset; off_t offset;
while (*buffer != 0) { while (*buffer != 0) {
@ -448,6 +452,7 @@ int execute(char *request, char **response) {
if (tdb == NULL) { if (tdb == NULL) {
return 1; return 1;
} }
**response = 0;
free(tdb->name); free(tdb->name);
free(tdb->path); free(tdb->path);
if (tdb->database != NULL) { if (tdb->database != NULL) {
@ -466,6 +471,7 @@ int execute(char *request, char **response) {
if (tdb == NULL) { if (tdb == NULL) {
return 1; return 1;
} }
**response = 0;
size_t pathlen = strlen(tdb->path); size_t pathlen = strlen(tdb->path);
char *remove_path = malloc(pathlen + 10); char *remove_path = malloc(pathlen + 10);
strcpy(remove_path, tdb->path); strcpy(remove_path, tdb->path);
@ -494,6 +500,7 @@ int execute(char *request, char **response) {
if (tanabata == NULL) { if (tanabata == NULL) {
return 1; return 1;
} }
**response = 0;
return tanabata_weed(tanabata); return tanabata_weed(tanabata);
} }
if (request_code == trc_sasa_get) { if (request_code == trc_sasa_get) {
@ -582,12 +589,14 @@ int execute(char *request, char **response) {
if (tanabata == NULL) { if (tanabata == NULL) {
return 1; return 1;
} }
**response = 0;
return tanabata_sasa_add(tanabata, request_body); return tanabata_sasa_add(tanabata, request_body);
} }
if (request_code == trc_sasa_update) { if (request_code == trc_sasa_update) {
if (tanabata == NULL) { if (tanabata == NULL) {
return 1; return 1;
} }
**response = 0;
char *endptr; char *endptr;
uint64_t sasa_id = strtoull(request_body, &endptr, 0); uint64_t sasa_id = strtoull(request_body, &endptr, 0);
if (*endptr != ' ') { if (*endptr != ' ') {
@ -599,6 +608,7 @@ int execute(char *request, char **response) {
if (tanabata == NULL) { if (tanabata == NULL) {
return 1; return 1;
} }
**response = 0;
char *endptr; char *endptr;
uint64_t sasa_id = strtoull(request_body, &endptr, 0); uint64_t sasa_id = strtoull(request_body, &endptr, 0);
if (*endptr != 0) { if (*endptr != 0) {
@ -610,6 +620,7 @@ int execute(char *request, char **response) {
if (tanabata == NULL) { if (tanabata == NULL) {
return 1; return 1;
} }
**response = 0;
char *endptr; char *endptr;
uint64_t tanzaku_id = strtoull(request_body, &endptr, 0); uint64_t tanzaku_id = strtoull(request_body, &endptr, 0);
if (*endptr != 0) { if (*endptr != 0) {
@ -726,6 +737,7 @@ int execute(char *request, char **response) {
if (tanabata == NULL) { if (tanabata == NULL) {
return 1; return 1;
} }
**response = 0;
char *name = request_body; char *name = request_body;
for (; *request_body != '\n' && *request_body != 0; request_body++); for (; *request_body != '\n' && *request_body != 0; request_body++);
if (*request_body == 0) { if (*request_body == 0) {
@ -739,6 +751,7 @@ int execute(char *request, char **response) {
if (tanabata == NULL) { if (tanabata == NULL) {
return 1; return 1;
} }
**response = 0;
char *endptr; char *endptr;
uint64_t tanzaku_id = strtoull(request_body, &endptr, 0); uint64_t tanzaku_id = strtoull(request_body, &endptr, 0);
if (*endptr != ' ') { if (*endptr != ' ') {
@ -757,6 +770,7 @@ int execute(char *request, char **response) {
if (tanabata == NULL) { if (tanabata == NULL) {
return 1; return 1;
} }
**response = 0;
char *endptr; char *endptr;
uint64_t tanzaku_id = strtoull(request_body, &endptr, 0); uint64_t tanzaku_id = strtoull(request_body, &endptr, 0);
if (*endptr != 0) { if (*endptr != 0) {
@ -768,6 +782,7 @@ int execute(char *request, char **response) {
if (tanabata == NULL) { if (tanabata == NULL) {
return 1; return 1;
} }
**response = 0;
char *endptr; char *endptr;
uint64_t sasa_id = strtoull(request_body, &endptr, 0); uint64_t sasa_id = strtoull(request_body, &endptr, 0);
if (*endptr != 0) { if (*endptr != 0) {
@ -819,6 +834,7 @@ int execute(char *request, char **response) {
if (tanabata == NULL) { if (tanabata == NULL) {
return 1; return 1;
} }
**response = 0;
char *endptr; char *endptr;
uint64_t sasa_id = strtoull(request_body, &endptr, 0); uint64_t sasa_id = strtoull(request_body, &endptr, 0);
if (*endptr != ' ') { if (*endptr != ' ') {
@ -834,6 +850,7 @@ int execute(char *request, char **response) {
if (tanabata == NULL) { if (tanabata == NULL) {
return 1; return 1;
} }
**response = 0;
char *endptr; char *endptr;
uint64_t sasa_id = strtoull(request_body, &endptr, 0), tanzaku_id; uint64_t sasa_id = strtoull(request_body, &endptr, 0), tanzaku_id;
if (*endptr != ' ') { if (*endptr != ' ') {
@ -851,6 +868,7 @@ int execute(char *request, char **response) {
if (tanabata == NULL) { if (tanabata == NULL) {
return 1; return 1;
} }
**response = 0;
char *endptr; char *endptr;
uint64_t tanzaku_id = strtoull(request_body, &endptr, 0), sasa_id; uint64_t tanzaku_id = strtoull(request_body, &endptr, 0), sasa_id;
if (*endptr != ' ') { if (*endptr != ' ') {
@ -868,6 +886,7 @@ int execute(char *request, char **response) {
if (tanabata == NULL) { if (tanabata == NULL) {
return 1; return 1;
} }
**response = 0;
char *endptr; char *endptr;
uint64_t sasa_id = strtoull(request_body, &endptr, 0); uint64_t sasa_id = strtoull(request_body, &endptr, 0);
if (*endptr != ' ') { if (*endptr != ' ') {