|
|
|
|
|
|
|
[Original]
[Print]
[Top]
|
下面是一个线程的代码,该线程主要首先从文件接收方接收一个请求,然后将文件流发送给它。
我现在有两个问题:
问题1,
在文件传输过程中,出现一个奇怪的问题,有时候问题可以传输成功,有的时候文件就传送失败。我用ethreal抓包看了一下,文件传输失败时发送的TCP包上面注释着TCP校验和错误。然后接受方提示文件传送失败。
问题2,
下面代码还存在一个结构上的问题,也就是当文件请求到达时,线程就忙于文件传输了,如果要传送大文件的话,在文件传输期间会导致无法响应其他的文件请求。我本来打算在接受到一个文件请求后,再开启一个线程来发送文件,但是实验了一下没有成功。所以,我的问题是,在线程中再创建一个线程是否会存在问题?
如果存在问题的话,那么怎么样更改程序的结构使之能够解决我所描述的问题。
还望指教!谢谢啦
static void *watch_file(void *arg)
{
int listenfd, connfd;
socklen_t len;
struct sockaddr_in localaddr, cliaddr;
localaddr.sin_family = AF_INET;
localaddr.sin_addr.s_addr = htonl(INADDR_ANY);
localaddr.sin_port = htons(IPMSG_PORT);
listenfd = socket(AF_INET, SOCK_STREAM, 0);
int i = bind(listenfd, (struct sockaddr *)&localaddr, sizeof(localaddr));
pthread_t tid;
pthread_detach(pthread_self());
if (i < 0)
{
perror("Tcp bind Error
");
} else
{
printf("Tcp bind Succeed
");
}
i = listen(listenfd, 1024);
#ifdef _DEBUG
if (i < 0)
{
perror("Tcp listen Error
");
} else
{
printf("Tcp listen Succeed
");
}
#endif
for (;;)
{
connfd = accept(listenfd, (struct sockaddr*)&cliaddr, &len);
char sendbuf[1024];
char command[1024];
memset(command, ' ', 1024);
int i = recv(connfd, command, 1024, MSG_DONTWAIT);
#ifdef _DEBUG
if (i)
{
printf("Receiver's request:%s Length:%d
", command, i);
}
#endif
int k = read(filetosend.fd, sendbuf, 1024);
while (k > 0)
{
#ifdef _DEBUG
printf("Trace file reading:k:%d
", k);
#endif
int m = send(connfd, sendbuf, k, NULL);
#ifdef _DEBUG
printf("Send byte:%d
", m);
#endif
k = read(filetosend.fd, sendbuf, 1024);
}
close(filetosend.fd);
close(connfd);
}
}
|
|
|
[Original]
[Print]
[Top]
|
|
« Previous thread
算法问题 |
C/C++编程版
第18页 |
Next thread »
请问一个关于gdb调试的问题 |
|