summaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
authorIWASE Yusuke <iwase.yusuke0@gmail.com>2016-06-08 11:05:31 +0900
committerFUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>2016-06-09 13:27:03 +0900
commit55a88d6805e5b62bae96aaa710459150c77340c5 (patch)
treec6cd02100e633e85a4d10e1ce64ee76a93c0e933
parentc263089e72564dae9b25180e07dde29d18562644 (diff)
BGPSpeaker: Remove unused utility modules
Reviewed-by: IWAMOTO Toshihiro <iwamoto@valinux.co.jp> Signed-off-by: IWASE Yusuke <iwase.yusuke0@gmail.com> Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
-rw-r--r--ryu/services/protocols/bgp/utils/internable.py106
-rw-r--r--ryu/services/protocols/bgp/utils/logs.py36
-rw-r--r--ryu/services/protocols/bgp/utils/other.py11
3 files changed, 0 insertions, 153 deletions
diff --git a/ryu/services/protocols/bgp/utils/internable.py b/ryu/services/protocols/bgp/utils/internable.py
deleted file mode 100644
index 2029bf0d..00000000
--- a/ryu/services/protocols/bgp/utils/internable.py
+++ /dev/null
@@ -1,106 +0,0 @@
-# Copyright (C) 2014 Nippon Telegraph and Telephone Corporation.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
-# implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import weakref
-
-
-#
-# Internable
-#
-class Internable(object):
- """Class that allows instances to be 'interned'. That is, given an
- instance of this class, one can obtain a canonical (interned)
- copy.
-
- This saves memory when there are likely to be many identical
- instances of the class -- users hold references to a single
- interned object instead of references to different objects that
- are identical.
-
- The interned version of a given instance is created on demand if
- necessary, and automatically cleaned up when nobody holds a
- reference to it.
-
- Instances of sub-classes must be usable as dictionary keys for
- Internable to work.
- """
-
- _internable_stats = None
- _internable_dict = None
-
- def __init__(self):
- self._interned = False
-
- class Stats(object):
-
- def __init__(self):
- self.d = {}
-
- def incr(self, name):
- self.d[name] = self.d.get(name, 0) + 1
-
- def __repr__(self):
- return repr(self.d)
-
- def __str__(self):
- return str(self.d)
-
- @classmethod
- def _internable_init(cls):
- # Objects to be interned are held as keys in a dictionary that
- # only holds weak references to keys. As a result, when the
- # last reference to an interned object goes away, the object
- # will be removed from the dictionary.
- cls._internable_dict = weakref.WeakKeyDictionary()
- cls._internable_stats = Internable.Stats()
-
- @classmethod
- def intern_stats(cls):
- return cls._internable_stats
-
- def intern(self):
- """Returns either itself or a canonical copy of itself."""
-
- # If this is an interned object, return it
- if hasattr(self, '_interned'):
- return self._internable_stats.incr('self')
-
- #
- # Got to find or create an interned object identical to this
- # one. Auto-initialize the class if need be.
- #
- cls = self.__class__
-
- if not cls._internable_dict:
- cls._internable_init()
-
- obj = cls._internable_dict.get(self)
- if (obj):
- # Found an interned copy.
- cls._internable_stats.incr('found')
- return obj
-
- # Create an interned copy. Take care to only keep a weak
- # reference to the object itself.
- def object_collected(obj):
- cls._internable_stats.incr('collected')
- # print("Object %s garbage collected" % obj)
- pass
-
- ref = weakref.ref(self, object_collected)
- cls._internable_dict[self] = ref
- self._interned = True
- cls._internable_stats.incr('inserted')
- return self
diff --git a/ryu/services/protocols/bgp/utils/logs.py b/ryu/services/protocols/bgp/utils/logs.py
deleted file mode 100644
index aa07d5c1..00000000
--- a/ryu/services/protocols/bgp/utils/logs.py
+++ /dev/null
@@ -1,36 +0,0 @@
-import json
-import logging
-import six
-import time
-
-from datetime import datetime
-
-
-class ApgwFormatter(logging.Formatter):
- LOG_TIME_FORMAT = '%Y-%m-%dT%H:%M:%S.%fZ'
- COMPONENT_NAME = 'BGPSpeaker'
-
- def format(self, record):
- msg = {
- 'component_name': self.COMPONENT_NAME,
- 'timestamp': datetime.utcfromtimestamp(
- time.time()
- ).strftime(self.LOG_TIME_FORMAT),
- 'msg': six.text_type(record.msg),
- 'level': record.levelname
-
- }
-
- if hasattr(record, 'log_type'):
- assert record.log_type in ('log', 'stats', 'state')
- msg['log_type'] = record.log_type
- else:
- msg['log_type'] = 'log'
- if hasattr(record, 'resource_id'):
- msg['resource_id'] = record.resource_id
- if hasattr(record, 'resource_name'):
- msg['resource_name'] = record.resource_name
-
- record.msg = json.dumps(msg)
-
- return super(ApgwFormatter, self).format(record)
diff --git a/ryu/services/protocols/bgp/utils/other.py b/ryu/services/protocols/bgp/utils/other.py
deleted file mode 100644
index 94f849a8..00000000
--- a/ryu/services/protocols/bgp/utils/other.py
+++ /dev/null
@@ -1,11 +0,0 @@
-def bytes2hex(given_bytes):
- return ''.join(["%02X " % ord(x) for x in given_bytes]).strip()
-
-
-def hex2byte(given_hex):
- given_hex = ''.join(given_hex.split())
- result = []
- for offset in range(0, len(given_hex), 2):
- result.append(chr(int(given_hex[offset:offset + 2], 16)))
-
- return ''.join(result)