#include <windows.h>
#include <stdio.h>
#include <process.h>

#define MAX_MSG_SIZE 424 // максимальный размер сообщения
HANDLE slot_read = NULL;

//*****************************************************************************************
// Поток приема сообщений из слота
unsigned __stdcall mailslot_recv(void* slot_name)
{
	// Открытие слота для приема
	char name[256];
	sprintf_s(name, 256, "\\\\.\\mailslot\\%s", slot_name);
	slot_read = CreateMailslot(name, MAX_MSG_SIZE, 1000, (LPSECURITY_ATTRIBUTES) NULL);
	bool work = true;
    if(slot_read == INVALID_HANDLE_VALUE) 
    { 
        printf("CreateMailslot failed with %d\n", GetLastError());
        work = false; 
    } 

	// Ожидание сообщений
	while(work) {
		char buf[MAX_MSG_SIZE + 1];
		DWORD read = 0;
		if(!ReadFile(slot_read, buf, MAX_MSG_SIZE, &read, NULL)) {
			switch(GetLastError()) {
				case 121:
					// Истекло время ожидания сообщения заданное в CreateMailslot()
					printf("*"); 
					read = 0;
					break;
				default:
					printf("ReadFile failed with %d.\n", GetLastError());
					work = false;
					break;
			}
		} else {
			buf[read] = 0;
			printf("%5d: recv %s\n", GetTickCount() % 100000, buf);
		}
	}
    _endthreadex(0);
    return 0;
}

//---------------------------------------------------------------------------------
// Отправка сообщения в слот всем слушающим в сети
bool mailslot_send(char* slot_name, char* msg, int size)
{
	if(size > MAX_MSG_SIZE) {
		printf("Message too long\n");
		return false;
	}
	// Открытие слота на отправку
	char name[256];
	sprintf_s(name, 256, "\\\\*\\mailslot\\%s", slot_name);
	HANDLE slot = CreateFile(name, GENERIC_WRITE, FILE_SHARE_READ, (LPSECURITY_ATTRIBUTES) NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, (HANDLE) NULL); 
	if(slot == INVALID_HANDLE_VALUE) {
		printf("CreateFile failed with %d.\n", GetLastError()); 
		return false;
	}
	// Отправка сообщения
	DWORD written = 0;
	if(!WriteFile(slot, msg, size, &written, NULL)) {
		printf("WriteFile failed with %d.\n", GetLastError()); 
		CloseHandle(slot);
		return false;
	}
	CloseHandle(slot);
	return true;
}

int main(int argc, char* argv[])
{
	char* slot_name = "compnames";
	HANDLE th = (HANDLE)_beginthreadex(NULL, 0, &mailslot_recv, slot_name, 0, NULL);
	// Получение имени компа
	char compname[100];
	size_t comp_size = 100;
	getenv_s( &comp_size, compname, comp_size, "COMPUTERNAME");
	if(comp_size <= 0) {
		strcpy(compname, "X3");
	} 
	// Рассылка своего имени всем
	for(int i = 0; i < 100; i++) {
		Sleep(500);
		char buf[1000];
		sprintf_s(buf, 1000, "%s %d", compname, i);
		mailslot_send(slot_name, buf, strlen(buf));
	}
	// Остановка приема
	CloseHandle(slot_read);
	WaitForSingleObject(th, INFINITE);
	CloseHandle(th);
	system("pause");
	return 0;
}