Вот этот небольшой примерчик демонстрирует что операция неполного чтения дейтаграммы вполне корректна.
Повторное чтение недочитанной дейтаграммы как и ожидалось не происходит.
| Код |
#include <iostream>
#include <string>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <errno.h>
namespace
{
const size_t SERV_PORT = 9654;
void err(const char* err)
{
std::cerr << "Err: " << err << std::endl;
std::cerr << strerror(errno) << std::endl;
}
}
int Socket(struct sockaddr_in* addr, const char* ip_addr = NULL)
{
int sockfd;
if((sockfd = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
{
err("create socket");
return -1;
}
bzero(addr, sizeof(*addr));
addr->sin_family = AF_INET;
addr->sin_port = htons(SERV_PORT);
if(ip_addr == NULL)
addr->sin_addr.s_addr = htonl(INADDR_ANY);
else
{
if(inet_aton(ip_addr, &(addr->sin_addr)) == 0)
{
err("do inet_aton");
close(sockfd);
return -1;
}
}
if(ip_addr == NULL)
{
if(bind(sockfd, (sockaddr *)addr, sizeof(*addr)) < 0)
{
err("cannot bind");
close(sockfd);
return -1;
}
}
return sockfd;
}
int main(int argc, char* argv[])
{
struct sockaddr_in servaddr, cliaddr;
int serv_sock, cli_sock;
std::cout << "Create server socket" << std::endl;
if((serv_sock = Socket(&servaddr)) < 0)
return 1;
std::cout << "Create client socket" << std::endl;
if((cli_sock = Socket(&cliaddr, "127.0.0.1")) < 0)
return 1;
std::cout << "Socket was created\n";
const char msg[] = "This is a test message";
sendto(cli_sock, msg, sizeof(msg), 0, (sockaddr *)&cliaddr, sizeof(cliaddr));
char recvmsg[sizeof(msg) / 2];
int bytesrecv;
errno = 0;
if ((bytesrecv = recvfrom(serv_sock, recvmsg, sizeof(recvmsg), 0, (sockaddr*)NULL, NULL)) < 0)
{
std::cout << "EEEERRROR" << std::endl;
}
std::cerr << strerror(errno) << std::endl;
std::cout << "bytesrecv = " << bytesrecv << std::endl;
std::cout << "recvmsg = " << std::string(recvmsg, bytesrecv) << std::endl;
if ((bytesrecv = recvfrom(serv_sock, recvmsg, sizeof(recvmsg), 0, (sockaddr*)NULL, NULL)) < 0)
{
std::cout << "EEEERRROR" << std::endl;
}
std::cout << "bytesrecv = " << bytesrecv << std::endl;
std::cout << "recvmsg = " << std::string(recvmsg, bytesrecv) << std::endl;
close(serv_sock);
close(cli_sock);
}
|
выхлоп
| Код |
Create server socket
Create client socket
Socket was created
Success
bytesrecv = 11
recvmsg = This is a t
... весим ждем данных
|
|
)