diff options
author | Matus Valo <matusvalo@gmail.com> | 2017-09-05 07:28:41 -0700 |
---|---|---|
committer | Matus Valo <matusvalo@gmail.com> | 2017-09-05 07:31:41 -0700 |
commit | 593281d950e8bc95f5f83fa26c9aaa54d72e0a5c (patch) | |
tree | 4e66b95c1660e843cbdf7ff8766a042d1f56fe4e | |
parent | a8593a1efb55b8aadc69908493660e47e9f0176d (diff) | |
download | librabbitmq-593281d950e8bc95f5f83fa26c9aaa54d72e0a5c.tar.gz |
Removed python <= 2.6 compatibility ifdefs
-rw-r--r-- | Modules/_librabbitmq/connection.c | 30 | ||||
-rw-r--r-- | Modules/_librabbitmq/connection.h | 14 |
2 files changed, 16 insertions, 28 deletions
diff --git a/Modules/_librabbitmq/connection.c b/Modules/_librabbitmq/connection.c index 6626e47..5216a80 100644 --- a/Modules/_librabbitmq/connection.c +++ b/Modules/_librabbitmq/connection.c @@ -248,8 +248,8 @@ PyDict_ToAMQTable(amqp_connection_state_t conn, PyObject *src, amqp_pool_t *pool { PyObject *dkey = NULL; PyObject *dvalue = NULL; - PY_SIZE_TYPE size = 0; - PY_SIZE_TYPE pos = 0; + Py_ssize_t size = 0; + Py_ssize_t pos = 0; uint64_t clong_value = 0; double cdouble_value = 0.0; int is_unicode = 0; @@ -343,12 +343,12 @@ error: static amqp_array_t PyIter_ToAMQArray(amqp_connection_state_t conn, PyObject *src, amqp_pool_t *pool) { - PY_SIZE_TYPE pos = 0; + Py_ssize_t pos = 0; uint64_t clong_value = 0; int is_unicode = 0; amqp_array_t dst = AMQP_EMPTY_ARRAY; - PY_SIZE_TYPE size = PySequence_Size(src); + Py_ssize_t size = PySequence_Size(src); if (size == -1) return dst; PyObject *iterator = PyObject_GetIter(src); @@ -608,7 +608,7 @@ AMQArray_toPyList(amqp_array_t *array) { register PyObject *value = NULL; PyObject *list = NULL; - list = PyList_New((PY_SIZE_TYPE) array->num_entries); + list = PyList_New((Py_ssize_t) array->num_entries); if (array) { int i; @@ -1304,8 +1304,8 @@ PyRabbitMQ_recv(PyRabbitMQ_Connection *self, PyObject *p, amqp_frame_t frame; amqp_basic_deliver_t *deliver; amqp_basic_properties_t *props; - PY_SIZE_TYPE body_target; - PY_SIZE_TYPE body_received; + Py_ssize_t body_target; + Py_ssize_t body_received; PyObject *channel = NULL; PyObject *consumer_tag = NULL; PyObject *delivery_info = NULL; @@ -1386,14 +1386,14 @@ PyRabbitMQ_recv(PyRabbitMQ_Connection *self, PyObject *p, if (!i) { if (body_received < body_target) { payload = PyString_FromStringAndSize(NULL, - (PY_SIZE_TYPE)body_target); + (Py_ssize_t)body_target); if (!payload) goto finally; buf = PyString_AsString(payload); if (!buf) goto finally; view = PyBuffer_FromObject(payload, 0, - (PY_SIZE_TYPE)body_target); + (Py_ssize_t)body_target); } else { if (p) { @@ -1401,7 +1401,7 @@ PyRabbitMQ_recv(PyRabbitMQ_Connection *self, PyObject *p, frame.payload.body_fragment); } else { view = PyBuffer_FromMemory(bufp, - (PY_SIZE_TYPE)frame.payload.body_fragment.len); + (Py_ssize_t)frame.payload.body_fragment.len); } break; } @@ -1654,7 +1654,7 @@ PyRabbitMQ_Connection_queue_declare(PyRabbitMQ_Connection *self, if ((ret = PyTuple_New(3)) == NULL) goto bail; PyTuple_SET_ITEM(ret, 0, PyString_FromStringAndSize(ok->queue.bytes, - (PY_SIZE_TYPE)ok->queue.len)); + (Py_ssize_t)ok->queue.len)); PyTuple_SET_ITEM(ret, 1, PyInt_FromLong((long)ok->message_count)); PyTuple_SET_ITEM(ret, 2, PyInt_FromLong((long)ok->consumer_count)); return ret; @@ -1808,7 +1808,7 @@ PyRabbitMQ_Connection_basic_publish(PyRabbitMQ_Connection *self, unsigned int immediate = 0; char *body_buf = NULL; - PY_SIZE_TYPE body_size = 0; + Py_ssize_t body_size = 0; int ret = 0; amqp_basic_properties_t props; @@ -1866,7 +1866,7 @@ static PyObject* PyRabbitMQ_Connection_basic_ack(PyRabbitMQ_Connection *self, PyObject *args) { - PY_SIZE_TYPE delivery_tag = 0; + Py_ssize_t delivery_tag = 0; unsigned int channel = 0; unsigned int multiple = 0; int ret = 0; @@ -1899,7 +1899,7 @@ bail: static PyObject *PyRabbitMQ_Connection_basic_reject(PyRabbitMQ_Connection *self, PyObject *args) { - PY_SIZE_TYPE delivery_tag = 0; + Py_ssize_t delivery_tag = 0; unsigned int channel = 0; unsigned int multiple = 0; @@ -2030,7 +2030,7 @@ PyRabbitMQ_Connection_basic_qos(PyRabbitMQ_Connection *self, PyObject *args) { unsigned int channel = 0; - PY_SIZE_TYPE prefetch_size = 0; + Py_ssize_t prefetch_size = 0; unsigned int prefetch_count = 0; unsigned int _global = 0; diff --git a/Modules/_librabbitmq/connection.h b/Modules/_librabbitmq/connection.h index 98de26c..f4e4e45 100644 --- a/Modules/_librabbitmq/connection.h +++ b/Modules/_librabbitmq/connection.h @@ -8,18 +8,6 @@ #include <amqp.h> #include <amqp_framing.h> -#if PY_VERSION_HEX < 0x02060000 && !defined(Py_SIZE) -# define Py_SIZE(ob) (((PyVarObject*)(ob))->ob_size) -#endif -#if PY_VERSION_HEX >= 0x02060000 /* 2.6 and up */ -# define PY_SIZE_TYPE Py_ssize_t -# define PyLong_FROM_SSIZE_T PyLong_FromSsize_t -# define PyLong_AS_SSIZE_T PyLong_AsSsize_t -# else /* 2.5 and below */ -# define PY_SIZE_TYPE unsigned long -# define PyLong_FROM_SSIZE_T PyLong_FromUnsignedLong -# define PyLong_AS_SSIZE_T PyLong_AsUnsignedLong -#endif #if PY_VERSION_HEX >= 0x03000000 /* 3.0 and up */ # define FROM_FORMAT PyUnicode_FromFormat @@ -69,7 +57,7 @@ } while(0) #define PySTRING_FROM_AMQBYTES(member) \ - PyString_FromStringAndSize(member.bytes, (PY_SIZE_TYPE)member.len); \ + PyString_FromStringAndSize(member.bytes, (Py_ssize_t)member.len); \ #define AMQTable_TO_PYKEY(table, i) \ PySTRING_FROM_AMQBYTES(table->entries[i].key) |