Bugzilla – Attachment 85119 Details for
Bug 21872
Elasticsearch indexing faster by making it multi-threaded
Home
|
New
|
Browse
|
Search
|
[?]
|
Reports
|
Help
|
New Account
|
Log In
[x]
|
Forgot Password
Login:
[x]
[patch]
Bug 21872: Simplify conditions and exit on invalid combination of arguments
Bug-21872-Simplify-conditions-and-exit-on-invalid-.patch (text/plain), 5.96 KB, created by
David Gustafsson
on 2019-02-14 14:17:37 UTC
(
hide
)
Description:
Bug 21872: Simplify conditions and exit on invalid combination of arguments
Filename:
MIME Type:
Creator:
David Gustafsson
Created:
2019-02-14 14:17:37 UTC
Size:
5.96 KB
patch
obsolete
>From 50d7ba603f9aa3609ec957e0d376eb7a1e50d25d Mon Sep 17 00:00:00 2001 >From: David Gustafsson <david.gustafsson@ub.gu.se> >Date: Thu, 14 Feb 2019 15:06:35 +0100 >Subject: [PATCH] Bug 21872: Simplify conditions and exit on invalid > combination of arguments > >Change to zero based indexing for slice index to simplify some >conditions. Exit with error message if trying to combine processes >and biblio numbers arguments. >--- > Koha/BiblioUtils.pm | 2 -- > Koha/MetadataRecord/Authority.pm | 2 -- > misc/search_tools/rebuild_elastic_search.pl | 23 ++++++++++++----------- > 3 files changed, 12 insertions(+), 15 deletions(-) > >diff --git a/Koha/BiblioUtils.pm b/Koha/BiblioUtils.pm >index b934b2c9ed..94e7f089e9 100644 >--- a/Koha/BiblioUtils.pm >+++ b/Koha/BiblioUtils.pm >@@ -129,8 +129,6 @@ sub get_all_biblios_iterator { > if ($options{slice}) { > $slice_count = $options{slice}->{count}; > $slice_modulo = $options{slice}->{index}; >- $slice_modulo = 0 if ($slice_modulo == $slice_count); >- > $search_terms = \[ ' mod(biblionumber, ?) = ?', $slice_count, $slice_modulo]; > } > >diff --git a/Koha/MetadataRecord/Authority.pm b/Koha/MetadataRecord/Authority.pm >index 3adac20707..9f939af07a 100644 >--- a/Koha/MetadataRecord/Authority.pm >+++ b/Koha/MetadataRecord/Authority.pm >@@ -180,8 +180,6 @@ sub get_all_authorities_iterator { > if ($options{slice}) { > $slice_count = $options{slice}->{count}; > $slice_modulo = $options{slice}->{index}; >- $slice_modulo = 0 if ($slice_modulo == $slice_count); >- > $search_terms->{authid} = \[ ' mod ? = ?', $slice_count, $slice_modulo]; > $search_terms = { > '-and' => [ >diff --git a/misc/search_tools/rebuild_elastic_search.pl b/misc/search_tools/rebuild_elastic_search.pl >index a2d40bd582..1c3d9b6cab 100755 >--- a/misc/search_tools/rebuild_elastic_search.pl >+++ b/misc/search_tools/rebuild_elastic_search.pl >@@ -122,6 +122,10 @@ unless ($index_authorities || $index_biblios) { > $index_authorities = $index_biblios = 1; > } > >+if ($processes && @record_numbers) { >+ die "Argument p|processes cannot be combined with bn|bnumber"; >+} >+ > pod2usage(1) if $help; > pod2usage( -exitstatus => 0, -verbose => 2 ) if $man; > >@@ -132,11 +136,12 @@ _verify_index_state($Koha::SearchEngine::Elasticsearch::AUTHORITIES_INDEX, $dele > > my $slice_index = 0; > my $slice_count = $processes // 1; >+my %iterator_options; > > if ($slice_count > 1) { > # Fire up child processes for processing slices from 2 on. This main process will handle slice 1. >- $slice_index = 1; >- for (my $proc = 2; $proc <= $processes; $proc++) { >+ $slice_index = 0; >+ for (my $proc = 1; $proc < $slice_count; $proc++) { > my $pid = fork(); > die "Failed to fork a child process\n" unless defined $pid; > if ($pid == 0) { >@@ -146,12 +151,8 @@ if ($slice_count > 1) { > } > } > # Fudge the commit count a bit to spread out the Elasticsearch commits >- $commit *= 1 + 0.10 * ($slice_index - 1); >-} >- >-my %iterator_options; >-if ($slice_index) { >- _log(1, "Processing slice $slice_index of $slice_count\n"); >+ $commit *= 1 + 0.10 * $slice_index; >+ _log(1, "Processing slice @{[$slice_index + 1]} of $slice_count\n"); > $iterator_options{slice} = { index => $slice_index, count => $slice_count }; > } > >@@ -190,16 +191,16 @@ if ($index_authorities) { > _do_reindex($next, $Koha::SearchEngine::Elasticsearch::AUTHORITIES_INDEX); > } > >-if ($slice_index == 1) { >+if ($slice_index == 0) { > # Main process, wait for children >- for (my $proc = 2; $proc <= $processes; $proc++) { >+ for (my $proc = 1; $proc < $processes; $proc++) { > wait(); > } > } > > =head2 _verify_index_state > >- _ verify_index_state($Koha::SearchEngine::Elasticsearch::BIBLIOS_INDEX, 1); >+ _verify_index_state($Koha::SearchEngine::Elasticsearch::BIBLIOS_INDEX, 1); > > Checks the index state and recreates it if requested. > >-- >2.11.0
You cannot view the attachment while viewing its details because your browser does not support IFRAMEs.
View the attachment on a separate page
.
View Attachment As Diff
View Attachment As Raw
Actions:
View
|
Diff
|
Splinter Review
Attachments on
bug 21872
:
82582
|
82583
|
82584
|
82585
|
82586
|
82598
|
82599
|
82780
|
85119
|
85121
|
85975
|
85976
|
85977
|
85978
|
85979
|
86053
|
86054
|
86055
|
86056
|
86057
|
89109
|
89110
|
89111
|
89112
|
89113