plico package

Subpackages

• plico.client package
  • Submodules
  • plico.client.hackerable_client module
    • HackerableClient
      • HackerableClient.eval()
      • HackerableClient.execute()
  • plico.client.serverinfo_client module
    • ServerInfoClient
      • ServerInfoClient.serverInfo()
  • Module contents
• plico.rpc package
  • Submodules
  • plico.rpc.abstract_remote_procedure_call module
    • AbstractRemoteProcedureCall
      • AbstractRemoteProcedureCall.handleRequest()
      • AbstractRemoteProcedureCall.publishPickable()
      • AbstractRemoteProcedureCall.receivePickable()
      • AbstractRemoteProcedureCall.recvCameraFrame()
      • AbstractRemoteProcedureCall.sendCameraFrame()
      • AbstractRemoteProcedureCall.sendRequest()
  • plico.rpc.dummy_remote_procedure_call module
    • DummyRpcHandler
      • DummyRpcHandler.handleRequest()
      • DummyRpcHandler.publishPickable()
      • DummyRpcHandler.receivePickable()
      • DummyRpcHandler.recvCameraFrame()
      • DummyRpcHandler.sendCameraFrame()
      • DummyRpcHandler.sendRequest()
  • plico.rpc.dummy_sockets module
    • DummySockets
      • DummySockets.serverDisplay()
      • DummySockets.serverDisplayAddress()
      • DummySockets.serverRequest()
      • DummySockets.serverRequestAddress()
      • DummySockets.serverStatus()
      • DummySockets.serverStatusAddress()
      • DummySockets.serverSubscriber()
      • DummySockets.serverSubscriberAddress()
  • plico.rpc.sockets module
    • Sockets
      • Sockets.serverDisplay()
      • Sockets.serverDisplayAddress()
      • Sockets.serverRequest()
      • Sockets.serverRequestAddress()
      • Sockets.serverStatus()
      • Sockets.serverStatusAddress()
      • Sockets.serverSubscriber()
      • Sockets.serverSubscriberAddress()
  • plico.rpc.zmq_ports module
    • ZmqPorts
      • ZmqPorts.SERVER_DISPLAY_PORT
      • ZmqPorts.SERVER_HOSTNAME
      • ZmqPorts.SERVER_PUBLISHER_PORT
      • ZmqPorts.SERVER_REPLY_PORT
      • ZmqPorts.SERVER_STATUS_PORT
      • ZmqPorts.fromConfiguration()
  • plico.rpc.zmq_remote_procedure_call module
    • ZmqRemoteProcedureCall
      • ZmqRemoteProcedureCall.handleRequest()
      • ZmqRemoteProcedureCall.ipcAddress()
      • ZmqRemoteProcedureCall.publishPickable()
      • ZmqRemoteProcedureCall.publisherSocket()
      • ZmqRemoteProcedureCall.receivePickable()
      • ZmqRemoteProcedureCall.receiveWithTimeout()
      • ZmqRemoteProcedureCall.recvCameraFrame()
      • ZmqRemoteProcedureCall.replyIpcSocket()
      • ZmqRemoteProcedureCall.replySocket()
      • ZmqRemoteProcedureCall.requestIpcSocket()
      • ZmqRemoteProcedureCall.requestSocket()
      • ZmqRemoteProcedureCall.sendCameraFrame()
      • ZmqRemoteProcedureCall.sendRequest()
      • ZmqRemoteProcedureCall.subscriberSocket()
      • ZmqRemoteProcedureCall.tcpAddress()
      • ZmqRemoteProcedureCall.terminate()
      • ZmqRemoteProcedureCall.xpubsubSockets()
    • ZmqRpcTimeoutError
  • Module contents
• plico.types package
  • Submodules
  • plico.types.server_info module
    • ServerInfo
  • plico.types.zernike_coefficients module
    • ZernikeCoefficients
      • ZernikeCoefficients.FIRST_ZERNIKE_MODE
      • ZernikeCoefficients.counter()
      • ZernikeCoefficients.fromNumpyArray()
      • ZernikeCoefficients.getZ()
      • ZernikeCoefficients.numberOfModes()
      • ZernikeCoefficients.setCounter()
      • ZernikeCoefficients.toDictionary()
      • ZernikeCoefficients.toNumpyArray()
      • ZernikeCoefficients.zernikeIndexes()
  • Module contents
