1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
|
// SPDX-License-Identifier: GPL-3.0-or-later
#include "rrdfunctions-inline.h"
struct rrd_function_inline {
rrd_function_execute_inline_cb_t cb;
};
static int rrd_function_run_inline(struct rrd_function_execute *rfe, void *data) {
// IMPORTANT: this function MUST call the result_cb even on failures
struct rrd_function_inline *fi = data;
int code;
if(rfe->is_cancelled.cb && rfe->is_cancelled.cb(rfe->is_cancelled.data))
code = HTTP_RESP_CLIENT_CLOSED_REQUEST;
else
code = fi->cb(rfe->result.wb, rfe->function, rfe->payload, rfe->source);
if(code == HTTP_RESP_CLIENT_CLOSED_REQUEST || (rfe->is_cancelled.cb && rfe->is_cancelled.cb(rfe->is_cancelled.data))) {
buffer_flush(rfe->result.wb);
code = HTTP_RESP_CLIENT_CLOSED_REQUEST;
}
if(rfe->result.cb)
rfe->result.cb(rfe->result.wb, code, rfe->result.data);
return code;
}
void rrd_function_add_inline(RRDHOST *host, RRDSET *st, const char *name, int timeout, int priority, uint32_t version,
const char *help, const char *tags,
HTTP_ACCESS access, rrd_function_execute_inline_cb_t execute_cb) {
rrd_collector_started(); // this creates a collector that runs for as long as netdata runs
struct rrd_function_inline *fi = callocz(1, sizeof(struct rrd_function_inline));
fi->cb = execute_cb;
rrd_function_add(host, st, name, timeout, priority, version,
help, tags, access, true,
rrd_function_run_inline, fi);
}
|
