Lines Matching defs:nnp
1174 rc_node_t *nnp = np->rcn_node;
1191 if (strcmp(nnp->rn_name, rnip->rni_namelist[i]) == 0)
1195 if (strcmp(nnp->rn_type, rnip->rni_typelist[i]) == 0)
1203 rc_notify_insert_node(rc_node_t *nnp)
1205 rc_notify_t *np = &nnp->rn_notify;
1211 if (nnp->rn_id.rl_type != REP_PROTOCOL_ENTITY_PROPERTYGRP)
1215 np->rcn_node = nnp;
1258 rc_notify_remove_node(rc_node_t *nnp)
1260 rc_notify_t *np = &nnp->rn_notify;
1263 assert(!MUTEX_HELD(&nnp->rn_lock));
1873 * First, swap np and nnp in the cache. newp's RC_NODE_IN_TX flag
3272 rc_node_t *nnp;
3280 * appropriate value. But leave *nnp pointing at us.
3294 nnp = cache_lookup_unlocked(bp, &np->rn_id);
3295 if (nnp == NULL) {
3304 (void) pthread_mutex_lock(&nnp->rn_lock);
3307 if (!(nnp->rn_flags & RC_NODE_IN_TX) ||
3308 !rc_node_wait_flag(nnp, RC_NODE_IN_TX))
3311 rc_node_rele_locked(nnp);
3318 if (nnp->rn_flags & RC_NODE_DEAD) {
3319 (void) pthread_mutex_unlock(&nnp->rn_lock);
3320 if (nnp != np && cpg == NULL)
3321 rc_node_assign(npp, nnp); /* updated */
3322 rc_node_rele(nnp);
3326 assert(!(nnp->rn_flags & RC_NODE_OLD));
3327 (void) pthread_mutex_unlock(&nnp->rn_lock);
3329 if (nnp != np && cpg == NULL)
3330 rc_node_assign(npp, nnp); /* updated */
3332 rc_node_rele(nnp);
3334 return ((nnp == np)? REP_PROTOCOL_SUCCESS : REP_PROTOCOL_DONE);
4168 rc_node_t *nnp;
4176 nnp = np->rn_parent;
4200 np = nnp;
5140 rc_node_t *nnp, *prev;
5288 nnp = NULL;
5305 while ((nnp = prev->rn_former) != NULL) {
5306 if (nnp->rn_snapshot_id == snapid) {
5307 rc_node_hold(nnp);
5310 prev = nnp;
5314 if (nnp == NULL) {
5316 nnp = rc_node_alloc();
5317 if (nnp == NULL) {
5322 nnp->rn_id = np->rn_id; /* structure assignment */
5323 nnp->rn_hash = np->rn_hash;
5324 nnp->rn_name = strdup(np->rn_name);
5325 nnp->rn_snapshot_id = snapid;
5326 nnp->rn_flags = RC_NODE_IN_TX | RC_NODE_USING_PARENT;
5328 if (nnp->rn_name == NULL) {
5339 nnp->rn_snapshot_id = snapid; /* fill in new snapid */
5341 assert(nnp->rn_snapshot_id == snapid);
5351 prev->rn_former = nnp->rn_former;
5352 (void) pthread_mutex_lock(&nnp->rn_lock);
5353 nnp->rn_flags &= ~RC_NODE_ON_FORMER;
5354 nnp->rn_former = NULL;
5355 (void) pthread_mutex_unlock(&nnp->rn_lock);
5361 * replace np with nnp
5363 rc_node_relink_child(pp, np, nnp);
5382 if (nnp != NULL) {
5384 rc_node_destroy(nnp);
5386 rc_node_rele(nnp);
6977 rc_node_t *nnp;
7166 nnp = rc_node_alloc();
7167 if (nnp == NULL) {
7172 nnp->rn_id = np->rn_id; /* structure assignment */
7173 nnp->rn_hash = np->rn_hash;
7174 nnp->rn_name = strdup(np->rn_name);
7175 nnp->rn_type = strdup(np->rn_type);
7176 nnp->rn_pgflags = np->rn_pgflags;
7178 nnp->rn_flags = RC_NODE_IN_TX | RC_NODE_USING_PARENT;
7180 if (nnp->rn_name == NULL || nnp->rn_type == NULL) {
7181 rc_node_destroy(nnp);
7195 rc_node_destroy(nnp);
7201 rc_node_destroy(nnp);
7209 rc_node_destroy(nnp);
7217 rc_node_destroy(nnp);
7239 rc_node_destroy(nnp);
7243 nnp->rn_gen_id = np->rn_gen_id;
7246 /* Sets nnp->rn_gen_id on success. */
7247 rc = object_tx_commit(&np->rn_id, tx_data, &nnp->rn_gen_id);
7256 rc_node_destroy(nnp);
7277 * replace np with nnp
7279 rc_node_relink_child(pp, np, nnp);
7500 rc_node_t *nnp;
7575 nnp = np->rcn_node;
7576 assert(nnp != NULL);
7579 * We can't bump nnp's reference count without grabbing its
7581 * temporarily block all removals to keep nnp from
7588 rc_node_assign(out, nnp);