Commit d5febc99 authored by Oleg Drokin's avatar Oleg Drokin Committed by Greg Kroah-Hartman

staging/lustre: Remove unused ptlrpcd_add_rqset()

No point in retaining it if it's unused.
Reported-by: default avatarArnd Bergmann <arnd@arndb.de>
Signed-off-by: default avatarOleg Drokin <green@linuxhacker.ru>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@linuxfoundation.org>
parent 2d075f05
...@@ -2902,7 +2902,6 @@ void ptlrpcd_stop(struct ptlrpcd_ctl *pc, int force); ...@@ -2902,7 +2902,6 @@ void ptlrpcd_stop(struct ptlrpcd_ctl *pc, int force);
void ptlrpcd_free(struct ptlrpcd_ctl *pc); void ptlrpcd_free(struct ptlrpcd_ctl *pc);
void ptlrpcd_wake(struct ptlrpc_request *req); void ptlrpcd_wake(struct ptlrpc_request *req);
void ptlrpcd_add_req(struct ptlrpc_request *req); void ptlrpcd_add_req(struct ptlrpc_request *req);
void ptlrpcd_add_rqset(struct ptlrpc_request_set *set);
int ptlrpcd_addref(void); int ptlrpcd_addref(void);
void ptlrpcd_decref(void); void ptlrpcd_decref(void);
......
...@@ -195,48 +195,6 @@ ptlrpcd_select_pc(struct ptlrpc_request *req) ...@@ -195,48 +195,6 @@ ptlrpcd_select_pc(struct ptlrpc_request *req)
return &pd->pd_threads[idx]; return &pd->pd_threads[idx];
} }
/**
* Move all request from an existing request set to the ptlrpcd queue.
* All requests from the set must be in phase RQ_PHASE_NEW.
*/
void ptlrpcd_add_rqset(struct ptlrpc_request_set *set)
{
struct list_head *tmp, *pos;
struct ptlrpcd_ctl *pc;
struct ptlrpc_request_set *new;
int count, i;
pc = ptlrpcd_select_pc(NULL);
new = pc->pc_set;
list_for_each_safe(pos, tmp, &set->set_requests) {
struct ptlrpc_request *req =
list_entry(pos, struct ptlrpc_request,
rq_set_chain);
LASSERT(req->rq_phase == RQ_PHASE_NEW);
req->rq_set = new;
req->rq_queued_time = cfs_time_current();
}
spin_lock(&new->set_new_req_lock);
list_splice_init(&set->set_requests, &new->set_new_requests);
i = atomic_read(&set->set_remaining);
count = atomic_add_return(i, &new->set_new_count);
atomic_set(&set->set_remaining, 0);
spin_unlock(&new->set_new_req_lock);
if (count == i) {
wake_up(&new->set_waitq);
/* XXX: It maybe unnecessary to wakeup all the partners. But to
* guarantee the async RPC can be processed ASAP, we have
* no other better choice. It maybe fixed in future. */
for (i = 0; i < pc->pc_npartners; i++)
wake_up(&pc->pc_partners[i]->pc_set->set_waitq);
}
}
EXPORT_SYMBOL(ptlrpcd_add_rqset);
/** /**
* Return transferred RPCs count. * Return transferred RPCs count.
*/ */
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment