Основы программирования в Linux

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

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

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

 #include <unistd.h>
 #include <stdlib.h>
 #include <stdio.h>
 #include <fcntl.h>
 #include <limits.h>
 #include <signal.h>
 #include <string.h>
 #include <errno.h>
 #include <sys/types.h>
 #include <sys/stat.h>
 #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, которую вы вскоре увидите.

 int main(int argc, char *argv[]) {
  struct sigaction new_action, old_action;
  message_db_t mess command;
  int database_init_type = 0;
  new_action.sa_handler = catch_signals;
  sigemptyset(&new_action.sa_mask);
  new_action.sa_flags = 0;
  if ((sigaction(SIGINT, &new_action, &old_action) != 0) ||
  (sigaction(SIGHUP, &new_action, &old_action) != 0) ||
  (sigaction(SIGTERM, &new_action, &old_action) != 0)) {
  fprintf(stderr, "Server startup error, signal catching failed\n");
  exit(EXIT_FAILURE);
  }
  if (argc > 1) {
  argv++;
  if (strncmp("-i", *argv, 2) == 0) database_init_type = 1;
  }
  if (!database_initialize(database_init_type)) {
  fprintf(stderr, "Server error :-\
  could not initialize database\n");
  exit (EXIT_FAILURE);
  }
  if (!server starting) exit(EXIT_FAILURE);
  while(server_running) {
  if (read_request_from_client(&mess_command)) {
  process_command(mess_command);
  } else {
  if (server_running) fprintf(stderr,
  "Server ended — can not read pipe\n");
  server_running = 0;
  }
  } /* while */
  server_ending;
  exit(EXIT_SUCCESS);
 }

3. Любые сообщения клиентов направляются в функцию process_command, где они обрабатываются в операторе case, который выполняет соответствующие вызовы из файла cd_dbm.c.

 static void process_command(const message_db_t comm) {
  message_db_t resp;
  int first_time = 1;
  resp = comm; /* копирует команду обратно,
  затем изменяет resp, как требовалось */
  if (!start_resp_to_client(resp)) {
  fprintf(stderr, "Server Warning:
  start_resp_to_client %d failed\n", resp.client_pid);
  return;
  }
  resp.response = r_success;
  memset(resp.error_text, '\0', sizeof(resp.error_text));
  save_errno = 0;
  switch(resp.request) {
  case s_create_new_database:
  if (!database initialize(1))
  resp.response = r_failure;
  break;
  case s_get_cdc_entry:
  resp.cdc_entry_data =
  get_cdc_entry(comm.cdc_entry_data.catalog);
  break;
  case s_get_cdt_entry:
  resp.cdt_entry_data =
  get_cdt_entry(comm.cdt_entry_data.catalog,
  comm.cdt_entry_data.track_no);
  break;
  case s_add_cdc_entry:
  if (!add_cdc_entry(comm.cdc_entry_data))
  resp.response = r_failure;
  break;
  case s_add_cdt_entry:
  if (!add_cdt_entry(comm.cdt_entry_data))
  resp.response = r_failure;
  break;
  case s_del_cdc_entry:
  if (!del_cdc_entry(comm.cdc_entry_data.catalog))
  resp.response = r_failure;
  break;
  case s_del_cdt_entry:
  if (!del_cdt_entry(comm.cdt_entry_data.catalog,
  comm.cdt_entry_data.track_no)) resp.response = r_failure;
  break;