user/dev discussion of public-inbox itself
 help / color / mirror / code / Atom feed
Search results ordered by [date|relevance]  view[summary|nested|Atom feed]
thread overview below | download mbox.gz: |
* [PATCH 4/3] nntpd: avoid exiting subroutine via next
  2016-07-02 21:50  6% ` [PATCH 1/3] config: introduce each_inbox for iteration Eric Wong
@ 2016-07-07 19:55  6%   ` Eric Wong
  0 siblings, 0 replies; 3+ results
From: Eric Wong @ 2016-07-07 19:55 UTC (permalink / raw)
  To: meta

Fixes: 33cef7f24d3d ("config: introduce each_inbox for iteration")
---
 lib/PublicInbox/NNTPD.pm | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/PublicInbox/NNTPD.pm b/lib/PublicInbox/NNTPD.pm
index a67811b..eb43a2b 100644
--- a/lib/PublicInbox/NNTPD.pm
+++ b/lib/PublicInbox/NNTPD.pm
@@ -25,7 +25,7 @@ sub refresh_groups () {
 	my @list;
 	$pi_config->each_inbox(sub {
 		my ($ng) = @_;
-		my $ngname = $ng->{newsgroup} or next;
+		my $ngname = $ng->{newsgroup} or return;
 		if (ref $ngname) {
 			warn 'multiple newsgroups not supported: '.
 				join(', ', @$ngname). "\n";
-- 
EW

^ permalink raw reply related	[relevance 6%]

* [PATCH 1/3] config: introduce each_inbox for iteration
  2016-07-02 21:50  7% [PATCH 0/3] misc NNTP improvements Eric Wong
@ 2016-07-02 21:50  6% ` Eric Wong
  2016-07-07 19:55  6%   ` [PATCH 4/3] nntpd: avoid exiting subroutine via next Eric Wong
  0 siblings, 1 reply; 3+ results
From: Eric Wong @ 2016-07-02 21:50 UTC (permalink / raw)
  To: meta

This fills in the internal lookup hashes and simplifies
callers.
---
 lib/PublicInbox/Config.pm | 18 ++++++++++++++----
 lib/PublicInbox/ExtMsg.pm | 32 +++++++++++++++++---------------
 lib/PublicInbox/NNTPD.pm  | 21 +++++++++------------
 3 files changed, 40 insertions(+), 31 deletions(-)

diff --git a/lib/PublicInbox/Config.pm b/lib/PublicInbox/Config.pm
index ddb4f6b..d34d11a 100644
--- a/lib/PublicInbox/Config.pm
+++ b/lib/PublicInbox/Config.pm
@@ -50,11 +50,21 @@ sub lookup {
 	_fill($self, $pfx);
 }
 
-sub lookup_name {
+sub lookup_name ($$) {
 	my ($self, $name) = @_;
-	my $rv = $self->{-by_name}->{$name};
-	return $rv if $rv;
-	$rv = _fill($self, "publicinbox.$name") or return;
+	$self->{-by_name}->{$name} || _fill($self, "publicinbox.$name");
+}
+
+sub each_inbox {
+	my ($self, $cb) = @_;
+	my %seen;
+	foreach my $k (keys %$self) {
+		$k =~ /\Apublicinbox\.([A-Z0-9a-z-]+)\.mainrepo\z/ or next;
+		next if $seen{$1};
+		$seen{$1} = 1;
+		my $ibx = lookup_name($self, $1) or next;
+		$cb->($ibx);
+	}
 }
 
 sub lookup_newsgroup {
diff --git a/lib/PublicInbox/ExtMsg.pm b/lib/PublicInbox/ExtMsg.pm
index 4b9e025..73bd4b1 100644
--- a/lib/PublicInbox/ExtMsg.pm
+++ b/lib/PublicInbox/ExtMsg.pm
@@ -30,19 +30,16 @@ sub ext_msg {
 
 	eval { require PublicInbox::Search };
 	my $have_xap = $@ ? 0 : 1;
-	my (@nox, @ibx);
+	my (@nox, @ibx, @found);
 
-	foreach my $k (keys %$pi_config) {
-		$k =~ /\Apublicinbox\.([A-Z0-9a-z-]+)\.url\z/ or next;
-		my $name = $1;
-		next if $name eq $cur->{name};
-		my $other = $pi_config->lookup_name($name) or next;
-		next unless $other->base_url;
+	$pi_config->each_inbox(sub {
+		my ($other) = @_;
+		return if $other->{name} eq $cur->{name} || !$other->base_url;
 
 		my $s = $other->search;
 		if (!$s) {
 			push @nox, $other;
-			next;
+			return;
 		}
 
 		# try to find the URL with Xapian to avoid forking
@@ -50,17 +47,22 @@ sub ext_msg {
 		if ($@) {
 			# xapian not configured properly for this repo
 			push @nox, $other;
-			next;
+			return;
 		}
 
 		# maybe we found it!
-		return r302($other, $mid) if defined $doc_id;
+		if (defined $doc_id) {
+			push @found, $other;
+		} else {
+			# no point in trying the fork fallback if we
+			# know Xapian is up-to-date but missing the
+			# message in the current repo
+			push @ibx, $other;
+		}
+	});
 
-		# no point in trying the fork fallback if we
-		# know Xapian is up-to-date but missing the
-		# message in the current repo
-		push @ibx, $other;
-	}
+	# TODO: multiple hits
+	return r302($found[0], $mid) if @found;
 
 	# Xapian not installed or configured for some repos,
 	# do a full MID check:
diff --git a/lib/PublicInbox/NNTPD.pm b/lib/PublicInbox/NNTPD.pm
index 50d022b..a67811b 100644
--- a/lib/PublicInbox/NNTPD.pm
+++ b/lib/PublicInbox/NNTPD.pm
@@ -23,21 +23,18 @@ sub refresh_groups () {
 	my $pi_config = PublicInbox::Config->new;
 	my $new = {};
 	my @list;
-	foreach my $k (keys %$pi_config) {
-		$k =~ /\Apublicinbox\.([^\.]+)\.mainrepo\z/ or next;
-		my $name = $1;
-		my $git_dir = $pi_config->{$k};
-		my $ngname = $pi_config->{"publicinbox.$name.newsgroup"};
-		next unless defined $ngname;
-		next if ($ngname eq ''); # disabled
-		my $ng = $pi_config->lookup_newsgroup($ngname) or next;
-
-		# Only valid if msgmap and search works
-		if ($ng->nntp_usable) {
+	$pi_config->each_inbox(sub {
+		my ($ng) = @_;
+		my $ngname = $ng->{newsgroup} or next;
+		if (ref $ngname) {
+			warn 'multiple newsgroups not supported: '.
+				join(', ', @$ngname). "\n";
+		} elsif ($ng->nntp_usable) {
+			# Only valid if msgmap and search works
 			$new->{$ngname} = $ng;
 			push @list, $ng;
 		}
-	}
+	});
 	@list =	sort { $a->{newsgroup} cmp $b->{newsgroup} } @list;
 	$self->{grouplist} = \@list;
 	# this will destroy old groups that got deleted

^ permalink raw reply related	[relevance 6%]

* [PATCH 0/3] misc NNTP improvements
@ 2016-07-02 21:50  7% Eric Wong
  2016-07-02 21:50  6% ` [PATCH 1/3] config: introduce each_inbox for iteration Eric Wong
  0 siblings, 1 reply; 3+ results
From: Eric Wong @ 2016-07-02 21:50 UTC (permalink / raw)
  To: meta

A couple of minor cleanups and shutdown improvement for NNTP.

Eric Wong (3):
      config: introduce each_inbox for iteration
      nntp: simplify update_idle_time
      nntp: respect 3 minute idle time for shutdown

 lib/PublicInbox/Config.pm | 18 ++++++++++++++----
 lib/PublicInbox/ExtMsg.pm | 32 +++++++++++++++++---------------
 lib/PublicInbox/NNTP.pm   | 20 ++++++++++++++------
 lib/PublicInbox/NNTPD.pm  | 21 +++++++++------------
 t/nntpd.t                 |  1 +
 5 files changed, 55 insertions(+), 37 deletions(-)


^ permalink raw reply	[relevance 7%]

Results 1-3 of 3 | reverse | options above
-- pct% links below jump to the message on this page, permalinks otherwise --
2016-07-02 21:50  7% [PATCH 0/3] misc NNTP improvements Eric Wong
2016-07-02 21:50  6% ` [PATCH 1/3] config: introduce each_inbox for iteration Eric Wong
2016-07-07 19:55  6%   ` [PATCH 4/3] nntpd: avoid exiting subroutine via next Eric Wong

Code repositories for project(s) associated with this public inbox

	https://80x24.org/public-inbox.git

This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for read-only IMAP folder(s) and NNTP newsgroup(s).