| #include<stdio.h> |
| #include<string.h> |
| #include<stdlib.h> |
| #include <unistd.h> |
| #include <getopt.h> |
| #include <sys/time.h> |
| #include <assert.h> |
| #ifdef HAVE_CONFIG_H |
| #include <config.h> |
| #endif |
| |
| |
| #include <ccn/ccn.h> |
| #include <ccn/uri.h> |
| #include <ccn/keystore.h> |
| #include <ccn/signing.h> |
| #include <ccn/schedule.h> |
| #include <ccn/hashtb.h> |
| |
| #include "nlsr.h" |
| #include "nlsr_lsdb.h" |
| #include "utility.h" |
| #include "nlsr_ndn.h" |
| #include "nlsr_adl.h" |
| |
| void |
| set_new_lsdb_version(void) |
| { |
| |
| char *time_stamp=get_current_timestamp_micro(); |
| |
| free(nlsr->lsdb->version); |
| nlsr->lsdb->version=(char *)malloc(strlen(time_stamp)+1); |
| memset(nlsr->lsdb->version,0,strlen(time_stamp)+1); |
| memcpy(nlsr->lsdb->version,time_stamp,strlen(time_stamp)+1); |
| |
| } |
| |
| |
| void |
| build_and_install_name_lsas(void) |
| { |
| printf("build_and_install_name_lsas called \n"); |
| |
| int i, npl_element; |
| struct name_prefix *np; |
| |
| struct hashtb_enumerator ee; |
| struct hashtb_enumerator *e = ⅇ |
| |
| hashtb_start(nlsr->npl, e); |
| npl_element=hashtb_n(nlsr->npl); |
| |
| for(i=0;i<npl_element;i++) |
| { |
| np=e->data; |
| struct nlsa *name_lsa=(struct nlsa *)malloc(sizeof( struct nlsa )); |
| build_name_lsa(name_lsa,np); |
| print_name_lsa(name_lsa); |
| install_name_lsa(name_lsa); |
| free(name_lsa); |
| hashtb_next(e); |
| } |
| |
| hashtb_end(e); |
| |
| } |
| |
| void |
| build_and_install_others_name_lsa(char *orig_router,int ls_type,long int ls_id,int isValid,char *np) |
| { |
| printf("build_and_install_others_name_lsa called \n"); |
| |
| struct nlsa *name_lsa=(struct nlsa *)malloc(sizeof( struct nlsa )); |
| build_others_name_lsa(name_lsa,orig_router,ls_type,ls_id,isValid,np); |
| print_name_lsa(name_lsa); |
| install_name_lsa(name_lsa); |
| print_name_lsdb(); |
| free(name_lsa); |
| } |
| |
| void |
| build_others_name_lsa(struct nlsa *name_lsa, char *orig_router,int ls_type,long int ls_id,int isValid,char *np) |
| { |
| printf("build_others_name_lsa called \n"); |
| |
| name_lsa->header=(struct nlsa_header *)malloc(sizeof(struct nlsa_header )); |
| name_lsa->header->ls_type=LS_TYPE_NAME; |
| |
| char *time_stamp=get_current_timestamp_micro(); |
| |
| name_lsa->header->orig_time=(char *)malloc(strlen(time_stamp)+1); |
| memset(name_lsa->header->orig_time,0,strlen(time_stamp)+1); |
| memcpy(name_lsa->header->orig_time,time_stamp,strlen(time_stamp)+1); |
| |
| name_lsa->header->ls_id=ls_id; |
| name_lsa->header->orig_router=(struct name_prefix *)malloc(sizeof(struct name_prefix )); |
| name_lsa->header->orig_router->name=(char *)malloc(strlen(orig_router)+1); |
| memset(name_lsa->header->orig_router->name,0,strlen(orig_router)+1); |
| memcpy(name_lsa->header->orig_router->name,orig_router,strlen(orig_router)+1); |
| name_lsa->header->orig_router->length=strlen(orig_router)+1; |
| name_lsa->header->isValid=isValid; |
| |
| name_lsa->name_prefix=(struct name_prefix *)malloc(sizeof(struct name_prefix )); |
| name_lsa->name_prefix->name=(char *)malloc(strlen(np)+1); |
| memset(name_lsa->name_prefix->name,0,strlen(np)+1); |
| memcpy(name_lsa->name_prefix->name,np,strlen(np)+1); |
| name_lsa->name_prefix->length=strlen(np)+1; |
| |
| |
| } |
| |
| void |
| build_name_lsa(struct nlsa *name_lsa, struct name_prefix *np) |
| { |
| printf("build_name_lsa called \n"); |
| |
| name_lsa->header=(struct nlsa_header *)malloc(sizeof(struct nlsa_header )); |
| name_lsa->header->ls_type=LS_TYPE_NAME; |
| |
| char *time_stamp=get_current_timestamp_micro(); |
| |
| name_lsa->header->orig_time=(char *)malloc(strlen(time_stamp)+1); |
| memset(name_lsa->header->orig_time,0,strlen(time_stamp)+1); |
| memcpy(name_lsa->header->orig_time,time_stamp,strlen(time_stamp)+1); |
| name_lsa->header->orig_time[strlen(name_lsa->header->orig_time)]='\0'; |
| |
| printf("Orig Time: %s\n",name_lsa->header->orig_time); |
| |
| name_lsa->header->ls_id=++nlsr->nlsa_id; |
| name_lsa->header->orig_router=(struct name_prefix *)malloc(sizeof(struct name_prefix )); |
| name_lsa->header->orig_router->name=(char *)malloc(nlsr->router_name->length); |
| memcpy(name_lsa->header->orig_router->name,nlsr->router_name->name,nlsr->router_name->length); |
| name_lsa->header->orig_router->length=nlsr->router_name->length; |
| name_lsa->header->isValid=1; |
| |
| |
| name_lsa->name_prefix=(struct name_prefix *)malloc(sizeof(struct name_prefix )); |
| name_lsa->name_prefix->name=(char *)malloc(np->length); |
| memcpy(name_lsa->name_prefix->name,np->name,np->length); |
| name_lsa->name_prefix->length=np->length; |
| |
| } |
| |
| |
| void |
| print_name_lsa(struct nlsa *name_lsa) |
| { |
| printf("print_name_lsa called \n"); |
| |
| printf("-----------Name LSA Content---------------\n"); |
| printf(" Origination Router : %s\n",name_lsa->header->orig_router->name); |
| printf(" Origination Router Length: %d\n",name_lsa->header->orig_router->length); |
| printf(" LS Type : %d\n",name_lsa->header->ls_type); |
| printf(" LS Id : %ld\n",name_lsa->header->ls_id); |
| printf(" Origination Time : %s\n",name_lsa->header->orig_time); |
| printf(" Is Valid : %d\n",name_lsa->header->isValid); |
| printf(" LSA Data \n"); |
| printf(" Name Prefix: : %s\n",name_lsa->name_prefix->name); |
| printf(" Name Prefix Length : %d\n",name_lsa->name_prefix->length); |
| |
| printf("\n"); |
| } |
| |
| void |
| install_name_lsa(struct nlsa *name_lsa) |
| { |
| printf("install_name_lsa called \n"); |
| |
| print_name_lsa(name_lsa); |
| |
| char *key=make_name_lsa_key(name_lsa->header->orig_router->name,name_lsa->header->ls_type,name_lsa->header->ls_id); |
| printf("Key:%s Length:%d\n",key,(int)strlen(key)); |
| |
| struct nlsa *new_name_lsa=(struct nlsa*)malloc(sizeof(struct nlsa )); |
| |
| struct hashtb_enumerator ee; |
| struct hashtb_enumerator *e = ⅇ |
| int res; |
| |
| hashtb_start(nlsr->lsdb->name_lsdb, e); |
| res = hashtb_seek(e, key, strlen(key), 0); |
| |
| if(res == HT_NEW_ENTRY ) |
| { |
| printf("New Name LSA... Adding to LSDB\n"); |
| new_name_lsa = e->data; |
| |
| new_name_lsa->header=(struct nlsa_header *)malloc(sizeof(struct nlsa_header )); |
| new_name_lsa->header->ls_type=name_lsa->header->ls_type; |
| |
| new_name_lsa->header->orig_time=(char *)malloc(strlen(name_lsa->header->orig_time)+1); |
| memcpy(new_name_lsa->header->orig_time,name_lsa->header->orig_time,strlen(name_lsa->header->orig_time)+1); |
| |
| printf("Orig Time: %s\n",new_name_lsa->header->orig_time); |
| |
| new_name_lsa->header->ls_id=name_lsa->header->ls_id; |
| new_name_lsa->header->orig_router=(struct name_prefix *)malloc(sizeof(struct name_prefix )); |
| new_name_lsa->header->orig_router->name=(char *)malloc(name_lsa->header->orig_router->length); |
| memcpy(new_name_lsa->header->orig_router->name,name_lsa->header->orig_router->name,name_lsa->header->orig_router->length); |
| new_name_lsa->header->orig_router->length=name_lsa->header->orig_router->length; |
| new_name_lsa->header->isValid=name_lsa->header->isValid; |
| |
| |
| new_name_lsa->name_prefix=(struct name_prefix *)malloc(sizeof(struct name_prefix )); |
| new_name_lsa->name_prefix->name=(char *)malloc(name_lsa->name_prefix->length); |
| memcpy(new_name_lsa->name_prefix->name,name_lsa->name_prefix->name,name_lsa->name_prefix->length); |
| new_name_lsa->name_prefix->length=name_lsa->name_prefix->length; |
| |
| printf("New Name LSA Added....\n"); |
| |
| printf("Old Version Number of LSDB: %s \n",nlsr->lsdb->version); |
| set_new_lsdb_version(); |
| printf("New Version Number of LSDB: %s \n",nlsr->lsdb->version); |
| |
| } |
| else if(res == HT_OLD_ENTRY) |
| { |
| printf("Duplicate Name LSA. Discarded...\n"); |
| |
| } |
| |
| hashtb_end(e); |
| } |
| |
| |
| char * |
| make_name_lsa_key(char *orig_router, int ls_type, long int ls_id) |
| { |
| |
| |
| printf("Orig Router: %s LS Type: %d LS Id: %ld\n",orig_router,ls_type,ls_id); |
| |
| char lst[2]; |
| memset(lst,0,2); |
| sprintf(lst,"%d",ls_type); |
| |
| char lsid[10]; |
| memset(lsid,0,10); |
| sprintf(lsid,"%ld",ls_id); |
| |
| |
| char *key=(char *)malloc(strlen(orig_router)+1+strlen(lst)+1+strlen(lsid)+1); |
| memset(key,0,strlen(orig_router)+1+strlen(lst)+1+strlen(lsid)+1); |
| memcpy(key+strlen(key),orig_router,strlen(orig_router)); |
| memcpy(key+strlen(key),"/",1); |
| memcpy(key+strlen(key),lst,strlen(lst)); |
| memcpy(key+strlen(key),"/",1); |
| memcpy(key+strlen(key),lsid,strlen(lsid)); |
| |
| printf("Key: %s\n",key); |
| |
| return key; |
| |
| } |
| |
| void |
| print_name_lsdb(void) |
| { |
| printf("print_name_lsdb called \n"); |
| int i, name_lsdb_element; |
| struct nlsa *name_lsa; |
| |
| struct hashtb_enumerator ee; |
| struct hashtb_enumerator *e = ⅇ |
| |
| hashtb_start(nlsr->lsdb->name_lsdb, e); |
| name_lsdb_element=hashtb_n(nlsr->lsdb->name_lsdb); |
| |
| for(i=0;i<name_lsdb_element;i++) |
| { |
| printf("-----------Name LSA (%d)---------------\n",i+1); |
| name_lsa=e->data; |
| print_name_lsa(name_lsa); |
| hashtb_next(e); |
| } |
| |
| hashtb_end(e); |
| |
| printf("\n"); |
| } |
| |
| int |
| build_and_install_adj_lsa(struct ccn_schedule *sched, void *clienth, struct ccn_scheduled_event *ev, int flags) |
| { |
| printf("build_and_install_adj_lsa called \n"); |
| my_lock(); |
| |
| printf("adj_build_flag = %d \n",nlsr->adj_build_flag); |
| |
| if(nlsr->adj_build_flag > 0) |
| { |
| printf("is_adj_lsa_build = %d \n",is_adj_lsa_build()); |
| if ( is_adj_lsa_build()> 0) |
| { |
| struct alsa *adj_lsa=(struct alsa *)malloc(sizeof( struct alsa )); |
| build_adj_lsa(adj_lsa); |
| print_adj_lsa(adj_lsa); |
| install_adj_lsa(adj_lsa); |
| free(adj_lsa); |
| nlsr->adj_build_flag=0; |
| print_adj_lsdb(); |
| } |
| else |
| { |
| printf("Can not build adj LSA now\n"); |
| } |
| } |
| nlsr->is_build_adj_lsa_sheduled=0; |
| my_unlock(); |
| return 0; |
| } |
| |
| void |
| build_and_install_others_adj_lsa(char *orig_router,int ls_type,char *orig_time, int no_link,char *data) |
| { |
| printf("build_and_install_others_adj_lsa called \n"); |
| struct alsa *adj_lsa=(struct alsa *)malloc(sizeof( struct alsa )); |
| build_others_adj_lsa(adj_lsa,orig_router,ls_type,orig_time,no_link,data); |
| print_adj_lsa(adj_lsa); |
| install_adj_lsa(adj_lsa); |
| free(adj_lsa); |
| print_adj_lsdb(); |
| |
| } |
| |
| void |
| build_others_adj_lsa(struct alsa *adj_lsa,char *orig_router,int ls_type,char *orig_time,int no_link,char *data) |
| { |
| printf("build_others_adj_lsa called \n"); |
| |
| /*Filling Up Header Data */ |
| adj_lsa->header=(struct alsa_header *)malloc(sizeof(struct alsa_header )); |
| adj_lsa->header->orig_router=(struct name_prefix *)malloc(sizeof(struct name_prefix )); |
| adj_lsa->header->orig_router->name=(char *)malloc(strlen(orig_router)+1); |
| memset(adj_lsa->header->orig_router->name,0,strlen(orig_router)+1); |
| memcpy(adj_lsa->header->orig_router->name,orig_router,strlen(orig_router)+1); |
| |
| adj_lsa->header->orig_router->length=strlen(orig_router)+1; |
| |
| |
| adj_lsa->header->ls_type=(unsigned)LS_TYPE_ADJ; |
| |
| adj_lsa->header->orig_time=(char *)malloc(strlen(orig_time)+1); |
| memset(adj_lsa->header->orig_time,0,strlen(orig_time)+1); |
| memcpy(adj_lsa->header->orig_time,orig_time,strlen(orig_time)+1); |
| |
| adj_lsa->no_link=no_link; |
| |
| adj_lsa->body=(char *)malloc(strlen(data)+1); |
| memset(adj_lsa->body,0,strlen(data)+1); |
| memcpy(adj_lsa->body,(char *)data,strlen(data)+1); |
| |
| } |
| |
| void |
| build_adj_lsa(struct alsa * adj_lsa) |
| { |
| printf("build_adj_lsa called \n"); |
| |
| int no_link=no_active_nbr(); |
| printf("Number of link in Adjacent LSA: %d\n",no_link); |
| |
| /*Filling Up Header Data */ |
| adj_lsa->header=(struct alsa_header *)malloc(sizeof(struct alsa_header )); |
| adj_lsa->header->ls_type=(unsigned)LS_TYPE_ADJ; |
| |
| char *time_stamp=get_current_timestamp_micro(); |
| adj_lsa->header->orig_time=(char *)malloc(strlen(time_stamp)+1); |
| memset(adj_lsa->header->orig_time,0,strlen(time_stamp)+1); |
| memcpy(adj_lsa->header->orig_time,time_stamp,strlen(time_stamp)+1); |
| adj_lsa->header->orig_time[strlen(adj_lsa->header->orig_time)]='\0'; |
| |
| printf("Router Name: %s Length: %d \n",nlsr->router_name->name,nlsr->router_name->length); |
| |
| char *temp_r=(char *)malloc(nlsr->router_name->length); |
| memset(temp_r,0,nlsr->router_name->length); |
| sprintf(temp_r,"%s",nlsr->router_name->name); |
| printf("Router Name: %s Length: %d \n",temp_r,(int)strlen(temp_r)+1); |
| |
| adj_lsa->header->orig_router=(struct name_prefix *)malloc(sizeof(struct name_prefix )); |
| adj_lsa->header->orig_router->name=(char *)malloc(strlen(temp_r)+1); |
| memset(adj_lsa->header->orig_router->name,0,strlen(temp_r)+1); |
| memcpy(adj_lsa->header->orig_router->name,temp_r,strlen(temp_r)+1); |
| |
| adj_lsa->header->orig_router->length=strlen(temp_r)+1; |
| printf("Router Name: %s Length: %d \n",nlsr->router_name->name,nlsr->router_name->length); |
| |
| /* Filling Up Body Data */ |
| |
| adj_lsa->no_link=no_link; |
| |
| |
| struct ccn_charbuf *c=ccn_charbuf_create(); |
| get_active_nbr_adj_data(c); |
| char *data=ccn_charbuf_as_string(c); |
| printf("Adjacent data: %s \n",data); |
| |
| adj_lsa->body=(char *)malloc(strlen(data)+1); |
| memset(adj_lsa->body,0,strlen(data)+1); |
| memcpy(adj_lsa->body,(char *)data,strlen(data)+1); |
| |
| |
| ccn_charbuf_destroy(&c); |
| |
| if( !nlsr->is_send_lsdb_interest_scheduled ) |
| { |
| nlsr->event_send_lsdb_interest= ccn_schedule_event(nlsr->sched, 1000, &send_lsdb_interest, NULL, 0); |
| nlsr->is_send_lsdb_interest_scheduled=1; |
| } |
| nlsr->adj_build_count++; |
| |
| |
| free(temp_r); |
| } |
| |
| |
| void |
| make_adj_lsa_key(char *key,struct alsa *adj_lsa) |
| { |
| memcpy(key+strlen(key),adj_lsa->header->orig_router->name,adj_lsa->header->orig_router->length); |
| memcpy(key+strlen(key),"/",1); |
| char ls_type[2]; |
| sprintf(ls_type,"%d",adj_lsa->header->ls_type); |
| memcpy(key+strlen(key),ls_type,strlen(ls_type)); |
| key[strlen(key)]='\0'; |
| } |
| |
| void |
| install_adj_lsa(struct alsa * adj_lsa) |
| { |
| printf("install_adj_lsa called \n"); |
| |
| char *key=(char *)malloc(adj_lsa->header->orig_router->length+2+2); |
| memset(key,0,adj_lsa->header->orig_router->length+2); |
| make_adj_lsa_key(key,adj_lsa); |
| printf("Adjacent LSA key: %s \n",key); |
| |
| struct alsa *new_adj_lsa=(struct alsa*)malloc(sizeof(struct alsa )); |
| |
| struct hashtb_enumerator ee; |
| struct hashtb_enumerator *e = ⅇ |
| int res; |
| |
| hashtb_start(nlsr->lsdb->adj_lsdb, e); |
| res = hashtb_seek(e, key, strlen(key), 0); |
| |
| |
| |
| if(res == HT_NEW_ENTRY ) |
| { |
| printf("New ADJ LSA... Adding to LSDB\n"); |
| new_adj_lsa = e->data; |
| |
| new_adj_lsa->header=(struct alsa_header *)malloc(sizeof(struct alsa_header )); |
| new_adj_lsa->header->ls_type=adj_lsa->header->ls_type; |
| new_adj_lsa->header->orig_time=(char *)malloc(strlen(adj_lsa->header->orig_time)+1); |
| memcpy(new_adj_lsa->header->orig_time,adj_lsa->header->orig_time,strlen(adj_lsa->header->orig_time)+1); |
| |
| new_adj_lsa->header->orig_router=(struct name_prefix *)malloc(sizeof(struct name_prefix )); |
| new_adj_lsa->header->orig_router->name=(char *)malloc(adj_lsa->header->orig_router->length); |
| memcpy(new_adj_lsa->header->orig_router->name,adj_lsa->header->orig_router->name,adj_lsa->header->orig_router->length); |
| new_adj_lsa->header->orig_router->length=adj_lsa->header->orig_router->length; |
| |
| new_adj_lsa->no_link=adj_lsa->no_link; |
| |
| new_adj_lsa->body=(char *)malloc(strlen(adj_lsa->body)+1); |
| memset(new_adj_lsa->body,0,strlen(adj_lsa->body)+1); |
| memcpy(new_adj_lsa->body,adj_lsa->body,strlen(adj_lsa->body)+1); |
| |
| printf("Old Version Number of LSDB: %s \n",nlsr->lsdb->version); |
| set_new_lsdb_version(); |
| printf("New Version Number of LSDB: %s \n",nlsr->lsdb->version); |
| |
| |
| } |
| else if(res == HT_OLD_ENTRY) |
| { |
| new_adj_lsa = e->data; |
| if(strcmp(adj_lsa->header->orig_time,new_adj_lsa->header->orig_time)<=0) |
| { |
| printf("Older/Duplicate Adj LSA. Discarded...\n"); |
| } |
| else |
| { |
| new_adj_lsa = e->data; |
| |
| free(new_adj_lsa->header->orig_time); |
| new_adj_lsa->header->orig_time=(char *)malloc(strlen(adj_lsa->header->orig_time)+1); |
| memcpy(new_adj_lsa->header->orig_time,adj_lsa->header->orig_time,strlen(adj_lsa->header->orig_time)+1); |
| |
| new_adj_lsa->no_link=adj_lsa->no_link; |
| |
| free(new_adj_lsa->body); |
| new_adj_lsa->body=(char *)malloc(strlen(adj_lsa->body)+1); |
| memset(new_adj_lsa->body,0,strlen(adj_lsa->body)+1); |
| memcpy(new_adj_lsa->body,adj_lsa->body,strlen(adj_lsa->body)+1); |
| |
| printf("Old Version Number of LSDB: %s \n",nlsr->lsdb->version); |
| set_new_lsdb_version(); |
| printf("New Version Number of LSDB: %s \n",nlsr->lsdb->version); |
| |
| } |
| |
| } |
| |
| hashtb_end(e); |
| |
| free(key); |
| } |
| |
| void |
| print_adj_lsa_body(const char *body, int no_link) |
| { |
| int i=0; |
| char *lsa_data=(char *)malloc(strlen(body)+1); |
| memset( lsa_data,0,strlen(body)+1); |
| memcpy(lsa_data,body,strlen(body)+1); |
| char *sep="|"; |
| char *rem; |
| char *rtr_id; |
| char *length; |
| char *face; |
| char *metric; |
| |
| printf(" Lsa Data:\n"); |
| printf(" No of Link : %d\n",no_link); |
| |
| if(no_link >0 ) |
| { |
| rtr_id=strtok_r(lsa_data,sep,&rem); |
| length=strtok_r(NULL,sep,&rem); |
| face=strtok_r(NULL,sep,&rem); |
| metric=strtok_r(NULL,sep,&rem); |
| |
| printf(" Link %d \n",i+1); |
| printf(" Neighbor : %s \n",rtr_id); |
| printf(" Neighbor Length : %s \n",length); |
| printf(" Connecting Face : %s \n",face); |
| printf(" Metric : %s \n",metric); |
| |
| |
| for(i=1;i<no_link;i++) |
| { |
| rtr_id=strtok_r(NULL,sep,&rem); |
| length=strtok_r(NULL,sep,&rem); |
| face=strtok_r(NULL,sep,&rem); |
| metric=strtok_r(NULL,sep,&rem); |
| printf(" Link %d \n",i+1); |
| printf(" Neighbor : %s \n",rtr_id); |
| printf(" Neighbor Length : %s \n",length); |
| printf(" Connecting Face : %s \n",face); |
| printf(" Metric : %s \n",metric); |
| |
| } |
| } |
| |
| free(lsa_data); |
| } |
| |
| void |
| print_adj_lsa(struct alsa * adj_lsa) |
| { |
| |
| printf("print_adj_lsa called \n"); |
| |
| printf("-----------ADJ LSA Content---------------\n"); |
| printf(" Origination Router : %s\n",adj_lsa->header->orig_router->name); |
| printf(" Origination Router Length: %d\n",adj_lsa->header->orig_router->length); |
| printf(" LS Type : %d\n",adj_lsa->header->ls_type); |
| printf(" Origination Time : %s\n",adj_lsa->header->orig_time); |
| |
| print_adj_lsa_body(adj_lsa->body,adj_lsa->no_link); |
| |
| |
| printf("\n"); |
| |
| } |
| |
| void |
| print_adj_lsdb(void) |
| { |
| printf("print_name_lsdb called \n"); |
| int i, adj_lsdb_element; |
| struct alsa *adj_lsa; |
| |
| struct hashtb_enumerator ee; |
| struct hashtb_enumerator *e = ⅇ |
| |
| hashtb_start(nlsr->lsdb->adj_lsdb, e); |
| adj_lsdb_element=hashtb_n(nlsr->lsdb->adj_lsdb); |
| |
| for(i=0;i<adj_lsdb_element;i++) |
| { |
| printf("-----------Adj LSA (%d)---------------\n",i+1); |
| adj_lsa=e->data; |
| print_adj_lsa(adj_lsa); |
| hashtb_next(e); |
| } |
| |
| hashtb_end(e); |
| |
| printf("\n"); |
| |
| } |
| |
| char * |
| get_name_lsdb_summary() |
| { |
| printf("get_name_lsdb_summary called \n"); |
| int i, name_lsdb_element; |
| |
| long int len=0; |
| |
| struct nlsa *name_lsa; |
| struct hashtb_enumerator ee; |
| struct hashtb_enumerator *e = ⅇ |
| |
| hashtb_start(nlsr->lsdb->name_lsdb, e); |
| name_lsdb_element=hashtb_n(nlsr->lsdb->name_lsdb); |
| |
| for(i=0;i<name_lsdb_element;i++) |
| { |
| name_lsa=e->data; |
| |
| //ccn_charbuf_append_string(sum_data,name_lsa->header->orig_router->name); |
| len+=strlen(name_lsa->header->orig_router->name); |
| //ccn_charbuf_append_string(sum_data,"|"); |
| len++; |
| |
| char *temp=(char *)malloc(20); |
| memset(temp,0,20); |
| sprintf(temp,"%d",name_lsa->header->ls_type); |
| len+=strlen(temp); |
| //ccn_charbuf_append_string(sum_data,temp); |
| free(temp); |
| //ccn_charbuf_append_string(sum_data,"|"); |
| len++; |
| |
| char *temp1=(char *)malloc(20); |
| memset(temp1,0,20); |
| sprintf(temp1,"%ld",name_lsa->header->ls_id); |
| //ccn_charbuf_append_string(sum_data,temp1); |
| len+=strlen(temp1); |
| free(temp1); |
| //ccn_charbuf_append_string(sum_data,"|"); |
| len++; |
| |
| hashtb_next(e); |
| } |
| |
| hashtb_end(e); |
| |
| len++; |
| |
| char *sum_data=malloc(len); |
| memset(sum_data,0,len); |
| |
| hashtb_start(nlsr->lsdb->name_lsdb, e); |
| for(i=0;i<name_lsdb_element;i++) |
| { |
| name_lsa=e->data; |
| |
| //ccn_charbuf_append_string(sum_data,name_lsa->header->orig_router->name); |
| memcpy(sum_data+strlen(sum_data),name_lsa->header->orig_router->name,strlen(name_lsa->header->orig_router->name)); |
| //len+=strlen(name_lsa->header->orig_router->name); |
| //ccn_charbuf_append_string(sum_data,"|"); |
| memcpy(sum_data+strlen(sum_data),"|",1); |
| //len++; |
| |
| char *tempstr=(char *)malloc(20); |
| memset(tempstr,0,20); |
| sprintf(tempstr,"%d",name_lsa->header->ls_type); |
| //len+=strlen(tempstr); |
| //ccn_charbuf_append_string(sum_data,temp); |
| memcpy(sum_data+strlen(sum_data),tempstr,strlen(tempstr)); |
| free(tempstr); |
| //ccn_charbuf_append_string(sum_data,"|"); |
| memcpy(sum_data+strlen(sum_data),"|",1); |
| //len++; |
| |
| char *temp1str=(char *)malloc(20); |
| memset(temp1str,0,20); |
| sprintf(temp1str,"%ld",name_lsa->header->ls_id); |
| //ccn_charbuf_append_string(sum_data,temp1); |
| memcpy(sum_data+strlen(sum_data),temp1str,strlen(temp1str)); |
| //len+=strlen(temp1str); |
| free(temp1str); |
| //ccn_charbuf_append_string(sum_data,"|"); |
| memcpy(sum_data+strlen(sum_data),"|",1); |
| //len++; |
| |
| hashtb_next(e); |
| } |
| |
| hashtb_end(e); |
| |
| printf("Summary Name LSDB: %s\n",sum_data); |
| |
| return sum_data; |
| } |
| |
| char * |
| get_adj_lsdb_summary(void) |
| { |
| printf("get_adj_lsdb_summary called \n"); |
| int i, adj_lsdb_element; |
| struct alsa *adj_lsa; |
| |
| long int len=0; |
| |
| struct hashtb_enumerator ee; |
| struct hashtb_enumerator *e = ⅇ |
| |
| hashtb_start(nlsr->lsdb->adj_lsdb, e); |
| adj_lsdb_element=hashtb_n(nlsr->lsdb->adj_lsdb); |
| |
| for(i=0;i<adj_lsdb_element;i++) |
| { |
| adj_lsa=e->data; |
| |
| //ccn_charbuf_append_string(sum_data,adj_lsa->header->orig_router->name); |
| len+=strlen(adj_lsa->header->orig_router->name); |
| //ccn_charbuf_append_string(sum_data,"|"); |
| len++; |
| |
| char *temp=(char *)malloc(20); |
| memset(temp,0,20); |
| sprintf(temp,"%d",adj_lsa->header->ls_type); |
| len+=strlen(temp); |
| //ccn_charbuf_append_string(sum_data,temp); |
| free(temp); |
| //ccn_charbuf_append_string(sum_data,"|"); |
| len++; |
| |
| //ccn_charbuf_append_string(sum_data,adj_lsa->header->orig_time); |
| len+=strlen(adj_lsa->header->orig_time); |
| //ccn_charbuf_append_string(sum_data,"|"); |
| len++; |
| |
| hashtb_next(e); |
| } |
| |
| hashtb_end(e); |
| len++; |
| |
| char *sum_data=(char *)malloc(len); |
| memset(sum_data,0,len); |
| |
| hashtb_start(nlsr->lsdb->adj_lsdb, e); |
| for(i=0;i<adj_lsdb_element;i++) |
| { |
| adj_lsa=e->data; |
| |
| //ccn_charbuf_append_string(sum_data,adj_lsa->header->orig_router->name); |
| memcpy(sum_data+strlen(sum_data),adj_lsa->header->orig_router->name,strlen(adj_lsa->header->orig_router->name)); |
| //len+=strlen(adj_lsa->header->orig_router->name); |
| //ccn_charbuf_append_string(sum_data,"|"); |
| memcpy(sum_data+strlen(sum_data),"|",1); |
| //len++; |
| |
| char *temp1=(char *)malloc(20); |
| memset(temp1,0,20); |
| sprintf(temp1,"%d",adj_lsa->header->ls_type); |
| //len+=strlen(temp); |
| //ccn_charbuf_append_string(sum_data,temp); |
| memcpy(sum_data+strlen(sum_data),temp1,strlen(temp1)); |
| free(temp1); |
| //ccn_charbuf_append_string(sum_data,"|"); |
| memcpy(sum_data+strlen(sum_data),"|",1); |
| //len++; |
| |
| //ccn_charbuf_append_string(sum_data,adj_lsa->header->orig_time); |
| memcpy(sum_data+strlen(sum_data),adj_lsa->header->orig_time,strlen(adj_lsa->header->orig_time)); |
| //len+=strlen(adj_lsa->header->orig_time); |
| //ccn_charbuf_append_string(sum_data,"|"); |
| memcpy(sum_data+strlen(sum_data),"|",1); |
| //len++; |
| |
| hashtb_next(e); |
| } |
| |
| hashtb_end(e); |
| |
| printf("Summary ADJ LSDB: %s\n",sum_data); |
| |
| return sum_data; |
| } |
| |
| void |
| get_name_lsa_data(struct ccn_charbuf *lsa_data,struct name_prefix *lsaId) |
| { |
| printf("get_name_lsa_data called \n"); |
| |
| struct nlsa *name_lsa=(struct nlsa*)malloc(sizeof(struct nlsa )); |
| |
| struct hashtb_enumerator ee; |
| struct hashtb_enumerator *e = ⅇ |
| int res; |
| |
| hashtb_start(nlsr->lsdb->name_lsdb, e); |
| res = hashtb_seek(e, lsaId->name, lsaId->length-1, 0); |
| |
| if( res == HT_OLD_ENTRY ) |
| { |
| name_lsa=e->data; |
| printf("NAME LSA found\n"); |
| |
| ccn_charbuf_append_string(lsa_data,name_lsa->header->orig_router->name); |
| ccn_charbuf_append_string(lsa_data,"|"); |
| |
| char *temp_length=(char *)malloc(20); |
| memset(temp_length,0,20); |
| sprintf(temp_length,"%d",name_lsa->header->orig_router->length); |
| ccn_charbuf_append_string(lsa_data,temp_length); |
| free(temp_length); |
| ccn_charbuf_append_string(lsa_data,"|"); |
| |
| char *temp_ltype=(char *)malloc(20); |
| memset(temp_ltype,0,20); |
| sprintf(temp_ltype,"%d",name_lsa->header->ls_type); |
| ccn_charbuf_append_string(lsa_data,temp_ltype); |
| free(temp_ltype); |
| ccn_charbuf_append_string(lsa_data,"|"); |
| |
| char *temp_lsid=(char *)malloc(20); |
| memset(temp_lsid,0,20); |
| sprintf(temp_lsid,"%ld",name_lsa->header->ls_id); |
| ccn_charbuf_append_string(lsa_data,temp_lsid); |
| free(temp_lsid); |
| ccn_charbuf_append_string(lsa_data,"|"); |
| |
| char *temp_valid=(char *)malloc(20); |
| memset(temp_valid,0,20); |
| sprintf(temp_valid,"%d",name_lsa->header->isValid); |
| ccn_charbuf_append_string(lsa_data,temp_valid); |
| free(temp_valid); |
| ccn_charbuf_append_string(lsa_data,"|"); |
| |
| ccn_charbuf_append_string(lsa_data,name_lsa->name_prefix->name); |
| ccn_charbuf_append_string(lsa_data,"|"); |
| |
| char *temp_npl=(char *)malloc(20); |
| memset(temp_npl,0,20); |
| sprintf(temp_npl,"%d",name_lsa->name_prefix->length); |
| ccn_charbuf_append_string(lsa_data,temp_npl); |
| free(temp_npl); |
| ccn_charbuf_append_string(lsa_data,"|"); |
| |
| } |
| else if(res == HT_NEW_ENTRY) |
| { |
| hashtb_delete(e); |
| } |
| |
| hashtb_end(e); |
| } |
| |
| void |
| get_adj_lsa_data(struct ccn_charbuf *lsa_data,struct name_prefix *lsaId) |
| { |
| printf("get_adj_lsa_data called \n"); |
| |
| struct alsa *adj_lsa=(struct alsa*)malloc(sizeof(struct alsa )); |
| |
| struct hashtb_enumerator ee; |
| struct hashtb_enumerator *e = ⅇ |
| int res; |
| |
| hashtb_start(nlsr->lsdb->adj_lsdb, e); |
| res = hashtb_seek(e, lsaId->name, lsaId->length-1, 0); |
| |
| if( res == HT_OLD_ENTRY ) |
| { |
| adj_lsa=e->data; |
| printf("NAME LSA found\n"); |
| |
| ccn_charbuf_append_string(lsa_data,adj_lsa->header->orig_router->name); |
| ccn_charbuf_append_string(lsa_data,"|"); |
| |
| char *temp_length=(char *)malloc(20); |
| memset(temp_length,0,20); |
| sprintf(temp_length,"%d",adj_lsa->header->orig_router->length); |
| ccn_charbuf_append_string(lsa_data,temp_length); |
| free(temp_length); |
| ccn_charbuf_append_string(lsa_data,"|"); |
| |
| char *temp_ltype=(char *)malloc(20); |
| memset(temp_ltype,0,20); |
| sprintf(temp_ltype,"%d",adj_lsa->header->ls_type); |
| ccn_charbuf_append_string(lsa_data,temp_ltype); |
| free(temp_ltype); |
| ccn_charbuf_append_string(lsa_data,"|"); |
| |
| ccn_charbuf_append_string(lsa_data,adj_lsa->header->orig_time); |
| ccn_charbuf_append_string(lsa_data,"|"); |
| |
| char *temp_nl=(char *)malloc(20); |
| memset(temp_nl,0,20); |
| sprintf(temp_nl,"%d",adj_lsa->no_link); |
| ccn_charbuf_append_string(lsa_data,temp_nl); |
| free(temp_nl); |
| ccn_charbuf_append_string(lsa_data,"|"); |
| |
| ccn_charbuf_append_string(lsa_data,adj_lsa->body); |
| |
| |
| } |
| else if(res == HT_NEW_ENTRY) |
| { |
| hashtb_delete(e); |
| } |
| |
| hashtb_end(e); |
| } |
| |
| long int |
| get_name_lsdb_num_element(void) |
| { |
| long int num_element; |
| |
| |
| struct hashtb_enumerator ee; |
| struct hashtb_enumerator *e = ⅇ |
| |
| hashtb_start(nlsr->lsdb->name_lsdb, e); |
| num_element=hashtb_n(nlsr->lsdb->name_lsdb); |
| hashtb_end(e); |
| |
| return num_element; |
| } |
| |
| long int |
| get_adj_lsdb_num_element(void) |
| { |
| long int num_element; |
| |
| |
| struct hashtb_enumerator ee; |
| struct hashtb_enumerator *e = ⅇ |
| |
| hashtb_start(nlsr->lsdb->adj_lsdb, e); |
| num_element=hashtb_n(nlsr->lsdb->adj_lsdb); |
| hashtb_end(e); |
| |
| return num_element; |
| } |