OXIESEC PANEL

Name	Size	Modified	Perms
📁 ..	-	05/09/2024 07:14:11 AM	rwxr-xr-x
📄 acl.rb	4.61 KB	10/21/2017 09:53:52 AM	rw-r--r--
📄 drb.rb	56.62 KB	12/19/2017 03:40:13 PM	rw-r--r--
📄 eq.rb	275 bytes	12/16/2015 05:07:31 AM	rw-r--r--
📄 extserv.rb	831 bytes	12/16/2015 05:07:31 AM	rw-r--r--
📄 extservm.rb	1.72 KB	10/08/2017 07:00:01 AM	rw-r--r--
📄 gw.rb	3 KB	12/16/2015 05:07:31 AM	rw-r--r--
📄 invokemethod.rb	777 bytes	12/16/2015 05:07:31 AM	rw-r--r--
📄 observer.rb	667 bytes	12/16/2015 05:07:31 AM	rw-r--r--
📄 ssl.rb	11.56 KB	12/12/2017 11:56:25 AM	rw-r--r--
📄 timeridconv.rb	2.16 KB	05/22/2016 11:03:44 AM	rw-r--r--
📄 unix.rb	2.75 KB	12/16/2015 05:07:31 AM	rw-r--r--

Editing: extservm.rb

# frozen_string_literal: false
=begin
 external service manager
        Copyright (c) 2000 Masatoshi SEKI
=end

require 'drb/drb'
require 'monitor'

module DRb
  class ExtServManager
    include DRbUndumped
    include MonitorMixin

@@command = {}

def self.command
      @@command
    end

def self.command=(cmd)
      @@command = cmd
    end

def initialize
      super()
      @cond = new_cond
      @servers = {}
      @waiting = []
      @queue = Thread::Queue.new
      @thread = invoke_thread
      @uri = nil
    end
    attr_accessor :uri

def service(name)
      synchronize do
        while true
          server = @servers[name]
          return server if server&.alive?
          invoke_service(name)
          @cond.wait
        end
      end
    end

def regist(name, ro)
      synchronize do
        @servers[name] = ro
        @cond.signal
      end
      self
    end

def unregist(name)
      synchronize do
        @servers.delete(name)
      end
    end

private
    def invoke_thread
      Thread.new do
        while true
          name = @queue.pop
          invoke_service_command(name, @@command[name])
        end
      end
    end

def invoke_service(name)
      @queue.push(name)
    end

def invoke_service_command(name, command)
      raise "invalid command. name: #{name}" unless command
      synchronize do
        return if @servers.include?(name)
        @servers[name] = false
      end
      uri = @uri || DRb.uri
      if command.respond_to? :to_ary
        command = command.to_ary + [uri, name]
        pid = spawn(*command)
      else
        pid = spawn("#{command} #{uri} #{name}")
      end
      th = Process.detach(pid)
      th[:drb_service] = name
      th
    end
  end
end