Gecko [ c.stage.kornherr.net ]

Name	Size	Permission	Date
__pycache__	[ DIR ]	drwxr-xr-x	2024-07-10 10:57
__init__.py	377 B	-rw-r--r--	2021-05-10 10:30
compose_spec.json	25.13 KB	-rw-r--r--	2021-05-10 10:30
config.py	48.92 KB	-rw-r--r--	2021-05-10 10:30
config_schema_v1.json	5.7 KB	-rw-r--r--	2021-05-10 10:30
environment.py	3.77 KB	-rw-r--r--	2021-05-10 10:30
errors.py	1.68 KB	-rw-r--r--	2021-05-10 10:30
interpolation.py	9.82 KB	-rw-r--r--	2021-05-10 10:30
serialize.py	4.97 KB	-rw-r--r--	2021-05-10 10:30
sort_services.py	2.43 KB	-rw-r--r--	2021-05-10 10:30
types.py	15.44 KB	-rw-r--r--	2021-05-10 10:30
validation.py	19.43 KB	-rw-r--r--	2021-05-10 10:30

Rename

from compose.config.errors import DependencyError

def get_service_name_from_network_mode(network_mode):
    return get_source_name_from_network_mode(network_mode, 'service')

def get_container_name_from_network_mode(network_mode):
    return get_source_name_from_network_mode(network_mode, 'container')

def get_source_name_from_network_mode(network_mode, source_type):
    if not network_mode:
        return

if not network_mode.startswith(source_type+':'):
        return

_, net_name = network_mode.split(':', 1)
    return net_name

def get_service_names(links):
    return [link.split(':', 1)[0] for link in links]

def get_service_names_from_volumes_from(volumes_from):
    return [volume_from.source for volume_from in volumes_from]

def get_service_dependents(service_dict, services):
    name = service_dict['name']
    return [
        service for service in services
        if (name in get_service_names(service.get('links', [])) or
            name in get_service_names_from_volumes_from(service.get('volumes_from', [])) or
            name == get_service_name_from_network_mode(service.get('network_mode')) or
            name == get_service_name_from_network_mode(service.get('pid')) or
            name == get_service_name_from_network_mode(service.get('ipc')) or
            name in service.get('depends_on', []))
    ]

def sort_service_dicts(services):
    # Topological sort (Cormen/Tarjan algorithm).
    unmarked = services[:]
    temporary_marked = set()
    sorted_services = []

def visit(n):
        if n['name'] in temporary_marked:
            if n['name'] in get_service_names(n.get('links', [])):
                raise DependencyError('A service can not link to itself: %s' % n['name'])
            if n['name'] in n.get('volumes_from', []):
                raise DependencyError('A service can not mount itself as volume: %s' % n['name'])
            if n['name'] in n.get('depends_on', []):
                raise DependencyError('A service can not depend on itself: %s' % n['name'])
            raise DependencyError('Circular dependency between %s' % ' and '.join(temporary_marked))

if n in unmarked:
            temporary_marked.add(n['name'])
            for m in get_service_dependents(n, services):
                visit(m)
            temporary_marked.remove(n['name'])
            unmarked.remove(n)
            sorted_services.insert(0, n)

while unmarked:
        visit(unmarked[-1])

return sorted_services