}
/**
- * lustre_msg_buflen - return the length of buffer \a n in message \a m
- * \param m lustre_msg (request or reply) to look at
- * \param n message index (base 0)
+ * lustre_msg_buflen() - return the length of buffer @n in message @m
+ * @m: lustre_msg (request or reply) to look at
+ * @n: message index (base 0)
*
* returns zero for non-existent message indices
*/
EXPORT_SYMBOL(ptlrpc_request_set_replen);
/**
- * Send a remote set_info_async.
+ * do_set_info_async() - Send a remote set_info_async.
+ * @imp: import object
+ * @opcode: operation type
+ * @version: operation version
+ * @keylen: length of key
+ * @key: pointer to key
+ * @vallen: length of value
+ * @val: pointer to value
+ * @set: pointer to ptlrpc_request_set (request to be added)
*
* This may go from client to server or server to client.
+ *
+ * Return:
+ * * %0 on success
+ * * %negative on failure
*/
int do_set_info_async(struct obd_import *imp,
int opcode, int version,
return &pd->pd_threads[idx];
}
-/**
+/*
* Return transferred RPCs count.
*/
static int ptlrpcd_steal_rqset(struct ptlrpc_request_set *des,
}
/**
+ * ptlrpcd_add_req() - Requests that are added to the ptlrpcd queue
+ * @req: request to add to ptlrpcd
+ *
* Requests that are added to the ptlrpcd queue are sent via
* ptlrpcd_check->ptlrpc_check_set().
*/
}
/**
- * Main ptlrpcd thread.
+ * ptlrpcd() - Main ptlrpcd thread.
+ * @arg: pointer to struct ptlrpcd_ctl
+ *
* ptlrpc's code paths like to execute in process context, so we have this
* thread which spins on a set which contains the rpcs and sends them.
+ *
+ * Return:
+ * * %0 on success
+ * * %negative on failure
*/
static int ptlrpcd(void *arg)
{