Name network listeners.
This commit is contained in:
parent
ebb6e57318
commit
ac7541e571
|
@ -406,4 +406,4 @@ let init () =
|
||||||
Node.send_ignore "factory" (Message.create (Sexp.Str "fanout",
|
Node.send_ignore "factory" (Message.create (Sexp.Str "fanout",
|
||||||
Sexp.Arr [Sexp.Str "amq.fanout"],
|
Sexp.Arr [Sexp.Str "amq.fanout"],
|
||||||
Sexp.Str "", Sexp.Str ""));
|
Sexp.Str "", Sexp.Str ""));
|
||||||
ignore (Util.create_thread "AMQP listener" None (Net.start_net Amqp_spec.port) start)
|
ignore (Util.create_thread "AMQP listener" None (Net.start_net "AMQP" Amqp_spec.port) start)
|
||||||
|
|
4
net.ml
4
net.ml
|
@ -23,10 +23,10 @@ let rec accept_loop sock connection_start_fn =
|
||||||
ignore (connection_start_fn (s, peername));
|
ignore (connection_start_fn (s, peername));
|
||||||
accept_loop sock connection_start_fn
|
accept_loop sock connection_start_fn
|
||||||
|
|
||||||
let start_net port_number connection_start_fn =
|
let start_net protocol_name port_number connection_start_fn =
|
||||||
let sock = socket PF_INET SOCK_STREAM 0 in
|
let sock = socket PF_INET SOCK_STREAM 0 in
|
||||||
setsockopt sock SO_REUSEADDR true;
|
setsockopt sock SO_REUSEADDR true;
|
||||||
bind sock (ADDR_INET (inet_addr_of_string "0.0.0.0", port_number));
|
bind sock (ADDR_INET (inet_addr_of_string "0.0.0.0", port_number));
|
||||||
listen sock 5;
|
listen sock 5;
|
||||||
Log.info "Accepting connections" [Sexp.Str (string_of_int port_number)];
|
Log.info "Accepting connections" [Sexp.Str protocol_name; Sexp.Str (string_of_int port_number)];
|
||||||
accept_loop sock connection_start_fn
|
accept_loop sock connection_start_fn
|
||||||
|
|
|
@ -36,4 +36,4 @@ let _ =
|
||||||
hook_log ();
|
hook_log ();
|
||||||
Amqp_relay.init ();
|
Amqp_relay.init ();
|
||||||
(* Speedtest.init (); *)
|
(* Speedtest.init (); *)
|
||||||
Net.start_net 5671 Relay.start
|
Net.start_net "Hop" 5671 Relay.start
|
||||||
|
|
Loading…
Reference in New Issue