c++ - C++ IRC Socket Exception? To trådet - Udvikleren.dk

Tags: c++

Bruger #11328 @ 07.06.09 18:46

Hej allesammen!

Så er jeg tilbage med mine C++ problemer...

Jeg prøver at lave en (meget) simpelt IRC klient der nu både kan modtage og sende data. Derfor gør jeg brug af Mutex of tråde.

Problemet er at jeg modtager en Exception hver gang jeg kører min kode der siger "Der blev fors°gt (forsøgt) en handling pÕ (på) noget, som ikke er en socket."

I følgende kode:

Kode

#include "Net.h"
#include "UnknownHostException.h"
#include "NetException.h"
#include "ConnectionLostException.h"
#include "TCPSocket.h"
#include "Thread.h"
#include "Mutex.h"
#include <iostream>
#if defined(__linux__)
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#endif

Mutex gMutex;

class IRCReader : public Thread {
    public:
        IRCReader(TCPSocket socket) : aSocket(socket){};
        static bool bKeepRunning;

    protected:
        virtual void run() {
            while(bKeepRunning)
            {

                try {
                    char buffer[1024];
                    int bytesRead;
                    while(bKeepRunning) {
                        gMutex.enter();
                        bytesRead = aSocket.read(buffer, sizeof(buffer));
                        std::cout.write(buffer, bytesRead);
                        std::cout.flush();
                        gMutex.leave();
                }
                } catch(ConnectionLostException & e) {
                    // Server disconnect
                }

                aSocket.close();
            }
        }
    private:
        TCPSocket aSocket;
};

bool IRCReader::bKeepRunning = true;

int main(int argc, char ** argv)
{

    try {
        netInit();
        try {
            string adrstr = "irc.freenode.net";


            TCPSocket socket(adrstr, 6667);
            socket.connect();
            std::string say = "PASS NOPASS\r\nNICK SaebekassebilII__\r\nUSER SaebekassebilIII_ 8 * :John Doe\r\nJOIN #saebekassebil\r\n";
            socket.write(say.c_str(), say.size());
            IRCReader reader(socket);
            reader.start();

            std::string inputString;
            while(inputString != "quit")
            {
                std::cin >> inputString;
                gMutex.enter();
                socket.write(inputString.c_str(), inputString.size());
                gMutex.leave();
            }

            IRCReader::bKeepRunning = false;
            reader.waitForThread();

        } catch(NetException & e) {
            std::cout << e << std::endl;
        }

        netRelease();

    } catch(NetException & e) {
        std::cout << "Couldn't initialize the component: " << e << std::endl;
    }

    return 0;
}

Kan slet ikke fatte fejlen da jeg mener at jeg har taget højde for det hele?

Indlæg senest redigeret d. 06.02.2010 20:42 af Bruger #11328

8 svar postet i denne tråd vises herunder
0 indlæg har modtaget i alt 0 karma

Sorter efter stemmer Sorter efter dato

Bruger #2695 @ 07.06.09 19:11

1.963

Prøv følgende constructor:

Kode

class IRCReader : public Thread {
    public:
        IRCReader(TCPSocket & socket) : aSocket(socket){};

...bemærk '&' tegnet. Uden dét bliver det en ny kopi af objektet og default constructoren bliver kaldt.

Bruger #11328 @ 07.06.09 20:15

1.323

Mange tak Robert! Ja, det hjalp gevaldigt! Kan nu modtage data. Problemet er dog at jeg ikke kan sende nu? Jeg kan skrive en streng én gang, men ellers så får jeg ikke chancen igen. Mit gæt er at den venter oppe ved min read funktion. Men ved ikke hvad jeg skal gøre ved det?

Kode

#include "Net.h"
#include "UnknownHostException.h"
#include "NetException.h"
#include "ConnectionLostException.h"
#include "TCPSocket.h"
#include "Thread.h"
#include "Mutex.h"
#include <iostream>
#if defined(__linux__)
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#endif

Mutex gMutex;

class IRCReader : public Thread {
    public:
        IRCReader(TCPSocket & socket) : aSocket(socket){};
        static bool bKeepRunning;

