1 /*[clinic input] 2 preserve 3 [clinic start generated code]*/ 4 5 PyDoc_STRVAR(simplequeue_new__doc__, 6 "SimpleQueue()\n" 7 "--\n" 8 "\n" 9 "Simple, unbounded, reentrant FIFO queue."); 10 11 static PyObject * 12 simplequeue_new_impl(PyTypeObject *type); 13 14 static PyObject * 15 simplequeue_new(PyTypeObject *type, PyObject *args, PyObject *kwargs) 16 { 17 PyObject *return_value = NULL; 18 19 if ((type == &PySimpleQueueType) && 20 !_PyArg_NoPositional("SimpleQueue", args)) { 21 goto exit; 22 } 23 if ((type == &PySimpleQueueType) && 24 !_PyArg_NoKeywords("SimpleQueue", kwargs)) { 25 goto exit; 26 } 27 return_value = simplequeue_new_impl(type); 28 29 exit: 30 return return_value; 31 } 32 33 PyDoc_STRVAR(_queue_SimpleQueue_put__doc__, 34 "put($self, /, item, block=True, timeout=None)\n" 35 "--\n" 36 "\n" 37 "Put the item on the queue.\n" 38 "\n" 39 "The optional \'block\' and \'timeout\' arguments are ignored, as this method\n" 40 "never blocks. They are provided for compatibility with the Queue class."); 41 42 #define _QUEUE_SIMPLEQUEUE_PUT_METHODDEF \ 43 {"put", (PyCFunction)_queue_SimpleQueue_put, METH_FASTCALL|METH_KEYWORDS, _queue_SimpleQueue_put__doc__}, 44 45 static PyObject * 46 _queue_SimpleQueue_put_impl(simplequeueobject *self, PyObject *item, 47 int block, PyObject *timeout); 48 49 static PyObject * 50 _queue_SimpleQueue_put(simplequeueobject *self, PyObject *const *args, Py_ssize_t nargs, PyObject *kwnames) 51 { 52 PyObject *return_value = NULL; 53 static const char * const _keywords[] = {"item", "block", "timeout", NULL}; 54 static _PyArg_Parser _parser = {"O|pO:put", _keywords, 0}; 55 PyObject *item; 56 int block = 1; 57 PyObject *timeout = Py_None; 58 59 if (!_PyArg_ParseStackAndKeywords(args, nargs, kwnames, &_parser, 60 &item, &block, &timeout)) { 61 goto exit; 62 } 63 return_value = _queue_SimpleQueue_put_impl(self, item, block, timeout); 64 65 exit: 66 return return_value; 67 } 68 69 PyDoc_STRVAR(_queue_SimpleQueue_put_nowait__doc__, 70 "put_nowait($self, /, item)\n" 71 "--\n" 72 "\n" 73 "Put an item into the queue without blocking.\n" 74 "\n" 75 "This is exactly equivalent to `put(item)` and is only provided\n" 76 "for compatibility with the Queue class."); 77 78 #define _QUEUE_SIMPLEQUEUE_PUT_NOWAIT_METHODDEF \ 79 {"put_nowait", (PyCFunction)_queue_SimpleQueue_put_nowait, METH_FASTCALL|METH_KEYWORDS, _queue_SimpleQueue_put_nowait__doc__}, 80 81 static PyObject * 82 _queue_SimpleQueue_put_nowait_impl(simplequeueobject *self, PyObject *item); 83 84 static PyObject * 85 _queue_SimpleQueue_put_nowait(simplequeueobject *self, PyObject *const *args, Py_ssize_t nargs, PyObject *kwnames) 86 { 87 PyObject *return_value = NULL; 88 static const char * const _keywords[] = {"item", NULL}; 89 static _PyArg_Parser _parser = {"O:put_nowait", _keywords, 0}; 90 PyObject *item; 91 92 if (!_PyArg_ParseStackAndKeywords(args, nargs, kwnames, &_parser, 93 &item)) { 94 goto exit; 95 } 96 return_value = _queue_SimpleQueue_put_nowait_impl(self, item); 97 98 exit: 99 return return_value; 100 } 101 102 PyDoc_STRVAR(_queue_SimpleQueue_get__doc__, 103 "get($self, /, block=True, timeout=None)\n" 104 "--\n" 105 "\n" 106 "Remove and return an item from the queue.\n" 107 "\n" 108 "If optional args \'block\' is true and \'timeout\' is None (the default),\n" 109 "block if necessary until an item is available. If \'timeout\' is\n" 110 "a non-negative number, it blocks at most \'timeout\' seconds and raises\n" 111 "the Empty exception if no item was available within that time.\n" 112 "Otherwise (\'block\' is false), return an item if one is immediately\n" 113 "available, else raise the Empty exception (\'timeout\' is ignored\n" 114 "in that case)."); 115 116 #define _QUEUE_SIMPLEQUEUE_GET_METHODDEF \ 117 {"get", (PyCFunction)_queue_SimpleQueue_get, METH_FASTCALL|METH_KEYWORDS, _queue_SimpleQueue_get__doc__}, 118 119 static PyObject * 120 _queue_SimpleQueue_get_impl(simplequeueobject *self, int block, 121 PyObject *timeout); 122 123 static PyObject * 124 _queue_SimpleQueue_get(simplequeueobject *self, PyObject *const *args, Py_ssize_t nargs, PyObject *kwnames) 125 { 126 PyObject *return_value = NULL; 127 static const char * const _keywords[] = {"block", "timeout", NULL}; 128 static _PyArg_Parser _parser = {"|pO:get", _keywords, 0}; 129 int block = 1; 130 PyObject *timeout = Py_None; 131 132 if (!_PyArg_ParseStackAndKeywords(args, nargs, kwnames, &_parser, 133 &block, &timeout)) { 134 goto exit; 135 } 136 return_value = _queue_SimpleQueue_get_impl(self, block, timeout); 137 138 exit: 139 return return_value; 140 } 141 142 PyDoc_STRVAR(_queue_SimpleQueue_get_nowait__doc__, 143 "get_nowait($self, /)\n" 144 "--\n" 145 "\n" 146 "Remove and return an item from the queue without blocking.\n" 147 "\n" 148 "Only get an item if one is immediately available. Otherwise\n" 149 "raise the Empty exception."); 150 151 #define _QUEUE_SIMPLEQUEUE_GET_NOWAIT_METHODDEF \ 152 {"get_nowait", (PyCFunction)_queue_SimpleQueue_get_nowait, METH_NOARGS, _queue_SimpleQueue_get_nowait__doc__}, 153 154 static PyObject * 155 _queue_SimpleQueue_get_nowait_impl(simplequeueobject *self); 156 157 static PyObject * 158 _queue_SimpleQueue_get_nowait(simplequeueobject *self, PyObject *Py_UNUSED(ignored)) 159 { 160 return _queue_SimpleQueue_get_nowait_impl(self); 161 } 162 163 PyDoc_STRVAR(_queue_SimpleQueue_empty__doc__, 164 "empty($self, /)\n" 165 "--\n" 166 "\n" 167 "Return True if the queue is empty, False otherwise (not reliable!)."); 168 169 #define _QUEUE_SIMPLEQUEUE_EMPTY_METHODDEF \ 170 {"empty", (PyCFunction)_queue_SimpleQueue_empty, METH_NOARGS, _queue_SimpleQueue_empty__doc__}, 171 172 static int 173 _queue_SimpleQueue_empty_impl(simplequeueobject *self); 174 175 static PyObject * 176 _queue_SimpleQueue_empty(simplequeueobject *self, PyObject *Py_UNUSED(ignored)) 177 { 178 PyObject *return_value = NULL; 179 int _return_value; 180 181 _return_value = _queue_SimpleQueue_empty_impl(self); 182 if ((_return_value == -1) && PyErr_Occurred()) { 183 goto exit; 184 } 185 return_value = PyBool_FromLong((long)_return_value); 186 187 exit: 188 return return_value; 189 } 190 191 PyDoc_STRVAR(_queue_SimpleQueue_qsize__doc__, 192 "qsize($self, /)\n" 193 "--\n" 194 "\n" 195 "Return the approximate size of the queue (not reliable!)."); 196 197 #define _QUEUE_SIMPLEQUEUE_QSIZE_METHODDEF \ 198 {"qsize", (PyCFunction)_queue_SimpleQueue_qsize, METH_NOARGS, _queue_SimpleQueue_qsize__doc__}, 199 200 static Py_ssize_t 201 _queue_SimpleQueue_qsize_impl(simplequeueobject *self); 202 203 static PyObject * 204 _queue_SimpleQueue_qsize(simplequeueobject *self, PyObject *Py_UNUSED(ignored)) 205 { 206 PyObject *return_value = NULL; 207 Py_ssize_t _return_value; 208 209 _return_value = _queue_SimpleQueue_qsize_impl(self); 210 if ((_return_value == -1) && PyErr_Occurred()) { 211 goto exit; 212 } 213 return_value = PyLong_FromSsize_t(_return_value); 214 215 exit: 216 return return_value; 217 } 218 /*[clinic end generated code: output=8badc3bb85263689 input=a9049054013a1b77]*/ 219
