Lines Matching refs:nnp

1174 	rc_node_t *nnp = np->rcn_node;  in rc_notify_info_interested()  local
1191 if (strcmp(nnp->rn_name, rnip->rni_namelist[i]) == 0) in rc_notify_info_interested()
1195 if (strcmp(nnp->rn_type, rnip->rni_typelist[i]) == 0) in rc_notify_info_interested()
1203 rc_notify_insert_node(rc_node_t *nnp) in rc_notify_insert_node() argument
1205 rc_notify_t *np = &nnp->rn_notify; in rc_notify_insert_node()
1211 if (nnp->rn_id.rl_type != REP_PROTOCOL_ENTITY_PROPERTYGRP) in rc_notify_insert_node()
1215 np->rcn_node = nnp; in rc_notify_insert_node()
1258 rc_notify_remove_node(rc_node_t *nnp) in rc_notify_remove_node() argument
1260 rc_notify_t *np = &nnp->rn_notify; in rc_notify_remove_node()
1263 assert(!MUTEX_HELD(&nnp->rn_lock)); in rc_notify_remove_node()
3272 rc_node_t *nnp; in rc_node_update() local
3294 nnp = cache_lookup_unlocked(bp, &np->rn_id); in rc_node_update()
3295 if (nnp == NULL) { in rc_node_update()
3304 (void) pthread_mutex_lock(&nnp->rn_lock); in rc_node_update()
3307 if (!(nnp->rn_flags & RC_NODE_IN_TX) || in rc_node_update()
3308 !rc_node_wait_flag(nnp, RC_NODE_IN_TX)) in rc_node_update()
3311 rc_node_rele_locked(nnp); in rc_node_update()
3318 if (nnp->rn_flags & RC_NODE_DEAD) { in rc_node_update()
3319 (void) pthread_mutex_unlock(&nnp->rn_lock); in rc_node_update()
3320 if (nnp != np && cpg == NULL) in rc_node_update()
3321 rc_node_assign(npp, nnp); /* updated */ in rc_node_update()
3322 rc_node_rele(nnp); in rc_node_update()
3326 assert(!(nnp->rn_flags & RC_NODE_OLD)); in rc_node_update()
3327 (void) pthread_mutex_unlock(&nnp->rn_lock); in rc_node_update()
3329 if (nnp != np && cpg == NULL) in rc_node_update()
3330 rc_node_assign(npp, nnp); /* updated */ in rc_node_update()
3332 rc_node_rele(nnp); in rc_node_update()
3334 return ((nnp == np)? REP_PROTOCOL_SUCCESS : REP_PROTOCOL_DONE); in rc_node_update()
4168 rc_node_t *nnp; in rc_notify_node_delete() local
4176 nnp = np->rn_parent; in rc_notify_node_delete()
4200 np = nnp; in rc_notify_node_delete()
5140 rc_node_t *nnp, *prev; in rc_attach_snapshot() local
5288 nnp = NULL; in rc_attach_snapshot()
5305 while ((nnp = prev->rn_former) != NULL) { in rc_attach_snapshot()
5306 if (nnp->rn_snapshot_id == snapid) { in rc_attach_snapshot()
5307 rc_node_hold(nnp); in rc_attach_snapshot()
5310 prev = nnp; in rc_attach_snapshot()
5314 if (nnp == NULL) { in rc_attach_snapshot()
5316 nnp = rc_node_alloc(); in rc_attach_snapshot()
5317 if (nnp == NULL) { in rc_attach_snapshot()
5322 nnp->rn_id = np->rn_id; /* structure assignment */ in rc_attach_snapshot()
5323 nnp->rn_hash = np->rn_hash; in rc_attach_snapshot()
5324 nnp->rn_name = strdup(np->rn_name); in rc_attach_snapshot()
5325 nnp->rn_snapshot_id = snapid; in rc_attach_snapshot()
5326 nnp->rn_flags = RC_NODE_IN_TX | RC_NODE_USING_PARENT; in rc_attach_snapshot()
5328 if (nnp->rn_name == NULL) { in rc_attach_snapshot()
5339 nnp->rn_snapshot_id = snapid; /* fill in new snapid */ in rc_attach_snapshot()
5341 assert(nnp->rn_snapshot_id == snapid); in rc_attach_snapshot()
5351 prev->rn_former = nnp->rn_former; in rc_attach_snapshot()
5352 (void) pthread_mutex_lock(&nnp->rn_lock); in rc_attach_snapshot()
5353 nnp->rn_flags &= ~RC_NODE_ON_FORMER; in rc_attach_snapshot()
5354 nnp->rn_former = NULL; in rc_attach_snapshot()
5355 (void) pthread_mutex_unlock(&nnp->rn_lock); in rc_attach_snapshot()
5363 rc_node_relink_child(pp, np, nnp); in rc_attach_snapshot()
5382 if (nnp != NULL) { in rc_attach_snapshot()
5384 rc_node_destroy(nnp); in rc_attach_snapshot()
5386 rc_node_rele(nnp); in rc_attach_snapshot()
6977 rc_node_t *nnp; in rc_tx_commit() local
7166 nnp = rc_node_alloc(); in rc_tx_commit()
7167 if (nnp == NULL) { in rc_tx_commit()
7172 nnp->rn_id = np->rn_id; /* structure assignment */ in rc_tx_commit()
7173 nnp->rn_hash = np->rn_hash; in rc_tx_commit()
7174 nnp->rn_name = strdup(np->rn_name); in rc_tx_commit()
7175 nnp->rn_type = strdup(np->rn_type); in rc_tx_commit()
7176 nnp->rn_pgflags = np->rn_pgflags; in rc_tx_commit()
7178 nnp->rn_flags = RC_NODE_IN_TX | RC_NODE_USING_PARENT; in rc_tx_commit()
7180 if (nnp->rn_name == NULL || nnp->rn_type == NULL) { in rc_tx_commit()
7181 rc_node_destroy(nnp); in rc_tx_commit()
7195 rc_node_destroy(nnp); in rc_tx_commit()
7201 rc_node_destroy(nnp); in rc_tx_commit()
7209 rc_node_destroy(nnp); in rc_tx_commit()
7217 rc_node_destroy(nnp); in rc_tx_commit()
7239 rc_node_destroy(nnp); in rc_tx_commit()
7243 nnp->rn_gen_id = np->rn_gen_id; in rc_tx_commit()
7247 rc = object_tx_commit(&np->rn_id, tx_data, &nnp->rn_gen_id); in rc_tx_commit()
7256 rc_node_destroy(nnp); in rc_tx_commit()
7279 rc_node_relink_child(pp, np, nnp); in rc_tx_commit()
7500 rc_node_t *nnp; in rc_notify_info_wait() local
7575 nnp = np->rcn_node; in rc_notify_info_wait()
7576 assert(nnp != NULL); in rc_notify_info_wait()
7588 rc_node_assign(out, nnp); in rc_notify_info_wait()