diff options
author | Brett Cannon <bcannon@gmail.com> | 2010-05-05 20:15:14 (GMT) |
---|---|---|
committer | Brett Cannon <bcannon@gmail.com> | 2010-05-05 20:15:14 (GMT) |
commit | 7a4cd7e1e2cff1d3a3ef079e47f0b0f833dae1de (patch) | |
tree | 0002fe72ec09b96d9e4aed7311ba678c7d9e8fd5 /Modules/_multiprocessing | |
parent | a1b562943b7c14fe85252f40a1a24b7ef1ea9491 (diff) | |
download | cpython-7a4cd7e1e2cff1d3a3ef079e47f0b0f833dae1de.zip cpython-7a4cd7e1e2cff1d3a3ef079e47f0b0f833dae1de.tar.gz cpython-7a4cd7e1e2cff1d3a3ef079e47f0b0f833dae1de.tar.bz2 |
Remove extraneous whitespace.
Diffstat (limited to 'Modules/_multiprocessing')
-rw-r--r-- | Modules/_multiprocessing/connection.h | 66 | ||||
-rw-r--r-- | Modules/_multiprocessing/pipe_connection.c | 4 | ||||
-rw-r--r-- | Modules/_multiprocessing/win32_functions.c | 32 |
3 files changed, 51 insertions, 51 deletions
diff --git a/Modules/_multiprocessing/connection.h b/Modules/_multiprocessing/connection.h index c2f8563..4443bdc 100644 --- a/Modules/_multiprocessing/connection.h +++ b/Modules/_multiprocessing/connection.h @@ -1,5 +1,5 @@ /* - * Definition of a `Connection` type. + * Definition of a `Connection` type. * Used by `socket_connection.c` and `pipe_connection.c`. * * connection.h @@ -42,7 +42,7 @@ connection_new(PyTypeObject *type, PyObject *args, PyObject *kwds) static char *kwlist[] = {"handle", "readable", "writable", NULL}; - if (!PyArg_ParseTupleAndKeywords(args, kwds, F_HANDLE "|ii", kwlist, + if (!PyArg_ParseTupleAndKeywords(args, kwds, F_HANDLE "|ii", kwlist, &handle, &readable, &writable)) return NULL; @@ -53,7 +53,7 @@ connection_new(PyTypeObject *type, PyObject *args, PyObject *kwds) } if (!readable && !writable) { - PyErr_SetString(PyExc_ValueError, + PyErr_SetString(PyExc_ValueError, "either readable or writable must be true"); return NULL; } @@ -120,10 +120,10 @@ connection_sendbytes(ConnectionObject *self, PyObject *args) } else { if (size < 0) { PyErr_SetString(PyExc_ValueError, "size is negative"); - return NULL; + return NULL; } if (offset + size > length) { - PyErr_SetString(PyExc_ValueError, + PyErr_SetString(PyExc_ValueError, "buffer length < offset + size"); return NULL; } @@ -142,7 +142,7 @@ connection_sendbytes(ConnectionObject *self, PyObject *args) } static PyObject * -connection_recvbytes(ConnectionObject *self, PyObject *args) +connection_recvbytes(ConnectionObject *self, PyObject *args) { char *freeme = NULL; Py_ssize_t res, maxlength = PY_SSIZE_T_MAX; @@ -152,15 +152,15 @@ connection_recvbytes(ConnectionObject *self, PyObject *args) return NULL; CHECK_READABLE(self); - + if (maxlength < 0) { PyErr_SetString(PyExc_ValueError, "maxlength < 0"); return NULL; } - - res = conn_recv_string(self, self->buffer, CONNECTION_BUFFER_SIZE, + + res = conn_recv_string(self, self->buffer, CONNECTION_BUFFER_SIZE, &freeme, maxlength); - + if (res < 0) { if (res == MP_BAD_MESSAGE_LENGTH) { if ((self->flags & WRITABLE) == 0) { @@ -173,7 +173,7 @@ connection_recvbytes(ConnectionObject *self, PyObject *args) } } mp_SetError(PyExc_IOError, res); - } else { + } else { if (freeme == NULL) { result = PyString_FromStringAndSize(self->buffer, res); } else { @@ -181,12 +181,12 @@ connection_recvbytes(ConnectionObject *self, PyObject *args) PyMem_Free(freeme); } } - + return result; } static PyObject * -connection_recvbytes_into(ConnectionObject *self, PyObject *args) +connection_recvbytes_into(ConnectionObject *self, PyObject *args) { char *freeme = NULL, *buffer = NULL; Py_ssize_t res, length, offset = 0; @@ -194,8 +194,8 @@ connection_recvbytes_into(ConnectionObject *self, PyObject *args) Py_buffer pbuf; CHECK_READABLE(self); - - if (!PyArg_ParseTuple(args, "w*|" F_PY_SSIZE_T, + + if (!PyArg_ParseTuple(args, "w*|" F_PY_SSIZE_T, &pbuf, &offset)) return NULL; @@ -205,14 +205,14 @@ connection_recvbytes_into(ConnectionObject *self, PyObject *args) if (offset < 0) { PyErr_SetString(PyExc_ValueError, "negative offset"); goto _error; - } + } if (offset > length) { PyErr_SetString(PyExc_ValueError, "offset too large"); goto _error; } - res = conn_recv_string(self, buffer+offset, length-offset, + res = conn_recv_string(self, buffer+offset, length-offset, &freeme, PY_SSIZE_T_MAX); if (res < 0) { @@ -231,8 +231,8 @@ connection_recvbytes_into(ConnectionObject *self, PyObject *args) if (freeme == NULL) { result = PyInt_FromSsize_t(res); } else { - result = PyObject_CallFunction(BufferTooShort, - F_RBUFFER "#", + result = PyObject_CallFunction(BufferTooShort, + F_RBUFFER "#", freeme, res); PyMem_Free(freeme); if (result) { @@ -266,7 +266,7 @@ connection_send_obj(ConnectionObject *self, PyObject *obj) CHECK_WRITABLE(self); - pickled_string = PyObject_CallFunctionObjArgs(pickle_dumps, obj, + pickled_string = PyObject_CallFunctionObjArgs(pickle_dumps, obj, pickle_protocol, NULL); if (!pickled_string) goto failure; @@ -298,7 +298,7 @@ connection_recv_obj(ConnectionObject *self) CHECK_READABLE(self); - res = conn_recv_string(self, self->buffer, CONNECTION_BUFFER_SIZE, + res = conn_recv_string(self, self->buffer, CONNECTION_BUFFER_SIZE, &freeme, PY_SSIZE_T_MAX); if (res < 0) { @@ -313,7 +313,7 @@ connection_recv_obj(ConnectionObject *self) } } mp_SetError(PyExc_IOError, res); - } else { + } else { if (freeme == NULL) { temp = PyString_FromStringAndSize(self->buffer, res); } else { @@ -323,7 +323,7 @@ connection_recv_obj(ConnectionObject *self) } if (temp) - result = PyObject_CallFunctionObjArgs(pickle_loads, + result = PyObject_CallFunctionObjArgs(pickle_loads, temp, NULL); Py_XDECREF(temp); return result; @@ -400,7 +400,7 @@ connection_repr(ConnectionObject *self) static char *conn_type[] = {"read-only", "write-only", "read-write"}; assert(self->flags >= 1 && self->flags <= 3); - return FROM_FORMAT("<%s %s, handle %zd>", + return FROM_FORMAT("<%s %s, handle %zd>", conn_type[self->flags - 1], CONNECTION_NAME, (Py_ssize_t)self->handle); } @@ -432,20 +432,20 @@ connection_writable(ConnectionObject *self, void *closure) */ static PyMethodDef connection_methods[] = { - {"send_bytes", (PyCFunction)connection_sendbytes, METH_VARARGS, + {"send_bytes", (PyCFunction)connection_sendbytes, METH_VARARGS, "send the byte data from a readable buffer-like object"}, - {"recv_bytes", (PyCFunction)connection_recvbytes, METH_VARARGS, + {"recv_bytes", (PyCFunction)connection_recvbytes, METH_VARARGS, "receive byte data as a string"}, {"recv_bytes_into",(PyCFunction)connection_recvbytes_into,METH_VARARGS, "receive byte data into a writeable buffer-like object\n" "returns the number of bytes read"}, - {"send", (PyCFunction)connection_send_obj, METH_O, + {"send", (PyCFunction)connection_send_obj, METH_O, "send a (picklable) object"}, - {"recv", (PyCFunction)connection_recv_obj, METH_NOARGS, + {"recv", (PyCFunction)connection_recv_obj, METH_NOARGS, "receive a (picklable) object"}, - {"poll", (PyCFunction)connection_poll, METH_VARARGS, + {"poll", (PyCFunction)connection_poll, METH_VARARGS, "whether there is any input available to be read"}, {"fileno", (PyCFunction)connection_fileno, METH_NOARGS, "file descriptor or handle of the connection"}, @@ -456,11 +456,11 @@ static PyMethodDef connection_methods[] = { }; static PyGetSetDef connection_getset[] = { - {"closed", (getter)connection_closed, NULL, + {"closed", (getter)connection_closed, NULL, "True if the connection is closed", NULL}, - {"readable", (getter)connection_readable, NULL, + {"readable", (getter)connection_readable, NULL, "True if the connection is readable", NULL}, - {"writable", (getter)connection_writable, NULL, + {"writable", (getter)connection_writable, NULL, "True if the connection is writable", NULL}, {NULL} }; @@ -494,7 +494,7 @@ PyTypeObject CONNECTION_TYPE = { /* tp_getattro */ 0, /* tp_setattro */ 0, /* tp_as_buffer */ 0, - /* tp_flags */ Py_TPFLAGS_DEFAULT | Py_TPFLAGS_BASETYPE | + /* tp_flags */ Py_TPFLAGS_DEFAULT | Py_TPFLAGS_BASETYPE | Py_TPFLAGS_HAVE_WEAKREFS, /* tp_doc */ connection_doc, /* tp_traverse */ 0, diff --git a/Modules/_multiprocessing/pipe_connection.c b/Modules/_multiprocessing/pipe_connection.c index 66947c8..980f760 100644 --- a/Modules/_multiprocessing/pipe_connection.c +++ b/Modules/_multiprocessing/pipe_connection.c @@ -39,7 +39,7 @@ conn_send_string(ConnectionObject *conn, char *string, size_t length) */ static Py_ssize_t -conn_recv_string(ConnectionObject *conn, char *buffer, +conn_recv_string(ConnectionObject *conn, char *buffer, size_t buflength, char **newbuffer, size_t maxlength) { DWORD left, length, full_length, err; @@ -130,7 +130,7 @@ conn_poll(ConnectionObject *conn, double timeout, PyThreadState *_save) Sleep(delay); /* check for signals */ - Py_BLOCK_THREADS + Py_BLOCK_THREADS res = PyErr_CheckSignals(); Py_UNBLOCK_THREADS diff --git a/Modules/_multiprocessing/win32_functions.c b/Modules/_multiprocessing/win32_functions.c index 549c151..5c6c817 100644 --- a/Modules/_multiprocessing/win32_functions.c +++ b/Modules/_multiprocessing/win32_functions.c @@ -26,7 +26,7 @@ win32_CloseHandle(PyObject *self, PyObject *args) return NULL; Py_BEGIN_ALLOW_THREADS - success = CloseHandle(hObject); + success = CloseHandle(hObject); Py_END_ALLOW_THREADS if (!success) @@ -42,7 +42,7 @@ win32_ConnectNamedPipe(PyObject *self, PyObject *args) LPOVERLAPPED lpOverlapped; BOOL success; - if (!PyArg_ParseTuple(args, F_HANDLE F_POINTER, + if (!PyArg_ParseTuple(args, F_HANDLE F_POINTER, &hNamedPipe, &lpOverlapped)) return NULL; @@ -68,17 +68,17 @@ win32_CreateFile(PyObject *self, PyObject *args) HANDLE hTemplateFile; HANDLE handle; - if (!PyArg_ParseTuple(args, "s" F_DWORD F_DWORD F_POINTER + if (!PyArg_ParseTuple(args, "s" F_DWORD F_DWORD F_POINTER F_DWORD F_DWORD F_HANDLE, - &lpFileName, &dwDesiredAccess, &dwShareMode, - &lpSecurityAttributes, &dwCreationDisposition, + &lpFileName, &dwDesiredAccess, &dwShareMode, + &lpSecurityAttributes, &dwCreationDisposition, &dwFlagsAndAttributes, &hTemplateFile)) return NULL; Py_BEGIN_ALLOW_THREADS - handle = CreateFile(lpFileName, dwDesiredAccess, - dwShareMode, lpSecurityAttributes, - dwCreationDisposition, + handle = CreateFile(lpFileName, dwDesiredAccess, + dwShareMode, lpSecurityAttributes, + dwCreationDisposition, dwFlagsAndAttributes, hTemplateFile); Py_END_ALLOW_THREADS @@ -101,17 +101,17 @@ win32_CreateNamedPipe(PyObject *self, PyObject *args) LPSECURITY_ATTRIBUTES lpSecurityAttributes; HANDLE handle; - if (!PyArg_ParseTuple(args, "s" F_DWORD F_DWORD F_DWORD + if (!PyArg_ParseTuple(args, "s" F_DWORD F_DWORD F_DWORD F_DWORD F_DWORD F_DWORD F_POINTER, - &lpName, &dwOpenMode, &dwPipeMode, - &nMaxInstances, &nOutBufferSize, + &lpName, &dwOpenMode, &dwPipeMode, + &nMaxInstances, &nOutBufferSize, &nInBufferSize, &nDefaultTimeOut, &lpSecurityAttributes)) return NULL; Py_BEGIN_ALLOW_THREADS - handle = CreateNamedPipe(lpName, dwOpenMode, dwPipeMode, - nMaxInstances, nOutBufferSize, + handle = CreateNamedPipe(lpName, dwOpenMode, dwPipeMode, + nMaxInstances, nOutBufferSize, nInBufferSize, nDefaultTimeOut, lpSecurityAttributes); Py_END_ALLOW_THREADS @@ -155,11 +155,11 @@ win32_OpenProcess(PyObject *self, PyObject *args) DWORD dwProcessId; HANDLE handle; - if (!PyArg_ParseTuple(args, F_DWORD "i" F_DWORD, + if (!PyArg_ParseTuple(args, F_DWORD "i" F_DWORD, &dwDesiredAccess, &bInheritHandle, &dwProcessId)) return NULL; - handle = OpenProcess(dwDesiredAccess, bInheritHandle, dwProcessId); + handle = OpenProcess(dwDesiredAccess, bInheritHandle, dwProcessId); if (handle == NULL) return PyErr_SetFromWindowsErr(0); @@ -174,7 +174,7 @@ win32_SetNamedPipeHandleState(PyObject *self, PyObject *args) DWORD dwArgs[3], *pArgs[3] = {NULL, NULL, NULL}; int i; - if (!PyArg_ParseTuple(args, F_HANDLE "OOO", + if (!PyArg_ParseTuple(args, F_HANDLE "OOO", &hNamedPipe, &oArgs[0], &oArgs[1], &oArgs[2])) return NULL; |