| /** |
| * \file session_client.c |
| * \author Michal Vasko <mvasko@cesnet.cz> |
| * \brief libnetconf2 session client functions |
| * |
| * Copyright (c) 2015 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 <assert.h> |
| #include <errno.h> |
| #include <fcntl.h> |
| #include <netdb.h> |
| #include <netinet/in.h> |
| #include <pthread.h> |
| #include <stdlib.h> |
| #include <string.h> |
| #include <sys/socket.h> |
| #include <sys/stat.h> |
| #include <sys/syscall.h> |
| #include <sys/types.h> |
| #include <unistd.h> |
| #include <arpa/inet.h> |
| #include <poll.h> |
| |
| #include <libyang/libyang.h> |
| |
| #include "libnetconf.h" |
| #include "session_client.h" |
| #include "messages_client.h" |
| |
| static const char *ncds2str[] = {NULL, "config", "url", "running", "startup", "candidate"}; |
| |
| #ifdef NC_ENABLED_SSH |
| int sshauth_hostkey_check(const char *hostname, ssh_session session, void *priv); |
| char *sshauth_password(const char *username, const char *hostname, void *priv); |
| char *sshauth_interactive(const char *auth_name, const char *instruction, const char *prompt, int echo, void *priv); |
| char *sshauth_privkey_passphrase(const char* privkey_path, void *priv); |
| #endif /* NC_ENABLED_SSH */ |
| |
| static pthread_once_t nc_client_context_once = PTHREAD_ONCE_INIT; |
| static pthread_key_t nc_client_context_key; |
| #ifdef __linux__ |
| static struct nc_client_context context_main = { |
| /* .opts zeroed */ |
| #ifdef NC_ENABLED_SSH |
| .ssh_opts = { |
| .auth_pref = {{NC_SSH_AUTH_INTERACTIVE, 3}, {NC_SSH_AUTH_PASSWORD, 2}, {NC_SSH_AUTH_PUBLICKEY, 1}}, |
| .auth_hostkey_check = sshauth_hostkey_check, |
| .auth_password = sshauth_password, |
| .auth_interactive = sshauth_interactive, |
| .auth_privkey_passphrase = sshauth_privkey_passphrase |
| }, |
| .ssh_ch_opts = { |
| .auth_pref = {{NC_SSH_AUTH_INTERACTIVE, 1}, {NC_SSH_AUTH_PASSWORD, 2}, {NC_SSH_AUTH_PUBLICKEY, 3}}, |
| .auth_hostkey_check = sshauth_hostkey_check, |
| .auth_password = sshauth_password, |
| .auth_interactive = sshauth_interactive, |
| .auth_privkey_passphrase = sshauth_privkey_passphrase |
| }, |
| #endif /* NC_ENABLED_SSH */ |
| /* .tls_ structures zeroed */ |
| .refcount = 0 |
| }; |
| #endif |
| |
| static void |
| nc_client_context_free(void *ptr) |
| { |
| struct nc_client_context *c = (struct nc_client_context *)ptr; |
| |
| if (--(c->refcount)) { |
| /* still used */ |
| return; |
| } |
| |
| #ifdef __linux__ |
| /* in __linux__ we use static memory in the main thread, |
| * so this check is for programs terminating the main() |
| * function by pthread_exit() :) |
| */ |
| if (c != &context_main) |
| #endif |
| { |
| /* for the main thread the same is done in nc_client_destroy() */ |
| nc_client_set_schema_searchpath(NULL); |
| #if defined(NC_ENABLED_SSH) || defined(NC_ENABLED_TLS) |
| nc_client_ch_del_bind(NULL, 0, 0); |
| #endif |
| #ifdef NC_ENABLED_SSH |
| nc_client_ssh_destroy_opts(); |
| #endif |
| #ifdef NC_ENABLED_TLS |
| nc_client_tls_destroy_opts(); |
| #endif |
| free(c); |
| } |
| } |
| |
| static void |
| nc_client_context_createkey(void) |
| { |
| int r; |
| |
| /* initiate */ |
| while ((r = pthread_key_create(&nc_client_context_key, nc_client_context_free)) == EAGAIN); |
| pthread_setspecific(nc_client_context_key, NULL); |
| } |
| |
| struct nc_client_context * |
| nc_client_context_location(void) |
| { |
| struct nc_client_context *e; |
| |
| pthread_once(&nc_client_context_once, nc_client_context_createkey); |
| e = pthread_getspecific(nc_client_context_key); |
| if (!e) { |
| /* prepare ly_err storage */ |
| #ifdef __linux__ |
| if (getpid() == syscall(SYS_gettid)) { |
| /* main thread - use global variable instead of thread-specific variable. */ |
| e = &context_main; |
| } else |
| #endif /* __linux__ */ |
| { |
| e = calloc(1, sizeof *e); |
| /* set default values */ |
| e->refcount = 1; |
| #ifdef NC_ENABLED_SSH |
| e->ssh_opts.auth_pref[0].type = NC_SSH_AUTH_INTERACTIVE; |
| e->ssh_opts.auth_pref[0].value = 3; |
| e->ssh_opts.auth_pref[1].type = NC_SSH_AUTH_PASSWORD; |
| e->ssh_opts.auth_pref[1].value = 2; |
| e->ssh_opts.auth_pref[2].type = NC_SSH_AUTH_PUBLICKEY; |
| e->ssh_opts.auth_pref[2].value = 1; |
| e->ssh_opts.auth_hostkey_check = sshauth_hostkey_check; |
| e->ssh_opts.auth_password = sshauth_password; |
| e->ssh_opts.auth_interactive = sshauth_interactive; |
| e->ssh_opts.auth_privkey_passphrase = sshauth_privkey_passphrase; |
| |
| /* callhome settings are the same except the inverted auth methods preferences */ |
| memcpy(&e->ssh_ch_opts, &e->ssh_opts, sizeof e->ssh_ch_opts); |
| e->ssh_ch_opts.auth_pref[0].value = 1; |
| e->ssh_ch_opts.auth_pref[1].value = 2; |
| e->ssh_ch_opts.auth_pref[2].value = 3; |
| #endif /* NC_ENABLED_SSH */ |
| } |
| pthread_setspecific(nc_client_context_key, e); |
| } |
| |
| return e; |
| } |
| |
| #define client_opts nc_client_context_location()->opts |
| |
| API void * |
| nc_client_get_thread_context(void) |
| { |
| return nc_client_context_location(); |
| } |
| |
| API void |
| nc_client_set_thread_context(void *context) |
| { |
| struct nc_client_context *old, *new; |
| |
| if (!context) { |
| ERRARG(context); |
| return; |
| } |
| |
| new = (struct nc_client_context *)context; |
| old = nc_client_context_location(); |
| if (old == new) { |
| /* nothing to change */ |
| return; |
| } |
| |
| /* replace old by new, increase reference counter in the newly set context */ |
| nc_client_context_free(old); |
| new->refcount++; |
| pthread_setspecific(nc_client_context_key, new); |
| } |
| |
| int |
| nc_session_new_ctx(struct nc_session *session, struct ly_ctx *ctx) |
| { |
| /* assign context (dicionary needed for handshake) */ |
| if (!ctx) { |
| ctx = ly_ctx_new(NULL, 0); |
| if (!ctx) { |
| return EXIT_FAILURE; |
| } |
| |
| /* user path must be first, the first path is used to store schemas retreived via get-schema */ |
| if (client_opts.schema_searchpath) { |
| ly_ctx_set_searchdir(ctx, client_opts.schema_searchpath); |
| } |
| ly_ctx_set_searchdir(ctx, NC_SCHEMAS_DIR); |
| |
| /* set callback for getting schemas, if provided */ |
| ly_ctx_set_module_imp_clb(ctx, client_opts.schema_clb, client_opts.schema_clb_data); |
| } else { |
| session->flags |= NC_SESSION_SHAREDCTX; |
| } |
| |
| session->ctx = ctx; |
| |
| return EXIT_SUCCESS; |
| } |
| |
| API int |
| nc_client_set_schema_searchpath(const char *path) |
| { |
| if (client_opts.schema_searchpath) { |
| free(client_opts.schema_searchpath); |
| } |
| |
| if (path) { |
| client_opts.schema_searchpath = strdup(path); |
| if (!client_opts.schema_searchpath) { |
| ERRMEM; |
| return 1; |
| } |
| } else { |
| client_opts.schema_searchpath = NULL; |
| } |
| |
| return 0; |
| } |
| |
| API const char * |
| nc_client_get_schema_searchpath(void) |
| { |
| return client_opts.schema_searchpath; |
| } |
| |
| API int |
| nc_client_set_schema_callback(ly_module_imp_clb clb, void *user_data) |
| { |
| client_opts.schema_clb = clb; |
| if (clb) { |
| client_opts.schema_clb_data = user_data; |
| } else { |
| client_opts.schema_clb_data = NULL; |
| } |
| |
| return 0; |
| } |
| |
| API ly_module_imp_clb |
| nc_client_get_schema_callback(void **user_data) |
| { |
| if (user_data) { |
| (*user_data) = client_opts.schema_clb_data; |
| } |
| return client_opts.schema_clb; |
| } |
| |
| /* NC_SCHEMAS_DIR used as the last resort */ |
| static int |
| ctx_check_and_load_ietf_netconf(struct ly_ctx *ctx, char **cpblts) |
| { |
| int i; |
| const struct lys_module *ietfnc; |
| |
| ietfnc = ly_ctx_get_module(ctx, "ietf-netconf", NULL, 1); |
| if (!ietfnc) { |
| ietfnc = ly_ctx_load_module(ctx, "ietf-netconf", NULL); |
| if (!ietfnc) { |
| ietfnc = lys_parse_path(ctx, NC_SCHEMAS_DIR"/ietf-netconf.yin", LYS_IN_YIN); |
| } |
| } |
| if (!ietfnc) { |
| ERR("Loading base NETCONF schema failed."); |
| return 1; |
| } |
| |
| /* set supported capabilities from ietf-netconf */ |
| for (i = 0; cpblts[i]; ++i) { |
| if (!strncmp(cpblts[i], "urn:ietf:params:netconf:capability:", 35)) { |
| if (!strncmp(cpblts[i] + 35, "writable-running", 16)) { |
| lys_features_enable(ietfnc, "writable-running"); |
| } else if (!strncmp(cpblts[i] + 35, "candidate", 9)) { |
| lys_features_enable(ietfnc, "candidate"); |
| } else if (!strcmp(cpblts[i] + 35, "confirmed-commit:1.1")) { |
| lys_features_enable(ietfnc, "confirmed-commit"); |
| } else if (!strncmp(cpblts[i] + 35, "rollback-on-error", 17)) { |
| lys_features_enable(ietfnc, "rollback-on-error"); |
| } else if (!strcmp(cpblts[i] + 35, "validate:1.1")) { |
| lys_features_enable(ietfnc, "validate"); |
| } else if (!strncmp(cpblts[i] + 35, "startup", 7)) { |
| lys_features_enable(ietfnc, "startup"); |
| } else if (!strncmp(cpblts[i] + 35, "url", 3)) { |
| lys_features_enable(ietfnc, "url"); |
| } else if (!strncmp(cpblts[i] + 35, "xpath", 5)) { |
| lys_features_enable(ietfnc, "xpath"); |
| } |
| } |
| } |
| |
| return 0; |
| } |
| |
| static char * |
| getschema_module_clb(const char *mod_name, const char *mod_rev, const char *submod_name, const char *submod_rev, |
| void *user_data, LYS_INFORMAT *format, void (**free_model_data)(void *model_data)) |
| { |
| struct nc_session *session = (struct nc_session *)user_data; |
| struct nc_rpc *rpc; |
| struct nc_reply *reply; |
| struct nc_reply_data *data_rpl; |
| struct nc_reply_error *error_rpl; |
| struct lyd_node_anydata *get_schema_data; |
| NC_MSG_TYPE msg; |
| char *model_data = NULL; |
| uint64_t msgid; |
| char *filename = NULL; |
| const char * const *searchdirs; |
| FILE *output; |
| |
| if (submod_name) { |
| rpc = nc_rpc_getschema(submod_name, submod_rev, "yang", NC_PARAMTYPE_CONST); |
| } else { |
| rpc = nc_rpc_getschema(mod_name, mod_rev, "yang", NC_PARAMTYPE_CONST); |
| } |
| |
| while ((msg = nc_send_rpc(session, rpc, 0, &msgid)) == NC_MSG_WOULDBLOCK) { |
| usleep(1000); |
| } |
| if (msg == NC_MSG_ERROR) { |
| ERR("Session %u: failed to send the <get-schema> RPC.", session->id); |
| nc_rpc_free(rpc); |
| return NULL; |
| } |
| |
| do { |
| msg = nc_recv_reply(session, rpc, msgid, NC_READ_ACT_TIMEOUT * 1000, 0, &reply); |
| } while (msg == NC_MSG_NOTIF); |
| nc_rpc_free(rpc); |
| if (msg == NC_MSG_WOULDBLOCK) { |
| ERR("Session %u: timeout for receiving reply to a <get-schema> expired.", session->id); |
| return NULL; |
| } else if (msg == NC_MSG_ERROR) { |
| ERR("Session %u: failed to receive a reply to <get-schema>.", session->id); |
| return NULL; |
| } |
| |
| switch (reply->type) { |
| case NC_RPL_OK: |
| ERR("Session %u: unexpected reply OK to a <get-schema> RPC.", session->id); |
| nc_reply_free(reply); |
| return NULL; |
| case NC_RPL_DATA: |
| /* fine */ |
| break; |
| case NC_RPL_ERROR: |
| error_rpl = (struct nc_reply_error *)reply; |
| if (error_rpl->count) { |
| ERR("Session %u: error reply to a <get-schema> RPC (tag \"%s\", message \"%s\").", |
| session->id, error_rpl->err[0].tag, error_rpl->err[0].message); |
| } else { |
| ERR("Session %u: unexpected reply error to a <get-schema> RPC.", session->id); |
| } |
| nc_reply_free(reply); |
| return NULL; |
| case NC_RPL_NOTIF: |
| ERR("Session %u: unexpected reply notification to a <get-schema> RPC.", session->id); |
| nc_reply_free(reply); |
| return NULL; |
| } |
| |
| data_rpl = (struct nc_reply_data *)reply; |
| if ((data_rpl->data->schema->nodetype != LYS_RPC) || strcmp(data_rpl->data->schema->name, "get-schema") |
| || !data_rpl->data->child || (data_rpl->data->child->schema->nodetype != LYS_ANYXML)) { |
| ERR("Session %u: unexpected data in reply to a <get-schema> RPC.", session->id); |
| nc_reply_free(reply); |
| return NULL; |
| } |
| get_schema_data = (struct lyd_node_anydata *)data_rpl->data->child; |
| switch (get_schema_data->value_type) { |
| case LYD_ANYDATA_CONSTSTRING: |
| case LYD_ANYDATA_STRING: |
| model_data = strdup(get_schema_data->value.str); |
| break; |
| case LYD_ANYDATA_DATATREE: |
| lyd_print_mem(&model_data, get_schema_data->value.tree, LYD_XML, LYP_WITHSIBLINGS); |
| break; |
| case LYD_ANYDATA_XML: |
| lyxml_print_mem(&model_data, get_schema_data->value.xml, LYXML_PRINT_SIBLINGS); |
| break; |
| case LYD_ANYDATA_JSON: |
| case LYD_ANYDATA_JSOND: |
| case LYD_ANYDATA_SXML: |
| case LYD_ANYDATA_SXMLD: |
| ERRINT; |
| break; |
| } |
| nc_reply_free(reply); |
| *free_model_data = free; |
| *format = LYS_IN_YANG; |
| |
| /* try to store the model_data into local schema repository */ |
| if (model_data) { |
| searchdirs = ly_ctx_get_searchdirs(session->ctx); |
| if (asprintf(&filename, "%s/%s%s%s.yang", searchdirs ? searchdirs[0] : ".", mod_name, |
| mod_rev ? "@" : "", mod_rev ? mod_rev : "") == -1) { |
| ERRMEM; |
| } else { |
| output = fopen(filename, "w"); |
| if (!output) { |
| WRN("Unable to store \"%s\" as a local copy of schema retreived via <get-schema> (%s).", |
| filename, strerror(errno)); |
| } else { |
| fputs(model_data, output); |
| fclose(output); |
| } |
| free(filename); |
| } |
| } |
| |
| return model_data; |
| } |
| |
| static int |
| nc_ctx_load_module(struct nc_session *session, const char *name, const char *revision, int implement, |
| ly_module_imp_clb user_clb, void *user_data, const struct lys_module **mod) |
| { |
| int ret = 0; |
| struct ly_err_item *eitem; |
| |
| *mod = ly_ctx_get_module(session->ctx, name, revision, 0); |
| if (*mod) { |
| if (implement && !(*mod)->implemented) { |
| /* make the present module implemented */ |
| if (lys_set_implemented(*mod)) { |
| ERR("Failed to implement model \"%s\".", (*mod)->name); |
| ret = -1; |
| } |
| } |
| } else if (!(*mod) && implement) { |
| /* missing implemented module, load it ... */ |
| |
| /* clear all the errors and just collect them for now */ |
| ly_err_clean(session->ctx, NULL); |
| ly_log_options(LY_LOSTORE); |
| |
| /* 1) using only searchpaths */ |
| *mod = ly_ctx_load_module(session->ctx, name, revision); |
| |
| /* 2) using user callback */ |
| if (!(*mod) && user_clb) { |
| ly_ctx_set_module_imp_clb(session->ctx, user_clb, user_data); |
| *mod = ly_ctx_load_module(session->ctx, name, revision); |
| } |
| |
| /* 3) using get-schema callback */ |
| if (!(*mod)) { |
| ly_ctx_set_module_imp_clb(session->ctx, &getschema_module_clb, session); |
| *mod = ly_ctx_load_module(session->ctx, name, revision); |
| if (*mod) { |
| /* print get-schema warning */ |
| eitem = ly_err_first(session->ctx); |
| if (eitem && (eitem->prev->level == LY_LLWRN)) { |
| ly_log_options(LY_LOLOG); |
| ly_err_print(eitem->prev); |
| } |
| } |
| } |
| |
| /* unset callback back to use searchpath */ |
| ly_ctx_set_module_imp_clb(session->ctx, NULL, NULL); |
| |
| /* restore logging options, then print errors on definite failure */ |
| ly_log_options(LY_LOLOG | LY_LOSTORE_LAST); |
| if (!(*mod)) { |
| for (eitem = ly_err_first(session->ctx); eitem && eitem->next; eitem = eitem->next) { |
| ly_err_print(eitem); |
| } |
| ret = -1; |
| } |
| |
| /* clean the errors */ |
| ly_err_clean(session->ctx, NULL); |
| } |
| |
| return ret; |
| } |
| |
| /* NC_SCHEMAS_DIR not used (implicitly) */ |
| static int |
| nc_ctx_fill_cpblts(struct nc_session *session, ly_module_imp_clb user_clb, void *user_data) |
| { |
| int ret = 1; |
| const struct lys_module *mod; |
| char *ptr, *ptr2; |
| const char *module_cpblt; |
| char *name = NULL, *revision = NULL, *features = NULL; |
| unsigned int u; |
| |
| for (u = 0; session->opts.client.cpblts[u]; ++u) { |
| module_cpblt = strstr(session->opts.client.cpblts[u], "module="); |
| /* this capability requires a module */ |
| if (!module_cpblt) { |
| continue; |
| } |
| |
| /* get module name */ |
| ptr = (char *)module_cpblt + 7; |
| ptr2 = strchr(ptr, '&'); |
| if (!ptr2) { |
| ptr2 = ptr + strlen(ptr); |
| } |
| free(name); |
| name = strndup(ptr, ptr2 - ptr); |
| |
| /* get module revision */ |
| free(revision); revision = NULL; |
| ptr = strstr(module_cpblt, "revision="); |
| if (ptr) { |
| ptr += 9; |
| ptr2 = strchr(ptr, '&'); |
| if (!ptr2) { |
| ptr2 = ptr + strlen(ptr); |
| } |
| revision = strndup(ptr, ptr2 - ptr); |
| } |
| |
| /* we can continue even if it fails */ |
| nc_ctx_load_module(session, name, revision, 1, user_clb, user_data, &mod); |
| |
| if (!mod) { |
| if (session->status != NC_STATUS_RUNNING) { |
| /* something bad heppened, discard the session */ |
| ERR("Session %d: invalid session, discarding.", nc_session_get_id(session)); |
| ret = 1; |
| goto cleanup; |
| } |
| |
| /* all loading ways failed, the schema will be ignored in the received data */ |
| WRN("Failed to load schema \"%s@%s\".", name, revision ? revision : "<latest>"); |
| session->flags |= NC_SESSION_CLIENT_NOT_STRICT; |
| } else { |
| /* set features - first disable all to enable specified then */ |
| lys_features_disable(mod, "*"); |
| |
| ptr = strstr(module_cpblt, "features="); |
| if (ptr) { |
| ptr += 9; |
| ptr2 = strchr(ptr, '&'); |
| if (!ptr2) { |
| ptr2 = ptr + strlen(ptr); |
| } |
| free(features); |
| features = strndup(ptr, ptr2 - ptr); |
| |
| /* basically manual strtok_r (to avoid macro) */ |
| ptr2 = features; |
| for (ptr = features; *ptr; ++ptr) { |
| if (*ptr == ',') { |
| *ptr = '\0'; |
| /* remember last feature */ |
| ptr2 = ptr + 1; |
| } |
| } |
| |
| ptr = features; |
| while (1) { |
| lys_features_enable(mod, ptr); |
| if (ptr != ptr2) { |
| ptr += strlen(ptr) + 1; |
| } else { |
| break; |
| } |
| } |
| } |
| } |
| } |
| |
| ret = 0; |
| |
| cleanup: |
| free(name); |
| free(revision); |
| free(features); |
| |
| return ret; |
| } |
| |
| static int |
| nc_ctx_fill_yl(struct nc_session *session, ly_module_imp_clb user_clb, void *user_data) |
| { |
| int ret = 1; |
| struct nc_rpc *rpc = NULL; |
| struct nc_reply *reply = NULL; |
| struct nc_reply_error *error_rpl; |
| struct nc_reply_data *data_rpl; |
| NC_MSG_TYPE msg; |
| uint64_t msgid; |
| struct lyd_node *data = NULL, *iter; |
| struct ly_set *modules = NULL, *imports = NULL, *features = NULL; |
| unsigned int u, v; |
| const char *name, *revision; |
| int implemented, imports_flag = 0; |
| const struct lys_module *mod; |
| |
| /* get yang-library data from the server */ |
| rpc = nc_rpc_get("/ietf-yang-library:*//.", 0, NC_PARAMTYPE_CONST); |
| if (!rpc) { |
| goto cleanup; |
| } |
| |
| while ((msg = nc_send_rpc(session, rpc, 0, &msgid)) == NC_MSG_WOULDBLOCK) { |
| usleep(1000); |
| } |
| if (msg == NC_MSG_ERROR) { |
| ERR("Session %u: failed to send request for yang-library data.", |
| session->id); |
| goto cleanup; |
| } |
| |
| do { |
| msg = nc_recv_reply(session, rpc, msgid, NC_READ_ACT_TIMEOUT * 1000, 0, &reply); |
| } while (msg == NC_MSG_NOTIF); |
| if (msg == NC_MSG_WOULDBLOCK) { |
| ERR("Session %u: timeout for receiving reply to a <get> yang-library data expired.", session->id); |
| goto cleanup; |
| } else if (msg == NC_MSG_ERROR) { |
| ERR("Session %u: failed to receive a reply to <get> of yang-library data.", session->id); |
| goto cleanup; |
| } |
| |
| switch (reply->type) { |
| case NC_RPL_OK: |
| ERR("Session %u: unexpected reply OK to a yang-library <get> RPC.", session->id); |
| goto cleanup; |
| case NC_RPL_DATA: |
| /* fine */ |
| break; |
| case NC_RPL_ERROR: |
| error_rpl = (struct nc_reply_error *)reply; |
| if (error_rpl->count) { |
| ERR("Session %u: error reply to a yang-library <get> RPC (tag \"%s\", message \"%s\").", |
| session->id, error_rpl->err[0].tag, error_rpl->err[0].message); |
| } else { |
| ERR("Session %u: unexpected reply error to a yang-library <get> RPC.", session->id); |
| } |
| goto cleanup; |
| case NC_RPL_NOTIF: |
| ERR("Session %u: unexpected reply notification to a yang-library <get> RPC.", session->id); |
| goto cleanup; |
| } |
| |
| data_rpl = (struct nc_reply_data *)reply; |
| if (!data_rpl->data || strcmp(data_rpl->data->schema->module->name, "ietf-yang-library")) { |
| ERR("Session %u: unexpected data in reply to a yang-library <get> RPC.", session->id); |
| goto cleanup; |
| } |
| |
| modules = lyd_find_path(data_rpl->data, "/ietf-yang-library:modules-state/module"); |
| if (!modules || !modules->number) { |
| ERR("No yang-library modules information for session %u.", session->id); |
| goto cleanup; |
| } |
| |
| features = ly_set_new(); |
| imports = ly_set_new(); |
| |
| parse: |
| for (u = modules->number - 1; u < modules->number; u--) { |
| name = revision = NULL; |
| ly_set_clean(features); |
| implemented = 0; |
| |
| /* store the data */ |
| LY_TREE_FOR(modules->set.d[u]->child, iter) { |
| if (!((struct lyd_node_leaf_list *)iter)->value_str || !((struct lyd_node_leaf_list *)iter)->value_str[0]) { |
| /* ignore empty nodes */ |
| continue; |
| } |
| if (!strcmp(iter->schema->name, "name")) { |
| name = ((struct lyd_node_leaf_list *)iter)->value_str; |
| } else if (!strcmp(iter->schema->name, "revision")) { |
| revision = ((struct lyd_node_leaf_list *)iter)->value_str; |
| } else if (!strcmp(iter->schema->name, "conformance-type")) { |
| implemented = !strcmp(((struct lyd_node_leaf_list *)iter)->value_str, "implement"); |
| } else if (!strcmp(iter->schema->name, "feature")) { |
| ly_set_add(features, (void*)((struct lyd_node_leaf_list *)iter)->value_str, LY_SET_OPT_USEASLIST); |
| } |
| } |
| |
| /* continue even on fail */ |
| nc_ctx_load_module(session, name, revision, implemented, user_clb, user_data, &mod); |
| |
| if (!mod) { /* !mod && !implemented - will be loaded automatically, but remember to set features in the end */ |
| assert(!implemented); |
| if (imports_flag) { |
| ERR("Module \"%s@%s\" is supposed to be imported, but no other module imports it.", |
| name, revision ? revision : "<latest>"); |
| ret = -1; |
| goto cleanup; |
| } |
| ly_set_add(imports, modules->set.d[u], LY_SET_OPT_USEASLIST); |
| continue; |
| } |
| |
| if (!mod) { |
| /* all loading ways failed, the schema will be ignored in the received data */ |
| WRN("Failed to load schema \"%s@%s\".", name, revision ? revision : "<latest>"); |
| session->flags |= NC_SESSION_CLIENT_NOT_STRICT; |
| } else { |
| /* set features - first disable all to enable specified then */ |
| lys_features_disable(mod, "*"); |
| for (v = 0; v < features->number; v++) { |
| lys_features_enable(mod, (const char*)features->set.g[v]); |
| } |
| } |
| } |
| |
| if (!imports_flag && imports->number) { |
| /* even imported modules should be now loaded as dependency, so just go through |
| * the parsing again and just set the features */ |
| ly_set_free(modules); |
| modules = imports; |
| imports = NULL; |
| imports_flag = 1; |
| goto parse; |
| } |
| |
| /* done */ |
| ret = 0; |
| |
| cleanup: |
| nc_rpc_free(rpc); |
| nc_reply_free(reply); |
| lyd_free_withsiblings(data); |
| |
| ly_set_free(modules); |
| ly_set_free(imports); |
| ly_set_free(features); |
| |
| if (session->status != NC_STATUS_RUNNING) { |
| ERR("Session %d: invalid session, discarding.", nc_session_get_id(session)); |
| ret = -1; |
| } |
| |
| return ret; |
| } |
| |
| int |
| nc_ctx_check_and_fill(struct nc_session *session) |
| { |
| int i, get_schema_support = 0, yanglib_support = 0, ret = -1, r; |
| ly_module_imp_clb old_clb = NULL; |
| void *old_data = NULL; |
| |
| assert(session->opts.client.cpblts && session->ctx); |
| |
| /* store the original user's callback, here we will be switching between searchpath, user callback |
| * and get-schema callback */ |
| old_clb = ly_ctx_get_module_imp_clb(session->ctx, &old_data); |
| ly_ctx_set_module_imp_clb(session->ctx, NULL, NULL); /* unset callback, so we prefer local searchpath */ |
| |
| /* check if get-schema is supported */ |
| for (i = 0; session->opts.client.cpblts[i]; ++i) { |
| if (!strncmp(session->opts.client.cpblts[i], "urn:ietf:params:xml:ns:yang:ietf-netconf-monitoring?", 52)) { |
| get_schema_support = 1; |
| if (yanglib_support) { |
| break; |
| } |
| } else if (!strncmp(session->opts.client.cpblts[i], "urn:ietf:params:xml:ns:yang:ietf-yang-library?", 46)) { |
| yanglib_support = 1; |
| if (get_schema_support) { |
| break; |
| } |
| } |
| } |
| |
| /* get-schema is supported, load local ietf-netconf-monitoring so we can create <get-schema> RPCs */ |
| if (get_schema_support && !ly_ctx_get_module(session->ctx, "ietf-netconf-monitoring", NULL, 1)) { |
| if (!lys_parse_path(session->ctx, NC_SCHEMAS_DIR"/ietf-netconf-monitoring.yin", LYS_IN_YIN)) { |
| WRN("Loading NETCONF monitoring schema failed, cannot use <get-schema>."); |
| get_schema_support = 0; |
| } |
| } |
| /* yang-library present does not need to be checked, it is one of the libyang's internal modules, |
| * so it is always present */ |
| |
| /* load base model disregarding whether it's in capabilities (but NETCONF capabilities are used to enable features) */ |
| if (ctx_check_and_load_ietf_netconf(session->ctx, session->opts.client.cpblts)) { |
| goto cleanup; |
| } |
| |
| if (yanglib_support && get_schema_support) { |
| /* load schemas according to the ietf-yang-library data, which are more precise than capabilities list */ |
| r = nc_ctx_fill_yl(session, old_clb, old_data); |
| if (r == -1) { |
| goto cleanup; |
| } else if (r == 1) { |
| VRB("Session %d: trying to use capabilities instead of ietf-yang-library data.", nc_session_get_id(session)); |
| /* try to use standard capabilities */ |
| goto capabilities; |
| } |
| } else { |
| capabilities: |
| |
| if (nc_ctx_fill_cpblts(session, old_clb, old_data)) { |
| goto cleanup; |
| } |
| } |
| |
| /* succsess */ |
| ret = 0; |
| |
| if (session->flags & NC_SESSION_CLIENT_NOT_STRICT) { |
| WRN("Some models failed to be loaded, any data from these models (and any other unknown) will be ignored."); |
| } |
| |
| cleanup: |
| /* set user callback back */ |
| ly_ctx_set_module_imp_clb(session->ctx, old_clb, old_data); |
| |
| return ret; |
| } |
| |
| API struct nc_session * |
| nc_connect_inout(int fdin, int fdout, struct ly_ctx *ctx) |
| { |
| struct nc_session *session; |
| |
| if (fdin < 0) { |
| ERRARG("fdin"); |
| return NULL; |
| } else if (fdout < 0) { |
| ERRARG("fdout"); |
| return NULL; |
| } |
| |
| /* prepare session structure */ |
| session = nc_new_session(0); |
| if (!session) { |
| ERRMEM; |
| return NULL; |
| } |
| session->status = NC_STATUS_STARTING; |
| session->side = NC_CLIENT; |
| |
| /* transport specific data */ |
| session->ti_type = NC_TI_FD; |
| pthread_mutex_init(session->ti_lock, NULL); |
| pthread_cond_init(session->ti_cond, NULL); |
| *session->ti_inuse = 0; |
| |
| session->ti.fd.in = fdin; |
| session->ti.fd.out = fdout; |
| |
| /* assign context (dicionary needed for handshake) */ |
| if (!ctx) { |
| ctx = ly_ctx_new(NC_SCHEMAS_DIR, 0); |
| /* definitely should not happen, but be ready */ |
| if (!ctx && !(ctx = ly_ctx_new(NULL, 0))) { |
| /* that's just it */ |
| goto fail; |
| } |
| } else { |
| session->flags |= NC_SESSION_SHAREDCTX; |
| } |
| session->ctx = ctx; |
| |
| /* NETCONF handshake */ |
| if (nc_handshake(session) != NC_MSG_HELLO) { |
| goto fail; |
| } |
| session->status = NC_STATUS_RUNNING; |
| |
| if (nc_ctx_check_and_fill(session) == -1) { |
| goto fail; |
| } |
| |
| return session; |
| |
| fail: |
| nc_session_free(session, NULL); |
| return NULL; |
| } |
| |
| int |
| nc_sock_connect(const char* host, uint16_t port) |
| { |
| int i, sock = -1, flags; |
| struct addrinfo hints, *res_list, *res; |
| char port_s[6]; /* length of string representation of short int */ |
| |
| snprintf(port_s, 6, "%u", port); |
| |
| /* Connect to a server */ |
| memset(&hints, 0, sizeof hints); |
| hints.ai_family = AF_UNSPEC; |
| hints.ai_socktype = SOCK_STREAM; |
| hints.ai_protocol = IPPROTO_TCP; |
| i = getaddrinfo(host, port_s, &hints, &res_list); |
| if (i != 0) { |
| ERR("Unable to translate the host address (%s).", gai_strerror(i)); |
| return -1; |
| } |
| |
| for (res = res_list; res != NULL; res = res->ai_next) { |
| sock = socket(res->ai_family, res->ai_socktype, res->ai_protocol); |
| if (sock == -1) { |
| /* socket was not created, try another resource */ |
| continue; |
| } |
| |
| if (connect(sock, res->ai_addr, res->ai_addrlen) == -1) { |
| /* network connection failed, try another resource */ |
| close(sock); |
| sock = -1; |
| continue; |
| } |
| |
| /* make the socket non-blocking */ |
| if (((flags = fcntl(sock, F_GETFL)) == -1) || (fcntl(sock, F_SETFL, flags | O_NONBLOCK) == -1)) { |
| ERR("Fcntl failed (%s).", strerror(errno)); |
| close(sock); |
| freeaddrinfo(res_list); |
| return -1; |
| } |
| |
| /* we're done, network connection established */ |
| break; |
| } |
| |
| if (sock != -1) { |
| VRB("Successfully connected to %s:%s over %s.", host, port_s, (res->ai_family == AF_INET6) ? "IPv6" : "IPv4"); |
| } |
| freeaddrinfo(res_list); |
| |
| return sock; |
| } |
| |
| static NC_MSG_TYPE |
| get_msg(struct nc_session *session, int timeout, uint64_t msgid, struct lyxml_elem **msg) |
| { |
| int r; |
| char *ptr; |
| const char *str_msgid; |
| uint64_t cur_msgid; |
| struct lyxml_elem *xml; |
| struct nc_msg_cont *cont, **cont_ptr; |
| NC_MSG_TYPE msgtype = 0; /* NC_MSG_ERROR */ |
| |
| r = nc_session_lock(session, timeout, __func__); |
| if (r == -1) { |
| /* error */ |
| return NC_MSG_ERROR; |
| } else if (!r) { |
| /* timeout */ |
| return NC_MSG_WOULDBLOCK; |
| } |
| |
| /* try to get notification from the session's queue */ |
| if (!msgid && session->opts.client.notifs) { |
| cont = session->opts.client.notifs; |
| session->opts.client.notifs = cont->next; |
| |
| xml = cont->msg; |
| free(cont); |
| |
| msgtype = NC_MSG_NOTIF; |
| } |
| |
| /* try to get rpc-reply from the session's queue */ |
| if (msgid && session->opts.client.replies) { |
| cont = session->opts.client.replies; |
| session->opts.client.replies = cont->next; |
| |
| xml = cont->msg; |
| free(cont); |
| |
| msgtype = NC_MSG_REPLY; |
| } |
| |
| if (!msgtype) { |
| /* read message from wire */ |
| msgtype = nc_read_msg_poll(session, timeout, &xml); |
| } |
| |
| /* we read rpc-reply, want a notif */ |
| if (!msgid && (msgtype == NC_MSG_REPLY)) { |
| cont_ptr = &session->opts.client.replies; |
| while (*cont_ptr) { |
| cont_ptr = &((*cont_ptr)->next); |
| } |
| *cont_ptr = malloc(sizeof **cont_ptr); |
| if (!*cont_ptr) { |
| ERRMEM; |
| nc_session_unlock(session, timeout, __func__); |
| lyxml_free(session->ctx, xml); |
| return NC_MSG_ERROR; |
| } |
| (*cont_ptr)->msg = xml; |
| (*cont_ptr)->next = NULL; |
| } |
| |
| /* we read notif, want a rpc-reply */ |
| if (msgid && (msgtype == NC_MSG_NOTIF)) { |
| if (!session->opts.client.ntf_tid) { |
| pthread_mutex_unlock(session->ti_lock); |
| ERR("Session %u: received a <notification> but session is not subscribed.", session->id); |
| lyxml_free(session->ctx, xml); |
| return NC_MSG_ERROR; |
| } |
| |
| cont_ptr = &session->opts.client.notifs; |
| while (*cont_ptr) { |
| cont_ptr = &((*cont_ptr)->next); |
| } |
| *cont_ptr = malloc(sizeof **cont_ptr); |
| if (!cont_ptr) { |
| ERRMEM; |
| nc_session_unlock(session, timeout, __func__); |
| lyxml_free(session->ctx, xml); |
| return NC_MSG_ERROR; |
| } |
| (*cont_ptr)->msg = xml; |
| (*cont_ptr)->next = NULL; |
| } |
| |
| nc_session_unlock(session, timeout, __func__); |
| |
| switch (msgtype) { |
| case NC_MSG_NOTIF: |
| if (!msgid) { |
| *msg = xml; |
| } |
| break; |
| |
| case NC_MSG_REPLY: |
| if (msgid) { |
| /* check message-id */ |
| str_msgid = lyxml_get_attr(xml, "message-id", NULL); |
| if (!str_msgid) { |
| WRN("Session %u: received a <rpc-reply> without a message-id.", session->id); |
| } else { |
| cur_msgid = strtoul(str_msgid, &ptr, 10); |
| if (cur_msgid != msgid) { |
| ERR("Session %u: received a <rpc-reply> with an unexpected message-id \"%s\".", |
| session->id, str_msgid); |
| msgtype = NC_MSG_REPLY_ERR_MSGID; |
| } |
| } |
| *msg = xml; |
| } |
| break; |
| |
| case NC_MSG_HELLO: |
| ERR("Session %u: received another <hello> message.", session->id); |
| lyxml_free(session->ctx, xml); |
| msgtype = NC_MSG_ERROR; |
| break; |
| |
| case NC_MSG_RPC: |
| ERR("Session %u: received <rpc> from a NETCONF server.", session->id); |
| lyxml_free(session->ctx, xml); |
| msgtype = NC_MSG_ERROR; |
| break; |
| |
| default: |
| /* NC_MSG_WOULDBLOCK and NC_MSG_ERROR - pass it out; |
| * NC_MSG_NONE is not returned by nc_read_msg() |
| */ |
| break; |
| } |
| |
| return msgtype; |
| } |
| |
| /* cannot strictly fail, but does not need to fill any error parameter at all */ |
| static void |
| parse_rpc_error(struct ly_ctx *ctx, struct lyxml_elem *xml, struct nc_err *err) |
| { |
| struct lyxml_elem *iter, *next, *info; |
| |
| LY_TREE_FOR(xml->child, iter) { |
| if (!iter->ns) { |
| if (iter->content) { |
| WRN("<rpc-error> child \"%s\" with value \"%s\" without namespace.", iter->name, iter->content); |
| } else { |
| WRN("<rpc-error> child \"%s\" without namespace.", iter->name); |
| } |
| continue; |
| } else if (strcmp(iter->ns->value, NC_NS_BASE)) { |
| if (iter->content) { |
| WRN("<rpc-error> child \"%s\" with value \"%s\" in an unknown namespace \"%s\".", |
| iter->name, iter->content, iter->ns->value); |
| } else { |
| WRN("<rpc-error> child \"%s\" in an unknown namespace \"%s\".", iter->name, iter->ns->value); |
| } |
| continue; |
| } |
| |
| if (!strcmp(iter->name, "error-type")) { |
| if (!iter->content || (strcmp(iter->content, "transport") && strcmp(iter->content, "rpc") |
| && strcmp(iter->content, "protocol") && strcmp(iter->content, "application"))) { |
| WRN("<rpc-error> <error-type> unknown value \"%s\".", (iter->content ? iter->content : "")); |
| } else if (err->type) { |
| WRN("<rpc-error> <error-type> duplicated."); |
| } else { |
| err->type = lydict_insert(ctx, iter->content, 0); |
| } |
| } else if (!strcmp(iter->name, "error-tag")) { |
| if (!iter->content || (strcmp(iter->content, "in-use") && strcmp(iter->content, "invalid-value") |
| && strcmp(iter->content, "too-big") && strcmp(iter->content, "missing-attribute") |
| && strcmp(iter->content, "bad-attribute") && strcmp(iter->content, "unknown-attribute") |
| && strcmp(iter->content, "missing-element") && strcmp(iter->content, "bad-element") |
| && strcmp(iter->content, "unknown-element") && strcmp(iter->content, "unknown-namespace") |
| && strcmp(iter->content, "access-denied") && strcmp(iter->content, "lock-denied") |
| && strcmp(iter->content, "resource-denied") && strcmp(iter->content, "rollback-failed") |
| && strcmp(iter->content, "data-exists") && strcmp(iter->content, "data-missing") |
| && strcmp(iter->content, "operation-not-supported") && strcmp(iter->content, "operation-failed") |
| && strcmp(iter->content, "malformed-message"))) { |
| WRN("<rpc-error> <error-tag> unknown value \"%s\".", (iter->content ? iter->content : "")); |
| } else if (err->tag) { |
| WRN("<rpc-error> <error-tag> duplicated."); |
| } else { |
| err->tag = lydict_insert(ctx, iter->content, 0); |
| } |
| } else if (!strcmp(iter->name, "error-severity")) { |
| if (!iter->content || (strcmp(iter->content, "error") && strcmp(iter->content, "warning"))) { |
| WRN("<rpc-error> <error-severity> unknown value \"%s\".", (iter->content ? iter->content : "")); |
| } else if (err->severity) { |
| WRN("<rpc-error> <error-severity> duplicated."); |
| } else { |
| err->severity = lydict_insert(ctx, iter->content, 0); |
| } |
| } else if (!strcmp(iter->name, "error-app-tag")) { |
| if (err->apptag) { |
| WRN("<rpc-error> <error-app-tag> duplicated."); |
| } else { |
| err->apptag = lydict_insert(ctx, (iter->content ? iter->content : ""), 0); |
| } |
| } else if (!strcmp(iter->name, "error-path")) { |
| if (err->path) { |
| WRN("<rpc-error> <error-path> duplicated."); |
| } else { |
| err->path = lydict_insert(ctx, (iter->content ? iter->content : ""), 0); |
| } |
| } else if (!strcmp(iter->name, "error-message")) { |
| if (err->message) { |
| WRN("<rpc-error> <error-message> duplicated."); |
| } else { |
| err->message_lang = lyxml_get_attr(iter, "xml:lang", NULL); |
| if (err->message_lang) { |
| err->message_lang = lydict_insert(ctx, err->message_lang, 0); |
| } else { |
| VRB("<rpc-error> <error-message> without the recommended \"xml:lang\" attribute."); |
| } |
| err->message = lydict_insert(ctx, (iter->content ? iter->content : ""), 0); |
| } |
| } else if (!strcmp(iter->name, "error-info")) { |
| LY_TREE_FOR_SAFE(iter->child, next, info) { |
| if (info->ns && !strcmp(info->ns->value, NC_NS_BASE)) { |
| if (!strcmp(info->name, "session-id")) { |
| if (err->sid) { |
| WRN("<rpc-error> <error-info> <session-id> duplicated."); |
| } else { |
| err->sid = lydict_insert(ctx, (info->content ? info->content : ""), 0); |
| } |
| } else if (!strcmp(info->name, "bad-attribute")) { |
| ++err->attr_count; |
| err->attr = nc_realloc(err->attr, err->attr_count * sizeof *err->attr); |
| if (!err->attr) { |
| ERRMEM; |
| return; |
| } |
| err->attr[err->attr_count - 1] = lydict_insert(ctx, (info->content ? info->content : ""), 0); |
| } else if (!strcmp(info->name, "bad-element")) { |
| ++err->elem_count; |
| err->elem = nc_realloc(err->elem, err->elem_count * sizeof *err->elem); |
| if (!err->elem) { |
| ERRMEM; |
| return; |
| } |
| err->elem[err->elem_count - 1] = lydict_insert(ctx, (info->content ? info->content : ""), 0); |
| } else if (!strcmp(info->name, "bad-namespace")) { |
| ++err->ns_count; |
| err->ns = nc_realloc(err->ns, err->ns_count * sizeof *err->ns); |
| if (!err->ns) { |
| ERRMEM; |
| return; |
| } |
| err->ns[err->ns_count - 1] = lydict_insert(ctx, (info->content ? info->content : ""), 0); |
| } else { |
| if (info->content) { |
| WRN("<rpc-error> <error-info> unknown child \"%s\" with value \"%s\".", |
| info->name, info->content); |
| } else { |
| WRN("<rpc-error> <error-info> unknown child \"%s\".", info->name); |
| } |
| } |
| } else { |
| lyxml_unlink(ctx, info); |
| ++err->other_count; |
| err->other = nc_realloc(err->other, err->other_count * sizeof *err->other); |
| if (!err->other) { |
| ERRMEM; |
| return; |
| } |
| err->other[err->other_count - 1] = info; |
| } |
| } |
| } else { |
| if (iter->content) { |
| WRN("<rpc-error> unknown child \"%s\" with value \"%s\".", iter->name, iter->content); |
| } else { |
| WRN("<rpc-error> unknown child \"%s\".", iter->name); |
| } |
| } |
| } |
| } |
| |
| static struct nc_reply * |
| parse_reply(struct ly_ctx *ctx, struct lyxml_elem *xml, struct nc_rpc *rpc, int parseroptions) |
| { |
| struct lyxml_elem *iter; |
| struct lyd_node *data = NULL, *rpc_act = NULL; |
| struct nc_client_reply_error *error_rpl; |
| struct nc_reply_data *data_rpl; |
| struct nc_reply *reply = NULL; |
| struct nc_rpc_act_generic *rpc_gen; |
| int i; |
| |
| if (!xml->child) { |
| ERR("An empty <rpc-reply>."); |
| return NULL; |
| } |
| |
| /* rpc-error */ |
| if (!strcmp(xml->child->name, "rpc-error") && xml->child->ns && !strcmp(xml->child->ns->value, NC_NS_BASE)) { |
| /* count and check elements */ |
| i = 0; |
| LY_TREE_FOR(xml->child, iter) { |
| if (strcmp(iter->name, "rpc-error")) { |
| ERR("<rpc-reply> content mismatch (<rpc-error> and <%s>).", iter->name); |
| return NULL; |
| } else if (!iter->ns) { |
| ERR("<rpc-reply> content mismatch (<rpc-error> without namespace)."); |
| return NULL; |
| } else if (strcmp(iter->ns->value, NC_NS_BASE)) { |
| ERR("<rpc-reply> content mismatch (<rpc-error> with NS \"%s\").", iter->ns->value); |
| return NULL; |
| } |
| ++i; |
| } |
| |
| error_rpl = malloc(sizeof *error_rpl); |
| if (!error_rpl) { |
| ERRMEM; |
| return NULL; |
| } |
| error_rpl->type = NC_RPL_ERROR; |
| error_rpl->err = calloc(i, sizeof *error_rpl->err); |
| if (!error_rpl->err) { |
| ERRMEM; |
| free(error_rpl); |
| return NULL; |
| } |
| error_rpl->count = i; |
| error_rpl->ctx = ctx; |
| reply = (struct nc_reply *)error_rpl; |
| |
| i = 0; |
| LY_TREE_FOR(xml->child, iter) { |
| parse_rpc_error(ctx, iter, error_rpl->err + i); |
| ++i; |
| } |
| |
| /* ok */ |
| } else if (!strcmp(xml->child->name, "ok") && xml->child->ns && !strcmp(xml->child->ns->value, NC_NS_BASE)) { |
| if (xml->child->next) { |
| ERR("<rpc-reply> content mismatch (<ok> and <%s>).", xml->child->next->name); |
| return NULL; |
| } |
| reply = malloc(sizeof *reply); |
| if (!reply) { |
| ERRMEM; |
| return NULL; |
| } |
| reply->type = NC_RPL_OK; |
| |
| /* some RPC output */ |
| } else { |
| switch (rpc->type) { |
| case NC_RPC_ACT_GENERIC: |
| rpc_gen = (struct nc_rpc_act_generic *)rpc; |
| |
| if (rpc_gen->has_data) { |
| rpc_act = rpc_gen->content.data; |
| } else { |
| rpc_act = lyd_parse_mem(ctx, rpc_gen->content.xml_str, LYD_XML, LYD_OPT_RPC | parseroptions, NULL); |
| if (!rpc_act) { |
| ERR("Failed to parse a generic RPC/action XML."); |
| return NULL; |
| } |
| } |
| break; |
| |
| case NC_RPC_GETCONFIG: |
| case NC_RPC_GET: |
| if (!xml->child->child) { |
| /* we did not receive any data */ |
| data_rpl = malloc(sizeof *data_rpl); |
| if (!data_rpl) { |
| ERRMEM; |
| return NULL; |
| } |
| data_rpl->type = NC_RPL_DATA; |
| data_rpl->data = NULL; |
| return (struct nc_reply *)data_rpl; |
| } |
| |
| /* special treatment */ |
| data = lyd_parse_xml(ctx, &xml->child->child, |
| LYD_OPT_DESTRUCT | (rpc->type == NC_RPC_GETCONFIG ? LYD_OPT_GETCONFIG : LYD_OPT_GET) |
| | parseroptions); |
| if (!data) { |
| ERR("Failed to parse <%s> reply.", (rpc->type == NC_RPC_GETCONFIG ? "get-config" : "get")); |
| return NULL; |
| } |
| break; |
| |
| case NC_RPC_GETSCHEMA: |
| rpc_act = lyd_new(NULL, ly_ctx_get_module(ctx, "ietf-netconf-monitoring", NULL, 1), "get-schema"); |
| if (!rpc_act) { |
| ERRINT; |
| return NULL; |
| } |
| break; |
| |
| case NC_RPC_EDIT: |
| case NC_RPC_COPY: |
| case NC_RPC_DELETE: |
| case NC_RPC_LOCK: |
| case NC_RPC_UNLOCK: |
| case NC_RPC_KILL: |
| case NC_RPC_COMMIT: |
| case NC_RPC_DISCARD: |
| case NC_RPC_CANCEL: |
| case NC_RPC_VALIDATE: |
| case NC_RPC_SUBSCRIBE: |
| /* there is no output defined */ |
| ERR("Unexpected data reply (root elem \"%s\").", xml->child->name); |
| return NULL; |
| default: |
| ERRINT; |
| return NULL; |
| } |
| |
| data_rpl = malloc(sizeof *data_rpl); |
| if (!data_rpl) { |
| ERRMEM; |
| return NULL; |
| } |
| data_rpl->type = NC_RPL_DATA; |
| if (!data) { |
| data_rpl->data = lyd_parse_xml(ctx, &xml->child, LYD_OPT_RPCREPLY | LYD_OPT_DESTRUCT | parseroptions, |
| rpc_act, NULL); |
| } else { |
| /* <get>, <get-config> */ |
| data_rpl->data = data; |
| } |
| lyd_free_withsiblings(rpc_act); |
| if (!data_rpl->data) { |
| ERR("Failed to parse <rpc-reply>."); |
| free(data_rpl); |
| return NULL; |
| } |
| reply = (struct nc_reply *)data_rpl; |
| } |
| |
| return reply; |
| } |
| |
| #if defined(NC_ENABLED_SSH) || defined(NC_ENABLED_TLS) |
| |
| int |
| nc_client_ch_add_bind_listen(const char *address, uint16_t port, NC_TRANSPORT_IMPL ti) |
| { |
| int sock; |
| |
| if (!address) { |
| ERRARG("address"); |
| return -1; |
| } else if (!port) { |
| ERRARG("port"); |
| return -1; |
| } |
| |
| sock = nc_sock_listen(address, port); |
| if (sock == -1) { |
| return -1; |
| } |
| |
| ++client_opts.ch_bind_count; |
| client_opts.ch_binds = nc_realloc(client_opts.ch_binds, client_opts.ch_bind_count * sizeof *client_opts.ch_binds); |
| if (!client_opts.ch_binds) { |
| ERRMEM; |
| close(sock); |
| return -1; |
| } |
| |
| client_opts.ch_bind_ti = nc_realloc(client_opts.ch_bind_ti, client_opts.ch_bind_count * sizeof *client_opts.ch_bind_ti); |
| if (!client_opts.ch_bind_ti) { |
| ERRMEM; |
| close(sock); |
| return -1; |
| } |
| client_opts.ch_bind_ti[client_opts.ch_bind_count - 1] = ti; |
| |
| client_opts.ch_binds[client_opts.ch_bind_count - 1].address = strdup(address); |
| if (!client_opts.ch_binds[client_opts.ch_bind_count - 1].address) { |
| ERRMEM; |
| close(sock); |
| return -1; |
| } |
| client_opts.ch_binds[client_opts.ch_bind_count - 1].port = port; |
| client_opts.ch_binds[client_opts.ch_bind_count - 1].sock = sock; |
| client_opts.ch_binds[client_opts.ch_bind_count - 1].pollin = 0; |
| |
| return 0; |
| } |
| |
| int |
| nc_client_ch_del_bind(const char *address, uint16_t port, NC_TRANSPORT_IMPL ti) |
| { |
| uint32_t i; |
| int ret = -1; |
| |
| if (!address && !port && !ti) { |
| for (i = 0; i < client_opts.ch_bind_count; ++i) { |
| close(client_opts.ch_binds[i].sock); |
| free((char *)client_opts.ch_binds[i].address); |
| |
| ret = 0; |
| } |
| free(client_opts.ch_binds); |
| client_opts.ch_binds = NULL; |
| client_opts.ch_bind_count = 0; |
| } else { |
| for (i = 0; i < client_opts.ch_bind_count; ++i) { |
| if ((!address || !strcmp(client_opts.ch_binds[i].address, address)) |
| && (!port || (client_opts.ch_binds[i].port == port)) |
| && (!ti || (client_opts.ch_bind_ti[i] == ti))) { |
| close(client_opts.ch_binds[i].sock); |
| free((char *)client_opts.ch_binds[i].address); |
| |
| --client_opts.ch_bind_count; |
| if (!client_opts.ch_bind_count) { |
| free(client_opts.ch_binds); |
| client_opts.ch_binds = NULL; |
| } else if (i < client_opts.ch_bind_count) { |
| memcpy(&client_opts.ch_binds[i], &client_opts.ch_binds[client_opts.ch_bind_count], sizeof *client_opts.ch_binds); |
| client_opts.ch_bind_ti[i] = client_opts.ch_bind_ti[client_opts.ch_bind_count]; |
| } |
| |
| ret = 0; |
| } |
| } |
| } |
| |
| return ret; |
| } |
| |
| API int |
| nc_accept_callhome(int timeout, struct ly_ctx *ctx, struct nc_session **session) |
| { |
| int sock; |
| char *host = NULL; |
| uint16_t port, idx; |
| |
| if (!client_opts.ch_binds) { |
| ERRINIT; |
| return -1; |
| } else if (!session) { |
| ERRARG("session"); |
| return -1; |
| } |
| |
| sock = nc_sock_accept_binds(client_opts.ch_binds, client_opts.ch_bind_count, timeout, &host, &port, &idx); |
| |
| if (sock < 1) { |
| free(host); |
| return sock; |
| } |
| |
| #ifdef NC_ENABLED_SSH |
| if (client_opts.ch_bind_ti[idx] == NC_TI_LIBSSH) { |
| *session = nc_accept_callhome_ssh_sock(sock, host, port, ctx, NC_TRANSPORT_TIMEOUT); |
| } else |
| #endif |
| #ifdef NC_ENABLED_TLS |
| if (client_opts.ch_bind_ti[idx] == NC_TI_OPENSSL) { |
| *session = nc_accept_callhome_tls_sock(sock, host, port, ctx, NC_TRANSPORT_TIMEOUT); |
| } else |
| #endif |
| { |
| close(sock); |
| *session = NULL; |
| } |
| |
| free(host); |
| |
| if (!(*session)) { |
| return -1; |
| } |
| |
| return 1; |
| } |
| |
| #endif /* NC_ENABLED_SSH || NC_ENABLED_TLS */ |
| |
| API const char * const * |
| nc_session_get_cpblts(const struct nc_session *session) |
| { |
| if (!session) { |
| ERRARG("session"); |
| return NULL; |
| } |
| |
| return (const char * const *)session->opts.client.cpblts; |
| } |
| |
| API const char * |
| nc_session_cpblt(const struct nc_session *session, const char *capab) |
| { |
| int i, len; |
| |
| if (!session) { |
| ERRARG("session"); |
| return NULL; |
| } else if (!capab) { |
| ERRARG("capab"); |
| return NULL; |
| } |
| |
| len = strlen(capab); |
| for (i = 0; session->opts.client.cpblts[i]; ++i) { |
| if (!strncmp(session->opts.client.cpblts[i], capab, len)) { |
| return session->opts.client.cpblts[i]; |
| } |
| } |
| |
| return NULL; |
| } |
| |
| API int |
| nc_session_ntf_thread_running(const struct nc_session *session) |
| { |
| if (!session || (session->side != NC_CLIENT)) { |
| ERRARG("session"); |
| return 0; |
| } |
| |
| return session->opts.client.ntf_tid ? 1 : 0; |
| } |
| |
| API void |
| nc_client_init(void) |
| { |
| nc_init(); |
| } |
| |
| API void |
| nc_client_destroy(void) |
| { |
| nc_client_set_schema_searchpath(NULL); |
| #if defined(NC_ENABLED_SSH) || defined(NC_ENABLED_TLS) |
| nc_client_ch_del_bind(NULL, 0, 0); |
| #endif |
| #ifdef NC_ENABLED_SSH |
| nc_client_ssh_destroy_opts(); |
| #endif |
| #ifdef NC_ENABLED_TLS |
| nc_client_tls_destroy_opts(); |
| #endif |
| nc_destroy(); |
| } |
| |
| API NC_MSG_TYPE |
| nc_recv_reply(struct nc_session *session, struct nc_rpc *rpc, uint64_t msgid, int timeout, int parseroptions, struct nc_reply **reply) |
| { |
| struct lyxml_elem *xml; |
| NC_MSG_TYPE msgtype = 0; /* NC_MSG_ERROR */ |
| |
| if (!session) { |
| ERRARG("session"); |
| return NC_MSG_ERROR; |
| } else if (!rpc) { |
| ERRARG("rpc"); |
| return NC_MSG_ERROR; |
| } else if (!reply) { |
| ERRARG("reply"); |
| return NC_MSG_ERROR; |
| } else if (parseroptions & LYD_OPT_TYPEMASK) { |
| ERRARG("parseroptions"); |
| return NC_MSG_ERROR; |
| } else if ((session->status != NC_STATUS_RUNNING) || (session->side != NC_CLIENT)) { |
| ERR("Session %u: invalid session to receive RPC replies.", session->id); |
| return NC_MSG_ERROR; |
| } |
| parseroptions &= ~(LYD_OPT_DESTRUCT | LYD_OPT_NOSIBLINGS); |
| if (!(session->flags & NC_SESSION_CLIENT_NOT_STRICT)) { |
| parseroptions &= LYD_OPT_STRICT; |
| } |
| /* no mechanism to check external dependencies is provided */ |
| parseroptions|= LYD_OPT_NOEXTDEPS; |
| *reply = NULL; |
| |
| msgtype = get_msg(session, timeout, msgid, &xml); |
| |
| if ((msgtype == NC_MSG_REPLY) || (msgtype == NC_MSG_REPLY_ERR_MSGID)) { |
| *reply = parse_reply(session->ctx, xml, rpc, parseroptions); |
| lyxml_free(session->ctx, xml); |
| if (!(*reply)) { |
| return NC_MSG_ERROR; |
| } |
| } |
| |
| return msgtype; |
| } |
| |
| API NC_MSG_TYPE |
| nc_recv_notif(struct nc_session *session, int timeout, struct nc_notif **notif) |
| { |
| struct lyxml_elem *xml, *ev_time; |
| NC_MSG_TYPE msgtype = 0; /* NC_MSG_ERROR */ |
| |
| if (!session) { |
| ERRARG("session"); |
| return NC_MSG_ERROR; |
| } else if (!notif) { |
| ERRARG("notif"); |
| return NC_MSG_ERROR; |
| } else if (session->status != NC_STATUS_RUNNING || session->side != NC_CLIENT) { |
| ERR("Session %u: invalid session to receive Notifications.", session->id); |
| return NC_MSG_ERROR; |
| } |
| |
| msgtype = get_msg(session, timeout, 0, &xml); |
| |
| if (msgtype == NC_MSG_NOTIF) { |
| *notif = calloc(1, sizeof **notif); |
| if (!*notif) { |
| ERRMEM; |
| lyxml_free(session->ctx, xml); |
| return NC_MSG_ERROR; |
| } |
| |
| /* eventTime */ |
| LY_TREE_FOR(xml->child, ev_time) { |
| if (!strcmp(ev_time->name, "eventTime")) { |
| (*notif)->datetime = lydict_insert(session->ctx, ev_time->content, 0); |
| /* lyd_parse does not know this element */ |
| lyxml_free(session->ctx, ev_time); |
| break; |
| } |
| } |
| if (!(*notif)->datetime) { |
| ERR("Session %u: notification is missing the \"eventTime\" element.", session->id); |
| goto fail; |
| } |
| |
| /* notification body */ |
| (*notif)->tree = lyd_parse_xml(session->ctx, &xml->child, LYD_OPT_NOTIF | LYD_OPT_DESTRUCT | LYD_OPT_NOEXTDEPS |
| | (session->flags & NC_SESSION_CLIENT_NOT_STRICT ? 0 : LYD_OPT_STRICT), NULL); |
| lyxml_free(session->ctx, xml); |
| xml = NULL; |
| if (!(*notif)->tree) { |
| ERR("Session %u: failed to parse a new notification.", session->id); |
| goto fail; |
| } |
| } |
| |
| return msgtype; |
| |
| fail: |
| lydict_remove(session->ctx, (*notif)->datetime); |
| lyd_free((*notif)->tree); |
| free(*notif); |
| *notif = NULL; |
| lyxml_free(session->ctx, xml); |
| |
| return NC_MSG_ERROR; |
| } |
| |
| static void * |
| nc_recv_notif_thread(void *arg) |
| { |
| struct nc_ntf_thread_arg *ntarg; |
| struct nc_session *session; |
| void (*notif_clb)(struct nc_session *session, const struct nc_notif *notif); |
| struct nc_notif *notif; |
| NC_MSG_TYPE msgtype; |
| |
| ntarg = (struct nc_ntf_thread_arg *)arg; |
| session = ntarg->session; |
| notif_clb = ntarg->notif_clb; |
| free(ntarg); |
| |
| while (session->opts.client.ntf_tid) { |
| msgtype = nc_recv_notif(session, NC_CLIENT_NOTIF_THREAD_SLEEP / 1000, ¬if); |
| if (msgtype == NC_MSG_NOTIF) { |
| notif_clb(session, notif); |
| if (!strcmp(notif->tree->schema->name, "notificationComplete") |
| && !strcmp(notif->tree->schema->module->name, "nc-notifications")) { |
| nc_notif_free(notif); |
| break; |
| } |
| nc_notif_free(notif); |
| } else if ((msgtype == NC_MSG_ERROR) && (session->status != NC_STATUS_RUNNING)) { |
| /* quit this thread once the session is broken */ |
| break; |
| } |
| |
| usleep(NC_CLIENT_NOTIF_THREAD_SLEEP); |
| } |
| |
| VRB("Session %u: notification thread exit.", session->id); |
| session->opts.client.ntf_tid = NULL; |
| return NULL; |
| } |
| |
| API int |
| nc_recv_notif_dispatch(struct nc_session *session, void (*notif_clb)(struct nc_session *session, const struct nc_notif *notif)) |
| { |
| struct nc_ntf_thread_arg *ntarg; |
| int ret; |
| |
| if (!session) { |
| ERRARG("session"); |
| return -1; |
| } else if (!notif_clb) { |
| ERRARG("notif_clb"); |
| return -1; |
| } else if ((session->status != NC_STATUS_RUNNING) || (session->side != NC_CLIENT)) { |
| ERR("Session %u: invalid session to receive Notifications.", session->id); |
| return -1; |
| } else if (session->opts.client.ntf_tid) { |
| ERR("Session %u: separate notification thread is already running.", session->id); |
| return -1; |
| } |
| |
| ntarg = malloc(sizeof *ntarg); |
| if (!ntarg) { |
| ERRMEM; |
| return -1; |
| } |
| ntarg->session = session; |
| ntarg->notif_clb = notif_clb; |
| |
| /* just so that nc_recv_notif_thread() does not immediately exit, the value does not matter */ |
| session->opts.client.ntf_tid = malloc(sizeof *session->opts.client.ntf_tid); |
| if (!session->opts.client.ntf_tid) { |
| ERRMEM; |
| free(ntarg); |
| return -1; |
| } |
| |
| ret = pthread_create((pthread_t *)session->opts.client.ntf_tid, NULL, nc_recv_notif_thread, ntarg); |
| if (ret) { |
| ERR("Session %u: failed to create a new thread (%s).", strerror(errno)); |
| free(ntarg); |
| free((pthread_t *)session->opts.client.ntf_tid); |
| session->opts.client.ntf_tid = NULL; |
| return -1; |
| } |
| |
| return 0; |
| } |
| |
| API NC_MSG_TYPE |
| nc_send_rpc(struct nc_session *session, struct nc_rpc *rpc, int timeout, uint64_t *msgid) |
| { |
| NC_MSG_TYPE r; |
| int ret, dofree = 1; |
| struct nc_rpc_act_generic *rpc_gen; |
| struct nc_rpc_getconfig *rpc_gc; |
| struct nc_rpc_edit *rpc_e; |
| struct nc_rpc_copy *rpc_cp; |
| struct nc_rpc_delete *rpc_del; |
| struct nc_rpc_lock *rpc_lock; |
| struct nc_rpc_get *rpc_g; |
| struct nc_rpc_kill *rpc_k; |
| struct nc_rpc_commit *rpc_com; |
| struct nc_rpc_cancel *rpc_can; |
| struct nc_rpc_validate *rpc_val; |
| struct nc_rpc_getschema *rpc_gs; |
| struct nc_rpc_subscribe *rpc_sub; |
| struct lyd_node *data, *node; |
| const struct lys_module *ietfnc = NULL, *ietfncmon, *notifs, *ietfncwd = NULL; |
| char str[11]; |
| uint64_t cur_msgid; |
| |
| if (!session) { |
| ERRARG("session"); |
| return NC_MSG_ERROR; |
| } else if (!rpc) { |
| ERRARG("rpc"); |
| return NC_MSG_ERROR; |
| } else if (!msgid) { |
| ERRARG("msgid"); |
| return NC_MSG_ERROR; |
| } else if (session->status != NC_STATUS_RUNNING || session->side != NC_CLIENT) { |
| ERR("Session %u: invalid session to send RPCs.", session->id); |
| return NC_MSG_ERROR; |
| } |
| |
| if ((rpc->type != NC_RPC_GETSCHEMA) && (rpc->type != NC_RPC_ACT_GENERIC) && (rpc->type != NC_RPC_SUBSCRIBE)) { |
| ietfnc = ly_ctx_get_module(session->ctx, "ietf-netconf", NULL, 1); |
| if (!ietfnc) { |
| ERR("Session %u: missing \"ietf-netconf\" schema in the context.", session->id); |
| return NC_MSG_ERROR; |
| } |
| } |
| |
| switch (rpc->type) { |
| case NC_RPC_ACT_GENERIC: |
| rpc_gen = (struct nc_rpc_act_generic *)rpc; |
| |
| if (rpc_gen->has_data) { |
| data = rpc_gen->content.data; |
| dofree = 0; |
| } else { |
| data = lyd_parse_mem(session->ctx, rpc_gen->content.xml_str, LYD_XML, LYD_OPT_RPC | LYD_OPT_NOEXTDEPS |
| | (session->flags & NC_SESSION_CLIENT_NOT_STRICT ? 0 : LYD_OPT_STRICT), NULL); |
| if (!data) { |
| return NC_MSG_ERROR; |
| } |
| } |
| break; |
| |
| case NC_RPC_GETCONFIG: |
| rpc_gc = (struct nc_rpc_getconfig *)rpc; |
| |
| data = lyd_new(NULL, ietfnc, "get-config"); |
| node = lyd_new(data, ietfnc, "source"); |
| node = lyd_new_leaf(node, ietfnc, ncds2str[rpc_gc->source], NULL); |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| if (rpc_gc->filter) { |
| if (!rpc_gc->filter[0] || (rpc_gc->filter[0] == '<')) { |
| node = lyd_new_anydata(data, ietfnc, "filter", rpc_gc->filter, LYD_ANYDATA_SXML); |
| lyd_insert_attr(node, NULL, "type", "subtree"); |
| } else { |
| node = lyd_new_anydata(data, ietfnc, "filter", NULL, LYD_ANYDATA_CONSTSTRING); |
| lyd_insert_attr(node, NULL, "type", "xpath"); |
| lyd_insert_attr(node, NULL, "select", rpc_gc->filter); |
| } |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| |
| if (rpc_gc->wd_mode) { |
| if (!ietfncwd) { |
| ietfncwd = ly_ctx_get_module(session->ctx, "ietf-netconf-with-defaults", NULL, 1); |
| if (!ietfncwd) { |
| ERR("Session %u: missing \"ietf-netconf-with-defaults\" schema in the context.", session->id); |
| return NC_MSG_ERROR; |
| } |
| } |
| switch (rpc_gc->wd_mode) { |
| case NC_WD_UNKNOWN: |
| /* cannot get here */ |
| break; |
| case NC_WD_ALL: |
| node = lyd_new_leaf(data, ietfncwd, "with-defaults", "report-all"); |
| break; |
| case NC_WD_ALL_TAG: |
| node = lyd_new_leaf(data, ietfncwd, "with-defaults", "report-all-tagged"); |
| break; |
| case NC_WD_TRIM: |
| node = lyd_new_leaf(data, ietfncwd, "with-defaults", "trim"); |
| break; |
| case NC_WD_EXPLICIT: |
| node = lyd_new_leaf(data, ietfncwd, "with-defaults", "explicit"); |
| break; |
| } |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| break; |
| |
| case NC_RPC_EDIT: |
| rpc_e = (struct nc_rpc_edit *)rpc; |
| |
| data = lyd_new(NULL, ietfnc, "edit-config"); |
| node = lyd_new(data, ietfnc, "target"); |
| node = lyd_new_leaf(node, ietfnc, ncds2str[rpc_e->target], NULL); |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| |
| if (rpc_e->default_op) { |
| node = lyd_new_leaf(data, ietfnc, "default-operation", rpcedit_dfltop2str[rpc_e->default_op]); |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| |
| if (rpc_e->test_opt) { |
| node = lyd_new_leaf(data, ietfnc, "test-option", rpcedit_testopt2str[rpc_e->test_opt]); |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| |
| if (rpc_e->error_opt) { |
| node = lyd_new_leaf(data, ietfnc, "error-option", rpcedit_erropt2str[rpc_e->error_opt]); |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| |
| if (!rpc_e->edit_cont[0] || (rpc_e->edit_cont[0] == '<')) { |
| node = lyd_new_anydata(data, ietfnc, "config", rpc_e->edit_cont, LYD_ANYDATA_SXML); |
| } else { |
| node = lyd_new_leaf(data, ietfnc, "url", rpc_e->edit_cont); |
| } |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| break; |
| |
| case NC_RPC_COPY: |
| rpc_cp = (struct nc_rpc_copy *)rpc; |
| |
| data = lyd_new(NULL, ietfnc, "copy-config"); |
| node = lyd_new(data, ietfnc, "target"); |
| if (rpc_cp->url_trg) { |
| node = lyd_new_leaf(node, ietfnc, "url", rpc_cp->url_trg); |
| } else { |
| node = lyd_new_leaf(node, ietfnc, ncds2str[rpc_cp->target], NULL); |
| } |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| |
| node = lyd_new(data, ietfnc, "source"); |
| if (rpc_cp->url_config_src) { |
| if (!rpc_cp->url_config_src[0] || (rpc_cp->url_config_src[0] == '<')) { |
| node = lyd_new_anydata(node, ietfnc, "config", rpc_cp->url_config_src, LYD_ANYDATA_SXML); |
| } else { |
| node = lyd_new_leaf(node, ietfnc, "url", rpc_cp->url_config_src); |
| } |
| } else { |
| node = lyd_new_leaf(node, ietfnc, ncds2str[rpc_cp->source], NULL); |
| } |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| |
| if (rpc_cp->wd_mode) { |
| if (!ietfncwd) { |
| ietfncwd = ly_ctx_get_module(session->ctx, "ietf-netconf-with-defaults", NULL, 1); |
| if (!ietfncwd) { |
| ERR("Session %u: missing \"ietf-netconf-with-defaults\" schema in the context.", session->id); |
| return NC_MSG_ERROR; |
| } |
| } |
| switch (rpc_cp->wd_mode) { |
| case NC_WD_UNKNOWN: |
| /* cannot get here */ |
| break; |
| case NC_WD_ALL: |
| node = lyd_new_leaf(data, ietfncwd, "with-defaults", "report-all"); |
| break; |
| case NC_WD_ALL_TAG: |
| node = lyd_new_leaf(data, ietfncwd, "with-defaults", "report-all-tagged"); |
| break; |
| case NC_WD_TRIM: |
| node = lyd_new_leaf(data, ietfncwd, "with-defaults", "trim"); |
| break; |
| case NC_WD_EXPLICIT: |
| node = lyd_new_leaf(data, ietfncwd, "with-defaults", "explicit"); |
| break; |
| } |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| break; |
| |
| case NC_RPC_DELETE: |
| rpc_del = (struct nc_rpc_delete *)rpc; |
| |
| data = lyd_new(NULL, ietfnc, "delete-config"); |
| node = lyd_new(data, ietfnc, "target"); |
| if (rpc_del->url) { |
| node = lyd_new_leaf(node, ietfnc, "url", rpc_del->url); |
| } else { |
| node = lyd_new_leaf(node, ietfnc, ncds2str[rpc_del->target], NULL); |
| } |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| break; |
| |
| case NC_RPC_LOCK: |
| rpc_lock = (struct nc_rpc_lock *)rpc; |
| |
| data = lyd_new(NULL, ietfnc, "lock"); |
| node = lyd_new(data, ietfnc, "target"); |
| node = lyd_new_leaf(node, ietfnc, ncds2str[rpc_lock->target], NULL); |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| break; |
| |
| case NC_RPC_UNLOCK: |
| rpc_lock = (struct nc_rpc_lock *)rpc; |
| |
| data = lyd_new(NULL, ietfnc, "unlock"); |
| node = lyd_new(data, ietfnc, "target"); |
| node = lyd_new_leaf(node, ietfnc, ncds2str[rpc_lock->target], NULL); |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| break; |
| |
| case NC_RPC_GET: |
| rpc_g = (struct nc_rpc_get *)rpc; |
| |
| data = lyd_new(NULL, ietfnc, "get"); |
| if (rpc_g->filter) { |
| if (!rpc_g->filter[0] || (rpc_g->filter[0] == '<')) { |
| node = lyd_new_anydata(data, ietfnc, "filter", rpc_g->filter, LYD_ANYDATA_SXML); |
| lyd_insert_attr(node, NULL, "type", "subtree"); |
| } else { |
| node = lyd_new_anydata(data, ietfnc, "filter", NULL, LYD_ANYDATA_CONSTSTRING); |
| lyd_insert_attr(node, NULL, "type", "xpath"); |
| lyd_insert_attr(node, NULL, "select", rpc_g->filter); |
| } |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| |
| if (rpc_g->wd_mode) { |
| if (!ietfncwd) { |
| ietfncwd = ly_ctx_get_module(session->ctx, "ietf-netconf-with-defaults", NULL, 1); |
| if (!ietfncwd) { |
| ERR("Session %u: missing \"ietf-netconf-with-defaults\" schema in the context.", session->id); |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| switch (rpc_g->wd_mode) { |
| case NC_WD_UNKNOWN: |
| /* cannot get here */ |
| break; |
| case NC_WD_ALL: |
| node = lyd_new_leaf(data, ietfncwd, "with-defaults", "report-all"); |
| break; |
| case NC_WD_ALL_TAG: |
| node = lyd_new_leaf(data, ietfncwd, "with-defaults", "report-all-tagged"); |
| break; |
| case NC_WD_TRIM: |
| node = lyd_new_leaf(data, ietfncwd, "with-defaults", "trim"); |
| break; |
| case NC_WD_EXPLICIT: |
| node = lyd_new_leaf(data, ietfncwd, "with-defaults", "explicit"); |
| break; |
| } |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| break; |
| |
| case NC_RPC_KILL: |
| rpc_k = (struct nc_rpc_kill *)rpc; |
| |
| data = lyd_new(NULL, ietfnc, "kill-session"); |
| sprintf(str, "%u", rpc_k->sid); |
| lyd_new_leaf(data, ietfnc, "session-id", str); |
| break; |
| |
| case NC_RPC_COMMIT: |
| rpc_com = (struct nc_rpc_commit *)rpc; |
| |
| data = lyd_new(NULL, ietfnc, "commit"); |
| if (rpc_com->confirmed) { |
| lyd_new_leaf(data, ietfnc, "confirmed", NULL); |
| } |
| |
| if (rpc_com->confirm_timeout) { |
| sprintf(str, "%u", rpc_com->confirm_timeout); |
| lyd_new_leaf(data, ietfnc, "confirm-timeout", str); |
| } |
| |
| if (rpc_com->persist) { |
| node = lyd_new_leaf(data, ietfnc, "persist", rpc_com->persist); |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| |
| if (rpc_com->persist_id) { |
| node = lyd_new_leaf(data, ietfnc, "persist-id", rpc_com->persist_id); |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| break; |
| |
| case NC_RPC_DISCARD: |
| data = lyd_new(NULL, ietfnc, "discard-changes"); |
| break; |
| |
| case NC_RPC_CANCEL: |
| rpc_can = (struct nc_rpc_cancel *)rpc; |
| |
| data = lyd_new(NULL, ietfnc, "cancel-commit"); |
| if (rpc_can->persist_id) { |
| node = lyd_new_leaf(data, ietfnc, "persist-id", rpc_can->persist_id); |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| break; |
| |
| case NC_RPC_VALIDATE: |
| rpc_val = (struct nc_rpc_validate *)rpc; |
| |
| data = lyd_new(NULL, ietfnc, "validate"); |
| node = lyd_new(data, ietfnc, "source"); |
| if (rpc_val->url_config_src) { |
| if (!rpc_val->url_config_src[0] || (rpc_val->url_config_src[0] == '<')) { |
| node = lyd_new_anydata(node, ietfnc, "config", rpc_val->url_config_src, LYD_ANYDATA_SXML); |
| } else { |
| node = lyd_new_leaf(node, ietfnc, "url", rpc_val->url_config_src); |
| } |
| } else { |
| node = lyd_new_leaf(node, ietfnc, ncds2str[rpc_val->source], NULL); |
| } |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| break; |
| |
| case NC_RPC_GETSCHEMA: |
| ietfncmon = ly_ctx_get_module(session->ctx, "ietf-netconf-monitoring", NULL, 1); |
| if (!ietfncmon) { |
| ERR("Session %u: missing \"ietf-netconf-monitoring\" schema in the context.", session->id); |
| return NC_MSG_ERROR; |
| } |
| |
| rpc_gs = (struct nc_rpc_getschema *)rpc; |
| |
| data = lyd_new(NULL, ietfncmon, "get-schema"); |
| node = lyd_new_leaf(data, ietfncmon, "identifier", rpc_gs->identifier); |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| if (rpc_gs->version) { |
| node = lyd_new_leaf(data, ietfncmon, "version", rpc_gs->version); |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| if (rpc_gs->format) { |
| node = lyd_new_leaf(data, ietfncmon, "format", rpc_gs->format); |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| break; |
| |
| case NC_RPC_SUBSCRIBE: |
| notifs = ly_ctx_get_module(session->ctx, "notifications", NULL, 1); |
| if (!notifs) { |
| ERR("Session %u: missing \"notifications\" schema in the context.", session->id); |
| return NC_MSG_ERROR; |
| } |
| |
| rpc_sub = (struct nc_rpc_subscribe *)rpc; |
| |
| data = lyd_new(NULL, notifs, "create-subscription"); |
| if (rpc_sub->stream) { |
| node = lyd_new_leaf(data, notifs, "stream", rpc_sub->stream); |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| |
| if (rpc_sub->filter) { |
| if (!rpc_sub->filter[0] || (rpc_sub->filter[0] == '<')) { |
| node = lyd_new_anydata(data, notifs, "filter", rpc_sub->filter, LYD_ANYDATA_SXML); |
| lyd_insert_attr(node, NULL, "type", "subtree"); |
| } else { |
| node = lyd_new_anydata(data, notifs, "filter", NULL, LYD_ANYDATA_CONSTSTRING); |
| lyd_insert_attr(node, NULL, "type", "xpath"); |
| lyd_insert_attr(node, NULL, "select", rpc_sub->filter); |
| } |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| |
| if (rpc_sub->start) { |
| node = lyd_new_leaf(data, notifs, "startTime", rpc_sub->start); |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| |
| if (rpc_sub->stop) { |
| node = lyd_new_leaf(data, notifs, "stopTime", rpc_sub->stop); |
| if (!node) { |
| lyd_free(data); |
| return NC_MSG_ERROR; |
| } |
| } |
| break; |
| default: |
| ERRINT; |
| return NC_MSG_ERROR; |
| } |
| |
| if (lyd_validate(&data, LYD_OPT_RPC | LYD_OPT_NOEXTDEPS |
| | (session->flags & NC_SESSION_CLIENT_NOT_STRICT ? 0 : LYD_OPT_STRICT), NULL)) { |
| if (dofree) { |
| lyd_free(data); |
| } |
| return NC_MSG_ERROR; |
| } |
| |
| ret = nc_session_lock(session, timeout, __func__); |
| if (ret == -1) { |
| /* error */ |
| r = NC_MSG_ERROR; |
| } else if (!ret) { |
| /* blocking */ |
| r = NC_MSG_WOULDBLOCK; |
| } else { |
| /* send RPC, store its message ID */ |
| r = nc_send_msg(session, data); |
| cur_msgid = session->opts.client.msgid; |
| } |
| nc_session_unlock(session, timeout, __func__); |
| |
| if (dofree) { |
| lyd_free(data); |
| } |
| |
| if (r != NC_MSG_RPC) { |
| return r; |
| } |
| |
| *msgid = cur_msgid; |
| return NC_MSG_RPC; |
| } |
| |
| API void |
| nc_client_session_set_not_strict(struct nc_session *session) |
| { |
| if (session->side != NC_CLIENT) { |
| ERRARG("session"); |
| return; |
| } |
| |
| session->flags |= NC_SESSION_CLIENT_NOT_STRICT; |
| } |