wangzhengquan
2020-06-16 27a32410481fc10e789315b3a1dab88a33020270
bipc/bipc.c
@@ -106,7 +106,7 @@
}
int bipc_recv(nng_socket *sock,  void *data, size_t *sizep) {
int bipc_recv(bipc_socket_t *sock,  void *data, size_t *sizep) {
   
   //int rv = nng_recv(*sock, data, sizep, 0);
   // char *buf = NULL;
@@ -120,12 +120,24 @@
   return rv;
}
int bipc_setopt(bipc_socket_t *s, const char *opt, const void *val, size_t valsz) {
   const char *tmp_opt;
   if(strcmp(opt, BIPC_OPT_RECVTIMEO) == 0) {
      tmp_opt = NNG_OPT_RECVTIMEO;
   }
   return nng_setopt(*s, tmp_opt, val, valsz);
}
void bipc_free(void *ptr, size_t size) {
    nng_free(ptr, size);
}
int bipc_close(bipc_socket_t *s){
   return nng_close(*s);
}
const char * bipc_strerror(int error) {
   return nng_strerror(error);