From 1b5afb45838e603fa6780762eb8cc59246dc2d81 Mon Sep 17 00:00:00 2001
From: IlyaOvodov <b@ovdv.ru>
Date: Tue, 08 May 2018 11:09:35 +0000
Subject: [PATCH] Output improvements for detector results: When printing detector results, output was done in random order, obfuscating results for interpreting. Now: 1. Text output includes coordinates of rects in (left,right,top,bottom in pixels) along with label and score 2. Text output is sorted by rect lefts to simplify finding appropriate rects on image 3. If several class probs are > thresh for some detection, the most probable is written first and coordinates for others are not repeated 4. Rects are imprinted in image in order by their best class prob, so most probable rects are always on top and not overlayed by less probable ones 5. Most probable label for rect is always written first Also: 6. Message about low GPU memory include required amount

---
 src/demo.c |  117 +++++++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 94 insertions(+), 23 deletions(-)

diff --git a/src/demo.c b/src/demo.c
index 49e08c2..4aee54f 100644
--- a/src/demo.c
+++ b/src/demo.c
@@ -24,6 +24,7 @@
 #ifndef CV_VERSION_EPOCH
 #include "opencv2/videoio/videoio_c.h"
 #endif
+#include "http_stream.h"
 image get_image_from_stream(CvCapture *cap);
 
 static char **demo_names;
@@ -39,6 +40,7 @@
 static image det_s;
 static image disp = {0};
 static CvCapture * cap;
+static int use_webcam = 0;
 static float fps = 0;
 static float demo_thresh = 0;
 
@@ -49,17 +51,24 @@
 static float *avg;
 
 void draw_detections_cv(IplImage* show_img, int num, float thresh, box *boxes, float **probs, char **names, image **alphabet, int classes);
-image get_image_from_stream_resize(CvCapture *cap, int w, int h, IplImage** in_img);
+void draw_detections_cv_v3(IplImage* show_img, detection *dets, int num, float thresh, char **names, image **alphabet, int classes);
+void show_image_cv_ipl(IplImage *disp, const char *name);
+image get_image_from_stream_resize(CvCapture *cap, int w, int h, IplImage** in_img, int use_webcam);
 IplImage* in_img;
 IplImage* det_img;
 IplImage* show_img;
 
+static int flag_exit;
+
 void *fetch_in_thread(void *ptr)
 {
     //in = get_image_from_stream(cap);
-	in = get_image_from_stream_resize(cap, net.w, net.h, &in_img);
+	in = get_image_from_stream_resize(cap, net.w, net.h, &in_img, use_webcam);
     if(!in.data){
-        error("Stream closed.");
+        //error("Stream closed.");
+		printf("Stream closed.\n");
+		flag_exit = 1;
+		return EXIT_FAILURE;
     }
     //in_s = resize_image(in, net.w, net.h);
 	in_s = make_image(in.w, in.h, in.c);
@@ -70,7 +79,7 @@
 
 void *detect_in_thread(void *ptr)
 {
-    float nms = .4;
+    float nms = .45;	// 0.4F
 
     layer l = net.layers[net.n-1];
     float *X = det_s.data;
@@ -81,6 +90,7 @@
     l.output = avg;
 
     free_image(det_s);
+	/*
     if(l.type == DETECTION){
         get_detection_boxes(l, 1, 1, demo_thresh, probs, boxes, 0);
     } else if (l.type == REGION){
@@ -89,6 +99,12 @@
         error("Last layer must produce detections\n");
     }
     if (nms > 0) do_nms(boxes, probs, l.w*l.h*l.n, l.classes, nms);
+	*/
+	int letter = 0;
+	int nboxes = 0;
+	detection *dets = get_network_boxes(&net, det.w, det.h, demo_thresh, demo_thresh, 0, 1, &nboxes, letter);
+	if (nms) do_nms_obj(dets, nboxes, l.classes, nms);
+
     printf("\033[2J");
     printf("\033[1;1H");
     printf("\nFPS:%.1f\n",fps);
@@ -101,7 +117,9 @@
     demo_index = (demo_index + 1)%FRAMES;
 	    
 	//draw_detections(det, l.w*l.h*l.n, demo_thresh, boxes, probs, demo_names, demo_alphabet, demo_classes);
-	draw_detections_cv(det_img, l.w*l.h*l.n, demo_thresh, boxes, probs, demo_names, demo_alphabet, demo_classes);
+	draw_detections_cv_v3(det_img, dets, nboxes, demo_thresh, demo_names, demo_alphabet, demo_classes);
+	//draw_detections_cv(det_img, l.w*l.h*l.n, demo_thresh, boxes, probs, demo_names, demo_alphabet, demo_classes);
+	free(dets);
 
 	return 0;
 }
@@ -115,7 +133,8 @@
     return (double)time.tv_sec + (double)time.tv_usec * .000001;
 }
 
