mirror of
https://github.com/adulau/aha.git
synced 2024-12-27 11:16:11 +00:00
0d90ba1cd4
Executes the backchannel task on the RPC state machine using the existing open connection previously established by the client. Signed-off-by: Ricardo Labiaga <ricardo.labiaga@netapp.com> nfs41: Add bc_svc.o to sunrpc Makefile. [nfs41: bc_send() does not need to be exported outside RPC module] [nfs41: xprt_free_bc_request() need not be exported outside RPC module] Signed-off-by: Ricardo Labiaga <Ricardo.Labiaga@netapp.com> Signed-off-by: Benny Halevy <bhalevy@panasas.com> [Update copyright] Signed-off-by: Ricardo Labiaga <Ricardo.Labiaga@netapp.com> Signed-off-by: Benny Halevy <bhalevy@panasas.com>
81 lines
2.3 KiB
C
81 lines
2.3 KiB
C
/******************************************************************************
|
|
|
|
(c) 2007 Network Appliance, Inc. All Rights Reserved.
|
|
(c) 2009 NetApp. All Rights Reserved.
|
|
|
|
NetApp provides this source code under the GPL v2 License.
|
|
The GPL v2 license is available at
|
|
http://opensource.org/licenses/gpl-license.php.
|
|
|
|
THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
|
"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
|
LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
|
A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR
|
|
CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
|
|
EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
|
|
PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
|
|
PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
|
|
LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
|
|
NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
|
|
SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
|
|
******************************************************************************/
|
|
|
|
/*
|
|
* The NFSv4.1 callback service helper routines.
|
|
* They implement the transport level processing required to send the
|
|
* reply over an existing open connection previously established by the client.
|
|
*/
|
|
|
|
#if defined(CONFIG_NFS_V4_1)
|
|
|
|
#include <linux/module.h>
|
|
|
|
#include <linux/sunrpc/xprt.h>
|
|
#include <linux/sunrpc/sched.h>
|
|
#include <linux/sunrpc/bc_xprt.h>
|
|
|
|
#define RPCDBG_FACILITY RPCDBG_SVCDSP
|
|
|
|
void bc_release_request(struct rpc_task *task)
|
|
{
|
|
struct rpc_rqst *req = task->tk_rqstp;
|
|
|
|
dprintk("RPC: bc_release_request: task= %p\n", task);
|
|
|
|
/*
|
|
* Release this request only if it's a backchannel
|
|
* preallocated request
|
|
*/
|
|
if (!bc_prealloc(req))
|
|
return;
|
|
xprt_free_bc_request(req);
|
|
}
|
|
|
|
/* Empty callback ops */
|
|
static const struct rpc_call_ops nfs41_callback_ops = {
|
|
};
|
|
|
|
|
|
/*
|
|
* Send the callback reply
|
|
*/
|
|
int bc_send(struct rpc_rqst *req)
|
|
{
|
|
struct rpc_task *task;
|
|
int ret;
|
|
|
|
dprintk("RPC: bc_send req= %p\n", req);
|
|
task = rpc_run_bc_task(req, &nfs41_callback_ops);
|
|
if (IS_ERR(task))
|
|
ret = PTR_ERR(task);
|
|
else {
|
|
BUG_ON(atomic_read(&task->tk_count) != 1);
|
|
ret = task->tk_status;
|
|
rpc_put_task(task);
|
|
}
|
|
return ret;
|
|
dprintk("RPC: bc_send ret= %d \n", ret);
|
|
}
|
|
|
|
#endif /* CONFIG_NFS_V4_1 */
|