Free cookie consent management tool by TermsFeed Policy Generator

Ignore:
Timestamp:
02/01/11 18:12:46 (14 years ago)
Author:
cneumuel
Message:

#1233

  • moved heartbeat timestamps of slaves and jobs into database to make server stateless
  • made slave use the right authentication ("hiveslave" instead of HL username/password)
  • moved heartbeat related methods into HeartbeatManager
  • changed signature of Service.Hello method, so all hardware related information is transferred in that method withing the Slave-object
File:
1 edited

Legend:

Unmodified
Added
Removed
  • branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Services.Hive/3.4/HiveService.cs

    r5404 r5405  
    2525    private ILifecycleManager lifecycleManager {
    2626      get { return ServiceLocator.Instance.LifecycleManager; }
     27    }
     28    private HeartbeatManager heartbeatManager {
     29      get { return ServiceLocator.Instance.HeartbeatManager; }
    2730    }
    2831
     
    162165
    163166    #region Login Methods
    164     public void Hello(Guid slaveId, string name, int cores, int memory) {
    165       using (trans.OpenTransaction()) {
    166         var slave = dao.GetSlave(slaveId);
     167    public void Hello(Slave slaveInfo) {
     168      using (trans.OpenTransaction()) {
     169        var slave = dao.GetSlave(slaveInfo.Id);
    167170
    168171        if (slave == null) {
    169           slave = new Slave { Id = slaveId, Name = name, Cores = cores, Memory = memory };
    170           slave.IsAllowedToCalculate = true; //a little bit to optimistic?
    171           slave.SlaveState = SlaveState.Idle;
    172           dao.AddSlave(slave);
     172          dao.AddSlave(slaveInfo);
    173173        } else {
    174           //TODO: error handling?
     174          dao.UpdateSlave(slaveInfo);
    175175        }
    176176      }
     
    191191    public List<MessageContainer> Heartbeat(Heartbeat heartbeat) {
    192192      using (trans.OpenTransaction()) {
    193         return lifecycleManager.ProcessHeartbeat(heartbeat);
     193        return heartbeatManager.ProcessHeartbeat(heartbeat);
    194194      }
    195195    }
Note: See TracChangeset for help on using the changeset viewer.