Functions
def	consumer (accel_mode, fpgas_queue, frames, i, debug_level=debug_level)

def	mega_work (accel_mode, fpgas_queue, frames, debug_level, start, end)

def	flatten (input)

Variables
bool	accel_mode = False

	debug_level = logging.DEBUG

	stream

	stdout

	level

int	width = 3840

int	height = 2160

int	total_size = height * width

int	DATASET_SIZE = 50

int	split = 1

int	REPEATS = 1

	address

	fpgas_queue = Queue(maxsize=100)

	tic_capture = time.perf_counter()

list	frames = []

list	frames_ret = []

	frame = cv.imread(cv.samples.findFile("CARLA.jpg"))

	toc_capture = time.perf_counter()

list	elapsed_times = []

	start_time = time.time()

	tic_consumers = time.perf_counter()

	frames_id = ray.put(frames)

	fpgas_queue_id = ray.put(fpgas_queue)

list	consumers = [mega_work.remote(accel_mode, fpgas_queue_id, frames_id, debug_level, isplit, (i+1)split) for i in range(int(len(frames)/split))]

	toc_consumers = time.perf_counter()

	tic_exec = time.perf_counter()

	results = ray.get(consumers)

	toc_exec = time.perf_counter()

	end_time = time.time()

	tic_save = time.perf_counter()

string	image_name = "CARLA_out_"+str(t)+".jpg"

	toc_save = time.perf_counter()

int	average_elapsed_time = sum(elapsed_times) / REPEATS

Function Documentation

◆ consumer()

def test_median_blur_images_ray.consumer	(	accel_mode,
		fpgas_queue,
		frames,
		i,
		debug_level = `debug_level`
	)

Definition at line 70 of file test_median_blur_images_ray.py.

 def consumer(accel_mode, fpgas_queue, frames, i, debug_level=debug_level):
     logging.basicConfig(stream=sys.stdout, level=debug_level)
     
     frame = frames[i]
     if accel_mode:
         next_item = fpgas_queue.get(block=True, timeout=100)
         logging.debug(f"will work on {next_item} and then put in back in the fpgas_queue")
         # Flattening the image from 2D to 1D
         image = frame.flatten()        
         output_array = trieres.vision.median_blur(image, total_size, next_item[0], int(next_item[1]), debug_level=debug_level)
         frame = np.reshape(output_array, (height, width))
         #frame = cv.medianBlur(frame, 9)
         fpgas_queue.put(next_item)
         logging.debug(f"finished working on {next_item} Now it is back in the fpgas_queue")
     else:
         logging.debug(f"Apllying medianBlur")
         frame = cv.medianBlur(frame, 9)
     return frame
  
  
 @ray.remote

Here is the caller graph for this function:

◆ flatten()

def test_median_blur_images_ray.flatten ( input )

Definition at line 95 of file test_median_blur_images_ray.py.

 def flatten(input):
     if(type(input[0])==list):
         new_list = []
         for i in input:
             for j in i:
                 new_list.append(j)
         return new_list
     else:
         return input
  
 try:
     fn = sys.argv[1]
 except:
     fn = 0
  

◆ mega_work()

def test_median_blur_images_ray.mega_work	(	accel_mode,
		fpgas_queue,
		frames,
		debug_level,
		start,
		end
	)

Definition at line 91 of file test_median_blur_images_ray.py.

 def mega_work(accel_mode, fpgas_queue, frames, debug_level, start, end):
     print("will work on ["+str(start)+"-"+str(end)+"]")
     return [consumer(accel_mode, fpgas_queue, frames, x, debug_level=debug_level) for x in range(start, end)]
  

Here is the call graph for this function:

Variable Documentation

◆ accel_mode

bool test_median_blur_images_ray.accel_mode = False

Definition at line 45 of file test_median_blur_images_ray.py.

◆ address

test_median_blur_images_ray.address

Definition at line 59 of file test_median_blur_images_ray.py.

◆ average_elapsed_time

int test_median_blur_images_ray.average_elapsed_time = sum(elapsed_times) / REPEATS

Definition at line 183 of file test_median_blur_images_ray.py.

◆ consumers

list test_median_blur_images_ray.consumers = [mega_work.remote(accel_mode, fpgas_queue_id, frames_id, debug_level, i*split, (i+1)*split) for i in range(int(len(frames)/split))]

Definition at line 134 of file test_median_blur_images_ray.py.