Changeset 783 for trunk/sources/HeuristicLab.Hive.Server.Core

Timestamp:

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

Author:

msteinbi

Message:

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

File:

• trunk/sources/HeuristicLab.Hive.Server.Core/ClientCommunicator.cs (modified) (2 diffs)

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;
     }