Changeset 783

Timestamp:

11/19/08 17:03:25 (15 years ago)

Author:

msteinbi

Message:

First version of a dummy implementation of the ClientCommunicator (#371)

Location:

trunk/sources

Files:

• HeuristicLab.Hive.Contracts/MessageContainer.cs (added)
• HeuristicLab.Hive.Contracts/ResponseHB.cs (modified) (2 diffs)
• HeuristicLab.Hive.Contracts/ResponseJob.cs (modified) (1 diff)
• HeuristicLab.Hive.Server.Core/ClientCommunicator.cs (modified) (2 diffs)

trunk/sources/HeuristicLab.Hive.Contracts/ResponseHB.cs

@@ -7 +7 @@
 namespace HeuristicLab.Hive.Contracts {
 
-  /// <summary>
-  /// If a client sends a heartbeat the server can request sereral actions
-  /// actions:
-  ///  - jobReady: an new Job is ready to be calculated
-  ///  - jobSnapshot: send a snapshot of the current status of the calculated job
-  ///  - abortJobwithReturn: abort the job and return all existing results
-  ///  - abortJobwithoutReturn: abort the job and don't send back anything
-  ///  - nothingToDo: there is nothing to do at the moment
-  /// </summary>
-  public enum Action { jobReady, jobSnapshot, abortJobwithReturn, abortJobwithoutReturn, nothingToDo }
 
   /// <summary>
@@ -24 +14 @@
   [DataContract]
   public class ResponseHB : Response {
-    /// <summary>
-    /// The server can send more than one actionRequest to the client
-    /// So they are stored in one Map
-    /// key [long]: JobId
-    /// value [Action]: action
-    /// </summary>
     [DataMember]
-    public Dictionary<long, Action> ActionRequest { get; set; }
+    public List<MessageContainer> ActionRequest { get; set; }
   }
 }

trunk/sources/HeuristicLab.Hive.Contracts/ResponseJob.cs

@@ -15 +15 @@
   public class ResponseJob : Response {
     [DataMember]
-    public Job Job { get; set; }
+    public long JobId { get; set; }
   }
 }

trunk/sources/HeuristicLab.Hive.Server.Core/ClientCommunicator.cs

@@ -12 +12 @@
   /// </summary>
   public class ClientCommunicator: IClientCommunicator {
+    List<Client> clients;
+    List<long> jobs;
+    int nrOfJobs = 10;
+
+    public ClientCommunicator() {
+      jobs = new List<long>();
+      for (int i = 1; i < nrOfJobs; i++) {
+        jobs.Add(i);
+      }
+    }
+
     #region IClientCommunicator Members
 
     public Response Login(Client clientInfo) {
+      if (clients == null)
+        clients = new List<Client>();
+
+      clients.Add(clientInfo);
+
       Response response = new Response();
       response.Success = true;
-      response.StatusMessage = "Logged in...";
+      response.StatusMessage = "Client with GUID " + clientInfo.ClientId + " successuflly logged in";
 
       return response;
@@ -23 +39 @@
 
     public ResponseHB SendHeartBeat(HeartBeatData hbData) {
-      throw new NotImplementedException();
+      ResponseHB response = new ResponseHB();
+
+      response.Success = true;
+      response.StatusMessage = "HeartBeat received";
+      if (jobs.Count > 0) 
+        response.ActionRequest.Add(new MessageContainer(MessageContainer.MessageType.FetchJob));
+      else
+        response.ActionRequest.Add(new MessageContainer(MessageContainer.MessageType.NoMessage));
+
+      return response;
     }
 
     public ResponseJob PullJob(Guid clientId) {
-      throw new NotImplementedException();
+      ResponseJob response = new ResponseJob();
+
+      response.JobId = jobs.ElementAt(jobs.Count);
+      response.Success = true;
+      response.StatusMessage = "Job with id " + jobs.Count + " sent";
+      jobs.Remove(jobs.Count);
+
+      return response;
     }
 
     public Response SendJobResult(JobResult Result, bool finished) {
-      throw new NotImplementedException();
+      Response response = new Response();
+      response.Success = true;
+      response.StatusMessage = "Thanks for calculating";
+
+      return response;
     }
 
     public Response Logout(Guid clientId) {
-      throw new NotImplementedException();
+      bool clientRemoved = false;
+      foreach (Client client in clients) {
+        if (client.ClientId.Equals(clientId)) {
+          clients.Remove(client);
+          clientRemoved = true;
+        }
+      }
+      Response response = new Response()
+      
+      if (clientRemoved) {
+        response.Success = true;
+        response.StatusMessage = "Successfully logged out. Good bye";
+      } else {
+        response.Success = false;
+        response.StatusMessage = "Sorry, but you weren't logged in";
+      }
+      return response;
     }