-void demo(char *cfgfile, char *weightfile, float thresh, int cam_index, const char *filename, char **names, int classes, int frame_skip, char *prefix)
+void demo(char *cfgfile, char *weightfile, float thresh, float hier_thresh, int cam_index, const char *filename, char **names, int classes,
+	int frame_skip, char *prefix, char *out_filename, int http_stream_port, int dont_show)
 {
     //skip = frame_skip;
     image **alphabet = load_alphabet();
@@ -125,19 +144,25 @@
     demo_classes = classes;
     demo_thresh = thresh;
     printf("Demo\n");
-    net = parse_network_cfg(cfgfile);
+    net = parse_network_cfg_custom(cfgfile, 1);	// set batch=1
     if(weightfile){
         load_weights(&net, weightfile);
     }
-    set_batch_network(&net, 1);
-
+    //set_batch_network(&net, 1);
+	fuse_conv_batchnorm(net);
     srand(2222222);
 
     if(filename){
         printf("video file: %s\n", filename);
         cap = cvCaptureFromFile(filename);
     }else{
+		printf("Webcam index: %d\n", cam_index);
+#ifdef CV_VERSION_EPOCH	// OpenCV 2.x
         cap = cvCaptureFromCAM(cam_index);
+#else					// OpenCV 3.x
+		use_webcam = 1;
+		cap = get_capture_webcam(cam_index);
+#endif
     }
 
     if(!cap) error("Couldn't connect to webcam.\n");
@@ -153,6 +178,8 @@
     probs = (float **)calloc(l.w*l.h*l.n, sizeof(float *));
     for(j = 0; j < l.w*l.h*l.n; ++j) probs[j] = (float *)calloc(l.classes, sizeof(float *));
 
+	flag_exit = 0;
+
     pthread_t fetch_thread;
     pthread_t detect_thread;
 
@@ -178,12 +205,28 @@
     }
 
     int count = 0;
