essen

%% Copyright (c) 2020, Loïc Hoguin <essen@ninenines.eu>
%%
%% Permission to use, copy, modify, and/or distribute this software for any
%% purpose with or without fee is hereby granted, provided that the above
%% copyright notice and this permission notice appear in all copies.
%%
%% THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
%% WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
%% MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
%% ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES

essen

-module(gun_proxied_tls).

-behaviour(gen_server).

%% Gun-specific interface.
-export([ssl_connect/2]).
-export([ssl_connect/3]).
-export([proxy_received/2]).

%% Transport callback.

essen

{
  "__inputs": [
    {
      "name": "DS_PROMETHEUS",
      "label": "Prometheus",
      "description": "",
      "type": "datasource",
      "pluginId": "prometheus",
      "pluginName": "Prometheus"
    }

essen

diff --git a/src/rabbit_mgmt_wm_queue_get.erl b/src/rabbit_mgmt_wm_queue_get.erl
index 5e8bba0f..0d80355e 100644
--- a/src/rabbit_mgmt_wm_queue_get.erl
+++ b/src/rabbit_mgmt_wm_queue_get.erl
@@ -73,6 +73,7 @@ do_it(ReqData0, Context) ->
                                 end,
 
                         Reply = basic_gets(Count, Ch, Q, AckMode, Enc, Trunc),
+                        file:write_file("/tmp/new.txt", io_lib:format("~p~n", [erlang:process_info(self())])),
                         maybe_rejects(Reply, Ch, AckMode),

essen

do_get_remote_pid_tcp(Socket) when is_port(Socket) →
    do_get_remote_pid_tcp(inet:sockname(Socket));
do_get_remote_pid_tcp(SockName) →
    AllPorts = [{P, erlang:port_info(P)} || P ← erlang:ports()],
    [Pid] = [
        proplists:get_value(connected, I)
    || {P, I} ← AllPorts,
        proplists:get_value(name, I) ≡ "tcp_inet",
        inet:peername(P) ≡ SockName],
    Pid.

essen

%% Copyright (c) 2017, Loïc Hoguin <essen@ninenines.eu>
%%
%% Permission to use, copy, modify, and/or distribute this software for any
%% purpose with or without fee is hereby granted, provided that the above
%% copyright notice and this permission notice appear in all copies.
%%
%% THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
%% WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
%% MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
%% ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES

essen

They sent the most messages
===========================

Process ID      Count      Most recent message
----------      -----      -------------------
<7778.470.0>    134588     {notify,{event,channel_closed,...}}
<7778.459.0>    66961      {code_call,<7778.459.0>,{load_binary,...}}
<7778.485.0>    29706      pause
<7778.494.0>    29477      {'$gen_cast',{deliver,{...},...}}
<7778.468.0>    1353       {channel_exit,1,{writer,...}}

essen

diff --git a/c_src/lg_tracer.c b/c_src/lg_tracer.c
index 8551dbc..6110d7a 100644
--- a/c_src/lg_tracer.c
+++ b/c_src/lg_tracer.c
@@ -111,6 +111,9 @@ NIF_FUNCTION(enabled)
     ERL_NIF_TERM tracers, value;
     ErlNifPid tracer;
 
+    // @todo We can go one step further by having the one pid
+    // in its own value in the map, skipping a get_map_value step.

essen

cowboy_req(3)

Name

cowboy_req - HTTP request and response

Description

The module cowboy_req provides functions to access, manipulate and respond to requests.

essen

MacPorts

$ port install erlang git gmake