Class: ScoutApm::RequestManager

Inherits:
Object
  • Object
show all
Defined in:
lib/scout_apm/request_manager.rb

Class Method Summary collapse

Class Method Details

.create ⇒ Object

Create a new TrackedRequest object for this thread XXX: Figure out who is in charge of creating a FakeStore - previously was here



35
36
37
38
39
 
# File 'lib/scout_apm/request_manager.rb', line 35

def self.create
  agent_context = ScoutApm::Agent.instance.context
  store = agent_context.store
  Thread.current[:scout_request] = TrackedRequest.new(agent_context, store)
end

.find ⇒ Object

Get the current Thread local, detecting and not returning a stale request, nor a request that belongs to a different thread.



12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
 
# File 'lib/scout_apm/request_manager.rb', line 12

def self.find
  req = Thread.current[:scout_request]
  return nil unless req

  # ActionController::Live runs the controller action in a child thread and
  # copies the parent thread's raw Thread.current locals (including
  # :scout_request) into it. Without this check the parent (Rack) thread and
  # the child (streaming) thread would share and concurrently mutate a single
  # TrackedRequest -- racing on @layers/@stopping -- which corrupts the layer
  # stack, drops the transaction, and leaks layers across requests. If the
  # resident request was created on a different thread, treat it as absent so
  # lookup creates a fresh one owned by this thread.
  return nil if req.creating_thread_id != Thread.current.object_id

  if req.stopping? || req.recorded?
    nil
  else
    req
  end
end

.lookup ⇒ Object 



6
7
8
 
# File 'lib/scout_apm/request_manager.rb', line 6

def self.lookup
  find || create
end