From: Ronnie Sahlberg Date: Wed, 6 Nov 2013 01:37:16 +0000 (-0800) Subject: Initial support for NSM X-Git-Tag: upstream/1.9.6^2~174 X-Git-Url: https://git.piment-noir.org/?a=commitdiff_plain;h=ed09b5676fde3acf65c817f9a77d8db479d3bac8;p=deb_libnfs.git Initial support for NSM --- diff --git a/Makefile.am b/Makefile.am index 18277c0..3dec343 100644 --- a/Makefile.am +++ b/Makefile.am @@ -1,4 +1,4 @@ -SUBDIRS = mount nfs nlm portmap rquota lib include . $(MAYBE_EXAMPLES) +SUBDIRS = mount nfs nlm nsm portmap rquota lib include . $(MAYBE_EXAMPLES) pkgconfigdir = $(libdir)/pkgconfig pkgconfig_DATA = libnfs.pc diff --git a/configure.ac b/configure.ac index 407b646..8877a5b 100644 --- a/configure.ac +++ b/configure.ac @@ -156,6 +156,7 @@ AC_CONFIG_FILES([Makefile] [mount/Makefile] [nfs/Makefile] [nlm/Makefile] + [nsm/Makefile] [portmap/Makefile] [rquota/Makefile] [examples/Makefile] diff --git a/include/Makefile.am b/include/Makefile.am index d757d2b..e1e65dc 100644 --- a/include/Makefile.am +++ b/include/Makefile.am @@ -7,4 +7,5 @@ dist_nfsc_HEADERS = \ ${abs_top_srcdir}/portmap/libnfs-raw-portmap.h \ ${abs_top_srcdir}/nfs/libnfs-raw-nfs.h \ ${abs_top_srcdir}/nlm/libnfs-raw-nlm.h \ + ${abs_top_srcdir}/nsm/libnfs-raw-nsm.h \ ${abs_top_srcdir}/rquota/libnfs-raw-rquota.h diff --git a/include/nfsc/libnfs-raw.h b/include/nfsc/libnfs-raw.h index b37d67c..c9f9d60 100644 --- a/include/nfsc/libnfs-raw.h +++ b/include/nfsc/libnfs-raw.h @@ -956,4 +956,28 @@ int rpc_nlm4_cancel_async(struct rpc_context *rpc, rpc_cb cb, struct NLM4_CANCar struct NLM4_UNLOCKargs; int rpc_nlm4_unlock_async(struct rpc_context *rpc, rpc_cb cb, struct NLM4_UNLOCKargs *args, void *private_data); +/* + * NSM functions + */ +char *nsmstat1_to_str(int stat); + +/* + * Call NSM/NULL + * Call the NULL procedure for the NSM protocol + * + * Function returns + * 0 : The call was initiated. The callback will be invoked when the call completes. + * <0 : An error occured when trying to set up the call. The callback will not be invoked. + * + * When the callback is invoked, status indicates the result: + * RPC_STATUS_SUCCESS : We got a successful response from the nsm daemon. + * data is NULL + * RPC_STATUS_ERROR : An error occured when trying to contact the nsm daemon. + * data is the error string. + * RPC_STATUS_CANCEL : The connection attempt was aborted before it could complete. + * data is NULL. + */ +int rpc_nsm1_null_async(struct rpc_context *rpc, rpc_cb cb, void *private_data); + + #endif diff --git a/lib/Makefile.am b/lib/Makefile.am index 4a51bc7..e35a6c0 100644 --- a/lib/Makefile.am +++ b/lib/Makefile.am @@ -5,6 +5,7 @@ libnfs_la_CPPFLAGS = -I$(abs_top_srcdir)/include \ -I../mount \ -I../nfs \ -I../nlm \ + -I../nsm \ -I../portmap \ -I../rquota \ "-D_U_=__attribute__((unused))" @@ -22,6 +23,7 @@ libnfs_la_LIBADD = \ ../mount/libmount.la \ ../nfs/libnfs.la \ ../nlm/libnlm.la \ + ../nsm/libnsm.la \ ../portmap/libportmap.la \ ../rquota/librquota.la diff --git a/nsm/Makefile.am b/nsm/Makefile.am new file mode 100644 index 0000000..1ec6ed6 --- /dev/null +++ b/nsm/Makefile.am @@ -0,0 +1,22 @@ +noinst_LTLIBRARIES = libnsm.la + +nsm_SOURCES_GENERATED = +nsm_HEADERS_GENERATED = +nsm_GENERATED = $(nsm_SOURCES_GENERATED) $(nsm_HEADERS_GENERATED) + +CLEANFILES = $(nsm_GENERATED) nsm-stamp + +libnsm_la_CPPFLAGS = -I$(abs_top_srcdir)/include \ + -I$(abs_top_srcdir)/include/nfsc +libnsm_la_SOURCES = \ + $(nsm_SOURCES_GENERATED) \ + nsm.c libnfs-raw-nsm.c + +$(nsm_GENERATED) : nsm-stamp +nsm-stamp : nsm.x + rm -f $(nsm_GENERATED) + touch nsm-stamp + +compile_rpc: + rpcgen -h nsm.x | sed -e "s/#include //" | sed -e "s/xdr/zdr/g" -e "s/XDR/ZDR/g" > libnfs-raw-nsm.h + rpcgen -c nsm.x | sed -e "s/#include \".*nsm.h\"/#include \"libnfs-xdr.h\"\n#include \"libnfs-raw-nsm.h\"/" -e "s/xdr/zdr/g" -e "s/XDR/ZDR/g" -e "s/register int32_t \*buf;/register int32_t *buf;\n buf = NULL;/" > libnfs-raw-nsm.c diff --git a/nsm/libnfs-raw-nsm.c b/nsm/libnfs-raw-nsm.c new file mode 100644 index 0000000..62ffc7b --- /dev/null +++ b/nsm/libnfs-raw-nsm.c @@ -0,0 +1,110 @@ +/* + * Please do not edit this file. + * It was generated using rpcgen. + */ + +#include "libnfs-zdr.h" +#include "libnfs-raw-nsm.h" + +bool_t +zdr_nsm_name (ZDR *zdrs, nsm_name *objp) +{ + register int32_t *buf; + buf = NULL; + + if (!zdr_string (zdrs, &objp->mon_name, NSM_MAXSTRLEN)) + return FALSE; + return TRUE; +} + +bool_t +zdr_nsmstat1 (ZDR *zdrs, nsmstat1 *objp) +{ + register int32_t *buf; + buf = NULL; + + if (!zdr_enum (zdrs, (enum_t *) objp)) + return FALSE; + return TRUE; +} + +bool_t +zdr_nsm_stat_res (ZDR *zdrs, nsm_stat_res *objp) +{ + register int32_t *buf; + buf = NULL; + + if (!zdr_nsmstat1 (zdrs, &objp->res)) + return FALSE; + if (!zdr_int (zdrs, &objp->state)) + return FALSE; + return TRUE; +} + +bool_t +zdr_nsm_stat (ZDR *zdrs, nsm_stat *objp) +{ + register int32_t *buf; + buf = NULL; + + if (!zdr_int (zdrs, &objp->state)) + return FALSE; + return TRUE; +} + +bool_t +zdr_nsm_my_id (ZDR *zdrs, nsm_my_id *objp) +{ + register int32_t *buf; + buf = NULL; + + if (!zdr_string (zdrs, &objp->my_name, NSM_MAXSTRLEN)) + return FALSE; + if (!zdr_int (zdrs, &objp->my_prog)) + return FALSE; + if (!zdr_int (zdrs, &objp->my_vers)) + return FALSE; + if (!zdr_int (zdrs, &objp->my_proc)) + return FALSE; + return TRUE; +} + +bool_t +zdr_nsm_mon_id (ZDR *zdrs, nsm_mon_id *objp) +{ + register int32_t *buf; + buf = NULL; + + if (!zdr_string (zdrs, &objp->mon_name, NSM_MAXSTRLEN)) + return FALSE; + if (!zdr_nsm_my_id (zdrs, &objp->my_id)) + return FALSE; + return TRUE; +} + +bool_t +zdr_nsm_mon (ZDR *zdrs, nsm_mon *objp) +{ + register int32_t *buf; + buf = NULL; + + int i; + if (!zdr_nsm_mon_id (zdrs, &objp->mon_id)) + return FALSE; + if (!zdr_opaque (zdrs, objp->priv, 16)) + return FALSE; + return TRUE; +} + +bool_t +zdr_nsm_stat_chg (ZDR *zdrs, nsm_stat_chg *objp) +{ + register int32_t *buf; + buf = NULL; + + if (!zdr_string (zdrs, &objp->mon_name, NSM_MAXSTRLEN)) + return FALSE; + if (!zdr_int (zdrs, &objp->state)) + return FALSE; + return TRUE; +} diff --git a/nsm/libnfs-raw-nsm.h b/nsm/libnfs-raw-nsm.h new file mode 100644 index 0000000..36074bc --- /dev/null +++ b/nsm/libnfs-raw-nsm.h @@ -0,0 +1,146 @@ +/* + * Please do not edit this file. + * It was generated using rpcgen. + */ + +#ifndef _NSM_H_RPCGEN +#define _NSM_H_RPCGEN + + + + +#ifdef __cplusplus +extern "C" { +#endif + +#define NSM_MAXSTRLEN 1024 + +struct nsm_name { + char *mon_name; +}; +typedef struct nsm_name nsm_name; + +enum nsmstat1 { + NSM_STAT_SUCC = 0, + NSM_STAT_FAIL = 1, +}; +typedef enum nsmstat1 nsmstat1; + +struct nsm_stat_res { + nsmstat1 res; + int state; +}; +typedef struct nsm_stat_res nsm_stat_res; + +struct nsm_stat { + int state; +}; +typedef struct nsm_stat nsm_stat; + +struct nsm_my_id { + char *my_name; + int my_prog; + int my_vers; + int my_proc; +}; +typedef struct nsm_my_id nsm_my_id; + +struct nsm_mon_id { + char *mon_name; + struct nsm_my_id my_id; +}; +typedef struct nsm_mon_id nsm_mon_id; + +struct nsm_mon { + struct nsm_mon_id mon_id; + char priv[16]; +}; +typedef struct nsm_mon nsm_mon; + +struct nsm_stat_chg { + char *mon_name; + int state; +}; +typedef struct nsm_stat_chg nsm_stat_chg; + +#define NSM_PROGRAM 100024 +#define NSM_V1 1 + +#if defined(__STDC__) || defined(__cplusplus) +#define NSM1_NULL 0 +extern void * nsm1_null_1(void *, CLIENT *); +extern void * nsm1_null_1_svc(void *, struct svc_req *); +#define NSM1_STAT 1 +extern struct nsm_stat_res * nsm1_stat_1(struct nsm_name *, CLIENT *); +extern struct nsm_stat_res * nsm1_stat_1_svc(struct nsm_name *, struct svc_req *); +#define NSM1_MON 2 +extern struct nsm_stat_res * nsm1_mon_1(struct nsm_mon *, CLIENT *); +extern struct nsm_stat_res * nsm1_mon_1_svc(struct nsm_mon *, struct svc_req *); +#define NSM1_UNMON 3 +extern struct nsm_stat * nsm1_unmon_1(struct nsm_mon_id *, CLIENT *); +extern struct nsm_stat * nsm1_unmon_1_svc(struct nsm_mon_id *, struct svc_req *); +#define NSM1_UNMON_ALL 4 +extern struct nsm_stat * nsm1_unmon_all_1(struct nsm_my_id *, CLIENT *); +extern struct nsm_stat * nsm1_unmon_all_1_svc(struct nsm_my_id *, struct svc_req *); +#define NSM1_SIMU_CRASH 5 +extern void * nsm1_simu_crash_1(void *, CLIENT *); +extern void * nsm1_simu_crash_1_svc(void *, struct svc_req *); +#define NSM1_NOTIFY 6 +extern void * nsm1_notify_1(struct nsm_stat_chg *, CLIENT *); +extern void * nsm1_notify_1_svc(struct nsm_stat_chg *, struct svc_req *); +extern int nsm_program_1_freeresult (SVCXPRT *, zdrproc_t, caddr_t); + +#else /* K&R C */ +#define NSM1_NULL 0 +extern void * nsm1_null_1(); +extern void * nsm1_null_1_svc(); +#define NSM1_STAT 1 +extern struct nsm_stat_res * nsm1_stat_1(); +extern struct nsm_stat_res * nsm1_stat_1_svc(); +#define NSM1_MON 2 +extern struct nsm_stat_res * nsm1_mon_1(); +extern struct nsm_stat_res * nsm1_mon_1_svc(); +#define NSM1_UNMON 3 +extern struct nsm_stat * nsm1_unmon_1(); +extern struct nsm_stat * nsm1_unmon_1_svc(); +#define NSM1_UNMON_ALL 4 +extern struct nsm_stat * nsm1_unmon_all_1(); +extern struct nsm_stat * nsm1_unmon_all_1_svc(); +#define NSM1_SIMU_CRASH 5 +extern void * nsm1_simu_crash_1(); +extern void * nsm1_simu_crash_1_svc(); +#define NSM1_NOTIFY 6 +extern void * nsm1_notify_1(); +extern void * nsm1_notify_1_svc(); +extern int nsm_program_1_freeresult (); +#endif /* K&R C */ + +/* the zdr functions */ + +#if defined(__STDC__) || defined(__cplusplus) +extern bool_t zdr_nsm_name (ZDR *, nsm_name*); +extern bool_t zdr_nsmstat1 (ZDR *, nsmstat1*); +extern bool_t zdr_nsm_stat_res (ZDR *, nsm_stat_res*); +extern bool_t zdr_nsm_stat (ZDR *, nsm_stat*); +extern bool_t zdr_nsm_my_id (ZDR *, nsm_my_id*); +extern bool_t zdr_nsm_mon_id (ZDR *, nsm_mon_id*); +extern bool_t zdr_nsm_mon (ZDR *, nsm_mon*); +extern bool_t zdr_nsm_stat_chg (ZDR *, nsm_stat_chg*); + +#else /* K&R C */ +extern bool_t zdr_nsm_name (); +extern bool_t zdr_nsmstat1 (); +extern bool_t zdr_nsm_stat_res (); +extern bool_t zdr_nsm_stat (); +extern bool_t zdr_nsm_my_id (); +extern bool_t zdr_nsm_mon_id (); +extern bool_t zdr_nsm_mon (); +extern bool_t zdr_nsm_stat_chg (); + +#endif /* K&R C */ + +#ifdef __cplusplus +} +#endif + +#endif /* !_NSM_H_RPCGEN */ diff --git a/nsm/nsm.c b/nsm/nsm.c new file mode 100644 index 0000000..591beb2 --- /dev/null +++ b/nsm/nsm.c @@ -0,0 +1,161 @@ +/* + Copyright (C) 2013 by Ronnie Sahlberg + + 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 . +*/ + +#ifdef WIN32 +#include "win32_compat.h" +#endif/*WIN32*/ + +#include +#include +#include "libnfs-zdr.h" +#include "libnfs.h" +#include "libnfs-raw.h" +#include "libnfs-private.h" +#include "libnfs-raw-nsm.h" + +int rpc_nsm1_null_async(struct rpc_context *rpc, rpc_cb cb, void *private_data) +{ + struct rpc_pdu *pdu; + + pdu = rpc_allocate_pdu(rpc, NSM_PROGRAM, NSM_V1, NSM1_NULL, cb, private_data, (zdrproc_t)zdr_void, 0); + if (pdu == NULL) { + rpc_set_error(rpc, "Out of memory. Failed to allocate pdu for nsm/null call"); + return -1; + } + + if (rpc_queue_pdu(rpc, pdu) != 0) { + rpc_set_error(rpc, "Out of memory. Failed to queue pdu for nsm/null call"); + rpc_free_pdu(rpc, pdu); + return -1; + } + + return 0; +} + +#if 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, (zdrproc_t)zdr_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 (zdr_NLM4_TESTargs(&pdu->zdr, args) == 0) { + rpc_set_error(rpc, "ZDR 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, (zdrproc_t)zdr_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 (zdr_NLM4_LOCKargs(&pdu->zdr, args) == 0) { + rpc_set_error(rpc, "ZDR 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, (zdrproc_t)zdr_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 (zdr_NLM4_CANCargs(&pdu->zdr, args) == 0) { + rpc_set_error(rpc, "ZDR 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, (zdrproc_t)zdr_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 (zdr_NLM4_UNLOCKargs(&pdu->zdr, args) == 0) { + rpc_set_error(rpc, "ZDR 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; +} +#endif + +char *nsmstat1_to_str(int st) +{ + enum nsmstat1 stat = st; + + char *str = "unknown n1m stat"; + switch (stat) { + case NSM_STAT_SUCC: str="NSM_STAT_SUCC";break; + case NSM_STAT_FAIL: str="NSM_STAT_FAIL";break; + } + return str; +} diff --git a/nsm/nsm.x b/nsm/nsm.x new file mode 100644 index 0000000..371a778 --- /dev/null +++ b/nsm/nsm.x @@ -0,0 +1,71 @@ +/* + * NSM definitions from: + * Protocols for Interworking: XNFS, Version 3W + * http://pubs.opengroup.org/onlinepubs/9629799/chap11.htm + * + * Symbols then massaged to avoid too much namespace pollution + * and to bring more inline with convention in nlm. + */ + +/* + * This defines the maximum length of the string + * identifying the caller. + */ +const NSM_MAXSTRLEN = 1024; + +struct nsm_name { + string mon_name; +}; + +enum nsmstat1 { + NSM_STAT_SUCC = 0, /* NSM agrees to monitor. */ + NSM_STAT_FAIL = 1 /* NSM cannot monitor. */ +}; + +struct nsm_stat_res { + nsmstat1 res; + int state; +}; + +struct nsm_stat { + int state; /* state number of NSM */ +}; + +struct nsm_my_id { + string my_name; /* hostname */ + int my_prog; /* RPC program number */ + int my_vers; /* program version number */ + int my_proc; /* procedure number */ +}; + +struct nsm_mon_id { + string mon_name; /* name of the host to be monitored */ + struct nsm_my_id my_id; +}; + +struct nsm_mon { + struct nsm_mon_id mon_id; + opaque priv[16]; /* private information */ +}; + +struct nsm_stat_chg { + string mon_name; + int state; +}; + +/* + * Protocol description for the NSM program. + */ +program NSM_PROGRAM { + version NSM_V1 { + void NSM1_NULL(void) = 0; + struct nsm_stat_res NSM1_STAT(struct nsm_name) = 1; + struct nsm_stat_res NSM1_MON(struct nsm_mon) = 2; + struct nsm_stat NSM1_UNMON(struct nsm_mon_id) = 3; + struct nsm_stat NSM1_UNMON_ALL(struct nsm_my_id) = 4; + void NSM1_SIMU_CRASH(void) = 5; + void NSM1_NOTIFY(struct nsm_stat_chg) = 6; + } = 1; +} = 100024; + +