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

   /**collection of RunLevel objects
    * @attribute
    */
   private Vector<RunLevel> mRunLevelCollection = new Vector<RunLevel>();
+  /**set in claimVersion, cleared in discardVersion
+   * @attribute
+   */
+  private String mPlannedPkgId = null;
+  /**set in claimVersion, cleared in discardVersion
+   * @attribute
+   */
+  private String mPlannedPkgVersion = null;
   /**in daemon mode
    *   select gm.gbe_value from release_manager.release_config rc, release_manager.gbe_machtype gm
    *   where rc.rtag_id=<baseline> and gm.gbe_id=rc.gbe_id;
    * in escrow mode
    *   select gm.gbe_value from deployment_manager.boms b, release_manager.release_config rc,
+        {
           mLogger.fatal("claimMutex show stopper");
           throw new Exception("claimMutex show stopper");
+        }
+      }
+      // about to start the planning process again, discard previous
+      discardVersions();
+    }
+  }
   /**sets CURRENT_BUILD_FILES to NULL for the rcon_id
    * update release_manager.run_level set current_build_files=null where rcon_id=<rcon_id>
   /**ensures a run_level_schedule row with a non null indefinite_pause column exists
    * this is aimed at stopping all daemons dead
    * it is raised when handling an unsupported exception case in either the main or slave daemons
    * typically an SQLException other than a database connection related one
    */
-  public void indefinitePause() throws SQLException
+  public void indefinitePause()
+  {
     mLogger.debug("indefinitePause");
     if ( mUseDatabase )
+    {
       try
+      {
-      connect();
+        connect();
-      CallableStatement stmt = mConnection.prepareCall( "begin PK_BUILDAPI.SET_INFINITE_PAUSE(); end;" );
+        CallableStatement stmt = mConnection.prepareCall( "begin PK_BUILDAPI.SET_INFINITE_PAUSE(); end;" );
-      stmt.executeUpdate();
+        stmt.executeUpdate();
-      stmt.close();
+        stmt.close();
-      mConnection.commit();
+        mConnection.commit();
-      disconnect();
+        disconnect();
+      }
       catch( SQLException e )
+      {
         // do not throw Exception
         // this is part of Exception handling
         mLogger.fatal( "indefinitePause caught Exception " + e.getMessage() );
+      }
+    }
+  }
+  /**ensures a run_level_schedule row with a non null indefinite_pause column does not exist
+   * this is aimed at resuming all daemons
+   */
+  private void resume() throws SQLException, Exception
+  {
+    mLogger.debug("resume");
+    if ( mUseDatabase )
+    {
+      try
+      {
+        CallableStatement stmt = mConnection.prepareCall( "begin PK_BUILDAPI.SET_RESUME(); end;" );
+        stmt.executeUpdate();
+        stmt.close();
+        mConnection.commit();
+      }
+      catch ( SQLException e )
+      {
+        if ( mConnection == null || ( mConnection != null && !mConnection.isValid(10) ) )
+        {
+          mLogger.error("resume database access error only");
+          throw new SQLException();
+        }
+        else
+        {
+          mLogger.fatal("resume show stopper");
+          throw new Exception("resume show stopper");
+        }
+      }
+    }
+  }
   /**only used in daemon mode to determine version existence in the database
    *  1 select pkg_id from release_manager.package_versions where pkg_id=<pkg_id> and pkg_version=<pkg_version>;
    *  2 select pkg_id from release_manager.planned_versions where pkg_id=<pkg_id> and pkg_version=<pkg_version>;
    * returns true if either resultset contains one record to indicate it already exists
    */
