This source file includes following definitions.
- new_data
- free_data
- post_connect
- reply_expected
- dispatch
- pcmk__schedulerd_api_methods
- do_schedulerd_api_call
- pcmk_schedulerd_api_graph
1
2
3
4
5
6
7
8
9
10 #include <crm_internal.h>
11
12 #include <stdlib.h>
13 #include <time.h>
14
15 #include <crm/crm.h>
16 #include <crm/msg_xml.h>
17 #include <crm/common/xml.h>
18 #include <crm/common/ipc.h>
19 #include <crm/common/ipc_internal.h>
20 #include <crm/common/ipc_schedulerd.h>
21 #include "crmcommon_private.h"
22
23 typedef struct schedulerd_api_private_s {
24 char *client_uuid;
25 } schedulerd_api_private_t;
26
27
28 static int
29 new_data(pcmk_ipc_api_t *api)
30 {
31 struct schedulerd_api_private_s *private = NULL;
32
33 api->api_data = calloc(1, sizeof(struct schedulerd_api_private_s));
34
35 if (api->api_data == NULL) {
36 return errno;
37 }
38
39 private = api->api_data;
40
41 private->client_uuid = pcmk__getpid_s();
42
43 return pcmk_rc_ok;
44 }
45
46 static void
47 free_data(void *data)
48 {
49 free(((struct schedulerd_api_private_s *) data)->client_uuid);
50 free(data);
51 }
52
53
54 static int
55 post_connect(pcmk_ipc_api_t *api)
56 {
57 if (api->api_data == NULL) {
58 return EINVAL;
59 }
60
61 return pcmk_rc_ok;
62 }
63
64 static bool
65 reply_expected(pcmk_ipc_api_t *api, xmlNode *request)
66 {
67 const char *command = crm_element_value(request, F_CRM_TASK);
68
69 if (command == NULL) {
70 return false;
71 }
72
73
74 return pcmk__str_any_of(command, CRM_OP_PECALC, NULL);
75 }
76
77 static bool
78 dispatch(pcmk_ipc_api_t *api, xmlNode *reply)
79 {
80 crm_exit_t status = CRM_EX_OK;
81 xmlNode *msg_data = NULL;
82 pcmk_schedulerd_api_reply_t reply_data = {
83 pcmk_schedulerd_reply_unknown
84 };
85 const char *value = NULL;
86
87 if (pcmk__str_eq((const char *) reply->name, "ack", pcmk__str_casei)) {
88 return false;
89 }
90
91 value = crm_element_value(reply, F_CRM_MSG_TYPE);
92 if (!pcmk__str_eq(value, XML_ATTR_RESPONSE, pcmk__str_none)) {
93 crm_info("Unrecognizable message from schedulerd: "
94 "message type '%s' not '" XML_ATTR_RESPONSE "'",
95 pcmk__s(value, ""));
96 status = CRM_EX_PROTOCOL;
97 goto done;
98 }
99
100 if (pcmk__str_empty(crm_element_value(reply, XML_ATTR_REFERENCE))) {
101 crm_info("Unrecognizable message from schedulerd: no reference");
102 status = CRM_EX_PROTOCOL;
103 goto done;
104 }
105
106
107 msg_data = get_message_xml(reply, F_CRM_DATA);
108 value = crm_element_value(reply, F_CRM_TASK);
109
110 if (pcmk__str_eq(value, CRM_OP_PECALC, pcmk__str_none)) {
111 reply_data.reply_type = pcmk_schedulerd_reply_graph;
112 reply_data.data.graph.reference = crm_element_value(reply, XML_ATTR_REFERENCE);
113 reply_data.data.graph.input = crm_element_value(reply, F_CRM_TGRAPH_INPUT);
114 reply_data.data.graph.tgraph = msg_data;
115 } else {
116 crm_info("Unrecognizable message from schedulerd: "
117 "unknown command '%s'", pcmk__s(value, ""));
118 status = CRM_EX_PROTOCOL;
119 goto done;
120 }
121
122 done:
123 pcmk__call_ipc_callback(api, pcmk_ipc_event_reply, status, &reply_data);
124 return false;
125 }
126
127 pcmk__ipc_methods_t *
128 pcmk__schedulerd_api_methods(void)
129 {
130 pcmk__ipc_methods_t *cmds = calloc(1, sizeof(pcmk__ipc_methods_t));
131
132 if (cmds != NULL) {
133 cmds->new_data = new_data;
134 cmds->free_data = free_data;
135 cmds->post_connect = post_connect;
136 cmds->reply_expected = reply_expected;
137 cmds->dispatch = dispatch;
138 }
139 return cmds;
140 }
141
142 static int
143 do_schedulerd_api_call(pcmk_ipc_api_t *api, const char *task, xmlNode *cib, char **ref)
144 {
145 schedulerd_api_private_t *private;
146 xmlNode *cmd = NULL;
147 int rc;
148
149 if (!pcmk_ipc_is_connected(api)) {
150 return ENOTCONN;
151 }
152
153 private = api->api_data;
154 CRM_ASSERT(private != NULL);
155
156 cmd = create_request(task, cib, NULL, CRM_SYSTEM_PENGINE,
157 crm_system_name? crm_system_name : "client",
158 private->client_uuid);
159
160 if (cmd) {
161 rc = pcmk__send_ipc_request(api, cmd);
162 if (rc != pcmk_rc_ok) {
163 crm_debug("Couldn't send request to schedulerd: %s rc=%d",
164 pcmk_rc_str(rc), rc);
165 }
166
167 *ref = strdup(crm_element_value(cmd, F_CRM_REFERENCE));
168 free_xml(cmd);
169 } else {
170 rc = ENOMSG;
171 }
172
173 return rc;
174 }
175
176 int
177 pcmk_schedulerd_api_graph(pcmk_ipc_api_t *api, xmlNode *cib, char **ref)
178 {
179 return do_schedulerd_api_call(api, CRM_OP_PECALC, cib, ref);
180 }