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 DistributedWorkManagerStatistics
values
- The valuespublic void join(Address address)
join
in interface NotificationListener
address
- The addresspublic void leave(Address address)
leave
in interface NotificationListener
address
- The addresspublic void updateShortRunningFree(Address address, long free)
updateShortRunningFree
in interface NotificationListener
address
- The addressfree
- The number of free threadspublic void updateLongRunningFree(Address address, long free)
updateLongRunningFree
in interface NotificationListener
address
- The addressfree
- The number of free threadspublic int getWorkActive()
getWorkActive
in interface WorkManagerStatistics
public int getWorkSuccessful()
getWorkSuccessful
in interface WorkManagerStatistics
public void deltaWorkSuccessful()
deltaWorkSuccessful
in interface NotificationListener
public int getWorkFailed()
getWorkFailed
in interface WorkManagerStatistics
public void deltaWorkFailed()
deltaWorkFailed
in interface NotificationListener
public int getDoWorkAccepted()
getDoWorkAccepted
in interface WorkManagerStatistics
public void deltaDoWorkAccepted()
deltaDoWorkAccepted
in interface NotificationListener
public int getDoWorkRejected()
getDoWorkRejected
in interface WorkManagerStatistics
public void deltaDoWorkRejected()
deltaDoWorkRejected
in interface NotificationListener
public int getScheduleWorkAccepted()
getScheduleWorkAccepted
in interface WorkManagerStatistics
public void deltaScheduleWorkAccepted()
deltaScheduleWorkAccepted
in interface NotificationListener
public int getScheduleWorkRejected()
getScheduleWorkRejected
in interface WorkManagerStatistics
public void deltaScheduleWorkRejected()
deltaScheduleWorkRejected
in interface NotificationListener
public int getStartWorkAccepted()
getStartWorkAccepted
in interface WorkManagerStatistics
public void deltaStartWorkAccepted()
deltaStartWorkAccepted
in interface NotificationListener
public int getStartWorkRejected()
getStartWorkRejected
in interface WorkManagerStatistics
public void deltaStartWorkRejected()
deltaStartWorkRejected
in interface NotificationListener
public void clear()
clear
in interface WorkManagerStatistics
public java.lang.String toString()
toString
in class java.lang.Object
Copyright © 2013 IronJacamar (http://www.ironjacamar.org)