| -rw-r--r-- | noncore/net/opietooth/lib/device.cc | 30 | ||||
| -rw-r--r-- | noncore/net/opietooth/lib/device.h | 12 | ||||
| -rw-r--r-- | noncore/net/opietooth/lib/lib.pro | 5 | ||||
| -rw-r--r-- | noncore/net/opietooth/lib/manager.cc | 99 | ||||
| -rw-r--r-- | noncore/net/opietooth/lib/manager.h | 29 |
5 files changed, 127 insertions, 48 deletions
diff --git a/noncore/net/opietooth/lib/device.cc b/noncore/net/opietooth/lib/device.cc index e3d7f3b..5234996 100644 --- a/noncore/net/opietooth/lib/device.cc +++ b/noncore/net/opietooth/lib/device.cc @@ -1,7 +1,7 @@ #include <signal.h> -#include "kprocess.h" +#include <opie/oprocess.h> #include "device.h" @@ -40,17 +40,17 @@ void Device::attach(){ if(m_process == 0 ){ m_output.resize(0); qWarning("new process to create" ); - m_process = new KProcess(); + m_process = new OProcess(); *m_process << "hciattach"; *m_process << "-p"; *m_process << m_device << m_mode; - connect(m_process, SIGNAL( processExited(KProcess*) ), - this, SLOT( slotExited(KProcess* ) ) ); - connect(m_process, SIGNAL( receivedStdout(KProcess*, char*, int) ), - this, SLOT(slotStdOut(KProcess*,char*,int ) ) ); - connect(m_process, SIGNAL(receivedStderr(KProcess*, char*, int ) ), - this, SLOT(slotStdErr(KProcess*,char*,int) ) ); - if(!m_process->start(KProcess::NotifyOnExit, KProcess::AllOutput ) ){ + connect(m_process, SIGNAL( processExited(OProcess*) ), + this, SLOT( slotExited(OProcess* ) ) ); + connect(m_process, SIGNAL( receivedStdout(OProcess*, char*, int) ), + this, SLOT(slotStdOut(OProcess*,char*,int ) ) ); + connect(m_process, SIGNAL(receivedStderr(OProcess*, char*, int ) ), + this, SLOT(slotStdErr(OProcess*,char*,int) ) ); + if(!m_process->start(OProcess::NotifyOnExit, OProcess::AllOutput ) ){ qWarning("Could not start" ); delete m_process; m_process = 0; @@ -74,7 +74,7 @@ bool Device::isLoaded()const{ QString Device::devName()const { return QString::fromLatin1("hci0"); }; -void Device::slotExited( KProcess* proc) +void Device::slotExited( OProcess* proc) { qWarning("prcess exited" ); if(proc== m_process ){ @@ -88,11 +88,11 @@ void Device::slotExited( KProcess* proc) // now hciconfig hci0 up ( determine hciX FIXME) // and call hciconfig hci0 up // FIXME hardcoded to hci0 now :( - m_hci = new KProcess( ); + m_hci = new OProcess( ); *m_hci << "hciconfig"; *m_hci << "hci0 up"; - connect(m_hci, SIGNAL( processExited(KProcess*) ), - this, SLOT( slotExited(KProcess* ) ) ); + connect(m_hci, SIGNAL( processExited(OProcess*) ), + this, SLOT( slotExited(OProcess* ) ) ); if(!m_hci->start() ){ qWarning("could not start" ); m_attached = false; @@ -125,7 +125,7 @@ void Device::slotExited( KProcess* proc) m_hci = 0; } } -void Device::slotStdOut(KProcess* proc, char* chars, int len) +void Device::slotStdOut(OProcess* proc, char* chars, int len) { qWarning("std out" ); if( len <1 ) @@ -136,7 +136,7 @@ void Device::slotStdOut(KProcess* proc, char* chars, int len) m_output.append( string.data() ); } } -void Device::slotStdErr(KProcess*, char*, int ) +void Device::slotStdErr(OProcess*, char*, int ) { qWarning("std err" ); } diff --git a/noncore/net/opietooth/lib/device.h b/noncore/net/opietooth/lib/device.h index 8498b14..c0e2658 100644 --- a/noncore/net/opietooth/lib/device.h +++ b/noncore/net/opietooth/lib/device.h @@ -8,7 +8,7 @@ #include <sys/types.h> -class KProcess; +class OProcess; namespace OpieTooth { /** * Device takes care of attaching serial @@ -65,16 +65,16 @@ namespace OpieTooth { */ void device(const QString& device, bool up ); private slots: - virtual void slotExited( KProcess* ); - virtual void slotStdOut(KProcess*, char*, int ); - virtual void slotStdErr(KProcess*, char*, int ); + virtual void slotExited( OProcess* ); + virtual void slotStdOut(OProcess*, char*, int ); + virtual void slotStdErr(OProcess*, char*, int ); private: class Private; Private *d; QString m_device; bool m_attached:1; - KProcess* m_hci; - KProcess* m_process; + OProcess* m_hci; + OProcess* m_process; QString m_devId; QString m_mode; pid_t pid; diff --git a/noncore/net/opietooth/lib/lib.pro b/noncore/net/opietooth/lib/lib.pro index a70c7ab..f2cde06 100644 --- a/noncore/net/opietooth/lib/lib.pro +++ b/noncore/net/opietooth/lib/lib.pro @@ -1,8 +1,9 @@ TEMPLATE = lib CONFIG += qte warn_on release -HEADERS = kprocctrl.h kprocess.h device.h manager.h remotedevice.h services.h -SOURCES = kprocctrl.cpp kprocess.cpp device.cc manager.cc remotedevice.cc services.cc +HEADERS = device.h manager.h remotedevice.h services.h +SOURCES = device.cc manager.cc remotedevice.cc services.cc TARGET = opietooth INCLUDEPATH += $(OPIEDIR)/include DESTDIR = $(QTDIR)/lib$(PROJMAK) +LIBS = -lopie #VERSION = 0.0.0 diff --git a/noncore/net/opietooth/lib/manager.cc b/noncore/net/opietooth/lib/manager.cc index 882af81..eeeab19 100644 --- a/noncore/net/opietooth/lib/manager.cc +++ b/noncore/net/opietooth/lib/manager.cc @@ -1,34 +1,49 @@ +#include <opie/oprocess.h> #include "manager.h" using namespace OpieTooth; -Manager::Manager( const QString& ) +Manager::Manager( const QString& dev ) : QObject() { - + m_device = dev; + m_hcitool = 0; + m_sdp = 0; } Manager::Manager( Device* dev ) : QObject() { - + m_hcitool = 0; + m_sdp = 0; } Manager::Manager() : QObject() { - + m_hcitool = 0; + m_sdp = 0; } Manager::~Manager(){ - + delete m_hcitool; + delete m_sdp; } void Manager::setDevice( const QString& dev ){ - + m_device = dev; } void Manager::setDevice( Device* dev ){ } void Manager::isConnected( const QString& device ){ + OProcess* l2ping = new OProcess(); + l2ping->setName( device.latin1() ); + *l2ping << "l2ping" << "-c1" << device; + connect(l2ping, SIGNAL(processExited(OProcess* ) ), + this, SLOT(slotProcessExited(OProcess*) ) ); + if (!l2ping->start() ) { + emit connected( device, false ); + delete l2ping; + } } void Manager::isConnected( Device* dev ){ @@ -44,26 +59,76 @@ void Manager::searchDevices(Device* d ){ } void Manager::addService(const QString& name ){ - -} -void Manager::addServices(const QStringList& ){ - + OProcess proc; + proc << "sdptool" << "add" << name; + bool bo = true; + if (!proc.start(OProcess::DontCare ) ) + bo = false; + emit addedService( name, bo ); +} +void Manager::addServices(const QStringList& list){ + QStringList::ConstIterator it; + for (it = list.begin(); it != list.end(); ++it ) + addService( (*it) ); } void Manager::removeService( const QString& name ){ - -} -void Manager::removeServices( const QStringList& ){ - + OProcess prc; + prc << "sdptool" << "del" << name; + bool bo = true; + if (!prc.start(OProcess::DontCare ) ) + bo = false; + emit removedService( name, bo ); +} +void Manager::removeServices( const QStringList& list){ + QStringList::ConstIterator it; + for (it = list.begin(); it != list.end(); ++it ) + removeService( (*it) ); } void Manager::searchServices( const QString& remDevice ){ + OProcess *m_sdp =new OProcess(); + *m_sdp << "sdptool" << "browse" << remDevice; + m_sdp->setName( remDevice.latin1() ); + connect(m_sdp, SIGNAL(processExited(OProcess*) ), + this, SLOT(slotSDPExited(OProcess* ) ) ); + connect(m_sdp, SIGNAL(receivedStdout(OProcess*, char*, int ) ), + this, SLOT(slotSDPOut(OProcess*, char*, int) ) ); + if (!m_sdp->start() ) { + delete m_sdp; + Services::ValueList list; + emit foundServices( remDevice, list ); + } +} +void Manager::searchServices( const RemoteDevices& dev){ + searchServices( dev.mac() ); +} +QString Manager::toDevice( const QString& mac ){ } -void Manager::searchServices( const RemoteDevices& ){ +QString Manager::toMac( const QString &device ){ } -QString Manager::toDevice( const QString& mac ){ +void Manager::slotProcessExited(OProcess* proc ) { + bool conn= false; + if (proc->normalExit() && proc->exitStatus() == 0 ) + conn = true; + QString name = QString::fromLatin1(proc->name() ); + emit connected( name, conn ); + delete proc; } -QString Manager::toMac( const QString &device ){ +void Manager::slotSDPOut(OProcess* proc, char* ch, int len) +{ + QCString str(ch, len+1 ); + QMap<QString, QString>::Iterator it; + it = m_out.find(proc->name() ); + if ( it != m_out.end() ) { + QString string = it.data(); + string.append( str ); + m_out.replace( proc->name(), string ); + } } +void Manager::slotSDPExited( OProcess* proc) +{ + delete proc; +} diff --git a/noncore/net/opietooth/lib/manager.h b/noncore/net/opietooth/lib/manager.h index 6c5e27f..03375c5 100644 --- a/noncore/net/opietooth/lib/manager.h +++ b/noncore/net/opietooth/lib/manager.h @@ -4,17 +4,19 @@ #include <qobject.h> #include <qstring.h> +#include <qmap.h> #include <qvaluelist.h> #include "remotedevice.h" #include "services.h" +class OProcess; namespace OpieTooth { class Device; /** Manager manages a blueZ device (hci0 for example) * with Manager you can control the things you * could do from command line in a OO and asynchronus - * way. + * way. */ class Manager : public QObject { Q_OBJECT @@ -27,7 +29,7 @@ Q_OBJECT /** c'tor * @param dev The Device to be managed * We don't care of Device so you need to delete it - */ + */ Manager( Device* dev ); /** * c'tor @@ -48,7 +50,8 @@ Q_OBJECT * is asynchron * If device is empty it will take the currently managed * device and see if it's up - * for Remote devices it will ping and see + * for Remote devices it will ping and see. + * @param either mac or hciX */ void isConnected(const QString& device= QString::null ); /** @@ -56,8 +59,8 @@ Q_OBJECT */ void isConnected(Device *dev ); - /** this search for devices reachable from the - * currently managed device + /** this searchs for devices reachable from the + * currently managed device * or from device if @param device is not empty */ void searchDevices(const QString& device= QString::null ); @@ -89,7 +92,7 @@ Q_OBJECT /** * search for services on a remote device - * + * */ void searchServices( const QString& remDevice ); /** @@ -103,10 +106,20 @@ Q_OBJECT // device either mac or dev name // the first device is the device which you access void connected( const QString& device, bool connected ); - void addedService( const QString& device, const QString& service, bool added ); - void removedService( const QString& device, const QString& service, bool removed ); + void addedService( const QString& service, bool added ); + void removedService( const QString& service, bool removed ); void foundServices( const QString& device, Services::ValueList ); void foundDevices( const QString& device, RemoteDevices::ValueList ); + void foundNothing( const QString& device ); +private slots: + void slotProcessExited(OProcess* ); + void slotSDPExited(OProcess*); + void slotSDPOut(OProcess*, char*, int); + private: + OProcess *m_hcitool; + OProcess *m_sdp; // not only one + QString m_device; + QMap<QString, QString> m_out; }; }; |