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.
1081 Commits
2 Branches
142MB
Tree: c38889940e
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from 'c38889940e'
${ noResults }
Cadence/src/catia.py

1448 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. from shared_i18n import *

  26. 

  27. # ------------------------------------------------------------------------------------------------------------

  28. # Try Import DBus

  29. 

  30. try:

  31.     import dbus

  32.     from dbus.mainloop.pyqt5 import DBusQtMainLoop

  33.     haveDBus = True

  34. except:

  35.     haveDBus = False

  36. 

  37. # ------------------------------------------------------------------------------------------------------------

  38. # Try Import OpenGL

  39. 

  40. try:

  41.     from PyQt5.QtOpenGL import QGLWidget

  42.     hasGL = True

  43. except:

  44.     hasGL = False

  45. 

  46. # ------------------------------------------------------------------------------------------------------------

  47. # Check for ALSA-MIDI

  48. 

  49. haveALSA = False

  50. 

  51. if LINUX:

  52.     for iPATH in PATH:

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

  54.             continue

  55. 

  56.         haveALSA = True

  57. 

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

  59.             from subprocess import getoutput

  60.         else:

  61.             from commands import getoutput

  62. 

  63.         if DEBUG:

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

  65. 

  66.         break

  67. 

  68. # ------------------------------------------------------------------------------------------------------------

  69. # Global Variables

  70. 

  71. global gA2JClientName

  72. gA2JClientName = None

  73. 

  74. # ------------------------------------------------------------------------------------------------------------

  75. # Static Variables

  76. 

  77. GROUP_TYPE_NULL = 0

  78. GROUP_TYPE_ALSA = 1

  79. GROUP_TYPE_JACK = 2

  80. 

  81. iGroupId   = 0

  82. iGroupName = 1

  83. iGroupType = 2

  84. 

  85. iPortId    = 0

  86. iPortName  = 1

  87. iPortNameR = 2

  88. iPortGroupName = 3

  89. 

  90. iConnId     = 0

  91. iConnOutput = 1

  92. iConnInput  = 2

  93. 

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

  95. 

  96. # ------------------------------------------------------------------------------------------------------------

  97. # Catia Main Window

  98. 

  99. class CatiaMainW(AbstractCanvasJackClass):

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

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

  102. 

  103.         self.fGroupList      = []

  104.         self.fGroupSplitList = []

  105.         self.fPortList       = []

  106.         self.fConnectionList = []

  107. 

  108.         self.fLastGroupId = 1

  109.         self.fLastPortId  = 1

  110.         self.fLastConnectionId = 1

  111. 

  112.         self.loadSettings(True)

  113. 

  114.         # -------------------------------------------------------------

  115.         # Set-up GUI

  116. 

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

  118. 

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

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

  121. 

  122.         self.ui.cb_buffer_size.clear()

  123.         self.ui.cb_sample_rate.clear()

  124. 

  125.         for bufferSize in BUFFER_SIZE_LIST:

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

  127. 

  128.         for sampleRate in SAMPLE_RATE_LIST:

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

  130. 

  131.         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,

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

  133.                                     self.ui.act_jack_bf_4096, self.ui.act_jack_bf_8192)

  134. 

  135.         if not haveALSA:

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

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

  138. 

  139.         # -------------------------------------------------------------

  140.         # Set-up Canvas

  141. 

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

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

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

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

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

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

  148. 

  149.         pOptions = patchcanvas.options_t()

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

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

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

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

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

  155. 

  156.         pFeatures = patchcanvas.features_t()

  157.         pFeatures.group_info   = False

  158.         pFeatures.group_rename = False

  159.         pFeatures.port_info    = True

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

  161.         pFeatures.handle_group_pos = True

  162. 

  163.         patchcanvas.setOptions(pOptions)

  164.         patchcanvas.setFeatures(pFeatures)

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

  166. 

  167.         # -------------------------------------------------------------

  168.         # Try to connect to jack

  169. 

  170.         if self.jackStarted():

  171.             self.initAlsaPorts()

  172. 

  173.         # -------------------------------------------------------------

  174.         # Check DBus

  175. 

  176.         if haveDBus:

  177.             if gDBus.jack:

  178.                 pass

  179.             else:

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

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

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

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

  184. 

  185.             if gDBus.a2j:

  186.                 if gDBus.a2j.is_started():

  187.                     self.a2jStarted()

  188.                 else:

  189.                     self.a2jStopped()

  190.             else:

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

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

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

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

  195. 

  196.         else:

  197.             # No DBus

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

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

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

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

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

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

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

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

  206. 

  207.         # -------------------------------------------------------------

  208.         # Set-up Timers

  209. 

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

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

  212. 

  213.         # -------------------------------------------------------------

  214.         # Set-up Connections

  215. 

  216.         self.setCanvasConnections()

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

  218. 

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

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

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

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

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

  224. 

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

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

  227. 

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

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

  230. 

  231.         self.XRunCallback.connect(self.slot_XRunCallback)

  232.         self.BufferSizeCallback.connect(self.slot_BufferSizeCallback)

  233.         self.SampleRateCallback.connect(self.slot_SampleRateCallback)

  234.         self.ClientRenameCallback.connect(self.slot_ClientRenameCallback)

  235.         self.PortRegistrationCallback.connect(self.slot_PortRegistrationCallback)

  236.         self.PortConnectCallback.connect(self.slot_PortConnectCallback)

  237.         self.PortRenameCallback.connect(self.slot_PortRenameCallback)

  238.         self.ShutdownCallback.connect(self.slot_ShutdownCallback)

  239. 

  240.         # -------------------------------------------------------------

  241.         # Set-up DBus

  242. 

  243.         if gDBus.jack or gDBus.a2j:

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

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

  246. 

  247.         # -------------------------------------------------------------

  248. 

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

  250.         if action == patchcanvas.ACTION_GROUP_INFO:

  251.             pass

  252. 

  253.         elif action == patchcanvas.ACTION_GROUP_RENAME:

  254.             pass

  255. 

  256.         elif action == patchcanvas.ACTION_GROUP_SPLIT:

  257.             groupId = value1

  258.             patchcanvas.splitGroup(groupId)

  259. 

  260.         elif action == patchcanvas.ACTION_GROUP_JOIN:

  261.             groupId = value1

  262.             patchcanvas.joinGroup(groupId)

  263. 

  264.         elif action == patchcanvas.ACTION_PORT_INFO:

  265.             portId = value1

  266. 

  267.             for port in self.fPortList:

  268.                 if port[iPortId] == portId:

  269.                     portNameR = port[iPortNameR]

  270.                     portNameG = port[iPortGroupName]

  271.                     break

  272.             else:

  273.                 return

  274. 

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

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

  277. 

  278.                 flags = []

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

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

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

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

  283. 

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

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

  286. 

  287.                 info = self.tr(""

  288.                               "<table>"

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

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

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

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

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

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

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

  296. 

  297.             else:

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

  299.                 portFlags = jacklib.port_flags(portPtr)

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

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

  302. 

  303.                 aliases = jacklib.port_get_aliases(portPtr)

  304.                 if aliases[0] == 1:

  305.                     alias1text = aliases[1]

  306.                     alias2text = "(none)"

  307.                 elif aliases[0] == 2:

  308.                     alias1text = aliases[1]

  309.                     alias2text = aliases[2]

  310.                 else:

  311.                     alias1text = "(none)"

  312.                     alias2text = "(none)"

  313. 

  314.                 flags = []

  315.                 if portFlags & jacklib.JackPortIsInput:

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

  317.                 if portFlags & jacklib.JackPortIsOutput:

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

  319.                 if portFlags & jacklib.JackPortIsPhysical:

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

  321.                 if portFlags & jacklib.JackPortCanMonitor:

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

  323.                 if portFlags & jacklib.JackPortIsTerminal:

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

  325. 

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

  327. 

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

  329.                 if portTypeStr == jacklib.JACK_DEFAULT_AUDIO_TYPE:

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

  331.                 elif portTypeStr == jacklib.JACK_DEFAULT_MIDI_TYPE:

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

  333.                 else:

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

  335. 

  336.                 portLatency      = jacklib.port_get_latency(portPtr)

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

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

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

  340. 

  341.                 info = self.tr(""

  342.                                "<table>"

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

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

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

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

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

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

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

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

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

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

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

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

  355. 

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

  357. 

  358.         elif action == patchcanvas.ACTION_PORT_RENAME:

  359.             global gA2JClientName

  360. 

  361.             portId = value1

  362.             portShortName = asciiString(valueStr)

  363. 

  364.             for port in self.fPortList:

  365.                 if port[iPortId] == portId:

  366.                     portNameR = port[iPortNameR]

  367. 

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

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

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

  371.                         return

  372. 

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

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

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

  376.                     else:

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

  378.                     break

  379.             else:

  380.                 return

  381. 

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

  383.             aliases = jacklib.port_get_aliases(portPtr)

  384. 

  385.             if aliases[0] == 2:

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

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

  388. 

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

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

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

  392. 

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

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

  395. 

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

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

  398.                 jacklib.port_set_alias(portPtr, portName)

  399. 

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

  401.                 patchcanvas.renamePort(portId, portShortName)

  402. 

  403.         elif action == patchcanvas.ACTION_PORTS_CONNECT:

  404.             portIdA = value1

  405.             portIdB = value2

  406.             portRealNameA = ""

  407.             portRealNameB = ""

  408. 

  409.             for port in self.fPortList:

  410.                 if port[iPortId] == portIdA:

  411.                     portRealNameA = port[iPortNameR]

  412.                 if port[iPortId] == portIdB:

  413.                     portRealNameB = port[iPortNameR]

  414. 

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

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

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

  418. 

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

  420.                     self.canvas_connectPorts(portIdA, portIdB)

  421. 

  422.             elif portRealNameA and portRealNameB:

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

  424. 

  425.         elif action == patchcanvas.ACTION_PORTS_DISCONNECT:

  426.             connectionId = value1

  427. 

  428.             for connection in self.fConnectionList:

  429.                 if connection[iConnId] == connectionId:

  430.                     portIdA = connection[iConnOutput]

  431.                     portIdB = connection[iConnInput]

  432.                     break

  433.             else:

  434.                 return

  435. 

  436.             portRealNameA = ""

  437.             portRealNameB = ""

  438. 

  439.             for port in self.fPortList:

  440.                 if port[iPortId] == portIdA:

  441.                     portRealNameA = port[iPortNameR]

  442.                 if port[iPortId] == portIdB:

  443.                     portRealNameB = port[iPortNameR]

  444. 

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

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

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

  448. 

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

  450.                     self.canvas_disconnectPorts(portIdA, portIdB)

  451. 

  452.             elif portRealNameA and portRealNameB:

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

  454. 

  455.     def initPorts(self):

  456.         self.fGroupList      = []

  457.         self.fGroupSplitList = []

  458.         self.fPortList       = []

  459.         self.fConnectionList = []

  460. 

  461.         self.fLastGroupId = 1

  462.         self.fLastPortId  = 1

  463.         self.fLastConnectionId = 1

  464. 

  465.         self.initJackPorts()

  466.         self.initAlsaPorts()

  467. 

  468.     def initJack(self):

  469.         self.fXruns = 0

  470.         self.fNextSampleRate = 0.0

  471. 

  472.         self.fLastBPM = None

  473.         self.fLastTransportState = None

  474. 

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

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

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

  478. 

  479.         self.ui_setBufferSize(bufferSize)

  480.         self.ui_setSampleRate(sampleRate)

  481.         self.ui_setRealTime(realtime)

  482.         self.ui_setXruns(0)

  483. 

  484.         self.refreshDSPLoad()

  485.         self.refreshTransport()

  486. 

  487.         self.initJackCallbacks()

  488.         self.initJackPorts()

  489. 

  490.         self.scene.zoom_fit()

  491.         self.scene.zoom_reset()

  492. 

  493.         jacklib.activate(gJack.client)

  494. 

  495.     def initJackCallbacks(self):

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

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

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

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

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

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

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

  503. 

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

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

  506. 

  507.     def initJackPorts(self):

  508.         if not gJack.client:

  509.             return

  510. 

  511.         global gA2JClientName

  512. 

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

  514.         a2jNameList  = []

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

  516. 

  517.         h = 0

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

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

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

  521.                 a2jNameList.append(portName)

  522.                 h += 1

  523. 

  524.         for a2jName in a2jNameList:

  525.             portNameList.append(a2jName)

  526. 

  527.         del a2jNameList

  528. 

  529.         # Add jack ports

  530.         for portName in portNameList:

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

  532.             self.canvas_addJackPort(portPtr, portName)

  533. 

  534.         # Add jack connections

  535.         for portName in portNameList:

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

  537. 

  538.             # Only make connections from an output port

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

  540.                 continue

  541. 

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

  543. 

  544.             for portConName in portConnectionNames:

  545.                 self.canvas_connectPortsByName(portName, portConName)

  546. 

  547.     def initAlsaPorts(self):

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

  549.             return

  550. 

  551.         # Get ALSA MIDI ports (outputs)

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

  553.         lastGroupId   = -1

  554.         lastGroupName = ""

  555. 

  556.         for line in output:

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

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

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

  560. 

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

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

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

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

  565.                 groupName  = lineSplit2[0]

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

  567. 

  568.                 lastGroupId = self.canvas_getGroupId(groupName)

  569. 

  570.                 if lastGroupId == -1:

  571.                     # Group doesn't exist yet

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

  573. 

  574.                 lastGroupName = groupName

  575. 

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

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

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

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

  580. 

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

  582. 

  583.             else:

  584.                 lastGroupId   = -1

  585.                 lastGroupName = ""

  586. 

  587.         # Get ALSA MIDI ports (inputs)

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

  589.         lastGroupId   = -1

  590.         lastGroupName = ""

  591. 

  592.         for line in output:

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

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

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

  596. 

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

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

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

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

  601.                 groupName  = lineSplit2[0]

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

  603. 

  604.                 lastGroupId = self.canvas_getGroupId(groupName)

  605. 

  606.                 if lastGroupId == -1:

  607.                     # Group doesn't exist yet

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

  609. 

  610.                 lastGroupName = groupName

  611. 

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

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

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

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

  616. 

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

  618. 

  619.             else:

  620.                 lastGroupId   = -1

  621.                 lastGroupName = ""

  622. 

  623.         # Get ALSA MIDI connections

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

  625.         lastGroupId = -1

  626.         lastPortId  = -1

  627. 

  628.         for line in output:

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

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

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

  632. 

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

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

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

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

  637.                 groupName  = lineSplit2[0]

  638. 

  639.                 lastGroupId = self.canvas_getGroupId(groupName)

  640. 

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

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

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

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

  645. 

  646.                 for port in self.fPortList:

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

  648.                         lastPortId = port[iPortId]

  649.                         break

  650.                 else:

  651.                     lastPortId = -1

  652. 

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

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

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

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

  657. 

  658.                     for lineConn in lineConns:

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

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

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

  662. 

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

  664. 

  665.                         for port in self.fPortList:

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

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

  668.                                 break

  669. 

  670.             else:

  671.                 lastGroupId = -1

  672.                 lastPortId  = -1

  673. 

  674.     def canvas_getGroupId(self, groupName):

  675.         for group in self.fGroupList:

  676.             if group[iGroupName] == groupName:

  677.                 return group[iGroupId]

  678.         return -1

  679. 

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

  681.         groupId = self.fLastGroupId

  682. 

  683.         if hwSplit:

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

  685.         else:

  686.             patchcanvas.addGroup(groupId, groupName)

  687. 

  688.         groupObj = [None, None, None]

  689.         groupObj[iGroupId]   = groupId

  690.         groupObj[iGroupName] = groupName

  691.         groupObj[iGroupType] = GROUP_TYPE_ALSA

  692. 

  693.         self.fGroupList.append(groupObj)

  694.         self.fLastGroupId += 1

  695. 

  696.         return groupId

  697. 

  698.     def canvas_addJackGroup(self, groupName):

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

  700. 

  701.         groupId    = self.fLastGroupId

  702.         groupSplit = patchcanvas.SPLIT_UNDEF

  703.         groupIcon  = patchcanvas.ICON_APPLICATION

  704. 

  705.         if ret == 0:

  706.             iconName = voidptr2str(data)

  707.             jacklib.free(data)

  708. 

  709.             if iconName == "hardware":

  710.                 groupSplit = patchcanvas.SPLIT_YES

  711.                 groupIcon  = patchcanvas.ICON_HARDWARE

  712.             #elif iconName =="carla":

  713.                 #groupIcon = patchcanvas.ICON_CARLA

  714.             elif iconName =="distrho":

  715.                 groupIcon = patchcanvas.ICON_DISTRHO

  716.             elif iconName =="file":

  717.                 groupIcon = patchcanvas.ICON_FILE

  718.             elif iconName =="plugin":

  719.                 groupIcon = patchcanvas.ICON_PLUGIN

  720. 

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

  722. 

  723.         groupObj = [None, None, None]

  724.         groupObj[iGroupId]   = groupId

  725.         groupObj[iGroupName] = groupName

  726.         groupObj[iGroupType] = GROUP_TYPE_JACK

  727. 

  728.         self.fGroupList.append(groupObj)

  729.         self.fLastGroupId += 1

  730. 

  731.         return groupId

  732. 

  733.     def canvas_removeGroup(self, groupName):

  734.         groupId = -1

  735.         for group in self.fGroupList:

  736.             if group[iGroupName] == groupName:

  737.                 groupId = group[iGroupId]

  738.                 self.fGroupList.remove(group)

  739.                 break

  740.         else:

  741.             print(self.tr("Catia - remove group failed"))

  742.             return

  743. 

  744.         patchcanvas.removeGroup(groupId)

  745. 

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

  747.         portId   = self.fLastPortId

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

  749.         portType = patchcanvas.PORT_TYPE_MIDI_ALSA

  750. 

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

  752. 

  753.         portObj = [None, None, None, None]

  754.         portObj[iPortId]    = portId

  755.         portObj[iPortName]  = portName

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

  757.         portObj[iPortGroupName] = groupName

  758. 

  759.         self.fPortList.append(portObj)

  760.         self.fLastPortId += 1

  761. 

  762.         return portId

  763. 

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

  765.         global gA2JClientName

  766. 

  767.         portId  = self.fLastPortId

  768.         groupId = -1

  769. 

  770.         portNameR = portName

  771. 

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

  773.         if aliasN in (1, 2):

  774.             aliases = jacklib.port_get_aliases(portPtr)

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

  776.                 portName = aliases[2]

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

  778.                 portName = aliases[1]

  779. 

  780.         portFlags = jacklib.port_flags(portPtr)

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

  782. 

  783.         if portFlags & jacklib.JackPortIsInput:

  784.             portMode = patchcanvas.PORT_MODE_INPUT

  785.         elif portFlags & jacklib.JackPortIsOutput:

  786.             portMode = patchcanvas.PORT_MODE_OUTPUT

  787.         else:

  788.             portMode = patchcanvas.PORT_MODE_NULL

  789. 

  790.         if groupName == gA2JClientName:

  791.             portType  = patchcanvas.PORT_TYPE_MIDI_A2J

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

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

  794. 

  795.         else:

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

  797. 

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

  799.             if portTypeStr == jacklib.JACK_DEFAULT_AUDIO_TYPE:

  800.                 portType = patchcanvas.PORT_TYPE_AUDIO_JACK

  801.             elif portTypeStr == jacklib.JACK_DEFAULT_MIDI_TYPE:

  802.                 portType = patchcanvas.PORT_TYPE_MIDI_JACK

  803.             else:

  804.                 portType = patchcanvas.PORT_TYPE_NULL

  805. 

  806.         for group in self.fGroupList:

  807.             if group[iGroupName] == groupName:

  808.                 groupId = group[iGroupId]

  809.                 break

  810.         else:

  811.             # For ports with no group

  812.             groupId = self.canvas_addJackGroup(groupName)

  813. 

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

  815. 

  816.         portObj = [None, None, None, None]

  817.         portObj[iPortId]    = portId

  818.         portObj[iPortName]  = portName

  819.         portObj[iPortNameR] = portNameR

  820.         portObj[iPortGroupName] = groupName

  821. 

  822.         self.fPortList.append(portObj)

  823.         self.fLastPortId += 1

  824. 

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

  826.             patchcanvas.splitGroup(groupId)

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

  828.             self.fGroupSplitList.append(groupId)

  829. 

  830.         return portId

  831. 

  832.     def canvas_removeJackPort(self, portId):

  833.         patchcanvas.removePort(portId)

  834. 

  835.         for port in self.fPortList:

  836.             if port[iPortId] == portId:

  837.                 groupName = port[iPortGroupName]

  838.                 self.fPortList.remove(port)

  839.                 break

  840.         else:

  841.             return

  842. 

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

  844.         for port in self.fPortList:

  845.             if port[iPortGroupName] == groupName:

  846.                 break

  847.         else:

  848.             self.canvas_removeGroup(groupName)

  849. 

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

  851.         patchcanvas.renamePort(portId, portShortName)

  852. 

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

  854.         connectionId = self.fLastConnectionId

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

  856. 

  857.         connObj = [None, None, None]

  858.         connObj[iConnId]     = connectionId

  859.         connObj[iConnOutput] = portOutId

  860.         connObj[iConnInput]  = portInId

  861. 

  862.         self.fConnectionList.append(connObj)

  863.         self.fLastConnectionId += 1

  864. 

  865.         return connectionId

  866. 

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

  868.         portOutId = -1

  869.         portInId  = -1

  870. 

  871.         for port in self.fPortList:

  872.             if port[iPortNameR] == portOutName:

  873.                 portOutId = port[iPortId]

  874.             elif port[iPortNameR] == portInName:

  875.                 portInId = port[iPortId]

  876. 

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

  878.                 break

  879. 

  880.         else:

  881.             print(self.tr("Catia - connect jack ports failed"))

  882.             return -1

  883. 

  884.         return self.canvas_connectPorts(portOutId, portInId)

  885. 

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

  887.         for connection in self.fConnectionList:

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

  889.                 patchcanvas.disconnectPorts(connection[iConnId])

  890.                 self.fConnectionList.remove(connection)

  891.                 break

  892. 

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

  894.         portOutId = -1

  895.         portInId  = -1

  896. 

  897.         for port in self.fPortList:

  898.             if port[iPortNameR] == portOutName:

  899.                 portOutId = port[iPortId]

  900.             elif port[iPortNameR] == portInName:

  901.                 portInId = port[iPortId]

  902. 

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

  904.             print(self.tr("Catia - disconnect ports failed"))

  905.             return

  906. 

  907.         self.canvas_disconnectPorts(portOutId, portInId)

  908. 

  909.     def jackStarted(self):

  910.         if not gJack.client:

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

  912.             if not gJack.client:

  913.                 self.jackStopped()

  914.                 return False

  915. 

  916.         canRender = render.canRender()

  917. 

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

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

  920.         self.menuJackServer(True)

  921.         self.menuJackTransport(True)

  922. 

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

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

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

  926. 

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

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

  929.         self.ui.pb_dsp_load.update()

  930. 

  931.         self.initJack()

  932. 

  933.         return True

  934. 

  935.     def jackStopped(self):

  936.         if haveDBus:

  937.             self.DBusReconnect()

  938. 

  939.         # client already closed

  940.         gJack.client = None

  941. 

  942.         # refresh canvas (remove jack ports)

  943.         patchcanvas.clear()

  944.         self.initPorts()

  945. 

  946.         if self.fNextSampleRate:

  947.             self.jack_setSampleRate(self.fNextSampleRate)

  948. 

  949.         if gDBus.jack:

  950.             bufferSize = jacksettings.getBufferSize()

  951.             sampleRate = jacksettings.getSampleRate()

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

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

  954. 

  955.             if bufferSizeTest:

  956.                 self.ui_setBufferSize(bufferSize)

  957. 

  958.             if sampleRateTest:

  959.                 self.ui_setSampleRate(sampleRate)

  960. 

  961.             self.ui_setRealTime(jacksettings.isRealtime())

  962. 

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

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

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

  966. 

  967.         else:

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

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

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

  971. 

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

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

  974.         self.menuJackServer(False)

  975.         self.menuJackTransport(False)

  976.         self.ui_setXruns(-1)

  977. 

  978.         if self.fCurTransportView == TRANSPORT_VIEW_HMS:

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

  980.         elif self.fCurTransportView == TRANSPORT_VIEW_BBT:

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

  982.         elif self.fCurTransportView == TRANSPORT_VIEW_FRAMES:

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

  984. 

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

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

  987.         self.ui.pb_dsp_load.update()

  988. 

  989.     def a2jStarted(self):

  990.         self.menuA2JBridge(True)

  991. 

  992.     def a2jStopped(self):

  993.         self.menuA2JBridge(False)

  994. 

  995.     def menuJackServer(self, started):

  996.         if gDBus.jack:

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

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

  999.             self.menuA2JBridge(False)

  1000. 

  1001.     def menuJackTransport(self, enabled):

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

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

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

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

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

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

  1008. 

  1009.     def menuA2JBridge(self, started):

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

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

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

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

  1014.         else:

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

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

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

  1018. 

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

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

  1021.             appInterface, appId, newId = args

  1022. 

  1023.             if not newId:

  1024.                 # Something crashed

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

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

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

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

  1029. 

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

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

  1032.                 self.jackStarted()

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

  1034.                 self.jackStopped()

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

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

  1037.                 self.a2jStarted()

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

  1039.                 self.a2jStopped()

  1040. 

  1041.     def DBusReconnect(self):

  1042.         global gA2JClientName

  1043. 

  1044.         try:

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

  1046.             jacksettings.initBus(gDBus.bus)

  1047.         except:

  1048.             gDBus.jack = None

  1049. 

  1050.         try:

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

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

  1053.         except:

  1054.             gDBus.a2j = None

  1055.             gA2JClientName = None

  1056. 

  1057.     def JackXRunCallback(self, arg):

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

  1059.         self.XRunCallback.emit()

  1060.         return 0

  1061. 

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

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

  1064.         self.BufferSizeCallback.emit(bufferSize)

  1065.         return 0

  1066. 

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

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

  1069.         self.SampleRateCallback.emit(sampleRate)

  1070.         return 0

  1071. 

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

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

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

  1075.         return 0

  1076. 

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

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

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

  1080.         return 0

  1081. 

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

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

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

  1085.         return 0

  1086. 

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

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

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

  1090.         return 0

  1091. 

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

  1093.         if WINDOWS:

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

  1095.         else:

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

  1097.                 filepath = "catia"

  1098.             else:

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

  1100. 

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

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

  1103. 

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

  1105.             app.quit()

  1106. 

  1107.             #jacklib.session_event_free(event)

  1108. 

  1109.     def JackShutdownCallback(self, arg):

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

  1111.         self.ShutdownCallback.emit()

  1112.         return 0

  1113. 

  1114.     @pyqtSlot(bool)

  1115.     def slot_showAlsaMIDI(self, yesNo):

  1116.         # refresh canvas (remove jack ports)

  1117.         patchcanvas.clear()

  1118.         self.initPorts()

  1119. 

  1120.     @pyqtSlot()

  1121.     def slot_JackServerStart(self):

  1122.         ret = False

  1123.         if gDBus.jack:

  1124.             try:

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

  1126.             except:

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

  1128.                 #self.jackStopped()

  1129.         return ret

  1130. 

  1131.     @pyqtSlot()

  1132.     def slot_JackServerStop(self):

  1133.         ret = False

  1134.         if gDBus.jack:

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

  1136.         return ret

  1137. 

  1138.     @pyqtSlot()

  1139.     def slot_JackClearXruns(self):

  1140.         if gJack.client:

  1141.             self.fXruns = 0

  1142.             self.ui_setXruns(0)

  1143. 

  1144.     @pyqtSlot()

  1145.     def slot_A2JBridgeStart(self):

  1146.         ret = False

  1147.         if gDBus.a2j:

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

  1149.         return ret

  1150. 

  1151.     @pyqtSlot()

  1152.     def slot_A2JBridgeStop(self):

  1153.         ret = False

  1154.         if gDBus.a2j:

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

  1156.         return ret

  1157. 

  1158.     @pyqtSlot()

  1159.     def slot_A2JBridgeExportHW(self):

  1160.         if gDBus.a2j:

  1161.             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)

  1162.             if ask == QMessageBox.Yes:

  1163.                 gDBus.a2j.set_hw_export(True)

  1164.             elif ask == QMessageBox.No:

  1165.                 gDBus.a2j.set_hw_export(False)

  1166. 

  1167.     @pyqtSlot()

  1168.     def slot_XRunCallback(self):

  1169.         self.fXruns += 1

  1170.         self.ui_setXruns(self.fXruns)

  1171. 

  1172.     @pyqtSlot(int)

  1173.     def slot_BufferSizeCallback(self, bufferSize):

  1174.         self.ui_setBufferSize(bufferSize)

  1175. 

  1176.     @pyqtSlot(int)

  1177.     def slot_SampleRateCallback(self, sampleRate):

  1178.         self.ui_setSampleRate(sampleRate)

  1179. 

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

  1181.         self.ui_setXruns(0)

  1182. 

  1183.     @pyqtSlot(str, str)

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

  1185.         pass # TODO

  1186. 

  1187.     @pyqtSlot(int, bool)

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

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

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

  1191. 

  1192.         if registerYesNo:

  1193.             self.canvas_addJackPort(portPtr, portNameR)

  1194.         else:

  1195.             for port in self.fPortList:

  1196.                 if port[iPortNameR] == portNameR:

  1197.                     portIdCanvas = port[iPortId]

  1198.                     break

  1199.             else:

  1200.                 return

  1201. 

  1202.             self.canvas_removeJackPort(portIdCanvas)

  1203. 

  1204.     @pyqtSlot(int, int, bool)

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

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

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

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

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

  1210. 

  1211.         if connectYesNo:

  1212.             self.canvas_connectPortsByName(portRealNameA, portRealNameB)

  1213.         else:

  1214.             self.canvas_disconnectPortsByName(portRealNameA, portRealNameB)

  1215. 

  1216.     @pyqtSlot(int, str, str)

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

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

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

  1220. 

  1221.         for port in self.fPortList:

  1222.             if port[iPortNameR] == oldName:

  1223.                 portIdCanvas = port[iPortId]

  1224.                 port[iPortNameR] = newName

  1225.                 break

  1226.         else:

  1227.             return

  1228. 

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

  1230.         aliases = jacklib.port_get_aliases(portPtr)

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

  1232.             pass

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

  1234.             pass

  1235.         else:

  1236.             self.canvas_renamePort(portIdCanvas, portShortName)

  1237. 

  1238.     @pyqtSlot()

  1239.     def slot_ShutdownCallback(self):

  1240.         self.jackStopped()

  1241. 

  1242.     @pyqtSlot()

  1243.     def slot_handleCrash_a2j(self):

  1244.         global gA2JClientName

  1245. 

  1246.         try:

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

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

  1249.         except:

  1250.             gDBus.a2j = None

  1251.             gA2JClientName = None

  1252. 

  1253.         if gDBus.a2j:

  1254.             if gDBus.a2j.is_started():

  1255.                 self.a2jStarted()

  1256.             else:

  1257.                 self.a2jStopped()

  1258.         else:

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

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

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

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

  1263. 

  1264.     @pyqtSlot()

  1265.     def slot_handleCrash_jack(self):

  1266.         self.DBusReconnect()

  1267. 

  1268.         if gDBus.jack:

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

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

  1271.         else:

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

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

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

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

  1276. 

  1277.         if gDBus.a2j:

  1278.             if gDBus.a2j.is_started():

  1279.                 self.a2jStarted()

  1280.             else:

  1281.                 self.a2jStopped()

  1282.         else:

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

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

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

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

  1287. 

  1288.         self.jackStopped()

  1289. 

  1290.     @pyqtSlot()

  1291.     def slot_configureCatia(self):

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

  1293.         if dialog.exec_():

  1294.             self.loadSettings(False)

  1295.             patchcanvas.clear()

  1296. 

  1297.             pOptions = patchcanvas.options_t()

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

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

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

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

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

  1303. 

  1304.             pFeatures = patchcanvas.features_t()

  1305.             pFeatures.group_info   = False

  1306.             pFeatures.group_rename = False

  1307.             pFeatures.port_info    = True

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

  1309.             pFeatures.handle_group_pos = True

  1310. 

  1311.             patchcanvas.setOptions(pOptions)

  1312.             patchcanvas.setFeatures(pFeatures)

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

  1314. 

  1315.             self.initPorts()

  1316. 

  1317.     @pyqtSlot()

  1318.     def slot_aboutCatia(self):

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

  1320.                                                                 "<br>Version %s"

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

  1322.                                                                 "<br>Copyright (C) 2010-2022 falkTX" % VERSION))

  1323. 

  1324.     def saveSettings(self):

  1325.         settings = QSettings()

  1326. 

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

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

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

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

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

  1332. 

  1333.     def loadSettings(self, geometry):

  1334.         settings = QSettings()

  1335. 

  1336.         if geometry:

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

  1338. 

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

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

  1341. 

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

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

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

  1345. 

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

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

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

  1349. 

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

  1351. 

  1352.         self.fSavedSettings = {

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

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

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

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

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

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

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

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

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

  1362.         }

  1363. 

  1364.     def timerEvent(self, event):

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

  1366.             if gJack.client:

  1367.                 self.refreshTransport()

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

  1369.             if gJack.client:

  1370.                 self.refreshDSPLoad()

  1371.         QMainWindow.timerEvent(self, event)

  1372. 

  1373.     def closeEvent(self, event):

  1374.         self.saveSettings()

  1375.         patchcanvas.clear()

  1376.         QMainWindow.closeEvent(self, event)

  1377. 

  1378. # ------------------------------------------------------------------------------------------------------------

  1379. # Main

  1380. 

  1381. if __name__ == '__main__':

  1382.     # App initialization

  1383.     app = QApplication(sys.argv)

  1384.     app.setApplicationName("Catia")

  1385.     app.setApplicationVersion(VERSION)

  1386.     app.setOrganizationName("Cadence")

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

  1388.     setup_i18n()

  1389. 

  1390.     if jacklib is None:

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

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

  1393.         sys.exit(1)

  1394. 

  1395.     if haveDBus:

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

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

  1398. 

  1399.         try:

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

  1401.             jacksettings.initBus(gDBus.bus)

  1402.         except:

  1403.             gDBus.jack = None

  1404. 

  1405.         try:

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

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

  1408.         except:

  1409.             gDBus.a2j = None

  1410.             gA2JClientName = None

  1411. 

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

  1413.             string = "Using DBus for "

  1414.             if gDBus.jack:

  1415.                 string += "JACK"

  1416.                 if gDBus.a2j:

  1417.                     string += " and a2jmidid"

  1418.             elif gDBus.a2j:

  1419.                 string += "a2jmidid"

  1420.             print(string)

  1421. 

  1422.     else:

  1423.         gDBus.jack = None

  1424.         gDBus.a2j  = None

  1425.         gA2JClientName = None

  1426.         if DEBUG:

  1427.             print("Not using DBus")

  1428. 

  1429.     # Init GUI

  1430.     gui = CatiaMainW()

  1431. 

  1432.     # Set-up custom signal handling

  1433.     setUpSignals(gui)

  1434. 

  1435.     # Show GUI

  1436.     gui.show()

  1437. 

  1438.     # App-Loop

  1439.     ret = app.exec_()

  1440. 

  1441.     # Close Jack

  1442.     if gJack.client:

  1443.         jacklib.deactivate(gJack.client)

  1444.         jacklib.client_close(gJack.client)

  1445. 

  1446.     # Exit properly

  1447.     sys.exit(ret)