Changeset 9365 for branches/OaaS/HeuristicLab.Clients.Hive.Slave.AzureClient

Timestamp:

04/17/13 10:49:49 (12 years ago)

Author:

fschoepp

Message:

#1888:

• WorkerRole of Slave now logs all exceptions during startup to the blobstore (slavelog).
• The PluginManager throws an exception during CheckWorkingDirectories() (Save method) which will be caught now, preventing crashes in Windows Azure.
• "db.DeferredLocal = false" has been removed to prevent loading bugs.
• HiveScenarioManager doesn't crash anymore, if he can't find an algorithm within a job during retrieval of the run results.

File:

• branches/OaaS/HeuristicLab.Clients.Hive.Slave.AzureClient/3.3/WorkerRole.cs (modified) (2 diffs)

branches/OaaS/HeuristicLab.Clients.Hive.Slave.AzureClient/3.3/WorkerRole.cs

@@ -26 +26 @@
 using Microsoft.WindowsAzure.Diagnostics;
 using Microsoft.WindowsAzure.ServiceRuntime;
+using Microsoft.WindowsAzure;
+using Microsoft.WindowsAzure.StorageClient;
+using System.Text;
 
 namespace HeuristicLab.Clients.Hive.Slave.AzureClient {
+
+
   public class WorkerRole : RoleEntryPoint {
     private Core core;
@@ -36 +41 @@
 
     public override void Run() {
-      core = new Core(false);
+      try {
+        LogError(new Exception("Starting Run()..."));
+        core = new Core(false);
 
-      string hiveServerAddress = RoleEnvironment.GetConfigurationSettingValue(HiveServerAddressSetting);
-      string hiveServerCertificate = RoleEnvironment.GetConfigurationSettingValue(HiveServerCertificateSetting);
+        string hiveServerAddress = RoleEnvironment.GetConfigurationSettingValue(HiveServerAddressSetting);
+        string hiveServerCertificate = RoleEnvironment.GetConfigurationSettingValue(HiveServerCertificateSetting);
 
-      // values are empty, settings from app.config are used
-      if (!string.IsNullOrEmpty(hiveServerAddress) && !string.IsNullOrEmpty(hiveServerCertificate)) {
-        core.SetNewHiveServer(hiveServerAddress, hiveServerCertificate);
+        // values are empty, settings from app.config are used
+        if (!string.IsNullOrEmpty(hiveServerAddress) && !string.IsNullOrEmpty(hiveServerCertificate)) {
+          core.SetNewHiveServer(hiveServerAddress, hiveServerCertificate);
+        }
+
+        coreThread = new Thread(core.Start);
+        coreThread.Start();
+
+        LogError(new Exception("Run(): Core started successfullly"));
+        while (true) {
+          Thread.Sleep(10000);
+        }
       }
-
-      coreThread = new Thread(core.Start);
-      coreThread.Start();
-
-      while (true) {
-        Thread.Sleep(10000);
+      catch (Exception e) {
+        LogError(e);
+    throw e;
       }
     }
 
     public override bool OnStart() {
-      ServicePointManager.DefaultConnectionLimit = 12;
-      //core = new Core();
       try {
-        if (!String.IsNullOrEmpty(RoleEnvironment.GetConfigurationSettingValue(Constants.DiagnosticsConnectionString))) {
-          DiagnosticMonitorConfiguration dmc = DiagnosticMonitor.GetDefaultInitialConfiguration();
-          dmc.Logs.ScheduledTransferPeriod = TimeSpan.FromMinutes(1);
-          dmc.Logs.ScheduledTransferLogLevelFilter = LogLevel.Verbose;
-          DiagnosticMonitor.Start(Constants.DiagnosticsConnectionString, dmc);
+        ServicePointManager.DefaultConnectionLimit = 12;
+        //core = new Core();
+        LogError(new Exception("Running OnStart()"));
+        try {
+          if (!String.IsNullOrEmpty(RoleEnvironment.GetConfigurationSettingValue(Constants.DiagnosticsConnectionString))) {
+            DiagnosticMonitorConfiguration dmc = DiagnosticMonitor.GetDefaultInitialConfiguration();
+            dmc.Logs.ScheduledTransferPeriod = TimeSpan.FromSeconds(5);
+            dmc.Logs.ScheduledTransferLogLevelFilter = LogLevel.Verbose;
+            DiagnosticMonitor.Start(Constants.DiagnosticsConnectionString, dmc);
+          }
         }
+        catch (RoleEnvironmentException ex) {
+          // diagnostics connection string not in configuration
+          // -> diagnostics disabled
+          // nothing more to do
+          LogError(ex);
+        }
+
+        RoleEnvironment.Changed += RoleEnvironmentChanged;
+        LogError(new Exception("Finished OnStart() successfullly"));
       }
-      catch (RoleEnvironmentException ex) {
-        // diagnostics connection string not in configuration
-        // -> diagnostics disabled
-        // nothing more to do
+      catch (Exception ex) {
+        LogError(ex);
+    throw ex;
       }
+      return base.OnStart();
+    }
 
-      RoleEnvironment.Changed += RoleEnvironmentChanged;
-
-      return base.OnStart();
+    private void LogError(Exception e) {
+      var storageAccount = CloudStorageAccount.Parse("DefaultEndpointsProtocol=https;AccountName=optimizationstorage1;AccountKey=n7Leom8ZFWkof/VQ2a4aRSvwOlX+Gwr3uojQF9CFJw1osmGCV0WwaNC8s7nkZ+qteLduAgW2l75WFpbXrkvG4Q==");
+      var blobClient = storageAccount.CreateCloudBlobClient();
+      var container = blobClient.GetContainerReference("slavelog");
+      container.CreateIfNotExist();
+      var guid = Guid.NewGuid();
+      var blob = container.GetBlobReference(guid.ToString());
+      var builder = new StringBuilder();
+      builder.Append("ToString: ").Append(e.ToString()).Append("\n");
+      builder.Append("Message: ").Append(e.Message).Append("\n");
+      blob.UploadText(builder.ToString());
     }