# -*- perl -*-
#
# Copyright (C) 2004-2005 Daniel P. Berrange
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 2 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program; if not, write to the Free Software
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
#
# $Id: Connection.pm,v 1.5 2005/11/21 10:55:44 dan Exp $
=pod
=head1 NAME
Net::DBus::Binding::Connection - A connection between client and server
=head1 SYNOPSIS
Creating a connection to a server and sending a message
use Net::DBus::Binding::Connection;
my $con = Net::DBus::Binding::Connection->new(address => "unix:path=/path/to/socket");
$con->send($message);
Registering message handlers
sub handle_something {
my $con = shift;
my $msg = shift;
... do something with the message...
}
$con->register_message_handler(
"/some/object/path",
\&handle_something);
Hooking up to an event loop:
my $reactor = Net::DBus::Binding::Reactor->new();
$reactor->manage($con);
$reactor->run();
=head1 DESCRIPTION
An outgoing connection to a server, or an incoming connection
from a client. The methods defined on this module have a close
correspondance to the dbus_connection_XXX methods in the C API,
so for further details on their behaviour, the C API documentation
may be of use.
=head1 METHODS
=over 4
=cut
package Net::DBus::Binding::Connection;
use 5.006;
use strict;
use warnings;
use Carp;
use Net::DBus;
use Net::DBus::Binding::Message::MethodReturn;
=pod
=item my $con = Net::DBus::Binding::Connection->new(address => "unix:path=/path/to/socket");
Creates a new connection to the remove server specified by
the parameter C<address>.
=cut
sub new {
my $proto = shift;
my $class = ref($proto) || $proto;
my %params = @_;
my $self = {};
$self->{address} = exists $params{address} ? $params{address} : (exists $params{connection} ? "" : confess "address parameter is required");
$self->{connection} = exists $params{connection} ? $params{connection} : Net::DBus::Binding::Connection::_open($self->{address});
bless $self, $class;
$self->{connection}->_set_owner($self);
return $self;
}
=pod
=item $status = $con->is_connected();
Returns zero if the connection has been disconnected,
otherwise a positive value is returned.
=cut
sub is_connected {
my $self = shift;
return $self->{connection}->dbus_connection_get_is_connected();
}
=pod
=item $status = $con->is_authenticated();
Returns zero if the connection has not yet successfully
completed authentication, otherwise a positive value is
returned.
=cut
sub is_authenticated {
my $self = shift;
return $self->{connection}->dbus_connection_get_is_authenticated();
}
=pod
=item $con->disconnect()
Closes this connection to the remote host. This method
is called automatically during garbage collection (ie
in the DESTROY method) if the programmer forgets to
explicitly disconnect.
=cut
sub disconnect {
my $self = shift;
$self->{connection}->dbus_connection_disconnect();
}
=pod
=item $con->flush()
Blocks execution until all data in the outgoing data
stream has been sent. This method will not re-enter
the application event loop.
=cut
sub flush {
my $self = shift;
$self->{connection}->dbus_connection_flush();
}
=pod
=item $con->send($message)
Queues a message up for sending to the remote host.
The data will be sent asynchronously as the applications
event loop determines there is space in the outgoing
socket send buffer. To force immediate sending of the
data, follow this method will a call to C<flush>. This
method will return the serial number of the message,
which can be used to identify a subsequent reply (if
any).
=cut
sub send {
my $self = shift;
my $msg = shift;
return $self->{connection}->_send($msg->{message});
}
=pod
=item my $reply = $con->send_with_reply_and_block($msg, $timeout);
Queues a message up for sending to the remote host
and blocks until it has been sent, and a corresponding
reply received. The return value of this method will
be a C<Net::DBus::Binding::Message::MethodReturn> or C<Net::DBus::Binding::Message::Error>
object.
=cut
sub send_with_reply_and_block {
my $self = shift;
my $msg = shift;
my $timeout = shift;
my $reply = $self->{connection}->_send_with_reply_and_block($msg->{message}, $timeout);
my $type = $reply->dbus_message_get_type;
if ($type == &Net::DBus::Binding::Message::MESSAGE_TYPE_ERROR) {
return Net::DBus::Binding::Message::Error->new(replyto => $msg,
message => $reply);
} elsif ($type == &Net::DBus::Binding::Message::MESSAGE_TYPE_METHOD_RETURN) {
return Net::DBus::Binding::Message::MethodReturn->new(call => $msg,
message => $reply);
} else {
confess "unknown method reply type $type";
}
}
=pod
=item $con->dispatch;
Dispatches any pending messages in the incoming queue
to their message handlers. This method is typically
called on each iteration of the main application event
loop where data has been read from the incoming socket.
=cut
sub dispatch {
my $self = shift;
$self->{connection}->_dispatch();
}
=pod
=item $message = $con->borrow_message
Temporarily removes the first message from the incoming
message queue. No other thread may access the message
while it is 'borrowed', so it should be replaced in the
queue with the C<return_message> method, or removed
permanently with th C<steal_message> method as soon as
is practical.
=cut
sub borrow_message {
my $self = shift;
my $msg = $self->{connection}->dbus_connection_borrow_message();
return Net::DBus::Binding::Message->new(message => $msg);
}
=pod
=item $con->return_message($msg)
Replaces a previously borrowed message in the incoming
message queue for subsequent dispatch to registered
message handlers.
=cut
sub return_message {
my $self = shift;
my $msg = shift;
$self->{connection}->dbus_connection_return_message($msg->{message});
}
=pod
=item $con->steal_message($msg)
Permanently remove a borrowed message from the incoming
message queue. No registered message handlers will now
be run for this message.
=cut
sub steal_message {
my $self = shift;
my $msg = shift;
$self->{connection}->dbus_connection_steal_borrowed_message($msg->{message});
}
=pod
=item $msg = $con->pop_message();
Permanently removes the first message on the incoming
message queue, without running any registered message
handlers. If you have hooked the connection up to an
event loop (C<Net::DBus::Binding::Reactor> for example), you probably
don't want to be calling this method.
=cut
sub pop_message {
my $self = shift;
my $msg = $self->{connection}->dbus_connection_pop_message();
return Net::DBus::Binding::Message->new(message => $msg);
}
=pod
=item $con->set_watch_callbacks(\&add_watch, \&remove_watch, \&toggle_watch);
Register a set of callbacks for adding, removing & updating
watches in the application's event loop. Each parameter
should be a code reference, which on each invocation, will be
supplied with two parameters, the connection object and the
watch object. If you are using a C<Net::DBus::Binding::Reactor> object
as the application event loop, then the 'manage' method on
that object will call this on your behalf.
=cut
sub set_watch_callbacks {
my $self = shift;
my $add = shift;
my $remove = shift;
my $toggled = shift;
$self->{add_watch} = $add;
$self->{remove_watch} = $remove;
$self->{toggled_watch} = $toggled;
$self->{connection}->_set_watch_callbacks();
}
=pod
=item $con->set_timeout_callbacks(\&add_timeout, \&remove_timeout, \&toggle_timeout);
Register a set of callbacks for adding, removing & updating
timeouts in the application's event loop. Each parameter
should be a code reference, which on each invocation, will be
supplied with two parameters, the connection object and the
timeout object. If you are using a C<Net::DBus::Binding::Reactor> object
as the application event loop, then the 'manage' method on
that object will call this on your behalf.
=cut
sub set_timeout_callbacks {
my $self = shift;
my $add = shift;
my $remove = shift;
my $toggled = shift;
$self->{add_timeout} = $add;
$self->{remove_timeout} = $remove;
$self->{toggled_timeout} = $toggled;
$self->{connection}->_set_timeout_callbacks();
}
=pod
=item $con->register_object_path($path, \&handler)
Registers a handler for messages whose path matches
that specified in the C<$path> parameter. The supplied
code reference will be invoked with two parameters, the
connection object on which the message was received,
and the message to be processed (an instance of the
C<Net::DBus::Binding::Message> class).
=cut
sub register_object_path {
my $self = shift;
my $path = shift;
my $code = shift;
my $callback = sub {
my $con = shift;
my $msg = shift;
&$code($con, Net::DBus::Binding::Message->new(message => $msg));
};
$self->{connection}->_register_object_path($path, $callback);
}
=pod
=item $con->set_max_message_size($bytes)
Sets the maximum allowable size of a single incoming
message. Messages over this size will be rejected
prior to exceeding this threshold. The message size
is specified in bytes.
=cut
sub set_max_message_size {
my $self = shift;
my $size = shift;
$self->{connection}->dbus_connection_set_max_message_size($size);
}
=pod
=item $bytes = $con->get_max_message_size();
Retrieves the maximum allowable incoming
message size. The returned size is measured
in bytes.
=cut
sub get_max_message_size {
my $self = shift;
return $self->{connection}->dbus_connection_get_max_message_size;
}
=pod
=item $con->set_max_received_size($bytes)
Sets the maximum size of the incoming message queue.
Once this threashold is exceeded, no more messages will
be read from wire before one or more of the existing
messages are dispatched to their registered handlers.
The implication is that the message queue can exceed
this threshold by at most the size of a single message.
=cut
sub set_max_received_size {
my $self = shift;
my $size = shift;
$self->{connection}->dbus_connection_set_max_received_size($size);
}
=pod
=item $bytes $con->get_max_received_size()
Retrieves the maximum incoming message queue size.
The returned size is measured in bytes.
=cut
sub get_max_received_size {
my $self = shift;
return $self->{connection}->dbus_connection_get_max_received_size;
}
sub add_filter {
my $self = shift;
my $callback = shift;
$self->{connection}->_add_filter($callback);
}
sub _message_filter {
my $self = shift;
my $rawmsg = shift;
my $code = shift;
my $msg = Net::DBus::Binding::Message->new(message => $rawmsg);
return &$code($self, $msg);
}
1;
=pod
=back
=head1 SEE ALSO
L<Net::DBus::Binding::Server>, L<Net::DBus::Binding::Bus>, L<Net::DBus::Binding::Message::Signal>, L<Net::DBus::Binding::Message::MethodCall>, L<Net::DBus::Binding::Message::MethodReturn>, L<Net::DBus::Binding::Message::Error>
=head1 AUTHOR
Daniel Berrange E<lt>dan@berrange.comE<gt>
=head1 COPYRIGHT
Copyright 2004 by Daniel Berrange
=cut