net.bluemind.backend.cyrus.replication.server

Class ReplicationSession

java.lang.Object

net.bluemind.backend.cyrus.replication.server.ReplicationSession

public class ReplicationSession
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.concurrent.atomic.AtomicLong	activeSessions

Constructor Summary

Constructors

Constructor and Description
ReplicationSession(io.vertx.core.Vertx vertx, io.vertx.core.net.NetSocket client, StorageApiLink storage, java.util.List<IReplicationObserver> observers)

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<java.lang.Void>	doApplyActivateSieve(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doApplyAnnotation(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doApplyExpunge(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doApplyMailbox(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doApplyMessage(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doApplyQuota(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doApplyRename(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doApplyReserve(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doApplySeen(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doApplySieve(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doApplySub(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doApplyUnmailbox(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doApplyUnquota(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doApplyUnsieve(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doApplyUnsub(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doApplyUnuser(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doAuthenticate(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doExit(ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doGetAnnotation(Token t, ReplicationFrame frame) GET ANNOTATION vagrant.vmw!domino^room^a8177012dabce540c1257cd0004bbb34_at_domino^res
java.util.concurrent.CompletableFuture<java.lang.Void>	doGetFetch(Token t, ReplicationFrame frame) GET FETCH %(MBOXNAME fws.fr!user.dani PARTITION bm-master__fws_fr UNIQUEID k3j4ly1rzg13gtex5nwmo3r5 GUID 3935e077b8a883b05105e1984166542c3ab2cdab UID 13238)
java.util.concurrent.CompletableFuture<java.lang.Void>	doGetFullMailbox(Token t, ReplicationFrame frame) GET FULLMAILBOX vagrant.vmw!user.admin * MAILBOX %(UNIQUEID 5596488a5890990f MBOXNAME vagrant.vmw!user.admin LAST_UID 3 HIGHESTMODSEQ 40 RECENTUID 3 RECENTTIME 1486035958 LAST_APPENDDATE 1485871655 POP3_LAST_LOGIN 0 UIDVALIDITY 1485871375 PARTITION vagrant_vmw ACL "admin@vagrant.vmw lrswipkxtecda admin0 lrswipkxtecda " OPTIONS P SYNC_CRC 3635576038 RECORD ( %(UID 1 MODSEQ 36 LAST_UPDATED 1486035945 FLAGS (\Seen) INTERNALDATE 1485871611 SIZE 1281 GUID 065ba5d1f867100b0da8622f75ff7760d26c5a83) %(UID 2 MODSEQ 39 LAST_UPDATED 1486035950 FLAGS (\Flagged) INTERNALDATE 1485871635 SIZE 35189 GUID 1a8b394b6827ac783ad40bb0c293ce5822b9e0cf) %(UID 3 MODSEQ 40 LAST_UPDATED 1486035958 FLAGS (\Seen) INTERNALDATE 1485871655 SIZE 4376698 GUID 8f6a929e05aeee58dcf2e8289320572ee99a0a82))) OK success
java.util.concurrent.CompletableFuture<java.lang.Void>	doGetMailboxes(Token t, ReplicationFrame frame) GET MAILBOXES (ex2016.vmw!user.tom ex2016.vmw!user.nico vagrant.vmw!user.jdoe vagrant.vmw!user.jdoe.Sent vagrant.vmw!user.jdoe.Outbox vagrant.vmw!user.jdoe.Trash vagrant.vmw!user.jdoe.Drafts vagrant.vmw!user.jdoe.Junk vagrant.vmw!user.janedoe vagrant.vmw!user.janedoe.Sent vagrant.vmw!user.janedoe.Outbox vagrant.vmw!user.janedoe.Trash vagrant.vmw!user.janedoe.Drafts vagrant.vmw!user.janedoe.Junk vagrant.vmw!domino^res^a2aae8f869e638e3c1257cc30023a0bd_at_domino^res vagrant.vmw!domino^res^a2aae8f869e638e3c1257cc30023a0bd_at_domino^res.Sent vagrant.vmw!domino^room^a8177012dabce540c1257cd0004bbb34_at_domino^res vagrant.vmw!domino^room^a8177012dabce540c1257cd0004bbb34_at_domino^res.Sent vagrant.vmw!domino^room^00c86c6c2095945ec1257cc20052c6fa_at_domino^res vagrant.vmw!domino^room^00c86c6c2095945ec1257cc20052c6fa_at_domino^res.Sent vagrant.vmw!user.admin ex2016.vmw!user.nico.Drafts ex2016.vmw!user.nico.Junk ex2016.vmw!user.nico.Outbox ex2016.vmw!user.nico.Sent ex2016.vmw!user.nico.Trash ex2016.vmw!user.sylvain ex2016.vmw!user.sylvain.Sent ex2016.vmw!user.sylvain.Outbox ex2016.vmw!user.sylvain.Trash ex2016.vmw!user.sylvain.Drafts ex2016.vmw!user.sylvain.Junk ex2016.vmw!user.admin ex2016.vmw!user.admin.Drafts ex2016.vmw!user.admin.Junk ex2016.vmw!user.admin.Outbox ex2016.vmw!user.admin.Sent ex2016.vmw!user.admin.Trash ex2016.vmw!user.sga ex2016.vmw!user.sga.Drafts ex2016.vmw!user.sga.Junk ex2016.vmw!user.sga.Outbox ex2016.vmw!user.sga.Sent ex2016.vmw!user.sga.Trash ex2016.vmw!tom ex2016.vmw!user.tom.Drafts ex2016.vmw!DELETED.user.tom.Drafts.5863AA42 ex2016.vmw!user.tom.Junk ex2016.vmw!DELETED.user.tom.Junk.5863AA42 ex2016.vmw!user.tom.Outbox ex2016.vmw!DELETED.user.tom.Outbox.5863AA42 ex2016.vmw!user.tom.Sent ex2016.vmw!DELETED.user.tom.Sent.5863AA42 ex2016.vmw!user.tom.Trash ex2016.vmw!DELETED.user.tom.Trash.5863AA42)
java.util.concurrent.CompletableFuture<java.lang.Void>	doGetMeta(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doGetUser(Token t, ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doNoop(ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doRestart(ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	doTLS(ReplicationFrame frame)
java.util.concurrent.CompletableFuture<java.lang.Void>	processFrame(ReplicationFrame frame)
java.lang.String	remoteIp()
void	start()
ReplicationState	state()
java.util.concurrent.CompletableFuture<java.lang.Void>	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

activeSessions

public static final java.util.concurrent.atomic.AtomicLong activeSessions

Constructor Detail

ReplicationSession

public ReplicationSession(io.vertx.core.Vertx vertx,
                          io.vertx.core.net.NetSocket client,
                          StorageApiLink storage,
                          java.util.List<IReplicationObserver> observers)

Method Detail

state

public ReplicationState state()

start

public void start()

stop

public java.util.concurrent.CompletableFuture<java.lang.Void> stop()

processFrame

public java.util.concurrent.CompletableFuture<java.lang.Void> processFrame(ReplicationFrame frame)

doExit

public java.util.concurrent.CompletableFuture<java.lang.Void> doExit(ReplicationFrame frame)

doRestart

public java.util.concurrent.CompletableFuture<java.lang.Void> doRestart(ReplicationFrame frame)

doNoop

public java.util.concurrent.CompletableFuture<java.lang.Void> doNoop(ReplicationFrame frame)

doApplyMessage

public java.util.concurrent.CompletableFuture<java.lang.Void> doApplyMessage(Token t,
                                                                             ReplicationFrame frame)

doApplyMailbox

public java.util.concurrent.CompletableFuture<java.lang.Void> doApplyMailbox(Token t,
                                                                             ReplicationFrame frame)

doApplyRename

public java.util.concurrent.CompletableFuture<java.lang.Void> doApplyRename(Token t,
                                                                            ReplicationFrame frame)

doApplyExpunge

public java.util.concurrent.CompletableFuture<java.lang.Void> doApplyExpunge(Token t,
                                                                             ReplicationFrame frame)

doApplyUnmailbox

public java.util.concurrent.CompletableFuture<java.lang.Void> doApplyUnmailbox(Token t,
                                                                               ReplicationFrame frame)

doApplyUnuser

public java.util.concurrent.CompletableFuture<java.lang.Void> doApplyUnuser(Token t,
                                                                            ReplicationFrame frame)

doApplyUnquota

public java.util.concurrent.CompletableFuture<java.lang.Void> doApplyUnquota(Token t,
                                                                             ReplicationFrame frame)

doApplyReserve

public java.util.concurrent.CompletableFuture<java.lang.Void> doApplyReserve(Token t,
                                                                             ReplicationFrame frame)

doApplySeen

public java.util.concurrent.CompletableFuture<java.lang.Void> doApplySeen(Token t,
                                                                          ReplicationFrame frame)

doApplySub

public java.util.concurrent.CompletableFuture<java.lang.Void> doApplySub(Token t,
                                                                         ReplicationFrame frame)

doApplyUnsub

public java.util.concurrent.CompletableFuture<java.lang.Void> doApplyUnsub(Token t,
                                                                           ReplicationFrame frame)

doApplyAnnotation

public java.util.concurrent.CompletableFuture<java.lang.Void> doApplyAnnotation(Token t,
                                                                                ReplicationFrame frame)

doApplySieve

public java.util.concurrent.CompletableFuture<java.lang.Void> doApplySieve(Token t,
                                                                           ReplicationFrame frame)

doApplyActivateSieve

public java.util.concurrent.CompletableFuture<java.lang.Void> doApplyActivateSieve(Token t,
                                                                                   ReplicationFrame frame)

doApplyUnsieve

public java.util.concurrent.CompletableFuture<java.lang.Void> doApplyUnsieve(Token t,
                                                                             ReplicationFrame frame)

doApplyQuota

public java.util.concurrent.CompletableFuture<java.lang.Void> doApplyQuota(Token t,
                                                                           ReplicationFrame frame)

doTLS

public java.util.concurrent.CompletableFuture<java.lang.Void> doTLS(ReplicationFrame frame)

doAuthenticate

public java.util.concurrent.CompletableFuture<java.lang.Void> doAuthenticate(Token t,
                                                                             ReplicationFrame frame)

doGetUser

public java.util.concurrent.CompletableFuture<java.lang.Void> doGetUser(Token t,
                                                                        ReplicationFrame frame)

doGetMeta

public java.util.concurrent.CompletableFuture<java.lang.Void> doGetMeta(Token t,
                                                                        ReplicationFrame frame)

doGetMailboxes

public java.util.concurrent.CompletableFuture<java.lang.Void> doGetMailboxes(Token t,
                                                                             ReplicationFrame frame)

GET MAILBOXES (ex2016.vmw!user.tom ex2016.vmw!user.nico vagrant.vmw!user.jdoe vagrant.vmw!user.jdoe.Sent vagrant.vmw!user.jdoe.Outbox vagrant.vmw!user.jdoe.Trash vagrant.vmw!user.jdoe.Drafts vagrant.vmw!user.jdoe.Junk vagrant.vmw!user.janedoe vagrant.vmw!user.janedoe.Sent vagrant.vmw!user.janedoe.Outbox vagrant.vmw!user.janedoe.Trash vagrant.vmw!user.janedoe.Drafts vagrant.vmw!user.janedoe.Junk vagrant.vmw!domino^res^a2aae8f869e638e3c1257cc30023a0bd_at_domino^res vagrant.vmw!domino^res^a2aae8f869e638e3c1257cc30023a0bd_at_domino^res.Sent vagrant.vmw!domino^room^a8177012dabce540c1257cd0004bbb34_at_domino^res vagrant.vmw!domino^room^a8177012dabce540c1257cd0004bbb34_at_domino^res.Sent vagrant.vmw!domino^room^00c86c6c2095945ec1257cc20052c6fa_at_domino^res vagrant.vmw!domino^room^00c86c6c2095945ec1257cc20052c6fa_at_domino^res.Sent vagrant.vmw!user.admin ex2016.vmw!user.nico.Drafts ex2016.vmw!user.nico.Junk ex2016.vmw!user.nico.Outbox ex2016.vmw!user.nico.Sent ex2016.vmw!user.nico.Trash ex2016.vmw!user.sylvain ex2016.vmw!user.sylvain.Sent ex2016.vmw!user.sylvain.Outbox ex2016.vmw!user.sylvain.Trash ex2016.vmw!user.sylvain.Drafts ex2016.vmw!user.sylvain.Junk ex2016.vmw!user.admin ex2016.vmw!user.admin.Drafts ex2016.vmw!user.admin.Junk ex2016.vmw!user.admin.Outbox ex2016.vmw!user.admin.Sent ex2016.vmw!user.admin.Trash ex2016.vmw!user.sga ex2016.vmw!user.sga.Drafts ex2016.vmw!user.sga.Junk ex2016.vmw!user.sga.Outbox ex2016.vmw!user.sga.Sent ex2016.vmw!user.sga.Trash ex2016.vmw!tom ex2016.vmw!user.tom.Drafts ex2016.vmw!DELETED.user.tom.Drafts.5863AA42 ex2016.vmw!user.tom.Junk ex2016.vmw!DELETED.user.tom.Junk.5863AA42 ex2016.vmw!user.tom.Outbox ex2016.vmw!DELETED.user.tom.Outbox.5863AA42 ex2016.vmw!user.tom.Sent ex2016.vmw!DELETED.user.tom.Sent.5863AA42 ex2016.vmw!user.tom.Trash ex2016.vmw!DELETED.user.tom.Trash.5863AA42)

Parameters:

t -

frame -

Returns:

doGetFullMailbox

public java.util.concurrent.CompletableFuture<java.lang.Void> doGetFullMailbox(Token t,
                                                                               ReplicationFrame frame)

GET FULLMAILBOX vagrant.vmw!user.admin * MAILBOX %(UNIQUEID 5596488a5890990f MBOXNAME vagrant.vmw!user.admin LAST_UID 3 HIGHESTMODSEQ 40 RECENTUID 3 RECENTTIME 1486035958 LAST_APPENDDATE 1485871655 POP3_LAST_LOGIN 0 UIDVALIDITY 1485871375 PARTITION vagrant_vmw ACL "admin@vagrant.vmw lrswipkxtecda admin0 lrswipkxtecda " OPTIONS P SYNC_CRC 3635576038 RECORD ( %(UID 1 MODSEQ 36 LAST_UPDATED 1486035945 FLAGS (\Seen) INTERNALDATE 1485871611 SIZE 1281 GUID 065ba5d1f867100b0da8622f75ff7760d26c5a83) %(UID 2 MODSEQ 39 LAST_UPDATED 1486035950 FLAGS (\Flagged) INTERNALDATE 1485871635 SIZE 35189 GUID 1a8b394b6827ac783ad40bb0c293ce5822b9e0cf) %(UID 3 MODSEQ 40 LAST_UPDATED 1486035958 FLAGS (\Seen) INTERNALDATE 1485871655 SIZE 4376698 GUID 8f6a929e05aeee58dcf2e8289320572ee99a0a82))) OK success

Parameters:

t -

frame -

Returns:

doGetAnnotation

public java.util.concurrent.CompletableFuture<java.lang.Void> doGetAnnotation(Token t,
                                                                              ReplicationFrame frame)

GET ANNOTATION vagrant.vmw!domino^room^a8177012dabce540c1257cd0004bbb34_at_domino^res

Parameters:

t -

frame -

Returns:

doGetFetch

public java.util.concurrent.CompletableFuture<java.lang.Void> doGetFetch(Token t,
                                                                         ReplicationFrame frame)

GET FETCH %(MBOXNAME fws.fr!user.dani PARTITION bm-master__fws_fr UNIQUEID k3j4ly1rzg13gtex5nwmo3r5 GUID 3935e077b8a883b05105e1984166542c3ab2cdab UID 13238)

Parameters:

t -

frame -

Returns:

remoteIp

public java.lang.String remoteIp()