mirrors/guru
1
0
Fork 0
mirror of https://github.com/gentoo-mirror/guru.git synced 2026-07-16 02:23:16 -04:00
Code Issues Packages Projects Releases Wiki Activity

dev-python/pyagentx-0.4 first release

Browse Source 
Signed-off-by: Andrea Postiglione <andrea.postiglione@gmail.com>
This commit is contained in:
Andrea Postiglione
2022-04-02 15:26:37 +02:00
parent ed6f0ff966
commit b74f56d404
5 changed files with 324 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
dev-python/pyagentx/Manifest Normal file
View File

@@ -0,0 +1,5 @@
AUX python3.patch 7481 BLAKE2B 2142c64935f067f88e7a59daa505a6ae4f44b5999191d43787fd9e2bddc6e79bf1a687c4ee341677958ba473f5f347a19a2ec0c09da3ab6049f2d3423c72ba50 SHA512 6b3a57c8bb5436b2a32970051a91d22f3c990aa52130c85ffc44a77413d424926f88f96426d2ce60b0123ee0b9b6a20c33fe485e591e048a7ac2783d97ad1a9b
AUX updater.patch 798 BLAKE2B 3e8ada0c8cef641b490cd797f8e610e7b6bc30443c65510d050cc8d0ca417fde58b2046ab2da6947cb8246c3bc36588e2936d5aaa76fd6c79a2a552d36d29a28 SHA512 d19e5647c9a0879908f93adf1d295f2ef4e35de48185824db6e0145cf78d85597a9f597fa2408aa1db009b100360fe5337f05a373e7c5b9ae9e8e5166f9d8f0e
DIST pyagentx-0.4.tar.gz 11353 BLAKE2B 1ae8197431a60651de61577d384ff3168ee2beb4bf6ce5cb2ccb4fbd9482f808c875301225e2d871e3fde94828e3291604f61e358570074b64af2271005e3f7f SHA512 2c13dc04b926fa0d6d7df24d577fc37d08440145adbc5e9ec45f99157da40d92afd7bd7e875e3d980b83330ee66ccde8649698cd967c150056db19cbbc4f7f6b
EBUILD pyagentx-0.4.ebuild 493 BLAKE2B a12f8e9d5ace3b69ca67edc5766d9e367e3c8761d3e42868c65f249712db57cd37a6408d0c70c48acd922f9c6a6f74226f3606a79aa620ad84ea4739b57ab7a8 SHA512 3a12026be830c0bf488d551e1819be58bdc39e69d1df99ab019317d90e1d37eb1d0fc595c8ad0cecc3a263867c98a5edbc24845d0a8e85ff06fd3e747d4369d6
MISC metadata.xml 626 BLAKE2B c3db5c408e852c05ab7b0eee7feef9cd52d2f42b7180b4a1071087f94e5326bb7797d2865bc8cb0612a3537b4ea870a8e1010c5975c52127957bf3ca575b6546 SHA512 c3e9f17b07bb9f1ba849901a3697552dd015242f08856a156642532d7eec9180efc02d6af2846c5b211b7f71c1f79cc9c7d6ff40a783b6bc0c8a2d27f51e5f3b

255
dev-python/pyagentx/files/python3.patch Normal file
View File

