sbin/hastctl/hastctl.c

45 #include "nv.h"
260 control_set_role(struct nv *nv, const char *newrole)
269 		res = nv_get_string(nv, "resource%u", ii);
273 		error = nv_get_int16(nv, "error%u", ii);
280 		oldrole = nv_get_string(nv, "role%u", ii);
293 control_list(struct nv *nv)
303 		str = nv_get_string(nv, "resource%u", ii);
307 		error = nv_get_int16(nv, "error%u", ii);
314 		printf("  role: %s\n", nv_get_string(nv, "role%u", ii));
316 		    nv_get_string(nv, "provname%u", ii));
318 		    nv_get_string(nv, "localpath%u", ii));
320 		    (unsigned int)nv_get_uint32(nv, "extentsize%u", ii),
321 		    (intmax_t)nv_get_uint32(nv, "extentsize%u", ii));
323 		    (unsigned int)nv_get_uint32(nv, "keepdirty%u", ii));
325 		    nv_get_string(nv, "remoteaddr%u", ii));
326 		str = nv_get_string(nv, "sourceaddr%u", ii);
330 		    nv_get_string(nv, "replication%u", ii));
331 		str = nv_get_string(nv, "status%u", ii);
334 		pid = nv_get_int32(nv, "workerpid%u", ii);
338 		    (uintmax_t)nv_get_uint64(nv, "dirty%u", ii),
339 		    (intmax_t)nv_get_uint64(nv, "dirty%u", ii));
342 		    (uintmax_t)nv_get_uint64(nv, "stat_read%u", ii));
344 		    (uintmax_t)nv_get_uint64(nv, "stat_write%u", ii));
346 		    (uintmax_t)nv_get_uint64(nv, "stat_delete%u", ii));
348 		    (uintmax_t)nv_get_uint64(nv, "stat_flush%u", ii));
350 		    (uintmax_t)nv_get_uint64(nv, "stat_activemap_update%u", ii));
353 		    (uintmax_t)nv_get_uint64(nv, "stat_read_error%u", ii),
354 		    (uintmax_t)nv_get_uint64(nv, "stat_write_error%u", ii),
355 		    (uintmax_t)nv_get_uint64(nv, "stat_delete_error%u", ii),
356 		    (uintmax_t)nv_get_uint64(nv, "stat_flush_error%u", ii));
359 		    (uintmax_t)nv_get_uint64(nv, "local_queue_size%u", ii),
360 		    (uintmax_t)nv_get_uint64(nv, "send_queue_size%u", ii),
361 		    (uintmax_t)nv_get_uint64(nv, "recv_queue_size%u", ii),
362 		    (uintmax_t)nv_get_uint64(nv, "done_queue_size%u", ii),
363 		    (uintmax_t)nv_get_uint64(nv, "idle_queue_size%u", ii));
369 control_status(struct nv *nv)
379 		str = nv_get_string(nv, "resource%u", ii);
387 		error = nv_get_int16(nv, "error%u", ii);
394 		str = nv_get_string(nv, "status%u", ii);
396 		printf("%-15s", nv_get_string(nv, "role%u", ii));
398 		    nv_get_string(nv, "localpath%u", ii));
400 		    nv_get_string(nv, "remoteaddr%u", ii));
408 	struct nv *nv;
503 		nv = nv_alloc();
504 		nv_add_uint8(nv, HASTCTL_CMD_SETROLE, "cmd");
506 			nv_add_uint8(nv, HAST_ROLE_INIT, "role");
508 			nv_add_uint8(nv, HAST_ROLE_PRIMARY, "role");
510 			nv_add_uint8(nv, HAST_ROLE_SECONDARY, "role");
514 			nv_add_string(nv, argv[ii + 1], "resource%d", ii);
519 		nv = nv_alloc();
520 		nv_add_uint8(nv, HASTCTL_CMD_STATUS, "cmd");
522 			nv_add_string(nv, "all", "resource%d", 0);
525 				nv_add_string(nv, argv[ii], "resource%d", ii);
548 	if (hast_proto_send(NULL, controlconn, nv, NULL, 0) == -1) {
553 	nv_free(nv);
555 	if (hast_proto_recv_hdr(controlconn, &nv) == -1) {
561 	error = nv_get_int16(nv, "error");
566 	nv_set_error(nv, 0);
570 		error = control_set_role(nv, argv[0]);
573 		error = control_list(nv);
576 		error = control_status(nv);