d4708/opentracker
1
0
Fork 0
mirror of git://erdgeist.org/opentracker synced 2025-01-14 08:50:10 +00:00
Code Issues Projects Releases Wiki Activity

Begun printf debugging

Browse Source
This commit is contained in:
denis 2006-12-08 22:37:44 +00:00
parent 62a9b02532
commit dc025776dd
2 changed files with 29 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Makefile
View File

@ -1,6 +1,6 @@
CC?=gcc CC?=gcc
CFLAGS+=-I../libowfat -Wall -O2 -pipe CFLAGS+=-I../libowfat -Wall -pipe -g -ggdb
LDFLAGS+=-L../libowfat/ -lowfat -s LDFLAGS+=-L../libowfat/ -lowfat
SOURCES=opentracker.c trackerlogic.c scan_urlencoded_query.c SOURCES=opentracker.c trackerlogic.c scan_urlencoded_query.c

41
opentracker.c
View File

@ -13,6 +13,8 @@
#include <unistd.h> #include <unistd.h>
#include <stdlib.h> #include <stdlib.h>
#include <errno.h> #include <errno.h>
#include <signal.h>
#include <stdio.h>
#include "trackerlogic.h" #include "trackerlogic.h"
#include "scan_urlencoded_query.h" #include "scan_urlencoded_query.h"
@ -109,7 +111,7 @@ void httpresponse(struct http_data* h,int64 s)
ot_torrent torrent; ot_torrent torrent;
ot_hash *hash = NULL; ot_hash *hash = NULL;
unsigned long numwant; unsigned long numwant;
int compact; int compact,x;
size_t reply_size = 0; size_t reply_size = 0;
array_cat0(&h->r); array_cat0(&h->r);
@ -130,40 +132,40 @@ e400:
if (*d!=' ') goto e400; if (*d!=' ') goto e400;
*d=0; *d=0;
if (c[0]!='/') goto e404; if (c[0]!='/') goto e404;
while (c[1]=='/') ++c; while (*c=='/') ++c;
switch( scan_urlencoded_query( &c, data = c, SCAN_PATH ) ) { switch( x = scan_urlencoded_query( &c, data = c, SCAN_PATH ) )
{
case 6: /* scrape ? */ case 6: /* scrape ? */
if (!byte_diff(c,6,"scrape")) if (byte_diff(data,6,"scrape"))
goto e404; goto e404;
break; break;
case 8: case 8:
if( !byte_diff(c,8,"announce")) if( byte_diff(data,8,"announce"))
goto e404; goto e404;
byte_copy( peer.ip, 4, h->ip ); byte_copy( peer.ip, 4, h->ip );
peer.port = 6881; peer.port = 6881;
numwant = 50; numwant = 50;
compact = 1; compact = 1;
while( 1 ) { while( 1 ) {
switch( scan_urlencoded_query( &c, data = c, SCAN_SEARCHPATH_PARAM ) ) { switch( x=scan_urlencoded_query( &c, data = c, SCAN_SEARCHPATH_PARAM ) ) {
case -1: /* error */ case -1: /* error */
goto e404; goto e404;
case 4: case 4:
if(!byte_diff(c,4,"port")) if(!byte_diff(data,4,"port"))
/* scan int */ c; /* scan int */ c;
else if(!byte_diff(c,4,"left")) else if(!byte_diff(data,4,"left"))
/* scan int */ c; /* scan int */ c;
break; break;
case 7: case 7:
if(!byte_diff(c,7,"numwant")) if(!byte_diff(data,7,"numwant"))
/* scan int */ c; /* scan int */ c;
else if(!byte_diff(c,7,"compact")) else if(!byte_diff(data,7,"compact"))
/* scan flag */ c; /* scan flag */ c;
break; break;
case 9: case 9:
if(byte_diff(c,9,"info_hash")) if(byte_diff(data,9,"info_hash"))
continue; continue;
/* ignore this, when we have less than 20 bytes */ /* ignore this, when we have less than 20 bytes */
switch( scan_urlencoded_query( &c, data = c, SCAN_SEARCHPATH_VALUE ) ) { switch( scan_urlencoded_query( &c, data = c, SCAN_SEARCHPATH_VALUE ) ) {
@ -171,11 +173,13 @@ e400:
goto e404; goto e404;
case 20: case 20:
hash = (ot_hash*)data; /* Fall through intended */ hash = (ot_hash*)data; /* Fall through intended */
printf("hash: %s\n",*hash);
default: default:
continue; continue;
} }
default: default:
continue; printf("blub %i\n",x);
break;
} }
} }
@ -196,6 +200,7 @@ e500:
} }
break; break;
default: /* neither scrape nor announce */ default: /* neither scrape nor announce */
printf("blub %i\n",x);
e404: e404:
httperror(h,"404 Not Found","No such file or directory."); httperror(h,"404 Not Found","No such file or directory.");
goto bailout; goto bailout;
@ -218,6 +223,11 @@ bailout:
io_wantwrite(s); io_wantwrite(s);
} }
void graceful( int s ) {
signal( SIGINT, SIG_IGN );
deinit_logic();
}
int main() int main()
{ {
int s=socket_tcp6(); int s=socket_tcp6();
@ -225,7 +235,7 @@ int main()
char ip[16]; char ip[16];
uint16 port; uint16 port;
if (socket_bind6_reuse(s,V6any,8000,0)==-1) if (socket_bind6_reuse(s,V6any,6969,0)==-1)
panic("socket_bind6_reuse"); panic("socket_bind6_reuse");
if (socket_listen(s,16)==-1) if (socket_listen(s,16)==-1)
@ -234,6 +244,9 @@ int main()
if (!io_fd(s)) if (!io_fd(s))
panic("io_fd"); panic("io_fd");
signal( SIGINT, graceful );
init_logic( "." );
io_wantread(s); io_wantread(s);
for (;;) for (;;)