int handle_sync(struct packet* new, const struct const_packet* old, struct hcon* h1, struct hcon* h2);
int handle_syncack(struct packet* new, const struct const_packet* old, struct hcon* h1, struct hcon* h2);
int handle_data(struct packet* new, const struct const_packet* old, struct hcon* h1, struct hcon* h2);
-int parse_options(const u_char* opt_start, int len, struct hcon* A, struct hcon* B);
-int process_feature(const u_char* feat, int len, int confirm, int L, struct hcon* A, struct hcon* B);
-void ack_vect2sack(struct hcon *seq, struct tcphdr *tcph, u_char* tcpopts, u_char* dccphdr,
- __be32 dccpack, struct hcon* o_hcn);
+int parse_options(const u_char* opt_start, int len,
+ const struct const_packet* pkt, struct hcon* A, struct hcon* B);
+int process_feature(const u_char* feat, int len, int confirm, int L,
+ const struct const_packet* pkt, struct hcon* A, struct hcon* B);
+void ack_vect2sack(struct hcon *seq, struct tcphdr *tcph,
+ u_char* tcpopts, u_char* dccphdr, d_seq_num dccpack, struct hcon* o_hcn);
void version();
void usage();
struct dccp_hdr_ext *dccphex;
struct hcon *h1=NULL;
struct hcon *h2=NULL;
+ char buf1[100];
+ char buf2[100];
/*Safety checks*/
if(!new || !old || !new->data || !old->data || !new->h || !old->h){
}
/*Get Hosts*/
- if(get_host(new->src_id, new->dest_id, new->id_len,
- dccph->dccph_sport, dccph->dccph_dport, &h1, &h2)){
+ if(get_host(new->src_id, new->dest_id, new->id_len, dccph->dccph_sport,
+ dccph->dccph_dport, dccph->dccph_type,&h1, &h2)){
dbgprintf(0,"Error: Can't Get Hosts!\n");
return 0;
}
dbgprintf(0, "Error: Can't Get Hosts!\n");
return 0;
}
+ if(h1->state==IGNORE || h2->state==IGNORE){
+ if(old->print_id){
+ dbgprintf(2,"Ignoring packet between %s:%i and %s:%i\n",
+ old->print_id(buf1,100,old->src_id,old->id_len),ntohs(dccph->dccph_sport),
+ old->print_id(buf2,100,old->dest_id,old->id_len), ntohs(dccph->dccph_dport));
+ }else{
+ dbgprintf(2,"Ignoring packet between %i and %i\n",
+ ntohs(dccph->dccph_sport), ntohs(dccph->dccph_dport));
+ }
+ return 0;
+ }
/*set TCP standard features*/
tcph->source=dccph->dccph_sport;
/*Process DCCP Options*/
dccpopt=old->data + sizeof(struct dccp_hdr) + sizeof(struct dccp_hdr_ext)+sizeof(struct dccp_hdr_request);
optlen=dccph->dccph_doff*4 - sizeof(struct dccp_hdr)-sizeof(struct dccp_hdr_ext)-sizeof(struct dccp_hdr_request);
- if(!parse_options(dccpopt,optlen,h1,h2)){
+ if(!parse_options(dccpopt,optlen,old,h1,h2)){
return 0;
}
sizeof(struct dccp_hdr_ack_bits) + sizeof(struct dccp_hdr_request);
optlen=dccph->dccph_doff*4 - sizeof(struct dccp_hdr) - sizeof(struct dccp_hdr_ext)
- sizeof(struct dccp_hdr_ack_bits) - sizeof(struct dccp_hdr_request);
- if(!parse_options(dccpopt,optlen,h1,h2)){
+ if(!parse_options(dccpopt,optlen,old,h1,h2)){
return 0;
}
/*Process DCCP Options*/
dccpopt=old->data + sizeof(struct dccp_hdr) + sizeof(struct dccp_hdr_ext) + sizeof(struct dccp_hdr_ack_bits);
optlen=dccph->dccph_doff*4 - sizeof(struct dccp_hdr) - sizeof(struct dccp_hdr_ext) - sizeof(struct dccp_hdr_ack_bits);
- if(!parse_options(dccpopt,optlen,h1,h2)){
+ if(!parse_options(dccpopt,optlen,old,h1,h2)){
return 0;
}
/*Process DCCP Options*/
dccpopt=old->data + sizeof(struct dccp_hdr) + sizeof(struct dccp_hdr_ext) + sizeof(struct dccp_hdr_ack_bits);
optlen=dccph->dccph_doff*4 - sizeof(struct dccp_hdr) - sizeof(struct dccp_hdr_ext) - sizeof(struct dccp_hdr_ack_bits);
- if(!parse_options(dccpopt,optlen,h1,h2)){
+ if(!parse_options(dccpopt,optlen,old,h1,h2)){
return 0;
}
/*Process DCCP Options*/
dccpopt=old->data + sizeof(struct dccp_hdr) + sizeof(struct dccp_hdr_ext) + sizeof(struct dccp_hdr_ack_bits);
optlen=dccph->dccph_doff*4 - sizeof(struct dccp_hdr) - sizeof(struct dccp_hdr_ext) - sizeof(struct dccp_hdr_ack_bits);
- if(!parse_options(dccpopt,optlen,h1,h2)){
+ if(!parse_options(dccpopt,optlen,old,h1,h2)){
return 0;
}
/*Process DCCP Options*/
dccpopt=old->data + sizeof(struct dccp_hdr) + sizeof(struct dccp_hdr_ext) + sizeof(struct dccp_hdr_ack_bits);
optlen=dccph->dccph_doff*4 - sizeof(struct dccp_hdr) - sizeof(struct dccp_hdr_ext) - sizeof(struct dccp_hdr_ack_bits);
- if(!parse_options(dccpopt,optlen,h1,h2)){
+ if(!parse_options(dccpopt,optlen,old,h1,h2)){
return 0;
}
/*Process DCCP Options*/
dccpopt=old->data + sizeof(struct dccp_hdr) + sizeof(struct dccp_hdr_ext) + sizeof(struct dccp_hdr_ack_bits);
optlen=dccph->dccph_doff*4 - sizeof(struct dccp_hdr) - sizeof(struct dccp_hdr_ext) - sizeof(struct dccp_hdr_ack_bits);
- if(!parse_options(dccpopt,optlen,h1,h2)){
+ if(!parse_options(dccpopt,optlen,old,h1,h2)){
return 0;
}
/*Process DCCP Options*/
dccpopt=old->data + sizeof(struct dccp_hdr) + sizeof(struct dccp_hdr_ext) + sizeof(struct dccp_hdr_ack_bits);
optlen=dccph->dccph_doff*4 - sizeof(struct dccp_hdr) - sizeof(struct dccp_hdr_ext) - sizeof(struct dccp_hdr_ack_bits);
- if(!parse_options(dccpopt,optlen,h1,h2)){
+ if(!parse_options(dccpopt,optlen,old,h1,h2)){
return 0;
}
/*Process DCCP Options*/
dccpopt=old->data + sizeof(struct dccp_hdr) + sizeof(struct dccp_hdr_ext) + sizeof(struct dccp_hdr_ack_bits);
optlen=dccph->dccph_doff*4 - sizeof(struct dccp_hdr) - sizeof(struct dccp_hdr_ext) - sizeof(struct dccp_hdr_ack_bits);
- if(!parse_options(dccpopt,optlen,h1,h2)){
+ if(!parse_options(dccpopt,optlen,old,h1,h2)){
return 0;
}
/*Process DCCP Options*/
dccpopt=old->data + sizeof(struct dccp_hdr) + sizeof(struct dccp_hdr_ext);
optlen=dccph->dccph_doff*4 - sizeof(struct dccp_hdr) - sizeof(struct dccp_hdr_ext);
- if(!parse_options(dccpopt,optlen,h1,h2)){
+ if(!parse_options(dccpopt,optlen,old,h1,h2)){
return 0;
}
return 1;
}
-int parse_options(const u_char* opt_start, int len, struct hcon* A, struct hcon* B)
+int parse_options(const u_char* opt_start, int len, const struct const_packet* pkt,
+ struct hcon* A, struct hcon* B)
{
int optlen;
int length;
const u_char* opt;
+ char buf1[100];
+ char buf2[100];
/*setup pointer to DCCP options and determine how long the options are*/
optlen=len;
/*Ack Vector Option*/
if(*opt==38 || *opt==39){
-
+ if(B->type==UNKNOWN){
+ B->type=CCID2;
+ if(pkt->print_id){
+ dbgprintf(1,"Half-connection from %s:%i to %s:%i probably using CCID 2\n",
+ pkt->print_id(buf1,100,pkt->dest_id,pkt->id_len),ntohs(B->port),
+ pkt->print_id(buf2,100,pkt->src_id,pkt->id_len), ntohs(A->port));
+ }else{
+ dbgprintf(1,"Half-connection from port %i to %i probably using CCID 2\n",
+ ntohs(B->port),ntohs(A->port));
+ }
+ }
}
/*NDP Count Option*/
if(*opt==37){
-
+ if(B->type==UNKNOWN){
+ B->type=CCID3;
+ if(pkt->print_id){
+ dbgprintf(1,"Half-connection from %s:%i to %s:%i probably using CCID 3\n",
+ pkt->print_id(buf1,100,pkt->dest_id,pkt->id_len),ntohs(B->port),
+ pkt->print_id(buf2,100,pkt->src_id,pkt->id_len), ntohs(A->port));
+ }else{
+ dbgprintf(1,"Half-connection from port %i to %i probably using CCID 3\n",
+ ntohs(B->port),ntohs(A->port));
+ }
+ }
}
/*Feature negotation*/
if(*opt==32){
/*Change L*/
- if(!process_feature(opt+2,length-2,FALSE,TRUE,A,B)){
+ if(!process_feature(opt+2,length-2,FALSE,TRUE,pkt,A,B)){
return 0;
}
}
if(*opt==33){
/*Confirm L*/
- if(!process_feature(opt+2,length-2,TRUE,TRUE,A,B)){
+ if(!process_feature(opt+2,length-2,TRUE,TRUE,pkt,A,B)){
return 0;
}
}
if(*opt==34){
/*Change R*/
- if(!process_feature(opt+2,length-2,FALSE,FALSE,A,B)){
+ if(!process_feature(opt+2,length-2,FALSE,FALSE,pkt,A,B)){
return 0;
}
}
if(*opt==35){
/*Confirm R*/
- if(!process_feature(opt+2,length-2,TRUE,FALSE,A,B)){
+ if(!process_feature(opt+2,length-2,TRUE,FALSE,pkt,A,B)){
return 0;
}
}
return 1;
}
-int process_feature(const u_char* feat, int len, int confirm, int L, struct hcon* A, struct hcon* B)
+int process_feature(const u_char* feat, int len, int confirm, int L,
+ const struct const_packet* pkt, struct hcon* A, struct hcon* B)
{
const u_char* val;
int ccid;
+ char buf1[100];
+ char buf2[100];
val=feat+1;
switch(*feat){
case 1:
/*CCID*/
- if(confirm==FALSE){
+ if(confirm==TRUE){
switch(*val){
case 2:
ccid=CCID2;
}
if(L==TRUE){
B->type=ccid;
+ if(pkt->print_id){
+ dbgprintf(1,"Half-connection from %s:%i to %s:%i using CCID %i\n",
+ pkt->print_id(buf1,100,pkt->dest_id,pkt->id_len),ntohs(B->port),
+ pkt->print_id(buf2,100,pkt->src_id,pkt->id_len), ntohs(A->port), *val);
+ }else{
+ dbgprintf(1,"Half-connection from port %i to %i using CCID %i\n",
+ ntohs(B->port),ntohs(A->port), *val);
+ }
}else{
A->type=ccid;
+ if(pkt->print_id){
+ dbgprintf(1,"Half-connection from %s:%i to %s:%i using CCID %i\n",
+ pkt->print_id(buf1,100,pkt->src_id,pkt->id_len),ntohs(A->port),
+ pkt->print_id(buf2,100,pkt->dest_id,pkt->id_len), ntohs(B->port), *val);
+ }else{
+ dbgprintf(1,"Half-connection from port %i to %i using CCID %i\n",
+ ntohs(A->port),ntohs(B->port), *val);
+ }
}
}
break;
case 2:
/*Short sequence nums*/
- if(confirm==FALSE && *val==1){
- dbgprintf(0,"Error! DCCP is trying to turn on short sequence numbers! We do not support this!!\n");
- exit(1);
+ if(confirm==TRUE && *val==1){
+ B->type=IGNORE;
+ A->type=IGNORE;
+ dbgprintf(0,"Error: DCCP is trying to turn on short sequence numbers\n"
+ " for the connection between %i and %i. We do not support this.\n"
+ " This connection will be ignored.",ntohs(A->port),ntohs(B->port));
+ return 0;
}
break;
}
/*Ack Vector to SACK Option*/
void ack_vect2sack(struct hcon *hcn, struct tcphdr *tcph, u_char* tcpopts, u_char* dccphdr,
- __be32 dccpack, struct hcon* o_hcn)
+ d_seq_num dccpack, struct hcon* o_hcn)
{
int hdrlen=((struct dccp_hdr*)dccphdr)->dccph_doff*4;
int optlen;
int len;
int tmp;
- __be32 bp;
+ d_seq_num bp;
u_char* temp;
u_char* opt;
u_char* cur;
void version()
{
- dbgprintf(0, "dccp2tcp version %.1f\nCopyright (C) %i Samuel Jero <sj323707@ohio.edu>\n", DCCP2TCP_VERSION,COPYRIGHT_YEAR);
+ dbgprintf(0, "dccp2tcp version %.1f\n",DCCP2TCP_VERSION);
+ dbgprintf(0, "Copyright (C) %i Samuel Jero <sj323707@ohio.edu>\n",COPYRIGHT_YEAR);
dbgprintf(0, "This program comes with ABSOLUTELY NO WARRANTY.\n");
- dbgprintf(0, "This is free software, and you are welcome to\nredistribute it under certain conditions.\n");
+ dbgprintf(0, "This is free software, and you are welcome to\n");
+ dbgprintf(0, "redistribute it under certain conditions.\n");
exit(0);
}
projects / dccp2tcp / blobdiff