JezK

Name: test
Start: 2022-11-25
End: 2022-11-25

Edit File: posix_spawn_process.rb

require 'ffi'
require 'thread'

module ChildProcess
  module Unix
    class PosixSpawnProcess < Process
      private

@@cwd_lock = Mutex.new

def launch_process
        pid_ptr = FFI::MemoryPointer.new(:pid_t)
        actions = Lib::FileActions.new
        attrs   = Lib::Attrs.new

if io.stdout
          actions.add_dup fileno_for(io.stdout), fileno_for(STDOUT)
        else
          actions.add_open fileno_for(STDOUT), "/dev/null", File::WRONLY, 0644
        end

if io.stderr
          actions.add_dup fileno_for(io.stderr), fileno_for(STDERR)
        else
          actions.add_open fileno_for(STDERR), "/dev/null", File::WRONLY, 0644
        end

if duplex?
          reader, writer = ::IO.pipe
          actions.add_dup fileno_for(reader), fileno_for(STDIN)
          actions.add_close fileno_for(writer)
        end

attrs.pgroup = 0 if leader?
        attrs.flags |= Platform::POSIX_SPAWN_USEVFORK if defined? Platform::POSIX_SPAWN_USEVFORK

# wrap in helper classes in order to avoid GC'ed pointers
        argv = Argv.new(@args)
        envp = Envp.new(ENV.to_hash.merge(@environment))

ret = 0
        @@cwd_lock.synchronize do
          Dir.chdir(@cwd || Dir.pwd) do
            if ChildProcess.jruby?
              # on JRuby, the current working directory is for some reason not inherited.
              # We'll work around it by making a chdir call through FFI.
              # TODO: report this to JRuby
              Lib.chdir Dir.pwd
            end

ret = Lib.posix_spawnp(
              pid_ptr,
              @args.first, # TODO: not sure this matches exec() behaviour
              actions,
              attrs,
              argv,
              envp
            )
          end
        end

if duplex?
          io._stdin = writer
          reader.close
        end

actions.free
        attrs.free

if ret != 0
          raise LaunchError, "#{Lib.strerror(ret)} (#{ret})"
        end

@pid = pid_ptr.read_int
        ::Process.detach(@pid) if detach?
      end

if ChildProcess.jruby?
        def fileno_for(obj)
          ChildProcess::JRuby.posix_fileno_for(obj)
        end
      else
        def fileno_for(obj)
          obj.fileno
        end
      end

class Argv
        def initialize(args)
          @ptrs = args.map do |e|
            if e.include?("\0")
              raise ArgumentError, "argument cannot contain null bytes: #{e.inspect}"
            end

FFI::MemoryPointer.from_string(e.to_s)
          end

@ptrs << FFI::Pointer.new(0)
        end

def to_ptr
          argv = FFI::MemoryPointer.new(:pointer, @ptrs.size)
          argv.put_array_of_pointer(0, @ptrs)

argv
        end
      end # Argv

class Envp
        def initialize(env)
          @ptrs = env.map do |key, val|
            next if val.nil?

if key =~ /=|\0/ || val.to_s.include?("\0")
              raise InvalidEnvironmentVariable, "#{key.inspect} => #{val.to_s.inspect}"
            end

FFI::MemoryPointer.from_string("#{key}=#{val.to_s}")
          end.compact

@ptrs << FFI::Pointer.new(0)
        end

def to_ptr
          env = FFI::MemoryPointer.new(:pointer, @ptrs.size)
          env.put_array_of_pointer(0, @ptrs)

env
        end
      end # Envp

end
  end
end

test | Fairnetzt-Hochrhein

Home Events test

test

Dies ist ein Test

Datum

25 Nov. 2022

Vorbei!

Uhrzeit

13:00 - 18:00

JezK

Edit File: posix_spawn_process.rb

test

Datum

Uhrzeit

Teile diese Veranstaltung