Lines Matching refs:pipeid
612 static int pipe_push(struct sip_msg * msg, str *pipeid) in pipe_push() argument
616 pipe = pl_pipe_get(pipeid, 1); in pipe_push()
619 LM_ERR("pipe not found [%.*s]\n", pipeid->len, pipeid->s); in pipe_push()
631 static int pl_check(struct sip_msg * msg, str *pipeid) in pl_check() argument
635 ret = pipe_push(msg, pipeid); in pl_check()
645 str pipeid = {0, 0}; in w_pl_check() local
647 if(fixup_get_svalue(msg, (gparam_p)p1, &pipeid)!=0 in w_pl_check()
648 || pipeid.s == 0) in w_pl_check()
654 return pl_check(msg, &pipeid); in w_pl_check()
661 static int pl_check_limit(sip_msg_t* msg, str *pipeid, str *alg, int limit) in pl_check_limit() argument
665 pipe = pl_pipe_get(pipeid, 1); in pl_check_limit()
668 pipeid->len, pipeid->s); in pl_check_limit()
669 if(pl_pipe_add(pipeid, alg, limit)<0) { in pl_check_limit()
671 pipeid->len, pipeid->s); in pl_check_limit()
674 pipe = pl_pipe_get(pipeid, 0); in pl_check_limit()
677 pipeid->len, pipeid->s); in pl_check_limit()
685 return pl_check(msg, pipeid); in pl_check_limit()
695 str pipeid = {0, 0}; in w_pl_check3() local
707 if(fixup_get_svalue(msg, (gparam_t*)p1pipe, &pipeid)!=0 in w_pl_check3()
708 || pipeid.s == 0) in w_pl_check3()
721 return pl_check_limit(msg, &pipeid, &alg, limit); in w_pl_check3()