| -rw-r--r-- | core/obex/obex.cpp | 187 |
1 files changed, 187 insertions, 0 deletions
diff --git a/core/obex/obex.cpp b/core/obex/obex.cpp new file mode 100644 index 0000000..36634ec --- a/dev/null +++ b/core/obex/obex.cpp @@ -0,0 +1,187 @@ + +#include "obex.h" + +/* OPIE */ +#include <opie2/oprocess.h> +#include <opie2/odebug.h> + +/* QT */ +#include <qfileinfo.h> + + + +using namespace OpieObex; + +using namespace Opie::Core; +/* TRANSLATOR OpieObex::Obex */ + +Obex::Obex( QObject *parent, const char* name ) + : QObject(parent, name ) +{ + m_rec = 0; + m_send=0; + m_count = 0; + m_receive = false; + connect( this, SIGNAL(error(int) ), // for recovering to receive + SLOT(slotError() ) ); + connect( this, SIGNAL(sent(bool) ), + SLOT(slotError() ) ); +}; +Obex::~Obex() { + delete m_rec; + delete m_send; +} +void Obex::receive() { + m_receive = true; + m_outp = QString::null; + m_rec = new OProcess(); + *m_rec << "irobex_palm3"; + // connect to the necessary slots + connect(m_rec, SIGNAL(processExited(Opie::Core::OProcess*) ), + this, SLOT(slotExited(Opie::Core::OProcess*) ) ); + + connect(m_rec, SIGNAL(receivedStdout(Opie::Core::OProcess*, char*, int ) ), + this, SLOT(slotStdOut(Opie::Core::OProcess*, char*, int) ) ); + + if(!m_rec->start(OProcess::NotifyOnExit, OProcess::AllOutput) ) { + emit done( false ); + delete m_rec; + m_rec = 0; + } +} + +void Obex::send( const QString& fileName) { // if currently receiving stop it send receive + m_count = 0; + m_file = fileName; + if (m_rec != 0 ) { + if (m_rec->isRunning() ) { + emit error(-1 ); + delete m_rec; + m_rec = 0; + + }else{ + emit error( -1 ); // we did not delete yet but it's not running slotExited is pending + return; + } + } + sendNow(); +} +void Obex::sendNow(){ + if ( m_count >= 25 ) { // could not send + emit error(-1 ); + emit sent(false); + return; + } + // OProcess inititialisation + m_send = new OProcess(); + m_send->setWorkingDirectory( QFileInfo(m_file).dirPath(true) ); + + *m_send << "irobex_palm3"; + *m_send << QFile::encodeName(QFileInfo(m_file).fileName()); + + // connect to slots Exited and and StdOut + connect(m_send, SIGNAL(processExited(Opie::Core::OProcess*) ), + this, SLOT(slotExited(Opie::Core::OProcess*)) ); + connect(m_send, SIGNAL(receivedStdout(Opie::Core::OProcess*, char*, int )), + this, SLOT(slotStdOut(Opie::Core::OProcess*, char*, int) ) ); + + // now start it + if (!m_send->start(/*OProcess::NotifyOnExit, OProcess::AllOutput*/ ) ) { + m_count = 25; + emit error(-1 ); + delete m_send; + m_send=0; + } + // end + m_count++; + emit currentTry( m_count ); +} + +void Obex::slotExited(OProcess* proc ){ + if (proc == m_rec ) // receive process + received(); + else if ( proc == m_send ) + sendEnd(); + +} +void Obex::slotStdOut(OProcess* proc, char* buf, int len){ + if ( proc == m_rec ) { // only receive + QByteArray ar( len ); + memcpy( ar.data(), buf, len ); + m_outp.append( ar ); + } +} + +void Obex::received() { + if (m_rec->normalExit() ) { + if ( m_rec->exitStatus() == 0 ) { // we got one + QString filename = parseOut(); + emit receivedFile( filename ); + } + }else{ + emit done(false); + }; + delete m_rec; + m_rec = 0; + receive(); +} + +void Obex::sendEnd() { + if (m_send->normalExit() ) { + if ( m_send->exitStatus() == 0 ) { + delete m_send; + m_send=0; + emit sent(true); + }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; + m_send = 0; + } +} +QString Obex::parseOut( ){ + QString path; + QStringList list = QStringList::split("\n", m_outp); + QStringList::Iterator it; + for (it = list.begin(); it != list.end(); ++it ) { + if ( (*it).startsWith("Wrote" ) ) { + int pos = (*it).findRev('(' ); + if ( pos > 0 ) { + + path = (*it).remove( pos, (*it).length() - pos ); + path = path.mid(6 ); + path = path.stripWhiteSpace(); + } + } + } + return path; +} +/** + * when sent is done slotError is called we will start receive again + */ +void Obex::slotError() { + if ( m_receive ) + receive(); +}; +void Obex::setReceiveEnabled( bool receive ) { + if ( !receive ) { // + m_receive = false; + shutDownReceive(); + } +} + +void Obex::shutDownReceive() { + if (m_rec != 0 ) { + if (m_rec->isRunning() ) { + emit error(-1 ); + delete m_rec; + m_rec = 0; + } + } + +} |