consensus-simulation Namespace Reference

Functions
def	bsc (n)
def	simulate (k, n, verbose)

Variables
	parser = argparse.ArgumentParser()
	metavar
	type
	int
	help
	action
	args = parser.parse_args()
float	sum = 0.0

Function Documentation

bsc()

def consensus-simulation.bsc

(

n

)

 count the bits set in n

Definition at line 25 of file consensus-simulation.py.

def bsc(n):
    """ count the bits set in n"""
    l = n.bit_length()
    c = 0
    x = 1
    for _ in range(0, l):
        if n & x:
            c = c + 1
        x = x << 1
    return c
 
 

Referenced by simulate().

Here is the caller graph for this function:

simulate()

def consensus-simulation.simulate	(		k,
			n,
			verbose
	)

Definition at line 37 of file consensus-simulation.py.

def simulate(k, n, verbose):
    assert k < n
    largest_arc = int(2**ceil(log(n, 2))) // 2
    num_ghosts = (2 * largest_arc) - n
    if verbose:
        print("we have", num_ghosts, "ghost peers")
        # n.b. all peers with idx<k are evil
    peers = list(range(n))
    info = [1 << x for x in range(n)]
 
    def done_p():
        for x in range(k, n):
            if bsc(info[x]) < n - k:
                return False
        return True
 
    rounds = 0
    while not done_p():
        if verbose:
            print("-- round --")
        arc = 1
        while arc <= largest_arc:
            if verbose:
                print("-- subround --")
            new_info = [x for x in info]
            for peer_physical in range(n):
                peer_logical = peers[peer_physical]
                peer_type = None
                partner_logical = (peer_logical + arc) % n
                partner_physical = peers.index(partner_logical)
                if peer_physical < k or partner_physical < k:
                    if verbose:
                        print(
                            "bad peer in connection", peer_physical, "--",
                            partner_physical
                        )
                    continue
                if peer_logical & arc == 0:
                    # we are outgoing
                    if verbose:
                        print(peer_physical, "connects to", partner_physical)
                    peer_type = "outgoing"
                    if peer_logical < num_ghosts:
                        # we have a ghost, check if the peer who connects
                        # to our ghost is actually outgoing
                        ghost_partner_logical = (peer_logical - arc) % n
                        if ghost_partner_logical & arc == 0:
                            peer_type = peer_type + ", ghost incoming"
                    new_info[peer_physical] = new_info[peer_physical] | info[
                        peer_physical] | info[partner_physical]
                    new_info[partner_physical
                             ] = new_info[partner_physical] | info[
                                 peer_physical] | info[partner_physical]
                else:
                    peer_type = "incoming"
                if verbose > 1:
                    print("type of", str(peer_physical) + ":", peer_type)
            info = new_info
            arc = arc << 1
        rounds = rounds + 1
        random.shuffle(peers)
    return rounds
 
 

References bsc(), int, and list.

Here is the call graph for this function:

Variable Documentation

parser

consensus-simulation.parser = argparse.ArgumentParser()

Definition at line 102 of file consensus-simulation.py.

Referenced by GNUNET_JSON_parse().

metavar

consensus-simulation.metavar

Definition at line 103 of file consensus-simulation.py.

type

consensus-simulation.type

Definition at line 103 of file consensus-simulation.py.

int

consensus-simulation.int

Definition at line 103 of file consensus-simulation.py.

Referenced by httpdomain.httpdomain.RFC2616Ref.__init__(), addr_info_cb(), audio_write(), calculate_fork_degree(), check_client_redirect_to_ip(), check_ipv6_listed(), check_reply(), check_use_ip(), compare_list_tunnels(), create_keys(), deserialize_download(), event_cb(), find_string(), GCCH_handle_channel_plaintext_data_ack(), gen_topo_from_file(), get_next_ibf_size(), get_node_info(), GNUNET_CRYPTO_ecc_dlog_prepare(), GNUNET_CRYPTO_hash_cmp(), GNUNET_memcmp_ct_(), GNUNET_STRINGS_base64_encode(), GNUNET_TESTBED_2dtorus_calc_links(), GNUNET_TESTBED_run(), handle_client_redirect_to_ip(), handle_client_redirect_to_service(), handle_get_peers(), handle_icmp_remote(), handle_peer_information(), handle_reply(), handle_tcp_remote(), handle_udp_remote(), handle_use_ip(), libgnunet_plugin_block_revocation_init(), load_file(), gnunet_janitor.main(), main(), next_phase(), process_header(), httpdomain.httpdomain.HTTPXRefStatusRole.result_nodes(), run(), gdb-iterate-dll.search_dll(), setup_service(), simulate(), updateUsage(), and uri_ksk_parse().

help

consensus-simulation.help

Definition at line 103 of file consensus-simulation.py.

action

consensus-simulation.action

Definition at line 106 of file consensus-simulation.py.

Referenced by automaton_state_traverse(), handle_message_delete(), and REGEX_INTERNAL_automaton_traverse().

args

consensus-simulation.args = parser.parse_args()

Definition at line 108 of file consensus-simulation.py.

Referenced by do_accept(), do_address(), do_help(), do_quit(), do_resume(), do_status(), do_suspend(), GNUNET_asprintf(), GNUNET_buffer_write_fstr(), GNUNET_buffer_write_vfstr(), GNUNET_CONFIGURATION_config_tool_run(), GNUNET_FS_meta_data_get_first_by_types(), GNUNET_snprintf(), make_json(), run(), run_process_and_wait(), run_service(), tcp_nat_port_map_callback(), and udp_nat_port_map_callback().

sum

float consensus-simulation.sum = 0.0

Definition at line 109 of file consensus-simulation.py.

Referenced by calc_checksum(), calculate_score(), compute_square_sum(), compute_square_sum_mpi_elements(), GNUNET_CRYPTO_crc16_finish(), GNUNET_CRYPTO_crc16_n(), GNUNET_CRYPTO_crc16_step(), GNUNET_TUN_calculate_icmp_checksum(), GNUNET_TUN_calculate_tcp4_checksum(), GNUNET_TUN_calculate_tcp6_checksum(), GNUNET_TUN_calculate_udp4_checksum(), GNUNET_TUN_calculate_udp6_checksum(), setup_estimate_message(), update_avg(), and update_network_size_estimate().