Книга: Системное программирование в среде Windows

Пример: сервер, обнаруживаемый клиентами

Пример: сервер, обнаруживаемый клиентами

Программа 11.4 представляет функцию потока, которую сервер командной строки (программа 11.3), выступающий в роли почтового клиента, использует для широковещательной рассылки имени своего канала ожидающим клиентам. Возможно существование нескольких серверов с различными характеристиками и именами каналов, и клиенты получают их имена, используя почтовый ящик с известным именем. Эта функция запускается как поток программой 11.3.

static DWORD WINAPI ServerBroadcast(LPLONG pNull) {
 MS_MESSAGE MsNotify;
 DWORD nXfer;
 HANDLE hMsFile;
 /*Открыть почтовый ящик для записывающей программы почтового "клиента"*/
 while (!ShutDown) { /* Цикл выполняется до тех пор, пока имеются серверные потоки. */
  /* Ждать, пока другой клиент не откроет почтовый ящик. */
  Sleep(CS_TIMEOUT);
  hMsFile = CreateFile(MS_CLTNAME, GENERIC_WRITE, FILE_SHARE_READ, NULL, OPEN EXISTING, FILE ATTRIBUTE NORMAL, NULL); 
  if (hMsFile == INVALID_HANDLE_VALUE) continue;
  /* Отправить сообщение в почтовый ящик. */
  MsNotify.msStatus = 0;
  MsNotify.msUtilization = 0;
  _tcscpy(MsNotify.msName, SERVER_PIPE);
  if (WriteFile(hMsFile, &MsNotify, MSM_SIZE, &nXfer, NULL)) ReportError(_T("Ошибка записи почтового сервера."), 13, TRUE);
  CloseHandle(hMsFile);
 }
 _tprintf(_T("Закрытие контролирующего потока.n"));
 _endthreadex(0);
 return 0;
} 

В программе 11.5 представлена функция, которая вызывается клиентом (см. программу 11.2) для обнаружения сервера.

/* Глава 11. LocSrver.c */
/* Найти сервер путем считывания информации из почтового ящика, используемого для широковещательной рассылки имен серверов. */
#include "EvryThng.h"
#include "ClntSrvr.h" /* Определяет имя почтового ящика. */
BOOL LocateServer(LPTSTR pPipeName) {
 HANDLE MsFile;
 MS_MESSAGE ServerMsg;
 BOOL Found = FALSE;
 DWORD cbRead;
 MsFile = CreateMailslot(MS_SRVNAME, 0, CS_TIMEOUT, NULL);
 while (!Found) {
  _tprintf(_T("Поиск сервера.n"));
  Found = ReadFile(MsFile, &ServerMsg, MSM_SIZE, &cbRead, NULL);
 }
 _tprintf(_T("Сервер найден.n"));
 CloseHandle(MsFile);
 /* Имя канала сервера. */
 _tcscpy(pPipeName, ServerMsg.msName);
 return TRUE;
}

Оглавление книги