jeena/dbus-cplusplus
1
0
Fork 0
Code Issues Pull requests Projects Packages Wiki Activity Actions

SourceForge Patches ID: 2701443 - Add methods to adjust timeout. Submitted: Oron Peled ( oron ) - 2009-03-21 23:27:55 CET

Browse source
This commit is contained in:
Andreas Volz 2010-06-03 20:44:32 +02:00
parent 7889c46e57
commit d083d07167
3 changed files with 25 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

10
include/dbus-c++/object.h
View file

@ -52,6 +52,10 @@ public:
inline Connection &conn(); inline Connection &conn();
void set_timeout(int new_timeout = -1);
inline int get_timeout() const;
private: private:
DXXAPILOCAL virtual bool handle_message(const Message &) = 0; DXXAPILOCAL virtual bool handle_message(const Message &) = 0;
@ -63,6 +67,7 @@ private:
Connection _conn; Connection _conn;
DBus::Path _path; DBus::Path _path;
std::string _service; std::string _service;
int _default_timeout;
}; };
/* /*
@ -83,6 +88,11 @@ const std::string &Object::service() const
return _service; return _service;
} }
int Object::get_timeout() const
{
return _default_timeout;
}
/* /*
*/ */

7
src/eventloop-integration.cpp
View file

@ -109,8 +109,11 @@ Timeout *BusDispatcher::add_timeout(Timeout::Internal *ti)
bt->expired = new Callback<BusDispatcher, void, DefaultTimeout &>(this, &BusDispatcher::timeout_expired); bt->expired = new Callback<BusDispatcher, void, DefaultTimeout &>(this, &BusDispatcher::timeout_expired);
bt->data(bt); bt->data(bt);
debug_log("added timeout %p (%s) interval=%d", debug_log("added timeout %p (%s) (%d millies)",
bt, ((Timeout *)bt)->enabled() ? "on":"off", ((Timeout *)bt)->interval()); bt,
((Timeout*)bt)->enabled() ? "on":"off",
((Timeout*)bt)->interval()
);
return bt; return bt;
} }

12
src/object.cpp
View file

@ -40,7 +40,7 @@
using namespace DBus; using namespace DBus;
Object::Object(Connection &conn, const Path &path, const char *service) Object::Object(Connection &conn, const Path &path, const char *service)
: _conn(conn), _path(path), _service(service ? service : "") : _conn(conn), _path(path), _service(service ? service : ""), _default_timeout(-1)
{ {
} }
@ -48,6 +48,14 @@ Object::~Object()
{ {
} }
void Object::set_timeout(int new_timeout)
{
debug_log("%s: %d millies", __PRETTY_FUNCTION__, new_timeout);
if(new_timeout < 0 && new_timeout != -1)
throw ErrorInvalidArgs("Bad timeout, cannot set it");
_default_timeout = new_timeout;
}
struct ObjectAdaptor::Private struct ObjectAdaptor::Private
{ {
static void unregister_function_stub(DBusConnection *, void *); static void unregister_function_stub(DBusConnection *, void *);
@ -329,7 +337,7 @@ Message ObjectProxy::_invoke_method(CallMessage &call)
if (call.destination() == NULL) if (call.destination() == NULL)
call.destination(service().c_str()); call.destination(service().c_str());
return conn().send_blocking(call); return conn().send_blocking(call, get_timeout());
} }
bool ObjectProxy::_invoke_method_noreply(CallMessage &call) bool ObjectProxy::_invoke_method_noreply(CallMessage &call)