c++ sockets recv

[c++ (Gast)]

Hallo,
ich möchte/muss unter C++ mit Sockets arbeiten. Das sieht jetzt so aus 
und funktioniert:

char echo_buffer[RCVBUFSIZE];
int recv_size;

recv_size = recv(sock, echo_buffer, RCVBUFSIZE,0);
    if(recv_size < 0)
    error_exit("Fehler bei recv()");

echo_buffer[recv_size] = '\0';
leer[recv_size] = '\0';

Bei recv gibt er mir alle epfangenen Daten seit dem letzten Mal. Wenn 
aber keine Daten kommen, wartet er, bis Daten kommen. Das darf nicht 
sein.
Mit

recv_size > 0 //Daten sind da

wird das auch nichts.

Meine Frage:
Wie kann ich gucken, ob überhaupt in diesem Moment neue Daten verfügbar 
sind, damit recv auf gar keinen Fall wartet?

[Karl H. (kbuchegg)]

schau dir mal die Funktion 'select()' an

[Georg B. (diereinegier)]

Auf Linux "man recv" tippen oder ein Buch lesen?

Man kann den Socket Non-Blocking machen (mit fcntl) oder (üblicher) mit 
select abfragen, ob Daten anliegen.

Ich würde zum Erlernen der Socket-Programmierung das Buch Unix Network 
Programming von Ruchard W. Stevens empfehlen. Es enthält sehr gut 
dokumentierte Beispiele in C.

[c++ (Gast)]

Danke für die Antworten!!!

Select scheint schonmal das richtige zu sein. Bisher suche ich noch nach 
einer Möglichkeit select() zu benutzen.

Hat da jemand einen Gedankenanstoß?

[CC (Gast)]

Die man-Page hat (bei mir) ein Beispiel drin. Muss natürlich angepasst 
werden, aber das schaffst du schon ;-)

[c++ (Gast)]

[c]
select(sock_max+1, &sock, NULL, NULL, NULL);
[\c]

ock ist mein Socket. Aber was soll sock_max sein?

[c++ (Gast)]

CC schrieb:
> Die man-Page hat (bei mir) ein Beispiel drin. Muss natürlich angepasst
> werden, aber das schaffst du schon ;-)

Ich guck' mal...

[CC (Gast)]

Der socket mit dem höchsten Wert in rdfs.

[CC (Gast)]

Ich seh gerade, &sock ist falsch. Muss der fd set sein, in dem die 
Sockets zum Lesen sind.

[c++ (Gast)]

CC schrieb:
> Der socket mit dem höchsten Wert in rdfs.

In man steht leider bei mir nichts.

Und vor allem:
Was ist rdfs?

[CC (Gast)]

http://linux.die.net/man/2/select
Nach unten scrollen. Oder eins der zig-tausend socket-Tutorials lesen 
(und verstehen)...

[c++ (Gast)]

sock wird übrigens so erzeugt;

sock = socket( AF_INET, SOCK_STREAM, 0 );

[c++ (Gast)]

Irgendwie hat das alles nichts mit meinem TCP zu tun.

Also mein Code bisher sieht so aus:

#include "Tcp.h"
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>

#include <iostream>
#include <string.h>
#include <cstring>

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#include <arpa/inet.h>
#include <unistd.h>

#define RCVBUFSIZE 8192

static void eingeben();
static void error_exit(char *errorMessage);
static void send(char *text);

int _port = 13050;

struct sockaddr_in server;
struct hostent *host_info;
unsigned long addr;

int sock;

unsigned int _len;


int Tcp::begin( int argc, char *argv[])
{
    //printf("" + argc);
    
    if (argc < 2)
        error_exit("usage: client server-ip echo_word\n");

    sock = socket( AF_INET, SOCK_STREAM, 0 );

    if (sock < 0)
        error_exit( "Fehler beim Anlegen eines Sockets");

    
    if ((addr = inet_addr( argv[1])) != INADDR_NONE)
    {
        //argv[1] sollte eine numerische IP-Adresse sein
        memcpy( (char *)&server.sin_addr, &addr, sizeof(addr));
    }
    else
    {
        //Computernamen oder "localhost" in IP-Adressen umwandeln
        host_info = gethostbyname(argv[1]);
        if (NULL == host_info)
        {
            addr = inet_addr( "127.0.0.1");
            memcpy( (char *)&server.sin_addr, &addr, sizeof(addr));
        }
        else
        {
            //Server-IP-Adresse
            memcpy( (char *)&server.sin_addr,
                    host_info->h_addr, host_info->h_length );
        }
    }

    //Eine IPv4-Verbindung solls werden
    server.sin_family = AF_INET;

    //Setze Portnummer
    server.sin_port = htons(_port);

    //Baue die Verbindung zum Server auf
    if(connect(sock,(struct sockaddr*)&server,sizeof(server)) <0)
        error_exit("Kann keine Verbindung zum "
                   "Server herstellen");
    
    
    return 0;
}

