in src/main/java/com/revo/deployr/rbroker/example/service/FraudService.java [323:361]
private RuntimeStats populateRuntimeStats(RuntimeStats runtimeStats,
RBrokerRuntimeStats stats) {
runtimeStats.requestedPoolSize = brokerConfig.maxConcurrentTaskLimit;
runtimeStats.allocatedPoolSize = lastAllocatedPoolSize;
runtimeStats.maxConcurrency = rBroker.maxConcurrency();
runtimeStats.endpoint = brokerConfig.deployrEndpoint;
if(brokerConfig.userCredentials != null) {
runtimeStats.username =
((RBasicAuthentication) brokerConfig.userCredentials).getUsername();
}
if(stats != null) {
runtimeStats.submittedTasks = stats.totalTasksRun;
runtimeStats.successfulTasks = stats.totalTasksRunToSuccess;
runtimeStats.failedTasks = stats.totalTasksRunToFailure;
runtimeStats.averageCodeExecution = 0L;
runtimeStats.averageServerOverhead = 0L;
runtimeStats.averageNetworkLatency = 0L;
if(stats.totalTasksRunToSuccess > 0) {
runtimeStats.averageCodeExecution =
stats.totalTimeTasksOnCode/stats.totalTasksRunToSuccess;
long avgTimeOnServer =
stats.totalTimeTasksOnServer/stats.totalTasksRunToSuccess;
runtimeStats.averageServerOverhead =
avgTimeOnServer - runtimeStats.averageCodeExecution;
long avgTimeOnCall =
stats.totalTimeTasksOnCall/stats.totalTasksRunToSuccess;
runtimeStats.averageNetworkLatency =
avgTimeOnCall - avgTimeOnServer;
}
}
return runtimeStats;
}