GDP

#!/usr/bin/env python

"""

A simple program to demonstrate asynchronous read

"""

import sys

import gdp

import pprint

def main(name_str, start, stop):

    # create a python object

    gcl_name = gdp.GDP_NAME(name_str)

    # Assume that the GCL already exists

    gcl_handle = gdp.GDP_GCL(gcl_name, gdp.GDP_MODE_RO)

    recs = 0

    for i in xrange(start, stop+1):

        retstatus = gcl_handle.multiread(i, 1)

        print "Sending multiread request# %d (%d, %d), multiread return status: %s" % \

                        (i, i, 1, gdp.ep_stat_tostr(retstatus))

        recs += 1

    t = {'tv_sec':0, 'tv_nsec':500*(10**6), 'tv_accuracy':0.0}

    events = []

    while True:

        # This could return a None, after the specified timeout

        event = gdp.GDP_GCL.get_next_event(t)

        if event is None: break

        events.append(event)

    event_dict = { 1: "GDP_EVENT_DATA", 2: "GDP_EVENT_EOS" }

    event_types = [event_dict[t["type"]] for t in events]

    print "Sequence of events returned:"

    for t in event_types: print t

    print "Total events: %d" % len(events)

if __name__ == "__main__":

    if len(sys.argv) < 4:

        print "Usage: %s <gcl-name> <start-recno> <stop-recno>" % sys.argv[0]

        sys.exit(1)

    # Change this to point to a gdp_router

    gdp.gdp_init()

    gdp.dbg_set("gdp.event=70")

    gdp.dbg_set("gdp.main=55")

    main(sys.argv[1], int(sys.argv[2]), int(sys.argv[3]))