1*7c478bd9Sstevel@tonic-gate /*
2*7c478bd9Sstevel@tonic-gate * CDDL HEADER START
3*7c478bd9Sstevel@tonic-gate *
4*7c478bd9Sstevel@tonic-gate * The contents of this file are subject to the terms of the
5*7c478bd9Sstevel@tonic-gate * Common Development and Distribution License, Version 1.0 only
6*7c478bd9Sstevel@tonic-gate * (the "License"). You may not use this file except in compliance
7*7c478bd9Sstevel@tonic-gate * with the License.
8*7c478bd9Sstevel@tonic-gate *
9*7c478bd9Sstevel@tonic-gate * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
10*7c478bd9Sstevel@tonic-gate * or http://www.opensolaris.org/os/licensing.
11*7c478bd9Sstevel@tonic-gate * See the License for the specific language governing permissions
12*7c478bd9Sstevel@tonic-gate * and limitations under the License.
13*7c478bd9Sstevel@tonic-gate *
14*7c478bd9Sstevel@tonic-gate * When distributing Covered Code, include this CDDL HEADER in each
15*7c478bd9Sstevel@tonic-gate * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
16*7c478bd9Sstevel@tonic-gate * If applicable, add the following below this CDDL HEADER, with the
17*7c478bd9Sstevel@tonic-gate * fields enclosed by brackets "[]" replaced with your own identifying
18*7c478bd9Sstevel@tonic-gate * information: Portions Copyright [yyyy] [name of copyright owner]
19*7c478bd9Sstevel@tonic-gate *
20*7c478bd9Sstevel@tonic-gate * CDDL HEADER END
21*7c478bd9Sstevel@tonic-gate */
22*7c478bd9Sstevel@tonic-gate /*
23*7c478bd9Sstevel@tonic-gate * Copyright (c) 1990-2001 by Sun Microsystems, Inc.
24*7c478bd9Sstevel@tonic-gate * All rights reserved.
25*7c478bd9Sstevel@tonic-gate */
26*7c478bd9Sstevel@tonic-gate
27*7c478bd9Sstevel@tonic-gate #include <stdlib.h>
28*7c478bd9Sstevel@tonic-gate #include <unistd.h>
29*7c478bd9Sstevel@tonic-gate #include <AudioPipe.h>
30*7c478bd9Sstevel@tonic-gate
31*7c478bd9Sstevel@tonic-gate // class AudioPipe methods
32*7c478bd9Sstevel@tonic-gate
33*7c478bd9Sstevel@tonic-gate
34*7c478bd9Sstevel@tonic-gate // Constructor with file descriptor, mode, and optional name
35*7c478bd9Sstevel@tonic-gate AudioPipe::
AudioPipe(const int desc,const FileAccess acc,const char * name_local)36*7c478bd9Sstevel@tonic-gate AudioPipe(
37*7c478bd9Sstevel@tonic-gate const int desc, // file descriptor
38*7c478bd9Sstevel@tonic-gate const FileAccess acc, // access mode
39*7c478bd9Sstevel@tonic-gate const char *name_local): // name
40*7c478bd9Sstevel@tonic-gate AudioUnixfile(name_local, acc)
41*7c478bd9Sstevel@tonic-gate {
42*7c478bd9Sstevel@tonic-gate setfd(desc);
43*7c478bd9Sstevel@tonic-gate }
44*7c478bd9Sstevel@tonic-gate
45*7c478bd9Sstevel@tonic-gate // The create routine for pipes writes a file header
46*7c478bd9Sstevel@tonic-gate AudioError AudioPipe::
Create()47*7c478bd9Sstevel@tonic-gate Create()
48*7c478bd9Sstevel@tonic-gate {
49*7c478bd9Sstevel@tonic-gate AudioError err;
50*7c478bd9Sstevel@tonic-gate
51*7c478bd9Sstevel@tonic-gate // Was the header properly set?
52*7c478bd9Sstevel@tonic-gate err = GetHeader().Validate();
53*7c478bd9Sstevel@tonic-gate if (err != AUDIO_SUCCESS)
54*7c478bd9Sstevel@tonic-gate return (RaiseError(err));
55*7c478bd9Sstevel@tonic-gate
56*7c478bd9Sstevel@tonic-gate // Open fd supplied by constructor
57*7c478bd9Sstevel@tonic-gate if (!isfdset())
58*7c478bd9Sstevel@tonic-gate return (RaiseError(AUDIO_ERR_NOEFFECT));
59*7c478bd9Sstevel@tonic-gate
60*7c478bd9Sstevel@tonic-gate // Write the file header with current (usually unknown) size
61*7c478bd9Sstevel@tonic-gate err = encode_filehdr();
62*7c478bd9Sstevel@tonic-gate if (err != AUDIO_SUCCESS) {
63*7c478bd9Sstevel@tonic-gate (void) close(getfd()); // If error, remove file
64*7c478bd9Sstevel@tonic-gate setfd(-1);
65*7c478bd9Sstevel@tonic-gate return (err);
66*7c478bd9Sstevel@tonic-gate }
67*7c478bd9Sstevel@tonic-gate
68*7c478bd9Sstevel@tonic-gate // Set the actual output length to zero
69*7c478bd9Sstevel@tonic-gate setlength(0.);
70*7c478bd9Sstevel@tonic-gate
71*7c478bd9Sstevel@tonic-gate return (AUDIO_SUCCESS);
72*7c478bd9Sstevel@tonic-gate }
73*7c478bd9Sstevel@tonic-gate
74*7c478bd9Sstevel@tonic-gate // The open routine for pipes decodes the header
75*7c478bd9Sstevel@tonic-gate AudioError AudioPipe::
Open()76*7c478bd9Sstevel@tonic-gate Open()
77*7c478bd9Sstevel@tonic-gate {
78*7c478bd9Sstevel@tonic-gate AudioError err;
79*7c478bd9Sstevel@tonic-gate
80*7c478bd9Sstevel@tonic-gate // The constructor should have supplied a valid fd
81*7c478bd9Sstevel@tonic-gate if (!isfdset())
82*7c478bd9Sstevel@tonic-gate return (RaiseError(AUDIO_ERR_NOEFFECT));
83*7c478bd9Sstevel@tonic-gate
84*7c478bd9Sstevel@tonic-gate // Decode a file header
85*7c478bd9Sstevel@tonic-gate err = decode_filehdr();
86*7c478bd9Sstevel@tonic-gate if (err != AUDIO_SUCCESS) {
87*7c478bd9Sstevel@tonic-gate (void) close(getfd());
88*7c478bd9Sstevel@tonic-gate setfd(-1);
89*7c478bd9Sstevel@tonic-gate return (err);
90*7c478bd9Sstevel@tonic-gate }
91*7c478bd9Sstevel@tonic-gate
92*7c478bd9Sstevel@tonic-gate return (AUDIO_SUCCESS);
93*7c478bd9Sstevel@tonic-gate }
94*7c478bd9Sstevel@tonic-gate
95*7c478bd9Sstevel@tonic-gate // Read data from underlying pipe into specified buffer.
96*7c478bd9Sstevel@tonic-gate // No data format translation takes place.
97*7c478bd9Sstevel@tonic-gate // Since there's no going back, the object's read position pointer is updated.
98*7c478bd9Sstevel@tonic-gate AudioError AudioPipe::
ReadData(void * buf,size_t & len,Double & pos)99*7c478bd9Sstevel@tonic-gate ReadData(
100*7c478bd9Sstevel@tonic-gate void* buf, // destination buffer address
101*7c478bd9Sstevel@tonic-gate size_t& len, // buffer length (updated)
102*7c478bd9Sstevel@tonic-gate Double& pos) // start position (updated)
103*7c478bd9Sstevel@tonic-gate {
104*7c478bd9Sstevel@tonic-gate AudioError err;
105*7c478bd9Sstevel@tonic-gate char *tbuf; // current buffer pointer
106*7c478bd9Sstevel@tonic-gate size_t remain; // number of bytes remaining
107*7c478bd9Sstevel@tonic-gate size_t cnt; // accumulated number of bytes read
108*7c478bd9Sstevel@tonic-gate
109*7c478bd9Sstevel@tonic-gate tbuf = (char *)buf;
110*7c478bd9Sstevel@tonic-gate remain = len;
111*7c478bd9Sstevel@tonic-gate cnt = 0;
112*7c478bd9Sstevel@tonic-gate
113*7c478bd9Sstevel@tonic-gate // Pipes return short reads. If non-blocking i/o, try to read all.
114*7c478bd9Sstevel@tonic-gate do {
115*7c478bd9Sstevel@tonic-gate // Call the real routine
116*7c478bd9Sstevel@tonic-gate err = AudioUnixfile::ReadData((void*)tbuf, remain, pos);
117*7c478bd9Sstevel@tonic-gate
118*7c478bd9Sstevel@tonic-gate // Update the object's read position
119*7c478bd9Sstevel@tonic-gate if (!err) {
120*7c478bd9Sstevel@tonic-gate (void) SetReadPosition(pos, Absolute);
121*7c478bd9Sstevel@tonic-gate if (remain == 0)
122*7c478bd9Sstevel@tonic-gate break;
123*7c478bd9Sstevel@tonic-gate cnt += remain;
124*7c478bd9Sstevel@tonic-gate tbuf += remain;
125*7c478bd9Sstevel@tonic-gate remain = len - cnt;
126*7c478bd9Sstevel@tonic-gate }
127*7c478bd9Sstevel@tonic-gate } while (!err && (remain > 0) && GetBlocking());
128*7c478bd9Sstevel@tonic-gate len = cnt;
129*7c478bd9Sstevel@tonic-gate if (len > 0)
130*7c478bd9Sstevel@tonic-gate return (AUDIO_SUCCESS);
131*7c478bd9Sstevel@tonic-gate return (err);
132*7c478bd9Sstevel@tonic-gate }
133*7c478bd9Sstevel@tonic-gate
134*7c478bd9Sstevel@tonic-gate // Write data to underlying file from specified buffer.
135*7c478bd9Sstevel@tonic-gate // No data format translation takes place.
136*7c478bd9Sstevel@tonic-gate // Since there's no going back, the object's write position pointer is updated.
137*7c478bd9Sstevel@tonic-gate AudioError AudioPipe::
WriteData(void * buf,size_t & len,Double & pos)138*7c478bd9Sstevel@tonic-gate WriteData(
139*7c478bd9Sstevel@tonic-gate void* buf, // source buffer address
140*7c478bd9Sstevel@tonic-gate size_t& len, // buffer length (updated)
141*7c478bd9Sstevel@tonic-gate Double& pos) // start position (updated)
142*7c478bd9Sstevel@tonic-gate {
143*7c478bd9Sstevel@tonic-gate AudioError err;
144*7c478bd9Sstevel@tonic-gate
145*7c478bd9Sstevel@tonic-gate // Call the real routine
146*7c478bd9Sstevel@tonic-gate err = AudioUnixfile::WriteData(buf, len, pos);
147*7c478bd9Sstevel@tonic-gate
148*7c478bd9Sstevel@tonic-gate // Update the object's write position
149*7c478bd9Sstevel@tonic-gate if (err == AUDIO_SUCCESS)
150*7c478bd9Sstevel@tonic-gate (void) SetWritePosition(pos, Absolute);
151*7c478bd9Sstevel@tonic-gate return (err);
152*7c478bd9Sstevel@tonic-gate }
153