First Commit with CCN Sync
diff --git a/nlsr-sync-0.0/nlsr_adl.c b/nlsr-sync-0.0/nlsr_adl.c
new file mode 100755
index 0000000..54d8954
--- /dev/null
+++ b/nlsr-sync-0.0/nlsr_adl.c
@@ -0,0 +1,919 @@
+#include<stdio.h>
+#include<string.h>
+#include<stdlib.h>
+#include<math.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_npl.h"
+#include "nlsr_adl.h"
+#include "utility.h"
+#include "nlsr_npt.h"
+
+void
+add_nbr_to_adl(struct name_prefix *new_nbr,int face)
+{
+ struct ndn_neighbor *nbr=(struct ndn_neighbor *)malloc(sizeof(struct ndn_neighbor )); //free
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+ int res;
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, new_nbr->name, new_nbr->length, 0);
+
+ if(res == HT_NEW_ENTRY )
+ {
+
+ nbr = e->data;
+
+ nbr->neighbor=(struct name_prefix *)malloc(sizeof( struct name_prefix )); //free
+ nbr->neighbor->name=(char *)malloc(new_nbr->length);
+ memcpy(nbr->neighbor->name,new_nbr->name,new_nbr->length);
+ nbr->neighbor->length=new_nbr->length;
+ nbr->face=face;
+ nbr->status=NBR_DOWN;
+ nbr->info_interest_timed_out=0;
+ nbr->lsdb_interest_timed_out=0;
+ nbr->lsdb_random_time_component=(int)(LSDB_SYNCH_INTERVAL/2);
+ nbr->lsdb_synch_interval=LSDB_SYNCH_INTERVAL;
+ nbr->metric=LINK_METRIC;
+ nbr->is_lsdb_send_interest_scheduled=0;
+
+
+ char *time_stamp=(char *)malloc(20);
+ get_current_timestamp_micro(time_stamp);
+ nbr->last_lsdb_version=(char *)malloc(strlen(time_stamp)+1); //free
+ memcpy(nbr->last_lsdb_version,time_stamp,strlen(time_stamp)+1);
+ memset(nbr->last_lsdb_version,'0',strlen(time_stamp));
+ nbr->last_info_version=(char *)malloc(strlen(time_stamp)+1); //free
+ memcpy(nbr->last_info_version,time_stamp,strlen(time_stamp)+1);
+ memset(nbr->last_info_version,'0',strlen(time_stamp));
+ free(time_stamp);
+
+ nbr->last_lsdb_requested=0;
+ }
+
+ hashtb_end(e);
+}
+
+
+void
+print_adjacent(struct ndn_neighbor *nbr)
+{
+ if ( nlsr->debugging )
+ {
+ printf("print_adjacent called\n");
+ printf("--------Neighbor---------------------------\n");
+ printf(" Neighbor: %s \n",nbr->neighbor->name);
+ printf(" Length : %d \n",nbr->neighbor->length);
+ printf(" Face : %d \n",nbr->face);
+ printf(" Metric : %d \n",nbr->metric);
+ printf(" Status : %d \n",nbr->status);
+ printf(" LSDB Version: %s \n",nbr->last_lsdb_version);
+ printf(" Info Version: %s \n",nbr->last_info_version);
+ printf(" Info Interest Timed Out : %d \n",nbr->info_interest_timed_out);
+ printf(" LSDB Interest Timed Out : %d \n",nbr->lsdb_interest_timed_out);
+ printf(" LSDB Synch Interval : %ld \n",nbr->lsdb_synch_interval);
+ printf(" LSDB Random Time comp : %d \n",nbr->lsdb_random_time_component);
+ printf(" Las Time LSDB Requested: %ld \n",nbr->last_lsdb_requested);
+ printf(" IS_lsdb_send_interest_scheduled : %d \n",nbr->is_lsdb_send_interest_scheduled);
+
+ printf("\n");
+ }
+
+ if ( nlsr->detailed_logging )
+ {
+
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"print_adjacent called\n");
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"--------Neighbor---------------------------\n");
+ writeLogg(__FILE__,__FUNCTION__,__LINE__," Neighbor: %s \n",nbr->neighbor->name);
+ writeLogg(__FILE__,__FUNCTION__,__LINE__," Length : %d \n",nbr->neighbor->length);
+ writeLogg(__FILE__,__FUNCTION__,__LINE__," Face : %d \n",nbr->face);
+ writeLogg(__FILE__,__FUNCTION__,__LINE__," Metric : %d \n",nbr->metric);
+ writeLogg(__FILE__,__FUNCTION__,__LINE__," Status : %d \n",nbr->status);
+ writeLogg(__FILE__,__FUNCTION__,__LINE__," LSDB Version: %s \n",nbr->last_lsdb_version);
+ writeLogg(__FILE__,__FUNCTION__,__LINE__," Info Version: %s \n",nbr->last_info_version);
+ writeLogg(__FILE__,__FUNCTION__,__LINE__," Info Interest Timed Out : %d \n",nbr->info_interest_timed_out);
+ writeLogg(__FILE__,__FUNCTION__,__LINE__," LSDB Interest Timed Out : %d \n",nbr->lsdb_interest_timed_out);
+ writeLogg(__FILE__,__FUNCTION__,__LINE__," LSDB Synch Interval : %ld \n",nbr->lsdb_synch_interval);
+ writeLogg(__FILE__,__FUNCTION__,__LINE__," LSDB Random Time comp : %d \n",nbr->lsdb_random_time_component);
+ writeLogg(__FILE__,__FUNCTION__,__LINE__," Las Time LSDB Requested: %ld \n",nbr->last_lsdb_requested);
+ writeLogg(__FILE__,__FUNCTION__,__LINE__," IS_lsdb_send_interest_scheduled : %d \n",nbr->is_lsdb_send_interest_scheduled);
+
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"\n");
+ }
+
+}
+
+void
+print_adjacent_from_adl(void)
+{
+ if ( nlsr->debugging )
+ printf("print_adjacent_from_adl called \n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"print_adjacent_from_adl called \n");
+
+ int i, adl_element;
+ struct ndn_neighbor *nbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ adl_element=hashtb_n(nlsr->adl);
+
+ for(i=0;i<adl_element;i++)
+ {
+ nbr=e->data;
+ print_adjacent(nbr);
+ hashtb_next(e);
+ }
+
+ hashtb_end(e);
+
+}
+
+int
+get_adjacent_status(struct name_prefix *nbr)
+{
+
+ if ( nlsr->debugging )
+ printf("get_adjacent_status called \n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"get_adjacent_status called \n");
+
+ int res;
+ int status=-1;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr->name, nbr->length, 0);
+
+ if (res == HT_OLD_ENTRY)
+ {
+ nnbr=e->data;
+ status=nnbr->status;
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+
+ return status;
+
+}
+
+int
+get_timed_out_number(struct name_prefix *nbr)
+{
+
+ if ( nlsr->debugging )
+ printf("get_timed_out_number called \n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"get_timed_out_number called \n");
+
+
+ int res,ret=-1;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr->name, nbr->length, 0);
+
+ if( res == HT_OLD_ENTRY )
+ {
+ nnbr=e->data;
+ ret=nnbr->info_interest_timed_out;
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+
+ return ret;
+}
+
+int
+get_lsdb_interest_timed_out_number(struct name_prefix *nbr)
+{
+
+ if ( nlsr->debugging )
+ printf("get_lsdb_interest_timed_out_number called \n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"get_lsdb_interest_timed_out_number called \n");
+
+ int res,ret=-1;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr->name, nbr->length, 0);
+
+ if( res == HT_OLD_ENTRY )
+ {
+ nnbr=e->data;
+ ret=nnbr->lsdb_interest_timed_out;
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+
+ return ret;
+}
+
+void
+update_adjacent_timed_out_to_adl(struct name_prefix *nbr, int increment)
+{
+ if ( nlsr->debugging )
+ printf("update_adjacent_timed_out_to_adl called \n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"update_adjacent_timed_out_to_adl called \n");
+
+ int res;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr->name, nbr->length, 0);
+
+ if( res == HT_OLD_ENTRY )
+ {
+ nnbr=e->data;
+ nnbr->info_interest_timed_out += increment;
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+}
+
+void
+update_adjacent_timed_out_zero_to_adl(struct name_prefix *nbr)
+{
+ if ( nlsr->debugging )
+ printf("update_adjacent_timed_out_zero_to_adl called \n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"update_adjacent_timed_out_zero_to_adl called \n");
+
+ int time_out_number=get_timed_out_number(nbr);
+ update_adjacent_timed_out_to_adl(nbr,-time_out_number);
+
+}
+
+
+void
+update_lsdb_interest_timed_out_to_adl(struct name_prefix *nbr, int increment)
+{
+ if ( nlsr->debugging )
+ printf("update_lsdb_interest_timed_out_to_adl called\n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"update_lsdb_interest_timed_out_to_adl called \n");
+
+ int res;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+
+ //printf("Neighbor: %s , Length: %d \n",nbr->name, nbr->length);
+
+ res = hashtb_seek(e, nbr->name, nbr->length, 0);
+
+ if( res == HT_OLD_ENTRY )
+ {
+ //printf("Old Neighbor\n");
+ nnbr=e->data;
+ nnbr->lsdb_interest_timed_out += increment;
+ //printf("lsdb_interest_timed_out: %d \n",nnbr->lsdb_interest_timed_out);
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ //print_adjacent_from_adl();
+ hashtb_end(e);
+}
+
+void
+update_lsdb_interest_timed_out_zero_to_adl(struct name_prefix *nbr)
+{
+ if ( nlsr->debugging )
+ printf("update_adjacent_timed_out_zero_to_adl called\n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"update_adjacent_timed_out_zero_to_adl called\n");
+
+ int time_out_number=get_lsdb_interest_timed_out_number(nbr);
+ update_lsdb_interest_timed_out_to_adl(nbr,-time_out_number);
+
+}
+
+void
+update_adjacent_status_to_adl(struct name_prefix *nbr, int status)
+{
+ if ( nlsr->debugging )
+ printf("update_adjacent_status_to_adl called\n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"update_adjacent_status_to_adl called \n");
+
+ int res;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr->name, nbr->length, 0);
+
+
+ if (res == HT_OLD_ENTRY)
+ {
+ nnbr=e->data;
+ if ( nnbr->status!=status )
+ {
+ nnbr->status=status;
+ nlsr->adj_build_flag++;
+ }
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+}
+
+
+void
+delete_nbr_from_adl(struct name_prefix *nbr)
+{
+ if ( nlsr->debugging )
+ printf("delete_nbr_from_adl called\n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"delete_nbr_from_adl called \n");
+
+ int res;
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr->name, nbr->length, 0);
+
+
+ if (res == HT_OLD_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+}
+
+void
+update_lsdb_synch_interval_to_adl(struct name_prefix *nbr, long int interval)
+{
+ if ( nlsr->debugging )
+ printf("update_lsdb_synch_interval_to_adl called\n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"update_lsdb_synch_interval_to_adl called \n");
+
+ int res;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr->name, nbr->length, 0);
+
+
+ if (res == HT_OLD_ENTRY)
+ {
+ nnbr=e->data;
+ if ( nnbr->lsdb_synch_interval!= interval )
+ {
+ nnbr->lsdb_synch_interval=interval;
+ nnbr->lsdb_random_time_component=(int)(interval/2);
+
+ }
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+}
+
+
+int
+no_active_nbr(void)
+{
+ int i, adl_element;
+ int no_link=0;
+ struct ndn_neighbor *nbr;
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+ hashtb_start(nlsr->adl, e);
+ adl_element=hashtb_n(nlsr->adl);
+
+ for(i=0;i<adl_element;i++)
+ {
+ nbr=e->data;
+ if( nbr->status == 1 )
+ no_link++;
+ hashtb_next(e);
+ }
+
+ hashtb_end(e);
+
+ return no_link;
+
+}
+
+int
+is_adj_lsa_build(void)
+{
+ int ret=0;
+
+ int nbr_count=0;
+
+ int i, adl_element;
+ struct ndn_neighbor *nbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ adl_element=hashtb_n(nlsr->adl);
+
+ for(i=0;i<adl_element;i++)
+ {
+ nbr=e->data;
+ if(nbr->status == 1 )
+ {
+ nbr_count++;
+ }
+ else if ( (nbr->status == 0) && (nbr->info_interest_timed_out >= nlsr->interest_retry || nbr->lsdb_interest_timed_out >= nlsr->interest_retry))
+ {
+ nbr_count++;
+ }
+ hashtb_next(e);
+ }
+
+ hashtb_end(e);
+ if(nbr_count == adl_element)
+ ret=1;
+
+ return ret;
+}
+
+
+void
+get_active_nbr_adj_data(struct ccn_charbuf *c)
+{
+
+ int i, adl_element;
+ struct ndn_neighbor *nbr;
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+ hashtb_start(nlsr->adl, e);
+ adl_element=hashtb_n(nlsr->adl);
+
+ for(i=0;i<adl_element;i++)
+ {
+ nbr=e->data;
+ if( nbr->status == 1 )
+ {
+ ccn_charbuf_append_string(c,nbr->neighbor->name);
+ ccn_charbuf_append_string(c,"|");
+
+ char *temp_length=(char *)malloc(20);
+ memset(temp_length,0,20);
+ sprintf(temp_length,"%d",nbr->neighbor->length);
+ ccn_charbuf_append_string(c,temp_length);
+ free(temp_length);
+ ccn_charbuf_append_string(c,"|");
+
+ char *temp_face=(char *)malloc(20);
+ memset(temp_face,0,20);
+ sprintf(temp_face,"%d",nbr->face);
+ ccn_charbuf_append_string(c,temp_face);
+ free(temp_face);
+ ccn_charbuf_append_string(c,"|");
+
+ char *temp_metric=(char *)malloc(20);
+ memset(temp_metric,0,20);
+ sprintf(temp_metric,"%d",nbr->metric);
+ ccn_charbuf_append_string(c,temp_metric);
+ free(temp_metric);
+ ccn_charbuf_append_string(c,"|");
+
+ }
+ hashtb_next(e);
+ }
+
+ hashtb_end(e);
+}
+
+long int
+get_nbr_time_diff_lsdb_req(char *nbr)
+{
+ if ( nlsr->debugging )
+ printf("get_nbr_time_diff_lsdb_req called\n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"get_nbr_time_diff_lsdb_req called\n");
+
+ long int time_diff=get_lsdb_synch_interval(nbr)+1;
+ int res;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr, strlen(nbr)+1, 0);
+
+ if (res == HT_OLD_ENTRY)
+ {
+ nnbr=e->data;
+
+ if (nnbr->last_lsdb_requested == 0)
+ time_diff=get_lsdb_synch_interval(nbr)+1;
+ else time_diff=get_current_time_sec() - get_nbr_last_lsdb_requested(nbr);
+
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+
+ return time_diff;
+}
+
+long int
+get_nbr_last_lsdb_requested(char *nbr)
+{
+ if ( nlsr->debugging )
+ printf("get_timed_out_number called\n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"get_timed_out_number called\n");
+
+ long int last_lsdb_requested=0;
+
+ int res;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr, strlen(nbr)+1, 0);
+
+ if (res == HT_OLD_ENTRY)
+ {
+ nnbr=e->data;
+ last_lsdb_requested=nnbr->last_lsdb_requested;
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+
+ return last_lsdb_requested;
+}
+
+
+int
+get_nbr_random_time_component(char *nbr)
+{
+ if ( nlsr->debugging )
+ printf("get_nbr_random_time_component called\n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"get_nbr_random_time_component called\n");
+
+ int time=0;
+
+ int res;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr, strlen(nbr)+1, 0);
+
+ if (res == HT_OLD_ENTRY)
+ {
+ nnbr=e->data;
+ time=nnbr->lsdb_random_time_component * (int)pow(-1,nnbr->lsdb_interest_timed_out+1);
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+
+ return time;
+}
+
+long int
+get_lsdb_synch_interval(char *nbr)
+{
+ if ( nlsr->debugging )
+ printf("get_lsdb_synch_interval called \n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"get_lsdb_synch_interval called \n");
+
+ long int lsdb_synch_interval=300;
+
+
+ int res;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr, strlen(nbr)+1, 0);
+
+ if (res == HT_OLD_ENTRY)
+ {
+ nnbr=e->data;
+ lsdb_synch_interval=nnbr->lsdb_synch_interval;
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+
+ return lsdb_synch_interval;
+
+}
+
+char *
+get_nbr_lsdb_version(char *nbr)
+{
+ if ( nlsr->debugging )
+ printf("get_nbr_lsdb_version called \n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"get_nbr_lsdb_version called \n");
+
+ char *version=NULL;
+
+ int res;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr, strlen(nbr)+1, 0);
+
+ if (res == HT_OLD_ENTRY)
+ {
+ nnbr=e->data;
+ version=(char *)malloc(strlen(nnbr->last_lsdb_version)+1);
+ memset(version,0,strlen(nnbr->last_lsdb_version)+1);
+ memcpy(version,nnbr->last_lsdb_version,strlen(nnbr->last_lsdb_version)+1);
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+
+ return version;
+}
+
+void
+update_adjacent_last_lsdb_requested_to_adl(char *nbr, long int timestamp)
+{
+ if ( nlsr->debugging )
+ printf("update_adjacent_last_lsdb_requested_to_adl called \n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"update_adjacent_last_lsdb_requested_to_adl called \n");
+
+ int res;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr, strlen(nbr)+1, 0);
+
+ if( res == HT_OLD_ENTRY )
+ {
+ nnbr=e->data;
+ nnbr->last_lsdb_requested=timestamp;
+
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+}
+
+void
+set_is_lsdb_send_interest_scheduled_to_zero(char *nbr)
+{
+ if ( nlsr->debugging )
+ printf("set_is_lsdb_send_interest_scheduled_to_zero called \n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"set_is_lsdb_send_interest_scheduled_to_zero called\n");
+
+
+ int res;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr, strlen(nbr)+1, 0);
+
+ if (res == HT_OLD_ENTRY)
+ {
+ nnbr=e->data;
+ nnbr->is_lsdb_send_interest_scheduled=0;
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+}
+
+void
+update_adjacent_lsdb_version_to_adl(struct name_prefix *nbr, char *version)
+{
+ if ( nlsr->debugging )
+ printf("update_adjacent_timed_out_to_adl called \n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"update_adjacent_timed_out_to_adl called\n");
+
+ int res;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr->name, nbr->length, 0);
+
+ if( res == HT_OLD_ENTRY )
+ {
+ nnbr=e->data;
+ free(nnbr->last_lsdb_version);
+ nnbr->last_lsdb_version=(char *)malloc(strlen(version)+1);
+ memset(nnbr->last_lsdb_version,0,strlen(version)+1);
+ memcpy(nnbr->last_lsdb_version,version,strlen(version)+1);
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+
+}
+
+void
+adjust_adjacent_last_lsdb_requested_to_adl(char *nbr, long int sec)
+{
+ printf("update_adjacent_last_lsdb_requested_to_adl called \n");
+
+ if ( nlsr->debugging )
+ printf("update_adjacent_last_lsdb_requested_to_adl called \n");
+ if ( nlsr->detailed_logging )
+ writeLogg(__FILE__,__FUNCTION__,__LINE__,"update_adjacent_last_lsdb_requested_to_adl called\n");
+
+
+ int res;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr, strlen(nbr)+1, 0);
+
+ if( res == HT_OLD_ENTRY )
+ {
+ nnbr=e->data;
+ nnbr->last_lsdb_requested=nnbr->last_lsdb_requested-sec;
+
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+
+}
+
+int
+get_next_hop_face_from_adl(char *nbr)
+{
+ int res;
+ int connecting_face=NO_FACE;
+ struct ndn_neighbor *nnbr;
+
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr, strlen(nbr)+1, 0);
+
+ if( res == HT_OLD_ENTRY )
+ {
+ nnbr=e->data;
+ connecting_face=nnbr->face;
+
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+ return connecting_face;
+}
+
+int
+is_neighbor(char *nbr)
+{
+ int ret=0;
+
+ int res;
+ struct hashtb_enumerator ee;
+ struct hashtb_enumerator *e = ⅇ
+
+ hashtb_start(nlsr->adl, e);
+ res = hashtb_seek(e, nbr, strlen(nbr)+1, 0);
+
+ if( res == HT_OLD_ENTRY )
+ {
+ ret=1;
+ }
+ else if(res == HT_NEW_ENTRY)
+ {
+ hashtb_delete(e);
+ }
+
+ hashtb_end(e);
+
+ return ret;
+}
+