Lines Matching refs:wq
17 struct autofs_wait_queue *wq, *nwq;
28 wq = sbi->queues;
30 while (wq) {
31 nwq = wq->next;
32 wq->status = -ENOENT; /* Magic is gone - report failure */
33 kfree(wq->name.name);
34 wq->name.name = NULL;
35 wake_up_interruptible(&wq->queue);
36 if (!--wq->wait_ctr)
37 kfree(wq);
38 wq = nwq;
80 struct autofs_wait_queue *wq,
93 (unsigned long) wq->wait_queue_token,
94 wq->name.len, wq->name.name, type);
109 mp->wait_queue_token = wq->wait_queue_token;
110 mp->len = wq->name.len;
111 memcpy(mp->name, wq->name.name, wq->name.len);
112 mp->name[wq->name.len] = '\0';
122 ep->wait_queue_token = wq->wait_queue_token;
123 ep->len = wq->name.len;
124 memcpy(ep->name, wq->name.name, wq->name.len);
125 ep->name[wq->name.len] = '\0';
142 packet->wait_queue_token = wq->wait_queue_token;
143 packet->len = wq->name.len;
144 memcpy(packet->name, wq->name.name, wq->name.len);
145 packet->name[wq->name.len] = '\0';
146 packet->dev = wq->dev;
147 packet->ino = wq->ino;
148 packet->uid = from_kuid_munged(user_ns, wq->uid);
149 packet->gid = from_kgid_munged(user_ns, wq->gid);
150 packet->pid = wq->pid;
151 packet->tgid = wq->tgid;
170 autofs_wait_release(sbi, wq->wait_queue_token, ret);
227 struct autofs_wait_queue *wq;
229 for (wq = sbi->queues; wq; wq = wq->next) {
230 if (wq->name.hash == qstr->hash &&
231 wq->name.len == qstr->len &&
232 wq->name.name &&
233 !memcmp(wq->name.name, qstr->name, qstr->len))
236 return wq;
253 struct autofs_wait_queue *wq;
260 wq = autofs_find_wait(sbi, qstr);
261 if (wq) {
262 *wait = wq;
294 wq = autofs_find_wait(sbi, qstr);
295 if (wq) {
296 *wait = wq;
352 struct autofs_wait_queue *wq;
410 ret = validate_request(&wq, sbi, &qstr, path, notify);
418 if (!wq) {
420 wq = kmalloc(sizeof(struct autofs_wait_queue), GFP_KERNEL);
421 if (!wq) {
427 wq->wait_queue_token = autofs_next_wait_queue;
430 wq->next = sbi->queues;
431 sbi->queues = wq;
432 init_waitqueue_head(&wq->queue);
433 memcpy(&wq->name, &qstr, sizeof(struct qstr));
434 wq->dev = autofs_get_dev(sbi);
435 wq->ino = autofs_get_ino(sbi);
436 wq->uid = current_uid();
437 wq->gid = current_gid();
438 wq->pid = pid;
439 wq->tgid = tgid;
440 wq->status = -EINTR; /* Status return if interrupted */
441 wq->wait_ctr = 2;
460 (unsigned long) wq->wait_queue_token, wq->name.len,
461 wq->name.name, notify);
466 autofs_notify_daemon(sbi, wq, type);
468 wq->wait_ctr++;
470 (unsigned long) wq->wait_queue_token, wq->name.len,
471 wq->name.name, notify);
477 * wq->name.name is NULL iff the lock is already released
480 wait_event_killable(wq->queue, wq->name.name == NULL);
481 status = wq->status;
508 ino->uid = wq->uid;
509 ino->gid = wq->gid;
519 if (!--wq->wait_ctr)
520 kfree(wq);
530 struct autofs_wait_queue *wq, **wql;
533 for (wql = &sbi->queues; (wq = *wql) != NULL; wql = &wq->next) {
534 if (wq->wait_queue_token == wait_queue_token)
538 if (!wq) {
543 *wql = wq->next; /* Unlink from chain */
544 kfree(wq->name.name);
545 wq->name.name = NULL; /* Do not wait on this queue */
546 wq->status = status;
547 wake_up(&wq->queue);
548 if (!--wq->wait_ctr)
549 kfree(wq);