-    if(!prefix){
+    if(!prefix && !dont_show){
         cvNamedWindow("Demo", CV_WINDOW_NORMAL); 
         cvMoveWindow("Demo", 0, 0);
         cvResizeWindow("Demo", 1352, 1013);
     }
 
+	CvVideoWriter* output_video_writer = NULL;    // cv::VideoWriter output_video;
+	if (out_filename && !flag_exit)
+	{
+		CvSize size;
+		size.width = det_img->width, size.height = det_img->height;
+
+		//const char* output_name = "test_dnn_out.avi";
+		//output_video_writer = cvCreateVideoWriter(out_filename, CV_FOURCC('H', '2', '6', '4'), 25, size, 1);
+		output_video_writer = cvCreateVideoWriter(out_filename, CV_FOURCC('D', 'I', 'V', 'X'), 25, size, 1);
+		//output_video_writer = cvCreateVideoWriter(out_filename, CV_FOURCC('M', 'J', 'P', 'G'), 25, size, 1);
+		//output_video_writer = cvCreateVideoWriter(out_filename, CV_FOURCC('M', 'P', '4', 'V'), 25, size, 1);
+		//output_video_writer = cvCreateVideoWriter(out_filename, CV_FOURCC('M', 'P', '4', '2'), 25, size, 1);
+		//output_video_writer = cvCreateVideoWriter(out_filename, CV_FOURCC('X', 'V', 'I', 'D'), 25, size, 1);
+		//output_video_writer = cvCreateVideoWriter(out_filename, CV_FOURCC('W', 'M', 'V', '2'), 25, size, 1);
+	}
+
     double before = get_wall_time();
 
     while(1){
@@ -192,25 +235,45 @@
             if(pthread_create(&fetch_thread, 0, fetch_in_thread, 0)) error("Thread creation failed");
             if(pthread_create(&detect_thread, 0, detect_in_thread, 0)) error("Thread creation failed");
 
-            if(!prefix){                
-				//show_image(disp, "Demo");
-				show_image_cv_ipl(show_img, "Demo");
-                int c = cvWaitKey(1);
-                if (c == 10){
-                    if(frame_skip == 0) frame_skip = 60;
-                    else if(frame_skip == 4) frame_skip = 0;
-                    else if(frame_skip == 60) frame_skip = 4;   
-                    else frame_skip = 0;
-                }
+            if(!prefix){
+				if (!dont_show) {
+					show_image_cv_ipl(show_img, "Demo");
+					int c = cvWaitKey(1);
+					if (c == 10) {
+						if (frame_skip == 0) frame_skip = 60;
+						else if (frame_skip == 4) frame_skip = 0;
+						else if (frame_skip == 60) frame_skip = 4;
+						else frame_skip = 0;
+					}
+				}
             }else{
                 char buff[256];
                 sprintf(buff, "%s_%08d", prefix, count);
                 save_image(disp, buff);
             }
 
+			// if you run it with param -http_port 8090  then open URL in your web-browser: http://localhost:8090
+			if (http_stream_port > 0 && show_img) {
+				//int port = 8090;
+				int port = http_stream_port;
+				int timeout = 200;
+				int jpeg_quality = 30;	// 1 - 100
+				send_mjpeg(show_img, port, timeout, jpeg_quality);
+			}
+
+			// save video file
+			if (output_video_writer && show_img) {
+				cvWriteFrame(output_video_writer, show_img);
+				printf("\n cvWriteFrame \n");
+			}
+
+			cvReleaseImage(&show_img);
+
             pthread_join(fetch_thread, 0);
             pthread_join(detect_thread, 0);
 
+			if (flag_exit == 1) break;
+
             if(delay == 0){
                 free_image(disp);
                 disp  = det;
@@ -229,8 +292,10 @@
                 free_image(disp);
                 disp = det;
             }
-            show_image(disp, "Demo");
-            cvWaitKey(1);
+			if (!dont_show) {
+				show_image(disp, "Demo");
+				cvWaitKey(1);
+			}
         }
         --delay;
         if(delay < 0){
@@ -242,9 +307,15 @@
             before = after;
         }
     }
+	printf("input video stream closed. \n");
+	if (output_video_writer) {
+		cvReleaseVideoWriter(&output_video_writer);
+		printf("output_video_writer closed. \n");
+	}
 }
 #else
-void demo(char *cfgfile, char *weightfile, float thresh, int cam_index, const char *filename, char **names, int classes, int frame_skip, char *prefix)
+void demo(char *cfgfile, char *weightfile, float thresh, float hier_thresh, int cam_index, const char *filename, char **names, int classes,
+	int frame_skip, char *prefix, char *out_filename, int http_stream_port, int dont_show)
 {
     fprintf(stderr, "Demo needs OpenCV for webcam images.\n");
 }

--
Gitblit v1.10.0