[deb_libnfs.git] / nlm / nlm.c

/*
   Copyright (C) 2012 by Ronnie Sahlberg <ronniesahlberg@gmail.com>

   This program is free software; you can redistribute it and/or modify
   it under the terms of the GNU Lesser General Public License as published by
   the Free Software Foundation; either version 2.1 of the License, or
   (at your option) any later version.

   This program is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   GNU Lesser General Public License for more details.

   You should have received a copy of the GNU Lesser General Public License
   along with this program; if not, see <http://www.gnu.org/licenses/>.
*/

#ifdef WIN32
#include "win32_compat.h"
#endif/*WIN32*/

#include <stdio.h>
#include <errno.h>
#include <rpc/rpc.h>
#include <rpc/xdr.h>
#include "libnfs.h"
#include "libnfs-raw.h"
#include "libnfs-private.h"
#include "libnfs-raw-nlm.h"

int rpc_nlm4_null_async(struct rpc_context *rpc, rpc_cb cb, void *private_data)
{
	struct rpc_pdu *pdu;

	pdu = rpc_allocate_pdu(rpc, NLM_PROGRAM, NLM_V4, NLM4_NULL, cb, private_data, (xdrproc_t)xdr_void, 0);
	if (pdu == NULL) {
		rpc_set_error(rpc, "Out of memory. Failed to allocate pdu for nlm/null call");
		return -1;
	}

	if (rpc_queue_pdu(rpc, pdu) != 0) {
		rpc_set_error(rpc, "Out of memory. Failed to queue pdu for nlm/null call");
		rpc_free_pdu(rpc, pdu);
		return -1;
	}

	return 0;
}

int rpc_nlm4_test_async(struct rpc_context *rpc, rpc_cb cb, struct NLM4_TESTargs *args, void *private_data)
{
	struct rpc_pdu *pdu;

	pdu = rpc_allocate_pdu(rpc, NLM_PROGRAM, NLM_V4, NLM4_TEST, cb, private_data, (xdrproc_t)xdr_NLM4_TESTres, sizeof(NLM4_TESTres));
	if (pdu == NULL) {
		rpc_set_error(rpc, "Out of memory. Failed to allocate pdu for nlm/test call");
		return -1;
	}

	if (xdr_NLM4_TESTargs(&pdu->xdr, args) == 0) {
		rpc_set_error(rpc, "XDR error: Failed to encode NLM4_TESTargs");
		rpc_free_pdu(rpc, pdu);
		return -2;
	}

	if (rpc_queue_pdu(rpc, pdu) != 0) {
		rpc_set_error(rpc, "Out of memory. Failed to queue pdu for nlm/test call");
		rpc_free_pdu(rpc, pdu);
		return -1;
	}

	return 0;
}

int rpc_nlm4_lock_async(struct rpc_context *rpc, rpc_cb cb, struct NLM4_LOCKargs *args, void *private_data)
{
	struct rpc_pdu *pdu;

	pdu = rpc_allocate_pdu(rpc, NLM_PROGRAM, NLM_V4, NLM4_LOCK, cb, private_data, (xdrproc_t)xdr_NLM4_LOCKres, sizeof(NLM4_LOCKres));
	if (pdu == NULL) {
		rpc_set_error(rpc, "Out of memory. Failed to allocate pdu for nlm/lock call");
		return -1;
	}

	if (xdr_NLM4_LOCKargs(&pdu->xdr, args) == 0) {
		rpc_set_error(rpc, "XDR error: Failed to encode NLM4_LOCKargs");
		rpc_free_pdu(rpc, pdu);
		return -2;
	}

	if (rpc_queue_pdu(rpc, pdu) != 0) {
		rpc_set_error(rpc, "Out of memory. Failed to queue pdu for nlm/lock call");
		rpc_free_pdu(rpc, pdu);
		return -1;
	}

	return 0;
}

int rpc_nlm4_cancel_async(struct rpc_context *rpc, rpc_cb cb, struct NLM4_CANCargs *args, void *private_data)
{
	struct rpc_pdu *pdu;

	pdu = rpc_allocate_pdu(rpc, NLM_PROGRAM, NLM_V4, NLM4_CANCEL, cb, private_data, (xdrproc_t)xdr_NLM4_CANCres, sizeof(NLM4_CANCres));
	if (pdu == NULL) {
		rpc_set_error(rpc, "Out of memory. Failed to allocate pdu for nlm/cancel call");
		return -1;
	}

	if (xdr_NLM4_CANCargs(&pdu->xdr, args) == 0) {
		rpc_set_error(rpc, "XDR error: Failed to encode NLM4_CANCargs");
		rpc_free_pdu(rpc, pdu);
		return -2;
	}

	if (rpc_queue_pdu(rpc, pdu) != 0) {
		rpc_set_error(rpc, "Out of memory. Failed to queue pdu for nlm/cancel call");
		rpc_free_pdu(rpc, pdu);
		return -1;
	}

	return 0;
}

