blob: b68808db925134089dbc9b583bda972fa95c1a48 [file] [log] [blame]
Radek Krejci469aab82012-07-22 18:42:20 +02001/*!
2 * \file mod_netconf.c
3 * \brief NETCONF Apache modul for Netopeer
4 * \author Tomas Cejka <cejkat@cesnet.cz>
5 * \author Radek Krejci <rkrejci@cesnet.cz>
6 * \date 2011
7 * \date 2012
Tomas Cejka94da2c52013-01-08 18:20:30 +01008 * \date 2013
Radek Krejci469aab82012-07-22 18:42:20 +02009 */
10/*
11 * Copyright (C) 2011-2012 CESNET
12 *
13 * LICENSE TERMS
14 *
15 * Redistribution and use in source and binary forms, with or without
16 * modification, are permitted provided that the following conditions
17 * are met:
18 * 1. Redistributions of source code must retain the above copyright
19 * notice, this list of conditions and the following disclaimer.
20 * 2. Redistributions in binary form must reproduce the above copyright
21 * notice, this list of conditions and the following disclaimer in
22 * the documentation and/or other materials provided with the
23 * distribution.
24 * 3. Neither the name of the Company nor the names of its contributors
25 * may be used to endorse or promote products derived from this
26 * software without specific prior written permission.
27 *
28 * ALTERNATIVELY, provided that this notice is retained in full, this
29 * product may be distributed under the terms of the GNU General Public
30 * License (GPL) version 2 or later, in which case the provisions
31 * of the GPL apply INSTEAD OF those given above.
32 *
33 * This software is provided ``as is'', and any express or implied
34 * warranties, including, but not limited to, the implied warranties of
35 * merchantability and fitness for a particular purpose are disclaimed.
36 * In no event shall the company or contributors be liable for any
37 * direct, indirect, incidental, special, exemplary, or consequential
38 * damages (including, but not limited to, procurement of substitute
39 * goods or services; loss of use, data, or profits; or business
40 * interruption) however caused and on any theory of liability, whether
41 * in contract, strict liability, or tort (including negligence or
42 * otherwise) arising in any way out of the use of this software, even
43 * if advised of the possibility of such damage.
44 *
45 */
Tomas Cejka689a1042013-01-16 15:08:25 +010046static const char rcsid[] __attribute__((used)) ="$Id: "__FILE__": "ARCSID" $";
Radek Krejci469aab82012-07-22 18:42:20 +020047
Radek Krejci7b4ddd02012-07-30 08:09:58 +020048#include <unistd.h>
49#include <poll.h>
Radek Krejci469aab82012-07-22 18:42:20 +020050#include <sys/types.h>
51#include <sys/socket.h>
52#include <sys/un.h>
David Kupka8e60a372012-09-04 09:15:20 +020053#include <pthread.h>
54#include <ctype.h>
Radek Krejci7b4ddd02012-07-30 08:09:58 +020055
56#include <unixd.h>
57#include <httpd.h>
58#include <http_log.h>
59#include <http_config.h>
60
61#include <apr_sha1.h>
62#include <apr_hash.h>
63#include <apr_signal.h>
64#include <apr_strings.h>
Radek Krejci469aab82012-07-22 18:42:20 +020065
Radek Krejci8fd1f5e2012-07-24 17:33:36 +020066#include <json/json.h>
67
Radek Krejci469aab82012-07-22 18:42:20 +020068#include <libnetconf.h>
Radek Krejci7b4ddd02012-07-30 08:09:58 +020069
Tomas Cejka94da2c52013-01-08 18:20:30 +010070#include "message_type.h"
71
Radek Krejci469aab82012-07-22 18:42:20 +020072
73#define MAX_PROCS 5
Radek Krejci6cb08982012-07-25 18:01:06 +020074#define SOCKET_FILENAME "/tmp/mod_netconf.sock"
Radek Krejci469aab82012-07-22 18:42:20 +020075#define MAX_SOCKET_CL 10
76#define BUFFER_SIZE 4096
77
78/* sleep in master process for non-blocking socket reading */
79#define SLEEP_TIME 200
80
81#ifndef offsetof
82#define offsetof(type, member) ((size_t) ((type *) 0)->member)
83#endif
84
Tomas Cejka027f3bc2012-11-10 20:28:36 +010085/* timeout in msec */
Radek Krejci469aab82012-07-22 18:42:20 +020086struct timeval timeout = { 1, 0 };
87
Tomas Cejka5064c232013-01-17 09:30:58 +010088#define NCWITHDEFAULTS NCWD_MODE_NOTSET
89
90
Radek Krejci8fd1f5e2012-07-24 17:33:36 +020091
Radek Krejci469aab82012-07-22 18:42:20 +020092#define MSG_OK 0
93#define MSG_OPEN 1
94#define MSG_DATA 2
95#define MSG_CLOSE 3
96#define MSG_ERROR 4
97#define MSG_UNKNOWN 5
98
Radek Krejci469aab82012-07-22 18:42:20 +020099module AP_MODULE_DECLARE_DATA netconf_module;
100
101typedef struct {
Radek Krejci469aab82012-07-22 18:42:20 +0200102 apr_pool_t *pool;
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200103 apr_proc_t *forkproc;
104 char* sockname;
Radek Krejcif23850c2012-07-23 16:14:17 +0200105} mod_netconf_cfg;
Radek Krejci469aab82012-07-22 18:42:20 +0200106
David Kupka8e60a372012-09-04 09:15:20 +0200107struct pass_to_thread {
108 int client; /**< opened socket */
109 apr_pool_t * pool; /**< ?? */
110 server_rec * server; /**< ?? */
111 apr_hash_t * netconf_sessions_list; /**< ?? */
112};
113
114struct session_with_mutex {
115 struct nc_session * session; /**< netconf session */
116 pthread_mutex_t lock; /**< mutex protecting the session from multiple access */
117};
118
119pthread_rwlock_t session_lock; /**< mutex protecting netconf_session_list from multiple access errors */
120
Radek Krejci469aab82012-07-22 18:42:20 +0200121volatile int isterminated = 0;
122
123static char* password;
124
125
126static void signal_handler(int sign)
127{
128 switch (sign) {
129 case SIGTERM:
130 isterminated = 1;
Radek Krejci469aab82012-07-22 18:42:20 +0200131 break;
132 }
133}
134
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200135static char* gen_ncsession_hash( const char* hostname, const char* port, const char* sid)
Radek Krejci469aab82012-07-22 18:42:20 +0200136{
Radek Krejcif23850c2012-07-23 16:14:17 +0200137 unsigned char hash_raw[APR_SHA1_DIGESTSIZE];
138 int i;
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200139 char* hash;
Radek Krejcif23850c2012-07-23 16:14:17 +0200140
Radek Krejci469aab82012-07-22 18:42:20 +0200141 apr_sha1_ctx_t sha1_ctx;
142 apr_sha1_init(&sha1_ctx);
143 apr_sha1_update(&sha1_ctx, hostname, strlen(hostname));
144 apr_sha1_update(&sha1_ctx, port, strlen(port));
145 apr_sha1_update(&sha1_ctx, sid, strlen(sid));
Radek Krejcif23850c2012-07-23 16:14:17 +0200146 apr_sha1_final(hash_raw, &sha1_ctx);
Radek Krejci469aab82012-07-22 18:42:20 +0200147
Radek Krejcif23850c2012-07-23 16:14:17 +0200148 /* convert binary hash into hex string, which is printable */
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200149 hash = malloc(sizeof(char) * ((2*APR_SHA1_DIGESTSIZE)+1));
Radek Krejcif23850c2012-07-23 16:14:17 +0200150 for (i = 0; i < APR_SHA1_DIGESTSIZE; i++) {
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200151 snprintf(hash + (2*i), 3, "%02x", hash_raw[i]);
Radek Krejcif23850c2012-07-23 16:14:17 +0200152 }
153 //hash[2*APR_SHA1_DIGESTSIZE] = 0;
Radek Krejci469aab82012-07-22 18:42:20 +0200154
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200155 return (hash);
Radek Krejci469aab82012-07-22 18:42:20 +0200156}
157
158int netconf_callback_ssh_hostkey_check (const char* hostname, int keytype, const char* fingerprint)
159{
160 /* always approve */
161 return (EXIT_SUCCESS);
162}
163
164char* netconf_callback_sshauth_password (const char* username, const char* hostname)
165{
166 char* buf;
167
168 buf = malloc ((strlen(password) + 1) * sizeof(char));
169 apr_cpystrn(buf, password, strlen(password) + 1);
170
171 return (buf);
172}
173
174void netconf_callback_sshauth_interactive (const char* name,
175 int name_len,
176 const char* instruction,
177 int instruction_len,
178 int num_prompts,
179 const LIBSSH2_USERAUTH_KBDINT_PROMPT* prompts,
180 LIBSSH2_USERAUTH_KBDINT_RESPONSE* responses,
181 void** abstract)
182{
183 int i;
184
185 for (i=0; i<num_prompts; i++) {
186 responses[i].text = malloc ((strlen(password) + 1) * sizeof(char));
187 apr_cpystrn(responses[i].text, password, strlen(password) + 1);
188 responses[i].length = strlen(responses[i].text) + 1;
189 }
190
191 return;
192}
193
Radek Krejcic11fd862012-07-26 12:41:21 +0200194static json_object *err_reply = NULL;
195void netconf_callback_error_process(const char* tag,
196 const char* type,
197 const char* severity,
198 const char* apptag,
199 const char* path,
200 const char* message,
201 const char* attribute,
202 const char* element,
203 const char* ns,
204 const char* sid)
205{
206 err_reply = json_object_new_object();
207 json_object_object_add(err_reply, "type", json_object_new_int(REPLY_ERROR));
208 if (tag) json_object_object_add(err_reply, "error-tag", json_object_new_string(tag));
209 if (type) json_object_object_add(err_reply, "error-type", json_object_new_string(type));
210 if (severity) json_object_object_add(err_reply, "error-severity", json_object_new_string(severity));
211 if (apptag) json_object_object_add(err_reply, "error-app-tag", json_object_new_string(apptag));
212 if (path) json_object_object_add(err_reply, "error-path", json_object_new_string(path));
213 if (message) json_object_object_add(err_reply, "error-message", json_object_new_string(message));
214 if (attribute) json_object_object_add(err_reply, "bad-attribute", json_object_new_string(attribute));
215 if (element) json_object_object_add(err_reply, "bad-element", json_object_new_string(element));
216 if (ns) json_object_object_add(err_reply, "bad-namespace", json_object_new_string(ns));
217 if (sid) json_object_object_add(err_reply, "session-id", json_object_new_string(sid));
218}
219
Kupka David00b9c5c2012-09-05 09:45:50 +0200220static char* netconf_connect(server_rec* server, apr_pool_t* pool, apr_hash_t* conns, const char* host, const char* port, const char* user, const char* pass, struct nc_cpblts * cpblts)
Radek Krejci469aab82012-07-22 18:42:20 +0200221{
Radek Krejci469aab82012-07-22 18:42:20 +0200222 struct nc_session* session;
David Kupka8e60a372012-09-04 09:15:20 +0200223 struct session_with_mutex * locked_session;
Radek Krejcif23850c2012-07-23 16:14:17 +0200224 char *session_key;
Radek Krejci469aab82012-07-22 18:42:20 +0200225
226 /* connect to the requested NETCONF server */
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200227 password = (char*)pass;
David Kupka8e60a372012-09-04 09:15:20 +0200228 session = nc_session_connect(host, (unsigned short) atoi (port), user, cpblts);
229
Radek Krejci469aab82012-07-22 18:42:20 +0200230 /* if connected successful, add session to the list */
231 if (session != NULL) {
232 /* generate hash for the session */
Radek Krejcic11fd862012-07-26 12:41:21 +0200233 session_key = gen_ncsession_hash(
234 (host==NULL) ? "localhost" : host,
235 (port==NULL) ? "830" : port,
Radek Krejcia282bed2012-07-27 14:43:45 +0200236 nc_session_get_id(session));
David Kupka8e60a372012-09-04 09:15:20 +0200237
238 if ((locked_session = malloc (sizeof (struct session_with_mutex))) == NULL || pthread_mutex_init (&locked_session->lock, NULL) != 0) {
239 nc_session_free(session);
240 free (locked_session);
241 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Creating structure session_with_mutex failed %d (%s)", errno, strerror(errno));
242 return NULL;
243 }
244 locked_session->session = session;
245 pthread_mutex_init (&locked_session->lock, NULL);
Tomas Cejkabcdc1142012-11-14 01:12:43 +0100246 ap_log_error(APLOG_MARK, APLOG_NOTICE, 0, server, "Before session_lock");
David Kupka8e60a372012-09-04 09:15:20 +0200247 /* get exclusive access to sessions_list (conns) */
248 if (pthread_rwlock_wrlock (&session_lock) != 0) {
249 nc_session_free(session);
250 free (locked_session);
251 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while locking rwlock: %d (%s)", errno, strerror(errno));
252 return NULL;
253 }
Tomas Cejkabcdc1142012-11-14 01:12:43 +0100254 ap_log_error(APLOG_MARK, APLOG_NOTICE, 0, server, "Add connection to the list");
David Kupka8e60a372012-09-04 09:15:20 +0200255 apr_hash_set(conns, apr_pstrdup(pool, session_key), APR_HASH_KEY_STRING, (void *) locked_session);
Tomas Cejkabcdc1142012-11-14 01:12:43 +0100256 ap_log_error(APLOG_MARK, APLOG_NOTICE, 0, server, "Before session_unlock");
David Kupka8e60a372012-09-04 09:15:20 +0200257 /* end of critical section */
258 if (pthread_rwlock_unlock (&session_lock) != 0) {
259 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while unlocking rwlock: %d (%s)", errno, strerror(errno));
260 return NULL;
261 }
Radek Krejci469aab82012-07-22 18:42:20 +0200262 ap_log_error(APLOG_MARK, APLOG_NOTICE, 0, server, "NETCONF session established");
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200263 return (session_key);
Radek Krejci469aab82012-07-22 18:42:20 +0200264 } else {
265 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Connection could not be established");
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200266 return (NULL);
Radek Krejci469aab82012-07-22 18:42:20 +0200267 }
268
Radek Krejci469aab82012-07-22 18:42:20 +0200269}
270
Radek Krejci80c10d92012-07-30 08:38:50 +0200271static int netconf_close(server_rec* server, apr_hash_t* conns, const char* session_key)
Radek Krejci469aab82012-07-22 18:42:20 +0200272{
273 struct nc_session *ns = NULL;
David Kupka8e60a372012-09-04 09:15:20 +0200274 struct session_with_mutex * locked_session;
Radek Krejci469aab82012-07-22 18:42:20 +0200275
Radek Krejcif23850c2012-07-23 16:14:17 +0200276 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Key in hash to get: %s", session_key);
David Kupka8e60a372012-09-04 09:15:20 +0200277 /* get exclusive (write) access to sessions_list (conns) */
278 if (pthread_rwlock_wrlock (&session_lock) != 0) {
279 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while locking rwlock: %d (%s)", errno, strerror(errno));
280 return EXIT_FAILURE;
281 }
282 locked_session = (struct session_with_mutex *)apr_hash_get(conns, session_key, APR_HASH_KEY_STRING);
283 if (locked_session != NULL) {
284 pthread_mutex_destroy(&locked_session->lock);
285 ns = locked_session->session;
286 free (locked_session);
287 }
Radek Krejci469aab82012-07-22 18:42:20 +0200288 if (ns != NULL) {
Tomas Cejka027f3bc2012-11-10 20:28:36 +0100289 nc_session_close (ns, NC_SESSION_TERM_CLOSED);
Radek Krejci469aab82012-07-22 18:42:20 +0200290 nc_session_free (ns);
291 ns = NULL;
292
293 /* remove session from the active sessions list */
294 apr_hash_set(conns, session_key, APR_HASH_KEY_STRING, NULL);
David Kupka8e60a372012-09-04 09:15:20 +0200295 /* end of critical section */
296 if (pthread_rwlock_unlock (&session_lock) != 0) {
297 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while unlocking rwlock: %d (%s)", errno, strerror(errno));
298 return EXIT_FAILURE;
299 }
Radek Krejci469aab82012-07-22 18:42:20 +0200300 ap_log_error(APLOG_MARK, APLOG_NOTICE, 0, server, "NETCONF session closed");
Radek Krejcif23850c2012-07-23 16:14:17 +0200301
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200302 return (EXIT_SUCCESS);
Radek Krejci469aab82012-07-22 18:42:20 +0200303 } else {
Tomas Cejka6c4609b2012-10-12 22:29:47 +0200304 if (pthread_rwlock_unlock (&session_lock) != 0) {
305 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while unlocking rwlock: %d (%s)", errno, strerror(errno));
306 return EXIT_FAILURE;
307 }
Radek Krejci469aab82012-07-22 18:42:20 +0200308 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Unknown session to close");
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200309 return (EXIT_FAILURE);
Radek Krejci469aab82012-07-22 18:42:20 +0200310 }
311}
312
Radek Krejci80c10d92012-07-30 08:38:50 +0200313static int netconf_op(server_rec* server, apr_hash_t* conns, const char* session_key, nc_rpc* rpc)
Radek Krejci469aab82012-07-22 18:42:20 +0200314{
315 struct nc_session *session = NULL;
David Kupka8e60a372012-09-04 09:15:20 +0200316 struct session_with_mutex * locked_session;
Radek Krejci035bf4e2012-07-25 10:59:09 +0200317 nc_reply* reply;
318 int retval = EXIT_SUCCESS;
Radek Krejcia332b692012-11-12 16:15:54 +0100319 NC_MSG_TYPE msgt;
320 NC_REPLY_TYPE replyt;
Radek Krejci035bf4e2012-07-25 10:59:09 +0200321
Radek Krejci8e4632a2012-07-26 13:40:34 +0200322 /* check requests */
323 if (rpc == NULL) {
324 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: rpc is not created");
325 return (EXIT_FAILURE);
326 }
327
David Kupka8e60a372012-09-04 09:15:20 +0200328 /* get non-exclusive (read) access to sessions_list (conns) */
329 if (pthread_rwlock_rdlock (&session_lock) != 0) {
330 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while locking rwlock: %d (%s)", errno, strerror(errno));
331 return EXIT_FAILURE;
332 }
Radek Krejci8e4632a2012-07-26 13:40:34 +0200333 /* get session where send the RPC */
David Kupka8e60a372012-09-04 09:15:20 +0200334 locked_session = (struct session_with_mutex *)apr_hash_get(conns, session_key, APR_HASH_KEY_STRING);
335 if (locked_session != NULL) {
336 session = locked_session->session;
337 }
Radek Krejci035bf4e2012-07-25 10:59:09 +0200338 if (session != NULL) {
David Kupka8e60a372012-09-04 09:15:20 +0200339 /* get exclusive access to session */
340 if (pthread_mutex_lock(&locked_session->lock) != 0) {
341 /* unlock before returning error */
342 if (pthread_rwlock_unlock (&session_lock) != 0) {
343 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while locking rwlock: %d (%s)", errno, strerror(errno));
344 return EXIT_FAILURE;
345 }
346 return EXIT_FAILURE;
347 }
Radek Krejci035bf4e2012-07-25 10:59:09 +0200348 /* send the request and get the reply */
Radek Krejcia332b692012-11-12 16:15:54 +0100349 msgt = nc_session_send_recv(session, rpc, &reply);
350
David Kupka8e60a372012-09-04 09:15:20 +0200351 /* first release exclusive lock for this session */
352 pthread_mutex_unlock(&locked_session->lock);
353 /* end of critical section */
354 if (pthread_rwlock_unlock (&session_lock) != 0) {
355 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while unlocking rwlock: %d (%s)", errno, strerror(errno));
356 return EXIT_FAILURE;
357 }
Radek Krejci035bf4e2012-07-25 10:59:09 +0200358
Radek Krejcia332b692012-11-12 16:15:54 +0100359 /* process the result of the operation */
360 switch (msgt) {
361 case NC_MSG_UNKNOWN:
362 if (nc_session_get_status(session) != NC_SESSION_STATUS_WORKING) {
363 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: receiving rpc-reply failed");
364 netconf_close(server, conns, session_key);
365 return (EXIT_FAILURE);
366 }
367 /* no break */
368 case NC_MSG_NONE:
369 /* there is error handled by callback */
370 return (EXIT_FAILURE);
371 break;
372 case NC_MSG_REPLY:
373 switch (replyt = nc_reply_get_type(reply)) {
374 case NC_REPLY_OK:
375 retval = EXIT_SUCCESS;
376 break;
377 default:
378 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: unexpected rpc-reply (%d)", replyt);
379 retval = EXIT_FAILURE;
380 break;
381 }
Radek Krejci035bf4e2012-07-25 10:59:09 +0200382 break;
383 default:
Radek Krejcia332b692012-11-12 16:15:54 +0100384 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: unexpected reply message received (%d)", msgt);
Radek Krejci035bf4e2012-07-25 10:59:09 +0200385 retval = EXIT_FAILURE;
386 break;
387 }
388 nc_reply_free(reply);
389 return (retval);
390 } else {
Tomas Cejkabcdc1142012-11-14 01:12:43 +0100391 /* release lock on failure */
392 if (pthread_rwlock_unlock (&session_lock) != 0) {
393 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while unlocking rwlock: %d (%s)", errno, strerror(errno));
394 }
Radek Krejci035bf4e2012-07-25 10:59:09 +0200395 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Unknown session to process.");
396 return (EXIT_FAILURE);
397 }
398}
Radek Krejci80c10d92012-07-30 08:38:50 +0200399
400static char* netconf_opdata(server_rec* server, apr_hash_t* conns, const char* session_key, nc_rpc* rpc)
Radek Krejci8e4632a2012-07-26 13:40:34 +0200401{
402 struct nc_session *session = NULL;
David Kupka8e60a372012-09-04 09:15:20 +0200403 struct session_with_mutex * locked_session;
Radek Krejcia332b692012-11-12 16:15:54 +0100404 nc_reply* reply = NULL;
Radek Krejci8e4632a2012-07-26 13:40:34 +0200405 char* data;
Radek Krejcia332b692012-11-12 16:15:54 +0100406 NC_MSG_TYPE msgt;
407 NC_REPLY_TYPE replyt;
Radek Krejci8e4632a2012-07-26 13:40:34 +0200408
409 /* check requests */
410 if (rpc == NULL) {
411 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: rpc is not created");
412 return (NULL);
413 }
414
David Kupka8e60a372012-09-04 09:15:20 +0200415 /* get non-exclusive (read) access to sessions_list (conns) */
416 if (pthread_rwlock_rdlock (&session_lock) != 0) {
417 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while locking rwlock: %d (%s)", errno, strerror(errno));
418 return NULL;
419 }
Radek Krejci8e4632a2012-07-26 13:40:34 +0200420 /* get session where send the RPC */
David Kupka8e60a372012-09-04 09:15:20 +0200421 locked_session = (struct session_with_mutex *)apr_hash_get(conns, session_key, APR_HASH_KEY_STRING);
422 if (locked_session != NULL) {
423 session = locked_session->session;
424 }
Radek Krejci8e4632a2012-07-26 13:40:34 +0200425 if (session != NULL) {
David Kupka8e60a372012-09-04 09:15:20 +0200426 /* get exclusive access to session */
427 if (pthread_mutex_lock(&locked_session->lock) != 0) {
428 /* unlock before returning error */
429 if (pthread_rwlock_unlock (&session_lock) != 0) {
430 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while locking rwlock: %d (%s)", errno, strerror(errno));
431 return NULL;
432 }
433 return NULL;
434 }
Radek Krejci8e4632a2012-07-26 13:40:34 +0200435 /* send the request and get the reply */
Radek Krejcia332b692012-11-12 16:15:54 +0100436 msgt = nc_session_send_recv(session, rpc, &reply);
437
David Kupka8e60a372012-09-04 09:15:20 +0200438 /* first release exclusive lock for this session */
439 pthread_mutex_unlock(&locked_session->lock);
440 /* end of critical section */
441 if (pthread_rwlock_unlock (&session_lock) != 0) {
442 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while unlocking rwlock: %d (%s)", errno, strerror(errno));
Radek Krejcia332b692012-11-12 16:15:54 +0100443 return (NULL);
David Kupka8e60a372012-09-04 09:15:20 +0200444 }
Radek Krejci8e4632a2012-07-26 13:40:34 +0200445
Radek Krejcia332b692012-11-12 16:15:54 +0100446 /* process the result of the operation */
447 switch (msgt) {
448 case NC_MSG_UNKNOWN:
449 if (nc_session_get_status(session) != NC_SESSION_STATUS_WORKING) {
450 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: receiving rpc-reply failed");
451 netconf_close(server, conns, session_key);
Radek Krejci8e4632a2012-07-26 13:40:34 +0200452 return (NULL);
453 }
Radek Krejcia332b692012-11-12 16:15:54 +0100454 /* no break */
455 case NC_MSG_NONE:
456 /* there is error handled by callback */
457 return (NULL);
458 break;
459 case NC_MSG_REPLY:
460 switch (replyt = nc_reply_get_type(reply)) {
461 case NC_REPLY_DATA:
462 if ((data = nc_reply_get_data (reply)) == NULL) {
463 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: no data from reply");
464 data = NULL;
465 }
466 break;
467 default:
468 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: unexpected rpc-reply (%d)", replyt);
469 data = NULL;
470 break;
471 }
Radek Krejci8e4632a2012-07-26 13:40:34 +0200472 break;
473 default:
Radek Krejcia332b692012-11-12 16:15:54 +0100474 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: unexpected reply message received (%d)", msgt);
475 data = NULL;
476 break;
Radek Krejci8e4632a2012-07-26 13:40:34 +0200477 }
478 nc_reply_free(reply);
Radek Krejci8e4632a2012-07-26 13:40:34 +0200479 return (data);
480 } else {
Tomas Cejkabcdc1142012-11-14 01:12:43 +0100481 /* release lock on failure */
482 if (pthread_rwlock_unlock (&session_lock) != 0) {
483 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while unlocking rwlock: %d (%s)", errno, strerror(errno));
484 }
Radek Krejci8e4632a2012-07-26 13:40:34 +0200485 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Unknown session to process.");
486 return (NULL);
487 }
488}
489
Radek Krejci80c10d92012-07-30 08:38:50 +0200490static char* netconf_getconfig(server_rec* server, apr_hash_t* conns, const char* session_key, NC_DATASTORE source, const char* filter)
Radek Krejci8e4632a2012-07-26 13:40:34 +0200491{
492 nc_rpc* rpc;
493 struct nc_filter *f = NULL;
494 char* data = NULL;
495
496 /* create filter if set */
497 if (filter != NULL) {
498 f = nc_filter_new(NC_FILTER_SUBTREE, filter);
499 }
500
501 /* create requests */
Tomas Cejka5064c232013-01-17 09:30:58 +0100502 rpc = nc_rpc_getconfig (source, f);
Radek Krejci8e4632a2012-07-26 13:40:34 +0200503 nc_filter_free(f);
504 if (rpc == NULL) {
505 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: creating rpc request failed");
506 return (NULL);
507 }
508
509 data = netconf_opdata(server, conns, session_key, rpc);
510 nc_rpc_free (rpc);
511 return (data);
512}
513
Tomas Cejka0aeca8b2012-12-22 19:56:03 +0100514static char* netconf_getschema(server_rec* server, apr_hash_t* conns, const char* session_key, const char* identifier, const char* version, const char* format)
515{
516 nc_rpc* rpc;
517 char* data = NULL;
518
519 /* create requests */
Tomas Cejka94da2c52013-01-08 18:20:30 +0100520 rpc = nc_rpc_getschema(identifier, version, format);
Tomas Cejka0aeca8b2012-12-22 19:56:03 +0100521 if (rpc == NULL) {
522 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: creating rpc request failed");
523 return (NULL);
524 }
525
526 data = netconf_opdata(server, conns, session_key, rpc);
527 nc_rpc_free (rpc);
528 return (data);
529}
530
Radek Krejci80c10d92012-07-30 08:38:50 +0200531static char* netconf_get(server_rec* server, apr_hash_t* conns, const char* session_key, const char* filter)
Radek Krejci8e4632a2012-07-26 13:40:34 +0200532{
533 nc_rpc* rpc;
534 struct nc_filter *f = NULL;
535 char* data = NULL;
536
537 /* create filter if set */
538 if (filter != NULL) {
539 f = nc_filter_new(NC_FILTER_SUBTREE, filter);
540 }
541
542 /* create requests */
Tomas Cejka5064c232013-01-17 09:30:58 +0100543 rpc = nc_rpc_get (f);
Radek Krejci8e4632a2012-07-26 13:40:34 +0200544 nc_filter_free(f);
545 if (rpc == NULL) {
546 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: creating rpc request failed");
547 return (NULL);
548 }
549
550 data = netconf_opdata(server, conns, session_key, rpc);
551 nc_rpc_free (rpc);
552 return (data);
553}
554
Tomas Cejka5064c232013-01-17 09:30:58 +0100555static int netconf_copyconfig(server_rec* server, apr_hash_t* conns, const char* session_key, NC_DATASTORE source, NC_DATASTORE target, const char* config, const char *url)
Radek Krejci8e4632a2012-07-26 13:40:34 +0200556{
557 nc_rpc* rpc;
558 int retval = EXIT_SUCCESS;
559
560 /* create requests */
Tomas Cejka5064c232013-01-17 09:30:58 +0100561 if ((source == NC_DATASTORE_CONFIG) || (source == NC_DATASTORE_URL)) {
562 if (target == NC_DATASTORE_URL) {
563 rpc = nc_rpc_copyconfig(source, target, config, url);
564 } else {
565 rpc = nc_rpc_copyconfig(source, target, config);
566 }
567 } else {
568 if (target == NC_DATASTORE_URL) {
569 rpc = nc_rpc_copyconfig(source, target, url);
570 } else {
571 rpc = nc_rpc_copyconfig(source, target);
572 }
573 }
Radek Krejci8e4632a2012-07-26 13:40:34 +0200574 if (rpc == NULL) {
575 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: creating rpc request failed");
576 return (EXIT_FAILURE);
577 }
578
579 retval = netconf_op(server, conns, session_key, rpc);
580 nc_rpc_free (rpc);
581 return (retval);
582}
Radek Krejci035bf4e2012-07-25 10:59:09 +0200583
Tomas Cejka5064c232013-01-17 09:30:58 +0100584static int netconf_editconfig(server_rec* server, apr_hash_t* conns, const char* session_key, NC_DATASTORE target, NC_EDIT_DEFOP_TYPE defop, NC_EDIT_ERROPT_TYPE erropt, NC_EDIT_TESTOPT_TYPE testopt, const char* config)
Radek Krejci62ab34b2012-07-26 13:42:05 +0200585{
586 nc_rpc* rpc;
587 int retval = EXIT_SUCCESS;
588
589 /* create requests */
Tomas Cejka5064c232013-01-17 09:30:58 +0100590 /* TODO source NC_DATASTORE_CONFIG / NC_DATASTORE_URL */
591 rpc = nc_rpc_editconfig(target, NC_DATASTORE_CONFIG, defop, erropt, testopt, config);
Radek Krejci62ab34b2012-07-26 13:42:05 +0200592 if (rpc == NULL) {
593 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: creating rpc request failed");
594 return (EXIT_FAILURE);
595 }
596
597 retval = netconf_op(server, conns, session_key, rpc);
598 nc_rpc_free (rpc);
599 return (retval);
600}
601
Radek Krejci80c10d92012-07-30 08:38:50 +0200602static int netconf_killsession(server_rec* server, apr_hash_t* conns, const char* session_key, const char* sid)
Radek Krejcie34d3eb2012-07-26 15:05:53 +0200603{
604 nc_rpc* rpc;
605 int retval = EXIT_SUCCESS;
606
607 /* create requests */
608 rpc = nc_rpc_killsession(sid);
609 if (rpc == NULL) {
610 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: creating rpc request failed");
611 return (EXIT_FAILURE);
612 }
613
614 retval = netconf_op(server, conns, session_key, rpc);
615 nc_rpc_free (rpc);
616 return (retval);
617}
618
Radek Krejci80c10d92012-07-30 08:38:50 +0200619static int netconf_onlytargetop(server_rec* server, apr_hash_t* conns, const char* session_key, NC_DATASTORE target, nc_rpc* (*op_func)(NC_DATASTORE))
Radek Krejci2f318372012-07-26 14:22:35 +0200620{
621 nc_rpc* rpc;
622 int retval = EXIT_SUCCESS;
623
624 /* create requests */
Radek Krejci5cd7d422012-07-26 14:50:29 +0200625 rpc = op_func(target);
Radek Krejci2f318372012-07-26 14:22:35 +0200626 if (rpc == NULL) {
627 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: creating rpc request failed");
628 return (EXIT_FAILURE);
629 }
630
631 retval = netconf_op(server, conns, session_key, rpc);
632 nc_rpc_free (rpc);
633 return (retval);
634}
635
Radek Krejci80c10d92012-07-30 08:38:50 +0200636static int netconf_deleteconfig(server_rec* server, apr_hash_t* conns, const char* session_key, NC_DATASTORE target)
Radek Krejci5cd7d422012-07-26 14:50:29 +0200637{
638 return (netconf_onlytargetop(server, conns, session_key, target, nc_rpc_deleteconfig));
639}
640
Radek Krejci80c10d92012-07-30 08:38:50 +0200641static int netconf_lock(server_rec* server, apr_hash_t* conns, const char* session_key, NC_DATASTORE target)
Radek Krejci5cd7d422012-07-26 14:50:29 +0200642{
643 return (netconf_onlytargetop(server, conns, session_key, target, nc_rpc_lock));
644}
645
Radek Krejci80c10d92012-07-30 08:38:50 +0200646static int netconf_unlock(server_rec* server, apr_hash_t* conns, const char* session_key, NC_DATASTORE target)
Radek Krejci5cd7d422012-07-26 14:50:29 +0200647{
648 return (netconf_onlytargetop(server, conns, session_key, target, nc_rpc_unlock));
649}
650
Radek Krejci80c10d92012-07-30 08:38:50 +0200651/**
652 * @return REPLY_OK: 0, *data == NULL
653 * REPLY_DATA: 0, *data != NULL
654 * REPLY_ERROR: 1, *data == NULL
655 */
656static int netconf_generic(server_rec* server, apr_hash_t* conns, const char* session_key, const char* content, char** data)
657{
658 struct nc_session *session = NULL;
659 nc_reply* reply;
660 nc_rpc* rpc;
661 int retval = EXIT_SUCCESS;
Radek Krejcia332b692012-11-12 16:15:54 +0100662 NC_MSG_TYPE msgt;
663 NC_REPLY_TYPE replyt;
Radek Krejci80c10d92012-07-30 08:38:50 +0200664
665 /* create requests */
666 rpc = nc_rpc_generic(content);
667 if (rpc == NULL) {
668 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: creating rpc request failed");
669 return (EXIT_FAILURE);
670 }
671
Radek Krejcia332b692012-11-12 16:15:54 +0100672 if (data != NULL) {
673 *data = NULL;
674 }
Radek Krejci80c10d92012-07-30 08:38:50 +0200675
676 /* get session where send the RPC */
677 session = (struct nc_session *)apr_hash_get(conns, session_key, APR_HASH_KEY_STRING);
678 if (session != NULL) {
679 /* send the request and get the reply */
Radek Krejcia332b692012-11-12 16:15:54 +0100680 msgt = nc_session_send_recv(session, rpc, &reply);
681 nc_rpc_free (rpc);
682
683 /* process the result of the operation */
684 switch (msgt) {
685 case NC_MSG_UNKNOWN:
Radek Krejci80c10d92012-07-30 08:38:50 +0200686 if (nc_session_get_status(session) != NC_SESSION_STATUS_WORKING) {
687 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: receiving rpc-reply failed");
688 netconf_close(server, conns, session_key);
689 return (EXIT_FAILURE);
690 }
Radek Krejcia332b692012-11-12 16:15:54 +0100691 /* no break */
692 case NC_MSG_NONE:
Radek Krejci80c10d92012-07-30 08:38:50 +0200693 /* there is error handled by callback */
694 return (EXIT_FAILURE);
Radek Krejci80c10d92012-07-30 08:38:50 +0200695 break;
Radek Krejcia332b692012-11-12 16:15:54 +0100696 case NC_MSG_REPLY:
697 switch (replyt = nc_reply_get_type(reply)) {
698 case NC_REPLY_DATA:
699 if ((data != NULL) && (*data = nc_reply_get_data (reply)) == NULL) {
700 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: no data from reply");
701 nc_reply_free(reply);
702 return (EXIT_FAILURE);
703 }
704 retval = EXIT_SUCCESS;
705 break;
706 case NC_REPLY_OK:
707 retval = EXIT_SUCCESS;
708 break;
709 default:
710 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: unexpected rpc-reply (%d)", replyt);
711 retval = EXIT_FAILURE;
712 break;
713 }
Radek Krejci80c10d92012-07-30 08:38:50 +0200714 break;
715 default:
Radek Krejcia332b692012-11-12 16:15:54 +0100716 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: unexpected reply message received (%d)", msgt);
Radek Krejci80c10d92012-07-30 08:38:50 +0200717 retval = EXIT_FAILURE;
718 break;
719 }
720 nc_reply_free(reply);
721
722 return (retval);
723 } else {
724 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Unknown session to process.");
725 return (EXIT_FAILURE);
726 }
727}
728
Radek Krejci469aab82012-07-22 18:42:20 +0200729server_rec* clb_print_server;
Radek Krejci7338bde2012-08-10 12:57:30 +0200730void clb_print(NC_VERB_LEVEL level, const char* msg)
Radek Krejci469aab82012-07-22 18:42:20 +0200731{
Radek Krejci7338bde2012-08-10 12:57:30 +0200732 switch (level) {
733 case NC_VERB_ERROR:
734 ap_log_error(APLOG_MARK, APLOG_ERR, 0, clb_print_server, msg);
735 break;
736 case NC_VERB_WARNING:
737 ap_log_error(APLOG_MARK, APLOG_WARNING, 0, clb_print_server, msg);
738 break;
739 case NC_VERB_VERBOSE:
740 ap_log_error(APLOG_MARK, APLOG_INFO, 0, clb_print_server, msg);
741 break;
742 case NC_VERB_DEBUG:
743 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, clb_print_server, msg);
744 break;
745 }
Radek Krejci469aab82012-07-22 18:42:20 +0200746}
747
David Kupka8e60a372012-09-04 09:15:20 +0200748void * thread_routine (void * arg)
749{
750 void * retval = NULL;
751
752 ssize_t buffer_len;
753 struct pollfd fds;
754 int status, buffer_size, ret;
Kupka David00b9c5c2012-09-05 09:45:50 +0200755 json_object *request, *reply, *json_obj, *capabilities;
David Kupka8e60a372012-09-04 09:15:20 +0200756 int operation;
Kupka David00b9c5c2012-09-05 09:45:50 +0200757 int i, chunk_len, len = 0;
David Kupka8e60a372012-09-04 09:15:20 +0200758 char* session_key, *data;
759 const char *host, *port, *user, *pass;
760 const char *msgtext, *cpbltstr;
761 const char *target, *source, *filter, *config, *defop, *erropt, *sid;
Tomas Cejka94da2c52013-01-08 18:20:30 +0100762 const char *identifier, *version, *format;
David Kupka8e60a372012-09-04 09:15:20 +0200763 struct nc_session *session = NULL;
Kupka Davidda134a12012-09-06 14:12:16 +0200764 struct session_with_mutex * locked_session;
Kupka David00b9c5c2012-09-05 09:45:50 +0200765 struct nc_cpblts* cpblts = NULL;
David Kupka8e60a372012-09-04 09:15:20 +0200766 NC_DATASTORE ds_type_s, ds_type_t;
Tomas Cejka5064c232013-01-17 09:30:58 +0100767 NC_EDIT_DEFOP_TYPE defop_type = NC_EDIT_DEFOP_NOTSET;
David Kupka8e60a372012-09-04 09:15:20 +0200768 NC_EDIT_ERROPT_TYPE erropt_type = 0;
769
770 apr_pool_t * pool = ((struct pass_to_thread*)arg)->pool;
771 apr_hash_t *netconf_sessions_list = ((struct pass_to_thread*)arg)->netconf_sessions_list;
772 server_rec * server = ((struct pass_to_thread*)arg)->server;
773 int client = ((struct pass_to_thread*)arg)->client;
774
775 char * buffer, chunk_len_str[12], *chunked_msg;
776 char c;
777
778 while (!isterminated) {
779 fds.fd = client;
780 fds.events = POLLIN;
781 fds.revents = 0;
782
783 status = poll(&fds, 1, 1000);
784
785 if (status == 0 || (status == -1 && (errno == EAGAIN || (errno == EINTR && isterminated == 0)))) {
786 /* poll was interrupted - check if the isterminated is set and if not, try poll again */
787 //ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "poll interrupted");
788 continue;
789 } else if (status < 0) {
790 /* 0: poll time outed
791 * close socket and ignore this request from the client, it can try it again
792 * -1: poll failed
793 * something wrong happend, close this socket and wait for another request
794 */
795 //ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "poll failed, status %d(%d: %s)", status, errno, strerror(errno));
796 close(client);
797 break;
798 }
799 /* status > 0 */
800
801 /* check the status of the socket */
802
803 /* if nothing to read and POLLHUP (EOF) or POLLERR set */
804 if ((fds.revents & POLLHUP) || (fds.revents & POLLERR)) {
805 /* close client's socket (it's probably already closed by client */
806 //ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "socket error (%d)", fds.revents);
807 close(client);
808 break;
809 }
810
811 /* read json in chunked framing */
812 buffer_size = 0;
813 buffer_len = 0;
814 buffer = NULL;
815 while (1) {
David Kupka1e3e4c82012-09-04 09:32:15 +0200816 /* read chunk length */
817 if ((ret = recv (client, &c, 1, 0)) != 1 || c != '\n') {
818 free (buffer);
819 buffer = NULL;
David Kupka8e60a372012-09-04 09:15:20 +0200820 break;
821 }
David Kupka1e3e4c82012-09-04 09:32:15 +0200822 if ((ret = recv (client, &c, 1, 0)) != 1 || c != '#') {
823 free (buffer);
824 buffer = NULL;
825 break;
826 }
827 i=0;
828 memset (chunk_len_str, 0, 12);
829 while ((ret = recv (client, &c, 1, 0) == 1 && (isdigit(c) || c == '#'))) {
830 if (i==0 && c == '#') {
831 if (recv (client, &c, 1, 0) != 1 || c != '\n') {
832 /* end but invalid */
833 free (buffer);
834 buffer = NULL;
835 }
836 /* end of message, double-loop break */
837 goto msg_complete;
838 }
839 chunk_len_str[i++] = c;
840 }
841 if (c != '\n') {
842 free (buffer);
843 buffer = NULL;
844 break;
845 }
846 if ((chunk_len = atoi (chunk_len_str)) == 0) {
847 free (buffer);
848 buffer = NULL;
849 break;
850 }
851 buffer_size += chunk_len+1;
852 buffer = realloc (buffer, sizeof(char)*buffer_size);
853 if ((ret = recv (client, buffer+buffer_len, chunk_len, 0)) == -1 || ret != chunk_len) {
854 free (buffer);
855 buffer = NULL;
856 break;
857 }
858 buffer_len += ret;
859 }
860msg_complete:
David Kupka8e60a372012-09-04 09:15:20 +0200861
862 if (buffer != NULL) {
863 request = json_tokener_parse(buffer);
864 operation = json_object_get_int(json_object_object_get(request, "type"));
865
866 session_key = (char*) json_object_get_string(json_object_object_get(request, "session"));
867 /* DO NOT FREE session_key HERE, IT IS PART OF REQUEST */
868 if (operation != MSG_CONNECT && session_key == NULL) {
869 reply = json_object_new_object();
870 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
871 json_object_object_add(reply, "error-message", json_object_new_string("Missing session specification."));
872 msgtext = json_object_to_json_string(reply);
873 send(client, msgtext, strlen(msgtext) + 1, 0);
874 json_object_put(reply);
875 /* there is some stupid client, so close the connection to give a chance to some other client */
876 close(client);
877 break;
878 }
879
880 /* get parameters */
Tomas Cejka5064c232013-01-17 09:30:58 +0100881 /* TODO NC_DATASTORE_URL */
David Kupka8e60a372012-09-04 09:15:20 +0200882 ds_type_t = -1;
883 if ((target = json_object_get_string(json_object_object_get(request, "target"))) != NULL) {
884 if (strcmp(target, "running") == 0) {
885 ds_type_t = NC_DATASTORE_RUNNING;
886 } else if (strcmp(target, "startup") == 0) {
887 ds_type_t = NC_DATASTORE_STARTUP;
888 } else if (strcmp(target, "candidate") == 0) {
889 ds_type_t = NC_DATASTORE_CANDIDATE;
890 }
891 }
892 ds_type_s = -1;
893 if ((source = json_object_get_string(json_object_object_get(request, "source"))) != NULL) {
894 if (strcmp(source, "running") == 0) {
895 ds_type_s = NC_DATASTORE_RUNNING;
896 } else if (strcmp(source, "startup") == 0) {
897 ds_type_s = NC_DATASTORE_STARTUP;
898 } else if (strcmp(source, "candidate") == 0) {
899 ds_type_s = NC_DATASTORE_CANDIDATE;
900 }
901 }
902
903 /* null global JSON error-reply */
904 err_reply = NULL;
905
906 /* prepare reply envelope */
907 reply = json_object_new_object();
908
909 /* process required operation */
910 switch (operation) {
911 case MSG_CONNECT:
912 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: Connect");
913
914 host = json_object_get_string(json_object_object_get(request, "host"));
915 port = json_object_get_string(json_object_object_get(request, "port"));
916 user = json_object_get_string(json_object_object_get(request, "user"));
917 pass = json_object_get_string(json_object_object_get(request, "pass"));
Tomas Cejkaf34f3912012-09-05 18:14:06 +0200918 capabilities = json_object_object_get(request, "capabilities");
919 if ((capabilities != NULL) && ((len = json_object_array_length(capabilities)) > 0)) {
Kupka David00b9c5c2012-09-05 09:45:50 +0200920 cpblts = nc_cpblts_new (NULL);
921 for (i=0; i<len; i++) {
922 nc_cpblts_add (cpblts, json_object_get_string(json_object_array_get_idx(capabilities, i)));
923 }
924 } else {
925 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "no capabilities specified");
926 }
David Kupka8e60a372012-09-04 09:15:20 +0200927 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "host: %s, port: %s, user: %s", host, port, user);
928 if ((host == NULL) || (user == NULL)) {
929 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Cannot connect - insufficient input.");
930 session_key = NULL;
931 } else {
Kupka David00b9c5c2012-09-05 09:45:50 +0200932 session_key = netconf_connect(server, pool, netconf_sessions_list, host, port, user, pass, cpblts);
933 nc_cpblts_free (cpblts);
David Kupka8e60a372012-09-04 09:15:20 +0200934 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "hash: %s", session_key);
935 }
936
937 reply = json_object_new_object();
938 if (session_key == NULL) {
939 /* negative reply */
940 if (err_reply == NULL) {
941 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
942 json_object_object_add(reply, "error-message", json_object_new_string("Connecting NETCONF server failed."));
Tomas Cejka1490ef12012-12-10 00:16:13 +0100943 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Connection failed.");
David Kupka8e60a372012-09-04 09:15:20 +0200944 } else {
945 /* use filled err_reply from libnetconf's callback */
946 json_object_put(reply);
947 reply = err_reply;
Tomas Cejka1490ef12012-12-10 00:16:13 +0100948 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Connect - error from libnetconf's callback.");
David Kupka8e60a372012-09-04 09:15:20 +0200949 }
950 } else {
951 /* positive reply */
952 json_object_object_add(reply, "type", json_object_new_int(REPLY_OK));
953 json_object_object_add(reply, "session", json_object_new_string(session_key));
954
955 free(session_key);
956 }
957
958 break;
959 case MSG_GET:
960 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: get (session %s)", session_key);
961
962 filter = json_object_get_string(json_object_object_get(request, "filter"));
963
964 //ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "get filter: %p", filter);
965
Tomas Cejkacdc274e2012-09-05 18:15:33 +0200966 if ((data = netconf_get(server, netconf_sessions_list, session_key, filter)) == NULL) {
David Kupka8e60a372012-09-04 09:15:20 +0200967 if (err_reply == NULL) {
968 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
969 json_object_object_add(reply, "error-message", json_object_new_string("get failed."));
970 } else {
971 /* use filled err_reply from libnetconf's callback */
972 json_object_put(reply);
973 reply = err_reply;
974 }
975 } else {
976 json_object_object_add(reply, "type", json_object_new_int(REPLY_DATA));
977 json_object_object_add(reply, "data", json_object_new_string(data));
978 }
979 break;
980 case MSG_GETCONFIG:
981 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: get-config (session %s)", session_key);
982
983 filter = json_object_get_string(json_object_object_get(request, "filter"));
984
985 if (ds_type_s == -1) {
986 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
987 json_object_object_add(reply, "error-message", json_object_new_string("Invalid source repository type requested."));
988 break;
989 }
990
991 if ((data = netconf_getconfig(server, netconf_sessions_list, session_key, ds_type_s, filter)) == NULL) {
992 if (err_reply == NULL) {
993 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
994 json_object_object_add(reply, "error-message", json_object_new_string("get-config failed."));
995 } else {
996 /* use filled err_reply from libnetconf's callback */
997 json_object_put(reply);
998 reply = err_reply;
999 }
1000 } else {
1001 json_object_object_add(reply, "type", json_object_new_int(REPLY_DATA));
1002 json_object_object_add(reply, "data", json_object_new_string(data));
1003 }
1004 break;
Tomas Cejka0aeca8b2012-12-22 19:56:03 +01001005 case MSG_GETSCHEMA:
1006 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: get-schema (session %s)", session_key);
1007 identifier = json_object_get_string(json_object_object_get(request, "identifier"));
1008 if (identifier == NULL) {
1009 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1010 json_object_object_add(reply, "error-message", json_object_new_string("No identifier for get-schema supplied."));
1011 break;
1012 }
Tomas Cejka94da2c52013-01-08 18:20:30 +01001013 version = json_object_get_string(json_object_object_get(request, "version"));
1014 format = json_object_get_string(json_object_object_get(request, "format"));
Tomas Cejka0aeca8b2012-12-22 19:56:03 +01001015
Tomas Cejka94da2c52013-01-08 18:20:30 +01001016 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "get-schema(version: %s, format: %s)", version, format);
Tomas Cejkaafe46072013-01-09 16:55:58 +01001017 if ((data = netconf_getschema(server, netconf_sessions_list, session_key, identifier, version, format)) == NULL) {
Tomas Cejka0aeca8b2012-12-22 19:56:03 +01001018 if (err_reply == NULL) {
1019 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1020 json_object_object_add(reply, "error-message", json_object_new_string("get-config failed."));
1021 } else {
1022 /* use filled err_reply from libnetconf's callback */
1023 json_object_put(reply);
1024 reply = err_reply;
1025 }
1026 } else {
1027 json_object_object_add(reply, "type", json_object_new_int(REPLY_DATA));
1028 json_object_object_add(reply, "data", json_object_new_string(data));
1029 }
1030 break;
David Kupka8e60a372012-09-04 09:15:20 +02001031 case MSG_EDITCONFIG:
1032 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: edit-config (session %s)", session_key);
1033
1034 defop = json_object_get_string(json_object_object_get(request, "default-operation"));
1035 if (defop != NULL) {
1036 if (strcmp(defop, "merge") == 0) {
1037 defop_type = NC_EDIT_DEFOP_MERGE;
1038 } else if (strcmp(defop, "replace") == 0) {
1039 defop_type = NC_EDIT_DEFOP_REPLACE;
1040 } else if (strcmp(defop, "none") == 0) {
1041 defop_type = NC_EDIT_DEFOP_NONE;
1042 } else {
1043 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1044 json_object_object_add(reply, "error-message", json_object_new_string("Invalid default-operation parameter."));
1045 break;
1046 }
1047 } else {
Tomas Cejka5064c232013-01-17 09:30:58 +01001048 defop_type = NC_EDIT_DEFOP_NOTSET;
David Kupka8e60a372012-09-04 09:15:20 +02001049 }
1050
1051 erropt = json_object_get_string(json_object_object_get(request, "error-option"));
1052 if (erropt != NULL) {
1053 if (strcmp(erropt, "continue-on-error") == 0) {
1054 erropt_type = NC_EDIT_ERROPT_CONT;
1055 } else if (strcmp(erropt, "stop-on-error") == 0) {
1056 erropt_type = NC_EDIT_ERROPT_STOP;
1057 } else if (strcmp(erropt, "rollback-on-error") == 0) {
1058 erropt_type = NC_EDIT_ERROPT_ROLLBACK;
1059 } else {
1060 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1061 json_object_object_add(reply, "error-message", json_object_new_string("Invalid error-option parameter."));
1062 break;
1063 }
1064 } else {
1065 erropt_type = 0;
1066 }
1067
1068 if (ds_type_t == -1) {
1069 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1070 json_object_object_add(reply, "error-message", json_object_new_string("Invalid target repository type requested."));
1071 break;
1072 }
1073
1074 config = json_object_get_string(json_object_object_get(request, "config"));
1075 if (config == NULL) {
1076 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1077 json_object_object_add(reply, "error-message", json_object_new_string("Invalid config data parameter."));
1078 break;
1079 }
1080
Tomas Cejka5064c232013-01-17 09:30:58 +01001081 /* TODO url capability see netconf_editconfig */
1082 /* TODO TESTSET - :validate:1.1 capability? http://tools.ietf.org/html/rfc6241#section-7.2 */
1083 if (netconf_editconfig(server, netconf_sessions_list, session_key, ds_type_t, defop_type, erropt_type, NC_EDIT_TESTOPT_NOTSET, config) != EXIT_SUCCESS) {
David Kupka8e60a372012-09-04 09:15:20 +02001084 if (err_reply == NULL) {
1085 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1086 json_object_object_add(reply, "error-message", json_object_new_string("edit-config failed."));
1087 } else {
1088 /* use filled err_reply from libnetconf's callback */
1089 json_object_put(reply);
1090 reply = err_reply;
1091 }
1092 } else {
1093 json_object_object_add(reply, "type", json_object_new_int(REPLY_OK));
1094 }
1095 break;
1096 case MSG_COPYCONFIG:
1097 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: copy-config (session %s)", session_key);
1098 config = NULL;
1099
1100 if (source == NULL) {
1101 /* no explicit source specified -> use config data */
Tomas Cejka027f3bc2012-11-10 20:28:36 +01001102 ds_type_s = NC_DATASTORE_CONFIG;
David Kupka8e60a372012-09-04 09:15:20 +02001103 config = json_object_get_string(json_object_object_get(request, "config"));
1104 } else if (ds_type_s == -1) {
1105 /* source datastore specified, but it is invalid */
1106 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1107 json_object_object_add(reply, "error-message", json_object_new_string("Invalid source repository type requested."));
1108 break;
1109 }
1110
1111 if (ds_type_t == -1) {
1112 /* invalid target datastore specified */
1113 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1114 json_object_object_add(reply, "error-message", json_object_new_string("Invalid target repository type requested."));
1115 break;
1116 }
1117
1118 if (source == NULL && config == NULL) {
1119 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1120 json_object_object_add(reply, "error-message", json_object_new_string("invalid input parameters - one of source and config is required."));
1121 } else {
1122 if (netconf_copyconfig(server, netconf_sessions_list, session_key, ds_type_s, ds_type_t, config) != EXIT_SUCCESS) {
1123 if (err_reply == NULL) {
1124 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1125 json_object_object_add(reply, "error-message", json_object_new_string("copy-config failed."));
1126 } else {
1127 /* use filled err_reply from libnetconf's callback */
1128 json_object_put(reply);
1129 reply = err_reply;
1130 }
1131 } else {
1132 json_object_object_add(reply, "type", json_object_new_int(REPLY_OK));
1133 }
1134 }
1135 break;
1136 case MSG_DELETECONFIG:
1137 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: delete-config (session %s)", session_key);
1138 /* no break - unifying code */
1139 case MSG_LOCK:
1140 if (operation == MSG_LOCK) {
1141 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: lock (session %s)", session_key);
1142 }
1143 /* no break - unifying code */
1144 case MSG_UNLOCK:
1145 if (operation == MSG_UNLOCK) {
1146 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: unlock (session %s)", session_key);
1147 }
1148
1149 if (ds_type_t == -1) {
1150 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1151 json_object_object_add(reply, "error-message", json_object_new_string("Invalid target repository type requested."));
1152 break;
1153 }
1154
1155 switch(operation) {
1156 case MSG_DELETECONFIG:
1157 status = netconf_deleteconfig(server, netconf_sessions_list, session_key, ds_type_t);
1158 break;
1159 case MSG_LOCK:
1160 status = netconf_lock(server, netconf_sessions_list, session_key, ds_type_t);
1161 break;
1162 case MSG_UNLOCK:
1163 status = netconf_unlock(server, netconf_sessions_list, session_key, ds_type_t);
1164 break;
1165 default:
1166 status = -1;
1167 break;
1168 }
1169
1170 if (status != EXIT_SUCCESS) {
1171 if (err_reply == NULL) {
1172 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1173 json_object_object_add(reply, "error-message", json_object_new_string("operation failed."));
1174 } else {
1175 /* use filled err_reply from libnetconf's callback */
1176 json_object_put(reply);
1177 reply = err_reply;
1178 }
1179 } else {
1180 json_object_object_add(reply, "type", json_object_new_int(REPLY_OK));
1181 }
1182 break;
1183 case MSG_KILL:
1184 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: kill-session, session %s", session_key);
1185
1186 sid = json_object_get_string(json_object_object_get(request, "session-id"));
1187
1188 if (sid == NULL) {
1189 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1190 json_object_object_add(reply, "error-message", json_object_new_string("Missing session-id parameter."));
1191 break;
1192 }
1193
1194 if (netconf_killsession(server, netconf_sessions_list, session_key, sid) != EXIT_SUCCESS) {
1195 if (err_reply == NULL) {
1196 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1197 json_object_object_add(reply, "error-message", json_object_new_string("kill-session failed."));
1198 } else {
1199 /* use filled err_reply from libnetconf's callback */
1200 json_object_put(reply);
1201 reply = err_reply;
1202 }
1203 } else {
1204 json_object_object_add(reply, "type", json_object_new_int(REPLY_OK));
1205 }
1206 break;
1207 case MSG_DISCONNECT:
1208 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: Disconnect session %s", session_key);
1209
1210 if (netconf_close(server, netconf_sessions_list, session_key) != EXIT_SUCCESS) {
1211 if (err_reply == NULL) {
1212 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1213 json_object_object_add(reply, "error-message", json_object_new_string("Invalid session identifier."));
1214 } else {
1215 /* use filled err_reply from libnetconf's callback */
1216 json_object_put(reply);
1217 reply = err_reply;
1218 }
1219 } else {
1220 json_object_object_add(reply, "type", json_object_new_int(REPLY_OK));
1221 }
1222 break;
1223 case MSG_INFO:
1224 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: get info about session %s", session_key);
1225
Kupka Davidda134a12012-09-06 14:12:16 +02001226 locked_session = (struct session_with_mutex *)apr_hash_get(netconf_sessions_list, session_key, APR_HASH_KEY_STRING);
1227 if (locked_session != NULL) {
1228 session = locked_session->session;
1229 } else {
1230 session = NULL;
1231 }
David Kupka8e60a372012-09-04 09:15:20 +02001232 if (session != NULL) {
1233 json_object_object_add(reply, "sid", json_object_new_string(nc_session_get_id(session)));
1234 json_object_object_add(reply, "version", json_object_new_string((nc_session_get_version(session) == 0)?"1.0":"1.1"));
1235 json_object_object_add(reply, "host", json_object_new_string(nc_session_get_host(session)));
1236 json_object_object_add(reply, "port", json_object_new_string(nc_session_get_port(session)));
1237 json_object_object_add(reply, "user", json_object_new_string(nc_session_get_user(session)));
1238 cpblts = nc_session_get_cpblts (session);
1239 if (cpblts != NULL) {
1240 json_obj = json_object_new_array();
1241 nc_cpblts_iter_start (cpblts);
1242 while ((cpbltstr = nc_cpblts_iter_next (cpblts)) != NULL) {
1243 json_object_array_add(json_obj, json_object_new_string(cpbltstr));
1244 }
1245 json_object_object_add(reply, "capabilities", json_obj);
1246 }
1247 } else {
1248 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1249 json_object_object_add(reply, "error-message", json_object_new_string("Invalid session identifier."));
1250 }
1251
1252 break;
1253 case MSG_GENERIC:
1254 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: generic request for session %s", session_key);
1255
1256 config = json_object_get_string(json_object_object_get(request, "content"));
1257
1258 if (config == NULL) {
1259 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1260 json_object_object_add(reply, "error-message", json_object_new_string("Missing content parameter."));
1261 break;
1262 }
1263
1264 if (netconf_generic(server, netconf_sessions_list, session_key, config, &data) != EXIT_SUCCESS) {
1265 if (err_reply == NULL) {
1266 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1267 json_object_object_add(reply, "error-message", json_object_new_string("kill-session failed."));
1268 } else {
1269 /* use filled err_reply from libnetconf's callback */
1270 json_object_put(reply);
1271 reply = err_reply;
1272 }
1273 } else {
1274 if (data == NULL) {
1275 json_object_object_add(reply, "type", json_object_new_int(REPLY_OK));
1276 } else {
1277 json_object_object_add(reply, "type", json_object_new_int(REPLY_DATA));
1278 json_object_object_add(reply, "data", json_object_new_string(data));
1279 }
1280 }
1281 break;
1282 default:
1283 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Unknown mod_netconf operation requested (%d)", operation);
1284 reply = json_object_new_object();
1285 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1286 json_object_object_add(reply, "error-message", json_object_new_string("Operation not supported."));
1287 break;
1288 }
1289 json_object_put(request);
1290
David Kupka1e3e4c82012-09-04 09:32:15 +02001291 /* send reply to caller */
1292 if (reply != NULL) {
1293 msgtext = json_object_to_json_string(reply);
1294 if (asprintf (&chunked_msg, "\n#%d\n%s\n##\n", (int)strlen(msgtext), msgtext) == -1) {
1295 free (buffer);
David Kupka8e60a372012-09-04 09:15:20 +02001296 break;
1297 }
David Kupka1e3e4c82012-09-04 09:32:15 +02001298 send(client, chunked_msg, strlen(chunked_msg) + 1, 0);
1299 json_object_put(reply);
1300 free (chunked_msg);
1301 free (buffer);
1302 } else {
1303 break;
David Kupka8e60a372012-09-04 09:15:20 +02001304 }
1305 }
1306 }
1307
1308 free (arg);
1309
1310 return retval;
1311}
1312
Radek Krejcif23850c2012-07-23 16:14:17 +02001313/*
1314 * This is actually implementation of NETCONF client
1315 * - requests are received from UNIX socket in the predefined format
1316 * - results are replied through the same way
1317 * - the daemon run as a separate process, but it is started and stopped
1318 * automatically by Apache.
1319 *
1320 */
Radek Krejci469aab82012-07-22 18:42:20 +02001321static void forked_proc(apr_pool_t * pool, server_rec * server)
1322{
1323 struct sockaddr_un local, remote;
David Kupka8e60a372012-09-04 09:15:20 +02001324 int lsock, client, ret, i, pthread_count = 0;
1325 socklen_t len;
Radek Krejciae021c12012-07-25 18:03:52 +02001326 mod_netconf_cfg *cfg;
Radek Krejci469aab82012-07-22 18:42:20 +02001327 apr_hash_t *netconf_sessions_list;
David Kupka8e60a372012-09-04 09:15:20 +02001328 struct pass_to_thread * arg;
1329 pthread_t * ptids = calloc (1,sizeof(pthread_t));
1330 struct timespec maxtime;
1331 pthread_rwlockattr_t lock_attrs;
1332
1333 /* wait at most 5 secons for every thread to terminate */
1334 maxtime.tv_sec = 5;
1335 maxtime.tv_nsec = 0;
Radek Krejci469aab82012-07-22 18:42:20 +02001336
Radek Krejcif23850c2012-07-23 16:14:17 +02001337 /* change uid and gid of process for security reasons */
Radek Krejci469aab82012-07-22 18:42:20 +02001338 unixd_setup_child();
1339
Radek Krejciae021c12012-07-25 18:03:52 +02001340 cfg = ap_get_module_config(server->module_config, &netconf_module);
1341 if (cfg == NULL) {
Radek Krejci8fd1f5e2012-07-24 17:33:36 +02001342 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Getting mod_netconf configuration failed");
1343 return;
1344 }
Radek Krejci469aab82012-07-22 18:42:20 +02001345
Radek Krejci8fd1f5e2012-07-24 17:33:36 +02001346 /* create listening UNIX socket to accept incoming connections */
Radek Krejci469aab82012-07-22 18:42:20 +02001347 if ((lsock = socket(PF_UNIX, SOCK_STREAM, 0)) == -1) {
1348 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Creating socket failed (%s)", strerror(errno));
1349 return;
1350 }
1351
1352 local.sun_family = AF_UNIX;
Radek Krejciae021c12012-07-25 18:03:52 +02001353 strncpy(local.sun_path, cfg->sockname, sizeof(local.sun_path));
Radek Krejci469aab82012-07-22 18:42:20 +02001354 unlink(local.sun_path);
1355 len = offsetof(struct sockaddr_un, sun_path) + strlen(local.sun_path);
1356
1357 if (bind(lsock, (struct sockaddr *) &local, len) == -1) {
1358 if (errno == EADDRINUSE) {
1359 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "mod_netconf socket address already in use");
1360 close(lsock);
1361 exit(0);
1362 }
1363 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Binding socket failed (%s)", strerror(errno));
1364 close(lsock);
1365 return;
1366 }
1367
1368 if (listen(lsock, MAX_SOCKET_CL) == -1) {
1369 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Setting up listen socket failed (%s)", strerror(errno));
1370 close(lsock);
1371 return;
1372 }
1373
1374 /* prepare internal lists */
1375 netconf_sessions_list = apr_hash_make(pool);
1376
1377 /* setup libnetconf's callbacks */
1378 nc_verbosity(NC_VERB_DEBUG);
1379 clb_print_server = server;
1380 nc_callback_print(clb_print);
1381 nc_callback_ssh_host_authenticity_check(netconf_callback_ssh_hostkey_check);
1382 nc_callback_sshauth_interactive(netconf_callback_sshauth_interactive);
1383 nc_callback_sshauth_password(netconf_callback_sshauth_password);
Radek Krejcic11fd862012-07-26 12:41:21 +02001384 nc_callback_error_reply(netconf_callback_error_process);
Radek Krejci469aab82012-07-22 18:42:20 +02001385
1386 /* disable publickey authentication */
1387 nc_ssh_pref(NC_SSH_AUTH_PUBLIC_KEYS, -1);
1388
David Kupka8e60a372012-09-04 09:15:20 +02001389 /* create mutex protecting session list */
1390 pthread_rwlockattr_init(&lock_attrs);
1391 /* rwlock is shared only with threads in this process */
1392 pthread_rwlockattr_setpshared(&lock_attrs, PTHREAD_PROCESS_PRIVATE);
1393 /* create rw lock */
1394 if (pthread_rwlock_init(&session_lock, &lock_attrs) != 0) {
1395 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Initialization of mutex failed: %d (%s)", errno, strerror(errno));
1396 close (lsock);
1397 return;
1398 }
1399
Radek Krejci469aab82012-07-22 18:42:20 +02001400 while (isterminated == 0) {
1401 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "waiting for another client's request");
1402
1403 /* open incoming connection if any */
David Kupka8e60a372012-09-04 09:15:20 +02001404 len = sizeof(remote);
1405 client = accept(lsock, (struct sockaddr *) &remote, &len);
Radek Krejci469aab82012-07-22 18:42:20 +02001406 if (client == -1 && (errno == EAGAIN || errno == EWOULDBLOCK)) {
1407 apr_sleep(SLEEP_TIME);
1408 continue;
1409 } else if (client == -1 && (errno == EINTR)) {
1410 continue;
1411 } else if (client == -1) {
1412 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Accepting mod_netconf client connection failed (%s)", strerror(errno));
1413 continue;
1414 }
Radek Krejci469aab82012-07-22 18:42:20 +02001415
1416 /* set client's socket as non-blocking */
Radek Krejcif23850c2012-07-23 16:14:17 +02001417 //fcntl(client, F_SETFL, fcntl(client, F_GETFL, 0) | O_NONBLOCK);
Radek Krejci469aab82012-07-22 18:42:20 +02001418
David Kupka8e60a372012-09-04 09:15:20 +02001419 arg = malloc (sizeof(struct pass_to_thread));
1420 arg->client = client;
1421 arg->pool = pool;
1422 arg->server = server;
1423 arg->netconf_sessions_list = netconf_sessions_list;
Radek Krejci469aab82012-07-22 18:42:20 +02001424
David Kupka8e60a372012-09-04 09:15:20 +02001425 /* start new thread. It will serve this particular request and then terminate */
1426 if ((ret = pthread_create (&ptids[pthread_count], NULL, thread_routine, (void*)arg)) != 0) {
1427 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Creating POSIX thread failed: %d\n", ret);
1428 } else {
1429 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Thread %lu created", ptids[pthread_count]);
1430 pthread_count++;
1431 ptids = realloc (ptids, sizeof(pthread_t)*(pthread_count+1));
1432 ptids[pthread_count] = 0;
1433 }
Radek Krejci469aab82012-07-22 18:42:20 +02001434
David Kupka8e60a372012-09-04 09:15:20 +02001435 /* check if some thread already terminated, free some resources by joining it */
1436 for (i=0; i<pthread_count; i++) {
1437 if (pthread_tryjoin_np (ptids[i], (void**)&arg) == 0) {
1438 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Thread %lu joined with retval %p", ptids[i], arg);
1439 pthread_count--;
1440 if (pthread_count > 0) {
1441 /* place last Thread ID on the place of joined one */
1442 ptids[i] = ptids[pthread_count];
Radek Krejci8fd1f5e2012-07-24 17:33:36 +02001443 }
Radek Krejci469aab82012-07-22 18:42:20 +02001444 }
1445 }
David Kupka8e60a372012-09-04 09:15:20 +02001446 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Running %d threads", pthread_count);
Radek Krejci469aab82012-07-22 18:42:20 +02001447 }
1448
David Kupka8e60a372012-09-04 09:15:20 +02001449 /* join all threads */
1450 for (i=0; i<pthread_count; i++) {
1451 pthread_timedjoin_np (ptids[i], (void**)&arg, &maxtime);
1452 }
1453 free (ptids);
1454
Radek Krejci469aab82012-07-22 18:42:20 +02001455 close(lsock);
1456
David Kupka8e60a372012-09-04 09:15:20 +02001457 /* destroy rwlock */
1458 pthread_rwlock_destroy(&session_lock);
1459 pthread_rwlockattr_destroy(&lock_attrs);
1460
Radek Krejci469aab82012-07-22 18:42:20 +02001461 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Exiting from the mod_netconf daemon");
1462
1463 exit(APR_SUCCESS);
1464}
1465
Radek Krejcif23850c2012-07-23 16:14:17 +02001466static void *mod_netconf_create_conf(apr_pool_t * pool, server_rec * s)
Radek Krejci469aab82012-07-22 18:42:20 +02001467{
Radek Krejcif23850c2012-07-23 16:14:17 +02001468 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, "Init netconf module config");
1469
1470 mod_netconf_cfg *config = apr_pcalloc(pool, sizeof(mod_netconf_cfg));
1471 apr_pool_create(&config->pool, pool);
1472 config->forkproc = NULL;
Radek Krejci8fd1f5e2012-07-24 17:33:36 +02001473 config->sockname = SOCKET_FILENAME;
Radek Krejcif23850c2012-07-23 16:14:17 +02001474
1475 return (void *)config;
Radek Krejci469aab82012-07-22 18:42:20 +02001476}
1477
1478static int mod_netconf_master_init(apr_pool_t * pconf, apr_pool_t * ptemp,
1479 apr_pool_t * plog, server_rec * s)
1480{
Radek Krejcif23850c2012-07-23 16:14:17 +02001481 mod_netconf_cfg *config;
1482 apr_status_t res;
1483
Radek Krejci469aab82012-07-22 18:42:20 +02001484 /* These two help ensure that we only init once. */
Radek Krejcia332b692012-11-12 16:15:54 +01001485 void *data = NULL;
Radek Krejcif23850c2012-07-23 16:14:17 +02001486 const char *userdata_key = "netconf_ipc_init";
Radek Krejci469aab82012-07-22 18:42:20 +02001487
1488 /*
1489 * The following checks if this routine has been called before.
1490 * This is necessary because the parent process gets initialized
1491 * a couple of times as the server starts up.
1492 */
1493 apr_pool_userdata_get(&data, userdata_key, s->process->pool);
1494 if (!data) {
1495 apr_pool_userdata_set((const void *)1, userdata_key, apr_pool_cleanup_null, s->process->pool);
1496 return (OK);
1497 }
1498
Radek Krejcif23850c2012-07-23 16:14:17 +02001499 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, "creating mod_netconf daemon");
1500 config = ap_get_module_config(s->module_config, &netconf_module);
Radek Krejcidfaa6ea2012-07-23 09:04:43 +02001501
Radek Krejcif23850c2012-07-23 16:14:17 +02001502 if (config && config->forkproc == NULL) {
1503 config->forkproc = apr_pcalloc(config->pool, sizeof(apr_proc_t));
1504 res = apr_proc_fork(config->forkproc, config->pool);
Radek Krejci469aab82012-07-22 18:42:20 +02001505 switch (res) {
1506 case APR_INCHILD:
1507 /* set signal handler */
Radek Krejcif23850c2012-07-23 16:14:17 +02001508 apr_signal_init(config->pool);
Radek Krejci469aab82012-07-22 18:42:20 +02001509 apr_signal(SIGTERM, signal_handler);
1510
1511 /* log start of the separated NETCONF communication process */
Radek Krejcif23850c2012-07-23 16:14:17 +02001512 ap_log_error(APLOG_MARK, APLOG_NOTICE, 0, s, "mod_netconf daemon started (PID %d)", getpid());
Radek Krejci469aab82012-07-22 18:42:20 +02001513
1514 /* start main loop providing NETCONF communication */
Radek Krejcif23850c2012-07-23 16:14:17 +02001515 forked_proc(config->pool, s);
Radek Krejci469aab82012-07-22 18:42:20 +02001516
Radek Krejcif23850c2012-07-23 16:14:17 +02001517 /* I never should be here, wtf?!? */
1518 ap_log_error(APLOG_MARK, APLOG_ERR, 0, s, "mod_netconf daemon unexpectedly stopped");
Radek Krejci469aab82012-07-22 18:42:20 +02001519 exit(APR_EGENERAL);
1520 break;
1521 case APR_INPARENT:
1522 /* register child to be killed (SIGTERM) when the module config's pool dies */
Radek Krejcif23850c2012-07-23 16:14:17 +02001523 apr_pool_note_subprocess(config->pool, config->forkproc, APR_KILL_AFTER_TIMEOUT);
Radek Krejci469aab82012-07-22 18:42:20 +02001524 break;
1525 default:
1526 ap_log_error(APLOG_MARK, APLOG_ERR, 0, s, "apr_proc_fork() failed");
1527 break;
1528 }
Radek Krejcif23850c2012-07-23 16:14:17 +02001529 } else {
1530 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, "mod_netconf misses configuration structure");
Radek Krejci469aab82012-07-22 18:42:20 +02001531 }
1532
1533 return OK;
1534}
1535
Radek Krejci469aab82012-07-22 18:42:20 +02001536/**
1537 * Register module hooks
1538 */
1539static void mod_netconf_register_hooks(apr_pool_t * p)
1540{
Radek Krejcif23850c2012-07-23 16:14:17 +02001541 ap_hook_post_config(mod_netconf_master_init, NULL, NULL, APR_HOOK_LAST);
Radek Krejci469aab82012-07-22 18:42:20 +02001542}
1543
Radek Krejci8fd1f5e2012-07-24 17:33:36 +02001544static const char* cfg_set_socket_path(cmd_parms* cmd, void* cfg, const char* arg)
1545{
1546 ((mod_netconf_cfg*)cfg)->sockname = apr_pstrdup(cmd->pool, arg);
1547 return NULL;
1548}
1549
1550static const command_rec netconf_cmds[] = {
1551 AP_INIT_TAKE1("NetconfSocket", cfg_set_socket_path, NULL, OR_ALL, "UNIX socket path for mod_netconf communication."),
1552 {NULL}
1553};
1554
Radek Krejci469aab82012-07-22 18:42:20 +02001555/* Dispatch list for API hooks */
1556module AP_MODULE_DECLARE_DATA netconf_module = {
1557 STANDARD20_MODULE_STUFF,
1558 NULL, /* create per-dir config structures */
1559 NULL, /* merge per-dir config structures */
Radek Krejcif23850c2012-07-23 16:14:17 +02001560 mod_netconf_create_conf, /* create per-server config structures */
Radek Krejci469aab82012-07-22 18:42:20 +02001561 NULL, /* merge per-server config structures */
Radek Krejci8fd1f5e2012-07-24 17:33:36 +02001562 netconf_cmds, /* table of config file commands */
Radek Krejci469aab82012-07-22 18:42:20 +02001563 mod_netconf_register_hooks /* register hooks */
1564};
Radek Krejcia332b692012-11-12 16:15:54 +01001565