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

1451 lines
55KB
Raw Blame History 

  1. #!/usr/bin/env python3

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

  3. 

  4. # JACK Patchbay

  5. # Copyright (C) 2010-2013 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 (Global)

  21. 

  22. from PyQt4.QtGui import QApplication

  23. 

  24. # ------------------------------------------------------------------------------------------------------------

  25. # Imports (Custom Stuff)

  26. 

  27. import ui_catia

  28. from shared_canvasjack import *

  29. from shared_settings import *

  30. 

  31. # ------------------------------------------------------------------------------------------------------------

  32. # Try Import DBus

  33. 

  34. try:

  35.     import dbus

  36.     from dbus.mainloop.qt import DBusQtMainLoop

  37.     haveDBus = True

  38. except:

  39.     haveDBus = False

  40. 

  41. # ------------------------------------------------------------------------------------------------------------

  42. # Try Import OpenGL

  43. 

  44. try:

  45.     from PyQt4.QtOpenGL import QGLWidget

  46.     hasGL = True

  47. except:

  48.     hasGL = False

  49. 

  50. # ------------------------------------------------------------------------------------------------------------

  51. # Check for ALSA-MIDI

  52. 

  53. haveALSA = False

  54. 

  55. if LINUX:

  56.     for iPATH in PATH:

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

  58.             continue

  59. 

  60.         haveALSA = True

  61. 

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

  63.             from subprocess import getoutput

  64.         else:

  65.             from commands import getoutput

  66. 

  67.         if DEBUG:

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

  69. 

  70.         break

  71. 

  72. # ------------------------------------------------------------------------------------------------------------

  73. # Global Variables

  74. 

  75. global gA2JClientName

  76. gA2JClientName = None

  77. 

  78. # ------------------------------------------------------------------------------------------------------------

  79. # Static Variables

  80. 

  81. GROUP_TYPE_NULL = 0

  82. GROUP_TYPE_ALSA = 1

  83. GROUP_TYPE_JACK = 2

  84. 

  85. iGroupId   = 0

  86. iGroupName = 1

  87. iGroupType = 2

  88. 

  89. iPortId    = 0

  90. iPortName  = 1

  91. iPortNameR = 2

  92. iPortGroupName = 3

  93. 

  94. iConnId     = 0

  95. iConnOutput = 1

  96. iConnInput  = 2

  97. 

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

  99. 

  100. # ------------------------------------------------------------------------------------------------------------

  101. # Catia Main Window

  102. 

  103. class CatiaMainW(AbstractCanvasJackClass):

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

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

  106. 

  107.         self.fGroupList      = []

  108.         self.fGroupSplitList = []

  109.         self.fPortList       = []

  110.         self.fConnectionList = []

  111. 

  112.         self.fLastGroupId = 1

  113.         self.fLastPortId  = 1

  114.         self.fLastConnectionId = 1

  115. 

  116.         self.loadSettings(True)

  117. 

  118.         # -------------------------------------------------------------

  119.         # Set-up GUI

  120. 

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

  122. 

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

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

  125. 

  126.         self.ui.cb_buffer_size.clear()

  127.         self.ui.cb_sample_rate.clear()

  128. 

  129.         for bufferSize in BUFFER_SIZE_LIST:

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

  131. 

  132.         for sampleRate in SAMPLE_RATE_LIST:

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

  134. 

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

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

  137.                                     self.ui.act_jack_bf_4096, self.ui.act_jack_bf_8192)

  138. 

  139.         if not haveALSA:

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

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

  142. 

  143.         # -------------------------------------------------------------

  144.         # Set-up Canvas

  145. 

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

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

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

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

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

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

  152. 

  153.         pOptions = patchcanvas.options_t()

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

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

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

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

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

  159. 

  160.         pFeatures = patchcanvas.features_t()

  161.         pFeatures.group_info   = False

  162.         pFeatures.group_rename = False

  163.         pFeatures.port_info    = True

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

  165.         pFeatures.handle_group_pos = True

  166. 

  167.         patchcanvas.setOptions(pOptions)

  168.         patchcanvas.setFeatures(pFeatures)

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

  170. 

  171.         # -------------------------------------------------------------

  172.         # Try to connect to jack

  173. 

  174.         if self.jackStarted():

  175.             self.init_alsaPorts()

  176. 

  177.         # -------------------------------------------------------------

  178.         # Check DBus

  179. 

  180.         if haveDBus:

  181.             if gDBus.jack:

  182.                 pass

  183.             else:

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

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

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

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

  188. 

  189.             if gDBus.a2j:

  190.                 if gDBus.a2j.is_started():

  191.                     self.a2jStarted()

  192.                 else:

  193.                     self.a2jStopped()

  194.             else:

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

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

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

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

  199. 

  200.         else:

  201.             # No DBus

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

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

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

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

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

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

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

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

  210. 

  211.         # -------------------------------------------------------------

  212.         # Set-up Timers

  213. 

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

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

  216. 

  217.         # -------------------------------------------------------------

  218.         # Set-up Connections

  219. 

  220.         self.setCanvasConnections()

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

  222. 

  223.         self.connect(self.ui.act_tools_jack_start, SIGNAL("triggered()"), SLOT("slot_JackServerStart()"))

  224.         self.connect(self.ui.act_tools_jack_stop, SIGNAL("triggered()"), SLOT("slot_JackServerStop()"))

  225.         self.connect(self.ui.act_tools_a2j_start, SIGNAL("triggered()"), SLOT("slot_A2JBridgeStart()"))

  226.         self.connect(self.ui.act_tools_a2j_stop, SIGNAL("triggered()"), SLOT("slot_A2JBridgeStop()"))

  227.         self.connect(self.ui.act_tools_a2j_export_hw, SIGNAL("triggered()"), SLOT("slot_A2JBridgeExportHW()"))

  228. 

  229.         self.connect(self.ui.act_settings_show_alsa, SIGNAL("triggered(bool)"), SLOT("slot_showAlsaMIDI(bool)"))

  230.         self.connect(self.ui.act_configure, SIGNAL("triggered()"), SLOT("slot_configureCatia()"))

  231. 

  232.         self.connect(self.ui.act_help_about, SIGNAL("triggered()"), SLOT("slot_aboutCatia()"))

  233.         self.connect(self.ui.act_help_about_qt, SIGNAL("triggered()"), app, SLOT("aboutQt()"))

  234. 

  235.         self.connect(self, SIGNAL("XRunCallback()"), SLOT("slot_XRunCallback()"))

  236.         self.connect(self, SIGNAL("BufferSizeCallback(int)"), SLOT("slot_BufferSizeCallback(int)"))

  237.         self.connect(self, SIGNAL("SampleRateCallback(int)"), SLOT("slot_SampleRateCallback(int)"))

  238.         self.connect(self, SIGNAL("ClientRenameCallback(QString, QString)"), SLOT("slot_ClientRenameCallback(QString, QString)"))

  239.         self.connect(self, SIGNAL("PortRegistrationCallback(int, bool)"), SLOT("slot_PortRegistrationCallback(int, bool)"))

  240.         self.connect(self, SIGNAL("PortConnectCallback(int, int, bool)"), SLOT("slot_PortConnectCallback(int, int, bool)"))

  241.         self.connect(self, SIGNAL("PortRenameCallback(int, QString, QString)"), SLOT("slot_PortRenameCallback(int, QString, QString)"))

  242.         self.connect(self, SIGNAL("ShutdownCallback()"), SLOT("slot_ShutdownCallback()"))

  243. 

  244.         # -------------------------------------------------------------

  245.         # Set-up DBus

  246. 

  247.         if gDBus.jack or gDBus.a2j:

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

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

  250. 

  251.         # -------------------------------------------------------------

  252. 

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

  254.         if action == patchcanvas.ACTION_GROUP_INFO:

  255.             pass

  256. 

  257.         elif action == patchcanvas.ACTION_GROUP_RENAME:

  258.             pass

  259. 

  260.         elif action == patchcanvas.ACTION_GROUP_SPLIT:

  261.             groupId = value1

  262.             patchcanvas.splitGroup(groupId)

  263. 

  264.         elif action == patchcanvas.ACTION_GROUP_JOIN:

  265.             groupId = value1

  266.             patchcanvas.joinGroup(groupId)

  267. 

  268.         elif action == patchcanvas.ACTION_PORT_INFO:

  269.             portId = value1

  270. 

  271.             for port in self.fPortList:

  272.                 if port[iPortId] == portId:

  273.                     portNameR = port[iPortNameR]

  274.                     portNameG = port[iPortGroupName]

  275.                     break

  276.             else:

  277.                 return

  278. 

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

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

  281. 

  282.                 flags = []

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

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

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

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

  287. 

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

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

  290. 

  291.                 info = self.tr(""

  292.                               "<table>"

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

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

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

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

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

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

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

  300. 

  301.             else:

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

  303.                 portFlags = jacklib.port_flags(portPtr)

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

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

  306. 

  307.                 aliases = jacklib.port_get_aliases(portPtr)

  308.                 if aliases[0] == 1:

  309.                     alias1text = aliases[1]

  310.                     alias2text = "(none)"

  311.                 elif aliases[0] == 2:

  312.                     alias1text = aliases[1]

  313.                     alias2text = aliases[2]

  314.                 else:

  315.                     alias1text = "(none)"

  316.                     alias2text = "(none)"

  317. 

  318.                 flags = []

  319.                 if portFlags & jacklib.JackPortIsInput:

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

  321.                 if portFlags & jacklib.JackPortIsOutput:

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

  323.                 if portFlags & jacklib.JackPortIsPhysical:

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

  325.                 if portFlags & jacklib.JackPortCanMonitor:

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

  327.                 if portFlags & jacklib.JackPortIsTerminal:

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

  329. 

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

  331. 

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

  333.                 if portTypeStr == jacklib.JACK_DEFAULT_AUDIO_TYPE:

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

  335.                 elif portTypeStr == jacklib.JACK_DEFAULT_MIDI_TYPE:

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

  337.                 else:

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

  339. 

  340.                 portLatency      = jacklib.port_get_latency(portPtr)

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

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

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

  344. 

  345.                 info = self.tr(""

  346.                                "<table>"

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

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

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

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

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

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

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

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

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

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

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

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

  359. 

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

  361. 

  362.         elif action == patchcanvas.ACTION_PORT_RENAME:

  363.             global gA2JClientName

  364. 

  365.             portId = value1

  366.             portShortName = asciiString(valueStr)

  367. 

  368.             for port in self.fPortList:

  369.                 if port[iPortId] == portId:

  370.                     portNameR = port[iPortNameR]

  371. 

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

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

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

  375.                         return

  376. 

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

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

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

  380.                     else:

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

  382.                     break

  383.             else:

  384.                 return

  385. 

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

  387.             aliases = jacklib.port_get_aliases(portPtr)

  388. 

  389.             if aliases[0] == 2:

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

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

  392. 

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

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

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

  396. 

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

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

  399. 

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

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

  402.                 jacklib.port_set_alias(portPtr, portName)

  403. 

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

  405.                 patchcanvas.renamePort(portId, portShortName)

  406. 

  407.         elif action == patchcanvas.ACTION_PORTS_CONNECT:

  408.             portIdA = value1

  409.             portIdB = value2

  410.             portRealNameA = ""

  411.             portRealNameB = ""

  412. 

  413.             for port in self.fPortList:

  414.                 if port[iPortId] == portIdA:

  415.                     portRealNameA = port[iPortNameR]

  416.                 if port[iPortId] == portIdB:

  417.                     portRealNameB = port[iPortNameR]

  418. 

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

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

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

  422. 

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

  424.                     self.canvas_connectPorts(portIdA, portIdB)

  425. 

  426.             elif portRealNameA and portRealNameB:

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

  428. 

  429.         elif action == patchcanvas.ACTION_PORTS_DISCONNECT:

  430.             connectionId = value1

  431. 

  432.             for connection in self.fConnectionList:

  433.                 if connection[iConnId] == connectionId:

  434.                     portIdA = connection[iConnOutput]

  435.                     portIdB = connection[iConnInput]

  436.                     break

  437.             else:

  438.                 return

  439. 

  440.             portRealNameA = ""

  441.             portRealNameB = ""

  442. 

  443.             for port in self.fPortList:

  444.                 if port[iPortId] == portIdA:

  445.                     portRealNameA = port[iPortNameR]

  446.                 if port[iPortId] == portIdB:

  447.                     portRealNameB = port[iPortNameR]

  448. 

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

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

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

  452. 

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

  454.                     self.canvas_disconnectPorts(portIdA, portIdB)

  455. 

  456.             elif portRealNameA and portRealNameB:

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

  458. 

  459.     def init_ports(self):

  460.         self.fGroupList      = []

  461.         self.fGroupSplitList = []

  462.         self.fPortList       = []

  463.         self.fConnectionList = []

  464. 

  465.         self.fLastGroupId = 1

  466.         self.fLastPortId  = 1

  467.         self.fLastConnectionId = 1

  468. 

  469.         self.init_jackPorts()

  470.         self.init_alsaPorts()

  471. 

  472.     def init_jack(self):

  473.         self.fXruns = 0

  474.         self.fNextSampleRate = 0.0

  475. 

  476.         self.fLastBPM = None

  477.         self.fLastTransportState = None

  478. 

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

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

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

  482. 

  483.         self.ui_setBufferSize(bufferSize)

  484.         self.ui_setSampleRate(sampleRate)

  485.         self.ui_setRealTime(realtime)

  486.         self.ui_setXruns(0)

  487. 

  488.         self.refreshDSPLoad()

  489.         self.refreshTransport()

  490. 

  491.         self.init_jackCallbacks()

  492.         self.init_jackPorts()

  493. 

  494.         self.scene.zoom_fit()

  495.         self.scene.zoom_reset()

  496. 

  497.         jacklib.activate(gJack.client)

  498. 

  499.     def init_jackCallbacks(self):

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

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

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

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

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

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

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

  507. 

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

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

  510. 

  511.     def init_jackPorts(self):

  512.         if not gJack.client:

  513.             return

  514. 

  515.         global gA2JClientName

  516. 

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

  518.         a2jNameList  = []

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

  520. 

  521.         h = 0

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

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

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

  525.                 a2jNameList.append(portName)

  526.                 h += 1

  527. 

  528.         for a2jName in a2jNameList:

  529.             portNameList.append(a2jName)

  530. 

  531.         del a2jNameList

  532. 

  533.         # Add jack ports

  534.         for portName in portNameList:

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

  536.             self.canvas_addJackPort(portPtr, portName)

  537. 

  538.         # Add jack connections

  539.         for portName in portNameList:

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

  541. 

  542.             # Only make connections from an output port

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

  544.                 continue

  545. 

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

  547. 

  548.             for portConName in portConnectionNames:

  549.                 self.canvas_connectPortsByName(portName, portConName)

  550. 

  551.     def init_alsaPorts(self):

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

  553.             return

  554. 

  555.         # Get ALSA MIDI ports (outputs)

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

  557.         lastGroupId   = -1

  558.         lastGroupName = ""

  559. 

  560.         for line in output:

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

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

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

  564. 

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

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

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

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

  569.                 groupName  = lineSplit2[0]

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

  571. 

  572.                 lastGroupId = self.canvas_getGroupId(groupName)

  573. 

  574.                 if lastGroupId == -1:

  575.                     # Group doesn't exist yet

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

  577. 

  578.                 lastGroupName = groupName

  579. 

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

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

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

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

  584. 

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

  586. 

  587.             else:

  588.                 lastGroupId   = -1

  589.                 lastGroupName = ""

  590. 

  591.         # Get ALSA MIDI ports (inputs)

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

  593.         lastGroupId   = -1

  594.         lastGroupName = ""

  595. 

  596.         for line in output:

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

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

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

  600. 

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

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

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

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

  605.                 groupName  = lineSplit2[0]

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

  607. 

  608.                 lastGroupId = self.canvas_getGroupId(groupName)

  609. 

  610.                 if lastGroupId == -1:

  611.                     # Group doesn't exist yet

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

  613. 

  614.                 lastGroupName = groupName

  615. 

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

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

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

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

  620. 

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

  622. 

  623.             else:

  624.                 lastGroupId   = -1

  625.                 lastGroupName = ""

  626. 

  627.         # Get ALSA MIDI connections

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

  629.         lastGroupId = -1

  630.         lastPortId  = -1

  631. 

  632.         for line in output:

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

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

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

  636. 

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

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

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

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

  641.                 groupName  = lineSplit2[0]

  642. 

  643.                 lastGroupId = self.canvas_getGroupId(groupName)

  644. 

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

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

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

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

  649. 

  650.                 for port in self.fPortList:

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

  652.                         lastPortId = port[iPortId]

  653.                         break

  654.                 else:

  655.                     lastPortId = -1

  656. 

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

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

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

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

  661. 

  662.                     for lineConn in lineConns:

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

  664.                         alsaGroupId   = int(lineConnSplit[0])

  665.                         alsaPortId    = int(lineConnSplit[1])

  666. 

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

  668. 

  669.                         for port in self.fPortList:

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

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

  672.                                 break

  673. 

  674.             else:

  675.                 lastGroupId = -1

  676.                 lastPortId  = -1

  677. 

  678.     def canvas_getGroupId(self, groupName):

  679.         for group in self.fGroupList:

  680.             if group[iGroupName] == groupName:

  681.                 return group[iGroupId]

  682.         return -1

  683. 

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

  685.         groupId = self.fLastGroupId

  686. 

  687.         if hwSplit:

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

  689.         else:

  690.             patchcanvas.addGroup(groupId, groupName)

  691. 

  692.         groupObj = [None, None, None]

  693.         groupObj[iGroupId]   = groupId

  694.         groupObj[iGroupName] = groupName

  695.         groupObj[iGroupType] = GROUP_TYPE_ALSA

  696. 

  697.         self.fGroupList.append(groupObj)

  698.         self.fLastGroupId += 1

  699. 

  700.         return groupId

  701. 

  702.     def canvas_addJackGroup(self, groupName):

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

  704. 

  705.         groupId    = self.fLastGroupId

  706.         groupSplit = patchcanvas.SPLIT_UNDEF

  707.         groupIcon  = patchcanvas.ICON_APPLICATION

  708. 

  709.         if ret == 0:

  710.             iconName = voidptr2str(data)

  711.             jacklib.free(data)

  712. 

  713.             if iconName == "hardware":

  714.                 groupSplit = patchcanvas.SPLIT_YES

  715.                 groupIcon  = patchcanvas.ICON_HARDWARE

  716.             #elif iconName =="carla":

  717.                 #groupIcon = patchcanvas.ICON_CARLA

  718.             elif iconName =="distrho":

  719.                 groupIcon = patchcanvas.ICON_DISTRHO

  720.             elif iconName =="file":

  721.                 groupIcon = patchcanvas.ICON_FILE

  722.             elif iconName =="plugin":

  723.                 groupIcon = patchcanvas.ICON_PLUGIN

  724. 

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

  726. 

  727.         groupObj = [None, None, None]

  728.         groupObj[iGroupId]   = groupId

  729.         groupObj[iGroupName] = groupName

  730.         groupObj[iGroupType] = GROUP_TYPE_JACK

  731. 

  732.         self.fGroupList.append(groupObj)

  733.         self.fLastGroupId += 1

  734. 

  735.         return groupId

  736. 

  737.     def canvas_removeGroup(self, groupName):

  738.         groupId = -1

  739.         for group in self.fGroupList:

  740.             if group[iGroupName] == groupName:

  741.                 groupId = group[iGroupId]

  742.                 self.fGroupList.remove(group)

  743.                 break

  744.         else:

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

  746.             return

  747. 

  748.         patchcanvas.removeGroup(groupId)

  749. 

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

  751.         portId   = self.fLastPortId

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

  753.         portType = patchcanvas.PORT_TYPE_MIDI_ALSA

  754. 

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

  756. 

  757.         portObj = [None, None, None, None]

  758.         portObj[iPortId]    = portId

  759.         portObj[iPortName]  = portName

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

  761.         portObj[iPortGroupName] = groupName

  762. 

  763.         self.fPortList.append(portObj)

  764.         self.fLastPortId += 1

  765. 

  766.         return portId

  767. 

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

  769.         global gA2JClientName

  770. 

  771.         portId  = self.fLastPortId

  772.         groupId = -1

  773. 

  774.         portNameR = portName

  775. 

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

  777.         if aliasN in (1, 2):

  778.             aliases = jacklib.port_get_aliases(portPtr)

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

  780.                 portName = aliases[2]

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

  782.                 portName = aliases[1]

  783. 

  784.         portFlags = jacklib.port_flags(portPtr)

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

  786. 

  787.         if portFlags & jacklib.JackPortIsInput:

  788.             portMode = patchcanvas.PORT_MODE_INPUT

  789.         elif portFlags & jacklib.JackPortIsOutput:

  790.             portMode = patchcanvas.PORT_MODE_OUTPUT

  791.         else:

  792.             portMode = patchcanvas.PORT_MODE_NULL

  793. 

  794.         if groupName == gA2JClientName:

  795.             portType  = patchcanvas.PORT_TYPE_MIDI_A2J

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

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

  798. 

  799.         else:

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

  801. 

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

  803.             if portTypeStr == jacklib.JACK_DEFAULT_AUDIO_TYPE:

  804.                 portType = patchcanvas.PORT_TYPE_AUDIO_JACK

  805.             elif portTypeStr == jacklib.JACK_DEFAULT_MIDI_TYPE:

  806.                 portType = patchcanvas.PORT_TYPE_MIDI_JACK

  807.             else:

  808.                 portType = patchcanvas.PORT_TYPE_NULL

  809. 

  810.         for group in self.fGroupList:

  811.             if group[iGroupName] == groupName:

  812.                 groupId = group[iGroupId]

  813.                 break

  814.         else:

  815.             # For ports with no group

  816.             groupId = self.canvas_addJackGroup(groupName)

  817. 

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

  819. 

  820.         portObj = [None, None, None, None]

  821.         portObj[iPortId]    = portId

  822.         portObj[iPortName]  = portName

  823.         portObj[iPortNameR] = portNameR

  824.         portObj[iPortGroupName] = groupName

  825. 

  826.         self.fPortList.append(portObj)

  827.         self.fLastPortId += 1

  828. 

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

  830.             patchcanvas.splitGroup(groupId)

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

  832.             self.fGroupSplitList.append(groupId)

  833. 

  834.         return portId

  835. 

  836.     def canvas_removeJackPort(self, portId):

  837.         patchcanvas.removePort(portId)

  838. 

  839.         for port in self.fPortList:

  840.             if port[iPortId] == portId:

  841.                 groupName = port[iPortGroupName]

  842.                 self.fPortList.remove(port)

  843.                 break

  844.         else:

  845.             return

  846. 

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

  848.         for port in self.fPortList:

  849.             if port[iPortGroupName] == groupName:

  850.                 break

  851.         else:

  852.             self.canvas_removeGroup(groupName)

  853. 

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

  855.         patchcanvas.renamePort(portId, portShortName)

  856. 

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

  858.         connectionId = self.fLastConnectionId

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

  860. 

  861.         connObj = [None, None, None]

  862.         connObj[iConnId]     = connectionId

  863.         connObj[iConnOutput] = portOutId

  864.         connObj[iConnInput]  = portInId

  865. 

  866.         self.fConnectionList.append(connObj)

  867.         self.fLastConnectionId += 1

  868. 

  869.         return connectionId

  870. 

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

  872.         portOutId = -1

  873.         portInId  = -1

  874. 

  875.         for port in self.fPortList:

  876.             if port[iPortNameR] == portOutName:

  877.                 portOutId = port[iPortId]

  878.             elif port[iPortNameR] == portInName:

  879.                 portInId = port[iPortId]

  880. 

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

  882.                 break

  883. 

  884.         else:

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

  886.             return -1

  887. 

  888.         return self.canvas_connectPorts(portOutId, portInId)

  889. 

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

  891.         for connection in self.fConnectionList:

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

  893.                 patchcanvas.disconnectPorts(connection[iConnId])

  894.                 self.fConnectionList.remove(connection)

  895.                 break

  896. 

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

  898.         portOutId = -1

  899.         portInId  = -1

  900. 

  901.         for port in self.fPortList:

  902.             if port[iPortNameR] == portOutName:

  903.                 portOutId = port[iPortId]

  904.             elif port[iPortNameR] == portInName:

  905.                 portInId = port[iPortId]

  906. 

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

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

  909.             return

  910. 

  911.         self.canvas_disconnectPorts(portOutId, portInId)

  912. 

  913.     def jackStarted(self):

  914.         if not gJack.client:

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

  916.             if not gJack.client:

  917.                 self.jackStopped()

  918.                 return False

  919. 

  920.         canRender = render.canRender()

  921. 

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

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

  924.         self.menuJackServer(True)

  925.         self.menuJackTransport(True)

  926. 

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

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

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

  930. 

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

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

  933.         self.ui.pb_dsp_load.update()

  934. 

  935.         self.init_jack()

  936. 

  937.         return True

  938. 

  939.     def jackStopped(self):

  940.         if haveDBus:

  941.             self.DBusReconnect()

  942. 

  943.         # client already closed

  944.         gJack.client = None

  945. 

  946.         # refresh canvas (remove jack ports)

  947.         patchcanvas.clear()

  948.         self.init_ports()

  949. 

  950.         if self.fNextSampleRate:

  951.             self.jack_setSampleRate(self.fNextSampleRate)

  952. 

  953.         if gDBus.jack:

  954.             bufferSize = jacksettings.getBufferSize()

  955.             sampleRate = jacksettings.getSampleRate()

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

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

  958. 

  959.             if bufferSizeTest:

  960.                 self.ui_setBufferSize(bufferSize)

  961. 

  962.             if sampleRateTest:

  963.                 self.ui_setSampleRate(sampleRate)

  964. 

  965.             self.ui_setRealTime(jacksettings.isRealtime())

  966. 

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

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

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

  970. 

  971.         else:

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

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

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

  975. 

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

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

  978.         self.menuJackServer(False)

  979.         self.menuJackTransport(False)

  980.         self.ui_setXruns(-1)

  981. 

  982.         if self.fCurTransportView == TRANSPORT_VIEW_HMS:

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

  984.         elif self.fCurTransportView == TRANSPORT_VIEW_BBT:

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

  986.         elif self.fCurTransportView == TRANSPORT_VIEW_FRAMES:

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

  988. 

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

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

  991.         self.ui.pb_dsp_load.update()

  992. 

  993.     def a2jStarted(self):

  994.         self.menuA2JBridge(True)

  995. 

  996.     def a2jStopped(self):

  997.         self.menuA2JBridge(False)

  998. 

  999.     def menuJackServer(self, started):

  1000.         if gDBus.jack:

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

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

  1003.             self.menuA2JBridge(False)

  1004. 

  1005.     def menuJackTransport(self, enabled):

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

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

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

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

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

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

  1012. 

  1013.     def menuA2JBridge(self, started):

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

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

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

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

  1018.         else:

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

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

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

  1022. 

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

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

  1025.             appInterface, appId, newId = args

  1026. 

  1027.             if not newId:

  1028.                 # Something crashed

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

  1030.                     QTimer.singleShot(0, self, SLOT("slot_handleCrash_a2j()"))

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

  1032.                     QTimer.singleShot(0, self, SLOT("slot_handleCrash_jack()"))

  1033. 

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

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

  1036.                 self.jackStarted()

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

  1038.                 self.jackStopped()

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

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

  1041.                 self.a2jStarted()

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

  1043.                 self.a2jStopped()

  1044. 

  1045.     def DBusReconnect(self):

  1046.         global gA2JClientName

  1047. 

  1048.         try:

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

  1050.             jacksettings.initBus(gDBus.bus)

  1051.         except:

  1052.             gDBus.jack = None

  1053. 

  1054.         try:

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

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

  1057.         except:

  1058.             gDBus.a2j = None

  1059.             gA2JClientName = None

  1060. 

  1061.     def JackXRunCallback(self, arg):

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

  1063.         self.emit(SIGNAL("XRunCallback()"))

  1064.         return 0

  1065. 

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

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

  1068.         self.emit(SIGNAL("BufferSizeCallback(int)"), bufferSize)

  1069.         return 0

  1070. 

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

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

  1073.         self.emit(SIGNAL("SampleRateCallback(int)"), sampleRate)

  1074.         return 0

  1075. 

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

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

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

  1079.         return 0

  1080. 

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

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

  1083.         self.emit(SIGNAL("PortRegistrationCallback(int, bool)"), portId, bool(registerYesNo))

  1084.         return 0

  1085. 

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

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

  1088.         self.emit(SIGNAL("PortConnectCallback(int, int, bool)"), portA, portB, bool(connectYesNo))

  1089.         return 0

  1090. 

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

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

  1093.         self.emit(SIGNAL("PortRenameCallback(int, QString, QString)"), portId, str(oldName, encoding="utf-8"), str(newName, encoding="utf-8"))

  1094.         return 0

  1095. 

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

  1097.         if WINDOWS:

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

  1099.         else:

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

  1101.                 filepath = "catia"

  1102.             else:

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

  1104. 

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

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

  1107. 

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

  1109.             app.quit()

  1110. 

  1111.             #jacklib.session_event_free(event)

  1112. 

  1113.     def JackShutdownCallback(self, arg):

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

  1115.         self.emit(SIGNAL("ShutdownCallback()"))

  1116.         return 0

  1117. 

  1118.     @pyqtSlot(bool)

  1119.     def slot_showAlsaMIDI(self, yesNo):

  1120.         # refresh canvas (remove jack ports)

  1121.         patchcanvas.clear()

  1122.         self.init_ports()

  1123. 

  1124.     @pyqtSlot()

  1125.     def slot_JackServerStart(self):

  1126.         ret = False

  1127.         if gDBus.jack:

  1128.             try:

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

  1130.             except:

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

  1132.                 #self.jackStopped()

  1133.         return ret

  1134. 

  1135.     @pyqtSlot()

  1136.     def slot_JackServerStop(self):

  1137.         ret = False

  1138.         if gDBus.jack:

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

  1140.         return ret

  1141. 

  1142.     @pyqtSlot()

  1143.     def slot_JackClearXruns(self):

  1144.         if gJack.client:

  1145.             self.fXruns = 0

  1146.             self.ui_setXruns(0)

  1147. 

  1148.     @pyqtSlot()

  1149.     def slot_A2JBridgeStart(self):

  1150.         ret = False

  1151.         if gDBus.a2j:

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

  1153.         return ret

  1154. 

  1155.     @pyqtSlot()

  1156.     def slot_A2JBridgeStop(self):

  1157.         ret = False

  1158.         if gDBus.a2j:

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

  1160.         return ret

  1161. 

  1162.     @pyqtSlot()

  1163.     def slot_A2JBridgeExportHW(self):

  1164.         if gDBus.a2j:

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

  1166.             if ask == QMessageBox.Yes:

  1167.                 gDBus.a2j.set_hw_export(True)

  1168.             elif ask == QMessageBox.No:

  1169.                 gDBus.a2j.set_hw_export(False)

  1170. 

  1171.     @pyqtSlot()

  1172.     def slot_XRunCallback(self):

  1173.         self.fXruns += 1

  1174.         self.ui_setXruns(self.fXruns)

  1175. 

  1176.     @pyqtSlot(int)

  1177.     def slot_BufferSizeCallback(self, bufferSize):

  1178.         self.ui_setBufferSize(bufferSize)

  1179. 

  1180.     @pyqtSlot(int)

  1181.     def slot_SampleRateCallback(self, sampleRate):

  1182.         self.ui_setSampleRate(sampleRate)

  1183. 

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

  1185.         self.ui_setXruns(0)

  1186. 

  1187.     @pyqtSlot(str, str)

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

  1189.         pass # TODO

  1190. 

  1191.     @pyqtSlot(int, bool)

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

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

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

  1195. 

  1196.         if registerYesNo:

  1197.             self.canvas_addJackPort(portPtr, portNameR)

  1198.         else:

  1199.             for port in self.fPortList:

  1200.                 if port[iPortNameR] == portNameR:

  1201.                     portIdCanvas = port[iPortId]

  1202.                     break

  1203.             else:

  1204.                 return

  1205. 

  1206.             self.canvas_removeJackPort(portIdCanvas)

  1207. 

  1208.     @pyqtSlot(int, int, bool)

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

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

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

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

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

  1214. 

  1215.         if connectYesNo:

  1216.             self.canvas_connectPortsByName(portRealNameA, portRealNameB)

  1217.         else:

  1218.             self.canvas_disconnectPortsByName(portRealNameA, portRealNameB)

  1219. 

  1220.     @pyqtSlot(int, str, str)

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

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

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

  1224. 

  1225.         for port in self.fPortList:

  1226.             if port[iPortNameR] == oldName:

  1227.                 portIdCanvas = port[iPortId]

  1228.                 port[iPortNameR] = newName

  1229.                 break

  1230.         else:

  1231.             return

  1232. 

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

  1234.         aliases = jacklib.port_get_aliases(portPtr)

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

  1236.             pass

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

  1238.             pass

  1239.         else:

  1240.             self.canvas_renamePort(portIdCanvas, portShortName)

  1241. 

  1242.     @pyqtSlot()

  1243.     def slot_ShutdownCallback(self):

  1244.         self.jackStopped()

  1245. 

  1246.     @pyqtSlot()

  1247.     def slot_handleCrash_a2j(self):

  1248.         global gA2JClientName

  1249. 

  1250.         try:

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

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

  1253.         except:

  1254.             gDBus.a2j = None

  1255.             gA2JClientName = None

  1256. 

  1257.         if gDBus.a2j:

  1258.             if gDBus.a2j.is_started():

  1259.                 self.a2jStarted()

  1260.             else:

  1261.                 self.a2jStopped()

  1262.         else:

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

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

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

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

  1267. 

  1268.     @pyqtSlot()

  1269.     def slot_handleCrash_jack(self):

  1270.         self.DBusReconnect()

  1271. 

  1272.         if gDBus.jack:

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

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

  1275.         else:

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

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

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

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

  1280. 

  1281.         if gDBus.a2j:

  1282.             if gDBus.a2j.is_started():

  1283.                 self.a2jStarted()

  1284.             else:

  1285.                 self.a2jStopped()

  1286.         else:

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

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

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

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

  1291. 

  1292.         self.jackStopped()

  1293. 

  1294.     @pyqtSlot()

  1295.     def slot_configureCatia(self):

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

  1297.         if dialog.exec_():

  1298.             self.loadSettings(False)

  1299.             patchcanvas.clear()

  1300. 

  1301.             pOptions = patchcanvas.options_t()

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

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

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

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

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

  1307. 

  1308.             pFeatures = patchcanvas.features_t()

  1309.             pFeatures.group_info   = False

  1310.             pFeatures.group_rename = False

  1311.             pFeatures.port_info    = True

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

  1313.             pFeatures.handle_group_pos = True

  1314. 

  1315.             patchcanvas.setOptions(pOptions)

  1316.             patchcanvas.setFeatures(pFeatures)

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

  1318. 

  1319.             self.init_ports()

  1320. 

  1321.     @pyqtSlot()

  1322.     def slot_aboutCatia(self):

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

  1324.                                                                 "<br>Version %s"

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

  1326.                                                                 "<br>Copyright (C) 2010-2013 falkTX" % VERSION))

  1327. 

  1328.     def saveSettings(self):

  1329.         settings = QSettings()

  1330. 

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

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

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

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

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

  1336. 

  1337.     def loadSettings(self, geometry):

  1338.         settings = QSettings()

  1339. 

  1340.         if geometry:

  1341.             self.restoreGeometry(settings.value("Geometry", ""))

  1342. 

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

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

  1345. 

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

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

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

  1349. 

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

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

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

  1353. 

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

  1355. 

  1356.         self.fSavedSettings = {

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

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

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

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

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

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

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

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

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

  1366.         }

  1367. 

  1368.     def timerEvent(self, event):

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

  1370.             if gJack.client:

  1371.                 self.refreshTransport()

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

  1373.             if gJack.client:

  1374.                 self.refreshDSPLoad()

  1375.         QMainWindow.timerEvent(self, event)

  1376. 

  1377.     def closeEvent(self, event):

  1378.         self.saveSettings()

  1379.         patchcanvas.clear()

  1380.         QMainWindow.closeEvent(self, event)

  1381. 

  1382. # ------------------------------------------------------------------------------------------------------------

  1383. # Main

  1384. 

  1385. if __name__ == '__main__':

  1386.     # App initialization

  1387.     app = QApplication(sys.argv)

  1388.     app.setApplicationName("Catia")

  1389.     app.setApplicationVersion(VERSION)

  1390.     app.setOrganizationName("Cadence")

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

  1392. 

  1393.     if jacklib is None:

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

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

  1396.         sys.exit(1)

  1397. 

  1398.     if haveDBus:

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

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

  1401. 

  1402.         try:

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

  1404.             jacksettings.initBus(gDBus.bus)

  1405.         except:

  1406.             gDBus.jack = None

  1407. 

  1408.         try:

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

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

  1411.         except:

  1412.             gDBus.a2j = None

  1413.             gA2JClientName = None

  1414. 

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

  1416.             string = "Using DBus for "

  1417.             if gDBus.jack:

  1418.                 string += "JACK"

  1419.                 if gDBus.a2j:

  1420.                     string += " and a2jmidid"

  1421.             elif gDBus.a2j:

  1422.                 string += "a2jmidid"

  1423.             print(string)

  1424. 

  1425.     else:

  1426.         gDBus.jack = None

  1427.         gDBus.a2j  = None

  1428.         gA2JClientName = None

  1429.         if DEBUG:

  1430.             print("Not using DBus")

  1431. 

  1432.     # Init GUI

  1433.     gui = CatiaMainW()

  1434. 

  1435.     # Set-up custom signal handling

  1436.     setUpSignals(gui)

  1437. 

  1438.     # Show GUI

  1439.     gui.show()

  1440. 

  1441.     # App-Loop

  1442.     ret = app.exec_()

  1443. 

  1444.     # Close Jack

  1445.     if gJack.client:

  1446.         jacklib.deactivate(gJack.client)

  1447.         jacklib.client_close(gJack.client)

  1448. 

  1449.     # Exit properly

  1450.     sys.exit(ret)