Changeset 609 for trunk/pdns/pdns/pdns_recursor.cc

Timestamp:

03/21/06 22:39:36 (7 years ago)

Author:

ahu

Message:

add sizing of UDP receive buffers, plus fix (somewhat) the latency
measurements

Files:

• trunk/pdns/pdns/pdns_recursor.cc (modified) (5 diffs)

trunk/pdns/pdns/pdns_recursor.cc

@@ -179 +179 @@
 }
 
+void setReceiveBuffer(int fd, uint32_t size)
+{
+  uint32_t psize;
+  socklen_t len;
+  getsockopt(fd, SOL_SOCKET, SO_RCVBUF, (char*)&psize, &len);
+  if (setsockopt(fd, SOL_SOCKET, SO_RCVBUF, (char*)&size, sizeof(size)) < 0 )
+    L<<Logger::Error<<"Warning: unable to raise socket buffer size to "<<size<<": "<<strerror(errno)<<"\n";
+}
+
+
 static void writePid(void)
 {
@@ -345 +355 @@
 
     uint64_t newLat=(uint64_t)(spent*1000000);
-    g_stats.avgLatencyUsec=0.01*g_stats.avgLatencyUsec + (1-0.01)*newLat;
+    g_stats.avgLatencyUsec=(1-0.0001)*g_stats.avgLatencyUsec + 0.0001*newLat;
     delete dc;
   }
@@ -371 +381 @@
   if(d_clientsock<0) 
     throw AhuException("Making a socket for resolver: "+stringerror());
-  
+  setReceiveBuffer(d_clientsock, 250000);  
   struct sockaddr_in sin;
   memset((char *)&sin,0, sizeof(sin));
@@ -393 +403 @@
 
   Utility::setNonBlocking(d_clientsock);
+
   L<<Logger::Error<<"Sending UDP queries from "<<inet_ntoa(sin.sin_addr)<<":"<< ntohs(sin.sin_port)  <<endl;
 }
@@ -450 +461 @@
     if(fd<0) 
       throw AhuException("Making a server socket for resolver: "+stringerror());
-  
+    setReceiveBuffer(fd, 250000);
     struct sockaddr_in sin;
     memset((char *)&sin,0, sizeof(sin));