个人中心
gpt4 book ai didi

c++ - 使用 c++ 套接字 - 使用 accept() 和文件描述符时会出现严重错误

转载 作者：行者123 更新时间：2023-11-28 03:27:11 29 4
gpt4 key购买 nike

<分区>

我已经使用这个网站一段时间了，(在这个学期之后)期待回馈!但是，我最后一次需要你的帮助，其他答案似乎都没有任何帮助。

背景:使用 C++、套接字和客户端/服务器架构设计一个基本的聊天室，最多可有 10 个客户端与服务器对话。一个客户端所说的任何内容都会在所有客户端和服务器中得到回应(发送客户端除外)。

问题:错误发生在 clientTalk 函数中作为 while 循环条件的 recv 调用。我得到一个“接收失败:错误的文件描述符”，但服务器和客户端都没有完全“崩溃”并且行为没有发生明显的变化，尽管接收完全被轰炸了。

尝试解决:

  • Google 和 SOf。 2小时...

  • 移动变量，尝试套接字设置和打开/关闭

-Valgrind:

==773== Warning: invalid file descriptor 96600128 in syscall read()

Recieve failed: Bad file descriptor
==773== Thread 2:
==773== Conditional jump or move depends on uninitialised value(s)
==773==    at 0x4015A0: ??? (in /nethome/users/ghm455/CS284/ChatServer/server)
==773==    by 0x4E39E99: start_thread (pthread_create.c:308)
==773==    by 0x5442CBC: clone (clone.S:112)
==773==
==773== Conditional jump or move depends on uninitialised value(s)
==773==    at 0x401614: ??? (in /nethome/users/ghm455/CS284/ChatServer/server)
==773==    by 0x4E39E99: start_thread (pthread_create.c:308)
==773==    by 0x5442CBC: clone (clone.S:112)
==773==
==773== Warning: invalid file descriptor 96600128 in syscall close()

第一个警告出现在我的接受声明中。接收失败发生在 recv 上，最后一个警告发生在尝试关闭时。这是由散落在整个代码中的 cout 语句决定的。

代码:下面。如果您认为错误在那里，我会发布客户端，但一切都表明这是服务器端问题。

