1da2e3ebdSchin /***********************************************************************
2da2e3ebdSchin * *
3da2e3ebdSchin * This software is part of the ast package *
4*b30d1939SAndy Fiddaman * Copyright (c) 1985-2011 AT&T Intellectual Property *
5da2e3ebdSchin * and is licensed under the *
6*b30d1939SAndy Fiddaman * Eclipse Public License, Version 1.0 *
77c2fbfb3SApril Chin * by AT&T Intellectual Property *
8da2e3ebdSchin * *
9da2e3ebdSchin * A copy of the License is available at *
10*b30d1939SAndy Fiddaman * http://www.eclipse.org/org/documents/epl-v10.html *
11*b30d1939SAndy Fiddaman * (with md5 checksum b35adb5213ca9657e911e9befb180842) *
12da2e3ebdSchin * *
13da2e3ebdSchin * Information and Software Systems Research *
14da2e3ebdSchin * AT&T Research *
15da2e3ebdSchin * Florham Park NJ *
16da2e3ebdSchin * *
17da2e3ebdSchin * Glenn Fowler <gsf@research.att.com> *
18da2e3ebdSchin * David Korn <dgk@research.att.com> *
19da2e3ebdSchin * Phong Vo <kpv@research.att.com> *
20da2e3ebdSchin * *
21da2e3ebdSchin ***********************************************************************/
22da2e3ebdSchin #include "sfhdr.h"
23da2e3ebdSchin
24da2e3ebdSchin /* Put out a null-terminated string
25da2e3ebdSchin **
26da2e3ebdSchin ** Written by Kiem-Phong Vo.
27da2e3ebdSchin */
28da2e3ebdSchin #if __STD_C
sfputr(Sfio_t * f,const char * s,int rc)297c2fbfb3SApril Chin ssize_t sfputr(Sfio_t* f, const char* s, int rc)
30da2e3ebdSchin #else
31da2e3ebdSchin ssize_t sfputr(f,s,rc)
327c2fbfb3SApril Chin Sfio_t* f; /* write to this stream */
33da2e3ebdSchin char* s; /* string to write */
347c2fbfb3SApril Chin int rc; /* record separator. */
35da2e3ebdSchin #endif
36da2e3ebdSchin {
37*b30d1939SAndy Fiddaman ssize_t p, n, w, sn;
38*b30d1939SAndy Fiddaman uchar *ps;
39*b30d1939SAndy Fiddaman char *ss;
407c2fbfb3SApril Chin SFMTXDECL(f);
41da2e3ebdSchin
427c2fbfb3SApril Chin SFMTXENTER(f,-1);
43da2e3ebdSchin
44da2e3ebdSchin if(f->mode != SF_WRITE && _sfmode(f,SF_WRITE,0) < 0)
45da2e3ebdSchin SFMTXRETURN(f, -1);
46da2e3ebdSchin
47da2e3ebdSchin SFLOCK(f,0);
48da2e3ebdSchin
49*b30d1939SAndy Fiddaman f->val = sn = -1; ss = (char*)s;
50da2e3ebdSchin for(w = 0; (*s || rc >= 0); )
51*b30d1939SAndy Fiddaman { /* need to communicate string size to exception handler */
52*b30d1939SAndy Fiddaman if((f->flags&SF_STRING) && f->next >= f->endb )
53*b30d1939SAndy Fiddaman { sn = sn < 0 ? strlen(s) : (sn - (s-ss));
54*b30d1939SAndy Fiddaman ss = (char*)s; /* save current checkpoint */
55*b30d1939SAndy Fiddaman f->val = sn + (rc >= 0 ? 1 : 0); /* space requirement */
56*b30d1939SAndy Fiddaman f->bits |= SF_PUTR; /* tell sfflsbuf to use f->val */
57*b30d1939SAndy Fiddaman }
58*b30d1939SAndy Fiddaman
59*b30d1939SAndy Fiddaman SFWPEEK(f,ps,p);
60*b30d1939SAndy Fiddaman f->bits &= ~SF_PUTR; /* remove any trace of this */
61*b30d1939SAndy Fiddaman
62*b30d1939SAndy Fiddaman if(p < 0 ) /* something not right about buffering */
6334f9b3eeSRoland Mainz break;
64da2e3ebdSchin
65da2e3ebdSchin if(p == 0 || (f->flags&SF_WHOLE) )
66*b30d1939SAndy Fiddaman { n = sn < 0 ? strlen(s) : sn - (s-ss);
67da2e3ebdSchin if(p >= (n + (rc < 0 ? 0 : 1)) )
68da2e3ebdSchin { /* buffer can hold everything */
69da2e3ebdSchin if(n > 0)
70da2e3ebdSchin { memcpy(ps, s, n);
71da2e3ebdSchin ps += n;
72da2e3ebdSchin w += n;
73da2e3ebdSchin }
74da2e3ebdSchin if(rc >= 0)
75da2e3ebdSchin { *ps++ = rc;
76da2e3ebdSchin w += 1;
77da2e3ebdSchin }
78da2e3ebdSchin f->next = ps;
79da2e3ebdSchin }
80da2e3ebdSchin else
81da2e3ebdSchin { /* create a reserve buffer to hold data */
82da2e3ebdSchin Sfrsrv_t* rsrv;
83da2e3ebdSchin
84da2e3ebdSchin p = n + (rc >= 0 ? 1 : 0);
85da2e3ebdSchin if(!(rsrv = _sfrsrv(f, p)) )
86da2e3ebdSchin n = 0;
87da2e3ebdSchin else
88da2e3ebdSchin { if(n > 0)
89da2e3ebdSchin memcpy(rsrv->data, s, n);
90da2e3ebdSchin if(rc >= 0)
91da2e3ebdSchin rsrv->data[n] = rc;
92da2e3ebdSchin if((n = SFWRITE(f,rsrv->data,p)) < 0 )
93da2e3ebdSchin n = 0;
94da2e3ebdSchin }
95da2e3ebdSchin
96da2e3ebdSchin w += n;
97da2e3ebdSchin }
98da2e3ebdSchin break;
99da2e3ebdSchin }
100da2e3ebdSchin
101da2e3ebdSchin if(*s == 0)
102da2e3ebdSchin { *ps++ = rc;
103da2e3ebdSchin f->next = ps;
104da2e3ebdSchin w += 1;
105da2e3ebdSchin break;
106da2e3ebdSchin }
107da2e3ebdSchin
108da2e3ebdSchin #if _lib_memccpy && !__ia64 /* these guys may never get it right */
109da2e3ebdSchin if((ps = (uchar*)memccpy(ps,s,'\0',p)) != NIL(uchar*))
110da2e3ebdSchin ps -= 1;
111da2e3ebdSchin else ps = f->next+p;
112da2e3ebdSchin s += ps - f->next;
113da2e3ebdSchin #else
114da2e3ebdSchin for(; p > 0; --p, ++ps, ++s)
115da2e3ebdSchin if((*ps = *s) == 0)
116da2e3ebdSchin break;
117da2e3ebdSchin #endif
118da2e3ebdSchin w += ps - f->next;
119da2e3ebdSchin f->next = ps;
120da2e3ebdSchin }
121da2e3ebdSchin
122da2e3ebdSchin /* sync unseekable shared streams */
123da2e3ebdSchin if(f->extent < 0 && (f->flags&SF_SHARE) )
124da2e3ebdSchin (void)SFFLSBUF(f,-1);
125da2e3ebdSchin
126da2e3ebdSchin /* check for line buffering */
127da2e3ebdSchin else if((f->flags&SF_LINE) && !(f->flags&SF_STRING) && (n = f->next-f->data) > 0)
128da2e3ebdSchin { if(n > w)
129da2e3ebdSchin n = w;
130da2e3ebdSchin f->next -= n;
131da2e3ebdSchin (void)SFWRITE(f,(Void_t*)f->next,n);
132da2e3ebdSchin }
133da2e3ebdSchin
134da2e3ebdSchin SFOPEN(f,0);
135da2e3ebdSchin SFMTXRETURN(f, w);
136da2e3ebdSchin }
137