Pass gpstart '-B' ('--parallel') option to gpstop

gpstart calls gpstop, so honor the parallel parameter by passing it along to gpstop.
Authored-by: NKalen Krempely <kkrempely@pivotal.io>

gpMgmt/bin/gppylib/commands/gp.py

@@ -784,7 +784,7 @@ class NewGpStop(Command):
 
 #-----------------------------------------------
 class GpStop(Command):
-    def __init__(self, name, masterOnly=False, verbose=False, quiet=False, restart=False, fast=False, force=False, datadir=None, ctxt=LOCAL, remoteHost=None, logfileDirectory=False, reload=False):
+    def __init__(self, name, masterOnly=False, verbose=False, quiet=False, restart=False, fast=False, force=False, datadir=None, parallel=None, reload=False, ctxt=LOCAL, remoteHost=None, logfileDirectory=False):
         self.cmdStr="$GPHOME/bin/gpstop -a"
         if masterOnly:
             self.cmdStr += " -m"
@@ -800,6 +800,8 @@ class GpStop(Command):
             self.cmdStr += " -v"
         if quiet:
             self.cmdStr += " -q"
+        if parallel:
+            self.cmdStr += " -B %s" % parallel
         if logfileDirectory:
             self.cmdStr += " -l '" + logfileDirectory + "'"
         if reload:
@@ -807,8 +809,8 @@ class GpStop(Command):
         Command.__init__(self,name,self.cmdStr,ctxt,remoteHost)
 
     @staticmethod
-    def local(name,masterOnly=False, verbose=False, quiet=False,restart=False, fast=False, force=False, datadir=None, reload=False):
-        cmd=GpStop(name,masterOnly,verbose,quiet,restart,fast,force,datadir,reload=reload)
+    def local(name,masterOnly=False, verbose=False, quiet=False,restart=False, fast=False, force=False, datadir=None, parallel=None, reload=False):
+        cmd=GpStop(name,masterOnly,verbose,quiet,restart,fast,force,datadir,parallel,reload)
         cmd.run(validateAfter=True)
         return cmd
 

gpMgmt/bin/gpstart

@@ -137,6 +137,7 @@ class GpStart:
                             fast=True, quiet=logging_is_quiet(),
                             verbose=logging_is_verbose(),
                             datadir=self.master_datadir,
+                            parallel=self.parallel,
                             logfileDirectory=self.logfileDirectory)
             cmd.run()
             logger.debug("results of forcing master shutdown: %s" % cmd)
@@ -257,6 +258,7 @@ class GpStart:
                 cmd = gp.GpStop("Shutting down master", masterOnly=True,
                                 fast=True, quiet=logging_is_quiet(),
                                 verbose=logging_is_verbose(),
+                                parallel=self.parallel,
                                 datadir=self.master_datadir)
                 cmd.run(validateAfter=True)
                 logger.info("Master Stopped...")
@@ -300,7 +302,7 @@ class GpStart:
         gp.GpStop.local("forcing master shutdown", masterOnly=True,
                         verbose=logging_is_verbose,
                         quiet=self.quiet, fast=False,
-                        force=True, datadir=self.master_datadir)
+                        force=True, datadir=self.master_datadir, parallel=self.parallel)
 
     ######
     def _remove_postmaster_tmpfile(self, port):