xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

make it compile

This commit is contained in:
Hongze Cheng 2024-07-24 13:15:00 +08:00
parent 599b0f8d9f
commit 402b47c788
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
source/util/src/tdigest.c
View File

@ -106,11 +106,11 @@ int32_t tdigestCompress(TDigest *t) {
int32_t i, j; int32_t i, j;
SMergeArgs args; SMergeArgs args;
if (t->num_buffered_pts <= 0) return; if (t->num_buffered_pts <= 0) return 0;
unmerged_centroids = (SCentroid *)taosMemoryMalloc(sizeof(SCentroid) * t->num_buffered_pts); unmerged_centroids = (SCentroid *)taosMemoryMalloc(sizeof(SCentroid) * t->num_buffered_pts);
if (unmerged_weight == NULL) { if (unmerged_centroids == NULL) {
return TSDB_CODE_OUT_OF_MEMORY; return terrno;
} }
for (i = 0; i < num_unmerged; i++) { for (i = 0; i < num_unmerged; i++) {
SPt *p = t->buffered_pts + i; SPt *p = t->buffered_pts + i;
@ -127,7 +127,7 @@ int32_t tdigestCompress(TDigest *t) {
args.centroids = (SCentroid *)taosMemoryMalloc((size_t)(sizeof(SCentroid) * t->size)); args.centroids = (SCentroid *)taosMemoryMalloc((size_t)(sizeof(SCentroid) * t->size));
if (args.centroids == NULL) { if (args.centroids == NULL) {
taosMemoryFree((void *)unmerged_centroids); taosMemoryFree((void *)unmerged_centroids);
return TSDB_CODE_OUT_OF_MEMORY; return terrno;
} }
memset(args.centroids, 0, (size_t)(sizeof(SCentroid) * t->size)); memset(args.centroids, 0, (size_t)(sizeof(SCentroid) * t->size));
@ -192,6 +192,7 @@ int32_t tdigestAdd(TDigest *t, double x, int64_t w) {
if (t->num_buffered_pts >= t->threshold) { if (t->num_buffered_pts >= t->threshold) {
return tdigestCompress(t); return tdigestCompress(t);
} }
return 0;
} }
#if 0 #if 0
@ -309,4 +310,6 @@ int32_t tdigestMerge(TDigest *t1, TDigest *t2) {
code = tdigestAdd(t1, t2->centroids[i].mean, t2->centroids[i].weight); code = tdigestAdd(t1, t2->centroids[i].mean, t2->centroids[i].weight);
if (code) return code; if (code) return code;
} }
return 0;
} }