You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

161 lines
3.9 KiB

;; Foreign functions
(in-package :cl-sipc)
(use-package :cl-sipc-mem)
(defctype si-type :int)
(defconstant +si-string+ 0)
(defconstant +si-binary+ 1)
(defconstant +si-close+ 2)
(defctype si-error :int)
(defconstant +sie-accept+ 0)
(defconstant +sie-read+ 1)
(defconstant +sie-pconcls+ 2)
(defconstant +sie-invalid+ 3)
(defconstant +sie-r-invalid+ 4)
(defconstant +sie-r-multi+ 5)
(defconstant +sie-r-disable+ 6)
(defconstant +sie-checksum+ 7)
;; recoverable ("warning") error codes
(defconstant +sief-warning+ #xAFF000)
(defconstant +siw-checksum+ #.(+ +sief-warning+ 1))
(defctype si-send-rc :int)
(defconstant +si-send-okay+ 0)
(defconstant +si-send-partial+ 1)
(defconstant +si-send-error+ -1)
(defconstant +si-send-failure+ -2)
;; params
(defparameter *response-message* nil)
;; library definition
(define-foreign-library libsipc
(:unix (:or "libsipc.so" "libsipc-ffi.so" "./libsipc.so"))
(t (:default "libsipc")))
(use-foreign-library libsipc)
;; FFI helper functions
(defcfun "sif_type" si-type (message :pointer))
(defcfun "sif_size" :unsigned-int (message :pointer))
(defcfun "sif_data" :pointer (message :pointer))
(defcfun "sif_heap_alloc" :pointer (keep-resp :int))
(defcfun "sif_heap_free" :void (resp :pointer))
(defcfun "si_error_string" :pointer (err si-error))
;; Callbacks
(defun marshal-ec (err)
(cond ((= err #.+sie-accept+) :accept)
((= err #.+sie-read+) :read)
((= err #.+sie-pconcls+) :closed)
((= err #.+sie-invalid+) :message)
((= err #.+sie-checksum+) :checksum)
((= err #.+siw-checksum+) '(:warning :checksum))
(t :unknown)))
(defcallback si-error-callback :int ((err si-error))
(when (symbol-value '*on-error*)
(if (funcall (symbol-value '*on-error*) (marshal-ec err))
0
-1)))
(defun si-typecase (message &key string binary close)
(let* ((type (sif-type message))
(size (sif-size message))
(data (sif-data message))
(rval (cond ((= type #.+si-string+) (funcall string (foreign-string-to-lisp data)))
((= type #.+si-close+) (funcall close nil))
((= type #.+si-binary+) (funcall binary (make-pointer :memory data :size size))))))
(if rval
0
-1)))
(defcallback si-callback :int ((message :pointer))
(let ((*response-message* message))
(si-typecase message
:string #'(lambda (value) (funcall (symbol-value '*on-message*) :string value))
:binary #'(lambda (value) (funcall (symbol-value '*on-message*) :binary value))
:close #'(lambda (avlue) (funcall (symbol-value '*on-message*) :close nil)))))
#| "(let* ((type (sif-type message))
(size (sif-size message))
(data (sif-data message))
(rval (cond ((= type #.+si-string+) (funcall (symbol-value '*on-message*) :string (foreign-string-to-lisp data)))
((= type #.+si-close+) (funcall (symbol-value '*on-message*) :close nil))
((= type #.+si-binary+) (funcall (symbol-value '*on-message*) :binary (make-pointer :memory data :size size))))))
(if rval
0
1))))"|#
;; libsipc functions
(defcfun "si_bind" :int
(file :string))
(defcfun "si_listen" :int
(server :int)
(on-error :pointer)
(on-message :pointer))
(defcfun "si_close" :void
(server :int))
(defcfun "si_connect" :int
(file :string))
;; send functions
(defcfun "siqs_string" :int
(sd :int)
(string :string))
(defcfun "siqs_string_r" :int
(sd :int)
(string :string)
(flags :unsigned-int)
(resp :pointer))
(defcfun "siqs_close" :int
(sd :int))
(defcfun "siqs_close_r" :int
(sd :int)
(flags :unsigned-int)
(resp :pointer))
(defcfun "siqs_binary" :int
(sd :int)
(buffer :pointer)
(size :int))
(defcfun "siqs_binary_r" :int
(sd :int)
(buffer :pointer)
(size :int)
(flags :unsigned-int)
(resp :pointer))
(defcfun "siqr_string" :int
(sd :pointer)
(str :string))
(defcfun "siqr_binary" :int
(sd :pointer)
(str :pointer)
(size :int))
(defcfun "siqr_close" :int
(sd :pointer))
(defcfun "si_timeout" :void
(sd :int)
(secs :int))