Home
last modified time | relevance | path

Searched refs:MCE (Results 1 – 25 of 1228) sorted by relevance

12345678910>>...50

/dports/devel/p5-MCE/MCE-1.876/lib/MCE/
H A DSubs.pm19 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 DCore.pod4 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 DCandy.pm7 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 DExamples.pod47 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 D04_prio_que_worker.t15 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 D04_norm_que_worker.t15 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 D05_mce_child_max_workers.t13 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 D03_max_workers.t14 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 D06_relay.t29 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 DMETA.yml18 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 DMANIFEST11 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 DChanges50 * 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 D07_shared_queue_prio.t16 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 D07_shared_queue_norm.t16 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 D05_mce_hobo_max_workers.t13 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 DMETA.yml18 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 DChanges6 * 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 DMCE.pod39 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 DMCE.pm7 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 DThreads.pm7 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 DMutex.pm7 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 DSimple.pm7 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 DShared.pm7 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 DX86CodeEmitter.cpp120 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 DChangelog26 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 …]

12345678910>>...50