Основы программирования в 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);

}

Интерфейс сервера server.c

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

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

process_command
и функции перехвата сигнала для обеспечения чистого завершения.

#include <unistd.h>

#include <stdlib.h>