@@ -0,0 +1,255 @@
commit dd1f0e84f8e321789264aec5ada0f1cb4d9ac8af
Author: Ondrej Mular <omular@redhat.com>
Date: Tue Nov 21 08:40:55 2017 +0100
Port to python3
diff --git a/pyagentx/__init__.py b/pyagentx/__init__.py
index efeef10..d4fd627 100644
--- a/pyagentx/__init__.py
+++ b/pyagentx/__init__.py
@@ -1,5 +1,10 @@
#!/usr/bin/env python
# -*- coding: utf-8 -*-
+from __future__ import (
+ absolute_import,
+ division,
+ print_function,
+)
import logging
diff --git a/pyagentx/agent.py b/pyagentx/agent.py
index b6c0e2a..2db39db 100644
--- a/pyagentx/agent.py
+++ b/pyagentx/agent.py
@@ -1,5 +1,10 @@
#!/usr/bin/env python
# -*- coding: utf-8 -*-
+from __future__ import (
+ absolute_import,
+ division,
+ print_function,
+)
# --------------------------------------------
import logging
@@ -11,8 +16,11 @@ logger.addHandler(NullHandler())
# --------------------------------------------
import time
-import Queue
import inspect
+try:
+ import queue
+except ImportError:
+ import Queue as queue
import pyagentx
from pyagentx.updater import Updater
@@ -57,18 +65,18 @@ class Agent(object):
pass
def start(self):
- queue = Queue.Queue(maxsize=20)
+ update_queue = queue.Queue(maxsize=20)
self.setup()
# Start Updaters
for u in self._updater_list:
logger.debug('Starting updater [%s]' % u['oid'])
t = u['class']()
- t.agent_setup(queue, u['oid'], u['freq'])
+ t.agent_setup(update_queue, u['oid'], u['freq'])
t.start()
self._threads.append(t)
# Start Network
oid_list = [u['oid'] for u in self._updater_list]
- t = Network(queue, oid_list, self._sethandlers)
+ t = Network(update_queue, oid_list, self._sethandlers)
t.start()
self._threads.append(t)
# Do nothing ... just wait for someone to stop you
diff --git a/pyagentx/network.py b/pyagentx/network.py
index 9711398..f30edad 100644
--- a/pyagentx/network.py
+++ b/pyagentx/network.py
@@ -1,5 +1,10 @@
#!/usr/bin/env python
# -*- coding: utf-8 -*-
+from __future__ import (
+ absolute_import,
+ division,
+ print_function,
+)
# --------------------------------------------
import logging
@@ -13,7 +18,10 @@ logger.addHandler(NullHandler())
import socket
import time
import threading
-import Queue
+try:
+ import queue
+except ImportError:
+ import Queue as queue
import pyagentx
from pyagentx.pdu import PDU
@@ -21,10 +29,10 @@ from pyagentx.pdu import PDU
class Network(threading.Thread):
- def __init__(self, queue, oid_list, sethandlers):
+ def __init__(self, update_queue, oid_list, sethandlers):
threading.Thread.__init__(self)
self.stop = threading.Event()
- self._queue = queue
+ self._queue = update_queue
self._oid_list = oid_list
self._sethandlers = sethandlers
@@ -84,7 +92,7 @@ class Network(threading.Thread):
update_oid = item['oid']
update_data = item['data']
# clear values with prefix oid
- for oid in self.data.keys():
+ for oid in list(self.data.keys()):
if oid.startswith(update_oid):
del(self.data[oid])
# insert updated value
@@ -94,7 +102,7 @@ class Network(threading.Thread):
'value':row['value']}
# recalculate reverse index if data changed
self.data_idx = sorted(self.data.keys(), key=lambda k: tuple(int(part) for part in k.split('.')))
- except Queue.Empty:
+ except queue.Empty:
break
diff --git a/pyagentx/pdu.py b/pyagentx/pdu.py
index 0af8e82..ac02a77 100644
--- a/pyagentx/pdu.py
+++ b/pyagentx/pdu.py
@@ -1,5 +1,10 @@
#!/usr/bin/env python
# -*- coding: utf-8 -*-
+from __future__ import (
+ absolute_import,
+ division,
+ print_function,
+)
# --------------------------------------------
import logging
@@ -68,10 +73,11 @@ class PDU(object):
def encode_octet(self, octet):
+ octet = octet.encode("utf-8")
buf = struct.pack('!L', len(octet))
- buf += str(octet)
+ buf += octet
padding = ( 4 - ( len(octet) % 4 ) ) % 4
- buf += chr(0)* padding
+ buf += chr(0).encode() * padding
return buf
@@ -107,7 +113,7 @@ class PDU(object):
def encode(self):
- buf = ''
+ buf = b''
if self.type == pyagentx.AGENTX_OPEN_PDU:
# timeout
buf += struct.pack('!BBBB', 5, 0, 0, 0)
@@ -169,7 +175,7 @@ class PDU(object):
sub_ids.append(t[0])
oid = '.'.join(str(i) for i in sub_ids)
return oid, ret['include']
- except Exception, e:
+ except Exception as e:
logger.exception('Invalid packing OID header')
logger.debug('%s' % pprint.pformat(self.decode_buf))
@@ -196,7 +202,7 @@ class PDU(object):
buf = self.decode_buf[:l]
self.decode_buf = self.decode_buf[l+padding:]
return buf
- except Exception, e:
+ except Exception as e:
logger.exception('Invalid packing octet header')
@@ -204,7 +210,7 @@ class PDU(object):
try:
vtype,_ = struct.unpack('!HH', self.decode_buf[:4])
self.decode_buf = self.decode_buf[4:]
- except Exception, e:
+ except Exception as e:
logger.exception('Invalid packing value header')
oid,_ = self.decode_oid()
if vtype in [pyagentx.TYPE_INTEGER, pyagentx.TYPE_COUNTER32, pyagentx.TYPE_GAUGE32, pyagentx.TYPE_TIMETICKS]:
@@ -252,7 +258,7 @@ class PDU(object):
context = self.decode_octet()
logger.debug('Context: %s' % context)
return ret
- except Exception, e:
+ except Exception as e:
logger.exception('Invalid packing: %d' % len(self.decode_buf))
logger.debug('%s' % pprint.pformat(self.decode_buf))
diff --git a/pyagentx/sethandler.py b/pyagentx/sethandler.py
index 30a2db5..97839b2 100644
--- a/pyagentx/sethandler.py
+++ b/pyagentx/sethandler.py
@@ -1,5 +1,10 @@
#!/usr/bin/env python
# -*- coding: utf-8 -*-
+from __future__ import (
+ absolute_import,
+ division,
+ print_function,
+)
# --------------------------------------------
import logging
diff --git a/pyagentx/updater.py b/pyagentx/updater.py
index 5fb06d4..711f87e 100644
--- a/pyagentx/updater.py
+++ b/pyagentx/updater.py
@@ -1,5 +1,10 @@
#!/usr/bin/env python
# -*- coding: utf-8 -*-
+from __future__ import (
+ absolute_import,
+ division,
+ print_function,
+)
# --------------------------------------------
import logging
@@ -12,7 +17,11 @@ logger.addHandler(NullHandler())
import time
import threading
-import Queue
+try:
+ import queue
+except ImportError:
+ import Queue as queue
+
import pyagentx
@@ -39,7 +48,7 @@ class Updater(threading.Thread):
self.update()
self._queue.put_nowait({'oid': self._oid,
'data':self._data})
- except Queue.Full:
+ except queue.Full:
logger.error('Queue full')
except:
logger.exception('Unhandled update exception')

