<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 TRANSITIONAL//EN">

<HTML>

<HEAD>

  <META HTTP-EQUIV="Content-Type" CONTENT="text/html; CHARSET=UTF-8">

  <META NAME="GENERATOR" CONTENT="GtkHTML/4.2.3">

</HEAD>

<BODY>

Hi,<BR>

<BR>

All that mqueue does is queue a string.<BR>

<BR>

When the request arrives I suspend it with t_suspend().&nbsp; I then queue the index and label returned from the suspend operation with mqueue.<BR>

<BR>

When I pull an item off the mqueue I get the index and label of a previously suspended transaction.&nbsp; I can use t_continue() to resume processing of that SIP request.<BR>

<BR>

So by having multiple queues, distributing across those queues according to priority, and then pulling stuff off the queues in the right order you can:<BR>

1) Receive requests on Kamailio in the order they arrive<BR>

2) But do any complex processing of them in an order based on whatever (arbitrary) priorities you choose<BR>

<BR>

Regards,<BR>

<BR>

Peter<BR>

<BR>

On Tue, 2012-05-01 at 15:30 +0530, Vineet Menon wrote:<BR>

<BLOCKQUOTE TYPE=CITE>

    Peter,<BR>

    You are telling about this module mqueue module, right....<BR>

    if yes, then I understood the module incorrectly.<BR>

    <BR>

    I will get back after I understand it sufficiently....btw any other place to look for the info apart from the sources??<BR>

    <BR>

    <BR>

    Regards,<BR>

    <BR>

    Vineet Menon<BR>

    <BR>

    <BR>

    <BR>

    <BR>

</BLOCKQUOTE>

<BLOCKQUOTE TYPE=CITE>

    On 1 May 2012 15:21, Peter Dunkley &lt;<A HREF="mailto:peter.dunkley@crocodile-rcs.com">peter.dunkley@crocodile-rcs.com</A>&gt; wrote:

</BLOCKQUOTE>

<BLOCKQUOTE TYPE=CITE>

    <BLOCKQUOTE>

        As soon as messages are pulled from the receive buffer they are suspended and queued.&nbsp; So it is the minimum processing required to pull them into Kamailio.&nbsp; The let us say you have three queues.&nbsp; Priority 1 messages are queued with queue 1, priority 2 in queue 2, priority 3 in queue 3.&nbsp; Instead of dequeuing the queues in separate processes (as I do) you dequeue them in one process.&nbsp; You empty queue 1 first, then queue 2, then queue 3.<BR>

        <BR>

        Won't that do what you want?

    </BLOCKQUOTE>

</BLOCKQUOTE>

<BLOCKQUOTE TYPE=CITE>

    <BLOCKQUOTE>

        <BR>

        <BR>

        On Tue, 2012-05-01 at 14:55 +0530, Vineet Menon wrote:<BR>

        <BLOCKQUOTE TYPE=CITE>

            @peter,<BR>

            I don't get it?? Your module mqueue seems to be doing IPC. What I want to do is prioratize messages that come to the server according to their behaviour...<BR>

            What I want is to have n queue : <BR>

            <BR>

            &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; _______________________________________________________<BR>

            &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Prio 1&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |<BR>

            &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |_______________________________________________________|<BR>

            &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Prio 2&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |<BR>

            &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |_______________________________________________________|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; _______<BR>

            ______ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Prio 3&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp; OUT&nbsp; \<BR>

            |&nbsp;&nbsp; IN&nbsp;&nbsp;&nbsp; \ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |_______________________________________________________|&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |______ /<BR>

            |______/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; / /<BR>

            &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; \ \<BR>

            &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; / /&nbsp; <BR>

            &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Prio n&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |<BR>

            &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |_______________________________________________________|<BR>

            <BR>

            IN would come from the OS (messages which has been identified as SIP messages)<BR>

            OUT would go to the kamailio processing part. i.e. it would now be actually reach the kamailio core.<BR>

            <BR>

            Regards,<BR>

            <BR>

            Vineet Menon<BR>

            <BR>

            <BR>

            <BR>

            <BR>

            On 1 May 2012 14:23, Peter Dunkley &lt;<A HREF="mailto:peter.dunkley@crocodile-rcs.com">peter.dunkley@crocodile-rcs.com</A>&gt; wrote:<BR>

            <BLOCKQUOTE>

                Hi,<BR>

                <BR>

                I have been using a configuration file based system to share certain SIP requests across different queues for handling by different processes.&nbsp; Such a scheme could be adapted for prioritisation.<BR>

                <BR>

                I have posted several configuration fragments for this on the list so you should find them if you look in the archives.&nbsp; My email from 28 March (at around 14:44) is probably the closest to what you are wanting.<BR>

                <BR>

                Regards,<BR>

                <BR>

                Peter <BR>

                <BR>

                <BR>

                On Tue, 2012-05-01 at 13:59 +0530, Vineet Menon wrote:<BR>

                <BLOCKQUOTE TYPE=CITE>

                    Hi Olle,<BR>

                    <BR>

                    What I want to do is test a &quot;hypothesis&quot; for congestion control using prioritized scheduling of messages....<BR>

                    But thx for that input regarding the newer message queue module....i'll look into it...<BR>

                    <BR>

                    <BR>

                    Regards,<BR>

                    <BR>

                    Vineet Menon<BR>

                    <BR>

                    <BR>

                    <BR>

                    <BR>

                    On 1 May 2012 13:18, Olle E. Johansson &lt;<A HREF="mailto:oej@edvina.net">oej@edvina.net</A>&gt; wrote:<BR>

                    <BLOCKQUOTE>

                        <BR>

                        1 maj 2012 kl. 09:39 skrev Vineet Menon: <BR>

                        <BR>

                        &gt; Hi,<BR>

                        &gt;<BR>

                        &gt; I am new to kamailio module devel...<BR>

                        &gt; I want to test a new scheduling for SIP messages... Can i do that with kamailio modules? or I should go for something else? probably kamailio core??<BR>

                        <BR>

                        <BR>

                        Can you elaborate a bit more? What do you mean with scheduling for SIP messages?<BR>

                        <BR>

                        We have a few new modules where you can queue messages for later processing and time their transmission. Check those first.<BR>

                        <BR>

                        /O<BR>

                        _______________________________________________<BR>

                        sr-dev mailing list<BR>

                        <A HREF="mailto:sr-dev@lists.sip-router.org">sr-dev@lists.sip-router.org</A><BR>

                        <A HREF="http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-dev">http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-dev</A> <BR>

                    </BLOCKQUOTE>

                    <BR>

