From ec63324b30442c599178fff68dc01e7f33874b5a Mon Sep 17 00:00:00 2001
From: Timothy Stack <stack@flux.utah.edu>
Date: Wed, 9 Mar 2005 16:34:30 +0000
Subject: [PATCH] Update the db when timelines and sequences are
started/stopped.
---
event/sched/event-sched.c | 3 ++-
event/sched/timeline-agent.c | 9 ++++++++-
2 files changed, 10 insertions(+), 2 deletions(-)
diff --git a/event/sched/event-sched.c b/event/sched/event-sched.c
index 6c642de1d6..0081480e70 100644
--- a/event/sched/event-sched.c
+++ b/event/sched/event-sched.c
@@ -1292,7 +1292,8 @@ handle_completeevent(event_handle_t handle, sched_event_t *eventp)
ctoken,
agerror);
- if (strcmp(objtype, TBDB_OBJECTTYPE_TIMELINE) == 0) {
+ if ((strcmp(objtype, TBDB_OBJECTTYPE_TIMELINE) == 0) ||
+ (strcmp(objtype, TBDB_OBJECTTYPE_SEQUENCE) == 0)) {
RPC_grab();
RPC_notifystart(pid, eid, objname, 0);
RPC_drop();
diff --git a/event/sched/timeline-agent.c b/event/sched/timeline-agent.c
index ae1483848b..58fa06148e 100644
--- a/event/sched/timeline-agent.c
+++ b/event/sched/timeline-agent.c
@@ -316,7 +316,7 @@ static int timeline_agent_immediate(local_agent_t la, sched_event_t *se)
struct timeval now, then;
int token, lpc;
- if (strcmp(la->la_agent->name, "__ns_timeline") != 0) {
+ if (strncmp(la->la_agent->name, "__", 2) != 0) {
RPC_grab();
RPC_notifystart(pid, eid, la->la_agent->name, 1);
RPC_drop();
@@ -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);
}
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,
se->notification,
"TOKEN",
--
GitLab