749 entity_setup(repcache_client_t *cp, struct rep_protocol_entity_setup *rpr)  in entity_setup()  argument
756 	if ((ep = entity_find(cp, rpr->rpr_entityid)) != NULL) {  in entity_setup()
762 		if (type != rpr->rpr_entitytype)  in entity_setup()
767 	switch (type = rpr->rpr_entitytype) {  in entity_setup()
786 	ep->re_id = rpr->rpr_entityid;  in entity_setup()
802 	const struct rep_protocol_entity_name *rpr = in;  in entity_name()  local
809 	ep = entity_find(cp, rpr->rpr_entityid);  in entity_name()
817 	    sz, rpr->rpr_answertype, &sz);  in entity_name()
836 	const struct rep_protocol_entity_name *rpr = in;  in entity_parent_type()  local
842 	ep = entity_find(cp, rpr->rpr_entityid);  in entity_parent_type()
870     struct rep_protocol_entity_get_child *rpr)  in entity_get_child()  argument
875 	uint32_t parentid = rpr->rpr_entityid;  in entity_get_child()
876 	uint32_t childid = rpr->rpr_childid;  in entity_get_child()
882 	rpr->rpr_name[sizeof (rpr->rpr_name) - 1] = 0;  in entity_get_child()
884 	result = rc_node_get_child(&parent->re_node, rpr->rpr_name,  in entity_get_child()
905 entity_get_parent(repcache_client_t *cp, struct rep_protocol_entity_parent *rpr)  in entity_get_parent()  argument
910 	uint32_t childid = rpr->rpr_entityid;  in entity_get_parent()
911 	uint32_t outid = rpr->rpr_outid;  in entity_get_parent()
927 entity_get(repcache_client_t *cp, struct rep_protocol_entity_get *rpr)  in entity_get()  argument
932 	ep = entity_find(cp, rpr->rpr_entityid);  in entity_get()
937 	switch (rpr->rpr_object) {  in entity_get()
956 entity_update(repcache_client_t *cp, struct rep_protocol_entity_update *rpr)  in entity_update()  argument
961 	if (rpr->rpr_changeid == INVALID_CHANGEID)  in entity_update()
964 	ep = entity_find(cp, rpr->rpr_entityid);  in entity_update()
969 	if (ep->re_changeid == rpr->rpr_changeid) {  in entity_update()
974 			ep->re_changeid = rpr->rpr_changeid;  in entity_update()
983 entity_reset(repcache_client_t *cp, struct rep_protocol_entity_reset *rpr)  in entity_reset()  argument
987 	ep = entity_find(cp, rpr->rpr_entityid);  in entity_reset()
1018     struct rep_protocol_entity_create_child *rpr)  in entity_create_child()  argument
1023 	uint32_t parentid = rpr->rpr_entityid;  in entity_create_child()
1024 	uint32_t childid = rpr->rpr_childid;  in entity_create_child()
1028 	if (rpr->rpr_changeid == INVALID_CHANGEID)  in entity_create_child()
1035 	rpr->rpr_name[sizeof (rpr->rpr_name) - 1] = 0;  in entity_create_child()
1037 	if (child->re_changeid == rpr->rpr_changeid) {  in entity_create_child()
1041 		    rpr->rpr_childtype, rpr->rpr_name, &child->re_node);  in entity_create_child()
1043 			child->re_changeid = rpr->rpr_changeid;  in entity_create_child()
1054     struct rep_protocol_entity_create_pg *rpr)  in entity_create_pg()  argument
1059 	uint32_t parentid = rpr->rpr_entityid;  in entity_create_pg()
1060 	uint32_t childid = rpr->rpr_childid;  in entity_create_pg()
1064 	if (rpr->rpr_changeid == INVALID_CHANGEID)  in entity_create_pg()
1071 	rpr->rpr_name[sizeof (rpr->rpr_name) - 1] = 0;  in entity_create_pg()
1072 	rpr->rpr_type[sizeof (rpr->rpr_type) - 1] = 0;  in entity_create_pg()
1074 	if (child->re_changeid == rpr->rpr_changeid) {  in entity_create_pg()
1078 		    child->re_type, rpr->rpr_name, rpr->rpr_type,  in entity_create_pg()
1079 		    rpr->rpr_flags, &child->re_node);  in entity_create_pg()
1081 			child->re_changeid = rpr->rpr_changeid;  in entity_create_pg()
1092     struct rep_protocol_entity_delete *rpr)  in entity_delete()  argument
1096 	uint32_t entityid = rpr->rpr_entityid;  in entity_delete()
1100 	if (rpr->rpr_changeid == INVALID_CHANGEID)  in entity_delete()
1108 	if (entity->re_changeid == rpr->rpr_changeid) {  in entity_delete()
1113 			entity->re_changeid = rpr->rpr_changeid;  in entity_delete()
1122 entity_teardown(repcache_client_t *cp, struct rep_protocol_entity_teardown *rpr)  in entity_teardown()  argument
1124 	entity_remove(cp, rpr->rpr_entityid);  in entity_teardown()
1135 iter_setup(repcache_client_t *cp, struct rep_protocol_iter_request *rpr)  in iter_setup()  argument
1145 	if ((iter = iter_find(cp, rpr->rpr_iterid)) != NULL) {  in iter_setup()
1162 	iter->ri_id = rpr->rpr_iterid;  in iter_setup()
1185 iter_start(repcache_client_t *cp, struct rep_protocol_iter_start *rpr)  in iter_start()  argument
1191 	result = iter_find_w_entity(cp, rpr->rpr_iterid, &iter,  in iter_start()
1192 	    rpr->rpr_entity, &ep);  in iter_start()
1207 	rpr->rpr_pattern[sizeof (rpr->rpr_pattern) - 1] = 0;  in iter_start()
1210 	    rpr->rpr_itertype, rpr->rpr_flags, rpr->rpr_pattern);  in iter_start()
1239 iter_read(repcache_client_t *cp, struct rep_protocol_iter_read *rpr)  in iter_read()  argument
1246 	result = iter_find_w_entity(cp, rpr->rpr_iterid, &iter,  in iter_read()
1247 	    rpr->rpr_entityid, &ep);  in iter_read()
1252 	sequence = rpr->rpr_sequence;  in iter_read()
1295 	const struct rep_protocol_iter_read_value *rpr = in;  in iter_read_value()  local
1305 	iter = iter_find(cp, rpr->rpr_iterid);  in iter_read_value()
1312 	sequence = rpr->rpr_sequence;  in iter_read_value()
1348 iter_reset(repcache_client_t *cp, struct rep_protocol_iter_request *rpr)  in iter_reset()  argument
1350 	repcache_iter_t *iter = iter_find(cp, rpr->rpr_iterid);  in iter_reset()
1364 iter_teardown(repcache_client_t *cp, struct rep_protocol_iter_request *rpr)  in iter_teardown()  argument
1366 	iter_remove(cp, rpr->rpr_iterid);  in iter_teardown()
1372 tx_start(repcache_client_t *cp, struct rep_protocol_transaction_start *rpr)  in tx_start()  argument
1378 	uint32_t txid = rpr->rpr_entityid_tx;  in tx_start()
1379 	uint32_t epid = rpr->rpr_entityid;  in tx_start()
1413 	const struct rep_protocol_transaction_commit *rpr = in;  in tx_commit()  local
1419 	if (rpr->rpr_size != insz) {  in tx_commit()
1424 	tx = entity_find(cp, rpr->rpr_entityid);  in tx_commit()
1437 		out->rpr_response = rc_tx_commit(&tx->re_node, rpr->rpr_cmd,  in tx_commit()
1458 next_snaplevel(repcache_client_t *cp, struct rep_protocol_entity_pair *rpr)  in next_snaplevel()  argument
1463 	uint32_t srcid = rpr->rpr_entity_src;  in next_snaplevel()
1464 	uint32_t destid = rpr->rpr_entity_dst;  in next_snaplevel()
1481 snapshot_take(repcache_client_t *cp, struct rep_protocol_snapshot_take *rpr)  in snapshot_take()  argument
1484 	uint32_t srcid = rpr->rpr_entityid_src;  in snapshot_take()
1486 	uint32_t destid = rpr->rpr_entityid_dest;  in snapshot_take()
1497 		rpr->rpr_name[sizeof (rpr->rpr_name) - 1] = 0;  in snapshot_take()
1499 		if (rpr->rpr_flags == REP_SNAPSHOT_NEW)  in snapshot_take()
1501 			    NULL, rpr->rpr_name, &dest->re_node);  in snapshot_take()
1502 		else if (rpr->rpr_flags == REP_SNAPSHOT_ATTACH &&  in snapshot_take()
1503 		    rpr->rpr_name[0] == 0)  in snapshot_take()
1517     struct rep_protocol_snapshot_take_named *rpr)  in snapshot_take_named()  argument
1520 	uint32_t srcid = rpr->rpr_entityid_src;  in snapshot_take_named()
1522 	uint32_t destid = rpr->rpr_entityid_dest;  in snapshot_take_named()
1533 		rpr->rpr_svcname[sizeof (rpr->rpr_svcname) - 1] = 0;  in snapshot_take_named()
1534 		rpr->rpr_instname[sizeof (rpr->rpr_instname) - 1] = 0;  in snapshot_take_named()
1535 		rpr->rpr_name[sizeof (rpr->rpr_name) - 1] = 0;  in snapshot_take_named()
1537 		result = rc_snapshot_take_new(&src->re_node, rpr->rpr_svcname,  in snapshot_take_named()
1538 		    rpr->rpr_instname, rpr->rpr_name, &dest->re_node);  in snapshot_take_named()
1547 snapshot_attach(repcache_client_t *cp, struct rep_protocol_snapshot_attach *rpr)  in snapshot_attach()  argument
1550 	uint32_t srcid = rpr->rpr_entityid_src;  in snapshot_attach()
1552 	uint32_t destid = rpr->rpr_entityid_dest;  in snapshot_attach()
1573 	const struct rep_protocol_property_request *rpr = in;  in property_get_type()  local
1580 	ep = entity_find(cp, rpr->rpr_entityid);  in property_get_type()
1615 	const struct rep_protocol_property_request *rpr = in;  in property_get_value()  local
1621 	ep = entity_find(cp, rpr->rpr_entityid);  in property_get_value()
1645     struct rep_protocol_propertygrp_request *rpr, int *out_fd)  in propertygrp_notify()  argument
1659 	if ((ep = entity_find(cp, rpr->rpr_entityid)) == NULL) {  in propertygrp_notify()
1689     struct rep_protocol_notify_request *rpr)  in client_add_notify()  argument
1691 	rpr->rpr_pattern[sizeof (rpr->rpr_pattern) - 1] = 0;  in client_add_notify()
1693 	switch (rpr->rpr_type) {  in client_add_notify()
1696 		    rpr->rpr_pattern));  in client_add_notify()
1700 		    rpr->rpr_pattern));  in client_add_notify()
1714 	const struct rep_protocol_wait_request *rpr = in;  in client_wait()  local
1733 		if ((ep = entity_find(cp, rpr->rpr_entityid)) != NULL) {  in client_wait()
1770     struct rep_protocol_backup_request *rpr)  in backup_repository()  argument
1778 	rpr->rpr_name[REP_PROTOCOL_NAME_LEN - 1] = 0;  in backup_repository()
1779 	if (strcmp(rpr->rpr_name, REPOSITORY_BOOT_BACKUP) == 0)  in backup_repository()
1783 	if (rpr->rpr_changeid != cp->rc_changeid) {  in backup_repository()
1784 		result = backend_create_backup(rpr->rpr_name);  in backup_repository()
1786 			cp->rc_changeid = rpr->rpr_changeid;  in backup_repository()
1807 set_annotation(repcache_client_t *cp, struct rep_protocol_annotation *rpr)  in set_annotation()  argument
1819 	if (rpr->rpr_operation[0] != 0) {  in set_annotation()
1823 		rpr->rpr_operation[sizeof (rpr->rpr_operation) - 1] = 0;  in set_annotation()
1824 		if ((operation = strdup(rpr->rpr_operation)) == NULL)  in set_annotation()
1827 	if (rpr->rpr_file[0] != 0) {  in set_annotation()
1831 		rpr->rpr_file[sizeof (rpr->rpr_file) - 1] = 0;  in set_annotation()
1832 		if ((file = strdup(rpr->rpr_file)) == NULL)  in set_annotation()
2027     struct rep_protocol_switch_request *rpr)  in repository_switch()  argument
2038 	if (rpr->rpr_changeid != cp->rc_changeid) {  in repository_switch()
2039 		if ((result = backend_switch(rpr->rpr_flag)) ==  in repository_switch()
2041 			cp->rc_changeid = rpr->rpr_changeid;  in repository_switch()
2051     const void *rpr);
2068     const void *rpr, int *out_fd);