Package org.eclipse.jgit.transport

Class Daemon

java.lang.Object

org.eclipse.jgit.transport.Daemon

public class Daemon
extends java.lang.Object

Basic daemon for the anonymous git:// transport protocol.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	Daemon.Acceptor

Field Summary

Fields

Modifier and Type	Field	Description
private Daemon.Acceptor	acceptThread
private static int	BACKLOG
static int	DEFAULT_PORT	9418: IANA assigned port number for Git.
private java.net.InetSocketAddress	myAddress
private PackConfig	packConfig
private java.lang.ThreadGroup	processors
(package private) ReceivePackFactory<DaemonClient>	receivePackFactory
private RepositoryResolver<DaemonClient>	repositoryResolver
private DaemonService[]	services
private int	timeout
(package private) UploadPackFactory<DaemonClient>	uploadPackFactory

Constructor Summary

Constructors

Constructor	Description
Daemon()	Configure a daemon to listen on any available network port.
Daemon(java.net.InetSocketAddress addr)	Configure a new daemon for the specified network address.

Method Summary

Modifier and Type	Method	Description
private void	clearThread()
java.net.InetSocketAddress	getAddress()	Get the address connections are received on.
PackConfig	getPackConfig()	Get configuration controlling packing, may be null.
ReceivePackFactory<DaemonClient>	getReceivePackFactory()	Get the factory used to construct per-request ReceivePack.
DaemonService	getService(java.lang.String name)	Lookup a supported service so it can be reconfigured.
int	getTimeout()	Get timeout (in seconds) before aborting an IO operation.
boolean	isRunning()	Whether this daemon is receiving connections.
(package private) DaemonService	matchService(java.lang.String cmd)
(package private) Repository	openRepository(DaemonClient client, java.lang.String name)
void	setPackConfig(PackConfig pc)	Set the configuration used by the pack generator.
void	setReceivePackFactory(ReceivePackFactory<DaemonClient> factory)	Set the factory to construct and configure per-request ReceivePack.
void	setRepositoryResolver(RepositoryResolver<DaemonClient> resolver)	Set the resolver used to locate a repository by name.
void	setTimeout(int seconds)	Set the timeout before willing to abort an IO call.
void	setUploadPackFactory(UploadPackFactory<DaemonClient> factory)	Set the factory to construct and configure per-request UploadPack.
void	start()	Start this daemon on a background thread.
(package private) void	startClient(java.net.Socket s)
void	stop()	Stop this daemon.
void	stopAndWait()	Stops this daemon and waits until it's acceptor thread has finished.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_PORT

public static final int DEFAULT_PORT

9418: IANA assigned port number for Git.

See Also:

Constant Field Values

BACKLOG

private static final int BACKLOG

See Also:

Constant Field Values

myAddress

private java.net.InetSocketAddress myAddress

services

private final DaemonService[] services

processors

private final java.lang.ThreadGroup processors

acceptThread

private Daemon.Acceptor acceptThread

timeout

private int timeout

packConfig

private PackConfig packConfig

repositoryResolver

private volatile RepositoryResolver<DaemonClient> repositoryResolver

uploadPackFactory

volatile UploadPackFactory<DaemonClient> uploadPackFactory

receivePackFactory

volatile ReceivePackFactory<DaemonClient> receivePackFactory

Constructor Detail

Daemon

public Daemon()

Configure a daemon to listen on any available network port.

Daemon

public Daemon(java.net.InetSocketAddress addr)

Configure a new daemon for the specified network address.

Parameters:

addr - address to listen for connections on. If null, any available port will be chosen on all network interfaces.

Method Detail

getAddress

public java.net.InetSocketAddress getAddress()

Get the address connections are received on.

Returns:

the address connections are received on.

getService

public DaemonService getService(java.lang.String name)

Lookup a supported service so it can be reconfigured.

Parameters:

name - name of the service; e.g. "receive-pack"/"git-receive-pack" or "upload-pack"/"git-upload-pack".

Returns:

the service; null if this daemon implementation doesn't support the requested service type.

getTimeout

public int getTimeout()

Get timeout (in seconds) before aborting an IO operation.

Returns:

timeout (in seconds) before aborting an IO operation.

setTimeout

public void setTimeout(int seconds)

Set the timeout before willing to abort an IO call.

Parameters:

seconds - number of seconds to wait (with no data transfer occurring) before aborting an IO read or write operation with the connected client.

getPackConfig

public PackConfig getPackConfig()

Get configuration controlling packing, may be null.

Returns:

configuration controlling packing, may be null.

setPackConfig

public void setPackConfig(PackConfig pc)

Set the configuration used by the pack generator.

Parameters:

pc - configuration controlling packing parameters. If null the source repository's settings will be used.

setRepositoryResolver

public void setRepositoryResolver(RepositoryResolver<DaemonClient> resolver)

Set the resolver used to locate a repository by name.

Parameters:

resolver - the resolver instance.

setUploadPackFactory

public void setUploadPackFactory(UploadPackFactory<DaemonClient> factory)

Set the factory to construct and configure per-request UploadPack.

Parameters:

factory - the factory. If null upload-pack is disabled.

getReceivePackFactory

public ReceivePackFactory<DaemonClient> getReceivePackFactory()

Get the factory used to construct per-request ReceivePack.

Returns:

the factory.

Since:

4.3

setReceivePackFactory

public void setReceivePackFactory(ReceivePackFactory<DaemonClient> factory)

Set the factory to construct and configure per-request ReceivePack.

Parameters:

factory - the factory. If null receive-pack is disabled.

start

public void start()
           throws java.io.IOException

Start this daemon on a background thread.

Throws:

java.io.IOException - the server socket could not be opened.

java.lang.IllegalStateException - the daemon is already running.

clearThread

private void clearThread()

isRunning

public boolean isRunning()

Whether this daemon is receiving connections.

Returns:

true if this daemon is receiving connections.

stop

public void stop()

Stop this daemon.

stopAndWait

public void stopAndWait()
                 throws java.lang.InterruptedException

Stops this daemon and waits until it's acceptor thread has finished.

Throws:

java.lang.InterruptedException - if waiting for the acceptor thread is interrupted

Since:

4.9

startClient

void startClient(java.net.Socket s)

matchService

DaemonService matchService(java.lang.String cmd)

openRepository

Repository openRepository(DaemonClient client,
                          java.lang.String name)
                   throws ServiceMayNotContinueException

Throws:

ServiceMayNotContinueException