Remove dead code from _multiprocessing

This commit is contained in:
Antoine Pitrou 2011-05-09 20:55:03 +02:00
parent fc75393275
commit 2341f9ba00
3 changed files with 3 additions and 58 deletions

View File

@ -16,7 +16,6 @@
PyObject *create_win32_namespace(void); PyObject *create_win32_namespace(void);
PyObject *pickle_dumps, *pickle_loads, *pickle_protocol;
PyObject *ProcessError, *BufferTooShort; PyObject *ProcessError, *BufferTooShort;
/* /*
@ -177,7 +176,7 @@ multiprocessing_address_of_buffer(PyObject *self, PyObject *obj)
if (PyObject_AsWriteBuffer(obj, &buffer, &buffer_len) < 0) if (PyObject_AsWriteBuffer(obj, &buffer, &buffer_len) < 0)
return NULL; return NULL;
return Py_BuildValue("N" F_PY_SSIZE_T, return Py_BuildValue("Nn",
PyLong_FromVoidPtr(buffer), buffer_len); PyLong_FromVoidPtr(buffer), buffer_len);
} }
@ -231,15 +230,6 @@ PyInit__multiprocessing(void)
if (!module) if (!module)
return NULL; return NULL;
/* Get copy of objects from pickle */
temp = PyImport_ImportModule(PICKLE_MODULE);
if (!temp)
return NULL;
pickle_dumps = PyObject_GetAttrString(temp, "dumps");
pickle_loads = PyObject_GetAttrString(temp, "loads");
pickle_protocol = PyObject_GetAttrString(temp, "HIGHEST_PROTOCOL");
Py_XDECREF(temp);
/* Get copy of BufferTooShort */ /* Get copy of BufferTooShort */
temp = PyImport_ImportModule("multiprocessing"); temp = PyImport_ImportModule("multiprocessing");
if (!temp) if (!temp)

View File

@ -63,20 +63,6 @@
#endif #endif
/*
* Make sure Py_ssize_t available
*/
#if PY_VERSION_HEX < 0x02050000 && !defined(PY_SSIZE_T_MIN)
typedef int Py_ssize_t;
# define PY_SSIZE_T_MAX INT_MAX
# define PY_SSIZE_T_MIN INT_MIN
# define F_PY_SSIZE_T "i"
# define PyInt_FromSsize_t(n) PyInt_FromLong((long)n)
#else
# define F_PY_SSIZE_T "n"
#endif
/* /*
* Format codes * Format codes
*/ */
@ -105,12 +91,6 @@
# define T_SEM_HANDLE T_POINTER # define T_SEM_HANDLE T_POINTER
#endif #endif
#if PY_VERSION_HEX >= 0x03000000
# define F_RBUFFER "y"
#else
# define F_RBUFFER "s"
#endif
/* /*
* Error codes which can be returned by functions called without GIL * Error codes which can be returned by functions called without GIL
*/ */
@ -127,36 +107,11 @@ PyObject *mp_SetError(PyObject *Type, int num);
* Externs - not all will really exist on all platforms * Externs - not all will really exist on all platforms
*/ */
extern PyObject *pickle_dumps;
extern PyObject *pickle_loads;
extern PyObject *pickle_protocol;
extern PyObject *BufferTooShort; extern PyObject *BufferTooShort;
extern PyTypeObject SemLockType; extern PyTypeObject SemLockType;
extern PyTypeObject PipeConnectionType; extern PyTypeObject PipeConnectionType;
extern HANDLE sigint_event; extern HANDLE sigint_event;
/*
* Py3k compatibility
*/
#if PY_VERSION_HEX >= 0x03000000
# define PICKLE_MODULE "pickle"
# define FROM_FORMAT PyUnicode_FromFormat
# define PyInt_FromLong PyLong_FromLong
# define PyInt_FromSsize_t PyLong_FromSsize_t
#else
# define PICKLE_MODULE "cPickle"
# define FROM_FORMAT PyString_FromFormat
#endif
#ifndef PyVarObject_HEAD_INIT
# define PyVarObject_HEAD_INIT(type, size) PyObject_HEAD_INIT(type) size,
#endif
#ifndef Py_TPFLAGS_HAVE_WEAKREFS
# define Py_TPFLAGS_HAVE_WEAKREFS 0
#endif
/* /*
* Miscellaneous * Miscellaneous
*/ */

View File

@ -481,7 +481,7 @@ semlock_dealloc(SemLockObject* self)
static PyObject * static PyObject *
semlock_count(SemLockObject *self) semlock_count(SemLockObject *self)
{ {
return PyInt_FromLong((long)self->count); return PyLong_FromLong((long)self->count);
} }
static PyObject * static PyObject *
@ -505,7 +505,7 @@ semlock_getvalue(SemLockObject *self)
the number of waiting threads */ the number of waiting threads */
if (sval < 0) if (sval < 0)
sval = 0; sval = 0;
return PyInt_FromLong((long)sval); return PyLong_FromLong((long)sval);
#endif #endif
} }