[Asterisk-cvs] asterisk/channels chan_iax2.c,1.145,1.146

[markster at lists.digium.com]

Update of /usr/cvsroot/asterisk/channels
In directory mongoose.digium.com:/tmp/cvs-serv4343/channels

Modified Files:
	chan_iax2.c 
Log Message:
Fix lag in diverging clocks (bug #1696)


Index: chan_iax2.c
===================================================================
RCS file: /usr/cvsroot/asterisk/channels/chan_iax2.c,v
retrieving revision 1.145
retrieving revision 1.146
diff -u -d -r1.145 -r1.146
--- chan_iax2.c	25 May 2004 15:16:45 -0000	1.145
+++ chan_iax2.c	30 May 2004 22:22:49 -0000	1.146
@@ -1109,21 +1109,14 @@
 	/* Just deliver the packet by using queueing.  This is called by
 	  the IAX thread with the iaxsl lock held. */
 	struct iax_frame *fr = data;
-	unsigned int ts;
 	fr->retrans = -1;
 	if (iaxs[fr->callno] && !iaxs[fr->callno]->alreadygone) {
-		if (fr->af.frametype == AST_FRAME_IAX) {
-			/* We have to treat some of these packets specially because
-			   they're LAG measurement packets */
-			if (fr->af.subclass == IAX_COMMAND_LAGRQ) {
-				/* If we got a queued request, build a reply and send it */
+		if (fr->af.frametype == AST_FRAME_IAX && 
+		    fr->af.subclass == IAX_COMMAND_LAGRQ) {
+			/* send a lag response to a lag request that has
+			 * gone through our jitter buffer */
 				fr->af.subclass = IAX_COMMAND_LAGRP;
 				iax2_send(iaxs[fr->callno], &fr->af, fr->ts, -1, 0, 0, 0);
-			} else if (fr->af.subclass == IAX_COMMAND_LAGRP) {
-				/* This is a reply we've been given, actually measure the difference */
-				ts = calc_timestamp(iaxs[fr->callno], 0, &fr->af);
-				iaxs[fr->callno]->lag = ts - fr->ts;
-			}
 		} else {
 			iax2_queue_frame(fr->callno, &fr->af);
 		}
@@ -5234,15 +5227,22 @@
 					forward_command(iaxs[fr.callno], AST_FRAME_IAX, f.subclass, fr.ts, NULL, 0, -1);
 				} else {
 #endif				
-					/* A little strange -- We have to actually go through the motions of
-					   delivering the packet.  In the very last step, it will be properly
-					   handled by do_deliver */
 					f.src = "LAGRQ";
 					f.mallocd = 0;
 					f.offset = 0;
 					f.samples = 0;
 					iax_frame_wrap(&fr, &f);
-					schedule_delivery(iaxfrdup2(&fr), 1, updatehistory);
+					if(f.subclass == IAX_COMMAND_LAGRQ) {
+						/* A little strange -- We have to actually go through the motions of
+						delivering the packet.  In the very last step, it will be properly
+						handled by do_deliver */
+					    schedule_delivery(iaxfrdup2(&fr), 1, updatehistory);
+					} else {
+					    unsigned int ts;
+					    /* This is a reply we've been given, actually measure the difference */
+					    ts = calc_timestamp(iaxs[fr.callno], 0, &fr.af);
+					    iaxs[fr.callno]->lag = ts - fr.ts;
+					}
 #ifdef BRIDGE_OPTIMIZATION
 				}
 #endif