1 /* 2 * CDDL HEADER START 3 * 4 * The contents of this file are subject to the terms of the 5 * Common Development and Distribution License, Version 1.0 only 6 * (the "License"). You may not use this file except in compliance 7 * with the License. 8 * 9 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 10 * or http://www.opensolaris.org/os/licensing. 11 * See the License for the specific language governing permissions 12 * and limitations under the License. 13 * 14 * When distributing Covered Code, include this CDDL HEADER in each 15 * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 16 * If applicable, add the following below this CDDL HEADER, with the 17 * fields enclosed by brackets "[]" replaced with your own identifying 18 * information: Portions Copyright [yyyy] [name of copyright owner] 19 * 20 * CDDL HEADER END 21 */ 22 /* 23 * Copyright 2004 Sun Microsystems, Inc. All rights reserved. 24 * Use is subject to license terms. 25 */ 26 27 #include <stdlib.h> 28 #include <stdio.h> 29 #include <unistd.h> 30 #include <errno.h> 31 #include <malloc.h> 32 #include <string.h> 33 #include <fcntl.h> 34 #include <sys/stat.h> 35 #include <sys/types.h> 36 #include <sys/mman.h> 37 38 #include <AudioFile.h> 39 #include <AudioLib.h> 40 #include <AudioDebug.h> 41 #include <libaudio.h> 42 #include <audio_hdr.h> 43 44 // class AudioFile methods 45 46 47 // Initialize temporary file params 48 #define TMPDIR "/tmp" 49 #define TMPFILE "/audiotoolXXXXXX" 50 static char *tmpdir = NULL; 51 static const char *tmpname = "(temporary file)"; 52 static const FileAccess tmpmode = ReadWrite; 53 static const VMAccess defaccess = SequentialAccess; 54 55 // Initialize default access mode, used when a filename is supplied 56 const FileAccess AudioFile::defmode = ReadOnly; 57 58 // Default audio file path prefix environment variable 59 const char *AudioFile::AUDIO_PATH = "AUDIOPATH"; 60 61 62 // Constructor with no arguments opens a read/write temporary file 63 AudioFile:: 64 AudioFile(): 65 AudioUnixfile(tmpname, tmpmode), 66 hdrsize(0), seekpos(0), origlen(0.), mapaddr(0), maplen(0), 67 vmaccess(defaccess) 68 { 69 } 70 71 // Constructor with pathname and optional mode arg 72 AudioFile:: 73 AudioFile( 74 const char *path, // filename 75 const FileAccess acc): // access mode 76 AudioUnixfile(path, acc), 77 hdrsize(0), seekpos(0), origlen(0.), mapaddr(0), maplen(0), 78 vmaccess(defaccess) 79 { 80 } 81 82 // Destructor must call the local Close() routine 83 AudioFile:: 84 ~AudioFile() 85 { 86 // If the file was open, close it 87 if (opened()) 88 (void) Close(); 89 } 90 91 // Set a default temporary file directory 92 AudioError AudioFile:: 93 SetTempPath( 94 const char *path) 95 { 96 struct stat st; 97 98 // Verify intended path 99 if ((stat(path, &st) < 0) || 100 !S_ISDIR(st.st_mode) || 101 (access(path, W_OK) < 0)) { 102 errno = ENOTDIR; 103 return (AUDIO_UNIXERROR); 104 } 105 106 if (tmpdir != NULL) 107 (void) free(tmpdir); 108 tmpdir = (char *)malloc(strlen(path) + 1); 109 (void) strcpy(tmpdir, path); 110 return (AUDIO_SUCCESS); 111 } 112 113 114 // Create a named file according to the current mode setting 115 AudioError AudioFile:: 116 createfile( 117 const char *path) // pathname or 0 118 { 119 char *tmpf; 120 char *tmpstr; 121 int openmode; 122 int desc; 123 AudioError err; 124 125 // Convert the open mode to an int argument for open() 126 openmode = GetAccess(); 127 128 // Was the header properly set? 129 if (!hdrset()) 130 return (RaiseError(AUDIO_ERR_BADHDR)); 131 132 // Can't create if already opened or if mode or name not set 133 if ((openmode == -1) || opened() || (strlen(path) == 0)) 134 return (RaiseError(AUDIO_ERR_NOEFFECT)); 135 136 // If temporary file, create and unlink it. 137 if (strcmp(path, tmpname) == 0) { 138 // Construct the temporary file path 139 tmpstr = (char *)malloc(1 + strlen(TMPFILE) + 140 strlen((tmpdir == NULL) ? TMPDIR : tmpdir)); 141 (void) sprintf(tmpstr, "%s%s", 142 (tmpdir == NULL) ? TMPDIR : tmpdir, TMPFILE); 143 tmpf = mktemp(tmpstr); 144 145 // Open the temp file and unlink it 146 err = createfile(tmpf); 147 if ((err == AUDIO_SUCCESS) && (unlink(tmpf) < 0)) { 148 (void) Close(); 149 err = RaiseError(AUDIO_UNIXERROR, Warning); 150 } 151 (void) free(tmpstr); 152 return (err); 153 } 154 155 // Create the file 156 desc = open(path, openmode | O_CREAT | O_TRUNC, 0666); 157 if ((desc < 0) && (errno == EOVERFLOW)) { 158 return (RaiseError(AUDIO_UNIXERROR, Fatal, 159 (char *)"Large File")); 160 } else if (desc < 0) { 161 return (RaiseError(AUDIO_UNIXERROR)); 162 } 163 164 // Set the file descriptor (this marks the file open) 165 setfd(desc); 166 167 // Write the file header with current (usually unknown) size 168 err = encode_filehdr(); 169 if (err != AUDIO_SUCCESS) { 170 setfd(-1); 171 (void) close(desc); // If error, remove file 172 (void) unlink(path); 173 return (err); 174 } 175 176 // Save the length that got written, then set it to zero 177 origlen = GetLength(); 178 setlength(0.); 179 180 // Set the size of the file header 181 hdrsize = lseek(desc, (off_t)0, SEEK_CUR); 182 if (hdrsize < 0) { 183 setfd(-1); 184 (void) close(desc); // If error, remove file 185 (void) unlink(path); 186 return (err); 187 } 188 seekpos = 0; 189 190 return (AUDIO_SUCCESS); 191 } 192 193 // Create a file whose name is already set, according to the mode setting 194 AudioError AudioFile:: 195 Create() 196 { 197 return (createfile(GetName())); 198 } 199 200 // Open a file whose name is set 201 AudioError AudioFile:: 202 Open() 203 { 204 return (OpenPath(NULL)); 205 } 206 207 // Open a file, using the specified path prefixes 208 AudioError AudioFile:: 209 OpenPath( 210 const char *path) 211 { 212 char *filename; 213 int flen; 214 char *prefix; 215 char *str; 216 char *wrk; 217 char *pathname; 218 int openmode; 219 AudioError err; 220 221 // Convert the open mode to an int argument for open() 222 openmode = GetAccess(); 223 filename = GetName(); 224 flen = strlen(filename); 225 226 // Can't open if already opened or if mode or name not set 227 if ((openmode == -1) || opened() || (strlen(filename) == 0)) 228 return (RaiseError(AUDIO_ERR_NOEFFECT)); 229 230 // Search path: 231 // 1) try name: if not found and not readonly: 232 // if Append mode, try creating it 233 // 2) if name is a relative pathname, and 'path' is not NULL: 234 // try every path prefix in 'path' 235 236 err = tryopen(filename, openmode); 237 if (!err) 238 return (AUDIO_SUCCESS); 239 if (GetAccess().Writeable() || (filename[0] == '/')) { 240 // If file is non-existent and Append mode, try creating it. 241 if ((err == AUDIO_UNIXERROR) && (err.sys == ENOENT) && 242 GetAccess().Append() && hdrset()) { 243 return (Create()); 244 } 245 return (RaiseError(err)); 246 } 247 248 // Try path as an environment variable name, else assume it is a path 249 str = (path == NULL) ? NULL : getenv(path); 250 if (str == NULL) 251 str = (char *)path; 252 253 if (str != NULL) { 254 // Make a copy of the path, to parse it 255 wrk = new char[strlen(str) + 1]; 256 (void) strcpy(wrk, str); 257 str = wrk; 258 259 // Try each component as a path prefix 260 for (prefix = str; 261 (prefix != NULL) && (prefix[0] != '\0'); 262 prefix = str) { 263 str = strchr(str, ':'); 264 if (str != NULL) 265 *str++ = '\0'; 266 pathname = new char[strlen(prefix) + flen + 2]; 267 (void) sprintf(pathname, "%s/%s", prefix, filename); 268 err = tryopen(pathname, openmode); 269 delete[] pathname; 270 switch (err) { 271 case AUDIO_SUCCESS: // found the file 272 delete[] wrk; 273 return (RaiseError(err)); 274 // XXX - if file found but not audio, stop looking?? 275 } 276 } 277 delete[] wrk; 278 } 279 // Can't find file. Return the original error condition. 280 return (RaiseError(tryopen(filename, openmode))); 281 } 282 283 // Attempt to open the given audio file 284 AudioError AudioFile:: 285 tryopen( 286 const char *pathname, 287 int openmode) 288 { 289 struct stat st; 290 int desc; 291 AudioError err; 292 293 // If the name is changing, set the new one 294 if (pathname != GetName()) 295 SetName(pathname); 296 297 // Does the file exist? 298 if (stat(pathname, &st) < 0) 299 return (AUDIO_UNIXERROR); 300 301 // If not a regular file, stop right there 302 if (!S_ISREG(st.st_mode)) 303 return (AUDIO_ERR_BADFILEHDR); 304 305 // Open the file and check that it's an audio file 306 desc = open(GetName(), openmode); 307 if ((desc < 0) && (errno == EOVERFLOW)) { 308 return (RaiseError(AUDIO_UNIXERROR, Fatal, 309 (char *)"Large File")); 310 } else if (desc < 0) { 311 return (AUDIO_UNIXERROR); 312 } 313 314 // Set the file descriptor (this marks the file open) 315 setfd(desc); 316 317 err = decode_filehdr(); 318 if (err != AUDIO_SUCCESS) { 319 (void) close(desc); 320 setfd(-1); 321 return (err); 322 } 323 324 // Save the length of the data and the size of the file header 325 origlen = GetLength(); 326 hdrsize = (off_t)lseek(desc, (off_t)0, SEEK_CUR); 327 if (hdrsize < 0) { 328 (void) close(desc); 329 setfd(-1); 330 return (err); 331 } 332 seekpos = 0; 333 334 // If this is ReadOnly file, mmap() it. Don't worry if mmap() fails. 335 if (!GetAccess().Writeable()) { 336 maplen = st.st_size; 337 338 /* 339 * Can't mmap LITTLE_ENDIAN as they are converted in 340 * place. 341 */ 342 if (localByteOrder() == BIG_ENDIAN) { 343 if ((mapaddr = (caddr_t)mmap(0, (int)maplen, PROT_READ, 344 MAP_SHARED, desc, 0)) != (caddr_t)-1) { 345 // set default access method 346 (void) madvise(mapaddr, (unsigned int)maplen, 347 (int)GetAccessType()); 348 } else { 349 (void) RaiseError(AUDIO_UNIXERROR, Warning, 350 (char *)"Could not mmap() file"); 351 mapaddr = 0; 352 maplen = 0; 353 } 354 } else { 355 mapaddr = 0; 356 maplen = 0; 357 } 358 } 359 return (AUDIO_SUCCESS); 360 } 361 362 // set VM access hint for mmapped files 363 AudioError AudioFile:: 364 SetAccessType(VMAccess vmacc) 365 { 366 if (!opened()) { 367 return (AUDIO_ERR_NOEFFECT); 368 } 369 370 if (mapaddr == 0) { 371 return (AUDIO_ERR_NOEFFECT); 372 } 373 374 (void) madvise(mapaddr, (unsigned int)maplen, (int)vmacc); 375 vmaccess = vmacc; 376 377 return (AUDIO_SUCCESS); 378 } 379 380 // Close the file 381 AudioError AudioFile:: 382 Close() 383 { 384 AudioError err; 385 386 if (!opened()) 387 return (RaiseError(AUDIO_ERR_NOEFFECT, Warning)); 388 389 // Rewind the file and rewrite the header with the correct length 390 if (GetAccess().Writeable() && (origlen != GetLength())) { 391 392 // sanity check 393 if (GetHeader().Time_to_Bytes(GetLength()) != 394 (lseek(getfd(), (off_t)0, SEEK_END) - hdrsize)) { 395 PrintMsg(_MGET_( 396 "AudioFile:Close()...inconsistent length\n"), 397 Fatal); 398 } 399 400 // XXX - should be rewritten in C++ 401 err = (AudioError) audio_rewrite_filesize(getfd(), FILE_AU, 402 (uint_t)GetHeader().Time_to_Bytes(GetLength()), 0, 0); 403 } 404 405 // Call the generic file close routine 406 err = AudioUnixfile::Close(); 407 408 if (mapaddr) { 409 munmap(mapaddr, (int)maplen); 410 mapaddr = 0; 411 maplen = 0; 412 } 413 414 // Init important values, in case the file is reopened 415 hdrsize = 0; 416 seekpos = 0; 417 return (RaiseError(err)); 418 } 419 420 // Read data from underlying file into specified buffer. 421 // No data format translation takes place. 422 // The object's read position pointer is unaffected. 423 AudioError AudioFile:: 424 ReadData( 425 void* buf, // destination buffer address 426 size_t& len, // buffer length (updated) 427 Double& pos) // start position (updated) 428 { 429 off_t offset; 430 size_t cnt; 431 caddr_t cp; 432 AudioError err; 433 434 // If the file is not mapped, call parent ReadData() and return 435 if (mapaddr == 0) { 436 // Call the real routine 437 err = AudioUnixfile::ReadData(buf, len, pos); 438 // Update the cached seek pointer 439 seekpos += len; 440 return (err); 441 } 442 443 // If the file is mmapped, do a memcpy() from the mapaddr 444 445 // Save buffer size and zero transfer count 446 cnt = (size_t)len; 447 len = 0; 448 449 // Cannot read if file is not open 450 if (!opened() || !GetAccess().Readable()) 451 return (RaiseError(AUDIO_ERR_NOEFFECT)); 452 453 // Position must be valid 454 if (Undefined(pos) || (pos < 0.) || ((int)cnt < 0)) 455 return (RaiseError(AUDIO_ERR_BADARG)); 456 457 // Make sure we don't read off the end of file 458 offset = GetHeader().Time_to_Bytes(pos); 459 460 if ((offset + hdrsize) >= maplen) { 461 // trying to read past EOF 462 err = AUDIO_EOF; 463 err.sys = AUDIO_COPY_INPUT_EOF; 464 return (err); 465 } else if ((offset + hdrsize + cnt) > maplen) { 466 // re-adjust cnt so it reads up to the end of file 467 cnt = (size_t)(maplen - (offset + hdrsize)); 468 } 469 470 // Zero-length reads are finished 471 if (GetHeader().Bytes_to_Bytes(cnt) == 0) { 472 err = AUDIO_SUCCESS; 473 err.sys = AUDIO_COPY_ZERO_LIMIT; 474 return (err); 475 } else { 476 cp = mapaddr + offset + hdrsize; 477 memcpy((void*)buf, (void*)cp, cnt); 478 } 479 480 // Return the updated byte count and position 481 len = cnt; 482 pos = GetHeader().Bytes_to_Time(offset + len); 483 484 // Check to see if the endian is right. Note that special care 485 // doesn't need to be taken because of the mmap, since the data 486 // is copied into a separate buffer anyway. 487 coerceEndian((unsigned char *)buf, len, localByteOrder()); 488 489 return (AUDIO_SUCCESS); 490 } 491 492 // Write data to underlying file from specified buffer. 493 // No data format translation takes place. 494 // The object's write position pointer is unaffected. 495 AudioError AudioFile:: 496 WriteData( 497 void* buf, // source buffer address 498 size_t& len, // buffer length (updated) 499 Double& pos) // start position (updated) 500 { 501 AudioError err; 502 503 // Call the real routine 504 err = AudioUnixfile::WriteData(buf, len, pos); 505 506 // Update the cached seek pointer 507 seekpos += len; 508 return (err); 509 } 510 511 // Set the Unix file pointer to match a given file position. 512 AudioError AudioFile:: 513 seekread( 514 Double pos, // position to seek to 515 off_t& offset) // returned byte offset 516 { 517 offset = GetHeader().Time_to_Bytes(pos); 518 if (offset != seekpos) { 519 if (lseek(getfd(), (off_t)(hdrsize + offset), SEEK_SET) < 0) 520 return (RaiseError(AUDIO_UNIXERROR, Warning)); 521 seekpos = offset; 522 } 523 return (AUDIO_SUCCESS); 524 } 525 526 // Set the Unix file pointer to match a given file position. 527 // If seek beyond end-of-file, NULL out intervening data. 528 AudioError AudioFile:: 529 seekwrite( 530 Double pos, // position to seek to 531 off_t& offset) // returned byte offset 532 { 533 // If append-only, can't seek backwards into file 534 if (GetAccess().Append() && (pos < GetLength())) 535 return (RaiseError(AUDIO_ERR_NOEFFECT, Warning)); 536 537 // If seek beyond eof, fill data 538 if (pos > GetLength()) { 539 seekwrite(GetLength(), offset); // seek to eof 540 541 // XXX - not implemented yet 542 543 return (AUDIO_SUCCESS); 544 } 545 546 offset = GetHeader().Time_to_Bytes(pos); 547 if (offset != seekpos) { 548 if (lseek(getfd(), (off_t)(hdrsize + offset), SEEK_SET) < 0) 549 return (RaiseError(AUDIO_UNIXERROR, Warning)); 550 seekpos = offset; 551 } 552 return (AUDIO_SUCCESS); 553 } 554 555 // Copy routine that handles mapped files 556 AudioError AudioFile:: 557 AsyncCopy( 558 Audio* to, // audio object to copy to 559 Double& frompos, 560 Double& topos, 561 Double& limit) 562 { 563 caddr_t bptr; 564 size_t offset; 565 size_t cnt; 566 size_t svlim; 567 Double svfrom; 568 Double svto; 569 AudioHdr tohdr; 570 AudioError err; 571 572 // If this is NOT mmapped, or the destination is an AudioBuffer, 573 // use the default routine 574 if ((mapaddr == 0) || to->isBuffer()) { 575 return (Audio::AsyncCopy(to, frompos, topos, limit)); 576 } 577 578 tohdr = to->GetHeader(); 579 if (err = tohdr.Validate()) 580 return (err); 581 if (limit < 0.) 582 return (RaiseError(AUDIO_ERR_BADARG)); 583 svlim = (size_t)tohdr.Time_to_Bytes(limit); 584 585 // Get maximum possible copy length 586 svfrom = GetLength(); 587 if ((frompos >= svfrom) || ((cnt = (size_t) 588 GetHeader().Time_to_Bytes(svfrom - frompos)) == 0)) { 589 limit = 0.; 590 err = AUDIO_EOF; 591 err.sys = AUDIO_COPY_INPUT_EOF; 592 return (err); 593 } 594 if (!Undefined(limit) && (svlim < cnt)) 595 cnt = svlim; 596 597 limit = 0.; 598 599 offset = (size_t)GetHeader().Time_to_Bytes(frompos); 600 if ((offset + hdrsize) >= maplen) { 601 // trying to read past EOF 602 err = AUDIO_EOF; 603 err.sys = AUDIO_COPY_INPUT_EOF; 604 return (err); 605 } else if ((offset + hdrsize + cnt) > maplen) { 606 // re-adjust cnt so it reads up to the end of file 607 cnt = (size_t)(maplen - (offset + hdrsize)); 608 } 609 610 // Zero-length reads are done 611 if (GetHeader().Bytes_to_Bytes(cnt) == 0) { 612 err = AUDIO_SUCCESS; 613 err.sys = AUDIO_COPY_ZERO_LIMIT; 614 return (err); 615 } 616 617 // Write the data to the destination and update pointers/ctrs 618 svfrom = frompos; 619 svto = topos; 620 svlim = cnt; 621 bptr = mapaddr + hdrsize + offset; 622 err = to->WriteData(bptr, cnt, topos); 623 limit = topos - svto; 624 frompos = svfrom + limit; 625 626 // Report short writes 627 if (!err && (cnt < svlim)) 628 err.sys = AUDIO_COPY_SHORT_OUTPUT; 629 return (err); 630 } 631