perl/lib/Thrasher/EventLoop/Glib.pm

   1 package Thrasher::EventLoop::Glib;
   2 use strict;
   3 use warnings;
   4
   5 =head1 NAME
   6
   7 Thrasher::EventLoop::Glib - implement the Thrasher event loop with
   8 Glib's event loop
   9
  10 =head1 DESCRIPTION
  11
  12 As the NAME says. Glib's event loop is used to implement the necessary
  13 event loop primitives.
  14
  15 Note that even if you don't need libpurple, Glib is a viable event
  16 loop for you to use, if you have the necessary glib and modules
  17 installed.
  18
  19 =cut
  20
  21 use Glib qw(FALSE G_PRIORITY_DEFAULT G_PRIORITY_HIGH);
  22
  23 use base 'Thrasher::EventLoop';
  24 use Thrasher::Log qw(:all);
  25
  26 sub new {
  27     my $class = shift;
  28
  29     my $self = $class->SUPER::new(@_);
  30
  31     $self->{mainloop_ref} = Glib::MainLoop->new(undef, FALSE);
  32
  33     return $self;
  34 }
  35
  36 sub go {
  37     my $self = shift;
  38
  39     $self->{mainloop_ref}->run();
  40
  41     delete $self->{mainloop_ref};
  42 }
  43
  44 sub schedule {
  45     my $self = shift;
  46     my $closure = shift;
  47     my $timeout = shift;
  48
  49     my ($package, $filename, $line) = caller;
  50     my $name = "Task scheduled at $filename\:$line";
  51     my $new_closure = Thrasher::error_wrap($name, $closure);
  52
  53     my $token = Glib::Timeout->add($timeout, $new_closure);
  54     debug("added scheduled event: $package\:$line: $token");
  55     return $token;
  56 }
  57
  58 sub cancel_scheduled_event {
  59     my $self = shift;
  60     my $opaque_token = shift;
  61     Glib::Source->remove($opaque_token);
  62 }
  63
  64 sub add_fd_watch {
  65     my $self = shift;
  66     my $fd = shift;
  67     my $directions = shift;
  68     my $closure = shift;
  69
  70     my $condition = 0;
  71     if ($directions & $Thrasher::EventLoop::IN) {
  72         $condition = 'G_IO_IN';
  73     } elsif ($directions & $Thrasher::EventLoop::OUT) {
  74         $condition = 'G_IO_OUT';
  75     }
  76
  77     debug("Adding watch: $fd, $condition, $closure\n");
  78
  79     my ($package, $filename, $line) = caller;
  80     my $name = "FD watch created at $filename\:$line";
  81     my $new_closure = Thrasher::error_wrap($name, $closure);
  82
  83     my $token = Glib::IO->add_watch($fd, $condition, $new_closure);
  84     debug("added fd watch: ($package\:$line) $token\n");
  85     return $token;
  86 }
  87
  88 sub remove_fd_watch {
  89     my $self = shift;
  90     my $opaque_token = shift;
  91
  92     debug("Removing fd watch: $opaque_token\n");
  93
  94     Glib::Source->remove($opaque_token);
  95 }
  96
  97 sub execute_on_idle {
  98     my $self = shift;
  99     my $closure = shift;
 100
 101     my ($package, $filename, $line) = caller;
 102     my $name = "Idle execution created at $filename\:$line";
 103     my $new_closure = Thrasher::error_wrap($name, $closure);
 104
 105     Glib::Idle->add($new_closure);
 106 }
 107
 108 sub quit {
 109     my $self = shift;
 110     $self->{mainloop_ref}->quit;
 111 }
 112
 113 1;