1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
|
package AnyEvent::Gearman::Task;
use Any::Moose;
use AnyEvent::Gearman::Constants;
BEGIN { do { eval q[use MouseX::Foreign; 1] or die $@ } if any_moose eq 'Mouse' }
extends any_moose('::Object'), 'Object::Event';
has function => (
is => 'rw',
isa => 'Str',
required => 1,
);
has workload => (
is => 'rw',
isa => 'Str',
required => 1,
);
has unique => (
is => 'rw',
isa => 'Str',
default => '',
);
has job_handle => (
is => 'rw',
isa => 'Str',
default => '',
);
has [qw/on_created on_data on_complete on_fail on_status on_warning/] => (
is => 'rw',
isa => 'CodeRef',
default => sub { sub {} },
);
no Any::Moose;
sub BUILDARGS {
my ($self, $function, $workload, %params) = @_;
return {
function => $function,
workload => $workload,
%params,
}
}
sub BUILD {
my $self = shift;
$self->reg_cb(
on_created => $self->on_created,
on_data => $self->on_data,
on_complete => $self->on_complete,
on_fail => $self->on_fail,
on_status => $self->on_status,
on_warning => $self->on_warning,
);
}
sub pack_req {
my ($self, $type) = @_;
$type = $type && $type eq 'bg'? SUBMIT_JOB_BG : SUBMIT_JOB;
my $data = $self->function . "\0"
. $self->unique . "\0"
. $self->workload;
"\0REQ" . pack('NN', $type, length($data)) . $data;
}
sub pack_option_req {
my ($self, $option) = @_;
"\0REQ" . pack('NN', OPTION_REQ, length($option)) . $option;
}
__PACKAGE__->meta->make_immutable;
__END__
=head1 NAME
AnyEvent::Gearman::Task - gearman task
=head1 METHODS
=head2 pack_req
=head2 pack_option_req
=head1 AUTHOR
Daisuke Murase <typester@cpan.org>
Pedro Melo <melo@cpan.org>
=head1 COPYRIGHT AND LICENSE
Copyright (c) 2009 by KAYAC Inc.
This program is free software; you can redistribute
it and/or modify it under the same terms as Perl itself.
The full text of the license can be found in the
LICENSE file included with this module.
=cut
|
