da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin/***********************************************************************
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* This software is part of the ast package *
3e14f97f673e8a630f076077de35afdd43dc1587Roger A. Faulkner* Copyright (c) 1985-2010 AT&T Intellectual Property *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* and is licensed under the *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* Common Public License, Version 1.0 *
7c2fbfb345896881c631598ee3852ce9ce33fb07April Chin* by AT&T Intellectual Property *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* A copy of the License is available at *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* http://www.opensource.org/licenses/cpl1.0.txt *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* (with md5 checksum 059e8cd6165cb4c31e351f2b69388fd9) *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* Information and Software Systems Research *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* AT&T Research *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* Florham Park NJ *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* Glenn Fowler <gsf@research.att.com> *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* David Korn <dgk@research.att.com> *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* Phong Vo <kpv@research.att.com> *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin* *
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin***********************************************************************/
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin#include "sfhdr.h"
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin/* Function to handle io exceptions.
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin** Written by Kiem-Phong Vo
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin*/
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin#if __STD_C
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chinint _sfexcept(Sfio_t* f, int type, ssize_t io, Sfdisc_t* disc)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin#else
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chinint _sfexcept(f,type,io,disc)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chinSfio_t* f; /* stream where the exception happened */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chinint type; /* io type that was performed */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chinssize_t io; /* the io return value that indicated exception */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chinSfdisc_t* disc; /* discipline in use */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin#endif
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin{
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin reg int ev, local, lock;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin reg ssize_t size;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin reg uchar* data;
7c2fbfb345896881c631598ee3852ce9ce33fb07April Chin SFMTXDECL(f);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
7c2fbfb345896881c631598ee3852ce9ce33fb07April Chin SFMTXENTER(f,-1);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin GETLOCAL(f,local);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin lock = f->mode&SF_LOCK;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(local && io <= 0)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin f->flags |= io < 0 ? SF_ERROR : SF_EOF;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(disc && disc->exceptf)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin { /* let the stream be generally accessible for this duration */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(local && lock)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFOPEN(f,0);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin /* so that exception handler knows what we are asking for */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin _Sfi = f->val = io;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin ev = (*(disc->exceptf))(f,type,&io,disc);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin /* relock if necessary */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(local && lock)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFLOCK(f,0);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(io > 0 && !(f->flags&SF_STRING) )
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFMTXRETURN(f, ev);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(ev < 0)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFMTXRETURN(f, SF_EDONE);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(ev > 0)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFMTXRETURN(f, SF_EDISC);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin }
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(f->flags&SF_STRING)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin { if(type == SF_READ)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin goto chk_stack;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin else if(type != SF_WRITE && type != SF_SEEK)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFMTXRETURN(f, SF_EDONE);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(local && io >= 0)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin { if(f->size >= 0 && !(f->flags&SF_MALLOC))
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin goto chk_stack;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin /* extend buffer */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if((size = f->size) < 0)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin size = 0;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if((io -= size) <= 0)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin io = SF_GRAIN;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin size = ((size+io+SF_GRAIN-1)/SF_GRAIN)*SF_GRAIN;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(f->size > 0)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin data = (uchar*)realloc((char*)f->data,size);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin else data = (uchar*)malloc(size);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(!data)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin goto chk_stack;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin f->endb = data + size;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin f->next = data + (f->next - f->data);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin f->endr = f->endw = f->data = data;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin f->size = size;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin }
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFMTXRETURN(f, SF_EDISC);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin }
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(errno == EINTR)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin { if(_Sfexiting || (f->bits&SF_ENDING) || /* stop being a hero */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin (f->flags&SF_IOINTR) ) /* application requests to return */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFMTXRETURN(f, SF_EDONE);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin /* a normal interrupt, we can continue */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin errno = 0;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin f->flags &= ~(SF_EOF|SF_ERROR);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFMTXRETURN(f, SF_ECONT);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin }
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chinchk_stack:
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(local && f->push &&
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin ((type == SF_READ && f->next >= f->endb) ||
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin (type == SF_WRITE && f->next <= f->data)))
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin { /* pop the stack */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin reg Sfio_t *pf;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(lock)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFOPEN(f,0);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin /* pop and close */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin pf = (*_Sfstack)(f,NIL(Sfio_t*));
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if((ev = sfclose(pf)) < 0) /* can't close, restack */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin (*_Sfstack)(f,pf);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(lock)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFLOCK(f,0);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin ev = ev < 0 ? SF_EDONE : SF_ESTACK;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin }
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin else ev = SF_EDONE;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFMTXRETURN(f, ev);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin}