Add Concurrent.cpu_requests that is cgroups aware.

Author: heka1024

lib/concurrent-ruby/concurrent/utility/processor_counter.rb

@@ -12,6 +12,7 @@ def initialize
         @processor_count          = Delay.new { compute_processor_count }
         @physical_processor_count = Delay.new { compute_physical_processor_count }
         @cpu_quota                = Delay.new { compute_cpu_quota }
+        @cpu_requests             = Delay.new { compute_cpu_requests }
       end
 
       def processor_count
@@ -41,6 +42,10 @@ def cpu_quota
         @cpu_quota.value
       end
 
+      def cpu_requests
+        @cpu_requests.value / 1024
+      end
+
       private
 
       def compute_processor_count
@@ -98,13 +103,13 @@ def run(command)
 
       def compute_cpu_quota
         if RbConfig::CONFIG["target_os"].include?("linux")
-          if File.exist?("/sys/fs/cgroup/cpu.max")
+          if cgroups_v2?
             # cgroups v2: https://docs.kernel.org/admin-guide/cgroup-v2.html#cpu-interface-files
             cpu_max = File.read("/sys/fs/cgroup/cpu.max")
             return nil if cpu_max.start_with?("max ") # no limit
             max, period = cpu_max.split.map(&:to_f)
             max / period
-          elsif File.exist?("/sys/fs/cgroup/cpu,cpuacct/cpu.cfs_quota_us")
+          elsif cgroups_v1?
             # cgroups v1: https://kernel.googlesource.com/pub/scm/linux/kernel/git/glommer/memcg/+/cpu_stat/Documentation/cgroups/cpu.txt
             max = File.read("/sys/fs/cgroup/cpu,cpuacct/cpu.cfs_quota_us").to_i
             return nil if max == 0
@@ -113,6 +118,26 @@ def compute_cpu_quota
           end
         end
       end
+
+      def compute_cpu_requests
+        if RbConfig::CONFIG["target_os"].include?("linux")
+          if cgroups_v2?
+            # Ref: https://github.com/kubernetes/enhancements/tree/master/keps/sig-node/2254-cgroup-v2#phase-1-convert-from-cgroups-v1-settings-to-v2
+            weight = File.read('/sys/fs/cgroup/cpu.weight').to_f
+            (((weight - 1) * 262142) / 9999) + 2
+          elsif cgroups_v1?
+            File.read('/sys/fs/cgroup/cpu/cpu.shares').to_f
+          end
+        end
+      end
+
+      def cgroups_v1?
+        File.exist?("/sys/fs/cgroup/cpu,cpuacct/cpu.cfs_quota_us")
+      end
+
+      def cgroups_v2?
+        File.exist?("/sys/fs/cgroup/cpu.max")
+      end
     end
   end
 
@@ -187,4 +212,12 @@ def self.available_processor_count
   def self.cpu_quota
     processor_counter.cpu_quota
   end
+
+  # The CPU shares requested by the process. For performance reasons the calculated
+  # value will be memoized on the first call.
+  #
+  # @return [Float, nil] CPU shares requested by the process, or nil if not set
+  def self.cpu_requests
+    processor_counter.cpu_requests
+  end
 end

spec/concurrent/utility/processor_count_spec.rb

@@ -92,4 +92,25 @@ module Concurrent
     end
 
   end
+
+  RSpec.describe '#cpu_requests' do
+
+    it 'returns a float when cgroups v2 sets a cpu.weight' do
+      expect(RbConfig::CONFIG).to receive(:[]).with("target_os").and_return("linux")
+      expect(File).to receive(:exist?).with("/sys/fs/cgroup/cpu.max").and_return(true)
+
+      expect(File).to receive(:read).with("/sys/fs/cgroup/cpu.weight").and_return("10000\n")
+      expect(Concurrent.cpu_requests).to be == 256.0
+    end
+
+    it 'returns a float if cgroups v1 sets a cpu.shares' do
+      expect(RbConfig::CONFIG).to receive(:[]).with("target_os").and_return("linux")
+      expect(File).to receive(:exist?).with("/sys/fs/cgroup/cpu.max").and_return(false)
+      expect(File).to receive(:exist?).with("/sys/fs/cgroup/cpu,cpuacct/cpu.cfs_quota_us").and_return(true)
+
+      expect(File).to receive(:read).with("/sys/fs/cgroup/cpu/cpu.shares").and_return("512\n")
+      expect(Concurrent.cpu_requests).to be == 0.5
+    end
+
+  end
 end