+    {
       try
+      {
         if (isRtagIdConfigured( rtag_id ))
+        {
-          CallableStatement stmt3 = mConnection.prepareCall("insert into release_manager.planned_versions (pkg_id, pkg_version) values (" + pkg_id + ", '" + pkg_version + "')");
+          CallableStatement stmt3 = mConnection.prepareCall("insert into release_manager.planned_versions (pkg_id, pkg_version, planned_time) values (" + pkg_id + ", '" + pkg_version + "', sysdate)");
           stmt3.executeUpdate();
           stmt3.close();
           CallableStatement stmt4 = mConnection.prepareCall(
           "update " +
           "(" +
           ")" +
           "set current_pkg_id_being_built=" + pkg_id);
           stmt4.executeUpdate();
           stmt4.close();
           mConnection.commit();
+          mPlannedPkgId = new String();
+          mPlannedPkgId += pkg_id;
+          mPlannedPkgVersion = new String( pkg_version );
+        }
+      }
       catch ( SQLException e )
+      {
         if ( mConnection == null || ( mConnection != null && !mConnection.isValid(10) ) )
+      }
+    }
+  }
   /**only used in daemon mode
+   * delete from release_manager.planned_versions where pkg_id=<pkg_id> and pkg_version=<pkg_version>;
+   */
+  public void discardVersion() throws SQLException, Exception
+  {
+    mLogger.debug("discardVersion");
+    if ( mPlannedPkgId != null && mPlannedPkgVersion != null )
+    {
+      try
+      {
+        CallableStatement stmt = mConnection.prepareCall("delete from release_manager.planned_versions where pkg_id=" + mPlannedPkgId + " and pkg_version='" + mPlannedPkgVersion + "'");
+        stmt.executeUpdate();
+        stmt.close();
+        mConnection.commit();
+        mPlannedPkgId = null;
+        mPlannedPkgVersion = null;
+      }
+      catch ( SQLException e )
+      {
+        if ( mConnection == null || ( mConnection != null && !mConnection.isValid(10) ) )
+        {
+          mLogger.error("discardVersion database access error only");
+          throw new SQLException();
+        }
+        else
+        {
+          mLogger.fatal("discardVersion show stopper");
+          throw new Exception("discardVersion show stopper");
+        }
+      }
+    }
+  }
+  /**only used in daemon mode
+   * delete planned versions over 24 hours old (rounded to the nearest hour that is)
+   * delete from release_manager.planned_versions where planned_time < trunc(sysdate, 'hh') - 1");
+   */
+  private void discardVersions() throws SQLException, Exception
+  {
+    mLogger.debug("discardVersions");
+    try
+    {
+      // housekeep whilst the daemon has the mutex
+      // trunc(sysdate, 'hh') returns the time now rounded to the nearest hour
+      // trunc(sysdate, 'hh') - 1 returns the time 24 hours ago rounded to the nearest hour
+      // this statement does not return any rows when planned_time is null, though this should never be the case
+      CallableStatement stmt = mConnection.prepareCall("delete from release_manager.planned_versions where planned_time < trunc(sysdate, 'hh') - 1");
+      stmt.executeUpdate();
+      stmt.close();
+      mConnection.commit();
+    }
+    catch ( SQLException e )
+    {
+      if ( mConnection == null || ( mConnection != null && !mConnection.isValid(10) ) )
+      {
+        mLogger.error("discardVersions database access error only");
+        throw new SQLException();
+      }
+      else
+      {
+        mLogger.fatal("discardVersions show stopper");
+        throw new Exception("discardVersions show stopper");
+      }
+    }
+  }
+  /**only used in daemon mode
    *  update
    *  (
    *  select current_pkg_id_being_built from release_manager.run_level
    *  where rcon_id=<rcon_id>
    *  )
     if ( mUseDatabase )
+    {
       try
+      {
         connect();
-        CallableStatement stmt = mConnection.prepareCall( "begin ? := PK_RMAPI.EXCLUDE_INDIRECT_FROM_BUILD(?,?,?,?,?,?,?); end;" );
-        stmt.registerOutParameter( 1, Types.INTEGER);
-        stmt.setString( 2, packageVersionId );
-        stmt.setString( 3, packageVersion );
-        stmt.setString( 4, rtagId );
+        boolean exist = false;
-        stmt.setString( 5, "buildadm" );
-        stmt.setString( 6, rootPvId);
-        stmt.setString( 7, rootCause);
+        // do not exclude a package already excluded ie let the first build failure count
-        stmt.setString( 8, rootFile);
+        CallableStatement stmt = mConnection.prepareCall("select pv_id from release_manager.do_not_ripple where pv_id=" + packageVersionId + "and rtag_id=" + rtagId);
-        stmt.executeUpdate();
-        int result = stmt.getInt( 1 );
+        ResultSet rset = stmt.executeQuery();
-        if ( result != 0 )
+        while( rset.next() )
+        {
-          // flag build failure
+          exist = true;
-          mLogger.fatal( "excludeFromBuild show stopper PK_RMAPI.EXCLUDE_INDIRECT_FROM_BUILD failed, returned " + result );
+          break;
-          throw new Exception("excludeFromBuild show stopper PK_RMAPI.EXCLUDE_INDIRECT_FROM_BUILD failed, returned " + result);
+        }
+        rset.close();
         stmt.close();
+        if ( !exist )
+        {
+          stmt = mConnection.prepareCall( "begin ? := PK_RMAPI.EXCLUDE_INDIRECT_FROM_BUILD(?,?,?,?,?,?,?); end;" );
+          stmt.registerOutParameter( 1, Types.INTEGER);
+          stmt.setString( 2, packageVersionId );
+          stmt.setString( 3, packageVersion );
+          stmt.setString( 4, rtagId );
+          stmt.setString( 5, "buildadm" );
+          stmt.setString( 6, rootPvId);
+          stmt.setString( 7, rootCause);
+          stmt.setString( 8, rootFile);
+          stmt.executeUpdate();
+          int result = stmt.getInt( 1 );
+          if ( result != 0 )
+          {
+            // flag build failure
+            mLogger.fatal( "excludeFromBuild show stopper PK_RMAPI.EXCLUDE_INDIRECT_FROM_BUILD failed, returned " + result );
+            throw new Exception("excludeFromBuild show stopper PK_RMAPI.EXCLUDE_INDIRECT_FROM_BUILD failed, returned " + result);
+          }
+          stmt.close();
-        mConnection.commit();
+          mConnection.commit();
+        }
         disconnect();
+      }
       catch( SQLException e )
+      {
         if ( mConnection == null || ( mConnection != null && !mConnection.isValid(10) ) )
     /**daemon_mode column value
      * @attribute
      */
     private char mDaemon_mode;
