/*

 *   This program is free software; you can redistribute it and/or modify

 *   it under the terms of the GNU General Public License as published by

 *   the Free Software Foundation; either version 2 of the License, or

 *   (at your option) any later version.

 *

 *   This program is distributed in the hope that it will be useful,

 *   but WITHOUT ANY WARRANTY; without even the implied warranty of

 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 *   GNU General Public License for more details.

 *

 *   You should have received a copy of the GNU General Public License

 *   along with this program; if not, write to the Free Software

 *   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA

 */

/**

 * $Id: 9d9fdda106a3317961e23baa3a4b2d9c6b20b24d $

 *

 * @file unlang/io.c

 * @brief Shim I/O worker functions for running fake requests.

 *

 * @copyright 2006-2019 The FreeRADIUS server project

 */

RCSID("$Id: 9d9fdda106a3317961e23baa3a4b2d9c6b20b24d $")

#include <freeradius-devel/io/listen.h>

#include "unlang_priv.h"

/** Allocate a child request based on the parent.

 *

 * @param[in] parent    spawning the child request.

 * @param[in] namespace   the child request operates in. If NULL the parent's namespace is used.

 * @param[in] detachable  Allow/disallow the child to be detached.

 * @return

 *      - The new child request.

 *  - NULL on error.

 */

request_t *unlang_io_subrequest_alloc(request_t *parent, fr_dict_t const *namespace, bool detachable)

{

  request_t   *child;

  char const    *server;

  if (!namespace) namespace = parent->proto_dict;

  /*

   *  A child cannot refer to local variables in the parent context.

   */

  fr_assert(fr_dict_proto_dict(namespace) == namespace);

  child = request_local_alloc_internal(detachable ? NULL : parent,

               (&(request_init_args_t){

            .parent = parent,

            .namespace = namespace,

            .detachable = detachable

               }));

  if (!child) return NULL;

  /*

   *  Child gets its parent's interpreter

   */

  ((unlang_stack_t *)child->stack)->intp = ((unlang_stack_t *)parent->stack)->intp;

  /*

   *  Push the child, and set its top frame to be true.

   */

  child->log.indent.unlang = parent->log.indent.unlang;

  /*

   *  Initialize some basic information for the child.

   */

  child->number = parent->number;

  /*

   *  Initialize all of the async fields.

   */

  child->async = talloc_zero(child, fr_async_t);

#define COPY_FIELD(_x) child->async->_x = parent->async->_x

  COPY_FIELD(recv_time);

  fr_assert(request_is_internal(child));

  server = unlang_interpret_virtual_server(parent);

  if (server) {

    child->packet->socket = (fr_socket_t) {

      .af = AF_FR_VIRTUAL_SERVER,

      .virtual.server = server,

    };

    child->reply->socket = child->packet->socket;

  }

  REQUEST_VERIFY(child);

  return child;

}