string Tcp::_all = "";

/**
 *  TCP-Eingabe überprüfen und gegebenenfalls verarbeiten lassen.
**/
bool Tcp::eingeben()
{
    sleep(10);
    
    char echo_buffer[RCVBUFSIZE];
    char leer[RCVBUFSIZE];
    int recv_size;

    recv_size = recv(sock, echo_buffer, RCVBUFSIZE,0);
    
    if(recv_size < 0)
        error_exit("Fehler bei recv()");

    echo_buffer[recv_size] = '\0';
    leer[recv_size] = '\0';

    std::string test1 = std::string(echo_buffer);

    int ready=select(sock_max+1, &sock, NULL, NULL, NULL);   //!! Das Problem!!
    
    if(recv_size > 0)
    {
      _all+=test1;
        
        //return 0;

        printf(echo_buffer);
      printf("\n");
      printf("=================================\n");
        return 1;
    }
    
    cout << _all << endl;
    
    _all = "";
    
    printf("\n");
    printf("=================================\n");
    
    return 1;
}

[CC (Gast)]

Der ist falsch. Wie es richtig geht steht in der man-Page, zu der ich 
Dir den Link gegeben habe. Passt ja schon allein mit den Datentypen 
nicht.

Ein Tipp: Im Link fragen sie Eingaben vom Keyboard ab (entspricht etwa 
einem Socket mit dem Wert 0).


Für den Rest: Tutorials sind dein Freund.

[CC (Gast)]

(...oder auch Bücher, welche geeignet sind, weiß ich spontan nicht. Wird 
aber viele geben.)

[CC (Gast)]

Ah, es macht auch wenig sinn, recv() VOR select() aufzurufen. Letzteres 
teilt nämlich mit, ob recv() blockieren wird oder nicht.

[c++ (Gast)]

CC schrieb:
> Ah, es macht auch wenig sinn, recv() VOR select() aufzurufen.
> Letzteres
> teilt nämlich mit, ob recv() blockieren wird oder nicht.

Mir fehlt der erste Parameter von select() Das ist das große Problem.

[Dr. Sommer (Gast)]

c++ schrieb:
> #include <stdio.h>
In C++ heißt diese Datei <cstdio>
> #include <stdlib.h>
und die <cstdlib>
> #include <string.h>
und die <cstring>
> #include <errno.h>
und die <cerrno>
> #include <string.h>
und die <cstring> - hoppla, die haben wir ja schon includet
> #include <cstring>
Uund gleich noch einmal includen.

c++ schrieb:
> #define RCVBUFSIZE 8192
In C++ muss man sich keiner Textersetzung bedienen, sondern kann echte 
Konstanten verwenden um die diversen Makro-Probleme zu vermeiden:

const size_t RCVBUFSIZE = 8192;

Wie wäre es mit Boost.Asio, das ist genau dafür gedacht was du machen 
willst:
http://www.boost.org/doc/libs/1_56_0/doc/html/boost_asio.html

[CC (Gast)]

c++ schrieb:
> Mir fehlt der erste Parameter von select() Das ist das große Problem.

Bei dir:

sock+1

Aber das ist nicht (nur) "das" große Problem.

[Rolf M. (rmagnus)]

Warum eigentlich überhaupt select()? Das ergibt doch hier überhaupt 
keinen Sinn. Das Haupt-Ziel von select() ist es, sich um mehrere fds 
gleichzeitig zu kümmern. Die gibt es hier aber gar nicht.
Es reicht, einfach den Socket non-blocking zu machen. Dann kehrt recv() 
immer ohne Wartezeit zurück, und wenn keine Daten verfügbar sind, 
liefert es -1 zurück, und errno wird auf den Wert EAGAIN gesetzt.

Dr. Sommer schrieb:
> In C++ muss man sich keiner Textersetzung bedienen, sondern kann echte
> Konstanten verwenden um die diversen Makro-Probleme zu vermeiden:
> const size_t RCVBUFSIZE = 8192;

Dann aber bitte auch nicht komplett groß scheiben, da das eigentlich das 
Erkennungszeichen für Makros ist.

c++ schrieb:
> Mir fehlt der erste Parameter von select() Das ist das große Problem.

Das große Problem ist eher, daß du noch gar nicht verstanden hast, was 
select() überhaupt tut.

[c++ (Gast)]

Rolf Magnus schrieb:
> Es reicht, einfach den Socket non-blocking zu machen. Dann kehrt recv()
> immer ohne Wartezeit zurück, und wenn keine Daten verfügbar sind,
> liefert es -1 zurück,

Genau das will ich!!! Hast da jemand einen Ansatz?

