summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorme_laptop <me_laptop@fb96df88-216d-11de-830c-f3023f12d8ac>2012-07-05 12:08:39 +0000
committerme_laptop <me_laptop@fb96df88-216d-11de-830c-f3023f12d8ac>2012-07-05 12:08:39 +0000
commit5f7db4a13df3a696729c805526a5511f9cccf38d (patch)
tree20046dc467c7702192535af6fcf79cff1d429ab3
parent06c68bd02b0f3fe7c4279985a0f856f91bf7c83f (diff)
downloadpica-pica-5f7db4a13df3a696729c805526a5511f9cccf38d.tar.gz
pica-pica-5f7db4a13df3a696729c805526a5511f9cccf38d.zip
fixed some compiler warnings
git-svn-id: svn://localhost/project_picapica/trunk@140 fb96df88-216d-11de-830c-f3023f12d8ac
-rwxr-xr-xPICA_node.c78
-rw-r--r--PICA_nodejoinskynet.c1
2 files changed, 34 insertions, 45 deletions
diff --git a/PICA_node.c b/PICA_node.c
index 49350ae..131bd76 100755
--- a/PICA_node.c
+++ b/PICA_node.c
@@ -153,7 +153,7 @@ if (buf[2]==PICA_PROTO_VER_HIGH && buf[3]==PICA_PROTO_VER_LOW)
newconn_free(nc);
- if (mp=client_wbuf_push(c,PICA_PROTO_INITRESPOK,PICA_PROTO_INITRESPOK_SIZE))
+ if ((mp = client_wbuf_push(c,PICA_PROTO_INITRESPOK,PICA_PROTO_INITRESPOK_SIZE)))
{
mp->tail[0]='O';
mp->tail[1]='K';
@@ -217,7 +217,7 @@ if (nc->addr.sin_addr.s_addr!=c->addr.sin_addr.s_addr)
if (link->state==PICA_CCLINK_LOCAL_WAITCONNCLE)
{
- if(mp=client_wbuf_push(link->p1,PICA_PROTO_FOUND,PICA_PROTO_FOUND_SIZE))
+ if((mp = client_wbuf_push(link->p1,PICA_PROTO_FOUND,PICA_PROTO_FOUND_SIZE)))
{
*((unsigned int*)mp->tail)=callee_id;
}
@@ -231,7 +231,7 @@ if (link->state==PICA_CCLINK_LOCAL_WAITCONNCLE)
if (link->state==PICA_CCLINK_N2NCLE_WAITCONNCLE)
{
- if(mp=nodelink_wbuf_push(link->caller_node,PICA_PROTO_N2NALLOW,PICA_PROTO_N2NALLOW_SIZE))
+ if((mp = nodelink_wbuf_push(link->caller_node,PICA_PROTO_N2NALLOW,PICA_PROTO_N2NALLOW_SIZE)))
{
*((unsigned int*)mp->tail)=caller_id;
*((unsigned int*)(mp->tail+4))=callee_id;
@@ -267,7 +267,7 @@ if (buf[2]==PICA_PROTO_VER_HIGH &&
if (!nl)
return 0;
- if (mp=nodelink_wbuf_push(nl,PICA_PROTO_INITRESPOK,PICA_PROTO_INITRESPOK_SIZE))
+ if ((mp = nodelink_wbuf_push(nl,PICA_PROTO_INITRESPOK,PICA_PROTO_INITRESPOK_SIZE)))
{
mp->tail[0]='O';
mp->tail[1]='K';
@@ -317,7 +317,7 @@ i=(struct client *)ptr;
callee_id=*(unsigned int*)(buf+2);
-if (o=client_tree_search(callee_id))
+if ((o = client_tree_search(callee_id)))
{
#warning "duplicated connections" // сделать проверку на наличие уже имеющегося соединения между клиентами
// и если оно есть, то разрывать его, либо... ???? надо подумать
@@ -325,7 +325,7 @@ if (o=client_tree_search(callee_id))
#warning "self" // а еще - если клиент вызывает сам себя?
//отправить o _CONNREQINC
- if (mp=client_wbuf_push(o,PICA_PROTO_CONNREQINC,PICA_PROTO_CONNREQINC_SIZE))
+ if ((mp = client_wbuf_push(o,PICA_PROTO_CONNREQINC,PICA_PROTO_CONNREQINC_SIZE)))
{
*((unsigned int*)mp->tail)=i->id;
cclink_list_addlocal(i,o);
@@ -343,7 +343,7 @@ if (cclink_list_findwaitsearch(callee_id)/*search request for this id is already
}
//отправить i _NOTFOUND
-if (mp=client_wbuf_push(i,PICA_PROTO_NOTFOUND,PICA_PROTO_NOTFOUND_SIZE))
+if ((mp = client_wbuf_push(i,PICA_PROTO_NOTFOUND,PICA_PROTO_NOTFOUND_SIZE)))
{
*((unsigned int*)mp->tail)=callee_id;
puts("sending NOTFOUND... put to senq q...");//debug
@@ -354,7 +354,7 @@ return 1;
unsigned int procmsg_CONNALLOW(unsigned char* buf,unsigned int size,void* ptr)
{
-struct client *caller,*callee;
+struct client *callee;
struct cclink *link;
unsigned int caller_id;
@@ -363,12 +363,6 @@ PICA_debug1("received CONALLOW");
callee=(struct client *)ptr;
caller_id=*(unsigned int*)(buf+2);
-puts("procmsg_CONNALLOW_");//debug
-printf("ptr=%X\n",ptr);//debug
-
-puts("procmsg_CONNALLOW__");//debug
-
-
link=cclink_list_search(caller_id,callee->id);
if (!link)
@@ -413,15 +407,15 @@ if (link->state!=PICA_CCLINK_LOCAL_WAITREP &&
if (link->state==PICA_CCLINK_LOCAL_WAITREP)
{
//отправить caller _NOTFOUND
- if (mp=client_wbuf_push(caller,PICA_PROTO_NOTFOUND,PICA_PROTO_NOTFOUND_SIZE))
+ if ((mp = client_wbuf_push(caller,PICA_PROTO_NOTFOUND,PICA_PROTO_NOTFOUND_SIZE)))
{
- *((unsigned int*)mp->tail)=callee->id;
+ *((unsigned int*)mp->tail) = callee->id;
}
}
else if (link->state==PICA_CCLINK_N2NCLE_WAITREP)
{
//отправить caller N2NNOTFOUND
- if (mp=nodelink_wbuf_push(link->caller_node,PICA_PROTO_N2NNOTFOUND,PICA_PROTO_N2NNOTFOUND_SIZE))
+ if ((mp = nodelink_wbuf_push(link->caller_node,PICA_PROTO_N2NNOTFOUND,PICA_PROTO_N2NNOTFOUND_SIZE)))
{
*((unsigned int*)mp->tail)=caller_id;
*( ((unsigned int*)mp->tail)+1)=callee->id;
@@ -500,6 +494,7 @@ struct nodelink *nlp;
unsigned int nl_size=0;
struct nodelink *n=0;
struct client *c=0;
+unsigned char *nl_buf = 0;
PICA_debug1("received NODELISTREQ");
@@ -513,7 +508,7 @@ switch(buf[0])
break;
}
-unsigned char *nl_buf=malloc(65536);
+nl_buf = (unsigned char*)malloc(65536);
if (!nl_buf)
return 0;//ERR
@@ -572,12 +567,11 @@ 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;
+PICA_debug1("received NODELIST");
while(listleft)
{
@@ -645,10 +639,10 @@ struct PICA_proto_msg *mp;
PICA_debug1("received N2NFOUND");
-while(cc=cclink_list_findwaitsearch(callee_id))
+while((cc = cclink_list_findwaitsearch(callee_id)))
{
cclink_attach_remotecle_node(cc,n);
- if(mp=nodelink_wbuf_push(n,PICA_PROTO_N2NCONNREQOUTG,PICA_PROTO_N2NCONNREQOUTG_SIZE))
+ if((mp = nodelink_wbuf_push(n,PICA_PROTO_N2NCONNREQOUTG,PICA_PROTO_N2NCONNREQOUTG_SIZE)))
{
*((unsigned int*)mp->tail) = cc->caller_id;
*((unsigned int*)(mp->tail+4)) = callee_id;
@@ -666,9 +660,9 @@ struct client *callee;
PICA_debug1("received SEARCH");
-if (callee=client_tree_search(callee_id))
+if ((callee = client_tree_search(callee_id)))
{
- if(mp=nodelink_wbuf_push(n,PICA_PROTO_N2NFOUND,PICA_PROTO_N2NFOUND_SIZE))
+ if ((mp = nodelink_wbuf_push(n,PICA_PROTO_N2NFOUND,PICA_PROTO_N2NFOUND_SIZE)))
{
*((unsigned int*)mp->tail) = callee_id;
}
@@ -688,9 +682,9 @@ PICA_debug1("received N2NCONNREQOUTG");
caller_id=*(unsigned int*)(buf+2);
callee_id=*(unsigned int*)(buf+6);
-if (callee=client_tree_search(callee_id))
+if ((callee = client_tree_search(callee_id)))
{
- if (mp=client_wbuf_push(callee,PICA_PROTO_CONNREQINC,PICA_PROTO_CONNREQINC_SIZE))
+ if ((mp = client_wbuf_push(callee,PICA_PROTO_CONNREQINC,PICA_PROTO_CONNREQINC_SIZE)))
{
*((unsigned int*)mp->tail)=caller_id;
cclink_list_addn2ncle(caller_id, n, callee);
@@ -698,7 +692,7 @@ if (callee=client_tree_search(callee_id))
}
else
{
- if(mp=nodelink_wbuf_push(n,PICA_PROTO_N2NNOTFOUND,PICA_PROTO_N2NNOTFOUND_SIZE))
+ if ((mp = nodelink_wbuf_push(n,PICA_PROTO_N2NNOTFOUND,PICA_PROTO_N2NNOTFOUND_SIZE)))
{
*((unsigned int*)mp->tail) = caller_id;
*((unsigned int*)(mp->tail+4)) = callee_id;
@@ -719,13 +713,13 @@ PICA_debug1("received N2NALLOW");
caller_id=*(unsigned int*)(buf+2);
callee_id=*(unsigned int*)(buf+6);
-cc=cclink_list_search(caller_id,callee_id);
+cc = cclink_list_search(caller_id,callee_id);
if (cc)
{
- if (mp=client_wbuf_push(cc->p1,PICA_PROTO_FOUND,PICA_PROTO_FOUND_SIZE))
+ if ((mp = client_wbuf_push(cc->p1,PICA_PROTO_FOUND,PICA_PROTO_FOUND_SIZE)))
{
- *((unsigned int*)mp->tail)=callee_id;
+ *((unsigned int*)mp->tail) = callee_id;
cclink_setwaitconn(cc);
}
@@ -749,7 +743,7 @@ cc=cclink_list_search(caller_id,callee_id);
if (cc)
{
- if (mp=client_wbuf_push(cc->p1,PICA_PROTO_NOTFOUND,PICA_PROTO_NOTFOUND_SIZE))
+ if ((mp = client_wbuf_push(cc->p1,PICA_PROTO_NOTFOUND,PICA_PROTO_NOTFOUND_SIZE)))
{
*((unsigned int*)mp->tail)=callee_id;
}
@@ -807,7 +801,7 @@ if (cc && cc->state==PICA_CCLINK_N2NCLR_ACTIVE)
return 1;
}
-if(mp=nodelink_wbuf_push(n,PICA_PROTO_N2NNOTFOUND,PICA_PROTO_N2NNOTFOUND_SIZE))
+if ((mp = nodelink_wbuf_push(n,PICA_PROTO_N2NNOTFOUND,PICA_PROTO_N2NNOTFOUND_SIZE)))
{
*((unsigned int*)mp->tail) = sender_id;
*((unsigned int*)(mp->tail+4)) = receiver_id;
@@ -1284,7 +1278,7 @@ if (!c)
return;
}
-printf("%p: %u LEFT: %p, RIGHT: %p\n", c, c->id, c->left, c->right);
+printf("%p: %u LEFT: %p, RIGHT: %p\n", (void*)c, c->id, (void*)c->left, (void*)c->right);
if (c->left)
client_tree_print(c->left);
@@ -1384,13 +1378,12 @@ SSL_set_fd(ci->ssl_comm,ci->sck_comm);
//ci->state=PICA_CLSTATE_SENDINGRESP;
-printf("client_list_addnew: returning %X\n",ci);//debug
+
return ci;
}
void client_list_delete(struct client* ci)
{
-printf("client_list_delete: ci=%X\n",ci);//debug
SSL_free(ci->ssl_comm);
//удаление из списка
@@ -1468,7 +1461,6 @@ if (!nl->r_buf)
}
nl->buflen_r=DEFAULT_BUF_SIZE;
-printf("nodelink_list_addnew: returning %X\n",nl);//debug
nodelink_list_count++;
return nl;
}
@@ -1716,24 +1708,22 @@ void process_listen_read(fd_set *readfds)
struct newconn *nc;
SOCKET s;
struct sockaddr_in addr;
-int addrsize=sizeof(struct sockaddr_in);
+int addrsize = sizeof(struct sockaddr_in);
if (FD_ISSET(listen_comm_sck,readfds))
{
puts("accept");//debug
- s=accept(listen_comm_sck,(struct sockaddr*)&addr,&addrsize);
+ s = accept(listen_comm_sck,(struct sockaddr*)&addr,&addrsize);
- if (s>0)
+ if (s >= 0)
{
- nc=newconn_add(newconns,&newconns_pos);
+ nc = newconn_add(newconns,&newconns_pos);
- nc->sck=s;
- nc->addr=addr;
+ nc->sck = s;
+ nc->addr = addr;
printf("accepted connection\n");//debug
}
else
{
- newconn_free(nc);
-
perror("accept:");//debug
printf("accept error!\n");//debug
//ERR_CHECK
diff --git a/PICA_nodejoinskynet.c b/PICA_nodejoinskynet.c
index 32a239e..e91cfcd 100644
--- a/PICA_nodejoinskynet.c
+++ b/PICA_nodejoinskynet.c
@@ -152,7 +152,6 @@ int PICA_node_joinskynet(char* addrlistfilename,const char *my_addr)
struct PICA_nodeaddr *nap,*addrlist_h=0;
struct nodelink *nlp;
struct newconn nc;
-clock_t tmst,t;
int ret;