具體：對圖片分組，分成多個包，pc傳給dsp，dsp接收了，再傳回來，問題就出在pc接收不到。我用dsp平臺顯示資料已經發送過來，但是，recvfrom失敗。開始傳送幾十K的圖片是沒問題的，但是傳送幾百K，幾兆的圖片，接收了幾個包（接收幾個包也不一定的）之后，就不收了，顯示接收失敗，用slect（）函式測驗，slect并沒有檢測到可讀的套接字。我也試圖改了接識訓沖區，設定收發實作，以及recvfrom()之后sleep()了幾秒，但是都不行，我也不知道怎么辦了。我的客戶端是用CFree5.0生成的exe。希望大神幫幫我。
#define _WIN32_WINNT 0x0601
#include <stdio.h>
#include <time.h>
#include <stdlib.h>
#include <string.h>
#include <winsock2.h>
#include <types.h>
#include <errno.h>
#include <fcntl.h>
#include <stat.h>
#include <ws2tcpip.h>
#define PORT 7
#define TIMEOUT 15 /* (seconds) */
/*
* ======== main ========
*/
int main(int argc, char *argv[])
{
SOCKET s;
unsigned short port = PORT;
char *name = argv[0];
fd_set readfds;
struct timeval timeout;
time_t ts;
int nr;
int status = EXIT_SUCCESS;
int value;
struct addrinfo hints;
struct addrinfo *results = NULL;
char portString[10];
FILE* fq=NULL;
FILE* fd=NULL;
int rd;
int wd;
int rc;
int sc;
timeout.tv_sec = TIMEOUT;
timeout.tv_usec = 0;
struct stat st;
char * pbuf = NULL;
char * rbuf = NULL;
// int len = 0;
if (argc < 2)
{
fprintf(stderr, "Usage: %s [IPv4 or IPv6 addr] [port]\n", name);
status = EXIT_FAILURE;
goto QUIT;
}
if (argc > 2)
{
port = (unsigned short)strtoul(argv[2], NULL, 0);
}
/* convert the port into string format in order to pass it to getaddrinfo */
sprintf(portString,"%d", port);
printf("\nTesting UDP echo server at %s:%d\n", argv[1], port);
/* initialize sockets environment */
//socketsStartup();
WSADATA wsaData;
WSAStartup(MAKEWORD(1, 1), &wsaData);
memset(&hints, 0, sizeof(hints));
hints.ai_family = AF_UNSPEC;
hints.ai_socktype = SOCK_DGRAM;
hints.ai_protocol = IPPROTO_UDP;
/*
* getaddrinfo() fills in the results struct for us appropriately
* depending on whether the IP address is v4 or v6
*
* argv[1] = IPv4 or IPv6 address passed in from command line
* argv[2] = port number passed in from command line
*/
value = getaddrinfo(argv[1], portString, &hints, &results);
if (value != 0)
{
fprintf(stderr, "getaddrinfo failed: %d\n", value);
if (value == -2 || value == 11004)
{
fprintf(stderr, "unrecognized IP address\n");
}
status = EXIT_FAILURE;
goto QUIT;
}
printf("succeed to get the info of the host\n");
/* create socket. ai_family determined for us via getaddrinfo() call */
if ((s = socket(results->ai_family, results->ai_socktype, 0)) == INVALID_SOCKET)
{
fprintf(stderr, "%s: failed socket \n", name);
printf ( "Could not create socket : %d" , WSAGetLastError());
status = EXIT_FAILURE;
goto QUIT;
}
printf("succeed to create the socket\n");
int opt=1;
setsockopt(s,SOL_SOCKET,SO_REUSEADDR,&opt,sizeof(opt));
//send bufffer
int nSendBuf=8*1024;// set as 32K
setsockopt(s,SOL_SOCKET,SO_SNDBUF,(const char*)&nSendBuf,sizeof(int));
// receive buffer
int nRecvBuf=8*1024;// set as 32K
setsockopt(s,SOL_SOCKET,SO_RCVBUF,(const char*)&nRecvBuf,sizeof(int));
//set timeout of sending and receiving
setsockopt( s, SOL_SOCKET, SO_SNDTIMEO, &timeout, sizeof( timeout ) );
setsockopt( s, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof( timeout ) );
if((fq=fopen("C:/Users/Administrator/Desktop/zyc2.jpg","rb"))== NULL)
{
perror("file error");
status = EXIT_FAILURE;
goto QUIT;
}
printf("succeed to open the file\n");
// stat("C:/Users/Administrator/Desktop/zyc2.jpg",&st);/*attain the size of file*/
// len = st.st_size;
fseek (fq , 0 , SEEK_END);
int lSize;
lSize = ftell (fq);
printf("the size of file is %d\n",lSize);
rewind (fq);
//send and receive buffer
if (!(pbuf =(char *) malloc(sizeof(char)*lSize)))
{
perror("failed temp buffer allocation\n");
status = EXIT_FAILURE;
goto QUIT;
}
if (!(rbuf =(char *) malloc(sizeof(char)*lSize)))
{
perror("failed temp buffer allocation\n");
status = EXIT_FAILURE;
goto QUIT;
}
rd=fread(pbuf,1,lSize,fq);
// long temin1=ftell(fq);
// printf("terminate file:%d\n",temin1);
if(rd!=lSize)
{
perror("read error\n");
printf("return:%d",rd);
status = EXIT_FAILURE;
goto QUIT;
}
printf("read %d bytes\n",rd);
printf("sending\n");
int i_group;
int i_pakge=512;
i_group=lSize/i_pakge;
int i_leftpk=lSize-i_pakge*i_group;
int i_count=1;
int i_addr=0;
ts = time(0);
while(i_count<=i_group)
{
sc=sendto(s,&pbuf[i_addr],i_pakge,0, results->ai_addr, results->ai_addrlen);
if(sc<0)
{
fprintf(stderr, "%s: send failed \n", name);
printf ( "%d group send failed: %d" ,i_count,WSAGetLastError());
status = EXIT_FAILURE;
goto QUIT;
}
//printf("succeed to send %d group:%d bytes data\n",i_count,sc);
/* Wait for the reply */
//receive....
//printf("receiving\n");
rc=recvfrom(s,&rbuf[i_addr],i_pakge,0,results->ai_addr, &(results->ai_addrlen));
/* {
printf("Received back %d group:%d bytes\n",i_count, rc);
}
*/
Sleep(2000);
if(rc<0)
{
fprintf(stderr, "%s: recv failed \n", name);
printf ( "%d group receive failed : %d" ,i_count,WSAGetLastError());
status = EXIT_FAILURE;
// perror("rc=%d,failed in receiving\n",rc);
goto QUIT;
}
i_addr=i_addr+i_pakge;
i_count++;
}
sc=sendto(s,&pbuf[i_addr],i_leftpk,0, results->ai_addr, results->ai_addrlen);
if(sc<0)
{
fprintf(stderr, "%s: send failed \n", name);
printf ( "Could not send lefting: %d" , WSAGetLastError());
status = EXIT_FAILURE;
goto QUIT;
}
printf("left group: succeed to send %d bytes data\n",sc);
printf("left group:waitting for the reply");
rc=recvfrom(s,&rbuf[i_addr],i_leftpk,0, results->ai_addr, &(results->ai_addrlen));
if(rc<0)
{
fprintf(stderr, "%s: receive failed \n", name);
printf ( "Could not receive: %d" , WSAGetLastError());
status = EXIT_FAILURE;
goto QUIT;
}
printf("left group:succeed to reveive %d bytes data\n",rc);
printf("Exiting test. Time = %d seconds\n", (int)(time(0) - ts));
if((fd=fopen("C:/Users/Administrator/Desktop/zyc3.jpg","wb"))== NULL)
{
perror("file error");
status = EXIT_FAILURE;
goto QUIT;
}
printf("succeed to open the file\n");
if((wd=fwrite(rbuf,1,lSize,fd))!=lSize)
{
perror("write");
status = EXIT_FAILURE;
goto QUIT;
}
printf("write %d bytes\n",wd);
QUIT:
printf("\nerror:exit %d\n",status);
if (s >= 0)
{
(void)closesocket(s);
}
WSACleanup();
//socketsShutdown();
/* if(fq!=NULL)
{
fclose(fq);
}
if(fd!=NULL)
{
fclose(fd);
}
*/
fclose(fq);
fclose(fd);
fq=NULL;
fd=NULL;
free(pbuf);
free(rbuf);
return (status);
}
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/81036.html
標籤：網絡及通訊開發
上一篇：兩個有序鏈表合并成一個有序鏈表