Add T[r]XXX sub-command.

PR: 	#59

Author: sobomax

src/Makefile.am

@@ -75,7 +75,8 @@ BASE_SOURCES=main.c rtp.h rtpp_server.c \
   $(CMDSRCDIR)/rpcpv1_norecord.c $(CMDSRCDIR)/rpcpv1_norecord.h \
   $(CMDSRCDIR)/rpcpv1_ul_subc.c $(CMDSRCDIR)/rpcpv1_ul_subc.h \
   $(RTPP_AUTOSRC_SOURCES) rtpp_epoll.c rtpp_str.c rtpp_str.h \
-  rtpp_sbuf.c rtpp_sbuf.h rtpp_refproxy.c rtpp_command_reply.c
+  rtpp_sbuf.c rtpp_sbuf.h rtpp_refproxy.c rtpp_command_reply.c \
+  $(CMDSRCDIR)/rpcpv1_ul_subc_ttl.c $(CMDSRCDIR)/rpcpv1_ul_subc_ttl.h
 BASE_SOURCES+=$(ADV_DIR)/packet_observer.h $(ADV_DIR)/pproc_manager.c \
   $(ADV_DIR)/pproc_manager.h
 BASE_SOURCES+=rtpp_modman.c

src/commands/rpcpv1_ul_subc.c

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2006-2020 Sippy Software, Inc., http://www.sippysoft.com
+ * Copyright (c) 2006-2021 Sippy Software, Inc., http://www.sippysoft.com
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
@@ -35,6 +35,7 @@
 #include "rtpp_util.h"
 #include "rtpp_log.h"
 #include "rtpp_log_obj.h"
+#include "rtpp_mallocs.h"
 #include "rtpp_modman.h"
 #include "rtpp_codeptr.h"
 #include "rtpp_refcnt.h"
@@ -45,6 +46,7 @@
 #include "commands/rpcpv1_ul.h"
 #include "commands/rpcpv1_ul_subc.h"
 #include "commands/rpcpv1_delete.h"
+#include "commands/rpcpv1_ul_subc_ttl.h"
 
 #if ENABLE_MODULE_IF
 static int
@@ -67,6 +69,31 @@ handle_mod_subc_parse(const struct rtpp_cfg *cfsp, const char *ip,
 }
 #endif
 
+static int
+handle_ttl_subc_parse(const struct rtpp_cfg *cfsp, const char *cp,
+  struct after_success_h *asp)
+{
+    struct rtpp_subcommand_ttl ttl_arg, *tap;
+
+    if (cp[0] == 'r' || cp[0] == 'R') {
+        ttl_arg.direction = TTL_REVERSE;
+        cp += 1;
+    } else {
+        ttl_arg.direction = TTL_FORWARD;
+    }
+    if (atoi_safe(cp, &ttl_arg.ttl) != ATOI_OK)
+        return (-1);
+    if (ttl_arg.ttl <= 0)
+        return (-1);
+    tap = rtpp_zmalloc(sizeof(ttl_arg));
+    if (tap == NULL)
+        return (-1);
+    *tap = ttl_arg;
+    asp->args.dyn = tap;
+    asp->handler = rtpp_subcommand_ttl_handler;
+    return (0);
+}
+
 int
 rtpp_subcommand_ul_opts_parse(const struct rtpp_cfg *cfsp, struct rtpp_command *cmd,
   const struct rtpp_command_args *subc_args, struct after_success_h *asp)
@@ -98,6 +125,13 @@ rtpp_subcommand_ul_opts_parse(const struct rtpp_cfg *cfsp, struct rtpp_command *
         asp->handler = handle_delete_as_subc;
         break;
 
+    case 'T':
+    case 't':
+        if (subc_args->c != 1)
+            return (-1);
+        return (handle_ttl_subc_parse(cfsp, &subc_args->v[0].s[1], asp));
+        break;
+
     default:
         return (-1);
     }

src/commands/rpcpv1_ul_subc_ttl.c

@@ -0,0 +1,67 @@
+/*
+ * Copyright (c) 2021 Sippy Software, Inc., http://www.sippysoft.com
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * 1. Redistributions of source code must retain the above copyright
+ *    notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ *    notice, this list of conditions and the following disclaimer in the
+ *    documentation and/or other materials provided with the distribution.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
+ * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
+ * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
+ * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+ * SUCH DAMAGE.
+ *
+ */
+
+#include <sys/socket.h>
+#include <stdint.h>
+#include <stdlib.h>
+
+#include "rtpp_codeptr.h"
+#include "rtpp_types.h"
+#include "rtpp_stream.h"
+#include "rtpp_ttl.h"
+#include "rtpp_command.h"
+#include "rtpp_command_sub.h"
+#include "rtpp_command_args.h"
+#include "rtpp_command_private.h"
+#include "commands/rpcpv1_ul.h"
+#include "commands/rpcpv1_ul_subc_ttl.h"
+
+int
+rtpp_subcommand_ttl_handler(const struct after_success_h_args *ashap,
+  const struct rtpp_subc_ctx *rscp)
+{
+    const struct rtpp_subcommand_ttl *tap;
+    struct rtpp_stream *strmp;
+
+    tap = (struct rtpp_subcommand_ttl *)ashap->dyn;
+    switch (tap->direction) {
+    case TTL_FORWARD:
+        strmp = rscp->strmp_in;
+        break;
+
+    case TTL_REVERSE:
+        strmp = rscp->strmp_out;
+        if (strmp == NULL)
+            return (-1);
+        break;
+
+    default:
+        abort();
+    }
+
+    CALL_SMETHOD(strmp->ttl, reset_with, tap->ttl);
+    return (0);
+}

src/commands/rpcpv1_ul_subc_ttl.h

@@ -0,0 +1,41 @@
+/*
+ * Copyright (c) 2021 Sippy Software, Inc., http://www.sippysoft.com
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * 1. Redistributions of source code must retain the above copyright
+ *    notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ *    notice, this list of conditions and the following disclaimer in the
+ *    documentation and/or other materials provided with the distribution.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
+ * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
+ * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
+ * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+ * SUCH DAMAGE.
+ *
+ */
+
+struct rtpp_subc_ctx;
+struct after_success_h_args;
+
+enum rtpp_subcommand_ttl_direction {
+    TTL_FORWARD = 0,
+    TTL_REVERSE = 1
+};
+
+struct rtpp_subcommand_ttl {
+    int ttl;
+    enum rtpp_subcommand_ttl_direction direction;
+};
+
+int rtpp_subcommand_ttl_handler(const struct after_success_h_args *,
+  const struct rtpp_subc_ctx *);

src/commands/rpcpv1_ver.c

@@ -70,6 +70,7 @@ const static struct proto_cap proto_caps[] = {
     { "20230314", "Support for for \"fusing\" G and D commands" },
     { "20230424", "Support for for \"longest_ipi\", \"rtpa_jlast\", \"rtpa_jmax\" and \"rtpa_javg\" counters" },
     { "20250523", "Support for the \"P\" modifier in the C command"},
+    { "20251015", "Support for changing session's ttl" },
     { NULL, NULL }
 };