diff options
| author | me_desk <me_desk@fb96df88-216d-11de-830c-f3023f12d8ac> | 2012-06-19 20:24:30 +0000 |
|---|---|---|
| committer | me_desk <me_desk@fb96df88-216d-11de-830c-f3023f12d8ac> | 2012-06-19 20:24:30 +0000 |
| commit | 53cd37ae110c635ba63be822ccbfd0cbd1169ea4 (patch) | |
| tree | 14d91a45a410a6f3f5cc18b6f6f7af21ef9db0e2 /PICA_node.c | |
| parent | 8df9466ada46e4b07990b9cb7e8b1cd61b96844a (diff) | |
| download | pica-pica-53cd37ae110c635ba63be822ccbfd0cbd1169ea4.tar.gz pica-pica-53cd37ae110c635ba63be822ccbfd0cbd1169ea4.zip | |
saving new nodes to sqlite database
git-svn-id: svn://localhost/project_picapica/trunk@129 fb96df88-216d-11de-830c-f3023f12d8ac
Diffstat (limited to 'PICA_node.c')
| -rwxr-xr-x | PICA_node.c | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/PICA_node.c b/PICA_node.c index 72c30cc..3f3b2e5 100755 --- a/PICA_node.c +++ b/PICA_node.c @@ -581,11 +581,12 @@ while(listleft) } else { - char addr[256]; + struct PICA_nodeaddr na; + //char addr[256]; struct newconn nc; struct nodelink *nlp; - memset(addr,0,256); + memset(na.addr,0,256); memset(&nc,0,sizeof(struct newconn)); switch(buf[size-listleft]) @@ -595,8 +596,8 @@ while(listleft) na_ipv4.addr=*(in_addr_t*)(buf+size-listleft+1); na_ipv4.port=*(in_port_t*)(buf+size-listleft+5); - sprintf(addr,"%.16s",inet_ntoa(*(struct in_addr*)&na_ipv4.addr)); - if (try_connect_to_node(addr,ntohs(na_ipv4.port),&nc)) + sprintf(na.addr,"%.16s",inet_ntoa(*(struct in_addr*)&na_ipv4.addr)); + if (try_connect_to_node(na.addr,ntohs(na_ipv4.port),&nc)) if (try_get_reply(&nc)) { nlp=nodelink_list_addnew(&nc); @@ -604,10 +605,13 @@ while(listleft) nodelink_attach_nodeaddr(nlp,na_ipv4.magick,&na_ipv4,sizeof(struct PICA_nodeaddr_ipv4)); printf("LINKED NODE:%s\n",inet_ntoa(*(struct in_addr*)&na_ipv4.addr));//debug } + + na.port = ntohs(na_ipv4.port); listleft-=PICA_PROTO_NODELIST_ITEM_IPV4_SIZE; break; } + PICA_nodeaddr_save("nodes.sqlite", &na);//CONF filename } } |