(((long)bzs->total_out_hi32 << 32) + bzs->total_out_lo32)
#elif SIZEOF_LONG_LONG >= 8
#define BZS_TOTAL_OUT(bzs) \
- (((long long)bzs->total_out_hi32 << 32) + bzs->total_out_lo32)
+ (((LONG_LONG)bzs->total_out_hi32 << 32) + bzs->total_out_lo32)
#else
#define BZS_TOTAL_OUT(bzs) \
bzs->total_out_lo32;
"correctly");
ret = 1;
break;
-
+
case BZ_PARAM_ERROR:
PyErr_SetString(PyExc_ValueError,
"the bz2 library has received wrong "
"parameters");
ret = 1;
break;
-
+
case BZ_MEM_ERROR:
PyErr_NoMemory();
ret = 1;
if (skipnextlf) {
skipnextlf = 0;
if (c == '\n') {
- /* Seeing a \n here with
- * skipnextlf true means we
+ /* Seeing a \n here with
+ * skipnextlf true means we
* saw a \r before.
*/
newlinetypes |= NEWLINE_CRLF;
PyFileObject *f = (PyFileObject*)self;
if (f->f_buf != NULL) {
- if((f->f_bufend - f->f_bufptr) >= 1)
+ if((f->f_bufend - f->f_bufptr) >= 1)
return 0;
else
Util_DropReadAhead(self);
int len;
if (f->f_buf == NULL)
- if (Util_ReadAhead(bf, bufsize) < 0)
+ if (Util_ReadAhead(bf, bufsize) < 0)
return NULL;
len = f->f_bufend - f->f_bufptr;
- if (len == 0)
+ if (len == 0)
return (PyStringObject *)
PyString_FromStringAndSize(NULL, skip);
bufptr = memchr(f->f_bufptr, '\n', len);
len = bufptr - f->f_bufptr;
s = (PyStringObject *)
PyString_FromStringAndSize(NULL, skip+len);
- if (s == NULL)
+ if (s == NULL)
return NULL;
memcpy(PyString_AS_STRING(s)+skip, f->f_bufptr, len);
f->f_bufptr = bufptr;
size_t bytesread, buffersize, chunksize;
int bzerror;
PyObject *ret = NULL;
-
+
if (!PyArg_ParseTuple(args, "|l:read", &bytesrequested))
return NULL;
-
+
ACQUIRE_LOCK(self);
switch (self->mode) {
case MODE_READ:
if (!PyArg_ParseTuple(args, "s#", &buf, &len))
return NULL;
-
+
ACQUIRE_LOCK(self);
switch (self->mode) {
case MODE_WRITE:
break;
-
+
case MODE_CLOSED:
PyErr_SetString(PyExc_ValueError,
"I/O operation on closed file");
goto cleanup;;
-
+
default:
PyErr_SetString(PyExc_IOError,
"file is not ready for writing");
BZ2_bzWrite (&bzerror, self->fp, buf, len);
self->pos += len;
Py_END_ALLOW_THREADS
-
+
if (bzerror != BZ_OK) {
Util_CatchBZ2Error(bzerror);
goto cleanup;
}
-
+
Py_INCREF(Py_None);
ret = Py_None;
int rewind = 0;
PyObject *func;
PyObject *ret = NULL;
-
+
if (!PyArg_ParseTuple(args, "l|i:seek", &offset, &where))
return NULL;
case MODE_READ:
case MODE_READ_EOF:
break;
-
+
case MODE_CLOSED:
PyErr_SetString(PyExc_ValueError,
"I/O operation on closed file");
goto cleanup;;
-
+
default:
PyErr_SetString(PyExc_IOError,
"seek works only while reading");
int univ_newline = 0;
self->size = -1;
-
+
if (!PyArg_ParseTupleAndKeywords(args, kwargs, "et|sii:BZ2File",
kwlist, Py_FileSystemDefaultEncoding,
&name, &mode, &buffering,
mode = univ_newline ? "rbU" : "rb";
else
mode = univ_newline ? "wbU" : "wb";
-
+
file_args = Py_BuildValue("(ssi)", name, mode, buffering);
if (!file_args)
return -1;
Py_DECREF(ret);
return NULL;
}
-
+
for (;;) {
Py_BEGIN_ALLOW_THREADS
bzerror = BZ2_bzCompress(bzs, BZ_FINISH);
Py_DECREF(ret);
return NULL;
}
-
+
for (;;) {
Py_BEGIN_ALLOW_THREADS
bzerror = BZ2_bzDecompress(bzs);