WaitForSingleObject на семафор не ждет, немедленно возвращается

Я пытаюсь сделать простую клиент-серверную программу, использующую отображение файлов Windows, и использующую семафоры. Клиенты отправляют на сервер 2 числа, сервер вычисляет nr1 + nr2 и nr1 * nr2. Я попробовал что-то, но это даже не работает для 1 клиента, и я хочу, чтобы это работало для большего количества клиентов. Вот код:

сервер:

#include <windows.h>
#include <stdio.h>
#include <iostream>
using namespace std;

typedef struct {
int nr1;
int nr2;
} Mesaj;

int main(int argc, char** argv) {

Mesaj* mesaj;

HANDLE createSemaphore = CreateSemaphore(NULL, 1, 1, "Semafor");
if (createSemaphore == NULL || createSemaphore == INVALID_HANDLE_VALUE) {
wcout << "Failed to create a semaphore\n";
} else {
wcout << "Created the semaphore\n";
}

HANDLE hMemory = CreateFileMapping(INVALID_HANDLE_VALUE, NULL,
PAGE_READWRITE, 0, sizeof(Mesaj), "SharedMemory");

WaitForSingleObject(createSemaphore, INFINITE);

mesaj = (Mesaj*) MapViewOfFile(hMemory, FILE_MAP_READ, 0, 0, sizeof(Mesaj));

printf("The numbers received are: %d, %d\n", mesaj->nr1, mesaj->nr2);

int produs = mesaj->nr1 * mesaj->nr2;
int suma = mesaj->nr1 + mesaj->nr2;

printf("\nSuma numerelor este: %d iar produsul lor este: %d", suma, produs);

ReleaseSemaphore(createSemaphore, 1, NULL);

Sleep(INFINITE);

return 0;
}

клиент:

#include <windows.h>
#include <stdio.h>
#include <iostream>
using namespace std;

typedef struct {
int nr1;
int nr2;
} Mesaj;

int main(int argc, char** argv) {

Mesaj* mesaj, *mesaj2;

mesaj2 = (Mesaj*) malloc(sizeof(Mesaj));

HANDLE hMemory = OpenFileMapping(FILE_MAP_ALL_ACCESS, FALSE,
"SharedMemory");

if (hMemory == NULL) {
wcout << "Error at OpenFileMapping\n";
}

HANDLE openSemaphore = OpenSemaphore(SEMAPHORE_ALL_ACCESS,TRUE,"Semafor");
if(openSemaphore != NULL || openSemaphore != INVALID_HANDLE_VALUE){
wcout<<"the semaphore is opened\n";
}

mesaj2 = (Mesaj*) MapViewOfFile(hMemory, FILE_MAP_WRITE, 0, 0,
sizeof(Mesaj));

int nr1 = 0, nr2 = 0;
printf("Give a number: ");
scanf("%d", &nr1);
printf("Give another number: ");
scanf("%d", &nr2);

mesaj2->nr1 = nr1;
mesaj2->nr2 = nr2;

if (mesaj2 == NULL) {
wcout << "Error\n"} else {
wcout << "I sent " << mesaj2->nr1 << " and " << mesaj2->nr2 << endl;
}system("pause");
return 0;
}

Что именно я делаю не так? Как мне работать с семафорами?

0

Решение

Когда я открываю сервер, он не ждет клиента.

Документация для CreateSemaphore говорит

Состояние объекта семафора сигнализируется, когда его счет больше нуля, и не сигнализируется, когда его счет равен нулю. lInitialCount Параметр указывает начальный счет.

Вы прошли lInitialCount=1 когда вы создали семафор. а также 1 > 0, так что семафор сигнализируется и WaitForSingleObject возвращается немедленно.

Предположительно, вы хотите создать семафор с начальным количеством 0так, чтобы это не стало сигналом, пока кто-то не звонит ReleaseSemaphore,

6

Другие решения

Других решений пока нет …

По вопросам рекламы [email protected]