summaryrefslogtreecommitdiffstats
path: root/src/stateless
diff options
context:
space:
mode:
authorimarom <imarom@cisco.com>2015-12-14 11:03:53 -0500
committerimarom <imarom@cisco.com>2015-12-14 11:05:07 -0500
commitd71dbce9695f348b2e52e00c9efd53cb89c62aa5 (patch)
treebb4727b416dac5f482545ce0e5ba9686db91b8ea /src/stateless
parent3f94a09f66657970636a532aac9411ad6a5290ad (diff)
bugs fixes
1. ignore your own force acquire of ports 2. TUI fixes
Diffstat (limited to 'src/stateless')
-rw-r--r--src/stateless/cp/trex_stateless_port.cpp6
-rw-r--r--src/stateless/cp/trex_stateless_port.h2
2 files changed, 6 insertions, 2 deletions
diff --git a/src/stateless/cp/trex_stateless_port.cpp b/src/stateless/cp/trex_stateless_port.cpp
index 9770c735..3a64f8c5 100644
--- a/src/stateless/cp/trex_stateless_port.cpp
+++ b/src/stateless/cp/trex_stateless_port.cpp
@@ -84,7 +84,7 @@ TrexStatelessPort::TrexStatelessPort(uint8_t port_id, const TrexPlatformApi *api
* @param force
*/
void
-TrexStatelessPort::acquire(const std::string &user, bool force) {
+TrexStatelessPort::acquire(const std::string &user, uint32_t session_id, bool force) {
/* if port is free - just take it */
if (get_owner().is_free()) {
@@ -97,7 +97,11 @@ TrexStatelessPort::acquire(const std::string &user, bool force) {
/* inform the other client of the steal... */
Json::Value data;
+
data["port_id"] = m_port_id;
+ data["who"] = user;
+ data["session_id"] = session_id;
+
get_stateless_obj()->get_publisher()->publish_event(TrexPublisher::EVENT_PORT_FORCE_ACQUIRED, data);
} else {
diff --git a/src/stateless/cp/trex_stateless_port.h b/src/stateless/cp/trex_stateless_port.h
index 4988b46a..a529d38f 100644
--- a/src/stateless/cp/trex_stateless_port.h
+++ b/src/stateless/cp/trex_stateless_port.h
@@ -138,7 +138,7 @@ public:
* acquire port
* throws TrexException in case of an error
*/
- void acquire(const std::string &user, bool force = false);
+ void acquire(const std::string &user, uint32_t session_id, bool force = false);
/**
* release the port from the current user