• plico.utils package
  • Submodules
  • plico.utils.addtree module
    • addtree()
    • mkdirp()
  • plico.utils.barrier module
    • Barrier
      • Barrier.waitFor()
      • Barrier.waitUntil()
    • BarrierTimeout
    • FunctionPredicate
      • FunctionPredicate.create()
      • FunctionPredicate.errorMessage()
      • FunctionPredicate.isFullfilled()
    • Predicate
      • Predicate.errorMessage()
      • Predicate.isFullfilled()
  • plico.utils.base_runner module
  • plico.utils.calibration_installer module
    • CalibrationInstaller
      • CalibrationInstaller.doesCalibrationFolderExists()
      • CalibrationInstaller.getCalibrationFolderPath()
      • CalibrationInstaller.installCalibrationFilesFromPackage()
  • plico.utils.concurrent_loop module
    • ConcurrentLoop
      • ConcurrentLoop.close()
      • ConcurrentLoop.deinitialize()
      • ConcurrentLoop.getConvergenceStepCount()
      • ConcurrentLoop.hasConverged()
      • ConcurrentLoop.initialize()
      • ConcurrentLoop.isClosed()
      • ConcurrentLoop.isInitialized()
      • ConcurrentLoop.name()
      • ConcurrentLoop.open()
      • ConcurrentLoop.performOnePass()
      • ConcurrentLoop.setStopDurationLimitSec()
    • ConcurrentLoopException
    • ThreadSafeStepCounter
      • ThreadSafeStepCounter.getCount()
      • ThreadSafeStepCounter.inc()
    • WorkerThread
      • WorkerThread.run()
      • WorkerThread.setStopDurationLimitSec()
      • WorkerThread.stop()
  • plico.utils.config_file_manager module
  • plico.utils.configuration module
  • plico.utils.constants module
    • Constants
      • Constants.APP_AUTHOR
      • Constants.APP_NAME
      • Constants.PICKLE_PROTOCOL
      • Constants.PORT_DISPLAY_OFFSET
      • Constants.PORT_PUBLISHER_OFFSET
      • Constants.PORT_REPLY_OFFSET
      • Constants.PORT_STATUS_OFFSET
  • plico.utils.control_loop module
    • ControlLoop
      • ControlLoop.start()
    • FaultTolerantControlLoop
      • FaultTolerantControlLoop.start()
    • IntolerantControlLoop
      • IntolerantControlLoop.start()
  • plico.utils.convergeable module
    • Convergeable
      • Convergeable.hasConverged()
      • Convergeable.measureConvergence()
      • Convergeable.performOneConvergenceStep()
  • plico.utils.decorator module
    • ReturnTypeMismatchError
    • cacheResult()
    • logEnterAndExit()
    • logFailureAndContinue()
    • logFailureAndRaise()
    • logTime()
    • override()
    • returns()
    • returnsForExample()
    • returnsNone()
    • suppressException()
    • synchronized()
  • plico.utils.executor module
    • BusyExecutorException
    • DelayedTaskControl
      • DelayedTaskControl.isDone()
      • DelayedTaskControl.isRunning()
      • DelayedTaskControl.markAsDone()
      • DelayedTaskControl.waitForCompletion()
    • DoneTaskControl
      • DoneTaskControl.isDone()
      • DoneTaskControl.isRunning()
      • DoneTaskControl.waitForCompletion()
    • Executor
      • Executor.execute()
    • ExecutorFactory
      • ExecutorFactory.buildMultiThreadExecutor()
      • ExecutorFactory.buildSingleThreadExecutor()
      • ExecutorFactory.buildSingleThreadImmediateExecutor()
    • FunctionTask
      • FunctionTask.NO_RESULT
      • FunctionTask.getException()
      • FunctionTask.getResult()
      • FunctionTask.name()
      • FunctionTask.perform()
      • FunctionTask.reraiseExceptionIfAny()
      • FunctionTask.withName()
    • FunctionTaskException
    • FutureTaskControl
      • FutureTaskControl.isDone()
      • FutureTaskControl.isRunning()
      • FutureTaskControl.waitForCompletion()
    • MultiThreadExecutor
      • MultiThreadExecutor.execute()
    • SerialExecutor
      • SerialExecutor.execute()
    • SingleThreadExecutor
    • SingleThreadImmediateExecutor
      • SingleThreadImmediateExecutor.execute()
      • SingleThreadImmediateExecutor.isIdle()
    • Task
      • Task.name()
      • Task.perform()
    • TaskControl
      • TaskControl.isDone()
      • TaskControl.isRunning()
      • TaskControl.waitForCompletion()
    • TaskDelayingExecutor
      • TaskDelayingExecutor.execute()
      • TaskDelayingExecutor.executeDelayedTasks()
      • TaskDelayingExecutor.getDelayedTasks()
    • TaskTimeoutError
    • logTaskFailure()
  • plico.utils.fake_convergeable module
    • FakeConvergeable
      • FakeConvergeable.blockStep()
      • FakeConvergeable.getConvergenceStepCount()
      • FakeConvergeable.getMeasureConvergenceCount()
      • FakeConvergeable.hasConverged()
      • FakeConvergeable.measureConvergence()
      • FakeConvergeable.name()
      • FakeConvergeable.performOneConvergenceStep()
      • FakeConvergeable.requestPanic()
      • FakeConvergeable.setAsConverged()
      • FakeConvergeable.setAsUnconverged()
      • FakeConvergeable.setStepSleepDurationSec()
      • FakeConvergeable.unblockStep()
  • plico.utils.fake_loop module
    • FakeLoop
      • FakeLoop.close()
      • FakeLoop.deinitialize()
      • FakeLoop.getConvergenceStepCount()
      • FakeLoop.hasConverged()
      • FakeLoop.initialize()
      • FakeLoop.isClosed()
      • FakeLoop.isInitialized()
      • FakeLoop.name()
      • FakeLoop.open()
      • FakeLoop.performOnePass()
      • FakeLoop.setConvergenceFlagTo()
  • plico.utils.fits_file_based_calibration_manager module
    • FitsFileBasedCalibrationManager
  • plico.utils.hackerable module
    • Hackerable
      • Hackerable.eval()
      • Hackerable.execute()
  • plico.utils.image_moments module
    • ImageMoments
      • ImageMoments.centralMoment()
      • ImageMoments.centralNormalizedMoment()
      • ImageMoments.centroid()
      • ImageMoments.covarianceMatrix()
      • ImageMoments.eccentricity()
      • ImageMoments.effectiveRadius()
      • ImageMoments.eigenvalues()
      • ImageMoments.orientation()
      • ImageMoments.principalMomentsOfInertia()
      • ImageMoments.rawMoment()
      • ImageMoments.semiAxes()
      • ImageMoments.xBar()
      • ImageMoments.yBar()
  • plico.utils.kill_process_by_name module
    • killProcessByName()
  • plico.utils.logger module
    • AbstractLogger
      • AbstractLogger.debug()
      • AbstractLogger.error()
      • AbstractLogger.fatal()
      • AbstractLogger.notice()
      • AbstractLogger.warn()
    • AbstractLoggerFactory
      • AbstractLoggerFactory.getLogger()
    • DummyLogger
      • DummyLogger.debug()
      • DummyLogger.error()
      • DummyLogger.fatal()
      • DummyLogger.notice()
      • DummyLogger.warn()
    • DummyLoggerFactory
      • DummyLoggerFactory.getLogger()
    • Logger
      • Logger.DEFAULT_LOGGER_FACTORY
      • Logger.of()
      • Logger.setLoggerFactory()
    • LoggerException
    • LoggerListener
      • LoggerListener.onDebug()
      • LoggerListener.onError()
      • LoggerListener.onFatal()
      • LoggerListener.onNotice()
      • LoggerListener.onWarning()
    • ObservableLogger
      • ObservableLogger.addListener()
      • ObservableLogger.debug()
      • ObservableLogger.error()
      • ObservableLogger.fatal()
      • ObservableLogger.notice()
      • ObservableLogger.warn()
    • ObservableLoggerFactory
      • ObservableLoggerFactory.addListener()
      • ObservableLoggerFactory.getLogger()
      • ObservableLoggerFactory.getLoggerMap()
    • PythonLogger
      • PythonLogger.debug()
      • PythonLogger.error()
      • PythonLogger.fatal()
      • PythonLogger.notice()
      • PythonLogger.setRelativePathRadix()
      • PythonLogger.warn()
    • PythonLoggerFactory
      • PythonLoggerFactory.getLogger()
  • plico.utils.loop module
    • Loop
      • Loop.close()
      • Loop.getConvergenceStepCount()
      • Loop.hasConverged()
      • Loop.isClosed()
      • Loop.name()
      • Loop.open()
      • Loop.performOnePass()
    • LoopException
  • plico.utils.plico_scipy module
    • binom()
    • curve_fit()
    • gaussian_filter()
    • leastsq()
    • medfilt2d()
    • median_filter()
    • minimize()
    • pinv()
    • pinv2()
    • rotate()
    • splev()
    • splrep()
    • svdvals()
  • plico.utils.serverinfoable module
    • ServerInfoable
      • ServerInfoable.serverInfo()
  • plico.utils.snapshotable module
    • Snapshotable
      • Snapshotable.asFITSHeader()
      • Snapshotable.fromFITSHeader()
      • Snapshotable.getSnapshot()
      • Snapshotable.prepend()
      • Snapshotable.removeEntriesWithValueNone()
  • plico.utils.starter_script_creator_base module
    • StarterScriptCreatorBase
      • StarterScriptCreatorBase.installExecutables()
      • StarterScriptCreatorBase.setConfigFileDestination()
      • StarterScriptCreatorBase.setInstallationBinDir()
      • StarterScriptCreatorBase.setPythonPath()
  • plico.utils.stepable module
    • Stepable
      • Stepable.isTerminated()
      • Stepable.step()
  • plico.utils.timekeeper module
    • TimeKeeper
      • TimeKeeper.inc()
  • plico.utils.timeout module
    • Timeout
      • Timeout.MIRROR_EVAL
      • Timeout.MIRROR_EXECUTE
      • Timeout.SERVER_INFO
  • plico.utils.timestamp module
    • Timestamp
      • Timestamp.asNowString()
      • Timestamp.asTodayString()
      • Timestamp.now()
      • Timestamp.nowUSec()
      • Timestamp.today()
  • plico.utils.zernike_generator module
    • ZernikeGenerator
      • ZernikeGenerator.getDerivativeX()
      • ZernikeGenerator.getDerivativeXDict()
      • ZernikeGenerator.getDerivativeY()
      • ZernikeGenerator.getDerivativeYDict()
      • ZernikeGenerator.getRadius()
      • ZernikeGenerator.getZernike()
      • ZernikeGenerator.getZernikeDict()
  • Module contents

Module contents