aboutsummaryrefslogtreecommitdiffstats
path: root/vpp-api
diff options
context:
space:
mode:
Diffstat (limited to 'vpp-api')
-rwxr-xr-xvpp-api/python/tests/test_modules.py3
-rw-r--r--vpp-api/python/vpp_papi/vpp_papi.py35
2 files changed, 21 insertions, 17 deletions
diff --git a/vpp-api/python/tests/test_modules.py b/vpp-api/python/tests/test_modules.py
index f3066b29395..48df17559a0 100755
--- a/vpp-api/python/tests/test_modules.py
+++ b/vpp-api/python/tests/test_modules.py
@@ -14,4 +14,7 @@ print('R:', r)
r = snat.snat_interface_add_del_feature(1, 1, 1)
print('R:', r)
+list_name = 'foobar'
+r = pot.pot_profile_add(0, 1, 123, 123, 0, 12, 0, 23, len(list_name), list_name)
+print('R:', r)
vpp_papi.disconnect()
diff --git a/vpp-api/python/vpp_papi/vpp_papi.py b/vpp-api/python/vpp_papi/vpp_papi.py
index 144151c4154..174e61d7e9e 100644
--- a/vpp-api/python/vpp_papi/vpp_papi.py
+++ b/vpp-api/python/vpp_papi/vpp_papi.py
@@ -17,7 +17,7 @@
#
from __future__ import print_function
-import signal, logging, os, sys
+import signal, os, sys
from struct import *
scriptdir = os.path.dirname(os.path.realpath(__file__))
@@ -30,25 +30,26 @@ import memclnt
from vpe import *
vpe = sys.modules['vpe']
+def eprint(*args, **kwargs):
+ print(*args, file=sys.stderr, **kwargs)
+
def msg_handler(msg):
if not msg:
- logging.warning('vpp_api.read failed')
+ eprint('vpp_api.read failed')
return
id = unpack('>H', msg[0:2])
- logging.debug('Received message', id[0])
if id[0] == memclnt.VL_API_RX_THREAD_EXIT:
- logging.info("We got told to leave")
return;
#
# Decode message and returns a tuple.
#
- logging.debug('api_func', api_func_table[id[0]])
- r = api_func_table[id[0]](msg)
- if not r:
- logging.warning('Message decode failed', id[0])
- return
+ try:
+ r = api_func_table[id[0]](msg)
+ except:
+ eprint('Message decode failed', id[0], api_func_table[id[0]])
+ raise
if 'context' in r._asdict():
if r.context > 0:
@@ -71,7 +72,7 @@ def msg_handler(msg):
waiting_for_reply_clear()
return
if not is_results_context(context):
- logging.warning('Not expecting results for this context', context)
+ eprint('Not expecting results for this context', context)
return
if is_results_more(context):
results_append(context, r)
@@ -85,7 +86,6 @@ def connect(name):
signal.alarm(3) # 3 second
rv = vpp_api.connect(name, msg_handler)
signal.alarm(0)
- logging.info("Connect:", rv)
#
# Assign message id space for plugins
@@ -96,7 +96,6 @@ def connect(name):
def disconnect():
rv = vpp_api.disconnect()
- logging.info("Disconnected")
return rv
# CLI convenience wrapper
@@ -128,10 +127,9 @@ def plugin_map_plugins():
version = plugins[p]['version']
name = p + '_' + format(version, '08x')
r = memclnt.get_first_msg_id(name.encode('ascii'))
-
- ## TODO: Add error handling
+ ## TODO: Add error handling / raise exception
if r.retval != 0:
- print('Failed getting first msg id for:', p)
+ eprint('Failed getting first msg id for:', p)
continue
# Set base
@@ -141,8 +139,12 @@ def plugin_map_plugins():
plugins[p]['base'] = base
func_table = plugins[p]['func_table']
i = r.first_msg_id
+ # Insert doesn't extend the table
+ if i + len(func_table) > len(api_func_table):
+ fill = [None] * (i + len(func_table) - len(api_func_table))
+ api_func_table.extend(fill)
for entry in func_table:
- api_func_table.insert(i, entry)
+ api_func_table[i] = entry
i += 1
plugin_name_to_id(p, plugins[p]['name_to_id_table'], base)
@@ -158,4 +160,3 @@ api_func_table.append(None)
api_func_table[1:] = plugins['memclnt']['func_table'] + plugins['vpe']['func_table']
plugin_name_to_id('memclnt', plugins['memclnt']['name_to_id_table'], 1)
plugin_name_to_id('vpe', plugins['vpe']['name_to_id_table'], plugins['vpe']['base'])
-#logging.basicConfig(level=logging.DEBUG)