Грубо, есть функция DeviceReceiveThread.
Выполняется в своем потоке, ожидающем сигнала о том что есть "входящий телефонный вызов".
На всякий случай приведу ее оригинал (из MS SDK) целиком под спойлером:
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
97.
98.
99.
100.
101.
102.
103.
104.
105.
106.
107.
108.
//+---------------------------------------------------------------------------
//
// function: DeviceReceiveThread
//
// Synopsis: Thread to watch for an incoming fax transmission
//
// Arguments: [pdwDeviceId] - pointer to the virtual fax device identifier
//
// Returns: DWORD
//
//----------------------------------------------------------------------------
DWORD WINAPI DeviceReceiveThread(LPDWORD pdwDeviceId)
{
// hChangeNotification is a handle to a notification change in a directory
HANDLE hChangeNotification;
// hWaitObjects are the handles to the wait objects
HANDLE hWaitObjects[2];
// dwDeviceId is the virtual fax device identifier
DWORD dwDeviceId;
// pLineMessage is a pointer to LINEMESSAGE structure to signal an incoming fax transmission to the fax service
LPLINEMESSAGE pLineMessage;
//WriteDebugString(L"---SampleFSP: DeviceReceiveThread Enter---\r\n");
// Copy the virtual fax device identifier
dwDeviceId = *pdwDeviceId;
MemFreeMacro(pdwDeviceId);
WriteDebugString(L"---SampleFSP: DeviceReceiveThread (Device=%x) Enter---\r\n", dwDeviceId);
// Create the change notification handle
hChangeNotification = FindFirstChangeNotification(g_pDeviceInfo[dwDeviceId]->Directory,
FALSE,
FILE_NOTIFY_CHANGE_ATTRIBUTES);
if (hChangeNotification == INVALID_HANDLE_VALUE) {
goto Exit;
}
// Wait for access to this virtual fax device
EnterCriticalSection(&g_pDeviceInfo[dwDeviceId]->cs);
// Set hWaitObjects
hWaitObjects[0] = g_pDeviceInfo[dwDeviceId]->ExitEvent;
hWaitObjects[1] = hChangeNotification;
// Release access to this virtual fax device
LeaveCriticalSection(&g_pDeviceInfo[dwDeviceId]->cs);
while (TRUE) {
// Wait for the exit event or notification change to be signaled
if ( WaitForMultipleObjects(2,
hWaitObjects,
FALSE,
INFINITE) == WAIT_OBJECT_0) {
break;
}
// Wait for access to this virtual fax device
EnterCriticalSection(&g_pDeviceInfo[dwDeviceId]->cs);
if (g_pDeviceInfo[dwDeviceId]->Status == DEVICE_IDLE) {
// Allocate a block of memory for the completion packet
pLineMessage = (LPLINEMESSAGE) LocalAlloc(LPTR, sizeof(LINEMESSAGE));
if (pLineMessage != NULL) {
// Initialize the completion packet
// Set the completion packet's handle to the virtual fax device
pLineMessage->hDevice = dwDeviceId + NEWFSP_DEVICE_ID_PREFIX;
// Set the completion packet's virtual fax device message
pLineMessage->dwMessageID = 0;
// Set the completion packet's instance data
pLineMessage->dwCallbackInstance = 0;
// Set the completion packet's first parameter
pLineMessage->dwParam1 = LINEDEVSTATE_RINGING;
// Set the completion packet's second parameter
pLineMessage->dwParam2 = 0;
// Set the completion packet's third parameter
pLineMessage->dwParam3 = 0;
WriteDebugString(L"---SampleFSP: DeviceReceiveThread (Device=%x) Signaling Fax Service...---\r\n", dwDeviceId);
// Post the completion packet
PostQueuedCompletionStatus(g_CompletionPort,
sizeof(LINEMESSAGE),
g_CompletionKey,
(LPOVERLAPPED) pLineMessage);
}
}
// Release access to this virtual fax device
LeaveCriticalSection(&g_pDeviceInfo[dwDeviceId]->cs);
// Find the next notification change
FindNextChangeNotification(hChangeNotification);
}
Exit:
if (hChangeNotification != INVALID_HANDLE_VALUE) {
// Close the handle to the change notification
FindCloseChangeNotification(hChangeNotification);
}
// Close the handle to the exit event
CloseHandle(hWaitObjects[0]);
//WriteDebugString(L"---SampleFSP: DeviceReceiveThread Exit---\r\n");
WriteDebugString(L"---SampleFSP: DeviceReceiveThread (Device=%x) Exit---\r\n", dwDeviceId);
return 0;
}
Смысл такой.
Бесконечно ждет через WaitForMultipleObjects одного из 2-х "сигналов":
(1) Сигнал на выход из функции (реализован внутри библиотеки)
Т.е. когда пользователь решил не использовать "девайс" для приема вызовов, по этому сигналу функция самозавершается.
1.
hWaitObjects[0] = g_pDeviceInfo[dwDeviceId]->ExitEvent;
Это меня устраивает.
(2) Сигнал о том, что есть входящий вызов, на который надо реагировать.
В тестовой SDK-библиотеке это реализовано так:
1.
2.
3.
4.
5.
6.
7.
8.
// Create the change notification handle
hChangeNotification = FindFirstChangeNotification(g_pDeviceInfo[dwDeviceId]->Directory,
FALSE,
FILE_NOTIFY_CHANGE_ATTRIBUTES);
if (hChangeNotification == INVALID_HANDLE_VALUE) {
goto Exit;
}
hWaitObjects[1] = hChangeNotification;
Т.е. этот объект следит за изменением атрибутов файлов в заданной папке g_pDeviceInfo[dwDeviceId]->Directory через FindFirstChangeNotification.
и как только я поменял какой-то атрибут у какого-то файла, это будет "звоночек в функцию".
Это сделано для теста.
Меня устраивает (1) и я не хочу это менять но ясен пень не устраивает (2).
(2) я хочу реализовать так.
читать MailSlot в этой ф-ции, как-только есть сообщение это означает "звоночек" и WaitForMultipleObjects выходит.
Т.е. мне надо стукнуть в DeviceReceiveThread из другого приложения (при этом желат. получить ответ, но это уже другой вопрос).
Как мне увязать WaitForMultipleObjects и MailSlot?
MailSlot обычно читается циклом, (либо бесконечное ожидание).
Т.е. мне нужно внутри ф-ции сделать hWaitObjects[1] который бы стучал в WaitForMultipleObjects "в MailSlot есть сообщение".
Я не могу
одновременно бесконечно ждать сообщение MailSlot (через ReadFile) и бесконечно ждать ->ExitEvent (через WaitForMultiple(Single)Objects).
Если я сделаю цикл с небесконечными ожиданиями, то не работает принцип "как только так сразу" для любого из событий, и не уверен что это есть хорошо.
Как извернуться?
