#include <Notification.h>
Public Member Functions | |
Notification () | |
Notification (const std::string host, const u_int16_t port) | |
Notification (const std::string notifId) | |
~Notification () | |
std::string | getNotifId () const |
time_t | getValid () const |
int | getFd () const |
void | addJob (const glite::wmsutils::jobid::JobId &jobId) |
void | removeJob (const glite::wmsutils::jobid::JobId &jobId) |
std::string | getJobs () |
void | setStates (const std::vector< glite::lb::JobStatus::Code > &) |
std::string | getStates () |
void | Register () |
void | Bind (const std::string address) |
int | receive (glite::lb::JobStatus &, timeval &) |
|
Create an empty object to be used for new notifications, i.e. with Register() |
|
Create from server host,port pair to be used for new notifications, i.e. with Register()
|
|
Create from NotifId to be used for existing notifications, i.e. with Bind()
|
|
|
|
Add this job to the list. Local operation only, Register() has to be called to propagate changes to server
|
|
Bind to the existing notification at the server i.e. change the receiving local address
|
|
retrieve local listener filedescriptor |
|
Get jobs on the list |
|
retrieve NotifId |
|
Get states |
|
retrieve time until when it is valid |
|
Receive notification. Blocks at most the specified timeout (maybe 0 for local polling).
|
|
Register (or re-register, i.e. change and extend) with the server |
|
Remove job from the list, local op again.
|
|
Receive notifications on these states |