| | |
| | | } |
| | | |
| | | |
| | | 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; |
| | |
| | | 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); |