From: Nickolai Zeldovich <kolya@mit.edu>
Date: Fri, 20 Jul 2001 16:59:43 +0000 (+0000)
Subject: rx-honor-only-client-initiated-debug-and-version-packets-to-prevent-loop-20010719
X-Git-Tag: BP-openafs-stable-1_2_x~87
X-Git-Url: https://git.openafs.org/?p=openafs.git;a=commitdiff_plain;h=902055cc97a8dd26a26af55778c0b3843de3cc70

rx-honor-only-client-initiated-debug-and-version-packets-to-prevent-loop-20010719


"This patch makes Rx only honor client-initiated Version and Debug
packets, and respond to them without the "client-initiated" flag.
All existing code sends Version and Debug queries from the client
with the appropriate flag set.  With the current code, one could
easily create a UDP packet loop between two Rx services."
---

diff --git a/src/rx/rx_packet.c b/src/rx/rx_packet.c
index 85136df..5cdf7de 100644
--- a/src/rx/rx_packet.c
+++ b/src/rx/rx_packet.c
@@ -1112,6 +1112,17 @@ struct rx_packet *rxi_ReceiveDebugPacket(ap, asocket, ahost, aport, istack)
     afs_int32 tl;
     struct rx_serverQueueEntry *np, *nqe;
 
+    /*
+     * Only respond to client-initiated Rx debug packets,
+     * and clear the client flag in the response.
+     */
+    if (ap->header.flags & RX_CLIENT_INITIATED) {
+	ap->header.flags = ap->header.flags & ~RX_CLIENT_INITIATED;
+	rxi_EncodePacketHeader(ap);
+    } else {
+	return ap;
+    }
+
     rx_packetread(ap, 0, sizeof(struct rx_debugIn), (char *)&tin);
     /* all done with packet, now set length to the truth, so we can 
      * reuse this packet */
@@ -1384,13 +1395,27 @@ struct rx_packet *rxi_ReceiveVersionPacket(ap, asocket, ahost, aport, istack)
   register struct rx_packet *ap;
   int istack;
 {
-  afs_int32 tl;
-	rx_packetwrite(ap, 0, 65, cml_version_number+4);
-        tl = ap->length;
+    afs_int32 tl;
+
+    /*
+     * Only respond to client-initiated version requests, and
+     * clear that flag in the response.
+     */
+    if (ap->header.flags & RX_CLIENT_INITIATED) {
+	char buf[66];
+
+	ap->header.flags = ap->header.flags & ~RX_CLIENT_INITIATED;
+	rxi_EncodePacketHeader(ap);
+	bzero(buf, sizeof(buf));
+	snprintf(buf, sizeof(buf), "%s", cml_version_number+4);
+	rx_packetwrite(ap, 0, 65, buf);
+	tl = ap->length;
 	ap->length = 65;
 	rxi_SendDebugPacket(ap, asocket, ahost, aport, istack);
-        ap->length = tl;
-	return ap;
+	ap->length = tl;
+    }
+
+    return ap;
 }