libs/ardour/coreaudio_source.cc

   1 /*
   2     Copyright (C) 2000 Paul Davis
   3
   4     This program is free software; you can redistribute it and/or modify
   5     it under the terms of the GNU General Public License as published by
   6     the Free Software Foundation; either version 2 of the License, or
   7     (at your option) any later version.
   8
   9     This program is distributed in the hope that it will be useful,
  10     but WITHOUT ANY WARRANTY; without even the implied warranty of
  11     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12     GNU General Public License for more details.
  13
  14     You should have received a copy of the GNU General Public License
  15     along with this program; if not, write to the Free Software
  16     Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  17
  18     $Id$
  19 */
  20
  21 #include <string>
  22 #include <sys/stat.h>
  23 #include <unistd.h>
  24 #include <sys/time.h>
  25
  26 #include <pbd/mountpoint.h>
  27 #include <ardour/coreaudio_source.h>
  28
  29 #include "i18n.h"
  30
  31 using namespace ARDOUR;
  32
  33 string CoreAudioSource::peak_dir = "";
  34
  35 CoreAudioSource::CoreAudioSource (const XMLNode& node)
  36         : Source (node)
  37 {
  38         if (set_state (node)) {
  39                 throw failed_constructor();
  40         }
  41
  42         init (_name, true);
  43         SourceCreated (this); /* EMIT SIGNAL */
  44 }
  45
  46 CoreAudioSource::CoreAudioSource (const string& idstr, bool build_peak)
  47         : Source(build_peak)
  48 {
  49         init (idstr, build_peak);
  50
  51         if (build_peak) {
  52                  SourceCreated (this); /* EMIT SIGNAL */
  53         }
  54 }
  55
  56 void
  57 CoreAudioSource::init (const string& idstr, bool build_peak)
  58 {
  59         string::size_type pos;
  60         string file;
  61
  62         tmpbuf = 0;
  63         tmpbufsize = 0;
  64         af_ref = 0;
  65
  66         _name = idstr;
  67
  68         if ((pos = idstr.find_last_of (':')) == string::npos) {
  69                 channel = 0;
  70                 file = idstr;
  71         } else {
  72                 channel = atoi (idstr.substr (pos+1).c_str());
  73                 file = idstr.substr (0, pos);
  74         }
  75
  76         /* note that we temporarily truncated _id at the colon */
  77         FSRef* ref;
  78         OSStatus err = FSPathMakeRef (file.c_str(), ref, 0);
  79         if (err) {
  80                 throw failed_constructor();
  81         }
  82         err = ExtAudioFileOpen (ref, af_ref);
  83         if (err) {
  84                 throw failed_constructor();
  85         }
  86
  87         if (channel >= n_channels) {
  88                 error << string_compose(_("CoreAudioSource: file only contains %1 channels; %2 is invalid as a channel number"), n_channels, channel) << endmsg;
  89                 ExtAudioFileDispose(af_ref);
  90                 throw failed_constructor();
  91         }
  92
  93         int64_t ca_frames;
  94         size_t prop_size = sizeof(ca_frames);
  95
  96         err = ExtAudioFileGetProperty(af_ref, kExtAudioFileProperty_FileLengthFrames,
  97                         sizeof(ca_frames), &ca_frames);
  98         if (err) {
  99                 throw failed_constructor();
 100         }
 101         _length = ca_frames;
 102
 103         _path = file;
 104
 105         if (build_peak) {
 106                 if (initialize_peakfile (false, file)) {
 107                         ExtAudioFileDispose(af_ref);
 108                         throw failed_constructor ();
 109                 }
 110         }
 111 }
 112
 113 CoreAudioSource::~CoreAudioSource ()
 114
 115 {
 116          GoingAway (this); /* EMIT SIGNAL */
 117
 118         if (af_ref) {
 119                 ExtAudioFileDispose(af_ref);
 120         }
 121
 122         if (tmpbuf) {
 123                 delete [] tmpbuf;
 124         }
 125 }
 126
 127 jack_nframes_t
 128 CoreAudioSource::read_unlocked (Sample *dst, jack_nframes_t start, jack_nframes_t cnt) const
 129 {
 130         return read (dst, start, cnt);
 131 }
 132
 133 jack_nframes_t
 134 CoreAudioSource::read (Sample *dst, jack_nframes_t start, jack_nframes_t cnt) const
 135 {
 136         int32_t nread;
 137         float *ptr;
 138         uint32_t real_cnt;
 139
 140         OSStatus err = ExtAudioFileSeek(af_ref, start);
 141         if (err) {
 142                 error << string_compose(_("CoreAudioSource: could not seek to frame %1 within %2"), start, _name.substr (1)) << endmsg;
 143                 return 0;
 144         }
 145
 146         if (n_channels == 1) {
 147                 uint32_t ioNumber = cnt;
 148                 err = ExtAudioFileRead(af_ref, &ioNumber, dst);
 149                 _read_data_count = cnt * sizeof(float);
 150                 return ioNumber;
 151         }
 152
 153         real_cnt = cnt * n_channels;
 154
 155         {
 156                 LockMonitor lm (_tmpbuf_lock, __LINE__, __FILE__);
 157
 158                 if (tmpbufsize < real_cnt) {
 159
 160                         if (tmpbuf) {
 161                                 delete [] tmpbuf;
 162                         }
 163                         tmpbufsize = real_cnt;
 164                         tmpbuf = new float[tmpbufsize];
 165                 }
 166
 167                 nread = real_cnt;
 168                 err = ExtAudioFileRead(af_ext, &nread, tmpbuf);
 169                 ptr = tmpbuf + channel;
 170                 nread /= n_channels;
 171
 172                 /* stride through the interleaved data */
 173
 174                 for (int32_t n = 0; n < nread; ++n) {
 175                         dst[n] = *ptr;
 176                         ptr += n_channels;
 177                 }
 178         }
 179
 180         _read_data_count = cnt * sizeof(float);
 181
 182         return nread;
 183 }
 184
 185 string
 186 CoreAudioSource::peak_path (string audio_path)
 187 {
 188         /* XXX hardly bombproof! fix me */
 189
 190         struct stat stat_file;
 191         struct stat stat_mount;
 192
 193         string mp = mountpoint (audio_path);
 194
 195         stat (audio_path.c_str(), &stat_file);
 196         stat (mp.c_str(), &stat_mount);
 197
 198         char buf[32];
 199         snprintf (buf, sizeof (buf), "%ld-%ld-%d.peak", stat_mount.st_ino, stat_file.st_ino, channel);
 200
 201         string res = peak_dir;
 202         res += buf;
 203
 204         return res;
 205 }
 206
 207 string
 208 CoreAudioSource::old_peak_path (string audio_path)
 209 {
 210         return peak_path (audio_path);
 211 }