Package com.linkedin.davinci.blobtransfer.server

Class P2PBlobTransferService

java.lang.Object

com.linkedin.venice.service.AbstractVeniceService

com.linkedin.davinci.blobtransfer.server.P2PBlobTransferService

All Implemented Interfaces:

Closeable, AutoCloseable

public class P2PBlobTransferService
extends AbstractVeniceService

Nested Class Summary

Nested classes/interfaces inherited from class com.linkedin.venice.service.AbstractVeniceService

AbstractVeniceService.ServiceState

Field Summary

Fields inherited from class com.linkedin.venice.service.AbstractVeniceService

logger, serviceState

Constructor Summary

Constructors

Constructor

Description

P2PBlobTransferService(int port, String baseDir, int blobTransferMaxTimeoutInMin, BlobSnapshotManager blobSnapshotManager, io.netty.handler.traffic.GlobalChannelTrafficShapingHandler globalChannelTrafficShapingHandler, AggBlobTransferStats aggBlobTransferStats, Optional<SSLFactory> sslFactory, Optional<BlobTransferAclHandler> aclHandler, int maxAllowedConcurrentSnapshotUsers, long maxChunkSizeBytes, int clientCapacityPercent, boolean serverAcceptClientBlobRequestEnabled, boolean dedicatedAllocatorEnabled)

Method Summary

Modifier and Type	Method	Description
io.netty.buffer.PooledByteBufAllocator	getByteBufAllocator()	The allocator the accepted connections allocate from, which is PooledByteBufAllocator.DEFAULT unless a dedicated one is enabled.
boolean	startInner()
void	stopInner()

Methods inherited from class com.linkedin.venice.service.AbstractVeniceService

close, getName, isRunning, start, stop

Methods inherited from class java.lang.Object

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

Constructor Details

P2PBlobTransferService

public P2PBlobTransferService(int port,
 String baseDir,
 int blobTransferMaxTimeoutInMin,
 BlobSnapshotManager blobSnapshotManager,
 io.netty.handler.traffic.GlobalChannelTrafficShapingHandler globalChannelTrafficShapingHandler,
 AggBlobTransferStats aggBlobTransferStats,
 Optional<SSLFactory> sslFactory,
 Optional<BlobTransferAclHandler> aclHandler,
 int maxAllowedConcurrentSnapshotUsers,
 long maxChunkSizeBytes,
 int clientCapacityPercent,
 boolean serverAcceptClientBlobRequestEnabled,
 boolean dedicatedAllocatorEnabled)

Method Details

getByteBufAllocator

public io.netty.buffer.PooledByteBufAllocator getByteBufAllocator()

The allocator the accepted connections allocate from, which is PooledByteBufAllocator.DEFAULT unless a dedicated one is enabled.

startInner

public boolean startInner()
                   throws Exception

Specified by:

startInner in class AbstractVeniceService

Returns:

true if the service is completely started, false if it is still starting asynchronously (in this case, it is the implementer's responsibility to set AbstractVeniceService.serviceState to AbstractVeniceService.ServiceState.STARTED upon completion of the async work).

Throws:

Exception

stopInner

public void stopInner()
               throws Exception

Specified by:

stopInner in class AbstractVeniceService

Throws:

Exception