-    /**gbebuildfilter column value
-     * @attribute
-     */
-    private String mGbebuildfilter;
     /**constructor
      */
-    ReleaseConfig(int rtag_id, int rcon_id, char daemon_mode,
+    ReleaseConfig(int rtag_id, int rcon_id, char daemon_mode)
-                  String gbebuildfilter)
+    {
-      mLogger.debug("ReleaseConfig rtag_id " + rtag_id + " rcon_id " + rcon_id + " daemon_mode " + daemon_mode + " gbebuildfilter " + gbebuildfilter );
+      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;
-      mGbebuildfilter = gbebuildfilter;
+    }
     /**accessor method
      */
     int get_rtag_id()
+    {
       mLogger.debug("get_daemon_mode");
       mLogger.info("get_daemon_mode returned " + mDaemon_mode);
       return mDaemon_mode;
+    }
-    /**accessor method
-     */
-    String get_gbebuildfilter()
-    {
-      mLogger.debug("get_gbebuildfilter");
-      mLogger.info("get_gbebuildfilter returned " + mGbebuildfilter);
-      return mGbebuildfilter;
-    }
+  }
   /**Representation of a row in the RUN_LEVEL table
    */
   private class RunLevel
   /**returns true if the mReleaseConfigCollection is not empty and returns the rcon_id, rtag_id, daemon_mode and gbebuildfilter of the first element
    */
   public boolean getFirstReleaseConfig(MutableInt rtag_id,
                                        MutableInt rcon_id,
-                                       MutableChar daemon_mode,
+                                       MutableChar daemon_mode)
-                                       MutableString gbebuildfilter)
+  {
     mLogger.debug("getFirstReleaseConfig 2");
     boolean retVal = true;
     try
       mReleaseConfigIndex = 0;
       ReleaseConfig rc = mReleaseConfigCollection.get( mReleaseConfigIndex );
       rtag_id.value = rc.get_rtag_id();
       rcon_id.value = rc.get_rcon_id();
       daemon_mode.value = rc.get_daemon_mode();
-      gbebuildfilter.value = rc.get_gbebuildfilter();
+    }
     catch( ArrayIndexOutOfBoundsException e )
