Adding upstream version 14.2.21.upstream/14.2.21upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

2 files changed, 32 insertions, 0 deletions

diff --git a/src/blkin/babeltrace-plugins/scribe_client/__init__.py b/src/blkin/babeltrace-plugins/scribe_client/__init__.py
new file mode 100644
index 00000000..50380384
--- /dev/null
+++ b/src/blkin/babeltrace-plugins/scribe_client/__init__.py
@@ -0,0 +1 @@
+from scribe_client import *
diff --git a/src/blkin/babeltrace-plugins/scribe_client/scribe_client.py b/src/blkin/babeltrace-plugins/scribe_client/scribe_client.py
new file mode 100644
index 00000000..b382ed99
--- /dev/null
+++ b/src/blkin/babeltrace-plugins/scribe_client/scribe_client.py
@@ -0,0 +1,31 @@
+#!/usr/bin/python
+# scribe_client.py
+
+from scribe import scribe
+from thrift.transport import TTransport, TSocket
+from thrift.protocol import TBinaryProtocol
+
+class ScribeClient(object):
+
+    def __init__(self, port, host):
+        print host
+        self.port = port
+        self.host = host
+        self.openConnection()
+
+    def openConnection(self):
+        socket = TSocket.TSocket(host=self.host, port=self.port)
+        self.transport = TTransport.TFramedTransport(socket)
+        protocol = TBinaryProtocol.TBinaryProtocol(trans=self.transport,
+                                                   strictRead=False,
+                                                   strictWrite=False)
+        self.client = scribe.Client(protocol)
+        self.transport.open()
+
+    def log(self, category, message):
+        log_entry = scribe.LogEntry(category, message)
+        result = self.client.Log(messages=[log_entry])
+        return result  # 0 for success
+
+    def close(self):
+        self.transport.close()