X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=lib%2Flibnfs-sync.c;h=0a57c7b97e562c1844fd0b183271d1ff8fea2b7f;hb=4b307c17146bd8a0d591c99f1b40b0f0cbc38174;hp=29c805c6f4bb135896025add4ca04cf045f4a3ea;hpb=cdb19ec1642636497881215a69166fd5f1d0cda2;p=deb_libnfs.git diff --git a/lib/libnfs-sync.c b/lib/libnfs-sync.c index 29c805c..0a57c7b 100644 --- a/lib/libnfs-sync.c +++ b/lib/libnfs-sync.c @@ -18,6 +18,7 @@ * High level api to nfs filesystems */ +#include "config.h" #include #include #include @@ -25,10 +26,14 @@ #include #include #include +#include #include #include #include #include +#include +#include +#include #include "libnfs.h" #include "libnfs-raw.h" #include "libnfs-raw-mount.h" @@ -1069,7 +1074,7 @@ int nfs_link(struct nfs_context *nfs, const char *oldpath, const char *newpath) return cb_data.status; } -void mount_getexports_cb(struct rpc_context *mount_context _U_, int status, void *data, void *private_data) +void mount_getexports_cb(struct rpc_context *mount_context, int status, void *data, void *private_data) { struct sync_cb_data *cb_data = private_data; exports export = *(exports *)data; @@ -1078,6 +1083,11 @@ void mount_getexports_cb(struct rpc_context *mount_context _U_, int status, void cb_data->status = status; cb_data->return_data = NULL; + if (status != 0) { + rpc_set_error(mount_context, "mount/export call failed with \"%s\"", (char *)data); + return; + } + while (export != NULL) { exports new_export; @@ -1124,3 +1134,197 @@ void mount_free_export_list(struct exportnode *exports) } } + + + +void free_nfs_srvr_list(struct nfs_server_list *srv) +{ + while (srv != NULL) { + struct nfs_server_list *next = srv->next; + + free(srv->addr); + free(srv); + srv = next; + } +} + +struct nfs_list_data { + int status; + struct nfs_server_list *srvrs; +}; + +void callit_cb(struct rpc_context *rpc, int status, void *data _U_, void *private_data) +{ + struct nfs_list_data *srv_data = private_data; + struct sockaddr *sin; + char hostdd[16]; + struct nfs_server_list *srvr; + + if (status == RPC_STATUS_CANCEL) { + return; + } + if (status != 0) { + srv_data->status = -1; + return; + } + + sin = rpc_get_recv_sockaddr(rpc); + if (sin == NULL) { + rpc_set_error(rpc, "failed to get sockaddr in CALLIT callback"); + srv_data->status = -1; + return; + } + + if (getnameinfo(sin, sizeof(struct sockaddr_in), &hostdd[0], sizeof(hostdd), NULL, 0, NI_NUMERICHOST) < 0) { + rpc_set_error(rpc, "getnameinfo failed in CALLIT callback"); + srv_data->status = -1; + return; + } + + + srvr = malloc(sizeof(struct nfs_server_list)); + if (srvr == NULL) { + rpc_set_error(rpc, "Malloc failed when allocating server structure"); + srv_data->status = -1; + return; + } + + srvr->addr = strdup(hostdd); + if (srvr->addr == NULL) { + rpc_set_error(rpc, "Strdup failed when allocating server structure"); + free(srvr); + srv_data->status = -1; + return; + } + + srvr->next = srv_data->srvrs; + srv_data->srvrs = srvr; +} + +struct nfs_server_list *nfs_find_local_servers(void) +{ + struct rpc_context *rpc; + struct nfs_list_data data = {0, NULL}; + struct timeval tv_start, tv_current; + struct ifconf ifc; + int size; + struct pollfd pfd; + char *ptr; + + rpc = rpc_init_udp_context(); + if (rpc == NULL) { + return NULL; + } + + if (rpc_bind_udp(rpc, "0.0.0.0", 0) < 0) { + rpc_destroy_context(rpc); + return NULL; + } + + + /* get list of all interfaces */ + size = sizeof(struct ifreq); + ifc.ifc_buf = NULL; + ifc.ifc_len = size; + + while(ifc.ifc_len > (size - sizeof(struct ifreq))) { + size *= 2; + + free(ifc.ifc_buf); + ifc.ifc_len = size; + ifc.ifc_buf = malloc(size); + memset(ifc.ifc_buf, 0, size); + if (ioctl(rpc_get_fd(rpc), SIOCGIFCONF, (caddr_t)&ifc) < 0) { + rpc_destroy_context(rpc); + free(ifc.ifc_buf); + return NULL; + } + } + + for (ptr =(char *)ifc.ifc_buf; ptr < ((char *)ifc.ifc_buf) + ifc.ifc_len; ) { + struct ifreq *ifr; + char bcdd[16]; + + ifr = (struct ifreq *)ptr; +#ifdef HAVE_SOCKADDR_LEN + if (ifr->ifr_addr.sa_len > sizeof(struct sockaddr)) { + ptr += sizeof(ifr->ifr_name) + ifr->ifr_addr.sa_len; + } else { + ptr += sizeof(ifr->ifr_name) + sizeof(struct sockaddr); + } +#else + ptr += sizeof(struct ifreq); +#endif + + if (ifr->ifr_addr.sa_family != AF_INET) { + continue; + } + if (ioctl(rpc_get_fd(rpc), SIOCGIFFLAGS, ifr) < 0) { + rpc_destroy_context(rpc); + free(ifc.ifc_buf); + return NULL; + } + if (!(ifr->ifr_flags & IFF_UP)) { + continue; + } + if (ifr->ifr_flags & IFF_LOOPBACK) { + continue; + } + if (!(ifr->ifr_flags & IFF_BROADCAST)) { + continue; + } + if (ioctl(rpc_get_fd(rpc), SIOCGIFBRDADDR, ifr) < 0) { + continue; + } + if (getnameinfo(&ifr->ifr_broadaddr, sizeof(struct sockaddr_in), &bcdd[0], sizeof(bcdd), NULL, 0, NI_NUMERICHOST) < 0) { + continue; + } + if (rpc_set_udp_destination(rpc, bcdd, 111, 1) < 0) { + rpc_destroy_context(rpc); + free(ifc.ifc_buf); + return NULL; + } + + if (rpc_pmap_callit_async(rpc, MOUNT_PROGRAM, 2, 0, NULL, 0, callit_cb, &data) < 0) { + rpc_destroy_context(rpc); + free(ifc.ifc_buf); + return NULL; + } + } + free(ifc.ifc_buf); + + gettimeofday(&tv_start, NULL); + for(;;) { + int mpt; + + pfd.fd = rpc_get_fd(rpc); + pfd.events = rpc_which_events(rpc); + + gettimeofday(&tv_current, NULL); + mpt = 1000 + - (tv_current.tv_sec *1000 + tv_current.tv_usec / 1000) + + (tv_start.tv_sec *1000 + tv_start.tv_usec / 1000); + + if (poll(&pfd, 1, mpt) < 0) { + free_nfs_srvr_list(data.srvrs); + rpc_destroy_context(rpc); + return NULL; + } + if (pfd.revents == 0) { + break; + } + + if (rpc_service(rpc, pfd.revents) < 0) { + break; + } + } + + rpc_destroy_context(rpc); + + if (data.status != 0) { + free_nfs_srvr_list(data.srvrs); + return NULL; + } + + return data.srvrs; +}