+    {
       retVal = false;
+    }
   /**returns true if the mReleaseConfigCollection contains a next element and returns the rcon_id, rtag_id, daemon_mode and gbebuildfilter of the next element
    */
   public boolean getNextReleaseConfig(MutableInt rtag_id,
                                       MutableInt rcon_id,
-                                      MutableChar daemon_mode,
+                                      MutableChar daemon_mode)
-                                      MutableString gbebuildfilter)
+  {
     mLogger.debug("getNextReleaseConfig 2");
     boolean retVal = true;
     try
       mReleaseConfigIndex++;
       ReleaseConfig rc = mReleaseConfigCollection.get( mReleaseConfigIndex );
       rtag_id.value = rc.get_rtag_id();
       rcon_id.value = rc.get_rcon_id();
       daemon_mode.value = rc.get_daemon_mode();
-      gbebuildfilter.value = rc.get_gbebuildfilter();
+    }
     catch( ArrayIndexOutOfBoundsException e )
+    {
       retVal = false;
+    }
     mLogger.info("queryDirectedRunLevel returning " + retVal);
     return retVal;
+  }
-  /**queries the RELEASE_CONFIG table using the rcon_id primary key, rtag_id, daemon_hostname, daemon_mode, gbebuildfilter
+  /**queries the RELEASE_CONFIG table using the rcon_id primary key, rtag_id, daemon_hostname, daemon_mode
    * return true if the query contains a result set containing one row
-   * (indicating the rcon_id is still configured and its configuration is unchanged)
+   * (indicating the rcon_id is still configured and its configuration is unchanged, aside from the gbe_buildfilter)
+   * the gbe_buildfilter is queried prior to usage
    * refer to sequence diagram allowed to proceed
    */
   public boolean queryReleaseConfig(final int rtag_id, final int rcon_id,
                                     final String daemon_hostname,
-                                    final char daemon_mode,
-                                    final String gbebuildfilter) throws SQLException, Exception
+                                    final char daemon_mode) throws SQLException, Exception
+  {
     mLogger.debug("queryReleaseConfig 1");
     boolean retVal = false;
     if ( !mUseDatabase )
         int rsetSize = 0;
         while( rset.next() )
+        {
           rsetSize++;
-          String gbe_buildfilter = rset.getString("gbe_buildfilter");
-          if ( gbe_buildfilter == null )
-          {
-            mLogger.info("queryReleaseConfig 1 gbe_buildfilter == null");
-            if ( gbebuildfilter.length() == 0 )
-            {
-              retVal = true;
+          retVal = true;
-            }
-          }
-          else
-          {
-            if ( gbebuildfilter.compareTo( gbe_buildfilter ) == 0 )
-            {
-              retVal = true;
-            }
-          }
+        }
         rset.close();
         stmt.close();
     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
+      {
+        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");
+        }
+      }
+    }
+  }
   /**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
     mReleaseConfigCollection.removeAllElements();
     if ( !mUseDatabase )
+    {
       mLogger.info("queryReleaseConfig 2 !mUseDatabase");
-      ReleaseConfig releaseConfig = new ReleaseConfig(1,1,'M',"unittestbuildfilter");
+      ReleaseConfig releaseConfig = new ReleaseConfig(1,1,'M');
       mReleaseConfigCollection.add(releaseConfig);
-      releaseConfig = new ReleaseConfig(1,2,'S',"anotherunittestbuildfilter");
+      releaseConfig = new ReleaseConfig(1,2,'S');
       mReleaseConfigCollection.add(releaseConfig);
+    }
     else
+    {
       try
+      {
         connect();
-        CallableStatement stmt = mConnection.prepareCall("select rcon_id, daemon_mode, gbe_buildfilter from release_manager.release_config where rtag_id=" + rtag_id );
+        CallableStatement stmt = mConnection.prepareCall("select rcon_id, daemon_mode from release_manager.release_config where rtag_id=" + rtag_id );
         ResultSet rset = stmt.executeQuery();
         while( rset.next() )
+        {
           int rcon_id = rset.getInt("rcon_id");
+            {
               dm = 'M';
+            }
+          }
-          String gbe_buildfilter = rset.getString("gbe_buildfilter");
-          if ( gbe_buildfilter == null )
-          {
-            gbe_buildfilter = new String("");
-          }
-          ReleaseConfig releaseConfig = new ReleaseConfig( rtag_id, rcon_id, dm, gbe_buildfilter );
+          ReleaseConfig releaseConfig = new ReleaseConfig( rtag_id, rcon_id, dm );
           mReleaseConfigCollection.add(releaseConfig);
+        }
         rset.close();
     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',"unit test spawn thread");
+      ReleaseConfig releaseConfig = new ReleaseConfig(1,1,'M');
       mReleaseConfigCollection.add(releaseConfig);
-      releaseConfig = new ReleaseConfig(2,2,'S',"unit test spawn thread");
+      releaseConfig = new ReleaseConfig(2,2,'S');
       mReleaseConfigCollection.add(releaseConfig);
+    }
     else
+    {
       try
+      {
         connect();
-        CallableStatement stmt = mConnection.prepareCall("select rc.rtag_id, rc.rcon_id, rc.daemon_mode, rc.gbe_buildfilter from release_manager.release_config rc, release_manager.release_tags rt where rc.daemon_hostname='" + hostname + "' and rt.rtag_id=rc.rtag_id and (rt.official = 'N' or rt.official='R' or rt.official='C')" );
+        CallableStatement stmt = mConnection.prepareCall("select rc.rtag_id, rc.rcon_id, rc.daemon_mode from release_manager.release_config rc, release_manager.release_tags rt where rc.daemon_hostname='" + hostname + "' and rt.rtag_id=rc.rtag_id 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");
+            {
               dm = 'M';
+            }
+          }
-          String gbe_buildfilter = rset.getString("gbe_buildfilter");
-          if ( gbe_buildfilter == null )
-          {
-            gbe_buildfilter = new String("");
-          }
-          ReleaseConfig releaseConfig = new ReleaseConfig( rtag_id, rcon_id, dm, gbe_buildfilter );
+          ReleaseConfig releaseConfig = new ReleaseConfig( rtag_id, rcon_id, dm );
           mReleaseConfigCollection.add(releaseConfig);
+        }
         rset.close();
         stmt.close();
+    }
+  }
   /**queries the RUN_LEVEL table using the rcon_id primary key
    * handles database connection and disconnection
-   * polls indefinitely until CURRENT_BUILD_FILES column is non NULL
    * returns the current_build_files
    * implements the sequence diagram consume build files
    */
   public void queryRunLevel(int rcon_id, MutableString currentBuildFiles) throws SQLException, Exception
