sbin/hastd/primary.c

55 #include <nv.h>
582 	struct nv *nvout, *nvin;
1483 	struct nv *nv;
1495 	nv = nv_alloc();
1496 	nv_add_uint8(nv, HIO_KEEPALIVE, "cmd");
1497 	if (nv_error(nv) != 0) {
1499 		nv_free(nv);
1504 	if (hast_proto_send(res, res->hr_remoteout, nv, NULL, 0) == -1) {
1508 		nv_free(nv);
1514 	nv_free(nv);
1528 	struct nv *nv;
1580 		nv = nv_alloc();
1581 		nv_add_uint8(nv, cmd, "cmd");
1582 		nv_add_uint64(nv, (uint64_t)ggio->gctl_seq, "seq");
1583 		nv_add_uint64(nv, offset, "offset");
1584 		nv_add_uint64(nv, length, "length");
1587 			nv_add_uint8(nv, 1, "memsync");
1589 		if (nv_error(nv) != 0) {
1590 			hio->hio_errors[ncomp] = nv_error(nv);
1596 			    strerror(nv_error(nv)));
1621 		if (hast_proto_send(res, res->hr_remoteout, nv, data,
1642 		nv_free(nv);
1647 		nv_free(nv);
1689 	struct nv *nv;
1725 		if (hast_proto_recv_hdr(res->hr_remotein, &nv) == -1) {
1733 		seq = nv_get_uint64(nv, "seq");
1736 			nv_free(nv);
1739 		memsyncack = nv_exists(nv, "received");
1752 			nv_free(nv);
1756 		error = nv_get_int16(nv, "error");
1762 			nv_free(nv);
1770 				nv_free(nv);
1773 			if (hast_proto_recv_data(res, res->hr_remotein, nv,
1779 				nv_free(nv);
1793 		nv_free(nv);
2240 primary_config_reload(struct hast_resource *res, struct nv *nv)
2250 	nv_assert(nv, "remoteaddr");
2251 	nv_assert(nv, "sourceaddr");
2252 	nv_assert(nv, "replication");
2253 	nv_assert(nv, "checksum");
2254 	nv_assert(nv, "compression");
2255 	nv_assert(nv, "timeout");
2256 	nv_assert(nv, "exec");
2257 	nv_assert(nv, "metaflush");
2271 	vstr = nv_get_string(nv, "remoteaddr");
2280 	vstr = nv_get_string(nv, "sourceaddr");
2285 	vint = nv_get_int32(nv, "replication");
2290 	vint = nv_get_int32(nv, "checksum");
2295 	vint = nv_get_int32(nv, "compression");
2300 	vint = nv_get_int32(nv, "timeout");
2305 	vstr = nv_get_string(nv, "exec");
2310 	vint = nv_get_int32(nv, "metaflush");
2350 			vstr = nv_get_string(nv, "remoteaddr");