int rpc_nlm4_unlock_async(struct rpc_context *rpc, rpc_cb cb, struct NLM4_UNLOCKargs *args, void *private_data)
{
	struct rpc_pdu *pdu;

	pdu = rpc_allocate_pdu(rpc, NLM_PROGRAM, NLM_V4, NLM4_UNLOCK, cb, private_data, (xdrproc_t)xdr_NLM4_UNLOCKres, sizeof(NLM4_UNLOCKres));
	if (pdu == NULL) {
		rpc_set_error(rpc, "Out of memory. Failed to allocate pdu for nlm/unlock call");
		return -1;
	}

	if (xdr_NLM4_UNLOCKargs(&pdu->xdr, args) == 0) {
		rpc_set_error(rpc, "XDR error: Failed to encode NLM4_UNLOCKargs");
		rpc_free_pdu(rpc, pdu);
		return -2;
	}

	if (rpc_queue_pdu(rpc, pdu) != 0) {
		rpc_set_error(rpc, "Out of memory. Failed to queue pdu for nlm/unlock call");
		rpc_free_pdu(rpc, pdu);
		return -1;
	}

	return 0;
}

char *nlmstat4_to_str(int st)
{
	enum nlmstat4 stat = st;

	char *str = "unknown nlm stat";
	switch (stat) {
	case NLM4_GRANTED: str="NLM4_GRANTED";break;
	case NLM4_DENIED: str="NLM4_DENIED";break;
	case NLM4_DENIED_NOLOCKS: str="NLM4_DENIED_NOLOCKS";break;
	case NLM4_BLOCKED: str="NLM4_BLOCKED";break;
	case NLM4_DENIED_GRACE_PERIOD: str="NLM4_DENIED_GRACE_PERIOD";break;
	case NLM4_DEADLCK: str="NLM4_DEADLCK";break;
	case NLM4_ROFS: str="NLM4_ROFS";break;
	case NLM4_STALE_FH: str="NLM4_STALE_FH";break;
	case NLM4_FBIG: str="NLM4_FBIG";break;
	case NLM4_FAILED: str="NLM4_FAILED";break;
	}
	return str;
}
Commit	Line	Data
6916a665 RS	1	/*
	2	Copyright (C) 2012 by Ronnie Sahlberg <ronniesahlberg@gmail.com>
	3
	4	This program is free software; you can redistribute it and/or modify
	5	it under the terms of the GNU Lesser General Public License as published by
	6	the Free Software Foundation; either version 2.1 of the License, or
	7	(at your option) any later version.
	8
	9	This program is distributed in the hope that it will be useful,
	10	but WITHOUT ANY WARRANTY; without even the implied warranty of
	11	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	12	GNU Lesser General Public License for more details.
	13
	14	You should have received a copy of the GNU Lesser General Public License
	15	along with this program; if not, see <http://www.gnu.org/licenses/>.
	16	*/
	17
	18	#ifdef WIN32
	19	#include "win32_compat.h"
	20	#endif/WIN32/
	21
	22	#include <stdio.h>
	23	#include <errno.h>
	24	#include <rpc/rpc.h>
	25	#include <rpc/xdr.h>
	26	#include "libnfs.h"
	27	#include "libnfs-raw.h"
	28	#include "libnfs-private.h"
	29	#include "libnfs-raw-nlm.h"
	30
e01ed6a2	31	int rpc_nlm4_null_async(struct rpc_context rpc, rpc_cb cb, void private_data)
6916a665 RS	32	{
	33	struct rpc_pdu *pdu;
	34
	35	pdu = rpc_allocate_pdu(rpc, NLM_PROGRAM, NLM_V4, NLM4_NULL, cb, private_data, (xdrproc_t)xdr_void, 0);
	36	if (pdu == NULL) {
	37	rpc_set_error(rpc, "Out of memory. Failed to allocate pdu for nlm/null call");
	38	return -1;
	39	}
	40
	41	if (rpc_queue_pdu(rpc, pdu) != 0) {
	42	rpc_set_error(rpc, "Out of memory. Failed to queue pdu for nlm/null call");
	43	rpc_free_pdu(rpc, pdu);
	44	return -1;
	45	}
	46
	47	return 0;
	48	}
	49
e01ed6a2 RS	50	int rpc_nlm4_test_async(struct rpc_context rpc, rpc_cb cb, struct NLM4_TESTargs args, void *private_data)
	51	{
	52	struct rpc_pdu *pdu;
	53
	54	pdu = rpc_allocate_pdu(rpc, NLM_PROGRAM, NLM_V4, NLM4_TEST, cb, private_data, (xdrproc_t)xdr_NLM4_TESTres, sizeof(NLM4_TESTres));
	55	if (pdu == NULL) {
	56	rpc_set_error(rpc, "Out of memory. Failed to allocate pdu for nlm/test call");
	57	return -1;
	58	}
	59
	60	if (xdr_NLM4_TESTargs(&pdu->xdr, args) == 0) {
	61	rpc_set_error(rpc, "XDR error: Failed to encode NLM4_TESTargs");
	62	rpc_free_pdu(rpc, pdu);
	63	return -2;
	64	}
	65
	66	if (rpc_queue_pdu(rpc, pdu) != 0) {
	67	rpc_set_error(rpc, "Out of memory. Failed to queue pdu for nlm/test call");
	68	rpc_free_pdu(rpc, pdu);
	69	return -1;
	70	}
	71
	72	return 0;
	73	}
	74
