static int width = 320;
static int height = 240;
static int bitrate = 1000000;
-int fps = 15;
+int fps = 30;
static const char *impform = "video4linux2";
AVFormatContext *s, *os;
static unsigned max_size = 0, min_size = -1;
static double avg_size = 0;
clock_gettime(CLOCK_MONOTONIC, &start);
+ start.tv_sec--; /* Avoid division by zero */
done = 0;
while (!(done = streamer_run_done_rq)) {
AVPacket *pkt;
pkt = read_input_packet(s);
+
+ clock_gettime(CLOCK_MONOTONIC, &end);
+ timespec_subtract(&d, &end, &start);
+ start = end;
+ int fps_now = (1000<<16)/(d.tv_sec*1000+d.tv_nsec/1000000);
+ fps_avg += (fps_now - fps_avg) >> 4;
+
if (pkt == NULL) {
done = 1;
} else {
//rt_job_start(pkt->pts);
f = pkt_decode(s, pkt);
if (f) {
+ int keyframe;
opkt = pkt_encode(os, f);
+ keyframe = os->streams[0]->codec->coded_frame->key_frame;
if (opkt) {
pkt_send(os, opkt);
- clock_gettime(CLOCK_MONOTONIC, &end);
- timespec_subtract(&d, &end, &start);
- int fps_now = (1000<<8)/(d.tv_sec*1000+d.tv_nsec/1000000);
- start = end;
- fps_avg += (fps_now - fps_avg) >> 3;
-
if (opkt->size > max_size)
max_size = opkt->size;
if (opkt->size < min_size)
min_size = opkt->size;
avg_size = avg_size*frame/(frame+1) + (double)opkt->size/(frame+1);
- printf("%5d: %2d fps opkt size: %5d b max=%5u b min=%5u b avg=%5.0f\n",
- frame,
- fps_avg>>8,
+ printf("%5d%c: %2d (%4.1f) fps opkt size: %5d b max=%5u b min=%5u b avg=%5.0f\n",
+ frame, keyframe ? '*':' ',
+ fps_avg>>16, 1000.0/(d.tv_sec*1000+d.tv_nsec/1000000),
opkt->size, max_size, min_size, avg_size);
if (frame % 100 == 0) max_size=0;
frame++;// = (frame + 1) % fps;
dump_format(os, 0, os->filename, 1);
sdp_print(os, sdp_file);
-#if CONFIG_STREAMER_WITH_FRSH && CONFIG_AQUOSA
+#if CONFIG_FFMPEG_WITH_FRSH
frsh_thread_attr_t frsh_attr;
frsh_thread_id_t thread;
frsh_vres_id_t cpu_vres;
frsh_contract_t cpu_contract;
frsh_rel_time_t cpu_budget, cpu_period;
- cpu_budget = fosa_msec_to_rel_time(50);
- cpu_period = fosa_msec_to_rel_time(100);
+ cpu_budget = fosa_msec_to_rel_time(5);
+ cpu_period = fosa_msec_to_rel_time(1000/fps);
/* Contract negotiation for CPU */
ret = frsh_contract_init(&cpu_contract);
if (ret) PERROR_AND_EXIT(ret, "CPU:frsh_contract_init");
FRSH_CT_REGULAR);
if (ret) PERROR_AND_EXIT(ret, "frsh_contract_set_basic_params");
ret = frsh_contract_set_resource_and_label(&cpu_contract,
- FRSH_RT_PROCESSOR, FRSH_CPU_ID_DEFAULT, "aqcpu_cont");
+ FRSH_RT_PROCESSOR, FRSH_CPU_ID_DEFAULT, "camera_ctrl");
if (ret) PERROR_AND_EXIT(ret, "frsh_contract_set_resource_and_label");
ret = frsh_contract_negotiate(&cpu_contract, &cpu_vres);