[livejournal] r22548: LJSUP-13173 (split news/ru_news notifica...

A   trunk/bin/worker/esn-process-sub-mass
U   trunk/cgi-bin/LJ/ESN.pm

Added: trunk/bin/worker/esn-process-sub-mass
===================================================================
--- trunk/bin/worker/esn-process-sub-mass	                        (rev 0)
+++ trunk/bin/worker/esn-process-sub-mass	2012-08-02 09:18:10 UTC (rev 22548)
@@ -0,0 +1,15 @@
+#!/usr/bin/perl
+use strict;
+use lib "$ENV{LJHOME}/cgi-bin";
+require 'ljlib.pl';
+require 'ljprotocol.pl';
+use LJ::Lang;
+use LJ::NewWorker::TheSchwartz;
+use LJ::ESN;
+LJ::NewWorker::TheSchwartz::ProcessSubMass->start();
+
+package LJ::NewWorker::TheSchwartz::ProcessSubMass;
+use base 'LJ::NewWorker::TheSchwartz';
+sub capabilities { "LJ::Worker::ProcessSubMass" }
+
+1;


Property changes on: trunk/bin/worker/esn-process-sub-mass
___________________________________________________________________
Added: svn:executable
   + *

Modified: trunk/cgi-bin/LJ/ESN.pm
===================================================================
--- trunk/cgi-bin/LJ/ESN.pm	2012-08-02 08:48:28 UTC (rev 22547)
+++ trunk/cgi-bin/LJ/ESN.pm	2012-08-02 09:18:10 UTC (rev 22548)
@@ -15,6 +15,7 @@
             "LJ::Worker::FindSubsByCluster",  # step 2: can go to 3 or 4
             "LJ::Worker::FilterSubs",         # step 3: goes to step 4
             "LJ::Worker::ProcessSub",         # step 4
+            "LJ::Worker::ProcessSubMass",     # alternative step 4
             );
 }
 
@@ -326,7 +327,7 @@
 
         my $params = $evt->raw_params;
         push @jobs, TheSchwartz::Job->new(
-            'funcname' => 'LJ::Worker::ProcessSub',
+            'funcname' => 'LJ::Worker::ProcessSubMass',
             'arg' => {
                 'userid'    => $sub->userid, 
                 'subdump'   => $sub->dump,
@@ -582,5 +583,8 @@
     return (10, 30, 60, 300, 600)[$fails];
 }
 
+package LJ::Worker::ProcessSubMass;
+use base qw( LJ::Worker::ProcessSub );
+
 1;