Thanks...I will be working on this today and tonight!
The Qt4 docs say that start is a slot and the QThread example describes run() in the little example..
I *will* switch as you have directed!!!! Thanks!
The TCP/IP server mechanism works in spite of this problem.
What mystifies me is that the problem persists even if I put a sleep(10) ahead of the tcpip_server code!
Thanks again!
I got the program to work using some well placed:
QApplication::processEvents(); (see tcpip.cpp):D
To copy to clipboard, switch view to plain text mode
inside the server code...who knows which one made it work!
The code hangs up in accept() as it should in TCP/IP server code.
waiting for a client. Accept hangs up Qt 4 tight!
I did the run/start thread code as suggested!
I think it is working!
Thanks!
tcpip.h
#ifndef TCPIP_H
#define TCPIP_H
#include <QThread>
#include <QtGui/QWidget>
#include "ui_tcpip.h"
class tcpip_client;
class tcpipThread;
{
Q_OBJECT
public:
~tcpip();
private:
Ui::tcpipClass ui;
ushort port;
tcpipThread* ptcpipThreadStart;
private slots:
void StartTCPServer();
void StartTCPClient();
void str_client(tcpip_client* tcpip_x, Ui::tcpipClass ui);
};
{
Ui::tcpipClass ui;
ushort port;
public:
tcpipThread( Ui::tcpipClass uiparm, unsigned portParam):ui(uiparm),port(portParam)
{}
void run();
};
#endif // TCPIP_H
#ifndef TCPIP_H
#define TCPIP_H
#include <QThread>
#include <QtGui/QWidget>
#include "ui_tcpip.h"
class tcpip_client;
class tcpipThread;
class tcpip : public QWidget
{
Q_OBJECT
public:
tcpip(QWidget *parent = 0);
~tcpip();
private:
Ui::tcpipClass ui;
ushort port;
tcpipThread* ptcpipThreadStart;
private slots:
void StartTCPServer();
void StartTCPClient();
void str_client(tcpip_client* tcpip_x, Ui::tcpipClass ui);
void currChanged(QWidget*);
};
class tcpipThread : public QThread
{
Ui::tcpipClass ui;
ushort port;
public:
tcpipThread( Ui::tcpipClass uiparm, unsigned portParam):ui(uiparm),port(portParam)
{}
void run();
};
#endif // TCPIP_H
To copy to clipboard, switch view to plain text mode
tcpip.cpp
#include "tcpip.h"
#include "tcpip_server.cpp"
#include "tcpip_client.cpp"
#include <iostream>
//#include <QtDebug>
{
ui.setupUi(this);
connect( ui.pushButtonStartTCPServer, SIGNAL(clicked()), this, SLOT(StartTCPServer()) );
connect( ui.pushButtonStartTCPClient, SIGNAL(clicked()), this, SLOT(StartTCPClient()) );
connect( ui.pushButtonClose, SIGNAL(clicked()), this, SLOT(localClose()) );
ui.
listWidgetServer->addItem
(QString("server constructor"));
}
//
tcpip::~tcpip()
{
delete ptcpipThreadStart;
}
void tcpip::StartTCPServer()
{
ui.
listWidgetServer->addItem
(QString("server1 StartTCPServer"));
bool ok = true;
QString qstr
= ui.
lineEditTCPIPServerPortServer->text
();
port = qstr.toInt(&ok);
//qDebug()<<" server port "<<port;
ui.lineEditServerStatus->setText("server started");
tcpipThread* ptcpipThreadStart = new tcpipThread(ui, port);
ptcpipThreadStart->start();
}
// ignore the following
void tcpip::StartTCPClient() // not part of the server...ignore
{
ui.
listWidgetClient->addItem
(QString("client StartTCPClient"));
bool ok = true;
QString qstr
= ui.
lineEditTCPIPServerPortClient->text
();
//QApplication::processEvents();
ushort port = qstr.toInt(&ok);
//qDebug()<<"client port = "<<port;
tcpip_client* p_client = new tcpip_client((int)19999,port,FALSE, ui);
str_client(p_client, ui); /* process the request */
close();
}
//
#define MAXLINE 512
// str_client is the client processing program
// particular to the application and depends on
// what the server is doing
void tcpip::str_client(tcpip_client* tcpip_x, Ui::tcpipClass ui)
{
int n;
char sendline[MAXLINE], recvline[MAXLINE + 1];
bool done=FALSE;
while (!done)
{
cout<<"enter keyboard string"<<endl;
cin.getline(sendline,256);
n = strlen(sendline);
if(n==0) break;
sendline[n] = '\n'; /* newline terminate */
sendline[n+1] = 0; /* newline terminate */
n++;
// use our client object to write to the server
ui.
listWidgetClient->addItem
(QString("client constructorstr_client"));
tcpip_x->tcp_write(sendline,n);
cout<<"sendline:"<<sendline<<endl;
/*
* Now read a line from the socket and write it to
* our standard output.
*/
n = tcpip_x->tcp_read(recvline);
recvline[n] = '\n'; /* null terminate */
recvline[n+1] = 0; /* null terminate */
n++;
cout<<"bytes received "<<n;
cout<<"client received:echo = "<<recvline<<endl;
}
}
void tcpip
::currChanged(QWidget*){};
void tcpipThread::run()
{
tcpip_server* p_serv = new tcpip_server((int)19999,port,tcpip_server::str_echo, ui);
qDebug()<<"should not happen before client calls in...back from CTOR";
delete p_serv;
}
#include "tcpip.h"
#include "tcpip_server.cpp"
#include "tcpip_client.cpp"
#include <iostream>
//#include <QtDebug>
tcpip::tcpip(QWidget *parent)
: QWidget(parent)
{
ui.setupUi(this);
connect( ui.pushButtonStartTCPServer, SIGNAL(clicked()), this, SLOT(StartTCPServer()) );
connect( ui.pushButtonStartTCPClient, SIGNAL(clicked()), this, SLOT(StartTCPClient()) );
connect( ui.pushButtonClose, SIGNAL(clicked()), this, SLOT(localClose()) );
ui.listWidgetServer->addItem(QString("server constructor"));
}
//
tcpip::~tcpip()
{
delete ptcpipThreadStart;
}
void tcpip::StartTCPServer()
{
ui.listWidgetServer->addItem(QString("server1 StartTCPServer"));
QApplication::processEvents();
bool ok = true;
QString qstr = ui.lineEditTCPIPServerPortServer->text();
port = qstr.toInt(&ok);
//qDebug()<<" server port "<<port;
ui.lineEditServerStatus->setText("server started");
QApplication::processEvents();
tcpipThread* ptcpipThreadStart = new tcpipThread(ui, port);
ptcpipThreadStart->start();
}
// ignore the following
void tcpip::StartTCPClient() // not part of the server...ignore
{
ui.listWidgetClient->addItem(QString("client StartTCPClient"));
bool ok = true;
QString qstr = ui.lineEditTCPIPServerPortClient->text();
//QApplication::processEvents();
ushort port = qstr.toInt(&ok);
//qDebug()<<"client port = "<<port;
tcpip_client* p_client = new tcpip_client((int)19999,port,FALSE, ui);
str_client(p_client, ui); /* process the request */
close();
}
//
#define MAXLINE 512
// str_client is the client processing program
// particular to the application and depends on
// what the server is doing
void tcpip::str_client(tcpip_client* tcpip_x, Ui::tcpipClass ui)
{
int n;
char sendline[MAXLINE], recvline[MAXLINE + 1];
bool done=FALSE;
while (!done)
{
cout<<"enter keyboard string"<<endl;
cin.getline(sendline,256);
n = strlen(sendline);
if(n==0) break;
sendline[n] = '\n'; /* newline terminate */
sendline[n+1] = 0; /* newline terminate */
n++;
// use our client object to write to the server
ui.listWidgetClient->addItem(QString("client constructorstr_client"));
tcpip_x->tcp_write(sendline,n);
cout<<"sendline:"<<sendline<<endl;
/*
* Now read a line from the socket and write it to
* our standard output.
*/
n = tcpip_x->tcp_read(recvline);
recvline[n] = '\n'; /* null terminate */
recvline[n+1] = 0; /* null terminate */
n++;
cout<<"bytes received "<<n;
cout<<"client received:echo = "<<recvline<<endl;
}
}
void tcpip::currChanged(QWidget*){};
void tcpipThread::run()
{
tcpip_server* p_serv = new tcpip_server((int)19999,port,tcpip_server::str_echo, ui);
qDebug()<<"should not happen before client calls in...back from CTOR";
delete p_serv;
}
To copy to clipboard, switch view to plain text mode
tcpip_server.cpp
#include "inet.h"
#include <iostream>
#include <sstream>
#include <exception>
using namespace std;
#include "thread.cpp"
#include "sock_io.cpp"
#include "tstash.h"
#include <QtDebug>
typedef void* (*p_VOID_FUNCT)(void*);
class tcpip_server {
static int socketfd, newsocketfd;
socklen_t clilen;
struct sockaddr_in cli_addr, serv_addr;
ushort port;
// struct sock_addr_in accept_ip_struct;
int accept_ip_address;
int client_ip_address;
Ui::tcpipClass ui;
public:
static bool running;
void localClose();
static void* str_echo(void* p_void);
// struct sock_addr_in client_ip_struct;
public:
tcpip_server(int accept_ip_addr,
ushort port_port,
p_VOID_FUNCT p_void_funct, Ui::tcpipClass uip):
accept_ip_address(accept_ip_addr),
port(port_port),
ui(uip)
{
int setreuse=1;
int istatus;
//
// server constructor section
//
/*
* Open a TCP socket (an Internet stream socket).
*/
if ( (socketfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
{
qDebug()<<"socketfd = socket(AF_INET, SOCK_STREAM, 0)) < 0";
return;
}
qDebug()<<"socketfd = socket(AF_INET, SOCK_STREAM, 0))"<<socketfd;
int errorDup = dup2(socketfd,20);
qDebug()<<"errorDup"<<errorDup;
qDebug()<<"socketfd = socket(AF_INET, SOCK_STREAM, 0))"<<socketfd;
/*
* Bind our local address so that the client can send to us.
*/
memset((char *) &serv_addr,0, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
serv_addr.sin_port = htons(SERV_TCP_PORT);
if(istatus = setsockopt(socketfd, SOL_SOCKET, SO_REUSEADDR,
(char *) &setreuse, sizeof(setreuse)))
{
qDebug()<<"setsockopt";
return;
}
if (bind(socketfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0)
{
qDebug()<<"bind";
return;
}
listen(socketfd, 5);
tstash<sock_io> vector_psio;
void* p_void = NULL;
running = true;
while(1)
{
clilen = sizeof(cli_addr);
newsocketfd = accept(socketfd, (struct sockaddr *) &cli_addr,
&clilen);
if (newsocketfd < 0)
{
return;
}
sock_io* p_sio = new sock_io( newsocketfd);
p_void = (void*)p_sio;
tthread* p_thread = new tthread( p_void_funct, p_void);
p_thread->run();
}
}
// destructor
~tcpip_server()
{
close(socketfd);
}
};// end of class declaration
#define MAXLINE 512
bool tcpip_server::running = true;
int tcpip_server::socketfd = 0;
int tcpip_server::newsocketfd = 0;
void* tcpip_server::str_echo(void* p_void)
{
sock_io* p_sio = (sock_io*)p_void;
int n;
char line[MAXLINE];
const char* pline = line;
bool exitNow = false;
do
{
n = p_sio->tcp_read(line);
if(!n)
{
running = false;
close(socketfd);
close(newsocketfd);
exit(0);
}
line[n] = '\n';
line[n+1] = 0;
n++;
qstr.trimmed();
qDebug()<<"_____"<<qstr<<"_________";
{
qDebug()<<"close detected";
running = false;
close(socketfd);
close(newsocketfd);
exitNow = true;
break;
}
p_sio->tcp_write(line, n);
} while(1);
void* p_void_exit=0;
delete p_sio;
pthread_exit(p_void_exit);
if (exitNow) exit(0);
return p_void_exit;
}
void tcpip_server::localClose()
{
running = false;
close(socketfd);
close(newsocketfd);
}
#include "inet.h"
#include <iostream>
#include <sstream>
#include <exception>
using namespace std;
#include "thread.cpp"
#include "sock_io.cpp"
#include "tstash.h"
#include <QtDebug>
typedef void* (*p_VOID_FUNCT)(void*);
class tcpip_server {
static int socketfd, newsocketfd;
socklen_t clilen;
struct sockaddr_in cli_addr, serv_addr;
ushort port;
// struct sock_addr_in accept_ip_struct;
int accept_ip_address;
int client_ip_address;
Ui::tcpipClass ui;
public:
static bool running;
void localClose();
static void* str_echo(void* p_void);
// struct sock_addr_in client_ip_struct;
public:
tcpip_server(int accept_ip_addr,
ushort port_port,
p_VOID_FUNCT p_void_funct, Ui::tcpipClass uip):
accept_ip_address(accept_ip_addr),
port(port_port),
ui(uip)
{
int setreuse=1;
int istatus;
//
// server constructor section
//
/*
* Open a TCP socket (an Internet stream socket).
*/
if ( (socketfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
{
qDebug()<<"socketfd = socket(AF_INET, SOCK_STREAM, 0)) < 0";
return;
}
qDebug()<<"socketfd = socket(AF_INET, SOCK_STREAM, 0))"<<socketfd;
int errorDup = dup2(socketfd,20);
qDebug()<<"errorDup"<<errorDup;
qDebug()<<"socketfd = socket(AF_INET, SOCK_STREAM, 0))"<<socketfd;
/*
* Bind our local address so that the client can send to us.
*/
memset((char *) &serv_addr,0, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
serv_addr.sin_port = htons(SERV_TCP_PORT);
if(istatus = setsockopt(socketfd, SOL_SOCKET, SO_REUSEADDR,
(char *) &setreuse, sizeof(setreuse)))
{
qDebug()<<"setsockopt";
return;
}
if (bind(socketfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0)
{
qDebug()<<"bind";
return;
}
listen(socketfd, 5);
tstash<sock_io> vector_psio;
void* p_void = NULL;
running = true;
while(1)
{
QApplication::processEvents();
clilen = sizeof(cli_addr);
newsocketfd = accept(socketfd, (struct sockaddr *) &cli_addr,
&clilen);
if (newsocketfd < 0)
{
return;
}
sock_io* p_sio = new sock_io( newsocketfd);
p_void = (void*)p_sio;
tthread* p_thread = new tthread( p_void_funct, p_void);
p_thread->run();
}
}
// destructor
~tcpip_server()
{
close(socketfd);
}
};// end of class declaration
#define MAXLINE 512
bool tcpip_server::running = true;
int tcpip_server::socketfd = 0;
int tcpip_server::newsocketfd = 0;
void* tcpip_server::str_echo(void* p_void)
{
sock_io* p_sio = (sock_io*)p_void;
int n;
char line[MAXLINE];
const char* pline = line;
bool exitNow = false;
do
{
n = p_sio->tcp_read(line);
if(!n)
{
running = false;
close(socketfd);
close(newsocketfd);
exit(0);
}
line[n] = '\n';
line[n+1] = 0;
n++;
QString qstr(pline);
qstr.trimmed();
qDebug()<<"_____"<<qstr<<"_________";
if (qstr == QString("close"))
{
qDebug()<<"close detected";
running = false;
close(socketfd);
close(newsocketfd);
exitNow = true;
break;
}
p_sio->tcp_write(line, n);
} while(1);
void* p_void_exit=0;
delete p_sio;
pthread_exit(p_void_exit);
if (exitNow) exit(0);
return p_void_exit;
}
void tcpip_server::localClose()
{
running = false;
close(socketfd);
close(newsocketfd);
}
To copy to clipboard, switch view to plain text mode
cannot write to QListWidget or QLineEdit
Reply With Quote
Originally Posted by landonmkelsey
rocessEvents(); didn't help!
Bookmarks