From 109ffe9a777658936a38d0c146579a67c60a0d17 Mon Sep 17 00:00:00 2001 From: xuxiuxi <xuxiuxi@454eff88-639b-444f-9e54-f578c98de674> Date: 星期四, 11 五月 2017 17:48:48 +0800 Subject: [PATCH] --- VisitFace/RtspNativeCodec/app/libs/live555/include/groupsock/GroupsockHelper.hh | 146 ++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 146 insertions(+), 0 deletions(-) diff --git a/VisitFace/RtspNativeCodec/app/libs/live555/include/groupsock/GroupsockHelper.hh b/VisitFace/RtspNativeCodec/app/libs/live555/include/groupsock/GroupsockHelper.hh new file mode 100644 index 0000000..8ca4275 --- /dev/null +++ b/VisitFace/RtspNativeCodec/app/libs/live555/include/groupsock/GroupsockHelper.hh @@ -0,0 +1,146 @@ +/********** +This library is free software; you can redistribute it and/or modify it under +the terms of the GNU Lesser General Public License as published by the +Free Software Foundation; either version 3 of the License, or (at your +option) any later version. (See <http://www.gnu.org/copyleft/lesser.html>.) + +This library 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 Lesser General Public License for +more details. + +You should have received a copy of the GNU Lesser General Public License +along with this library; if not, write to the Free Software Foundation, Inc., +51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA +**********/ +// "mTunnel" multicast access service +// Copyright (c) 1996-2017 Live Networks, Inc. All rights reserved. +// Helper routines to implement 'group sockets' +// C++ header + +#ifndef _GROUPSOCK_HELPER_HH +#define _GROUPSOCK_HELPER_HH + +#ifndef _NET_ADDRESS_HH +#include "NetAddress.hh" +#endif + +int setupDatagramSocket(UsageEnvironment& env, Port port); +int setupStreamSocket(UsageEnvironment& env, + Port port, Boolean makeNonBlocking = True); + +int readSocket(UsageEnvironment& env, + int socket, unsigned char* buffer, unsigned bufferSize, + struct sockaddr_in& fromAddress); + +Boolean writeSocket(UsageEnvironment& env, + int socket, struct in_addr address, portNumBits portNum/*network byte order*/, + u_int8_t ttlArg, + unsigned char* buffer, unsigned bufferSize); + +Boolean writeSocket(UsageEnvironment& env, + int socket, struct in_addr address, portNumBits portNum/*network byte order*/, + unsigned char* buffer, unsigned bufferSize); + // An optimized version of "writeSocket" that omits the "setsockopt()" call to set the TTL. + +void ignoreSigPipeOnSocket(int socketNum); + +unsigned getSendBufferSize(UsageEnvironment& env, int socket); +unsigned getReceiveBufferSize(UsageEnvironment& env, int socket); +unsigned setSendBufferTo(UsageEnvironment& env, + int socket, unsigned requestedSize); +unsigned setReceiveBufferTo(UsageEnvironment& env, + int socket, unsigned requestedSize); +unsigned increaseSendBufferTo(UsageEnvironment& env, + int socket, unsigned requestedSize); +unsigned increaseReceiveBufferTo(UsageEnvironment& env, + int socket, unsigned requestedSize); + +Boolean makeSocketNonBlocking(int sock); +Boolean makeSocketBlocking(int sock, unsigned writeTimeoutInMilliseconds = 0); + // A "writeTimeoutInMilliseconds" value of 0 means: Don't timeout + +Boolean socketJoinGroup(UsageEnvironment& env, int socket, + netAddressBits groupAddress); +Boolean socketLeaveGroup(UsageEnvironment&, int socket, + netAddressBits groupAddress); + +// source-specific multicast join/leave +Boolean socketJoinGroupSSM(UsageEnvironment& env, int socket, + netAddressBits groupAddress, + netAddressBits sourceFilterAddr); +Boolean socketLeaveGroupSSM(UsageEnvironment&, int socket, + netAddressBits groupAddress, + netAddressBits sourceFilterAddr); + +Boolean getSourcePort(UsageEnvironment& env, int socket, Port& port); + +netAddressBits ourIPAddress(UsageEnvironment& env); // in network order + +// IP addresses of our sending and receiving interfaces. (By default, these +// are INADDR_ANY (i.e., 0), specifying the default interface.) +extern netAddressBits SendingInterfaceAddr; +extern netAddressBits ReceivingInterfaceAddr; + +// Allocates a randomly-chosen IPv4 SSM (multicast) address: +netAddressBits chooseRandomIPv4SSMAddress(UsageEnvironment& env); + +// Returns a simple "hh:mm:ss" string, for use in debugging output (e.g.) +char const* timestampString(); + + +#ifdef HAVE_SOCKADDR_LEN +#define SET_SOCKADDR_SIN_LEN(var) var.sin_len = sizeof var +#else +#define SET_SOCKADDR_SIN_LEN(var) +#endif + +#define MAKE_SOCKADDR_IN(var,adr,prt) /*adr,prt must be in network order*/\ + struct sockaddr_in var;\ + var.sin_family = AF_INET;\ + var.sin_addr.s_addr = (adr);\ + var.sin_port = (prt);\ + SET_SOCKADDR_SIN_LEN(var); + + +// By default, we create sockets with the SO_REUSE_* flag set. +// If, instead, you want to create sockets without the SO_REUSE_* flags, +// Then enclose the creation code with: +// { +// NoReuse dummy; +// ... +// } +class NoReuse { +public: + NoReuse(UsageEnvironment& env); + ~NoReuse(); + +private: + UsageEnvironment& fEnv; +}; + + +// Define the "UsageEnvironment"-specific "groupsockPriv" structure: + +struct _groupsockPriv { // There should be only one of these allocated + HashTable* socketTable; + int reuseFlag; +}; +_groupsockPriv* groupsockPriv(UsageEnvironment& env); // allocates it if necessary +void reclaimGroupsockPriv(UsageEnvironment& env); + + +#if (defined(__WIN32__) || defined(_WIN32)) && !defined(__MINGW32__) +// For Windoze, we need to implement our own gettimeofday() +extern int gettimeofday(struct timeval*, int*); +#else +#include <sys/time.h> +#endif + +// The following are implemented in inet.c: +extern "C" netAddressBits our_inet_addr(char const*); +extern "C" void our_srandom(int x); +extern "C" long our_random(); +extern "C" u_int32_t our_random32(); // because "our_random()" returns a 31-bit number + +#endif -- Gitblit v1.8.0