27
dev-python/pyagentx/files/updater.patch Normal file
View File

@@ -0,0 +1,27 @@
commit 1f0337b2d481d16936a4921498fe67614687bd38
Author: Mohammed Alshohayeb <moshohayeb@gmail.com>
Date: Tue Jun 30 14:40:00 2015 +0300
permit remote descendants of Updater to be useable
diff --git a/pyagentx/agent.py b/pyagentx/agent.py
index 173a966..b6c0e2a 100644
--- a/pyagentx/agent.py
+++ b/pyagentx/agent.py
@@ -12,6 +12,7 @@ logger.addHandler(NullHandler())
import time
import Queue
+import inspect
import pyagentx
from pyagentx.updater import Updater
@@ -30,7 +31,7 @@ class Agent(object):
self._threads = []
def register(self, oid, class_, freq=10):
- if Updater not in class_.__bases__:
+ if Updater not in inspect.getmro(class_):
raise AgentError('Class given isn\'t an updater')
# cleanup and test oid
try:

16
dev-python/pyagentx/metadata.xml Normal file
View File

@@ -0,0 +1,16 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE pkgmetadata SYSTEM "http://www.gentoo.org/dtd/metadata.dtd">
<pkgmetadata>
<maintainer type="person">
<email>andrea.postiglione@gmail.com</email>
<name>Andrea Postiglione</name>
</maintainer>
<longdescription lang="en">
Pcs is a Corosync and Pacemaker configuration tool. It permits users to easily view, modify and
create Pacemaker based clusters. Pcs contains pcsd, a pcs daemon, which operates as a remote server
for pcs and provides a web UI.
</longdescription>
<upstream>
<remote-id type="github">ClusterLabs/pcs</remote-id>
</upstream>
</pkgmetadata>

21
dev-python/pyagentx/pyagentx-0.4.ebuild Normal file
View File

@@ -0,0 +1,21 @@
# Copyright 1999-2022 Gentoo Authors
# Distributed under the terms of the GNU General Public License v2
EAPI=8
PYTHON_COMPAT=( python3_{7..10} )
inherit distutils-r1
DESCRIPTION="Python AgentX Implementation"
HOMEPAGE="https://github.com/hosthvo/pyagentx"
SRC_URI="https://github.com/hosthvo/pyagentx/archive/refs/tags/v${PV}.tar.gz -> ${P}.tar.gz"
LICENSE="BSD-2"
SLOT="0"
KEYWORDS="~amd64"
PATCHES="${FILESDIR}/updater.patch
${FILESDIR}/python3.patch"
distutils_enable_tests pytest