Patch by mark.
diffs (57 lines):
diff -r 8dc9568d4226 -r 25a3848e4b8a bin/worker/synsuck
--- a/bin/worker/synsuck Wed Sep 02 18:14:38 2009 +0000
+++ b/bin/worker/synsuck Thu Sep 03 06:04:47 2009 +0000
@@ -20,6 +20,7 @@ use LJ::Worker::TheSchwartz;
use LJ::Worker::TheSchwartz;
use LJ::SynSuck;
+schwartz_prioritize( 1 );
schwartz_decl( 'DW::Worker::SynSuck' );
schwartz_work();
diff -r 8dc9568d4226 -r 25a3848e4b8a cgi-bin/LJ/SynSuck.pm
--- a/cgi-bin/LJ/SynSuck.pm Wed Sep 02 18:14:38 2009 +0000
+++ b/cgi-bin/LJ/SynSuck.pm Thu Sep 03 06:04:47 2009 +0000
@@ -532,6 +532,7 @@ sub process_hubbub_notification {
funcname => 'DW::Worker::SynSuck',
arg => { userid => $u->id },
uniqkey => "synsuck:" . $u->id,
+ priority => 200, # arbitrary, high
) );
# let devserver know
diff -r 8dc9568d4226 -r 25a3848e4b8a cgi-bin/LJ/Worker/TheSchwartz.pm
--- a/cgi-bin/LJ/Worker/TheSchwartz.pm Wed Sep 02 18:14:38 2009 +0000
+++ b/cgi-bin/LJ/Worker/TheSchwartz.pm Thu Sep 03 06:04:47 2009 +0000
@@ -18,9 +18,10 @@ my $quit_flag = 0;
$quit_flag = 1;
};
-...@export = qw(schwartz_decl schwartz_work schwartz_on_idle
schwartz_on_afterwork schwartz_on_prework);
+...@export = qw(schwartz_decl schwartz_work schwartz_on_idle
schwartz_on_afterwork schwartz_on_prework schwartz_prioritize);
my $sclient;
+my $prioritize = 0;
my $on_idle = sub {};
my $on_afterwork = sub {};
@@ -36,6 +37,7 @@ sub schwartz_init {
$sclient = LJ::theschwartz({ role => $role }) or die "Could not get
schwartz client";
$used_role = $role; # save success role
$sclient->set_verbose($verbose);
+ $sclient->set_prioritize( $prioritize );
}
sub schwartz_decl {
@@ -47,6 +49,11 @@ sub schwartz_decl {
schwartz_init($role) unless $sclient;
$sclient->can_do($classname);
+}
+
+sub schwartz_prioritize {
+ $prioritize = $_[0] ? 1 : 0;
+ $sclient->set_prioritize( $prioritize ) if $sclient;
}
sub schwartz_on_idle {
_______________________________________________
dw-changelog mailing list
[email protected]
http://lists.dwscoalition.org/mailman/listinfo/dw-changelog
