blob: a0967a137e35d2b655886d394f0b875dca5dd38c [file] [log] [blame]
akmhoque59980a52012-08-09 12:36:09 -05001#include<stdio.h>
2#include<string.h>
3#include<stdlib.h>
4#include <unistd.h>
5#include <getopt.h>
6#include <sys/time.h>
7#include <assert.h>
8#ifdef HAVE_CONFIG_H
9#include <config.h>
10#endif
11
12
13#include <ccn/ccn.h>
14#include <ccn/uri.h>
15#include <ccn/keystore.h>
16#include <ccn/signing.h>
17#include <ccn/schedule.h>
18#include <ccn/hashtb.h>
19
20#include "nlsr.h"
21#include "nlsr_ndn.h"
akmhoque03004e62012-09-06 01:12:28 -050022#include "nlsr_npl.h"
akmhoque8a5babe2012-08-16 17:39:33 -050023#include "nlsr_adl.h"
akmhoqued79438d2012-08-27 13:31:42 -050024#include "nlsr_lsdb.h"
akmhoque53f64222012-09-05 13:57:51 -050025#include "utility.h"
akmhoqueedb68d92013-03-05 10:18:16 -060026#include "nlsr_km.h"
27#include "nlsr_km_util.h"
akmhoque53f64222012-09-05 13:57:51 -050028
akmhoqueedb68d92013-03-05 10:18:16 -060029
akmhoque59980a52012-08-09 12:36:09 -050030
akmhoque3d319d42013-02-20 11:08:32 -060031/**
32* get neighbor name prefix from interest/content name and put into nbr
33*/
akmhoque53f64222012-09-05 13:57:51 -050034
35void
akmhoque3d319d42013-02-20 11:08:32 -060036get_nbr(struct name_prefix *nbr,struct ccn_closure *selfp,
37 struct ccn_upcall_info *info)
akmhoque53f64222012-09-05 13:57:51 -050038{
akmhoque7b791452012-10-30 11:24:56 -050039 if ( nlsr->debugging )
40 printf("get_nbr called\n");
41 if ( nlsr->detailed_logging )
42 writeLogg(__FILE__,__FUNCTION__,__LINE__,"get_nbr called\n");
akmhoque53f64222012-09-05 13:57:51 -050043
akmhoque53f64222012-09-05 13:57:51 -050044 int res,i;
45 int nlsr_position=0;
46 int name_comps=(int)info->interest_comps->n;
47 int len=0;
48
49 for(i=0;i<name_comps;i++)
50 {
51 res=ccn_name_comp_strcmp(info->interest_ccnb,info->interest_comps,i,"nlsr");
52 if( res == 0)
53 {
54 nlsr_position=i;
55 break;
56 }
57 }
58
59
60 const unsigned char *comp_ptr1;
61 size_t comp_size;
62 for(i=0;i<nlsr_position;i++)
63 {
akmhoque3d319d42013-02-20 11:08:32 -060064 res=ccn_name_comp_get(info->interest_ccnb, info->interest_comps,i,&
65 comp_ptr1, &comp_size);
akmhoque53f64222012-09-05 13:57:51 -050066 len+=1;
67 len+=(int)comp_size;
68 }
69 len++;
70
71 char *neighbor=(char *)malloc(len);
72 memset(neighbor,0,len);
73
74 for(i=0; i<nlsr_position;i++)
75 {
akmhoque3d319d42013-02-20 11:08:32 -060076 res=ccn_name_comp_get(info->interest_ccnb, info->interest_comps,i,
77 &comp_ptr1, &comp_size);
akmhoque53f64222012-09-05 13:57:51 -050078 memcpy(neighbor+strlen(neighbor),"/",1);
79 memcpy(neighbor+strlen(neighbor),(char *)comp_ptr1,strlen((char *)comp_ptr1));
80
81 }
akmhoque53f64222012-09-05 13:57:51 -050082
akmhoque284056b2013-03-15 01:20:16 -050083 nbr->name=(char *)calloc(strlen(neighbor)+1,sizeof(char));
akmhoque53f64222012-09-05 13:57:51 -050084 memcpy(nbr->name,neighbor,strlen(neighbor)+1);
85 nbr->length=strlen(neighbor)+1;
86
akmhoque7b791452012-10-30 11:24:56 -050087 if ( nlsr->debugging )
88 printf("Neighbor: %s Length: %d\n",nbr->name,nbr->length);
89 if ( nlsr->detailed_logging )
akmhoque3d319d42013-02-20 11:08:32 -060090 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Neighbor: %s Length: %d\n",
91 nbr->name,nbr->length);
akmhoquececba942013-02-25 17:33:34 -060092 free(neighbor);
akmhoque53f64222012-09-05 13:57:51 -050093}
94
akmhoque3d319d42013-02-20 11:08:32 -060095/**
96* Retrieve LSA identifier from content name
97*/
akmhoque53f64222012-09-05 13:57:51 -050098
akmhoque3d319d42013-02-20 11:08:32 -060099void
100get_lsa_identifier(struct name_prefix *lsaId,struct ccn_closure *selfp,
101 struct ccn_upcall_info *info, int offset)
102{
akmhoque7b791452012-10-30 11:24:56 -0500103
104 if ( nlsr->debugging )
105 printf("get_lsa_identifier called\n");
106 if ( nlsr->detailed_logging )
107 writeLogg(__FILE__,__FUNCTION__,__LINE__,"get_lsa_identifier called\n");
108
akmhoque53f64222012-09-05 13:57:51 -0500109 int res,i;
110 int nlsr_position=0;
111 int name_comps=(int)info->interest_comps->n;
112 int len=0;
113
114 for(i=0;i<name_comps;i++)
115 {
116 res=ccn_name_comp_strcmp(info->interest_ccnb,info->interest_comps,i,"nlsr");
117 if( res == 0)
118 {
119 nlsr_position=i;
120 break;
121 }
122 }
123
124
125 const unsigned char *comp_ptr1;
126 size_t comp_size;
akmhoque03004e62012-09-06 01:12:28 -0500127 for(i=nlsr_position+3+offset;i<info->interest_comps->n-1;i++)
akmhoque53f64222012-09-05 13:57:51 -0500128 {
akmhoque3d319d42013-02-20 11:08:32 -0600129 res=ccn_name_comp_get(info->interest_ccnb, info->interest_comps,i,
130 &comp_ptr1, &comp_size);
akmhoque53f64222012-09-05 13:57:51 -0500131 len+=1;
132 len+=(int)comp_size;
133 }
134 len++;
135
akmhoquececba942013-02-25 17:33:34 -0600136 char *neighbor=(char *)calloc(len,sizeof(char));
137 //memset(neighbor,0,len);
akmhoque53f64222012-09-05 13:57:51 -0500138
akmhoque03004e62012-09-06 01:12:28 -0500139 for(i=nlsr_position+3+offset; i<info->interest_comps->n-1;i++)
akmhoque53f64222012-09-05 13:57:51 -0500140 {
akmhoque3d319d42013-02-20 11:08:32 -0600141 res=ccn_name_comp_get(info->interest_ccnb, info->interest_comps,i,
142 &comp_ptr1, &comp_size);
akmhoque53f64222012-09-05 13:57:51 -0500143 memcpy(neighbor+strlen(neighbor),"/",1);
144 memcpy(neighbor+strlen(neighbor),(char *)comp_ptr1,strlen((char *)comp_ptr1));
145
146 }
akmhoque53f64222012-09-05 13:57:51 -0500147
148 lsaId->name=(char *)malloc(strlen(neighbor)+1);
149 memset(lsaId->name,0,strlen(neighbor)+1);
150 memcpy(lsaId->name,neighbor,strlen(neighbor)+1);
151 lsaId->length=strlen(neighbor)+1;
152
akmhoque7b791452012-10-30 11:24:56 -0500153 if ( nlsr->debugging )
154 printf("LSA Identifier: %s Length: %d\n",lsaId->name,lsaId->length-1);
155 if ( nlsr->detailed_logging )
akmhoque3d319d42013-02-20 11:08:32 -0600156 writeLogg(__FILE__,__FUNCTION__,__LINE__,"LSA Identifier: %s Length: "
157 "%d\n",lsaId->name,lsaId->length-1);
akmhoque03004e62012-09-06 01:12:28 -0500158
akmhoquececba942013-02-25 17:33:34 -0600159 free(neighbor);
akmhoque03004e62012-09-06 01:12:28 -0500160}
161
162
akmhoque3d319d42013-02-20 11:08:32 -0600163
164/**
165* Call back function registered in ccnd to get all interest coming to NLSR
166* application
167*/
akmhoque03004e62012-09-06 01:12:28 -0500168
akmhoque59980a52012-08-09 12:36:09 -0500169enum ccn_upcall_res
170incoming_interest(struct ccn_closure *selfp,
171 enum ccn_upcall_kind kind, struct ccn_upcall_info *info)
172{
akmhoqueffacaa82012-09-13 17:48:30 -0500173
174 nlsr_lock();
175
akmhoque59980a52012-08-09 12:36:09 -0500176 switch (kind) {
177 case CCN_UPCALL_FINAL:
178 break;
179 case CCN_UPCALL_INTEREST:
akmhoque03004e62012-09-06 01:12:28 -0500180 // printing the name prefix for which it received interest
akmhoque7b791452012-10-30 11:24:56 -0500181 if ( nlsr->debugging )
182 printf("Interest Received for name: ");
183 if ( nlsr->detailed_logging )
184 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Interest Received for name: ");
185
akmhoque03004e62012-09-06 01:12:28 -0500186 struct ccn_charbuf*c;
187 c=ccn_charbuf_create();
188 ccn_uri_append(c,info->interest_ccnb,info->pi->offset[CCN_PI_E_Name],0);
akmhoque7b791452012-10-30 11:24:56 -0500189
190 if ( nlsr->debugging )
191 printf("%s\n",ccn_charbuf_as_string(c));
192 if ( nlsr->detailed_logging )
193 writeLogg(__FILE__,__FUNCTION__,__LINE__,"%s\n",ccn_charbuf_as_string(c));
194
akmhoque03004e62012-09-06 01:12:28 -0500195 ccn_charbuf_destroy(&c);
196
akmhoque1c9b92f2012-08-13 10:57:50 -0500197 process_incoming_interest(selfp, info);
akmhoque03004e62012-09-06 01:12:28 -0500198
akmhoque59980a52012-08-09 12:36:09 -0500199 break;
akmhoque03004e62012-09-06 01:12:28 -0500200
akmhoque59980a52012-08-09 12:36:09 -0500201 default:
202 break;
203 }
akmhoque03004e62012-09-06 01:12:28 -0500204
akmhoqueffacaa82012-09-13 17:48:30 -0500205 nlsr_unlock();
206
akmhoque59980a52012-08-09 12:36:09 -0500207 return CCN_UPCALL_RESULT_OK;
208}
209
akmhoque3d319d42013-02-20 11:08:32 -0600210/**
211* Function for processing incoming interest and reply with content/NACK content
212*/
akmhoque59980a52012-08-09 12:36:09 -0500213
akmhoqued79438d2012-08-27 13:31:42 -0500214void
akmhoque1c9b92f2012-08-13 10:57:50 -0500215process_incoming_interest(struct ccn_closure *selfp, struct ccn_upcall_info *info)
216{
akmhoque7b791452012-10-30 11:24:56 -0500217 if ( nlsr->debugging )
218 printf("process_incoming_interest called \n");
219 if ( nlsr->detailed_logging )
220 writeLogg(__FILE__,__FUNCTION__,__LINE__,"process_incoming_interest called \n");
221
akmhoque1c9b92f2012-08-13 10:57:50 -0500222 const unsigned char *comp_ptr1;
223 size_t comp_size;
224 int res,i;
225 int nlsr_position=0;
226 int name_comps=(int)info->interest_comps->n;
akmhoque53f64222012-09-05 13:57:51 -0500227
akmhoque1c9b92f2012-08-13 10:57:50 -0500228 for(i=0;i<name_comps;i++)
229 {
230 res=ccn_name_comp_strcmp(info->interest_ccnb,info->interest_comps,i,"nlsr");
231 if( res == 0)
232 {
akmhoqueea3603e2012-08-13 11:24:09 -0500233 nlsr_position=i;
akmhoque1c9b92f2012-08-13 10:57:50 -0500234 break;
235 }
236 }
237
akmhoque3d319d42013-02-20 11:08:32 -0600238 res=ccn_name_comp_get(info->interest_ccnb, info->interest_comps,nlsr_position+1,
239 &comp_ptr1, &comp_size);
akmhoque53f64222012-09-05 13:57:51 -0500240
akmhoque1c9b92f2012-08-13 10:57:50 -0500241
akmhoqued79438d2012-08-27 13:31:42 -0500242 if(!strcmp((char *)comp_ptr1,"info"))
243 {
244 process_incoming_interest_info(selfp,info);
245 }
akmhoqueb77b95f2013-02-08 12:28:47 -0600246
akmhoque53f64222012-09-05 13:57:51 -0500247}
248
akmhoque3d319d42013-02-20 11:08:32 -0600249/**
akmhoque7ab49a32013-02-20 11:27:51 -0600250* Processes incoming interest for "info" interest. Send back reply content back,
251* if interest comes from a neighbor with status down, NLSR will send "info"
252* ineterst to that neighbor
akmhoque3d319d42013-02-20 11:08:32 -0600253*/
254
akmhoque53f64222012-09-05 13:57:51 -0500255void
256process_incoming_interest_info(struct ccn_closure *selfp, struct ccn_upcall_info *info)
257{
akmhoque7b791452012-10-30 11:24:56 -0500258 if ( nlsr->debugging )
259 {
260 printf("process_incoming_interest_info called \n");
261 printf("Sending Info Content back.....\n");
262 }
263 if ( nlsr->detailed_logging )
264 {
akmhoque3d319d42013-02-20 11:08:32 -0600265 writeLogg(__FILE__,__FUNCTION__,__LINE__,"process_incoming_interest_info"
266 " called \n");
akmhoque7b791452012-10-30 11:24:56 -0500267 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Sending Info Content back.....\n");
268 }
269
akmhoque53f64222012-09-05 13:57:51 -0500270
akmhoque53f64222012-09-05 13:57:51 -0500271 int res;
akmhoque6e2ba842013-03-05 19:35:26 -0600272 //struct ccn_charbuf *data=ccn_charbuf_create();
akmhoque53f64222012-09-05 13:57:51 -0500273 struct ccn_charbuf *name=ccn_charbuf_create();
akmhoquedd7a7a72013-02-20 08:25:41 -0600274
akmhoque03004e62012-09-06 01:12:28 -0500275
akmhoque3d319d42013-02-20 11:08:32 -0600276 res=ccn_charbuf_append(name, info->interest_ccnb + info->pi->offset[CCN_PI_B_Name],
277 info->pi->offset[CCN_PI_E_Name] - info->pi->offset[CCN_PI_B_Name]);
akmhoque53f64222012-09-05 13:57:51 -0500278 if (res >= 0)
279 {
akmhoquedd7a7a72013-02-20 08:25:41 -0600280
akmhoque6e2ba842013-03-05 19:35:26 -0600281 /*
akmhoquec06dcf12013-02-20 08:13:37 -0600282 struct ccn_charbuf *pubid = ccn_charbuf_create();
283 struct ccn_charbuf *pubkey = ccn_charbuf_create();
284
akmhoque7ca519b2013-02-20 09:49:43 -0600285 //pubid is the digest_result pubkey is result
286 ccn_get_public_key(nlsr->ccn, NULL, pubid, pubkey);
287
288
akmhoquedd7a7a72013-02-20 08:25:41 -0600289
290 struct ccn_signing_params sp=CCN_SIGNING_PARAMS_INIT;
291 sp.template_ccnb=ccn_charbuf_create();
akmhoque3d319d42013-02-20 11:08:32 -0600292
akmhoqueb63a41e2013-03-01 12:00:20 -0600293 ccn_charbuf_append_tt(sp.template_ccnb,CCN_DTAG_SignedInfo, CCN_DTAG);
akmhoque3d319d42013-02-20 11:08:32 -0600294 ccnb_tagged_putf(sp.template_ccnb, CCN_DTAG_FreshnessSeconds, "%ld", 10);
295 sp.sp_flags |= CCN_SP_TEMPL_FRESHNESS;
296 ccn_charbuf_append_closer(sp.template_ccnb);
akmhoqueb63a41e2013-03-01 12:00:20 -0600297
akmhoque53f64222012-09-05 13:57:51 -0500298
akmhoqueb77b95f2013-02-08 12:28:47 -0600299 char *raw_data=(char *)malloc(20);
300 memset(raw_data,0,20);
akmhoque6e2ba842013-03-05 19:35:26 -0600301 sprintf(raw_data,"%s", nlsr->lsdb->lsdb_version);
302 */
akmhoque53f64222012-09-05 13:57:51 -0500303
akmhoque6e2ba842013-03-05 19:35:26 -0600304 struct ccn_charbuf *resultbuf=ccn_charbuf_create();
305
306 res=sign_content_with_user_defined_keystore(name,
307 resultbuf,
308 "info",
309 strlen("info"),
310 nlsr->keystore_path,
311 nlsr->keystore_passphrase,
312 nlsr->root_key_prefix,
313 nlsr->site_name,
314 nlsr->router_name);
315
316
317 //res= ccn_sign_content(nlsr->ccn, data, name, &sp, "info",strlen("info"));
akmhoque53f64222012-09-05 13:57:51 -0500318 if(res >= 0)
akmhoque7b791452012-10-30 11:24:56 -0500319 {
320 if ( nlsr->debugging )
321 printf("Signing info Content is successful \n");
322 if ( nlsr->detailed_logging )
akmhoque3d319d42013-02-20 11:08:32 -0600323 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Signing info Content"
324 " is successful \n");
akmhoque53f64222012-09-05 13:57:51 -0500325
akmhoque7b791452012-10-30 11:24:56 -0500326 }
akmhoque6e2ba842013-03-05 19:35:26 -0600327 res=ccn_put(nlsr->ccn,resultbuf->buf,resultbuf->length);
akmhoque53f64222012-09-05 13:57:51 -0500328 if(res >= 0)
akmhoque7b791452012-10-30 11:24:56 -0500329 {
330 if ( nlsr->debugging )
331 printf("Sending Info Content is successful \n");
332 if ( nlsr->detailed_logging )
akmhoque3d319d42013-02-20 11:08:32 -0600333 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Sending info Content"
334 " is successful \n");
akmhoque7b791452012-10-30 11:24:56 -0500335 }
336
akmhoque53f64222012-09-05 13:57:51 -0500337
338
akmhoquee1dd7772013-02-24 14:21:49 -0600339 struct name_prefix *nbr=(struct name_prefix * )malloc(sizeof(struct name_prefix));
akmhoque03004e62012-09-06 01:12:28 -0500340 get_lsa_identifier(nbr,selfp,info,-1);
akmhoque7b791452012-10-30 11:24:56 -0500341
342 if ( nlsr->debugging )
akmhoque3d319d42013-02-20 11:08:32 -0600343 printf("Neighbor : %s Length : %d Status : %d\n",nbr->name,nbr->length,
344 get_adjacent_status(nbr));
akmhoque7b791452012-10-30 11:24:56 -0500345 if ( nlsr->detailed_logging )
akmhoque3d319d42013-02-20 11:08:32 -0600346 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Neighbor : %s Length : %d"
347 " Status : %d\n",nbr->name,nbr->length,get_adjacent_status(nbr));
akmhoque03004e62012-09-06 01:12:28 -0500348
akmhoque53f64222012-09-05 13:57:51 -0500349
akmhoque3d319d42013-02-20 11:08:32 -0600350 if( get_adjacent_status(nbr) == 0 && get_timed_out_number(nbr) >=
351 nlsr->interest_retry )
akmhoque53f64222012-09-05 13:57:51 -0500352 {
akmhoqueb8195202012-09-25 11:53:23 -0500353 update_adjacent_timed_out_zero_to_adl(nbr);
akmhoque53f64222012-09-05 13:57:51 -0500354 send_info_interest_to_neighbor(nbr);
355 }
356
357 free(nbr);
akmhoque6e2ba842013-03-05 19:35:26 -0600358 //free(raw_data);
359 //ccn_charbuf_destroy(&sp.template_ccnb);
360 //ccn_charbuf_destroy(&pubid);
361 //ccn_charbuf_destroy(&pubkey);
akmhoque284056b2013-03-15 01:20:16 -0500362 ccn_charbuf_destroy(&resultbuf);
akmhoque53f64222012-09-05 13:57:51 -0500363 }
akmhoque03004e62012-09-06 01:12:28 -0500364
akmhoque6e2ba842013-03-05 19:35:26 -0600365 //ccn_charbuf_destroy(&data);
akmhoque03004e62012-09-06 01:12:28 -0500366 ccn_charbuf_destroy(&name);
akmhoque53f64222012-09-05 13:57:51 -0500367
akmhoquebf1aa832012-08-13 13:26:59 -0500368}
369
370
akmhoque7ab49a32013-02-20 11:27:51 -0600371/**
372* Call back function registered in ccnd to get all content coming to NLSR
373* application
374*/
akmhoque03004e62012-09-06 01:12:28 -0500375
akmhoque53f64222012-09-05 13:57:51 -0500376enum ccn_upcall_res incoming_content(struct ccn_closure* selfp,
377 enum ccn_upcall_kind kind, struct ccn_upcall_info* info)
akmhoqued79438d2012-08-27 13:31:42 -0500378{
379
akmhoqueffacaa82012-09-13 17:48:30 -0500380 nlsr_lock();
akmhoque03004e62012-09-06 01:12:28 -0500381
akmhoque53f64222012-09-05 13:57:51 -0500382 switch(kind) {
383 case CCN_UPCALL_FINAL:
384 break;
385 case CCN_UPCALL_CONTENT:
akmhoque7b791452012-10-30 11:24:56 -0500386 if ( nlsr->debugging )
387 printf("Content Received for Name: ");
388 if ( nlsr->detailed_logging )
389 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Content Received for Name: ");
390
akmhoque03004e62012-09-06 01:12:28 -0500391 struct ccn_charbuf*c;
392 c=ccn_charbuf_create();
393 ccn_uri_append(c,info->interest_ccnb,info->pi->offset[CCN_PI_E],0);
akmhoque7b791452012-10-30 11:24:56 -0500394 if ( nlsr->debugging )
395 printf("%s\n",ccn_charbuf_as_string(c));
396 if ( nlsr->detailed_logging )
397 writeLogg(__FILE__,__FUNCTION__,__LINE__,"%s\n",ccn_charbuf_as_string(c));
398
akmhoque03004e62012-09-06 01:12:28 -0500399 ccn_charbuf_destroy(&c);
400
401 process_incoming_content(selfp,info);
akmhoqued79438d2012-08-27 13:31:42 -0500402
akmhoque53f64222012-09-05 13:57:51 -0500403 break;
404 case CCN_UPCALL_INTEREST_TIMED_OUT:
akmhoqueedb68d92013-03-05 10:18:16 -0600405 //printf("Interest Timed Out Received for Name: ");
406 if ( nlsr->debugging )
407 printf("Interest Timed Out Received for Name: ");
408 if ( nlsr->detailed_logging )
409 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Interest Timed Out Receiv"
akmhoque3d319d42013-02-20 11:08:32 -0600410 "ed for Name: ");
akmhoque03004e62012-09-06 01:12:28 -0500411
akmhoqueedb68d92013-03-05 10:18:16 -0600412 struct ccn_charbuf*ito;
413 ito=ccn_charbuf_create();
414 ccn_uri_append(ito,info->interest_ccnb,info->pi->offset[CCN_PI_E],0);
415 if ( nlsr->debugging )
416 printf("%s\n",ccn_charbuf_as_string(ito));
417 if ( nlsr->detailed_logging )
418 writeLogg(__FILE__,__FUNCTION__,__LINE__,"%s\n",ccn_charbuf_as_string(ito));
419 ccn_charbuf_destroy(&ito);
akmhoque03004e62012-09-06 01:12:28 -0500420
akmhoqueedb68d92013-03-05 10:18:16 -0600421 process_incoming_timed_out_interest(selfp,info);
akmhoqued79438d2012-08-27 13:31:42 -0500422
akmhoque53f64222012-09-05 13:57:51 -0500423 break;
akmhoqueedb68d92013-03-05 10:18:16 -0600424
425 case CCN_UPCALL_CONTENT_UNVERIFIED:
426 if ( nlsr->debugging )
427 printf("Unverified Content Received ..Waiting for verification\n");
428 if ( nlsr->detailed_logging )
429 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Unverified Content"
430 " Received ..Waiting for verification\n");
akmhoque6e2ba842013-03-05 19:35:26 -0600431 //return CCN_UPCALL_RESULT_VERIFY;
akmhoque4637d9d2013-03-08 06:52:00 -0600432 process_incoming_content(selfp,info);
akmhoqueedb68d92013-03-05 10:18:16 -0600433 break;
434
akmhoque53f64222012-09-05 13:57:51 -0500435 default:
436 fprintf(stderr, "Unexpected response of kind %d\n", kind);
akmhoqueedb68d92013-03-05 10:18:16 -0600437 if ( nlsr->debugging )
438 printf("Unexpected response of kind %d\n", kind);
439 if ( nlsr->detailed_logging )
440 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Unexpected response of "
akmhoque3d319d42013-02-20 11:08:32 -0600441 "kind %d\n", kind);
akmhoqueffacaa82012-09-13 17:48:30 -0500442 break;
akmhoque53f64222012-09-05 13:57:51 -0500443 }
akmhoqueffacaa82012-09-13 17:48:30 -0500444
445 nlsr_unlock();
akmhoqued79438d2012-08-27 13:31:42 -0500446
akmhoque53f64222012-09-05 13:57:51 -0500447 return CCN_UPCALL_RESULT_OK;
akmhoqued79438d2012-08-27 13:31:42 -0500448}
449
akmhoque7ab49a32013-02-20 11:27:51 -0600450/**
451* process any incoming content to NLSR from ccnd
452*/
akmhoque03004e62012-09-06 01:12:28 -0500453
akmhoqued79438d2012-08-27 13:31:42 -0500454void
akmhoque53f64222012-09-05 13:57:51 -0500455process_incoming_content(struct ccn_closure *selfp, struct ccn_upcall_info* info)
akmhoqued79438d2012-08-27 13:31:42 -0500456{
akmhoque7b791452012-10-30 11:24:56 -0500457 if ( nlsr->debugging )
458 printf("process_incoming_content called \n");
459 if ( nlsr->detailed_logging )
460 writeLogg(__FILE__,__FUNCTION__,__LINE__,"process_incoming_content called \n");
akmhoque53f64222012-09-05 13:57:51 -0500461
462 const unsigned char *comp_ptr1;
463 size_t comp_size;
464 int res,i;
465 int nlsr_position=0;
466 int name_comps=(int)info->interest_comps->n;
467
468 for(i=0;i<name_comps;i++)
469 {
470 res=ccn_name_comp_strcmp(info->interest_ccnb,info->interest_comps,i,"nlsr");
471 if( res == 0)
472 {
473 nlsr_position=i;
474 break;
475 }
476 }
477
akmhoque3d319d42013-02-20 11:08:32 -0600478 res=ccn_name_comp_get(info->interest_ccnb, info->interest_comps,
479 nlsr_position+1,&comp_ptr1, &comp_size);
akmhoque53f64222012-09-05 13:57:51 -0500480
akmhoque53f64222012-09-05 13:57:51 -0500481
482 if(!strcmp((char *)comp_ptr1,"info"))
483 {
484 process_incoming_content_info(selfp,info);
485 }
akmhoque03004e62012-09-06 01:12:28 -0500486
akmhoque53f64222012-09-05 13:57:51 -0500487}
488
akmhoque7ab49a32013-02-20 11:27:51 -0600489/**
490* process any incoming "info" content to NLSR from ccnd
491*/
akmhoque03004e62012-09-06 01:12:28 -0500492
akmhoque53f64222012-09-05 13:57:51 -0500493void
akmhoque3d319d42013-02-20 11:08:32 -0600494process_incoming_content_info(struct ccn_closure *selfp,
495 struct ccn_upcall_info* info)
akmhoque53f64222012-09-05 13:57:51 -0500496{
akmhoque7b791452012-10-30 11:24:56 -0500497 if ( nlsr->debugging )
498 printf("process_incoming_content_info called \n");
499 if ( nlsr->detailed_logging )
akmhoque3d319d42013-02-20 11:08:32 -0600500 writeLogg(__FILE__,__FUNCTION__,__LINE__,"process_incoming_content_info"
501 " called \n");
akmhoque03004e62012-09-06 01:12:28 -0500502
akmhoque53f64222012-09-05 13:57:51 -0500503 struct name_prefix *nbr=(struct name_prefix *)malloc(sizeof(struct name_prefix ));
504 get_nbr(nbr,selfp,info);
akmhoque03004e62012-09-06 01:12:28 -0500505
akmhoque7b791452012-10-30 11:24:56 -0500506 if ( nlsr->debugging )
akmhoque3d319d42013-02-20 11:08:32 -0600507 printf("Info Content Received For Neighbor: %s Length:%d\n",nbr->name,
508 nbr->length);
akmhoque7b791452012-10-30 11:24:56 -0500509 if ( nlsr->detailed_logging )
akmhoque3d319d42013-02-20 11:08:32 -0600510 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Info Content Received For Nei"
511 "ghbor: %s Length:%d\n",nbr->name,nbr->length);
akmhoque03004e62012-09-06 01:12:28 -0500512
akmhoquefc7016f2013-03-08 07:17:14 -0600513
akmhoque53f64222012-09-05 13:57:51 -0500514
akmhoque6e2ba842013-03-05 19:35:26 -0600515 if ( contain_key_name(info->content_ccnb, info->pco) == 1){
akmhoque6e2ba842013-03-05 19:35:26 -0600516
akmhoqueb7958182013-03-11 12:03:54 -0500517 int res_verify=verify_key(info->content_ccnb,info->pco,0);
akmhoque03004e62012-09-06 01:12:28 -0500518
akmhoqueb7958182013-03-11 12:03:54 -0500519 if ( res_verify != 0 ){
akmhoque1162d852013-03-15 01:07:00 -0500520 if ( nlsr->debugging )
521 printf("Error in verfiying keys !! :( \n");
akmhoqueb7958182013-03-11 12:03:54 -0500522 }
523 else{
akmhoque1162d852013-03-15 01:07:00 -0500524 if ( nlsr->debugging )
525 printf("Key verification is successful :)\n");
akmhoqueb7958182013-03-11 12:03:54 -0500526 update_adjacent_timed_out_zero_to_adl(nbr);
527 update_adjacent_status_to_adl(nbr,NBR_ACTIVE);
528 print_adjacent_from_adl();
akmhoque53f64222012-09-05 13:57:51 -0500529
akmhoqueb7958182013-03-11 12:03:54 -0500530 if(!nlsr->is_build_adj_lsa_sheduled){
531 if ( nlsr->debugging )
532 printf("Scheduling Build and Install Adj LSA...\n");
533 if ( nlsr->detailed_logging )
534 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Scheduling"
akmhoque6e2ba842013-03-05 19:35:26 -0600535 "Build and Install Adj LSA...\n");
akmhoqueb7958182013-03-11 12:03:54 -0500536 nlsr->event_build_adj_lsa = ccn_schedule_event(
akmhoque6e2ba842013-03-05 19:35:26 -0600537 nlsr->sched, 100000,
akmhoque3d319d42013-02-20 11:08:32 -0600538 &build_and_install_adj_lsa, NULL, 0);
akmhoqueb7958182013-03-11 12:03:54 -0500539 nlsr->is_build_adj_lsa_sheduled=1;
540 }
541 else{
542 if ( nlsr->debugging )
543 printf("Build and Install Adj LSA already scheduled\n");
544 if ( nlsr->detailed_logging )
545 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Build and Install Adj LSA"
akmhoque3d319d42013-02-20 11:08:32 -0600546 " already scheduled\n");
akmhoqueb7958182013-03-11 12:03:54 -0500547 }
akmhoque6e2ba842013-03-05 19:35:26 -0600548
akmhoqueb7958182013-03-11 12:03:54 -0500549 }
akmhoque53f64222012-09-05 13:57:51 -0500550 }
akmhoquefc7016f2013-03-08 07:17:14 -0600551 /*
akmhoque10c9a212013-03-08 07:05:18 -0600552 update_adjacent_timed_out_zero_to_adl(nbr);
553 update_adjacent_status_to_adl(nbr,NBR_ACTIVE);
554 print_adjacent_from_adl();
555
556 if(!nlsr->is_build_adj_lsa_sheduled){
557 if ( nlsr->debugging )
558 printf("Scheduling Build and Install Adj LSA...\n");
559 if ( nlsr->detailed_logging )
560 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Scheduling"
561 "Build and Install Adj LSA...\n");
562 nlsr->event_build_adj_lsa = ccn_schedule_event(
563 nlsr->sched, 100000,
564 &build_and_install_adj_lsa, NULL, 0);
565 nlsr->is_build_adj_lsa_sheduled=1;
566 }
567 else{
568 if ( nlsr->debugging )
569 printf("Build and Install Adj LSA already scheduled\n");
570 if ( nlsr->detailed_logging )
571 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Build and Install Adj LSA"
572 " already scheduled\n");
573 }
akmhoque03004e62012-09-06 01:12:28 -0500574
akmhoquefc7016f2013-03-08 07:17:14 -0600575 */
akmhoque6e2ba842013-03-05 19:35:26 -0600576
akmhoque53f64222012-09-05 13:57:51 -0500577 free(nbr);
akmhoque03004e62012-09-06 01:12:28 -0500578
akmhoque53f64222012-09-05 13:57:51 -0500579
580}
581
akmhoque7ab49a32013-02-20 11:27:51 -0600582/**
583* process any incoming interest timed out content to NLSR from ccnd
584*/
akmhoque53f64222012-09-05 13:57:51 -0500585
akmhoque03004e62012-09-06 01:12:28 -0500586
akmhoque53f64222012-09-05 13:57:51 -0500587void
akmhoque3d319d42013-02-20 11:08:32 -0600588process_incoming_timed_out_interest(struct ccn_closure* selfp,
589 struct ccn_upcall_info* info)
akmhoque53f64222012-09-05 13:57:51 -0500590{
akmhoque3171d652012-11-13 11:44:33 -0600591
592
593 if ( nlsr->debugging )
594 printf("process_incoming_timed_out_interest called \n");
595 if ( nlsr->detailed_logging )
akmhoque3d319d42013-02-20 11:08:32 -0600596 writeLogg(__FILE__,__FUNCTION__,__LINE__,"process_incoming_timed_out_int"
597 "erest called \n");
akmhoque3171d652012-11-13 11:44:33 -0600598
akmhoque53f64222012-09-05 13:57:51 -0500599 int res,i;
600 int nlsr_position=0;
601 int name_comps=(int)info->interest_comps->n;
602
603 for(i=0;i<name_comps;i++)
604 {
605 res=ccn_name_comp_strcmp(info->interest_ccnb,info->interest_comps,i,"nlsr");
606 if( res == 0)
607 {
608 nlsr_position=i;
609 break;
610 }
611 }
612
akmhoque3d319d42013-02-20 11:08:32 -0600613 if(ccn_name_comp_strcmp(info->interest_ccnb,info->interest_comps,
614 nlsr_position+1,"info") == 0)
akmhoque53f64222012-09-05 13:57:51 -0500615 {
616 process_incoming_timed_out_interest_info(selfp,info);
617 }
618}
619
akmhoque7ab49a32013-02-20 11:27:51 -0600620/**
621* process any incoming "info" interest timed out content to NLSR from ccnd
622*/
623
akmhoque53f64222012-09-05 13:57:51 -0500624void
akmhoque3d319d42013-02-20 11:08:32 -0600625process_incoming_timed_out_interest_info(struct ccn_closure* selfp, struct
626 ccn_upcall_info* info)
akmhoque53f64222012-09-05 13:57:51 -0500627{
akmhoque3171d652012-11-13 11:44:33 -0600628
629 if ( nlsr->debugging )
630 printf("process_incoming_timed_out_interest_info called \n");
631 if ( nlsr->detailed_logging )
akmhoque3d319d42013-02-20 11:08:32 -0600632 writeLogg(__FILE__,__FUNCTION__,__LINE__,"process_incoming_timed_out_int"
633 "erest_info called \n");
akmhoque53f64222012-09-05 13:57:51 -0500634
635 struct name_prefix *nbr=(struct name_prefix *)malloc(sizeof(struct name_prefix ));
636 get_nbr(nbr,selfp,info);
637
akmhoque3171d652012-11-13 11:44:33 -0600638 if ( nlsr->debugging )
akmhoque3d319d42013-02-20 11:08:32 -0600639 printf("Info Interest Timed Out for for Neighbor: %s Length:%d\n",
640 nbr->name,nbr->length);
akmhoque3171d652012-11-13 11:44:33 -0600641 if ( nlsr->detailed_logging )
akmhoque3d319d42013-02-20 11:08:32 -0600642 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Info Interest Timed Out for"
643 " Neighbor: %s Length:%d\n",nbr->name,nbr->length);
akmhoque3171d652012-11-13 11:44:33 -0600644
akmhoque03004e62012-09-06 01:12:28 -0500645
646
akmhoque53f64222012-09-05 13:57:51 -0500647 update_adjacent_timed_out_to_adl(nbr,1);
648 print_adjacent_from_adl();
649 int timed_out=get_timed_out_number(nbr);
akmhoque03004e62012-09-06 01:12:28 -0500650
akmhoque3171d652012-11-13 11:44:33 -0600651 if ( nlsr->debugging )
akmhoque3d319d42013-02-20 11:08:32 -0600652 printf("Neighbor: %s Info Interest Timed Out: %d times\n",nbr->name,
653 timed_out);
akmhoque3171d652012-11-13 11:44:33 -0600654 if ( nlsr->detailed_logging )
akmhoque3d319d42013-02-20 11:08:32 -0600655 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Neighbor: %s Info Interest "
656 "Timed Out: %d times\n",nbr->name,timed_out);
akmhoque3171d652012-11-13 11:44:33 -0600657
akmhoque53f64222012-09-05 13:57:51 -0500658
659 if(timed_out<nlsr->interest_retry && timed_out>0) // use configured variables
660 {
akmhoque53f64222012-09-05 13:57:51 -0500661 send_info_interest_to_neighbor(nbr);
662 }
663 else
akmhoque3171d652012-11-13 11:44:33 -0600664 {
akmhoque53f64222012-09-05 13:57:51 -0500665 update_adjacent_status_to_adl(nbr,NBR_DOWN);
666 if(!nlsr->is_build_adj_lsa_sheduled)
667 {
akmhoque3d319d42013-02-20 11:08:32 -0600668 nlsr->event_build_adj_lsa = ccn_schedule_event(nlsr->sched, 1000,
669 &build_and_install_adj_lsa, NULL, 0);
akmhoque53f64222012-09-05 13:57:51 -0500670 nlsr->is_build_adj_lsa_sheduled=1;
671 }
672 }
673
akmhoque284056b2013-03-15 01:20:16 -0500674 if ( nbr->name != NULL )
675 free(nbr->name);
676 if ( nbr != NULL )
677 free(nbr);
akmhoque03004e62012-09-06 01:12:28 -0500678
akmhoque53f64222012-09-05 13:57:51 -0500679
680}
681
akmhoque7ab49a32013-02-20 11:27:51 -0600682/**
683* send "info" interest to each and every neighbor in ADL and also schedule for
684* itself for periodical sending of "info" interest
685*/
akmhoque29c1db52012-09-07 14:47:43 -0500686
akmhoque03004e62012-09-06 01:12:28 -0500687int
akmhoque3d319d42013-02-20 11:08:32 -0600688send_info_interest(struct ccn_schedule *sched, void *clienth,
689 struct ccn_scheduled_event *ev, int flags)
akmhoque53f64222012-09-05 13:57:51 -0500690{
akmhoqueffacaa82012-09-13 17:48:30 -0500691 if(flags == CCN_SCHEDULE_CANCEL)
692 {
693 return -1;
694 }
695
696 nlsr_lock();
697
akmhoque3171d652012-11-13 11:44:33 -0600698 if ( nlsr->debugging )
699 printf("send_info_interest called \n");
700 if ( nlsr->detailed_logging )
701 writeLogg(__FILE__,__FUNCTION__,__LINE__,"send_info_interest called \n");
702
703 if ( nlsr->debugging )
704 printf("\n");
705 if ( nlsr->detailed_logging )
706 writeLogg(__FILE__,__FUNCTION__,__LINE__,"\n");
akmhoqued79438d2012-08-27 13:31:42 -0500707
akmhoque53f64222012-09-05 13:57:51 -0500708 int adl_element,i;
akmhoque53f64222012-09-05 13:57:51 -0500709 struct ndn_neighbor *nbr;
710
711 struct hashtb_enumerator ee;
712 struct hashtb_enumerator *e = &ee;
713
714 hashtb_start(nlsr->adl, e);
715 adl_element=hashtb_n(nlsr->adl);
716
717 for(i=0;i<adl_element;i++)
718 {
719 nbr=e->data;
720 send_info_interest_to_neighbor(nbr->neighbor);
721 hashtb_next(e);
722 }
akmhoque53f64222012-09-05 13:57:51 -0500723 hashtb_end(e);
724
akmhoqueffacaa82012-09-13 17:48:30 -0500725 nlsr_unlock();
726
akmhoque3d319d42013-02-20 11:08:32 -0600727 nlsr->event = ccn_schedule_event(nlsr->sched, 60000000, &send_info_interest,
728 NULL, 0);
akmhoque9fa58a82012-10-05 07:56:02 -0500729
akmhoque53f64222012-09-05 13:57:51 -0500730 return 0;
731}
732
akmhoque7ab49a32013-02-20 11:27:51 -0600733
734/**
735* send "info" interest neighbor nbr
736*
737*/
738
akmhoque53f64222012-09-05 13:57:51 -0500739void
740send_info_interest_to_neighbor(struct name_prefix *nbr)
741{
akmhoque3171d652012-11-13 11:44:33 -0600742
743 if ( nlsr->debugging )
744 printf("send_info_interest_to_neighbor called \n");
745 if ( nlsr->detailed_logging )
akmhoque3d319d42013-02-20 11:08:32 -0600746 writeLogg(__FILE__,__FUNCTION__,__LINE__,"send_info_interest_to_neighbor"
747 " called \n");
akmhoque3171d652012-11-13 11:44:33 -0600748
akmhoqued79438d2012-08-27 13:31:42 -0500749
750 int res;
akmhoque53f64222012-09-05 13:57:51 -0500751 char info_str[5];
752 char nlsr_str[5];
akmhoque53f64222012-09-05 13:57:51 -0500753
akmhoqued79438d2012-08-27 13:31:42 -0500754 memset(&nlsr_str,0,5);
755 sprintf(nlsr_str,"nlsr");
756 memset(&info_str,0,5);
757 sprintf(info_str,"info");
758
akmhoque53f64222012-09-05 13:57:51 -0500759
760 struct ccn_charbuf *name;
akmhoqued79438d2012-08-27 13:31:42 -0500761 name=ccn_charbuf_create();
akmhoqued79438d2012-08-27 13:31:42 -0500762
akmhoque3d319d42013-02-20 11:08:32 -0600763 char *int_name=(char *)malloc(strlen(nbr->name)+1+strlen(nlsr_str)+1+
764 strlen(info_str)+strlen(nlsr->router_name)+1);
765 memset(int_name,0,strlen(nbr->name)+1+strlen(nlsr_str)+1+strlen(info_str)+
766 strlen(nlsr->router_name)+1);
akmhoque53f64222012-09-05 13:57:51 -0500767 memcpy(int_name+strlen(int_name),nbr->name,strlen(nbr->name));
768 memcpy(int_name+strlen(int_name),"/",1);
769 memcpy(int_name+strlen(int_name),nlsr_str,strlen(nlsr_str));
770 memcpy(int_name+strlen(int_name),"/",1);
771 memcpy(int_name+strlen(int_name),info_str,strlen(info_str));
akmhoque03004e62012-09-06 01:12:28 -0500772 memcpy(int_name+strlen(int_name),nlsr->router_name,strlen(nlsr->router_name));
akmhoque53f64222012-09-05 13:57:51 -0500773
774
775 res=ccn_name_from_uri(name,int_name);
776 if ( res >=0 )
777 {
akmhoque53f64222012-09-05 13:57:51 -0500778 /* adding InterestLifeTime and InterestScope filter */
779
780 struct ccn_charbuf *templ;
781 templ = ccn_charbuf_create();
782
783 ccn_charbuf_append_tt(templ, CCN_DTAG_Interest, CCN_DTAG);
784 ccn_charbuf_append_tt(templ, CCN_DTAG_Name, CCN_DTAG);
785 ccn_charbuf_append_closer(templ); /* </Name> */
akmhoque03004e62012-09-06 01:12:28 -0500786 ccn_charbuf_append_tt(templ, CCN_DTAG_Scope, CCN_DTAG);
787 ccn_charbuf_append_tt(templ, 1, CCN_UDATA);
akmhoqueb77b95f2013-02-08 12:28:47 -0600788 /* Adding InterestLifeTime and InterestScope filter done */
akmhoque3d319d42013-02-20 11:08:32 -0600789 ccn_charbuf_append(templ, "2", 1); //scope of interest: 2
790 //(not further than next host)
akmhoque03004e62012-09-06 01:12:28 -0500791 ccn_charbuf_append_closer(templ); /* </Scope> */
akmhoque53f64222012-09-05 13:57:51 -0500792
793 appendLifetime(templ,nlsr->interest_resend_time);
akmhoqueb77b95f2013-02-08 12:28:47 -0600794 unsigned int face_id=get_next_hop_face_from_adl(nbr->name);
795 ccnb_tagged_putf(templ, CCN_DTAG_FaceID, "%u", face_id);
akmhoque53f64222012-09-05 13:57:51 -0500796 ccn_charbuf_append_closer(templ); /* </Interest> */
akmhoqueb77b95f2013-02-08 12:28:47 -0600797
akmhoque53f64222012-09-05 13:57:51 -0500798
akmhoque3171d652012-11-13 11:44:33 -0600799 if ( nlsr->debugging )
akmhoque3d319d42013-02-20 11:08:32 -0600800 printf("Sending info interest on name prefix : %s through Face:%u\n"
801 ,int_name,face_id);
akmhoque3171d652012-11-13 11:44:33 -0600802 if ( nlsr->detailed_logging )
akmhoque3d319d42013-02-20 11:08:32 -0600803 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Sending info interest on"
804 "name prefix : %s through Face:%u\n",int_name,face_id);
akmhoque53f64222012-09-05 13:57:51 -0500805
806 res=ccn_express_interest(nlsr->ccn,name,&(nlsr->in_content),templ);
807
808 if ( res >= 0 )
akmhoque3171d652012-11-13 11:44:33 -0600809 {
810 if ( nlsr->debugging )
811 printf("Info interest sending Successfull .... \n");
812 if ( nlsr->detailed_logging )
akmhoque3d319d42013-02-20 11:08:32 -0600813 writeLogg(__FILE__,__FUNCTION__,__LINE__,"Info"
814 "interest sending Successfull .... \n");
akmhoque3171d652012-11-13 11:44:33 -0600815 }
akmhoque53f64222012-09-05 13:57:51 -0500816 ccn_charbuf_destroy(&templ);
817 }
akmhoque7adb2772013-03-05 16:30:59 -0600818
akmhoque53f64222012-09-05 13:57:51 -0500819 ccn_charbuf_destroy(&name);
820 free(int_name);
akmhoquec06dcf12013-02-20 08:13:37 -0600821}