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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
/**
* @file oper_pull_push_example.c
* @author Michal Vasko <mvasko@cesnet.cz>
* @brief example of an application providing some operational data
*
* @copyright
* Copyright (c) 2020 CESNET, z.s.p.o.
*
* This source code is licensed under BSD 3-Clause License (the "License").
* You may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* https://opensource.org/licenses/BSD-3-Clause
*/
#define _GNU_SOURCE
#include <inttypes.h>
#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <libyang/libyang.h>
#include "sysrepo.h"
static int
dp_get_items_cb(sr_session_ctx_t *session, uint32_t sub_id, const char *module_name, const char *xpath,
const char *request_xpath, uint32_t request_id, struct lyd_node **parent, void *private_data)
{
const struct ly_ctx *ly_ctx;
(void)session;
(void)sub_id;
(void)request_xpath;
(void)request_id;
(void)private_data;
if (!strcmp(module_name, "examples") && !strcmp(xpath, "/examples:stats")) {
ly_ctx = sr_acquire_context(sr_session_get_connection(session));
lyd_new_path(NULL, ly_ctx, "/examples:stats/counter", "852", 0, parent);
lyd_new_path(*parent, NULL, "/examples:stats/counter2", "1052", 0, NULL);
sr_release_context(sr_session_get_connection(session));
}
return SR_ERR_OK;
}
int
main(void)
{
sr_conn_ctx_t *connection = NULL;
sr_session_ctx_t *session = NULL;
sr_subscription_ctx_t *subscription = NULL;
int rc = SR_ERR_OK;
const char *mod_name, *path;
sr_data_t *data;
path = "/examples:stats";
mod_name = "examples";
/* turn logging on */
sr_log_stderr(SR_LL_WRN);
/* connect to sysrepo */
rc = sr_connect(0, &connection);
if (rc != SR_ERR_OK) {
goto cleanup;
}
/* start session in operational datastore */
rc = sr_session_start(connection, SR_DS_OPERATIONAL, &session);
if (rc != SR_ERR_OK) {
goto cleanup;
}
printf("Application will provide data \"%s\" of \"%s\" using both pull and push operational data subscription.\n\n",
path, mod_name);
/* subscribe for providing pull operational data */
rc = sr_oper_get_subscribe(session, mod_name, path, dp_get_items_cb, NULL, 0, &subscription);
if (rc != SR_ERR_OK) {
goto cleanup;
}
/* get data */
printf("======= PULL OPERATIONAL DATA \"%s\" REQUESTED ========\n\n", path);
rc = sr_get_data(session, path, 0, 0, 0, &data);
if (rc != SR_ERR_OK) {
goto cleanup;
}
/* print data */
if (data) {
lyd_print_file(stdout, data->tree, LYD_XML, LYD_PRINT_WITHSIBLINGS);
}
printf("\n");
sr_release_data(data);
/* unsubscribe */
sr_unsubscribe(subscription);
/* set push operational data (their lifetime is limited by the lifetime of the connection!) */
rc = sr_set_item_str(session, "/examples:stats/counter", "852", NULL, 0);
if (rc != SR_ERR_OK) {
goto cleanup;
}
rc = sr_set_item_str(session, "/examples:stats/counter2", "1052", NULL, 0);
if (rc != SR_ERR_OK) {
goto cleanup;
}
rc = sr_apply_changes(session, 0);
if (rc != SR_ERR_OK) {
goto cleanup;
}
/* get data */
printf("======= PUSH OPERATIONAL DATA \"%s\" REQUESTED ========\n\n", path);
rc = sr_get_data(session, path, 0, 0, 0, &data);
if (rc != SR_ERR_OK) {
goto cleanup;
}
/* print data */
if (data) {
lyd_print_file(stdout, data->tree, LYD_XML, LYD_PRINT_WITHSIBLINGS);
}
printf("\n");
sr_release_data(data);
cleanup:
sr_disconnect(connection);
return rc ? EXIT_FAILURE : EXIT_SUCCESS;
}
|
