diff options
| author | me_desk <me_desk@fb96df88-216d-11de-830c-f3023f12d8ac> | 2012-07-04 07:59:07 +0000 |
|---|---|---|
| committer | me_desk <me_desk@fb96df88-216d-11de-830c-f3023f12d8ac> | 2012-07-04 07:59:07 +0000 |
| commit | 70b51b80ce48dfe60978b6cde9c45544c2c00ec9 (patch) | |
| tree | ecfde26188d420a63fc9ec2741cedd1b43c56e23 /PICA_node.c | |
| parent | a5557e562f177e1b2f838fd925026603412f1987 (diff) | |
| download | pica-pica-70b51b80ce48dfe60978b6cde9c45544c2c00ec9.tar.gz pica-pica-70b51b80ce48dfe60978b6cde9c45544c2c00ec9.zip | |
debug1 for all received protocol messages; TASKS update
git-svn-id: svn://localhost/project_picapica/trunk@138 fb96df88-216d-11de-830c-f3023f12d8ac
Diffstat (limited to 'PICA_node.c')
| -rwxr-xr-x | PICA_node.c | 37 |
1 files changed, 29 insertions, 8 deletions
diff --git a/PICA_node.c b/PICA_node.c index c1f4646..07f4bf7 100755 --- a/PICA_node.c +++ b/PICA_node.c @@ -142,6 +142,8 @@ unsigned int procmsg_INITREQ(unsigned char* buf,unsigned int size,void* ptr) struct newconn *nc=(struct newconn*)ptr; struct PICA_proto_msg *mp; +PICA_debug1("received INITREQ"); + if (buf[2]==PICA_PROTO_VER_HIGH && buf[3]==PICA_PROTO_VER_LOW) { struct client *c; @@ -158,7 +160,6 @@ if (buf[2]==PICA_PROTO_VER_HIGH && buf[3]==PICA_PROTO_VER_LOW) } c->state=PICA_CLSTATE_SENDINGRESP; - printf("got PICA_PROTO_INITREQ from client\n");//debug }///////---------<<<<<<<<<<< new client else { @@ -177,7 +178,7 @@ struct newconn *nc=(struct newconn*)ptr; unsigned int caller_id,callee_id; struct cclink *link; -puts("received CONNID");//debug +PICA_debug1("received CONNID"); caller_id=*((unsigned int*)(buf+2)); callee_id=*((unsigned int*)(buf+6)); @@ -253,6 +254,8 @@ unsigned int procmsg_NODECONNREQ(unsigned char* buf,unsigned int size,void* ptr) struct newconn *nc=(struct newconn*)ptr; struct PICA_proto_msg *mp; +PICA_debug1("received NODECONNREQ"); + if (buf[2]==PICA_PROTO_VER_HIGH && buf[3]==PICA_PROTO_VER_LOW) { @@ -308,7 +311,7 @@ struct client *i,*o;//i - указатель на вызывающего клиÐ unsigned int callee_id; struct PICA_proto_msg *mp; -puts("procmsg_CONNREQOUTGOING");//debug +PICA_debug1("received CONNREQOUTG"); i=(struct client *)ptr; @@ -355,7 +358,7 @@ struct client *caller,*callee; struct cclink *link; unsigned int caller_id; -puts("procmsg_CONNALLOW");//debug +PICA_debug1("received CONALLOW"); callee=(struct client *)ptr; caller_id=*(unsigned int*)(buf+2); @@ -388,7 +391,7 @@ struct cclink *link; unsigned int caller_id; struct PICA_proto_msg *mp; -puts("procmsg_procmsg_CONNDENY");//debug +PICA_debug1("received CONNDENY"); callee=(struct client *)ptr; caller_id=*(unsigned int*)(buf+2); @@ -432,6 +435,9 @@ return 1; unsigned int procmsg_NODERESP(unsigned char* buf,unsigned int size,void* ptr) { + +PICA_debug1("received NODERESP"); + switch(buf[0]) { case PICA_PROTO_INITRESPOK: @@ -454,6 +460,8 @@ unsigned int procmsg_NEWNODE(unsigned char* buf,unsigned int size,void* ptr) struct nodelink *n=(struct nodelink *)ptr; struct PICA_nodeaddr na; +PICA_debug1("received NEWNODE"); + switch (buf[0]) { case PICA_PROTO_NEWNODE_IPV4: @@ -493,6 +501,8 @@ unsigned int nl_size=0; struct nodelink *n=0; struct client *c=0; +PICA_debug1("received NODELISTREQ"); + switch(buf[0]) { case PICA_PROTO_CLNODELISTREQ: @@ -508,7 +518,6 @@ unsigned char *nl_buf=malloc(65536); if (!nl_buf) return 0;//ERR -puts("NODELISTREQ");//debug {//TEMP FIXME CONF //собственный адрес узла @@ -563,12 +572,12 @@ unsigned int procmsg_NODELIST(unsigned char* buf,unsigned int size,void* ptr) { struct PICA_nodeaddr_ipv4 na_ipv4; +PICA_debug1("received NODELIST"); + struct nodelink *n=(struct nodelink *)ptr; unsigned int listsize=size-2-PICA_MSG_VARSIZE_INT16; unsigned int listleft=listsize; -puts("NODELIST");//debug -printf("NODELIST_SIZE:%u\n",listsize); while(listleft) { @@ -634,6 +643,8 @@ struct nodelink *n=(struct nodelink *)ptr; unsigned int callee_id=*(unsigned int*)(buf+2); struct PICA_proto_msg *mp; +PICA_debug1("received N2NFOUND"); + while(cc=cclink_list_findwaitsearch(callee_id)) { cclink_attach_remotecle_node(cc,n); @@ -653,6 +664,8 @@ unsigned int callee_id=*(unsigned int*)(buf+2); struct PICA_proto_msg *mp; struct client *callee; +PICA_debug1("received SEARCH"); + if (callee=client_tree_search(callee_id)) { if(mp=nodelink_wbuf_push(n,PICA_PROTO_N2NFOUND,PICA_PROTO_N2NFOUND_SIZE)) @@ -670,6 +683,8 @@ unsigned int caller_id,callee_id; struct PICA_proto_msg *mp; struct client *callee; +PICA_debug1("received N2NCONNREQOUTG"); + caller_id=*(unsigned int*)(buf+2); callee_id=*(unsigned int*)(buf+6); @@ -699,6 +714,8 @@ unsigned int caller_id,callee_id; struct PICA_proto_msg *mp; struct cclink *cc; +PICA_debug1("received N2NALLOW"); + caller_id=*(unsigned int*)(buf+2); callee_id=*(unsigned int*)(buf+6); @@ -723,6 +740,8 @@ unsigned int caller_id,callee_id; struct PICA_proto_msg *mp; struct cclink *cc; +PICA_debug1("received N2NNOTFOUND"); + caller_id=*(unsigned int*)(buf+2); callee_id=*(unsigned int*)(buf+6); @@ -748,6 +767,8 @@ unsigned int sender_id,receiver_id; struct cclink *cc; unsigned int len,datalen; +PICA_debug1("received N2NMSG"); + len=*(unsigned short*)(buf+2); sender_id=*(unsigned int*)(buf+4); receiver_id=*(unsigned int*)(buf+8); |
