VOL-2861 replace uint64 kafka interadapter timestamps with timestamp proto
Change-Id: I413b88bac061bbca6d6bcf1cc0e5064139fd44eb
diff --git a/VERSION b/VERSION
index 005119b..8e8299d 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-2.4.1
+2.4.2
diff --git a/pyvoltha/adapters/kafka/adapter_proxy.py b/pyvoltha/adapters/kafka/adapter_proxy.py
index 591c1c3..3e63433 100644
--- a/pyvoltha/adapters/kafka/adapter_proxy.py
+++ b/pyvoltha/adapters/kafka/adapter_proxy.py
@@ -97,7 +97,7 @@
else:
h.id = uuid4().hex
- h.timestamp = int(round(time.time() * 1000))
+ h.timestamp.GetCurrentTime()
iaMsg = InterAdapterMessage()
iaMsg.header.CopyFrom(h)
iaMsg.body.Pack(msg)
diff --git a/pyvoltha/adapters/kafka/kafka_inter_container_library.py b/pyvoltha/adapters/kafka/kafka_inter_container_library.py
index 9e9a6be..1b005e7 100644
--- a/pyvoltha/adapters/kafka/kafka_inter_container_library.py
+++ b/pyvoltha/adapters/kafka/kafka_inter_container_library.py
@@ -339,7 +339,7 @@
request_body.response_required = True
response_required = True
- request.header.timestamp = int(round(time.time() * 1000))
+ request.header.timestamp.GetCurrentTime()
request_body.rpc = rpc
for a, b in six.iteritems(kwargs):
arg = Argument()
@@ -372,8 +372,7 @@
response = InterContainerMessage()
response_body = InterContainerResponseBody()
response.header.id = msg_header.id
- response.header.timestamp = int(
- round(time.time() * 1000))
+ response.header.timestamp.GetCurrentTime()
response.header.type = MessageType.Value("RESPONSE")
response.header.from_topic = msg_header.to_topic
response.header.to_topic = msg_header.from_topic
diff --git a/requirements.txt b/requirements.txt
index b9243fb..8232468 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -18,4 +18,4 @@
structlog==19.2.0
transitions==0.6.4
txaioetcd==0.3.0
-voltha-protos==3.3.0
+voltha-protos==3.3.2