glusterd: cleanup pidfile on pmap signout

This patch ensures
1. brick pidfile is cleaned up on pmap signout
2. pmap signout evemt is sent for all the bricks when a brick process
shuts down.

>Reviewed-on: https://review.gluster.org/17168
>Smoke: Gluster Build System <jenkins@build.gluster.org>
>NetBSD-regression: NetBSD Build System <jenkins@build.gluster.org>
>CentOS-regression: Gluster Build System <jenkins@build.gluster.org>
>Reviewed-by: Jeff Darcy <jeff@pl.atyp.us>
>(cherry picked from commit 3d35e21ffb15713237116d85711e9cd1dda1688a)

Change-Id: I7606a60775b484651d4b9743b6037b40323931a2
BUG: 1449004
Signed-off-by: Atin Mukherjee <amukherj@redhat.com>
Reviewed-on: https://review.gluster.org/17211
Reviewed-by: Prashanth Pai <ppai@redhat.com>
Smoke: Gluster Build System <jenkins@build.gluster.org>
NetBSD-regression: NetBSD Build System <jenkins@build.gluster.org>
CentOS-regression: Gluster Build System <jenkins@build.gluster.org>
Reviewed-by: Jeff Darcy <jeff@pl.atyp.us>

1 files changed, 62 insertions, 0 deletions

diff --git a/xlators/mgmt/glusterd/src/glusterd-utils.c b/xlators/mgmt/glusterd/src/glusterd-utils.c
index 27af1b79851..4b8eb88e7fb 100644
--- a/xlators/mgmt/glusterd/src/glusterd-utils.c
+++ b/xlators/mgmt/glusterd/src/glusterd-utils.c
@@ -5824,6 +5824,7 @@ glusterd_get_brickinfo (xlator_t *this, const char *brickname, int port,
         glusterd_conf_t         *priv = NULL;
         glusterd_volinfo_t      *volinfo = NULL;
         glusterd_brickinfo_t    *tmpbrkinfo = NULL;
+        glusterd_snap_t         *snap    = NULL;
         int                     ret = -1;
 
         GF_ASSERT (brickname);
@@ -5842,6 +5843,21 @@ glusterd_get_brickinfo (xlator_t *this, const char *brickname, int port,
                         }
                 }
         }
+        /* In case normal volume is not found, check for snapshot volumes */
+        cds_list_for_each_entry (snap, &priv->snapshots, snap_list) {
+                cds_list_for_each_entry (volinfo, &snap->volumes, vol_list) {
+                        cds_list_for_each_entry (tmpbrkinfo, &volinfo->bricks,
+                                                 brick_list) {
+                                if (gf_uuid_compare (tmpbrkinfo->uuid, MY_UUID))
+                                        continue;
+                                if (!strcmp(tmpbrkinfo->path, brickname)) {
+                                        *brickinfo = tmpbrkinfo;
+                                        return 0;
+                                }
+                        }
+                }
+        }
+
         return ret;
 }
 
@@ -13241,6 +13257,52 @@ out:
         return ret;
 }
 
+int
+glusterd_get_volinfo_from_brick (char *brick, glusterd_volinfo_t **volinfo)
+{
+        int             ret                 = -1;
+        xlator_t                *this       = NULL;
+        glusterd_conf_t         *conf       = NULL;
+        glusterd_volinfo_t      *voliter    = NULL;
+        glusterd_brickinfo_t    *brickiter  = NULL;
+        glusterd_snap_t         *snap    = NULL;
+
+        this = THIS;
+        GF_VALIDATE_OR_GOTO ("glusterd", this, out);
+        conf = this->private;
+        GF_VALIDATE_OR_GOTO (this->name, conf, out);
+
+        /* First check for normal volumes */
+        cds_list_for_each_entry (voliter, &conf->volumes, vol_list) {
+                cds_list_for_each_entry (brickiter, &voliter->bricks,
+                                         brick_list) {
+                        if (gf_uuid_compare (brickiter->uuid, MY_UUID))
+                                continue;
+                        if (!strcmp(brickiter->path, brick)) {
+                                *volinfo = voliter;
+                                return 0;
+                        }
+                }
+        }
+        /* In case normal volume is not found, check for snapshot volumes */
+        cds_list_for_each_entry (snap, &conf->snapshots, snap_list) {
+                cds_list_for_each_entry (voliter, &snap->volumes, vol_list) {
+                        cds_list_for_each_entry (brickiter, &voliter->bricks,
+                                                 brick_list) {
+                                if (gf_uuid_compare (brickiter->uuid, MY_UUID))
+                                        continue;
+                                if (!strcmp(brickiter->path, brick)) {
+                                        *volinfo = voliter;
+                                        return 0;
+                                }
+                        }
+                }
+        }
+
+out:
+        return ret;
+}
+
 glusterd_op_t
 gd_cli_to_gd_op (char *cli_op)
 {