Lines Matching defs:rp

73 #define	NETFAMILY(rp)	\
74 	(((rp)->rc_flag & RC_INETADDR) ? AF_INET : AF_UNSPEC)
91 nfsrv_cleanentry(struct nfsrvcache *rp)
93 	if ((rp->rc_flag & RC_REPMBUF) != 0)
94 		m_freem(rp->rc_reply);
96 	if ((rp->rc_flag & RC_NAM) != 0)
97 		m_free(rp->rc_nam);
99 	rp->rc_flag &= ~(RC_REPSTATUS|RC_REPMBUF);
131 	struct nfsrvcache *rp;
143 	rp = nfsrv_lookupcache(nd);
144 	if (rp) {
146 		if (TAILQ_NEXT(rp, rc_lru)) {
147 			TAILQ_REMOVE(&nfsrvlruhead, rp, rc_lru);
148 			TAILQ_INSERT_TAIL(&nfsrvlruhead, rp, rc_lru);
150 		if (rp->rc_state == RC_UNUSED)
152 		if (rp->rc_state == RC_INPROG) {
155 		} else if (rp->rc_flag & RC_REPSTATUS) {
157 			nfs_rephead(0, nd, slp, rp->rc_status, repp, &mb);
159 		} else if (rp->rc_flag & RC_REPMBUF) {
161 			*repp = m_copym(rp->rc_reply, 0, M_COPYALL, M_WAIT);
165 			rp->rc_state = RC_INPROG;
168 		rp->rc_flag &= ~RC_LOCKED;
169 		if (rp->rc_flag & RC_WANTED) {
170 			rp->rc_flag &= ~RC_WANTED;
171 			wakeup(rp);
178 		rp = malloc(sizeof(*rp), M_NFSD, M_WAITOK|M_ZERO);
180 		rp->rc_flag = RC_LOCKED;
182 		rp = TAILQ_FIRST(&nfsrvlruhead);
183 		while ((rp->rc_flag & RC_LOCKED) != 0) {
184 			rp->rc_flag |= RC_WANTED;
185 			tsleep_nsec(rp, PZERO-1, "nfsrc", INFSLP);
186 			rp = TAILQ_FIRST(&nfsrvlruhead);
188 		rp->rc_flag |= RC_LOCKED;
189 		LIST_REMOVE(rp, rc_hash);
190 		TAILQ_REMOVE(&nfsrvlruhead, rp, rc_lru);
191 		nfsrv_cleanentry(rp);
192 		rp->rc_flag &= (RC_LOCKED | RC_WANTED);
194 	TAILQ_INSERT_TAIL(&nfsrvlruhead, rp, rc_lru);
195 	rp->rc_state = RC_INPROG;
196 	rp->rc_xid = nd->nd_retxid;
200 		rp->rc_flag |= RC_INETADDR;
201 		rp->rc_inetaddr = saddr->sin_addr.s_addr;
204 		rp->rc_flag |= RC_NAM;
205 		rp->rc_nam = m_copym(nd->nd_nam, 0, M_COPYALL, M_WAIT);
208 	rp->rc_proc = nd->nd_procnum;
210 	LIST_INSERT_HEAD(hash, rp, rc_hash);
211 	rp->rc_flag &= ~RC_LOCKED;
212 	if (rp->rc_flag & RC_WANTED) {
213 		rp->rc_flag &= ~RC_WANTED;
214 		wakeup(rp);
224 	struct nfsrvcache *rp;
229 	rp = nfsrv_lookupcache(nd);
230 	if (rp) {
231 		nfsrv_cleanentry(rp);
232 		rp->rc_state = RC_DONE;
240 				rp->rc_status = nd->nd_repstat;
241 				rp->rc_flag |= RC_REPSTATUS;
243 				rp->rc_reply = m_copym(repmbuf, 0, M_COPYALL,
245 				rp->rc_flag |= RC_REPMBUF;
248 		rp->rc_flag &= ~RC_LOCKED;
249 		if (rp->rc_flag & RC_WANTED) {
250 			rp->rc_flag &= ~RC_WANTED;
251 			wakeup(rp);
261 	struct nfsrvcache *rp, *nextrp;
263 	for (rp = TAILQ_FIRST(&nfsrvlruhead); rp != NULL; rp = nextrp) {
264 		nextrp = TAILQ_NEXT(rp, rc_lru);
265 		LIST_REMOVE(rp, rc_hash);
266 		TAILQ_REMOVE(&nfsrvlruhead, rp, rc_lru);
267 		nfsrv_cleanentry(rp);
268 		free(rp, M_NFSD, sizeof(*rp));
277 	struct nfsrvcache	*rp;
281 	LIST_FOREACH(rp, hash, rc_hash) {
282 		if (nd->nd_retxid == rp->rc_xid &&
283 		    nd->nd_procnum == rp->rc_proc &&
284 		    netaddr_match(NETFAMILY(rp), &rp->rc_haddr, nd->nd_nam)) {
285 			if ((rp->rc_flag & RC_LOCKED)) {
286 				rp->rc_flag |= RC_WANTED;
287 				tsleep_nsec(rp, PZERO - 1, "nfsrc", INFSLP);
290 			rp->rc_flag |= RC_LOCKED;
291 			return (rp);