| 450 | } |
| 451 | |
| 452 | int RedisModule_OnLoad(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) { |
| 453 | REDISMODULE_NOT_USED(argv); |
| 454 | REDISMODULE_NOT_USED(argc); |
| 455 | |
| 456 | if (RedisModule_Init(ctx, "blockonkeys", 1, REDISMODULE_APIVER_1)== REDISMODULE_ERR) |
| 457 | return REDISMODULE_ERR; |
| 458 | |
| 459 | RedisModuleTypeMethods tm = { |
| 460 | .version = REDISMODULE_TYPE_METHOD_VERSION, |
| 461 | .rdb_load = fsl_rdb_load, |
| 462 | .rdb_save = fsl_rdb_save, |
| 463 | .aof_rewrite = fsl_aofrw, |
| 464 | .mem_usage = NULL, |
| 465 | .free = fsl_free, |
| 466 | .digest = NULL |
| 467 | }; |
| 468 | |
| 469 | fsltype = RedisModule_CreateDataType(ctx, "fsltype_t", 0, &tm); |
| 470 | if (fsltype == NULL) |
| 471 | return REDISMODULE_ERR; |
| 472 | |
| 473 | if (RedisModule_CreateCommand(ctx,"fsl.push",fsl_push,"",0,0,0) == REDISMODULE_ERR) |
| 474 | return REDISMODULE_ERR; |
| 475 | |
| 476 | if (RedisModule_CreateCommand(ctx,"fsl.bpop",fsl_bpop,"",0,0,0) == REDISMODULE_ERR) |
| 477 | return REDISMODULE_ERR; |
| 478 | |
| 479 | if (RedisModule_CreateCommand(ctx,"fsl.bpopgt",fsl_bpopgt,"",0,0,0) == REDISMODULE_ERR) |
| 480 | return REDISMODULE_ERR; |
| 481 | |
| 482 | if (RedisModule_CreateCommand(ctx,"fsl.bpoppush",fsl_bpoppush,"",0,0,0) == REDISMODULE_ERR) |
| 483 | return REDISMODULE_ERR; |
| 484 | |
| 485 | if (RedisModule_CreateCommand(ctx,"fsl.getall",fsl_getall,"",0,0,0) == REDISMODULE_ERR) |
| 486 | return REDISMODULE_ERR; |
| 487 | |
| 488 | if (RedisModule_CreateCommand(ctx, "blockonkeys.popall", blockonkeys_popall, |
| 489 | "", 1, 1, 1) == REDISMODULE_ERR) |
| 490 | return REDISMODULE_ERR; |
| 491 | |
| 492 | if (RedisModule_CreateCommand(ctx, "blockonkeys.lpush", blockonkeys_lpush, |
| 493 | "", 1, 1, 1) == REDISMODULE_ERR) |
| 494 | return REDISMODULE_ERR; |
| 495 | |
| 496 | if (RedisModule_CreateCommand(ctx, "blockonkeys.lpush_unblock", blockonkeys_lpush, |
| 497 | "", 1, 1, 1) == REDISMODULE_ERR) |
| 498 | return REDISMODULE_ERR; |
| 499 | |
| 500 | if (RedisModule_CreateCommand(ctx, "blockonkeys.blpopn", blockonkeys_blpopn, |
| 501 | "", 1, 1, 1) == REDISMODULE_ERR) |
| 502 | return REDISMODULE_ERR; |
| 503 | |
| 504 | return REDISMODULE_OK; |
| 505 | } |
nothing calls this directly
no test coverage detected