summaryrefslogtreecommitdiff
Side-by-side diff
Diffstat (more/less context) (ignore whitespace changes)
-rw-r--r--core/applets/obex/obex.cc32
-rw-r--r--core/applets/obex/obex.h10
-rw-r--r--core/applets/obex/obex.pro8
-rw-r--r--core/applets/obex/obeximpl.cc25
-rw-r--r--core/applets/obex/obeximpl.h5
5 files changed, 44 insertions, 36 deletions
diff --git a/core/applets/obex/obex.cc b/core/applets/obex/obex.cc
index f2ceff8..582ebbc 100644
--- a/core/applets/obex/obex.cc
+++ b/core/applets/obex/obex.cc
@@ -1,104 +1,104 @@
-#include "kprocess.h"
+#include <opie/oprocess.h>
#include "obex.h"
using namespace OpieObex;
Obex::Obex( QObject *parent, const char* name )
: QObject(parent, name )
{
m_rec = 0;
m_send=0;
m_count = 0;
};
Obex::~Obex() {
delete m_rec;
delete m_send;
}
void Obex::receive() {
- m_rec = new KProcess();
+ m_rec = new OProcess();
*m_rec << "irobex_palm3";
// connect to the necessary slots
- connect(m_rec, SIGNAL(processExited(KProcess*) ),
- this, SLOT(slotExited(KProcess*) ) );
+ connect(m_rec, SIGNAL(processExited(OProcess*) ),
+ this, SLOT(slotExited(OProcess*) ) );
- connect(m_rec, SIGNAL(receivedStdout(KProcess*, char*, int ) ),
- this, SLOT(slotStdOut(KProcess*, char*, int) ) );
+ connect(m_rec, SIGNAL(receivedStdout(OProcess*, char*, int ) ),
+ this, SLOT(slotStdOut(OProcess*, char*, int) ) );
- if(!m_rec->start(KProcess::NotifyOnExit, KProcess::AllOutput) ) {
+ if(!m_rec->start(OProcess::NotifyOnExit, OProcess::AllOutput) ) {
qWarning("could not start :(");
emit done( false );
}
emit currentTry(m_count );
}
void Obex::send( const QString& fileName) {
m_count = 0;
m_file = fileName;
sendNow();
}
void Obex::sendNow(){
if ( m_count >= 15 ) { // could not send
emit error(-1 );
}
- // KProcess inititialisation
- m_send = new KProcess();
+ // OProcess inititialisation
+ m_send = new OProcess();
*m_send << "irobex_palm3";
*m_send << m_file;
// connect to slots Exited and and StdOut
- connect(m_send, SIGNAL(processExited(KProcess*) ),
- this, SLOT(slotExited(KProcess*)) );
- connect(m_send, SIGNAL(receivedStdout(KProcess*, char*, int )),
- this, SLOT(slotStdOut(KProcess*, char*, int) ) );
+ connect(m_send, SIGNAL(processExited(OProcess*) ),
+ this, SLOT(slotExited(OProcess*)) );
+ connect(m_send, SIGNAL(receivedStdout(OProcess*, char*, int )),
+ this, SLOT(slotStdOut(OProcess*, char*, int) ) );
// now start it
- if (!m_send->start(/*KProcess::NotifyOnExit, KProcess::AllOutput*/ ) ) {
+ if (!m_send->start(/*OProcess::NotifyOnExit, OProcess::AllOutput*/ ) ) {
m_count = 15;
emit error(-1 );
}
// end
m_count++;
emit currentTry( m_count );
}
-void Obex::slotExited(KProcess* proc ){
+void Obex::slotExited(OProcess* proc ){
if (proc == m_rec ) { // recieve process
recieved();
}else if ( proc == m_send ) {
sendEnd();
}
}
-void Obex::slotStdOut(KProcess* proc, char* buf, int len){
+void Obex::slotStdOut(OProcess* proc, char* buf, int len){
if ( proc == m_rec ) { // only recieve
QCString cstring( buf, len );
m_outp.append( cstring.data() );
}
}
void Obex::recieved() {
if (m_rec->normalExit() ) {
if ( m_rec->exitStatus() == 0 ) { // we got one
QString filename = parseOut();
emit receivedFile( filename );
}
}else{
emit error(-1);
};
delete m_rec;
}
void Obex::sendEnd() {
if (m_send->normalExit() ) {
if ( m_send->exitStatus() == 0 ) {
delete m_send;
m_send=0;
emit sent();
}else if (m_send->exitStatus() == 255 ) { // it failed maybe the other side wasn't ready
// let's try it again
delete m_send;
m_send = 0;
sendNow();
}
}else {
emit error( -1 );
delete m_send;
diff --git a/core/applets/obex/obex.h b/core/applets/obex/obex.h
index 17b8141..4e78015 100644
--- a/core/applets/obex/obex.h
+++ b/core/applets/obex/obex.h
@@ -1,81 +1,81 @@
#ifndef OpieObex_H
#define OpieObex_H
#include <qobject.h>
-class KProcess;
+class OProcess;
class QCopChannel;
namespace OpieObex {
class Obex : public QObject {
Q_OBJECT
public:
/**
* Obex c'tor look
*/
Obex( QObject *parent, const char* name);
/**
* d'tor
*/
~Obex();
/**
* Starting listening to irda after enabled by the applet
* a signal gets emitted when recieved a file
*/
void receive();
void send( const QString& );
signals:
/**
* a signal
* @param path The path to the recieved file
*/
void receivedFile( const QString& path);
/**
* error signal if the program couldn't be started or the
* the connection timed out
*/
void error( int );
/**
* The current try to receive data
*/
void currentTry(unsigned int);
/**
* signal sent The file got beamed to the remote location
*/
void sent();
// private slots
void done(bool);
private:
uint m_count;
QString m_file;
QString m_outp;
- KProcess *m_send;
- KProcess *m_rec;
+ OProcess *m_send;
+ OProcess *m_rec;
private slots:
/**
* send over palm obex
*/
//void send(const QString&);
// the process exited
- void slotExited(KProcess* proc) ;
- void slotStdOut(KProcess*, char*, int);
+ void slotExited(OProcess* proc) ;
+ void slotStdOut(OProcess*, char*, int);
private:
void sendNow();
QString parseOut();
void recieved();
void sendEnd();
};
};
#endif
diff --git a/core/applets/obex/obex.pro b/core/applets/obex/obex.pro
index ce07ac9..72ad78f 100644
--- a/core/applets/obex/obex.pro
+++ b/core/applets/obex/obex.pro
@@ -1,11 +1,11 @@
TEMPLATE = lib
CONFIG += qt warn_on release
-HEADERS = kprocess.h kprocctrl.h obex.h
-SOURCES = kprocess.cpp kprocctrl.cpp obex.cc
+HEADERS = obex.h obeximpl.h
+SOURCES = obex.cc obeximpl.cc
TARGET = obex
-DESTDIR = ../../plugins/applets
+DESTDIR = ../../plugins/obex
INCLUDEPATH += $(OPIEDIR)/include
DEPENDPATH += ../$(OPIEDIR)/include
-LIBS += -lqpe
+LIBS += -lqpe -lopie
VERSION = 0.0.1
diff --git a/core/applets/obex/obeximpl.cc b/core/applets/obex/obeximpl.cc
index a3004ab..fa2a30a 100644
--- a/core/applets/obex/obeximpl.cc
+++ b/core/applets/obex/obeximpl.cc
@@ -1,50 +1,57 @@
+#include <qdatastream.h>
+#include <qpe/qcom.h>
#include "obex.h"
#include "obeximpl.h"
+
+
using namespace OpieObex;
ObexImpl::ObexImpl( )
- : QObject {
+ : QObject() {
// register to a channel
+ qWarning( "c'tor" );
m_obex = new Obex(this, "obex");
m_chan = new QCopChannel("QPE/Obex" );
- cconnect(m_chan, SIGNAL(received(const QCString&, const QByteArray& ) ),
+ connect(m_chan, SIGNAL(received(const QCString&, const QByteArray& ) ),
this, SLOT(slotMessage(const QCString&, const QByteArray&) ) );
}
ObexImpl::~ObexImpl() {
delete m_obex;
delete m_chan;
}
QRESULT ObexImpl::queryInterface( const QUuid &uuid, QUnknownInterface **iface ) {
*iface = 0;
- if( uuid == IID_QUknown )
+ if( uuid == IID_QUnknown )
*iface = this;
else if( uuid == IID_ObexInterface )
*iface = this;
+ qWarning("query" );
if(*iface )
(*iface)->addRef();
return QS_OK;
}
void ObexImpl::slotMessage( const QCString& msg, const QByteArray&data ) {
- QDataStrean stream( data, IO_ReadOnly );
+ QDataStream stream( data, IO_ReadOnly );
+ qWarning("Message %s", msg.data() );
if(msg == "send(QString,QString,QString)" ) {
QString desc;
stream >> desc;
QString filename;
stream >> filename;
m_obex->send(filename );
- QCopEnvelope e ("QPE/Obex", "done(QString)" ):
- e << filename;
- }else if( ) {
-
+ QCopEnvelope e ("QPE/Obex", "done(QString)" );
+ e << filename;
+ }else if(msg == "receive(bool)" ) {
+ ;
}
}
Q_EXPORT_INTERFACE()
{
- Q_CREATE_INSTANCE( IrdaAppletImpl )
+ Q_CREATE_INSTANCE( ObexImpl )
}
diff --git a/core/applets/obex/obeximpl.h b/core/applets/obex/obeximpl.h
index 996627b..d5159e1 100644
--- a/core/applets/obex/obeximpl.h
+++ b/core/applets/obex/obeximpl.h
@@ -1,25 +1,26 @@
#ifndef OpieObexImpl_H
#define OpieObexImpl_H
+#include <qobject.h>
#include "../obexinterface.h"
#include <qpe/qcopenvelope_qws.h>
namespace OpieObex {
class Obex;
- class ObexImpl : public ObexInterface, public QObject {
+ class ObexImpl : public QObject, public ObexInterface {
Q_OBJECT
public:
ObexImpl();
- virtual ObexImpl();
+ virtual ~ObexImpl();
QRESULT queryInterface( const QUuid&, QUnknownInterface** );
Q_REFCOUNT // for reference counting (macro )
private:
ulong ref;
Obex* m_obex; // obex lib
QCopChannel *m_chan;
private slots:
void slotMessage( const QCString&, const QByteArray& );
};
};
#endif