Der zentrale Server des Extra Systems Cypher Net-Systems ist der Punkt für die Weiterleitung des Datenverkehrs zwischen Teilnehmern. Es akzeptiert TCP-Verbindungen von Clients, empfängt Fingerabdruckdateien von ihnen (und identifiziert so die Legalität der Abonnenten) und stellt dann sicher, dass der Sitzungsschlüssel im Rahmen des Prolog-Verfahrens zwischen ihnen vereinbart wird. (Sollte sich im Falle eines Hackerangriffs herausstellen, dass der Fingerabdruck gefälscht ist, wird die Verbindung natürlich sofort unterbrochen.)
typedef struct thread_data
{
int thread_id;
int thread_socket;
PEERID client_id;
PEERID server_id;
int server_thread;
char *buffer_to_send;
int buf_size;
int prolog_size;
unsigned char client_mode;
} THREADDATA;
THREADDATA thread_pool[THREAD_POOL_SIZE];
void run_main_loop(int main_socket) {
int new_socket, addr_size, i, pooled;
struct sockaddr_in client_addr;
while (1)
{
addr_size = sizeof(client_addr);
new_socket = accept(main_socket, (struct sockaddr *) &client_addr, &addr_size);
if (new_socket < 0) break;
pooled = 0;
while (!pooled) {
for (i = 0; (i < THREAD_POOL_SIZE) && (!pooled); i++) {
if (thread_pool[i].thread_id == 0) {
thread_pool[i].thread_socket = new_socket;
thread_pool[i].thread_id = esthread_create(dispatch_call, &thread_pool[i]);
pooled = 1;
}
}
if (!pooled) es_sleep(100);
}
}
}
int main(void)
{
int my_socket;
init_hash();
init_hard_hash();
load_rsa_keys("public_0", "private_0");
sockets_startup();
my_socket = create_server_socket(main_server_port);
memset(thread_pool, 0, sizeof(thread_pool));
run_main_loop(my_socket);
sockets_cleanup();
return 0;
}
Wie aus dem Code ersichtlich ist, lädt der Server unmittelbar nach dem Start über die Prozedur „load_rsa_keys“ seinen privaten Schlüssel aus einer lokalen Datei, mit dem er RSA verwendet, um Fingerabdruckdateien zu entschlüsseln, die von Abonnenten zu ihm kommen (in der Prozedur „check_finger_print“). Anschließend wird die Prozedur run_main_loop gestartet, die den Port abhört und TCP-Verbindungen akzeptiert. Vom Server empfangene Anrufe werden zur Bearbeitung in eine Warteschlange gestellt – ein statisches Array thread_pool. Die direkte Bearbeitung von Aufrufen erfolgt durch die Prozedur „dispatch_call“, die für jeden Aufruf in einem separaten Thread gestartet wird (die dieser Verbindung entsprechende Instanz der thread_data-Struktur wird ihr als Parameter übergeben).
Der Inhalt dieser Seite ist auch in Englisch, Französisch, Portugiesisch, Spanisch, Italienisch, Ukrainisch und Russisch verfügbar.
| © Extra Systems, 2024 |
|