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

Comparing OpenCL/OpenCL.pm (file contents):
Revision 1.51 by root, Tue Apr 24 13:45:58 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
490=cut
491
492package OpenCL;
493
494use common::sense;
495use Async::Interrupt ();
496
497our $POLL_FUNC; # set by XS
498
499BEGIN {
500 our $VERSION = '0.97';
501
502 require XSLoader;
503 XSLoader::load (__PACKAGE__, $VERSION);
504
505 @OpenCL::Platform::ISA =
506 @OpenCL::Device::ISA =
507 @OpenCL::Context::ISA =
508 @OpenCL::Queue::ISA =
509 @OpenCL::Memory::ISA =
510 @OpenCL::Sampler::ISA =
511 @OpenCL::Program::ISA =
512 @OpenCL::Kernel::ISA =
513 @OpenCL::Event::ISA = OpenCL::Object::;
514
515 @OpenCL::Buffer::ISA =
516 @OpenCL::Image::ISA = OpenCL::Memory::;
517
518 @OpenCL::BufferObj::ISA = OpenCL::Buffer::;
519
520 @OpenCL::Image2D::ISA =
521 @OpenCL::Image3D::ISA =
522 @OpenCL::Image2DArray::ISA =
523 @OpenCL::Image1D::ISA =
524 @OpenCL::Image1DArray::ISA =
525 @OpenCL::Image1DBuffer::ISA = OpenCL::Image::;
526
527 @OpenCL::UserEvent::ISA = OpenCL::Event::;
528}
529
381=head2 THE OpenCL PACKAGE 530=head2 THE OpenCL PACKAGE
382 531
383=over 4 532=over 4
384 533
385=item $int = OpenCL::errno 534=item $int = OpenCL::errno
403 552
404Returns all available OpenCL::Platform objects. 553Returns all available OpenCL::Platform objects.
405 554
406L<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>
407 556
408=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
409 558
410Tries 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.
411 560
412L<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>
413 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
414=item OpenCL::wait_for_events $wait_events... 570=item OpenCL::wait_for_events $wait_events...
415 571
416Waits for all events to complete. 572Waits for all events to complete.
417 573
418L<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>
419 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}
612
420=back 613=back
421 614
615=head2 THE OpenCL::Object CLASS
616
617This is the base class for all objects in the OpenCL module. The only
618method it implements is the C<id> method, which is only useful if you want
619to interface to OpenCL on the C level.
620
621=over 4
622
623=item $iv = $obj->id
624
625OpenCL objects are represented by pointers or integers on the C level. If
626you want to interface to an OpenCL object directly on the C level, then
627you need this value, which is returned by this method. You should use an
628C<IV> type in your code and cast that to the correct type.
629
630=cut
631
632sub OpenCL::Object::id {
633 ref $_[0] eq "SCALAR"
634 ? ${ $_[0] }
635 : $_[0][0]
636}
637
638=back
639
422=head2 THE OpenCL::Platform CLASS 640=head2 THE OpenCL::Platform CLASS
423 641
424=over 4 642=over 4
425 643
426=item @devices = $platform->devices ($type = OpenCL::DEVICE_TYPE_ALL) 644=item @devices = $platform->devices ($type = OpenCL::DEVICE_TYPE_ALL)
427 645
428Returns a list of matching OpenCL::Device objects. 646Returns a list of matching OpenCL::Device objects.
429 647
430=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)
431 649
432Tries 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.
433 651
434L<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>
435 653
436=item $ctx = $platform->context ($properties = undef, @$devices, $notify = undef) 654=item $ctx = $platform->context ($properties, \@devices, $callback->($err, $pvt) = $print_stderr)
437 655
438Create 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
439CL_CONTEXT_PLATFORM property is supplied automatically. 657CL_CONTEXT_PLATFORM property is supplied automatically.
440 658
441L<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>
781=cut 999=cut
782 1000
783sub OpenCL::Context::build_program { 1001sub OpenCL::Context::build_program {
784 my ($self, $prog, $options) = @_; 1002 my ($self, $prog, $options) = @_;
785 1003
1004 require Carp;
1005
786 $prog = $self->program_with_source ($prog) 1006 $prog = $self->program_with_source ($prog)
787 unless ref $prog; 1007 unless ref $prog;
788 1008
1009 # we build separately per device so we instantly know which one failed
789 for my $dev ($self->devices) { 1010 for my $dev ($self->devices) {
790 eval { $prog->build ($dev, $options); 1 } 1011 eval { $prog->build ([$dev], $options); 1 }
791 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"
792 . $prog->build_log ($dev); 1013 . $prog->build_log ($dev));
793 } 1014 }
794 1015
795 $prog 1016 $prog
796} 1017}
797 1018
1000 1221
1001Yeah. 1222Yeah.
1002 1223
1003L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clEnqueueCopyBufferToImage.html>. 1224L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clEnqueueCopyBufferToImage.html>.
1004 1225
1226=item $ev = $queue->enqueue_fill_buffer ($mem, $pattern, $offset, $size, ...)
1227
1228Fills the given buffer object with repeated applications of C<$pattern>,
1229starting at C<$offset> for C<$size> octets.
1230
1231L<http://www.khronos.org/registry/cl/sdk/1.2/docs/man/xhtml/clEnqueueFillBuffer.html>
1232
1233=item $ev = $queue->enqueue_fill_image ($img, $r, $g, $b, $a, $x, $y, $z, $width, $height, $depth, ...)
1234
1235Fills the given image area with the given rgba colour components. The
1236components are normally floating point values between C<0> and C<1>,
1237except when the image channel data type is a signe dor unsigned
1238unnormalised format, in which case the range is determined by the format.
1239
1240L<http://www.khronos.org/registry/cl/sdk/1.2/docs/man/xhtml/clEnqueueFillImage.html>
1241
1005=item $ev = $queue->enqueue_task ($kernel, $wait_events...) 1242=item $ev = $queue->enqueue_task ($kernel, $wait_events...)
1006 1243
1007L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clEnqueueTask.html> 1244L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clEnqueueTask.html>
1008 1245
1009=item $ev = $queue->enqueue_nd_range_kernel ($kernel, @$global_work_offset, @$global_work_size, @$local_work_size, $wait_events...) 1246=item $ev = $queue->enqueue_nd_range_kernel ($kernel, @$global_work_offset, @$global_work_size, @$local_work_size, $wait_events...)
1177OpenCL::Image1DArray, OpenCL::Image1DBuffer, OpenCL::Image2D, 1414OpenCL::Image1DArray, OpenCL::Image1DBuffer, OpenCL::Image2D,
1178OpenCL::Image2DArray and OpenCL::Image3D. 1415OpenCL::Image2DArray and OpenCL::Image3D.
1179 1416
1180=over 4 1417=over 4
1181 1418
1182=item $packed_value = $ev->image_info ($name) 1419=item $packed_value = $image->image_info ($name)
1183 1420
1184See C<< $platform->info >> for details. 1421See C<< $platform->info >> for details.
1185 1422
1186The reason this method is not called C<info> is that there already is an 1423The reason this method is not called C<info> is that there already is an
1187C<< ->info >> method inherited from C<OpenCL::Memory>. 1424C<< ->info >> method inherited from C<OpenCL::Memory>.
1188 1425
1189L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clGetImageInfo.html> 1426L<http://www.khronos.org/registry/cl/sdk/1.1/docs/man/xhtml/clGetImageInfo.html>
1190 1427
1428=item ($channel_order, $channel_data_type) = $image->format
1429
1430Returns the channel order and type used to create the image by calling
1431C<clGetImageInfo> with C<CL_IMAGE_FORMAT>.
1432
1191=for gengetinfo begin image 1433=for gengetinfo begin image
1192 1434
1193=item $int = $image->element_size 1435=item $int = $image->element_size
1194 1436
1195Calls C<clGetImageInfo> with C<CL_IMAGE_ELEMENT_SIZE> and returns the result. 1437Calls C<clGetImageInfo> with C<CL_IMAGE_ELEMENT_SIZE> and returns the result.
1268 1510
1269=head2 THE OpenCL::Program CLASS 1511=head2 THE OpenCL::Program CLASS
1270 1512
1271=over 4 1513=over 4
1272 1514
1273=item $program->build ($device, $options = "") 1515=item $program->build (\@devices = undef, $options = "", $cb->($program) = undef)
1274 1516
1275Tries to build the program with the given options. See also the 1517Tries to build the program with the given options. See also the
1276C<$ctx->build> convenience function. 1518C<$ctx->build> convenience function.
1277 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
1278L<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).
1279 1536
1280=item $packed_value = $program->build_info ($device, $name) 1537=item $packed_value = $program->build_info ($device, $name)
1281 1538
1282Similar to C<< $platform->info >>, but returns build info for a previous 1539Similar to C<< $platform->info >>, but returns build info for a previous
1283build attempt for the given device. 1540build attempt for the given device.
1460 1717
1461Waits for the event to complete. 1718Waits for the event to complete.
1462 1719
1463L<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>
1464 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
1465=item $packed_value = $ev->info ($name) 1729=item $packed_value = $ev->info ($name)
1466 1730
1467See C<< $platform->info >> for details. 1731See C<< $platform->info >> for details.
1468 1732
1469L<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>
1529 1793
1530=over 4 1794=over 4
1531 1795
1532=item $ev->set_status ($execution_status) 1796=item $ev->set_status ($execution_status)
1533 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
1534L<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>
1535 1802
1536=back 1803=back
1537 1804
1538=cut 1805=cut
1539
1540package OpenCL;
1541
1542use common::sense;
1543
1544BEGIN {
1545 our $VERSION = '0.96';
1546
1547 require XSLoader;
1548 XSLoader::load (__PACKAGE__, $VERSION);
1549
1550 @OpenCL::Buffer::ISA =
1551 @OpenCL::Image::ISA = OpenCL::Memory::;
1552
1553 @OpenCL::BufferObj::ISA = OpenCL::Buffer::;
1554
1555 @OpenCL::Image2D::ISA =
1556 @OpenCL::Image3D::ISA =
1557 @OpenCL::Image2DArray::ISA =
1558 @OpenCL::Image1D::ISA =
1559 @OpenCL::Image1DArray::ISA =
1560 @OpenCL::Image1DBuffer::ISA = OpenCL::Image::;
1561
1562 @OpenCL::UserEvent::ISA = OpenCL::Event::;
1563}
1564 1806
15651; 18071;
1566 1808
1567=head1 AUTHOR 1809=head1 AUTHOR
1568 1810

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines