Commit ec63324b authored by Timothy Stack's avatar Timothy Stack
Browse files

Update the db when timelines and sequences are started/stopped.

parent 70792420
...@@ -1292,7 +1292,8 @@ handle_completeevent(event_handle_t handle, sched_event_t *eventp) ...@@ -1292,7 +1292,8 @@ handle_completeevent(event_handle_t handle, sched_event_t *eventp)
ctoken, ctoken,
agerror); agerror);
if (strcmp(objtype, TBDB_OBJECTTYPE_TIMELINE) == 0) { if ((strcmp(objtype, TBDB_OBJECTTYPE_TIMELINE) == 0) ||
(strcmp(objtype, TBDB_OBJECTTYPE_SEQUENCE) == 0)) {
RPC_grab(); RPC_grab();
RPC_notifystart(pid, eid, objname, 0); RPC_notifystart(pid, eid, objname, 0);
RPC_drop(); RPC_drop();
......
...@@ -316,7 +316,7 @@ static int timeline_agent_immediate(local_agent_t la, sched_event_t *se) ...@@ -316,7 +316,7 @@ static int timeline_agent_immediate(local_agent_t la, sched_event_t *se)
struct timeval now, then; struct timeval now, then;
int token, lpc; int token, lpc;
if (strcmp(la->la_agent->name, "__ns_timeline") != 0) { if (strncmp(la->la_agent->name, "__", 2) != 0) {
RPC_grab(); RPC_grab();
RPC_notifystart(pid, eid, la->la_agent->name, 1); RPC_notifystart(pid, eid, la->la_agent->name, 1);
RPC_drop(); RPC_drop();
...@@ -390,6 +390,13 @@ static int sequence_agent_immediate(local_agent_t la, sched_event_t *se) ...@@ -390,6 +390,13 @@ static int sequence_agent_immediate(local_agent_t la, sched_event_t *se)
sa->ta_local_agent.la_link.ln_Name); sa->ta_local_agent.la_link.ln_Name);
} }
else if (sa->ta_count > 0) { else if (sa->ta_count > 0) {
if (strncmp(la->la_agent->name, "__", 2) != 0) {
RPC_grab();
RPC_notifystart(pid, eid,
la->la_agent->name, 1);
RPC_drop();
}
event_notification_get_int32(handle, event_notification_get_int32(handle,
se->notification, se->notification,
"TOKEN", "TOKEN",
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment