#!/usr/bin/env python

#

# Copyright 2006,2010 Free Software Foundation, Inc.

# 

# This file is part of GNU Radio

# 

# GNU Radio is free software; you can redistribute it and/or modify

# it under the terms of the GNU General Public License as published by

# the Free Software Foundation; either version 3, or (at your option)

# any later version.

# 

# GNU Radio is distributed in the hope that it will be useful,

# but WITHOUT ANY WARRANTY; without even the implied warranty of

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

# GNU General Public License for more details.

# 

# You should have received a copy of the GNU General Public License

# along with GNU Radio; see the file COPYING.  If not, write to

# the Free Software Foundation, Inc., 51 Franklin Street,

# Boston, MA 02110-1301, USA.

# 

from gnuradio import gr

from gnuradio.eng_option import eng_option

from optparse import OptionParser

class vector_source(gr.top_block):

    def __init__(self, host, port, pkt_size, eof):

        gr.top_block.__init__(self, "vector_source")

        data = [i*0.01 for i in range(1000)]

        vec = gr.vector_source_f(data, True)

        udp = gr.udp_sink(gr.sizeof_float, host, port, pkt_size, eof=eof)

        self.connect(vec, udp)

if __name__ == '__main__':

    parser = OptionParser(option_class=eng_option)

    parser.add_option("", "--host", type="string", default="localhost",

                      help="Remote host name (domain name or IP address")

    parser.add_option("", "--port", type="int", default=65500,

                      help="port number to connect to")

    parser.add_option("", "--packet-size", type="int", default=1471,

                      help="packet size.")

    parser.add_option("", "--no-eof", action="store_true", default=False,

                      help="don't send EOF on disconnect")

    (options, args) = parser.parse_args()

    if len(args) != 0:

        parser.print_help()

        raise SystemExit, 1

# Create an instance of a hierarchical block

    top_block = vector_source(options.host, options.port, options.packet_size,

                              not options.no_eof)

    try:    

        # Run forever

        top_block.run()

    except KeyboardInterrupt:

        # Ctrl-C exits

        pass