blob: 66afd2f36bbdd8b598e553ab0288c3c212cfc2ac [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
8 */
9/*
10 * Copyright (C) 2011-2012 CESNET
11 *
12 * LICENSE TERMS
13 *
14 * Redistribution and use in source and binary forms, with or without
15 * modification, are permitted provided that the following conditions
16 * are met:
17 * 1. Redistributions of source code must retain the above copyright
18 * notice, this list of conditions and the following disclaimer.
19 * 2. Redistributions in binary form must reproduce the above copyright
20 * notice, this list of conditions and the following disclaimer in
21 * the documentation and/or other materials provided with the
22 * distribution.
23 * 3. Neither the name of the Company nor the names of its contributors
24 * may be used to endorse or promote products derived from this
25 * software without specific prior written permission.
26 *
27 * ALTERNATIVELY, provided that this notice is retained in full, this
28 * product may be distributed under the terms of the GNU General Public
29 * License (GPL) version 2 or later, in which case the provisions
30 * of the GPL apply INSTEAD OF those given above.
31 *
32 * This software is provided ``as is'', and any express or implied
33 * warranties, including, but not limited to, the implied warranties of
34 * merchantability and fitness for a particular purpose are disclaimed.
35 * In no event shall the company or contributors be liable for any
36 * direct, indirect, incidental, special, exemplary, or consequential
37 * damages (including, but not limited to, procurement of substitute
38 * goods or services; loss of use, data, or profits; or business
39 * interruption) however caused and on any theory of liability, whether
40 * in contract, strict liability, or tort (including negligence or
41 * otherwise) arising in any way out of the use of this software, even
42 * if advised of the possibility of such damage.
43 *
44 */
45
Radek Krejci7b4ddd02012-07-30 08:09:58 +020046#include <unistd.h>
47#include <poll.h>
Radek Krejci469aab82012-07-22 18:42:20 +020048#include <sys/types.h>
49#include <sys/socket.h>
50#include <sys/un.h>
David Kupka8e60a372012-09-04 09:15:20 +020051#include <pthread.h>
52#include <ctype.h>
Radek Krejci7b4ddd02012-07-30 08:09:58 +020053
54#include <unixd.h>
55#include <httpd.h>
56#include <http_log.h>
57#include <http_config.h>
58
59#include <apr_sha1.h>
60#include <apr_hash.h>
61#include <apr_signal.h>
62#include <apr_strings.h>
Radek Krejci469aab82012-07-22 18:42:20 +020063
Radek Krejci8fd1f5e2012-07-24 17:33:36 +020064#include <json/json.h>
65
Radek Krejci469aab82012-07-22 18:42:20 +020066#include <libnetconf.h>
Radek Krejci7b4ddd02012-07-30 08:09:58 +020067
Radek Krejci469aab82012-07-22 18:42:20 +020068
69#define MAX_PROCS 5
Radek Krejci6cb08982012-07-25 18:01:06 +020070#define SOCKET_FILENAME "/tmp/mod_netconf.sock"
Radek Krejci469aab82012-07-22 18:42:20 +020071#define MAX_SOCKET_CL 10
72#define BUFFER_SIZE 4096
73
74/* sleep in master process for non-blocking socket reading */
75#define SLEEP_TIME 200
76
77#ifndef offsetof
78#define offsetof(type, member) ((size_t) ((type *) 0)->member)
79#endif
80
81struct timeval timeout = { 1, 0 };
82
Radek Krejci8fd1f5e2012-07-24 17:33:36 +020083typedef enum MSG_TYPE {
84 REPLY_OK,
85 REPLY_DATA,
86 REPLY_ERROR,
Radek Krejci9e04c7b2012-07-26 15:54:25 +020087 REPLY_INFO,
Radek Krejci8fd1f5e2012-07-24 17:33:36 +020088 MSG_CONNECT,
89 MSG_DISCONNECT,
90 MSG_GET,
91 MSG_GETCONFIG,
92 MSG_EDITCONFIG,
93 MSG_COPYCONFIG,
94 MSG_DELETECONFIG,
95 MSG_LOCK,
96 MSG_UNLOCK,
Radek Krejci9e04c7b2012-07-26 15:54:25 +020097 MSG_KILL,
Radek Krejci80c10d92012-07-30 08:38:50 +020098 MSG_INFO,
99 MSG_GENERIC
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200100} MSG_TYPE;
101
Radek Krejci469aab82012-07-22 18:42:20 +0200102#define MSG_OK 0
103#define MSG_OPEN 1
104#define MSG_DATA 2
105#define MSG_CLOSE 3
106#define MSG_ERROR 4
107#define MSG_UNKNOWN 5
108
Radek Krejci469aab82012-07-22 18:42:20 +0200109module AP_MODULE_DECLARE_DATA netconf_module;
110
111typedef struct {
Radek Krejci469aab82012-07-22 18:42:20 +0200112 apr_pool_t *pool;
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200113 apr_proc_t *forkproc;
114 char* sockname;
Radek Krejcif23850c2012-07-23 16:14:17 +0200115} mod_netconf_cfg;
Radek Krejci469aab82012-07-22 18:42:20 +0200116
David Kupka8e60a372012-09-04 09:15:20 +0200117struct pass_to_thread {
118 int client; /**< opened socket */
119 apr_pool_t * pool; /**< ?? */
120 server_rec * server; /**< ?? */
121 apr_hash_t * netconf_sessions_list; /**< ?? */
122};
123
124struct session_with_mutex {
125 struct nc_session * session; /**< netconf session */
126 pthread_mutex_t lock; /**< mutex protecting the session from multiple access */
127};
128
129pthread_rwlock_t session_lock; /**< mutex protecting netconf_session_list from multiple access errors */
130
Radek Krejci469aab82012-07-22 18:42:20 +0200131volatile int isterminated = 0;
132
133static char* password;
134
135
136static void signal_handler(int sign)
137{
138 switch (sign) {
139 case SIGTERM:
140 isterminated = 1;
Radek Krejci469aab82012-07-22 18:42:20 +0200141 break;
142 }
143}
144
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200145static char* gen_ncsession_hash( const char* hostname, const char* port, const char* sid)
Radek Krejci469aab82012-07-22 18:42:20 +0200146{
Radek Krejcif23850c2012-07-23 16:14:17 +0200147 unsigned char hash_raw[APR_SHA1_DIGESTSIZE];
148 int i;
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200149 char* hash;
Radek Krejcif23850c2012-07-23 16:14:17 +0200150
Radek Krejci469aab82012-07-22 18:42:20 +0200151 apr_sha1_ctx_t sha1_ctx;
152 apr_sha1_init(&sha1_ctx);
153 apr_sha1_update(&sha1_ctx, hostname, strlen(hostname));
154 apr_sha1_update(&sha1_ctx, port, strlen(port));
155 apr_sha1_update(&sha1_ctx, sid, strlen(sid));
Radek Krejcif23850c2012-07-23 16:14:17 +0200156 apr_sha1_final(hash_raw, &sha1_ctx);
Radek Krejci469aab82012-07-22 18:42:20 +0200157
Radek Krejcif23850c2012-07-23 16:14:17 +0200158 /* convert binary hash into hex string, which is printable */
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200159 hash = malloc(sizeof(char) * ((2*APR_SHA1_DIGESTSIZE)+1));
Radek Krejcif23850c2012-07-23 16:14:17 +0200160 for (i = 0; i < APR_SHA1_DIGESTSIZE; i++) {
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200161 snprintf(hash + (2*i), 3, "%02x", hash_raw[i]);
Radek Krejcif23850c2012-07-23 16:14:17 +0200162 }
163 //hash[2*APR_SHA1_DIGESTSIZE] = 0;
Radek Krejci469aab82012-07-22 18:42:20 +0200164
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200165 return (hash);
Radek Krejci469aab82012-07-22 18:42:20 +0200166}
167
168int netconf_callback_ssh_hostkey_check (const char* hostname, int keytype, const char* fingerprint)
169{
170 /* always approve */
171 return (EXIT_SUCCESS);
172}
173
174char* netconf_callback_sshauth_password (const char* username, const char* hostname)
175{
176 char* buf;
177
178 buf = malloc ((strlen(password) + 1) * sizeof(char));
179 apr_cpystrn(buf, password, strlen(password) + 1);
180
181 return (buf);
182}
183
184void netconf_callback_sshauth_interactive (const char* name,
185 int name_len,
186 const char* instruction,
187 int instruction_len,
188 int num_prompts,
189 const LIBSSH2_USERAUTH_KBDINT_PROMPT* prompts,
190 LIBSSH2_USERAUTH_KBDINT_RESPONSE* responses,
191 void** abstract)
192{
193 int i;
194
195 for (i=0; i<num_prompts; i++) {
196 responses[i].text = malloc ((strlen(password) + 1) * sizeof(char));
197 apr_cpystrn(responses[i].text, password, strlen(password) + 1);
198 responses[i].length = strlen(responses[i].text) + 1;
199 }
200
201 return;
202}
203
Radek Krejcic11fd862012-07-26 12:41:21 +0200204static json_object *err_reply = NULL;
205void netconf_callback_error_process(const char* tag,
206 const char* type,
207 const char* severity,
208 const char* apptag,
209 const char* path,
210 const char* message,
211 const char* attribute,
212 const char* element,
213 const char* ns,
214 const char* sid)
215{
216 err_reply = json_object_new_object();
217 json_object_object_add(err_reply, "type", json_object_new_int(REPLY_ERROR));
218 if (tag) json_object_object_add(err_reply, "error-tag", json_object_new_string(tag));
219 if (type) json_object_object_add(err_reply, "error-type", json_object_new_string(type));
220 if (severity) json_object_object_add(err_reply, "error-severity", json_object_new_string(severity));
221 if (apptag) json_object_object_add(err_reply, "error-app-tag", json_object_new_string(apptag));
222 if (path) json_object_object_add(err_reply, "error-path", json_object_new_string(path));
223 if (message) json_object_object_add(err_reply, "error-message", json_object_new_string(message));
224 if (attribute) json_object_object_add(err_reply, "bad-attribute", json_object_new_string(attribute));
225 if (element) json_object_object_add(err_reply, "bad-element", json_object_new_string(element));
226 if (ns) json_object_object_add(err_reply, "bad-namespace", json_object_new_string(ns));
227 if (sid) json_object_object_add(err_reply, "session-id", json_object_new_string(sid));
228}
229
Kupka David00b9c5c2012-09-05 09:45:50 +0200230static 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 +0200231{
Radek Krejci469aab82012-07-22 18:42:20 +0200232 struct nc_session* session;
David Kupka8e60a372012-09-04 09:15:20 +0200233 struct session_with_mutex * locked_session;
Radek Krejcif23850c2012-07-23 16:14:17 +0200234 char *session_key;
Radek Krejci469aab82012-07-22 18:42:20 +0200235
236 /* connect to the requested NETCONF server */
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200237 password = (char*)pass;
David Kupka8e60a372012-09-04 09:15:20 +0200238 session = nc_session_connect(host, (unsigned short) atoi (port), user, cpblts);
239
Radek Krejci469aab82012-07-22 18:42:20 +0200240 /* if connected successful, add session to the list */
241 if (session != NULL) {
242 /* generate hash for the session */
Radek Krejcic11fd862012-07-26 12:41:21 +0200243 session_key = gen_ncsession_hash(
244 (host==NULL) ? "localhost" : host,
245 (port==NULL) ? "830" : port,
Radek Krejcia282bed2012-07-27 14:43:45 +0200246 nc_session_get_id(session));
David Kupka8e60a372012-09-04 09:15:20 +0200247
248 if ((locked_session = malloc (sizeof (struct session_with_mutex))) == NULL || pthread_mutex_init (&locked_session->lock, NULL) != 0) {
249 nc_session_free(session);
250 free (locked_session);
251 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Creating structure session_with_mutex failed %d (%s)", errno, strerror(errno));
252 return NULL;
253 }
254 locked_session->session = session;
255 pthread_mutex_init (&locked_session->lock, NULL);
256 /* get exclusive access to sessions_list (conns) */
257 if (pthread_rwlock_wrlock (&session_lock) != 0) {
258 nc_session_free(session);
259 free (locked_session);
260 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while locking rwlock: %d (%s)", errno, strerror(errno));
261 return NULL;
262 }
263 apr_hash_set(conns, apr_pstrdup(pool, session_key), APR_HASH_KEY_STRING, (void *) locked_session);
264 /* end of critical section */
265 if (pthread_rwlock_unlock (&session_lock) != 0) {
266 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while unlocking rwlock: %d (%s)", errno, strerror(errno));
267 return NULL;
268 }
Radek Krejci469aab82012-07-22 18:42:20 +0200269 ap_log_error(APLOG_MARK, APLOG_NOTICE, 0, server, "NETCONF session established");
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200270 return (session_key);
Radek Krejci469aab82012-07-22 18:42:20 +0200271 } else {
272 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Connection could not be established");
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200273 return (NULL);
Radek Krejci469aab82012-07-22 18:42:20 +0200274 }
275
Radek Krejci469aab82012-07-22 18:42:20 +0200276}
277
Radek Krejci80c10d92012-07-30 08:38:50 +0200278static int netconf_close(server_rec* server, apr_hash_t* conns, const char* session_key)
Radek Krejci469aab82012-07-22 18:42:20 +0200279{
280 struct nc_session *ns = NULL;
David Kupka8e60a372012-09-04 09:15:20 +0200281 struct session_with_mutex * locked_session;
Radek Krejci469aab82012-07-22 18:42:20 +0200282
Radek Krejcif23850c2012-07-23 16:14:17 +0200283 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Key in hash to get: %s", session_key);
David Kupka8e60a372012-09-04 09:15:20 +0200284 /* get exclusive (write) access to sessions_list (conns) */
285 if (pthread_rwlock_wrlock (&session_lock) != 0) {
286 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while locking rwlock: %d (%s)", errno, strerror(errno));
287 return EXIT_FAILURE;
288 }
289 locked_session = (struct session_with_mutex *)apr_hash_get(conns, session_key, APR_HASH_KEY_STRING);
290 if (locked_session != NULL) {
291 pthread_mutex_destroy(&locked_session->lock);
292 ns = locked_session->session;
293 free (locked_session);
294 }
Radek Krejci469aab82012-07-22 18:42:20 +0200295 if (ns != NULL) {
296 nc_session_close (ns, "NETCONF session closed by client");
297 nc_session_free (ns);
298 ns = NULL;
299
300 /* remove session from the active sessions list */
301 apr_hash_set(conns, session_key, APR_HASH_KEY_STRING, NULL);
David Kupka8e60a372012-09-04 09:15:20 +0200302 /* end of critical section */
303 if (pthread_rwlock_unlock (&session_lock) != 0) {
304 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while unlocking rwlock: %d (%s)", errno, strerror(errno));
305 return EXIT_FAILURE;
306 }
Radek Krejci469aab82012-07-22 18:42:20 +0200307 ap_log_error(APLOG_MARK, APLOG_NOTICE, 0, server, "NETCONF session closed");
Radek Krejcif23850c2012-07-23 16:14:17 +0200308
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200309 return (EXIT_SUCCESS);
Radek Krejci469aab82012-07-22 18:42:20 +0200310 } else {
311 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Unknown session to close");
Radek Krejci8fd1f5e2012-07-24 17:33:36 +0200312 return (EXIT_FAILURE);
Radek Krejci469aab82012-07-22 18:42:20 +0200313 }
314}
315
Radek Krejci80c10d92012-07-30 08:38:50 +0200316static int netconf_op(server_rec* server, apr_hash_t* conns, const char* session_key, nc_rpc* rpc)
Radek Krejci469aab82012-07-22 18:42:20 +0200317{
318 struct nc_session *session = NULL;
David Kupka8e60a372012-09-04 09:15:20 +0200319 struct session_with_mutex * locked_session;
Radek Krejci035bf4e2012-07-25 10:59:09 +0200320 nc_reply* reply;
321 int retval = EXIT_SUCCESS;
322
Radek Krejci8e4632a2012-07-26 13:40:34 +0200323 /* check requests */
324 if (rpc == NULL) {
325 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: rpc is not created");
326 return (EXIT_FAILURE);
327 }
328
David Kupka8e60a372012-09-04 09:15:20 +0200329 /* get non-exclusive (read) access to sessions_list (conns) */
330 if (pthread_rwlock_rdlock (&session_lock) != 0) {
331 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while locking rwlock: %d (%s)", errno, strerror(errno));
332 return EXIT_FAILURE;
333 }
Radek Krejci8e4632a2012-07-26 13:40:34 +0200334 /* get session where send the RPC */
David Kupka8e60a372012-09-04 09:15:20 +0200335 locked_session = (struct session_with_mutex *)apr_hash_get(conns, session_key, APR_HASH_KEY_STRING);
336 if (locked_session != NULL) {
337 session = locked_session->session;
338 }
Radek Krejci035bf4e2012-07-25 10:59:09 +0200339 if (session != NULL) {
David Kupka8e60a372012-09-04 09:15:20 +0200340 /* get exclusive access to session */
341 if (pthread_mutex_lock(&locked_session->lock) != 0) {
342 /* unlock before returning error */
343 if (pthread_rwlock_unlock (&session_lock) != 0) {
344 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while locking rwlock: %d (%s)", errno, strerror(errno));
345 return EXIT_FAILURE;
346 }
347 return EXIT_FAILURE;
348 }
Radek Krejci035bf4e2012-07-25 10:59:09 +0200349 /* send the request and get the reply */
350 nc_session_send_rpc (session, rpc);
Radek Krejci035bf4e2012-07-25 10:59:09 +0200351 if (nc_session_recv_reply (session, &reply) == 0) {
Radek Krejci035bf4e2012-07-25 10:59:09 +0200352 if (nc_session_get_status(session) != NC_SESSION_STATUS_WORKING) {
Radek Krejci035bf4e2012-07-25 10:59:09 +0200353 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: receiving rpc-reply failed");
David Kupka8e60a372012-09-04 09:15:20 +0200354 /* first release exclusive lock for this session */
355 pthread_mutex_unlock(&locked_session->lock);
356 /* release read lock, netconf_close will get exclusive access and close this session */
357 if (pthread_rwlock_unlock (&session_lock) != 0) {
358 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while unlocking rwlock: %d (%s)", errno, strerror(errno));
359 return EXIT_FAILURE;
360 }
Radek Krejci035bf4e2012-07-25 10:59:09 +0200361 netconf_close(server, conns, session_key);
Radek Krejci035bf4e2012-07-25 10:59:09 +0200362 return (EXIT_FAILURE);
363 }
David Kupka8e60a372012-09-04 09:15:20 +0200364 /* first release exclusive lock for this session */
365 pthread_mutex_unlock(&locked_session->lock);
366 /* unlock before returning error */
367 if (pthread_rwlock_unlock (&session_lock) != 0) {
368 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while unlocking rwlock: %d (%s)", errno, strerror(errno));
369 return EXIT_FAILURE;
370 }
Radek Krejci035bf4e2012-07-25 10:59:09 +0200371 /* there is error handled by callback */
372 return (EXIT_FAILURE);
373 }
David Kupka8e60a372012-09-04 09:15:20 +0200374 /* first release exclusive lock for this session */
375 pthread_mutex_unlock(&locked_session->lock);
376 /* end of critical section */
377 if (pthread_rwlock_unlock (&session_lock) != 0) {
378 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while unlocking rwlock: %d (%s)", errno, strerror(errno));
379 return EXIT_FAILURE;
380 }
Radek Krejci035bf4e2012-07-25 10:59:09 +0200381
382 switch (nc_reply_get_type (reply)) {
383 case NC_REPLY_OK:
384 retval = EXIT_SUCCESS;
385 break;
386 default:
387 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: unexpected rpc-reply");
388 retval = EXIT_FAILURE;
389 break;
390 }
391 nc_reply_free(reply);
392 return (retval);
393 } else {
394 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Unknown session to process.");
395 return (EXIT_FAILURE);
396 }
397}
Radek Krejci80c10d92012-07-30 08:38:50 +0200398
399static char* netconf_opdata(server_rec* server, apr_hash_t* conns, const char* session_key, nc_rpc* rpc)
Radek Krejci8e4632a2012-07-26 13:40:34 +0200400{
401 struct nc_session *session = NULL;
David Kupka8e60a372012-09-04 09:15:20 +0200402 struct session_with_mutex * locked_session;
Radek Krejci8e4632a2012-07-26 13:40:34 +0200403 nc_reply* reply;
404 char* data;
405
406 /* check requests */
407 if (rpc == NULL) {
408 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: rpc is not created");
409 return (NULL);
410 }
411
David Kupka8e60a372012-09-04 09:15:20 +0200412 /* get non-exclusive (read) access to sessions_list (conns) */
413 if (pthread_rwlock_rdlock (&session_lock) != 0) {
414 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while locking rwlock: %d (%s)", errno, strerror(errno));
415 return NULL;
416 }
Radek Krejci8e4632a2012-07-26 13:40:34 +0200417 /* get session where send the RPC */
David Kupka8e60a372012-09-04 09:15:20 +0200418 locked_session = (struct session_with_mutex *)apr_hash_get(conns, session_key, APR_HASH_KEY_STRING);
419 if (locked_session != NULL) {
420 session = locked_session->session;
421 }
Radek Krejci8e4632a2012-07-26 13:40:34 +0200422 if (session != NULL) {
David Kupka8e60a372012-09-04 09:15:20 +0200423 /* get exclusive access to session */
424 if (pthread_mutex_lock(&locked_session->lock) != 0) {
425 /* unlock before returning error */
426 if (pthread_rwlock_unlock (&session_lock) != 0) {
427 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while locking rwlock: %d (%s)", errno, strerror(errno));
428 return NULL;
429 }
430 return NULL;
431 }
Radek Krejci8e4632a2012-07-26 13:40:34 +0200432 /* send the request and get the reply */
433 nc_session_send_rpc (session, rpc);
434 if (nc_session_recv_reply (session, &reply) == 0) {
Radek Krejci8e4632a2012-07-26 13:40:34 +0200435 if (nc_session_get_status(session) != NC_SESSION_STATUS_WORKING) {
436 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: receiving rpc-reply failed");
David Kupka8e60a372012-09-04 09:15:20 +0200437 /* first release exclusive lock for this session */
438 pthread_mutex_unlock(&locked_session->lock);
439 /* release read lock, netconf_close will get exclusive access and close this session */
440 if (pthread_rwlock_unlock (&session_lock) != 0) {
441 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while unlocking rwlock: %d (%s)", errno, strerror(errno));
442 return NULL;
443 }
Radek Krejci8e4632a2012-07-26 13:40:34 +0200444 netconf_close(server, conns, session_key);
445 return (NULL);
446 }
David Kupka8e60a372012-09-04 09:15:20 +0200447 /* first release exclusive lock for this session */
448 pthread_mutex_unlock(&locked_session->lock);
449 /* unlock before returning error */
450 if (pthread_rwlock_unlock (&session_lock) != 0) {
451 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while unlocking rwlock: %d (%s)", errno, strerror(errno));
452 return NULL;
453 }
Radek Krejci8e4632a2012-07-26 13:40:34 +0200454 /* there is error handled by callback */
455 return (NULL);
456 }
David Kupka8e60a372012-09-04 09:15:20 +0200457 /* first release exclusive lock for this session */
458 pthread_mutex_unlock(&locked_session->lock);
459 /* end of critical section */
460 if (pthread_rwlock_unlock (&session_lock) != 0) {
461 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "Error while unlocking rwlock: %d (%s)", errno, strerror(errno));
462 return NULL;
463 }
Radek Krejci8e4632a2012-07-26 13:40:34 +0200464
465 switch (nc_reply_get_type (reply)) {
466 case NC_REPLY_DATA:
467 if ((data = nc_reply_get_data (reply)) == NULL) {
468 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: no data from reply");
469 return (NULL);
470 }
471 break;
472 default:
473 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: unexpected rpc-reply");
474 return (NULL);
475 }
476 nc_reply_free(reply);
477
478 return (data);
479 } else {
480 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Unknown session to process.");
481 return (NULL);
482 }
483}
484
Radek Krejci80c10d92012-07-30 08:38:50 +0200485static 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 +0200486{
487 nc_rpc* rpc;
488 struct nc_filter *f = NULL;
489 char* data = NULL;
490
491 /* create filter if set */
492 if (filter != NULL) {
493 f = nc_filter_new(NC_FILTER_SUBTREE, filter);
494 }
495
496 /* create requests */
497 rpc = nc_rpc_getconfig (source, f);
498 nc_filter_free(f);
499 if (rpc == NULL) {
500 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: creating rpc request failed");
501 return (NULL);
502 }
503
504 data = netconf_opdata(server, conns, session_key, rpc);
505 nc_rpc_free (rpc);
506 return (data);
507}
508
Radek Krejci80c10d92012-07-30 08:38:50 +0200509static char* netconf_get(server_rec* server, apr_hash_t* conns, const char* session_key, const char* filter)
Radek Krejci8e4632a2012-07-26 13:40:34 +0200510{
511 nc_rpc* rpc;
512 struct nc_filter *f = NULL;
513 char* data = NULL;
514
515 /* create filter if set */
516 if (filter != NULL) {
517 f = nc_filter_new(NC_FILTER_SUBTREE, filter);
518 }
519
520 /* create requests */
521 rpc = nc_rpc_get (f);
522 nc_filter_free(f);
523 if (rpc == NULL) {
524 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: creating rpc request failed");
525 return (NULL);
526 }
527
528 data = netconf_opdata(server, conns, session_key, rpc);
529 nc_rpc_free (rpc);
530 return (data);
531}
532
Radek Krejci80c10d92012-07-30 08:38:50 +0200533static int netconf_copyconfig(server_rec* server, apr_hash_t* conns, const char* session_key, NC_DATASTORE source, NC_DATASTORE target, const char* config)
Radek Krejci8e4632a2012-07-26 13:40:34 +0200534{
535 nc_rpc* rpc;
536 int retval = EXIT_SUCCESS;
537
538 /* create requests */
539 rpc = nc_rpc_copyconfig(source, target, config);
540 if (rpc == NULL) {
541 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: creating rpc request failed");
542 return (EXIT_FAILURE);
543 }
544
545 retval = netconf_op(server, conns, session_key, rpc);
546 nc_rpc_free (rpc);
547 return (retval);
548}
Radek Krejci035bf4e2012-07-25 10:59:09 +0200549
Radek Krejci80c10d92012-07-30 08:38:50 +0200550static 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, const char* config)
Radek Krejci62ab34b2012-07-26 13:42:05 +0200551{
552 nc_rpc* rpc;
553 int retval = EXIT_SUCCESS;
554
555 /* create requests */
556 rpc = nc_rpc_editconfig(target, defop, erropt, config);
557 if (rpc == NULL) {
558 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: creating rpc request failed");
559 return (EXIT_FAILURE);
560 }
561
562 retval = netconf_op(server, conns, session_key, rpc);
563 nc_rpc_free (rpc);
564 return (retval);
565}
566
Radek Krejci80c10d92012-07-30 08:38:50 +0200567static int netconf_killsession(server_rec* server, apr_hash_t* conns, const char* session_key, const char* sid)
Radek Krejcie34d3eb2012-07-26 15:05:53 +0200568{
569 nc_rpc* rpc;
570 int retval = EXIT_SUCCESS;
571
572 /* create requests */
573 rpc = nc_rpc_killsession(sid);
574 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}
583
Radek Krejci80c10d92012-07-30 08:38:50 +0200584static 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 +0200585{
586 nc_rpc* rpc;
587 int retval = EXIT_SUCCESS;
588
589 /* create requests */
Radek Krejci5cd7d422012-07-26 14:50:29 +0200590 rpc = op_func(target);
Radek Krejci2f318372012-07-26 14:22:35 +0200591 if (rpc == NULL) {
592 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: creating rpc request failed");
593 return (EXIT_FAILURE);
594 }
595
596 retval = netconf_op(server, conns, session_key, rpc);
597 nc_rpc_free (rpc);
598 return (retval);
599}
600
Radek Krejci80c10d92012-07-30 08:38:50 +0200601static int netconf_deleteconfig(server_rec* server, apr_hash_t* conns, const char* session_key, NC_DATASTORE target)
Radek Krejci5cd7d422012-07-26 14:50:29 +0200602{
603 return (netconf_onlytargetop(server, conns, session_key, target, nc_rpc_deleteconfig));
604}
605
Radek Krejci80c10d92012-07-30 08:38:50 +0200606static int netconf_lock(server_rec* server, apr_hash_t* conns, const char* session_key, NC_DATASTORE target)
Radek Krejci5cd7d422012-07-26 14:50:29 +0200607{
608 return (netconf_onlytargetop(server, conns, session_key, target, nc_rpc_lock));
609}
610
Radek Krejci80c10d92012-07-30 08:38:50 +0200611static int netconf_unlock(server_rec* server, apr_hash_t* conns, const char* session_key, NC_DATASTORE target)
Radek Krejci5cd7d422012-07-26 14:50:29 +0200612{
613 return (netconf_onlytargetop(server, conns, session_key, target, nc_rpc_unlock));
614}
615
Radek Krejci80c10d92012-07-30 08:38:50 +0200616/**
617 * @return REPLY_OK: 0, *data == NULL
618 * REPLY_DATA: 0, *data != NULL
619 * REPLY_ERROR: 1, *data == NULL
620 */
621static int netconf_generic(server_rec* server, apr_hash_t* conns, const char* session_key, const char* content, char** data)
622{
623 struct nc_session *session = NULL;
624 nc_reply* reply;
625 nc_rpc* rpc;
626 int retval = EXIT_SUCCESS;
627
628 /* create requests */
629 rpc = nc_rpc_generic(content);
630 if (rpc == NULL) {
631 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: creating rpc request failed");
632 return (EXIT_FAILURE);
633 }
634
635 *data = NULL;
636
637 /* get session where send the RPC */
638 session = (struct nc_session *)apr_hash_get(conns, session_key, APR_HASH_KEY_STRING);
639 if (session != NULL) {
640 /* send the request and get the reply */
641 nc_session_send_rpc (session, rpc);
642 if (nc_session_recv_reply (session, &reply) == 0) {
643 nc_rpc_free (rpc);
644 if (nc_session_get_status(session) != NC_SESSION_STATUS_WORKING) {
645 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: receiving rpc-reply failed");
646 netconf_close(server, conns, session_key);
647 return (EXIT_FAILURE);
648 }
649
650 /* there is error handled by callback */
651 return (EXIT_FAILURE);
652 }
653 nc_rpc_free (rpc);
654
655 switch (nc_reply_get_type (reply)) {
656 case NC_REPLY_DATA:
657 if ((*data = nc_reply_get_data (reply)) == NULL) {
658 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: no data from reply");
659 return (EXIT_FAILURE);
660 }
661 retval = EXIT_SUCCESS;
662 break;
663 case NC_REPLY_OK:
664 retval = EXIT_SUCCESS;
665 break;
666 default:
667 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "mod_netconf: unexpected rpc-reply");
668 retval = EXIT_FAILURE;
669 break;
670 }
671 nc_reply_free(reply);
672
673 return (retval);
674 } else {
675 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Unknown session to process.");
676 return (EXIT_FAILURE);
677 }
678}
679
Radek Krejci469aab82012-07-22 18:42:20 +0200680server_rec* clb_print_server;
Radek Krejci7338bde2012-08-10 12:57:30 +0200681void clb_print(NC_VERB_LEVEL level, const char* msg)
Radek Krejci469aab82012-07-22 18:42:20 +0200682{
Radek Krejci7338bde2012-08-10 12:57:30 +0200683 switch (level) {
684 case NC_VERB_ERROR:
685 ap_log_error(APLOG_MARK, APLOG_ERR, 0, clb_print_server, msg);
686 break;
687 case NC_VERB_WARNING:
688 ap_log_error(APLOG_MARK, APLOG_WARNING, 0, clb_print_server, msg);
689 break;
690 case NC_VERB_VERBOSE:
691 ap_log_error(APLOG_MARK, APLOG_INFO, 0, clb_print_server, msg);
692 break;
693 case NC_VERB_DEBUG:
694 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, clb_print_server, msg);
695 break;
696 }
Radek Krejci469aab82012-07-22 18:42:20 +0200697}
698
David Kupka8e60a372012-09-04 09:15:20 +0200699void * thread_routine (void * arg)
700{
701 void * retval = NULL;
702
703 ssize_t buffer_len;
704 struct pollfd fds;
705 int status, buffer_size, ret;
Kupka David00b9c5c2012-09-05 09:45:50 +0200706 json_object *request, *reply, *json_obj, *capabilities;
David Kupka8e60a372012-09-04 09:15:20 +0200707 int operation;
Kupka David00b9c5c2012-09-05 09:45:50 +0200708 int i, chunk_len, len = 0;
David Kupka8e60a372012-09-04 09:15:20 +0200709 char* session_key, *data;
710 const char *host, *port, *user, *pass;
711 const char *msgtext, *cpbltstr;
712 const char *target, *source, *filter, *config, *defop, *erropt, *sid;
713 struct nc_session *session = NULL;
Kupka David00b9c5c2012-09-05 09:45:50 +0200714 struct nc_cpblts* cpblts = NULL;
David Kupka8e60a372012-09-04 09:15:20 +0200715 NC_DATASTORE ds_type_s, ds_type_t;
716 NC_EDIT_DEFOP_TYPE defop_type = 0;
717 NC_EDIT_ERROPT_TYPE erropt_type = 0;
718
719 apr_pool_t * pool = ((struct pass_to_thread*)arg)->pool;
720 apr_hash_t *netconf_sessions_list = ((struct pass_to_thread*)arg)->netconf_sessions_list;
721 server_rec * server = ((struct pass_to_thread*)arg)->server;
722 int client = ((struct pass_to_thread*)arg)->client;
723
724 char * buffer, chunk_len_str[12], *chunked_msg;
725 char c;
726
727 while (!isterminated) {
728 fds.fd = client;
729 fds.events = POLLIN;
730 fds.revents = 0;
731
732 status = poll(&fds, 1, 1000);
733
734 if (status == 0 || (status == -1 && (errno == EAGAIN || (errno == EINTR && isterminated == 0)))) {
735 /* poll was interrupted - check if the isterminated is set and if not, try poll again */
736 //ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "poll interrupted");
737 continue;
738 } else if (status < 0) {
739 /* 0: poll time outed
740 * close socket and ignore this request from the client, it can try it again
741 * -1: poll failed
742 * something wrong happend, close this socket and wait for another request
743 */
744 //ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "poll failed, status %d(%d: %s)", status, errno, strerror(errno));
745 close(client);
746 break;
747 }
748 /* status > 0 */
749
750 /* check the status of the socket */
751
752 /* if nothing to read and POLLHUP (EOF) or POLLERR set */
753 if ((fds.revents & POLLHUP) || (fds.revents & POLLERR)) {
754 /* close client's socket (it's probably already closed by client */
755 //ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "socket error (%d)", fds.revents);
756 close(client);
757 break;
758 }
759
760 /* read json in chunked framing */
761 buffer_size = 0;
762 buffer_len = 0;
763 buffer = NULL;
764 while (1) {
David Kupka1e3e4c82012-09-04 09:32:15 +0200765 /* read chunk length */
766 if ((ret = recv (client, &c, 1, 0)) != 1 || c != '\n') {
767 free (buffer);
768 buffer = NULL;
David Kupka8e60a372012-09-04 09:15:20 +0200769 break;
770 }
David Kupka1e3e4c82012-09-04 09:32:15 +0200771 if ((ret = recv (client, &c, 1, 0)) != 1 || c != '#') {
772 free (buffer);
773 buffer = NULL;
774 break;
775 }
776 i=0;
777 memset (chunk_len_str, 0, 12);
778 while ((ret = recv (client, &c, 1, 0) == 1 && (isdigit(c) || c == '#'))) {
779 if (i==0 && c == '#') {
780 if (recv (client, &c, 1, 0) != 1 || c != '\n') {
781 /* end but invalid */
782 free (buffer);
783 buffer = NULL;
784 }
785 /* end of message, double-loop break */
786 goto msg_complete;
787 }
788 chunk_len_str[i++] = c;
789 }
790 if (c != '\n') {
791 free (buffer);
792 buffer = NULL;
793 break;
794 }
795 if ((chunk_len = atoi (chunk_len_str)) == 0) {
796 free (buffer);
797 buffer = NULL;
798 break;
799 }
800 buffer_size += chunk_len+1;
801 buffer = realloc (buffer, sizeof(char)*buffer_size);
802 if ((ret = recv (client, buffer+buffer_len, chunk_len, 0)) == -1 || ret != chunk_len) {
803 free (buffer);
804 buffer = NULL;
805 break;
806 }
807 buffer_len += ret;
808 }
809msg_complete:
David Kupka8e60a372012-09-04 09:15:20 +0200810
811 if (buffer != NULL) {
812 request = json_tokener_parse(buffer);
813 operation = json_object_get_int(json_object_object_get(request, "type"));
814
815 session_key = (char*) json_object_get_string(json_object_object_get(request, "session"));
816 /* DO NOT FREE session_key HERE, IT IS PART OF REQUEST */
817 if (operation != MSG_CONNECT && session_key == NULL) {
818 reply = json_object_new_object();
819 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
820 json_object_object_add(reply, "error-message", json_object_new_string("Missing session specification."));
821 msgtext = json_object_to_json_string(reply);
822 send(client, msgtext, strlen(msgtext) + 1, 0);
823 json_object_put(reply);
824 /* there is some stupid client, so close the connection to give a chance to some other client */
825 close(client);
826 break;
827 }
828
829 /* get parameters */
830 ds_type_t = -1;
831 if ((target = json_object_get_string(json_object_object_get(request, "target"))) != NULL) {
832 if (strcmp(target, "running") == 0) {
833 ds_type_t = NC_DATASTORE_RUNNING;
834 } else if (strcmp(target, "startup") == 0) {
835 ds_type_t = NC_DATASTORE_STARTUP;
836 } else if (strcmp(target, "candidate") == 0) {
837 ds_type_t = NC_DATASTORE_CANDIDATE;
838 }
839 }
840 ds_type_s = -1;
841 if ((source = json_object_get_string(json_object_object_get(request, "source"))) != NULL) {
842 if (strcmp(source, "running") == 0) {
843 ds_type_s = NC_DATASTORE_RUNNING;
844 } else if (strcmp(source, "startup") == 0) {
845 ds_type_s = NC_DATASTORE_STARTUP;
846 } else if (strcmp(source, "candidate") == 0) {
847 ds_type_s = NC_DATASTORE_CANDIDATE;
848 }
849 }
850
851 /* null global JSON error-reply */
852 err_reply = NULL;
853
854 /* prepare reply envelope */
855 reply = json_object_new_object();
856
857 /* process required operation */
858 switch (operation) {
859 case MSG_CONNECT:
860 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: Connect");
861
862 host = json_object_get_string(json_object_object_get(request, "host"));
863 port = json_object_get_string(json_object_object_get(request, "port"));
864 user = json_object_get_string(json_object_object_get(request, "user"));
865 pass = json_object_get_string(json_object_object_get(request, "pass"));
Tomas Cejkaf34f3912012-09-05 18:14:06 +0200866 capabilities = json_object_object_get(request, "capabilities");
867 if ((capabilities != NULL) && ((len = json_object_array_length(capabilities)) > 0)) {
Kupka David00b9c5c2012-09-05 09:45:50 +0200868 cpblts = nc_cpblts_new (NULL);
869 for (i=0; i<len; i++) {
870 nc_cpblts_add (cpblts, json_object_get_string(json_object_array_get_idx(capabilities, i)));
871 }
872 } else {
873 ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "no capabilities specified");
874 }
David Kupka8e60a372012-09-04 09:15:20 +0200875 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "host: %s, port: %s, user: %s", host, port, user);
876 if ((host == NULL) || (user == NULL)) {
877 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Cannot connect - insufficient input.");
878 session_key = NULL;
879 } else {
Kupka David00b9c5c2012-09-05 09:45:50 +0200880 session_key = netconf_connect(server, pool, netconf_sessions_list, host, port, user, pass, cpblts);
881 nc_cpblts_free (cpblts);
David Kupka8e60a372012-09-04 09:15:20 +0200882 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "hash: %s", session_key);
883 }
884
885 reply = json_object_new_object();
886 if (session_key == NULL) {
887 /* negative reply */
888 if (err_reply == NULL) {
889 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
890 json_object_object_add(reply, "error-message", json_object_new_string("Connecting NETCONF server failed."));
891 } else {
892 /* use filled err_reply from libnetconf's callback */
893 json_object_put(reply);
894 reply = err_reply;
895 }
896 } else {
897 /* positive reply */
898 json_object_object_add(reply, "type", json_object_new_int(REPLY_OK));
899 json_object_object_add(reply, "session", json_object_new_string(session_key));
900
901 free(session_key);
902 }
903
904 break;
905 case MSG_GET:
906 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: get (session %s)", session_key);
907
908 filter = json_object_get_string(json_object_object_get(request, "filter"));
909
910 //ap_log_error (APLOG_MARK, APLOG_ERR, 0, server, "get filter: %p", filter);
911
Tomas Cejkacdc274e2012-09-05 18:15:33 +0200912 if ((data = netconf_get(server, netconf_sessions_list, session_key, filter)) == NULL) {
David Kupka8e60a372012-09-04 09:15:20 +0200913 if (err_reply == NULL) {
914 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
915 json_object_object_add(reply, "error-message", json_object_new_string("get failed."));
916 } else {
917 /* use filled err_reply from libnetconf's callback */
918 json_object_put(reply);
919 reply = err_reply;
920 }
921 } else {
922 json_object_object_add(reply, "type", json_object_new_int(REPLY_DATA));
923 json_object_object_add(reply, "data", json_object_new_string(data));
924 }
925 break;
926 case MSG_GETCONFIG:
927 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: get-config (session %s)", session_key);
928
929 filter = json_object_get_string(json_object_object_get(request, "filter"));
930
931 if (ds_type_s == -1) {
932 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
933 json_object_object_add(reply, "error-message", json_object_new_string("Invalid source repository type requested."));
934 break;
935 }
936
937 if ((data = netconf_getconfig(server, netconf_sessions_list, session_key, ds_type_s, filter)) == NULL) {
938 if (err_reply == NULL) {
939 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
940 json_object_object_add(reply, "error-message", json_object_new_string("get-config failed."));
941 } else {
942 /* use filled err_reply from libnetconf's callback */
943 json_object_put(reply);
944 reply = err_reply;
945 }
946 } else {
947 json_object_object_add(reply, "type", json_object_new_int(REPLY_DATA));
948 json_object_object_add(reply, "data", json_object_new_string(data));
949 }
950 break;
951 case MSG_EDITCONFIG:
952 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: edit-config (session %s)", session_key);
953
954 defop = json_object_get_string(json_object_object_get(request, "default-operation"));
955 if (defop != NULL) {
956 if (strcmp(defop, "merge") == 0) {
957 defop_type = NC_EDIT_DEFOP_MERGE;
958 } else if (strcmp(defop, "replace") == 0) {
959 defop_type = NC_EDIT_DEFOP_REPLACE;
960 } else if (strcmp(defop, "none") == 0) {
961 defop_type = NC_EDIT_DEFOP_NONE;
962 } else {
963 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
964 json_object_object_add(reply, "error-message", json_object_new_string("Invalid default-operation parameter."));
965 break;
966 }
967 } else {
968 defop_type = 0;
969 }
970
971 erropt = json_object_get_string(json_object_object_get(request, "error-option"));
972 if (erropt != NULL) {
973 if (strcmp(erropt, "continue-on-error") == 0) {
974 erropt_type = NC_EDIT_ERROPT_CONT;
975 } else if (strcmp(erropt, "stop-on-error") == 0) {
976 erropt_type = NC_EDIT_ERROPT_STOP;
977 } else if (strcmp(erropt, "rollback-on-error") == 0) {
978 erropt_type = NC_EDIT_ERROPT_ROLLBACK;
979 } else {
980 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
981 json_object_object_add(reply, "error-message", json_object_new_string("Invalid error-option parameter."));
982 break;
983 }
984 } else {
985 erropt_type = 0;
986 }
987
988 if (ds_type_t == -1) {
989 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
990 json_object_object_add(reply, "error-message", json_object_new_string("Invalid target repository type requested."));
991 break;
992 }
993
994 config = json_object_get_string(json_object_object_get(request, "config"));
995 if (config == NULL) {
996 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
997 json_object_object_add(reply, "error-message", json_object_new_string("Invalid config data parameter."));
998 break;
999 }
1000
1001 if (netconf_editconfig(server, netconf_sessions_list, session_key, ds_type_t, defop_type, erropt_type, config) != EXIT_SUCCESS) {
1002 if (err_reply == NULL) {
1003 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1004 json_object_object_add(reply, "error-message", json_object_new_string("edit-config failed."));
1005 } else {
1006 /* use filled err_reply from libnetconf's callback */
1007 json_object_put(reply);
1008 reply = err_reply;
1009 }
1010 } else {
1011 json_object_object_add(reply, "type", json_object_new_int(REPLY_OK));
1012 }
1013 break;
1014 case MSG_COPYCONFIG:
1015 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: copy-config (session %s)", session_key);
1016 config = NULL;
1017
1018 if (source == NULL) {
1019 /* no explicit source specified -> use config data */
1020 ds_type_s = NC_DATASTORE_NONE;
1021 config = json_object_get_string(json_object_object_get(request, "config"));
1022 } else if (ds_type_s == -1) {
1023 /* source datastore specified, but it is invalid */
1024 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1025 json_object_object_add(reply, "error-message", json_object_new_string("Invalid source repository type requested."));
1026 break;
1027 }
1028
1029 if (ds_type_t == -1) {
1030 /* invalid target datastore specified */
1031 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1032 json_object_object_add(reply, "error-message", json_object_new_string("Invalid target repository type requested."));
1033 break;
1034 }
1035
1036 if (source == NULL && config == NULL) {
1037 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1038 json_object_object_add(reply, "error-message", json_object_new_string("invalid input parameters - one of source and config is required."));
1039 } else {
1040 if (netconf_copyconfig(server, netconf_sessions_list, session_key, ds_type_s, ds_type_t, config) != EXIT_SUCCESS) {
1041 if (err_reply == NULL) {
1042 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1043 json_object_object_add(reply, "error-message", json_object_new_string("copy-config failed."));
1044 } else {
1045 /* use filled err_reply from libnetconf's callback */
1046 json_object_put(reply);
1047 reply = err_reply;
1048 }
1049 } else {
1050 json_object_object_add(reply, "type", json_object_new_int(REPLY_OK));
1051 }
1052 }
1053 break;
1054 case MSG_DELETECONFIG:
1055 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: delete-config (session %s)", session_key);
1056 /* no break - unifying code */
1057 case MSG_LOCK:
1058 if (operation == MSG_LOCK) {
1059 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: lock (session %s)", session_key);
1060 }
1061 /* no break - unifying code */
1062 case MSG_UNLOCK:
1063 if (operation == MSG_UNLOCK) {
1064 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: unlock (session %s)", session_key);
1065 }
1066
1067 if (ds_type_t == -1) {
1068 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1069 json_object_object_add(reply, "error-message", json_object_new_string("Invalid target repository type requested."));
1070 break;
1071 }
1072
1073 switch(operation) {
1074 case MSG_DELETECONFIG:
1075 status = netconf_deleteconfig(server, netconf_sessions_list, session_key, ds_type_t);
1076 break;
1077 case MSG_LOCK:
1078 status = netconf_lock(server, netconf_sessions_list, session_key, ds_type_t);
1079 break;
1080 case MSG_UNLOCK:
1081 status = netconf_unlock(server, netconf_sessions_list, session_key, ds_type_t);
1082 break;
1083 default:
1084 status = -1;
1085 break;
1086 }
1087
1088 if (status != EXIT_SUCCESS) {
1089 if (err_reply == NULL) {
1090 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1091 json_object_object_add(reply, "error-message", json_object_new_string("operation failed."));
1092 } else {
1093 /* use filled err_reply from libnetconf's callback */
1094 json_object_put(reply);
1095 reply = err_reply;
1096 }
1097 } else {
1098 json_object_object_add(reply, "type", json_object_new_int(REPLY_OK));
1099 }
1100 break;
1101 case MSG_KILL:
1102 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: kill-session, session %s", session_key);
1103
1104 sid = json_object_get_string(json_object_object_get(request, "session-id"));
1105
1106 if (sid == NULL) {
1107 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1108 json_object_object_add(reply, "error-message", json_object_new_string("Missing session-id parameter."));
1109 break;
1110 }
1111
1112 if (netconf_killsession(server, netconf_sessions_list, session_key, sid) != EXIT_SUCCESS) {
1113 if (err_reply == NULL) {
1114 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1115 json_object_object_add(reply, "error-message", json_object_new_string("kill-session failed."));
1116 } else {
1117 /* use filled err_reply from libnetconf's callback */
1118 json_object_put(reply);
1119 reply = err_reply;
1120 }
1121 } else {
1122 json_object_object_add(reply, "type", json_object_new_int(REPLY_OK));
1123 }
1124 break;
1125 case MSG_DISCONNECT:
1126 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: Disconnect session %s", session_key);
1127
1128 if (netconf_close(server, netconf_sessions_list, session_key) != EXIT_SUCCESS) {
1129 if (err_reply == NULL) {
1130 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1131 json_object_object_add(reply, "error-message", json_object_new_string("Invalid session identifier."));
1132 } else {
1133 /* use filled err_reply from libnetconf's callback */
1134 json_object_put(reply);
1135 reply = err_reply;
1136 }
1137 } else {
1138 json_object_object_add(reply, "type", json_object_new_int(REPLY_OK));
1139 }
1140 break;
1141 case MSG_INFO:
1142 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: get info about session %s", session_key);
1143
1144 session = (struct nc_session *)apr_hash_get(netconf_sessions_list, session_key, APR_HASH_KEY_STRING);
1145 if (session != NULL) {
1146 json_object_object_add(reply, "sid", json_object_new_string(nc_session_get_id(session)));
1147 json_object_object_add(reply, "version", json_object_new_string((nc_session_get_version(session) == 0)?"1.0":"1.1"));
1148 json_object_object_add(reply, "host", json_object_new_string(nc_session_get_host(session)));
1149 json_object_object_add(reply, "port", json_object_new_string(nc_session_get_port(session)));
1150 json_object_object_add(reply, "user", json_object_new_string(nc_session_get_user(session)));
1151 cpblts = nc_session_get_cpblts (session);
1152 if (cpblts != NULL) {
1153 json_obj = json_object_new_array();
1154 nc_cpblts_iter_start (cpblts);
1155 while ((cpbltstr = nc_cpblts_iter_next (cpblts)) != NULL) {
1156 json_object_array_add(json_obj, json_object_new_string(cpbltstr));
1157 }
1158 json_object_object_add(reply, "capabilities", json_obj);
1159 }
1160 } else {
1161 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1162 json_object_object_add(reply, "error-message", json_object_new_string("Invalid session identifier."));
1163 }
1164
1165 break;
1166 case MSG_GENERIC:
1167 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "Request: generic request for session %s", session_key);
1168
1169 config = json_object_get_string(json_object_object_get(request, "content"));
1170
1171 if (config == 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("Missing content parameter."));
1174 break;
1175 }
1176
1177 if (netconf_generic(server, netconf_sessions_list, session_key, config, &data) != EXIT_SUCCESS) {
1178 if (err_reply == NULL) {
1179 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1180 json_object_object_add(reply, "error-message", json_object_new_string("kill-session failed."));
1181 } else {
1182 /* use filled err_reply from libnetconf's callback */
1183 json_object_put(reply);
1184 reply = err_reply;
1185 }
1186 } else {
1187 if (data == NULL) {
1188 json_object_object_add(reply, "type", json_object_new_int(REPLY_OK));
1189 } else {
1190 json_object_object_add(reply, "type", json_object_new_int(REPLY_DATA));
1191 json_object_object_add(reply, "data", json_object_new_string(data));
1192 }
1193 }
1194 break;
1195 default:
1196 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Unknown mod_netconf operation requested (%d)", operation);
1197 reply = json_object_new_object();
1198 json_object_object_add(reply, "type", json_object_new_int(REPLY_ERROR));
1199 json_object_object_add(reply, "error-message", json_object_new_string("Operation not supported."));
1200 break;
1201 }
1202 json_object_put(request);
1203
David Kupka1e3e4c82012-09-04 09:32:15 +02001204 /* send reply to caller */
1205 if (reply != NULL) {
1206 msgtext = json_object_to_json_string(reply);
1207 if (asprintf (&chunked_msg, "\n#%d\n%s\n##\n", (int)strlen(msgtext), msgtext) == -1) {
1208 free (buffer);
David Kupka8e60a372012-09-04 09:15:20 +02001209 break;
1210 }
David Kupka1e3e4c82012-09-04 09:32:15 +02001211 send(client, chunked_msg, strlen(chunked_msg) + 1, 0);
1212 json_object_put(reply);
1213 free (chunked_msg);
1214 free (buffer);
1215 } else {
1216 break;
David Kupka8e60a372012-09-04 09:15:20 +02001217 }
1218 }
1219 }
1220
1221 free (arg);
1222
1223 return retval;
1224}
1225
Radek Krejcif23850c2012-07-23 16:14:17 +02001226/*
1227 * This is actually implementation of NETCONF client
1228 * - requests are received from UNIX socket in the predefined format
1229 * - results are replied through the same way
1230 * - the daemon run as a separate process, but it is started and stopped
1231 * automatically by Apache.
1232 *
1233 */
Radek Krejci469aab82012-07-22 18:42:20 +02001234static void forked_proc(apr_pool_t * pool, server_rec * server)
1235{
1236 struct sockaddr_un local, remote;
David Kupka8e60a372012-09-04 09:15:20 +02001237 int lsock, client, ret, i, pthread_count = 0;
1238 socklen_t len;
Radek Krejciae021c12012-07-25 18:03:52 +02001239 mod_netconf_cfg *cfg;
Radek Krejci469aab82012-07-22 18:42:20 +02001240 apr_hash_t *netconf_sessions_list;
David Kupka8e60a372012-09-04 09:15:20 +02001241 struct pass_to_thread * arg;
1242 pthread_t * ptids = calloc (1,sizeof(pthread_t));
1243 struct timespec maxtime;
1244 pthread_rwlockattr_t lock_attrs;
1245
1246 /* wait at most 5 secons for every thread to terminate */
1247 maxtime.tv_sec = 5;
1248 maxtime.tv_nsec = 0;
Radek Krejci469aab82012-07-22 18:42:20 +02001249
Radek Krejcif23850c2012-07-23 16:14:17 +02001250 /* change uid and gid of process for security reasons */
Radek Krejci469aab82012-07-22 18:42:20 +02001251 unixd_setup_child();
1252
Radek Krejciae021c12012-07-25 18:03:52 +02001253 cfg = ap_get_module_config(server->module_config, &netconf_module);
1254 if (cfg == NULL) {
Radek Krejci8fd1f5e2012-07-24 17:33:36 +02001255 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Getting mod_netconf configuration failed");
1256 return;
1257 }
Radek Krejci469aab82012-07-22 18:42:20 +02001258
Radek Krejci8fd1f5e2012-07-24 17:33:36 +02001259 /* create listening UNIX socket to accept incoming connections */
Radek Krejci469aab82012-07-22 18:42:20 +02001260 if ((lsock = socket(PF_UNIX, SOCK_STREAM, 0)) == -1) {
1261 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Creating socket failed (%s)", strerror(errno));
1262 return;
1263 }
1264
1265 local.sun_family = AF_UNIX;
Radek Krejciae021c12012-07-25 18:03:52 +02001266 strncpy(local.sun_path, cfg->sockname, sizeof(local.sun_path));
Radek Krejci469aab82012-07-22 18:42:20 +02001267 unlink(local.sun_path);
1268 len = offsetof(struct sockaddr_un, sun_path) + strlen(local.sun_path);
1269
1270 if (bind(lsock, (struct sockaddr *) &local, len) == -1) {
1271 if (errno == EADDRINUSE) {
1272 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "mod_netconf socket address already in use");
1273 close(lsock);
1274 exit(0);
1275 }
1276 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Binding socket failed (%s)", strerror(errno));
1277 close(lsock);
1278 return;
1279 }
1280
1281 if (listen(lsock, MAX_SOCKET_CL) == -1) {
1282 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Setting up listen socket failed (%s)", strerror(errno));
1283 close(lsock);
1284 return;
1285 }
1286
1287 /* prepare internal lists */
1288 netconf_sessions_list = apr_hash_make(pool);
1289
1290 /* setup libnetconf's callbacks */
1291 nc_verbosity(NC_VERB_DEBUG);
1292 clb_print_server = server;
1293 nc_callback_print(clb_print);
1294 nc_callback_ssh_host_authenticity_check(netconf_callback_ssh_hostkey_check);
1295 nc_callback_sshauth_interactive(netconf_callback_sshauth_interactive);
1296 nc_callback_sshauth_password(netconf_callback_sshauth_password);
Radek Krejcic11fd862012-07-26 12:41:21 +02001297 nc_callback_error_reply(netconf_callback_error_process);
Radek Krejci469aab82012-07-22 18:42:20 +02001298
1299 /* disable publickey authentication */
1300 nc_ssh_pref(NC_SSH_AUTH_PUBLIC_KEYS, -1);
1301
David Kupka8e60a372012-09-04 09:15:20 +02001302 /* create mutex protecting session list */
1303 pthread_rwlockattr_init(&lock_attrs);
1304 /* rwlock is shared only with threads in this process */
1305 pthread_rwlockattr_setpshared(&lock_attrs, PTHREAD_PROCESS_PRIVATE);
1306 /* create rw lock */
1307 if (pthread_rwlock_init(&session_lock, &lock_attrs) != 0) {
1308 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Initialization of mutex failed: %d (%s)", errno, strerror(errno));
1309 close (lsock);
1310 return;
1311 }
1312
Radek Krejci469aab82012-07-22 18:42:20 +02001313 while (isterminated == 0) {
1314 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, server, "waiting for another client's request");
1315
1316 /* open incoming connection if any */
David Kupka8e60a372012-09-04 09:15:20 +02001317 len = sizeof(remote);
1318 client = accept(lsock, (struct sockaddr *) &remote, &len);
Radek Krejci469aab82012-07-22 18:42:20 +02001319 if (client == -1 && (errno == EAGAIN || errno == EWOULDBLOCK)) {
1320 apr_sleep(SLEEP_TIME);
1321 continue;
1322 } else if (client == -1 && (errno == EINTR)) {
1323 continue;
1324 } else if (client == -1) {
1325 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Accepting mod_netconf client connection failed (%s)", strerror(errno));
1326 continue;
1327 }
Radek Krejci469aab82012-07-22 18:42:20 +02001328
1329 /* set client's socket as non-blocking */
Radek Krejcif23850c2012-07-23 16:14:17 +02001330 //fcntl(client, F_SETFL, fcntl(client, F_GETFL, 0) | O_NONBLOCK);
Radek Krejci469aab82012-07-22 18:42:20 +02001331
David Kupka8e60a372012-09-04 09:15:20 +02001332 arg = malloc (sizeof(struct pass_to_thread));
1333 arg->client = client;
1334 arg->pool = pool;
1335 arg->server = server;
1336 arg->netconf_sessions_list = netconf_sessions_list;
Radek Krejci469aab82012-07-22 18:42:20 +02001337
David Kupka8e60a372012-09-04 09:15:20 +02001338 /* start new thread. It will serve this particular request and then terminate */
1339 if ((ret = pthread_create (&ptids[pthread_count], NULL, thread_routine, (void*)arg)) != 0) {
1340 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Creating POSIX thread failed: %d\n", ret);
1341 } else {
1342 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Thread %lu created", ptids[pthread_count]);
1343 pthread_count++;
1344 ptids = realloc (ptids, sizeof(pthread_t)*(pthread_count+1));
1345 ptids[pthread_count] = 0;
1346 }
Radek Krejci469aab82012-07-22 18:42:20 +02001347
David Kupka8e60a372012-09-04 09:15:20 +02001348 /* check if some thread already terminated, free some resources by joining it */
1349 for (i=0; i<pthread_count; i++) {
1350 if (pthread_tryjoin_np (ptids[i], (void**)&arg) == 0) {
1351 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Thread %lu joined with retval %p", ptids[i], arg);
1352 pthread_count--;
1353 if (pthread_count > 0) {
1354 /* place last Thread ID on the place of joined one */
1355 ptids[i] = ptids[pthread_count];
Radek Krejci8fd1f5e2012-07-24 17:33:36 +02001356 }
Radek Krejci469aab82012-07-22 18:42:20 +02001357 }
1358 }
David Kupka8e60a372012-09-04 09:15:20 +02001359 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Running %d threads", pthread_count);
Radek Krejci469aab82012-07-22 18:42:20 +02001360 }
1361
David Kupka8e60a372012-09-04 09:15:20 +02001362 /* join all threads */
1363 for (i=0; i<pthread_count; i++) {
1364 pthread_timedjoin_np (ptids[i], (void**)&arg, &maxtime);
1365 }
1366 free (ptids);
1367
Radek Krejci469aab82012-07-22 18:42:20 +02001368 close(lsock);
1369
David Kupka8e60a372012-09-04 09:15:20 +02001370 /* destroy rwlock */
1371 pthread_rwlock_destroy(&session_lock);
1372 pthread_rwlockattr_destroy(&lock_attrs);
1373
Radek Krejci469aab82012-07-22 18:42:20 +02001374 ap_log_error(APLOG_MARK, APLOG_ERR, 0, server, "Exiting from the mod_netconf daemon");
1375
1376 exit(APR_SUCCESS);
1377}
1378
Radek Krejcif23850c2012-07-23 16:14:17 +02001379static void *mod_netconf_create_conf(apr_pool_t * pool, server_rec * s)
Radek Krejci469aab82012-07-22 18:42:20 +02001380{
Radek Krejcif23850c2012-07-23 16:14:17 +02001381 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, "Init netconf module config");
1382
1383 mod_netconf_cfg *config = apr_pcalloc(pool, sizeof(mod_netconf_cfg));
1384 apr_pool_create(&config->pool, pool);
1385 config->forkproc = NULL;
Radek Krejci8fd1f5e2012-07-24 17:33:36 +02001386 config->sockname = SOCKET_FILENAME;
Radek Krejcif23850c2012-07-23 16:14:17 +02001387
1388 return (void *)config;
Radek Krejci469aab82012-07-22 18:42:20 +02001389}
1390
1391static int mod_netconf_master_init(apr_pool_t * pconf, apr_pool_t * ptemp,
1392 apr_pool_t * plog, server_rec * s)
1393{
Radek Krejcif23850c2012-07-23 16:14:17 +02001394 mod_netconf_cfg *config;
1395 apr_status_t res;
1396
Radek Krejci469aab82012-07-22 18:42:20 +02001397 /* These two help ensure that we only init once. */
1398 void *data;
Radek Krejcif23850c2012-07-23 16:14:17 +02001399 const char *userdata_key = "netconf_ipc_init";
Radek Krejci469aab82012-07-22 18:42:20 +02001400
1401 /*
1402 * The following checks if this routine has been called before.
1403 * This is necessary because the parent process gets initialized
1404 * a couple of times as the server starts up.
1405 */
1406 apr_pool_userdata_get(&data, userdata_key, s->process->pool);
1407 if (!data) {
1408 apr_pool_userdata_set((const void *)1, userdata_key, apr_pool_cleanup_null, s->process->pool);
1409 return (OK);
1410 }
1411
Radek Krejcif23850c2012-07-23 16:14:17 +02001412 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, "creating mod_netconf daemon");
1413 config = ap_get_module_config(s->module_config, &netconf_module);
Radek Krejcidfaa6ea2012-07-23 09:04:43 +02001414
Radek Krejcif23850c2012-07-23 16:14:17 +02001415 if (config && config->forkproc == NULL) {
1416 config->forkproc = apr_pcalloc(config->pool, sizeof(apr_proc_t));
1417 res = apr_proc_fork(config->forkproc, config->pool);
Radek Krejci469aab82012-07-22 18:42:20 +02001418 switch (res) {
1419 case APR_INCHILD:
1420 /* set signal handler */
Radek Krejcif23850c2012-07-23 16:14:17 +02001421 apr_signal_init(config->pool);
Radek Krejci469aab82012-07-22 18:42:20 +02001422 apr_signal(SIGTERM, signal_handler);
1423
1424 /* log start of the separated NETCONF communication process */
Radek Krejcif23850c2012-07-23 16:14:17 +02001425 ap_log_error(APLOG_MARK, APLOG_NOTICE, 0, s, "mod_netconf daemon started (PID %d)", getpid());
Radek Krejci469aab82012-07-22 18:42:20 +02001426
1427 /* start main loop providing NETCONF communication */
Radek Krejcif23850c2012-07-23 16:14:17 +02001428 forked_proc(config->pool, s);
Radek Krejci469aab82012-07-22 18:42:20 +02001429
Radek Krejcif23850c2012-07-23 16:14:17 +02001430 /* I never should be here, wtf?!? */
1431 ap_log_error(APLOG_MARK, APLOG_ERR, 0, s, "mod_netconf daemon unexpectedly stopped");
Radek Krejci469aab82012-07-22 18:42:20 +02001432 exit(APR_EGENERAL);
1433 break;
1434 case APR_INPARENT:
1435 /* register child to be killed (SIGTERM) when the module config's pool dies */
Radek Krejcif23850c2012-07-23 16:14:17 +02001436 apr_pool_note_subprocess(config->pool, config->forkproc, APR_KILL_AFTER_TIMEOUT);
Radek Krejci469aab82012-07-22 18:42:20 +02001437 break;
1438 default:
1439 ap_log_error(APLOG_MARK, APLOG_ERR, 0, s, "apr_proc_fork() failed");
1440 break;
1441 }
Radek Krejcif23850c2012-07-23 16:14:17 +02001442 } else {
1443 ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, s, "mod_netconf misses configuration structure");
Radek Krejci469aab82012-07-22 18:42:20 +02001444 }
1445
1446 return OK;
1447}
1448
Radek Krejci469aab82012-07-22 18:42:20 +02001449/**
1450 * Register module hooks
1451 */
1452static void mod_netconf_register_hooks(apr_pool_t * p)
1453{
Radek Krejcif23850c2012-07-23 16:14:17 +02001454 ap_hook_post_config(mod_netconf_master_init, NULL, NULL, APR_HOOK_LAST);
Radek Krejci469aab82012-07-22 18:42:20 +02001455}
1456
Radek Krejci8fd1f5e2012-07-24 17:33:36 +02001457static const char* cfg_set_socket_path(cmd_parms* cmd, void* cfg, const char* arg)
1458{
1459 ((mod_netconf_cfg*)cfg)->sockname = apr_pstrdup(cmd->pool, arg);
1460 return NULL;
1461}
1462
1463static const command_rec netconf_cmds[] = {
1464 AP_INIT_TAKE1("NetconfSocket", cfg_set_socket_path, NULL, OR_ALL, "UNIX socket path for mod_netconf communication."),
1465 {NULL}
1466};
1467
Radek Krejci469aab82012-07-22 18:42:20 +02001468/* Dispatch list for API hooks */
1469module AP_MODULE_DECLARE_DATA netconf_module = {
1470 STANDARD20_MODULE_STUFF,
1471 NULL, /* create per-dir config structures */
1472 NULL, /* merge per-dir config structures */
Radek Krejcif23850c2012-07-23 16:14:17 +02001473 mod_netconf_create_conf, /* create per-server config structures */
Radek Krejci469aab82012-07-22 18:42:20 +02001474 NULL, /* merge per-server config structures */
Radek Krejci8fd1f5e2012-07-24 17:33:36 +02001475 netconf_cmds, /* table of config file commands */
Radek Krejci469aab82012-07-22 18:42:20 +02001476 mod_netconf_register_hooks /* register hooks */
1477};