/dports/devel/p5-MCE/MCE-1.876/lib/MCE/ |
H A D | Subs.pm | 19 use MCE; 20 use MCE::Relay; 62 return $MCE::MCE->restart_worker(@_); 70 sub mce_run (@) { return $MCE::MCE->run(@_); } 73 sub mce_spawn ( ) { return $MCE::MCE->spawn(); } 80 sub mce_last ( ) { return $MCE::MCE->last(); } 81 sub mce_next ( ) { return $MCE::MCE->next(); } 85 sub mce_sync ( ) { return $MCE::MCE->sync(); } 91 sub mce_do (@) { return $MCE::MCE->do(@_); } 104 sub mce_pid ( ) { return $MCE::MCE->pid(); } [all …]
|
H A D | Core.pod | 4 MCE::Core - Documentation describing the core MCE API 16 use MCE; 34 MCE->say("Hello from " . MCE->wid); 49 use MCE; 199 # use MCE (or) use MCE; (or) use MCE; 218 # (i.e. MCE->process, MCE->run) 356 use MCE; 371 use MCE 1132 Output from MCE->sendto('STDERR/STDOUT', ...), MCE->printf, MCE->print, and 1568 L<MCE::Candy>. Stubs exist in MCE which load MCE::Candy automatically. [all …]
|
H A D | Candy.pm | 7 package MCE::Candy; 49 my $x = shift; my $self = ref($x) ? $x : $MCE::MCE; 52 MCE::_validate_runstate($self, 'MCE::forchunk'); 64 MCE::_croak('MCE::forchunk: (input_data) is not specified') 79 my $x = shift; my $self = ref($x) ? $x : $MCE::MCE; 82 MCE::_validate_runstate($self, 'MCE::foreach'); 96 MCE::_croak('MCE::foreach: (input_data) is not specified') 112 my $x = shift; my $self = ref($x) ? $x : $MCE::MCE; 115 MCE::_validate_runstate($self, 'MCE::forseq'); 127 MCE::_croak('MCE::forseq: (sequence) is not specified') [all …]
|
H A D | Examples.pod | 47 use MCE; 93 use MCE; 115 use MCE::Loop; 142 use MCE; 198 use MCE; 226 use MCE::Loop; 264 use MCE; 795 use MCE; 936 use MCE; 1163 use MCE; [all …]
|
/dports/devel/p5-MCE/MCE-1.876/t/ |
H A D | 04_prio_que_worker.t | 15 MCE::Flow->init( 90 $q = MCE::Queue->new( type => $MCE::Queue::FIFO ); 155 MCE::Flow->finish; 161 $q = MCE::Queue->new( type => $MCE::Queue::LIFO ); 226 MCE::Flow->finish; 232 $q = MCE::Queue->new( 233 porder => $MCE::Queue::HIGHEST, type => $MCE::Queue::FIFO 258 MCE::Flow->finish; 264 $q = MCE::Queue->new( 265 porder => $MCE::Queue::LOWEST, type => $MCE::Queue::FIFO [all …]
|
H A D | 04_norm_que_worker.t | 15 MCE::Flow->init( 88 @a = (); $q = MCE::Queue->new( queue => \@a, type => $MCE::Queue::FIFO ); 103 MCE->do('check_enqueue', 'fifo, check enqueue'); 109 MCE->do('check_dequeue_fifo', @r); 113 MCE->do('check_clear', 'fifo, check clear'); 154 MCE::Flow->finish; 160 @a = (); $q = MCE::Queue->new( queue => \@a, type => $MCE::Queue::LIFO ); 175 MCE->do('check_enqueue', 'lifo, check enqueue'); 181 MCE->do('check_dequeue_lifo', @r); 185 MCE->do('check_clear', 'lifo, check clear'); [all …]
|
H A D | 05_mce_child_max_workers.t | 13 sub MCE::Util::get_ncpu { return 16; } 21 MCE::Child->init(max_workers => 0); 24 MCE::Child->max_workers(5); 27 MCE::Child->max_workers(20); 35 is(MCE::Child->max_workers(), 16, 45 is(MCE::Child->max_workers(), 1, 49 MCE::Child->max_workers('1%'); 50 is(MCE::Child->max_workers(), 1, 54 MCE::Child->max_workers('25%'); 55 is(MCE::Child->max_workers(), 4, [all …]
|
H A D | 03_max_workers.t | 14 sub MCE::Util::get_ncpu { return 16; } 21 my $mce = MCE->new(max_workers => 0); 24 $mce = MCE->new(max_workers => 5); 27 $mce = MCE->new(max_workers => 20); 70 $mce = MCE->new(user_tasks => [ 98 $mce = MCE->new(max_workers => '1%'); 103 $mce = MCE->new(max_workers => '25%'); 123 $mce = MCE->new(user_tasks => [ 145 sub { MCE->gather('a'.MCE->task_wid()); }, # 1 worker 146 sub { MCE->gather('b'.MCE->task_wid()); }; # 4 workers [all …]
|
H A D | 06_relay.t | 29 my $ind = MCE->wid - 1; 37 MCE::Flow->finish; 39 my @data = MCE->relay_final; 55 my $key = MCE->wid; 63 MCE::Flow->finish; 83 MCE->gather( $n ); 88 MCE::Flow->finish; 90 my $val = MCE->relay_final; 120 MCE->relay( sub { 122 MCE->gather( "ἔλθε μοι καὶ νῦν".MCE->wid ); [all …]
|
/dports/devel/p5-MCE/MCE-1.876/ |
H A D | META.yml | 18 name: MCE 26 MCE: 29 MCE::Candy: 44 MCE::Child: 71 MCE::Flow: 74 MCE::Grep: 77 MCE::Loop: 80 MCE::Map: 104 MCE::Step: 110 MCE::Subs: [all …]
|
H A D | MANIFEST | 11 lib/MCE.pm 12 lib/MCE.pod 13 lib/MCE/Candy.pm 14 lib/MCE/Channel.pm 18 lib/MCE/Child.pm 19 lib/MCE/Core.pod 29 lib/MCE/Flow.pm 30 lib/MCE/Grep.pm 31 lib/MCE/Loop.pm 32 lib/MCE/Map.pm [all …]
|
H A D | Changes | 50 * MCE->say, MCE->print, and MCE->printf now return 1. 61 enabled for the MCE->print, MCE->printf, and MCE->say output routines. 904 * MCE models now set $MCE::FREEZE, $MCE::THAW, and $MCE::TMP_DIR when 950 * Optimization for MCE->print, MCE->printf, MCE->say and MCE->sendto. 1262 MCE::Flow, MCE::Loop, and MCE::Step. 1269 than through the init method for MCE::Loop, MCE::Grep, and MCE::Map. 1285 MCE::Flow and MCE::Loop. 1403 * MCE::Grep, MCE::Map, and MCE::Stream were failing for mce_grep_s, 1434 MCE::Loop, MCE::Map, and MCE::Stream. 1484 * Five models: MCE::Flow, MCE::Grep, MCE::Loop, MCE::Map, and MCE::Stream. [all …]
|
/dports/devel/p5-MCE-Shared/MCE-Shared-1.874/t/ |
H A D | 07_shared_queue_prio.t | 16 MCE::Flow->init( 26 my $q1 = MCE::Shared->queue( type => $MCE::Shared::Queue::FIFO ); 27 my $q2 = MCE::Shared->queue( type => $MCE::Shared::Queue::LIFO ); 29 my $q3 = MCE::Shared->queue( 31 type => $MCE::Shared::Queue::FIFO 34 my $q4 = MCE::Shared->queue( 36 type => $MCE::Shared::Queue::FIFO 167 MCE::Flow->finish; 239 MCE::Flow->finish; 269 MCE::Flow->finish; [all …]
|
H A D | 07_shared_queue_norm.t | 16 MCE::Flow->init( 26 my $q1 = MCE::Shared->queue( type => $MCE::Shared::Queue::FIFO ); 27 my $q2 = MCE::Shared->queue( type => $MCE::Shared::Queue::LIFO ); 33 MCE::Shared->start() unless $INC{'IO/FDPass.pm'}; 106 $w = MCE->do('check_enqueue', 'fifo, check enqueue'); 112 $w = MCE->do('check_dequeue_fifo', @r); 116 $w = MCE->do('check_clear', 'fifo, check clear'); 157 MCE::Flow->finish; 185 $w = MCE->do('check_dequeue_lifo', @r); 189 $w = MCE->do('check_clear', 'lifo, check clear'); [all …]
|
H A D | 05_mce_hobo_max_workers.t | 13 sub MCE::Util::get_ncpu { return 16; } 21 MCE::Hobo->init(max_workers => 0); 24 MCE::Hobo->max_workers(5); 27 MCE::Hobo->max_workers(20); 35 is(MCE::Hobo->max_workers(), 16, 45 is(MCE::Hobo->max_workers(), 1, 49 MCE::Hobo->max_workers('1%'); 50 is(MCE::Hobo->max_workers(), 1, 54 MCE::Hobo->max_workers('25%'); 55 is(MCE::Hobo->max_workers(), 4, [all …]
|
/dports/devel/p5-MCE-Shared/MCE-Shared-1.874/ |
H A D | META.yml | 18 name: MCE-Shared 24 MCE::Hobo: 27 MCE::Shared: 30 MCE::Shared::Array: 33 MCE::Shared::Base: 36 MCE::Shared::Cache: 42 MCE::Shared::Handle: 45 MCE::Shared::Hash: 48 MCE::Shared::Minidb: 54 MCE::Shared::Queue: [all …]
|
H A D | Changes | 6 * Bumped MCE dependency to 1.874. 8 * MCE::Hobo update. 72 Resolved MCE::Hobo stalling MCE::Shared::Server during global cleanup. 89 * Use MCE::Channel for MCE::Hobo->yield to not incur unnecessary delays 102 in MCE 1.863. 188 (i.e. MCE::Shared->scalar, MCE::Shared->cache, et cetera). 344 * Refactored MCE::Hobo, MCE::Shared, and MCE::Shared::Server. 358 * Improved running MCE::Hobo and MCE::Shared with PDL. 369 * Validated MCE::Hobo and MCE::Shared on SmartOS. 442 MCE->new( [all …]
|
/dports/devel/p5-MCE/MCE-1.876/lib/ |
H A D | MCE.pod | 39 use MCE; 41 my $mce = MCE->new( 57 MCE->say("Hello from " . MCE->wid); 62 use MCE::Loop; 104 use MCE::Flow; 122 MCE::Flow->init( 164 =head1 MCE EXTRAS 199 MCE when specifying the C<init_relay> MCE option. 203 =head1 MCE MODELS 205 The MCE models are sugar syntax on top of the L<MCE::Core> API. Two MCE options [all …]
|
H A D | MCE.pm | 7 package MCE; package 64 use MCE::Mutex (); 195 $MCE = MCE->new( _module_instance => 1, max_workers => 0 ); 281 $MCE->exit if ( exists $MCE->{_wuf} && $MCE->{_pid} eq $_pid ); 341 $_prev_mce = $MCE; $MCE = $_[0]; 499 $MCE = \%self if ($MCE->{_wid} == 0); 524 $MCE::_GMUTEX->lock() if ($_tid && $MCE::_GMUTEX); 621 require MCE::Relay; MCE::Relay->import(); 723 $MCE = $self if ($MCE->{_wid} == 0); 725 $MCE::_GMUTEX->unlock() if ($_tid && $MCE::_GMUTEX); [all …]
|
/dports/devel/p5-MCE/MCE-1.876/lib/MCE/Channel/ |
H A D | Threads.pm | 7 package MCE::Channel::Threads; 23 my $freeze = MCE::Channel::_get_freeze(); 24 my $thaw = MCE::Channel::_get_thaw(); 29 $obj{init_pid} = MCE::Channel::_pid(); 30 MCE::Util::_sock_pair( \%obj, 'p_sock', 'c_sock' ); 232 local $MCE::Signal::SIG; 237 local $MCE::Signal::IPC = 1; 244 CORE::kill($MCE::Signal::SIG, $$) if $MCE::Signal::SIG; 263 ? MCE::Util::_sysread( $p_sock, $plen, 4 ) 287 MCE::Util::_nonblocking( $p_sock, 1 ); [all …]
|
H A D | Mutex.pm | 7 package MCE::Channel::Mutex; 17 use MCE::Mutex (); 20 my $freeze = MCE::Channel::_get_freeze(); 21 my $thaw = MCE::Channel::_get_thaw(); 26 $obj{init_pid} = MCE::Channel::_pid(); 27 MCE::Util::_sock_pair( \%obj, 'p_sock', 'c_sock' ); 194 MCE::Util::_nonblocking( $self->{c_sock}, 1 ); 196 MCE::Util::_nonblocking( $self->{c_sock}, 0 ); 222 local $MCE::Signal::SIG; 225 local $MCE::Signal::IPC = 1; [all …]
|
H A D | Simple.pm | 7 package MCE::Channel::Simple; 20 my $freeze = MCE::Channel::_get_freeze(); 21 my $thaw = MCE::Channel::_get_thaw(); 26 $obj{init_pid} = MCE::Channel::_pid(); 27 MCE::Util::_sock_pair( \%obj, 'p_sock', 'c_sock' ); 198 MCE::Util::_nonblocking( $self->{c_sock}, 1 ); 204 MCE::Util::_nonblocking( $self->{c_sock}, 0 ); 230 local $MCE::Signal::SIG; 233 local $MCE::Signal::IPC = 1; 239 CORE::kill($MCE::Signal::SIG, $$) if $MCE::Signal::SIG; [all …]
|
/dports/devel/p5-MCE-Shared/MCE-Shared-1.874/lib/MCE/ |
H A D | Shared.pm | 7 package MCE::Shared; 28 use MCE::Mutex (); 29 use MCE::Shared::Server (); 68 my $_obj = MCE::Shared::Server::_new( 201 my $_obj = MCE::Shared::Server::_new( 312 return MCE::Shared->cache(@_) if $_cache; 313 return MCE::Shared->ordhash(@_) if $_ordered; 314 return MCE::Shared->hash(@_); 332 goto &MCE::_croak; 335 goto &MCE::Shared::Base::_croak; [all …]
|
/dports/security/clamav-lts/clamav-0.103.5/libclamav/c++/llvm/lib/Target/X86/ |
H A D | X86CodeEmitter.cpp | 120 MCE.setModuleInfo(MMI); in runOnMachineFunction() 254 MCE.addRelocation(MachineRelocation::getBB(MCE.getCurrentPCOffset(), in emitPCRelativeBlockAddress() 256 MCE.emitWordLE(0); in emitPCRelativeBlockAddress() 300 MCE.addRelocation(MachineRelocation::getExtSym(MCE.getCurrentPCOffset(), in emitExternalSymbolAddress() 304 MCE.emitDWordLE(0); in emitExternalSymbolAddress() 306 MCE.emitWordLE(0); in emitExternalSymbolAddress() 321 MCE.addRelocation(MachineRelocation::getConstPool(MCE.getCurrentPCOffset(), in emitConstPoolAddress() 341 MCE.addRelocation(MachineRelocation::getJumpTable(MCE.getCurrentPCOffset(), in emitJumpTableAddress() 345 MCE.emitDWordLE(0); in emitJumpTableAddress() 347 MCE.emitWordLE(0); in emitJumpTableAddress() [all …]
|
/dports/x11/xautolock/xautolock-2.2/ |
H A D | Changelog | 26 Review : - 28/12/2007 (MCE) : 29 - 30/09/2007 (MCE) : 32 - 08/09/2004 (MCE) : 36 - 20/04/2004 (MCE) : 39 - 12/12/2001 (MCE) : 42 - 10/09/2001 (MCE) : 45 - 05/05/2001 (MCE) : 52 - 16/04/2001 (MCE) : 55 - 23/03/2001 (MCE) : 58 - 01/11/1999 (MCE) : [all …]
|