Help with GIOChanel on Win32 - How do I know that a socket was closed?

["Daniel K. O." <danielosmari yahoo com br>]

Hello.

I'm trying to use GIOChannels, but I probably didn't understand the 
proper way to use them (or is it a bug?).

Using:
    g_io_add_watch(io,
         G_IO_IN | G_IO_PRI | G_IO_NVAL | G_IO_ERR | G_IO_HUP,
         foo,
         NULL);

should call my callback (foo) when the connection finishes, right? But 
it never gets called when the connection ends.
My code is bellow.

I'm using Win 98 SE, MinGW/GCC 3.3.1, latest GLib from Tor's site.



Daniel K. O.


----------- code ----------------
#include <stdlib.h>
#include <glib.h>
#include <winsock2.h>


SOCKET do_winsock_stuffs(const char *server);
void do_glib_stuffs(int s);

int main(int argc, char *argv[])
{
        const char * server = "rolex.peachnet.edu";
        SOCKET s;

        if (argc<2)
                g_print("Using default\n");
        else
                server = argv[1];

        g_print("Press 'Q' to exit\n");
        g_print("Server: %s\n", server);

        s = do_winsock_stuffs(server);

        /* now, let's use GLib's stuffs */
        do_glib_stuffs(s);

        g_print("We're done\n");
        system("PAUSE");

        return 0;
}

SOCKET do_winsock_stuffs(const char *server)
{
        struct hostent *phe;
        struct servent *pse;
        struct protoent *ppe;
        struct sockaddr_in sin;
        WSADATA wsa;
        SOCKET s;
        
        
        WSAStartup(MAKEWORD(2, 0), &wsa);
        atexit((void(*)(void))WSACleanup);


        memset(&sin, 0, sizeof sin);
        /* set the address family... */
        sin.sin_family = AF_INET;
        /* ... the port ... */
        if (pse = getservbyname("TCP", "daytime"))
                sin.sin_port = pse->s_port;
        else
                sin.sin_port = htons( 13 );
        /* ... and the address */
        if (phe = gethostbyname(server)) {
                /* resolved */
                memcpy(&sin.sin_addr, phe->h_addr, phe->h_length);
        } else {
                /* probably is in x.x.x.x form */
                sin.sin_addr.s_addr = inet_addr(server);
                g_assert(sin.sin_addr.s_addr != INADDR_NONE);
        }

        g_print("Connecting...");
        ppe = getprotobyname("TCP");
        g_assert(ppe);

        /* Many people use AF_INET here, but it's WRONG! */
        s = socket(PF_INET, SOCK_STREAM, ppe->p_proto);
        g_assert(s!=INVALID_SOCKET);


        connect(s, (SOCKADDR*)&sin, sizeof sin);
        g_print("OK\n");
        return s;
}




gboolean foo(GIOChannel *source, GIOCondition condition, gpointer data)
{
        char buffer[1024];
        int len;
        GIOStatus status;

        g_assert(condition); /* 0 is an invalid condition */

        if (condition & G_IO_IN) {
                status = g_io_channel_read_chars(source, buffer,
                                sizeof buffer - 1, &len, NULL);
                if (status != G_IO_STATUS_NORMAL) {
                        g_print("Connection error: reading - status: %d\n",
                                status);
                        g_io_channel_shutdown(source, FALSE, NULL);
                        g_io_channel_unref(source);
                        return FALSE;
                }
                buffer[len] = '\0';
                g_print("Read: \"%s\"\n", buffer);
        }
        
        if (condition & G_IO_ERR) {
                g_print("Connection error\n");
                g_io_channel_shutdown(source, FALSE, NULL);
                g_io_channel_unref(source);
                return FALSE;
        }
        
        if (condition & G_IO_HUP) {
                g_print("Connection was closed\n");
                g_io_channel_shutdown(source, FALSE, NULL);
                g_io_channel_unref(source);
                return FALSE;
        }

        g_print("Condition: %d\n", condition);

        return TRUE;
}

gboolean bar(gpointer data)
{
        if (kbhit()) {
                int c = getch();
                if (c=='q' || c=='Q') {
                        GMainLoop *loop = data;
                        g_main_loop_quit(loop);
                }
        }
        return TRUE;
}

void do_glib_stuffs(int s)
{
        GIOChannel *io;
        GMainLoop *loop;
        
        loop = g_main_loop_new(NULL, FALSE);

        io = g_io_channel_unix_new(s);

        g_io_add_watch(io, G_IO_IN | G_IO_PRI | G_IO_NVAL | G_IO_ERR | 
G_IO_HUP , foo, NULL);
        g_io_channel_unref(io);

        g_idle_add(bar, loop);

        g_main_loop_run(loop);
}
------------