diff options
Diffstat (limited to 'swift/1.4.8/plugins/middleware')
-rw-r--r-- | swift/1.4.8/plugins/middleware/__init__.py | 0 | ||||
-rw-r--r-- | swift/1.4.8/plugins/middleware/gluster.py | 40 | ||||
-rw-r--r-- | swift/1.4.8/plugins/middleware/glusterfs.py | 55 |
3 files changed, 95 insertions, 0 deletions
diff --git a/swift/1.4.8/plugins/middleware/__init__.py b/swift/1.4.8/plugins/middleware/__init__.py new file mode 100644 index 00000000000..e69de29bb2d --- /dev/null +++ b/swift/1.4.8/plugins/middleware/__init__.py diff --git a/swift/1.4.8/plugins/middleware/gluster.py b/swift/1.4.8/plugins/middleware/gluster.py new file mode 100644 index 00000000000..e0e65e35312 --- /dev/null +++ b/swift/1.4.8/plugins/middleware/gluster.py @@ -0,0 +1,40 @@ +# Copyright (c) 2012 Red Hat, Inc. +# +# 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. + +# Noop Middleware that simply allows us to monkey patch the constraints +import swift.plugins.constraints + +class Gluster(object): + """ + Noop middleware for use with the proxy server to get paste.deploy to load + this middleware such that the plugin constraints monkey patch the common + constraints ahead of their use. + """ + def __init__(self, app, conf): + self.app = app + self.conf = conf + + def __call__(self, env, start_response): + return self.app(env, start_response) + + +def filter_factory(global_conf, **local_conf): + """Returns a WSGI filter app for use with paste.deploy.""" + conf = global_conf.copy() + conf.update(local_conf) + + def gluster_filter(app): + return Gluster(app, conf) + return gluster_filter diff --git a/swift/1.4.8/plugins/middleware/glusterfs.py b/swift/1.4.8/plugins/middleware/glusterfs.py new file mode 100644 index 00000000000..7472146406c --- /dev/null +++ b/swift/1.4.8/plugins/middleware/glusterfs.py @@ -0,0 +1,55 @@ +# Copyright (c) 2012 Red Hat, Inc. +# +# 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. + +# Monkey patch constraints +import swift.plugins.constraints +from swift.plugins.Glusterfs import Glusterfs +from ConfigParser import ConfigParser + +fs_conf = ConfigParser() +if fs_conf.read('/etc/swift/fs.conf'): + try: + mount_path = fs_conf.get ('DEFAULT', 'mount_path') + except NoSectionError, NoOptionError: + # FIXME - How to log during module initialization + logger.exception(_('ERROR mount_path not present')) + mount_path = '' +else: + mount_path = '' + + +class Gluster(object): + """ + Update the environment with keys that reflect GlusterFS middleware enabled + """ + def __init__(self, app, conf): + self.app = app + self.conf = conf + + def __call__(self, env, start_response): + env['Gluster_enabled'] = True + env['fs_object'] = Glusterfs() + env['root'] = mount_path + return self.app(env, start_response) + + +def filter_factory(global_conf, **local_conf): + """Returns a WSGI filter app for use with paste.deploy.""" + conf = global_conf.copy() + conf.update(local_conf) + + def gluster_filter(app): + return Gluster(app, conf) + return gluster_filter |