54 #include <nv.h>
264 output_status_aux(struct nv *nvout)  in output_status_aux()
634 	struct nv *nvout, *nvin;  in init_remote()
1504 	struct nv *nv;  in keepalive_send()  local
1516 	nv = nv_alloc();  in keepalive_send()
1517 	nv_add_uint8(nv, HIO_KEEPALIVE, "cmd");  in keepalive_send()
1518 	if (nv_error(nv) != 0) {  in keepalive_send()
1520 		nv_free(nv);  in keepalive_send()
1525 	if (hast_proto_send(res, res->hr_remoteout, nv, NULL, 0) == -1) {  in keepalive_send()
1529 		nv_free(nv);  in keepalive_send()
1535 	nv_free(nv);  in keepalive_send()
1549 	struct nv *nv;  in remote_send_thread()  local
1601 		nv = nv_alloc();  in remote_send_thread()
1602 		nv_add_uint8(nv, cmd, "cmd");  in remote_send_thread()
1603 		nv_add_uint64(nv, (uint64_t)ggio->gctl_seq, "seq");  in remote_send_thread()
1604 		nv_add_uint64(nv, offset, "offset");  in remote_send_thread()
1605 		nv_add_uint64(nv, length, "length");  in remote_send_thread()
1607 			nv_add_uint8(nv, 1, "memsync");  in remote_send_thread()
1608 		if (nv_error(nv) != 0) {  in remote_send_thread()
1609 			hio->hio_errors[ncomp] = nv_error(nv);  in remote_send_thread()
1615 			    strerror(nv_error(nv)));  in remote_send_thread()
1641 		if (hast_proto_send(res, res->hr_remoteout, nv, data,  in remote_send_thread()
1654 		nv_free(nv);  in remote_send_thread()
1659 		nv_free(nv);  in remote_send_thread()
1705 	struct nv *nv;  in remote_recv_thread()  local
1743 		if (hast_proto_recv_hdr(res->hr_remotein, &nv) == -1) {  in remote_recv_thread()
1751 		seq = nv_get_uint64(nv, "seq");  in remote_recv_thread()
1754 			nv_free(nv);  in remote_recv_thread()
1757 		memsyncack = nv_exists(nv, "received");  in remote_recv_thread()
1771 			nv_free(nv);  in remote_recv_thread()
1775 		error = nv_get_int16(nv, "error");  in remote_recv_thread()
1781 			nv_free(nv);  in remote_recv_thread()
1789 				nv_free(nv);  in remote_recv_thread()
1792 			if (hast_proto_recv_data(res, res->hr_remotein, nv,  in remote_recv_thread()
1798 				nv_free(nv);  in remote_recv_thread()
1812 		nv_free(nv);  in remote_recv_thread()
2213 primary_config_reload(struct hast_resource *res, struct nv *nv)  in primary_config_reload()  argument
2223 	nv_assert(nv, "remoteaddr");  in primary_config_reload()
2224 	nv_assert(nv, "sourceaddr");  in primary_config_reload()
2225 	nv_assert(nv, "replication");  in primary_config_reload()
2226 	nv_assert(nv, "checksum");  in primary_config_reload()
2227 	nv_assert(nv, "compression");  in primary_config_reload()
2228 	nv_assert(nv, "timeout");  in primary_config_reload()
2229 	nv_assert(nv, "exec");  in primary_config_reload()
2230 	nv_assert(nv, "metaflush");  in primary_config_reload()
2244 	vstr = nv_get_string(nv, "remoteaddr");  in primary_config_reload()
2253 	vstr = nv_get_string(nv, "sourceaddr");  in primary_config_reload()
2258 	vint = nv_get_int32(nv, "replication");  in primary_config_reload()
2263 	vint = nv_get_int32(nv, "checksum");  in primary_config_reload()
2268 	vint = nv_get_int32(nv, "compression");  in primary_config_reload()
2273 	vint = nv_get_int32(nv, "timeout");  in primary_config_reload()
2278 	vstr = nv_get_string(nv, "exec");  in primary_config_reload()
2283 	vint = nv_get_int32(nv, "metaflush");  in primary_config_reload()
2323 			vstr = nv_get_string(nv, "remoteaddr");  in primary_config_reload()