Contents

# frozen_string_literal: true

module Pitchfork
  module SharedMemory
    extend self

    CURRENT_GENERATION_OFFSET = 0
    SHUTDOWN_OFFSET = 1
    MOLD_TICK_OFFSET = 2
    MOLD_PROMOTION_TICK_OFFSET = 3
    SERVICE_TICK_OFFSET = 4
    WORKER_TICK_OFFSET = 5

    PAGES = [MemoryPage.new(MemoryPage::SLOTS)]

    def current_generation
      PAGES[0][CURRENT_GENERATION_OFFSET]
    end

    def current_generation=(value)
      PAGES[0][CURRENT_GENERATION_OFFSET] = value
    end

    def shutting_down!
      PAGES[0][SHUTDOWN_OFFSET] = 1
    end

    def shutting_down?
      PAGES[0][SHUTDOWN_OFFSET] > 0
    end

    class Field
      def initialize(offset)
        @drop = PAGES.fetch(offset / MemoryPage::SLOTS)
        @offset = offset % MemoryPage::SLOTS
      end

      def value
        @drop[@offset]
      end

      def value=(value)
        @drop[@offset] = value
      end
    end

    def mold_deadline
      self[MOLD_TICK_OFFSET]
    end

    def mold_promotion_deadline
      self[MOLD_PROMOTION_TICK_OFFSET]
    end

    def service_deadline
      self[SERVICE_TICK_OFFSET]
    end

    def worker_deadline(worker_nr)
      self[WORKER_TICK_OFFSET + worker_nr]
    end

    def [](offset)
      Field.new(offset)
    end

    # Since workers are created from another process, we have to
    # pre-allocate the drops so they are shared between everyone.
    #
    # However this doesn't account for TTIN signals that increase the
    # number of workers, but we should probably remove that feature too.
    def preallocate_pages(workers_count)
      0.upto(((WORKER_TICK_OFFSET + workers_count) / MemoryPage::SLOTS.to_f).ceil) do |i|
        PAGES[i] ||= MemoryPage.new(MemoryPage::SLOTS)
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
pitchfork-0.16.0	lib/pitchfork/shared_memory.rb
pitchfork-0.15.0	lib/pitchfork/shared_memory.rb
pitchfork-0.14.0	lib/pitchfork/shared_memory.rb