a171d4da RS	75	int rpc_nlm4_lock_async(struct rpc_context rpc, rpc_cb cb, struct NLM4_LOCKargs args, void *private_data)
	76	{
	77	struct rpc_pdu *pdu;
	78
	79	pdu = rpc_allocate_pdu(rpc, NLM_PROGRAM, NLM_V4, NLM4_LOCK, cb, private_data, (xdrproc_t)xdr_NLM4_LOCKres, sizeof(NLM4_LOCKres));
	80	if (pdu == NULL) {
	81	rpc_set_error(rpc, "Out of memory. Failed to allocate pdu for nlm/lock call");
	82	return -1;
	83	}
	84
	85	if (xdr_NLM4_LOCKargs(&pdu->xdr, args) == 0) {
	86	rpc_set_error(rpc, "XDR error: Failed to encode NLM4_LOCKargs");
	87	rpc_free_pdu(rpc, pdu);
	88	return -2;
	89	}
	90
	91	if (rpc_queue_pdu(rpc, pdu) != 0) {
	92	rpc_set_error(rpc, "Out of memory. Failed to queue pdu for nlm/lock call");
	93	rpc_free_pdu(rpc, pdu);
	94	return -1;
	95	}
	96
	97	return 0;
	98	}
	99
	100	int rpc_nlm4_cancel_async(struct rpc_context rpc, rpc_cb cb, struct NLM4_CANCargs args, void *private_data)
	101	{
	102	struct rpc_pdu *pdu;
	103
	104	pdu = rpc_allocate_pdu(rpc, NLM_PROGRAM, NLM_V4, NLM4_CANCEL, cb, private_data, (xdrproc_t)xdr_NLM4_CANCres, sizeof(NLM4_CANCres));
	105	if (pdu == NULL) {
	106	rpc_set_error(rpc, "Out of memory. Failed to allocate pdu for nlm/cancel call");
	107	return -1;
	108	}
	109
	110	if (xdr_NLM4_CANCargs(&pdu->xdr, args) == 0) {
	111	rpc_set_error(rpc, "XDR error: Failed to encode NLM4_CANCargs");
	112	rpc_free_pdu(rpc, pdu);
	113	return -2;
	114	}
	115
	116	if (rpc_queue_pdu(rpc, pdu) != 0) {
	117	rpc_set_error(rpc, "Out of memory. Failed to queue pdu for nlm/cancel call");
	118	rpc_free_pdu(rpc, pdu);
	119	return -1;
	120	}
	121
	122	return 0;
	123	}
	124
	125	int rpc_nlm4_unlock_async(struct rpc_context rpc, rpc_cb cb, struct NLM4_UNLOCKargs args, void *private_data)
	126	{
	127	struct rpc_pdu *pdu;
	128
	129	pdu = rpc_allocate_pdu(rpc, NLM_PROGRAM, NLM_V4, NLM4_UNLOCK, cb, private_data, (xdrproc_t)xdr_NLM4_UNLOCKres, sizeof(NLM4_UNLOCKres));
	130	if (pdu == NULL) {
	131	rpc_set_error(rpc, "Out of memory. Failed to allocate pdu for nlm/unlock call");
	132	return -1;
	133	}
	134
	135	if (xdr_NLM4_UNLOCKargs(&pdu->xdr, args) == 0) {
	136	rpc_set_error(rpc, "XDR error: Failed to encode NLM4_UNLOCKargs");
	137	rpc_free_pdu(rpc, pdu);
	138	return -2;
139	}
140
141	if (rpc_queue_pdu(rpc, pdu) != 0) {
142	rpc_set_error(rpc, "Out of memory. Failed to queue pdu for nlm/unlock call");
143	rpc_free_pdu(rpc, pdu);
144	return -1;
145	}
146
147	return 0;
148	}
149
6916a665 RS	150	char *nlmstat4_to_str(int st)
	151	{
	152	enum nlmstat4 stat = st;
	153
	154	char *str = "unknown nlm stat";
	155	switch (stat) {
	156	case NLM4_GRANTED: str="NLM4_GRANTED";break;
	157	case NLM4_DENIED: str="NLM4_DENIED";break;
	158	case NLM4_DENIED_NOLOCKS: str="NLM4_DENIED_NOLOCKS";break;
	159	case NLM4_BLOCKED: str="NLM4_BLOCKED";break;
	160	case NLM4_DENIED_GRACE_PERIOD: str="NLM4_DENIED_GRACE_PERIOD";break;
	161	case NLM4_DEADLCK: str="NLM4_DEADLCK";break;
	162	case NLM4_ROFS: str="NLM4_ROFS";break;
	163	case NLM4_STALE_FH: str="NLM4_STALE_FH";break;
	164	case NLM4_FBIG: str="NLM4_FBIG";break;
	165	case NLM4_FAILED: str="NLM4_FAILED";break;
	166	}
	167	return str;
	168	}
	169
	170
	171
	172