From: Ronnie Sahlberg Date: Sun, 26 Jun 2011 08:52:03 +0000 (+1000) Subject: add a function for portmap/callit X-Git-Tag: upstream/1.9.6^2~368 X-Git-Url: https://git.piment-noir.org/?p=deb_libnfs.git;a=commitdiff_plain;h=fd59fd0da36b43eaa0f6d038b8c711a15b3f795b add a function for portmap/callit for the low level raw interface --- diff --git a/include/libnfs-raw.h b/include/libnfs-raw.h index bd23dc1..34e5f87 100644 --- a/include/libnfs-raw.h +++ b/include/libnfs-raw.h @@ -103,6 +103,21 @@ int rpc_pmap_null_async(struct rpc_context *rpc, rpc_cb cb, void *private_data); int rpc_pmap_getport_async(struct rpc_context *rpc, int program, int version, rpc_cb cb, void *private_data); +/* + * Call PORTMAPPER/CALLIT. + * Function returns + * 0 : The connection was initiated. Once the connection establish finishes, the callback will be invoked. + * <0 : An error occured when trying to set up the connection. 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 portmapper daemon + * data is a 'pmap_call_result' pointer. + * RPC_STATUS_ERROR : An error occured when trying to contact the portmapper. + * data is the error string. + * RPC_STATUS_CANCEL : The connection attempt was aborted before it could complete. + * data is NULL. + */ +int rpc_pmap_callit_async(struct rpc_context *rpc, int program, int version, int procedure, const char *data, int datalen, rpc_cb cb, void *private_data); /* * MOUNT FUNCTIONS diff --git a/portmap/portmap.c b/portmap/portmap.c index d8015d9..07aa912 100644 --- a/portmap/portmap.c +++ b/portmap/portmap.c @@ -72,3 +72,34 @@ int rpc_pmap_getport_async(struct rpc_context *rpc, int program, int version, rp return 0; } + +int rpc_pmap_callit_async(struct rpc_context *rpc, int program, int version, int procedure, const char *data, int datalen, rpc_cb cb, void *private_data) +{ + struct rpc_pdu *pdu; + struct pmap_call_args ca; + + pdu = rpc_allocate_pdu(rpc, PMAP_PROGRAM, PMAP_V2, PMAP_CALLIT, cb, private_data, (xdrproc_t)xdr_pmap_call_result, sizeof(pmap_call_result)); + if (pdu == NULL) { + rpc_set_error(rpc, "Out of memory. Failed to allocate pdu for portmap/callit call"); + return -1; + } + + ca.prog = program; + ca.vers = version; + ca.proc = procedure; + ca.args.args_len = datalen; + ca.args.args_val = data; + + if (xdr_pmap_call_args(&pdu->xdr, &ca) == 0) { + rpc_set_error(rpc, "XDR error: Failed to encode data for portmap/callit call"); + rpc_free_pdu(rpc, pdu); + return -1; + } + + if (rpc_queue_pdu(rpc, pdu) != 0) { + rpc_set_error(rpc, "Failed to queue portmap/callit pdu: %s", rpc_get_error(rpc)); + return -1; + } + + return 0; +}