ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/OpenCL/OpenCL.pm
(Generate patch)

Comparing OpenCL/OpenCL.pm (file contents):
Revision 1.53 by root, Tue Apr 24 14:30:57 2012 UTC vs.
Revision 1.56 by root, Tue Apr 24 23:53:12 2012 UTC

376 376
377For this to work, the OpenGL library must be loaded, a GLX context must 377For this to work, the OpenGL library must be loaded, a GLX context must
378have been created and be made current, and C<dlsym> must be available and 378have been created and be made current, and C<dlsym> must be available and
379capable of finding the function via C<RTLD_DEFAULT>. 379capable of finding the function via C<RTLD_DEFAULT>.
380 380
381=head2 EVENT SYSTEM
382
383OpenCL can generate a number of (potentially) asynchronous events, for
384example, after compiling a program, to signal a context-related error or,
385perhaps most important, to signal completion of queued jobs (by setting
386callbacks on OpenCL::Event objects).
387
388To facilitate this, this module maintains an event queue - each
389time an asynchronous event happens, it is queued, and perl will be
390interrupted. This is implemented via the L<Async::Interrupt> module. In
391addition, this module has L<AnyEvent> support, so it can seamlessly
392integrate itself into many event loops.
393
394Since this module is a bit hard to understand, here are some case examples:
395
396=head3 Don't use callbacks.
397
398When your program never uses any callbacks, then there will never be any
399notifications you need to take care of, and therefore no need to worry
400about all this.
401
402You can achieve a great deal by explicitly waiting for events, or using
403barriers and flush calls. In many programs, there is no need at all to
404tinker with asynchronous events.
405
406=head3 Use AnyEvent
407
408This module automatically registers a watcher that invokes all outstanding
409event callbacks when AnyEvent is initialised (and block asynchronous
410interruptions). Using this mode of operations is the safest and most
411recommended one.
412
413To use this, simply use AnyEvent and this module normally, make sure you
414have an event loop running:
415
416 use Gtk2 -init;
417 use AnyEvent;
418
419 # initialise AnyEvent, by creating a watcher, or:
420 AnyEvent::detect;
421
422 my $e = $queue->enqueue_marker;
423 $e->cb (sub {
424 warn "opencl is finished\n";
425 })
426
427 main Gtk2;
428
429Note that this module will not initialise AnyEvent for you. Before
430AnyEvent is initialised, the module will asynchronously interrupt perl
431instead. To avoid any surprises, it's best to explicitly initialise
432AnyEvent.
433
434You can temporarily enable asynchronous interruptions (see next paragraph)
435by calling C<$OpenCL::INTERRUPT->unblock> and disable them again by
436calling C<$OpenCL::INTERRUPT->block>.
437
438=head3 Let yourself be interrupted at any time
439
440This mode is the default unless AnyEvent is loaded and initialised. In
441this mode, OpenCL asynchronously interrupts a running perl program. The
442emphasis is on both I<asynchronously> and I<running> here.
443
444Asynchronously means that perl might execute your callbacks at any
445time. For example, in the following code (I<THAT YOU SHOULD NOT COPY>),
446the C<until> loop following the marker call will be interrupted by the
447callback:
448
449 my $e = $queue->enqueue_marker;
450 my $flag;
451 $e->cb (sub { $flag = 1 });
452 1 until $flag;
453 # $flag is now 1
454
455The reason why you shouldn't blindly copy the above code is that
456busy waiting is a really really bad thing, and really really bad for
457performance.
458
459While at first this asynchronous business might look exciting, it can be
460really hard, because you need to be prepared for the callback code to be
461executed at any time, which limits the amount of things the callback code
462can do safely.
463
464This can be mitigated somewhat by using C<<
465$OpenCL::INTERRUPT->scope_block >> (see the L<Async::Interrupt>
466documentation for details).
467
468The other problem is that your program must be actively I<running> to be
469interrupted. When you calculate stuff, your program is running. When you
470hang in some C functions or other block execution (by calling C<sleep>,
471C<select>, running an event loop and so on), your program is waiting, not
472running.
473
474One way around that would be to attach a read watcher to your event loop,
475listening for events on C<< $OpenCL::INTERRUPT->pipe_fileno >>, using a
476dummy callback (C<sub { }>) to temporarily execute some perl code.
477
478That is then awfully close to using the built-in AnyEvent support above,
479though, so consider that one instead.
480
481=head3 Be creative
482
483OpenCL exports the L<Async::Interrupt> object it uses in the global
484variable C<$OpenCL::INTERRUPT>. You can configure it in any way you like.
485
486So if you want to feel like a real pro, err, wait, if you feel no risk
487menas no fun, you can experiment by implementing your own mode of
488operations.
489
381=cut 490=cut
382 491
383package OpenCL; 492package OpenCL;
384 493
385use common::sense; 494use common::sense;
495use Async::Interrupt ();
496
497our $POLL_FUNC; # set by XS
386 498
387BEGIN { 499BEGIN {
388 our $VERSION = '0.96'; 500 our $VERSION = '0.97';
389 501
390 require XSLoader; 502 require XSLoader;
391 XSLoader::load (__PACKAGE__, $VERSION); 503 XSLoader::load (__PACKAGE__, $VERSION);
392 504
393 @OpenCL::Platform::ISA = 505 @OpenCL::Platform::ISA =
440 552
441Returns all available OpenCL::Platform objects. 553Returns all available OpenCL::Platform objects.
442 554
443L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clGetPlatformIDs.html> 555L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clGetPlatformIDs.html>
444 556
445=item $ctx = OpenCL::context_from_type $properties, $type = OpenCL::DEVICE_TYPE_DEFAULT, $notify = undef 557=item $ctx = OpenCL::context_from_type $properties, $type = OpenCL::DEVICE_TYPE_DEFAULT, $callback->($err, $pvt) = $print_stderr
446 558
447Tries to create a context from a default device and platform - never worked for me. 559Tries to create a context from a default device and platform type - never worked for me.
448 560
449L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clCreateContextFromType.html> 561L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clCreateContextFromType.html>
450 562
563=item $ctx = OpenCL::context $properties, \@devices, $callback->($err, $pvt) = $print_stderr)
564
565Create a new OpenCL::Context object using the given device object(s). This
566function isn't implemented yet, use C<< $platform->context >> instead.
567
568L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clCreateContext.html>
569
451=item OpenCL::wait_for_events $wait_events... 570=item OpenCL::wait_for_events $wait_events...
452 571
453Waits for all events to complete. 572Waits for all events to complete.
454 573
455L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clWaitForEvents.html> 574L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clWaitForEvents.html>
575
576=item OpenCL::poll
577
578Checks if there are any outstanding events (see L<EVENT SYSTEM>) and
579invokes their callbacks.
580
581=item $OpenCL::INTERRUPT
582
583The L<Async::Interrupt> object used to signal asynchronous events (see
584L<EVENT SYSTEM>).
585
586=cut
587
588our $INTERRUPT = new Async::Interrupt c_cb => [$POLL_FUNC, 0];
589
590&_eq_initialise ($INTERRUPT->signal_func);
591
592=item $OpenCL::WATCHER
593
594The L<AnyEvent> watcher object used to watch for asynchronous events (see
595L<EVENT SYSTEM>). This variable is C<undef> until L<AnyEvent> has been
596loaded I<and> initialised (e.g. by calling C<AnyEvent::detect>).
597
598=cut
599
600our $WATCHER;
601
602sub _init_anyevent {
603 $INTERRUPT->block;
604 $WATCHER = AE::io ($INTERRUPT->pipe_fileno, 0, sub { $INTERRUPT->handle });
605}
606
607if (defined $AnyEvent::MODEL) {
608 _init_anyevent;
609} else {
610 push @AnyEvent::post_detect, \&_init_anyevent;
611}
456 612
457=back 613=back
458 614
459=head2 THE OpenCL::Object CLASS 615=head2 THE OpenCL::Object CLASS
460 616
472C<IV> type in your code and cast that to the correct type. 628C<IV> type in your code and cast that to the correct type.
473 629
474=cut 630=cut
475 631
476sub OpenCL::Object::id { 632sub OpenCL::Object::id {
633 ref $_[0] eq "SCALAR"
477 ${$_[0]} 634 ? ${ $_[0] }
635 : $_[0][0]
478} 636}
479 637
480=back 638=back
481 639
482=head2 THE OpenCL::Platform CLASS 640=head2 THE OpenCL::Platform CLASS
485 643
486=item @devices = $platform->devices ($type = OpenCL::DEVICE_TYPE_ALL) 644=item @devices = $platform->devices ($type = OpenCL::DEVICE_TYPE_ALL)
487 645
488Returns a list of matching OpenCL::Device objects. 646Returns a list of matching OpenCL::Device objects.
489 647
490=item $ctx = $platform->context_from_type ($properties, $type = OpenCL::DEVICE_TYPE_DEFAULT, $notify = undef) 648=item $ctx = $platform->context_from_type ($properties, $type = OpenCL::DEVICE_TYPE_DEFAULT, $callback->($err, $pvt) = $print_stderr)
491 649
492Tries to create a context. Never worked for me, and you need devices explicitly anyway. 650Tries to create a context. Never worked for me, and you need devices explicitly anyway.
493 651
494L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clCreateContextFromType.html> 652L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clCreateContextFromType.html>
495 653
496=item $ctx = $platform->context ($properties = undef, @$devices, $notify = undef) 654=item $ctx = $platform->context ($properties, \@devices, $callback->($err, $pvt) = $print_stderr)
497 655
498Create a new OpenCL::Context object using the given device object(s)- a 656Create a new OpenCL::Context object using the given device object(s)- a
499CL_CONTEXT_PLATFORM property is supplied automatically. 657CL_CONTEXT_PLATFORM property is supplied automatically.
500 658
501L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clCreateContext.html> 659L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clCreateContext.html>
841=cut 999=cut
842 1000
843sub OpenCL::Context::build_program { 1001sub OpenCL::Context::build_program {
844 my ($self, $prog, $options) = @_; 1002 my ($self, $prog, $options) = @_;
845 1003
1004 require Carp;
1005
846 $prog = $self->program_with_source ($prog) 1006 $prog = $self->program_with_source ($prog)
847 unless ref $prog; 1007 unless ref $prog;
848 1008
1009 # we build separately per device so we instantly know which one failed
849 for my $dev ($self->devices) { 1010 for my $dev ($self->devices) {
850 eval { $prog->build ($dev, $options); 1 } 1011 eval { $prog->build ([$dev], $options); 1 }
851 or Carp::croak "Building OpenCL program for device '" . $dev->name . "' failed:\n" 1012 or Carp::croak ("Building OpenCL program for device '" . $dev->name . "' failed:\n"
852 . $prog->build_log ($dev); 1013 . $prog->build_log ($dev));
853 } 1014 }
854 1015
855 $prog 1016 $prog
856} 1017}
857 1018
1349 1510
1350=head2 THE OpenCL::Program CLASS 1511=head2 THE OpenCL::Program CLASS
1351 1512
1352=over 4 1513=over 4
1353 1514
1354=item $program->build ($device, $options = "") 1515=item $program->build (\@devices = undef, $options = "", $cb->($program) = undef)
1355 1516
1356Tries to build the program with the given options. See also the 1517Tries to build the program with the given options. See also the
1357C<$ctx->build> convenience function. 1518C<$ctx->build> convenience function.
1358 1519
1520If a callback is specified, then it will be called when compilation is
1521finished. Note that many OpenCL implementations block your program while
1522compiling whether you use a callback or not. See C<build_async> if you
1523want to make sure the build is done in the background.
1524
1525Note that some OpenCL implementations atc up badly, and don't call the
1526callback in some error cases (but call it in others). This implementation
1527assumes the callback will always be called, and leaks memory if this is
1528not so. So best make sure you don't pass in invalid values.
1529
1359L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clBuildProgram.html> 1530L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clBuildProgram.html>
1531
1532=item $program->build_async (\@devices = undef, $options = "", $cb->($program) = undef)
1533
1534Similar to C<< ->build >>, except it starts a thread, and never fails (you
1535need to check the compilation status form the callback, or by polling).
1360 1536
1361=item $packed_value = $program->build_info ($device, $name) 1537=item $packed_value = $program->build_info ($device, $name)
1362 1538
1363Similar to C<< $platform->info >>, but returns build info for a previous 1539Similar to C<< $platform->info >>, but returns build info for a previous
1364build attempt for the given device. 1540build attempt for the given device.
1541 1717
1542Waits for the event to complete. 1718Waits for the event to complete.
1543 1719
1544L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clWaitForEvents.html> 1720L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clWaitForEvents.html>
1545 1721
1722=item $ev->cb ($exec_callback_type, $callback->($event, $event_command_exec_status))
1723
1724Adds a callback to the callback stack for the given event type. There is
1725no way to remove a callback again.
1726
1727L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clSetEventCallback.html>
1728
1546=item $packed_value = $ev->info ($name) 1729=item $packed_value = $ev->info ($name)
1547 1730
1548See C<< $platform->info >> for details. 1731See C<< $platform->info >> for details.
1549 1732
1550L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clGetEventInfo.html> 1733L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clGetEventInfo.html>
1610 1793
1611=over 4 1794=over 4
1612 1795
1613=item $ev->set_status ($execution_status) 1796=item $ev->set_status ($execution_status)
1614 1797
1798Sets the execution status of the user event. Can only be called once,
1799either with OpenCL::COMPLETE or a negative number as status.
1800
1615L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clSetUserEventStatus.html> 1801L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clSetUserEventStatus.html>
1616 1802
1617=back 1803=back
1618 1804
1619=cut 1805=cut

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines