|
@@ -227,9 +227,9 @@ void ts_write_packets(struct ts *ts, uint8_t *data, ssize_t data_len) {
|
227
|
227
|
uint16_t pid = ts_packet_get_pid(ts_packet);
|
228
|
228
|
if (ts->pid_filter) {
|
229
|
229
|
if (pidmap_get(&ts->pidmap, pid)) // PAT or allowed PIDs
|
230
|
|
- write(1, ts_packet, 188);
|
|
230
|
+ write(ts->output_fd, ts_packet, 188);
|
231
|
231
|
} else {
|
232
|
|
- write(1, ts_packet, 188);
|
|
232
|
+ write(ts->output_fd, ts_packet, 188);
|
233
|
233
|
}
|
234
|
234
|
}
|
235
|
235
|
}
|
|
@@ -249,7 +249,7 @@ int main(int argc, char **argv) {
|
249
|
249
|
|
250
|
250
|
camd35_connect(&ts.camd35);
|
251
|
251
|
do {
|
252
|
|
- readen = read(0, ts_packet, FRAME_SIZE);
|
|
252
|
+ readen = read(ts.input_fd, ts_packet, FRAME_SIZE);
|
253
|
253
|
if (readen > 0) {
|
254
|
254
|
ts_process_packets(&ts, ts_packet, readen);
|
255
|
255
|
ts_write_packets(&ts, ts_packet, readen);
|