extend_linux/dotnet/cpu_utilization · 322d9db5e1cc700d36dd26c2191e831381539131 · Bergen.It / ems-sdk · Mos.Hub

 private static readonly string[] _commands = { "top -b -n1 -1 -p0 -w 400", "top -b -n1 -w 400" };
 private static string TopCpuPrefix = "%cpu";
  public record HandleResult(int Success, string Stdout, string Stderr);
 public static HandleResult CallSsh(CollectLinuxCpuUtilisationRequest request, string command)
 {
  DeviceConnector connection = request.Device.Connectors.First();
  Credential creds=connection.Credentials.First();

  using (SshClient client = new SshClient(connection.Address, creds.Port, creds.Login, creds.Password))
  {
   client.Connect();
   SshCommand cmdRes = client.RunCommand(command);
   if (cmdRes.ExitStatus == 0)
   {
    client.Disconnect();
    return new HandleResult(cmdRes.ExitStatus,
    cmdRes.Result, cmdRes.Error);
   }
   client.Disconnect();
   return new HandleResult(cmdRes.ExitStatus,
    cmdRes.Result, cmdRes.Error);
  }
 }
 top - 17:55:32 up 1 min,  1 user,  load average: 0.01, 0.01, 0.00
 Tasks:   1 total,   1 running,   0 sleeping,   0 stopped,   0 zombie
 %Cpu0  :  0.0 us,  0.0 sy,  0.0 ni,100.0 id,  0.0 wa,  0.0 hi,  0.0 si,  0.0 st
 %Cpu1  :  0.0 us,  0.0 sy,  0.0 ni,100.0 id,  0.0 wa,  0.0 hi,  0.0 si,  0.0 st

 ...

 %Cpu19 :  0.0 us,  0.0 sy,  0.0 ni,100.0 id,  0.0 wa,  0.0 hi,  0.0 si,  0.0 st
 MiB Mem :   7806.4 total,   6860.3 free,    509.2 used,    436.8 buff/cache
 MiB Swap:   2048.0 total,   2048.0 free,      0.0 used.   7067.7 avail Mem

  PID USER      PR  NI    VIRT    RES    SHR S  %CPU  %MEM     TIME+ COMMAND
  697 vvsurje+  20   0    7656   3236   2872 R   0.0   0.0   0:00.00 top

 top - 17:55:52 up 2 min,  1 user,  load average: 0.01, 0.00, 0.00
 Tasks:  35 total,   1 running,  34 sleeping,   0 stopped,   0 zombie
 %Cpu(s):  0.0 us,  0.0 sy,  0.0 ni,100.0 id,  0.0 wa,  0.0 hi,  0.0 si,  0.0 st
 MiB Mem :   7806.4 total,   6858.4 free,    511.2 used,    436.9 buff/cache
 MiB Swap:   2048.0 total,   2048.0 free,      0.0 used.   7065.8 avail Mem

  PID USER      PR  NI    VIRT    RES    SHR S  %CPU  %MEM     TIME+ COMMAND
  690 root      20   0   43696  37724   9956 S  13.3   0.5   0:00.75 python3
    1 root      20   0  166004  11392   8352 S   0.0   0.1   0:00.21 systemd
    ...
  public static CollectLinuxCpuUtilizationResponse ProcessResponse(HandleResult[] results, CollectLinuxCpuUtilizationRequest request)
  {
   string response = "";
   foreach (HandleResult res in results)
   {
    if (res.Success == 0)
    {
     response += res.Stdout;
    }
   }

   CollectLinuxCpuUtilizationResponse statDeviceCpu = new()
   {
    CpuUtilization = new()
    {
     DeviceIdentity = new DeviceDataIdentity()
     {
      DeviceId = request.Device.DeviceId,
      Source = ServiceSource.LinuxManager
     },
     SummaryUtilization = new()
    }
   };

   IEnumerable<string> rows = response.ToLowerInvariant()
    .Split('\n', StringSplitOptions.TrimEntries)
    .Where(s => s.StartsWith(TopCpuPrefix))
    .SelectMany(c => c
     .Split(TopCpuPrefix, StringSplitOptions.TrimEntries)
     .Where(d => !string.IsNullOrWhiteSpace(d))
     .Select(s => TopCpuPrefix + s));

   foreach (string item in rows)
   {
    int processorIdEnd = item.IndexOf(' ', TopCpuPrefix.Length);

    if (processorIdEnd == -1)
    {
     continue;
    }

    string? strProcessorId = item[TopCpuPrefix.Length..processorIdEnd];

    int processorId;

    if (strProcessorId == "(s):")
    {
     processorId = -1;
    }
    else if (!int.TryParse(strProcessorId, out processorId))
    {
     continue;
    }
    CpuUnitUtilization cpu = new();

    foreach (string entiry in item[(processorIdEnd + 3)..].Split(',', StringSplitOptions.TrimEntries))
    {
     string[] parts = entiry.Split(' ', 2, StringSplitOptions.TrimEntries);

     if (parts.Length != 2)
     {
      continue;
     }

     string key = parts[1];
     string strValue = parts[0];

     if (float.TryParse(strValue, out float intValue))
     {
      switch (key)
      {
       case "us": cpu.UserUsing = (int)Math.Ceiling(intValue); break;
       case "sy": cpu.SystemUsing = (int)Math.Ceiling(intValue); break;
       case "ni": cpu.NiceValueUsing = (int)Math.Ceiling(intValue); break;
       case "id": cpu.IdleTime = (int)Math.Ceiling(intValue); break;
       case "wa": cpu.IoWaiting = (int)Math.Ceiling(intValue); break;
       case "hi": cpu.HwServiceInterrupts = (int)Math.Ceiling(intValue); break;
       case "si": cpu.SoftServiceInterrupts = (int)Math.Ceiling(intValue); break;
       case "st": cpu.StealTime = (int)Math.Ceiling(intValue); break;
       default: break;
      }
     }

    }
    if (processorId == -1)
    {
     statDeviceCpu.CpuUtilization.SummaryUtilization = cpu;
    }
    else
    {
     statDeviceCpu.CpuUtilization.UnitUtilistaions.Add(processorId, cpu);
    }
   }
   return statDeviceCpu;
  }
  public static CollectLinuxCpuUtilisationResponse GetCpuUtilisation(CollectLinuxCpuUtilisationRequest request)
  {
   HandleResult[] responses= _commands.Select(cmd=> CallSsh(request,cmd)).ToArray();
   return ProcessResponse(responses, request);
  }
 namespace SshExample.Services;

 public class LinuxManagerService : LinuxManager.LinuxManagerBase
 {
  public override Task<CollectLinuxCpuUtilisationResponse> CollectCpuUtilisation(CollectLinuxCpuUtilisationRequest request, ServerCallContext context)
  {
   return Task.FromResult(SshCommandCaller.GetCpuUtilisation(request));
  }
 }