X-Git-Url: http://git.rot13.org/?a=blobdiff_plain;f=lib%2FAPKPM%2FGearman%2FClient.pm;fp=lib%2FAPKPM%2FGearman%2FClient.pm;h=932bd5ad655fd3775903f653fbab8bbd23b84acc;hb=a7dc6e088d22d80a0b8fa74e8d9b6316483babfa;hp=2ab1b795c9d8dc8e7823d9ae38ef54fdf98483fe;hpb=9c5e18162aa6813b34f1b2bbf19f58f27de546a7;p=APKPM.git

diff --git a/lib/APKPM/Gearman/Client.pm b/lib/APKPM/Gearman/Client.pm
index 2ab1b79..932bd5a 100644
--- a/lib/APKPM/Gearman/Client.pm
+++ b/lib/APKPM/Gearman/Client.pm
@@ -36,4 +36,15 @@ sub do {
 	return JSON::XS::decode_json $$ret;
 }
 
+sub do_high {
+	my ( $self, $func, $args ) = @_;
+	warn "# do_high ",dump( $func,$args );
+
+	my $task = Gearman::Task->new( $func, \$args, { high_priority => 1 } );
+
+	my $ret = $self->gc->do_task( $task );
+	warn "## $func $args = ",dump($ret);
+	return $$ret =~ m/^{/ ? JSON::XS::decode_json($$ret) : $$ret;
+}
+
 1;