Skip to content

Commit

Permalink
Removed OrderedDict.
Browse files Browse the repository at this point in the history
  • Loading branch information
idlesign committed May 1, 2020
1 parent fb3d514 commit 028d445
Show file tree
Hide file tree
Showing 3 changed files with 66 additions and 74 deletions.
5 changes: 2 additions & 3 deletions uwsgiconf/base.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,3 @@
from collections import OrderedDict
from .utils import listify


Expand Down Expand Up @@ -229,7 +228,7 @@ def handle_plugin_required(val):
opts[key] = value

def _make_section_like(self):
self._section = type('SectionLike', (object,), {'_opts': OrderedDict()})
self._section = type('SectionLike', (object,), {'_opts': {}})

def _contribute_to_opts(self, target):
target_section = target._section
Expand All @@ -256,7 +255,7 @@ class ParametrizedValue(OptionsGroup):

def __init__(self, *args):
self.args = list(args)
self._opts = OrderedDict()
self._opts = {}
super(ParametrizedValue, self).__init__(_section=self)

def __str__(self):
Expand Down
9 changes: 4 additions & 5 deletions uwsgiconf/config.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
import os
import sys
from collections import OrderedDict
from copy import deepcopy
from datetime import datetime
from functools import partial
Expand Down Expand Up @@ -166,8 +165,8 @@ def __init__(
self._plugins = embedded_plugins or []

self._section = self
self._options_objects = OrderedDict()
self._opts = OrderedDict()
self._options_objects = {}
self._opts = {}

self.name = name or 'uwsgi'
self._runtime_dir = runtime_dir or ''
Expand Down Expand Up @@ -563,7 +562,7 @@ def get_descriptions(cls):

descriptions = sorted(descriptions.items(), key=lambda item: item[0].lower())

return OrderedDict(descriptions)
return dict(descriptions)

@classmethod
def bootstrap(cls, dsn, allow_shared_sockets=None, **init_kwargs):
Expand Down Expand Up @@ -735,7 +734,7 @@ def configure_uwsgi(configurator_func):
return None

configurations = configurator_func()
registry = OrderedDict()
registry = {}

if not isinstance(configurations, (list, tuple)):
configurations = [configurations]
Expand Down
126 changes: 60 additions & 66 deletions uwsgiconf/contrib/django/uwsgify/admin/realms.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,3 @@
from collections import OrderedDict
from datetime import datetime, timedelta

from django.template.defaultfilters import filesizeformat
Expand Down Expand Up @@ -41,35 +40,35 @@ def get_signals_info(signals):
rss, vsz = uwsgi.memory
config = uwsgi.config

info_basic = OrderedDict([
(_('Version'), uwsgi.get_version()),
(_('Hostname'), uwsgi.hostname),
(_('Serving since'), time_started),
(_('Serving for'), datetime.now() - time_started),
(_('Clock'), uwsgi.clock),
(_('Master PID'), uwsgi.master_pid),
(_('Memory (RSS, VSZ)'), '\n'.join((filesizeformat(rss), filesizeformat(vsz)))),
(_('Buffer size'), uwsgi.buffer_size),
(_('Cores'), uwsgi.cores_count),
(_('Workers'), uwsgi.workers_count),
(_('Mules'), config.get('mules', 0)),
(_('Farms'), '\n'.join(map(str, Farm.get_farms()))),
(_('Threads support'), '+' if uwsgi.threads_enabled else '-'),
(_('Current worker'), uwsgi.worker_id),
(_('Requests by worker'), uwsgi.request.id),
(_('Requests total'), uwsgi.request.total_count),
(_('Socket queue size'), uwsgi.get_listen_queue()),
(_('Log size'), get_current_log_size()),
(_('RPC'), '\n'.join(get_rpc_list())),
(_('Post fork hooks'), '\n'.join(map(get_func_name, uwsgi.postfork_hooks.funcs))),
(_('Signals'), '\n'.join(get_signals_info(registry_signals))),
(_('Spoolers'), '\n'.join(map(str, Spooler.get_spoolers()))),
])
info_basic = {
_('Version'): uwsgi.get_version(),
_('Hostname'): uwsgi.hostname,
_('Serving since'): time_started,
_('Serving for'): datetime.now() - time_started,
_('Clock'): uwsgi.clock,
_('Master PID'): uwsgi.master_pid,
_('Memory (RSS, VSZ)'): '\n'.join((filesizeformat(rss), filesizeformat(vsz))),
_('Buffer size'): uwsgi.buffer_size,
_('Cores'): uwsgi.cores_count,
_('Workers'): uwsgi.workers_count,
_('Mules'): config.get('mules', 0),
_('Farms'): '\n'.join(map(str, Farm.get_farms())),
_('Threads support'): '+' if uwsgi.threads_enabled else '-',
_('Current worker'): uwsgi.worker_id,
_('Requests by worker'): uwsgi.request.id,
_('Requests total'): uwsgi.request.total_count,
_('Socket queue size'): uwsgi.get_listen_queue(),
_('Log size'): get_current_log_size(),
_('RPC'): '\n'.join(get_rpc_list()),
_('Post fork hooks'): '\n'.join(map(get_func_name, uwsgi.postfork_hooks.funcs)),
_('Signals'): '\n'.join(get_signals_info(registry_signals)),
_('Spoolers'): '\n'.join(map(str, Spooler.get_spoolers())),
}

context.update({
'panels': {
'': {
'rows': OrderedDict(((key, [val]) for key, val in info_basic.items())),
'rows': dict((key, [val]) for key, val in info_basic.items()),
}
},
})
Expand All @@ -82,7 +81,7 @@ def contribute_onepage_context(self, request, context):

context.update({
'panels': {
'': {'rows': OrderedDict(((key, [val]) for key, val in uwsgi.config.items()))},
'': {'rows': dict((key, [val]) for key, val in uwsgi.config.items())},
},
})

Expand All @@ -94,46 +93,41 @@ def contribute_onepage_context(self, request, context):

fromts = datetime.fromtimestamp

info_worker_map = OrderedDict([
('id', (_('ID'), None)),
('pid', (_('PID'), None)),
('status', (_('Status'), None)),

('running_time', (_('Running for'), lambda val: timedelta(microseconds=val))),
('last_spawn', (_('Spawned at'), lambda val: fromts(val))),

('respawn_count', (_('Respawns'), None)),
('requests', (_('Requests'), None)),
('delta_requests', (_('Delta requests'), None)), # Used alongside with MAX_REQUESTS
('exceptions', (_('Exceptions'), None)),
('signals', (_('Signals'), None)),

('rss', (_('RSS'), lambda val: filesizeformat(val))),
('vsz', (_('VSZ'), lambda val: filesizeformat(val))),

('tx', (_('Transmitted'), lambda val: filesizeformat(val))),
('avg_rt', (_('Avg. response'), lambda val: timedelta(microseconds=val))),

('apps', (None, lambda val: iter_items(val, info_app_map))),
])

info_app_map = OrderedDict([
('id', (_('ID'), None)),
('startup_time', (_('Serving since'), None)),
('interpreter', (_('Interpreter'), None)),
('modifier1', (_('Modifier 1'), None)),
('mountpoint', (_('Mountpoint'), None)),
('callable', (_('Callable'), None)),
('chdir', (_('Directory'), None)),
('requests', (_('Requests'), None)),
('exceptions', (_('Exceptions'), None)),
])

panels = OrderedDict()
info_workers = OrderedDict()
info_worker_map = {
'id': (_('ID'), None),
'pid': (_('PID'), None),
'status': (_('Status'), None),
'running_time': (_('Running for'), lambda val: timedelta(microseconds=val)),
'last_spawn': (_('Spawned at'), lambda val: fromts(val)),
'respawn_count': (_('Respawns'), None),
'requests': (_('Requests'), None),
'delta_requests': (_('Delta requests'), None), # Used alongside with MAX_REQUESTS
'exceptions': (_('Exceptions'), None),
'signals': (_('Signals'), None),
'rss': (_('RSS'), lambda val: filesizeformat(val)),
'vsz': (_('VSZ'), lambda val: filesizeformat(val)),
'tx': (_('Transmitted'), lambda val: filesizeformat(val)),
'avg_rt': (_('Avg. response'), lambda val: timedelta(microseconds=val)),
'apps': (None, lambda val: iter_items(val, info_app_map)),
}

info_app_map = {
'id': (_('ID'), None),
'startup_time': (_('Serving since'), None),
'interpreter': (_('Interpreter'), None),
'modifier1': (_('Modifier 1'), None),
'mountpoint': (_('Mountpoint'), None),
'callable': (_('Callable'), None),
'chdir': (_('Directory'), None),
'requests': (_('Requests'), None),
'exceptions': (_('Exceptions'), None),
}

panels = {}
info_workers = {}
panels[''] = {'rows': info_workers}

info_apps = OrderedDict()
info_apps = {}

def iter_items(info, mapping):

Expand All @@ -157,7 +151,7 @@ def iter_items(info, mapping):
# Get info about applications served by worker,
for idx_app, keyname_app, name_app, value_app in value_worker:
app_key = f'%s {idx_worker + 1}. %s {idx_app}' % (_('Worker'), _('Application'))
info_apps.setdefault(app_key, OrderedDict())[name_app] = [value_app]
info_apps.setdefault(app_key, {})[name_app] = [value_app]

else:
info_workers.setdefault(name_worker, []).append(value_worker)
Expand Down

0 comments on commit 028d445

Please sign in to comment.