org.eclipse.jgit.internal.ketch

Class ReplicaPushRequest

java.lang.Object

org.eclipse.jgit.internal.ketch.ReplicaPushRequest

public class ReplicaPushRequest
extends Object

A push request sending objects to a replica, and its result.

Implementors of KetchReplica must populate the command result fields, setRefs(Map), and call one of setException(Repository, Throwable) or done(Repository) to finish processing.

Constructor Summary

Constructors

Constructor and Description
ReplicaPushRequest(KetchReplica replica, Collection<ReceiveCommand> commands) Construct a new push request for a replica.

Method Summary

Modifier and Type	Method and Description
void	done(Repository repo) Mark the request as completed without exception.
Collection<ReceiveCommand>	getCommands() Get commands to be executed, and their results.
Throwable	getException() Get exception thrown, if any.
Map<String,Ref>	getRefs() Get remote references, usually from the advertisement.
void	setException(Repository repo, Throwable err) Mark the request as crashing with a communication error.
void	setRefs(Map<String,Ref> refs) Set references observed from the replica.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicaPushRequest

public ReplicaPushRequest(KetchReplica replica,
                          Collection<ReceiveCommand> commands)

Construct a new push request for a replica.

Parameters:

replica - the replica being pushed to.

commands - commands to be executed.

Method Detail

getCommands

public Collection<ReceiveCommand> getCommands()

Get commands to be executed, and their results.

Returns:

commands to be executed, and their results.

getRefs

@Nullable
public Map<String,Ref> getRefs()

Get remote references, usually from the advertisement.

Returns:

remote references, usually from the advertisement.

setRefs

public void setRefs(Map<String,Ref> refs)

Set references observed from the replica.

Parameters:

refs - references observed from the replica.

getException

@Nullable
public Throwable getException()

Get exception thrown, if any.

Returns:

exception thrown, if any.

setException

public void setException(@Nullable
                         Repository repo,
                         Throwable err)

Mark the request as crashing with a communication error.

This method may take significant time acquiring the leader lock and updating the Ketch state machine with the failure.

Parameters:

repo - local repository reference used by the push attempt.

err - exception thrown during communication.

done

public void done(Repository repo)

Mark the request as completed without exception.

This method may take significant time acquiring the leader lock and updating the Ketch state machine with results from this replica.

Parameters:

repo - local repository reference used by the push attempt.