diff options
Diffstat (limited to 'xlators/nfs/server')
| -rw-r--r-- | xlators/nfs/server/src/acl3.c | 2 | ||||
| -rw-r--r-- | xlators/nfs/server/src/nfs.c | 74 | ||||
| -rw-r--r-- | xlators/nfs/server/src/nfs3.c | 6 | ||||
| -rw-r--r-- | xlators/nfs/server/src/nfs3.h | 2 |
4 files changed, 47 insertions, 37 deletions
diff --git a/xlators/nfs/server/src/acl3.c b/xlators/nfs/server/src/acl3.c index 08b099b4e60..a9843c7108b 100644 --- a/xlators/nfs/server/src/acl3.c +++ b/xlators/nfs/server/src/acl3.c @@ -562,7 +562,7 @@ acl3svc_setacl (rpcsvc_request_t *req) } /* Populate xattr buffer for Default ACL */ - bufheader = (struct posix_acl_xattr_header *)(cs->aclxattr); + bufheader = (struct posix_acl_xattr_header *)(cs->daclxattr); bufheader->version = htole32(POSIX_ACL_VERSION); bufentry = bufheader->entries; for (i = 0; i < cs->daclcount; i++) { diff --git a/xlators/nfs/server/src/nfs.c b/xlators/nfs/server/src/nfs.c index 75c8fe44eaf..8c895c66d92 100644 --- a/xlators/nfs/server/src/nfs.c +++ b/xlators/nfs/server/src/nfs.c @@ -959,7 +959,8 @@ nfs_init_state (xlator_t *this) nfs->enable_nlm = _gf_false; } - nfs->rpcsvc = rpcsvc_init (this, this->ctx, this->options, 0); + nfs->rpcsvc = rpcsvc_init (this, this->ctx, + this->options, fopspoolsize); if (!nfs->rpcsvc) { ret = -1; gf_log (GF_NFS, GF_LOG_ERROR, "RPC service init failed"); @@ -995,6 +996,9 @@ nfs_drc_init (xlator_t *this) int ret = -1; rpcsvc_t *svc = NULL; + GF_VALIDATE_OR_GOTO (GF_NFS, this, out); + GF_VALIDATE_OR_GOTO (GF_NFS, this->private, out); + svc = ((struct nfs_state *)(this->private))->rpcsvc; if (!svc) goto out; @@ -1227,6 +1231,23 @@ reconfigure (xlator_t *this, dict_t *options) return (0); } +/* Main init() routine for NFS server xlator. It inits NFS v3 protocol + * and its dependent protocols e.g. ACL, MOUNT v3 (mount3), NLM and + * DRC. + * + * Usage: glusterfsd: + * glusterfs_process_volfp() => + * glusterfs_graph_activate() => + * glusterfs_graph_init() => + * xlator_init () => NFS init() routine + * + * If init() routine fails, the glusterfsd cleans up the NFS process + * by invoking cleanup_and_exit(). + * + * RETURN: + * 0 (SUCCESS) if all protocol specific inits PASS. + * -1 (FAILURE) if any of them FAILS. + */ int init (xlator_t *this) { @@ -1234,59 +1255,52 @@ init (xlator_t *this) { int ret = -1; if (!this) - return -1; + return (-1); nfs = nfs_init_state (this); if (!nfs) { gf_log (GF_NFS, GF_LOG_ERROR, "Failed to init nfs option"); - return -1; + return (-1); } ret = nfs_add_all_initiators (nfs); - if (ret == -1) { + if (ret) { gf_log (GF_NFS, GF_LOG_ERROR, "Failed to add initiators"); - goto err; + return (-1); } ret = nfs_init_subvolumes (nfs, this->children); - if (ret == -1) { - gf_log (GF_NFS, GF_LOG_CRITICAL, "Failed to init NFS " - "exports"); - goto err; + if (ret) { + gf_log (GF_NFS, GF_LOG_CRITICAL, "Failed to init NFS exports"); + return (-1); } ret = mount_init_state (this); - if (ret == -1) { - gf_log (GF_NFS, GF_LOG_CRITICAL, "Failed to init Mount" - "state"); - goto err; + if (ret) { + gf_log (GF_NFS, GF_LOG_CRITICAL, "Failed to init Mount state"); + return (-1); } ret = nlm4_init_state (this); - if (ret == -1) { - gf_log (GF_NFS, GF_LOG_CRITICAL, "Failed to init NLM" - "state"); - goto err; + if (ret) { + gf_log (GF_NFS, GF_LOG_CRITICAL, "Failed to init NLM state"); + return (-1); } ret = nfs_init_versions (nfs, this); - if (ret == -1) { - gf_log (GF_NFS, GF_LOG_ERROR, "Failed to initialize " - "protocols"); - /* Do not return an error on this. If we dont return - * an error, the process keeps running and it helps - * to point out where the log is by doing ps ax|grep gluster. - */ - ret = 0; - goto err; + if (ret) { + gf_log (GF_NFS, GF_LOG_ERROR, "Failed to initialize protocols"); + return (-1); } ret = nfs_drc_init (this); - if (ret == 0) - gf_log (GF_NFS, GF_LOG_INFO, "NFS service started"); -err: + if (ret) { + gf_log (GF_NFS, GF_LOG_ERROR, "Failed to initialize DRC"); + return (-1); + } - return ret; + gf_log (GF_NFS, GF_LOG_INFO, "NFS service started"); + return (0); /* SUCCESS */ } diff --git a/xlators/nfs/server/src/nfs3.c b/xlators/nfs/server/src/nfs3.c index f914c31937d..0fea135c784 100644 --- a/xlators/nfs/server/src/nfs3.c +++ b/xlators/nfs/server/src/nfs3.c @@ -5256,8 +5256,6 @@ nfs3_init_options (struct nfs3_state *nfs3, dict_t *options) * accommodate the NFS headers also in the same buffer. */ nfs3->iobsize = nfs3->iobsize * 2; - /* mem-factor */ - nfs3->memfactor = GF_NFS3_DEFAULT_MEMFACTOR; ret = 0; err: return ret; @@ -5507,7 +5505,7 @@ nfs3_init_state (xlator_t *nfsx) unsigned int localpool = 0; struct nfs_state *nfs = NULL; - if (!nfsx) + if ((!nfsx) || (!nfsx->private)) return NULL; nfs3 = (struct nfs3_state *)GF_CALLOC (1, sizeof (*nfs3), @@ -5526,7 +5524,7 @@ nfs3_init_state (xlator_t *nfsx) nfs3->iobpool = nfsx->ctx->iobuf_pool; - localpool = nfs3->memfactor * GF_NFS_CONCURRENT_OPS_MULT; + localpool = nfs->memfactor * GF_NFS_CONCURRENT_OPS_MULT; gf_log (GF_NFS3, GF_LOG_TRACE, "local pool: %d", localpool); nfs3->localpool = mem_pool_new (nfs3_call_state_t, localpool); if (!nfs3->localpool) { diff --git a/xlators/nfs/server/src/nfs3.h b/xlators/nfs/server/src/nfs3.h index 0c35445a471..023b394cf5a 100644 --- a/xlators/nfs/server/src/nfs3.h +++ b/xlators/nfs/server/src/nfs3.h @@ -143,8 +143,6 @@ typedef struct nfs3_state { */ uint64_t iobsize; - unsigned int memfactor; - struct list_head fdlru; gf_lock_t fdlrulock; int fdcount; |