
public class DistributedWorkManagerStatisticsImpl extends java.lang.Object implements DistributedWorkManagerStatistics, NotificationListener
| Constructor and Description |
|---|
DistributedWorkManagerStatisticsImpl()
Constructor
|
DistributedWorkManagerStatisticsImpl(Address ownId,
Transport t)
Constructor
|
| Modifier and Type | Method and Description |
|---|---|
void |
clear()
Clear the statistics
|
void |
deltaDoWorkAccepted()
Delta doWork accepted
|
void |
deltaDoWorkRejected()
Delta doWork rejected
|
void |
deltaScheduleWorkAccepted()
Delta scheduleWork accepted
|
void |
deltaScheduleWorkRejected()
Delta scheduleWork rejected
|
void |
deltaStartWorkAccepted()
Delta startWork accepted
|
void |
deltaStartWorkRejected()
Delta startWork rejected
|
void |
deltaWorkFailed()
Delta work failed
|
void |
deltaWorkSuccessful()
Delta work successful
|
int |
getDoWorkAccepted()
DoWork: Accepted
|
int |
getDoWorkRejected()
DoWork: Rejected
|
int |
getScheduleWorkAccepted()
ScheduleWork: Accepted
|
int |
getScheduleWorkRejected()
ScheduleWork: Rejected
|
int |
getStartWorkAccepted()
StartWork: Accepted
|
int |
getStartWorkRejected()
StartWork: Rejected
|
int |
getWorkActive()
Work: Active
|
int |
getWorkFailed()
Work: Failed
|
int |
getWorkSuccessful()
Work: Successful
|
void |
initialize(DistributedWorkManagerStatisticsValues values)
Initialize the statistics
|
void |
join(Address address)
A distributed work manager joined
|
void |
leave(Address address)
A distributed work manager left
|
void |
setOwnId(Address v)
Set own id
|
void |
setTransport(Transport v)
Set transport
|
java.lang.String |
toString()
String representation
|
void |
updateLongRunningFree(Address address,
long free)
Update the long thread pool information for a distributed work manager
|
void |
updateShortRunningFree(Address address,
long free)
Update the short thread pool information for a distributed work manager
|
public DistributedWorkManagerStatisticsImpl()
public void setOwnId(Address v)
v - The valuepublic void setTransport(Transport v)
v - The valuepublic void initialize(DistributedWorkManagerStatisticsValues values)
initialize in interface DistributedWorkManagerStatisticsvalues - The valuespublic void join(Address address)
join in interface NotificationListeneraddress - The addresspublic void leave(Address address)
leave in interface NotificationListeneraddress - The addresspublic void updateShortRunningFree(Address address, long free)
updateShortRunningFree in interface NotificationListeneraddress - The addressfree - The number of free threadspublic void updateLongRunningFree(Address address, long free)
updateLongRunningFree in interface NotificationListeneraddress - The addressfree - The number of free threadspublic int getWorkActive()
getWorkActive in interface WorkManagerStatisticspublic int getWorkSuccessful()
getWorkSuccessful in interface WorkManagerStatisticspublic void deltaWorkSuccessful()
deltaWorkSuccessful in interface NotificationListenerpublic int getWorkFailed()
getWorkFailed in interface WorkManagerStatisticspublic void deltaWorkFailed()
deltaWorkFailed in interface NotificationListenerpublic int getDoWorkAccepted()
getDoWorkAccepted in interface WorkManagerStatisticspublic void deltaDoWorkAccepted()
deltaDoWorkAccepted in interface NotificationListenerpublic int getDoWorkRejected()
getDoWorkRejected in interface WorkManagerStatisticspublic void deltaDoWorkRejected()
deltaDoWorkRejected in interface NotificationListenerpublic int getScheduleWorkAccepted()
getScheduleWorkAccepted in interface WorkManagerStatisticspublic void deltaScheduleWorkAccepted()
deltaScheduleWorkAccepted in interface NotificationListenerpublic int getScheduleWorkRejected()
getScheduleWorkRejected in interface WorkManagerStatisticspublic void deltaScheduleWorkRejected()
deltaScheduleWorkRejected in interface NotificationListenerpublic int getStartWorkAccepted()
getStartWorkAccepted in interface WorkManagerStatisticspublic void deltaStartWorkAccepted()
deltaStartWorkAccepted in interface NotificationListenerpublic int getStartWorkRejected()
getStartWorkRejected in interface WorkManagerStatisticspublic void deltaStartWorkRejected()
deltaStartWorkRejected in interface NotificationListenerpublic void clear()
clear in interface WorkManagerStatisticspublic java.lang.String toString()
toString in class java.lang.ObjectCopyright © 2014 IronJacamar (http://www.ironjacamar.org)