pipelimit: rpc commands updated to use rpl_printf()

modules/pipelimit/pipelimit.c

@@ -827,7 +827,7 @@ void rpc_pl_set_pipe(rpc_t *rpc, void *c);
 
 void rpc_pl_get_pid(rpc_t *rpc, void *c) {
 	rpl_pipe_lock(0);
-	rpc->printf(c, "ki[%f] kp[%f] kd[%f] ", *pid_ki, *pid_kp, *pid_kd);
+	rpc->rpl_printf(c, "ki[%f] kp[%f] kd[%f] ", *pid_ki, *pid_kp, *pid_kd);
 	rpl_pipe_release(0);
 }
 

modules/pipelimit/pl_ht.c

@@ -605,7 +605,7 @@ void rpc_pl_stats(rpc_t *rpc, void *c)
 		while(it)
 		{
 			if (it->algo != PIPE_ALGO_NOP) {
-				if (rpc->printf(c, "PIPE: id=%.*s load=%d counter=%d",
+				if (rpc->rpl_printf(c, "PIPE: id=%.*s load=%d counter=%d",
 					it->name.len, it->name.s,
 					it->load, it->last_counter) < 0)
 				{
@@ -637,7 +637,7 @@ void rpc_pl_get_pipes(rpc_t *rpc, void *c)
 					lock_release(&_pl_pipes_ht->slots[i].lock);
 					return;
 				}
-				if (rpc->printf(c, "PIPE: id=%.*s algorithm=%.*s limit=%d counter=%d",
+				if (rpc->rpl_printf(c, "PIPE: id=%.*s algorithm=%.*s limit=%d counter=%d",
 					it->name.len, it->name.s, algo.len, algo.s,
 					it->limit, it->counter) < 0)
 				{