    protected:
        virtual void run() {
            while(bKeepRunning)
            {

                try {
                    char buffer[1024];
                    int bytesRead;
                    while(bKeepRunning) {
                        gMutex.enter();
                        bytesRead = aSocket.read(buffer, sizeof(buffer));
                        gMutex.leave();
                        std::cout.write(buffer, bytesRead);
                        std::cout.flush();
                    }
                } catch(ConnectionLostException & e) {
                    // Server disconnect
                }
            }
        }
    private:
        TCPSocket aSocket;
};

bool IRCReader::bKeepRunning = true;

int main(int argc, char ** argv)
{

    try {
        netInit();
        try {
            string adrstr = "irc.freenode.net";


            TCPSocket socket(adrstr, 6667);
            socket.connect();
            std::string say = "PASS NOPASS\r\nNICK Saebekassebil5\r\nUSER Saebekassebil5_ 8 * :John Doe\r\nJOIN #testingsaebekassebil\r\n";
            socket.write(say.c_str(), say.size());
            IRCReader reader(socket);
            reader.start();

            std::string inputString;
            while(inputString != "quit")
            {
                std::cout << "Write something:";
                std::cin >> inputString;
                gMutex.enter();
                socket.write(inputString.c_str(), inputString.size());
                gMutex.leave();
                inputString = "";
            }


            std::string quitString("QUIT :Just leaving");
            gMutex.enter();
            socket.write(quitString.c_str(), quitString.size());
            gMutex.leave();

            IRCReader::bKeepRunning = false;
            reader.waitForThread();
            socket.close();

        } catch(NetException & e) {
            std::cout << e << std::endl;
        }

        netRelease();

    } catch(NetException & e) {
        std::cout << "Couldn't initialize the component: " << e << std::endl;
    }

    return 0;
}

Indlæg senest redigeret d. 06.02.2010 20:42 af Bruger #11328

Bruger #2695 @ 07.06.09 20:40

1.963

Du har låst din mutex.

Når du har sendt dine data låser du din mutex op, og så får læse tråden adgang og udfører følgende:

Kode

while(bKeepRunning) {
                        gMutex.enter();
                        bytesRead = aSocket.read(buffer, sizeof(buffer));

Så er mutexen låst, og tråden venter på data...som først kommer når du har sendt, og du kan ikke sende, fordi mutexen er låst.

Bruger #11328 @ 07.06.09 20:48

1.323

Jamen problemet er så at når jeg skriver kan jeg ikke modtage data?? Egentlig burde det kun lige være selve "sendingen" af dataen der burde være Mutex låst.. Men ved ikke hvordan jeg skal implementere det?

I bund og grund er det vel det at "read" funktionen laver et kald til "waitForData()" indtil den modtager data.. Som så får låsen på read til at vare utroligt længe...

Bruger #2695 @ 07.06.09 21:03

1.963

Jamen problemet er så at når jeg skriver kan jeg ikke modtage data?? Egentlig burde det kun lige være selve "sendingen" af dataen der burde være Mutex låst.. Men ved ikke hvordan jeg skal implementere det?

I bund og grund er det vel det at "read" funktionen laver et kald til "waitForData()" indtil den modtager data.. Som så får låsen på read til at vare utroligt længe...

Faktisk er der ikke noget problem i at have én tråd til at læse og én til at skrive til samme socket samtidig...uden mutex.

Men IRC er en lidt mere komplex protokol, hvor samme socket både kan sende svar på forespørgsler og notifikationer om events (chat, invitationer, osv) samtidig, så det er nok et helt anderledes design, du skal ud i.

Bruger #11328 @ 07.06.09 22:41

1.323

En notifikation kan jo komme på helt tilfældige tidsspunkter. Men det var netop designet jeg ikke lige kunne finde en løsning på? Kan du evt. lave en skitse af en simpel program-design løsning?

Bruger #2695 @ 08.06.09 10:36

1.963

En notifikation kan jo komme på helt tilfældige tidsspunkter. Men det var netop designet jeg ikke lige kunne finde en løsning på? Kan du evt. lave en skitse af en simpel program-design løsning?

Jeg kan godt tegne et diagram, som jeg ville lave det, men simpelt bliver det nok ikke.

Bruger #11328 @ 08.06.09 12:44

1.323

Hele ideen var at det skulle være simpelt og så kunne jeg bygge videre på det...

Hvorfor bliver det ikke simpelt? (Er dog meget interesseret i dit diagram! (Er det UML?)

C++ IRC Socket Exception? To trådet

Karma barometer (30 dage)

Modtaget

Givet

Favorit hos
Forum tråde
Artikler