org.eclipse.jgit.internal.ketch

Class KetchPreReceive

java.lang.Object

org.eclipse.jgit.internal.ketch.KetchPreReceive

All Implemented Interfaces:

PreReceiveHook

public class KetchPreReceive
extends java.lang.Object
implements PreReceiveHook

PreReceiveHook for handling push traffic in a Ketch system.

Install an instance on ReceivePack to capture the commands and other connection state and relay them through the KetchLeader, allowing the leader to gain consensus about the new reference state.

Field Summary

Fields

Modifier and Type	Field and Description
private KetchLeader	leader
private static org.slf4j.Logger	log

Fields inherited from interface org.eclipse.jgit.transport.PreReceiveHook

NULL

Constructor Summary

Constructors

Constructor and Description
KetchPreReceive(KetchLeader leader) Construct a hook executing updates through a KetchLeader.

Method Summary

Modifier and Type	Method and Description
void	onPreReceive(ReceivePack rp, java.util.Collection<ReceiveCommand> cmds) Invoked just before commands are executed.
private void	waitForPropose(Proposal proposal, ProgressSpinner spinner)
private void	waitForQueue(Proposal proposal, ProgressSpinner spinner)

Methods inherited from class java.lang.Object

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

Field Detail

log

private static final org.slf4j.Logger log

leader

private final KetchLeader leader

Constructor Detail

KetchPreReceive

public KetchPreReceive(KetchLeader leader)

Construct a hook executing updates through a KetchLeader.

Parameters:

leader - leader for this repository.

Method Detail

onPreReceive

public void onPreReceive(ReceivePack rp,
                         java.util.Collection<ReceiveCommand> cmds)

Invoked just before commands are executed.

See the class description for how this method can impact execution.

Specified by:

onPreReceive in interface PreReceiveHook

Parameters:

rp - the process handling the current receive. Hooks may obtain details about the destination repository through this handle.

cmds - unmodifiable set of valid commands still pending execution. May be the empty set.

waitForQueue

private void waitForQueue(Proposal proposal,
                          ProgressSpinner spinner)
                   throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

waitForPropose

private void waitForPropose(Proposal proposal,
                            ProgressSpinner spinner)
                     throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException