DeploymentSettings
A set of default parameter that controls Prajna execution behavior
Constructors
| Constructor | Description |
new()
Signature: unit -> DeploymentSettings
|
|
Static members
| Static member | Description |
BufferListBufferSize()
Signature: unit -> int
|
The buffer size of buffers in shared memory pool used by BufferListStream |
BufferListBufferSize()
Signature: unit -> unit
|
The buffer size of buffers in shared memory pool used by BufferListStream |
DataFolder
Signature: string
|
Directory at remote node that holds Prajna data files |
DefaultGroupBySerialization()
Signature: unit -> int
|
default group by size used in DSet |
DefaultGroupBySerialization()
Signature: unit -> unit
|
default group by size used in DSet |
DefaultLaunchBehavior()
Signature: unit -> TaskLaunchMode
|
Control whether determiate remote container of different versions. |
DefaultLaunchBehavior()
Signature: unit -> unit
|
Control whether determiate remote container of different versions. |
DefaultSerializationLimit()
Signature: unit -> int
|
Default SerializationLimit for a DSet |
DefaultSerializationLimit()
Signature: unit -> unit
|
Default SerializationLimit for a DSet |
EnvStringGetJobDirectory()
Signature: unit -> string
|
Use curJob.EnvVars.Add( envvar, DeploymentSettings.EnvStringGetJobDirectory) to setup environment string in relationship to the JobDirectory of the remote container. |
EnvStringGetJobDirectory()
Signature: unit -> unit
|
Use curJob.EnvVars.Add( envvar, DeploymentSettings.EnvStringGetJobDirectory) to setup environment string in relationship to the JobDirectory of the remote container. |
EnvStringSetJobDirectory()
Signature: unit -> string
|
Use curJob.EnvVars.Add(DeploymentSettings.EnvStringSetJobDirectory, depDirname ) to set the JobDirectory of remote container, where curJob is the current JobDependency object. |
EnvStringSetJobDirectory()
Signature: unit -> unit
|
Use curJob.EnvVars.Add(DeploymentSettings.EnvStringSetJobDirectory, depDirname ) to set the JobDirectory of remote container, where curJob is the current JobDependency object. |
ExecutionLevelTouchAssembly()
Signature: unit -> LogLevel
|
Whether we will touch file when dependency/assembly is copied as a SHA256 named file in the remote node. set the parameter to LogLevel.Info will touch dependecy/assembly when they are written. |
ExecutionLevelTouchAssembly()
Signature: unit -> unit
|
Whether we will touch file when dependency/assembly is copied as a SHA256 named file in the remote node. set the parameter to LogLevel.Info will touch dependecy/assembly when they are written. |
GetAllDataDrivesInfo()
Signature: unit -> unit -> seq<string * int64>
|
|
GetAllDataDrivesInfo()
Signature: unit -> unit
|
|
HashFolder
Signature: string
|
Directory at remote node that holds strong hashed file of the remote execution roster. |
InitBufferListNumBuffers()
Signature: unit -> int
|
The initial # of buffers for shared memory pool used by BufferListStream |
InitBufferListNumBuffers()
Signature: unit -> unit
|
The initial # of buffers for shared memory pool used by BufferListStream |
InitNetworkSocketAsyncEventArgBuffers()
Signature: unit -> int
|
The initial # of buffers in SocketAsyncEventArg stack |
InitNetworkSocketAsyncEventArgBuffers()
Signature: unit -> unit
|
The initial # of buffers in SocketAsyncEventArg stack |
IsDataDrive()
Signature: unit -> string -> bool
|
Is data drive |
IsDataDrive()
Signature: unit -> unit
|
Is data drive |
LaunchDebugMode()
Signature: unit -> DebugMode
|
Control the launch of container in Debug or Release mode. |
LaunchDebugMode()
Signature: unit -> unit
|
Control the launch of container in Debug or Release mode. |
LocalClusterTraceLevel()
Signature: unit -> LogLevel
|
Default Trace Level to start Local Cluster |
LocalClusterTraceLevel()
Signature: unit -> unit
|
Default Trace Level to start Local Cluster |
LocalFolder
Signature: string
|
Directory at remote node that holds Prajna operating state. |
MaxNetworkStackMemory()
Signature: unit -> int
|
Maximum network stack memory (total across all connections), 0 means unbounded (in bytes) |
MaxNetworkStackMemory()
Signature: unit -> unit
|
Maximum network stack memory (total across all connections), 0 means unbounded (in bytes) |
MaxNetworkStackMemoryPercentage()
Signature: unit -> float<MeasureOne>
|
Maximum network stack memory (total across all connections) as percentage of total (as percent) |
MaxNetworkStackMemoryPercentage()
Signature: unit -> unit
|
Maximum network stack memory (total across all connections) as percentage of total (as percent) |
MaxSendingQueueLimit()
Signature: unit -> int
|
JinL to SanjeevM: can you please provide explanation for the following three parameters? Maximum combined buffer devoted to sending queue (in bytes) |
MaxSendingQueueLimit()
Signature: unit -> unit
|
JinL to SanjeevM: can you please provide explanation for the following three parameters? Maximum combined buffer devoted to sending queue (in bytes) |
MaxWaitToEndJobInMilliseconds()
Signature: unit -> int
|
If a job is idle for this much time, it is considered to have problems, and may be cancelled. |
MaxWaitToEndJobInMilliseconds()
Signature: unit -> unit
|
If a job is idle for this much time, it is considered to have problems, and may be cancelled. |
NetworkCmdRecvQSize()
Signature: unit -> int
|
The size of network command queue for receiving |
NetworkCmdRecvQSize()
Signature: unit -> unit
|
The size of network command queue for receiving |
NetworkCmdSendQSize()
Signature: unit -> int
|
The size of network command queue for sending |
NetworkCmdSendQSize()
Signature: unit -> unit
|
The size of network command queue for sending |
NetworkSARecvQSize()
Signature: unit -> int
|
The size of network socket async event args queue for receiving |
NetworkSARecvQSize()
Signature: unit -> unit
|
The size of network socket async event args queue for receiving |
NetworkSASendQSize()
Signature: unit -> int
|
The size of network socket async event args queue for sending |
NetworkSASendQSize()
Signature: unit -> unit
|
The size of network socket async event args queue for sending |
NetworkSocketAsyncEventArgBufferSize()
Signature: unit -> int
|
The buffer size used by SocketAsyncEventArgs |
NetworkSocketAsyncEventArgBufferSize()
Signature: unit -> unit
|
The buffer size used by SocketAsyncEventArgs |
NumNetworkThreads()
Signature: unit -> int
|
Number of threads for network processing |
NumNetworkThreads()
Signature: unit -> unit
|
Number of threads for network processing |
RemappingIntervalInMillisecond
Signature: int
|
Remapping interval (in sec ), that the host will seek to find a new peer to assign a partition. |
RemoteContainerEstablishmentTimeoutLimit(...)
Signature: unit -> int64
|
Timeout when trying to setup a remote container (in seconds). The default value is 30 seconds. If the remote execution roster is particularly large, e.g., including data files of multi-gigabyte in size, the program should enlarge this timeout value so that there is time to send the entire remote execution roster to the remote node. |
RemoteContainerEstablishmentTimeoutLimit(...)
Signature: unit -> unit
|
Timeout when trying to setup a remote container (in seconds). The default value is 30 seconds. If the remote execution roster is particularly large, e.g., including data files of multi-gigabyte in size, the program should enlarge this timeout value so that there is time to send the entire remote execution roster to the remote node. |
TCPRcvBufSize()
Signature: unit -> int
|
TCP receiving buffer size |
TCPRcvBufSize()
Signature: unit -> unit
|
TCP receiving buffer size |
TCPSendBufSize()
Signature: unit -> int
|
JinL to SanjeevM: Please review the following parameter should this parameter be scaled according to number of connections? If there are thousands of connections, will the TCP Send/Receive buffer take too large a size? TCP sending buffer size |
TCPSendBufSize()
Signature: unit -> unit
|
JinL to SanjeevM: Please review the following parameter should this parameter be scaled according to number of connections? If there are thousands of connections, will the TCP Send/Receive buffer take too large a size? TCP sending buffer size |
