WebSVN – DevTools – Diff – /buildtool/trunk/src/generated/com/erggroup/buildtool/ripple/ReleaseManager.java

   private int mRunLevelIndex = -1;
   /**collection of ReleaseConfig objects
    * @attribute
    */
-  private Vector<ReleaseConfig> mReleaseConfigCollection = new Vector<ReleaseConfig>();
+  public Vector<ReleaseConfig> mReleaseConfigCollection = new Vector<ReleaseConfig>();
   /**database connection string
    * @attribute
    */
   private static String mConnectionString = new String();
+    {
       String sql = new String("");
       if ( daemonMode )
+      {
-        sql = "select gm.gbe_value " +
+        sql = "select gm.gbe_value" +
-              "from release_manager.release_config rc, release_manager.gbe_machtype gm " +
+              " from release_manager.release_config rc, release_manager.gbe_machtype gm" +
-              "where rc.rtag_id=" + baseline + " and gm.gbe_id=rc.gbe_id";
+              " where rc.rtag_id=" + baseline + " and gm.gbe_id=rc.gbe_id";
+      }
       else
+      {
-        sql =
-        "select gm.gbe_value " +
+        sql = "select gm.gbe_value" +
-          "from deployment_manager.boms b, release_manager.release_config rc, release_manager.gbe_machtype gm " +
+              " from deployment_manager.boms b, release_manager.release_config rc, release_manager.gbe_machtype gm" +
-          "where b.bom_id=" + baseline +
+              " where b.bom_id=" + baseline +  " and gm.gbe_id=rc.gbe_id" +
-          " and rc.rtag_id=b.rtag_id_fk "+
+              " and rc.rtag_id=b.rtag_id_fk ";
-          " and gm.gbe_id=rc.gbe_id";
+      }
       try
+      {
         CallableStatement stmt = mConnection.prepareCall(sql);
           // get planned package build info
           mLogger.warn("queryPackageVersions: stmt3");
           CallableStatement stmt3 = mConnection.prepareCall(
           "select pl.pv_id, bm.bm_name, bsa.bsa_name, pv.modified_stamp " +
+          "from release_manager.planned pl," +
+          "     release_manager.package_versions pv," +
+          "     release_manager.package_build_info pbi," +
+          "     release_manager.build_machines bm," +
-          "from release_manager.planned pl, release_manager.package_versions pv, release_manager.package_build_info pbi, release_manager.build_machines bm, release_manager.build_standards_addendum bsa " +
+          "     release_manager.build_standards_addendum bsa " +
+          "where pl.rtag_id=" + baseline +
-          "where pl.rtag_id=" + baseline + " and pv.build_type='A' and pv.dlocked='A' " +
+          "     and pv.build_type='A' and pv.dlocked='A' " +
+          "     and pv.pv_id = pl.pv_id" +
+          "     and pbi.pv_id=pv.pv_id" +
+          "     and bm.bm_id=pbi.bm_id" +
-          "and pv.pv_id = pl.pv_id and pbi.pv_id=pv.pv_id and bm.bm_id=pbi.bm_id and bsa.bsa_id=pbi.bsa_id " +
+          "     and bsa.bsa_id=pbi.bsa_id " +
           "order by pv.modified_stamp"
           );
           ResultSet rset3 = stmt3.executeQuery();
           while( rset3.next() )
           // view based
           mLogger.warn("queryPackageVersions: stmt5");
           CallableStatement stmt5 = mConnection.prepareCall(
           "select pl.pv_id, u.user_email, pv.modified_stamp " +
+          " from release_manager.planned pl, " +
+          "      release_manager.release_tags rt, " +
+          "      release_manager.package_versions pv, " +
-          "from release_manager.planned pl, release_manager.release_tags rt, release_manager.package_versions pv, release_manager.autobuild_failure af, release_manager.members_group mg, release_manager.users u " +
+          "      release_manager.autobuild_failure af, " +
+          "      release_manager.members_group mg, " +
+          "      release_manager.users u " +
+          " where pl.rtag_id=" + baseline +
+          "      and rt.rtag_id=pl.rtag_id" +
-          "where pl.rtag_id=" + baseline + " and rt.rtag_id=pl.rtag_id and pv.build_type='A' and pv.dlocked='A' " +
+          "      and pv.build_type='A' and pv.dlocked='A' " +
+          "      and pv.pv_id = pl.pv_id " +
+          "      and af.view_id=pl.view_id " +
-          "and pv.pv_id = pl.pv_id and af.view_id=pl.view_id and mg.group_email_id=af.group_email_id and u.user_id=mg.user_id and af.proj_id=rt.proj_id " +
+          "      and mg.group_email_id=af.group_email_id " +
+          "      and u.user_id=mg.user_id " +
+          "      and af.proj_id=rt.proj_id " +
-          "order by pv.modified_stamp"
+          " order by pv.modified_stamp"
           );
           ResultSet rset5 = stmt5.executeQuery();
           while( rset5.next() )
+          {
           // get released package build info
           mLogger.warn("queryPackageVersions: stmt10");
           CallableStatement stmt10 = mConnection.prepareCall(
           "select rc.pv_id, bm.bm_name, bsa.bsa_name " +
+          "from release_manager.release_content rc," +
+          "     release_manager.package_versions pv," +
+          "     release_manager.package_build_info pbi," +
+          "     release_manager.build_machines bm," +
-          "from release_manager.release_content rc, release_manager.package_versions pv, release_manager.package_build_info pbi, release_manager.build_machines bm, release_manager.build_standards_addendum bsa " +
+          "     release_manager.build_standards_addendum bsa " +
           "where rc.rtag_id=" + baseline +
+          "     and pv.pv_id = rc.pv_id" +
+          "     and pbi.pv_id=pv.pv_id" +
+          "     and bm.bm_id=pbi.bm_id" +
-          " and pv.pv_id = rc.pv_id and pbi.pv_id=pv.pv_id and bm.bm_id=pbi.bm_id and bsa.bsa_id=pbi.bsa_id " +
+          "     and bsa.bsa_id=pbi.bsa_id " +
           "order by rc.pv_id"
           );
           ResultSet rset10 = stmt10.executeQuery();
           while( rset10.next() )
                 // get planned package build info
                 mLogger.warn("queryPackageVersions: stmt17");
                 CallableStatement stmt17 = mConnection.prepareCall(
                 "select bm.bm_name, bsa.bsa_name " +
+                "from release_manager.work_in_progress wip," +
+                "     release_manager.package_versions pv," +
+                "     release_manager.package_build_info pbi," +
+                "     release_manager.build_machines bm," +
-                "from release_manager.work_in_progress wip, release_manager.package_versions pv, release_manager.package_build_info pbi, release_manager.build_machines bm, release_manager.build_standards_addendum bsa " +
+                "     release_manager.build_standards_addendum bsa " +
                 "where wip.rtag_id=" + baseline +
-                " and wip.pv_id=" + testBuildPvId +
+                "   and wip.pv_id=" + testBuildPvId +
-                " and pv.pv_id=" + testBuildPvId +
+                "   and pv.pv_id=" + testBuildPvId +
+                "   and pbi.pv_id=pv.pv_id" +
+                "   and bm.bm_id=pbi.bm_id" +
-                " and pbi.pv_id=pv.pv_id and bm.bm_id=pbi.bm_id and bsa.bsa_id=pbi.bsa_id "
+                "   and bsa.bsa_id=pbi.bsa_id"
                 );
                 ResultSet rset17 = stmt17.executeQuery();
                 while( rset17.next() )
+                {
+    {
       try
+      {
         CallableStatement stmt = mConnection.prepareCall(
         "select bm.bm_name, bsa.bsa_name " +
+        "from release_manager.package_versions pv," +
+        "     release_manager.package_build_info pbi," +
+        "     release_manager.build_machines bm," +
-        "from release_manager.package_versions pv, release_manager.package_build_info pbi, release_manager.build_machines bm, release_manager.build_standards_addendum bsa " +
+        "     release_manager.build_standards_addendum bsa " +
+        "where pv.pv_id=" + p.mId +
+        "   and pbi.pv_id=pv.pv_id" +
+        "   and bm.bm_id=pbi.bm_id" +
-        "where pv.pv_id=" + p.mId + " and pbi.pv_id=pv.pv_id and bm.bm_id=pbi.bm_id and bsa.bsa_id=pbi.bsa_id " +
+        "   and bsa.bsa_id=pbi.bsa_id " +
         "order by pv.pv_id"
         );
         ResultSet rset = stmt.executeQuery();
         while( rset.next() )
+    }
+  }
   /**Representation of a row in the RELEASE_CONFIG table
    */
-  private class ReleaseConfig
-  {
-    /**rtag_id column value
-     * @attribute
-     */
-    private int mRtag_id;
-    /**rcon_id column value
-     * @attribute
-     */
-    private int mRcon_id;
-    /**daemon_mode column value
-     * @attribute
-     */
-    private char mDaemon_mode;
-    /**constructor
-     */
-    ReleaseConfig(int rtag_id, int rcon_id, char daemon_mode)
-    {
-      mLogger.debug("ReleaseConfig rtag_id " + rtag_id + " rcon_id " + rcon_id + " daemon_mode " + daemon_mode );
-      mRtag_id = rtag_id;
-      mRcon_id = rcon_id;
-      mDaemon_mode = daemon_mode;
-    }
-    /**accessor method
-     */
-    int get_rtag_id()
-    {
-      mLogger.debug("get_rtag_id");
-      mLogger.info("get_rtag_id returned " + mRtag_id);
-      return mRtag_id;
-    }
-    /**accessor method
-     */
-    int get_rcon_id()
-    {
-      mLogger.debug("get_rcon_id");
-      mLogger.info("get_rcon_id returned " + mRcon_id);
-      return mRcon_id;
-    }
-    /**accessor method
-     */
-    char get_daemon_mode()
-    {
-      mLogger.debug("get_daemon_mode");
-      mLogger.info("get_daemon_mode returned " + mDaemon_mode);
-      return mDaemon_mode;
-    }
-  }
   /**Representation of a row in the RUN_LEVEL table
    */
   private class RunLevel
+  {
     /**rcon_id column value
      */
     private boolean mPause;
     /**constructor
      */
-    RunLevel(int rcon_id, String current_build_file, int current_run_level,
+    RunLevel(int rcon_id, String current_build_file, int current_run_level, boolean pause)
-             boolean pause)
+    {
       mLogger.debug("RunLevel");
       mRcon_id = rcon_id;
       mCurrent_build_file = current_build_file;
       mCurrent_run_level = current_run_level;
     mLogger.info("getFirstReleaseConfig 2 returning " + retVal);
     return retVal;
+  }
-  /**returns true if the mRunLevelCollection is not empty and returns the rcon_id and current_run_level of the first element
-   */
-  public boolean getFirstRunLevel(MutableInt rcon_id,
-                                  MutableInt current_run_level)
-  {
-    mLogger.debug("getFirstRunLevel");
-    boolean retVal = true;
-    try
-    {
-      mRunLevelIndex = 0;
-      RunLevel rl = mRunLevelCollection.get( mRunLevelIndex );
-      rcon_id.value = rl.get_rcon_id();
-      current_run_level.value = rl.get_current_run_level();
-    }
-    catch( ArrayIndexOutOfBoundsException e )
-    {
-      retVal = false;
-    }
-    mLogger.info("getFirstRunLevel returning " + retVal);
-    return retVal;
-  }
   /**returns true if the mReleaseConfigCollection contains a next element and returns the rcon_id of the next element
    */
   public boolean getNextReleaseConfig(MutableInt rcon_id)
+  {
     mLogger.debug("getNextReleaseConfig 1");
     mLogger.info("getNextReleaseConfig 2 returning " + retVal);
     return retVal;
+  }
+  /**returns true if the mRunLevelCollection is not empty and returns the rcon_id and current_run_level of the first element
+   */
+  public boolean getFirstRunLevel(MutableInt rcon_id,
+                                  MutableInt current_run_level)
+  {
+    mLogger.debug("getFirstRunLevel");
+    boolean retVal = true;
+    try
+    {
+      mRunLevelIndex = 0;
+      RunLevel rl = mRunLevelCollection.get( mRunLevelIndex );
+      rcon_id.value = rl.get_rcon_id();
+      current_run_level.value = rl.get_current_run_level();
+    }
+    catch( ArrayIndexOutOfBoundsException e )
+    {
+      retVal = false;
+    }
+    mLogger.info("getFirstRunLevel returning " + retVal);
+    return retVal;
+  }
   /**returns true if the mRunLevelCollection contains a next element and returns the rcon_id and current_run_level of the next element
    */
   public boolean getNextRunLevel(MutableInt rcon_id,
                                  MutableInt current_run_level)
+  {
     mLogger.info("queryReleaseConfig 1 returning " + retVal);
     return retVal;
+  }
-  /**queries the RELEASE_CONFIG table using the rcon_id primary key for the gbebuildfilter
-   */
-  public void queryBuildFilter(final int rcon_id,
-                               MutableString gbebuildfilter) throws SQLException, Exception
-  {
-    mLogger.debug("queryBuildFilter");
-    if ( !mUseDatabase )
-    {
-      mLogger.info("queryBuildFilter !mUseDatabase");
-    }
-    else
-    {
-      try
-      {
-        connect();
-        String sql = new String("select gbe_buildfilter from release_manager.release_config where rcon_id=" + rcon_id );
-        CallableStatement stmt = mConnection.prepareCall( sql );
-        ResultSet rset = stmt.executeQuery();
-        int rsetSize = 0;
-        while( rset.next() )
-        {
-          rsetSize++;
-          gbebuildfilter.value = rset.getString("gbe_buildfilter");
-        }
-        rset.close();
-        stmt.close();
-        if ( rsetSize > 1 )
-        {
-          mLogger.fatal("queryBuildFilter rsetSize > 1");
-          // show stopper
-          throw new Exception("queryBuildFilter rsetSize > 1");
-        }
-      }
-      catch ( SQLException e )
-      {
-        if ( mConnection == null || ( mConnection != null && !mConnection.isValid(10) ) )
-        {
-          mLogger.error("queryBuildFilter database access error only");
-          throw new SQLException();
-        }
-        else
-        {
-          mLogger.fatal("queryBuildFilter show stopper");
-          throw new Exception("queryBuildFilter show stopper");
-        }
-      }
-      finally
-      {
-        // this block is executed regardless of what happens in the try block
-        // even if an exception is thrown
-        // ensure disconnect
-        disconnect();
-      }
-    }
-  }
   /**removes all elements from the mReleaseConfigCollection
    * handles database connection and disconnection
    * queries the RELEASE_CONFIG table using the rtag_id
    * populates the mReleaseConfigCollection with the query result set
    * partially implements the sequence diagrams coordinate slave threads generate build files
+   *
+   * Used by Master Thread to determine the build machines that will be a part
+   * of the Slave-Sync process.
    */
   public void queryReleaseConfig(final int rtag_id) throws SQLException, Exception
+  {
     mLogger.debug("queryReleaseConfig 2");
     mReleaseConfigCollection.removeAllElements();
     if ( !mUseDatabase )
+    {
       mLogger.info("queryReleaseConfig 2 !mUseDatabase");
-      ReleaseConfig releaseConfig = new ReleaseConfig(1,1,'M');
+      ReleaseConfig releaseConfig = new ReleaseConfig(1,1,'M', "DummyHost1","DummyTarget1", "DummyMachtype1", "Win32");
       mReleaseConfigCollection.add(releaseConfig);
-      releaseConfig = new ReleaseConfig(1,2,'S');
+      releaseConfig = new ReleaseConfig(1,2,'S', "DummyHost2","DummyTarget2", "DummyMachtype1", "Linux");
       mReleaseConfigCollection.add(releaseConfig);
+    }
     else
+    {
       try
+      {
         connect();
         CallableStatement stmt = mConnection.prepareCall(
-            "select rc.rcon_id, rc.daemon_mode, rl.pause" +
+            " select rc.rcon_id, rc.daemon_mode, rl.pause, bc.machine_hostname, rc.gbe_buildfilter, mt.gbe_value, bm.bm_name" +
-            " from release_manager.release_config rc, release_manager.run_level rl" +
+            "    from release_manager.release_config rc, " +
+            "         release_manager.run_level rl, " +
+            "         release_manager.build_machine_config bc, " +
+            "         release_manager.gbe_machtype mt," +
+            "         release_manager.build_machines bm" +
+            "    where rc.rtag_id=" + rtag_id +
-            " where rc.rtag_id=" + rtag_id + " and rl.rcon_id=rc.rcon_id");
+            "        and rl.rcon_id=rc.rcon_id " +
+            "        and bc.machine_hostname=rc.daemon_hostname " +
+            "        and mt.gbe_id=bc.gbe_id" +
+            "        and mt.bm_id=bm.bm_id"
+            );
         ResultSet rset = stmt.executeQuery();
         while( rset.next() )
+        {
+            {
               dm = 'M';
+            }
+          }
+          String machine_hostname = rset.getString("machine_hostname");
+          if (machine_hostname == null)
+          {
+              mLogger.fatal("queryReleaseConfig 2 null machine_hostname " + rtag_id);
+              throw new Exception("queryReleaseConfig 2 null machine_hostname " + rtag_id);
+          }
+          String gbe_buildfilter = rset.getString("gbe_buildfilter");
+          String gbe_machtype = rset.getString("gbe_value");
+          if (gbe_machtype == null)
+          {
+              mLogger.fatal("queryReleaseConfig 2 null gbe_value " + rtag_id);
+              throw new Exception("queryReleaseConfig 2 null gbe_value " + rtag_id);
+          }
+          String gbe_machclass = rset.getString("bm_name");
+          if (gbe_machclass == null)
+          {
+              mLogger.fatal("queryReleaseConfig 2 null bm_name " + rtag_id);
+              throw new Exception("queryReleaseConfig 2 null bm_name " + rtag_id);
+          }
           //
           //  Pause: null -> 0 == Run
           //         1         == Pause
           //         2         == Disabled
           //
           int pause = rset.getInt("pause");
           if ( rset.wasNull() )
+          {
             pause = 0;
+          }
-          mLogger.info("queryReleaseConfig 2: " + rtag_id + ", " + rcon_id + ", "+ dm + ", " + pause );
+          mLogger.info("queryReleaseConfig 2: " + rtag_id + ", " + rcon_id + ", "+ dm + ", " + pause +
+                       ", " + machine_hostname + ", " + gbe_buildfilter + ", " + gbe_machtype + ", + " + gbe_machclass );
+          //
+          // Do not include build daemons that are disabled
+          //
           if ( pause <= 1 )
+          {
-            ReleaseConfig releaseConfig = new ReleaseConfig( rtag_id, rcon_id, dm );
+            ReleaseConfig releaseConfig = new ReleaseConfig( rtag_id, rcon_id, dm, machine_hostname, gbe_buildfilter, gbe_machtype, gbe_machclass);
             mReleaseConfigCollection.add(releaseConfig);
+          }
+        }
   /**removes all elements from the mReleaseConfigCollection
    * handles database connection and disconnection
    * queries the RELEASE_CONFIG table using the daemon_hostname
    * populates the mReleaseConfigCollection with the query result set
    * partially implements the sequence diagram spawn thread
+   *
+   * Used by each build thread to determine daemons to start and stop
    */
   public void queryReleaseConfig(final String hostname) throws SQLException, Exception
+  {
     mLogger.debug("queryReleaseConfig 3 " + hostname);
     mReleaseConfigCollection.removeAllElements();
     if ( mConnectionString.compareTo("unit test spawn thread") == 0)
+    {
       mLogger.info("queryReleaseConfig 3 unit test spawn thread");
       // specifying a gbebuildfilter of unit test is designed to invoke a benign thread for unit test purposes
-      ReleaseConfig releaseConfig = new ReleaseConfig(1,1,'M');
+      ReleaseConfig releaseConfig = new ReleaseConfig(1,1,'M', "DummyHost1","DummyTarget1", "DummyMachtype1", "Win32");
       mReleaseConfigCollection.add(releaseConfig);
-      releaseConfig = new ReleaseConfig(2,2,'S');
+      releaseConfig = new ReleaseConfig(2,2,'S', "DummyHost2","DummyTarget2", "DummyMachtype2", "Linux");
       mReleaseConfigCollection.add(releaseConfig);
+    }
     else
+    {
       try
+      {
         connect();
         CallableStatement stmt = mConnection.prepareCall(
-            "select rc.rtag_id, rc.rcon_id, rc.daemon_mode, rl.pause " +
+            "select rc.rtag_id, rc.rcon_id, rc.daemon_mode, rl.pause, bc.machine_hostname, rc.gbe_buildfilter, mt.gbe_value, bm.bm_name" +
-            "from release_manager.release_config rc, release_manager.release_tags rt, release_manager.run_level rl " +
+            "    from release_manager.release_config rc," +
+            "       release_manager.release_tags rt," +
+            "       release_manager.run_level rl," +
+            "       release_manager.build_machine_config bc," +
+            "       release_manager.gbe_machtype mt," +
+            "       release_manager.build_machines bm " +
-            "where rc.daemon_hostname='" + hostname + "'" +
+            "    where rc.daemon_hostname='"+ hostname +"'" +
-            "  and rt.rtag_id=rc.rtag_id" +
+            "      and rt.rtag_id=rc.rtag_id" +
-            "  and rl.rcon_id=rc.rcon_id" +
+            "      and rl.rcon_id=rc.rcon_id" +
+            "      and bc.machine_hostname=rc.daemon_hostname" +
+            "      and mt.gbe_id=bc.gbe_id" +
+            "      and mt.bm_id=bm.bm_id" +
-            "  and (rt.official = 'N' or rt.official='R' or rt.official='C')"
+            "      and (rt.official = 'N' or rt.official='R' or rt.official='C')"
             );
         ResultSet rset = stmt.executeQuery();
         while( rset.next() )
+        {
           int rtag_id = rset.getInt("rtag_id");
           int rcon_id = rset.getInt("rcon_id");
           if ( rset.wasNull() )
+          {
             mLogger.fatal("queryReleaseConfig 3 null rcon_id");
-            // show stopper
             throw new Exception("queryReleaseConfig 3 null rcon_id");
+          }
           char dm = 'S';
           String daemon_mode = rset.getString("daemon_mode");
             if ( daemon_mode.compareTo("M") == 0 )
+            {
               dm = 'M';
+            }
+          }
+          String machine_hostname = rset.getString("machine_hostname");
+          if (machine_hostname == null)
+          {
+              mLogger.fatal("queryReleaseConfig 3 null machine_hostname " + rtag_id);
+              throw new Exception("queryReleaseConfig 3 null machine_hostname " + rtag_id);
+          }
+          String gbe_buildfilter = rset.getString("gbe_buildfilter");
+          String gbe_machtype = rset.getString("gbe_value");
+          if (gbe_machtype == null)
+          {
+              mLogger.fatal("queryReleaseConfig 3 null gbe_value " + rtag_id);
+              throw new Exception("queryReleaseConfig 3 null gbe_value " + rtag_id);
+          }
+          String gbe_machclass = rset.getString("bm_name");
+          if (gbe_machclass == null)
+          {
+              mLogger.fatal("queryReleaseConfig 3 null bm_name " + rtag_id);
+              throw new Exception("queryReleaseConfig 3 null bm_name " + rtag_id);
+          }
           //
           //  Pause: null -> 0 == Run
           //         1         == Pause
           //         2         == Disabled
           int pause = rset.getInt("pause");
           if ( rset.wasNull() )
+          {
             pause = 0;
+          }
-          mLogger.info("queryReleaseConfig 3: " + rtag_id + ", " + rcon_id + ", "+ dm + ", " + pause );
+          mLogger.info("queryReleaseConfig 3: " + rtag_id + ", " + rcon_id + ", "+ dm + ", " + pause +
+                       ", " + machine_hostname + ", " + gbe_buildfilter + ", " + gbe_machtype + ", + " + gbe_machclass );
+          //
+          // Do not include build daemons that are disabled
+          // Only those that are running or paused
+          //
           if ( pause <= 1 )
+          {
-            ReleaseConfig releaseConfig = new ReleaseConfig( rtag_id, rcon_id, dm );
+            ReleaseConfig releaseConfig = new ReleaseConfig( rtag_id, rcon_id, dm, machine_hostname, gbe_buildfilter, gbe_machtype, gbe_machclass);
             mReleaseConfigCollection.add(releaseConfig);
+          }
+        }
         rset.close();
+  }
   /**queries the RUN_LEVEL table using the rcon_id primary key
    * handles database connection and disconnection
    * returns the current_build_files
    * implements the sequence diagram consume build files
+   *
+   * Used by the Slave Daemon
    */
   public void queryRunLevel(int rcon_id, MutableString currentBuildFiles) throws SQLException, Exception
+  {
     mLogger.debug("queryRunLevel 1 rcon_id " + rcon_id);
     if ( !mUseDatabase )
   /**removes all elements from the mRunLevelCollection
    * handles database connection and disconnection
    *   select rl.rcon_id, rl.current_run_level from release_manager.release_config rc, release_manager.run_level rl
    *   where rc.rtag_id=<rtag_id> and rl.rcon_id=rc.rcon_id;
    * populates the mRunLevelCollection with the query result set
    * refer to sequence diagram coordinate slave threads
+   *
+   * Used by the Master Daemon
    */
   public void queryRunLevel(final int rtag_id) throws SQLException, Exception
+  {
     mLogger.debug("queryRunLevel 2 rtag_id " + rtag_id);
     if ( mConnectionString.compareTo("unit test coordinate slave threads") == 0)
       try
+      {
         connect();
         CallableStatement stmt = mConnection.prepareCall(
-        "select rl.rcon_id, rl.current_run_level from release_manager.release_config rc, release_manager.run_level rl " +
+            "select rl.rcon_id, rl.current_run_level from release_manager.release_config rc, release_manager.run_level rl " +
-        "where rc.rtag_id=" +rtag_id + " and rl.rcon_id=rc.rcon_id");
+            "where rc.rtag_id=" +rtag_id + " and rl.rcon_id=rc.rcon_id");
         ResultSet rset = stmt.executeQuery();
         int rsetSize = 0;
         int rcon_id = 0;
         int current_run_level = 0;

Subversion Repositories DevTools

(root)/buildtool/trunk/src/generated/com/erggroup/buildtool/ripple/ReleaseManager.java @ 4280 – Rev 4212 → 4280