# File lib/new_relic/agent/pipe_channel_manager.rb, line 227 def merge_data_from_pipe(pipe_handle) pipe = find_pipe_for_handle(pipe_handle) raw_payload = pipe.read if raw_payload && !raw_payload.empty? if raw_payload == Pipe::READY_MARKER pipe.after_fork_in_parent else payload = unmarshal(raw_payload) if payload endpoint, items = payload NewRelic::Agent.agent.merge_data_for_endpoint(endpoint, items) end end end pipe.close if pipe.eof? end