Skip to content

Commit a35bb30

Browse files
committed
Add AI.INFO command
1 parent b9a13fe commit a35bb30

File tree

6 files changed

+225
-87
lines changed

6 files changed

+225
-87
lines changed

src/backends.c

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@ RedisModuleString* RAI_GetModulePath(RedisModuleCtx *ctx) {
2121
return module_path;
2222
}
2323

24-
2524
RedisModuleString* RAI_GetBackendsPath(RedisModuleCtx *ctx) {
2625
Dl_info info;
2726
RedisModuleString* backends_path = NULL;
@@ -36,6 +35,20 @@ RedisModuleString* RAI_GetBackendsPath(RedisModuleCtx *ctx) {
3635
return backends_path;
3736
}
3837

38+
const char* RAI_BackendName(int backend) {
39+
switch (backend) {
40+
case RAI_BACKEND_TENSORFLOW:
41+
return "TF";
42+
case RAI_BACKEND_TFLITE:
43+
return "TFLITE";
44+
case RAI_BACKEND_TORCH:
45+
return "TORCH";
46+
case RAI_BACKEND_ONNXRUNTIME:
47+
return "ONNX";
48+
}
49+
return NULL;
50+
}
51+
3952
int RAI_LoadBackend_TensorFlow(RedisModuleCtx *ctx, const char *path) {
4053
if (RAI_backends.tf.model_run != NULL) {
4154
RedisModule_Log(ctx, "warning", "Could not load TF backend: backend already loaded");

src/backends.h

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,4 +35,6 @@ char* RAI_BackendsPath;
3535
int RAI_LoadBackend(RedisModuleCtx *ctx, int backend, const char *path);
3636
int RAI_LoadDefaultBackend(RedisModuleCtx *ctx, int backend);
3737

38-
#endif
38+
const char* RAI_BackendName(int backend);
39+
40+
#endif

src/model.c

Lines changed: 2 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -135,25 +135,11 @@ static void RAI_Model_AofRewrite(RedisModuleIO *aof, RedisModuleString *key, voi
135135
array_append(outputs_, RedisModule_CreateString(ctx, model->outputs[i], strlen(model->outputs[i])));
136136
}
137137

138-
char backend[256] = "";
139-
switch (model->backend) {
140-
case RAI_BACKEND_TENSORFLOW:
141-
strcpy(backend, "TF");
142-
break;
143-
case RAI_BACKEND_TFLITE:
144-
strcpy(backend, "TFLITE");
145-
break;
146-
case RAI_BACKEND_TORCH:
147-
strcpy(backend, "TORCH");
148-
break;
149-
case RAI_BACKEND_ONNXRUNTIME:
150-
strcpy(backend, "ONNX");
151-
break;
152-
}
138+
const char* backendstr = RAI_BackendName(model->backend);
153139

154140
RedisModule_EmitAOF(aof, "AI.MODELSET", "slccvcvb",
155141
key,
156-
backend, model->devicestr,
142+
backendstr, model->devicestr,
157143
"INPUTS", inputs_, model->ninputs,
158144
"OUTPUTS", outputs_, model->noutputs,
159145
buffer, len);

src/model_struct.h

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,6 @@ typedef struct RAI_Model {
1717
char **outputs;
1818
size_t noutputs;
1919
long long refCount;
20-
long long backend_calls;
21-
long long backend_us;
2220
void* data;
2321
} RAI_Model;
2422

0 commit comments

Comments
 (0)