# $Id: Glib.pm,v 1.3 2006/04/23 08:37:41 joern Exp $

#-----------------------------------------------------------------------
# Copyright (C) 2002-2006 Jörn Reder <joern AT zyn.de>.
# All Rights Reserved. See file COPYRIGHT for details.
# 
# This module is part of Event::RPC, which is free software; you can
# redistribute it and/or modify it under the same terms as Perl itself.
#-----------------------------------------------------------------------

package Event::RPC::Loop::Glib;

use base qw( Event::RPC::Loop );

use strict;
use Glib;

sub get_glib_main_loop		{ shift->{glib_main_loop}		}
sub set_glib_main_loop		{ shift->{glib_main_loop}	= $_[1]	}

sub add_io_watcher {
	my $self = shift;
	my %par = @_;
	my ($fh, $cb, $desc, $poll) = @par{'fh','cb','desc','poll'};

	my $cond = $poll eq 'r' ?
		['G_IO_IN', 'G_IO_HUP']:
		['G_IO_OUT','G_IO_HUP'];
	
	return Glib::IO->add_watch ($fh->fileno, $cond, sub { &$cb(); 1 } );
}

sub del_io_watcher {
	my $self = shift;
	my ($watcher) = @_;

	Glib::Source->remove ($watcher);

	1;
}

sub add_timer {
	my $self = shift;
	my %par = @_;
	my  ($interval, $after, $cb, $desc) =
	@par{'interval','after','cb','desc'};

	die "interval and after can't be used together"
		if $interval && $after;

	if ( $interval ) {
		return Glib::Timeout->add (
			$interval * 1000,
			sub { &$cb(); 1 }
		);
	} else {
		return Glib::Timeout->add (
			$after * 1000,
			sub { &$cb(); 0 }
		);
	}

	1;
}

sub del_timer {
	my $self = shift;
	my ($timer) = @_;
	
	Glib::Source->remove($timer);
	
	1;
}

sub enter {
	my $self = shift;
	
	Glib->install_exception_handler(sub {
		print "Event::RPC::Loop::Glib caught an exception: $@\n";
		1;
	});
	
	my $main_loop = Glib::MainLoop->new;
	$self->set_glib_main_loop($main_loop);
	
	$main_loop->run;

	1;
}

sub leave {
	my $self = shift;
	
	$self->get_glib_main_loop->quit;

	1;
}

1;

__END__

=head1 NAME

Event::RPC::Loop::Glib - Glib mainloop for Event::RPC

=head1 SYNOPSIS

  use Event::RPC::Server;
  use Event::RPC::Loop::Glib;
  
  my $server = Event::RPC::Server->new (
      ...
      loop => Event::RPC::Loop::Glib->new(),
      ...
  );

  $server->start;

=head1 DESCRIPTION

This modules implements a mainloop using Glib for the
Event::RPC::Server module. It implements the interface
of Event::RPC::Loop. Please refer to the manpage of
Event::RPC::Loop for details.

=head1 AUTHORS

  Jörn Reder <joern at zyn dot de>

=head1 COPYRIGHT AND LICENSE

Copyright (C) 2002-2006 by Joern Reder, All Rights Reserved.

This library is free software; you can redistribute it
and/or modify it under the same terms as Perl itself.

=cut