Форум на Исходниках.RU

const char* SendingremoteIP = "127.0.0.1";

USHORT SendingremotePort = 5000;

const char* ClientIP = "127.0.0.1";

USHORT ClientPort = 5050;

int handle, new_handle;

WSADATA WsaData;

void CAutomat::StartSocket()

{

CString Msg;

SOCKADDR_IN sin;

sin.sin_family = AF_INET;

sin.sin_port = htons(SendingremotePort);

sin.sin_addr.s_addr = ::inet_addr(SendingremoteIP);

int addrlen = sizeof(sin);

int errW = WSAStartup(0x0101, &WsaData);

if (errW == SOCKET_ERROR)

{

Msg.Format("WSAStartup() failed: %ld\n", GetLastError());

AfxMessageBox(Msg);

}

handle = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);

if (handle <= 0)

{

Msg.Format(" failed to create socket\n %d\n", handle);

AfxMessageBox(Msg);

}

else

{

Msg.Format("socket created\n %d\n", handle);

AfxMessageBox(Msg);

}

int errB = bind(handle, (const sockaddr*)&sin, sizeof(sin));

if (errB < 0)

{

Msg.Format(" failed to bind\n errB=%d Port=%d\n", errB, sin.sin_port);

AfxMessageBox(Msg);

}

else

{

Msg.Format("binded\n errB=%d Port=%d\n", errB, sin.sin_port);

AfxMessageBox(Msg);

}

DWORD nonBlocking = 1;

if (ioctlsocket(handle, FIONBIO, &nonBlocking) != 0)

{

Msg.Format(" Невозможно перевести порт в неблокирующий режим");

AfxMessageBox(Msg);

}

listen(handle, 3);

new_handle = accept(handle, (struct sockaddr *)&sin, (socklen_t*)&addrlen);

}

int CAutomat::Writeing(unsigned long WordNumber)

{

///Тест!!! Это надо удалить!!!!!

AfxMessageBox(_T("Трансляция команды"));

CString Msg;

char * SendingData;

unsigned long SendingBytes;

SOCKADDR_IN client;

client.sin_family = AF_INET;

client.sin_addr.s_addr = ::inet_addr(ClientIP);

client.sin_port = htons(ClientPort);

SendingData = "Hello, world!";

SendingBytes = sizeof(SendingData);

int sent_bytes = sendto(new_handle, SendingData, SendingBytes, 0, (struct sockaddr *)&client, sizeof(sockaddr_in)) ;

if (sent_bytes != SendingBytes)

{

Msg.Format("Failed to send packet: return value = %d\n", sent_bytes);

AfxMessageBox(Msg);

}

return 0;

Reading();

}

UINT16 CAutomat:: Reading()

{

CString Msg;

SOCKADDR_IN client;

client.sin_family = AF_INET;

client.sin_addr.s_addr = ::inet_addr(ClientIP);

client.sin_port = htons(ClientPort);

unsigned char packet_data[256];

unsigned int maximum_packet_size = sizeof(packet_data);

sockaddr_in from;

socklen_t fromLength = sizeof(from);

for (int i = 0; i < 256; i++) packet_data[i] = 0x00;

int received_bytes;

received_bytes = recvfrom(new_handle, (char*)packet_data, maximum_packet_size, 0, (sockaddr*)&from, &fromLength);

int errR=WSAGetLastError();

if (received_bytes <= 0)

{

Msg.Format("Failed to get packet: return value = %d errR=%d\n", received_bytes, errR);

AfxMessageBox(Msg);

}

else

{

Msg.Format("Ой, чёйта? = %d errR=%d\n", received_bytes, errR);

AfxMessageBox(Msg);

}