102
102
s = "fakesrc can-activate-push=false ! fakesink can-activate-pull=true";
103
103
run_pipeline (setup_pipeline (s), s,
104
104
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |
105
GST_MESSAGE_STREAM_STATUS | GST_MESSAGE_ASYNC_DONE, GST_MESSAGE_UNKNOWN);
105
GST_MESSAGE_STREAM_STATUS | GST_MESSAGE_ASYNC_DONE |
106
GST_MESSAGE_STREAM_START, GST_MESSAGE_UNKNOWN);
107
108
s = "fakesrc can-activate-push=true ! fakesink can-activate-pull=false";
108
109
run_pipeline (setup_pipeline (s), s,
109
110
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |
110
GST_MESSAGE_STREAM_STATUS | GST_MESSAGE_ASYNC_DONE, GST_MESSAGE_UNKNOWN);
111
GST_MESSAGE_STREAM_STATUS | GST_MESSAGE_ASYNC_DONE |
112
GST_MESSAGE_STREAM_START, GST_MESSAGE_UNKNOWN);
112
114
s = "fakesrc can-activate-push=false num-buffers=10 ! fakesink can-activate-pull=true";
113
115
run_pipeline (setup_pipeline (s), s,
114
116
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |
115
GST_MESSAGE_STREAM_STATUS | GST_MESSAGE_ASYNC_DONE, GST_MESSAGE_EOS);
117
GST_MESSAGE_STREAM_STATUS | GST_MESSAGE_ASYNC_DONE |
118
GST_MESSAGE_STREAM_START, GST_MESSAGE_EOS);
117
120
s = "fakesrc can-activate-push=true num-buffers=10 ! fakesink can-activate-pull=false";
118
121
run_pipeline (setup_pipeline (s), s,
119
122
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |
120
GST_MESSAGE_STREAM_STATUS | GST_MESSAGE_ASYNC_DONE, GST_MESSAGE_EOS);
123
GST_MESSAGE_STREAM_STATUS | GST_MESSAGE_ASYNC_DONE |
124
GST_MESSAGE_STREAM_START, GST_MESSAGE_EOS);
122
126
s = "fakesrc can-activate-push=false ! fakesink can-activate-pull=false";
123
127
ASSERT_CRITICAL (run_pipeline (setup_pipeline (s), s,
124
128
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |
125
GST_MESSAGE_STREAM_STATUS | GST_MESSAGE_ASYNC_DONE,
126
GST_MESSAGE_UNKNOWN));
129
GST_MESSAGE_STREAM_STATUS | GST_MESSAGE_ASYNC_DONE |
130
GST_MESSAGE_STREAM_START, GST_MESSAGE_UNKNOWN));
193
197
s = "fakesrc can-activate-push=true ! tee ! fakesink can-activate-push=true";
194
198
run_pipeline (setup_pipeline (s), s,
195
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED, GST_MESSAGE_UNKNOWN);
199
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |
200
GST_MESSAGE_STREAM_START, GST_MESSAGE_UNKNOWN);
197
202
s = "fakesrc can-activate-push=true num-buffers=10 ! tee ! fakesink can-activate-push=true";
198
203
run_pipeline (setup_pipeline (s), s,
199
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED, GST_MESSAGE_EOS);
204
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |
205
GST_MESSAGE_STREAM_START, GST_MESSAGE_EOS);
201
207
s = "fakesrc can-activate-push=false can-activate-pull=true ! tee ! fakesink can-activate-pull=true";
202
208
ASSERT_CRITICAL (run_pipeline (setup_pipeline (s), s,
203
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED,
204
GST_MESSAGE_UNKNOWN));
209
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |
210
GST_MESSAGE_STREAM_START, GST_MESSAGE_UNKNOWN));
206
212
s = "fakesrc can-activate-push=false can-activate-pull=true "
207
213
"! tee pull-mode=single ! fakesink can-activate-pull=true";
208
214
run_pipeline (setup_pipeline (s), s,
209
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED, GST_MESSAGE_UNKNOWN);
215
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |
216
GST_MESSAGE_STREAM_START, GST_MESSAGE_UNKNOWN);
211
218
s = "fakesrc can-activate-push=false can-activate-pull=true num-buffers=10 "
212
219
"! tee pull-mode=single ! fakesink can-activate-pull=true";
213
220
run_pipeline (setup_pipeline (s), s,
214
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED, GST_MESSAGE_EOS);
221
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |
222
GST_MESSAGE_STREAM_START, GST_MESSAGE_EOS);
216
224
s = "fakesrc can-activate-push=false can-activate-pull=true "
217
225
"! tee name=t pull-mode=single ! fakesink can-activate-pull=true "
218
226
"t. ! queue ! fakesink can-activate-pull=true can-activate-push=false";
219
227
ASSERT_CRITICAL (run_pipeline (setup_pipeline (s), s,
220
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED,
221
GST_MESSAGE_UNKNOWN));
228
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |
229
GST_MESSAGE_STREAM_START, GST_MESSAGE_UNKNOWN));
223
231
s = "fakesrc can-activate-push=false can-activate-pull=true "
224
232
"! tee name=t pull-mode=single ! fakesink can-activate-pull=true "
225
233
"t. ! queue ! fakesink";
226
234
run_pipeline (setup_pipeline (s), s,
227
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED, GST_MESSAGE_UNKNOWN);
235
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |
236
GST_MESSAGE_STREAM_START, GST_MESSAGE_UNKNOWN);
229
238
s = "fakesrc can-activate-push=false can-activate-pull=true num-buffers=10 "
230
239
"! tee name=t pull-mode=single ! fakesink can-activate-pull=true "
231
240
"t. ! queue ! fakesink";
232
241
run_pipeline (setup_pipeline (s), s,
233
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED, GST_MESSAGE_EOS);
242
GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |
243
GST_MESSAGE_STREAM_START, GST_MESSAGE_EOS);