/[svn]/linuxsampler/trunk/src/drivers/audio/AudioOutputDeviceJack.cpp

Diff of /linuxsampler/trunk/src/drivers/audio/AudioOutputDeviceJack.cpp

Parent Directory | Revision Log | View Patch Patch

-revision 289 by schoenebeck,
Tue Oct 19 14:41:38 2004 UTC
+revision 2412 by schoenebeck,
Mon Feb  4 21:52:56 2013 UTC
 Line 3
   *   LinuxSampler - modular, streaming capable sampler                     *
   *                                                                         *
   *   Copyright (C) 2003, 2004 by Benno Senoner and Christian Schoenebeck   *
+  *   Copyright (C) 2005 - 2013 Christian Schoenebeck                       *
   *                                                                         *
   *   This program is free software; you can redistribute it and/or modify  *
   *   it under the terms of the GNU General Public License as published by  *
-Line 27
+Line 28
  #if HAVE_JACK
+ #ifndef HAVE_JACK_CLIENT_NAME_SIZE
+ #define jack_client_name_size() 33
+ #endif
  namespace LinuxSampler {
- // *************** ParameterName ***************
+     /// number of currently existing JACK audio output devices in LinuxSampler
+     static int existingJackDevices = 0;
+ // *************** AudioChannelJack::ParameterName ***************
  // *
      AudioOutputDeviceJack::AudioChannelJack::ParameterName::ParameterName(AudioChannelJack* pChannel) : AudioChannel::ParameterName(ToString(pChannel->ChannelNr)) {
-Line 42 
 namespace LinuxSampler {
+Line 50 
 namespace LinuxSampler {
- // *************** ParameterJackBindings ***************
+ // *************** AudioChannelJack::ParameterJackBindings ***************
  // *
      AudioOutputDeviceJack::AudioChannelJack::ParameterJackBindings::ParameterJackBindings(AudioChannelJack* pChannel) : DeviceRuntimeParameterStrings(std::vector<String>()) {
-Line 58 
 namespace LinuxSampler {
+Line 66 
 namespace LinuxSampler {
      }
      std::vector<String> AudioOutputDeviceJack::AudioChannelJack::ParameterJackBindings::PossibilitiesAsString() {
-         const char** pPortNames = jack_get_ports(pChannel->pDevice->hJackClient, NULL, NULL, JackPortIsInput);
+         const char** pPortNames = jack_get_ports(pChannel->pDevice->hJackClient, NULL, JACK_DEFAULT_AUDIO_TYPE, JackPortIsInput);
          if (!pPortNames) return std::vector<String>();
          std::vector<String> result;
          for (int i = 0; pPortNames[i]; i++) result.push_back(pPortNames[i]);
-         //free(pPortNames); FIXME: pPortNames should be freed here
+         free(pPortNames);
          return result;
      }
      void AudioOutputDeviceJack::AudioChannelJack::ParameterJackBindings::OnSetValue(std::vector<String> vS) {
-         // TODO: we should remove all existing bindings before we connect new ones here
+         String src_name = ((DeviceCreationParameterString*)pChannel->pDevice->Parameters["NAME"])->ValueAsString() + ":" +
-         String src_name = "LinuxSampler:" + ((DeviceRuntimeParameterString*)pChannel->Parameters["NAME"])->ValueAsString();
+                           ((DeviceRuntimeParameterString*)pChannel->Parameters["NAME"])->ValueAsString();
+         // disconnect all current bindings first
+         for (int i = 0; i < Bindings.size(); i++) {
+             String dst_name = Bindings[i];
+             /*int res =*/ jack_disconnect(pChannel->pDevice->hJackClient, src_name.c_str(), dst_name.c_str());
+         }
+         // connect new bindings
          for (int i = 0; i < vS.size(); i++) {
              String dst_name = vS[i];
              int res = jack_connect(pChannel->pDevice->hJackClient, src_name.c_str(), dst_name.c_str());
              if (res == EEXIST) throw AudioOutputException("Jack: Connection to port '" + dst_name + "' already established");
              else if (res)      throw AudioOutputException("Jack: Cannot connect port '" + src_name + "' to port '" + dst_name + "'");
          }
+         // remember bindings
+         Bindings = vS;
      }
      String AudioOutputDeviceJack::AudioChannelJack::ParameterJackBindings::Name() {
-Line 89 
 namespace LinuxSampler {
+Line 105 
 namespace LinuxSampler {
      AudioOutputDeviceJack::AudioChannelJack::AudioChannelJack(uint ChannelNr, AudioOutputDeviceJack* pDevice) throw (AudioOutputException) : AudioChannel(ChannelNr, CreateJackPort(ChannelNr, pDevice), pDevice->uiMaxSamplesPerCycle) {
          this->pDevice   = pDevice;
          this->ChannelNr = ChannelNr;
+         delete Parameters["NAME"];
          Parameters["NAME"]          = new ParameterName(this);
          Parameters["JACK_BINDINGS"] = new ParameterJackBindings(this);
      }
-Line 103 
 namespace LinuxSampler {
+Line 120 
 namespace LinuxSampler {
          if (!hJackPort) throw AudioOutputException("Jack: Cannot register Jack output port.");
          return (float*) jack_port_get_buffer(hJackPort, pDevice->uiMaxSamplesPerCycle);
      }
+     void AudioOutputDeviceJack::AudioChannelJack::UpdateJackBuffer(uint size) {
+         SetBuffer(
+            (float*)jack_port_get_buffer(hJackPort, size)
+         );
+     }
+ // *************** AudioOutputDeviceJack::ParameterName ***************
+ // *
+     AudioOutputDeviceJack::ParameterName::ParameterName() : DeviceCreationParameterString() {
+         InitWithDefault(); // use default name
+     }
+     AudioOutputDeviceJack::ParameterName::ParameterName(String s) throw (Exception) : DeviceCreationParameterString(s) {
+     }
+     String AudioOutputDeviceJack::ParameterName::Description() {
+         return "Arbitrary JACK client name";
+     }
+     bool AudioOutputDeviceJack::ParameterName::Fix() {
+         return true;
+     }
+     bool AudioOutputDeviceJack::ParameterName::Mandatory() {
+         return false;
+     }
+     std::map<String,DeviceCreationParameter*> AudioOutputDeviceJack::ParameterName::DependsAsParameters() {
+         return std::map<String,DeviceCreationParameter*>(); // no dependencies
+     }
+     std::vector<String> AudioOutputDeviceJack::ParameterName::PossibilitiesAsString(std::map<String,String> Parameters) {
+         return std::vector<String>();
+     }
+     optional<String> AudioOutputDeviceJack::ParameterName::DefaultAsString(std::map<String,String> Parameters) {
+         return (existingJackDevices) ? "LinuxSampler" + ToString(existingJackDevices) : "LinuxSampler";
+     }
+     void AudioOutputDeviceJack::ParameterName::OnSetValue(String s) throw (Exception) {
+         // not possible, as parameter is fix
+     }
+     String AudioOutputDeviceJack::ParameterName::Name() {
+         return "NAME";
+     }
-Line 117 
 namespace LinuxSampler {
+Line 184 
 namespace LinuxSampler {
       * @see AcquireChannels()
       */
      AudioOutputDeviceJack::AudioOutputDeviceJack(std::map<String,DeviceCreationParameter*> Parameters) : AudioOutputDevice(Parameters) {
-         if ((hJackClient = jack_client_new("LinuxSampler")) == 0)
+         pJackClient = JackClient::CreateAudio(((DeviceCreationParameterString*)Parameters["NAME"])->ValueAsString());
-             throw AudioOutputException("Seems Jack server not running.");
+         existingJackDevices++;
+         pJackClient->SetAudioOutputDevice(this);
-         jack_set_process_callback(hJackClient, __libjack_process_callback, this);
+         hJackClient = pJackClient->hJackClient;
-         jack_on_shutdown(hJackClient, __libjack_shutdown_callback, this);
-         if (jack_activate(hJackClient))
-             throw AudioOutputException("Jack: Cannot activate Jack client.");
          uiMaxSamplesPerCycle = jack_get_buffer_size(hJackClient);
          // create audio channels
-Line 135 
 namespace LinuxSampler {
+Line 198 
 namespace LinuxSampler {
      }
      AudioOutputDeviceJack::~AudioOutputDeviceJack() {
-         // destroy jack client
+         // destroy jack client if there is no midi device associated with it
-         jack_client_close(hJackClient);
+         JackClient::ReleaseAudio(((DeviceCreationParameterString*)Parameters["NAME"])->ValueAsString());
+         existingJackDevices--;
      }
      /**
-Line 144 
 namespace LinuxSampler {
+Line 208 
 namespace LinuxSampler {
       * libjack to demand transmission of further sample points.
       */
      int AudioOutputDeviceJack::Process(uint Samples) {
+         int res;
+         // in recent versions of JACK2 and JACk1, we are forced to
+         // re-retrieve the audio buffer pointers in each process period
+         UpdateJackBuffers(Samples);
          if (csIsPlaying.Pop()) {
              // let all connected engines render 'Samples' sample points
-             return RenderAudio(Samples);
+             res = RenderAudio(Samples);
          }
          else {
              // playback stop by zeroing output buffer(s) and not calling connected sampler engines to render audio
-             return RenderSilence(Samples);
+             res = RenderSilence(Samples);
          }
+         csIsPlaying.RttDone();
+         return res;
+     }
+     void AudioOutputDeviceJack::UpdateJackBuffers(uint size) {
+         for (int i = 0; i < Channels.size(); ++i)
+             static_cast<AudioChannelJack*>(Channels[i])->UpdateJackBuffer(size);
+     }
+     float AudioOutputDeviceJack::latency() {
+         if (!hJackClient) return -1;
+         const float size = jack_get_buffer_size(hJackClient);
+         const float rate = jack_get_sample_rate(hJackClient);
+         return size / rate;
+     }
+     jack_client_t* AudioOutputDeviceJack::jackClientHandle() {
+         return hJackClient;
      }
      void AudioOutputDeviceJack::Play() {
-Line 159 
 namespace LinuxSampler {
+Line 247 
 namespace LinuxSampler {
      }
      bool AudioOutputDeviceJack::IsPlaying() {
-         csIsPlaying.GetUnsafe();
+         return csIsPlaying.GetUnsafe();
      }
      void AudioOutputDeviceJack::Stop() {
-Line 177 
 namespace LinuxSampler {
+Line 265 
 namespace LinuxSampler {
      uint AudioOutputDeviceJack::SampleRate() {
          return jack_get_sample_rate(hJackClient);
      }
+     void AudioOutputDeviceJack::addListener(JackListener* listener) {
+         pJackClient->addListener(listener);
+     }
      String AudioOutputDeviceJack::Name() {
          return "JACK";
-Line 191 
 namespace LinuxSampler {
+Line 283 
 namespace LinuxSampler {
      }
      String AudioOutputDeviceJack::Version() {
-        String s = "$Revision: 1.14 $";
+        String s = "$Revision: 1.25 $";
         return s.substr(11, s.size() - 13); // cut dollar signs, spaces and CVS macro keyword
      }
+ // *************** JackClient ***************
+ // *
      // libjack callback functions
-     int __libjack_process_callback(jack_nframes_t nframes, void* arg) {
+     int linuxsampler_libjack_process_callback(jack_nframes_t nframes, void* arg) {
-         AudioOutputDeviceJack* pAudioOutputDeviceJack = (AudioOutputDeviceJack*) arg;
+         return static_cast<JackClient*>(arg)->Process(nframes);
-         return pAudioOutputDeviceJack->Process(nframes);
      }
-     void __libjack_shutdown_callback(void* arg) {
+     void JackClient::libjackShutdownCallback(void* arg) {
-         AudioOutputDeviceJack* pAudioOutputDeviceJack = (AudioOutputDeviceJack*) arg;
+         JackClient* jackClient = static_cast<JackClient*>(arg);
-         pAudioOutputDeviceJack->Stop();
+         jackClient->Stop();
          fprintf(stderr, "Jack: Jack server shutdown, exiting.\n");
+         for (int i = 0; i < jackClient->jackListeners.size(); ++i) {
+             JackListener* listener = jackClient->jackListeners[i];
+             listener->onJackShutdown();
+         }
+     }
+     int JackClient::libjackSampleRateCallback(jack_nframes_t nframes, void *arg) {
+         JackClient* client = static_cast<JackClient*>(arg);
+         const config_t& config = client->ConfigReader.Lock();
+         if (config.AudioDevice)
+             config.AudioDevice->ReconnectAll();
+         client->ConfigReader.Unlock();
+         return 0;
+     }
+     int JackClient::libjackBufferSizeCallback(jack_nframes_t nframes, void *arg) {
+         dmsg(1,("libjackBufferSizeCallback(%d)\n",nframes));
+         JackClient* client = static_cast<JackClient*>(arg);
+         const config_t& config = client->ConfigReader.Lock();
+         if (config.AudioDevice) {
+             config.AudioDevice->UpdateJackBuffers(nframes);
+             config.AudioDevice->ReconnectAll();
+         }
+         client->ConfigReader.Unlock();
+         return 0;
+     }
+     void JackClient::addListener(JackListener* listener) {
+         jackListeners.push_back(listener);
+     }
+     std::map<String, JackClient*> JackClient::Clients;
+     int JackClient::Process(uint Samples) {
+         const config_t& config = ConfigReader.Lock();
+ #if HAVE_JACK_MIDI
+         if (config.MidiDevice) config.MidiDevice->Process(Samples);
+ #endif
+         int res = config.AudioDevice ? config.AudioDevice->Process(Samples) : 0;
+         ConfigReader.Unlock();
+         return res;
+     }
+     void JackClient::Stop() {
+         const config_t& config = ConfigReader.Lock();
+         if (config.AudioDevice) config.AudioDevice->Stop();
+         ConfigReader.Unlock();
+     }
+     JackClient::JackClient(String Name) : ConfigReader(Config) {
+         {
+             config_t& config = Config.GetConfigForUpdate();
+             config.AudioDevice = 0;
+ #if HAVE_JACK_MIDI
+             config.MidiDevice = 0;
+ #endif
+         }
+         {
+             config_t& config = Config.SwitchConfig();
+             config.AudioDevice = 0;
+ #if HAVE_JACK_MIDI
+             config.MidiDevice = 0;
+ #endif
+         }
+         audio = midi = false;
+         if (Name.size() >= jack_client_name_size())
+             throw Exception("JACK client name too long");
+ #if HAVE_JACK_CLIENT_OPEN
+         hJackClient = jack_client_open(Name.c_str(), JackNullOption, NULL);
+ #else
+         hJackClient = jack_client_new(Name.c_str());
+ #endif
+         if (!hJackClient)
+             throw Exception("Seems Jack server is not running.");
+         jack_set_process_callback(hJackClient, linuxsampler_libjack_process_callback, this);
+         jack_on_shutdown(hJackClient, libjackShutdownCallback, this);
+         jack_set_buffer_size_callback(hJackClient, libjackBufferSizeCallback, this);
+         jack_set_sample_rate_callback(hJackClient, libjackSampleRateCallback, this);
+         if (jack_activate(hJackClient))
+             throw Exception("Jack: Cannot activate Jack client.");
+     }
+     JackClient::~JackClient() {
+         jack_client_close(hJackClient);
+     }
+     void JackClient::SetAudioOutputDevice(AudioOutputDeviceJack* device) {
+         Config.GetConfigForUpdate().AudioDevice = device;
+         Config.SwitchConfig().AudioDevice = device;
+     }
+ #if HAVE_JACK_MIDI
+     void JackClient::SetMidiInputDevice(MidiInputDeviceJack* device) {
+         Config.GetConfigForUpdate().MidiDevice = device;
+         Config.SwitchConfig().MidiDevice = device;
+     }
+ #endif
+     JackClient* JackClient::CreateAudio(String Name) { // static
+         JackClient* client;
+         std::map<String, JackClient*>::const_iterator it = Clients.find(Name);
+         if (it == Clients.end()) {
+             client = new JackClient(Name);
+             Clients[Name] = client;
+         } else {
+             client = it->second;
+             if (client->audio) throw Exception("Jack audio device '" + Name + "' already exists");
+         }
+         client->audio = true;
+         return client;
+     }
+     JackClient* JackClient::CreateMidi(String Name) { // static
+         JackClient* client;
+         std::map<String, JackClient*>::const_iterator it = Clients.find(Name);
+         if (it == Clients.end()) {
+             client = new JackClient(Name);
+             Clients[Name] = client;
+         } else {
+             client = it->second;
+             if (client->midi) throw Exception("Jack MIDI device '" + Name + "' already exists");
+         }
+         client->midi = true;
+         return client;
+     }
+     void JackClient::ReleaseAudio(String Name) { // static
+         JackClient* client = Clients[Name];
+         client->SetAudioOutputDevice(0);
+         client->audio = false;
+         if (!client->midi) {
+             Clients.erase(Name);
+             delete client;
+         }
+     }
+     void JackClient::ReleaseMidi(String Name) { // static
+         JackClient* client = Clients[Name];
+ #if HAVE_JACK_MIDI
+         client->SetMidiInputDevice(0);
+ #endif
+         client->midi = false;
+         if (!client->audio) {
+             Clients.erase(Name);
+             delete client;
+         }
      }
  } // namespace LinuxSampler

 Legend:



Removed from v.289
 


changed lines


 
Added in v.2412
 Legend:



Removed from v.289
 


changed lines


 
Added in v.2412
-Removed from v.289
+Added in v.2412

	ViewVC Help
Powered by ViewVC