peer_discovery.h File Reference

Go to the source code of this file.

Functions
void	init_peer_discovery ()
	Initializes peer discovery based on configuration.
void *	handle_peer_discovery (void *arg)
	Peer discovery handler thread.

Function Documentation

handle_peer_discovery()

void * handle_peer_discovery

(

void *

arg

)

Peer discovery handler thread.

Parameters

arg	Not used. Write dummy code for no warning.

Definition at line 31 of file peer_discovery.c.

{
    usleep(1000000); // 1 s
    while (!get_exit_flag())
    {
        if (get_peer_discovery() && !get_peer_discovery_in_progress() && !get_peer_discovery_succeeded())
        {
            start_peer_discovery_progress();
            int peer_count = 0;
            bool search = false;
 
            if (get_peer_discovery_hardcoded_seeds())
            {
                // query hardcoded seeds
                search = true;
                for (int i = 0; hardcoded_peers[i] != NULL; ++i)
                {
                    add_peer_to_queue(hardcoded_peers[i], 0);
                    guarded_print_line("Added hardcoded peer: %s", hardcoded_peers[i]);
                    peer_count++;
                }
            }
            else if (get_peer_discovery_dns_lookup())
            {
                // query DNS seeds
                search = true;
 
                if (get_peer_discovery_dns_domain() == NULL)
                {
                    for (int i = 0; dns_seeds[i] != NULL; ++i)
                    {
                        char ip_address[BUFFER_SIZE];
                        lookup_address(dns_seeds[i], ip_address);
                        char* token = strtok(ip_address, " ");
                        while (token != NULL && *token != '\0')
                        {
                            if (strcmp(token, "0.0.0.0") == 0)
                            {
                                log_message(LOG_ERROR, BITLAB_LOG, __FILE__, "Invalid IP from DNS seed: %s", dns_seeds[i]);
                                break;
                            }
                            add_peer_to_queue(token, 8333);
                            token = strtok(NULL, " ");
                            peer_count++;
                        }
                    }
                }
                else
                {
                    char ip_address[BUFFER_SIZE];
                    lookup_address(get_peer_discovery_dns_domain(), ip_address);
                    char* token = strtok(ip_address, " ");
                    while (token != NULL && *token != '\0')
                    {
                        if (strcmp(token, "0.0.0.0") == 0)
                        {
                            log_message(LOG_ERROR, BITLAB_LOG, __FILE__, "Invalid IP from DNS seed: %s", get_peer_discovery_dns_domain());
                            break;
                        }
                        add_peer_to_queue(token, 8333);
                        token = strtok(NULL, " ");
                        peer_count++;
                    }
                }
            }
            else
            {
                log_message(LOG_ERROR, BITLAB_LOG, __FILE__, "Peer discovery operation or no valid state set");
                finish_peer_discovery_progress(false);
            }
 
            // [ ] Implement peer processing using the Bitcoin P2P protocol
 
            if (peer_count > 0)
            {
                log_message(LOG_INFO, BITLAB_LOG, __FILE__, "Peer discovery succeeded: found %d peers", peer_count);
                finish_peer_discovery_progress(true);
            }
            else if (!search)
            {
                log_message(LOG_ERROR, BITLAB_LOG, __FILE__, "Peer discovery failed: no valid state set");
                finish_peer_discovery_progress(false);
            }
            else
            {
                log_message(LOG_ERROR, BITLAB_LOG, __FILE__, "Peer discovery failed: no peers found");
                finish_peer_discovery_progress(false);
            }
        }
        usleep(100000); // 100 ms
    }
    if (arg) {} // dummy code to avoid unused parameter warning
    log_message(LOG_INFO, BITLAB_LOG, __FILE__, "Exiting peer discovery thread");
    pthread_exit(NULL);
}

References add_peer_to_queue(), BITLAB_LOG, BUFFER_SIZE, dns_seeds, finish_peer_discovery_progress(), get_exit_flag(), get_peer_discovery(), get_peer_discovery_dns_domain(), get_peer_discovery_dns_lookup(), get_peer_discovery_hardcoded_seeds(), get_peer_discovery_in_progress(), get_peer_discovery_succeeded(), guarded_print_line(), hardcoded_peers, LOG_ERROR, LOG_INFO, log_message(), lookup_address(), start_peer_discovery_progress(), strtok(), and usleep().

Referenced by run_bitlab().

init_peer_discovery()

void init_peer_discovery

(

)

Initializes peer discovery based on configuration.