<PRE>

_______________________________________________

sr-dev mailing list

<A HREF="mailto:sr-dev@lists.sip-router.org">sr-dev@lists.sip-router.org</A>

<A HREF="http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-dev">http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-dev</A>

</PRE>

                </BLOCKQUOTE>

                <BR>

                <BR>

                <TABLE CELLSPACING="0" CELLPADDING="0" WIDTH="100%">

<TR>

<TD>

<PRE>

-- 

Peter Dunkley

Technical Director

Crocodile RCS Ltd

</PRE>

</TD>

</TR>

</TABLE>

                <BR>

                _______________________________________________<BR>

                sr-dev mailing list<BR>

                <A HREF="mailto:sr-dev@lists.sip-router.org">sr-dev@lists.sip-router.org</A><BR>

                <A HREF="http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-dev">http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-dev</A><BR>

                <BR>

            </BLOCKQUOTE>

            <BR>

<PRE>

_______________________________________________

sr-dev mailing list

<A HREF="mailto:sr-dev@lists.sip-router.org">sr-dev@lists.sip-router.org</A>

<A HREF="http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-dev">http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-dev</A>

</PRE>

        </BLOCKQUOTE>

        <BR>

        <TABLE CELLSPACING="0" CELLPADDING="0" WIDTH="100%">

<TR>

<TD>

<PRE>

-- 

Peter Dunkley

Technical Director

Crocodile RCS Ltd

</PRE>

</TD>

</TR>

</TABLE>

    </BLOCKQUOTE>

</BLOCKQUOTE>

<BLOCKQUOTE TYPE=CITE>

    <BLOCKQUOTE>

        <BR>

        _______________________________________________<BR>

        sr-dev mailing list<BR>

        <A HREF="mailto:sr-dev@lists.sip-router.org">sr-dev@lists.sip-router.org</A><BR>

        <A HREF="http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-dev">http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-dev</A><BR>

        <BR>

    </BLOCKQUOTE>

</BLOCKQUOTE>

<BLOCKQUOTE TYPE=CITE>

    <BR>

<PRE>

_______________________________________________

sr-dev mailing list

<A HREF="mailto:sr-dev@lists.sip-router.org">sr-dev@lists.sip-router.org</A>

<A HREF="http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-dev">http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-dev</A>

</PRE>

</BLOCKQUOTE>

<BR>

<TABLE CELLSPACING="0" CELLPADDING="0" WIDTH="100%">

<TR>

<TD>

<PRE>

-- 

Peter Dunkley

Technical Director

Crocodile RCS Ltd

</PRE>

</TD>

</TR>

</TABLE>

</BODY>

</HTML>