Subversion Repositories DevTools

Rev

Rev 908 | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 908 Rev 916
Line 238... Line 238...
238
    
238
    
239
    try
239
    try
240
    {
240
    {
241
      mRunLevel = RunLevel.IDLE;
241
      mRunLevel = RunLevel.IDLE;
242
      mLogger.warn("allowedToProceed changing run level to IDLE for rcon_id " + mRconId);
242
      mLogger.warn("allowedToProceed changing run level to IDLE for rcon_id " + mRconId);
-
 
243
      mLogger.fatal("allowedToProceed calling mRunLevel.persist on IDLE");                      
243
      mRunLevel.persist(mReleaseManager, mRconId);
244
      mRunLevel.persist(mReleaseManager, mRconId);
244
      if ( master )
245
      if ( master )
245
      {
246
      {
-
 
247
        mLogger.fatal("allowedToProceed calling mReleaseManager.discardVersion");                      
246
        mReleaseManager.discardVersion();
248
        mReleaseManager.discardVersion();
247
      }
249
      }
-
 
250
      mLogger.fatal("allowedToProceed calling mReleaseManager.clearCurrentPackageBeingBuilt");                      
248
      mReleaseManager.clearCurrentPackageBeingBuilt(mRconId);      
251
      mReleaseManager.clearCurrentPackageBeingBuilt(mRconId);      
249
    }
252
    }
250
    catch(SQLException e)
253
    catch(SQLException e)
251
    {
254
    {
252
      mLogger.warn("allowedToProceed caught SQLException");
255
      mLogger.warn("allowedToProceed caught SQLException");
Line 262... Line 265...
262
        {
265
        {
263
          // sleep only 3 secs on slave
266
          // sleep only 3 secs on slave
264
          sleepTime = 3000;
267
          sleepTime = 3000;
265
        }
268
        }
266
        mLogger.warn("allowedToProceed sleep " + sleepTime.toString() + " secs no build requirement");
269
        mLogger.warn("allowedToProceed sleep " + sleepTime.toString() + " secs no build requirement");
-
 
270
        mLogger.fatal("allowedToProceed calling Thread.sleep for 3 secs");                      
267
        Thread.sleep(sleepTime);
271
        Thread.sleep(sleepTime);
268
        mLogger.info("allowedToProceed sleep returned");
272
        mLogger.info("allowedToProceed sleep returned");
269
      }
273
      }
270
      catch(InterruptedException e)
274
      catch(InterruptedException e)
271
      {
275
      {
Line 277... Line 281...
277
    
281
    
278
    try
282
    try
279
    {
283
    {
280
      while ( !proceed )
284
      while ( !proceed )
281
      {
285
      {
-
 
286
        mLogger.fatal("allowedToProceed calling mReleaseManager.connect");                      
282
        mReleaseManager.connect();
287
        mReleaseManager.connect();
-
 
288
        mLogger.fatal("allowedToProceed calling mReleaseManager.queryReleaseConfig");                      
283
        if ( !mReleaseManager.queryReleaseConfig(mRtagId, mRconId, BuildDaemon.mHostname, getMode()) )
289
        if ( !mReleaseManager.queryReleaseConfig(mRtagId, mRconId, BuildDaemon.mHostname, getMode()) )
284
        {
290
        {
285
          mReleaseManager.disconnect();
291
          mReleaseManager.disconnect();
286
          mLogger.warn("allowedToProceed queryReleaseConfig failed");
292
          mLogger.warn("allowedToProceed queryReleaseConfig failed");
287
          throw new ExitException();
293
          throw new ExitException();
288
        }
294
        }
289
        
295
        
290
        Date resumeTime = new Date( 0 );
296
        Date resumeTime = new Date( 0 );
-
 
297
        mLogger.fatal("allowedToProceed calling mReleaseManager.queryRunLevelSchedule");                      
291
        if ( !mReleaseManager.queryRunLevelSchedule(resumeTime, mRecoverable) )
298
        if ( !mReleaseManager.queryRunLevelSchedule(resumeTime, mRecoverable) )
292
        {
299
        {
293
          mLogger.info("allowedToProceed scheduled downtime");
300
          mLogger.info("allowedToProceed scheduled downtime");
294
          mReleaseManager.disconnect();
301
          mReleaseManager.disconnect();
295
          mRunLevel = RunLevel.PAUSED;
302
          mRunLevel = RunLevel.PAUSED;
Line 336... Line 343...
336
          }
343
          }
337
          
344
          
338
        }
345
        }
339
        else
346
        else
340
        {
347
        {
-
 
348
          mLogger.fatal("allowedToProceed calling mReleaseManager.queryDirectedRunLevel");                      
341
          if ( !mReleaseManager.queryDirectedRunLevel(mRconId) )
349
          if ( !mReleaseManager.queryDirectedRunLevel(mRconId) )
342
          {
350
          {
343
            mLogger.info("allowedToProceed downtime");
351
            mLogger.info("allowedToProceed downtime");
344
            mReleaseManager.disconnect();
352
            mReleaseManager.disconnect();
345
            mRunLevel = RunLevel.PAUSED;
353
            mRunLevel = RunLevel.PAUSED;
Line 368... Line 376...
368
    finally
376
    finally
369
    {
377
    {
370
      // this block is executed regardless of what happens in the try block
378
      // this block is executed regardless of what happens in the try block
371
      // even if an exception is thrown
379
      // even if an exception is thrown
372
      // ensure disconnect
380
      // ensure disconnect
-
 
381
      mLogger.fatal("allowedToProceed calling mReleaseManager.disconnect");                      
373
      mReleaseManager.disconnect();
382
      mReleaseManager.disconnect();
374
    }
383
    }
375
    
384
    
376
    mRecoverable = false;
385
    mRecoverable = false;
377
  }
386
  }