From 553f62329afd51f88b61c8ebcc8177b3760966f9 Mon Sep 17 00:00:00 2001
From: erdgeist <>
Date: Tue, 14 Jul 2009 21:22:02 +0000
Subject: Parse accesslist file by mmaping the whole thing and searching for
 lines by ourself. fgets is slooooooow on linux.

---
 ot_accesslist.c | 31 +++++++++++++++++++------------
 1 file changed, 19 insertions(+), 12 deletions(-)

(limited to 'ot_accesslist.c')

diff --git a/ot_accesslist.c b/ot_accesslist.c
index d991c4e..104a414 100644
--- a/ot_accesslist.c
+++ b/ot_accesslist.c
@@ -14,6 +14,7 @@
 #include "byte.h"
 #include "scan.h"
 #include "ip6.h"
+#include "mmap.h"
 
 /* Opentracker */
 #include "trackerlogic.h"
@@ -48,17 +49,15 @@ static int accesslist_addentry( ot_vector *al, ot_hash infohash ) {
 
 /* Read initial access list */
 static void accesslist_readfile( int sig ) {
-  FILE *    accesslist_filehandle;
   ot_hash   infohash;
   ot_vector accesslist_tmp;
   void     *olddata;
-  char      inbuf[512];
+  char     *map, *map_end, *read_offs;
+  size_t    maplen;
 
   if( sig != SIGHUP ) return;
-  
-  accesslist_filehandle = fopen( g_accesslist_filename, "r" );
 
-  if( accesslist_filehandle == NULL ) {
+  if( ( map = mmap_read( g_accesslist_filename, &maplen ) ) == NULL ) {
     char *wd = getcwd( NULL, 0 );
     fprintf( stderr, "Warning: Can't open accesslist file: %s (but will try to create it later, if necessary and possible).\nPWD: %s\n", g_accesslist_filename, wd );
     free( wd );
@@ -68,26 +67,34 @@ static void accesslist_readfile( int sig ) {
   /* Initialise an empty accesslist vector */
   memset( &accesslist_tmp, 0, sizeof(accesslist_tmp));
 
+  /* No use */
+  map_end = map + maplen - 41;
+  read_offs = map;
+
   /* We do ignore anything that is not of the form "^[:xdigit:]{40}[^:xdigit:].*" */
-  while( fgets( inbuf, sizeof(inbuf), accesslist_filehandle ) ) {
+  while( read_offs < map_end ) {
     int i;
     for( i=0; i<(int)sizeof(ot_hash); ++i ) {
-      int eger = 16 * scan_fromhex( inbuf[ 2*i ] ) + scan_fromhex( inbuf[ 1 + 2*i ] );
+      int eger = 16 * scan_fromhex( read_offs[ 2*i ] ) + scan_fromhex( read_offs[ 1 + 2*i ] );
       if( eger < 0 )
         continue;
       infohash[i] = eger;
     }
-    if( scan_fromhex( inbuf[ 40 ] ) >= 0 )
-      continue;
+
+    read_offs += 40;
 
     /* Append accesslist to accesslist vector */
-    accesslist_addentry( &accesslist_tmp, infohash );
+    if( scan_fromhex( *read_offs ) < 0 )
+      accesslist_addentry( &accesslist_tmp, infohash );
+
+    /* Find start of next line */
+    while( read_offs < map_end && *(read_offs++) != '\n' );
   }
 #ifdef _DEBUG
   fprintf( stderr, "Added %zd info_hashes to accesslist\n", accesslist_tmp.size );
 #endif
 
-  fclose( accesslist_filehandle );
+  mmap_unmap( map, maplen);
 
   /* Now exchange the accesslist vector in the least race condition prone way */
   accesslist.size = 0;
@@ -156,4 +163,4 @@ int accesslist_isblessed( ot_ip6 ip, ot_permissions permissions ) {
   return 0;
 }
 
-const char *g_version_accesslist_c = "$Source$: $Revision$\n";
\ No newline at end of file
+const char *g_version_accesslist_c = "$Source$: $Revision$\n";
-- 
cgit v1.2.3