vision Namespace Reference

Functions
def	median_blur (input_array, total_size, fpga_ip, fpga_port, debug_level)

Variables
int	recvBufSize = 0x1000000
int	real_buffer_size = 0

Function Documentation

median_blur()

def vision.median_blur	(		input_array,
			total_size,
			fpga_ip,
			fpga_port,
			debug_level
	)

Definition at line 42 of file vision.py.

def median_blur(input_array, total_size, fpga_ip, fpga_port, debug_level):
    logging.basicConfig(level=debug_level)
    bytesToSend = input_array.tostring()
    # Create a UDP socket at client side
    UDPClientSocket = socket.socket(family=socket.AF_INET, type=socket.SOCK_DGRAM)
    previous_buffer_size = UDPClientSocket.getsockopt(socket.SOL_SOCKET,socket.SO_RCVBUF)
    UDPClientSocket.setsockopt(socket.SOL_SOCKET,socket.SO_RCVBUF, recvBufSize)
    real_buffer_size = UDPClientSocket.getsockopt(socket.SOL_SOCKET,socket.SO_RCVBUF)
    if(real_buffer_size/2 != recvBufSize):
        logging.warning("set SO_RCVBUF failed! got only: " +str(real_buffer_size/2) + "; trying to continue...")
    BUFF_SIZE = 1024#65536
    serverAddressPort   = (fpga_ip, fpga_port)
    cnt = 0;
    while True:
        logging.debug("Sending bytes: " + str(cnt*BUFF_SIZE) + " : " + str((cnt+1)*BUFF_SIZE-1))
        UDPClientSocket.sendto(bytesToSend[cnt*BUFF_SIZE:(cnt+1)*BUFF_SIZE], serverAddressPort)
        if ((cnt+1)*BUFF_SIZE >= total_size):
            logging.debug("INFO: Reached size to sent")
            break;
        else:
            cnt = cnt + 1
    cnt = 0;
    output_array = np.zeros((total_size,))
    while True:
        logging.debug("Receiving bytes: " + str(cnt*BUFF_SIZE) + " : " + str((cnt+1)*BUFF_SIZE-1))
        msgFromServer = UDPClientSocket.recvfrom(BUFF_SIZE)
        y = np.frombuffer(msgFromServer[0], dtype=input_array.dtype)
        logging.debug(output_array[cnt*BUFF_SIZE:(cnt+1)*BUFF_SIZE-1].size)
        output_array[cnt*BUFF_SIZE:(cnt+1)*BUFF_SIZE] = y
        if ((cnt+1)*BUFF_SIZE >= total_size):
            logging.debug("Reached size to receive")
            break;
        else:
            cnt = cnt + 1
    return output_array
 

Here is the call graph for this function:

Variable Documentation

real_buffer_size

int vision.real_buffer_size = 0

Definition at line 40 of file vision.py.

recvBufSize

int vision.recvBufSize = 0x1000000

Definition at line 39 of file vision.py.