* Update fwrite().
CORE-8080

svn path=/trunk/; revision=63257
This commit is contained in:
Amine Khaldi 2014-05-12 15:32:43 +00:00
parent c36bab312a
commit e68148f878

View file

@ -2506,33 +2506,36 @@ size_t CDECL fwrite(const void *ptr, size_t size, size_t nmemb, FILE* file)
return 0; return 0;
_lock_file(file); _lock_file(file);
if(file->_cnt) {
int pcnt=((unsigned)file->_cnt>wrcnt)? wrcnt: file->_cnt; while(wrcnt) {
memcpy(file->_ptr, ptr, pcnt); if(file->_cnt) {
file->_cnt -= pcnt; int pcnt=((unsigned)file->_cnt>wrcnt)? wrcnt: file->_cnt;
file->_ptr += pcnt; memcpy(file->_ptr, ptr, pcnt);
written = pcnt; file->_cnt -= pcnt;
wrcnt -= pcnt; file->_ptr += pcnt;
ptr = (const char*)ptr + pcnt; written += pcnt;
} else if(!(file->_flag & _IOWRT)) { wrcnt -= pcnt;
if(file->_flag & _IORW) { ptr = (const char*)ptr + pcnt;
file->_flag |= _IOWRT; } else if(!file->_bufsiz && (file->_flag & _IONBF)) {
} else { if(!(file->_flag & _IOWRT)) {
_unlock_file(file); if(file->_flag & _IORW)
return 0; file->_flag |= _IOWRT;
} else
} break;
if(wrcnt) {
/* Flush buffer */
int res=flush_buffer(file);
if(!res) {
int pwritten = _write(file->_file, ptr, wrcnt);
if (pwritten <= 0)
{
file->_flag |= _IOERR;
pwritten=0;
} }
written += pwritten;
if(_write(file->_file, ptr, wrcnt) <= 0) {
file->_flag |= _IOERR;
break;
}
written += wrcnt;
wrcnt = 0;
} else {
if(_flsbuf(*(const char*)ptr, file) == EOF)
break;
written++;
wrcnt--;
ptr = (const char*)ptr + 1;
} }
} }