summaryrefslogtreecommitdiff
path: root/x11/ipc/client
Side-by-side diff
Diffstat (limited to 'x11/ipc/client') (more/less context) (show whitespace changes)
-rw-r--r--x11/ipc/client/ocopclient.cpp21
-rw-r--r--x11/ipc/client/ocopclient.h4
2 files changed, 24 insertions, 1 deletions
diff --git a/x11/ipc/client/ocopclient.cpp b/x11/ipc/client/ocopclient.cpp
index 43e426c..ac6e4a3 100644
--- a/x11/ipc/client/ocopclient.cpp
+++ b/x11/ipc/client/ocopclient.cpp
@@ -4,4 +4,5 @@
#include <unistd.h>
#include <sys/socket.h>
+#include <sys/types.h>
#include <sys/un.h>
@@ -17,13 +18,23 @@ OCOPClient::OCOPClient( const QString& path, QObject* obj )
: QObject( obj )
{
+ m_tries = 0;
init(QFile::encodeName(path) );
}
OCOPClient::~OCOPClient() {
+ delete m_notify;
close( m_socket );
}
+void OCOPClient::init() {
+ // failed start ther server NOW!!!
+ startUP();
+ QCString str;
+ init(str );
+}
void OCOPClient::init( const QCString& ) {
+ m_tries++;
struct sockaddr_un unix_adr;
if ( (m_socket = socket(PF_UNIX, SOCK_STREAM, 0) ) < 0 ) {
qWarning("could not socket");
+ if ( m_tries < 8 )
QTimer::singleShot(400, this,SLOT(init() ) );
return;
@@ -37,4 +48,5 @@ void OCOPClient::init( const QCString& ) {
qWarning("could not connect %d", errno );
close( m_socket );
+ if ( m_tries < 8 )
QTimer::singleShot(400, this, SLOT(init() ) );
return;
@@ -128,2 +140,11 @@ void OCOPClient::call( const OCOPPacket& pack ) {
write(m_socket, pack.content().data(), pack.content().size() );
}
+void OCOPClient::startUP() {
+ qWarning("Start me up");
+ pid_t pi = fork();
+ if ( pi == 0 ) {
+ setsid();
+ execlp("opie-ipc", "opie-ipc", NULL );
+ _exit(1);
+ }
+}
diff --git a/x11/ipc/client/ocopclient.h b/x11/ipc/client/ocopclient.h
index e9544b9..53018a5 100644
--- a/x11/ipc/client/ocopclient.h
+++ b/x11/ipc/client/ocopclient.h
@@ -45,7 +45,9 @@ signals:
void called(const QCString&, const QCString&, const QByteArray& );
private slots:
+ void init();
void init(const QCString& pa);
void newData();
private:
+ void startUP();
OCOPPacket packet()const;
void call( const OCOPPacket& );
@@ -53,5 +55,5 @@ private:
QSocketNotifier* m_notify;
int m_socket;
-private slots:
+ int m_tries;
};