Skip to content

Commit cfc4167

Browse files
author
DvirDukhan
committed
fixed PR comments
1 parent 6d0c6ff commit cfc4167

File tree

3 files changed

+20
-16
lines changed

3 files changed

+20
-16
lines changed

src/serialization/RDB/decoder/current/v1/decode_v1.c

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -158,7 +158,10 @@ void *RAI_RDBLoadModel_v1(RedisModuleIO *io) {
158158
RedisModuleCtx *stats_ctx = RedisModule_GetContextFromIO(io);
159159
RedisModuleString *stats_keystr =
160160
RedisModule_CreateStringFromString(stats_ctx, RedisModule_GetKeyNameFromIO(io));
161-
model->infokey = RAI_AddStatsEntry(stats_ctx, stats_keystr, RAI_MODEL, backend, devicestr, tag);
161+
RedisModuleString *stats_tag = RAI_HoldString(NULL, tag);
162+
163+
model->infokey =
164+
RAI_AddStatsEntry(stats_ctx, stats_keystr, RAI_MODEL, backend, devicestr, stats_tag);
162165

163166
for (size_t i = 0; i < ninputs; i++) {
164167
RedisModule_Free((void *)inputs[i]);
@@ -170,7 +173,6 @@ void *RAI_RDBLoadModel_v1(RedisModuleIO *io) {
170173
RedisModule_Free(outputs);
171174
RedisModule_Free(buffer);
172175

173-
RedisModule_Free(tag);
174176
RedisModule_Free(devicestr);
175177
RedisModule_Free(stats_keystr);
176178

@@ -240,18 +242,17 @@ void *RAI_RDBLoadScript_v1(RedisModuleIO *io) {
240242
RedisModuleString *stats_keystr =
241243
RedisModule_CreateStringFromString(stats_ctx, RedisModule_GetKeyNameFromIO(io));
242244

245+
const char *stats_devicestr = RedisModule_Strdup(devicestr);
246+
247+
tag = RAI_HoldString(NULL, tag);
248+
243249
script->infokey =
244250
RAI_AddStatsEntry(stats_ctx, stats_keystr, RAI_SCRIPT, RAI_BACKEND_TORCH, devicestr, tag);
245251

246-
RedisModule_Free(tag);
247-
RedisModule_Free(devicestr);
248-
RedisModule_Free(scriptdef);
249-
RedisModule_Free(stats_keystr);
252+
RedisModule_FreeString(NULL, stats_keystr);
250253

251254
return script;
252255
cleanup:
253-
if (tag)
254-
RedisModule_Free(tag);
255256
if (devicestr)
256257
RedisModule_Free(devicestr);
257258
if (scriptdef)

src/serialization/RDB/decoder/previous/v0/decode_v0.c

Lines changed: 10 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -138,7 +138,11 @@ void *RAI_RDBLoadModel_v0(RedisModuleIO *io) {
138138
RedisModuleCtx *stats_ctx = RedisModule_GetContextFromIO(io);
139139
RedisModuleString *stats_keystr =
140140
RedisModule_CreateStringFromString(stats_ctx, RedisModule_GetKeyNameFromIO(io));
141-
model->infokey = RAI_AddStatsEntry(stats_ctx, stats_keystr, RAI_MODEL, backend, devicestr, tag);
141+
142+
RedisModuleString *stats_tag = RAI_HoldString(NULL, tag);
143+
144+
model->infokey =
145+
RAI_AddStatsEntry(stats_ctx, stats_keystr, RAI_MODEL, backend, devicestr, stats_tag);
142146

143147
for (size_t i = 0; i < ninputs; i++) {
144148
RedisModule_Free((void *)inputs[i]);
@@ -150,7 +154,6 @@ void *RAI_RDBLoadModel_v0(RedisModuleIO *io) {
150154
RedisModule_Free(outputs);
151155
RedisModule_Free(buffer);
152156

153-
RedisModule_Free(tag);
154157
RedisModule_Free(devicestr);
155158
RedisModule_Free(stats_keystr);
156159

@@ -220,18 +223,17 @@ void *RAI_RDBLoadScript_v0(RedisModuleIO *io) {
220223
RedisModuleString *stats_keystr =
221224
RedisModule_CreateStringFromString(stats_ctx, RedisModule_GetKeyNameFromIO(io));
222225

226+
const char *stats_devicestr = RedisModule_Strdup(devicestr);
227+
228+
tag = RAI_HoldString(NULL, tag);
229+
223230
script->infokey =
224231
RAI_AddStatsEntry(stats_ctx, stats_keystr, RAI_SCRIPT, RAI_BACKEND_TORCH, devicestr, tag);
225232

226-
RedisModule_Free(tag);
227-
RedisModule_Free(devicestr);
228-
RedisModule_Free(scriptdef);
229-
RedisModule_Free(stats_keystr);
233+
RedisModule_FreeString(NULL, stats_keystr);
230234

231235
return script;
232236
cleanup:
233-
if (tag)
234-
RedisModule_Free(tag);
235237
if (devicestr)
236238
RedisModule_Free(devicestr);
237239
if (scriptdef)

src/serialization/serialization_include.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,3 +7,4 @@
77
#include "../script.h"
88
#include "../backends.h"
99
#include "../version.h"
10+
#include "../util/string_utils.h"

0 commit comments

Comments
 (0)