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/* Invoke event handlers for a stream
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin**
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin** Written by Kiem-Phong Vo.
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin*/
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin#if __STD_C
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chinstatic int _sfraiseall(int type, Void_t* data)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin#else
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chinstatic int _sfraiseall(type, data)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chinint type; /* type of event */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chinVoid_t* data; /* associated data */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin#endif
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin{
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin Sfio_t *f;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin Sfpool_t *p, *next;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin int n, rv;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin rv = 0;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin for(p = &_Sfpool; p; p = next)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin {
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin for(next = p->next; next; next = next->next)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(next->n_sf > 0)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin break;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin for(n = 0; n < p->n_sf; ++n)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin { f = p->sf[n];
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(sfraise(f, type, data) < 0)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin rv -= 1;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin }
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin }
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin return rv;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin}
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin#if __STD_C
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chinint sfraise(Sfio_t* f, int type, Void_t* data)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin#else
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chinint sfraise(f, type, data)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chinSfio_t* f; /* stream */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chinint type; /* type of event */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chinVoid_t* data; /* associated data */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin#endif
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin{
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin reg Sfdisc_t *disc, *next, *d;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin reg int local, rv;
7c2fbfb345896881c631598ee3852ce9ce33fb07April Chin SFMTXDECL(f);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(!f)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin return _sfraiseall(type,data);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
7c2fbfb345896881c631598ee3852ce9ce33fb07April Chin SFMTXENTER(f, -1);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin GETLOCAL(f,local);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(!SFKILLED(f) &&
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin !(local &&
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin (type == SF_NEW || type == SF_CLOSING ||
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin type == SF_FINAL || type == SF_ATEXIT)) &&
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFMODE(f,local) != (f->mode&SF_RDWR) && _sfmode(f,0,local) < 0)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFMTXRETURN(f, -1);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFLOCK(f,local);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin for(disc = f->disc; disc; )
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin { next = disc->disc;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(type == SF_FINAL)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin f->disc = next;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(disc->exceptf)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin { SFOPEN(f,0);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if((rv = (*disc->exceptf)(f,type,data,disc)) != 0 )
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFMTXRETURN(f, rv);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFLOCK(f,0);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin }
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if((disc = next) )
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin { /* make sure that "next" hasn't been popped */
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin for(d = f->disc; d; d = d->disc)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(d == disc)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin break;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin if(!d)
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin disc = f->disc;
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin }
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin }
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFOPEN(f,local);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin SFMTXRETURN(f, 0);
da2e3ebdc1edfbc5028edf1354e7dd2fa69a7968chin}