g_io_channel + socket = сервер, все еще не получили правильные данные и просто получили один клиент?на языке Си - PullRequest
Новая
       1

g_io_channel + socket = сервер, все еще не получили правильные данные и просто получили один клиент?на языке Си

0 голосов
/ 05 марта 2011

люди,

, если вы не возражаете, посмотрите следующий код: 

#include <glib.h>
#include <gio/gio.h> // gio channel

#include <sys/socket.h> //socket();
#include <netdb.h> // structure

#include <stdio.h> // printf

void deal(GIOChannel *in, GIOCondition condition, gpointer data)
{
    struct sockaddr_storage income;

    int insock = g_io_channel_unix_get_fd(in);
    socklen_t income_len = sizeof(income);
    int newsock = accept(insock, (struct sockaddr*)&income, &income_len );
    if(newsock == -1)
    {
        printf("failure on newsock\n");
    }

    char buff[128];

    int recv_total = 0;
    int recv_byte = 128;
    int recv_sizing;

    while (recv_total < recv_byte ){

    recv_sizing = recv(newsock,buff + recv_total,recv_byte,0);

    // breaking if recv_sizing = -1 assuming as error, 0 assuming as lost communication from client suddenly
    if(recv_sizing < 0 || recv_sizing == 0)
     {
         printf("connection lost or error while recv(); [ just guess ] number : %d \n",recv_sizing);
         break;
    }

    recv_byte -= recv_sizing;
    recv_total += recv_sizing;


    }


    buff[recv_total] = '\0';
    //recv_sizing = recv(newsock,buff,recv_byte,0);
    printf("data : %s\n",buff);

    close(newsock); // close immediate and look for another some1 new


}

int main()
{
    GIOChannel *in;


    struct sockaddr_in my;
    my.sin_addr.s_addr = INADDR_ANY;
    my.sin_family      = AF_INET;
    my.sin_port        = htons(3000);

    //socket initiate root socket
    int rsock = socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);

    //allow re-use address
    setsockopt(rsock,SOL_SOCKET,SO_REUSEADDR,(int*)1,sizeof(int));

    //binding
    bind(rsock,(struct sockaddr*)&my,sizeof(my));

    //listen
    listen(rsock,10);


    in = g_io_channel_unix_new(rsock);

    g_io_add_watch(in, G_IO_IN | G_IO_OUT | G_IO_HUP, (GIOFunc) deal, NULL);


    GMainLoop *loop = g_main_loop_new(NULL,FALSE); // pengganti while(1) ato gtk_main_loop
    g_main_loop_run(loop);
    return 0;
}

и он скомпилирован: 

$ gcc -o dengersocket_glib dengersocket_glib.c `pkg-config --cflags --libs glib-2.0`

и теперь слушаю и с нетерпением жду любогоДанные пакета от клиента и клиента отправляют следующий пакет: 

$ echo wew | nc -v localhost 3000 
nc: connect to localhost port 3000 (tcp) failed: Connection refused
Connection to localhost 3000 port [tcp/*] succeeded!

, и теперь сервер получает следующий странный пакет: 

$ ./dengersocket_glib 
data : �o=

, и мой вопрос в том, где ошибка на моемcode?,

1.Как получить правильный пакет, и каждый клиент может подключиться к серверу?[решено]

2. Передача данных решена, но все равно может принять только один клиент, как получить более одного клиента?

1 Ответ

1 голос
/ 05 марта 2011 
int recv_total;

должно быть 

int recv_total = 0;

При случайном значении мусора, которое имеет recv_total из-за отсутствия инициализации, вы также получите случайные данные мусора в buf, если только recv_total не окажется <128, а первый символ в буфере будет быть мусором, если <code>recv_total не оказалось 0.

EDIT: Кроме того, ваш вызов принятия неверен, вы приводите размер к void *, но должны передать указатель на socklen_t, который должен содержать и получить размер sockaddr. 

socklen_t ss = sizeof(income);
accept(..., &ss);

Затем проверьте возвращаемое значение из accept, убедитесь, что вы получили действительный сокет. 

if (newsock == -1) {
  printf("...");
}
...