diff options
| author | me_desk <me_desk@fb96df88-216d-11de-830c-f3023f12d8ac> | 2012-09-29 15:09:20 +0000 |
|---|---|---|
| committer | me_desk <me_desk@fb96df88-216d-11de-830c-f3023f12d8ac> | 2012-09-29 15:09:20 +0000 |
| commit | 29a367041df5c041c066a2b1220b9667536ecc91 (patch) | |
| tree | 0bb931f453e02dfe4142ee9df77eec9fccd5fc05 /PICA_node.c | |
| parent | b2883e24e7ad2b0853ebbc5b6e611695f9a5f2d5 (diff) | |
| download | pica-pica-29a367041df5c041c066a2b1220b9667536ecc91.tar.gz pica-pica-29a367041df5c041c066a2b1220b9667536ecc91.zip | |
sending PINGREP from client, bugfix in sending PINGREQ from node
git-svn-id: svn://localhost/project_picapica/trunk@210 fb96df88-216d-11de-830c-f3023f12d8ac
Diffstat (limited to 'PICA_node.c')
| -rwxr-xr-x | PICA_node.c | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/PICA_node.c b/PICA_node.c index 0ff6894..6084fbd 100755 --- a/PICA_node.c +++ b/PICA_node.c @@ -487,7 +487,7 @@ unsigned int procmsg_PINGREP_client(unsigned char* buf,unsigned int size,void* p { struct client *c = (struct client*)ptr; -PICA_debug3("PINGREP"); +PICA_debug3("PINGREP c2n"); c->disconnect_ticking = 0; c->tmst = time(0); @@ -516,7 +516,7 @@ unsigned int procmsg_PINGREP_node(unsigned char* buf,unsigned int size,void* ptr { struct nodelink *n=(struct nodelink *)ptr; -PICA_debug3("PINGREP"); +PICA_debug3("PINGREP n2n"); n->disconnect_ticking = 0; n->tmst = time(0); @@ -1521,6 +1521,7 @@ if (!ci->r_buf) } ci->buflen_r = DEFAULT_BUF_SIZE; +ci->tmst = time(0); return ci; } @@ -1643,6 +1644,8 @@ if (!nl->r_buf) } nl->buflen_r=DEFAULT_BUF_SIZE; +nl->tmst = time(0); + nodelink_list_count++; return nl; } @@ -1845,7 +1848,11 @@ while(i_ptr) if ((mp = client_wbuf_push(i_ptr, PICA_PROTO_PINGREQ, PICA_PROTO_PINGREQ_SIZE))) { + PICA_debug3("sending PINGREQ to %p", i_ptr); RAND_bytes(mp->tail, 2); + + i_ptr->tmst = time(0); + i_ptr->disconnect_ticking = 1; } else kill_ptr = i_ptr; |