41 #include <nv.h>
52 	/* Size of nv headers. */
56 typedef int hps_send_t(const struct hast_resource *, struct nv *nv, void **,
58 typedef int hps_recv_t(const struct hast_resource *, struct nv *nv, void **,
73  * Send the given nv structure via conn.
74  * We keep headers in nv structure and pass data in separate argument.
79     struct nv *nv, const void *data, size_t size)  in hast_proto_send()  argument
97 			(void)pipeline[ii].hps_send(res, nv, &dptr, &size,  in hast_proto_send()
100 		nv_add_uint32(nv, size, "size");  in hast_proto_send()
101 		if (nv_error(nv) != 0) {  in hast_proto_send()
102 			errno = nv_error(nv);  in hast_proto_send()
107 	eb = nv_hton(nv);  in hast_proto_send()
130 hast_proto_recv_hdr(const struct proto_conn *conn, struct nv **nvp)  in hast_proto_recv_hdr()
133 	struct nv *nv;  in hast_proto_recv_hdr()  local
138 	nv = NULL;  in hast_proto_recv_hdr()
159 	nv = nv_ntoh(eb);  in hast_proto_recv_hdr()
160 	if (nv == NULL)  in hast_proto_recv_hdr()
163 	*nvp = nv;  in hast_proto_recv_hdr()
173     struct nv *nv, void *data, size_t size)  in hast_proto_recv_data()  argument
188 	dsize = nv_get_uint32(nv, "size");  in hast_proto_recv_data()
193 		(void)nv_set_error(nv, 0);  in hast_proto_recv_data()
199 			ret = pipeline[ii - 1].hps_recv(res, nv, &dptr,  in hast_proto_recv_data()