Add and use a PubSub system in place of ar_gossip

apps/arweave/c_src/Makefile

@@ -31,6 +31,11 @@ else ifeq ($(UNAME_SYS), Linux)
 	CXXFLAGS ?= -O3 -finline-functions -Wall
 endif
 
+ifneq (, $(shell which pkg-config))
+	CFLAGS += `pkg-config --cflags gmp`
+	LDFLAGS += `pkg-config --libs gmp`
+endif
+
 CFLAGS += -fPIC -I $(ERTS_INCLUDE_DIR) -I $(ERL_INTERFACE_INCLUDE_DIR) -I /usr/local/include -I ../lib/RandomX/src
 CXXFLAGS += -fPIC -I $(ERTS_INCLUDE_DIR) -I $(ERL_INTERFACE_INCLUDE_DIR) -I ../lib/RandomX/src
 

apps/arweave/include/ar.hrl

@@ -417,23 +417,6 @@
 	reward = 0			% The fee in Winstons.
 }).
 
-%% Gossip protocol state.
-%% Passed to and from the gossip library functions of `ar_gossip`.
--record(gs_state, {
-	peers, % A list of the peers known to this node.
-	heard = [], % Hashes of the messages received thus far.
-	loss_probability = 0, % Message loss probability for network simulation.
-	delay = 0, % Message passing delay for network simulation.
-	xfer_speed = undefined % Transfer speed in bytes/s for network simulation.
-}).
-
-%% A message intended to be handled by the internal gossip protocol
-%% library, `ar_gossip`.
--record(gs_msg, {
-	hash,
-	data
-}).
-
 %% Peering performance of a node.
 -record(performance, {
 	bytes = 0,

apps/arweave/include/ar_config.hrl

@@ -113,7 +113,8 @@
 		arql => ?MAX_PARALLEL_ARQL_REQUESTS,
 		gateway_arql => ?MAX_PARALLEL_GATEWAY_ARQL_REQUESTS,
 		get_sync_record => ?MAX_PARALLEL_GET_SYNC_RECORD_REQUESTS
-	}
+	},
+	debug = false
 }).
 
 -endif.

apps/arweave/src/ar.erl

@@ -49,7 +49,6 @@
 		ar_tx_db,
 		ar_tx,
 		ar_wallet,
-		ar_gossip,
 		ar_serialize,
 		ar_block,
 		ar_difficulty_tests,
@@ -226,6 +225,9 @@ show_help() ->
 			{"randomx_bulk_hashing_iterations",
 				"The number of hashes RandomX generates before reporting the result back"
 				" to the Arweave miner. The faster CPU hashes, the higher this value should be."
+			},
+			{"debug",
+				"Enable extended logging."
 			}
 		]
 	),
@@ -353,6 +355,8 @@ parse_cli_args(["max_disk_pool_data_root_buffer_mb", Num | Rest], C) ->
 	parse_cli_args(Rest, C#config { max_disk_pool_data_root_buffer_mb = list_to_integer(Num) });
 parse_cli_args(["randomx_bulk_hashing_iterations", Num | Rest], C) ->
 	parse_cli_args(Rest, C#config { randomx_bulk_hashing_iterations = list_to_integer(Num) });
+parse_cli_args(["debug" | Rest], C) ->
+	parse_cli_args(Rest, C#config { debug = true });
 parse_cli_args([Arg|_Rest], _O) ->
 	io:format("~nUnknown argument: ~s.~n", [Arg]),
 	show_help().