rtsp-server/RTSP_state_machine.cpp at master · widefire/rtsp-server · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
#include "RTSP_server.h"
#include "taskSendRtspResbData.h"
#include "taskSchedule.h"

int RTSP_state_machine(LP_RTSP_buffer rtsp,RTSP_CMD_STATE method)
{
	int iRet=0;
	do
	{
		char	*s;
		LP_RTSP_session	pSession=nullptr;
		char session_id[64];
		char	trash[256];
		//非合控制:
		//一个track对应一个session，一个RTSP连接可同时多个session;
		//setup返回流对应的session,ssrc 接收端根据SSRC来判断是音频还是视频;
		//play方法启动所有已经SETUP成功的track;
		//合控制:
		/*此种前提下，服务器有可以被当作一个整体控制的多个流。
		在此情况下，就即有用于给出流URL的媒体级"a=control:"属性，又有用作合控制的请求URL的会话级"a=control:"。
		如果媒体级URL是相对URL，它将根据上文C1.1节所述被处理为绝对URL。
		如果表示只由单个流组成，媒体级"a=control:"将被全部忽略。
		但是，如果表示包含多于一个流，每个媒体流部分【必须】包含自己的"a=control:"属性。*/
		//a=control:rtsp://example.com/movie/
		//有session
		if ((s=strstr(rtsp->in_buffer,HDR_SESSION))!=0)
		{
			if (sscanf(s,"%254s %s",trash,&session_id)!=2)
			{
				RTSP_send_err_reply(454,0,rtsp);
				iRet=-1;
				break;
			}
			std::list<LP_RTSP_session>::iterator it;
			for (it=rtsp->session_list.begin();it!=rtsp->session_list.end(); it++)
			{
				if (strcmp(session_id,(*it)->session_id.c_str())==0)
				{
					pSession = *it;
					break;
				}
			}
		}else
		{
			//没有session,采用默认session;
			pSession=*rtsp->session_list.begin();
		}
		if (pSession==nullptr)
		{
			pSession = *rtsp->session_list.begin();
		}

		char reply[RTSP_BUFFER_SIZE];
		taskSendRtspResbData *sendTask = nullptr;
		switch (pSession->cur_state)
		{
		case INIT_STAT:
			switch (method)
			{
			case RTSP_ID_DESCRIBE:
				iRet=RTSP_DESCRIBE(rtsp);
				break;
			case RTSP_ID_SETUP:
				iRet=RTSP_SETUP(rtsp,pSession);
				if (iRet==0)
				{
					pSession->cur_state=READY_STAT;
				}
				break;
			case RTSP_ID_TEARDOWN:
				iRet=RTSP_TEARDOWN(rtsp,pSession);
				break;
			case RTSP_ID_OPTIONS:
				iRet=RTSP_OPTIONS(rtsp);
				if (iRet==0)
				{
					pSession->cur_state=INIT_STAT;
				}
				break;
			case RTSP_ID_PLAY:
			case RTSP_ID_PAUSE:
				RTSP_send_err_reply(455, "Accept: OPTIONS, DESCRIBE, SETUP, TEARDOWN\n", rtsp);
				break;
			default:
				RTSP_send_err_reply(501, "Accept: OPTIONS, DESCRIBE, SETUP, TEARDOWN\n", rtsp);
				break;
			}
			break;
		case READY_STAT:
			switch(method)
			{
			case RTSP_ID_PLAY:
				iRet=RTSP_PLAY(rtsp,pSession);
				if (iRet==0)
				{
					pSession->cur_state=PLAY_STAT;
				}
				break;
			case RTSP_ID_SETUP:
				iRet = RTSP_SETUP(rtsp, pSession);
				if (iRet == 0)
				{
					pSession->cur_state = READY_STAT;
				}
				break;
			case RTSP_ID_TEARDOWN:
				iRet = RTSP_TEARDOWN(rtsp, pSession);
				break;
			default:
				RTSP_send_err_reply(501, "Accept: OPTIONS, SETUP, PLAY, TEARDOWN\n", rtsp);
				break;
			}break;
		case PLAY_STAT:
			switch (method)
			{
			case RTSP_ID_BAD_REQ:
				break;
			case RTSP_ID_DESCRIBE:
				break;
			case RTSP_ID_ANNOUNCE:
				break;
			case RTSP_ID_GET_PARAMETERS:
				break;
			case RTSP_ID_OPTIONS:
				//由于正在播放状态，这里发送socket很可能会出错，叫streamSource自身去响应
				//RTSP_send_err_reply(551, "Accept: PAUSE, TEARDOWN\n", rtsp);
				sprintf(reply, "%s %d %s" RTSP_EL"CSeq: %d", RTSP_VER, 551, get_stat(551), rtsp->rtsp_seq);
				strcat(reply, RTSP_EL RTSP_EL);
				sendTask = new taskSendRtspResbData(reply, rtsp->session_list.front()->session_id);
				taskSchedule::getInstance().addTaskObj(sendTask);
				break;
			case RTSP_ID_PAUSE:
				LOG_INFO(configData::getInstance().get_loggerId(),"RTSP pause in play state");
				iRet = RTSP_PAUSE(rtsp,pSession);
				if (iRet==0)
				{
					pSession->cur_state = READY_STAT;
				}
				break;
			case RTSP_ID_PLAY:
				break;
			case RTSP_ID_RECORD:
				break;
			case RTSP_ID_REDIRECT:
				break;
			case RTSP_ID_SETUP:
				break;
			case RTSP_ID_SET_PARAMETER:
				break;
			case RTSP_ID_TEARDOWN:
				iRet = RTSP_TEARDOWN(rtsp, pSession);
				break;
			default:
				break;
			}
		default:
			break;
		}
	} while (0);
	return iRet;
}