You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2019/11/18 02:51:15 UTC
[james-project] 41/44: JAMES-2632 concatMap for mailbox search
This is an automated email from the ASF dual-hosted git repository.
btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit c1b2357a52e3f3b36cd5ea935d0612596b7665a1
Author: Benoit Tellier <bt...@linagora.com>
AuthorDate: Thu Nov 7 16:59:39 2019 +0700
JAMES-2632 concatMap for mailbox search
This slighlty decrease average performance of GetMailboxes but
allows a much lower p99 and completly get rid of errors.
Scenario: 13.706 req/s (GetMailboxes)
Before:
Average: 414 ms
p99: 2104 ms
Errors: 54
After:
Average: 470 ms
p99: 1723 ms
Errors: 0
---
.../org/apache/james/mailbox/cassandra/mail/CassandraMailboxMapper.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMailboxMapper.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMailboxMapper.java
index 56b32d3..09ed684 100644
--- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMailboxMapper.java
+++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMailboxMapper.java
@@ -155,7 +155,7 @@ public class CassandraMailboxMapper implements MailboxMapper {
private List<Mailbox> toMailboxes(MailboxQuery.UserBound query, Flux<CassandraIdAndPath> listUserMailboxes) {
return listUserMailboxes
.filter(idAndPath -> query.isPathMatch(idAndPath.getMailboxPath()))
- .flatMap(this::retrieveMailbox)
+ .concatMap(this::retrieveMailbox)
.collectList()
.block();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org