summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorTim Angus <tim@ngus.net>2006-09-23 13:47:07 +0000
committerTim Angus <tim@ngus.net>2006-09-23 13:47:07 +0000
commitbea6a74b8d5dc84e1c03cbe4f14498334801bd55 (patch)
tree008d47574c0fe70ff36ab294babb364a658f8969 /src
parenta92ed49c40ee36c47e6fc5ab3d1e0b9f0a9ecd68 (diff)
* Hack the master server up to ignore a list of abusive IP addresses
Diffstat (limited to 'src')
-rw-r--r--src/master/master.c155
1 files changed, 155 insertions, 0 deletions
diff --git a/src/master/master.c b/src/master/master.c
index bd93b0b8..f58f515d 100644
--- a/src/master/master.c
+++ b/src/master/master.c
@@ -520,6 +520,157 @@ static void cleanUp( int signal )
exitNow = qtrue;
}
+#define ADDRESS_LENGTH 16
+static const char *ignoreFile = "ignore.txt";
+
+typedef struct
+{
+ char address[ ADDRESS_LENGTH ]; // Dotted quad
+} ignoreAddress_t;
+
+#define PARSE_INTERVAL 60 // seconds
+
+static time_t lastParseTime = 0;
+static int numIgnoreAddresses = 0;
+static ignoreAddress_t *ignoreAddresses = NULL;
+
+/*
+====================
+parseIgnoreAddress
+====================
+*/
+static qboolean parseIgnoreAddress( void )
+{
+ int numAllocIgnoreAddresses = 1;
+ FILE *f = NULL;
+ int i;
+
+ // Only reparse periodically
+ if( crt_time - lastParseTime < PARSE_INTERVAL )
+ return qtrue;
+
+ lastParseTime = time( NULL );
+
+ // Free existing list
+ if( ignoreAddresses != NULL )
+ {
+ free( ignoreAddresses );
+ ignoreAddresses = NULL;
+ }
+
+ numIgnoreAddresses = 0;
+ ignoreAddresses = malloc( sizeof( ignoreAddress_t ) * numAllocIgnoreAddresses );
+
+ // Alloc failed, fail parsing
+ if( ignoreAddresses == NULL )
+ return qfalse;
+
+ f = fopen( ignoreFile, "r" );
+
+ if( !f )
+ {
+ free( ignoreAddresses );
+ ignoreAddresses = NULL;
+ return qfalse;
+ }
+
+ while( !feof( f ) )
+ {
+ char c;
+ char buffer[ ADDRESS_LENGTH ];
+
+ i = 0;
+
+ // Skip whitespace
+ do
+ {
+ c = fgetc( f );
+ }
+ while( c != EOF && isspace( c ) );
+
+ if( c != EOF )
+ {
+ do
+ {
+ if( i >= ADDRESS_LENGTH )
+ {
+ buffer[ i - 1 ] = '\0';
+ break;
+ }
+
+ buffer[ i ] = c;
+
+ if( isspace( c ) )
+ {
+ buffer[ i ] = '\0';
+ break;
+ }
+
+ i++;
+ } while( ( c = fgetc( f ) ) != EOF );
+
+ strcpy( ignoreAddresses[ numIgnoreAddresses ].address, buffer );
+
+ numIgnoreAddresses++;
+
+ // Make list bigger
+ if( numIgnoreAddresses >= numAllocIgnoreAddresses )
+ {
+ ignoreAddress_t *new;
+
+ numAllocIgnoreAddresses *= 2;
+ new = realloc( ignoreAddresses,
+ sizeof( ignoreAddress_t ) * numAllocIgnoreAddresses );
+
+ // Alloc failed, fail parsing
+ if( new == NULL )
+ {
+ fclose( f );
+ free( ignoreAddresses );
+ ignoreAddresses = NULL;
+ return qfalse;
+ }
+
+ ignoreAddresses = new;
+ }
+ }
+ }
+
+ fclose( f );
+
+ return qtrue;
+}
+
+/*
+====================
+ignoreAddress
+
+Check whether or not to ignore a specific address
+====================
+*/
+static qboolean ignoreAddress( const char *address )
+{
+ int i;
+
+ if( !parseIgnoreAddress( ) )
+ {
+ // Couldn't parse, allow the address
+ return qfalse;
+ }
+
+ for( i = 0; i < numIgnoreAddresses; i++ )
+ {
+ if( strcmp( address, ignoreAddresses[ i ].address ) == 0 )
+ break;
+ }
+
+ // It matched
+ if( i < numIgnoreAddresses )
+ return qtrue;
+
+ return qfalse;
+}
+
/*
====================
main
@@ -588,6 +739,10 @@ int main (int argc, const char* argv [])
continue;
}
+ // Ignore abusers
+ if( ignoreAddress( inet_ntoa( address.sin_addr ) ) )
+ continue;
+
// If we may have to print something, rebuild the peer address buffer
if (max_msg_level != MSG_NOPRINT)
snprintf (peer_address, sizeof (peer_address), "%s:%hu",