aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorMattias Andrée <maandree@kth.se>2019-10-22 20:47:49 +0200
committerMattias Andrée <maandree@kth.se>2019-10-22 20:48:13 +0200
commit6aeb2443f562c9b879009137c4aa92cfd592a93e (patch)
treeb8e1a7028b0472fbd88019a2b9325024038443e3 /src
parentFix Python 3.7 compatility (diff)
downloadpylibcoopgamma-1.1.2.tar.gz
pylibcoopgamma-1.1.2.tar.bz2
pylibcoopgamma-1.1.2.tar.xz
Change license, flat file hier, do not use gpp, join .py and .pyx, simpler makefile1.1.2
Signed-off-by: Mattias Andrée <maandree@kth.se>
Diffstat (limited to '')
-rw-r--r--libcoopgamma.pyx (renamed from src/libcoopgamma_native.pyx.gpp)1289
-rw-r--r--src/include-libcoopgamma.h28
-rw-r--r--src/libcoopgamma.py1205
-rwxr-xr-xtest (renamed from src/test)20
4 files changed, 1219 insertions, 1323 deletions
diff --git a/src/libcoopgamma_native.pyx.gpp b/libcoopgamma.pyx
index eee05ec..57a53a4 100644
--- a/src/libcoopgamma_native.pyx.gpp
+++ b/libcoopgamma.pyx
@@ -1,21 +1,5 @@
# -*- python -*-
-'''
-pylibcoopgamma -- Python library for interfacing with cooperative gamma servers
-Copyright (C) 2016 Mattias Andrée (maandree@kth.se)
-
-This library is free software: you can redistribute it and/or modify
-it under the terms of the GNU General Public License as published by
-the Free Software Foundation, either version 3 of the License, or
-(at your option) any later version.
-
-This library is distributed in the hope that it will be useful,
-but WITHOUT ANY WARRANTY; without even the implied warranty of
-MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-GNU General Public License for more details.
-
-You should have received a copy of the GNU General Public License
-along with this library. If not, see <http://www.gnu.org/licenses/>.
-'''
+# See LICENSE file for copyright and license details.
cimport cython
from libc.stddef cimport size_t
@@ -23,6 +7,7 @@ from libc.stdlib cimport calloc, malloc, free
from libc.stdint cimport int64_t, uint8_t, uint16_t, uint32_t, uint64_t, intptr_t
from libc.errno cimport errno
+import enum as _enum
ctypedef int libcoopgamma_support_t
@@ -90,13 +75,6 @@ cdef extern from "include-libcoopgamma.h":
# and `.blue_size` are undefined
libcoopgamma_support_t supported
# The data type and bit-depth of the ramp stops
-$$<cpp <<EOF | tail -n 1 | sed '/#/d'
-#include <limits.h>
-#if INT_MAX != LONG_MAX
- int padding__
-#endif
-EOF
-$$>
size_t red_size
# The number of stops in the red ramp
size_t green_size
@@ -138,13 +116,6 @@ $$>
# The CRTC for which the the current filters shall returned
int coalesce
# Whether to coalesce all filters into one gamma ramp triplet
-$$<cpp <<EOF | tail -n 1 | sed '/#/d'
-#include <limits.h>
-#if INT_MAX != LONG_MAX
- int padding__
-#endif
-EOF
-$$>
ctypedef struct libcoopgamma_queried_filter_t:
# Stripped down version of `libcoopgamma_filter` which only contains
@@ -176,13 +147,6 @@ $$>
# and `.filters->priority` is undefined.
libcoopgamma_depth_t depth
# The data type and bit-depth of the ramp stops
-$$<cpp <<EOF | tail -n 1 | sed '/#/d'
-#include <limits.h>
-#if INT_MAX != LONG_MAX
- int padding__
-#endif
-EOF
-$$>
ctypedef struct libcoopgamma_error_t:
# Error message from coopgamma server
@@ -792,7 +756,7 @@ operation without disconnection from the server
-def libcoopgamma_native_get_methods():
+def _libcoopgamma_native_get_methods():
'''
List all recognised adjustment method
@@ -818,7 +782,7 @@ def libcoopgamma_native_get_methods():
return ret
-def libcoopgamma_native_get_method_and_site(method : str, site : str):
+def _libcoopgamma_native_get_method_and_site(method : str, site : str):
'''
Get the adjustment method and site
@@ -866,7 +830,7 @@ def libcoopgamma_native_get_method_and_site(method : str, site : str):
free(rcssite)
-def libcoopgamma_native_get_pid_file(method : str, site : str):
+def _libcoopgamma_native_get_pid_file(method : str, site : str):
'''
Get the PID file of the coopgamma server
@@ -904,7 +868,7 @@ def libcoopgamma_native_get_pid_file(method : str, site : str):
return int(errno)
-def libcoopgamma_native_get_socket_file(method : str, site : str):
+def _libcoopgamma_native_get_socket_file(method : str, site : str):
'''
Get the socket file of the coopgamma server
@@ -943,7 +907,7 @@ def libcoopgamma_native_get_socket_file(method : str, site : str):
return int(errno)
-def libcoopgamma_native_context_create():
+def _libcoopgamma_native_context_create():
'''
Create an instance of `libcoopgamma_context_t`
@@ -963,7 +927,7 @@ def libcoopgamma_native_context_create():
return (True, int(<intptr_t><void*>this))
-def libcoopgamma_native_context_free(address : int):
+def _libcoopgamma_native_context_free(address : int):
'''
Disconnect and free an instance of a `libcoopgamma_context_t`
@@ -974,7 +938,7 @@ def libcoopgamma_native_context_free(address : int):
free(this)
-def libcoopgamma_native_context_marshal(address : int):
+def _libcoopgamma_native_context_marshal(address : int):
'''
Marshal a `libcoopgamma_context_t` into a buffer
@@ -994,7 +958,7 @@ def libcoopgamma_native_context_marshal(address : int):
free(buf)
-def libcoopgamma_native_context_unmarshal(buf : bytes):
+def _libcoopgamma_native_context_unmarshal(buf : bytes):
'''
Unmarshal a `libcoopgamma_context_t` from a buffer
@@ -1032,7 +996,7 @@ def libcoopgamma_native_context_unmarshal(buf : bytes):
free(bs)
-def libcoopgamma_native_context_set_fd(address : int, fd : int):
+def _libcoopgamma_native_context_set_fd(address : int, fd : int):
'''
Set the field for socket file descriptor in a `libcoopgamma_context_t`
@@ -1043,7 +1007,7 @@ def libcoopgamma_native_context_set_fd(address : int, fd : int):
this.fd = fd
-def libcoopgamma_native_async_context_create():
+def _libcoopgamma_native_async_context_create():
'''
Create an instance of `libcoopgamma_context_t`
@@ -1063,7 +1027,7 @@ def libcoopgamma_native_async_context_create():
return (True, int(<intptr_t><void*>this))
-def libcoopgamma_native_async_context_free(address : int):
+def _libcoopgamma_native_async_context_free(address : int):
'''
Free an instance of a `libcoopgamma_async_context_t`
@@ -1074,7 +1038,7 @@ def libcoopgamma_native_async_context_free(address : int):
free(this)
-def libcoopgamma_native_async_context_marshal(address : int):
+def _libcoopgamma_native_async_context_marshal(address : int):
'''
Marshal a `libcoopgamma_async_context_t` into a buffer
@@ -1095,7 +1059,7 @@ def libcoopgamma_native_async_context_marshal(address : int):
return ret
-def libcoopgamma_native_async_context_unmarshal(buf : bytes):
+def _libcoopgamma_native_async_context_unmarshal(buf : bytes):
'''
Unmarshal a `libcoopgamma_async_context_t` from a buffer
@@ -1133,7 +1097,7 @@ def libcoopgamma_native_async_context_unmarshal(buf : bytes):
free(bs)
-def libcoopgamma_native_connect(method : str, site : str, address : int):
+def _libcoopgamma_native_connect(method : str, site : str, address : int):
'''
Connect to a coopgamma server, and start it if necessary
@@ -1170,7 +1134,7 @@ def libcoopgamma_native_connect(method : str, site : str, address : int):
free(csite)
-def libcoopgamma_native_set_nonblocking(address : int, nonblocking : bool):
+def _libcoopgamma_native_set_nonblocking(address : int, nonblocking : bool):
'''
By default communication is blocking, this function
can be used to switch between blocking and nonblocking
@@ -1192,7 +1156,7 @@ def libcoopgamma_native_set_nonblocking(address : int, nonblocking : bool):
return 0
-def libcoopgamma_native_flush(address : int):
+def _libcoopgamma_native_flush(address : int):
'''
Send all pending outbound data
@@ -1211,7 +1175,7 @@ def libcoopgamma_native_flush(address : int):
return 0
-def libcoopgamma_native_synchronise(address : int, pending : list):
+def _libcoopgamma_native_synchronise(address : int, pending : list):
'''
Wait for the next message to be received
@@ -1238,7 +1202,7 @@ def libcoopgamma_native_synchronise(address : int, pending : list):
return (True, <int>selected)
-def libcoopgamma_native_skip_message(address : int):
+def _libcoopgamma_native_skip_message(address : int):
'''
Tell the library that you will not be parsing a receive message
@@ -1247,7 +1211,7 @@ def libcoopgamma_native_skip_message(address : int):
libcoopgamma_skip_message(<libcoopgamma_context_t*><void*><intptr_t>address)
-def libcoopgamma_native_get_crtcs_send(address : int, async_ctx : int):
+def _libcoopgamma_native_get_crtcs_send(address : int, async_ctx : int):
'''
List all available CRTC:s, send request part
@@ -1262,7 +1226,7 @@ def libcoopgamma_native_get_crtcs_send(address : int, async_ctx : int):
return 0
-def libcoopgamma_native_get_crtcs_recv(address : int, async_ctx : int):
+def _libcoopgamma_native_get_crtcs_recv(address : int, async_ctx : int):
'''
List all available CRTC:s, receive response part
@@ -1288,7 +1252,7 @@ def libcoopgamma_native_get_crtcs_recv(address : int, async_ctx : int):
return ret
-def libcoopgamma_native_get_crtcs_sync(address : int):
+def _libcoopgamma_native_get_crtcs_sync(address : int):
'''
List all available CRTC:s, synchronous version
@@ -1319,7 +1283,7 @@ def libcoopgamma_native_get_crtcs_sync(address : int):
return ret
-def libcoopgamma_native_get_gamma_info_send(crtc : str, address : int, async_ctx : int):
+def _libcoopgamma_native_get_gamma_info_send(crtc : str, address : int, async_ctx : int):
'''
Retrieve information about a CRTC:s gamma ramps, send request part
@@ -1348,7 +1312,7 @@ def libcoopgamma_native_get_gamma_info_send(crtc : str, address : int, async_ctx
return 0
-def libcoopgamma_native_get_gamma_info_recv(address : int, async_ctx : int):
+def _libcoopgamma_native_get_gamma_info_recv(address : int, async_ctx : int):
'''
Retrieve information about a CRTC:s gamma ramps, receive response part
@@ -1383,7 +1347,7 @@ def libcoopgamma_native_get_gamma_info_recv(address : int, async_ctx : int):
return ret
-def libcoopgamma_native_get_gamma_info_sync(crtc : str, address : int):
+def _libcoopgamma_native_get_gamma_info_sync(crtc : str, address : int):
'''
Retrieve information about a CRTC:s gamma ramps, synchronous version
@@ -1428,7 +1392,7 @@ def libcoopgamma_native_get_gamma_info_sync(crtc : str, address : int):
return ret
-def libcoopgamma_native_get_gamma_send(query, address : int, async_ctx : int):
+def _libcoopgamma_native_get_gamma_send(query, address : int, async_ctx : int):
'''
Retrieve the current gamma ramp adjustments, send request part
@@ -1461,7 +1425,7 @@ def libcoopgamma_native_get_gamma_send(query, address : int, async_ctx : int):
return 0
-def libcoopgamma_native_get_gamma_recv(address : int, async_ctx : int):
+def _libcoopgamma_native_get_gamma_recv(address : int, async_ctx : int):
'''
Retrieve the current gamma ramp adjustments, receive response part
@@ -1549,7 +1513,7 @@ def libcoopgamma_native_get_gamma_recv(address : int, async_ctx : int):
return ret
-def libcoopgamma_native_get_gamma_sync(query, address : int):
+def _libcoopgamma_native_get_gamma_sync(query, address : int):
'''
Retrieve the current gamma ramp adjustments, synchronous version
@@ -1656,7 +1620,7 @@ def libcoopgamma_native_get_gamma_sync(query, address : int):
return ret
-def libcoopgamma_native_copy_ramps(intptr_t dest_address, src, libcoopgamma_depth_t depth):
+def _libcoopgamma_native_copy_ramps(intptr_t dest_address, src, libcoopgamma_depth_t depth):
'''
Copy a Python ramp-trio into C ramp-trio
@@ -1766,7 +1730,7 @@ def libcoopgamma_native_copy_ramps(intptr_t dest_address, src, libcoopgamma_dept
dest.u_blue = <void*>bd
-def libcoopgamma_native_set_gamma_send(filtr, address : int, async_ctx : int):
+def _libcoopgamma_native_set_gamma_send(filtr, address : int, async_ctx : int):
'''
Apply, update, or remove a gamma ramp adjustment, send request part
@@ -1797,7 +1761,7 @@ def libcoopgamma_native_set_gamma_send(filtr, address : int, async_ctx : int):
flr.ramps.u_blue = NULL
try:
if filtr.ramps is not None:
- libcoopgamma_native_copy_ramps(<intptr_t><void*>&(flr.ramps), filtr.ramps, flr.depth)
+ _libcoopgamma_native_copy_ramps(<intptr_t><void*>&(flr.ramps), filtr.ramps, flr.depth)
flr.crtc = <char*>malloc(len(crtc_bs) * sizeof(char))
if flr.crtc is NULL:
return int(errno)
@@ -1817,7 +1781,7 @@ def libcoopgamma_native_set_gamma_send(filtr, address : int, async_ctx : int):
return 0
-def libcoopgamma_native_set_gamma_recv(address : int, async_ctx : int):
+def _libcoopgamma_native_set_gamma_recv(address : int, async_ctx : int):
'''
Apply, update, or remove a gamma ramp adjustment, receive response part
@@ -1839,7 +1803,7 @@ def libcoopgamma_native_set_gamma_recv(address : int, async_ctx : int):
return None
-def libcoopgamma_native_set_gamma_sync(filtr, address : int):
+def _libcoopgamma_native_set_gamma_sync(filtr, address : int):
'''
Apply, update, or remove a gamma ramp adjustment, synchronous version
@@ -1873,7 +1837,7 @@ def libcoopgamma_native_set_gamma_sync(filtr, address : int):
flr.ramps.u_blue = NULL
try:
if filtr.ramps is not None:
- libcoopgamma_native_copy_ramps(<intptr_t><void*>&(flr.ramps), filtr.ramps, flr.depth)
+ _libcoopgamma_native_copy_ramps(<intptr_t><void*>&(flr.ramps), filtr.ramps, flr.depth)
flr.crtc = <char*>malloc(len(crtc_bs) * sizeof(char))
if flr.crtc is NULL:
return int(errno)
@@ -1896,3 +1860,1186 @@ def libcoopgamma_native_set_gamma_sync(filtr, address : int):
free(flr.ramps.u_red)
return None
+
+class Support(_enum.IntEnum):
+ '''
+ Values used to indicate the support for gamma adjustments
+
+ @value NO=0 Gamma adjustments are not supported
+ @value MAYBE=1 Don't know whether gamma adjustments are supported
+ @value YES=2 Gamma adjustments are supported
+ '''
+ NO = 0
+ MAYBE = 1
+ YES = 2
+
+ @staticmethod
+ def str(v):
+ '''
+ Get string representation of a value
+
+ @param v:int The value, must be value of the enum
+ @return :str Human-readable string representation of the value
+ '''
+ if v == Support.NO:
+ return 'no'
+ if v == Support.YES:
+ return 'yes'
+ if v == Support.MAYBE:
+ return 'maybe'
+ raise ValueError()
+
+
+class Depth(_enum.IntEnum):
+ '''
+ Values used to tell which datatype is used for the gamma ramp stops
+
+ The values will always be the number of bits for integral types, and
+ negative for floating-point types
+
+ @value UINT8=8 Unsigned 8-bit integer
+ @value UINT16=16 Unsigned 16-bit integer
+ @value UINT32=32 Unsigned 32-bit integer
+ @value UINT64=64 Unsigned 64-bit integer
+ @value FLOAT<0 Single-precision floating-point
+ @value DOUBLE<0 Double-precision floating-point
+ '''
+ UINT8 = 8
+ UINT16 = 16
+ UINT32 = 32
+ UINT64 = 64
+ FLOAT = -1
+ DOUBLE = -2
+
+ @staticmethod
+ def str(v):
+ '''
+ Get string representation of a value
+
+ @param v:int The value, must be value of the enum
+ @return :str Human-readable string representation of the value
+ '''
+ if v == Depth.UINT8:
+ return '8-bits'
+ if v == Depth.UINT16:
+ return '16-bits'
+ if v == Depth.UINT32:
+ return '32-bits'
+ if v == Depth.UINT64:
+ return '64-bits'
+ if v == Depth.FLOAT:
+ return 'single-precision floating-point'
+ if v == Depth.DOUBLE:
+ return 'double-precision floating-point'
+ raise ValueError()
+
+
+class Lifespan(_enum.IntEnum):
+ '''
+ Values used to tell when a filter should be removed
+
+ @value REMOVE=0 Remove the filter now
+ @value UNTIL_DEATH>0 Remove the filter when disconnecting from the coopgamma server
+ @value UNTIL_REMOVAL>0 Only remove the filter when it is explicitly requested
+ '''
+ REMOVE = 0
+ UNTIL_DEATH = 1
+ UNTIL_REMOVAL = 2
+
+ @staticmethod
+ def str(v):
+ '''
+ Get string representation of a value
+
+ @param v:int The value, must be value of the enum
+ @return :str Human-readable string representation of the value
+ '''
+ if v == Lifespan.REMOVE:
+ return 'remove'
+ if v == Lifespan.UNTIL_DEATH:
+ return 'until death'
+ if v == Lifespan.UNTIL_REMOVAL:
+ return 'until removal'
+ raise ValueError()
+
+
+class Colourspace(_enum.IntEnum):
+ '''
+ Colourspaces
+
+ @value UNKNOWN=0 The colourspace is unknown
+ @value SRGB>0 sRGB (Standard RGB)
+ @value RGB>0 RGB other than sRGB
+ @value NON_RGB>0 Non-RGB multicolour
+ @value GREY>0 Monochrome, greyscale, or some other singlecolour scale
+ '''
+ UNKNOWN = 0
+ SRGB = 1
+ RGB = 2
+ NON_RGB = 3
+ GREY = 4
+
+ @staticmethod
+ def str(v):
+ '''
+ Get string representation of a value
+
+ @param v:int The value, must be value of the enum
+ @return :str Human-readable string representation of the value
+ '''
+ if v == Colourspace.UNKNOWN:
+ return 'unknown'
+ if v == Colourspace.SRGB:
+ return 'sRGB'
+ if v == Colourspace.RGB:
+ return 'RGB'
+ if v == Colourspace.NON_RGB:
+ return 'non-RGB'
+ if v == Colourspace.GREY:
+ return 'greyscale'
+ raise ValueError()
+
+
+class Ramps:
+ '''
+ Gamma ramp structure
+
+ @variable red:list<int> The red gamma ramp
+ @variable green:list<int> The green gamma ramp
+ @variable blue:list<int> The blue gamma ramp
+ '''
+ def __init__(self, red, green, blue):
+ '''
+ Constructor
+
+ @param red:int The number of stops in the red ramp
+ @param green:int The number of stops in the green ramp
+ @param blue:int The number of stops in the blue ramp
+
+ -- or --
+
+ @param red:list<int> The red gamma ramp
+ @param green:list<int> The green gamma ramp
+ @param blue:list<int> The blue gamma ramp
+ '''
+ if isinstance(red, list):
+ self.red = list(red)
+ self.green = list(green)
+ self.blue = list(blue)
+ else:
+ self.red = [0] * red
+ self.green = [0] * green
+ self.blue = [0] * blue
+
+ def clone(self):
+ '''
+ Create a copy of the instance
+ '''
+ return Ramps(self.red, self.green, self.blue)
+
+ def __repr__(self):
+ '''
+ Create a parsable string representation of the instance
+
+ @return :str Parsable representation of the instance
+ '''
+ params = (self.red, self.green, self.blue)
+ return 'libcoopgamma.Ramps(%s)' % ', '.join(repr(p) for p in params)
+
+
+class Filter:
+ '''
+ Data set to the coopgamma server to apply, update, or remove a filter
+
+ @variable priority:int The priority of the filter, higher priority
+ is applied first. The gamma correction should
+ have priority 0. This is a signed 64-bit integer.
+ @variable crtc:str The CRTC for which this filter shall be applied
+ @variable fclass:str Identifier for the filter.
+ The syntax must be "${PACKAGE_NAME}::${COMMAND_NAME}::${RULE}".
+ @variable lifespan:Lifespan When shall the filter be removed?
+ If this member's value is `LIBCOOPGAMMA_REMOVE`,
+ only `.crtc` and `.class` need also be defined.
+ @variable depth:Depth The data type and bit-depth of the ramp stops
+ @variable ramps:Ramps The gamma ramp adjustments of the filter
+ '''
+ def __init__(self, priority = None, crtc = None, fclass = None, lifespan = None, depth = None, ramps = None):
+ '''
+ Constructor
+
+ @param priority:int The priority of the filter, higher priority
+ is applied first. The gamma correction should
+ have priority 0. This is a signed 64-bit integer.
+ @param crtc:str The CRTC for which this filter shall be applied
+ @param fclass:str Identifier for the filter.
+ The syntax must be "${PACKAGE_NAME}::${COMMAND_NAME}::${RULE}".
+ @param lifespan:Lifespan When shall the filter be removed?
+ If this member's value is `LIBCOOPGAMMA_REMOVE`,
+ only `.crtc` and `.class` need also be defined.
+ @param depth:Depth The data type and bit-depth of the ramp stops
+ @param ramps:Ramps The gamma ramp adjustments of the filter
+ '''
+ self.priority = priority
+ self.crtc = crtc
+ self.fclass = fclass
+ self.lifespan = lifespan
+ self.depth = depth
+ self.ramps = ramps
+
+ def clone(self, shallow = False):
+ '''
+ Create a copy of the instance
+
+ @param shallow:bool Create a shallow copy?
+ '''
+ ramps = self.ramps if shallow else self.ramps.clone()
+ return Filter(self.priority, self.crtc, self.fclass, self.lifespan, self.depth, ramps)
+
+ def __repr__(self):
+ '''
+ Create a parsable string representation of the instance
+
+ @return :str Parsable representation of the instance
+ '''
+ params = (self.priority, self.crtc, self.fclass, self.lifespan, self.depth, self.ramps)
+ return 'libcoopgamma.Filter(%s)' % ', '.join(repr(p) for p in params)
+
+
+class GamutPoint:
+ '''
+ The x- and y-values (CIE xyY) of a colour
+
+ @variable x_raw:int The x-value (CIE xyY) multiplied by 1024
+ @variable y_raw:int The y-value (CIE xyY) multiplied by 1024
+ @variable x:int The x-value (CIE xyY)
+ @variable y:int The y-value (CIE xyY)
+ '''
+ def __init__(self, x, y):
+ '''
+ Constructor
+
+ @param x:int The x-value (CIE xyY) multiplied by 1024
+ @param y:int The y-value (CIE xyY) multiplied by 1024
+ '''
+ self.x_raw, self.x = x, x / 1024
+ self.y_raw, self.y = y, y / 1024
+
+ def clone(self):
+ '''
+ Create a copy of the instance
+ '''
+ return GamutPoint(self.x_raw, self.y_raw)
+
+ def __repr__(self):
+ '''
+ Create a parsable string representation of the instance
+
+ @return :str Parsable representation of the instance
+ '''
+ params = (self.x_raw, self.y_raw)
+ return 'libcoopgamma.GamutPoint(%s)' % ', '.join(repr(p) for p in params)
+
+ def __str__(self):
+ '''
+ Get human-readable string representation of instance
+
+ @return :str Human-readable string representation of instance
+ '''
+ return '(%f, %f)' % (self.x, self.y)
+
+
+class Gamut:
+ '''
+ The values of the monitor's colour stimuli
+
+ @variable red:GamutPoint The red stimuli
+ @variable green:GamutPoint The green stimuli
+ @variable blue:GamutPoint The blue stimuli
+ @variable white:GamutPoint The default whitepoint
+ '''
+ def __init__(self, red = None, green = None, blue = None, white = None):
+ '''
+ Constructor
+
+ @param red:GamutPoint|(int, int) The red stimuli
+ @param green:GamutPoint|(int, int) The green stimuli
+ @param blue:GamutPoint|(int, int) The blue stimuli
+ @param white:GamutPoint|(int, int) The default whitepoint
+ '''
+ self.red = GamutPoint(*red) if isinstance(red, tuple) else red
+ self.green = GamutPoint(*green) if isinstance(green, tuple) else green
+ self.blue = GamutPoint(*blue) if isinstance(blue, tuple) else blue
+ self.white = GamutPoint(*white) if isinstance(white, tuple) else white
+
+ def clone(self, shallow = True):
+ '''
+ Create a copy of the instance
+
+ @param shallow:bool Create a shallow copy?
+ '''
+ if shallow:
+ return Gamut(self.red, self.green, self.blue, self.white)
+ return Gamut(self.red.clone(), self.green.clone(), self.blue.clone(), self.white.clone())
+
+ def __repr__(self):
+ '''
+ Create a parsable string representation of the instance
+
+ @return :str Parsable representation of the instance
+ '''
+ params = (repr(self.red), repr(self.green), repr(self.blue), repr(self.white))
+ return 'libcoopgamma.Gamut(%s)' % ', '.join(repr(p) for p in params)
+
+
+class CRTCInfo:
+ '''
+ Gamma ramp meta information for a CRTC
+
+ @variable cooperative:bool Is cooperative gamma server running?
+ @variable depth:Depth? The data type and bit-depth of the ramp stops
+ @variable supported:Support Is gamma adjustments supported on the CRTC?
+ If not, `depth`, `red_size`, `green_size`,
+ and `blue_size` are undefined
+ @variable red_size:int? The number of stops in the red ramp
+ @variable green_size:int? The number of stops in the green ramp
+ @variable blue_size:int? The number of stops in the blue ramp
+ @variable colourspace:Colourspace The monitor's colourspace
+ @variable gamut:Gamut? Measurements of the monitor's colourspace,
+ `None` if the this information is unavailable.
+ If this is not `None`, but the colourspace
+ is not RGB (or sRGB), there is something
+ wrong. Always check the colourspace.
+ '''
+ def __init__(self, cooperative = None, depth = None, supported = None, red_size = None,
+ green_size = None, blue_size = None, colourspace = None, gamut = None):
+ '''
+ Constructor
+
+ @param cooperative:bool Is cooperative gamma server running?
+ @param depth:Depth? The data type and bit-depth of the ramp stops
+ @param supported:Support Is gamma adjustments supported on the CRTC?
+ If not, `depth`, `red_size`, `green_size`,
+ and `blue_size` are undefined
+ @param red_size:int? The number of stops in the red ramp
+ @param green_size:int? The number of stops in the green ramp
+ @param blue_size:int? The number of stops in the blue ramp
+ @param colourspace:Colourspace The monitor's colourspace
+ @param gamut:Gamut|tuple? Measurements of the monitor's colourspace,
+ `None` if the this information is unavailable
+ '''
+ self.cooperative = cooperative
+ self.depth = depth
+ self.supported = supported
+ self.red_size = red_size
+ self.green_size = green_size
+ self.blue_size = blue_size
+ self.colourspace = colourspace
+ if gamut is None or isinstance(gamut, Gamut):
+ self.gamut = gamut
+ else:
+ self.gamut = Gamut(*gamut)
+
+ def make_ramps(self):
+ '''
+ Construct a `Ramps` instances for this CRTC
+
+ @return :Ramps An instance of `Ramps` with same a number of ramp stops
+ matching this CRTC
+ '''
+ return Ramps(self.red_size, self.green_size, self.blue_size)
+
+ def clone(self, shallow = True):
+ '''
+ Create a copy of the instance
+
+ @param shallow:bool Create a shallow copy?
+ '''
+ return CRTCInfo(self.cooperative, self.depth, self.supported, self.red_size,
+ self.green_size, self.blue_size, self.colourspace,
+ self.gamut if shallow else self.gamut.clone())
+
+ def __repr__(self):
+ '''
+ Create a parsable string representation of the instance
+
+ @return :str Parsable representation of the instance
+ '''
+ params = (self.cooperative, self.depth, self.supported, self.red_size,
+ self.green_size, self.blue_size, self.colourspace, self.gamut)
+ return 'libcoopgamma.CRTCInfo(%s)' % ', '.join(repr(p) for p in params)
+
+
+class FilterQuery:
+ '''
+ Data sent to the coopgamma server when requestng the current filter table
+
+ @variable high_priority:int Do no return filters with higher priority than
+ this value. This is a signed 64-bit integer.
+ @variable low_priority:int Do no return filters with lower priority than
+ this value. This is a signed 64-bit integer.
+ @variable crtc:str The CRTC for which the the current filters shall returned
+ @variable coalesce:bool Whether to coalesce all filters into one gamma ramp triplet
+ '''
+ def __init__(self, high_priority = 9223372036854775807,
+ low_priority = -9223372036854775808, crtc = None, coalesce = False):
+ '''
+ Constructor
+
+ @param high_priority:int Do no return filters with higher priority than
+ this value. This is a signed 64-bit integer.
+ @param low_priority:int Do no return filters with lower priority than
+ this value. This is a signed 64-bit integer.
+ @param crtc:str The CRTC for which the the current filters shall returned
+ @param coalesce:bool Whether to coalesce all filters into one gamma ramp triplet
+ '''
+ self.high_priority = high_priority
+ self.low_priority = low_priority
+ self.crtc = crtc
+ self.coalesce = coalesce
+
+ def clone(self):
+ '''
+ Create a copy of the instance
+ '''
+ return FilterQuery(self.high_priority, self.low_priority, self.crtc, self.coalesce)
+
+ def __repr__(self):
+ '''
+ Create a parsable string representation of the instance
+
+ @return :str Parsable representation of the instance
+ '''
+ params = (self.high_priority, self.low_priority, self.crtc, self.coalesce)
+ return 'libcoopgamma.FilterQuery(%s)' % ', '.join(repr(p) for p in params)
+
+
+class QueriedFilter:
+ '''
+ Stripped down version of `Filter` which only contains the
+ information returned in response to "Command: get-gamma"
+
+ @variable priority:int The filter's priority. This is a signed 64-bit integer.
+ @variable fclass:str The filter's class
+ @variable ramps:Ramps The gamma ramp adjustments of the filter
+ '''
+ def __init__(self, priority = None, fclass = None, ramps = None):
+ '''
+ Constructor
+
+ @param priority:int The filter's priority. This is a signed 64-bit integer.
+ @param fclass:str The filter's class
+ @param ramps:Ramps|tuple The gamma ramp adjustments of the filter
+ '''
+ self.priority = priority
+ self.fclass = fclass
+ self.ramps = None
+ if ramps is not None:
+ self.ramps = Ramps(*ramps) if isinstance(ramps, tuple) else ramps
+
+ def clone(self, shallow = False):
+ '''
+ Create a copy of the instance
+
+ @param shallow:bool Create a sallow copy?
+ '''
+ ramps = self.ramps if shallow else self.ramps.clone()
+ return QueriedFilter(self.priority, self.fclass, ramps)
+
+ def __repr__(self):
+ '''
+ Create a parsable string representation of the instance
+
+ @return :str Parsable representation of the instance
+ '''
+ params = (self.priority, self.fclass, self.ramps)
+ return 'libcoopgamma.QueriedFilter(%s)' % ', '.join(repr(p) for p in params)
+
+
+class FilterTable:
+ '''
+ Response type for "Command: get-gamma": a list of applied filters
+ and meta-information that was necessary for decoding the response
+
+ @variable red_size:int The number of stops in the red ramp
+ @variable green_size:int The number of stops in the green ramp
+ @variable blue_size:int The number of stops in the blue ramp
+ @variable depth:Depth The data type and bit-depth of the ramp stops
+ @variable filters:list<QueriedFilter> The filters, should be ordered by priority
+ in descending order, lest there is something
+ wrong with the coopgamma server.
+ If filter coalition was requested, there will
+ be exactly one filter and `filters[0].class`
+ and `filters[0].priority` are undefined.
+ '''
+ def __init__(self, red_size = None, green_size = None, blue_size = None, depth = None, filters = None):
+ '''
+ Constructor
+
+ @param red_size:int The number of stops in the red ramp
+ @param green_size:int The number of stops in the green ramp
+ @param blue_size:int The number of stops in the blue ramp
+ @param depth:Depth The data type and bit-depth of the ramp stops
+ @param filters:list<QueriedFilter|tuple> The filters, should be ordered by priority
+ in descending order, lest there is something
+ wrong with the coopgamma server.
+ If filter coalition was requested, there will
+ be exactly one filter and `filters[0].class`
+ and `filters[0].priority` are undefined.
+ '''
+ self.red_size = red_size
+ self.green_size = green_size
+ self.blue_size = blue_size
+ self.depth = depth
+ if filters is None:
+ self.filters
+ else:
+ self.filters = list(QueriedFilter(*f) if isinstance(f, tuple) else f for f in filters)
+
+ def make_ramps(self):
+ '''
+ Construct a `Ramps` instances for this CRTC
+
+ @return :Ramps An instance of `Ramps` with same a number of ramp stops
+ matching this CRTC
+ '''
+ return Ramps(self.red_size, self.green_size, self.blue_size)
+
+ def clone(self, shallow = False):
+ '''
+ Create a copy of the instance
+
+ @param shallow:bool Create a sallow copy?
+ '''
+ filters = list(self.filters) if shallow else [f.clone() for f in self.filters]
+ return FilterTable(self.red_size, self.green_size, self.blue_size, self.depth, filters)
+
+ def __repr__(self):
+ '''
+ Create a parsable string representation of the instance
+
+ @return :str Parsable representation of the instance
+ '''
+ params = (self.red_size, self.green_size, self.blue_size, self.depth, self.filters)
+ return 'libcoopgamma.FilterTable(%s)' % ', '.join(repr(p) for p in params)
+
+
+class ErrorReport:
+ '''
+ Error message from coopgamma server
+
+ @variable number:int The error code. If `.custom` is false, 0 indicates success,
+ otherwise, 0 indicates that no error code has been assigned.
+ @variable custom:bool Is this a custom error?
+ @variable server_side:bool Did the error occur on the server-side?
+ @variable description:str? Error message, can be `None` if `custom` is false
+ '''
+ def __init__(self, number = None, custom = None, server_side = None, description = None):
+ '''
+ Constructor
+
+ @param number:int The error code. If `.custom` is false, 0 indicates success,
+ otherwise, 0 indicates that no error code has been assigned.
+ @param custom:bool Is this a custom error?
+ @param server_side:bool Did the error occur on the server-side?
+ @param description:str? Error message, can be `None` if `custom` is false
+ '''
+ self.number = number
+ self.custom = custom
+ self.server_side = server_side
+ self.description = description
+
+ def clone(self):
+ '''
+ Create a copy of the instance
+ '''
+ return ErrorReport(self.number, self.custom, self.server_side, self.description)
+
+ def __repr__(self):
+ '''
+ Create a parsable string representation of the instance
+
+ @return :str Parsable representation of the instance
+ '''
+ params = (self.number, self.custom, self.server_side, self.description)
+ return 'libcoopgamma.ErrorReport(%s)' % ', '.join(repr(p) for p in params)
+
+ @staticmethod
+ def create_error(error):
+ '''
+ Create an instance of a subclass of `Exception`
+
+ @param error Error information
+ '''
+ if isinstance(error, int):
+ import os
+ return OSError(error, os.strerror(error))
+ error = ErrorReport(*error)
+ if not error.custom and not error.server_side:
+ import os
+ return OSError(error.number, os.strerror(error.number))
+ else:
+ return LibcoopgammaError(error)
+
+
+class LibcoopgammaError(Exception):
+ '''
+ libcoopgamma error class
+
+ @variable error:ErrorReport Error information
+ '''
+ def __init__(self, error):
+ '''
+ Constructor
+
+ @param error:ErrorReport Error information
+ '''
+ self.error = error
+
+ def __str__(self):
+ '''
+ Return description and error number as a string
+
+ @return :str Description and error number
+ '''
+ if self.error.description is not None:
+ if self.error.number != 0:
+ return '%s (#%i)' % (self.error.description, self.error.number)
+ else:
+ return '%s' % self.error.description
+ else:
+ return '#%i' % self.error.number
+
+ def __repr__(self):
+ '''
+ Create a parsable string representation of the instance
+
+ @return :str Parsable representation of the instance
+ '''
+ return 'libcoopgamma.LibcoopgammaError(%s)' % repr(self.error)
+
+
+class IncompatibleDowngradeError(Exception):
+ '''
+ Unmarshalled state from a newer version, that is not supported, of libcoopgamma
+ '''
+ def __init__(self):
+ '''
+ Constructor
+ '''
+ pass
+
+ def __str__(self):
+ '''
+ Return descriptor of the error
+
+ @return :str Descriptor of the error
+ '''
+ return 'Incompatible downgrade error'
+
+ def __repr__(self):
+ '''
+ Create a parsable string representation of the instance
+
+ @return :str Parsable representation of the instance
+ '''
+ return 'libcoopgamma.IncompatibleDowngradeError()'
+
+
+class IncompatibleUpgradeError(Exception):
+ '''
+ Unmarshalled state from an older version, that is no longer supported, of libcoopgamma
+ '''
+ def __init__(self):
+ '''
+ Constructor
+ '''
+ pass
+
+ def __str__(self):
+ '''
+ Return descriptor of the error
+
+ @return :str Descriptor of the error
+ '''
+ return 'Incompatible downgrade error'
+
+ def __repr__(self):
+ '''
+ Create a parsable string representation of the instance
+
+ @return :str Parsable representation of the instance
+ '''
+ return 'libcoopgamma.IncompatibleUpgradeErrorError()'
+
+
+class ServerInitialisationError(Exception):
+ '''
+ coopgamma server failed to initialise, reason unknown
+ '''
+ def __init__(self):
+ '''
+ Constructor
+ '''
+ pass
+
+ def __str__(self):
+ '''
+ Return descriptor of the error
+
+ @return :str Descriptor of the error
+ '''
+ return 'Server initialisation error'
+
+ def __repr__(self):
+ '''
+ Create a parsable string representation of the instance
+
+ @return :str Parsable representation of the instance
+ '''
+ return 'libcoopgamma.ServerInitialisationError()'
+
+
+class Context:
+ '''
+ Library state
+
+ Use of this structure is not thread-safe, create
+ one instance per thread that uses this structure
+
+ @variable fd:int File descriptor for the socket
+ '''
+ def __init__(self, fd = -1, buf = None):
+ '''
+ Constructor
+
+ @param fd:int File descriptor for the socket
+ @param buf:bytes? Buffer to unmarshal
+ '''
+ self.address = None
+ self.fd = fd
+ if buf is None:
+ (successful, value) = _libcoopgamma_native_context_create()
+ if not successful:
+ raise ErrorReport.create_error(value)
+ else:
+ (error, value) = _libcoopgamma_native_context_unmarshal(buf)
+ if error < 0:
+ raise ErrorReport.create_error(value)
+ elif error == 1:
+ raise IncompatibleDowngradeError()
+ elif error == 2:
+ raise IncompatibleUpgradeError()
+ self.address = value
+
+ def __del__(self):
+ '''
+ Destructor
+ '''
+ if self.address is not None:
+ _libcoopgamma_native_context_free(self.address)
+
+ def __repr__(self):
+ '''
+ Create a parsable string representation of the instance
+
+ @return :str Parsable representation of the instance
+ '''
+ data = _libcoopgamma_native_context_marshal(self.address)
+ if isinstance(data, int):
+ raise ErrorReport.create_error(data)
+ params = (self.fd, data)
+ return 'libcoopgamma.Context(%s)' % ', '.join(repr(p) for p in params)
+
+ def connect(self, method = None, site = None):
+ '''
+ Connect to a coopgamma server, and start it if necessary
+
+ Use `del` keyword to disconnect
+
+ SIGCHLD must not be ignored or blocked
+
+ All other methods in this class requires that this
+ method has been called successfully
+
+ @param method:int|str? The adjustment method, `None` for automatic
+ @param site:str? The site, `None` for automatic
+ '''
+ if method is not None and isinstance(method, int):
+ method = str(method)
+ (successful, value) = _libcoopgamma_native_connect(method, site, self.address)
+ if not successful:
+ if value == 0:
+ raise ServerInitialisationError()
+ else:
+ raise ErrorReport.create_error(value)
+ self.fd = value
+
+ def detach(self):
+ '''
+ After calling this function, communication with the
+ server is impossible, but the connection is not
+ closed and the when the instance is destroyed the
+ connection will remain
+ '''
+ _libcoopgamma_native_context_set_fd(self.address, -1)
+
+ def attach(self):
+ '''
+ Undoes the action of `detach`
+ '''
+ _libcoopgamma_native_context_set_fd(self.address, self.fd)
+
+ def set_nonbreaking(self, nonbreaking):
+ '''
+ By default communication is blocking, this function
+ can be used to switch between blocking and nonblocking
+
+ After setting the communication to nonblocking, `flush`, `synchronise` and
+ and request-sending functions can fail with EAGAIN and EWOULDBLOCK. It is
+ safe to continue with `flush` (for `flush` it selfand equest-sending functions)
+ or `synchronise` just like EINTR failure.
+
+ @param nonblocking:bool Nonblocking mode?
+ '''
+ error = _libcoopgamma_native_set_nonblocking(self.address, nonbreaking)
+ if error != 0:
+ raise ErrorReport.create_error(error)
+
+ def flush(self):
+ '''
+ Send all pending outbound data
+
+ If this function or another function that sends a request to the server fails
+ with EINTR, call this function to complete the transfer. The `async_ctx` parameter
+ will always be in a properly configured state if a function fails with EINTR.
+ '''
+ error = _libcoopgamma_native_flush(self.address)
+ if error != 0:
+ raise ErrorReport.create_error(error)
+
+ def synchronise(self, pending):
+ '''
+ Wait for the next message to be received
+
+ @param pending:list<AsyncContext> Information for each pending request
+ @return :int? The index of the element in `pending` which corresponds
+ to the first inbound message, note that this only means
+ that the message is not for any of the other request,
+ if the message is corrupt any of the listed requests can
+ be selected even if it is not for any of the requests.
+ Functions that parse the message will detect such corruption.
+ `None` if the message is ignored, which happens if
+ corresponding AsyncContext is not listed.
+ '''
+ pending = [p.address for p in pending]
+ (successful, value) = _libcoopgamma_native_synchronise(self.address, pending)
+ if not successful:
+ if value == 0:
+ return None
+ else:
+ raise ErrorReport.create_error(value)
+ else:
+ return value
+
+ def skip_message(self):
+ '''
+ Tell the library that you will not be parsing a receive message
+ '''
+ _libcoopgamma_native_skip_message(self.address)
+
+ def get_crtcs_send(self, async_ctx):
+ '''
+ List all available CRTC:s, send request part
+
+ @param async_ctx:AsyncContext Slot for information about the request that is
+ needed to identify and parse the response
+ '''
+
+ error = _libcoopgamma_native_get_crtcs_send(self.address, async_ctx.address)
+ if error != 0:
+ raise ErrorReport.create_error(error)
+
+ def get_crtcs_recv(self, async_ctx):
+ '''
+ List all available CRTC:s, receive response part
+
+ @param async_ctx:AsyncContext Information about the request
+ @return :list<str> A list of names. You should only free the outer
+ pointer, inner pointers are subpointers of the
+ outer pointer and cannot be freed.
+ '''
+ ret = _libcoopgamma_native_get_crtcs_recv(self.address, async_ctx.address)
+ if isinstance(ret, int):
+ raise ErrorReport.create_error(ret)
+ return ret
+
+ def get_crtcs_sync(self):
+ '''
+ List all available CRTC:s, synchronous version
+
+ This is a synchronous request function, as such, you have to ensure that
+ communication is blocking (default), and that there are not asynchronous
+ requests waiting, it also means that EINTR:s are silently ignored and
+ there no wait to cancel the operation without disconnection from the server
+
+ @return :list<str> A list of names. You should only free the outer pointer, inner
+ pointers are subpointers of the outer pointer and cannot be freed.
+ '''
+ ret = _libcoopgamma_native_get_crtcs_sync(self.address)
+ if isinstance(ret, int):
+ raise ErrorReport.create_error(ret)
+ return ret
+
+ def get_gamma_info_send(self, crtc, async_ctx):
+ '''
+ Retrieve information about a CRTC:s gamma ramps, send request part
+
+ @param crtc:str The name of the CRT
+ @param async_ctx:AsyncContext Slot for information about the request that is
+ needed to identify and parse the response
+ '''
+ error = _libcoopgamma_native_get_gamma_info_send(crtc, self.address, async_ctx.address)
+ if error != 0:
+ raise ErrorReport.create_error(error)
+
+ def get_gamma_info_recv(self, async_ctx):
+ '''
+ Retrieve information about a CRTC:s gamma ramps, receive response part
+
+ @param async_ctx:AsyncContext Information about the request
+ @return :CRTCInfo Information about the CRTC
+ '''
+ value = _libcoopgamma_native_get_gamma_info_recv(self.address, async_ctx.address)
+ if isinstance(value, int):
+ raise ErrorReport.create_error(value)
+ (successful, value) = value
+ if not successful:
+ raise ErrorReport.create_error(value)
+ return CRTCInfo(*value)
+
+ def get_gamma_info_sync(self, crtc):
+ '''
+ Retrieve information about a CRTC:s gamma ramps, synchronous version
+
+ This is a synchronous request function, as such, you have to ensure that
+ communication is blocking (default), and that there are not asynchronous
+ requests waiting, it also means that EINTR:s are silently ignored and
+ there no wait to cancel the operation without disconnection from the server
+
+ @param crtc:str The name of the CRT
+ @return :CRTCInfo Information about the CRTC
+ '''
+ value = _libcoopgamma_native_get_gamma_info_sync(crtc, self.address)
+ if isinstance(value, int):
+ raise ErrorReport.create_error(value)
+ (successful, value) = value
+ if not successful:
+ raise ErrorReport.create_error(value)
+ return CRTCInfo(*value)
+
+ def get_gamma_send(self, query, async_ctx):
+ '''
+ Retrieve the current gamma ramp adjustments, send request part
+
+ @param query:FilterQuery The query to send
+ @param async_ctx:AsyncContext Slot for information about the request that is
+ needed to identify and parse the response
+ '''
+ error = _libcoopgamma_native_get_gamma_send(
+ query, self.address, async_ctx.address)
+ if error != 0:
+ raise ErrorReport.create_error(error)
+
+ def get_gamma_recv(self, async_ctx):
+ '''
+ Retrieve the current gamma ramp adjustments, receive response part
+
+ @param async_ctx:AsyncContext Information about the request
+ @return :FilterTable Filter table
+ '''
+ value = _libcoopgamma_native_get_gamma_recv(self.address, async_ctx.address)
+ if isinstance(value, int):
+ raise ErrorReport.create_error(value)
+ (successful, value) = value
+ if not successful:
+ raise ErrorReport.create_error(value)
+ return FilterTable(*value)
+
+ def get_gamma_sync(self, query):
+ '''
+ Retrieve the current gamma ramp adjustments, synchronous version
+
+ This is a synchronous request function, as such, you have to ensure that
+ communication is blocking (default), and that there are not asynchronous
+ requests waiting, it also means that EINTR:s are silently ignored and
+ there no wait to cancel the operation without disconnection from the server
+
+ @param query:FilterQuery The query to send
+ @return :FilterTable Filter table
+ '''
+ value = _libcoopgamma_native_get_gamma_sync(query, self.address)
+ if isinstance(value, int):
+ raise ErrorReport.create_error(value)
+ (successful, value) = value
+ if not successful:
+ raise ErrorReport.create_error(value)
+ return FilterTable(*value)
+
+ def set_gamma_send(self, filtr, async_ctx):
+ '''
+ Apply, update, or remove a gamma ramp adjustment, send request part
+
+ @param filtr:Filter The filter to apply, update, or remove, gamma ramp
+ meta-data must match the CRTC's
+ @param async_ctx:AsyncContext Slot for information about the request that is
+ needed to identify and parse the response
+ '''
+ error = _libcoopgamma_native_set_gamma_send(filtr, self.address, async_ctx.address)
+ if error != 0:
+ raise ErrorReport.create_error(error)
+
+ def set_gamma_recv(self, async_ctx):
+ '''
+ Apply, update, or remove a gamma ramp adjustment, receive response part
+
+ @param async_ctx:AsyncContext Information about the request
+ '''
+ error = _libcoopgamma_native_set_gamma_recv(self.address, async_ctx.address)
+ if error is not None:
+ raise ErrorReport.create_error(error)
+
+ def set_gamma_sync(self, filtr):
+ '''
+ Apply, update, or remove a gamma ramp adjustment, synchronous version
+
+ This is a synchronous request function, as such, you have to ensure that
+ communication is blocking (default), and that there are not asynchronous
+ requests waiting, it also means that EINTR:s are silently ignored and
+ there no wait to cancel the operation without disconnection from the server
+
+ @param filtr:Filter The filter to apply, update, or remove,
+ gamma ramp meta-data must match the CRTC's
+ '''
+ error = _libcoopgamma_native_set_gamma_sync(filtr, self.address)
+ if error is not None:
+ raise ErrorReport.create_error(error)
+
+
+class AsyncContext:
+ '''
+ Information necessary to identify and parse a response from the server
+ '''
+ def __init__(self, buf = None):
+ '''
+ Constructor
+
+ @param buf:bytes? Buffer to unmarshal
+ '''
+ self.address = None
+ if buf is None:
+ (successful, value) = _libcoopgamma_native_async_context_create()
+ if not successful:
+ raise ErrorReport.create_error(value)
+ else:
+ (error, value) = _libcoopgamma_native_async_context_unmarshal(buf)
+ if error < 0:
+ raise ErrorReport.create_error(value)
+ elif error == 1:
+ raise IncompatibleDowngradeError()
+ elif error == 2:
+ raise IncompatibleUpgradeError()
+ self.address = value
+
+ def __del__(self):
+ '''
+ Destructor
+ '''
+ if self.address is not None:
+ _libcoopgamma_native_async_context_free(self.address)
+
+ def __repr__(self):
+ '''
+ Create a parsable string representation of the instance
+
+ @return :str Parsable representation of the instance
+ '''
+ data = _libcoopgamma_native_async_context_marshal(self.address)
+ if isinstance(data, int):
+ raise ErrorReport.create_error(data)
+ return 'libcoopgamma.AsyncContext(%s)' % repr(data)
+
+
+def get_methods():
+ '''
+ List all recognised adjustment method
+
+ SIGCHLD must not be ignored or blocked
+
+ @return :list<str> A list of names. You should only free the outer pointer, inner
+ pointers are subpointers of the outer pointer and cannot be freed.
+ '''
+ ret = _libcoopgamma_native_get_methods()
+ if isinstance(ret, int):
+ raise ErrorReport.create_error(ret)
+ return ret
+
+
+def get_method_and_site(method = None, site = None):
+ '''
+ Get the adjustment method and site
+
+ SIGCHLD must not be ignored or blocked
+
+ @param method:int|str? The adjustment method, `None` for automatic
+ @param site:str? The site, `None` for automatic
+ @return :(:str, :str?) The selected adjustment method and the selected the
+ selected site. If the adjustment method only supports
+ one site or if `site` is `None` and no site can be
+ selected automatically, the selected site (the second
+ element in the returned tuple) will be `None`.
+ '''
+ if method is not None:
+ method = str(method)
+ ret = _libcoopgamma_native_get_method_and_site(method, site)
+ if isinstance(ret, int):
+ raise ErrorReport.create_error(ret)
+ return ret
+
+
+def get_pid_file(method = None, site = None):
+ '''
+ Get the PID file of the coopgamma server
+
+ SIGCHLD must not be ignored or blocked
+
+ @param method:int|str? The adjustment method, `None` for automatic
+ @param site:str? The site, `None` for automatic
+ @return :str? The pathname of the server's PID file.
+ `None` if the server does not use PID files.
+ '''
+ if method is not None:
+ method = str(method)
+ ret = _libcoopgamma_native_get_pid_file(method, site)
+ if ret is not None and isinstance(ret, int):
+ raise ErrorReport.create_error(ret)
+ return ret
+
+
+def get_socket_file(method = None, site = None):
+ '''
+ Get the socket file of the coopgamma server
+
+ SIGCHLD must not be ignored or blocked
+
+ @param method:int|str? The adjustment method, `None` for automatic
+ @param site:str? The site, `None` for automatic
+ @return :str? The pathname of the server's socket, `None` if the server does have
+ its own socket, which is the case when communicating with a server
+ in a multi-server display server like mds
+ '''
+ if method is not None:
+ method = str(method)
+ ret = _libcoopgamma_native_get_socket_file(method, site)
+ if ret is not None and isinstance(ret, int):
+ raise ErrorReport.create_error(ret)
+ return ret
diff --git a/src/include-libcoopgamma.h b/src/include-libcoopgamma.h
deleted file mode 100644
index 5150bf3..0000000
--- a/src/include-libcoopgamma.h
+++ /dev/null
@@ -1,28 +0,0 @@
-/**
- * pylibcoopgamma -- Python library for interfacing with cooperative gamma servers
- * Copyright (C) 2016 Mattias Andrée (maandree@kth.se)
- *
- * This library is free software: you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation, either version 3 of the License, or
- * (at your option) any later version.
- *
- * This library is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this library. If not, see <http://www.gnu.org/licenses/>.
- */
-#include <libcoopgamma.h>
-
-
-#define fclass class
-#define u_red_size u8.red_size
-#define u_green_size u8.green_size
-#define u_blue_size u8.blue_size
-#define u_red u8.red
-#define u_green u8.green
-#define u_blue u8.blue
-
diff --git a/src/libcoopgamma.py b/src/libcoopgamma.py
deleted file mode 100644
index 37856c1..0000000
--- a/src/libcoopgamma.py
+++ /dev/null
@@ -1,1205 +0,0 @@
-# -*- python -*-
-'''
-pylibcoopgamma -- Python library for interfacing with cooperative gamma servers
-Copyright (C) 2016 Mattias Andrée (maandree@kth.se)
-
-This library is free software: you can redistribute it and/or modify
-it under the terms of the GNU General Public License as published by
-the Free Software Foundation, either version 3 of the License, or
-(at your option) any later version.
-
-This library is distributed in the hope that it will be useful,
-but WITHOUT ANY WARRANTY; without even the implied warranty of
-MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-GNU General Public License for more details.
-
-You should have received a copy of the GNU General Public License
-along with this library. If not, see <http://www.gnu.org/licenses/>.
-'''
-
-import enum, libcoopgamma_native
-
-
-class Support(enum.IntEnum):
- '''
- Values used to indicate the support for gamma adjustments
-
- @value NO=0 Gamma adjustments are not supported
- @value MAYBE=1 Don't know whether gamma adjustments are supported
- @value YES=2 Gamma adjustments are supported
- '''
- NO = 0
- MAYBE = 1
- YES = 2
-
- @staticmethod
- def str(v):
- '''
- Get string representation of a value
-
- @param v:int The value, must be value of the enum
- @return :str Human-readable string representation of the value
- '''
- if v == Support.NO:
- return 'no'
- if v == Support.YES:
- return 'yes'
- if v == Support.MAYBE:
- return 'maybe'
- raise ValueError()
-
-
-class Depth(enum.IntEnum):
- '''
- Values used to tell which datatype is used for the gamma ramp stops
-
- The values will always be the number of bits for integral types, and
- negative for floating-point types
-
- @value UINT8=8 Unsigned 8-bit integer
- @value UINT16=16 Unsigned 16-bit integer
- @value UINT32=32 Unsigned 32-bit integer
- @value UINT64=64 Unsigned 64-bit integer
- @value FLOAT<0 Single-precision floating-point
- @value DOUBLE<0 Double-precision floating-point
- '''
- UINT8 = 8
- UINT16 = 16
- UINT32 = 32
- UINT64 = 64
- FLOAT = -1
- DOUBLE = -2
-
- @staticmethod
- def str(v):
- '''
- Get string representation of a value
-
- @param v:int The value, must be value of the enum
- @return :str Human-readable string representation of the value
- '''
- if v == Depth.UINT8:
- return '8-bits'
- if v == Depth.UINT16:
- return '16-bits'
- if v == Depth.UINT32:
- return '32-bits'
- if v == Depth.UINT64:
- return '64-bits'
- if v == Depth.FLOAT:
- return 'single-precision floating-point'
- if v == Depth.DOUBLE:
- return 'double-precision floating-point'
- raise ValueError()
-
-
-class Lifespan(enum.IntEnum):
- '''
- Values used to tell when a filter should be removed
-
- @value REMOVE=0 Remove the filter now
- @value UNTIL_DEATH>0 Remove the filter when disconnecting from the coopgamma server
- @value UNTIL_REMOVAL>0 Only remove the filter when it is explicitly requested
- '''
- REMOVE = 0
- UNTIL_DEATH = 1
- UNTIL_REMOVAL = 2
-
- @staticmethod
- def str(v):
- '''
- Get string representation of a value
-
- @param v:int The value, must be value of the enum
- @return :str Human-readable string representation of the value
- '''
- if v == Lifespan.REMOVE:
- return 'remove'
- if v == Lifespan.UNTIL_DEATH:
- return 'until death'
- if v == Lifespan.UNTIL_REMOVAL:
- return 'until removal'
- raise ValueError()
-
-
-class Colourspace(enum.IntEnum):
- '''
- Colourspaces
-
- @value UNKNOWN=0 The colourspace is unknown
- @value SRGB>0 sRGB (Standard RGB)
- @value RGB>0 RGB other than sRGB
- @value NON_RGB>0 Non-RGB multicolour
- @value GREY>0 Monochrome, greyscale, or some other singlecolour scale
- '''
- UNKNOWN = 0
- SRGB = 1
- RGB = 2
- NON_RGB = 3
- GREY = 4
-
- @staticmethod
- def str(v):
- '''
- Get string representation of a value
-
- @param v:int The value, must be value of the enum
- @return :str Human-readable string representation of the value
- '''
- if v == Colourspace.UNKNOWN:
- return 'unknown'
- if v == Colourspace.SRGB:
- return 'sRGB'
- if v == Colourspace.RGB:
- return 'RGB'
- if v == Colourspace.NON_RGB:
- return 'non-RGB'
- if v == Colourspace.GREY:
- return 'greyscale'
- raise ValueError()
-
-
-class Ramps:
- '''
- Gamma ramp structure
-
- @variable red:list<int> The red gamma ramp
- @variable green:list<int> The green gamma ramp
- @variable blue:list<int> The blue gamma ramp
- '''
- def __init__(self, red, green, blue):
- '''
- Constructor
-
- @param red:int The number of stops in the red ramp
- @param green:int The number of stops in the green ramp
- @param blue:int The number of stops in the blue ramp
-
- -- or --
-
- @param red:list<int> The red gamma ramp
- @param green:list<int> The green gamma ramp
- @param blue:list<int> The blue gamma ramp
- '''
- if isinstance(red, list):
- self.red = list(red)
- self.green = list(green)
- self.blue = list(blue)
- else:
- self.red = [0] * red
- self.green = [0] * green
- self.blue = [0] * blue
-
- def clone(self):
- '''
- Create a copy of the instance
- '''
- return Ramps(self.red, self.green, self.blue)
-
- def __repr__(self):
- '''
- Create a parsable string representation of the instance
-
- @return :str Parsable representation of the instance
- '''
- params = (self.red, self.green, self.blue)
- return 'libcoopgamma.Ramps(%s)' % ', '.join(repr(p) for p in params)
-
-
-class Filter:
- '''
- Data set to the coopgamma server to apply, update, or remove a filter
-
- @variable priority:int The priority of the filter, higher priority
- is applied first. The gamma correction should
- have priority 0. This is a signed 64-bit integer.
- @variable crtc:str The CRTC for which this filter shall be applied
- @variable fclass:str Identifier for the filter.
- The syntax must be "${PACKAGE_NAME}::${COMMAND_NAME}::${RULE}".
- @variable lifespan:Lifespan When shall the filter be removed?
- If this member's value is `LIBCOOPGAMMA_REMOVE`,
- only `.crtc` and `.class` need also be defined.
- @variable depth:Depth The data type and bit-depth of the ramp stops
- @variable ramps:Ramps The gamma ramp adjustments of the filter
- '''
- def __init__(self, priority = None, crtc = None, fclass = None, lifespan = None, depth = None, ramps = None):
- '''
- Constructor
-
- @param priority:int The priority of the filter, higher priority
- is applied first. The gamma correction should
- have priority 0. This is a signed 64-bit integer.
- @param crtc:str The CRTC for which this filter shall be applied
- @param fclass:str Identifier for the filter.
- The syntax must be "${PACKAGE_NAME}::${COMMAND_NAME}::${RULE}".
- @param lifespan:Lifespan When shall the filter be removed?
- If this member's value is `LIBCOOPGAMMA_REMOVE`,
- only `.crtc` and `.class` need also be defined.
- @param depth:Depth The data type and bit-depth of the ramp stops
- @param ramps:Ramps The gamma ramp adjustments of the filter
- '''
- self.priority = priority
- self.crtc = crtc
- self.fclass = fclass
- self.lifespan = lifespan
- self.depth = depth
- self.ramps = ramps
-
- def clone(self, shallow = False):
- '''
- Create a copy of the instance
-
- @param shallow:bool Create a shallow copy?
- '''
- ramps = self.ramps if shallow else self.ramps.clone()
- return Filter(self.priority, self.crtc, self.fclass, self.lifespan, self.depth, ramps)
-
- def __repr__(self):
- '''
- Create a parsable string representation of the instance
-
- @return :str Parsable representation of the instance
- '''
- params = (self.priority, self.crtc, self.fclass, self.lifespan, self.depth, self.ramps)
- return 'libcoopgamma.Filter(%s)' % ', '.join(repr(p) for p in params)
-
-
-class GamutPoint:
- '''
- The x- and y-values (CIE xyY) of a colour
-
- @variable x_raw:int The x-value (CIE xyY) multiplied by 1024
- @variable y_raw:int The y-value (CIE xyY) multiplied by 1024
- @variable x:int The x-value (CIE xyY)
- @variable y:int The y-value (CIE xyY)
- '''
- def __init__(self, x, y):
- '''
- Constructor
-
- @param x:int The x-value (CIE xyY) multiplied by 1024
- @param y:int The y-value (CIE xyY) multiplied by 1024
- '''
- self.x_raw, self.x = x, x / 1024
- self.y_raw, self.y = y, y / 1024
-
- def clone(self):
- '''
- Create a copy of the instance
- '''
- return GamutPoint(self.x_raw, self.y_raw)
-
- def __repr__(self):
- '''
- Create a parsable string representation of the instance
-
- @return :str Parsable representation of the instance
- '''
- params = (self.x_raw, self.y_raw)
- return 'libcoopgamma.GamutPoint(%s)' % ', '.join(repr(p) for p in params)
-
- def __str__(self):
- '''
- Get human-readable string representation of instance
-
- @return :str Human-readable string representation of instance
- '''
- return '(%f, %f)' % (self.x, self.y)
-
-
-class Gamut:
- '''
- The values of the monitor's colour stimuli
-
- @variable red:GamutPoint The red stimuli
- @variable green:GamutPoint The green stimuli
- @variable blue:GamutPoint The blue stimuli
- @variable white:GamutPoint The default whitepoint
- '''
- def __init__(self, red = None, green = None, blue = None, white = None):
- '''
- Constructor
-
- @param red:GamutPoint|(int, int) The red stimuli
- @param green:GamutPoint|(int, int) The green stimuli
- @param blue:GamutPoint|(int, int) The blue stimuli
- @param white:GamutPoint|(int, int) The default whitepoint
- '''
- self.red = GamutPoint(*red) if isinstance(red, tuple) else red
- self.green = GamutPoint(*green) if isinstance(green, tuple) else green
- self.blue = GamutPoint(*blue) if isinstance(blue, tuple) else blue
- self.white = GamutPoint(*white) if isinstance(white, tuple) else white
-
- def clone(self, shallow = True):
- '''
- Create a copy of the instance
-
- @param shallow:bool Create a shallow copy?
- '''
- if shallow:
- return Gamut(self.red, self.green, self.blue, self.white)
- return Gamut(self.red.clone(), self.green.clone(), self.blue.clone(), self.white.clone())
-
- def __repr__(self):
- '''
- Create a parsable string representation of the instance
-
- @return :str Parsable representation of the instance
- '''
- params = (repr(self.red), repr(self.green), repr(self.blue), repr(self.white))
- return 'libcoopgamma.Gamut(%s)' % ', '.join(repr(p) for p in params)
-
-
-class CRTCInfo:
- '''
- Gamma ramp meta information for a CRTC
-
- @variable cooperative:bool Is cooperative gamma server running?
- @variable depth:Depth? The data type and bit-depth of the ramp stops
- @variable supported:Support Is gamma adjustments supported on the CRTC?
- If not, `depth`, `red_size`, `green_size`,
- and `blue_size` are undefined
- @variable red_size:int? The number of stops in the red ramp
- @variable green_size:int? The number of stops in the green ramp
- @variable blue_size:int? The number of stops in the blue ramp
- @variable colourspace:Colourspace The monitor's colourspace
- @variable gamut:Gamut? Measurements of the monitor's colourspace,
- `None` if the this information is unavailable.
- If this is not `None`, but the colourspace
- is not RGB (or sRGB), there is something
- wrong. Always check the colourspace.
- '''
- def __init__(self, cooperative = None, depth = None, supported = None, red_size = None,
- green_size = None, blue_size = None, colourspace = None, gamut = None):
- '''
- Constructor
-
- @param cooperative:bool Is cooperative gamma server running?
- @param depth:Depth? The data type and bit-depth of the ramp stops
- @param supported:Support Is gamma adjustments supported on the CRTC?
- If not, `depth`, `red_size`, `green_size`,
- and `blue_size` are undefined
- @param red_size:int? The number of stops in the red ramp
- @param green_size:int? The number of stops in the green ramp
- @param blue_size:int? The number of stops in the blue ramp
- @param colourspace:Colourspace The monitor's colourspace
- @param gamut:Gamut|tuple? Measurements of the monitor's colourspace,
- `None` if the this information is unavailable
- '''
- self.cooperative = cooperative
- self.depth = depth
- self.supported = supported
- self.red_size = red_size
- self.green_size = green_size
- self.blue_size = blue_size
- self.colourspace = colourspace
- if gamut is None or isinstance(gamut, Gamut):
- self.gamut = gamut
- else:
- self.gamut = Gamut(*gamut)
-
- def make_ramps(self):
- '''
- Construct a `Ramps` instances for this CRTC
-
- @return :Ramps An instance of `Ramps` with same a number of ramp stops
- matching this CRTC
- '''
- return Ramps(self.red_size, self.green_size, self.blue_size)
-
- def clone(self, shallow = True):
- '''
- Create a copy of the instance
-
- @param shallow:bool Create a shallow copy?
- '''
- return CRTCInfo(self.cooperative, self.depth, self.supported, self.red_size,
- self.green_size, self.blue_size, self.colourspace,
- self.gamut if shallow else self.gamut.clone())
-
- def __repr__(self):
- '''
- Create a parsable string representation of the instance
-
- @return :str Parsable representation of the instance
- '''
- params = (self.cooperative, self.depth, self.supported, self.red_size,
- self.green_size, self.blue_size, self.colourspace, self.gamut)
- return 'libcoopgamma.CRTCInfo(%s)' % ', '.join(repr(p) for p in params)
-
-
-class FilterQuery:
- '''
- Data sent to the coopgamma server when requestng the current filter table
-
- @variable high_priority:int Do no return filters with higher priority than
- this value. This is a signed 64-bit integer.
- @variable low_priority:int Do no return filters with lower priority than
- this value. This is a signed 64-bit integer.
- @variable crtc:str The CRTC for which the the current filters shall returned
- @variable coalesce:bool Whether to coalesce all filters into one gamma ramp triplet
- '''
- def __init__(self, high_priority = 9223372036854775807,
- low_priority = -9223372036854775808, crtc = None, coalesce = False):
- '''
- Constructor
-
- @param high_priority:int Do no return filters with higher priority than
- this value. This is a signed 64-bit integer.
- @param low_priority:int Do no return filters with lower priority than
- this value. This is a signed 64-bit integer.
- @param crtc:str The CRTC for which the the current filters shall returned
- @param coalesce:bool Whether to coalesce all filters into one gamma ramp triplet
- '''
- self.high_priority = high_priority
- self.low_priority = low_priority
- self.crtc = crtc
- self.coalesce = coalesce
-
- def clone(self):
- '''
- Create a copy of the instance
- '''
- return FilterQuery(self.high_priority, self.low_priority, self.crtc, self.coalesce)
-
- def __repr__(self):
- '''
- Create a parsable string representation of the instance
-
- @return :str Parsable representation of the instance
- '''
- params = (self.high_priority, self.low_priority, self.crtc, self.coalesce)
- return 'libcoopgamma.FilterQuery(%s)' % ', '.join(repr(p) for p in params)
-
-
-class QueriedFilter:
- '''
- Stripped down version of `Filter` which only contains the
- information returned in response to "Command: get-gamma"
-
- @variable priority:int The filter's priority. This is a signed 64-bit integer.
- @variable fclass:str The filter's class
- @variable ramps:Ramps The gamma ramp adjustments of the filter
- '''
- def __init__(self, priority = None, fclass = None, ramps = None):
- '''
- Constructor
-
- @param priority:int The filter's priority. This is a signed 64-bit integer.
- @param fclass:str The filter's class
- @param ramps:Ramps|tuple The gamma ramp adjustments of the filter
- '''
- self.priority = priority
- self.fclass = fclass
- self.ramps = None
- if ramps is not None:
- self.ramps = Ramps(*ramps) if isinstance(ramps, tuple) else ramps
-
- def clone(self, shallow = False):
- '''
- Create a copy of the instance
-
- @param shallow:bool Create a sallow copy?
- '''
- ramps = self.ramps if shallow else self.ramps.clone()
- return QueriedFilter(self.priority, self.fclass, ramps)
-
- def __repr__(self):
- '''
- Create a parsable string representation of the instance
-
- @return :str Parsable representation of the instance
- '''
- params = (self.priority, self.fclass, self.ramps)
- return 'libcoopgamma.QueriedFilter(%s)' % ', '.join(repr(p) for p in params)
-
-
-class FilterTable:
- '''
- Response type for "Command: get-gamma": a list of applied filters
- and meta-information that was necessary for decoding the response
-
- @variable red_size:int The number of stops in the red ramp
- @variable green_size:int The number of stops in the green ramp
- @variable blue_size:int The number of stops in the blue ramp
- @variable depth:Depth The data type and bit-depth of the ramp stops
- @variable filters:list<QueriedFilter> The filters, should be ordered by priority
- in descending order, lest there is something
- wrong with the coopgamma server.
- If filter coalition was requested, there will
- be exactly one filter and `filters[0].class`
- and `filters[0].priority` are undefined.
- '''
- def __init__(self, red_size = None, green_size = None, blue_size = None, depth = None, filters = None):
- '''
- Constructor
-
- @param red_size:int The number of stops in the red ramp
- @param green_size:int The number of stops in the green ramp
- @param blue_size:int The number of stops in the blue ramp
- @param depth:Depth The data type and bit-depth of the ramp stops
- @param filters:list<QueriedFilter|tuple> The filters, should be ordered by priority
- in descending order, lest there is something
- wrong with the coopgamma server.
- If filter coalition was requested, there will
- be exactly one filter and `filters[0].class`
- and `filters[0].priority` are undefined.
- '''
- self.red_size = red_size
- self.green_size = green_size
- self.blue_size = blue_size
- self.depth = depth
- if filters is None:
- self.filters
- else:
- self.filters = list(QueriedFilter(*f) if isinstance(f, tuple) else f for f in filters)
-
- def make_ramps(self):
- '''
- Construct a `Ramps` instances for this CRTC
-
- @return :Ramps An instance of `Ramps` with same a number of ramp stops
- matching this CRTC
- '''
- return Ramps(self.red_size, self.green_size, self.blue_size)
-
- def clone(self, shallow = False):
- '''
- Create a copy of the instance
-
- @param shallow:bool Create a sallow copy?
- '''
- filters = list(self.filters) if shallow else [f.clone() for f in self.filters]
- return FilterTable(self.red_size, self.green_size, self.blue_size, self.depth, filters)
-
- def __repr__(self):
- '''
- Create a parsable string representation of the instance
-
- @return :str Parsable representation of the instance
- '''
- params = (self.red_size, self.green_size, self.blue_size, self.depth, self.filters)
- return 'libcoopgamma.FilterTable(%s)' % ', '.join(repr(p) for p in params)
-
-
-class ErrorReport:
- '''
- Error message from coopgamma server
-
- @variable number:int The error code. If `.custom` is false, 0 indicates success,
- otherwise, 0 indicates that no error code has been assigned.
- @variable custom:bool Is this a custom error?
- @variable server_side:bool Did the error occur on the server-side?
- @variable description:str? Error message, can be `None` if `custom` is false
- '''
- def __init__(self, number = None, custom = None, server_side = None, description = None):
- '''
- Constructor
-
- @param number:int The error code. If `.custom` is false, 0 indicates success,
- otherwise, 0 indicates that no error code has been assigned.
- @param custom:bool Is this a custom error?
- @param server_side:bool Did the error occur on the server-side?
- @param description:str? Error message, can be `None` if `custom` is false
- '''
- self.number = number
- self.custom = custom
- self.server_side = server_side
- self.description = description
-
- def clone(self):
- '''
- Create a copy of the instance
- '''
- return ErrorReport(self.number, self.custom, self.server_side, self.description)
-
- def __repr__(self):
- '''
- Create a parsable string representation of the instance
-
- @return :str Parsable representation of the instance
- '''
- params = (self.number, self.custom, self.server_side, self.description)
- return 'libcoopgamma.ErrorReport(%s)' % ', '.join(repr(p) for p in params)
-
- @staticmethod
- def create_error(error):
- '''
- Create an instance of a subclass of `Exception`
-
- @param error Error information
- '''
- if isinstance(error, int):
- import os
- return OSError(error, os.strerror(error))
- error = ErrorReport(*error)
- if not error.custom and not error.server_side:
- import os
- return OSError(error.number, os.strerror(error.number))
- else:
- return LibcoopgammaError(error)
-
-
-class LibcoopgammaError(Exception):
- '''
- libcoopgamma error class
-
- @variable error:ErrorReport Error information
- '''
- def __init__(self, error):
- '''
- Constructor
-
- @param error:ErrorReport Error information
- '''
- self.error = error
-
- def __str__(self):
- '''
- Return description and error number as a string
-
- @return :str Description and error number
- '''
- if self.error.description is not None:
- if self.error.number != 0:
- return '%s (#%i)' % (self.error.description, self.error.number)
- else:
- return '%s' % self.error.description
- else:
- return '#%i' % self.error.number
-
- def __repr__(self):
- '''
- Create a parsable string representation of the instance
-
- @return :str Parsable representation of the instance
- '''
- return 'libcoopgamma.LibcoopgammaError(%s)' % repr(self.error)
-
-
-class IncompatibleDowngradeError(Exception):
- '''
- Unmarshalled state from a newer version, that is not supported, of libcoopgamma
- '''
- def __init__(self):
- '''
- Constructor
- '''
- pass
-
- def __str__(self):
- '''
- Return descriptor of the error
-
- @return :str Descriptor of the error
- '''
- return 'Incompatible downgrade error'
-
- def __repr__(self):
- '''
- Create a parsable string representation of the instance
-
- @return :str Parsable representation of the instance
- '''
- return 'libcoopgamma.IncompatibleDowngradeError()'
-
-
-class IncompatibleUpgradeError(Exception):
- '''
- Unmarshalled state from an older version, that is no longer supported, of libcoopgamma
- '''
- def __init__(self):
- '''
- Constructor
- '''
- pass
-
- def __str__(self):
- '''
- Return descriptor of the error
-
- @return :str Descriptor of the error
- '''
- return 'Incompatible downgrade error'
-
- def __repr__(self):
- '''
- Create a parsable string representation of the instance
-
- @return :str Parsable representation of the instance
- '''
- return 'libcoopgamma.IncompatibleUpgradeErrorError()'
-
-
-class ServerInitialisationError(Exception):
- '''
- coopgamma server failed to initialise, reason unknown
- '''
- def __init__(self):
- '''
- Constructor
- '''
- pass
-
- def __str__(self):
- '''
- Return descriptor of the error
-
- @return :str Descriptor of the error
- '''
- return 'Server initialisation error'
-
- def __repr__(self):
- '''
- Create a parsable string representation of the instance
-
- @return :str Parsable representation of the instance
- '''
- return 'libcoopgamma.ServerInitialisationError()'
-
-
-class Context:
- '''
- Library state
-
- Use of this structure is not thread-safe, create
- one instance per thread that uses this structure
-
- @variable fd:int File descriptor for the socket
- '''
- def __init__(self, fd = -1, buf = None):
- '''
- Constructor
-
- @param fd:int File descriptor for the socket
- @param buf:bytes? Buffer to unmarshal
- '''
- self.address = None
- self.fd = fd
- if buf is None:
- (successful, value) = libcoopgamma_native.libcoopgamma_native_context_create()
- if not successful:
- raise ErrorReport.create_error(value)
- else:
- (error, value) = libcoopgamma_native.libcoopgamma_native_context_unmarshal(buf)
- if error < 0:
- raise ErrorReport.create_error(value)
- elif error == 1:
- raise IncompatibleDowngradeError()
- elif error == 2:
- raise IncompatibleUpgradeError()
- self.address = value
-
- def __del__(self):
- '''
- Destructor
- '''
- if self.address is not None:
- libcoopgamma_native.libcoopgamma_native_context_free(self.address)
-
- def __repr__(self):
- '''
- Create a parsable string representation of the instance
-
- @return :str Parsable representation of the instance
- '''
- data = libcoopgamma_native.libcoopgamma_native_context_marshal(self.address)
- if isinstance(data, int):
- raise ErrorReport.create_error(data)
- params = (self.fd, data)
- return 'libcoopgamma.Context(%s)' % ', '.join(repr(p) for p in params)
-
- def connect(self, method = None, site = None):
- '''
- Connect to a coopgamma server, and start it if necessary
-
- Use `del` keyword to disconnect
-
- SIGCHLD must not be ignored or blocked
-
- All other methods in this class requires that this
- method has been called successfully
-
- @param method:int|str? The adjustment method, `None` for automatic
- @param site:str? The site, `None` for automatic
- '''
- if method is not None and isinstance(method, int):
- method = str(method)
- (successful, value) = libcoopgamma_native.libcoopgamma_native_connect(method, site, self.address)
- if not successful:
- if value == 0:
- raise ServerInitialisationError()
- else:
- raise ErrorReport.create_error(value)
- self.fd = value
-
- def detach(self):
- '''
- After calling this function, communication with the
- server is impossible, but the connection is not
- closed and the when the instance is destroyed the
- connection will remain
- '''
- libcoopgamma_native.libcoopgamma_native_context_set_fd(self.address, -1)
-
- def attach(self):
- '''
- Undoes the action of `detach`
- '''
- libcoopgamma_native.libcoopgamma_native_context_set_fd(self.address, self.fd)
-
- def set_nonbreaking(self, nonbreaking):
- '''
- By default communication is blocking, this function
- can be used to switch between blocking and nonblocking
-
- After setting the communication to nonblocking, `flush`, `synchronise` and
- and request-sending functions can fail with EAGAIN and EWOULDBLOCK. It is
- safe to continue with `flush` (for `flush` it selfand equest-sending functions)
- or `synchronise` just like EINTR failure.
-
- @param nonblocking:bool Nonblocking mode?
- '''
- error = libcoopgamma_native.libcoopgamma_native_set_nonblocking(self.address, nonbreaking)
- if error != 0:
- raise ErrorReport.create_error(error)
-
- def flush(self):
- '''
- Send all pending outbound data
-
- If this function or another function that sends a request to the server fails
- with EINTR, call this function to complete the transfer. The `async_ctx` parameter
- will always be in a properly configured state if a function fails with EINTR.
- '''
- error = libcoopgamma_native.libcoopgamma_native_flush(self.address)
- if error != 0:
- raise ErrorReport.create_error(error)
-
- def synchronise(self, pending):
- '''
- Wait for the next message to be received
-
- @param pending:list<AsyncContext> Information for each pending request
- @return :int? The index of the element in `pending` which corresponds
- to the first inbound message, note that this only means
- that the message is not for any of the other request,
- if the message is corrupt any of the listed requests can
- be selected even if it is not for any of the requests.
- Functions that parse the message will detect such corruption.
- `None` if the message is ignored, which happens if
- corresponding AsyncContext is not listed.
- '''
- pending = [p.address for p in pending]
- (successful, value) = libcoopgamma_native.libcoopgamma_native_synchronise(self.address, pending)
- if not successful:
- if value == 0:
- return None
- else:
- raise ErrorReport.create_error(value)
- else:
- return value
-
- def skip_message(self):
- '''
- Tell the library that you will not be parsing a receive message
- '''
- libcoopgamma_native.libcoopgamma_native_skip_message(self.address)
-
- def get_crtcs_send(self, async_ctx):
- '''
- List all available CRTC:s, send request part
-
- @param async_ctx:AsyncContext Slot for information about the request that is
- needed to identify and parse the response
- '''
-
- error = libcoopgamma_native.libcoopgamma_native_get_crtcs_send(self.address, async_ctx.address)
- if error != 0:
- raise ErrorReport.create_error(error)
-
- def get_crtcs_recv(self, async_ctx):
- '''
- List all available CRTC:s, receive response part
-
- @param async_ctx:AsyncContext Information about the request
- @return :list<str> A list of names. You should only free the outer
- pointer, inner pointers are subpointers of the
- outer pointer and cannot be freed.
- '''
- ret = libcoopgamma_native.libcoopgamma_native_get_crtcs_recv(self.address, async_ctx.address)
- if isinstance(ret, int):
- raise ErrorReport.create_error(ret)
- return ret
-
- def get_crtcs_sync(self):
- '''
- List all available CRTC:s, synchronous version
-
- This is a synchronous request function, as such, you have to ensure that
- communication is blocking (default), and that there are not asynchronous
- requests waiting, it also means that EINTR:s are silently ignored and
- there no wait to cancel the operation without disconnection from the server
-
- @return :list<str> A list of names. You should only free the outer pointer, inner
- pointers are subpointers of the outer pointer and cannot be freed.
- '''
- ret = libcoopgamma_native.libcoopgamma_native_get_crtcs_sync(self.address)
- if isinstance(ret, int):
- raise ErrorReport.create_error(ret)
- return ret
-
- def get_gamma_info_send(self, crtc, async_ctx):
- '''
- Retrieve information about a CRTC:s gamma ramps, send request part
-
- @param crtc:str The name of the CRT
- @param async_ctx:AsyncContext Slot for information about the request that is
- needed to identify and parse the response
- '''
- error = libcoopgamma_native.libcoopgamma_native_get_gamma_info_send(crtc, self.address, async_ctx.address)
- if error != 0:
- raise ErrorReport.create_error(error)
-
- def get_gamma_info_recv(self, async_ctx):
- '''
- Retrieve information about a CRTC:s gamma ramps, receive response part
-
- @param async_ctx:AsyncContext Information about the request
- @return :CRTCInfo Information about the CRTC
- '''
- value = libcoopgamma_native.libcoopgamma_native_get_gamma_info_recv(self.address, async_ctx.address)
- if isinstance(value, int):
- raise ErrorReport.create_error(value)
- (successful, value) = value
- if not successful:
- raise ErrorReport.create_error(value)
- return CRTCInfo(*value)
-
- def get_gamma_info_sync(self, crtc):
- '''
- Retrieve information about a CRTC:s gamma ramps, synchronous version
-
- This is a synchronous request function, as such, you have to ensure that
- communication is blocking (default), and that there are not asynchronous
- requests waiting, it also means that EINTR:s are silently ignored and
- there no wait to cancel the operation without disconnection from the server
-
- @param crtc:str The name of the CRT
- @return :CRTCInfo Information about the CRTC
- '''
- value = libcoopgamma_native.libcoopgamma_native_get_gamma_info_sync(crtc, self.address)
- if isinstance(value, int):
- raise ErrorReport.create_error(value)
- (successful, value) = value
- if not successful:
- raise ErrorReport.create_error(value)
- return CRTCInfo(*value)
-
- def get_gamma_send(self, query, async_ctx):
- '''
- Retrieve the current gamma ramp adjustments, send request part
-
- @param query:FilterQuery The query to send
- @param async_ctx:AsyncContext Slot for information about the request that is
- needed to identify and parse the response
- '''
- error = libcoopgamma_native.libcoopgamma_native_get_gamma_send(
- query, self.address, async_ctx.address)
- if error != 0:
- raise ErrorReport.create_error(error)
-
- def get_gamma_recv(self, async_ctx):
- '''
- Retrieve the current gamma ramp adjustments, receive response part
-
- @param async_ctx:AsyncContext Information about the request
- @return :FilterTable Filter table
- '''
- value = libcoopgamma_native.libcoopgamma_native_get_gamma_recv(self.address, async_ctx.address)
- if isinstance(value, int):
- raise ErrorReport.create_error(value)
- (successful, value) = value
- if not successful:
- raise ErrorReport.create_error(value)
- return FilterTable(*value)
-
- def get_gamma_sync(self, query):
- '''
- Retrieve the current gamma ramp adjustments, synchronous version
-
- This is a synchronous request function, as such, you have to ensure that
- communication is blocking (default), and that there are not asynchronous
- requests waiting, it also means that EINTR:s are silently ignored and
- there no wait to cancel the operation without disconnection from the server
-
- @param query:FilterQuery The query to send
- @return :FilterTable Filter table
- '''
- value = libcoopgamma_native.libcoopgamma_native_get_gamma_sync(query, self.address)
- if isinstance(value, int):
- raise ErrorReport.create_error(value)
- (successful, value) = value
- if not successful:
- raise ErrorReport.create_error(value)
- return FilterTable(*value)
-
- def set_gamma_send(self, filtr, async_ctx):
- '''
- Apply, update, or remove a gamma ramp adjustment, send request part
-
- @param filtr:Filter The filter to apply, update, or remove, gamma ramp
- meta-data must match the CRTC's
- @param async_ctx:AsyncContext Slot for information about the request that is
- needed to identify and parse the response
- '''
- error = libcoopgamma_native.libcoopgamma_native_set_gamma_send(filtr, self.address, async_ctx.address)
- if error != 0:
- raise ErrorReport.create_error(error)
-
- def set_gamma_recv(self, async_ctx):
- '''
- Apply, update, or remove a gamma ramp adjustment, receive response part
-
- @param async_ctx:AsyncContext Information about the request
- '''
- error = libcoopgamma_native.libcoopgamma_native_set_gamma_recv(self.address, async_ctx.address)
- if error is not None:
- raise ErrorReport.create_error(error)
-
- def set_gamma_sync(self, filtr):
- '''
- Apply, update, or remove a gamma ramp adjustment, synchronous version
-
- This is a synchronous request function, as such, you have to ensure that
- communication is blocking (default), and that there are not asynchronous
- requests waiting, it also means that EINTR:s are silently ignored and
- there no wait to cancel the operation without disconnection from the server
-
- @param filtr:Filter The filter to apply, update, or remove,
- gamma ramp meta-data must match the CRTC's
- '''
- error = libcoopgamma_native.libcoopgamma_native_set_gamma_sync(filtr, self.address)
- if error is not None:
- raise ErrorReport.create_error(error)
-
-
-class AsyncContext:
- '''
- Information necessary to identify and parse a response from the server
- '''
- def __init__(self, buf = None):
- '''
- Constructor
-
- @param buf:bytes? Buffer to unmarshal
- '''
- self.address = None
- if buf is None:
- (successful, value) = libcoopgamma_native.libcoopgamma_native_async_context_create()
- if not successful:
- raise ErrorReport.create_error(value)
- else:
- (error, value) = libcoopgamma_native.libcoopgamma_native_async_context_unmarshal(buf)
- if error < 0:
- raise ErrorReport.create_error(value)
- elif error == 1:
- raise IncompatibleDowngradeError()
- elif error == 2:
- raise IncompatibleUpgradeError()
- self.address = value
-
- def __del__(self):
- '''
- Destructor
- '''
- if self.address is not None:
- libcoopgamma_native.libcoopgamma_native_async_context_free(self.address)
-
- def __repr__(self):
- '''
- Create a parsable string representation of the instance
-
- @return :str Parsable representation of the instance
- '''
- data = libcoopgamma_native.libcoopgamma_native_async_context_marshal(self.address)
- if isinstance(data, int):
- raise ErrorReport.create_error(data)
- return 'libcoopgamma.AsyncContext(%s)' % repr(data)
-
-
-def get_methods():
- '''
- List all recognised adjustment method
-
- SIGCHLD must not be ignored or blocked
-
- @return :list<str> A list of names. You should only free the outer pointer, inner
- pointers are subpointers of the outer pointer and cannot be freed.
- '''
- ret = libcoopgamma_native.libcoopgamma_native_get_methods()
- if isinstance(ret, int):
- raise ErrorReport.create_error(ret)
- return ret
-
-
-def get_method_and_site(method = None, site = None):
- '''
- Get the adjustment method and site
-
- SIGCHLD must not be ignored or blocked
-
- @param method:int|str? The adjustment method, `None` for automatic
- @param site:str? The site, `None` for automatic
- @return :(:str, :str?) The selected adjustment method and the selected the
- selected site. If the adjustment method only supports
- one site or if `site` is `None` and no site can be
- selected automatically, the selected site (the second
- element in the returned tuple) will be `None`.
- '''
- if method is not None:
- method = str(method)
- ret = libcoopgamma_native.libcoopgamma_native_get_method_and_site(method, site)
- if isinstance(ret, int):
- raise ErrorReport.create_error(ret)
- return ret
-
-
-def get_pid_file(method = None, site = None):
- '''
- Get the PID file of the coopgamma server
-
- SIGCHLD must not be ignored or blocked
-
- @param method:int|str? The adjustment method, `None` for automatic
- @param site:str? The site, `None` for automatic
- @return :str? The pathname of the server's PID file.
- `None` if the server does not use PID files.
- '''
- if method is not None:
- method = str(method)
- ret = libcoopgamma_native.libcoopgamma_native_get_pid_file(method, site)
- if ret is not None and isinstance(ret, int):
- raise ErrorReport.create_error(ret)
- return ret
-
-
-def get_socket_file(method = None, site = None):
- '''
- Get the socket file of the coopgamma server
-
- SIGCHLD must not be ignored or blocked
-
- @param method:int|str? The adjustment method, `None` for automatic
- @param site:str? The site, `None` for automatic
- @return :str? The pathname of the server's socket, `None` if the server does have
- its own socket, which is the case when communicating with a server
- in a multi-server display server like mds
- '''
- if method is not None:
- method = str(method)
- ret = libcoopgamma_native.libcoopgamma_native_get_socket_file(method, site)
- if ret is not None and isinstance(ret, int):
- raise ErrorReport.create_error(ret)
- return ret
-
diff --git a/src/test b/test
index f2bb71e..407c668 100755
--- a/src/test
+++ b/test
@@ -1,21 +1,5 @@
#!/usr/bin/env python3
-'''
-pylibcoopgamma -- Python library for interfacing with cooperative gamma servers
-Copyright (C) 2016 Mattias Andrée (maandree@kth.se)
-
-This library is free software: you can redistribute it and/or modify
-it under the terms of the GNU General Public License as published by
-the Free Software Foundation, either version 3 of the License, or
-(at your option) any later version.
-
-This library is distributed in the hope that it will be useful,
-but WITHOUT ANY WARRANTY; without even the implied warranty of
-MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-GNU General Public License for more details.
-
-You should have received a copy of the GNU General Public License
-along with this library. If not, see <http://www.gnu.org/licenses/>.
-'''
+# See LICENSE file for copyright and license details.
import os, sys, time, errno, select
@@ -26,7 +10,6 @@ import libcoopgamma
cg = libcoopgamma
if len(sys.argv) == 1:
-
print('\033[1m%s:\033[m' % 'Methods')
for m in cg.get_methods():
print(m)
@@ -373,4 +356,3 @@ while any(unsynced):
time.sleep(0.5)
del g
-