[−][src]Crate nng_sys
Examples
use nng_sys::*; use std::{ffi::CString, os::raw::c_char, ptr::null_mut}; fn example() { unsafe { let url = CString::new("inproc://nng_sys/tests/example").unwrap(); let url = url.as_bytes_with_nul().as_ptr() as *const c_char; // Reply socket let mut rep_socket = nng_socket::default(); nng_rep0_open(&mut rep_socket); nng_listen(rep_socket, url, null_mut(), 0); // Request socket let mut req_socket = nng_socket::default(); nng_req0_open(&mut req_socket); nng_dial(req_socket, url, null_mut(), 0); // Send message let mut req_msg: *mut nng_msg = null_mut(); nng_msg_alloc(&mut req_msg, 0); // Add a value to the body of the message let val = 0x12345678; nng_msg_append_u32(req_msg, val); nng_sendmsg(req_socket, req_msg, 0); // Receive it let mut recv_msg: *mut nng_msg = null_mut(); nng_recvmsg(rep_socket, &mut recv_msg, 0); // Remove our value from the body of the received message let mut recv_val: u32 = 0; nng_msg_trim_u32(recv_msg, &mut recv_val); assert_eq!(val, recv_val); // Can't do this because nng uses network order (big-endian) //assert_eq!(val, *(nng_msg_body(recv_msg) as *const u32)); nng_close(req_socket); nng_close(rep_socket); } }
Structs
TryFromIntError | |
nng_aio | |
nng_ctx_s | |
nng_dialer_s | |
nng_iov | |
nng_listener_s | |
nng_msg | |
nng_pipe_s | |
nng_sockaddr_in | |
nng_sockaddr_in6 | |
nng_sockaddr_inproc | |
nng_sockaddr_path | |
nng_sockaddr_zt | |
nng_socket_s | |
nng_stat | |
nng_url |
Enums
nng_pipe_ev | |
nng_sockaddr_family | |
nng_stat_type_enum | |
nng_unit_enum | |
nng_zt_status |
Constants
Functions
Type Definitions
Unions
nng_sockaddr |