| /* | |
| * | |
| * Copyright (C) 2007 Mindspeed Technologies, Inc. | |
| * | |
| * 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA | |
| */ | |
| #include "cmm.h" | |
| #include <stdlib.h> | |
| #include <string.h> | |
| #include "module_rtp.h" | |
| #include "fpp.h" | |
| static void cmmRTPSetUsage(void) | |
| { | |
| cmm_print(DEBUG_STDOUT, | |
| "Usage: set rtp \n" | |
| "\n" | |
| " [open | update]\n" | |
| " [ccn {call control number}] \n" | |
| " [sock_id_a {socket ID}]\n" | |
| " [sock_id_b {socket ID}] \n" | |
| "\n" | |
| " [takeover]\n" | |
| " [ccn {call control number}] \n" | |
| " [sock_id {socket ID}]\n" | |
| " [seq_nb_base {Sequence number base }]\n" | |
| " [rtp_ssrc {RTP SSRC}]\n" | |
| " [rtp_time_base {RTP timestamp base}]\n" | |
| " [rtp_time_incr {RTP timestamp increment}]\n" | |
| " [rtp_time_incr_mode {0:TS value, 1:Freq HZ}]\n" | |
| " [ssrc_mode {0: regular, 1: auto}]\n" | |
| "\n" | |
| " [control]\n" | |
| " [ccn {call control number}] \n" | |
| " [rtp_media_ctrl {0-3}]\n" | |
| "\n" | |
| " [close]\n" | |
| " [ccn {call control number}] \n" | |
| "\n" | |
| " [spectx_ctrl]\n" | |
| " [ccn {call control number}] \n" | |
| " [type_tx {0: Transmission start, 1: Reception response, 2: Transmission stop, 3: Transmission single shot}] \n" | |
| "\n" | |
| " [spectx_payload]\n" | |
| " [ccn {call control number}] \n" | |
| " [id {0: special payload 1, 1: special payload 2}] \n" | |
| " [rtp_payload {Special RTP payload (string)}] \n" | |
| "\n" | |
| ); | |
| } | |
| static void cmmRTCPQueryUsage(void) | |
| { | |
| cmm_print(DEBUG_STDOUT, | |
| "Usage: query rtcp [sock_id {socket ID}] [reset {full | partial}]\n" | |
| "\n" | |
| ); | |
| } | |
| int cmmRTPSetProcess(char ** keywords, int tabStart, daemon_handle_t daemon_handle) | |
| { | |
| int cpt = tabStart; | |
| unsigned int tmp; | |
| unsigned int takeover_mode = 0; | |
| char * endptr; | |
| char rcvBuffer[256]; | |
| if(!keywords[cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "open") == 0) | |
| ||(strcasecmp(keywords[cpt], "update") == 0)) | |
| { | |
| fpp_rtp_open_cmd_t cmd; | |
| unsigned int action; | |
| if(strcasecmp(keywords[cpt], "open") == 0) | |
| action = FPP_CMD_RTP_OPEN; | |
| else | |
| action = FPP_CMD_RTP_UPDATE; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "ccn") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > USHRT_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: ccn must be a number between 0 and %d\n", USHRT_MAX); | |
| goto print_help; | |
| } | |
| cmd.call_id = tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "sock_id_a") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > USHRT_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: sock_id_a parameter must be a number between 0 and %d\n", USHRT_MAX); | |
| goto print_help; | |
| } | |
| cmd.socket_a= tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "sock_id_b") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > USHRT_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: sock_id_b parameter must be a number between 0 and %d\n", USHRT_MAX); | |
| goto print_help; | |
| } | |
| cmd.socket_b= tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| // Send command | |
| if(cmmSendToDaemon(daemon_handle, action, &cmd, sizeof(cmd), &rcvBuffer) == 2) | |
| { | |
| if ((((unsigned short*)rcvBuffer)[0]) != 0) | |
| cmm_print(DEBUG_STDERR, "Error %s (%d) received from FPP \n", getErrorString(((unsigned short*)rcvBuffer)[0]), ((unsigned short*)rcvBuffer)[0]); | |
| } | |
| } | |
| else if (strcasecmp(keywords[cpt], "takeover") == 0) | |
| { | |
| fpp_rtp_takeover_cmd_t cmd; | |
| memset(&cmd,0,sizeof(fpp_rtp_takeover_cmd_t)); | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "ccn") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > USHRT_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: ccn must be a number between 0 and %d\n", USHRT_MAX); | |
| goto print_help; | |
| } | |
| cmd.call_id = tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "sock_id") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > USHRT_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: sock_id parameter must be a number between 0 and %d\n", USHRT_MAX); | |
| goto print_help; | |
| } | |
| cmd.socket= tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "seq_nb_base") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > USHRT_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: seq_nb_base parameter must be a number between 0 and %d\n", USHRT_MAX); | |
| goto print_help; | |
| } | |
| cmd.seq_number_base= tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "rtp_ssrc") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > ULONG_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: sock_id_b parameter must be a number between 0 and %d\n", (unsigned int) ULONG_MAX); | |
| goto print_help; | |
| } | |
| cmd.ssrc= tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "rtp_time_base") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > ULONG_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: rtp_time_base parameter must be a number between 0 and %d\n", (unsigned int) ULONG_MAX); | |
| goto print_help; | |
| } | |
| cmd.ts_base= tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto send; | |
| if((strcasecmp(keywords[cpt], "rtp_time_incr") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > ULONG_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: rtp_time_incr parameter must be a number between 0 and %d\n", (unsigned int) ULONG_MAX); | |
| goto print_help; | |
| } | |
| cmd.ts_incr= tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto send; | |
| if((strcasecmp(keywords[cpt], "rtp_time_incr_mode") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > 1)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: rtp_time_incr_mod parameter must be 0 or 1\n"); | |
| goto print_help; | |
| } | |
| if(tmp) | |
| takeover_mode = FPP_RTP_TAKEOVER_MODE_TSINCR_FREQ; | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto send; | |
| if((strcasecmp(keywords[cpt], "ssrc_mode") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > 1)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: ssrc_mode parameter must be 0 or 1\n"); | |
| goto print_help; | |
| } | |
| if(tmp) | |
| takeover_mode |= FPP_RTP_TAKEOVER_MODE_SSRC; | |
| } | |
| else | |
| goto keyword_error; | |
| cmd.mode = takeover_mode; | |
| send: | |
| // Send command | |
| if(cmmSendToDaemon(daemon_handle, FPP_CMD_RTP_TAKEOVER, &cmd, sizeof(cmd), &rcvBuffer) == 2) | |
| { | |
| if ((((unsigned short*)rcvBuffer)[0]) != 0) | |
| cmm_print(DEBUG_STDERR, "Error %s (%d) received from FPP \n", getErrorString(((unsigned short*)rcvBuffer)[0]), ((unsigned short*)rcvBuffer)[0]); | |
| } | |
| } | |
| else if (strcasecmp(keywords[cpt], "control") == 0) | |
| { | |
| fpp_rtp_ctrl_cmd_t cmd; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "ccn") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > USHRT_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: ccn must be a number between 0 and %d\n", USHRT_MAX); | |
| goto print_help; | |
| } | |
| cmd.call_id = tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "rtp_media_ctrl") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > 3)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: rtp_media_ctrl parameter must be a number between 0 and 3\n"); | |
| goto print_help; | |
| } | |
| cmd.control_dir= tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| // Send command | |
| if(cmmSendToDaemon(daemon_handle, FPP_CMD_RTP_CONTROL, &cmd, sizeof(cmd), &rcvBuffer) == 2) | |
| { | |
| if ((((unsigned short*)rcvBuffer)[0]) != 0) | |
| cmm_print(DEBUG_STDERR, "Error %s (%d) received from FPP \n", getErrorString(((unsigned short*)rcvBuffer)[0]), ((unsigned short*)rcvBuffer)[0]); | |
| } | |
| } | |
| else if (strcasecmp(keywords[cpt], "close") == 0) | |
| { | |
| fpp_rtp_close_cmd_t cmd; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "ccn") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > USHRT_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: ccn must be a number between 0 and %d\n", USHRT_MAX); | |
| goto print_help; | |
| } | |
| cmd.call_id = tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| // Send command | |
| if(cmmSendToDaemon(daemon_handle, FPP_CMD_RTP_CLOSE, &cmd, sizeof(cmd), &rcvBuffer) == 2) | |
| { | |
| if ((((unsigned short*)rcvBuffer)[0]) != 0) | |
| cmm_print(DEBUG_STDERR, "Error %s (%d) received from FPP \n", getErrorString(((unsigned short*)rcvBuffer)[0]), ((unsigned short*)rcvBuffer)[0]); | |
| } | |
| } | |
| else if (strcasecmp(keywords[cpt], "spectx_ctrl") == 0) | |
| { | |
| fpp_rtp_spec_tx_ctrl_cmd_t cmd; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "ccn") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > USHRT_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: ccn must be a number between 0 and %d\n", USHRT_MAX); | |
| goto print_help; | |
| } | |
| cmd.call_id = tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "type_tx") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > 3)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: type_tx must be a number between 0 and 3\n"); | |
| goto print_help; | |
| } | |
| cmd.type= tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| // Send command | |
| if(cmmSendToDaemon(daemon_handle, FPP_CMD_RTP_SPECTX_CTRL, &cmd, sizeof(cmd), &rcvBuffer) == 2) | |
| { | |
| if ((((unsigned short*)rcvBuffer)[0]) != 0) | |
| cmm_print(DEBUG_STDERR, "Error %s (%d) received from FPP \n", getErrorString(((unsigned short*)rcvBuffer)[0]), ((unsigned short*)rcvBuffer)[0]); | |
| } | |
| } | |
| else if (strcasecmp(keywords[cpt], "spectx_payload") == 0) | |
| { | |
| fpp_rtp_spec_tx_payload_cmd_t cmd; | |
| char *rtp_payload; | |
| unsigned short rtp_payload_s; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "ccn") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > USHRT_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: ccn must be a number between 0 and %d\n", USHRT_MAX); | |
| goto print_help; | |
| } | |
| cmd.call_id = tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "id") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > 1)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: id must be a number between 0 and 1\n"); | |
| goto print_help; | |
| } | |
| cmd.payload_id = tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "rtp_payload") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| rtp_payload = keywords[cpt]; | |
| } | |
| else | |
| goto keyword_error; | |
| rtp_payload_s = strlen(rtp_payload); | |
| if(rtp_payload_s > FPP_MAX_SPTX_STRING_SIZE) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: RTP payload string size must be < %d\n", FPP_MAX_SPTX_STRING_SIZE); | |
| goto print_help; | |
| } | |
| cmd.payload_length = rtp_payload_s; | |
| memcpy(cmd.payload, rtp_payload, rtp_payload_s); | |
| // Send command | |
| if(cmmSendToDaemon(daemon_handle, FPP_CMD_RTP_SPECTX_PLD, &cmd, sizeof(cmd), &rcvBuffer) == 2) | |
| { | |
| if ((((unsigned short*)rcvBuffer)[0]) != 0) | |
| cmm_print(DEBUG_STDERR, "Error %s (%d) received from FPP \n", getErrorString(((unsigned short*)rcvBuffer)[0]), ((unsigned short*)rcvBuffer)[0]); | |
| } | |
| } | |
| else | |
| { | |
| goto keyword_error; | |
| } | |
| return 0; | |
| keyword_error: | |
| cmm_print(DEBUG_STDOUT,"ERR: unknown keyword %s\n", keywords[cpt]); | |
| print_help: | |
| cmmRTPSetUsage(); | |
| return -1; | |
| } | |
| int cmmRTCPQueryProcess(char ** keywords, int tabStart, daemon_handle_t daemon_handle) | |
| { | |
| int cpt = tabStart; | |
| char rcvBuffer[256] __attribute__ ((aligned (4))); | |
| fpp_rtcp_query_cmd_t cmd; | |
| fpp_rtcp_query_res_t *rsp = (fpp_rtcp_query_res_t *)(rcvBuffer + 4); | |
| unsigned int tmp; | |
| char * endptr; | |
| int rcvBytes; | |
| if(!keywords[cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "sock_id") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| memset(&cmd, 0, sizeof(cmd)); | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > USHRT_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtp ERROR: sock_id must be a number between 0 and %d\n", USHRT_MAX); | |
| goto print_help; | |
| } | |
| cmd.socket_id = tmp; | |
| if (keywords[++cpt]) | |
| { | |
| if (strcasecmp(keywords[cpt], "reset") == 0) | |
| { | |
| if(!keywords[++cpt]) | |
| cmd.flags = 0x1; //default is full reset | |
| else if(strcasecmp(keywords[cpt], "full") == 0) | |
| cmd.flags = 0x1; | |
| else if(strcasecmp(keywords[cpt], "partial") == 0) | |
| cmd.flags = 0x2; | |
| } | |
| else | |
| goto print_help; | |
| } | |
| } | |
| else | |
| goto keyword_error; | |
| // Send command | |
| rcvBytes = cmmSendToDaemon(daemon_handle, FPP_CMD_RTCP_QUERY, &cmd, sizeof(fpp_rtcp_query_cmd_t), rcvBuffer + 2); | |
| if (rcvBytes < sizeof(unsigned short)) | |
| { | |
| cmm_print(DEBUG_CRIT, "Short message received from FPP \n"); | |
| goto out; | |
| } | |
| if ((((unsigned short*)rcvBuffer)[1]) != 0) | |
| { | |
| cmm_print(DEBUG_CRIT, "Error: %s (%d) received from FPP for CMD_RTCP_QUERY\n", getErrorString(((unsigned short*)rcvBuffer)[1]), ((unsigned short*)rcvBuffer)[1]); | |
| goto out; | |
| } | |
| if (rcvBytes < (sizeof(fpp_rtcp_query_res_t) + sizeof(unsigned short))) | |
| { | |
| cmm_print(DEBUG_CRIT, "Short message received from FPP \n"); | |
| goto out; | |
| } | |
| cmm_print(DEBUG_STDOUT, "RTCP Statistics (sport %u dport %u)\n\n" | |
| "prev_reception_period(ms) : %u\n" | |
| "last_reception_period(ms) : %u\n" | |
| "num_tx_pkts : %u\n" | |
| "num_rx_pkts : %u\n" | |
| "last_rx_Seq : %u\n" | |
| "last_rx_TimeStamp : %u\n" | |
| "RTP_header : %x %x %x %x %x %x %x %x %x %x %x %x\n" | |
| "num_dup_rx : %u\n" | |
| "num_rx_since_RTCP : %u\n" | |
| "num_tx_bytes : %u\n" | |
| "min_jitter(us) : %u\n" | |
| "max_jitter(us) : %u\n" | |
| "average_jitter(us) : %u\n" | |
| "num_rx_lost_pkts : %u\n" | |
| "min_reception_period(us) : %u\n" | |
| "max_reception_period(us) : %u\n" | |
| "average_reception_period(us) : %u\n" | |
| "num_malformed_pkts : %u\n" | |
| "num_expected_pkts : %u\n" | |
| "num_late_pkts : %u\n" | |
| "ssrc_overwrite_value : %x\n", | |
| ntohs(rsp->sport), | |
| ntohs(rsp->dport), | |
| rsp->prev_reception_period, | |
| rsp->last_reception_period, | |
| rsp->num_tx_pkts, | |
| rsp->num_rx_pkts, | |
| rsp->last_rx_seq, | |
| rsp->last_rx_timestamp, | |
| rsp->rtp_header[0], rsp->rtp_header[1], rsp->rtp_header[2], rsp->rtp_header[3], rsp->rtp_header[4], rsp->rtp_header[5], | |
| rsp->rtp_header[6], rsp->rtp_header[7], rsp->rtp_header[8], rsp->rtp_header[9], rsp->rtp_header[10], rsp->rtp_header[11], | |
| rsp->num_rx_dup, | |
| rsp->num_rx_since_rtcp, | |
| rsp->num_tx_bytes, | |
| rsp->min_jitter, rsp->max_jitter, rsp->average_jitter, | |
| rsp->num_rx_lost_pkts, | |
| rsp->min_reception_period, | |
| rsp->max_reception_period, | |
| rsp->average_reception_period, | |
| rsp->num_malformed_pkts, | |
| rsp->num_expected_pkts, | |
| rsp->num_late_pkts, | |
| rsp->ssrc_overwrite_value | |
| ); | |
| out: | |
| return 0 ; | |
| keyword_error: | |
| cmm_print(DEBUG_STDOUT,"ERR: unknown keyword %s\n", keywords[cpt]); | |
| print_help: | |
| cmmRTCPQueryUsage(); | |
| return -1; | |
| } | |
| /******************** RTP Statistics for QoS Measurement ********************************/ | |
| static void cmmRTPStatsSetUsage(void) | |
| { | |
| cmm_print(DEBUG_STDOUT, | |
| "Usage: set rtpstats \n" | |
| "\n" | |
| " [enable]\n" | |
| " [id {RTP stream ID}]\n" | |
| " [type {connection type: ip4 | ip6 | mc4 | mc6 | relay | relay6}]\n" | |
| " [saddr {ip source}]\n" | |
| " [daddr {ip destination}]\n" | |
| " [sport {port source}]\n" | |
| " [dport {port destination}]\n" | |
| " [proto {layer 3 protocol: udp | tcp}]\n" | |
| " [auto {udp port discovery mode}]\n" | |
| "\n" | |
| " [disable]\n" | |
| " [id {RTP stream ID}]\n" | |
| "\n" | |
| " [dtmf_relay]\n" | |
| " [{pt value 1} {pt value 2}]\n" | |
| "\n" | |
| ); | |
| } | |
| static void cmmRTPStatsQueryUsage(void) | |
| { | |
| cmm_print(DEBUG_STDOUT, | |
| "Usage: query rtpstats [id {RTP stream ID}] [reset {full | partial}]\n" | |
| "\n" | |
| ); | |
| } | |
| int cmmRTPStatsSetProcess(char ** keywords, int tabStart, daemon_handle_t daemon_handle) | |
| { | |
| int cpt = tabStart; | |
| unsigned int tmp; | |
| char * endptr; | |
| char rcvBuffer[256]; | |
| fpp_rtp_stat_enable_cmd_t cmd_ena; | |
| fpp_rtp_stat_disable_cmd_t cmd_dis; | |
| fpp_rtp_stat_dtmf_pt_cmd_t cmd_dtmf_pt; | |
| unsigned char pt_low, pt_high; | |
| int family; | |
| int rcvBytes; | |
| memset(&cmd_ena, 0 , sizeof(fpp_rtp_stat_enable_cmd_t)); | |
| memset(&cmd_dis, 0 , sizeof(fpp_rtp_stat_disable_cmd_t)); | |
| memset(&cmd_dtmf_pt, 0 , sizeof(fpp_rtp_stat_dtmf_pt_cmd_t)); | |
| if(!keywords[cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "enable") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if(strcasecmp(keywords[cpt], "id") == 0) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > USHRT_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "ERROR: stream ID parameter must be a number between 0 and %d\n", USHRT_MAX); | |
| goto print_help; | |
| } | |
| cmd_ena.stream_id= tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "type") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if(strcasecmp(keywords[cpt], "ip4") == 0) { | |
| cmd_ena.stream_type = FPP_RTPSTATS_TYPE_IP4; | |
| family = AF_INET; | |
| } | |
| else if(strcasecmp(keywords[cpt], "ip6") == 0) { | |
| cmd_ena.stream_type = FPP_RTPSTATS_TYPE_IP6; | |
| family = AF_INET6; | |
| } | |
| else if(strcasecmp(keywords[cpt], "mc4") == 0) { | |
| cmd_ena.stream_type = FPP_RTPSTATS_TYPE_MC4; | |
| family = AF_INET; | |
| } | |
| else if (strcasecmp(keywords[cpt], "mc6") == 0) { | |
| cmd_ena.stream_type = FPP_RTPSTATS_TYPE_MC6; | |
| family = AF_INET6; | |
| } | |
| else if (strcasecmp(keywords[cpt], "relay") == 0) { | |
| cmd_ena.stream_type = FPP_RTPSTATS_TYPE_RLY; | |
| family = AF_INET; | |
| } | |
| else if (strcasecmp(keywords[cpt], "relay6") == 0) { | |
| cmd_ena.stream_type = FPP_RTPSTATS_TYPE_RLY6; | |
| family = AF_INET6; | |
| } | |
| else | |
| goto keyword_error; | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "saddr") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if (!inet_pton(family, keywords[cpt], cmd_ena.saddr)) | |
| { | |
| cmm_print(DEBUG_CRIT,"ERROR: reading source address %s\n", keywords[cpt]); | |
| goto keyword_error; | |
| } | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "daddr") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if (!inet_pton(family, keywords[cpt], cmd_ena.daddr)) | |
| { | |
| cmm_print(DEBUG_CRIT,"ERROR:reading destination address %s\n", keywords[cpt]); | |
| goto keyword_error; | |
| } | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "sport") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > USHRT_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "ERROR: sport must be a number between 0 and %d\n", USHRT_MAX); | |
| goto print_help; | |
| } | |
| cmd_ena.sport = htons(tmp); | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "dport") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > USHRT_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "ERROR: dport must be a number between 0 and %d\n", USHRT_MAX); | |
| goto print_help; | |
| } | |
| cmd_ena.dport = htons(tmp); | |
| } | |
| else | |
| goto keyword_error; | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "proto") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if(strcasecmp(keywords[cpt], "udp") == 0) | |
| cmd_ena.proto = IPPROTO_UDP; | |
| else if (strcasecmp(keywords[cpt], "tcp") == 0) | |
| cmd_ena.proto = IPPROTO_TCP; | |
| else | |
| goto keyword_error; | |
| } | |
| else | |
| goto keyword_error; | |
| /* auto mode is optional */ | |
| if(keywords[++cpt]) | |
| { | |
| if((strcasecmp(keywords[cpt], "auto") == 0)) | |
| { | |
| cmd_ena.mode = 1; | |
| } | |
| else | |
| goto keyword_error; | |
| } | |
| // Send command | |
| rcvBytes = cmmSendToDaemon(daemon_handle, FPP_CMD_RTP_STATS_ENABLE, &cmd_ena, sizeof(cmd_ena), &rcvBuffer); | |
| if (rcvBytes < sizeof(unsigned short)) | |
| { | |
| cmm_print(DEBUG_CRIT, "Short message received from FPP \n"); | |
| goto out; | |
| } | |
| if ((((unsigned short*)rcvBuffer)[0]) != 0) | |
| { | |
| cmm_print(DEBUG_CRIT, "ERROR: %s (%d) received from FPP for CMD_RTP_STATS_ENABLE\n", getErrorString(((unsigned short*)rcvBuffer)[0]), ((unsigned short*)rcvBuffer)[0]); | |
| goto out; | |
| } | |
| } | |
| else if((strcasecmp(keywords[cpt], "disable") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| if(strcasecmp(keywords[cpt], "id") == 0) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > USHRT_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "ERROR: stream ID parameter must be a number between 0 and %d\n", USHRT_MAX); | |
| goto print_help; | |
| } | |
| cmd_dis.stream_id = tmp; | |
| } | |
| else | |
| goto keyword_error; | |
| // Send command | |
| rcvBytes = cmmSendToDaemon(daemon_handle, FPP_CMD_RTP_STATS_DISABLE, &cmd_dis, sizeof(cmd_dis), &rcvBuffer); | |
| if (rcvBytes < sizeof(unsigned short)) | |
| { | |
| cmm_print(DEBUG_CRIT, "Short message received from FPP \n"); | |
| goto out; | |
| } | |
| if ((((unsigned short*)rcvBuffer)[0]) != 0) | |
| { | |
| cmm_print(DEBUG_CRIT, "ERROR: %s (%d) received from FPP for CMD_RTP_STATS_DISABLE\n", getErrorString(((unsigned short*)rcvBuffer)[0]), ((unsigned short*)rcvBuffer)[0]); | |
| goto out; | |
| } | |
| } | |
| else if((strcasecmp(keywords[cpt], "dtmf_relay") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > 255)) | |
| { | |
| cmm_print(DEBUG_CRIT, "ERROR: payload type parameter must be a number between 0 and %d\n", 255); | |
| goto print_help; | |
| } | |
| pt_low = (0x00FF & tmp); | |
| /* if only one parameter specified, re-used first one */ | |
| if(!keywords[++cpt]) | |
| pt_high = pt_low; | |
| else | |
| { | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > 255)) | |
| { | |
| cmm_print(DEBUG_CRIT, "ERROR: payload type parameter must be a number between 0 and %d\n", 255); | |
| goto print_help; | |
| } | |
| pt_high = (0x00FF & tmp); | |
| /* make sure values are ordered */ | |
| if(pt_high < pt_low) | |
| { | |
| pt_high = pt_low; | |
| pt_low = (0x00FF & tmp); | |
| } | |
| } | |
| cmd_dtmf_pt.pt = (pt_high << 8) | pt_low; | |
| // Send command | |
| rcvBytes = cmmSendToDaemon(daemon_handle, FPP_CMD_RTP_STATS_DTMF_PT, &cmd_dtmf_pt, sizeof(cmd_dtmf_pt), &rcvBuffer); | |
| if (rcvBytes < sizeof(unsigned short)) | |
| { | |
| cmm_print(DEBUG_CRIT, "Short message received from FPP \n"); | |
| goto out; | |
| } | |
| if ((((unsigned short*)rcvBuffer)[0]) != 0) | |
| { | |
| cmm_print(DEBUG_CRIT, "ERROR: %s (%d) received from FPP for CMD_RTP_STATS_DTMF_PT\n", getErrorString(((unsigned short*)rcvBuffer)[0]), ((unsigned short*)rcvBuffer)[0]); | |
| goto out; | |
| } | |
| } | |
| else | |
| { | |
| goto keyword_error; | |
| } | |
| out: | |
| return 0; | |
| keyword_error: | |
| cmm_print(DEBUG_STDOUT,"ERROR: unknown keyword %s\n", keywords[cpt]); | |
| print_help: | |
| cmmRTPStatsSetUsage(); | |
| return -1; | |
| } | |
| int cmmRTPStatsQueryProcess(char ** keywords, int tabStart, daemon_handle_t daemon_handle) | |
| { | |
| int cpt = tabStart; | |
| /* TO CLEAN: Temporary fix for alignment */ | |
| char rcvBuffer[256] __attribute__ ((aligned (4))); | |
| fpp_rtcp_query_cmd_t cmd; | |
| fpp_rtcp_query_res_t *rsp = (fpp_rtcp_query_res_t*)(rcvBuffer + 4); | |
| unsigned int tmp; | |
| char * endptr; | |
| int rcvBytes; | |
| if(!keywords[cpt]) | |
| goto print_help; | |
| if((strcasecmp(keywords[cpt], "id") == 0)) | |
| { | |
| if(!keywords[++cpt]) | |
| goto print_help; | |
| memset(&cmd, 0, sizeof(cmd)); | |
| /*Get an integer from the string*/ | |
| endptr = NULL; | |
| tmp = strtoul(keywords[cpt], &endptr, 0); | |
| if ((keywords[cpt] == endptr) || (tmp > USHRT_MAX)) | |
| { | |
| cmm_print(DEBUG_CRIT, "rtpstats: stream id must be a number between 0 and %d\n", USHRT_MAX); | |
| goto print_help; | |
| } | |
| cmd.socket_id = tmp; | |
| if(keywords[++cpt]) | |
| { | |
| if(strcasecmp(keywords[cpt++], "reset") == 0) | |
| { | |
| if(!keywords[cpt]) | |
| cmd.flags = 0x1; //default is full reset | |
| else if(strcasecmp(keywords[cpt], "full") == 0) | |
| cmd.flags = 0x1; | |
| else if(strcasecmp(keywords[cpt], "partial") == 0) | |
| cmd.flags = 0x2; | |
| } | |
| else | |
| goto print_help; | |
| } | |
| } | |
| else | |
| goto keyword_error; | |
| // Send command | |
| rcvBytes = cmmSendToDaemon(daemon_handle, FPP_CMD_RTP_STATS_QUERY, &cmd, sizeof(cmd), rcvBuffer + 2); | |
| if (rcvBytes < sizeof(unsigned short)) | |
| { | |
| cmm_print(DEBUG_CRIT, "Short message received from FPP \n"); | |
| goto out; | |
| } | |
| if ((((unsigned short*)rcvBuffer)[1]) != 0) | |
| { | |
| cmm_print(DEBUG_CRIT, "Error: %s (%d) received from FPP for CMD_RTP_STATS_QUERY\n", getErrorString(((unsigned short*)rcvBuffer)[1]), ((unsigned short*)rcvBuffer)[1]); | |
| goto out; | |
| } | |
| if (rcvBytes < (sizeof(fpp_rtcp_query_res_t) + sizeof(unsigned short))) | |
| { | |
| cmm_print(DEBUG_CRIT, "Short message received from FPP \n"); | |
| goto out; | |
| } | |
| cmm_print(DEBUG_STDOUT, "RTP Statistics (sport %u dport %u)\n\n" | |
| "prev_reception_period(ms) : %u\n" | |
| "last_reception_period(ms) : %u\n" | |
| "num_tx_pkts : %u\n" | |
| "num_rx_pkts : %u\n" | |
| "last_rx_Seq : %u\n" | |
| "last_rx_TimeStamp : %u\n" | |
| "RTP_header : %x %x %x %x %x %x %x %x %x %x %x %x\n" | |
| "num_dup_rx : %u\n" | |
| "num_rx_since_RTCP : %u\n" | |
| "num_tx_bytes : %u\n" | |
| "min_jitter(us) : %u\n" | |
| "max_jitter(us) : %u\n" | |
| "average_jitter(us) : %u\n" | |
| "num_rx_lost_pkts : %u\n" | |
| "num_cumulative_rx_lost_pkts : %u\n" | |
| "min_reception_period(us) : %u\n" | |
| "max_reception_period(us) : %u\n" | |
| "average_reception_period(us) : %u\n" | |
| "num_malformed_pkts : %u\n" | |
| "num_expected_pkts : %u\n" | |
| "num_late_pkts : %u\n", | |
| ntohs(rsp->sport), | |
| ntohs(rsp->dport), | |
| rsp->prev_reception_period, | |
| rsp->last_reception_period, | |
| rsp->num_tx_pkts, | |
| rsp->num_rx_pkts, | |
| rsp->last_rx_seq, | |
| rsp->last_rx_timestamp, | |
| rsp->rtp_header[0], rsp->rtp_header[1], rsp->rtp_header[2], rsp->rtp_header[3], rsp->rtp_header[4], rsp->rtp_header[5], | |
| rsp->rtp_header[6], rsp->rtp_header[7], rsp->rtp_header[8], rsp->rtp_header[9], rsp->rtp_header[10], rsp->rtp_header[11], | |
| rsp->num_rx_dup, | |
| rsp->num_rx_since_rtcp, | |
| rsp->num_tx_bytes, | |
| rsp->min_jitter, rsp->max_jitter, rsp->average_jitter, | |
| rsp->num_rx_lost_pkts, | |
| rsp->num_cumulative_rx_lost_pkts, | |
| rsp->min_reception_period, | |
| rsp->max_reception_period, | |
| rsp->average_reception_period, | |
| rsp->num_malformed_pkts, | |
| rsp->num_expected_pkts, | |
| rsp->num_late_pkts | |
| ); | |
| out: | |
| return 0 ; | |
| keyword_error: | |
| cmm_print(DEBUG_STDOUT,"ERR: unknown keyword %s\n", keywords[cpt]); | |
| print_help: | |
| cmmRTPStatsQueryUsage(); | |
| return -1; | |
| } | |