[Manuel (Gast)]

struct pollfd fd;
int res;

fd.fd = s;
fd.events = POLLIN;
res = poll(&fd, 1, 1000); // 1000 ms timeout

if (res == 0)
{
    // timeout
}
else if (res == -1)
{
    // error
}
else
{
    // implies (fd.revents & POLLIN) != 0
    recv(s,buf,sizeof(buf),0); // we can read ...
}

[Rolf Magnus (Gast)]

c++ schrieb:
> Rolf Magnus schrieb:
>> Es reicht, einfach den Socket non-blocking zu machen. Dann kehrt recv()
>> immer ohne Wartezeit zurück, und wenn keine Daten verfügbar sind,
>> liefert es -1 zurück,
>
> Genau das will ich!!! Hast da jemand einen Ansatz?

Ich hab sogar mehrere:

- man-Page lesen
- Ein Buch lesen
- Nach dem Thema googeln
- falls das Lesen von Doku untragbar ist: umsatteln auf Briefmarken 
sammeln

[c++ (Gast)]

Rolf Magnus schrieb:
> c++ schrieb:
>> Rolf Magnus schrieb:
>>> Es reicht, einfach den Socket non-blocking zu machen. Dann kehrt recv()
>>> immer ohne Wartezeit zurück, und wenn keine Daten verfügbar sind,
>>> liefert es -1 zurück,
>>
>> Genau das will ich!!! Hast da jemand einen Ansatz?
>
> Ich hab sogar mehrere:
>
> - man-Page lesen
> - Ein Buch lesen
> - Nach dem Thema googeln
> - falls das Lesen von Doku untragbar ist: umsatteln auf Briefmarken
> sammeln

Danke! Ich hasse nur leider Sockets in C++ und brauche diese für EIN 
Projekt. Und dieser ganze FD-Mist entsprach nicht im Ansatz dem, was ich 
gebraucht habe. Nach langer Suche ohne FD hab ich nun

fcntl(sock, F_SETFL, O_NONBLOCK)

gefunden, was mein Problem löst.

Rolf Magnus schrieb:
> Dann aber bitte auch nicht komplett groß scheiben, da das eigentlich das
> Erkennungszeichen für Makros ist.

Stimmt. Der gepostete Code ist Dreck, das weiß ich selbst. Der Rest des 
Projektes sieht deutlich sauberer aus. Wir sind nämlich keine Anfänger. 
Da dieser Teil aber Softwaretechnisch unser größtes Problem darstellte, 
haben wir uns erst um eine Lösung bemüht und kümmern uns nun auch in 
dieser Klasse um einen sauberen Programmierstil.


Rolf Magnus schrieb:
> Ich hab sogar mehrere:
>
> - man-Page lesen
> - Ein Buch lesen
> - Nach dem Thema googeln
> - falls das Lesen von Doku untragbar ist: umsatteln auf Briefmarken
> sammeln

Ich lese oft Doku. Das hat mir in diesem Fall leider nicht besonders 
geholfen. Da C++ keine besonders neue Sprache ist (damit wurden schon 
uralte Großrechner programmiert, lange vor TCP) , ist der ganze TCP-Kram 
nicht so in der Sprache drin, wie in anderen Programmiersprachen.
In C# oder Java ist das schon einfacher. Da tut es "ein wenig" Doku 
lesen. So hardwareferne Sprachen können wir hier aber leider nicht 
gebrauchen.

==========

Vielen Dank an alle, die nach einer Lösung gesucht haben.

[Rolf Magnus (Gast)]

c++ schrieb:
> Nach langer Suche ohne FD hab ich nunfcntl(sock, F_SETFL, O_NONBLOCK)
> gefunden, was mein Problem löst.

Um ehrlich zu sein wundert mich das. Wenn man bei google nach 
"non-blocking socket" sucht, bekommt man seitenweise Ergebnisse, wo das 
drin steht.

c++ schrieb:
> Da C++ keine besonders neue Sprache ist (damit wurden schon
> uralte Großrechner programmiert, lange vor TCP) , ist der ganze TCP-Kram
> nicht so in der Sprache drin, wie in anderen Programmiersprachen.

Bei boost gibt's ein socket-API für C++. Hab ich aber noch nicht 
ausprobiert.

[Rufus Τ. F. (rufus)]

c++ schrieb:
> Da C++ keine besonders neue Sprache ist (damit wurden schon uralte
> Großrechner programmiert, lange vor TCP)

hust

C++ gibt es effektiv* erst seit 1985, TCP ist gut zehn Jahre älter ...

Sprachbestandteil ist "der ganze TCP-Kram" aus ganz anderen Gründen 
nicht.

*) Den Namen gibt es seit '83, '85 erschien die erste Ausgabe des Buchs 
von Stroustrup