rtsp

type ClientType int

type CommandError string

type MediaType int

type NetSession struct {
	protocolinterface.BasicNetSession
	SessionType                  ClientType                       // type for pusher or puller
	AudioStreamName              string                           // audio stream name
	VideoStreamName              string                           // video stream name
	RtspURL                      *url.URL                         // resource path in url
	PusherPullersSessionMap      map[string]*PusherPullersSession // map url's resource to sessions
	PusherPullersSessionMapMutex *sync.Mutex                      // provide ResourceMap's atom
	SdpContent                   string                           // sdp raw data from announce request
	ReourcePath                  string                           // Resource Path of request url
	// contains filtered or unexported fields
}

type Package struct {
	protocolinterface.NetPackage
	RtspHeaderMap map[string]string
	Method        string
	URL           string
	Version       string
	Content       []byte
	ResponseInfo
}

type PackageType int

type PullerClientInfo struct {
	RtpRemotePort, RtcpRemotePort, IPRemote *string
}

type PusherPullersPair struct {
	Pusher       *RtpRtcpSession
	Pullers      *list.List
	PullersMutex sync.Mutex

	IfStop bool
	// contains filtered or unexported fields
}

type PusherPullersSession struct {
	PusherPullersPairMap map[MediaType]*PusherPullersPair // has vidio and audio
	SdpMessage           *sdp.Message                     // sdp info from pusher
	SdpContent           *string                          // sdp raw content
	AudioStreamName      *string                          // audio stream name from sdp content
	VideoStreamName      *string                          // video stream name from sdp content
}

type ResponseInfo struct {
	Error           CommandError
	OptionsMethods  string
	SetupTransport  string
	DescribeContent string
}

type RtpRtcpPackage []byte

type RtpRtcpSession struct {
	RtspSessionID       string               // identification of rtsp session
	RtpUDPConnToPuller  *net.UDPConn         // rtp udp connection to puller
	RtcpUDPConnToPuller *net.UDPConn         // rtcp udp connection to puller
	RtpUDPConnToPusher  *net.UDPConn         // rtp udp connection to pusher
	RtcpUDPConnToPusher *net.UDPConn         // rtcp udp connection to pusher
	RtpServerPort       *string              // rtp Server port in udp session
	RtcpServerPort      *string              // rtcp Server port in udp session
	SessionMediaType    MediaType            // this session's media type
	SessionClientType   ClientType           // this session's client type(connected to pusher or puller)
	RtpPackageChannel   chan *RtpRtcpPackage // rtp packages for puller
	RtcpPackageChannel  chan *RtpRtcpPackage // rtcp packages for puller
	IfStop              bool                 // if stop is true,then stop go routines created by this session
	IfPause             bool                 // if pause transfer
}

type Server struct {
	protocolinterface.BasicNet
	PusherPullersSessionMap      map[string]*PusherPullersSession
	PusherPullersSessionMapMutex sync.Mutex
}