blob: 386f9412eddb38070d1a71c1ddcdcb6360fa1573 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
# frozen_string_literal: true
module Sass
# The {ForkTracker} module.
#
# It tracks objects that need to be closed after `Process.fork`.
module ForkTracker
module_function
if Process.respond_to?(:_fork)
# TODO: remove next line once ruby 3.1 support is dropped
require 'set' unless defined?(::Set)
SET = Set.new.compare_by_identity
MUTEX = Mutex.new
private_constant :SET, :MUTEX
def add(object)
MUTEX.synchronize do
SET.add(object)
end
end
def delete(object)
MUTEX.synchronize do
SET.delete(object)
end
end
def each(&)
MUTEX.synchronize do
SET.to_a
end.each(&)
end
# The {CoreExt} module.
#
# It closes objects after `Process.fork`.
module CoreExt
def _fork
pid = super
ForkTracker.each(&:close) if pid.zero?
pid
end
end
private_constant :CoreExt
Process.singleton_class.prepend(CoreExt)
else
def add(object); end
def delete(object); end
end
end
private_constant :ForkTracker
end
|
