-/*
- * Copyright (C) 2006-2009 Andre Noll <maan@systemlinux.org>
- *
- * Licensed under the GPL v2. For licencing details see COPYING.
- */
+/* Copyright (C) 2006 Andre Noll <maan@tuebingen.mpg.de>, see file COPYING. */
/** \file recv_common.c common functions of para_recv and para_audiod */
#include <regex.h>
+#include <inttypes.h>
+#include <lopsub.h>
+#include "recv_cmd.lsg.h"
#include "para.h"
+#include "error.h"
#include "list.h"
#include "sched.h"
-#include "ggo.h"
+#include "buffer_tree.h"
#include "recv.h"
#include "string.h"
-DEFINE_RECEIVER_ARRAY;
-
/**
* Call the init function of each paraslash receiver.
+ *
+ * Receivers employ the user_data feature of the lopsub library: Each receiver
+ * of the recv_cmd suite defines a struct receiver as its user data.
+ * recv_init() obtains a pointer to this structure by calling lls_user_data().
+ * If the receiver has an init function (i.e., if ->init is not NULL), ->init()
+ * is called to initialize the receiver.
*/
void recv_init(void)
{
int i;
- FOR_EACH_RECEIVER(i)
- receivers[i].init(&receivers[i]);
+ FOR_EACH_RECEIVER(i) {
+ const struct lls_command *cmd = RECV_CMD(i);
+ const struct receiver *r = lls_user_data(cmd);
+ if (r && r->init)
+ r->init();
+ }
}
-static void *parse_receiver_args(int receiver_num, char *options)
+/**
+ * Check if the given string is a valid receiver specifier.
+ *
+ * \param ra string of the form receiver_name [options...]
+ * \param lprp Filled in on success, undefined else.
+ *
+ * This function checks whether \a ra starts with the name of a receiver,
+ * optionally followed by options for that receiver. If a valid receiver name
+ * was found the remaining part of \a ra is passed to the receiver's config
+ * parser.
+ *
+ * If a NULL pointer or an empty string is passed as the first argument, the
+ * hhtp receiver with no options is assumed.
+ *
+ * \return On success the number of the receiver is returned. On errors, the
+ * function calls exit(EXIT_FAILURE).
+ */
+int check_receiver_arg(const char *ra, struct lls_parse_result **lprp)
{
- struct receiver *r = &receivers[receiver_num];
- char **argv;
- int argc, i;
- void *conf;
-
+ int ret, argc, receiver_num;
+ char *errctx = NULL, **argv;
+ const struct lls_command *cmd;
- PARA_DEBUG_LOG("%s, options: %s\n", r->name,
- options? options : "(none)");
- if (options) {
- PARA_DEBUG_LOG("options: %s\n", options);
- argc = create_argv(options, " \t", &argv);
- if (argc < 0)
- return NULL;
- for (i = argc - 1; i >= 0; i--)
- argv[i + 1] = argv[i];
- argv[0] = NULL;
- argc++;
- } else {
+ *lprp = NULL;
+ if (!ra || !*ra) {
argc = 1;
argv = para_malloc(2 * sizeof(char*));
- argv[0] = NULL;
+ argv[0] = para_strdup("http");
argv[1] = NULL;
+ } else {
+ ret = create_argv(ra, " \t\n", &argv);
+ if (ret < 0) {
+ PARA_EMERG_LOG("%s\n", para_strerror(-ret));
+ exit(EXIT_FAILURE);
+ }
+ argc = ret;
+ }
+ ret = lls(lls_lookup_subcmd(argv[0], recv_cmd_suite, &errctx));
+ if (ret < 0) {
+ PARA_EMERG_LOG("%s: %s\n", errctx? errctx : argv[0],
+ para_strerror(-ret));
+ exit(EXIT_FAILURE);
+ }
+ receiver_num = ret;
+ cmd = RECV_CMD(receiver_num);
+ ret = lls(lls_parse(argc, argv, cmd, lprp, &errctx));
+ if (ret < 0) {
+ if (errctx)
+ PARA_ERROR_LOG("%s\n", errctx);
+ PARA_EMERG_LOG("%s\n", para_strerror(-ret));
+ exit(EXIT_FAILURE);
}
- conf = r->parse_config(argc, argv);
- for (i = 1; i < argc; i++)
- free(argv[i]);
- free(argv);
- return conf;
+ ret = receiver_num;
+ free_argv(argv);
+ return ret;
}
/**
- * check if given string is a valid command line for any receiver
- *
- * \param \ra string of the form receiver_name:options
- * \param receiver_num contains the number of the receiver upon success
- *
- * This function checks whether \a ra starts with the name of a supported
- * paraslash receiver, optinally followed by a colon and any options for that
- * receiver. If a valid receiver name was found and further are present, the
- * remaining part of \a ra is passed to that receiver's config parser.
+ * Print out the help texts to all receivers.
*
- * \return On success, a pointer to the gengetopt args info struct is returned
- * and \a receiver_num contains the number of the receiver. Otherwise this function
- * returns \p NULL.
+ * \param detailed Whether to print the short or the detailed help.
*/
-void *check_receiver_arg(char *ra, int *receiver_num)
+void print_receiver_helps(bool detailed)
{
- int j;
+ int i;
- PARA_DEBUG_LOG("checking %s\n", ra);
- for (j = 0; receivers[j].name; j++) {
- const char *name = receivers[j].name;
- size_t len = strlen(name);
- char c;
- if (strlen(ra) < len)
- continue;
- if (strncmp(name, ra, len))
- continue;
- c = ra[len];
- if (c && c != ' ')
+ printf("\nAvailable receivers: ");
+ FOR_EACH_RECEIVER(i) {
+ const struct lls_command *cmd = RECV_CMD(i);
+ printf("%s%s", i? " " : "", lls_command_name(cmd));
+ }
+ printf("\n\n");
+ FOR_EACH_RECEIVER(i) {
+ const struct lls_command *cmd = RECV_CMD(i);
+ char *help = detailed? lls_long_help(cmd) : lls_short_help(cmd);
+ if (!help)
continue;
- if (c && !receivers[j].parse_config)
- return NULL;
- *receiver_num = j;
- return parse_receiver_args(j, c? ra + len + 1: NULL);
+ printf("%s\n", help);
+ free(help);
}
- PARA_ERROR_LOG("receiver not found\n");
- return NULL;
}
/**
- * Print out the help texts to all receivers.
+ * Simple pre-select hook, used by all receivers.
+ *
+ * \param s Scheduler info.
+ * \param rn The receiver node.
+ *
+ * This requests a minimal delay from the scheduler if the status of the buffer
+ * tree node indicates an error/eof condition. No file descriptors are added to
+ * the fd sets of \a s.
*
- * \param detailed Whether the detailed help should be printed.
+ * \return The status of the btr node of the receiver node, i.e. the return
+ * value of the underlying call to \ref btr_node_status().
*/
-void print_receiver_helps(int detailed)
+int generic_recv_pre_select(struct sched *s, struct receiver_node *rn)
{
- int i;
+ int ret = btr_node_status(rn->btrn, 0, BTR_NT_ROOT);
- printf_or_die("\nAvailable receivers: \n\t");
- FOR_EACH_RECEIVER(i)
- printf_or_die("%s%s", i? " " : "", receivers[i].name);
- printf_or_die("\n\n");
- FOR_EACH_RECEIVER(i) {
- struct receiver *r = receivers + i;
- if (!r->help.short_help)
- continue;
- printf_or_die("Options for %s:\n", r->name);
- ggo_print_help(&r->help, detailed);
- }
+ if (ret < 0)
+ sched_min_delay(s);
+ return ret;
}