falkTX
/
Cadence
mirror of https://github.com/falkTX/Cadence
1
0
Fork 0
Code Releases 3 Activity
Collection of tools useful for audio production
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
1035 Commits
2 Branches
19MB
Tree: 915065c1f1
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from '915065c1f1'
${ noResults }
Cadence/src/catia.py

1446 lines
54KB
Raw Blame History 

  1. #!/usr/bin/env python3

  2. # -*- coding: utf-8 -*-

  3. 

  4. # JACK Patchbay

  5. # Copyright (C) 2010-2018 Filipe Coelho <falktx@falktx.com>

  6. #

  7. # This program is free software; you can redistribute it and/or modify

  8. # it under the terms of the GNU General Public License as published by

  9. # the Free Software Foundation; either version 2 of the License, or

  10. # any later version.

  11. #

  12. # This program is distributed in the hope that it will be useful,

  13. # but WITHOUT ANY WARRANTY; without even the implied warranty of

  14. # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

  15. # GNU General Public License for more details.

  16. #

  17. # For a full copy of the GNU General Public License see the COPYING file

  18. 

  19. # ------------------------------------------------------------------------------------------------------------

  20. # Imports (Custom Stuff)

  21. 

  22. import ui_catia

  23. from shared_canvasjack import *

  24. from shared_settings import *

  25. 

  26. # ------------------------------------------------------------------------------------------------------------

  27. # Try Import DBus

  28. 

  29. try:

  30.     import dbus

  31.     from dbus.mainloop.pyqt5 import DBusQtMainLoop

  32.     haveDBus = True

  33. except:

  34.     haveDBus = False

  35. 

  36. # ------------------------------------------------------------------------------------------------------------

  37. # Try Import OpenGL

  38. 

  39. try:

  40.     from PyQt5.QtOpenGL import QGLWidget

  41.     hasGL = True

  42. except:

  43.     hasGL = False

  44. 

  45. # ------------------------------------------------------------------------------------------------------------

  46. # Check for ALSA-MIDI

  47. 

  48. haveALSA = False

  49. 

  50. if LINUX:

  51.     for iPATH in PATH:

  52.         if not os.path.exists(os.path.join(iPATH, "aconnect")):

  53.             continue

  54. 

  55.         haveALSA = True

  56. 

  57.         if sys.version_info >= (3, 0):

  58.             from subprocess import getoutput

  59.         else:

  60.             from commands import getoutput

  61. 

  62.         if DEBUG:

  63.             print("Using experimental ALSA-MIDI support")

  64. 

  65.         break

  66. 

  67. # ------------------------------------------------------------------------------------------------------------

  68. # Global Variables

  69. 

  70. global gA2JClientName

  71. gA2JClientName = None

  72. 

  73. # ------------------------------------------------------------------------------------------------------------

  74. # Static Variables

  75. 

  76. GROUP_TYPE_NULL = 0

  77. GROUP_TYPE_ALSA = 1

  78. GROUP_TYPE_JACK = 2

  79. 

  80. iGroupId   = 0

  81. iGroupName = 1

  82. iGroupType = 2

  83. 

  84. iPortId    = 0

  85. iPortName  = 1

  86. iPortNameR = 2

  87. iPortGroupName = 3

  88. 

  89. iConnId     = 0

  90. iConnOutput = 1

  91. iConnInput  = 2

  92. 

  93. URI_CANVAS_ICON = "http://kxstudio.sf.net/ns/canvas/icon"

  94. 

  95. # ------------------------------------------------------------------------------------------------------------

  96. # Catia Main Window

  97. 

  98. class CatiaMainW(AbstractCanvasJackClass):

  99.     def __init__(self, parent=None):

  100.         AbstractCanvasJackClass.__init__(self, "Catia", ui_catia.Ui_CatiaMainW, parent)

  101. 

  102.         self.fGroupList      = []

  103.         self.fGroupSplitList = []

  104.         self.fPortList       = []

  105.         self.fConnectionList = []

  106. 

  107.         self.fLastGroupId = 1

  108.         self.fLastPortId  = 1

  109.         self.fLastConnectionId = 1

  110. 

  111.         self.loadSettings(True)

  112. 

  113.         # -------------------------------------------------------------

  114.         # Set-up GUI

  115. 

  116.         setIcons(self, ["canvas", "jack", "transport", "misc"])

  117. 

  118.         self.ui.act_quit.setIcon(getIcon("application-exit"))

  119.         self.ui.act_configure.setIcon(getIcon("configure"))

  120. 

  121.         self.ui.cb_buffer_size.clear()

  122.         self.ui.cb_sample_rate.clear()

  123. 

  124.         for bufferSize in BUFFER_SIZE_LIST:

  125.             self.ui.cb_buffer_size.addItem(str(bufferSize))

  126. 

  127.         for sampleRate in SAMPLE_RATE_LIST:

  128.             self.ui.cb_sample_rate.addItem(str(sampleRate))

  129. 

  130.         self.ui.act_jack_bf_list = (self.ui.act_jack_bf_16, self.ui.act_jack_bf_32, self.ui.act_jack_bf_64, self.ui.act_jack_bf_128,

  131.                                     self.ui.act_jack_bf_256, self.ui.act_jack_bf_512, self.ui.act_jack_bf_1024, self.ui.act_jack_bf_2048,

  132.                                     self.ui.act_jack_bf_4096, self.ui.act_jack_bf_8192)

  133. 

  134.         if not haveALSA:

  135.             self.ui.act_settings_show_alsa.setChecked(False)

  136.             self.ui.act_settings_show_alsa.setEnabled(False)

  137. 

  138.         # -------------------------------------------------------------

  139.         # Set-up Canvas

  140. 

  141.         self.scene = patchcanvas.PatchScene(self, self.ui.graphicsView)

  142.         self.ui.graphicsView.setScene(self.scene)

  143.         self.ui.graphicsView.setRenderHint(QPainter.Antialiasing, bool(self.fSavedSettings["Canvas/Antialiasing"] == patchcanvas.ANTIALIASING_FULL))

  144.         if self.fSavedSettings["Canvas/UseOpenGL"] and hasGL:

  145.             self.ui.graphicsView.setViewport(QGLWidget(self.ui.graphicsView))

  146.             self.ui.graphicsView.setRenderHint(QPainter.HighQualityAntialiasing, self.fSavedSettings["Canvas/HighQualityAntialiasing"])

  147. 

  148.         pOptions = patchcanvas.options_t()

  149.         pOptions.theme_name       = self.fSavedSettings["Canvas/Theme"]

  150.         pOptions.auto_hide_groups = self.fSavedSettings["Canvas/AutoHideGroups"]

  151.         pOptions.use_bezier_lines = self.fSavedSettings["Canvas/UseBezierLines"]

  152.         pOptions.antialiasing     = self.fSavedSettings["Canvas/Antialiasing"]

  153.         pOptions.eyecandy         = self.fSavedSettings["Canvas/EyeCandy"]

  154. 

  155.         pFeatures = patchcanvas.features_t()

  156.         pFeatures.group_info   = False

  157.         pFeatures.group_rename = False

  158.         pFeatures.port_info    = True

  159.         pFeatures.port_rename  = bool(self.fSavedSettings["Main/JackPortAlias"] > 0)

  160.         pFeatures.handle_group_pos = True

  161. 

  162.         patchcanvas.setOptions(pOptions)

  163.         patchcanvas.setFeatures(pFeatures)

  164.         patchcanvas.init("Catia", self.scene, self.canvasCallback, DEBUG)

  165. 

  166.         # -------------------------------------------------------------

  167.         # Try to connect to jack

  168. 

  169.         if self.jackStarted():

  170.             self.initAlsaPorts()

  171. 

  172.         # -------------------------------------------------------------

  173.         # Check DBus

  174. 

  175.         if haveDBus:

  176.             if gDBus.jack:

  177.                 pass

  178.             else:

  179.                 self.ui.act_tools_jack_start.setEnabled(False)

  180.                 self.ui.act_tools_jack_stop.setEnabled(False)

  181.                 self.ui.act_jack_configure.setEnabled(False)

  182.                 self.ui.b_jack_configure.setEnabled(False)

  183. 

  184.             if gDBus.a2j:

  185.                 if gDBus.a2j.is_started():

  186.                     self.a2jStarted()

  187.                 else:

  188.                     self.a2jStopped()

  189.             else:

  190.                 self.ui.act_tools_a2j_start.setEnabled(False)

  191.                 self.ui.act_tools_a2j_stop.setEnabled(False)

  192.                 self.ui.act_tools_a2j_export_hw.setEnabled(False)

  193.                 self.ui.menu_A2J_Bridge.setEnabled(False)

  194. 

  195.         else:

  196.             # No DBus

  197.             self.ui.act_tools_jack_start.setEnabled(False)

  198.             self.ui.act_tools_jack_stop.setEnabled(False)

  199.             self.ui.act_jack_configure.setEnabled(False)

  200.             self.ui.b_jack_configure.setEnabled(False)

  201.             self.ui.act_tools_a2j_start.setEnabled(False)

  202.             self.ui.act_tools_a2j_stop.setEnabled(False)

  203.             self.ui.act_tools_a2j_export_hw.setEnabled(False)

  204.             self.ui.menu_A2J_Bridge.setEnabled(False)

  205. 

  206.         # -------------------------------------------------------------

  207.         # Set-up Timers

  208. 

  209.         self.fTimer120 = self.startTimer(self.fSavedSettings["Main/RefreshInterval"])

  210.         self.fTimer600 = self.startTimer(self.fSavedSettings["Main/RefreshInterval"] * 5)

  211. 

  212.         # -------------------------------------------------------------

  213.         # Set-up Connections

  214. 

  215.         self.setCanvasConnections()

  216.         self.setJackConnections(["jack", "buffer-size", "transport", "misc"])

  217. 

  218.         self.ui.act_tools_jack_start.triggered.connect(self.slot_JackServerStart)

  219.         self.ui.act_tools_jack_stop.triggered.connect(self.slot_JackServerStop)

  220.         self.ui.act_tools_a2j_start.triggered.connect(self.slot_A2JBridgeStart)

  221.         self.ui.act_tools_a2j_stop.triggered.connect(self.slot_A2JBridgeStop)

  222.         self.ui.act_tools_a2j_export_hw.triggered.connect(self.slot_A2JBridgeExportHW)

  223. 

  224.         self.ui.act_settings_show_alsa.triggered.connect(self.slot_showAlsaMIDI)

  225.         self.ui.act_configure.triggered.connect(self.slot_configureCatia)

  226. 

  227.         self.ui.act_help_about.triggered.connect(self.slot_aboutCatia)

  228.         self.ui.act_help_about_qt.triggered.connect(app.aboutQt)

  229. 

  230.         self.XRunCallback.connect(self.slot_XRunCallback)

  231.         self.BufferSizeCallback.connect(self.slot_BufferSizeCallback)

  232.         self.SampleRateCallback.connect(self.slot_SampleRateCallback)

  233.         self.ClientRenameCallback.connect(self.slot_ClientRenameCallback)

  234.         self.PortRegistrationCallback.connect(self.slot_PortRegistrationCallback)

  235.         self.PortConnectCallback.connect(self.slot_PortConnectCallback)

  236.         self.PortRenameCallback.connect(self.slot_PortRenameCallback)

  237.         self.ShutdownCallback.connect(self.slot_ShutdownCallback)

  238. 

  239.         # -------------------------------------------------------------

  240.         # Set-up DBus

  241. 

  242.         if gDBus.jack or gDBus.a2j:

  243.             gDBus.bus.add_signal_receiver(self.DBusSignalReceiver, destination_keyword="dest", path_keyword="path",

  244.                 member_keyword="member", interface_keyword="interface", sender_keyword="sender")

  245. 

  246.         # -------------------------------------------------------------

  247. 

  248.     def canvasCallback(self, action, value1, value2, valueStr):

  249.         if action == patchcanvas.ACTION_GROUP_INFO:

  250.             pass

  251. 

  252.         elif action == patchcanvas.ACTION_GROUP_RENAME:

  253.             pass

  254. 

  255.         elif action == patchcanvas.ACTION_GROUP_SPLIT:

  256.             groupId = value1

  257.             patchcanvas.splitGroup(groupId)

  258. 

  259.         elif action == patchcanvas.ACTION_GROUP_JOIN:

  260.             groupId = value1

  261.             patchcanvas.joinGroup(groupId)

  262. 

  263.         elif action == patchcanvas.ACTION_PORT_INFO:

  264.             portId = value1

  265. 

  266.             for port in self.fPortList:

  267.                 if port[iPortId] == portId:

  268.                     portNameR = port[iPortNameR]

  269.                     portNameG = port[iPortGroupName]

  270.                     break

  271.             else:

  272.                 return

  273. 

  274.             if portNameR.startswith("[ALSA-"):

  275.                 portId, portName = portNameR.split("] ", 1)[1].split(" ", 1)

  276. 

  277.                 flags = []

  278.                 if portNameR.startswith("[ALSA-Input] "):

  279.                     flags.append(self.tr("Input"))

  280.                 elif portNameR.startswith("[ALSA-Output] "):

  281.                     flags.append(self.tr("Output"))

  282. 

  283.                 flagsText = " | ".join(flags)

  284.                 typeText  = self.tr("ALSA MIDI")

  285. 

  286.                 info = self.tr(""

  287.                               "<table>"

  288.                               "<tr><td align='right'><b>Group Name:</b></td><td>&nbsp;%s</td></tr>"

  289.                               "<tr><td align='right'><b>Port Id:</b></td><td>&nbsp;%s</td></tr>"

  290.                               "<tr><td align='right'><b>Port Name:</b></td><td>&nbsp;%s</td></tr>"

  291.                               "<tr><td colspan='2'>&nbsp;</td></tr>"

  292.                               "<tr><td align='right'><b>Port Flags:</b></td><td>&nbsp;%s</td></tr>"

  293.                               "<tr><td align='right'><b>Port Type:</b></td><td>&nbsp;%s</td></tr>"

  294.                               "</table>" % (portNameG, portId, portName, flagsText, typeText))

  295. 

  296.             else:

  297.                 portPtr   = jacklib.port_by_name(gJack.client, portNameR)

  298.                 portFlags = jacklib.port_flags(portPtr)

  299.                 groupName = portNameR.split(":", 1)[0]

  300.                 portShortName = str(jacklib.port_short_name(portPtr), encoding="utf-8")

  301. 

  302.                 aliases = jacklib.port_get_aliases(portPtr)

  303.                 if aliases[0] == 1:

  304.                     alias1text = aliases[1]

  305.                     alias2text = "(none)"

  306.                 elif aliases[0] == 2:

  307.                     alias1text = aliases[1]

  308.                     alias2text = aliases[2]

  309.                 else:

  310.                     alias1text = "(none)"

  311.                     alias2text = "(none)"

  312. 

  313.                 flags = []

  314.                 if portFlags & jacklib.JackPortIsInput:

  315.                     flags.append(self.tr("Input"))

  316.                 if portFlags & jacklib.JackPortIsOutput:

  317.                     flags.append(self.tr("Output"))

  318.                 if portFlags & jacklib.JackPortIsPhysical:

  319.                     flags.append(self.tr("Physical"))

  320.                 if portFlags & jacklib.JackPortCanMonitor:

  321.                     flags.append(self.tr("Can Monitor"))

  322.                 if portFlags & jacklib.JackPortIsTerminal:

  323.                     flags.append(self.tr("Terminal"))

  324. 

  325.                 flagsText = " | ".join(flags)

  326. 

  327.                 portTypeStr = str(jacklib.port_type(portPtr), encoding="utf-8")

  328.                 if portTypeStr == jacklib.JACK_DEFAULT_AUDIO_TYPE:

  329.                     typeText = self.tr("JACK Audio")

  330.                 elif portTypeStr == jacklib.JACK_DEFAULT_MIDI_TYPE:

  331.                     typeText = self.tr("JACK MIDI")

  332.                 else:

  333.                     typeText = self.tr("Unknown")

  334. 

  335.                 portLatency      = jacklib.port_get_latency(portPtr)

  336.                 portTotalLatency = jacklib.port_get_total_latency(gJack.client, portPtr)

  337.                 latencyText      = self.tr("%.1f ms (%i frames)" % (portLatency * 1000 / int(self.fSampleRate), portLatency))

  338.                 latencyTotalText = self.tr("%.1f ms (%i frames)" % (portTotalLatency * 1000 / int(self.fSampleRate), portTotalLatency))

  339. 

  340.                 info = self.tr(""

  341.                                "<table>"

  342.                                "<tr><td align='right'><b>Group Name:</b></td><td>&nbsp;%s</td></tr>"

  343.                                "<tr><td align='right'><b>Port Name:</b></td><td>&nbsp;%s</td></tr>"

  344.                                "<tr><td align='right'><b>Full Port Name:</b></td><td>&nbsp;%s</td></tr>"

  345.                                "<tr><td align='right'><b>Port Alias #1:</b></td><td>&nbsp;%s</td></tr>"

  346.                                "<tr><td align='right'><b>Port Alias #2:</b></td><td>&nbsp;%s</td></tr>"

  347.                                "<tr><td colspan='2'>&nbsp;</td></tr>"

  348.                                "<tr><td align='right'><b>Port Flags:</b></td><td>&nbsp;%s</td></tr>"

  349.                                "<tr><td align='right'><b>Port Type:</b></td><td>&nbsp;%s</td></tr>"

  350.                                "<tr><td colspan='2'>&nbsp;</td></tr>"

  351.                                "<tr><td align='right'><b>Port Latency:</b></td><td>&nbsp;%s</td></tr>"

  352.                                "<tr><td align='right'><b>Total Port Latency:</b></td><td>&nbsp;%s</td></tr>"

  353.                                "</table>" % (groupName, portShortName, portNameR, alias1text, alias2text, flagsText, typeText, latencyText, latencyTotalText))

  354. 

  355.             QMessageBox.information(self, self.tr("Port Information"), info)

  356. 

  357.         elif action == patchcanvas.ACTION_PORT_RENAME:

  358.             global gA2JClientName

  359. 

  360.             portId = value1

  361.             portShortName = asciiString(valueStr)

  362. 

  363.             for port in self.fPortList:

  364.                 if port[iPortId] == portId:

  365.                     portNameR = port[iPortNameR]

  366. 

  367.                     if portNameR.startswith("[ALSA-"):

  368.                         QMessageBox.warning(self, self.tr("Cannot continue"), self.tr(""

  369.                             "Rename functions rely on JACK aliases and cannot be done in ALSA ports"))

  370.                         return

  371. 

  372.                     if portNameR.split(":", 1)[0] == gA2JClientName:

  373.                         a2jSplit = portNameR.split(":", 3)

  374.                         portName = "%s:%s: %s" % (a2jSplit[0], a2jSplit[1], portShortName)

  375.                     else:

  376.                         portName = "%s:%s" % (port[iPortGroupName], portShortName)

  377.                     break

  378.             else:

  379.                 return

  380. 

  381.             portPtr = jacklib.port_by_name(gJack.client, portNameR)

  382.             aliases = jacklib.port_get_aliases(portPtr)

  383. 

  384.             if aliases[0] == 2:

  385.                 # JACK only allows 2 aliases, remove 2nd

  386.                 jacklib.port_unset_alias(portPtr, aliases[2])

  387. 

  388.                 # If we're going for 1st alias, unset it too

  389.                 if self.fSavedSettings["Main/JackPortAlias"] == 1:

  390.                     jacklib.port_unset_alias(portPtr, aliases[1])

  391. 

  392.             elif aliases[0] == 1 and self.fSavedSettings["Main/JackPortAlias"] == 1:

  393.                 jacklib.port_unset_alias(portPtr, aliases[1])

  394. 

  395.             if aliases[0] == 0 and self.fSavedSettings["Main/JackPortAlias"] == 2:

  396.                 # If 2nd alias is enabled and port had no previous aliases, set the 1st alias now

  397.                 jacklib.port_set_alias(portPtr, portName)

  398. 

  399.             if jacklib.port_set_alias(portPtr, portName) == 0:

  400.                 patchcanvas.renamePort(portId, portShortName)

  401. 

  402.         elif action == patchcanvas.ACTION_PORTS_CONNECT:

  403.             portIdA = value1

  404.             portIdB = value2

  405.             portRealNameA = ""

  406.             portRealNameB = ""

  407. 

  408.             for port in self.fPortList:

  409.                 if port[iPortId] == portIdA:

  410.                     portRealNameA = port[iPortNameR]

  411.                 if port[iPortId] == portIdB:

  412.                     portRealNameB = port[iPortNameR]

  413. 

  414.             if portRealNameA.startswith("[ALSA-"):

  415.                 portIdAlsaA = portRealNameA.split(" ", 2)[1]

  416.                 portIdAlsaB = portRealNameB.split(" ", 2)[1]

  417. 

  418.                 if os.system("aconnect %s %s" % (portIdAlsaA, portIdAlsaB)) == 0:

  419.                     self.canvas_connectPorts(portIdA, portIdB)

  420. 

  421.             elif portRealNameA and portRealNameB:

  422.                 jacklib.connect(gJack.client, portRealNameA, portRealNameB)

  423. 

  424.         elif action == patchcanvas.ACTION_PORTS_DISCONNECT:

  425.             connectionId = value1

  426. 

  427.             for connection in self.fConnectionList:

  428.                 if connection[iConnId] == connectionId:

  429.                     portIdA = connection[iConnOutput]

  430.                     portIdB = connection[iConnInput]

  431.                     break

  432.             else:

  433.                 return

  434. 

  435.             portRealNameA = ""

  436.             portRealNameB = ""

  437. 

  438.             for port in self.fPortList:

  439.                 if port[iPortId] == portIdA:

  440.                     portRealNameA = port[iPortNameR]

  441.                 if port[iPortId] == portIdB:

  442.                     portRealNameB = port[iPortNameR]

  443. 

  444.             if portRealNameA.startswith("[ALSA-"):

  445.                 portIdAlsaA = portRealNameA.split(" ", 2)[1]

  446.                 portIdAlsaB = portRealNameB.split(" ", 2)[1]

  447. 

  448.                 if os.system("aconnect -d %s %s" % (portIdAlsaA, portIdAlsaB)) == 0:

  449.                     self.canvas_disconnectPorts(portIdA, portIdB)

  450. 

  451.             elif portRealNameA and portRealNameB:

  452.                 jacklib.disconnect(gJack.client, portRealNameA, portRealNameB)

  453. 

  454.     def initPorts(self):

  455.         self.fGroupList      = []

  456.         self.fGroupSplitList = []

  457.         self.fPortList       = []

  458.         self.fConnectionList = []

  459. 

  460.         self.fLastGroupId = 1

  461.         self.fLastPortId  = 1

  462.         self.fLastConnectionId = 1

  463. 

  464.         self.initJackPorts()

  465.         self.initAlsaPorts()

  466. 

  467.     def initJack(self):

  468.         self.fXruns = 0

  469.         self.fNextSampleRate = 0.0

  470. 

  471.         self.fLastBPM = None

  472.         self.fLastTransportState = None

  473. 

  474.         bufferSize = int(jacklib.get_buffer_size(gJack.client))

  475.         sampleRate = int(jacklib.get_sample_rate(gJack.client))

  476.         realtime   = bool(int(jacklib.is_realtime(gJack.client)))

  477. 

  478.         self.ui_setBufferSize(bufferSize)

  479.         self.ui_setSampleRate(sampleRate)

  480.         self.ui_setRealTime(realtime)

  481.         self.ui_setXruns(0)

  482. 

  483.         self.refreshDSPLoad()

  484.         self.refreshTransport()

  485. 

  486.         self.initJackCallbacks()

  487.         self.initJackPorts()

  488. 

  489.         self.scene.zoom_fit()

  490.         self.scene.zoom_reset()

  491. 

  492.         jacklib.activate(gJack.client)

  493. 

  494.     def initJackCallbacks(self):

  495.         jacklib.set_buffer_size_callback(gJack.client, self.JackBufferSizeCallback, None)

  496.         jacklib.set_sample_rate_callback(gJack.client, self.JackSampleRateCallback, None)

  497.         jacklib.set_xrun_callback(gJack.client, self.JackXRunCallback, None)

  498.         jacklib.set_port_registration_callback(gJack.client, self.JackPortRegistrationCallback, None)

  499.         jacklib.set_port_connect_callback(gJack.client, self.JackPortConnectCallback, None)

  500.         jacklib.set_session_callback(gJack.client, self.JackSessionCallback, None)

  501.         jacklib.on_shutdown(gJack.client, self.JackShutdownCallback, None)

  502. 

  503.         jacklib.set_client_rename_callback(gJack.client, self.JackClientRenameCallback, None)

  504.         jacklib.set_port_rename_callback(gJack.client, self.JackPortRenameCallback, None)

  505. 

  506.     def initJackPorts(self):

  507.         if not gJack.client:

  508.             return

  509. 

  510.         global gA2JClientName

  511. 

  512.         # Get all jack ports, put a2j ones to the bottom of the list

  513.         a2jNameList  = []

  514.         portNameList = c_char_p_p_to_list(jacklib.get_ports(gJack.client, "", "", 0))

  515. 

  516.         h = 0

  517.         for i in range(len(portNameList)):

  518.             if portNameList[i - h].split(":")[0] == gA2JClientName:

  519.                 portName = portNameList.pop(i - h)

  520.                 a2jNameList.append(portName)

  521.                 h += 1

  522. 

  523.         for a2jName in a2jNameList:

  524.             portNameList.append(a2jName)

  525. 

  526.         del a2jNameList

  527. 

  528.         # Add jack ports

  529.         for portName in portNameList:

  530.             portPtr = jacklib.port_by_name(gJack.client, portName)

  531.             self.canvas_addJackPort(portPtr, portName)

  532. 

  533.         # Add jack connections

  534.         for portName in portNameList:

  535.             portPtr = jacklib.port_by_name(gJack.client, portName)

  536. 

  537.             # Only make connections from an output port

  538.             if jacklib.port_flags(portPtr) & jacklib.JackPortIsInput:

  539.                 continue

  540. 

  541.             portConnectionNames = c_char_p_p_to_list(jacklib.port_get_all_connections(gJack.client, portPtr))

  542. 

  543.             for portConName in portConnectionNames:

  544.                 self.canvas_connectPortsByName(portName, portConName)

  545. 

  546.     def initAlsaPorts(self):

  547.         if not (haveALSA and self.ui.act_settings_show_alsa.isChecked()):

  548.             return

  549. 

  550.         # Get ALSA MIDI ports (outputs)

  551.         output = getoutput("env LANG=C LC_ALL=C aconnect -i").split("\n")

  552.         lastGroupId   = -1

  553.         lastGroupName = ""

  554. 

  555.         for line in output:

  556.             # Make 'System' match JACK's 'system'

  557.             if line == "client 0: 'System' [type=kernel]":

  558.                 line = "client 0: 'system' [type=kernel]"

  559. 

  560.             if line.startswith("client "):

  561.                 lineSplit  = line.split(": ", 1)

  562.                 lineSplit2 = lineSplit[1].replace("'", "", 1).split("' [type=", 1)

  563.                 groupId    = int(lineSplit[0].replace("client ", ""))

  564.                 groupName  = lineSplit2[0]

  565.                 groupType  = lineSplit2[1].rsplit("]", 1)[0]

  566. 

  567.                 lastGroupId = self.canvas_getGroupId(groupName)

  568. 

  569.                 if lastGroupId == -1:

  570.                     # Group doesn't exist yet

  571.                     lastGroupId = self.canvas_addAlsaGroup(groupId, groupName, bool(groupType == "kernel"))

  572. 

  573.                 lastGroupName = groupName

  574. 

  575.             elif line.startswith("   ") and lastGroupId >= 0 and lastGroupName:

  576.                 lineSplit = line.split(" '", 1)

  577.                 portId    = int(lineSplit[0].strip())

  578.                 portName  = lineSplit[1].rsplit("'", 1)[0].strip()

  579. 

  580.                 self.canvas_addAlsaPort(lastGroupId, lastGroupName, portName, "%i:%i %s" % (groupId, portId, portName), False)

  581. 

  582.             else:

  583.                 lastGroupId   = -1

  584.                 lastGroupName = ""

  585. 

  586.         # Get ALSA MIDI ports (inputs)

  587.         output = getoutput("env LANG=C LC_ALL=C aconnect -o").split("\n")

  588.         lastGroupId   = -1

  589.         lastGroupName = ""

  590. 

  591.         for line in output:

  592.             # Make 'System' match JACK's 'system'

  593.             if line == "client 0: 'System' [type=kernel]":

  594.                 line = "client 0: 'system' [type=kernel]"

  595. 

  596.             if line.startswith("client "):

  597.                 lineSplit  = line.split(": ", 1)

  598.                 lineSplit2 = lineSplit[1].replace("'", "", 1).split("' [type=", 1)

  599.                 groupId    = int(lineSplit[0].replace("client ", ""))

  600.                 groupName  = lineSplit2[0]

  601.                 groupType  = lineSplit2[1].rsplit("]", 1)[0]

  602. 

  603.                 lastGroupId = self.canvas_getGroupId(groupName)

  604. 

  605.                 if lastGroupId == -1:

  606.                     # Group doesn't exist yet

  607.                     lastGroupId = self.canvas_addAlsaGroup(groupId, groupName, bool(groupType == "kernel"))

  608. 

  609.                 lastGroupName = groupName

  610. 

  611.             elif line.startswith("   ") and lastGroupId >= 0 and lastGroupName:

  612.                 lineSplit = line.split(" '", 1)

  613.                 portId    = int(lineSplit[0].strip())

  614.                 portName  = lineSplit[1].rsplit("'", 1)[0].strip()

  615. 

  616.                 self.canvas_addAlsaPort(lastGroupId, lastGroupName, portName, "%i:%i %s" % (groupId, portId, portName), True)

  617. 

  618.             else:

  619.                 lastGroupId   = -1

  620.                 lastGroupName = ""

  621. 

  622.         # Get ALSA MIDI connections

  623.         output = getoutput("env LANG=C LC_ALL=C aconnect -ol").split("\n")

  624.         lastGroupId = -1

  625.         lastPortId  = -1

  626. 

  627.         for line in output:

  628.             # Make 'System' match JACK's 'system'

  629.             if line == "client 0: 'System' [type=kernel]":

  630.                 line = "client 0: 'system' [type=kernel]"

  631. 

  632.             if line.startswith("client "):

  633.                 lineSplit  = line.split(": ", 1)

  634.                 lineSplit2 = lineSplit[1].replace("'", "", 1).split("' [type=", 1)

  635.                 groupId    = int(lineSplit[0].replace("client ", ""))

  636.                 groupName  = lineSplit2[0]

  637. 

  638.                 lastGroupId = self.canvas_getGroupId(groupName)

  639. 

  640.             elif line.startswith("    ") and lastGroupId >= 0:

  641.                 lineSplit = line.split(" '", 1)

  642.                 portId    = int(lineSplit[0].strip())

  643.                 portName  = lineSplit[1].rsplit("'", 1)[0].strip()

  644. 

  645.                 for port in self.fPortList:

  646.                     if port[iPortNameR] == "[ALSA-Input] %i:%i %s" % (groupId, portId, portName):

  647.                         lastPortId = port[iPortId]

  648.                         break

  649.                 else:

  650.                     lastPortId = -1

  651. 

  652.             elif line.startswith("\tConnect") and lastGroupId >= 0 and lastPortId >= 0:

  653.                 if line.startswith("\tConnected From"):

  654.                     lineSplit = line.split(": ", 1)[1]

  655.                     lineConns = lineSplit.split(", ")

  656. 

  657.                     for lineConn in lineConns:

  658.                         lineConnSplit = lineConn.replace("'","").split(":", 1)

  659.                         alsaGroupId   = int(lineConnSplit[0].split("[real:",1)[0])

  660.                         alsaPortId    = int(lineConnSplit[1].split("[real:",1)[0])

  661. 

  662.                         portNameRtest = "[ALSA-Output] %i:%i " % (alsaGroupId, alsaPortId)

  663. 

  664.                         for port in self.fPortList:

  665.                             if port[iPortNameR].startswith(portNameRtest):

  666.                                 self.canvas_connectPorts(port[iPortId], lastPortId)

  667.                                 break

  668. 

  669.             else:

  670.                 lastGroupId = -1

  671.                 lastPortId  = -1

  672. 

  673.     def canvas_getGroupId(self, groupName):

  674.         for group in self.fGroupList:

  675.             if group[iGroupName] == groupName:

  676.                 return group[iGroupId]

  677.         return -1

  678. 

  679.     def canvas_addAlsaGroup(self, alsaGroupId, groupName, hwSplit):

  680.         groupId = self.fLastGroupId

  681. 

  682.         if hwSplit:

  683.             patchcanvas.addGroup(groupId, groupName, patchcanvas.SPLIT_YES, patchcanvas.ICON_HARDWARE)

  684.         else:

  685.             patchcanvas.addGroup(groupId, groupName)

  686. 

  687.         groupObj = [None, None, None]

  688.         groupObj[iGroupId]   = groupId

  689.         groupObj[iGroupName] = groupName

  690.         groupObj[iGroupType] = GROUP_TYPE_ALSA

  691. 

  692.         self.fGroupList.append(groupObj)

  693.         self.fLastGroupId += 1

  694. 

  695.         return groupId

  696. 

  697.     def canvas_addJackGroup(self, groupName):

  698.         ret, data, dataSize = jacklib.custom_get_data(gJack.client, groupName, URI_CANVAS_ICON)

  699. 

  700.         groupId    = self.fLastGroupId

  701.         groupSplit = patchcanvas.SPLIT_UNDEF

  702.         groupIcon  = patchcanvas.ICON_APPLICATION

  703. 

  704.         if ret == 0:

  705.             iconName = voidptr2str(data)

  706.             jacklib.free(data)

  707. 

  708.             if iconName == "hardware":

  709.                 groupSplit = patchcanvas.SPLIT_YES

  710.                 groupIcon  = patchcanvas.ICON_HARDWARE

  711.             #elif iconName =="carla":

  712.                 #groupIcon = patchcanvas.ICON_CARLA

  713.             elif iconName =="distrho":

  714.                 groupIcon = patchcanvas.ICON_DISTRHO

  715.             elif iconName =="file":

  716.                 groupIcon = patchcanvas.ICON_FILE

  717.             elif iconName =="plugin":

  718.                 groupIcon = patchcanvas.ICON_PLUGIN

  719. 

  720.         patchcanvas.addGroup(groupId, groupName, groupSplit, groupIcon)

  721. 

  722.         groupObj = [None, None, None]

  723.         groupObj[iGroupId]   = groupId

  724.         groupObj[iGroupName] = groupName

  725.         groupObj[iGroupType] = GROUP_TYPE_JACK

  726. 

  727.         self.fGroupList.append(groupObj)

  728.         self.fLastGroupId += 1

  729. 

  730.         return groupId

  731. 

  732.     def canvas_removeGroup(self, groupName):

  733.         groupId = -1

  734.         for group in self.fGroupList:

  735.             if group[iGroupName] == groupName:

  736.                 groupId = group[iGroupId]

  737.                 self.fGroupList.remove(group)

  738.                 break

  739.         else:

  740.             print("Catia - remove group failed")

  741.             return

  742. 

  743.         patchcanvas.removeGroup(groupId)

  744. 

  745.     def canvas_addAlsaPort(self, groupId, groupName, portName, portNameR, isPortInput):

  746.         portId   = self.fLastPortId

  747.         portMode = patchcanvas.PORT_MODE_INPUT if isPortInput else patchcanvas.PORT_MODE_OUTPUT

  748.         portType = patchcanvas.PORT_TYPE_MIDI_ALSA

  749. 

  750.         patchcanvas.addPort(groupId, portId, portName, portMode, portType)

  751. 

  752.         portObj = [None, None, None, None]

  753.         portObj[iPortId]    = portId

  754.         portObj[iPortName]  = portName

  755.         portObj[iPortNameR] = "[ALSA-%s] %s" % ("Input" if isPortInput else "Output", portNameR)

  756.         portObj[iPortGroupName] = groupName

  757. 

  758.         self.fPortList.append(portObj)

  759.         self.fLastPortId += 1

  760. 

  761.         return portId

  762. 

  763.     def canvas_addJackPort(self, portPtr, portName):

  764.         global gA2JClientName

  765. 

  766.         portId  = self.fLastPortId

  767.         groupId = -1

  768. 

  769.         portNameR = portName

  770. 

  771.         aliasN = self.fSavedSettings["Main/JackPortAlias"]

  772.         if aliasN in (1, 2):

  773.             aliases = jacklib.port_get_aliases(portPtr)

  774.             if aliases[0] == 2 and aliasN == 2:

  775.                 portName = aliases[2]

  776.             elif aliases[0] >= 1 and aliasN == 1:

  777.                 portName = aliases[1]

  778. 

  779.         portFlags = jacklib.port_flags(portPtr)

  780.         groupName = portName.split(":", 1)[0]

  781. 

  782.         if portFlags & jacklib.JackPortIsInput:

  783.             portMode = patchcanvas.PORT_MODE_INPUT

  784.         elif portFlags & jacklib.JackPortIsOutput:

  785.             portMode = patchcanvas.PORT_MODE_OUTPUT

  786.         else:

  787.             portMode = patchcanvas.PORT_MODE_NULL

  788. 

  789.         if groupName == gA2JClientName:

  790.             portType  = patchcanvas.PORT_TYPE_MIDI_A2J

  791.             groupName = portName.replace("%s:" % gA2JClientName, "", 1).split(" [", 1)[0]

  792.             portShortName = portName.split("): ", 1)[1]

  793. 

  794.         else:

  795.             portShortName = portName.replace("%s:" % groupName, "", 1)

  796. 

  797.             portTypeStr = str(jacklib.port_type(portPtr), encoding="utf-8")

  798.             if portTypeStr == jacklib.JACK_DEFAULT_AUDIO_TYPE:

  799.                 portType = patchcanvas.PORT_TYPE_AUDIO_JACK

  800.             elif portTypeStr == jacklib.JACK_DEFAULT_MIDI_TYPE:

  801.                 portType = patchcanvas.PORT_TYPE_MIDI_JACK

  802.             else:

  803.                 portType = patchcanvas.PORT_TYPE_NULL

  804. 

  805.         for group in self.fGroupList:

  806.             if group[iGroupName] == groupName:

  807.                 groupId = group[iGroupId]

  808.                 break

  809.         else:

  810.             # For ports with no group

  811.             groupId = self.canvas_addJackGroup(groupName)

  812. 

  813.         patchcanvas.addPort(groupId, portId, portShortName, portMode, portType)

  814. 

  815.         portObj = [None, None, None, None]

  816.         portObj[iPortId]    = portId

  817.         portObj[iPortName]  = portName

  818.         portObj[iPortNameR] = portNameR

  819.         portObj[iPortGroupName] = groupName

  820. 

  821.         self.fPortList.append(portObj)

  822.         self.fLastPortId += 1

  823. 

  824.         if groupId not in self.fGroupSplitList and (portFlags & jacklib.JackPortIsPhysical) > 0:

  825.             patchcanvas.splitGroup(groupId)

  826.             patchcanvas.setGroupIcon(groupId, patchcanvas.ICON_HARDWARE)

  827.             self.fGroupSplitList.append(groupId)

  828. 

  829.         return portId

  830. 

  831.     def canvas_removeJackPort(self, portId):

  832.         patchcanvas.removePort(portId)

  833. 

  834.         for port in self.fPortList:

  835.             if port[iPortId] == portId:

  836.                 groupName = port[iPortGroupName]

  837.                 self.fPortList.remove(port)

  838.                 break

  839.         else:

  840.             return

  841. 

  842.         # Check if group has no more ports; if yes remove it

  843.         for port in self.fPortList:

  844.             if port[iPortGroupName] == groupName:

  845.                 break

  846.         else:

  847.             self.canvas_removeGroup(groupName)

  848. 

  849.     def canvas_renamePort(self, portId, portShortName):

  850.         patchcanvas.renamePort(portId, portShortName)

  851. 

  852.     def canvas_connectPorts(self, portOutId, portInId):

  853.         connectionId = self.fLastConnectionId

  854.         patchcanvas.connectPorts(connectionId, portOutId, portInId)

  855. 

  856.         connObj = [None, None, None]

  857.         connObj[iConnId]     = connectionId

  858.         connObj[iConnOutput] = portOutId

  859.         connObj[iConnInput]  = portInId

  860. 

  861.         self.fConnectionList.append(connObj)

  862.         self.fLastConnectionId += 1

  863. 

  864.         return connectionId

  865. 

  866.     def canvas_connectPortsByName(self, portOutName, portInName):

  867.         portOutId = -1

  868.         portInId  = -1

  869. 

  870.         for port in self.fPortList:

  871.             if port[iPortNameR] == portOutName:

  872.                 portOutId = port[iPortId]

  873.             elif port[iPortNameR] == portInName:

  874.                 portInId = port[iPortId]

  875. 

  876.             if portOutId >= 0 and portInId >= 0:

  877.                 break

  878. 

  879.         else:

  880.             print("Catia - connect jack ports failed")

  881.             return -1

  882. 

  883.         return self.canvas_connectPorts(portOutId, portInId)

  884. 

  885.     def canvas_disconnectPorts(self, portOutId, portInId):

  886.         for connection in self.fConnectionList:

  887.             if connection[iConnOutput] == portOutId and connection[iConnInput] == portInId:

  888.                 patchcanvas.disconnectPorts(connection[iConnId])

  889.                 self.fConnectionList.remove(connection)

  890.                 break

  891. 

  892.     def canvas_disconnectPortsByName(self, portOutName, portInName):

  893.         portOutId = -1

  894.         portInId  = -1

  895. 

  896.         for port in self.fPortList:

  897.             if port[iPortNameR] == portOutName:

  898.                 portOutId = port[iPortId]

  899.             elif port[iPortNameR] == portInName:

  900.                 portInId = port[iPortId]

  901. 

  902.         if portOutId == -1 or portInId == -1:

  903.             print("Catia - disconnect ports failed")

  904.             return

  905. 

  906.         self.canvas_disconnectPorts(portOutId, portInId)

  907. 

  908.     def jackStarted(self):

  909.         if not gJack.client:

  910.             gJack.client = jacklib.client_open("catia", jacklib.JackNoStartServer | jacklib.JackSessionID, None)

  911.             if not gJack.client:

  912.                 self.jackStopped()

  913.                 return False

  914. 

  915.         canRender = render.canRender()

  916. 

  917.         self.ui.act_jack_render.setEnabled(canRender)

  918.         self.ui.b_jack_render.setEnabled(canRender)

  919.         self.menuJackServer(True)

  920.         self.menuJackTransport(True)

  921. 

  922.         self.ui.cb_buffer_size.setEnabled(True)

  923.         self.ui.cb_sample_rate.setEnabled(bool(gDBus.jack)) # DBus.jack and jacksettings.getSampleRate() != -1

  924.         self.ui.menu_Jack_Buffer_Size.setEnabled(True)

  925. 

  926.         self.ui.pb_dsp_load.setMaximum(100)

  927.         self.ui.pb_dsp_load.setValue(0)

  928.         self.ui.pb_dsp_load.update()

  929. 

  930.         self.initJack()

  931. 

  932.         return True

  933. 

  934.     def jackStopped(self):

  935.         if haveDBus:

  936.             self.DBusReconnect()

  937. 

  938.         # client already closed

  939.         gJack.client = None

  940. 

  941.         # refresh canvas (remove jack ports)

  942.         patchcanvas.clear()

  943.         self.initPorts()

  944. 

  945.         if self.fNextSampleRate:

  946.             self.jack_setSampleRate(self.fNextSampleRate)

  947. 

  948.         if gDBus.jack:

  949.             bufferSize = jacksettings.getBufferSize()

  950.             sampleRate = jacksettings.getSampleRate()

  951.             bufferSizeTest = bool(bufferSize != -1)

  952.             sampleRateTest = bool(sampleRate != -1)

  953. 

  954.             if bufferSizeTest:

  955.                 self.ui_setBufferSize(bufferSize)

  956. 

  957.             if sampleRateTest:

  958.                 self.ui_setSampleRate(sampleRate)

  959. 

  960.             self.ui_setRealTime(jacksettings.isRealtime())

  961. 

  962.             self.ui.cb_buffer_size.setEnabled(bufferSizeTest)

  963.             self.ui.cb_sample_rate.setEnabled(sampleRateTest)

  964.             self.ui.menu_Jack_Buffer_Size.setEnabled(bufferSizeTest)

  965. 

  966.         else:

  967.             self.ui.cb_buffer_size.setEnabled(False)

  968.             self.ui.cb_sample_rate.setEnabled(False)

  969.             self.ui.menu_Jack_Buffer_Size.setEnabled(False)

  970. 

  971.         self.ui.act_jack_render.setEnabled(False)

  972.         self.ui.b_jack_render.setEnabled(False)

  973.         self.menuJackServer(False)

  974.         self.menuJackTransport(False)

  975.         self.ui_setXruns(-1)

  976. 

  977.         if self.fCurTransportView == TRANSPORT_VIEW_HMS:

  978.             self.ui.label_time.setText("00:00:00")

  979.         elif self.fCurTransportView == TRANSPORT_VIEW_BBT:

  980.             self.ui.label_time.setText("000|0|0000")

  981.         elif self.fCurTransportView == TRANSPORT_VIEW_FRAMES:

  982.             self.ui.label_time.setText("000'000'000")

  983. 

  984.         self.ui.pb_dsp_load.setValue(0)

  985.         self.ui.pb_dsp_load.setMaximum(0)

  986.         self.ui.pb_dsp_load.update()

  987. 

  988.     def a2jStarted(self):

  989.         self.menuA2JBridge(True)

  990. 

  991.     def a2jStopped(self):

  992.         self.menuA2JBridge(False)

  993. 

  994.     def menuJackServer(self, started):

  995.         if gDBus.jack:

  996.             self.ui.act_tools_jack_start.setEnabled(not started)

  997.             self.ui.act_tools_jack_stop.setEnabled(started)

  998.             self.menuA2JBridge(False)

  999. 

  1000.     def menuJackTransport(self, enabled):

  1001.         self.ui.act_transport_play.setEnabled(enabled)

  1002.         self.ui.act_transport_stop.setEnabled(enabled)

  1003.         self.ui.act_transport_backwards.setEnabled(enabled)

  1004.         self.ui.act_transport_forwards.setEnabled(enabled)

  1005.         self.ui.menu_Transport.setEnabled(enabled)

  1006.         self.ui.group_transport.setEnabled(enabled)

  1007. 

  1008.     def menuA2JBridge(self, started):

  1009.         if gDBus.jack and not gDBus.jack.IsStarted():

  1010.             self.ui.act_tools_a2j_start.setEnabled(False)

  1011.             self.ui.act_tools_a2j_stop.setEnabled(False)

  1012.             self.ui.act_tools_a2j_export_hw.setEnabled(gDBus.a2j and not gDBus.a2j.is_started())

  1013.         else:

  1014.             self.ui.act_tools_a2j_start.setEnabled(not started)

  1015.             self.ui.act_tools_a2j_stop.setEnabled(started)

  1016.             self.ui.act_tools_a2j_export_hw.setEnabled(not started)

  1017. 

  1018.     def DBusSignalReceiver(self, *args, **kwds):

  1019.         if kwds["interface"] == "org.freedesktop.DBus" and kwds["path"] == "/org/freedesktop/DBus" and kwds["member"] == "NameOwnerChanged":

  1020.             appInterface, appId, newId = args

  1021. 

  1022.             if not newId:

  1023.                 # Something crashed

  1024.                 if appInterface == "org.gna.home.a2jmidid":

  1025.                     QTimer.singleShot(0, self.slot_handleCrash_a2j)

  1026.                 elif appInterface == "org.jackaudio.service":

  1027.                     QTimer.singleShot(0, self.slot_handleCrash_jack)

  1028. 

  1029.         elif kwds['interface'] == "org.jackaudio.JackControl":

  1030.             if kwds['member'] == "ServerStarted":

  1031.                 self.jackStarted()

  1032.             elif kwds['member'] == "ServerStopped":

  1033.                 self.jackStopped()

  1034.         elif kwds['interface'] == "org.gna.home.a2jmidid.control":

  1035.             if kwds['member'] == "bridge_started":

  1036.                 self.a2jStarted()

  1037.             elif kwds['member'] == "bridge_stopped":

  1038.                 self.a2jStopped()

  1039. 

  1040.     def DBusReconnect(self):

  1041.         global gA2JClientName

  1042. 

  1043.         try:

  1044.             gDBus.jack = gDBus.bus.get_object("org.jackaudio.service", "/org/jackaudio/Controller")

  1045.             jacksettings.initBus(gDBus.bus)

  1046.         except:

  1047.             gDBus.jack = None

  1048. 

  1049.         try:

  1050.             gDBus.a2j = dbus.Interface(gDBus.bus.get_object("org.gna.home.a2jmidid", "/"), "org.gna.home.a2jmidid.control")

  1051.             gA2JClientName = str(gDBus.a2j.get_jack_client_name())

  1052.         except:

  1053.             gDBus.a2j = None

  1054.             gA2JClientName = None

  1055. 

  1056.     def JackXRunCallback(self, arg):

  1057.         if DEBUG: print("JackXRunCallback()")

  1058.         self.XRunCallback.emit()

  1059.         return 0

  1060. 

  1061.     def JackBufferSizeCallback(self, bufferSize, arg):

  1062.         if DEBUG: print("JackBufferSizeCallback(%i)" % bufferSize)

  1063.         self.BufferSizeCallback.emit(bufferSize)

  1064.         return 0

  1065. 

  1066.     def JackSampleRateCallback(self, sampleRate, arg):

  1067.         if DEBUG: print("JackSampleRateCallback(%i)" % sampleRate)

  1068.         self.SampleRateCallback.emit(sampleRate)

  1069.         return 0

  1070. 

  1071.     def JackClientRenameCallback(self, oldName, newName, arg):

  1072.         if DEBUG: print("JackClientRenameCallback(\"%s\", \"%s\")" % (oldName, newName))

  1073.         self.ClientRenameCallback.emit(str(oldName, encoding="utf-8"), str(newName, encoding="utf-8"))

  1074.         return 0

  1075. 

  1076.     def JackPortRegistrationCallback(self, portId, registerYesNo, arg):

  1077.         if DEBUG: print("JackPortRegistrationCallback(%i, %i)" % (portId, registerYesNo))

  1078.         self.PortRegistrationCallback.emit(portId, bool(registerYesNo))

  1079.         return 0

  1080. 

  1081.     def JackPortConnectCallback(self, portA, portB, connectYesNo, arg):

  1082.         if DEBUG: print("JackPortConnectCallback(%i, %i, %i)" % (portA, portB, connectYesNo))

  1083.         self.PortConnectCallback.emit(portA, portB, bool(connectYesNo))

  1084.         return 0

  1085. 

  1086.     def JackPortRenameCallback(self, portId, oldName, newName, arg):

  1087.         if DEBUG: print("JackPortRenameCallback(%i, \"%s\", \"%s\")" % (portId, oldName, newName))

  1088.         self.PortRenameCallback.emit(portId, str(oldName, encoding="utf-8"), str(newName, encoding="utf-8"))

  1089.         return 0

  1090. 

  1091.     def JackSessionCallback(self, event, arg):

  1092.         if WINDOWS:

  1093.             filepath = os.path.join(sys.argv[0])

  1094.         else:

  1095.             if sys.argv[0].startswith("/"):

  1096.                 filepath = "catia"

  1097.             else:

  1098.                 filepath = os.path.join(sys.path[0], "catia.py")

  1099. 

  1100.         event.command_line = str(filepath).encode("utf-8")

  1101.         jacklib.session_reply(gJack.client, event)

  1102. 

  1103.         if event.type == jacklib.JackSessionSaveAndQuit:

  1104.             app.quit()

  1105. 

  1106.             #jacklib.session_event_free(event)

  1107. 

  1108.     def JackShutdownCallback(self, arg):

  1109.         if DEBUG: print("JackShutdownCallback()")

  1110.         self.ShutdownCallback.emit()

  1111.         return 0

  1112. 

  1113.     @pyqtSlot(bool)

  1114.     def slot_showAlsaMIDI(self, yesNo):

  1115.         # refresh canvas (remove jack ports)

  1116.         patchcanvas.clear()

  1117.         self.initPorts()

  1118. 

  1119.     @pyqtSlot()

  1120.     def slot_JackServerStart(self):

  1121.         ret = False

  1122.         if gDBus.jack:

  1123.             try:

  1124.                 ret = bool(gDBus.jack.StartServer())

  1125.             except:

  1126.                 QMessageBox.warning(self, self.tr("Warning"), self.tr("Failed to start JACK, please check the logs for more information."))

  1127.                 #self.jackStopped()

  1128.         return ret

  1129. 

  1130.     @pyqtSlot()

  1131.     def slot_JackServerStop(self):

  1132.         ret = False

  1133.         if gDBus.jack:

  1134.             ret = bool(gDBus.jack.StopServer())

  1135.         return ret

  1136. 

  1137.     @pyqtSlot()

  1138.     def slot_JackClearXruns(self):

  1139.         if gJack.client:

  1140.             self.fXruns = 0

  1141.             self.ui_setXruns(0)

  1142. 

  1143.     @pyqtSlot()

  1144.     def slot_A2JBridgeStart(self):

  1145.         ret = False

  1146.         if gDBus.a2j:

  1147.             ret = bool(gDBus.a2j.start())

  1148.         return ret

  1149. 

  1150.     @pyqtSlot()

  1151.     def slot_A2JBridgeStop(self):

  1152.         ret = False

  1153.         if gDBus.a2j:

  1154.             ret = bool(gDBus.a2j.stop())

  1155.         return ret

  1156. 

  1157.     @pyqtSlot()

  1158.     def slot_A2JBridgeExportHW(self):

  1159.         if gDBus.a2j:

  1160.             ask = QMessageBox.question(self, self.tr("A2J Hardware Export"), self.tr("Enable Hardware Export on the A2J Bridge?"), QMessageBox.Yes | QMessageBox.No | QMessageBox.Cancel, QMessageBox.No)

  1161.             if ask == QMessageBox.Yes:

  1162.                 gDBus.a2j.set_hw_export(True)

  1163.             elif ask == QMessageBox.No:

  1164.                 gDBus.a2j.set_hw_export(False)

  1165. 

  1166.     @pyqtSlot()

  1167.     def slot_XRunCallback(self):

  1168.         self.fXruns += 1

  1169.         self.ui_setXruns(self.fXruns)

  1170. 

  1171.     @pyqtSlot(int)

  1172.     def slot_BufferSizeCallback(self, bufferSize):

  1173.         self.ui_setBufferSize(bufferSize)

  1174. 

  1175.     @pyqtSlot(int)

  1176.     def slot_SampleRateCallback(self, sampleRate):

  1177.         self.ui_setSampleRate(sampleRate)

  1178. 

  1179.         self.ui_setRealTime(bool(int(jacklib.is_realtime(gJack.client))))

  1180.         self.ui_setXruns(0)

  1181. 

  1182.     @pyqtSlot(str, str)

  1183.     def slot_ClientRenameCallback(self, oldName, newName):

  1184.         pass # TODO

  1185. 

  1186.     @pyqtSlot(int, bool)

  1187.     def slot_PortRegistrationCallback(self, portIdJack, registerYesNo):

  1188.         portPtr = jacklib.port_by_id(gJack.client, portIdJack)

  1189.         portNameR = str(jacklib.port_name(portPtr), encoding="utf-8")

  1190. 

  1191.         if registerYesNo:

  1192.             self.canvas_addJackPort(portPtr, portNameR)

  1193.         else:

  1194.             for port in self.fPortList:

  1195.                 if port[iPortNameR] == portNameR:

  1196.                     portIdCanvas = port[iPortId]

  1197.                     break

  1198.             else:

  1199.                 return

  1200. 

  1201.             self.canvas_removeJackPort(portIdCanvas)

  1202. 

  1203.     @pyqtSlot(int, int, bool)

  1204.     def slot_PortConnectCallback(self, portIdJackA, portIdJackB, connectYesNo):

  1205.         portPtrA = jacklib.port_by_id(gJack.client, portIdJackA)

  1206.         portPtrB = jacklib.port_by_id(gJack.client, portIdJackB)

  1207.         portRealNameA = str(jacklib.port_name(portPtrA), encoding="utf-8")

  1208.         portRealNameB = str(jacklib.port_name(portPtrB), encoding="utf-8")

  1209. 

  1210.         if connectYesNo:

  1211.             self.canvas_connectPortsByName(portRealNameA, portRealNameB)

  1212.         else:

  1213.             self.canvas_disconnectPortsByName(portRealNameA, portRealNameB)

  1214. 

  1215.     @pyqtSlot(int, str, str)

  1216.     def slot_PortRenameCallback(self, portIdJack, oldName, newName):

  1217.         portPtr = jacklib.port_by_id(gJack.client, portIdJack)

  1218.         portShortName = str(jacklib.port_short_name(portPtr), encoding="utf-8")

  1219. 

  1220.         for port in self.fPortList:

  1221.             if port[iPortNameR] == oldName:

  1222.                 portIdCanvas = port[iPortId]

  1223.                 port[iPortNameR] = newName

  1224.                 break

  1225.         else:

  1226.             return

  1227. 

  1228.         # Only set new name in canvas if no alias is active for this port

  1229.         aliases = jacklib.port_get_aliases(portPtr)

  1230.         if aliases[0] == 1 and self.fSavedSettings["Main/JackPortAlias"] == 1:

  1231.             pass

  1232.         elif aliases[0] == 2 and self.fSavedSettings["Main/JackPortAlias"] == 2:

  1233.             pass

  1234.         else:

  1235.             self.canvas_renamePort(portIdCanvas, portShortName)

  1236. 

  1237.     @pyqtSlot()

  1238.     def slot_ShutdownCallback(self):

  1239.         self.jackStopped()

  1240. 

  1241.     @pyqtSlot()

  1242.     def slot_handleCrash_a2j(self):

  1243.         global gA2JClientName

  1244. 

  1245.         try:

  1246.             gDBus.a2j = dbus.Interface(gDBus.bus.get_object("org.gna.home.a2jmidid", "/"), "org.gna.home.a2jmidid.control")

  1247.             gA2JClientName = str(gDBus.a2j.get_jack_client_name())

  1248.         except:

  1249.             gDBus.a2j = None

  1250.             gA2JClientName = None

  1251. 

  1252.         if gDBus.a2j:

  1253.             if gDBus.a2j.is_started():

  1254.                 self.a2jStarted()

  1255.             else:

  1256.                 self.a2jStopped()

  1257.         else:

  1258.             self.ui.act_tools_a2j_start.setEnabled(False)

  1259.             self.ui.act_tools_a2j_stop.setEnabled(False)

  1260.             self.ui.act_tools_a2j_export_hw.setEnabled(False)

  1261.             self.ui.menu_A2J_Bridge.setEnabled(False)

  1262. 

  1263.     @pyqtSlot()

  1264.     def slot_handleCrash_jack(self):

  1265.         self.DBusReconnect()

  1266. 

  1267.         if gDBus.jack:

  1268.             self.ui.act_jack_configure.setEnabled(True)

  1269.             self.ui.b_jack_configure.setEnabled(True)

  1270.         else:

  1271.             self.ui.act_tools_jack_start.setEnabled(False)

  1272.             self.ui.act_tools_jack_stop.setEnabled(False)

  1273.             self.ui.act_jack_configure.setEnabled(False)

  1274.             self.ui.b_jack_configure.setEnabled(False)

  1275. 

  1276.         if gDBus.a2j:

  1277.             if gDBus.a2j.is_started():

  1278.                 self.a2jStarted()

  1279.             else:

  1280.                 self.a2jStopped()

  1281.         else:

  1282.             self.ui.act_tools_a2j_start.setEnabled(False)

  1283.             self.ui.act_tools_a2j_stop.setEnabled(False)

  1284.             self.ui.act_tools_a2j_export_hw.setEnabled(False)

  1285.             self.ui.menu_A2J_Bridge.setEnabled(False)

  1286. 

  1287.         self.jackStopped()

  1288. 

  1289.     @pyqtSlot()

  1290.     def slot_configureCatia(self):

  1291.         dialog = SettingsW(self, "catia", hasGL)

  1292.         if dialog.exec_():

  1293.             self.loadSettings(False)

  1294.             patchcanvas.clear()

  1295. 

  1296.             pOptions = patchcanvas.options_t()

  1297.             pOptions.theme_name       = self.fSavedSettings["Canvas/Theme"]

  1298.             pOptions.auto_hide_groups = self.fSavedSettings["Canvas/AutoHideGroups"]

  1299.             pOptions.use_bezier_lines = self.fSavedSettings["Canvas/UseBezierLines"]

  1300.             pOptions.antialiasing     = self.fSavedSettings["Canvas/Antialiasing"]

  1301.             pOptions.eyecandy         = self.fSavedSettings["Canvas/EyeCandy"]

  1302. 

  1303.             pFeatures = patchcanvas.features_t()

  1304.             pFeatures.group_info   = False

  1305.             pFeatures.group_rename = False

  1306.             pFeatures.port_info    = True

  1307.             pFeatures.port_rename  = bool(self.fSavedSettings["Main/JackPortAlias"] > 0)

  1308.             pFeatures.handle_group_pos = True

  1309. 

  1310.             patchcanvas.setOptions(pOptions)

  1311.             patchcanvas.setFeatures(pFeatures)

  1312.             patchcanvas.init("Catia", self.scene, self.canvasCallback, DEBUG)

  1313. 

  1314.             self.initPorts()

  1315. 

  1316.     @pyqtSlot()

  1317.     def slot_aboutCatia(self):

  1318.         QMessageBox.about(self, self.tr("About Catia"), self.tr("<h3>Catia</h3>"

  1319.                                                                 "<br>Version %s"

  1320.                                                                 "<br>Catia is a nice JACK Patchbay with A2J Bridge integration.<br>"

  1321.                                                                 "<br>Copyright (C) 2010-2018 falkTX" % VERSION))

  1322. 

  1323.     def saveSettings(self):

  1324.         settings = QSettings()

  1325. 

  1326.         settings.setValue("Geometry", self.saveGeometry())

  1327.         settings.setValue("ShowAlsaMIDI", self.ui.act_settings_show_alsa.isChecked())

  1328.         settings.setValue("ShowToolbar",  self.ui.frame_toolbar.isVisible())

  1329.         settings.setValue("ShowStatusbar", self.ui.frame_statusbar.isVisible())

  1330.         settings.setValue("TransportView", self.fCurTransportView)

  1331. 

  1332.     def loadSettings(self, geometry):

  1333.         settings = QSettings()

  1334. 

  1335.         if geometry:

  1336.             self.restoreGeometry(settings.value("Geometry", b""))

  1337. 

  1338.             showAlsaMidi = settings.value("ShowAlsaMIDI", False, type=bool)

  1339.             self.ui.act_settings_show_alsa.setChecked(showAlsaMidi)

  1340. 

  1341.             showToolbar = settings.value("ShowToolbar", True, type=bool)

  1342.             self.ui.act_settings_show_toolbar.setChecked(showToolbar)

  1343.             self.ui.frame_toolbar.setVisible(showToolbar)

  1344. 

  1345.             showStatusbar = settings.value("ShowStatusbar", True, type=bool)

  1346.             self.ui.act_settings_show_statusbar.setChecked(showStatusbar)

  1347.             self.ui.frame_statusbar.setVisible(showStatusbar)

  1348. 

  1349.             self.setTransportView(settings.value("TransportView", TRANSPORT_VIEW_HMS, type=int))

  1350. 

  1351.         self.fSavedSettings = {

  1352.             "Main/RefreshInterval": settings.value("Main/RefreshInterval", 120, type=int),

  1353.             "Main/JackPortAlias": settings.value("Main/JackPortAlias", 2, type=int),

  1354.             "Canvas/Theme": settings.value("Canvas/Theme", patchcanvas.getDefaultThemeName(), type=str),

  1355.             "Canvas/AutoHideGroups": settings.value("Canvas/AutoHideGroups", False, type=bool),

  1356.             "Canvas/UseBezierLines": settings.value("Canvas/UseBezierLines", True, type=bool),

  1357.             "Canvas/EyeCandy": settings.value("Canvas/EyeCandy", patchcanvas.EYECANDY_SMALL, type=int),

  1358.             "Canvas/UseOpenGL": settings.value("Canvas/UseOpenGL", False, type=bool),

  1359.             "Canvas/Antialiasing": settings.value("Canvas/Antialiasing", patchcanvas.ANTIALIASING_SMALL, type=int),

  1360.             "Canvas/HighQualityAntialiasing": settings.value("Canvas/HighQualityAntialiasing", False, type=bool)

  1361.         }

  1362. 

  1363.     def timerEvent(self, event):

  1364.         if event.timerId() == self.fTimer120:

  1365.             if gJack.client:

  1366.                 self.refreshTransport()

  1367.         elif event.timerId() == self.fTimer600:

  1368.             if gJack.client:

  1369.                 self.refreshDSPLoad()

  1370.         QMainWindow.timerEvent(self, event)

  1371. 

  1372.     def closeEvent(self, event):

  1373.         self.saveSettings()

  1374.         patchcanvas.clear()

  1375.         QMainWindow.closeEvent(self, event)

  1376. 

  1377. # ------------------------------------------------------------------------------------------------------------

  1378. # Main

  1379. 

  1380. if __name__ == '__main__':

  1381.     # App initialization

  1382.     app = QApplication(sys.argv)

  1383.     app.setApplicationName("Catia")

  1384.     app.setApplicationVersion(VERSION)

  1385.     app.setOrganizationName("Cadence")

  1386.     app.setWindowIcon(QIcon(":/scalable/catia.svg"))

  1387. 

  1388.     if jacklib is None:

  1389.         QMessageBox.critical(None, app.translate("CatiaMainW", "Error"), app.translate("CatiaMainW",

  1390.             "JACK is not available in this system, cannot use this application."))

  1391.         sys.exit(1)

  1392. 

  1393.     if haveDBus:

  1394.         gDBus.loop = DBusQtMainLoop(set_as_default=True)

  1395.         gDBus.bus  = dbus.SessionBus(mainloop=gDBus.loop)

  1396. 

  1397.         try:

  1398.             gDBus.jack = gDBus.bus.get_object("org.jackaudio.service", "/org/jackaudio/Controller")

  1399.             jacksettings.initBus(gDBus.bus)

  1400.         except:

  1401.             gDBus.jack = None

  1402. 

  1403.         try:

  1404.             gDBus.a2j = dbus.Interface(gDBus.bus.get_object("org.gna.home.a2jmidid", "/"), "org.gna.home.a2jmidid.control")

  1405.             gA2JClientName = str(gDBus.a2j.get_jack_client_name())

  1406.         except:

  1407.             gDBus.a2j = None

  1408.             gA2JClientName = None

  1409. 

  1410.         if DEBUG and (gDBus.jack or gDBus.a2j):

  1411.             string = "Using DBus for "

  1412.             if gDBus.jack:

  1413.                 string += "JACK"

  1414.                 if gDBus.a2j:

  1415.                     string += " and a2jmidid"

  1416.             elif gDBus.a2j:

  1417.                 string += "a2jmidid"

  1418.             print(string)

  1419. 

  1420.     else:

  1421.         gDBus.jack = None

  1422.         gDBus.a2j  = None

  1423.         gA2JClientName = None

  1424.         if DEBUG:

  1425.             print("Not using DBus")

  1426. 

  1427.     # Init GUI

  1428.     gui = CatiaMainW()

  1429. 

  1430.     # Set-up custom signal handling

  1431.     setUpSignals(gui)

  1432. 

  1433.     # Show GUI

  1434.     gui.show()

  1435. 

  1436.     # App-Loop

  1437.     ret = app.exec_()

  1438. 

  1439.     # Close Jack

  1440.     if gJack.client:

  1441.         jacklib.deactivate(gJack.client)

  1442.         jacklib.client_close(gJack.client)

  1443. 

  1444.     # Exit properly

  1445.     sys.exit(ret)