Changeset 4116 for branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/ClientCommunicator.cs

Timestamp:

07/27/10 18:36:36 (14 years ago)

Author:

cneumuel

Message:

worked on HiveExperiment (#1115)

File:

• branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/ClientCommunicator.cs (modified) (17 diffs)

branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/ClientCommunicator.cs

@@ -82 +82 @@
 
         foreach (ClientDto client in allClients) {
-          if (client.State != State.offline && client.State != State.nullState) {
+          if (client.State != State.Offline && client.State != State.NullState) {
             heartbeatLock.EnterUpgradeableReadLock();
 
@@ -88 +88 @@
               Logger.Info("Client " + client.Id +
                               " wasn't offline but hasn't sent heartbeats - setting offline");
-              client.State = State.offline;
+              client.State = State.Offline;
               DaoLocator.ClientDao.Update(client);
               Logger.Info("Client " + client.Id +
@@ -113 +113 @@
                 Logger.Debug("setting client offline");
                 // client must be set offline
-                client.State = State.offline;
+                client.State = State.Offline;
 
                 //clientAdapter.Update(client);
@@ -146 +146 @@
 
     private void CheckForPendingJobs() {
-      IList<JobDto> pendingJobsInDB = new List<JobDto>(DaoLocator.JobDao.GetJobsByState(State.pending));
+      IList<JobDto> pendingJobsInDB = new List<JobDto>(DaoLocator.JobDao.GetJobsByState(State.Pending));
 
       foreach (JobDto currJob in pendingJobsInDB) {
@@ -152 +152 @@
           if (pendingJobs.ContainsKey(currJob.Id)) {
             if (pendingJobs[currJob.Id] <= 0) {
-              currJob.State = State.offline;
+              currJob.State = State.Offline;
               DaoLocator.JobDao.Update(currJob);
             } else {
@@ -185 +185 @@
       //Really set offline? 
       //Reconnect issues with the currently calculating jobs
-      clientInfo.State = State.idle;
+      clientInfo.State = State.Idle;
       clientInfo.CalendarSyncStatus = dbClient != null ? dbClient.CalendarSyncStatus : CalendarState.NotAllowedToFetch;
 
@@ -258 +258 @@
       Logger.Debug("END Finished Client Fetching");
       // check if the client is logged in
-      if (client.State == State.offline || client.State == State.nullState) {
+      if (client.State == State.Offline || client.State == State.NullState) {
         response.Success = false;
         response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_USER_NOT_LOGGED_IN;
@@ -341 +341 @@
             response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_JOB_IS_NOT_BEEING_CALCULATED;
             Logger.Error("There is no job calculated by this user " + hbData.ClientId + " Job: " + curJob);
-          } else if (curJob.State == State.abort) {
+          } else if (curJob.State == State.Abort) {
             // a request to abort the job has been set
             response.ActionRequest.Add(new MessageContainer(MessageContainer.MessageType.AbortJob, curJob.Id));
-            curJob.State = State.finished;
+            curJob.State = State.Finished;
           } else {
             // save job progress
             curJob.Percentage = jobProgress.Value;
 
-            if (curJob.State == State.requestSnapshot) {
+            if (curJob.State == State.RequestSnapshot) {
               // a request for a snapshot has been set
               response.ActionRequest.Add(new MessageContainer(MessageContainer.MessageType.RequestSnapshot, curJob.Id));
-              curJob.State = State.requestSnapshotSent;
+              curJob.State = State.RequestSnapshotSent;
             }
           }
@@ -376 +376 @@
                 Logger.Error("Job TTL reached Zero, Job gets removed: " + currJob + " and set back to offline. User that sucks: " + currJob.Client);
 
-                currJob.State = State.offline;
+                currJob.State = State.Offline;
                 DaoLocator.JobDao.Update(currJob);
 
@@ -385 +385 @@
             } else {
               Logger.Error("Job ID wasn't with the heartbeats:  " + currJob);
-              currJob.State = State.offline;
+              currJob.State = State.Offline;
               DaoLocator.JobDao.Update(currJob);
             }
@@ -516 +516 @@
         return response;
       }
-      if (job.JobInfo.State == State.abort) {
+      if (job.JobInfo.State == State.Abort) {
         response.Success = false;
         response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_JOB_WAS_ABORTED;
@@ -545 +545 @@
         return response;
       }
-      if (job.JobInfo.State == State.finished) {
+      if (job.JobInfo.State == State.Finished) {
         response.Success = true;
         response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_JOBRESULT_RECEIVED;
@@ -556 +556 @@
       }
       //Todo: RequestsnapshotSent => calculating?
-      if (job.JobInfo.State == State.requestSnapshotSent) {
-        job.JobInfo.State = State.calculating;
-      }
-      if (job.JobInfo.State != State.calculating &&
-        job.JobInfo.State != State.pending) {
+      if (job.JobInfo.State == State.RequestSnapshotSent) {
+        job.JobInfo.State = State.Calculating;
+      }
+      if (job.JobInfo.State != State.Calculating &&
+        job.JobInfo.State != State.Pending) {
         response.Success = false;
         response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_WRONG_JOB_STATE;
@@ -573 +573 @@
 
       if (finished) {
-        job.JobInfo.State = State.finished;
+        job.JobInfo.State = State.Finished;
         job.JobInfo.DateFinished = DateTime.Now;
       }
@@ -637 +637 @@
         return response;
       }
-      if (client.State == State.calculating) {
+      if (client.State == State.Calculating) {
         // check wich job the client was calculating and reset it
         IEnumerable<JobDto> jobsOfClient = DaoLocator.JobDao.FindActiveJobsOfClient(client);
         foreach (JobDto job in jobsOfClient) {
-          if (job.State != State.finished)
+          if (job.State != State.Finished)
             DaoLocator.JobDao.SetJobOffline(job);
         }
       }
 
-      client.State = State.offline;
+      client.State = State.Offline;
       DaoLocator.ClientDao.Update(client);
 
@@ -670 +670 @@
         return response;
       }
-      if (job.State == State.finished) {
+      if (job.State == State.Finished) {
         response.Success = true;
         response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_JOB_ALLREADY_FINISHED;
@@ -676 +676 @@
         return response;
       }
-      job.State = State.pending;
+      job.State = State.Pending;
       lock (pendingJobs) {
         pendingJobs.Add(job.Id, PENDING_TIMEOUT);