2012-08-20 11:18:35 +02:00
|
|
|
/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
|
|
|
|
/*
|
|
|
|
* This file is part of the LibreOffice project.
|
|
|
|
*
|
|
|
|
* This Source Code Form is subject to the terms of the Mozilla Public
|
|
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
|
|
* file, You can obtain one at http://mozilla.org/MPL/2.0/.
|
|
|
|
*/
|
2013-02-12 11:02:47 +00:00
|
|
|
|
2012-08-20 11:18:35 +02:00
|
|
|
#include "BluetoothServer.hxx"
|
2013-02-14 12:00:11 +02:00
|
|
|
|
2013-02-14 17:07:01 +02:00
|
|
|
#include <iostream>
|
|
|
|
#include <iomanip>
|
2012-08-20 11:18:35 +02:00
|
|
|
|
2012-09-20 09:49:29 +02:00
|
|
|
#include <sal/log.hxx>
|
|
|
|
|
2012-09-18 13:19:57 +02:00
|
|
|
#if (defined(LINUX) && !defined(__FreeBSD_kernel__)) && defined(ENABLE_DBUS)
|
2012-09-20 09:54:29 +02:00
|
|
|
#include <glib.h>
|
|
|
|
#include <dbus/dbus-glib.h>
|
2012-12-06 13:00:22 +02:00
|
|
|
#include <errno.h>
|
2012-09-20 09:54:29 +02:00
|
|
|
#include <sys/unistd.h>
|
|
|
|
#include <sys/socket.h>
|
|
|
|
#include <bluetooth/bluetooth.h>
|
|
|
|
#include <bluetooth/rfcomm.h>
|
|
|
|
#define DBUS_TYPE_G_STRING_ANY_HASHTABLE (dbus_g_type_get_map( "GHashTable", G_TYPE_STRING, G_TYPE_VALUE ))
|
|
|
|
#ifndef G_VALUE_INIT
|
|
|
|
#define G_VALUE_INIT {0,{{0}}} // G_VALUE_INIT only present in glib >= 2.30
|
|
|
|
#endif
|
|
|
|
#ifndef DBusGObjectPath
|
|
|
|
#define DBusGObjectPath char // DBusGObjectPath is only present in newer version of dbus-glib
|
|
|
|
#endif
|
2013-02-14 12:00:11 +02:00
|
|
|
#include "BluetoothServiceRecord.hxx"
|
2013-02-16 12:21:09 +02:00
|
|
|
#include "BufferedStreamSocket.hxx"
|
2012-08-20 11:18:35 +02:00
|
|
|
#endif
|
|
|
|
|
2012-09-13 20:58:12 +02:00
|
|
|
#ifdef WIN32
|
2012-12-12 22:32:54 +01:00
|
|
|
// LO vs WinAPI conflict
|
|
|
|
#undef WB_LEFT
|
|
|
|
#undef WB_RIGHT
|
2012-09-13 20:58:12 +02:00
|
|
|
#include <winsock2.h>
|
|
|
|
#include <ws2bth.h>
|
2013-02-16 12:21:09 +02:00
|
|
|
#include "BufferedStreamSocket.hxx"
|
2012-09-13 20:58:12 +02:00
|
|
|
#endif
|
|
|
|
|
2013-02-14 12:00:11 +02:00
|
|
|
#ifdef MACOSX
|
2013-02-14 17:07:01 +02:00
|
|
|
#include <osl/conditn.hxx> // Include this early to avoid error as check() gets defined by some SDK header to empty
|
2013-02-14 12:00:11 +02:00
|
|
|
#include <premac.h>
|
2013-02-14 16:52:07 +02:00
|
|
|
#if MACOSX_SDK_VERSION >= 1070
|
|
|
|
#import <IOBluetooth/IOBluetooth.h>
|
|
|
|
#else
|
|
|
|
#import <CoreFoundation/CoreFoundation.h>
|
|
|
|
#import <IOBluetooth/IOBluetoothUtilities.h>
|
|
|
|
#import <IOBluetooth/objc/IOBluetoothSDPUUID.h>
|
|
|
|
#import <IOBluetooth/objc/IOBluetoothSDPServiceRecord.h>
|
|
|
|
#endif
|
2013-02-14 12:00:11 +02:00
|
|
|
#include <postmac.h>
|
2013-02-14 17:07:01 +02:00
|
|
|
#import "OSXBluetooth.h"
|
|
|
|
#include "OSXBluetoothWrapper.hxx"
|
2013-02-14 12:00:11 +02:00
|
|
|
#endif
|
|
|
|
|
2012-12-06 10:13:38 +01:00
|
|
|
#ifdef __MINGW32__
|
|
|
|
// Value taken from http://msdn.microsoft.com/en-us/library/windows/desktop/ms738518%28v=vs.85%29.aspx
|
|
|
|
#define NS_BTH 16
|
|
|
|
#endif
|
|
|
|
|
2012-08-22 12:44:42 +02:00
|
|
|
#include "Communicator.hxx"
|
|
|
|
|
2012-08-20 11:18:35 +02:00
|
|
|
using namespace sd;
|
|
|
|
|
2012-09-18 18:22:12 +02:00
|
|
|
#if (defined(LINUX) && !defined(__FreeBSD_kernel__)) && defined(ENABLE_DBUS)
|
|
|
|
DBusGProxy* bluezGetDefaultAdapter( DBusGConnection* aConnection,
|
|
|
|
const gchar* aInterfaceType = "org.bluez.Adapter" )
|
|
|
|
{
|
|
|
|
GError *aError = NULL;
|
|
|
|
|
|
|
|
DBusGProxy *aManager = NULL;
|
|
|
|
aManager = dbus_g_proxy_new_for_name( aConnection, "org.bluez", "/",
|
|
|
|
"org.bluez.Manager" );
|
|
|
|
|
|
|
|
if ( aManager == NULL )
|
|
|
|
{
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_WARN( "sdremote.bluetooth", "getting org.bluez.Manager failed" );
|
2012-09-18 18:22:12 +02:00
|
|
|
dbus_g_connection_unref( aConnection );
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
gboolean aResult;
|
2012-09-20 09:54:29 +02:00
|
|
|
DBusGObjectPath* aAdapterPath = NULL;
|
2012-09-18 18:22:12 +02:00
|
|
|
aResult = dbus_g_proxy_call( aManager, "DefaultAdapter", &aError,
|
|
|
|
G_TYPE_INVALID,
|
|
|
|
DBUS_TYPE_G_OBJECT_PATH, &aAdapterPath,
|
|
|
|
G_TYPE_INVALID);
|
|
|
|
|
|
|
|
g_object_unref( G_OBJECT( aManager ));
|
|
|
|
if ( !aResult || aError )
|
|
|
|
{
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_WARN( "sdremote.bluetooth", "getting DefaultAdapter path failed" );
|
2012-09-18 18:22:12 +02:00
|
|
|
if ( aError )
|
|
|
|
g_error_free( aError );
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
DBusGProxy *aAdapter = NULL;
|
|
|
|
aAdapter = dbus_g_proxy_new_for_name( aConnection, "org.bluez",
|
|
|
|
aAdapterPath, aInterfaceType );
|
|
|
|
g_free( aAdapterPath );
|
|
|
|
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_INFO( "sdremote.bluetooth", "DefaultAdapter retrieved" );
|
2012-09-18 18:22:12 +02:00
|
|
|
return aAdapter;
|
|
|
|
}
|
|
|
|
#endif // defined(LINUX) && defined(ENABLE_DBUS)
|
|
|
|
|
2013-02-14 17:07:01 +02:00
|
|
|
#if defined(MACOSX)
|
|
|
|
|
|
|
|
OSXBluetoothWrapper::OSXBluetoothWrapper( IOBluetoothRFCOMMChannel* channel ) :
|
|
|
|
mpChannel(channel),
|
|
|
|
mnMTU(0),
|
|
|
|
mHaveBytes(),
|
|
|
|
mMutex(),
|
|
|
|
mBuffer()
|
|
|
|
{
|
|
|
|
// silly enough, can't write more than mnMTU bytes at once
|
|
|
|
mnMTU = [channel getMTU];
|
|
|
|
|
|
|
|
SAL_INFO( "sdremote.bluetooth", "OSXBluetoothWrapper::OSXBluetoothWrapper(): mnMTU=" << mnMTU );
|
|
|
|
}
|
|
|
|
|
|
|
|
sal_Int32 OSXBluetoothWrapper::readLine( rtl::OString& aLine )
|
|
|
|
{
|
|
|
|
SAL_INFO( "sdremote.bluetooth", "OSXBluetoothWrapper::readLine()" );
|
|
|
|
|
|
|
|
while( true )
|
|
|
|
{
|
|
|
|
{
|
|
|
|
SAL_INFO( "sdremote.bluetooth", "OSXBluetoothWrapper::readLine: entering mutex" );
|
|
|
|
::osl::MutexGuard aQueueGuard( mMutex );
|
|
|
|
SAL_INFO( "sdremote.bluetooth", "OSXBluetoothWrapper::readLine: entered mutex" );
|
|
|
|
|
|
|
|
#ifdef SAL_LOG_INFO
|
|
|
|
// We should have in the sal logging some standard way to
|
|
|
|
// output char buffers with non-printables escaped.
|
|
|
|
std::ostringstream s;
|
2013-02-18 11:57:02 +02:00
|
|
|
if (mBuffer.size() > 0)
|
2013-02-14 17:07:01 +02:00
|
|
|
{
|
2013-02-18 11:57:02 +02:00
|
|
|
for (unsigned char *p = (unsigned char *) &mBuffer.front(); p != (unsigned char *) &mBuffer.front() + mBuffer.size(); p++)
|
|
|
|
{
|
|
|
|
if (*p == '\n')
|
|
|
|
s << "\\n";
|
2013-02-18 11:59:03 +02:00
|
|
|
else if (*p < ' ' || *p >= 0x7F)
|
2013-02-18 11:57:02 +02:00
|
|
|
s << "\\0x" << std::hex << std::setw(2) << std::setfill('0') << (int) *p << std::setfill(' ') << std::setw(1) << std::dec;
|
|
|
|
else
|
|
|
|
s << *p;
|
|
|
|
}
|
2013-02-14 17:07:01 +02:00
|
|
|
}
|
2013-02-18 12:50:17 +02:00
|
|
|
SAL_INFO( "sdremote.bluetooth", "OSXBluetoothWrapper::readLine mBuffer: \"" << s.str() << "\"" );
|
2013-02-14 17:07:01 +02:00
|
|
|
#endif
|
|
|
|
|
|
|
|
// got enough bytes to return a line?
|
|
|
|
std::vector<char>::iterator aIt;
|
|
|
|
if ( (aIt = find( mBuffer.begin(), mBuffer.end(), '\n' ))
|
|
|
|
!= mBuffer.end() )
|
|
|
|
{
|
|
|
|
sal_uInt64 aLocation = aIt - mBuffer.begin();
|
|
|
|
|
|
|
|
aLine = OString( &(*mBuffer.begin()), aLocation );
|
|
|
|
|
|
|
|
mBuffer.erase( mBuffer.begin(), aIt + 1 ); // Also delete the empty line
|
|
|
|
|
|
|
|
// yeps
|
|
|
|
SAL_INFO( "sdremote.bluetooth", " returning, got \"" << OStringToOUString( aLine, RTL_TEXTENCODING_UTF8 ) << "\"" );
|
|
|
|
return aLine.getLength() + 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
// nope - wait some more (after releasing the mutex)
|
|
|
|
SAL_INFO( "sdremote.bluetooth", " resetting mHaveBytes" );
|
|
|
|
mHaveBytes.reset();
|
|
|
|
SAL_INFO( "sdremote.bluetooth", " leaving mutex" );
|
|
|
|
}
|
|
|
|
|
|
|
|
SAL_INFO( "sdremote.bluetooth", " waiting for mHaveBytes" );
|
|
|
|
mHaveBytes.wait();
|
|
|
|
SAL_INFO( "sdremote.bluetooth", "OSXBluetoothWrapper::readLine: got mHaveBytes" );
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
sal_Int32 OSXBluetoothWrapper::write( const void* pBuffer, sal_uInt32 n )
|
|
|
|
{
|
|
|
|
SAL_INFO( "sdremote.bluetooth", "OSXBluetoothWrapper::write(" << pBuffer << ", " << n << ") mpChannel=" << mpChannel );
|
|
|
|
|
|
|
|
char* ptr = (char*)pBuffer;
|
|
|
|
sal_uInt32 nBytesWritten = 0;
|
|
|
|
while( nBytesWritten < n )
|
|
|
|
{
|
|
|
|
int toWrite = n - nBytesWritten;
|
|
|
|
toWrite = toWrite <= mnMTU ? toWrite : mnMTU;
|
|
|
|
if ( [mpChannel writeSync:ptr length:toWrite] != kIOReturnSuccess )
|
|
|
|
{
|
|
|
|
SAL_INFO( "sdremote.bluetooth", " [mpChannel writeSync:" << (void *) ptr << " length:" << toWrite << "] returned error, total written " << nBytesWritten );
|
|
|
|
return nBytesWritten;
|
|
|
|
}
|
|
|
|
ptr += toWrite;
|
|
|
|
nBytesWritten += toWrite;
|
|
|
|
}
|
|
|
|
SAL_INFO( "sdremote.bluetooth", " total written " << nBytesWritten );
|
|
|
|
return nBytesWritten;
|
|
|
|
}
|
|
|
|
|
|
|
|
void OSXBluetoothWrapper::appendData(void* pBuffer, size_t len)
|
|
|
|
{
|
|
|
|
SAL_INFO( "sdremote.bluetooth", "OSXBluetoothWrapper::appendData(" << pBuffer << ", " << len << ")" );
|
|
|
|
|
|
|
|
if( len )
|
|
|
|
{
|
|
|
|
SAL_INFO( "sdremote.bluetooth", "OSXBluetoothWrapper::appendData: entering mutex" );
|
|
|
|
::osl::MutexGuard aQueueGuard( mMutex );
|
|
|
|
SAL_INFO( "sdremote.bluetooth", "OSXBluetoothWrapper::appendData: entered mutex" );
|
|
|
|
mBuffer.insert(mBuffer.begin()+mBuffer.size(),
|
|
|
|
(char*)pBuffer, (char *)pBuffer+len);
|
|
|
|
SAL_INFO( "sdremote.bluetooth", " setting mHaveBytes" );
|
|
|
|
mHaveBytes.set();
|
|
|
|
SAL_INFO( "sdremote.bluetooth", " leaving mutex" );
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void incomingCallback( void *userRefCon,
|
|
|
|
IOBluetoothUserNotificationRef inRef,
|
|
|
|
IOBluetoothObjectRef objectRef )
|
|
|
|
{
|
|
|
|
(void) inRef;
|
|
|
|
|
|
|
|
SAL_INFO( "sdremote.bluetooth", "incomingCallback()" );
|
|
|
|
|
|
|
|
BluetoothServer* pServer = (BluetoothServer*)userRefCon;
|
|
|
|
|
|
|
|
IOBluetoothRFCOMMChannel* channel = [IOBluetoothRFCOMMChannel withRFCOMMChannelRef:(IOBluetoothRFCOMMChannelRef)objectRef];
|
|
|
|
|
|
|
|
OSXBluetoothWrapper* socket = new OSXBluetoothWrapper( channel);
|
|
|
|
Communicator* pCommunicator = new Communicator( socket );
|
|
|
|
pServer->addCommunicator( pCommunicator );
|
|
|
|
|
|
|
|
ChannelDelegate* delegate = [[ChannelDelegate alloc] initWithCommunicatorAndSocket: pCommunicator socket: socket];
|
|
|
|
[channel setDelegate: delegate];
|
|
|
|
[delegate retain];
|
|
|
|
|
|
|
|
pCommunicator->launch();
|
|
|
|
}
|
|
|
|
|
|
|
|
#endif // MACOSX
|
|
|
|
|
|
|
|
|
2012-11-23 17:59:41 +01:00
|
|
|
BluetoothServer::BluetoothServer( std::vector<Communicator*>* pCommunicators )
|
|
|
|
: mpCommunicators( pCommunicators )
|
2012-08-20 11:18:35 +02:00
|
|
|
{
|
|
|
|
}
|
|
|
|
|
|
|
|
BluetoothServer::~BluetoothServer()
|
|
|
|
{
|
|
|
|
}
|
|
|
|
|
2012-09-18 11:16:45 +02:00
|
|
|
bool BluetoothServer::isDiscoverable()
|
|
|
|
{
|
2012-09-18 18:22:12 +02:00
|
|
|
#if (defined(LINUX) && !defined(__FreeBSD_kernel__)) && defined(ENABLE_DBUS)
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_INFO( "sdremote.bluetooth", "BluetoothServer::isDiscoverable called" );
|
2012-09-18 18:22:12 +02:00
|
|
|
g_type_init();
|
|
|
|
gboolean aResult;
|
|
|
|
|
|
|
|
GError *aError = NULL;
|
|
|
|
|
|
|
|
DBusGConnection *aConnection = NULL;
|
|
|
|
aConnection = dbus_g_bus_get( DBUS_BUS_SYSTEM, &aError );
|
|
|
|
|
|
|
|
if ( aError != NULL ) {
|
|
|
|
g_error_free (aError);
|
2013-02-07 22:49:35 +01:00
|
|
|
SAL_INFO( "sdremote.bluetooth", "did not get DBusGConnection" );
|
2012-09-18 18:22:12 +02:00
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
DBusGProxy* aAdapter = bluezGetDefaultAdapter( aConnection );
|
|
|
|
if ( aAdapter == NULL )
|
|
|
|
{
|
|
|
|
dbus_g_connection_unref( aConnection );
|
2013-02-07 22:49:35 +01:00
|
|
|
SAL_INFO( "sdremote.bluetooth", "did not get default adaptor" );
|
2012-09-18 18:22:12 +02:00
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
2013-01-26 12:32:17 +11:00
|
|
|
GHashTable* aProperties = NULL;
|
2012-09-18 18:22:12 +02:00
|
|
|
aResult = dbus_g_proxy_call( aAdapter, "GetProperties", &aError,
|
|
|
|
G_TYPE_INVALID,
|
|
|
|
DBUS_TYPE_G_STRING_ANY_HASHTABLE, &aProperties,
|
|
|
|
G_TYPE_INVALID);
|
|
|
|
g_object_unref( G_OBJECT( aAdapter ));
|
|
|
|
dbus_g_connection_unref( aConnection );
|
|
|
|
if ( !aResult || aError )
|
|
|
|
{
|
|
|
|
if ( aError )
|
|
|
|
g_error_free( aError );
|
2013-02-07 22:49:35 +01:00
|
|
|
SAL_INFO( "sdremote.bluetooth", "did not get properties" );
|
2012-09-18 18:22:12 +02:00
|
|
|
return false;
|
|
|
|
}
|
2012-09-18 22:00:36 +02:00
|
|
|
|
|
|
|
gboolean aIsDiscoverable = g_value_get_boolean( (GValue*) g_hash_table_lookup(
|
|
|
|
aProperties, "Discoverable" ) );
|
2012-09-18 18:22:12 +02:00
|
|
|
|
2013-01-26 12:32:17 +11:00
|
|
|
g_hash_table_unref( aProperties );
|
2013-02-07 22:49:35 +01:00
|
|
|
|
|
|
|
SAL_INFO( "sdremote.bluetooth", "BluetoothServer::isDiscoverable() returns " << static_cast< bool >( aIsDiscoverable ) );
|
2012-09-18 18:22:12 +02:00
|
|
|
return aIsDiscoverable;
|
|
|
|
#else // defined(LINUX) && defined(ENABLE_DBUS)
|
|
|
|
return false;
|
|
|
|
#endif
|
2012-09-18 11:16:45 +02:00
|
|
|
}
|
|
|
|
|
2012-09-18 18:22:12 +02:00
|
|
|
void BluetoothServer::setDiscoverable( bool aDiscoverable )
|
2012-08-20 11:18:35 +02:00
|
|
|
{
|
2012-09-18 13:19:57 +02:00
|
|
|
#if (defined(LINUX) && !defined(__FreeBSD_kernel__)) && defined(ENABLE_DBUS)
|
2012-12-14 09:40:04 +02:00
|
|
|
SAL_INFO( "sdremote.bluetooth", "BluetoothServer::setDiscoverable called" );
|
2012-08-22 12:44:42 +02:00
|
|
|
g_type_init();
|
2012-09-18 18:22:12 +02:00
|
|
|
gboolean aResult;
|
2012-09-03 12:34:31 +02:00
|
|
|
|
2012-09-05 11:50:54 +02:00
|
|
|
GError *aError = NULL;
|
|
|
|
|
|
|
|
DBusGConnection *aConnection = NULL;
|
|
|
|
aConnection = dbus_g_bus_get( DBUS_BUS_SYSTEM, &aError );
|
|
|
|
|
2012-09-18 18:22:12 +02:00
|
|
|
if ( aError != NULL )
|
|
|
|
{
|
2012-09-05 11:50:54 +02:00
|
|
|
g_error_free (aError);
|
|
|
|
return;
|
2012-08-22 12:44:42 +02:00
|
|
|
}
|
|
|
|
|
2012-09-18 18:22:12 +02:00
|
|
|
DBusGProxy* aAdapter = bluezGetDefaultAdapter( aConnection );
|
|
|
|
if ( aAdapter == NULL )
|
|
|
|
{
|
|
|
|
dbus_g_connection_unref( aConnection );
|
|
|
|
return;
|
|
|
|
}
|
2012-09-05 11:50:54 +02:00
|
|
|
|
2012-09-18 18:22:12 +02:00
|
|
|
GHashTable* aProperties;
|
|
|
|
aResult = dbus_g_proxy_call( aAdapter, "GetProperties", &aError,
|
|
|
|
G_TYPE_INVALID,
|
|
|
|
DBUS_TYPE_G_STRING_ANY_HASHTABLE, &aProperties,
|
|
|
|
G_TYPE_INVALID);
|
2012-09-05 11:50:54 +02:00
|
|
|
|
2012-09-18 18:22:12 +02:00
|
|
|
if ( !aResult || aError )
|
2012-08-22 12:44:42 +02:00
|
|
|
{
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_WARN( "sdremote.bluetooth", "GetProperties failed" );
|
2012-09-18 18:22:12 +02:00
|
|
|
if ( aError )
|
2012-09-20 09:49:29 +02:00
|
|
|
{
|
2012-09-18 18:22:12 +02:00
|
|
|
g_error_free( aError );
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_WARN( "sdremote.bluetooth", "with error " << aError->message );
|
|
|
|
}
|
2012-09-18 18:22:12 +02:00
|
|
|
return;
|
|
|
|
}
|
2012-09-18 22:00:36 +02:00
|
|
|
|
|
|
|
gboolean aPowered = g_value_get_boolean( (GValue*) g_hash_table_lookup(
|
|
|
|
aProperties, "Powered" ) );
|
|
|
|
|
2013-01-26 12:32:17 +11:00
|
|
|
g_hash_table_unref( aProperties );
|
2012-09-18 18:22:12 +02:00
|
|
|
if ( !aPowered )
|
|
|
|
{
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_INFO( "sdremote.bluetooth", "Bluetooth adapter not powered, returning" );
|
2012-09-18 18:22:12 +02:00
|
|
|
g_object_unref( G_OBJECT( aAdapter ));
|
2012-09-05 11:50:54 +02:00
|
|
|
return;
|
2012-08-22 12:44:42 +02:00
|
|
|
}
|
|
|
|
|
2012-09-18 18:22:12 +02:00
|
|
|
GValue aTimeout = G_VALUE_INIT;
|
|
|
|
g_value_init( &aTimeout, G_TYPE_UINT );
|
|
|
|
g_value_set_uint( &aTimeout, 0 );
|
|
|
|
aResult = dbus_g_proxy_call( aAdapter, "SetProperty", &aError,
|
|
|
|
G_TYPE_STRING, "DiscoverableTimeout",
|
|
|
|
G_TYPE_VALUE, &aTimeout, G_TYPE_INVALID, G_TYPE_INVALID);
|
|
|
|
if ( !aResult || aError )
|
|
|
|
{
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_WARN( "sdremote.bluetooth", "SetProperty(DiscoverableTimeout) failed" );
|
2012-09-18 18:22:12 +02:00
|
|
|
if ( aError )
|
2012-09-20 09:49:29 +02:00
|
|
|
{
|
2012-09-18 18:22:12 +02:00
|
|
|
g_error_free( aError );
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_WARN( "sdremote.bluetooth", "with error " << aError->message );
|
|
|
|
}
|
2012-09-18 18:22:12 +02:00
|
|
|
return;
|
|
|
|
}
|
2012-09-03 12:34:31 +02:00
|
|
|
|
2012-09-18 18:22:12 +02:00
|
|
|
GValue aDiscoverableGValue = G_VALUE_INIT;
|
|
|
|
g_value_init( &aDiscoverableGValue, G_TYPE_BOOLEAN );
|
|
|
|
g_value_set_boolean( &aDiscoverableGValue, aDiscoverable );
|
|
|
|
aResult = dbus_g_proxy_call( aAdapter, "SetProperty", &aError,
|
|
|
|
G_TYPE_STRING, "Discoverable",
|
|
|
|
G_TYPE_VALUE, &aDiscoverableGValue, G_TYPE_INVALID, G_TYPE_INVALID);
|
|
|
|
if ( !aResult || aError )
|
2012-09-05 11:50:54 +02:00
|
|
|
{
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_WARN( "sdremote.bluetooth", "SetProperty(Discoverable) failed" );
|
2012-09-18 18:22:12 +02:00
|
|
|
if ( aError )
|
2012-09-20 09:49:29 +02:00
|
|
|
{
|
2012-09-18 18:22:12 +02:00
|
|
|
g_error_free( aError );
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_WARN( "sdremote.bluetooth", "with error " << aError->message );
|
|
|
|
}
|
2012-09-05 11:50:54 +02:00
|
|
|
return;
|
|
|
|
}
|
2012-09-03 12:34:31 +02:00
|
|
|
|
2012-09-18 18:22:12 +02:00
|
|
|
g_object_unref( G_OBJECT( aAdapter ));
|
|
|
|
dbus_g_connection_unref( aConnection );
|
|
|
|
#else // defined(LINUX) && defined(ENABLE_DBUS)
|
2012-12-05 15:06:51 +01:00
|
|
|
(void) aDiscoverable; // avoid warnings
|
2012-09-18 18:22:12 +02:00
|
|
|
#endif
|
|
|
|
}
|
|
|
|
|
2013-02-14 17:07:01 +02:00
|
|
|
void BluetoothServer::addCommunicator( Communicator* pCommunicator )
|
|
|
|
{
|
|
|
|
mpCommunicators->push_back( pCommunicator );
|
|
|
|
}
|
|
|
|
|
2012-11-23 17:59:41 +01:00
|
|
|
void SAL_CALL BluetoothServer::run()
|
2012-09-18 18:22:12 +02:00
|
|
|
{
|
2012-12-14 09:40:04 +02:00
|
|
|
SAL_INFO( "sdremote.bluetooth", "BluetoothServer::run called" );
|
2012-09-18 18:22:12 +02:00
|
|
|
#if (defined(LINUX) && !defined(__FreeBSD_kernel__)) && defined(ENABLE_DBUS)
|
|
|
|
g_type_init();
|
|
|
|
|
|
|
|
GError *aError = NULL;
|
|
|
|
|
|
|
|
DBusGConnection *aConnection = NULL;
|
|
|
|
aConnection = dbus_g_bus_get( DBUS_BUS_SYSTEM, &aError );
|
|
|
|
|
|
|
|
if ( aError != NULL ) {
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_WARN( "sdremote.bluetooth", "failed to get dbus system bus" );
|
2012-09-18 18:22:12 +02:00
|
|
|
g_error_free (aError);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
DBusGProxy* aAdapter = bluezGetDefaultAdapter( aConnection, "org.bluez.Service" );
|
2012-09-05 11:50:54 +02:00
|
|
|
if ( aAdapter == NULL )
|
2012-08-22 12:44:42 +02:00
|
|
|
{
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_WARN( "sdremote.bluetooth", "failed to retrieve default adapter" );
|
2012-09-05 11:50:54 +02:00
|
|
|
dbus_g_connection_unref( aConnection );
|
|
|
|
return;
|
2012-08-22 12:44:42 +02:00
|
|
|
}
|
2012-09-03 12:34:31 +02:00
|
|
|
|
2012-09-05 11:50:54 +02:00
|
|
|
// Add the record -- the handle can be used to release it again, but we
|
|
|
|
// don't bother as the record is automatically released when LO exits.
|
|
|
|
guint aHandle;
|
2012-09-18 18:22:12 +02:00
|
|
|
gboolean aResult = dbus_g_proxy_call( aAdapter, "AddRecord", &aError,
|
2013-02-12 11:02:47 +00:00
|
|
|
G_TYPE_STRING, bluetooth_service_record,
|
2012-09-05 11:50:54 +02:00
|
|
|
G_TYPE_INVALID,
|
|
|
|
G_TYPE_UINT, &aHandle,
|
|
|
|
G_TYPE_INVALID);
|
|
|
|
|
|
|
|
g_object_unref( G_OBJECT( aAdapter ));
|
|
|
|
dbus_g_connection_unref( aConnection );
|
|
|
|
if ( !aResult)
|
|
|
|
{
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_WARN( "sdremote.bluetooth", "SDP registration failed" );
|
2012-09-05 11:50:54 +02:00
|
|
|
return;
|
|
|
|
}
|
2012-09-03 12:34:31 +02:00
|
|
|
|
|
|
|
// ---------------- Socket code
|
2012-08-20 11:18:35 +02:00
|
|
|
int aSocket;
|
|
|
|
if ( (aSocket = socket( AF_BLUETOOTH, SOCK_STREAM, BTPROTO_RFCOMM )) < 0 )
|
|
|
|
{
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_WARN( "sdremote.bluetooth", "failed to open bluetooth socket with error " << aSocket );
|
2012-08-20 11:18:35 +02:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
sockaddr_rc aAddr;
|
|
|
|
aAddr.rc_family = AF_BLUETOOTH;
|
2012-09-03 12:34:31 +02:00
|
|
|
// BDADDR_ANY is broken, so use memset to set to 0.
|
2012-08-22 23:38:19 +02:00
|
|
|
memset( &aAddr.rc_bdaddr, 0, sizeof( aAddr.rc_bdaddr ) );
|
2012-08-22 12:44:42 +02:00
|
|
|
aAddr.rc_channel = 5;
|
2012-08-20 11:18:35 +02:00
|
|
|
|
2012-09-20 09:49:29 +02:00
|
|
|
int a;
|
|
|
|
if ( ( a = bind( aSocket, (sockaddr*) &aAddr, sizeof(aAddr) ) ) < 0 ) {
|
|
|
|
SAL_WARN( "sdremote.bluetooth", "bind failed with error" << a );
|
2012-08-20 11:18:35 +02:00
|
|
|
close( aSocket );
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2012-09-20 09:49:29 +02:00
|
|
|
if ( ( a = listen( aSocket, 1 ) ) < 0 )
|
2012-08-20 11:18:35 +02:00
|
|
|
{
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_WARN( "sdremote.bluetooth", "listen failed with error" << a );
|
2012-08-20 11:18:35 +02:00
|
|
|
close( aSocket );
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
sockaddr_rc aRemoteAddr;
|
|
|
|
socklen_t aRemoteAddrLen = sizeof(aRemoteAddr);
|
2012-09-03 12:34:31 +02:00
|
|
|
while ( true )
|
2012-08-20 11:18:35 +02:00
|
|
|
{
|
2012-12-06 11:38:03 +01:00
|
|
|
int bSocket;
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_INFO( "sdremote.bluetooth", "waiting on accept" );
|
2012-12-06 11:38:03 +01:00
|
|
|
if ( (bSocket = accept(aSocket, (sockaddr*) &aRemoteAddr, &aRemoteAddrLen)) < 0 )
|
2012-09-03 12:34:31 +02:00
|
|
|
{
|
2012-12-06 11:38:03 +01:00
|
|
|
int err = errno;
|
|
|
|
SAL_WARN( "sdremote.bluetooth", "accept failed with errno " << err );
|
2012-09-03 12:34:31 +02:00
|
|
|
close( aSocket );
|
|
|
|
return;
|
|
|
|
} else {
|
2012-09-20 09:49:29 +02:00
|
|
|
SAL_INFO( "sdremote.bluetooth", "connection accepted" );
|
2012-12-06 11:38:03 +01:00
|
|
|
Communicator* pCommunicator = new Communicator( new BufferedStreamSocket( bSocket ) );
|
2012-09-03 12:34:31 +02:00
|
|
|
mpCommunicators->push_back( pCommunicator );
|
|
|
|
pCommunicator->launch();
|
|
|
|
}
|
2012-08-20 11:18:35 +02:00
|
|
|
}
|
|
|
|
|
2012-09-13 20:58:12 +02:00
|
|
|
#elif defined(WIN32)
|
|
|
|
WORD wVersionRequested;
|
|
|
|
WSADATA wsaData;
|
2012-08-20 11:18:35 +02:00
|
|
|
|
2012-09-13 20:58:12 +02:00
|
|
|
wVersionRequested = MAKEWORD(2, 2);
|
|
|
|
|
|
|
|
if ( WSAStartup(wVersionRequested, &wsaData) )
|
|
|
|
{
|
|
|
|
return; // winsock dll couldn't be loaded
|
|
|
|
}
|
|
|
|
|
|
|
|
int aSocket = socket( AF_BTH, SOCK_STREAM, BTHPROTO_RFCOMM );
|
|
|
|
if ( !aSocket )
|
|
|
|
{
|
|
|
|
WSACleanup();
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
SOCKADDR_BTH aAddr;
|
|
|
|
aAddr.addressFamily = AF_BTH;
|
|
|
|
aAddr.btAddr = 0;
|
|
|
|
aAddr.serviceClassId = GUID_NULL;
|
|
|
|
aAddr.port = BT_PORT_ANY; // Select any free socket.
|
|
|
|
if ( bind( aSocket, (SOCKADDR*) &aAddr, sizeof(aAddr) ) == SOCKET_ERROR )
|
|
|
|
{
|
|
|
|
closesocket( aSocket );
|
|
|
|
WSACleanup();
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
SOCKADDR aName;
|
|
|
|
int aNameSize = sizeof(aAddr);
|
|
|
|
getsockname( aSocket, &aName, &aNameSize ); // Retrieve the local address and port
|
|
|
|
|
|
|
|
CSADDR_INFO aAddrInfo;
|
|
|
|
memset( &aAddrInfo, 0, sizeof(aAddrInfo) );
|
|
|
|
aAddrInfo.LocalAddr.lpSockaddr = &aName;
|
|
|
|
aAddrInfo.LocalAddr.iSockaddrLength = sizeof( SOCKADDR_BTH );
|
|
|
|
aAddrInfo.RemoteAddr.lpSockaddr = &aName;
|
|
|
|
aAddrInfo.RemoteAddr.iSockaddrLength = sizeof( SOCKADDR_BTH );
|
|
|
|
aAddrInfo.iSocketType = SOCK_STREAM;
|
|
|
|
aAddrInfo.iProtocol = BTHPROTO_RFCOMM;
|
|
|
|
|
|
|
|
// To be used for setting a custom UUID once available.
|
|
|
|
// GUID uuid;
|
|
|
|
// uuid.Data1 = 0x00001101;
|
|
|
|
// memset( &uuid, 0x1000 + UUID*2^96, sizeof( GUID ) );
|
|
|
|
// uuid.Data2 = 0;
|
|
|
|
// uuid.Data3 = 0x1000;
|
|
|
|
// ULONGLONG aData4 = 0x800000805F9B34FB;
|
|
|
|
// memcpy( uuid.Data4, &aData4, sizeof(uuid.Data4) );
|
|
|
|
|
|
|
|
WSAQUERYSET aRecord;
|
|
|
|
memset( &aRecord, 0, sizeof(aRecord));
|
|
|
|
aRecord.dwSize = sizeof(aRecord);
|
2013-02-12 17:17:37 +02:00
|
|
|
aRecord.lpszServiceInstanceName = "LibreOffice Impress Remote Control";
|
2012-09-13 20:58:12 +02:00
|
|
|
aRecord.lpszComment = "Remote control of presentations over bluetooth.";
|
|
|
|
aRecord.lpServiceClassId = (LPGUID) &SerialPortServiceClass_UUID;
|
|
|
|
aRecord.dwNameSpace = NS_BTH;
|
|
|
|
aRecord.dwNumberOfCsAddrs = 1;
|
|
|
|
aRecord.lpcsaBuffer = &aAddrInfo;
|
|
|
|
|
|
|
|
if ( WSASetService( &aRecord, RNRSERVICE_REGISTER, 0 ) == SOCKET_ERROR )
|
|
|
|
{
|
|
|
|
closesocket( aSocket );
|
|
|
|
WSACleanup();
|
|
|
|
return;
|
|
|
|
}
|
2012-08-20 11:18:35 +02:00
|
|
|
|
2012-09-13 20:58:12 +02:00
|
|
|
if ( listen( aSocket, 1 ) == SOCKET_ERROR )
|
|
|
|
{
|
|
|
|
closesocket( aSocket );
|
|
|
|
WSACleanup();
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
SOCKADDR_BTH aRemoteAddr;
|
|
|
|
int aRemoteAddrLen = sizeof(aRemoteAddr);
|
|
|
|
while ( true )
|
|
|
|
{
|
2012-12-06 10:13:38 +01:00
|
|
|
SOCKET socket;
|
|
|
|
if ( (socket = accept(aSocket, (sockaddr*) &aRemoteAddr, &aRemoteAddrLen)) == INVALID_SOCKET )
|
2012-09-13 20:58:12 +02:00
|
|
|
{
|
|
|
|
closesocket( aSocket );
|
|
|
|
WSACleanup();
|
|
|
|
return;
|
|
|
|
} else {
|
2012-12-06 10:13:38 +01:00
|
|
|
Communicator* pCommunicator = new Communicator( new BufferedStreamSocket( socket) );
|
2012-09-13 20:58:12 +02:00
|
|
|
mpCommunicators->push_back( pCommunicator );
|
|
|
|
pCommunicator->launch();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2013-02-14 12:00:11 +02:00
|
|
|
#elif defined(MACOSX)
|
|
|
|
// Build up dictionary at run-time instead of bothering with a
|
|
|
|
// .plist file, using the Objective-C API
|
|
|
|
|
|
|
|
// Compare to BluetoothServiceRecord.hxx
|
|
|
|
|
|
|
|
NSDictionary *dict =
|
|
|
|
[NSDictionary dictionaryWithObjectsAndKeys:
|
|
|
|
|
|
|
|
// Service class ID list
|
|
|
|
[NSArray arrayWithObject:
|
|
|
|
[IOBluetoothSDPUUID uuid16: kBluetoothSDPUUID16ServiceClassSerialPort]],
|
|
|
|
@"0001 - ServiceClassIDList",
|
|
|
|
|
|
|
|
// Protocol descriptor list
|
|
|
|
[NSArray arrayWithObjects:
|
|
|
|
[NSArray arrayWithObject: [IOBluetoothSDPUUID uuid16: kBluetoothSDPUUID16L2CAP]],
|
|
|
|
[NSArray arrayWithObjects:
|
|
|
|
[IOBluetoothSDPUUID uuid16: kBluetoothL2CAPPSMRFCOMM],
|
|
|
|
[NSDictionary dictionaryWithObjectsAndKeys:
|
|
|
|
[NSNumber numberWithInt: 1],
|
|
|
|
@"DataElementSize",
|
|
|
|
[NSNumber numberWithInt: 1],
|
|
|
|
@"DataElementType",
|
|
|
|
[NSNumber numberWithInt: 5], // RFCOMM port number, will be replaced if necessary automatically
|
|
|
|
@"DataElementValue",
|
|
|
|
nil],
|
|
|
|
nil],
|
|
|
|
nil],
|
|
|
|
@"0004 - Protocol descriptor list",
|
|
|
|
|
|
|
|
// Browse group list
|
|
|
|
[NSArray arrayWithObject:
|
|
|
|
[IOBluetoothSDPUUID uuid16: kBluetoothSDPUUID16ServiceClassPublicBrowseGroup]],
|
|
|
|
@"0005 - BrowseGroupList",
|
|
|
|
|
|
|
|
// Language base attribute ID list
|
|
|
|
[NSArray arrayWithObjects:
|
|
|
|
[NSData dataWithBytes: "en" length: 2],
|
|
|
|
[NSDictionary dictionaryWithObjectsAndKeys:
|
|
|
|
[NSNumber numberWithInt: 2],
|
|
|
|
@"DataElementSize",
|
|
|
|
[NSNumber numberWithInt: 1],
|
|
|
|
@"DataElementType",
|
|
|
|
[NSNumber numberWithInt: 0x006a], // encoding
|
|
|
|
@"DataElementValue",
|
|
|
|
nil],
|
|
|
|
[NSDictionary dictionaryWithObjectsAndKeys:
|
|
|
|
[NSNumber numberWithInt: 2],
|
|
|
|
@"DataElementSize",
|
|
|
|
[NSNumber numberWithInt: 1],
|
|
|
|
@"DataElementType",
|
|
|
|
[NSNumber numberWithInt: 0x0100], // offset
|
|
|
|
@"DataElementValue",
|
|
|
|
nil],
|
|
|
|
nil],
|
|
|
|
@"0006 - LanguageBaseAttributeIDList",
|
|
|
|
|
|
|
|
// Bluetooth profile descriptor list
|
|
|
|
[NSArray arrayWithObject:
|
|
|
|
[NSArray arrayWithObjects:
|
|
|
|
[IOBluetoothSDPUUID uuid16: kBluetoothSDPUUID16ServiceClassSerialPort],
|
|
|
|
[NSDictionary dictionaryWithObjectsAndKeys:
|
|
|
|
[NSNumber numberWithInt: 2],
|
|
|
|
@"DataElementSize",
|
|
|
|
[NSNumber numberWithInt: 1],
|
|
|
|
@"DataElementType",
|
|
|
|
[NSNumber numberWithInt: 0x0100], // version number ?
|
|
|
|
@"DataElementValue",
|
|
|
|
nil],
|
|
|
|
nil]],
|
|
|
|
@"0009 - BluetoothProfileDescriptorList",
|
|
|
|
|
|
|
|
// Attributes pointed to by the LanguageBaseAttributeIDList
|
|
|
|
@"LibreOffice Impress Remote Control",
|
|
|
|
@"0100 - ServiceName",
|
|
|
|
@"The Document Foundation",
|
|
|
|
@"0102 - ProviderName",
|
|
|
|
nil];
|
|
|
|
|
|
|
|
// Create service
|
|
|
|
IOBluetoothSDPServiceRecordRef serviceRecordRef;
|
|
|
|
IOReturn rc = IOBluetoothAddServiceDict((CFDictionaryRef) dict, &serviceRecordRef);
|
|
|
|
|
2013-02-14 17:07:01 +02:00
|
|
|
SAL_INFO("sdremote.bluetooth", "IOBluetoothAddServiceDict returned " << rc);
|
2013-02-14 12:00:11 +02:00
|
|
|
|
|
|
|
if (rc == kIOReturnSuccess)
|
|
|
|
{
|
|
|
|
IOBluetoothSDPServiceRecord *serviceRecord =
|
|
|
|
[IOBluetoothSDPServiceRecord withSDPServiceRecordRef: serviceRecordRef];
|
|
|
|
|
|
|
|
BluetoothRFCOMMChannelID channelID;
|
|
|
|
[serviceRecord getRFCOMMChannelID: &channelID];
|
|
|
|
|
|
|
|
BluetoothSDPServiceRecordHandle serviceRecordHandle;
|
|
|
|
[serviceRecord getServiceRecordHandle: &serviceRecordHandle];
|
|
|
|
|
2013-02-14 17:07:01 +02:00
|
|
|
// Register callback for incoming connections
|
|
|
|
IOBluetoothUserNotificationRef callbackRef =
|
|
|
|
IOBluetoothRegisterForFilteredRFCOMMChannelOpenNotifications(
|
|
|
|
incomingCallback,
|
|
|
|
this,
|
|
|
|
channelID,
|
|
|
|
kIOBluetoothUserNotificationChannelDirectionIncoming);
|
|
|
|
|
|
|
|
(void) callbackRef;
|
2013-02-14 12:00:11 +02:00
|
|
|
|
2013-02-14 17:07:01 +02:00
|
|
|
[serviceRecord release];
|
2013-02-14 12:00:11 +02:00
|
|
|
}
|
|
|
|
(void) mpCommunicators;
|
|
|
|
#else
|
2012-09-13 20:58:12 +02:00
|
|
|
(void) mpCommunicators; // avoid warnings about unused member
|
2012-08-20 11:18:35 +02:00
|
|
|
#endif
|
|
|
|
}
|
|
|
|
|
|
|
|
BluetoothServer *sd::BluetoothServer::spServer = NULL;
|
|
|
|
|
2012-08-22 12:44:42 +02:00
|
|
|
void BluetoothServer::setup( std::vector<Communicator*>* pCommunicators )
|
2012-08-20 11:18:35 +02:00
|
|
|
{
|
|
|
|
if (spServer)
|
|
|
|
return;
|
|
|
|
|
2012-08-22 12:44:42 +02:00
|
|
|
spServer = new BluetoothServer( pCommunicators );
|
2012-11-23 17:59:41 +01:00
|
|
|
spServer->create();
|
2012-08-20 11:18:35 +02:00
|
|
|
}
|
|
|
|
|
2012-08-30 13:58:15 +01:00
|
|
|
/* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|