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

if (send_mess_to_server(mess_send)) {

if (read_one_response(&mess_ret)) {

if (mess_ret.response == r_success) {

return(1);

} else {

fprintf(stderr, "%s", mess_ret.error_text);

}

} else {

fprintf(stderr, "Server failed to respond\n");

}

} else {

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

}

return(0);

}

int del_cdt_entry(const char *cd_catalog_ptr, const int track no) {

message_db_t mess_send;

message_db_t mess_ret;

mess_send.client_pid = mypid;

mess_send.request = s_del_cdt_entry;

strcpy(mess_send.cdt_entry_data.catalog, cd_catalog_ptr);

mess_send.cdt_entry_data.track_no = track_no;

if (send_mess_to_server(mess_send)) {

if (read_one_response(&mess_ret)) {

if (mess_ret.response == r_success) {

return(1);

} else {

fprintf(stderr, "%s", mess_ret.error_text);

}

} else {

fprintf(stderr, "Server failed to respond\n");

}

} else {

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

}

return(0);

}

Функция поиска по ключу компакт-диска сложнее. Пользователь этой функции рассчитывает вызвать ее один раз для начала поиска. Мы удовлетворили его ожидания в главе 7, задавая параметр *first_call_ptrравным trueпри первом вызове функции, и функция в этом случае возвращает первое найденное совпадение. При последующих вызовах функции поиска указатель *first_call_ptrравен falseи возвращаются дальнейшие совпадения, по одному на каждый вызов.

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

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

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;

static void process_command(const message_db_t mess_command);

void catch_signals() {

server_running = 0;

}

2. Теперь переходите к функции main. После проверки успешного завершения подпрограмм захвата сигнала программа проверяет, передали ли вы -iв командной строке. Если да, она создаст новую базу данных. Если вызов подпрограммы database_initializeв файле cd_dbm.c завершится аварийно, будет выведено сообщение об ошибке. Если все хорошо и сервер работает, любые запросы от клиента направляются функции process_command, которую вы вскоре увидите.