sbin/hastd/control.c

76 control_set_role_common(struct hastd_config *cfg, struct nv *nvout,
83 		nv_add_string(nvout, name, "resource%u", no);
94 			nv_add_int16(nvout, EHAST_NOENTRY, "error%u", no);
101 	nv_add_string(nvout, role2str(res->hr_role), "role%u", no);
152 control_status_worker(struct hast_resource *res, struct nv *nvout,
196 	nv_add_string(nvout, str, "status%u", no);
197 	nv_add_uint64(nvout, nv_get_uint64(cnvin, "dirty"), "dirty%u", no);
198 	nv_add_uint32(nvout, nv_get_uint32(cnvin, "extentsize"),
200 	nv_add_uint32(nvout, nv_get_uint32(cnvin, "keepdirty"),
202 	nv_add_uint64(nvout, nv_get_uint64(cnvin, "stat_read"),
204 	nv_add_uint64(nvout, nv_get_uint64(cnvin, "stat_write"),
206 	nv_add_uint64(nvout, nv_get_uint64(cnvin, "stat_delete"),
208 	nv_add_uint64(nvout, nv_get_uint64(cnvin, "stat_flush"),
210 	nv_add_uint64(nvout, nv_get_uint64(cnvin, "stat_activemap_update"),
212 	nv_add_uint64(nvout, nv_get_uint64(cnvin, "stat_read_error"),
214 	nv_add_uint64(nvout, nv_get_uint64(cnvin, "stat_write_error"),
216 	nv_add_uint64(nvout, nv_get_uint64(cnvin, "stat_delete_error"),
218 	nv_add_uint64(nvout, nv_get_uint64(cnvin, "stat_flush_error"),
220 	nv_add_uint64(nvout, nv_get_uint64(cnvin, "idle_queue_size"),
222 	nv_add_uint64(nvout, nv_get_uint64(cnvin, "local_queue_size"),
224 	nv_add_uint64(nvout, nv_get_uint64(cnvin, "send_queue_size"),
226 	nv_add_uint64(nvout, nv_get_uint64(cnvin, "recv_queue_size"),
228 	nv_add_uint64(nvout, nv_get_uint64(cnvin, "done_queue_size"),
236 		nv_add_int16(nvout, error, "error");
240 control_status(struct hastd_config *cfg, struct nv *nvout,
245 	PJDLOG_ASSERT(nvout != NULL);
249 	nv_add_string(nvout, name, "resource%u", no);
257 			nv_add_int16(nvout, EHAST_NOENTRY, "error%u", no);
262 	nv_add_string(nvout, res->hr_provname, "provname%u", no);
263 	nv_add_string(nvout, res->hr_localpath, "localpath%u", no);
264 	nv_add_string(nvout, res->hr_remoteaddr, "remoteaddr%u", no);
266 		nv_add_string(nvout, res->hr_sourceaddr, "sourceaddr%u", no);
269 		nv_add_string(nvout, "fullsync", "replication%u", no);
272 		nv_add_string(nvout, "memsync", "replication%u", no);
275 		nv_add_string(nvout, "async", "replication%u", no);
278 		nv_add_string(nvout, "unknown", "replication%u", no);
281 	nv_add_string(nvout, checksum_name(res->hr_checksum),
283 	nv_add_string(nvout, compression_name(res->hr_compression),
285 	nv_add_string(nvout, role2str(res->hr_role), "role%u", no);
286 	nv_add_int32(nvout, res->hr_workerpid, "workerpid%u", no);
304 	control_status_worker(res, nvout, no);
311 	struct nv *nvin, *nvout;
323 	nvin = nvout = NULL;
340 	nvout = nv_alloc();
341 	if (nvout == NULL) {
376 				control_set_role_common(cfg, nvout, role, res,
380 				control_status(cfg, nvout, res, res->hr_name,
399 				control_set_role_common(cfg, nvout, role, NULL,
403 				control_status(cfg, nvout, NULL, str, ii);
413 	if (nv_error(nvout) != 0)
417 		nv_add_int16(nvout, error, "error");
419 	if (hast_proto_send(NULL, conn, nvout, NULL, 0) == -1)
424 	if (nvout != NULL)
425 		nv_free(nvout);
437 	struct nv *nvin, *nvout;
455 		nvout = nv_alloc();
460 				nv_add_string(nvout, "complete", "status");
462 				nv_add_string(nvout, "degraded", "status");
464 			nv_add_uint32(nvout, (uint32_t)res->hr_extentsize,
467 				nv_add_uint32(nvout,
469 				nv_add_uint64(nvout,
473 				nv_add_uint32(nvout, (uint32_t)0, "keepdirty");
474 				nv_add_uint64(nvout, (uint64_t)0, "dirty");
476 			nv_add_uint64(nvout, res->hr_stat_read, "stat_read");
477 			nv_add_uint64(nvout, res->hr_stat_write, "stat_write");
478 			nv_add_uint64(nvout, res->hr_stat_delete,
480 			nv_add_uint64(nvout, res->hr_stat_flush, "stat_flush");
481 			nv_add_uint64(nvout, res->hr_stat_activemap_update,
483 			nv_add_uint64(nvout, res->hr_stat_read_error,
485 			nv_add_uint64(nvout, res->hr_stat_write_error +
488 			nv_add_uint64(nvout, res->hr_stat_delete_error,
490 			nv_add_uint64(nvout, res->hr_stat_flush_error +
493 			res->output_status_aux(nvout);
494 			nv_add_int16(nvout, 0, "error");
504 			nv_add_int16(nvout, 0, "error");
507 			nv_add_int16(nvout, EINVAL, "error");
511 		if (nv_error(nvout) != 0) {
513 			nv_free(nvout);
516 		if (hast_proto_send(NULL, res->hr_ctrl, nvout, NULL, 0) == -1) {
520 		nv_free(nvout);