`#define SERVER_PORT 9999        /* define a server port number */

using std::cout;
using std::endl;
using std::string;

//Globals - descriptorArray holds client FDs.  arraySize is its size.
//soc holds the information on the server's socket.
//m is the global mutex shared among the server and all clients
const int MAX_CLIENT = 10;
int descriptorArray[MAX_CLIENT];
int arraySize = 0;
int soc;
pthread_mutex_t m;

struct thread_info
{
pthread_t threadID; //Stores the ID number returned by pthread_create
int threadNumber;   //We have to number incoming threads correctly
char *messageSent;  //Message taken in from command line
};

int main()
{
void exitHandler(int sig); // Function that handles the control-C
void* clientTalk(void *arg); // Reads and writes with clients
struct sockaddr_in server_addr, client_addr;
int option = 1;
unsigned int clientCount;
uint8_t *new_socket;

//Initialize the socket
soc = socket(AF_INET, SOCK_STREAM, 0);
if (soc < 0)
{
    cout << "ERROR : problem opening socket" <<endl;
    return 1;
}

//Create socket structure
bzero((char *) &server_addr, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = INADDR_ANY;
server_addr.sin_port = htons(SERVER_PORT);

//Binding host address
if (bind(soc, (struct sockaddr *) &server_addr, sizeof(server_addr)) < 0)
{
    cout << "ERROR : problem occured while binding" <<endl;
    close(soc);
    exit(1);
}
if(setsockopt(soc, SOL_SOCKET, SO_REUSEADDR, (char*) &option, sizeof(option)) < 0)
{
    printf("setsockopt failed\n");
    close(soc);
    exit(1);
} 

signal(SIGINT, exitHandler);
listen(soc, MAX_CLIENT);

clientCount = sizeof(struct sockaddr_in);
int clientID;
//cout << "Z " <<endl;
while(clientID = accept(soc, (struct sockaddr *) &client_addr, (socklen_t*)&clientCount))
{
    //printf( "A");
    if (clientID < 0 )  
    {   
        perror("ERROR ON ACCEPT");
        exit(1);
    }
    else
    {
        pthread_t newClient;
        new_socket = (uint8_t*)malloc(1);
        *new_socket = clientID;
        pthread_mutex_lock(&m);
        if (arraySize < 10)
        {
            descriptorArray[arraySize++] = newClient;
        }
        else
        {
            cout << "There are already 10 clients connected!" << endl;
        }
        pthread_mutex_unlock(&m);
        if( pthread_create(&newClient, NULL, clientTalk, &new_socket) < 0)
        {
            perror("ERROR Creating thread");
            return 1;
        }
        cout << "Assigned!" <<endl;
        pthread_join(newClient, NULL);
    }
}
close(soc);
return 0;
}

void exitHandler(int sig)
{
sig = sig + 0; //Removing the warning. A clean compile looks a lot nicer.
for (int i = 0; i < arraySize; i++)
{
    write(descriptorArray[i], "WARNING: Server exiting in ten seconds. End your conversation!", 1000);
}
cout << "WARNING: Server exiting in ten seconds.  ";
cout << "End your conversation!" << endl;
sleep(10f); 
for (int i = 0; i < arraySize; i++)
{
    close(descriptorArray[i]);
}
close(soc);
exit(1);
}


void* clientTalk(void* arg)
{
int* myFD = (int*) arg;
char buffer[2000];
read(*myFD, buffer, 20);
char username[20];
//strcpy(username, buffer); // Takes in the username and stores it
char movableString[2000];
int amount_read;

// for (int i = 0; i < arraySize; i++)
// {
    //strcpy(movableString, username);
//  strcat(movableString, " has joined the room!");
    //if (descriptorArray[0] != *myFD)
    //{
    //  write(descriptorArray[0], movableString, 2000);
    //}
//}
cout << "x" << endl;
int arrayLocation;  
while ( (amount_read = recv(*myFD, buffer, 2000, MSG_WAITALL)) > 0)
{
    cout << " Um" << endl;
    pthread_mutex_lock(&m);
    for (int i = 0; i < arraySize; i++)
    {
        if (descriptorArray[i] == *myFD)
        {
            arrayLocation = i;
            break;
        }
    }
    strcpy(movableString, username);
    strcat(movableString, ": ");
    strcat(movableString, buffer);
    for (int i = 0; i < arraySize; i++)
    {
        //if (i != arrayLocation)
        //{
            write(*myFD, movableString, 2000); 
        //}
    }
    pthread_mutex_unlock(&m);
}
if (amount_read == 0)
{
    cout << username << "disconnected unexpectedly" <<endl;
    fflush(stdout);
}
if (amount_read == -1)
{
    perror("Recieve failed");
}


pthread_mutex_lock(&m);
for (int i = 0; i < arraySize; i++)
{
    if (descriptorArray[i] == *myFD)
    {
        arrayLocation = i;
        break;
    }
}

for (int i = arrayLocation; i < arraySize - 1; i++)
{
    descriptorArray[i] = descriptorArray[i + 1];
}
arraySize--;

pthread_mutex_unlock(&m);
close(*myFD);
pthread_exit(NULL);
free(arg);
}

`

我会监控此站点以回答您可能提出的任何问题。对于在提问时犯的任何新手错误，我提前表示歉意。

感谢您的帮助!

29 4 0
文章推荐： c++ - 在 Windows 应用商店应用程序中映射 Direct3D11 中的动态缓冲区
文章推荐： javascript - 如何将对象函数的输出添加到数组
文章推荐： java - 如何使用 Java 发送 HTTP GET 并使用用 C++ 编写的 CGI 应用程序打印 QUERY_STRING 环境变量？
文章推荐： c++ - 无法计算字符串中的字符数
行者123
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com