blob: 76c848491d0dd7738ad44662b81a1a2e706a6470 [file] [log] [blame]
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001
2#include "Python.h"
Fred Drake08ebfec2004-10-17 19:36:57 +00003#include "structmember.h"
Raymond Hettinger96ef8112003-02-01 00:10:11 +00004
5/* Itertools module written and maintained
6 by Raymond D. Hettinger <python@rcn.com>
7 Copyright (c) 2003 Python Software Foundation.
8 All rights reserved.
9*/
10
Raymond Hettingerd25c1c62003-12-06 16:23:06 +000011
12/* groupby object ***********************************************************/
13
14typedef struct {
15 PyObject_HEAD
16 PyObject *it;
17 PyObject *keyfunc;
18 PyObject *tgtkey;
19 PyObject *currkey;
20 PyObject *currvalue;
21} groupbyobject;
22
23static PyTypeObject groupby_type;
24static PyObject *_grouper_create(groupbyobject *, PyObject *);
25
26static PyObject *
27groupby_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
28{
Martin v. Löwis02cbf4a2006-02-27 17:20:04 +000029 static char *kwargs[] = {"iterable", "key", NULL};
Raymond Hettingerd25c1c62003-12-06 16:23:06 +000030 groupbyobject *gbo;
31 PyObject *it, *keyfunc = Py_None;
32
33 if (!PyArg_ParseTupleAndKeywords(args, kwds, "O|O:groupby", kwargs,
34 &it, &keyfunc))
35 return NULL;
36
37 gbo = (groupbyobject *)type->tp_alloc(type, 0);
38 if (gbo == NULL)
39 return NULL;
40 gbo->tgtkey = NULL;
41 gbo->currkey = NULL;
42 gbo->currvalue = NULL;
43 gbo->keyfunc = keyfunc;
44 Py_INCREF(keyfunc);
45 gbo->it = PyObject_GetIter(it);
46 if (gbo->it == NULL) {
47 Py_DECREF(gbo);
48 return NULL;
49 }
50 return (PyObject *)gbo;
51}
52
53static void
54groupby_dealloc(groupbyobject *gbo)
55{
56 PyObject_GC_UnTrack(gbo);
57 Py_XDECREF(gbo->it);
58 Py_XDECREF(gbo->keyfunc);
59 Py_XDECREF(gbo->tgtkey);
60 Py_XDECREF(gbo->currkey);
61 Py_XDECREF(gbo->currvalue);
Christian Heimese93237d2007-12-19 02:37:44 +000062 Py_TYPE(gbo)->tp_free(gbo);
Raymond Hettingerd25c1c62003-12-06 16:23:06 +000063}
64
65static int
66groupby_traverse(groupbyobject *gbo, visitproc visit, void *arg)
67{
Raymond Hettinger58ed69b2004-07-15 05:32:47 +000068 Py_VISIT(gbo->it);
69 Py_VISIT(gbo->keyfunc);
70 Py_VISIT(gbo->tgtkey);
71 Py_VISIT(gbo->currkey);
72 Py_VISIT(gbo->currvalue);
Raymond Hettingerd25c1c62003-12-06 16:23:06 +000073 return 0;
74}
75
76static PyObject *
77groupby_next(groupbyobject *gbo)
78{
Raymond Hettinger4cda01e2004-09-28 04:45:28 +000079 PyObject *newvalue, *newkey, *r, *grouper, *tmp;
Raymond Hettingerd25c1c62003-12-06 16:23:06 +000080
81 /* skip to next iteration group */
82 for (;;) {
83 if (gbo->currkey == NULL)
84 /* pass */;
85 else if (gbo->tgtkey == NULL)
86 break;
87 else {
88 int rcmp;
89
90 rcmp = PyObject_RichCompareBool(gbo->tgtkey,
91 gbo->currkey, Py_EQ);
92 if (rcmp == -1)
93 return NULL;
94 else if (rcmp == 0)
95 break;
96 }
97
98 newvalue = PyIter_Next(gbo->it);
99 if (newvalue == NULL)
100 return NULL;
101
102 if (gbo->keyfunc == Py_None) {
103 newkey = newvalue;
104 Py_INCREF(newvalue);
105 } else {
106 newkey = PyObject_CallFunctionObjArgs(gbo->keyfunc,
107 newvalue, NULL);
108 if (newkey == NULL) {
109 Py_DECREF(newvalue);
110 return NULL;
111 }
112 }
113
Raymond Hettinger4cda01e2004-09-28 04:45:28 +0000114 tmp = gbo->currkey;
Raymond Hettingerd25c1c62003-12-06 16:23:06 +0000115 gbo->currkey = newkey;
Raymond Hettinger4cda01e2004-09-28 04:45:28 +0000116 Py_XDECREF(tmp);
117
118 tmp = gbo->currvalue;
Raymond Hettingerd25c1c62003-12-06 16:23:06 +0000119 gbo->currvalue = newvalue;
Raymond Hettinger4cda01e2004-09-28 04:45:28 +0000120 Py_XDECREF(tmp);
Raymond Hettingerd25c1c62003-12-06 16:23:06 +0000121 }
122
Raymond Hettingerd25c1c62003-12-06 16:23:06 +0000123 Py_INCREF(gbo->currkey);
Raymond Hettinger4cda01e2004-09-28 04:45:28 +0000124 tmp = gbo->tgtkey;
125 gbo->tgtkey = gbo->currkey;
126 Py_XDECREF(tmp);
Raymond Hettingerd25c1c62003-12-06 16:23:06 +0000127
128 grouper = _grouper_create(gbo, gbo->tgtkey);
129 if (grouper == NULL)
130 return NULL;
131
132 r = PyTuple_Pack(2, gbo->currkey, grouper);
133 Py_DECREF(grouper);
134 return r;
135}
136
137PyDoc_STRVAR(groupby_doc,
138"groupby(iterable[, keyfunc]) -> create an iterator which returns\n\
139(key, sub-iterator) grouped by each value of key(value).\n");
140
141static PyTypeObject groupby_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +0000142 PyVarObject_HEAD_INIT(NULL, 0)
Raymond Hettingerd25c1c62003-12-06 16:23:06 +0000143 "itertools.groupby", /* tp_name */
144 sizeof(groupbyobject), /* tp_basicsize */
145 0, /* tp_itemsize */
146 /* methods */
147 (destructor)groupby_dealloc, /* tp_dealloc */
148 0, /* tp_print */
149 0, /* tp_getattr */
150 0, /* tp_setattr */
151 0, /* tp_compare */
152 0, /* tp_repr */
153 0, /* tp_as_number */
154 0, /* tp_as_sequence */
155 0, /* tp_as_mapping */
156 0, /* tp_hash */
157 0, /* tp_call */
158 0, /* tp_str */
159 PyObject_GenericGetAttr, /* tp_getattro */
160 0, /* tp_setattro */
161 0, /* tp_as_buffer */
162 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC |
163 Py_TPFLAGS_BASETYPE, /* tp_flags */
164 groupby_doc, /* tp_doc */
165 (traverseproc)groupby_traverse, /* tp_traverse */
166 0, /* tp_clear */
167 0, /* tp_richcompare */
168 0, /* tp_weaklistoffset */
169 PyObject_SelfIter, /* tp_iter */
170 (iternextfunc)groupby_next, /* tp_iternext */
171 0, /* tp_methods */
172 0, /* tp_members */
173 0, /* tp_getset */
174 0, /* tp_base */
175 0, /* tp_dict */
176 0, /* tp_descr_get */
177 0, /* tp_descr_set */
178 0, /* tp_dictoffset */
179 0, /* tp_init */
180 0, /* tp_alloc */
181 groupby_new, /* tp_new */
182 PyObject_GC_Del, /* tp_free */
183};
184
185
186/* _grouper object (internal) ************************************************/
187
188typedef struct {
189 PyObject_HEAD
190 PyObject *parent;
191 PyObject *tgtkey;
192} _grouperobject;
193
194static PyTypeObject _grouper_type;
195
196static PyObject *
197_grouper_create(groupbyobject *parent, PyObject *tgtkey)
198{
199 _grouperobject *igo;
200
201 igo = PyObject_New(_grouperobject, &_grouper_type);
202 if (igo == NULL)
203 return NULL;
204 igo->parent = (PyObject *)parent;
205 Py_INCREF(parent);
206 igo->tgtkey = tgtkey;
207 Py_INCREF(tgtkey);
208
209 return (PyObject *)igo;
210}
211
212static void
213_grouper_dealloc(_grouperobject *igo)
214{
215 Py_DECREF(igo->parent);
216 Py_DECREF(igo->tgtkey);
217 PyObject_Del(igo);
218}
219
220static PyObject *
221_grouper_next(_grouperobject *igo)
222{
223 groupbyobject *gbo = (groupbyobject *)igo->parent;
224 PyObject *newvalue, *newkey, *r;
225 int rcmp;
226
227 if (gbo->currvalue == NULL) {
228 newvalue = PyIter_Next(gbo->it);
229 if (newvalue == NULL)
230 return NULL;
231
232 if (gbo->keyfunc == Py_None) {
233 newkey = newvalue;
234 Py_INCREF(newvalue);
235 } else {
236 newkey = PyObject_CallFunctionObjArgs(gbo->keyfunc,
237 newvalue, NULL);
238 if (newkey == NULL) {
239 Py_DECREF(newvalue);
240 return NULL;
241 }
242 }
243
244 assert(gbo->currkey == NULL);
245 gbo->currkey = newkey;
246 gbo->currvalue = newvalue;
247 }
248
249 assert(gbo->currkey != NULL);
250 rcmp = PyObject_RichCompareBool(igo->tgtkey, gbo->currkey, Py_EQ);
251 if (rcmp <= 0)
252 /* got any error or current group is end */
253 return NULL;
254
255 r = gbo->currvalue;
256 gbo->currvalue = NULL;
Raymond Hettinger75ccea32004-09-01 07:02:44 +0000257 Py_CLEAR(gbo->currkey);
Raymond Hettingerd25c1c62003-12-06 16:23:06 +0000258
259 return r;
260}
261
262static PyTypeObject _grouper_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +0000263 PyVarObject_HEAD_INIT(NULL, 0)
Raymond Hettingerd25c1c62003-12-06 16:23:06 +0000264 "itertools._grouper", /* tp_name */
265 sizeof(_grouperobject), /* tp_basicsize */
266 0, /* tp_itemsize */
267 /* methods */
268 (destructor)_grouper_dealloc, /* tp_dealloc */
269 0, /* tp_print */
270 0, /* tp_getattr */
271 0, /* tp_setattr */
272 0, /* tp_compare */
273 0, /* tp_repr */
274 0, /* tp_as_number */
275 0, /* tp_as_sequence */
276 0, /* tp_as_mapping */
277 0, /* tp_hash */
278 0, /* tp_call */
279 0, /* tp_str */
280 PyObject_GenericGetAttr, /* tp_getattro */
281 0, /* tp_setattro */
282 0, /* tp_as_buffer */
283 Py_TPFLAGS_DEFAULT, /* tp_flags */
284 0, /* tp_doc */
285 0, /* tp_traverse */
286 0, /* tp_clear */
287 0, /* tp_richcompare */
288 0, /* tp_weaklistoffset */
289 PyObject_SelfIter, /* tp_iter */
290 (iternextfunc)_grouper_next, /* tp_iternext */
291 0, /* tp_methods */
292 0, /* tp_members */
293 0, /* tp_getset */
294 0, /* tp_base */
295 0, /* tp_dict */
296 0, /* tp_descr_get */
297 0, /* tp_descr_set */
298 0, /* tp_dictoffset */
299 0, /* tp_init */
300 0, /* tp_alloc */
301 0, /* tp_new */
302 PyObject_Del, /* tp_free */
303};
304
305
306
Raymond Hettingerad983e72003-11-12 14:32:26 +0000307/* tee object and with supporting function and objects ***************/
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000308
Raymond Hettingerad983e72003-11-12 14:32:26 +0000309/* The teedataobject pre-allocates space for LINKCELLS number of objects.
310 To help the object fit neatly inside cache lines (space for 16 to 32
311 pointers), the value should be a multiple of 16 minus space for
312 the other structure members including PyHEAD overhead. The larger the
313 value, the less memory overhead per object and the less time spent
314 allocating/deallocating new links. The smaller the number, the less
315 wasted space and the more rapid freeing of older data.
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000316*/
Raymond Hettingerad983e72003-11-12 14:32:26 +0000317#define LINKCELLS 57
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000318
319typedef struct {
320 PyObject_HEAD
321 PyObject *it;
Raymond Hettingerad983e72003-11-12 14:32:26 +0000322 int numread;
323 PyObject *nextlink;
324 PyObject *(values[LINKCELLS]);
325} teedataobject;
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000326
327typedef struct {
328 PyObject_HEAD
Raymond Hettingerad983e72003-11-12 14:32:26 +0000329 teedataobject *dataobj;
330 int index;
Raymond Hettingera9f60922004-10-17 16:40:14 +0000331 PyObject *weakreflist;
Raymond Hettingerad983e72003-11-12 14:32:26 +0000332} teeobject;
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000333
Raymond Hettingerad983e72003-11-12 14:32:26 +0000334static PyTypeObject teedataobject_type;
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000335
336static PyObject *
Raymond Hettingerad983e72003-11-12 14:32:26 +0000337teedataobject_new(PyObject *it)
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000338{
Raymond Hettingerad983e72003-11-12 14:32:26 +0000339 teedataobject *tdo;
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000340
Thomas Wouters19bf33b2006-03-27 21:02:13 +0000341 tdo = PyObject_GC_New(teedataobject, &teedataobject_type);
Raymond Hettingerad983e72003-11-12 14:32:26 +0000342 if (tdo == NULL)
Raymond Hettinger45143692003-10-25 06:37:47 +0000343 return NULL;
Raymond Hettingerad983e72003-11-12 14:32:26 +0000344
345 tdo->numread = 0;
346 tdo->nextlink = NULL;
347 Py_INCREF(it);
348 tdo->it = it;
Thomas Wouters19bf33b2006-03-27 21:02:13 +0000349 PyObject_GC_Track(tdo);
Raymond Hettingerad983e72003-11-12 14:32:26 +0000350 return (PyObject *)tdo;
351}
352
353static PyObject *
354teedataobject_jumplink(teedataobject *tdo)
355{
356 if (tdo->nextlink == NULL)
357 tdo->nextlink = teedataobject_new(tdo->it);
Neal Norwitz9029b5f2006-07-23 07:59:00 +0000358 Py_XINCREF(tdo->nextlink);
Raymond Hettingerad983e72003-11-12 14:32:26 +0000359 return tdo->nextlink;
360}
361
362static PyObject *
363teedataobject_getitem(teedataobject *tdo, int i)
364{
365 PyObject *value;
366
367 assert(i < LINKCELLS);
368 if (i < tdo->numread)
369 value = tdo->values[i];
370 else {
371 /* this is the lead iterator, so fetch more data */
372 assert(i == tdo->numread);
373 value = PyIter_Next(tdo->it);
374 if (value == NULL)
375 return NULL;
376 tdo->numread++;
377 tdo->values[i] = value;
Raymond Hettinger45143692003-10-25 06:37:47 +0000378 }
Raymond Hettingerad983e72003-11-12 14:32:26 +0000379 Py_INCREF(value);
380 return value;
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000381}
382
Thomas Wouters19bf33b2006-03-27 21:02:13 +0000383static int
384teedataobject_traverse(teedataobject *tdo, visitproc visit, void * arg)
385{
386 int i;
387 Py_VISIT(tdo->it);
388 for (i = 0; i < tdo->numread; i++)
389 Py_VISIT(tdo->values[i]);
390 Py_VISIT(tdo->nextlink);
391 return 0;
392}
393
394static int
395teedataobject_clear(teedataobject *tdo)
396{
397 int i;
398 Py_CLEAR(tdo->it);
399 for (i=0 ; i<tdo->numread ; i++)
400 Py_CLEAR(tdo->values[i]);
401 Py_CLEAR(tdo->nextlink);
402 return 0;
403}
404
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000405static void
Raymond Hettingerad983e72003-11-12 14:32:26 +0000406teedataobject_dealloc(teedataobject *tdo)
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000407{
Thomas Wouters19bf33b2006-03-27 21:02:13 +0000408 PyObject_GC_UnTrack(tdo);
409 teedataobject_clear(tdo);
410 PyObject_GC_Del(tdo);
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000411}
412
Raymond Hettingerad983e72003-11-12 14:32:26 +0000413PyDoc_STRVAR(teedataobject_doc, "Data container common to multiple tee objects.");
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000414
Raymond Hettingerad983e72003-11-12 14:32:26 +0000415static PyTypeObject teedataobject_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +0000416 PyVarObject_HEAD_INIT(0, 0) /* Must fill in type value later */
Raymond Hettingerad983e72003-11-12 14:32:26 +0000417 "itertools.tee_dataobject", /* tp_name */
418 sizeof(teedataobject), /* tp_basicsize */
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000419 0, /* tp_itemsize */
420 /* methods */
Raymond Hettingerad983e72003-11-12 14:32:26 +0000421 (destructor)teedataobject_dealloc, /* tp_dealloc */
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000422 0, /* tp_print */
423 0, /* tp_getattr */
424 0, /* tp_setattr */
425 0, /* tp_compare */
426 0, /* tp_repr */
427 0, /* tp_as_number */
428 0, /* tp_as_sequence */
429 0, /* tp_as_mapping */
430 0, /* tp_hash */
431 0, /* tp_call */
432 0, /* tp_str */
433 PyObject_GenericGetAttr, /* tp_getattro */
434 0, /* tp_setattro */
435 0, /* tp_as_buffer */
Thomas Wouters19bf33b2006-03-27 21:02:13 +0000436 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC, /* tp_flags */
Raymond Hettingerad983e72003-11-12 14:32:26 +0000437 teedataobject_doc, /* tp_doc */
Thomas Wouters19bf33b2006-03-27 21:02:13 +0000438 (traverseproc)teedataobject_traverse, /* tp_traverse */
439 (inquiry)teedataobject_clear, /* tp_clear */
440 0, /* tp_richcompare */
441 0, /* tp_weaklistoffset */
442 0, /* tp_iter */
443 0, /* tp_iternext */
444 0, /* tp_methods */
445 0, /* tp_members */
446 0, /* tp_getset */
447 0, /* tp_base */
448 0, /* tp_dict */
449 0, /* tp_descr_get */
450 0, /* tp_descr_set */
451 0, /* tp_dictoffset */
452 0, /* tp_init */
453 0, /* tp_alloc */
454 0, /* tp_new */
455 PyObject_GC_Del, /* tp_free */
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000456};
457
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000458
459static PyTypeObject tee_type;
460
461static PyObject *
Raymond Hettingerad983e72003-11-12 14:32:26 +0000462tee_next(teeobject *to)
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000463{
Raymond Hettingerad983e72003-11-12 14:32:26 +0000464 PyObject *value, *link;
465
466 if (to->index >= LINKCELLS) {
467 link = teedataobject_jumplink(to->dataobj);
Neal Norwitz9029b5f2006-07-23 07:59:00 +0000468 Py_DECREF(to->dataobj);
Raymond Hettingerad983e72003-11-12 14:32:26 +0000469 to->dataobj = (teedataobject *)link;
470 to->index = 0;
471 }
472 value = teedataobject_getitem(to->dataobj, to->index);
473 if (value == NULL)
474 return NULL;
475 to->index++;
476 return value;
477}
478
Thomas Wouters19bf33b2006-03-27 21:02:13 +0000479static int
480tee_traverse(teeobject *to, visitproc visit, void *arg)
481{
482 Py_VISIT((PyObject *)to->dataobj);
483 return 0;
484}
485
Raymond Hettingerad983e72003-11-12 14:32:26 +0000486static PyObject *
487tee_copy(teeobject *to)
488{
489 teeobject *newto;
490
Thomas Wouters19bf33b2006-03-27 21:02:13 +0000491 newto = PyObject_GC_New(teeobject, &tee_type);
Raymond Hettingerad983e72003-11-12 14:32:26 +0000492 if (newto == NULL)
493 return NULL;
494 Py_INCREF(to->dataobj);
495 newto->dataobj = to->dataobj;
496 newto->index = to->index;
Raymond Hettingera9f60922004-10-17 16:40:14 +0000497 newto->weakreflist = NULL;
Thomas Woutersb3deb942006-04-15 22:33:13 +0000498 PyObject_GC_Track(newto);
Raymond Hettingerad983e72003-11-12 14:32:26 +0000499 return (PyObject *)newto;
500}
501
502PyDoc_STRVAR(teecopy_doc, "Returns an independent iterator.");
503
504static PyObject *
505tee_fromiterable(PyObject *iterable)
506{
507 teeobject *to;
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000508 PyObject *it = NULL;
Raymond Hettingerad983e72003-11-12 14:32:26 +0000509
510 it = PyObject_GetIter(iterable);
511 if (it == NULL)
512 return NULL;
513 if (PyObject_TypeCheck(it, &tee_type)) {
514 to = (teeobject *)tee_copy((teeobject *)it);
515 goto done;
516 }
517
Thomas Wouters19bf33b2006-03-27 21:02:13 +0000518 to = PyObject_GC_New(teeobject, &tee_type);
Raymond Hettingerad983e72003-11-12 14:32:26 +0000519 if (to == NULL)
520 goto done;
521 to->dataobj = (teedataobject *)teedataobject_new(it);
Neal Norwitz9029b5f2006-07-23 07:59:00 +0000522 if (!to->dataobj) {
523 PyObject_GC_Del(to);
524 to = NULL;
525 goto done;
526 }
527
Raymond Hettingerad983e72003-11-12 14:32:26 +0000528 to->index = 0;
Raymond Hettingera9f60922004-10-17 16:40:14 +0000529 to->weakreflist = NULL;
Thomas Wouters19bf33b2006-03-27 21:02:13 +0000530 PyObject_GC_Track(to);
Raymond Hettingerad983e72003-11-12 14:32:26 +0000531done:
532 Py_XDECREF(it);
533 return (PyObject *)to;
534}
535
536static PyObject *
537tee_new(PyTypeObject *type, PyObject *args, PyObject *kw)
538{
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000539 PyObject *iterable;
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000540
541 if (!PyArg_UnpackTuple(args, "tee", 1, 1, &iterable))
542 return NULL;
Raymond Hettingerad983e72003-11-12 14:32:26 +0000543 return tee_fromiterable(iterable);
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000544}
545
Thomas Wouters19bf33b2006-03-27 21:02:13 +0000546static int
547tee_clear(teeobject *to)
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000548{
Raymond Hettingera9f60922004-10-17 16:40:14 +0000549 if (to->weakreflist != NULL)
550 PyObject_ClearWeakRefs((PyObject *) to);
Thomas Wouters19bf33b2006-03-27 21:02:13 +0000551 Py_CLEAR(to->dataobj);
552 return 0;
553}
554
555static void
556tee_dealloc(teeobject *to)
557{
558 PyObject_GC_UnTrack(to);
559 tee_clear(to);
560 PyObject_GC_Del(to);
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000561}
562
Raymond Hettingerad983e72003-11-12 14:32:26 +0000563PyDoc_STRVAR(teeobject_doc,
564"Iterator wrapped to make it copyable");
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000565
Raymond Hettingerad983e72003-11-12 14:32:26 +0000566static PyMethodDef tee_methods[] = {
567 {"__copy__", (PyCFunction)tee_copy, METH_NOARGS, teecopy_doc},
568 {NULL, NULL} /* sentinel */
569};
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000570
571static PyTypeObject tee_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +0000572 PyVarObject_HEAD_INIT(NULL, 0)
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000573 "itertools.tee", /* tp_name */
574 sizeof(teeobject), /* tp_basicsize */
575 0, /* tp_itemsize */
576 /* methods */
577 (destructor)tee_dealloc, /* tp_dealloc */
578 0, /* tp_print */
579 0, /* tp_getattr */
580 0, /* tp_setattr */
581 0, /* tp_compare */
582 0, /* tp_repr */
583 0, /* tp_as_number */
584 0, /* tp_as_sequence */
585 0, /* tp_as_mapping */
586 0, /* tp_hash */
587 0, /* tp_call */
588 0, /* tp_str */
Raymond Hettingerf0c5aec2003-10-26 14:25:56 +0000589 0, /* tp_getattro */
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000590 0, /* tp_setattro */
591 0, /* tp_as_buffer */
Thomas Wouters19bf33b2006-03-27 21:02:13 +0000592 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC, /* tp_flags */
Raymond Hettingerad983e72003-11-12 14:32:26 +0000593 teeobject_doc, /* tp_doc */
Thomas Wouters19bf33b2006-03-27 21:02:13 +0000594 (traverseproc)tee_traverse, /* tp_traverse */
595 (inquiry)tee_clear, /* tp_clear */
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000596 0, /* tp_richcompare */
Raymond Hettingera9f60922004-10-17 16:40:14 +0000597 offsetof(teeobject, weakreflist), /* tp_weaklistoffset */
Raymond Hettingerad983e72003-11-12 14:32:26 +0000598 PyObject_SelfIter, /* tp_iter */
599 (iternextfunc)tee_next, /* tp_iternext */
600 tee_methods, /* tp_methods */
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000601 0, /* tp_members */
602 0, /* tp_getset */
603 0, /* tp_base */
604 0, /* tp_dict */
605 0, /* tp_descr_get */
606 0, /* tp_descr_set */
607 0, /* tp_dictoffset */
608 0, /* tp_init */
609 0, /* tp_alloc */
610 tee_new, /* tp_new */
Thomas Wouters19bf33b2006-03-27 21:02:13 +0000611 PyObject_GC_Del, /* tp_free */
Raymond Hettinger6a5b0272003-10-24 08:45:23 +0000612};
613
Raymond Hettingerad983e72003-11-12 14:32:26 +0000614static PyObject *
615tee(PyObject *self, PyObject *args)
616{
Neal Norwitz69e88972006-09-02 02:58:13 +0000617 Py_ssize_t i, n=2;
Raymond Hettingerad983e72003-11-12 14:32:26 +0000618 PyObject *it, *iterable, *copyable, *result;
619
Neal Norwitz69e88972006-09-02 02:58:13 +0000620 if (!PyArg_ParseTuple(args, "O|n", &iterable, &n))
Raymond Hettingerad983e72003-11-12 14:32:26 +0000621 return NULL;
Neal Norwitz69e88972006-09-02 02:58:13 +0000622 if (n < 0) {
623 PyErr_SetString(PyExc_ValueError, "n must be >= 0");
624 return NULL;
625 }
Raymond Hettingerad983e72003-11-12 14:32:26 +0000626 result = PyTuple_New(n);
627 if (result == NULL)
628 return NULL;
629 if (n == 0)
630 return result;
631 it = PyObject_GetIter(iterable);
632 if (it == NULL) {
633 Py_DECREF(result);
634 return NULL;
635 }
636 if (!PyObject_HasAttrString(it, "__copy__")) {
637 copyable = tee_fromiterable(it);
638 Py_DECREF(it);
639 if (copyable == NULL) {
640 Py_DECREF(result);
641 return NULL;
642 }
643 } else
644 copyable = it;
645 PyTuple_SET_ITEM(result, 0, copyable);
646 for (i=1 ; i<n ; i++) {
647 copyable = PyObject_CallMethod(copyable, "__copy__", NULL);
648 if (copyable == NULL) {
649 Py_DECREF(result);
650 return NULL;
651 }
652 PyTuple_SET_ITEM(result, i, copyable);
653 }
654 return result;
655}
656
657PyDoc_STRVAR(tee_doc,
658"tee(iterable, n=2) --> tuple of n independent iterators.");
659
660
Raymond Hettinger61fe64d2003-02-23 04:40:07 +0000661/* cycle object **********************************************************/
662
663typedef struct {
664 PyObject_HEAD
665 PyObject *it;
666 PyObject *saved;
667 int firstpass;
668} cycleobject;
669
Raymond Hettinger1d7a3482003-07-14 07:07:12 +0000670static PyTypeObject cycle_type;
Raymond Hettinger61fe64d2003-02-23 04:40:07 +0000671
672static PyObject *
673cycle_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
674{
675 PyObject *it;
676 PyObject *iterable;
677 PyObject *saved;
678 cycleobject *lz;
679
Georg Brandlb84c1372007-01-21 10:28:43 +0000680 if (type == &cycle_type && !_PyArg_NoKeywords("cycle()", kwds))
Georg Brandl02c42872005-08-26 06:42:30 +0000681 return NULL;
682
Raymond Hettinger61fe64d2003-02-23 04:40:07 +0000683 if (!PyArg_UnpackTuple(args, "cycle", 1, 1, &iterable))
684 return NULL;
685
686 /* Get iterator. */
687 it = PyObject_GetIter(iterable);
688 if (it == NULL)
689 return NULL;
690
691 saved = PyList_New(0);
692 if (saved == NULL) {
693 Py_DECREF(it);
694 return NULL;
695 }
696
697 /* create cycleobject structure */
698 lz = (cycleobject *)type->tp_alloc(type, 0);
699 if (lz == NULL) {
700 Py_DECREF(it);
701 Py_DECREF(saved);
702 return NULL;
703 }
704 lz->it = it;
705 lz->saved = saved;
706 lz->firstpass = 0;
707
708 return (PyObject *)lz;
709}
710
711static void
712cycle_dealloc(cycleobject *lz)
713{
714 PyObject_GC_UnTrack(lz);
715 Py_XDECREF(lz->saved);
716 Py_XDECREF(lz->it);
Christian Heimese93237d2007-12-19 02:37:44 +0000717 Py_TYPE(lz)->tp_free(lz);
Raymond Hettinger61fe64d2003-02-23 04:40:07 +0000718}
719
720static int
721cycle_traverse(cycleobject *lz, visitproc visit, void *arg)
722{
Raymond Hettinger58ed69b2004-07-15 05:32:47 +0000723 Py_VISIT(lz->it);
724 Py_VISIT(lz->saved);
Raymond Hettinger61fe64d2003-02-23 04:40:07 +0000725 return 0;
726}
727
728static PyObject *
729cycle_next(cycleobject *lz)
730{
731 PyObject *item;
732 PyObject *it;
Raymond Hettinger880430e2004-10-02 10:56:43 +0000733 PyObject *tmp;
Raymond Hettinger61fe64d2003-02-23 04:40:07 +0000734
735 while (1) {
736 item = PyIter_Next(lz->it);
737 if (item != NULL) {
738 if (!lz->firstpass)
739 PyList_Append(lz->saved, item);
740 return item;
741 }
Raymond Hettinger9d7c8702004-05-08 19:49:42 +0000742 if (PyErr_Occurred()) {
743 if (PyErr_ExceptionMatches(PyExc_StopIteration))
744 PyErr_Clear();
745 else
746 return NULL;
747 }
Raymond Hettinger61fe64d2003-02-23 04:40:07 +0000748 if (PyList_Size(lz->saved) == 0)
749 return NULL;
750 it = PyObject_GetIter(lz->saved);
751 if (it == NULL)
752 return NULL;
Raymond Hettinger880430e2004-10-02 10:56:43 +0000753 tmp = lz->it;
Raymond Hettinger61fe64d2003-02-23 04:40:07 +0000754 lz->it = it;
755 lz->firstpass = 1;
Raymond Hettinger880430e2004-10-02 10:56:43 +0000756 Py_DECREF(tmp);
Raymond Hettinger61fe64d2003-02-23 04:40:07 +0000757 }
758}
759
Raymond Hettinger61fe64d2003-02-23 04:40:07 +0000760PyDoc_STRVAR(cycle_doc,
761"cycle(iterable) --> cycle object\n\
762\n\
763Return elements from the iterable until it is exhausted.\n\
764Then repeat the sequence indefinitely.");
765
Raymond Hettinger1d7a3482003-07-14 07:07:12 +0000766static PyTypeObject cycle_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +0000767 PyVarObject_HEAD_INIT(NULL, 0)
Raymond Hettinger61fe64d2003-02-23 04:40:07 +0000768 "itertools.cycle", /* tp_name */
769 sizeof(cycleobject), /* tp_basicsize */
770 0, /* tp_itemsize */
771 /* methods */
772 (destructor)cycle_dealloc, /* tp_dealloc */
773 0, /* tp_print */
774 0, /* tp_getattr */
775 0, /* tp_setattr */
776 0, /* tp_compare */
777 0, /* tp_repr */
778 0, /* tp_as_number */
779 0, /* tp_as_sequence */
780 0, /* tp_as_mapping */
781 0, /* tp_hash */
782 0, /* tp_call */
783 0, /* tp_str */
784 PyObject_GenericGetAttr, /* tp_getattro */
785 0, /* tp_setattro */
786 0, /* tp_as_buffer */
787 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC |
788 Py_TPFLAGS_BASETYPE, /* tp_flags */
789 cycle_doc, /* tp_doc */
790 (traverseproc)cycle_traverse, /* tp_traverse */
791 0, /* tp_clear */
792 0, /* tp_richcompare */
793 0, /* tp_weaklistoffset */
Raymond Hettinger1da1dbf2003-03-17 19:46:11 +0000794 PyObject_SelfIter, /* tp_iter */
Raymond Hettinger61fe64d2003-02-23 04:40:07 +0000795 (iternextfunc)cycle_next, /* tp_iternext */
796 0, /* tp_methods */
797 0, /* tp_members */
798 0, /* tp_getset */
799 0, /* tp_base */
800 0, /* tp_dict */
801 0, /* tp_descr_get */
802 0, /* tp_descr_set */
803 0, /* tp_dictoffset */
804 0, /* tp_init */
Raymond Hettingerbfef18c2003-05-23 03:55:42 +0000805 0, /* tp_alloc */
Raymond Hettinger61fe64d2003-02-23 04:40:07 +0000806 cycle_new, /* tp_new */
807 PyObject_GC_Del, /* tp_free */
808};
809
810
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000811/* dropwhile object **********************************************************/
812
813typedef struct {
814 PyObject_HEAD
815 PyObject *func;
816 PyObject *it;
817 long start;
818} dropwhileobject;
819
Raymond Hettinger1d7a3482003-07-14 07:07:12 +0000820static PyTypeObject dropwhile_type;
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000821
822static PyObject *
823dropwhile_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
824{
825 PyObject *func, *seq;
826 PyObject *it;
827 dropwhileobject *lz;
828
Georg Brandlb84c1372007-01-21 10:28:43 +0000829 if (type == &dropwhile_type && !_PyArg_NoKeywords("dropwhile()", kwds))
Georg Brandl02c42872005-08-26 06:42:30 +0000830 return NULL;
831
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000832 if (!PyArg_UnpackTuple(args, "dropwhile", 2, 2, &func, &seq))
833 return NULL;
834
835 /* Get iterator. */
836 it = PyObject_GetIter(seq);
837 if (it == NULL)
838 return NULL;
839
840 /* create dropwhileobject structure */
841 lz = (dropwhileobject *)type->tp_alloc(type, 0);
842 if (lz == NULL) {
843 Py_DECREF(it);
844 return NULL;
845 }
846 Py_INCREF(func);
847 lz->func = func;
848 lz->it = it;
849 lz->start = 0;
850
851 return (PyObject *)lz;
852}
853
854static void
855dropwhile_dealloc(dropwhileobject *lz)
856{
857 PyObject_GC_UnTrack(lz);
858 Py_XDECREF(lz->func);
859 Py_XDECREF(lz->it);
Christian Heimese93237d2007-12-19 02:37:44 +0000860 Py_TYPE(lz)->tp_free(lz);
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000861}
862
863static int
864dropwhile_traverse(dropwhileobject *lz, visitproc visit, void *arg)
865{
Raymond Hettinger58ed69b2004-07-15 05:32:47 +0000866 Py_VISIT(lz->it);
867 Py_VISIT(lz->func);
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000868 return 0;
869}
870
871static PyObject *
872dropwhile_next(dropwhileobject *lz)
873{
874 PyObject *item, *good;
Raymond Hettingerd1a283b2003-03-01 01:48:24 +0000875 PyObject *it = lz->it;
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000876 long ok;
Raymond Hettinger0faa1ca2004-03-17 04:27:44 +0000877 PyObject *(*iternext)(PyObject *);
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000878
Raymond Hettinger0faa1ca2004-03-17 04:27:44 +0000879 assert(PyIter_Check(it));
Christian Heimese93237d2007-12-19 02:37:44 +0000880 iternext = *Py_TYPE(it)->tp_iternext;
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000881 for (;;) {
Raymond Hettinger0faa1ca2004-03-17 04:27:44 +0000882 item = iternext(it);
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000883 if (item == NULL)
884 return NULL;
885 if (lz->start == 1)
886 return item;
887
888 good = PyObject_CallFunctionObjArgs(lz->func, item, NULL);
889 if (good == NULL) {
890 Py_DECREF(item);
891 return NULL;
892 }
893 ok = PyObject_IsTrue(good);
894 Py_DECREF(good);
895 if (!ok) {
896 lz->start = 1;
897 return item;
898 }
899 Py_DECREF(item);
900 }
901}
902
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000903PyDoc_STRVAR(dropwhile_doc,
904"dropwhile(predicate, iterable) --> dropwhile object\n\
905\n\
906Drop items from the iterable while predicate(item) is true.\n\
907Afterwards, return every element until the iterable is exhausted.");
908
Raymond Hettinger1d7a3482003-07-14 07:07:12 +0000909static PyTypeObject dropwhile_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +0000910 PyVarObject_HEAD_INIT(NULL, 0)
Raymond Hettinger60eca932003-02-09 06:40:58 +0000911 "itertools.dropwhile", /* tp_name */
912 sizeof(dropwhileobject), /* tp_basicsize */
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000913 0, /* tp_itemsize */
914 /* methods */
Raymond Hettinger60eca932003-02-09 06:40:58 +0000915 (destructor)dropwhile_dealloc, /* tp_dealloc */
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000916 0, /* tp_print */
917 0, /* tp_getattr */
918 0, /* tp_setattr */
919 0, /* tp_compare */
920 0, /* tp_repr */
921 0, /* tp_as_number */
922 0, /* tp_as_sequence */
923 0, /* tp_as_mapping */
924 0, /* tp_hash */
925 0, /* tp_call */
926 0, /* tp_str */
927 PyObject_GenericGetAttr, /* tp_getattro */
928 0, /* tp_setattro */
929 0, /* tp_as_buffer */
930 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC |
931 Py_TPFLAGS_BASETYPE, /* tp_flags */
Raymond Hettinger60eca932003-02-09 06:40:58 +0000932 dropwhile_doc, /* tp_doc */
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000933 (traverseproc)dropwhile_traverse, /* tp_traverse */
934 0, /* tp_clear */
935 0, /* tp_richcompare */
936 0, /* tp_weaklistoffset */
Raymond Hettinger1da1dbf2003-03-17 19:46:11 +0000937 PyObject_SelfIter, /* tp_iter */
Raymond Hettinger60eca932003-02-09 06:40:58 +0000938 (iternextfunc)dropwhile_next, /* tp_iternext */
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000939 0, /* tp_methods */
940 0, /* tp_members */
941 0, /* tp_getset */
942 0, /* tp_base */
943 0, /* tp_dict */
944 0, /* tp_descr_get */
945 0, /* tp_descr_set */
946 0, /* tp_dictoffset */
947 0, /* tp_init */
Raymond Hettingerbfef18c2003-05-23 03:55:42 +0000948 0, /* tp_alloc */
Raymond Hettinger60eca932003-02-09 06:40:58 +0000949 dropwhile_new, /* tp_new */
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000950 PyObject_GC_Del, /* tp_free */
951};
952
953
954/* takewhile object **********************************************************/
955
956typedef struct {
957 PyObject_HEAD
958 PyObject *func;
959 PyObject *it;
960 long stop;
961} takewhileobject;
962
Raymond Hettinger1d7a3482003-07-14 07:07:12 +0000963static PyTypeObject takewhile_type;
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000964
965static PyObject *
966takewhile_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
967{
968 PyObject *func, *seq;
969 PyObject *it;
970 takewhileobject *lz;
971
Georg Brandlb84c1372007-01-21 10:28:43 +0000972 if (type == &takewhile_type && !_PyArg_NoKeywords("takewhile()", kwds))
Georg Brandl02c42872005-08-26 06:42:30 +0000973 return NULL;
974
Raymond Hettinger96ef8112003-02-01 00:10:11 +0000975 if (!PyArg_UnpackTuple(args, "takewhile", 2, 2, &func, &seq))
976 return NULL;
977
978 /* Get iterator. */
979 it = PyObject_GetIter(seq);
980 if (it == NULL)
981 return NULL;
982
983 /* create takewhileobject structure */
984 lz = (takewhileobject *)type->tp_alloc(type, 0);
985 if (lz == NULL) {
986 Py_DECREF(it);
987 return NULL;
988 }
989 Py_INCREF(func);
990 lz->func = func;
991 lz->it = it;
992 lz->stop = 0;
993
994 return (PyObject *)lz;
995}
996
997static void
998takewhile_dealloc(takewhileobject *lz)
999{
1000 PyObject_GC_UnTrack(lz);
1001 Py_XDECREF(lz->func);
1002 Py_XDECREF(lz->it);
Christian Heimese93237d2007-12-19 02:37:44 +00001003 Py_TYPE(lz)->tp_free(lz);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001004}
1005
1006static int
1007takewhile_traverse(takewhileobject *lz, visitproc visit, void *arg)
1008{
Raymond Hettinger58ed69b2004-07-15 05:32:47 +00001009 Py_VISIT(lz->it);
1010 Py_VISIT(lz->func);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001011 return 0;
1012}
1013
1014static PyObject *
1015takewhile_next(takewhileobject *lz)
1016{
1017 PyObject *item, *good;
Raymond Hettingerd1a283b2003-03-01 01:48:24 +00001018 PyObject *it = lz->it;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001019 long ok;
1020
1021 if (lz->stop == 1)
1022 return NULL;
1023
Raymond Hettingerd1a283b2003-03-01 01:48:24 +00001024 assert(PyIter_Check(it));
Christian Heimese93237d2007-12-19 02:37:44 +00001025 item = (*Py_TYPE(it)->tp_iternext)(it);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001026 if (item == NULL)
1027 return NULL;
1028
1029 good = PyObject_CallFunctionObjArgs(lz->func, item, NULL);
1030 if (good == NULL) {
1031 Py_DECREF(item);
1032 return NULL;
1033 }
1034 ok = PyObject_IsTrue(good);
1035 Py_DECREF(good);
1036 if (ok)
1037 return item;
1038 Py_DECREF(item);
1039 lz->stop = 1;
1040 return NULL;
1041}
1042
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001043PyDoc_STRVAR(takewhile_doc,
1044"takewhile(predicate, iterable) --> takewhile object\n\
1045\n\
1046Return successive entries from an iterable as long as the \n\
1047predicate evaluates to true for each entry.");
1048
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00001049static PyTypeObject takewhile_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +00001050 PyVarObject_HEAD_INIT(NULL, 0)
Raymond Hettinger60eca932003-02-09 06:40:58 +00001051 "itertools.takewhile", /* tp_name */
1052 sizeof(takewhileobject), /* tp_basicsize */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001053 0, /* tp_itemsize */
1054 /* methods */
Raymond Hettinger60eca932003-02-09 06:40:58 +00001055 (destructor)takewhile_dealloc, /* tp_dealloc */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001056 0, /* tp_print */
1057 0, /* tp_getattr */
1058 0, /* tp_setattr */
1059 0, /* tp_compare */
1060 0, /* tp_repr */
1061 0, /* tp_as_number */
1062 0, /* tp_as_sequence */
1063 0, /* tp_as_mapping */
1064 0, /* tp_hash */
1065 0, /* tp_call */
1066 0, /* tp_str */
1067 PyObject_GenericGetAttr, /* tp_getattro */
1068 0, /* tp_setattro */
1069 0, /* tp_as_buffer */
1070 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC |
1071 Py_TPFLAGS_BASETYPE, /* tp_flags */
Raymond Hettinger60eca932003-02-09 06:40:58 +00001072 takewhile_doc, /* tp_doc */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001073 (traverseproc)takewhile_traverse, /* tp_traverse */
1074 0, /* tp_clear */
1075 0, /* tp_richcompare */
1076 0, /* tp_weaklistoffset */
Raymond Hettinger1da1dbf2003-03-17 19:46:11 +00001077 PyObject_SelfIter, /* tp_iter */
Raymond Hettinger60eca932003-02-09 06:40:58 +00001078 (iternextfunc)takewhile_next, /* tp_iternext */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001079 0, /* tp_methods */
1080 0, /* tp_members */
1081 0, /* tp_getset */
1082 0, /* tp_base */
1083 0, /* tp_dict */
1084 0, /* tp_descr_get */
1085 0, /* tp_descr_set */
1086 0, /* tp_dictoffset */
1087 0, /* tp_init */
Raymond Hettingerbfef18c2003-05-23 03:55:42 +00001088 0, /* tp_alloc */
Raymond Hettinger60eca932003-02-09 06:40:58 +00001089 takewhile_new, /* tp_new */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001090 PyObject_GC_Del, /* tp_free */
1091};
1092
1093
1094/* islice object ************************************************************/
1095
1096typedef struct {
1097 PyObject_HEAD
1098 PyObject *it;
Jack Diederich6c433a92006-05-26 11:15:17 +00001099 Py_ssize_t next;
1100 Py_ssize_t stop;
1101 Py_ssize_t step;
1102 Py_ssize_t cnt;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001103} isliceobject;
1104
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00001105static PyTypeObject islice_type;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001106
1107static PyObject *
1108islice_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
1109{
1110 PyObject *seq;
Jack Diederich6c433a92006-05-26 11:15:17 +00001111 Py_ssize_t start=0, stop=-1, step=1;
Raymond Hettingerb2594052004-12-05 09:25:51 +00001112 PyObject *it, *a1=NULL, *a2=NULL, *a3=NULL;
Martin v. Löwisad0a4622006-02-16 14:30:23 +00001113 Py_ssize_t numargs;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001114 isliceobject *lz;
1115
Georg Brandlb84c1372007-01-21 10:28:43 +00001116 if (type == &islice_type && !_PyArg_NoKeywords("islice()", kwds))
Georg Brandl02c42872005-08-26 06:42:30 +00001117 return NULL;
1118
Raymond Hettingerb2594052004-12-05 09:25:51 +00001119 if (!PyArg_UnpackTuple(args, "islice", 2, 4, &seq, &a1, &a2, &a3))
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001120 return NULL;
1121
Raymond Hettingerb2594052004-12-05 09:25:51 +00001122 numargs = PyTuple_Size(args);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001123 if (numargs == 2) {
Raymond Hettinger14ef54c2003-05-02 19:04:37 +00001124 if (a1 != Py_None) {
Jack Diederich6c433a92006-05-26 11:15:17 +00001125 stop = PyInt_AsSsize_t(a1);
Raymond Hettinger14ef54c2003-05-02 19:04:37 +00001126 if (stop == -1) {
1127 if (PyErr_Occurred())
1128 PyErr_Clear();
1129 PyErr_SetString(PyExc_ValueError,
Raymond Hettingerb2594052004-12-05 09:25:51 +00001130 "Stop argument for islice() must be a non-negative integer or None.");
Raymond Hettinger14ef54c2003-05-02 19:04:37 +00001131 return NULL;
1132 }
1133 }
Raymond Hettinger341deb72003-05-02 19:44:20 +00001134 } else {
Raymond Hettingerb2594052004-12-05 09:25:51 +00001135 if (a1 != Py_None)
Jack Diederich6c433a92006-05-26 11:15:17 +00001136 start = PyInt_AsSsize_t(a1);
Raymond Hettingerb2594052004-12-05 09:25:51 +00001137 if (start == -1 && PyErr_Occurred())
Raymond Hettinger14ef54c2003-05-02 19:04:37 +00001138 PyErr_Clear();
Raymond Hettinger14ef54c2003-05-02 19:04:37 +00001139 if (a2 != Py_None) {
Jack Diederich6c433a92006-05-26 11:15:17 +00001140 stop = PyInt_AsSsize_t(a2);
Raymond Hettinger14ef54c2003-05-02 19:04:37 +00001141 if (stop == -1) {
1142 if (PyErr_Occurred())
1143 PyErr_Clear();
1144 PyErr_SetString(PyExc_ValueError,
Raymond Hettingerb2594052004-12-05 09:25:51 +00001145 "Stop argument for islice() must be a non-negative integer or None.");
Raymond Hettinger14ef54c2003-05-02 19:04:37 +00001146 return NULL;
1147 }
1148 }
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001149 }
Raymond Hettinger14ef54c2003-05-02 19:04:37 +00001150 if (start<0 || stop<-1) {
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001151 PyErr_SetString(PyExc_ValueError,
Raymond Hettingerb2594052004-12-05 09:25:51 +00001152 "Indices for islice() must be non-negative integers or None.");
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001153 return NULL;
1154 }
1155
Raymond Hettingerb2594052004-12-05 09:25:51 +00001156 if (a3 != NULL) {
1157 if (a3 != Py_None)
Jack Diederich6c433a92006-05-26 11:15:17 +00001158 step = PyInt_AsSsize_t(a3);
Raymond Hettingerb2594052004-12-05 09:25:51 +00001159 if (step == -1 && PyErr_Occurred())
1160 PyErr_Clear();
1161 }
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001162 if (step<1) {
1163 PyErr_SetString(PyExc_ValueError,
Raymond Hettingerb2594052004-12-05 09:25:51 +00001164 "Step for islice() must be a positive integer or None.");
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001165 return NULL;
1166 }
1167
1168 /* Get iterator. */
1169 it = PyObject_GetIter(seq);
1170 if (it == NULL)
1171 return NULL;
1172
1173 /* create isliceobject structure */
1174 lz = (isliceobject *)type->tp_alloc(type, 0);
1175 if (lz == NULL) {
1176 Py_DECREF(it);
1177 return NULL;
1178 }
1179 lz->it = it;
1180 lz->next = start;
1181 lz->stop = stop;
1182 lz->step = step;
1183 lz->cnt = 0L;
1184
1185 return (PyObject *)lz;
1186}
1187
1188static void
1189islice_dealloc(isliceobject *lz)
1190{
1191 PyObject_GC_UnTrack(lz);
1192 Py_XDECREF(lz->it);
Christian Heimese93237d2007-12-19 02:37:44 +00001193 Py_TYPE(lz)->tp_free(lz);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001194}
1195
1196static int
1197islice_traverse(isliceobject *lz, visitproc visit, void *arg)
1198{
Raymond Hettinger58ed69b2004-07-15 05:32:47 +00001199 Py_VISIT(lz->it);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001200 return 0;
1201}
1202
1203static PyObject *
1204islice_next(isliceobject *lz)
1205{
1206 PyObject *item;
Raymond Hettingerd1a283b2003-03-01 01:48:24 +00001207 PyObject *it = lz->it;
Jack Diederich6c433a92006-05-26 11:15:17 +00001208 Py_ssize_t oldnext;
Raymond Hettinger0faa1ca2004-03-17 04:27:44 +00001209 PyObject *(*iternext)(PyObject *);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001210
Raymond Hettinger0faa1ca2004-03-17 04:27:44 +00001211 assert(PyIter_Check(it));
Christian Heimese93237d2007-12-19 02:37:44 +00001212 iternext = *Py_TYPE(it)->tp_iternext;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001213 while (lz->cnt < lz->next) {
Raymond Hettinger0faa1ca2004-03-17 04:27:44 +00001214 item = iternext(it);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001215 if (item == NULL)
1216 return NULL;
1217 Py_DECREF(item);
1218 lz->cnt++;
1219 }
Raymond Hettinger14ef54c2003-05-02 19:04:37 +00001220 if (lz->stop != -1 && lz->cnt >= lz->stop)
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001221 return NULL;
Raymond Hettingerd1a283b2003-03-01 01:48:24 +00001222 assert(PyIter_Check(it));
Raymond Hettinger0faa1ca2004-03-17 04:27:44 +00001223 item = iternext(it);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001224 if (item == NULL)
1225 return NULL;
1226 lz->cnt++;
Raymond Hettinger2012f172003-02-07 05:32:58 +00001227 oldnext = lz->next;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001228 lz->next += lz->step;
Raymond Hettinger2012f172003-02-07 05:32:58 +00001229 if (lz->next < oldnext) /* Check for overflow */
1230 lz->next = lz->stop;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001231 return item;
1232}
1233
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001234PyDoc_STRVAR(islice_doc,
1235"islice(iterable, [start,] stop [, step]) --> islice object\n\
1236\n\
1237Return an iterator whose next() method returns selected values from an\n\
1238iterable. If start is specified, will skip all preceding elements;\n\
1239otherwise, start defaults to zero. Step defaults to one. If\n\
1240specified as another value, step determines how many values are \n\
1241skipped between successive calls. Works like a slice() on a list\n\
1242but returns an iterator.");
1243
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00001244static PyTypeObject islice_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +00001245 PyVarObject_HEAD_INIT(NULL, 0)
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001246 "itertools.islice", /* tp_name */
1247 sizeof(isliceobject), /* tp_basicsize */
1248 0, /* tp_itemsize */
1249 /* methods */
Raymond Hettinger60eca932003-02-09 06:40:58 +00001250 (destructor)islice_dealloc, /* tp_dealloc */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001251 0, /* tp_print */
1252 0, /* tp_getattr */
1253 0, /* tp_setattr */
1254 0, /* tp_compare */
1255 0, /* tp_repr */
1256 0, /* tp_as_number */
1257 0, /* tp_as_sequence */
1258 0, /* tp_as_mapping */
1259 0, /* tp_hash */
1260 0, /* tp_call */
1261 0, /* tp_str */
1262 PyObject_GenericGetAttr, /* tp_getattro */
1263 0, /* tp_setattro */
1264 0, /* tp_as_buffer */
1265 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC |
1266 Py_TPFLAGS_BASETYPE, /* tp_flags */
Raymond Hettinger60eca932003-02-09 06:40:58 +00001267 islice_doc, /* tp_doc */
1268 (traverseproc)islice_traverse, /* tp_traverse */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001269 0, /* tp_clear */
1270 0, /* tp_richcompare */
1271 0, /* tp_weaklistoffset */
Raymond Hettinger1da1dbf2003-03-17 19:46:11 +00001272 PyObject_SelfIter, /* tp_iter */
Raymond Hettinger60eca932003-02-09 06:40:58 +00001273 (iternextfunc)islice_next, /* tp_iternext */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001274 0, /* tp_methods */
1275 0, /* tp_members */
1276 0, /* tp_getset */
1277 0, /* tp_base */
1278 0, /* tp_dict */
1279 0, /* tp_descr_get */
1280 0, /* tp_descr_set */
1281 0, /* tp_dictoffset */
1282 0, /* tp_init */
Raymond Hettingerbfef18c2003-05-23 03:55:42 +00001283 0, /* tp_alloc */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001284 islice_new, /* tp_new */
1285 PyObject_GC_Del, /* tp_free */
1286};
1287
1288
1289/* starmap object ************************************************************/
1290
1291typedef struct {
1292 PyObject_HEAD
1293 PyObject *func;
1294 PyObject *it;
1295} starmapobject;
1296
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00001297static PyTypeObject starmap_type;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001298
1299static PyObject *
1300starmap_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
1301{
1302 PyObject *func, *seq;
1303 PyObject *it;
1304 starmapobject *lz;
1305
Georg Brandlb84c1372007-01-21 10:28:43 +00001306 if (type == &starmap_type && !_PyArg_NoKeywords("starmap()", kwds))
Georg Brandl02c42872005-08-26 06:42:30 +00001307 return NULL;
1308
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001309 if (!PyArg_UnpackTuple(args, "starmap", 2, 2, &func, &seq))
1310 return NULL;
1311
1312 /* Get iterator. */
1313 it = PyObject_GetIter(seq);
1314 if (it == NULL)
1315 return NULL;
1316
1317 /* create starmapobject structure */
1318 lz = (starmapobject *)type->tp_alloc(type, 0);
1319 if (lz == NULL) {
1320 Py_DECREF(it);
1321 return NULL;
1322 }
1323 Py_INCREF(func);
1324 lz->func = func;
1325 lz->it = it;
1326
1327 return (PyObject *)lz;
1328}
1329
1330static void
1331starmap_dealloc(starmapobject *lz)
1332{
1333 PyObject_GC_UnTrack(lz);
1334 Py_XDECREF(lz->func);
1335 Py_XDECREF(lz->it);
Christian Heimese93237d2007-12-19 02:37:44 +00001336 Py_TYPE(lz)->tp_free(lz);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001337}
1338
1339static int
1340starmap_traverse(starmapobject *lz, visitproc visit, void *arg)
1341{
Raymond Hettinger58ed69b2004-07-15 05:32:47 +00001342 Py_VISIT(lz->it);
1343 Py_VISIT(lz->func);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001344 return 0;
1345}
1346
1347static PyObject *
1348starmap_next(starmapobject *lz)
1349{
1350 PyObject *args;
1351 PyObject *result;
Raymond Hettingerd1a283b2003-03-01 01:48:24 +00001352 PyObject *it = lz->it;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001353
Raymond Hettingerd1a283b2003-03-01 01:48:24 +00001354 assert(PyIter_Check(it));
Christian Heimese93237d2007-12-19 02:37:44 +00001355 args = (*Py_TYPE(it)->tp_iternext)(it);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001356 if (args == NULL)
1357 return NULL;
Raymond Hettinger2012f172003-02-07 05:32:58 +00001358 if (!PyTuple_CheckExact(args)) {
Raymond Hettinger47317092008-01-17 03:02:14 +00001359 PyObject *newargs = PySequence_Tuple(args);
Raymond Hettinger2012f172003-02-07 05:32:58 +00001360 Py_DECREF(args);
Raymond Hettinger47317092008-01-17 03:02:14 +00001361 if (newargs == NULL)
1362 return NULL;
1363 args = newargs;
Raymond Hettinger2012f172003-02-07 05:32:58 +00001364 }
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001365 result = PyObject_Call(lz->func, args, NULL);
1366 Py_DECREF(args);
1367 return result;
1368}
1369
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001370PyDoc_STRVAR(starmap_doc,
1371"starmap(function, sequence) --> starmap object\n\
1372\n\
1373Return an iterator whose values are returned from the function evaluated\n\
1374with a argument tuple taken from the given sequence.");
1375
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00001376static PyTypeObject starmap_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +00001377 PyVarObject_HEAD_INIT(NULL, 0)
Raymond Hettinger60eca932003-02-09 06:40:58 +00001378 "itertools.starmap", /* tp_name */
1379 sizeof(starmapobject), /* tp_basicsize */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001380 0, /* tp_itemsize */
1381 /* methods */
Raymond Hettinger60eca932003-02-09 06:40:58 +00001382 (destructor)starmap_dealloc, /* tp_dealloc */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001383 0, /* tp_print */
1384 0, /* tp_getattr */
1385 0, /* tp_setattr */
1386 0, /* tp_compare */
1387 0, /* tp_repr */
1388 0, /* tp_as_number */
1389 0, /* tp_as_sequence */
1390 0, /* tp_as_mapping */
1391 0, /* tp_hash */
1392 0, /* tp_call */
1393 0, /* tp_str */
1394 PyObject_GenericGetAttr, /* tp_getattro */
1395 0, /* tp_setattro */
1396 0, /* tp_as_buffer */
1397 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC |
1398 Py_TPFLAGS_BASETYPE, /* tp_flags */
Raymond Hettinger60eca932003-02-09 06:40:58 +00001399 starmap_doc, /* tp_doc */
1400 (traverseproc)starmap_traverse, /* tp_traverse */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001401 0, /* tp_clear */
1402 0, /* tp_richcompare */
1403 0, /* tp_weaklistoffset */
Raymond Hettinger1da1dbf2003-03-17 19:46:11 +00001404 PyObject_SelfIter, /* tp_iter */
Raymond Hettinger60eca932003-02-09 06:40:58 +00001405 (iternextfunc)starmap_next, /* tp_iternext */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001406 0, /* tp_methods */
1407 0, /* tp_members */
1408 0, /* tp_getset */
1409 0, /* tp_base */
1410 0, /* tp_dict */
1411 0, /* tp_descr_get */
1412 0, /* tp_descr_set */
1413 0, /* tp_dictoffset */
1414 0, /* tp_init */
Raymond Hettingerbfef18c2003-05-23 03:55:42 +00001415 0, /* tp_alloc */
Raymond Hettinger60eca932003-02-09 06:40:58 +00001416 starmap_new, /* tp_new */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001417 PyObject_GC_Del, /* tp_free */
1418};
1419
1420
1421/* imap object ************************************************************/
1422
1423typedef struct {
1424 PyObject_HEAD
1425 PyObject *iters;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001426 PyObject *func;
1427} imapobject;
1428
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00001429static PyTypeObject imap_type;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001430
1431static PyObject *
1432imap_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
1433{
Raymond Hettingerf0c00242003-02-07 07:26:25 +00001434 PyObject *it, *iters, *func;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001435 imapobject *lz;
Martin v. Löwisad0a4622006-02-16 14:30:23 +00001436 Py_ssize_t numargs, i;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001437
Georg Brandlb84c1372007-01-21 10:28:43 +00001438 if (type == &imap_type && !_PyArg_NoKeywords("imap()", kwds))
Georg Brandl02c42872005-08-26 06:42:30 +00001439 return NULL;
1440
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001441 numargs = PyTuple_Size(args);
1442 if (numargs < 2) {
1443 PyErr_SetString(PyExc_TypeError,
1444 "imap() must have at least two arguments.");
1445 return NULL;
1446 }
1447
1448 iters = PyTuple_New(numargs-1);
1449 if (iters == NULL)
1450 return NULL;
1451
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001452 for (i=1 ; i<numargs ; i++) {
1453 /* Get iterator. */
1454 it = PyObject_GetIter(PyTuple_GET_ITEM(args, i));
1455 if (it == NULL) {
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001456 Py_DECREF(iters);
1457 return NULL;
1458 }
1459 PyTuple_SET_ITEM(iters, i-1, it);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001460 }
1461
1462 /* create imapobject structure */
1463 lz = (imapobject *)type->tp_alloc(type, 0);
1464 if (lz == NULL) {
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001465 Py_DECREF(iters);
1466 return NULL;
1467 }
1468 lz->iters = iters;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001469 func = PyTuple_GET_ITEM(args, 0);
1470 Py_INCREF(func);
1471 lz->func = func;
1472
1473 return (PyObject *)lz;
1474}
1475
1476static void
1477imap_dealloc(imapobject *lz)
1478{
1479 PyObject_GC_UnTrack(lz);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001480 Py_XDECREF(lz->iters);
1481 Py_XDECREF(lz->func);
Christian Heimese93237d2007-12-19 02:37:44 +00001482 Py_TYPE(lz)->tp_free(lz);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001483}
1484
1485static int
1486imap_traverse(imapobject *lz, visitproc visit, void *arg)
1487{
Raymond Hettinger58ed69b2004-07-15 05:32:47 +00001488 Py_VISIT(lz->iters);
1489 Py_VISIT(lz->func);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001490 return 0;
1491}
1492
Raymond Hettinger2012f172003-02-07 05:32:58 +00001493/*
1494imap() is an iterator version of __builtins__.map() except that it does
1495not have the None fill-in feature. That was intentionally left out for
1496the following reasons:
1497
1498 1) Itertools are designed to be easily combined and chained together.
1499 Having all tools stop with the shortest input is a unifying principle
1500 that makes it easier to combine finite iterators (supplying data) with
1501 infinite iterators like count() and repeat() (for supplying sequential
1502 or constant arguments to a function).
1503
1504 2) In typical use cases for combining itertools, having one finite data
1505 supplier run out before another is likely to be an error condition which
1506 should not pass silently by automatically supplying None.
1507
1508 3) The use cases for automatic None fill-in are rare -- not many functions
1509 do something useful when a parameter suddenly switches type and becomes
1510 None.
1511
1512 4) If a need does arise, it can be met by __builtins__.map() or by
Raymond Hettingerbefa37d2003-06-18 19:25:37 +00001513 writing: chain(iterable, repeat(None)).
Raymond Hettinger2012f172003-02-07 05:32:58 +00001514
1515 5) Similar toolsets in Haskell and SML do not have automatic None fill-in.
1516*/
1517
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001518static PyObject *
1519imap_next(imapobject *lz)
1520{
1521 PyObject *val;
Raymond Hettingerf0c00242003-02-07 07:26:25 +00001522 PyObject *argtuple;
1523 PyObject *result;
Martin v. Löwisad0a4622006-02-16 14:30:23 +00001524 Py_ssize_t numargs, i;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001525
1526 numargs = PyTuple_Size(lz->iters);
Raymond Hettingerf0c00242003-02-07 07:26:25 +00001527 argtuple = PyTuple_New(numargs);
1528 if (argtuple == NULL)
1529 return NULL;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001530
Raymond Hettingerf0c00242003-02-07 07:26:25 +00001531 for (i=0 ; i<numargs ; i++) {
1532 val = PyIter_Next(PyTuple_GET_ITEM(lz->iters, i));
1533 if (val == NULL) {
1534 Py_DECREF(argtuple);
1535 return NULL;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001536 }
Raymond Hettingerf0c00242003-02-07 07:26:25 +00001537 PyTuple_SET_ITEM(argtuple, i, val);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001538 }
Raymond Hettingerf0c00242003-02-07 07:26:25 +00001539 if (lz->func == Py_None)
1540 return argtuple;
1541 result = PyObject_Call(lz->func, argtuple, NULL);
1542 Py_DECREF(argtuple);
1543 return result;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001544}
1545
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001546PyDoc_STRVAR(imap_doc,
1547"imap(func, *iterables) --> imap object\n\
1548\n\
1549Make an iterator that computes the function using arguments from\n\
1550each of the iterables. Like map() except that it returns\n\
1551an iterator instead of a list and that it stops when the shortest\n\
1552iterable is exhausted instead of filling in None for shorter\n\
1553iterables.");
1554
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00001555static PyTypeObject imap_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +00001556 PyVarObject_HEAD_INIT(NULL, 0)
Raymond Hettinger60eca932003-02-09 06:40:58 +00001557 "itertools.imap", /* tp_name */
1558 sizeof(imapobject), /* tp_basicsize */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001559 0, /* tp_itemsize */
1560 /* methods */
1561 (destructor)imap_dealloc, /* tp_dealloc */
1562 0, /* tp_print */
1563 0, /* tp_getattr */
1564 0, /* tp_setattr */
1565 0, /* tp_compare */
1566 0, /* tp_repr */
1567 0, /* tp_as_number */
1568 0, /* tp_as_sequence */
1569 0, /* tp_as_mapping */
1570 0, /* tp_hash */
1571 0, /* tp_call */
1572 0, /* tp_str */
1573 PyObject_GenericGetAttr, /* tp_getattro */
1574 0, /* tp_setattro */
1575 0, /* tp_as_buffer */
1576 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC |
1577 Py_TPFLAGS_BASETYPE, /* tp_flags */
1578 imap_doc, /* tp_doc */
1579 (traverseproc)imap_traverse, /* tp_traverse */
1580 0, /* tp_clear */
1581 0, /* tp_richcompare */
1582 0, /* tp_weaklistoffset */
Raymond Hettinger1da1dbf2003-03-17 19:46:11 +00001583 PyObject_SelfIter, /* tp_iter */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001584 (iternextfunc)imap_next, /* tp_iternext */
1585 0, /* tp_methods */
1586 0, /* tp_members */
1587 0, /* tp_getset */
1588 0, /* tp_base */
1589 0, /* tp_dict */
1590 0, /* tp_descr_get */
1591 0, /* tp_descr_set */
1592 0, /* tp_dictoffset */
1593 0, /* tp_init */
Raymond Hettingerbfef18c2003-05-23 03:55:42 +00001594 0, /* tp_alloc */
Raymond Hettinger60eca932003-02-09 06:40:58 +00001595 imap_new, /* tp_new */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001596 PyObject_GC_Del, /* tp_free */
1597};
1598
1599
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00001600/* chain object ************************************************************/
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001601
1602typedef struct {
1603 PyObject_HEAD
Raymond Hettinger05bf6332008-02-28 22:30:42 +00001604 PyObject *source; /* Iterator over input iterables */
1605 PyObject *active; /* Currently running input iterator */
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00001606} chainobject;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001607
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00001608static PyTypeObject chain_type;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001609
Raymond Hettinger05bf6332008-02-28 22:30:42 +00001610static PyObject *
1611chain_new_internal(PyTypeObject *type, PyObject *source)
1612{
1613 chainobject *lz;
1614
1615 lz = (chainobject *)type->tp_alloc(type, 0);
1616 if (lz == NULL) {
1617 Py_DECREF(source);
1618 return NULL;
1619 }
1620
1621 lz->source = source;
1622 lz->active = NULL;
1623 return (PyObject *)lz;
1624}
1625
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001626static PyObject *
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00001627chain_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001628{
Raymond Hettinger05bf6332008-02-28 22:30:42 +00001629 PyObject *source;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001630
Georg Brandlb84c1372007-01-21 10:28:43 +00001631 if (type == &chain_type && !_PyArg_NoKeywords("chain()", kwds))
Georg Brandl02c42872005-08-26 06:42:30 +00001632 return NULL;
Raymond Hettinger05bf6332008-02-28 22:30:42 +00001633
1634 source = PyObject_GetIter(args);
1635 if (source == NULL)
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001636 return NULL;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001637
Raymond Hettinger05bf6332008-02-28 22:30:42 +00001638 return chain_new_internal(type, source);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001639}
1640
Raymond Hettingerb4cbc982008-02-28 22:46:41 +00001641static PyObject *
1642chain_new_from_iterable(PyTypeObject *type, PyObject *arg)
1643{
1644 PyObject *source;
1645
1646 source = PyObject_GetIter(arg);
1647 if (source == NULL)
1648 return NULL;
1649
1650 return chain_new_internal(type, source);
1651}
1652
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001653static void
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00001654chain_dealloc(chainobject *lz)
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001655{
1656 PyObject_GC_UnTrack(lz);
Raymond Hettinger05bf6332008-02-28 22:30:42 +00001657 Py_XDECREF(lz->active);
1658 Py_XDECREF(lz->source);
Christian Heimese93237d2007-12-19 02:37:44 +00001659 Py_TYPE(lz)->tp_free(lz);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001660}
1661
Raymond Hettinger2012f172003-02-07 05:32:58 +00001662static int
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00001663chain_traverse(chainobject *lz, visitproc visit, void *arg)
Raymond Hettinger2012f172003-02-07 05:32:58 +00001664{
Raymond Hettinger05bf6332008-02-28 22:30:42 +00001665 Py_VISIT(lz->source);
1666 Py_VISIT(lz->active);
Raymond Hettinger2012f172003-02-07 05:32:58 +00001667 return 0;
1668}
1669
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001670static PyObject *
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00001671chain_next(chainobject *lz)
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001672{
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00001673 PyObject *item;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001674
Raymond Hettinger05bf6332008-02-28 22:30:42 +00001675 if (lz->source == NULL)
1676 return NULL; /* already stopped */
1677
1678 if (lz->active == NULL) {
1679 PyObject *iterable = PyIter_Next(lz->source);
1680 if (iterable == NULL) {
1681 Py_CLEAR(lz->source);
1682 return NULL; /* no more input sources */
Raymond Hettinger9d7c8702004-05-08 19:49:42 +00001683 }
Raymond Hettinger05bf6332008-02-28 22:30:42 +00001684 lz->active = PyObject_GetIter(iterable);
1685 if (lz->active == NULL) {
1686 Py_DECREF(iterable);
1687 Py_CLEAR(lz->source);
1688 return NULL; /* input not iterable */
1689 }
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001690 }
Raymond Hettinger05bf6332008-02-28 22:30:42 +00001691 item = PyIter_Next(lz->active);
1692 if (item != NULL)
1693 return item;
1694 if (PyErr_Occurred()) {
1695 if (PyErr_ExceptionMatches(PyExc_StopIteration))
1696 PyErr_Clear();
1697 else
1698 return NULL; /* input raised an exception */
1699 }
1700 Py_CLEAR(lz->active);
1701 return chain_next(lz); /* recurse and use next active */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001702}
1703
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00001704PyDoc_STRVAR(chain_doc,
1705"chain(*iterables) --> chain object\n\
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001706\n\
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00001707Return a chain object whose .next() method returns elements from the\n\
1708first iterable until it is exhausted, then elements from the next\n\
1709iterable, until all of the iterables are exhausted.");
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001710
Raymond Hettingerb4cbc982008-02-28 22:46:41 +00001711PyDoc_STRVAR(chain_from_iterable_doc,
1712"chain.from_iterable(iterable) --> chain object\n\
1713\n\
1714Alternate chain() contructor taking a single iterable argument\n\
1715that evaluates lazily.");
1716
1717static PyMethodDef chain_methods[] = {
1718 {"from_iterable", (PyCFunction) chain_new_from_iterable, METH_O | METH_CLASS,
1719 chain_from_iterable_doc},
1720 {NULL, NULL} /* sentinel */
1721};
1722
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00001723static PyTypeObject chain_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +00001724 PyVarObject_HEAD_INIT(NULL, 0)
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00001725 "itertools.chain", /* tp_name */
1726 sizeof(chainobject), /* tp_basicsize */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001727 0, /* tp_itemsize */
1728 /* methods */
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00001729 (destructor)chain_dealloc, /* tp_dealloc */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001730 0, /* tp_print */
1731 0, /* tp_getattr */
1732 0, /* tp_setattr */
1733 0, /* tp_compare */
1734 0, /* tp_repr */
1735 0, /* tp_as_number */
1736 0, /* tp_as_sequence */
1737 0, /* tp_as_mapping */
1738 0, /* tp_hash */
1739 0, /* tp_call */
1740 0, /* tp_str */
1741 PyObject_GenericGetAttr, /* tp_getattro */
1742 0, /* tp_setattro */
1743 0, /* tp_as_buffer */
1744 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC |
1745 Py_TPFLAGS_BASETYPE, /* tp_flags */
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00001746 chain_doc, /* tp_doc */
1747 (traverseproc)chain_traverse, /* tp_traverse */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001748 0, /* tp_clear */
1749 0, /* tp_richcompare */
1750 0, /* tp_weaklistoffset */
Raymond Hettinger1da1dbf2003-03-17 19:46:11 +00001751 PyObject_SelfIter, /* tp_iter */
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00001752 (iternextfunc)chain_next, /* tp_iternext */
Raymond Hettingerb4cbc982008-02-28 22:46:41 +00001753 chain_methods, /* tp_methods */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001754 0, /* tp_members */
1755 0, /* tp_getset */
1756 0, /* tp_base */
1757 0, /* tp_dict */
1758 0, /* tp_descr_get */
1759 0, /* tp_descr_set */
1760 0, /* tp_dictoffset */
1761 0, /* tp_init */
Raymond Hettingerbfef18c2003-05-23 03:55:42 +00001762 0, /* tp_alloc */
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00001763 chain_new, /* tp_new */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00001764 PyObject_GC_Del, /* tp_free */
1765};
1766
1767
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001768/* product object ************************************************************/
1769
1770typedef struct {
1771 PyObject_HEAD
1772 PyObject *pools; /* tuple of pool tuples */
Raymond Hettinger532316d2008-02-23 04:03:50 +00001773 Py_ssize_t *indices; /* one index per pool */
1774 PyObject *result; /* most recently returned result tuple */
1775 int stopped; /* set to 1 when the product iterator is exhausted */
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001776} productobject;
1777
1778static PyTypeObject product_type;
1779
1780static PyObject *
1781product_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
1782{
1783 productobject *lz;
Raymond Hettinger08ff6822008-02-29 02:21:48 +00001784 Py_ssize_t nargs, npools, repeat=1;
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001785 PyObject *pools = NULL;
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001786 Py_ssize_t *indices = NULL;
1787 Py_ssize_t i;
1788
Raymond Hettinger08ff6822008-02-29 02:21:48 +00001789 if (kwds != NULL) {
1790 char *kwlist[] = {"repeat", 0};
1791 PyObject *tmpargs = PyTuple_New(0);
1792 if (tmpargs == NULL)
1793 return NULL;
1794 if (!PyArg_ParseTupleAndKeywords(tmpargs, kwds, "|n:product", kwlist, &repeat)) {
1795 Py_DECREF(tmpargs);
1796 return NULL;
1797 }
1798 Py_DECREF(tmpargs);
1799 if (repeat < 0) {
1800 PyErr_SetString(PyExc_ValueError,
1801 "repeat argument cannot be negative");
1802 return NULL;
1803 }
1804 }
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001805
1806 assert(PyTuple_Check(args));
Raymond Hettinger08ff6822008-02-29 02:21:48 +00001807 nargs = (repeat == 0) ? 0 : PyTuple_GET_SIZE(args);
1808 npools = nargs * repeat;
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001809
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001810 indices = PyMem_Malloc(npools * sizeof(Py_ssize_t));
Raymond Hettinger61024b92008-03-02 11:57:16 +00001811 if (indices == NULL) {
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001812 PyErr_NoMemory();
1813 goto error;
1814 }
1815
1816 pools = PyTuple_New(npools);
1817 if (pools == NULL)
1818 goto error;
1819
Raymond Hettinger08ff6822008-02-29 02:21:48 +00001820 for (i=0; i < nargs ; ++i) {
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001821 PyObject *item = PyTuple_GET_ITEM(args, i);
1822 PyObject *pool = PySequence_Tuple(item);
1823 if (pool == NULL)
1824 goto error;
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001825 PyTuple_SET_ITEM(pools, i, pool);
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001826 indices[i] = 0;
1827 }
Raymond Hettinger08ff6822008-02-29 02:21:48 +00001828 for ( ; i < npools; ++i) {
1829 PyObject *pool = PyTuple_GET_ITEM(pools, i - nargs);
1830 Py_INCREF(pool);
1831 PyTuple_SET_ITEM(pools, i, pool);
Raymond Hettinger08ff6822008-02-29 02:21:48 +00001832 indices[i] = 0;
1833 }
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001834
1835 /* create productobject structure */
1836 lz = (productobject *)type->tp_alloc(type, 0);
Raymond Hettinger3bd77122008-02-27 01:08:04 +00001837 if (lz == NULL)
Raymond Hettinger73d79632008-02-23 02:20:41 +00001838 goto error;
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001839
1840 lz->pools = pools;
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001841 lz->indices = indices;
1842 lz->result = NULL;
1843 lz->stopped = 0;
1844
1845 return (PyObject *)lz;
1846
1847error:
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001848 if (indices != NULL)
1849 PyMem_Free(indices);
1850 Py_XDECREF(pools);
1851 return NULL;
1852}
1853
1854static void
1855product_dealloc(productobject *lz)
1856{
1857 PyObject_GC_UnTrack(lz);
1858 Py_XDECREF(lz->pools);
1859 Py_XDECREF(lz->result);
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001860 PyMem_Free(lz->indices);
1861 Py_TYPE(lz)->tp_free(lz);
1862}
1863
1864static int
1865product_traverse(productobject *lz, visitproc visit, void *arg)
1866{
1867 Py_VISIT(lz->pools);
1868 Py_VISIT(lz->result);
1869 return 0;
1870}
1871
1872static PyObject *
1873product_next(productobject *lz)
1874{
1875 PyObject *pool;
1876 PyObject *elem;
Raymond Hettinger73d79632008-02-23 02:20:41 +00001877 PyObject *oldelem;
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001878 PyObject *pools = lz->pools;
1879 PyObject *result = lz->result;
1880 Py_ssize_t npools = PyTuple_GET_SIZE(pools);
1881 Py_ssize_t i;
1882
1883 if (lz->stopped)
1884 return NULL;
Raymond Hettinger73d79632008-02-23 02:20:41 +00001885
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001886 if (result == NULL) {
Raymond Hettinger73d79632008-02-23 02:20:41 +00001887 /* On the first pass, return an initial tuple filled with the
Raymond Hettingerd553d852008-03-04 04:17:08 +00001888 first element from each pool. */
Raymond Hettinger73d79632008-02-23 02:20:41 +00001889 result = PyTuple_New(npools);
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001890 if (result == NULL)
1891 goto empty;
1892 lz->result = result;
1893 for (i=0; i < npools; i++) {
1894 pool = PyTuple_GET_ITEM(pools, i);
1895 if (PyTuple_GET_SIZE(pool) == 0)
1896 goto empty;
1897 elem = PyTuple_GET_ITEM(pool, 0);
1898 Py_INCREF(elem);
Raymond Hettinger73d79632008-02-23 02:20:41 +00001899 PyTuple_SET_ITEM(result, i, elem);
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001900 }
1901 } else {
1902 Py_ssize_t *indices = lz->indices;
Raymond Hettinger73d79632008-02-23 02:20:41 +00001903
1904 /* Copy the previous result tuple or re-use it if available */
1905 if (Py_REFCNT(result) > 1) {
1906 PyObject *old_result = result;
1907 result = PyTuple_New(npools);
1908 if (result == NULL)
1909 goto empty;
1910 lz->result = result;
1911 for (i=0; i < npools; i++) {
1912 elem = PyTuple_GET_ITEM(old_result, i);
1913 Py_INCREF(elem);
1914 PyTuple_SET_ITEM(result, i, elem);
1915 }
1916 Py_DECREF(old_result);
1917 }
1918 /* Now, we've got the only copy so we can update it in-place */
Raymond Hettingere3fabd12008-03-02 12:02:19 +00001919 assert (npools==0 || Py_REFCNT(result) == 1);
Raymond Hettinger73d79632008-02-23 02:20:41 +00001920
1921 /* Update the pool indices right-to-left. Only advance to the
1922 next pool when the previous one rolls-over */
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001923 for (i=npools-1 ; i >= 0 ; i--) {
1924 pool = PyTuple_GET_ITEM(pools, i);
1925 indices[i]++;
Raymond Hettinger61024b92008-03-02 11:57:16 +00001926 if (indices[i] == PyTuple_GET_SIZE(pool)) {
Raymond Hettinger73d79632008-02-23 02:20:41 +00001927 /* Roll-over and advance to next pool */
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001928 indices[i] = 0;
1929 elem = PyTuple_GET_ITEM(pool, 0);
1930 Py_INCREF(elem);
Raymond Hettinger73d79632008-02-23 02:20:41 +00001931 oldelem = PyTuple_GET_ITEM(result, i);
1932 PyTuple_SET_ITEM(result, i, elem);
1933 Py_DECREF(oldelem);
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001934 } else {
Raymond Hettinger73d79632008-02-23 02:20:41 +00001935 /* No rollover. Just increment and stop here. */
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001936 elem = PyTuple_GET_ITEM(pool, indices[i]);
1937 Py_INCREF(elem);
Raymond Hettinger73d79632008-02-23 02:20:41 +00001938 oldelem = PyTuple_GET_ITEM(result, i);
1939 PyTuple_SET_ITEM(result, i, elem);
1940 Py_DECREF(oldelem);
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001941 break;
1942 }
1943 }
Raymond Hettinger73d79632008-02-23 02:20:41 +00001944
1945 /* If i is negative, then the indices have all rolled-over
1946 and we're done. */
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001947 if (i < 0)
Raymond Hettinger73d79632008-02-23 02:20:41 +00001948 goto empty;
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001949 }
1950
Raymond Hettinger73d79632008-02-23 02:20:41 +00001951 Py_INCREF(result);
1952 return result;
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001953
1954empty:
1955 lz->stopped = 1;
1956 return NULL;
1957}
1958
1959PyDoc_STRVAR(product_doc,
1960"product(*iterables) --> product object\n\
1961\n\
Raymond Hettinger73d79632008-02-23 02:20:41 +00001962Cartesian product of input iterables. Equivalent to nested for-loops.\n\n\
Raymond Hettinger50986cc2008-02-22 03:16:42 +00001963For example, product(A, B) returns the same as: ((x,y) for x in A for y in B).\n\
1964The leftmost iterators are in the outermost for-loop, so the output tuples\n\
1965cycle in a manner similar to an odometer (with the rightmost element changing\n\
1966on every iteration).\n\n\
1967product('ab', range(3)) --> ('a',0) ('a',1) ('a',2) ('b',0) ('b',1) ('b',2)\n\
1968product((0,1), (0,1), (0,1)) --> (0,0,0) (0,0,1) (0,1,0) (0,1,1) (1,0,0) ...");
1969
1970static PyTypeObject product_type = {
1971 PyVarObject_HEAD_INIT(NULL, 0)
1972 "itertools.product", /* tp_name */
1973 sizeof(productobject), /* tp_basicsize */
1974 0, /* tp_itemsize */
1975 /* methods */
1976 (destructor)product_dealloc, /* tp_dealloc */
1977 0, /* tp_print */
1978 0, /* tp_getattr */
1979 0, /* tp_setattr */
1980 0, /* tp_compare */
1981 0, /* tp_repr */
1982 0, /* tp_as_number */
1983 0, /* tp_as_sequence */
1984 0, /* tp_as_mapping */
1985 0, /* tp_hash */
1986 0, /* tp_call */
1987 0, /* tp_str */
1988 PyObject_GenericGetAttr, /* tp_getattro */
1989 0, /* tp_setattro */
1990 0, /* tp_as_buffer */
1991 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC |
1992 Py_TPFLAGS_BASETYPE, /* tp_flags */
1993 product_doc, /* tp_doc */
1994 (traverseproc)product_traverse, /* tp_traverse */
1995 0, /* tp_clear */
1996 0, /* tp_richcompare */
1997 0, /* tp_weaklistoffset */
1998 PyObject_SelfIter, /* tp_iter */
1999 (iternextfunc)product_next, /* tp_iternext */
2000 0, /* tp_methods */
2001 0, /* tp_members */
2002 0, /* tp_getset */
2003 0, /* tp_base */
2004 0, /* tp_dict */
2005 0, /* tp_descr_get */
2006 0, /* tp_descr_set */
2007 0, /* tp_dictoffset */
2008 0, /* tp_init */
2009 0, /* tp_alloc */
2010 product_new, /* tp_new */
2011 PyObject_GC_Del, /* tp_free */
2012};
2013
2014
Raymond Hettinger93e804d2008-02-26 23:40:50 +00002015/* combinations object ************************************************************/
2016
2017typedef struct {
2018 PyObject_HEAD
2019 PyObject *pool; /* input converted to a tuple */
2020 Py_ssize_t *indices; /* one index per result element */
2021 PyObject *result; /* most recently returned result tuple */
2022 Py_ssize_t r; /* size of result tuple */
2023 int stopped; /* set to 1 when the combinations iterator is exhausted */
2024} combinationsobject;
2025
2026static PyTypeObject combinations_type;
2027
2028static PyObject *
2029combinations_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
2030{
2031 combinationsobject *co;
2032 Py_ssize_t n;
2033 Py_ssize_t r;
2034 PyObject *pool = NULL;
2035 PyObject *iterable = NULL;
2036 Py_ssize_t *indices = NULL;
2037 Py_ssize_t i;
2038 static char *kwargs[] = {"iterable", "r", NULL};
2039
2040 if (!PyArg_ParseTupleAndKeywords(args, kwds, "On:combinations", kwargs,
2041 &iterable, &r))
2042 return NULL;
2043
2044 pool = PySequence_Tuple(iterable);
2045 if (pool == NULL)
2046 goto error;
2047 n = PyTuple_GET_SIZE(pool);
2048 if (r < 0) {
2049 PyErr_SetString(PyExc_ValueError, "r must be non-negative");
2050 goto error;
2051 }
2052 if (r > n) {
2053 PyErr_SetString(PyExc_ValueError, "r cannot be bigger than the iterable");
2054 goto error;
2055 }
2056
2057 indices = PyMem_Malloc(r * sizeof(Py_ssize_t));
2058 if (indices == NULL) {
2059 PyErr_NoMemory();
2060 goto error;
2061 }
2062
2063 for (i=0 ; i<r ; i++)
2064 indices[i] = i;
2065
2066 /* create combinationsobject structure */
2067 co = (combinationsobject *)type->tp_alloc(type, 0);
2068 if (co == NULL)
2069 goto error;
2070
2071 co->pool = pool;
2072 co->indices = indices;
2073 co->result = NULL;
2074 co->r = r;
2075 co->stopped = 0;
2076
2077 return (PyObject *)co;
2078
2079error:
2080 if (indices != NULL)
2081 PyMem_Free(indices);
2082 Py_XDECREF(pool);
2083 return NULL;
2084}
2085
2086static void
2087combinations_dealloc(combinationsobject *co)
2088{
2089 PyObject_GC_UnTrack(co);
2090 Py_XDECREF(co->pool);
2091 Py_XDECREF(co->result);
2092 PyMem_Free(co->indices);
2093 Py_TYPE(co)->tp_free(co);
2094}
2095
2096static int
2097combinations_traverse(combinationsobject *co, visitproc visit, void *arg)
2098{
2099 Py_VISIT(co->pool);
2100 Py_VISIT(co->result);
2101 return 0;
2102}
2103
2104static PyObject *
2105combinations_next(combinationsobject *co)
2106{
2107 PyObject *elem;
2108 PyObject *oldelem;
2109 PyObject *pool = co->pool;
2110 Py_ssize_t *indices = co->indices;
2111 PyObject *result = co->result;
2112 Py_ssize_t n = PyTuple_GET_SIZE(pool);
2113 Py_ssize_t r = co->r;
2114 Py_ssize_t i, j, index;
2115
2116 if (co->stopped)
2117 return NULL;
2118
2119 if (result == NULL) {
2120 /* On the first pass, initialize result tuple using the indices */
2121 result = PyTuple_New(r);
2122 if (result == NULL)
2123 goto empty;
2124 co->result = result;
2125 for (i=0; i<r ; i++) {
2126 index = indices[i];
2127 elem = PyTuple_GET_ITEM(pool, index);
2128 Py_INCREF(elem);
2129 PyTuple_SET_ITEM(result, i, elem);
2130 }
2131 } else {
2132 /* Copy the previous result tuple or re-use it if available */
2133 if (Py_REFCNT(result) > 1) {
2134 PyObject *old_result = result;
2135 result = PyTuple_New(r);
2136 if (result == NULL)
2137 goto empty;
2138 co->result = result;
2139 for (i=0; i<r ; i++) {
2140 elem = PyTuple_GET_ITEM(old_result, i);
2141 Py_INCREF(elem);
2142 PyTuple_SET_ITEM(result, i, elem);
2143 }
2144 Py_DECREF(old_result);
2145 }
Christian Heimescdddf182008-02-28 11:18:49 +00002146 /* Now, we've got the only copy so we can update it in-place
2147 * CPython's empty tuple is a singleton and cached in
2148 * PyTuple's freelist.
2149 */
2150 assert(r == 0 || Py_REFCNT(result) == 1);
Raymond Hettinger93e804d2008-02-26 23:40:50 +00002151
2152 /* Scan indices right-to-left until finding one that is not
2153 at its maximum (i + n - r). */
2154 for (i=r-1 ; i >= 0 && indices[i] == i+n-r ; i--)
2155 ;
2156
2157 /* If i is negative, then the indices are all at
2158 their maximum value and we're done. */
2159 if (i < 0)
2160 goto empty;
2161
2162 /* Increment the current index which we know is not at its
2163 maximum. Then move back to the right setting each index
2164 to its lowest possible value (one higher than the index
2165 to its left -- this maintains the sort order invariant). */
2166 indices[i]++;
2167 for (j=i+1 ; j<r ; j++)
2168 indices[j] = indices[j-1] + 1;
2169
2170 /* Update the result tuple for the new indices
2171 starting with i, the leftmost index that changed */
2172 for ( ; i<r ; i++) {
2173 index = indices[i];
2174 elem = PyTuple_GET_ITEM(pool, index);
2175 Py_INCREF(elem);
2176 oldelem = PyTuple_GET_ITEM(result, i);
2177 PyTuple_SET_ITEM(result, i, elem);
2178 Py_DECREF(oldelem);
2179 }
2180 }
2181
2182 Py_INCREF(result);
2183 return result;
2184
2185empty:
2186 co->stopped = 1;
2187 return NULL;
2188}
2189
2190PyDoc_STRVAR(combinations_doc,
2191"combinations(iterables) --> combinations object\n\
2192\n\
2193Return successive r-length combinations of elements in the iterable.\n\n\
2194combinations(range(4), 3) --> (0,1,2), (0,1,3), (0,2,3), (1,2,3)");
2195
2196static PyTypeObject combinations_type = {
2197 PyVarObject_HEAD_INIT(NULL, 0)
2198 "itertools.combinations", /* tp_name */
2199 sizeof(combinationsobject), /* tp_basicsize */
2200 0, /* tp_itemsize */
2201 /* methods */
2202 (destructor)combinations_dealloc, /* tp_dealloc */
2203 0, /* tp_print */
2204 0, /* tp_getattr */
2205 0, /* tp_setattr */
2206 0, /* tp_compare */
2207 0, /* tp_repr */
2208 0, /* tp_as_number */
2209 0, /* tp_as_sequence */
2210 0, /* tp_as_mapping */
2211 0, /* tp_hash */
2212 0, /* tp_call */
2213 0, /* tp_str */
2214 PyObject_GenericGetAttr, /* tp_getattro */
2215 0, /* tp_setattro */
2216 0, /* tp_as_buffer */
2217 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC |
2218 Py_TPFLAGS_BASETYPE, /* tp_flags */
2219 combinations_doc, /* tp_doc */
2220 (traverseproc)combinations_traverse, /* tp_traverse */
2221 0, /* tp_clear */
2222 0, /* tp_richcompare */
2223 0, /* tp_weaklistoffset */
2224 PyObject_SelfIter, /* tp_iter */
2225 (iternextfunc)combinations_next, /* tp_iternext */
2226 0, /* tp_methods */
2227 0, /* tp_members */
2228 0, /* tp_getset */
2229 0, /* tp_base */
2230 0, /* tp_dict */
2231 0, /* tp_descr_get */
2232 0, /* tp_descr_set */
2233 0, /* tp_dictoffset */
2234 0, /* tp_init */
2235 0, /* tp_alloc */
2236 combinations_new, /* tp_new */
2237 PyObject_GC_Del, /* tp_free */
2238};
2239
2240
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002241/* ifilter object ************************************************************/
2242
2243typedef struct {
2244 PyObject_HEAD
2245 PyObject *func;
2246 PyObject *it;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002247} ifilterobject;
2248
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00002249static PyTypeObject ifilter_type;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002250
2251static PyObject *
2252ifilter_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
2253{
Raymond Hettinger60eca932003-02-09 06:40:58 +00002254 PyObject *func, *seq;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002255 PyObject *it;
2256 ifilterobject *lz;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002257
Georg Brandlb84c1372007-01-21 10:28:43 +00002258 if (type == &ifilter_type && !_PyArg_NoKeywords("ifilter()", kwds))
Georg Brandl02c42872005-08-26 06:42:30 +00002259 return NULL;
2260
Raymond Hettinger60eca932003-02-09 06:40:58 +00002261 if (!PyArg_UnpackTuple(args, "ifilter", 2, 2, &func, &seq))
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002262 return NULL;
2263
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002264 /* Get iterator. */
2265 it = PyObject_GetIter(seq);
2266 if (it == NULL)
2267 return NULL;
2268
2269 /* create ifilterobject structure */
2270 lz = (ifilterobject *)type->tp_alloc(type, 0);
2271 if (lz == NULL) {
2272 Py_DECREF(it);
2273 return NULL;
2274 }
2275 Py_INCREF(func);
2276 lz->func = func;
2277 lz->it = it;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002278
2279 return (PyObject *)lz;
2280}
2281
2282static void
2283ifilter_dealloc(ifilterobject *lz)
2284{
2285 PyObject_GC_UnTrack(lz);
2286 Py_XDECREF(lz->func);
2287 Py_XDECREF(lz->it);
Christian Heimese93237d2007-12-19 02:37:44 +00002288 Py_TYPE(lz)->tp_free(lz);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002289}
2290
2291static int
2292ifilter_traverse(ifilterobject *lz, visitproc visit, void *arg)
2293{
Raymond Hettinger58ed69b2004-07-15 05:32:47 +00002294 Py_VISIT(lz->it);
2295 Py_VISIT(lz->func);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002296 return 0;
2297}
2298
2299static PyObject *
2300ifilter_next(ifilterobject *lz)
2301{
2302 PyObject *item;
Raymond Hettingerd1a283b2003-03-01 01:48:24 +00002303 PyObject *it = lz->it;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002304 long ok;
Raymond Hettinger0faa1ca2004-03-17 04:27:44 +00002305 PyObject *(*iternext)(PyObject *);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002306
Raymond Hettinger0faa1ca2004-03-17 04:27:44 +00002307 assert(PyIter_Check(it));
Christian Heimese93237d2007-12-19 02:37:44 +00002308 iternext = *Py_TYPE(it)->tp_iternext;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002309 for (;;) {
Raymond Hettinger0faa1ca2004-03-17 04:27:44 +00002310 item = iternext(it);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002311 if (item == NULL)
2312 return NULL;
2313
Facundo Batistab1d70e22008-02-25 23:46:02 +00002314 if (lz->func == Py_None || lz->func == (PyObject *)&PyBool_Type) {
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002315 ok = PyObject_IsTrue(item);
2316 } else {
2317 PyObject *good;
2318 good = PyObject_CallFunctionObjArgs(lz->func,
2319 item, NULL);
2320 if (good == NULL) {
2321 Py_DECREF(item);
2322 return NULL;
2323 }
2324 ok = PyObject_IsTrue(good);
2325 Py_DECREF(good);
2326 }
Raymond Hettinger60eca932003-02-09 06:40:58 +00002327 if (ok)
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002328 return item;
2329 Py_DECREF(item);
2330 }
2331}
2332
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002333PyDoc_STRVAR(ifilter_doc,
Raymond Hettinger60eca932003-02-09 06:40:58 +00002334"ifilter(function or None, sequence) --> ifilter object\n\
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002335\n\
Raymond Hettinger60eca932003-02-09 06:40:58 +00002336Return those items of sequence for which function(item) is true.\n\
2337If function is None, return the items that are true.");
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002338
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00002339static PyTypeObject ifilter_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +00002340 PyVarObject_HEAD_INIT(NULL, 0)
Raymond Hettinger60eca932003-02-09 06:40:58 +00002341 "itertools.ifilter", /* tp_name */
2342 sizeof(ifilterobject), /* tp_basicsize */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002343 0, /* tp_itemsize */
2344 /* methods */
Raymond Hettinger60eca932003-02-09 06:40:58 +00002345 (destructor)ifilter_dealloc, /* tp_dealloc */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002346 0, /* tp_print */
2347 0, /* tp_getattr */
2348 0, /* tp_setattr */
2349 0, /* tp_compare */
2350 0, /* tp_repr */
2351 0, /* tp_as_number */
2352 0, /* tp_as_sequence */
2353 0, /* tp_as_mapping */
2354 0, /* tp_hash */
2355 0, /* tp_call */
2356 0, /* tp_str */
2357 PyObject_GenericGetAttr, /* tp_getattro */
2358 0, /* tp_setattro */
2359 0, /* tp_as_buffer */
2360 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC |
2361 Py_TPFLAGS_BASETYPE, /* tp_flags */
Raymond Hettinger60eca932003-02-09 06:40:58 +00002362 ifilter_doc, /* tp_doc */
2363 (traverseproc)ifilter_traverse, /* tp_traverse */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002364 0, /* tp_clear */
2365 0, /* tp_richcompare */
2366 0, /* tp_weaklistoffset */
Raymond Hettinger1da1dbf2003-03-17 19:46:11 +00002367 PyObject_SelfIter, /* tp_iter */
Raymond Hettinger60eca932003-02-09 06:40:58 +00002368 (iternextfunc)ifilter_next, /* tp_iternext */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002369 0, /* tp_methods */
2370 0, /* tp_members */
2371 0, /* tp_getset */
2372 0, /* tp_base */
2373 0, /* tp_dict */
2374 0, /* tp_descr_get */
2375 0, /* tp_descr_set */
2376 0, /* tp_dictoffset */
2377 0, /* tp_init */
Raymond Hettingerbfef18c2003-05-23 03:55:42 +00002378 0, /* tp_alloc */
Raymond Hettinger60eca932003-02-09 06:40:58 +00002379 ifilter_new, /* tp_new */
2380 PyObject_GC_Del, /* tp_free */
2381};
2382
2383
2384/* ifilterfalse object ************************************************************/
2385
2386typedef struct {
2387 PyObject_HEAD
2388 PyObject *func;
2389 PyObject *it;
2390} ifilterfalseobject;
2391
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00002392static PyTypeObject ifilterfalse_type;
Raymond Hettinger60eca932003-02-09 06:40:58 +00002393
2394static PyObject *
2395ifilterfalse_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
2396{
Guido van Rossumd58f3fc2003-02-09 17:19:18 +00002397 PyObject *func, *seq;
Raymond Hettinger60eca932003-02-09 06:40:58 +00002398 PyObject *it;
2399 ifilterfalseobject *lz;
2400
Georg Brandlb84c1372007-01-21 10:28:43 +00002401 if (type == &ifilterfalse_type &&
2402 !_PyArg_NoKeywords("ifilterfalse()", kwds))
Georg Brandl02c42872005-08-26 06:42:30 +00002403 return NULL;
2404
Raymond Hettinger60eca932003-02-09 06:40:58 +00002405 if (!PyArg_UnpackTuple(args, "ifilterfalse", 2, 2, &func, &seq))
2406 return NULL;
2407
2408 /* Get iterator. */
2409 it = PyObject_GetIter(seq);
2410 if (it == NULL)
2411 return NULL;
2412
2413 /* create ifilterfalseobject structure */
2414 lz = (ifilterfalseobject *)type->tp_alloc(type, 0);
2415 if (lz == NULL) {
2416 Py_DECREF(it);
2417 return NULL;
2418 }
2419 Py_INCREF(func);
2420 lz->func = func;
2421 lz->it = it;
2422
2423 return (PyObject *)lz;
2424}
2425
2426static void
2427ifilterfalse_dealloc(ifilterfalseobject *lz)
2428{
2429 PyObject_GC_UnTrack(lz);
2430 Py_XDECREF(lz->func);
2431 Py_XDECREF(lz->it);
Christian Heimese93237d2007-12-19 02:37:44 +00002432 Py_TYPE(lz)->tp_free(lz);
Raymond Hettinger60eca932003-02-09 06:40:58 +00002433}
2434
2435static int
2436ifilterfalse_traverse(ifilterfalseobject *lz, visitproc visit, void *arg)
2437{
Raymond Hettinger58ed69b2004-07-15 05:32:47 +00002438 Py_VISIT(lz->it);
2439 Py_VISIT(lz->func);
Raymond Hettinger60eca932003-02-09 06:40:58 +00002440 return 0;
2441}
2442
2443static PyObject *
2444ifilterfalse_next(ifilterfalseobject *lz)
2445{
2446 PyObject *item;
Raymond Hettingerd1a283b2003-03-01 01:48:24 +00002447 PyObject *it = lz->it;
Raymond Hettinger60eca932003-02-09 06:40:58 +00002448 long ok;
Raymond Hettinger0faa1ca2004-03-17 04:27:44 +00002449 PyObject *(*iternext)(PyObject *);
Raymond Hettinger60eca932003-02-09 06:40:58 +00002450
Raymond Hettinger0faa1ca2004-03-17 04:27:44 +00002451 assert(PyIter_Check(it));
Christian Heimese93237d2007-12-19 02:37:44 +00002452 iternext = *Py_TYPE(it)->tp_iternext;
Raymond Hettinger60eca932003-02-09 06:40:58 +00002453 for (;;) {
Raymond Hettinger0faa1ca2004-03-17 04:27:44 +00002454 item = iternext(it);
Raymond Hettinger60eca932003-02-09 06:40:58 +00002455 if (item == NULL)
2456 return NULL;
2457
Facundo Batistab1d70e22008-02-25 23:46:02 +00002458 if (lz->func == Py_None || lz->func == (PyObject *)&PyBool_Type) {
Raymond Hettinger60eca932003-02-09 06:40:58 +00002459 ok = PyObject_IsTrue(item);
2460 } else {
2461 PyObject *good;
2462 good = PyObject_CallFunctionObjArgs(lz->func,
2463 item, NULL);
2464 if (good == NULL) {
2465 Py_DECREF(item);
2466 return NULL;
2467 }
2468 ok = PyObject_IsTrue(good);
2469 Py_DECREF(good);
2470 }
2471 if (!ok)
2472 return item;
2473 Py_DECREF(item);
2474 }
2475}
2476
Raymond Hettinger60eca932003-02-09 06:40:58 +00002477PyDoc_STRVAR(ifilterfalse_doc,
2478"ifilterfalse(function or None, sequence) --> ifilterfalse object\n\
2479\n\
2480Return those items of sequence for which function(item) is false.\n\
2481If function is None, return the items that are false.");
2482
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00002483static PyTypeObject ifilterfalse_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +00002484 PyVarObject_HEAD_INIT(NULL, 0)
Raymond Hettinger60eca932003-02-09 06:40:58 +00002485 "itertools.ifilterfalse", /* tp_name */
2486 sizeof(ifilterfalseobject), /* tp_basicsize */
2487 0, /* tp_itemsize */
2488 /* methods */
2489 (destructor)ifilterfalse_dealloc, /* tp_dealloc */
2490 0, /* tp_print */
2491 0, /* tp_getattr */
2492 0, /* tp_setattr */
2493 0, /* tp_compare */
2494 0, /* tp_repr */
2495 0, /* tp_as_number */
2496 0, /* tp_as_sequence */
2497 0, /* tp_as_mapping */
2498 0, /* tp_hash */
2499 0, /* tp_call */
2500 0, /* tp_str */
2501 PyObject_GenericGetAttr, /* tp_getattro */
2502 0, /* tp_setattro */
2503 0, /* tp_as_buffer */
2504 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC |
2505 Py_TPFLAGS_BASETYPE, /* tp_flags */
2506 ifilterfalse_doc, /* tp_doc */
2507 (traverseproc)ifilterfalse_traverse, /* tp_traverse */
2508 0, /* tp_clear */
2509 0, /* tp_richcompare */
2510 0, /* tp_weaklistoffset */
Raymond Hettinger1da1dbf2003-03-17 19:46:11 +00002511 PyObject_SelfIter, /* tp_iter */
Raymond Hettinger60eca932003-02-09 06:40:58 +00002512 (iternextfunc)ifilterfalse_next, /* tp_iternext */
2513 0, /* tp_methods */
2514 0, /* tp_members */
2515 0, /* tp_getset */
2516 0, /* tp_base */
2517 0, /* tp_dict */
2518 0, /* tp_descr_get */
2519 0, /* tp_descr_set */
2520 0, /* tp_dictoffset */
2521 0, /* tp_init */
Raymond Hettingerbfef18c2003-05-23 03:55:42 +00002522 0, /* tp_alloc */
Raymond Hettinger60eca932003-02-09 06:40:58 +00002523 ifilterfalse_new, /* tp_new */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002524 PyObject_GC_Del, /* tp_free */
2525};
2526
2527
2528/* count object ************************************************************/
2529
2530typedef struct {
2531 PyObject_HEAD
Jack Diederich6c433a92006-05-26 11:15:17 +00002532 Py_ssize_t cnt;
Raymond Hettinger50e90e22007-10-04 00:20:27 +00002533 PyObject *long_cnt; /* Arbitrarily large count when cnt >= PY_SSIZE_T_MAX */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002534} countobject;
2535
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00002536static PyTypeObject count_type;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002537
2538static PyObject *
2539count_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
2540{
2541 countobject *lz;
Jack Diederich6c433a92006-05-26 11:15:17 +00002542 Py_ssize_t cnt = 0;
Raymond Hettinger50e90e22007-10-04 00:20:27 +00002543 PyObject *cnt_arg = NULL;
2544 PyObject *long_cnt = NULL;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002545
Georg Brandlb84c1372007-01-21 10:28:43 +00002546 if (type == &count_type && !_PyArg_NoKeywords("count()", kwds))
Georg Brandl02c42872005-08-26 06:42:30 +00002547 return NULL;
2548
Raymond Hettinger50e90e22007-10-04 00:20:27 +00002549 if (!PyArg_UnpackTuple(args, "count", 0, 1, &cnt_arg))
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002550 return NULL;
2551
Raymond Hettinger50e90e22007-10-04 00:20:27 +00002552 if (cnt_arg != NULL) {
2553 cnt = PyInt_AsSsize_t(cnt_arg);
2554 if (cnt == -1 && PyErr_Occurred()) {
2555 PyErr_Clear();
2556 if (!PyLong_Check(cnt_arg)) {
2557 PyErr_SetString(PyExc_TypeError, "an integer is required");
2558 return NULL;
2559 }
2560 long_cnt = cnt_arg;
2561 Py_INCREF(long_cnt);
2562 cnt = PY_SSIZE_T_MAX;
2563 }
2564 }
2565
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002566 /* create countobject structure */
2567 lz = (countobject *)PyObject_New(countobject, &count_type);
Raymond Hettinger50e90e22007-10-04 00:20:27 +00002568 if (lz == NULL) {
2569 Py_XDECREF(long_cnt);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002570 return NULL;
Raymond Hettinger50e90e22007-10-04 00:20:27 +00002571 }
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002572 lz->cnt = cnt;
Raymond Hettinger50e90e22007-10-04 00:20:27 +00002573 lz->long_cnt = long_cnt;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002574
2575 return (PyObject *)lz;
2576}
2577
Raymond Hettinger50e90e22007-10-04 00:20:27 +00002578static void
2579count_dealloc(countobject *lz)
2580{
2581 Py_XDECREF(lz->long_cnt);
2582 PyObject_Del(lz);
2583}
2584
2585static PyObject *
2586count_nextlong(countobject *lz)
2587{
2588 static PyObject *one = NULL;
2589 PyObject *cnt;
2590 PyObject *stepped_up;
2591
2592 if (lz->long_cnt == NULL) {
2593 lz->long_cnt = PyInt_FromSsize_t(PY_SSIZE_T_MAX);
2594 if (lz->long_cnt == NULL)
2595 return NULL;
2596 }
2597 if (one == NULL) {
2598 one = PyInt_FromLong(1);
2599 if (one == NULL)
2600 return NULL;
2601 }
2602 cnt = lz->long_cnt;
2603 assert(cnt != NULL);
2604 stepped_up = PyNumber_Add(cnt, one);
2605 if (stepped_up == NULL)
2606 return NULL;
2607 lz->long_cnt = stepped_up;
2608 return cnt;
2609}
2610
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002611static PyObject *
2612count_next(countobject *lz)
2613{
Raymond Hettinger50e90e22007-10-04 00:20:27 +00002614 if (lz->cnt == PY_SSIZE_T_MAX)
2615 return count_nextlong(lz);
Jack Diederich36234e82006-09-21 17:50:26 +00002616 return PyInt_FromSsize_t(lz->cnt++);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002617}
2618
Raymond Hettinger7dacda22004-04-08 21:54:00 +00002619static PyObject *
2620count_repr(countobject *lz)
2621{
Raymond Hettinger50e90e22007-10-04 00:20:27 +00002622 PyObject *cnt_repr;
2623 PyObject *result;
2624
2625 if (lz->cnt != PY_SSIZE_T_MAX)
2626 return PyString_FromFormat("count(%zd)", lz->cnt);
2627
2628 cnt_repr = PyObject_Repr(lz->long_cnt);
2629 if (cnt_repr == NULL)
2630 return NULL;
2631 result = PyString_FromFormat("count(%s)", PyString_AS_STRING(cnt_repr));
2632 Py_DECREF(cnt_repr);
2633 return result;
Raymond Hettinger7dacda22004-04-08 21:54:00 +00002634}
2635
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002636PyDoc_STRVAR(count_doc,
2637"count([firstval]) --> count object\n\
2638\n\
2639Return a count object whose .next() method returns consecutive\n\
2640integers starting from zero or, if specified, from firstval.");
2641
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00002642static PyTypeObject count_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +00002643 PyVarObject_HEAD_INIT(NULL, 0)
Raymond Hettinger60eca932003-02-09 06:40:58 +00002644 "itertools.count", /* tp_name */
2645 sizeof(countobject), /* tp_basicsize */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002646 0, /* tp_itemsize */
2647 /* methods */
Raymond Hettinger50e90e22007-10-04 00:20:27 +00002648 (destructor)count_dealloc, /* tp_dealloc */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002649 0, /* tp_print */
2650 0, /* tp_getattr */
2651 0, /* tp_setattr */
2652 0, /* tp_compare */
Raymond Hettinger7dacda22004-04-08 21:54:00 +00002653 (reprfunc)count_repr, /* tp_repr */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002654 0, /* tp_as_number */
2655 0, /* tp_as_sequence */
2656 0, /* tp_as_mapping */
2657 0, /* tp_hash */
2658 0, /* tp_call */
2659 0, /* tp_str */
2660 PyObject_GenericGetAttr, /* tp_getattro */
2661 0, /* tp_setattro */
2662 0, /* tp_as_buffer */
2663 Py_TPFLAGS_DEFAULT, /* tp_flags */
Raymond Hettinger60eca932003-02-09 06:40:58 +00002664 count_doc, /* tp_doc */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002665 0, /* tp_traverse */
2666 0, /* tp_clear */
2667 0, /* tp_richcompare */
2668 0, /* tp_weaklistoffset */
Raymond Hettinger1da1dbf2003-03-17 19:46:11 +00002669 PyObject_SelfIter, /* tp_iter */
Raymond Hettinger60eca932003-02-09 06:40:58 +00002670 (iternextfunc)count_next, /* tp_iternext */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002671 0, /* tp_methods */
2672 0, /* tp_members */
2673 0, /* tp_getset */
2674 0, /* tp_base */
2675 0, /* tp_dict */
2676 0, /* tp_descr_get */
2677 0, /* tp_descr_set */
2678 0, /* tp_dictoffset */
2679 0, /* tp_init */
Raymond Hettingerbfef18c2003-05-23 03:55:42 +00002680 0, /* tp_alloc */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002681 count_new, /* tp_new */
2682};
2683
2684
2685/* izip object ************************************************************/
2686
2687#include "Python.h"
2688
2689typedef struct {
2690 PyObject_HEAD
Martin v. Löwisad0a4622006-02-16 14:30:23 +00002691 Py_ssize_t tuplesize;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002692 PyObject *ittuple; /* tuple of iterators */
Raymond Hettinger2012f172003-02-07 05:32:58 +00002693 PyObject *result;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002694} izipobject;
2695
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00002696static PyTypeObject izip_type;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002697
2698static PyObject *
2699izip_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
2700{
2701 izipobject *lz;
Jack Diederich6c433a92006-05-26 11:15:17 +00002702 Py_ssize_t i;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002703 PyObject *ittuple; /* tuple of iterators */
Raymond Hettinger2012f172003-02-07 05:32:58 +00002704 PyObject *result;
Martin v. Löwisad0a4622006-02-16 14:30:23 +00002705 Py_ssize_t tuplesize = PySequence_Length(args);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002706
Georg Brandlb84c1372007-01-21 10:28:43 +00002707 if (type == &izip_type && !_PyArg_NoKeywords("izip()", kwds))
Georg Brandl02c42872005-08-26 06:42:30 +00002708 return NULL;
2709
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002710 /* args must be a tuple */
2711 assert(PyTuple_Check(args));
2712
2713 /* obtain iterators */
2714 ittuple = PyTuple_New(tuplesize);
Neal Norwitz2f3136b2006-05-27 05:18:57 +00002715 if (ittuple == NULL)
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002716 return NULL;
2717 for (i=0; i < tuplesize; ++i) {
2718 PyObject *item = PyTuple_GET_ITEM(args, i);
2719 PyObject *it = PyObject_GetIter(item);
2720 if (it == NULL) {
2721 if (PyErr_ExceptionMatches(PyExc_TypeError))
2722 PyErr_Format(PyExc_TypeError,
Neal Norwitz2f3136b2006-05-27 05:18:57 +00002723 "izip argument #%zd must support iteration",
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002724 i+1);
2725 Py_DECREF(ittuple);
2726 return NULL;
2727 }
2728 PyTuple_SET_ITEM(ittuple, i, it);
2729 }
2730
Raymond Hettinger2012f172003-02-07 05:32:58 +00002731 /* create a result holder */
2732 result = PyTuple_New(tuplesize);
2733 if (result == NULL) {
2734 Py_DECREF(ittuple);
2735 return NULL;
2736 }
2737 for (i=0 ; i < tuplesize ; i++) {
2738 Py_INCREF(Py_None);
2739 PyTuple_SET_ITEM(result, i, Py_None);
2740 }
2741
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002742 /* create izipobject structure */
2743 lz = (izipobject *)type->tp_alloc(type, 0);
2744 if (lz == NULL) {
2745 Py_DECREF(ittuple);
Raymond Hettinger2012f172003-02-07 05:32:58 +00002746 Py_DECREF(result);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002747 return NULL;
2748 }
2749 lz->ittuple = ittuple;
2750 lz->tuplesize = tuplesize;
Raymond Hettinger2012f172003-02-07 05:32:58 +00002751 lz->result = result;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002752
2753 return (PyObject *)lz;
2754}
2755
2756static void
2757izip_dealloc(izipobject *lz)
2758{
2759 PyObject_GC_UnTrack(lz);
2760 Py_XDECREF(lz->ittuple);
Raymond Hettinger2012f172003-02-07 05:32:58 +00002761 Py_XDECREF(lz->result);
Christian Heimese93237d2007-12-19 02:37:44 +00002762 Py_TYPE(lz)->tp_free(lz);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002763}
2764
2765static int
2766izip_traverse(izipobject *lz, visitproc visit, void *arg)
2767{
Raymond Hettinger58ed69b2004-07-15 05:32:47 +00002768 Py_VISIT(lz->ittuple);
2769 Py_VISIT(lz->result);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002770 return 0;
2771}
2772
2773static PyObject *
2774izip_next(izipobject *lz)
2775{
Jack Diederich6c433a92006-05-26 11:15:17 +00002776 Py_ssize_t i;
Martin v. Löwisad0a4622006-02-16 14:30:23 +00002777 Py_ssize_t tuplesize = lz->tuplesize;
Raymond Hettinger2012f172003-02-07 05:32:58 +00002778 PyObject *result = lz->result;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002779 PyObject *it;
2780 PyObject *item;
Raymond Hettinger4f01f892003-08-30 00:10:06 +00002781 PyObject *olditem;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002782
Raymond Hettingerb5a42082003-08-08 05:10:41 +00002783 if (tuplesize == 0)
2784 return NULL;
Christian Heimese93237d2007-12-19 02:37:44 +00002785 if (Py_REFCNT(result) == 1) {
Raymond Hettingera56f6b62003-08-29 23:09:58 +00002786 Py_INCREF(result);
Raymond Hettinger2012f172003-02-07 05:32:58 +00002787 for (i=0 ; i < tuplesize ; i++) {
Raymond Hettingerf0c00242003-02-07 07:26:25 +00002788 it = PyTuple_GET_ITEM(lz->ittuple, i);
Raymond Hettingerd1a283b2003-03-01 01:48:24 +00002789 assert(PyIter_Check(it));
Christian Heimese93237d2007-12-19 02:37:44 +00002790 item = (*Py_TYPE(it)->tp_iternext)(it);
Raymond Hettingera56f6b62003-08-29 23:09:58 +00002791 if (item == NULL) {
2792 Py_DECREF(result);
Raymond Hettingerf0c00242003-02-07 07:26:25 +00002793 return NULL;
Raymond Hettingera56f6b62003-08-29 23:09:58 +00002794 }
Raymond Hettinger4f01f892003-08-30 00:10:06 +00002795 olditem = PyTuple_GET_ITEM(result, i);
Raymond Hettingerf0c00242003-02-07 07:26:25 +00002796 PyTuple_SET_ITEM(result, i, item);
Raymond Hettinger4f01f892003-08-30 00:10:06 +00002797 Py_DECREF(olditem);
Raymond Hettinger2012f172003-02-07 05:32:58 +00002798 }
Raymond Hettinger2012f172003-02-07 05:32:58 +00002799 } else {
Raymond Hettinger2012f172003-02-07 05:32:58 +00002800 result = PyTuple_New(tuplesize);
2801 if (result == NULL)
2802 return NULL;
Raymond Hettingerf0c00242003-02-07 07:26:25 +00002803 for (i=0 ; i < tuplesize ; i++) {
2804 it = PyTuple_GET_ITEM(lz->ittuple, i);
Raymond Hettingerd1a283b2003-03-01 01:48:24 +00002805 assert(PyIter_Check(it));
Christian Heimese93237d2007-12-19 02:37:44 +00002806 item = (*Py_TYPE(it)->tp_iternext)(it);
Raymond Hettingerf0c00242003-02-07 07:26:25 +00002807 if (item == NULL) {
2808 Py_DECREF(result);
2809 return NULL;
2810 }
2811 PyTuple_SET_ITEM(result, i, item);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002812 }
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002813 }
2814 return result;
2815}
2816
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002817PyDoc_STRVAR(izip_doc,
2818"izip(iter1 [,iter2 [...]]) --> izip object\n\
2819\n\
2820Return a izip object whose .next() method returns a tuple where\n\
2821the i-th element comes from the i-th iterable argument. The .next()\n\
2822method continues until the shortest iterable in the argument sequence\n\
2823is exhausted and then it raises StopIteration. Works like the zip()\n\
2824function but consumes less memory by returning an iterator instead of\n\
2825a list.");
2826
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00002827static PyTypeObject izip_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +00002828 PyVarObject_HEAD_INIT(NULL, 0)
Raymond Hettinger60eca932003-02-09 06:40:58 +00002829 "itertools.izip", /* tp_name */
2830 sizeof(izipobject), /* tp_basicsize */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002831 0, /* tp_itemsize */
2832 /* methods */
Raymond Hettinger60eca932003-02-09 06:40:58 +00002833 (destructor)izip_dealloc, /* tp_dealloc */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002834 0, /* tp_print */
2835 0, /* tp_getattr */
2836 0, /* tp_setattr */
2837 0, /* tp_compare */
2838 0, /* tp_repr */
2839 0, /* tp_as_number */
2840 0, /* tp_as_sequence */
2841 0, /* tp_as_mapping */
2842 0, /* tp_hash */
2843 0, /* tp_call */
2844 0, /* tp_str */
2845 PyObject_GenericGetAttr, /* tp_getattro */
2846 0, /* tp_setattro */
2847 0, /* tp_as_buffer */
2848 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC |
2849 Py_TPFLAGS_BASETYPE, /* tp_flags */
Raymond Hettinger60eca932003-02-09 06:40:58 +00002850 izip_doc, /* tp_doc */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002851 (traverseproc)izip_traverse, /* tp_traverse */
2852 0, /* tp_clear */
2853 0, /* tp_richcompare */
2854 0, /* tp_weaklistoffset */
Raymond Hettinger1da1dbf2003-03-17 19:46:11 +00002855 PyObject_SelfIter, /* tp_iter */
Raymond Hettinger60eca932003-02-09 06:40:58 +00002856 (iternextfunc)izip_next, /* tp_iternext */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002857 0, /* tp_methods */
2858 0, /* tp_members */
2859 0, /* tp_getset */
2860 0, /* tp_base */
2861 0, /* tp_dict */
2862 0, /* tp_descr_get */
2863 0, /* tp_descr_set */
2864 0, /* tp_dictoffset */
2865 0, /* tp_init */
Raymond Hettingerbfef18c2003-05-23 03:55:42 +00002866 0, /* tp_alloc */
Raymond Hettinger60eca932003-02-09 06:40:58 +00002867 izip_new, /* tp_new */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002868 PyObject_GC_Del, /* tp_free */
2869};
2870
2871
2872/* repeat object ************************************************************/
2873
2874typedef struct {
2875 PyObject_HEAD
2876 PyObject *element;
Jack Diederich6c433a92006-05-26 11:15:17 +00002877 Py_ssize_t cnt;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002878} repeatobject;
2879
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00002880static PyTypeObject repeat_type;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002881
2882static PyObject *
2883repeat_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
2884{
2885 repeatobject *ro;
2886 PyObject *element;
Jack Diederich6c433a92006-05-26 11:15:17 +00002887 Py_ssize_t cnt = -1;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002888
Georg Brandlb84c1372007-01-21 10:28:43 +00002889 if (type == &repeat_type && !_PyArg_NoKeywords("repeat()", kwds))
Georg Brandl02c42872005-08-26 06:42:30 +00002890 return NULL;
2891
Jack Diederich6c433a92006-05-26 11:15:17 +00002892 if (!PyArg_ParseTuple(args, "O|n:repeat", &element, &cnt))
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002893 return NULL;
2894
Raymond Hettinger7c2bb5b2003-05-03 05:59:48 +00002895 if (PyTuple_Size(args) == 2 && cnt < 0)
2896 cnt = 0;
2897
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002898 ro = (repeatobject *)type->tp_alloc(type, 0);
2899 if (ro == NULL)
2900 return NULL;
2901 Py_INCREF(element);
2902 ro->element = element;
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00002903 ro->cnt = cnt;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002904 return (PyObject *)ro;
2905}
2906
2907static void
2908repeat_dealloc(repeatobject *ro)
2909{
2910 PyObject_GC_UnTrack(ro);
2911 Py_XDECREF(ro->element);
Christian Heimese93237d2007-12-19 02:37:44 +00002912 Py_TYPE(ro)->tp_free(ro);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002913}
2914
2915static int
2916repeat_traverse(repeatobject *ro, visitproc visit, void *arg)
2917{
Raymond Hettinger58ed69b2004-07-15 05:32:47 +00002918 Py_VISIT(ro->element);
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002919 return 0;
2920}
2921
2922static PyObject *
2923repeat_next(repeatobject *ro)
2924{
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00002925 if (ro->cnt == 0)
2926 return NULL;
2927 if (ro->cnt > 0)
2928 ro->cnt--;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002929 Py_INCREF(ro->element);
2930 return ro->element;
2931}
2932
Raymond Hettinger7dacda22004-04-08 21:54:00 +00002933static PyObject *
2934repeat_repr(repeatobject *ro)
2935{
2936 PyObject *result, *objrepr;
2937
2938 objrepr = PyObject_Repr(ro->element);
2939 if (objrepr == NULL)
2940 return NULL;
2941
2942 if (ro->cnt == -1)
2943 result = PyString_FromFormat("repeat(%s)",
2944 PyString_AS_STRING(objrepr));
2945 else
Jack Diederich6c433a92006-05-26 11:15:17 +00002946 result = PyString_FromFormat("repeat(%s, %zd)",
Raymond Hettinger7dacda22004-04-08 21:54:00 +00002947 PyString_AS_STRING(objrepr), ro->cnt);
2948 Py_DECREF(objrepr);
2949 return result;
2950}
2951
Raymond Hettinger6b27cda2005-09-24 21:23:05 +00002952static PyObject *
Raymond Hettinger5cab2e32004-02-10 09:25:40 +00002953repeat_len(repeatobject *ro)
2954{
Raymond Hettinger6b27cda2005-09-24 21:23:05 +00002955 if (ro->cnt == -1) {
Raymond Hettinger5cab2e32004-02-10 09:25:40 +00002956 PyErr_SetString(PyExc_TypeError, "len() of unsized object");
Raymond Hettinger6b27cda2005-09-24 21:23:05 +00002957 return NULL;
2958 }
Jack Diederich6c433a92006-05-26 11:15:17 +00002959 return PyInt_FromSize_t(ro->cnt);
Raymond Hettinger5cab2e32004-02-10 09:25:40 +00002960}
2961
Armin Rigof5b3e362006-02-11 21:32:43 +00002962PyDoc_STRVAR(length_hint_doc, "Private method returning an estimate of len(list(it)).");
Raymond Hettinger6b27cda2005-09-24 21:23:05 +00002963
2964static PyMethodDef repeat_methods[] = {
Armin Rigof5b3e362006-02-11 21:32:43 +00002965 {"__length_hint__", (PyCFunction)repeat_len, METH_NOARGS, length_hint_doc},
Raymond Hettinger6b27cda2005-09-24 21:23:05 +00002966 {NULL, NULL} /* sentinel */
Raymond Hettinger5cab2e32004-02-10 09:25:40 +00002967};
2968
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002969PyDoc_STRVAR(repeat_doc,
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00002970"repeat(element [,times]) -> create an iterator which returns the element\n\
2971for the specified number of times. If not specified, returns the element\n\
2972endlessly.");
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002973
Raymond Hettinger1d7a3482003-07-14 07:07:12 +00002974static PyTypeObject repeat_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +00002975 PyVarObject_HEAD_INIT(NULL, 0)
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002976 "itertools.repeat", /* tp_name */
2977 sizeof(repeatobject), /* tp_basicsize */
2978 0, /* tp_itemsize */
2979 /* methods */
Raymond Hettinger60eca932003-02-09 06:40:58 +00002980 (destructor)repeat_dealloc, /* tp_dealloc */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002981 0, /* tp_print */
2982 0, /* tp_getattr */
2983 0, /* tp_setattr */
2984 0, /* tp_compare */
Raymond Hettinger7dacda22004-04-08 21:54:00 +00002985 (reprfunc)repeat_repr, /* tp_repr */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002986 0, /* tp_as_number */
Raymond Hettinger6b27cda2005-09-24 21:23:05 +00002987 0, /* tp_as_sequence */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002988 0, /* tp_as_mapping */
2989 0, /* tp_hash */
2990 0, /* tp_call */
2991 0, /* tp_str */
2992 PyObject_GenericGetAttr, /* tp_getattro */
2993 0, /* tp_setattro */
2994 0, /* tp_as_buffer */
2995 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC |
2996 Py_TPFLAGS_BASETYPE, /* tp_flags */
Raymond Hettinger60eca932003-02-09 06:40:58 +00002997 repeat_doc, /* tp_doc */
2998 (traverseproc)repeat_traverse, /* tp_traverse */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00002999 0, /* tp_clear */
3000 0, /* tp_richcompare */
3001 0, /* tp_weaklistoffset */
Raymond Hettinger1da1dbf2003-03-17 19:46:11 +00003002 PyObject_SelfIter, /* tp_iter */
Raymond Hettinger60eca932003-02-09 06:40:58 +00003003 (iternextfunc)repeat_next, /* tp_iternext */
Raymond Hettinger6b27cda2005-09-24 21:23:05 +00003004 repeat_methods, /* tp_methods */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00003005 0, /* tp_members */
3006 0, /* tp_getset */
3007 0, /* tp_base */
3008 0, /* tp_dict */
3009 0, /* tp_descr_get */
3010 0, /* tp_descr_set */
3011 0, /* tp_dictoffset */
3012 0, /* tp_init */
Raymond Hettingerbfef18c2003-05-23 03:55:42 +00003013 0, /* tp_alloc */
Raymond Hettinger96ef8112003-02-01 00:10:11 +00003014 repeat_new, /* tp_new */
3015 PyObject_GC_Del, /* tp_free */
3016};
3017
Raymond Hettingerd36862c2007-02-21 05:20:38 +00003018/* iziplongest object ************************************************************/
3019
3020#include "Python.h"
3021
3022typedef struct {
3023 PyObject_HEAD
3024 Py_ssize_t tuplesize;
3025 Py_ssize_t numactive;
3026 PyObject *ittuple; /* tuple of iterators */
3027 PyObject *result;
3028 PyObject *fillvalue;
Raymond Hettingerd36862c2007-02-21 05:20:38 +00003029} iziplongestobject;
3030
3031static PyTypeObject iziplongest_type;
3032
3033static PyObject *
3034izip_longest_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
3035{
3036 iziplongestobject *lz;
3037 Py_ssize_t i;
3038 PyObject *ittuple; /* tuple of iterators */
3039 PyObject *result;
3040 PyObject *fillvalue = Py_None;
Raymond Hettingerd36862c2007-02-21 05:20:38 +00003041 Py_ssize_t tuplesize = PySequence_Length(args);
3042
3043 if (kwds != NULL && PyDict_CheckExact(kwds) && PyDict_Size(kwds) > 0) {
3044 fillvalue = PyDict_GetItemString(kwds, "fillvalue");
3045 if (fillvalue == NULL || PyDict_Size(kwds) > 1) {
3046 PyErr_SetString(PyExc_TypeError,
3047 "izip_longest() got an unexpected keyword argument");
3048 return NULL;
3049 }
3050 }
3051
3052 /* args must be a tuple */
3053 assert(PyTuple_Check(args));
3054
3055 /* obtain iterators */
3056 ittuple = PyTuple_New(tuplesize);
3057 if (ittuple == NULL)
3058 return NULL;
3059 for (i=0; i < tuplesize; ++i) {
3060 PyObject *item = PyTuple_GET_ITEM(args, i);
3061 PyObject *it = PyObject_GetIter(item);
3062 if (it == NULL) {
3063 if (PyErr_ExceptionMatches(PyExc_TypeError))
3064 PyErr_Format(PyExc_TypeError,
3065 "izip_longest argument #%zd must support iteration",
3066 i+1);
3067 Py_DECREF(ittuple);
3068 return NULL;
3069 }
3070 PyTuple_SET_ITEM(ittuple, i, it);
3071 }
3072
Raymond Hettingerd36862c2007-02-21 05:20:38 +00003073 /* create a result holder */
3074 result = PyTuple_New(tuplesize);
3075 if (result == NULL) {
3076 Py_DECREF(ittuple);
Raymond Hettingerd36862c2007-02-21 05:20:38 +00003077 return NULL;
3078 }
3079 for (i=0 ; i < tuplesize ; i++) {
3080 Py_INCREF(Py_None);
3081 PyTuple_SET_ITEM(result, i, Py_None);
3082 }
3083
3084 /* create iziplongestobject structure */
3085 lz = (iziplongestobject *)type->tp_alloc(type, 0);
3086 if (lz == NULL) {
3087 Py_DECREF(ittuple);
Raymond Hettingerd36862c2007-02-21 05:20:38 +00003088 Py_DECREF(result);
3089 return NULL;
3090 }
3091 lz->ittuple = ittuple;
3092 lz->tuplesize = tuplesize;
3093 lz->numactive = tuplesize;
3094 lz->result = result;
3095 Py_INCREF(fillvalue);
3096 lz->fillvalue = fillvalue;
Raymond Hettingerd36862c2007-02-21 05:20:38 +00003097 return (PyObject *)lz;
3098}
3099
3100static void
3101izip_longest_dealloc(iziplongestobject *lz)
3102{
3103 PyObject_GC_UnTrack(lz);
3104 Py_XDECREF(lz->ittuple);
3105 Py_XDECREF(lz->result);
3106 Py_XDECREF(lz->fillvalue);
Christian Heimese93237d2007-12-19 02:37:44 +00003107 Py_TYPE(lz)->tp_free(lz);
Raymond Hettingerd36862c2007-02-21 05:20:38 +00003108}
3109
3110static int
3111izip_longest_traverse(iziplongestobject *lz, visitproc visit, void *arg)
3112{
3113 Py_VISIT(lz->ittuple);
3114 Py_VISIT(lz->result);
3115 Py_VISIT(lz->fillvalue);
Raymond Hettingerd36862c2007-02-21 05:20:38 +00003116 return 0;
3117}
3118
3119static PyObject *
3120izip_longest_next(iziplongestobject *lz)
3121{
3122 Py_ssize_t i;
3123 Py_ssize_t tuplesize = lz->tuplesize;
3124 PyObject *result = lz->result;
3125 PyObject *it;
3126 PyObject *item;
3127 PyObject *olditem;
3128
3129 if (tuplesize == 0)
3130 return NULL;
Raymond Hettinger1b6ca542007-02-21 17:22:05 +00003131 if (lz->numactive == 0)
3132 return NULL;
Christian Heimese93237d2007-12-19 02:37:44 +00003133 if (Py_REFCNT(result) == 1) {
Raymond Hettingerd36862c2007-02-21 05:20:38 +00003134 Py_INCREF(result);
3135 for (i=0 ; i < tuplesize ; i++) {
3136 it = PyTuple_GET_ITEM(lz->ittuple, i);
Raymond Hettinger1b6ca542007-02-21 17:22:05 +00003137 if (it == NULL) {
3138 Py_INCREF(lz->fillvalue);
3139 item = lz->fillvalue;
3140 } else {
3141 assert(PyIter_Check(it));
Christian Heimese93237d2007-12-19 02:37:44 +00003142 item = (*Py_TYPE(it)->tp_iternext)(it);
Raymond Hettinger1b6ca542007-02-21 17:22:05 +00003143 if (item == NULL) {
3144 lz->numactive -= 1;
3145 if (lz->numactive == 0) {
3146 Py_DECREF(result);
3147 return NULL;
3148 } else {
3149 Py_INCREF(lz->fillvalue);
3150 item = lz->fillvalue;
3151 PyTuple_SET_ITEM(lz->ittuple, i, NULL);
3152 Py_DECREF(it);
3153 }
3154 }
3155 }
Raymond Hettingerd36862c2007-02-21 05:20:38 +00003156 olditem = PyTuple_GET_ITEM(result, i);
3157 PyTuple_SET_ITEM(result, i, item);
3158 Py_DECREF(olditem);
3159 }
3160 } else {
3161 result = PyTuple_New(tuplesize);
3162 if (result == NULL)
3163 return NULL;
3164 for (i=0 ; i < tuplesize ; i++) {
3165 it = PyTuple_GET_ITEM(lz->ittuple, i);
Raymond Hettinger1b6ca542007-02-21 17:22:05 +00003166 if (it == NULL) {
3167 Py_INCREF(lz->fillvalue);
3168 item = lz->fillvalue;
3169 } else {
3170 assert(PyIter_Check(it));
Christian Heimese93237d2007-12-19 02:37:44 +00003171 item = (*Py_TYPE(it)->tp_iternext)(it);
Raymond Hettinger1b6ca542007-02-21 17:22:05 +00003172 if (item == NULL) {
3173 lz->numactive -= 1;
3174 if (lz->numactive == 0) {
3175 Py_DECREF(result);
3176 return NULL;
3177 } else {
3178 Py_INCREF(lz->fillvalue);
3179 item = lz->fillvalue;
3180 PyTuple_SET_ITEM(lz->ittuple, i, NULL);
3181 Py_DECREF(it);
3182 }
3183 }
3184 }
Raymond Hettingerd36862c2007-02-21 05:20:38 +00003185 PyTuple_SET_ITEM(result, i, item);
3186 }
3187 }
3188 return result;
3189}
3190
3191PyDoc_STRVAR(izip_longest_doc,
3192"izip_longest(iter1 [,iter2 [...]], [fillvalue=None]) --> izip_longest object\n\
3193\n\
3194Return an izip_longest object whose .next() method returns a tuple where\n\
3195the i-th element comes from the i-th iterable argument. The .next()\n\
3196method continues until the longest iterable in the argument sequence\n\
3197is exhausted and then it raises StopIteration. When the shorter iterables\n\
3198are exhausted, the fillvalue is substituted in their place. The fillvalue\n\
3199defaults to None or can be specified by a keyword argument.\n\
3200");
3201
3202static PyTypeObject iziplongest_type = {
Martin v. Löwis68192102007-07-21 06:55:02 +00003203 PyVarObject_HEAD_INIT(NULL, 0)
Raymond Hettingerd36862c2007-02-21 05:20:38 +00003204 "itertools.izip_longest", /* tp_name */
3205 sizeof(iziplongestobject), /* tp_basicsize */
3206 0, /* tp_itemsize */
3207 /* methods */
3208 (destructor)izip_longest_dealloc, /* tp_dealloc */
3209 0, /* tp_print */
3210 0, /* tp_getattr */
3211 0, /* tp_setattr */
3212 0, /* tp_compare */
3213 0, /* tp_repr */
3214 0, /* tp_as_number */
3215 0, /* tp_as_sequence */
3216 0, /* tp_as_mapping */
3217 0, /* tp_hash */
3218 0, /* tp_call */
3219 0, /* tp_str */
3220 PyObject_GenericGetAttr, /* tp_getattro */
3221 0, /* tp_setattro */
3222 0, /* tp_as_buffer */
3223 Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC |
3224 Py_TPFLAGS_BASETYPE, /* tp_flags */
3225 izip_longest_doc, /* tp_doc */
3226 (traverseproc)izip_longest_traverse, /* tp_traverse */
3227 0, /* tp_clear */
3228 0, /* tp_richcompare */
3229 0, /* tp_weaklistoffset */
3230 PyObject_SelfIter, /* tp_iter */
3231 (iternextfunc)izip_longest_next, /* tp_iternext */
3232 0, /* tp_methods */
3233 0, /* tp_members */
3234 0, /* tp_getset */
3235 0, /* tp_base */
3236 0, /* tp_dict */
3237 0, /* tp_descr_get */
3238 0, /* tp_descr_set */
3239 0, /* tp_dictoffset */
3240 0, /* tp_init */
3241 0, /* tp_alloc */
3242 izip_longest_new, /* tp_new */
3243 PyObject_GC_Del, /* tp_free */
3244};
Raymond Hettinger96ef8112003-02-01 00:10:11 +00003245
3246/* module level code ********************************************************/
3247
3248PyDoc_STRVAR(module_doc,
3249"Functional tools for creating and using iterators.\n\
3250\n\
3251Infinite iterators:\n\
3252count([n]) --> n, n+1, n+2, ...\n\
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00003253cycle(p) --> p0, p1, ... plast, p0, p1, ...\n\
Andrew M. Kuchlingdff694b2003-04-14 15:31:27 +00003254repeat(elem [,n]) --> elem, elem, elem, ... endlessly or up to n times\n\
Raymond Hettinger96ef8112003-02-01 00:10:11 +00003255\n\
3256Iterators terminating on the shortest input sequence:\n\
3257izip(p, q, ...) --> (p[0], q[0]), (p[1], q[1]), ... \n\
Raymond Hettingerd36862c2007-02-21 05:20:38 +00003258izip_longest(p, q, ...) --> (p[0], q[0]), (p[1], q[1]), ... \n\
Raymond Hettinger60eca932003-02-09 06:40:58 +00003259ifilter(pred, seq) --> elements of seq where pred(elem) is True\n\
3260ifilterfalse(pred, seq) --> elements of seq where pred(elem) is False\n\
Raymond Hettinger96ef8112003-02-01 00:10:11 +00003261islice(seq, [start,] stop [, step]) --> elements from\n\
3262 seq[start:stop:step]\n\
3263imap(fun, p, q, ...) --> fun(p0, q0), fun(p1, q1), ...\n\
3264starmap(fun, seq) --> fun(*seq[0]), fun(*seq[1]), ...\n\
Raymond Hettingerad983e72003-11-12 14:32:26 +00003265tee(it, n=2) --> (it1, it2 , ... itn) splits one iterator into n\n\
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00003266chain(p, q, ...) --> p0, p1, ... plast, q0, q1, ... \n\
Raymond Hettinger96ef8112003-02-01 00:10:11 +00003267takewhile(pred, seq) --> seq[0], seq[1], until pred fails\n\
3268dropwhile(pred, seq) --> seq[n], seq[n+1], starting when pred fails\n\
Raymond Hettingerd25c1c62003-12-06 16:23:06 +00003269groupby(iterable[, keyfunc]) --> sub-iterators grouped by value of keyfunc(v)\n\
Raymond Hettinger96ef8112003-02-01 00:10:11 +00003270");
3271
3272
Raymond Hettingerad983e72003-11-12 14:32:26 +00003273static PyMethodDef module_methods[] = {
3274 {"tee", (PyCFunction)tee, METH_VARARGS, tee_doc},
3275 {NULL, NULL} /* sentinel */
3276};
3277
Raymond Hettinger96ef8112003-02-01 00:10:11 +00003278PyMODINIT_FUNC
3279inititertools(void)
3280{
Raymond Hettinger60eca932003-02-09 06:40:58 +00003281 int i;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00003282 PyObject *m;
Raymond Hettinger60eca932003-02-09 06:40:58 +00003283 char *name;
3284 PyTypeObject *typelist[] = {
Raymond Hettinger93e804d2008-02-26 23:40:50 +00003285 &combinations_type,
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00003286 &cycle_type,
Raymond Hettinger60eca932003-02-09 06:40:58 +00003287 &dropwhile_type,
3288 &takewhile_type,
3289 &islice_type,
3290 &starmap_type,
3291 &imap_type,
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00003292 &chain_type,
Raymond Hettinger60eca932003-02-09 06:40:58 +00003293 &ifilter_type,
3294 &ifilterfalse_type,
3295 &count_type,
3296 &izip_type,
Raymond Hettinger50986cc2008-02-22 03:16:42 +00003297 &iziplongest_type,
Raymond Hettinger93e804d2008-02-26 23:40:50 +00003298 &product_type,
Raymond Hettinger60eca932003-02-09 06:40:58 +00003299 &repeat_type,
Raymond Hettingerd25c1c62003-12-06 16:23:06 +00003300 &groupby_type,
Raymond Hettinger60eca932003-02-09 06:40:58 +00003301 NULL
3302 };
3303
Christian Heimese93237d2007-12-19 02:37:44 +00003304 Py_TYPE(&teedataobject_type) = &PyType_Type;
Raymond Hettingerad983e72003-11-12 14:32:26 +00003305 m = Py_InitModule3("itertools", module_methods, module_doc);
Neal Norwitz1ac754f2006-01-19 06:09:39 +00003306 if (m == NULL)
3307 return;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00003308
Raymond Hettinger60eca932003-02-09 06:40:58 +00003309 for (i=0 ; typelist[i] != NULL ; i++) {
3310 if (PyType_Ready(typelist[i]) < 0)
3311 return;
Raymond Hettingerd449eab2003-05-22 16:32:58 +00003312 name = strchr(typelist[i]->tp_name, '.');
Raymond Hettinger61fe64d2003-02-23 04:40:07 +00003313 assert (name != NULL);
Raymond Hettinger60eca932003-02-09 06:40:58 +00003314 Py_INCREF(typelist[i]);
Raymond Hettingerd449eab2003-05-22 16:32:58 +00003315 PyModule_AddObject(m, name+1, (PyObject *)typelist[i]);
Raymond Hettinger60eca932003-02-09 06:40:58 +00003316 }
Raymond Hettingerad983e72003-11-12 14:32:26 +00003317
3318 if (PyType_Ready(&teedataobject_type) < 0)
3319 return;
3320 if (PyType_Ready(&tee_type) < 0)
3321 return;
Raymond Hettingerd25c1c62003-12-06 16:23:06 +00003322 if (PyType_Ready(&_grouper_type) < 0)
3323 return;
Raymond Hettinger96ef8112003-02-01 00:10:11 +00003324}