org.apache.storm.daemon.supervisor

Class AdvancedFSOps

java.lang.Object

org.apache.storm.daemon.supervisor.AdvancedFSOps

public class AdvancedFSOps
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	_symlinksDisabled

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AdvancedFSOps(Map<String,Object> conf)

Method Summary

Modifier and Type	Method and Description
void	copyDirectory(File fromDir, File toDir) Copy a directory
void	createSymlink(File link, File target) Create a symbolic link pointing at target
void	deleteIfExists(File path) Delete a file or a directory and all of the children.
void	deleteIfExists(File path, String user, String logPrefix) Delete a file or a directory and all of the children.
boolean	doRequiredTopoFilesExist(Map<String,Object> conf, String topologyId) Sanity check if everything the topology needs is there for it to run.
void	dump(File location, String data) Dump a string to a file
boolean	fileExists(File path) Check if a file exists or not
void	forceMkdir(File path) Makes a directory, including any necessary but nonexistent parent directories.
OutputStream	getOutputStream(File file) Get an output stream to write to a given file
Writer	getWriter(File file) Get a writer for the given location
static AdvancedFSOps	make(Map<String,Object> conf) Factory to create a new AdvancedFSOps
void	moveDirectoryPreferAtomic(File fromDir, File toDir) Move fromDir to toDir, and try to make it an atomic move if possible
void	restrictDirectoryPermissions(File dir) Set directory permissions to (OWNER)RWX (GROUP)R-X (OTHER)— On some systems that do not support this, it may become a noop
void	setupBlobPermissions(File path, String user) Setup permissions properly for an internal blob store path
void	setupStormCodeDir(String user, File path) Setup the permissions for the storm code dir
void	setupWorkerArtifactsDir(String user, File path) Setup the permissions for the worker artifacts dirs
byte[]	slurp(File location) Read the contents of a file into a byte array.
String	slurpString(File location) Read the contents of a file into a String
boolean	supportsAtomicDirectoryMove()

Methods inherited from class java.lang.Object

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

Field Detail

_symlinksDisabled

protected final boolean _symlinksDisabled

Constructor Detail

AdvancedFSOps

protected AdvancedFSOps(Map<String,Object> conf)

Method Detail

make

public static AdvancedFSOps make(Map<String,Object> conf)

Factory to create a new AdvancedFSOps

Parameters:

conf - the configuration of the process

Returns:

the appropriate instance of the class for this config and environment.

restrictDirectoryPermissions

public void restrictDirectoryPermissions(File dir)
                                  throws IOException

Set directory permissions to (OWNER)RWX (GROUP)R-X (OTHER)— On some systems that do not support this, it may become a noop

Parameters:

dir - the directory to change permissions on

Throws:

IOException - on any error

moveDirectoryPreferAtomic

public void moveDirectoryPreferAtomic(File fromDir,
                                      File toDir)
                               throws IOException

Move fromDir to toDir, and try to make it an atomic move if possible

Parameters:

fromDir - what to move

toDir - where to move it from

Throws:

IOException - on any error

supportsAtomicDirectoryMove

public boolean supportsAtomicDirectoryMove()

Returns:

true if an atomic directory move works, else false.

copyDirectory

public void copyDirectory(File fromDir,
                          File toDir)
                   throws IOException

Copy a directory

Parameters:

fromDir - from where

toDir - to where

Throws:

IOException - on any error

setupBlobPermissions

public void setupBlobPermissions(File path,
                                 String user)
                          throws IOException

Setup permissions properly for an internal blob store path

Parameters:

path - the path to set the permissions on

user - the user to change the permissions for

Throws:

IOException - on any error

deleteIfExists

public void deleteIfExists(File path,
                           String user,
                           String logPrefix)
                    throws IOException

Delete a file or a directory and all of the children. If it exists.

Parameters:

path - what to delete

user - who to delete it as if doing it as someone else is supported

logPrefix - if an external process needs to be launched to delete the object what prefix to include in the logs

Throws:

IOException - on any error.

deleteIfExists

public void deleteIfExists(File path)
                    throws IOException

Delete a file or a directory and all of the children. If it exists.

Parameters:

path - what to delete

Throws:

IOException - on any error.

setupStormCodeDir

public void setupStormCodeDir(String user,
                              File path)
                       throws IOException

Setup the permissions for the storm code dir

Parameters:

user - the user that owns the topology

path - the directory to set the permissions on

Throws:

IOException - on any error

setupWorkerArtifactsDir

public void setupWorkerArtifactsDir(String user,
                                    File path)
                             throws IOException

Setup the permissions for the worker artifacts dirs

Parameters:

user - the user that owns the topology

path - the directory to set the permissions on

Throws:

IOException - on any error

doRequiredTopoFilesExist

public boolean doRequiredTopoFilesExist(Map<String,Object> conf,
                                        String topologyId)
                                 throws IOException

Sanity check if everything the topology needs is there for it to run.

Parameters:

conf - the config of the supervisor

topologyId - the ID of the topology

Returns:

true if everything is there, else false

Throws:

IOException - on any error

forceMkdir

public void forceMkdir(File path)
                throws IOException

Makes a directory, including any necessary but nonexistent parent directories.

Parameters:

path - the directory to create

Throws:

IOException - on any error

fileExists

public boolean fileExists(File path)
                   throws IOException

Check if a file exists or not

Parameters:

path - the path to check

Returns:

true if it exists else false

Throws:

IOException - on any error.

getWriter

public Writer getWriter(File file)
                 throws IOException

Get a writer for the given location

Parameters:

file - the file to write to

Returns:

the Writer to use.

Throws:

IOException - on any error

getOutputStream

public OutputStream getOutputStream(File file)
                             throws IOException

Get an output stream to write to a given file

Parameters:

file - the file to write to

Returns:

an OutputStream for that file

Throws:

IOException - on any error

dump

public void dump(File location,
                 String data)
          throws IOException

Dump a string to a file

Parameters:

location - where to write to

data - the data to write

Throws:

IOException - on any error

slurpString

public String slurpString(File location)
                   throws IOException

Read the contents of a file into a String

Parameters:

location - the file to read

Returns:

the contents of the file

Throws:

IOException - on any error

slurp

public byte[] slurp(File location)
             throws IOException

Read the contents of a file into a byte array.

Parameters:

localtion - the file to read

Returns:

the contents of the file

Throws:

IOException - on any error

createSymlink

public void createSymlink(File link,
                          File target)
                   throws IOException

Create a symbolic link pointing at target

Parameters:

link - the link to create

target - where it should point to

Throws:

IOException - on any error.