#include <sys/wait.h>
#include <tr_gss.h>
+#include "mons_handlers.h"
+
/**
* Allocate a new MONS_INSTANCE
*
MONS_INSTANCE *mons = talloc(mem_ctx, MONS_INSTANCE);
if (mons) {
+ mons->hostname = NULL;
mons->port = 0;
+ mons->tids = NULL;
+ mons->trps = NULL;
mons->req_handler = NULL;
mons->auth_handler = NULL;
mons->cookie = NULL;
}
/**
+ * Callback to process a request and produce a response
+ *
+ * @param req_str JSON-encoded request
+ * @param data pointer to a MONS_INSTANCE
+ * @return pointer to the response string or null to send no response
+ */
+static TR_MSG *mons_req_cb(TALLOC_CTX *mem_ctx, TR_MSG *req_msg, void *data)
+{
+ TALLOC_CTX *tmp_ctx = talloc_new(NULL);
+ //MONS_INSTANCE *mons = talloc_get_type_abort(data, MONS_INSTANCE);
+ MON_REQ *req = NULL;
+ TR_MSG *resp_msg = NULL; /* This is the response value */
+
+ /* Validate inputs */
+ if (req_msg == NULL)
+ goto cleanup;
+
+ req = tr_msg_get_mon_req(req_msg);
+ if (req == NULL) {
+ /* this is an internal error */
+ tr_err("mons_req_cb: Received incorrect message type (was %d, expected %d)",
+ tr_msg_get_msg_type(req_msg),
+ MON_REQUEST);
+ /* TODO send an error response */
+ goto cleanup;
+ }
+
+cleanup:
+ talloc_free(tmp_ctx);
+ return resp_msg;
+}
+
+/**
* Create a listener for monitoring requests
*
* Accept connections with mons_accept()
* @param max_fd
* @return
*/
-int mons_get_listener(MONS_INSTANCE *mons,
- MONS_REQ_FUNC *req_handler,
- MONS_AUTH_FUNC *auth_handler,
- unsigned int port,
- void *cookie,
- int *fd_out,
- size_t max_fd)
+int mons_get_listener(MONS_INSTANCE *mons, MONS_REQ_FUNC *req_handler, MONS_AUTH_FUNC *auth_handler, const char *hostname,
+ unsigned int port, void *cookie, int *fd_out, size_t max_fd)
{
size_t n_fd=0;
size_t ii=0;
/* store the caller's request handler & cookie */
mons->req_handler = req_handler;
mons->auth_handler = auth_handler;
+ mons->hostname = hostname;
mons->cookie = cookie;
}