X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fmeta.c;fp=src%2Fmeta.c;h=9420a49b09670f16873486107d4eea4c09929359;hb=196806f90f40fcc0cf727abd4bed6bc5aefff5ff;hp=a51df8dd182f40ce44f261063fe7393ca13e50ce;hpb=d34be0cfec4f726ffdcad2fcb393780a8daba8b9;p=meshlink diff --git a/src/meta.c b/src/meta.c index a51df8dd..9420a49b 100644 --- a/src/meta.c +++ b/src/meta.c @@ -50,7 +50,7 @@ bool send_meta(meshlink_handle_t *mesh, connection_t *c, const char *buffer, int } logger(mesh, MESHLINK_DEBUG, "Sending %d bytes of metadata to %s (%s)", length, - c->name, c->hostname); + c->name, c->hostname); if(c->allow_request == ID) { buffer_add(&c->outbuf, buffer, length); @@ -116,12 +116,12 @@ bool receive_meta(meshlink_handle_t *mesh, connection_t *c) { if(inlen <= 0) { if(!inlen || !errno) { logger(mesh, MESHLINK_INFO, "Connection closed by %s (%s)", - c->name, c->hostname); + c->name, c->hostname); } else if(sockwouldblock(sockerrno)) return true; else logger(mesh, MESHLINK_ERROR, "Metadata socket read error for %s (%s): %s", - c->name, c->hostname, sockstrerror(sockerrno)); + c->name, c->hostname, sockstrerror(sockerrno)); return false; } @@ -145,9 +145,8 @@ bool receive_meta(meshlink_handle_t *mesh, connection_t *c) { if(c->inbuf.len >= sizeof inbuf) { logger(mesh, MESHLINK_ERROR, "Input buffer full for %s (%s)", c->name, c->hostname); return false; - } else { + } else return true; - } } return sptps_receive_data(&c->sptps, inbuf, inlen);