@ -1046,6 +1046,11 @@ static void cli_incoming_ksadd(str *instr, struct cli_writer *cw) {
unsigned long uint_keyspace_db ;
unsigned long uint_keyspace_db ;
char * endptr ;
char * endptr ;
if ( ! rtpe_redis_notify ) {
cw - > cw_printf ( cw , " Keyspace notification feature has not been configured. \n " ) ;
return ;
}
if ( str_shift ( instr , 1 ) ) {
if ( str_shift ( instr , 1 ) ) {
cw - > cw_printf ( cw , " %s \n " , " More parameters required. " ) ;
cw - > cw_printf ( cw , " %s \n " , " More parameters required. " ) ;
return ;
return ;
@ -1076,6 +1081,11 @@ static void cli_incoming_ksrm(str *instr, struct cli_writer *cw) {
unsigned long uint_keyspace_db ;
unsigned long uint_keyspace_db ;
char * endptr ;
char * endptr ;
if ( ! rtpe_redis_notify ) {
cw - > cw_printf ( cw , " Keyspace notification feature has not been configured. \n " ) ;
return ;
}
if ( str_shift ( instr , 1 ) ) {
if ( str_shift ( instr , 1 ) ) {
cw - > cw_printf ( cw , " %s \n " , " More parameters required. " ) ;
cw - > cw_printf ( cw , " %s \n " , " More parameters required. " ) ;
return ;
return ;
@ -1110,6 +1120,11 @@ static void cli_incoming_ksrm(str *instr, struct cli_writer *cw) {
static void cli_incoming_kslist ( str * instr , struct cli_writer * cw ) {
static void cli_incoming_kslist ( str * instr , struct cli_writer * cw ) {
GList * l ;
GList * l ;
if ( ! rtpe_redis_notify ) {
cw - > cw_printf ( cw , " Keyspace notification feature has not been configured. \n " ) ;
return ;
}
cw - > cw_printf ( cw , " \n Subscribed-on keyspaces: \n " ) ;
cw - > cw_printf ( cw , " \n Subscribed-on keyspaces: \n " ) ;
rwlock_lock_r ( & rtpe_config . keyspaces_lock ) ;
rwlock_lock_r ( & rtpe_config . keyspaces_lock ) ;