alluxio.master.file

Class FileSystemMasterClientServiceProcessor

java.lang.Object

org.apache.thrift.TBaseProcessor<I>

alluxio.thrift.AlluxioService.Processor<I>

alluxio.thrift.FileSystemMasterClientService.Processor

alluxio.master.file.FileSystemMasterClientServiceProcessor

All Implemented Interfaces:

org.apache.thrift.TProcessor

public class FileSystemMasterClientServiceProcessor
extends FileSystemMasterClientService.Processor

Alluxio customized Thrift processor to handle RPC and track client IP. Original Thrift framework does not expose client IP because: a) there is no such interface to query IP. b) IP is not stored by Thrift. c) The last stop from Thrift framework into Alluxio land is the ProcessFunction.process(int, org.apache.thrift.protocol.TProtocol, org.apache.thrift.protocol.TProtocol, I) method of ProcessFunction class. This method has the information of in protocol from which we can derive IP. However, this method is made final deliberately. Consequently, it is very hard to subclass ProcessFunction and override process method to pass IP informaton to Alluxio via arguments. Based on a), b) and c), we decide to subclass the auto-generated FileSystemMasterClientService.Processor class and override its ProcessFunction.process(int, org.apache.thrift.protocol.TProtocol, org.apache.thrift.protocol.TProtocol, I) method. In this method, we store the client IP as a thread-local variable for future use by DefaultFileSystemMaster.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.thrift.FileSystemMasterClientService.Processor

FileSystemMasterClientService.Processor.checkConsistency<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.completeFile<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.createDirectory<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.createFile<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.free<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.getFilePath<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.getMountTable<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.getNewBlockIdForFile<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.getStatus<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.listStatus<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.loadMetadata<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.mount<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.remove<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.rename<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.scheduleAsyncPersistence<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.setAttribute<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.unmount<I extends FileSystemMasterClientService.Iface>, FileSystemMasterClientService.Processor.updateUfsMode<I extends FileSystemMasterClientService.Iface>

Nested classes/interfaces inherited from class alluxio.thrift.AlluxioService.Processor

AlluxioService.Processor.getServiceVersion<I extends AlluxioService.Iface>

Constructor Summary

Constructors

Constructor and Description
FileSystemMasterClientServiceProcessor(FileSystemMasterClientService.Iface handler) Constructs a FileSystemMasterClientServiceProcessor instance.

Method Summary

Modifier and Type	Method and Description
static String	getClientIp() Retrieves the client IP of current thread.
boolean	process(org.apache.thrift.protocol.TProtocol in, org.apache.thrift.protocol.TProtocol out)

Methods inherited from class org.apache.thrift.TBaseProcessor

getProcessMapView

Methods inherited from class java.lang.Object

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

Constructor Detail

FileSystemMasterClientServiceProcessor

public FileSystemMasterClientServiceProcessor(FileSystemMasterClientService.Iface handler)

Constructs a FileSystemMasterClientServiceProcessor instance.

Parameters:

handler - user-specified handler to process RPC

Method Detail

getClientIp

public static String getClientIp()

Retrieves the client IP of current thread.

Returns:

the IP of the client of current thread

process

public boolean process(org.apache.thrift.protocol.TProtocol in,
                       org.apache.thrift.protocol.TProtocol out)
                throws org.apache.thrift.TException

Specified by:

process in interface org.apache.thrift.TProcessor

Overrides:

process in class org.apache.thrift.TBaseProcessor

Throws:

org.apache.thrift.TException