Package org.apache.tika.pipes.core.protocol

Class ForkBootstrap

java.lang.Object

org.apache.tika.pipes.core.protocol.ForkBootstrap

public final class ForkBootstrap
extends Object

What the parent hands a forked PipesServer on its stdin before anything else: an auth token and the parent's config. The fork presents the token as the first bytes of every socket connection so the other end can reject a stranger that connected first.

Frame: 32-byte token, int config length, config JSON. The config's ${env:...} references are resolved by the parent, never by the fork.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	TOKEN_LENGTH_BYTES

Method Summary

Modifier and Type	Method	Description
static boolean	checkToken(InputStream in, byte[] expected)	Reads 32 bytes and compares them to expected in constant time.
byte[]	getToken()
TikaJsonConfig	loadConfig()	Loads the config without resolving env references: the parent already did.
static byte[]	newToken()
static ForkBootstrap	read(InputStream in)
static byte[]	toBytes(TikaJsonConfig tikaJsonConfig)	Serializes the parent's loaded config.
static void	write(OutputStream out, byte[] token, byte[] config)

Methods inherited from class java.lang.Object

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

Field Details

TOKEN_LENGTH_BYTES

public static final int TOKEN_LENGTH_BYTES

See Also:

• Constant Field Values

Method Details

newToken

public static byte[] newToken()

toBytes

public static byte[] toBytes(TikaJsonConfig tikaJsonConfig)
                      throws IOException

Serializes the parent's loaded config. Its env references are already resolved, so the bytes may carry secrets; they travel only over the fork's stdin.

Throws:

IOException

write

public static void write(OutputStream out,
 byte[] token,
 byte[] config)
                  throws IOException

Throws:

IOException

read

public static ForkBootstrap read(InputStream in)
                          throws IOException

Throws:

IOException

checkToken

public static boolean checkToken(InputStream in,
 byte[] expected)
                          throws IOException

Reads 32 bytes and compares them to expected in constant time. False on a short read or a mismatch.

Throws:

IOException

getToken

public byte[] getToken()

loadConfig

public TikaJsonConfig loadConfig()
                          throws TikaConfigException

Loads the config without resolving env references: the parent already did.

Throws:

TikaConfigException