Нейл Мэтью - Основы программирования в Linux

Теперь, когда вы разделили приложение на два процесса, нельзя разрешать поиску обрабатывать по одному элементу на сервере, потому что другой клиент может запросить у сервера иной поиск, когда выполняется ваш поиск. Вы не можете заставить серверную часть хранить отдельно содержимое (как далеко продвинулся поиск) для поиска каждого клиента, т.к. клиент может просто остановить поиск на полпути, когда найден нужный компакт-диск или клиент "упал".

Можно либо изменить алгоритм поиска, либо, как показано в приведенном далее программном коде, спрятать сложность в подпрограмме интерфейса. Данный код вынуждает сервер возвращать все возможные совпадения с искомым значением и затем сохраняет их во временном файле до тех пор, пока клиент не запросит их.

1. Эта функция не так сложна, как кажется, просто в ней вызываются три функции канала send_mess_to_server, start_resp_from_serverи read_resp_fromserver, которые будут рассмотрены в следующем разделе.

cdc_entry search_cdc_entry(const char *cd_catalog_ptr,

int *first_call_ptr) {

message_db_t mess_send;

message_db_t mess_ret;

static FILE *work_file = (FILE *)0;

static int entries_matching = 0;

cdc_entry ret_val;

ret_val.catalog[0] = '\0';

if (!work_file && (*first_call_ptr == 0)) return(ret_val);

2. Далее показан первый вызов для поиска с указателем *first_call_ptr, равным true. Он немедленно приравнивается false, на случай, если вы забыли. Создается временный файл work_fileи инициализируется структура сообщения клиенту.

if (*first_call_ptr) {

*first_call_ptr = 0;

if (work_file) fclose(work_file);

work_file = tmpfile();

if (!work_file) return(ret_val);

mess_send.client_pid = mypid;

mess_send.request = s_find_cdc_entry;

strcpy(mess_send.cdc_entry_data.catalog, cd_catalog_ptr);

3. Теперь приводится проверка условий с тремя уровнями вложенности, заставляющая вызывать функции из файла pipe_imp.c. Если сообщение успешно отправлено на сервер, клиент ждет ответа от сервера. Пока считывания с сервера успешны, совпадения с искомой величиной возвращаются в work_fileклиента и наращивается счетчик entries_matching.

if (send_mess_to_server(mess_send)) {

if (start_resp_from_server()) {

while (read_resp_from_server(&mess_ret)) {

if (mess_ret.response == r_success) {

fwrite(&mess_ret.cdc_entry_data, sizeof(cdc_entry), 1, work_file);

entries_matching++;

} else {

break;

}

} /* while */

} else {

fprintf(stderr, "Server not responding\n");

}

} else {

fprintf (stderr, "Server not accepting requests\n");

}

4. Следующая проверка ищет, есть ли совпадения с заданным значением. Далее вызов fseekпереводит указатель в файле work_fileна место записи следующей порции данных.

if (entries_matching == 0) {

fclose(work_file);

work_file = (FILE *)0;

return(ret_val);

}

(void)fseek(work_file, 0L, SEEK_SET);

5. Если это не первый вызов функции поиска для данного конкретного элемента, программа проверяет, были ли уже найдены совпадения. В заключение в структуру ret_valчитается следующий совпадающий элемент. Предшествующие проверки гарантируют наличие совпадающего элемента.

} else {

/* не *first_call_ptr */

if (entries_matching == 0) {

fclose(work_file);

work_file = (FILE *)0;

return(ret_val);

}

}

fread(&ret_val, sizeof(cdc_entry), 1, work_file);

entries_matching--;

return(ret_val);

}

Если у клиента есть интерфейс для обращения к программе app_ui.c, серверу также нужна программа для управления (переименованной) программой cd_access.c, теперь cd_dbm.c. Далее приведена функция main сервера.

1. Начните с объявления нескольких глобальных переменных, прототипа функции process_commandи функции перехвата сигнала для обеспечения чистого завершения.

#include

#include

#include

#include

#include

#include

#include

#include

#include

#include

#include "cd_data.h"

#include "cliserv.h"

int save errno;

static int server_running = 1;