[prev in list] [next in list] [prev in thread] [next in thread]
List: sanlock-devel
Subject: 2 commits - python/sanlock.c
From: teigland () fedoraproject ! org (David Teigland)
Date: 2012-12-06 20:36:46
Message-ID: 20121206203646.CD866133E () hosted02 ! fedoraproject ! org
[Download RAW message or body]
python/sanlock.c | 249 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 file changed, 249 insertions(+)
New commits:
commit 2a1bc7aeff0113c314826d37a7bb3cac710bf745
Author: Federico Simoncelli <fsimonce at redhat.com>
Date: Fri Nov 30 12:22:02 2012 -0500
python: add read lockspace and resource
Signed-off-by: Federico Simoncelli <fsimonce at redhat.com>
diff --git a/python/sanlock.c b/python/sanlock.c
index 2fc34ca..92e1396 100644
--- a/python/sanlock.c
+++ b/python/sanlock.c
@@ -310,6 +310,151 @@ py_write_lockspace(PyObject *self __unused, PyObject *args, PyObject *keywds)
Py_RETURN_NONE;
}
+/* read_lockspace */
+PyDoc_STRVAR(pydoc_read_lockspace, "\
+read_lockspace(path, offset=0) -> dict\n\
+Read the lockspace information from a device at a specific offset.");
+
+static PyObject *
+py_read_lockspace(PyObject *self __unused, PyObject *args, PyObject *keywds)
+{
+ int rv;
+ uint32_t io_timeout = 0;
+ const char *path;
+ struct sanlk_lockspace ls;
+ PyObject *ls_info = NULL, *ls_entry = NULL;
+
+ static char *kwlist[] = {"path", "offset", NULL};
+
+ /* initialize lockspace structure */
+ memset(&ls, 0, sizeof(struct sanlk_lockspace));
+
+ /* parse python tuple */
+ if (!PyArg_ParseTupleAndKeywords(args, keywds, "s|k", kwlist,
+ &path, &ls.host_id_disk.offset)) {
+ return NULL;
+ }
+
+ /* prepare sanlock names */
+ strncpy(ls.host_id_disk.path, path, SANLK_PATH_LEN - 1);
+
+ /* read sanlock lockspace (gil disabled) */
+ Py_BEGIN_ALLOW_THREADS
+ rv = sanlock_read_lockspace(&ls, 0, &io_timeout);
+ Py_END_ALLOW_THREADS
+
+ if (rv != 0) {
+ __set_exception(rv, "Sanlock lockspace read failure");
+ return NULL;
+ }
+
+ /* prepare the dictionary holding the information */
+ if ((ls_info = PyDict_New()) == NULL)
+ goto exit_fail;
+
+ /* fill the dictionary information: lockspace */
+ if ((ls_entry = PyString_FromString(ls.name)) == NULL)
+ goto exit_fail;
+ rv = PyDict_SetItemString(ls_info, "lockspace", ls_entry);
+ Py_DECREF(ls_entry);
+ if (rv != 0)
+ goto exit_fail;
+
+ /* fill the dictionary information: iotimeout */
+ if ((ls_entry = PyInt_FromLong(io_timeout)) == NULL)
+ goto exit_fail;
+ Py_DECREF(ls_entry);
+ rv = PyDict_SetItemString(ls_info, "iotimeout", ls_entry);
+ if (rv != 0)
+ goto exit_fail;
+
+ /* success */
+ return ls_info;
+
+ /* failure */
+exit_fail:
+ Py_XDECREF(ls_info);
+ return NULL;
+}
+
+/* read_resource */
+PyDoc_STRVAR(pydoc_read_resource, "\
+read_resource(path, offset=0) -> dict\n\
+Read the resource information from a device at a specific offset.");
+
+static PyObject *
+py_read_resource(PyObject *self __unused, PyObject *args, PyObject *keywds)
+{
+ int rv, rs_len;
+ const char *path;
+ struct sanlk_resource *rs;
+ PyObject *rs_info = NULL, *rs_entry = NULL;
+
+ static char *kwlist[] = {"path", "offset", NULL};
+
+ /* allocate the needed memory for the resource and one disk */
+ rs_len = sizeof(struct sanlk_resource) + sizeof(struct sanlk_disk);
+ rs = malloc(rs_len);
+
+ if (rs == NULL) {
+ PyErr_NoMemory();
+ return NULL;
+ }
+
+ /* initialize resource and disk structures */
+ memset(rs, 0, rs_len);
+ rs->num_disks = 1;
+
+ /* parse python tuple */
+ if (!PyArg_ParseTupleAndKeywords(args, keywds, "s|k", kwlist,
+ &path, &(rs->disks[0].offset))) {
+ goto exit_fail;
+ }
+
+ /* prepare the resource disk path */
+ strncpy(rs->disks[0].path, path, SANLK_PATH_LEN - 1);
+
+ /* read sanlock resource (gil disabled) */
+ Py_BEGIN_ALLOW_THREADS
+ rv = sanlock_read_resource(rs, 0);
+ Py_END_ALLOW_THREADS
+
+ if (rv != 0) {
+ __set_exception(rv, "Sanlock resource read failure");
+ goto exit_fail;
+ }
+
+ /* prepare the dictionary holding the information */
+ if ((rs_info = PyDict_New()) == NULL)
+ goto exit_fail;
+
+ /* fill the dictionary information: lockspace */
+ if ((rs_entry = PyString_FromString(rs->lockspace_name)) == NULL)
+ goto exit_fail;
+ rv = PyDict_SetItemString(rs_info, "lockspace", rs_entry);
+ Py_DECREF(rs_entry);
+ if (rv != 0)
+ goto exit_fail;
+
+ /* fill the dictionary information: resource */
+ if ((rs_entry = PyString_FromString(rs->name)) == NULL)
+ goto exit_fail;
+ rv = PyDict_SetItemString(rs_info, "resource", rs_entry);
+ Py_DECREF(rs_entry);
+ if (rv != 0)
+ goto exit_fail;
+
+ /* success */
+ free(rs);
+ return rs_info;
+
+ /* failure */
+exit_fail:
+ free(rs);
+ Py_XDECREF(rs_info);
+ return NULL;
+}
+
/* write_resource */
PyDoc_STRVAR(pydoc_write_resource, "\
write_resource(lockspace, resource, disks, max_hosts=0, num_hosts=0)\n\
@@ -748,6 +893,10 @@ sanlock_methods[] = {
METH_VARARGS|METH_KEYWORDS, pydoc_write_lockspace},
{"write_resource", (PyCFunction) py_write_resource,
METH_VARARGS|METH_KEYWORDS, pydoc_write_resource},
+ {"read_lockspace", (PyCFunction) py_read_lockspace,
+ METH_VARARGS|METH_KEYWORDS, pydoc_read_lockspace},
+ {"read_resource", (PyCFunction) py_read_resource,
+ METH_VARARGS|METH_KEYWORDS, pydoc_read_resource},
{"add_lockspace", (PyCFunction) py_add_lockspace,
METH_VARARGS|METH_KEYWORDS, pydoc_add_lockspace},
{"inq_lockspace", (PyCFunction) py_inq_lockspace,
commit 35bf5036c86f51a53a103d2ea61f8c42dcfe93ef
Author: Federico Simoncelli <fsimonce at redhat.com>
Date: Thu Dec 6 09:20:16 2012 -0500
python: add write lockspace and resource
Signed-off-by: Federico Simoncelli <fsimonce at redhat.com>
diff --git a/python/sanlock.c b/python/sanlock.c
index c57909a..2fc34ca 100644
--- a/python/sanlock.c
+++ b/python/sanlock.c
@@ -174,6 +174,7 @@ py_get_alignment(PyObject *self __unused, PyObject *args)
PyDoc_STRVAR(pydoc_init_lockspace, "\
init_lockspace(lockspace, path, offset=0, max_hosts=0, num_hosts=0, \
use_aio=True)\n\
+*DEPRECATED* use write_lockspace instead.\n\
Initialize a device to be used as sanlock lockspace.");
static PyObject *
@@ -217,6 +218,7 @@ py_init_lockspace(PyObject *self __unused, PyObject *args, PyObject *keywds)
PyDoc_STRVAR(pydoc_init_resource, "\
init_resource(lockspace, resource, disks, max_hosts=0, num_hosts=0, \
use_aio=True)\n\
+*DEPRECATED* use write_resource instead.\n\
Initialize a device to be used as sanlock resource.\n\
The disks must be in the format: [(path, offset), ... ]");
@@ -265,6 +267,100 @@ exit_fail:
return NULL;
}
+/* write_lockspace */
+PyDoc_STRVAR(pydoc_write_lockspace, "\
+write_lockspace(lockspace, path, offset=0, max_hosts=0, iotimeout=0)\n\
+Initialize or update a device to be used as sanlock lockspace.");
+
+static PyObject *
+py_write_lockspace(PyObject *self __unused, PyObject *args, PyObject *keywds)
+{
+ int rv, max_hosts = 0;
+ uint32_t io_timeout = 0;
+ const char *lockspace, *path;
+ struct sanlk_lockspace ls;
+
+ static char *kwlist[] = {"lockspace", "path", "offset", "max_hosts",
+ "iotimeout", NULL};
+
+ /* initialize lockspace structure */
+ memset(&ls, 0, sizeof(struct sanlk_lockspace));
+
+ /* parse python tuple */
+ if (!PyArg_ParseTupleAndKeywords(args, keywds, "ss|kiiI", kwlist,
+ &lockspace, &path, &ls.host_id_disk.offset, &max_hosts,
+ &io_timeout)) {
+ return NULL;
+ }
+
+ /* prepare sanlock names */
+ strncpy(ls.name, lockspace, SANLK_NAME_LEN);
+ strncpy(ls.host_id_disk.path, path, SANLK_PATH_LEN - 1);
+
+ /* write sanlock lockspace (gil disabled) */
+ Py_BEGIN_ALLOW_THREADS
+ rv = sanlock_write_lockspace(&ls, max_hosts, 0, io_timeout);
+ Py_END_ALLOW_THREADS
+
+ if (rv != 0) {
+ __set_exception(rv, "Sanlock lockspace write failure");
+ return NULL;
+ }
+
+ Py_RETURN_NONE;
+}
+
+/* write_resource */
+PyDoc_STRVAR(pydoc_write_resource, "\
+write_resource(lockspace, resource, disks, max_hosts=0, num_hosts=0)\n\
+Initialize a device to be used as sanlock resource.\n\
+The disks must be in the format: [(path, offset), ... ]");
+
+static PyObject *
+py_write_resource(PyObject *self __unused, PyObject *args, PyObject *keywds)
+{
+ int rv, max_hosts = 0, num_hosts = 0;
+ const char *lockspace, *resource;
+ struct sanlk_resource *rs;
+ PyObject *disks;
+
+ static char *kwlist[] = {"lockspace", "resource", "disks", "max_hosts",
+ "num_hosts", NULL};
+
+ /* parse python tuple */
+ if (!PyArg_ParseTupleAndKeywords(args, keywds, "ssO!|iii",
+ kwlist, &lockspace, &resource, &PyList_Type, &disks, &max_hosts,
+ &num_hosts)) {
+ return NULL;
+ }
+
+ /* parse and check sanlock resource */
+ if (__parse_resource(disks, &rs) != 0) {
+ return NULL;
+ }
+
+ /* prepare sanlock names */
+ strncpy(rs->lockspace_name, lockspace, SANLK_NAME_LEN);
+ strncpy(rs->name, resource, SANLK_NAME_LEN);
+
+ /* init sanlock resource (gil disabled) */
+ Py_BEGIN_ALLOW_THREADS
+ rv = sanlock_write_resource(rs, max_hosts, num_hosts, 0);
+ Py_END_ALLOW_THREADS
+
+ if (rv != 0) {
+ __set_exception(rv, "Sanlock resource write failure");
+ goto exit_fail;
+ }
+
+ free(rs);
+ Py_RETURN_NONE;
+
+exit_fail:
+ free(rs);
+ return NULL;
+}
+
/* add_lockspace */
PyDoc_STRVAR(pydoc_add_lockspace, "\
add_lockspace(lockspace, host_id, path, offset=0, iotimeout=0, async=False)\n\
@@ -648,6 +744,10 @@ sanlock_methods[] = {
METH_VARARGS|METH_KEYWORDS, pydoc_init_lockspace},
{"init_resource", (PyCFunction) py_init_resource,
METH_VARARGS|METH_KEYWORDS, pydoc_init_resource},
+ {"write_lockspace", (PyCFunction) py_write_lockspace,
+ METH_VARARGS|METH_KEYWORDS, pydoc_write_lockspace},
+ {"write_resource", (PyCFunction) py_write_resource,
+ METH_VARARGS|METH_KEYWORDS, pydoc_write_resource},
{"add_lockspace", (PyCFunction) py_add_lockspace,
METH_VARARGS|METH_KEYWORDS, pydoc_add_lockspace},
{"inq_lockspace", (PyCFunction) py_inq_lockspace,
[prev in list] [next in list] [prev in thread] [next in thread]
Configure |
About |
News |
Add a list |
Sponsored by KoreLogic