+  {
+      }
+    }
+  }
   /**queries the RUN_LEVEL_SCHEDULE table
+   * when recover is true, checks for archive existence and runs resume when both archives exist
+   * this should delete rows with a non NULL indefinite pause
    * returns false if a row in the query result set indicates build service downtime is scheduled
    * returns false if a row in the query result set has a non NULL indefinite_pause
    * refer to the sequence diagram allowed to proceed
    */
-  public boolean queryRunLevelSchedule(Date resumeTime) throws SQLException, Exception
+  public boolean queryRunLevelSchedule(Date resumeTime, boolean recover) throws SQLException, Exception
+  {
     mLogger.debug("queryRunLevelSchedule");
     boolean retVal = true;
     if ( !mUseDatabase )
+    }
     else
+    {
       try
+      {
+        if ( recover )
+        {
+          if ( Package.recover() )
+          {
+            // dpkg and deploy archives exist
+            // clear the indefinite pause condition
+            resume();
+          }
+        }
         CallableStatement stmt = mConnection.prepareCall("select scheduled_pause, scheduled_resume, repeat, indefinite_pause from release_manager.run_level_schedule");
         ResultSet rset = stmt.executeQuery();
         Date now = new Date();
           //
           //  Look for indefinite_pause style of entry
           //  Note: due to an implemenation error there may be many
           //        rows that match. We only need one. The scan will
-          //        be termineted if we find any
+          //        be terminated if we find any
           //
           //
           String ip = rset.getString("indefinite_pause");
           if ( ip != null )
+          {

Subversion Repositories DevTools

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