pipelimit: fix dynamic pipe limit check

- proper add and check at the same time

modules/pipelimit/doc/pipelimit_admin.xml

@@ -302,7 +302,15 @@ modparam("pipelimit", "reply_reason", "Limiting")
 		<para>Meaning of the parameters is as follows:</para>
 		<itemizedlist>
 			<listitem><para>
-			<emphasis>name</emphasis> - the pseudovariable holding the pipe name.
+			<emphasis>name</emphasis> - the string or pseudovariable with the pipe name.
+			</para></listitem>
+			<listitem><para>
+			<emphasis>algorithm</emphasis> - the string or pseudovariable with the
+			algorithm. The values can be: taildrop, red, network or feedback - see
+			readme of ratelimit module for details on each algorithm.
+			</para></listitem>
+			<listitem><para>
+			<emphasis>limit</emphasis> - the integer or pseudovariable with the limit value.
 			</para></listitem>
 		</itemizedlist>
 		<para>
@@ -345,6 +353,14 @@ with unexpected retcode=$var(check_result)\n");
 		exit;
 	}
 ...
+	# perform pipe match for authenticated user
+	$var(limit) = 20;
+	if (!pl_check("$au", "traildrop", "$var(limit)")) {
+		pl_drop();
+		exit;
+	}
+...
+
 </programlisting>
 		</example>
 	</section>

modules/pipelimit/pipelimit.c

@@ -645,7 +645,7 @@ static int w_pl_check3(struct sip_msg* msg, char *p1pipe, char *p2alg,
 		return -1;
 	}
 
-	pipe = pl_pipe_get(&pipeid, 1);
+	pipe = pl_pipe_get(&pipeid, 0);
 	if(pipe==NULL)
 	{
 		LM_DBG("pipe not found [%.*s] - trying to add it\n",
@@ -656,7 +656,7 @@ static int w_pl_check3(struct sip_msg* msg, char *p1pipe, char *p2alg,
 				pipeid.len, pipeid.s);
 			return -2;
 		}
-		pipe = pl_pipe_get(&pipeid, 1);
+		pipe = pl_pipe_get(&pipeid, 0);
 		if(pipe==NULL)
 		{
 			LM_ERR("failed to retrieve pipe [%.*s]\n",
@@ -665,7 +665,7 @@ static int w_pl_check3(struct sip_msg* msg, char *p1pipe, char *p2alg,
 		}
 	}
 
-	return 1;
+	return pl_check(msg, &pipeid);
 }
 
 static int fixup_pl_check3(void** param, int param_no)

modules/pipelimit/pl_ht.c

@@ -240,7 +240,7 @@ pl_pipe_t* pl_pipe_get(str *pipeid, int mode)
 		if(pipeid->len==it->name.len 
 				&& strncmp(pipeid->s, it->name.s, pipeid->len)==0)
 		{
-			 /* lock_release(&_pl_pipes_ht->slots[idx].lock);*/
+			 if(mode==0) lock_release(&_pl_pipes_ht->slots[idx].lock);
 			 return it;
 		}
 		it = it->next;