summaryrefslogtreecommitdiff
path: root/packages/fcl-async
diff options
context:
space:
mode:
authorpeter <peter@3ad0048d-3df7-0310-abae-a5850022a9f2>2007-10-28 21:26:51 +0000
committerpeter <peter@3ad0048d-3df7-0310-abae-a5850022a9f2>2007-10-28 21:26:51 +0000
commit9a1c84e2531f3f115297d745fa9f03b322e5e881 (patch)
treeb6e0165c05e881ee4bc595ed417dd9a315e0d15c /packages/fcl-async
parent77722a04c495e3d5b8200c8641f56d364009f1f1 (diff)
downloadfpc-9a1c84e2531f3f115297d745fa9f03b322e5e881.tar.gz
* created fcl-async and fcl-process packages
git-svn-id: http://svn.freepascal.org/svn/fpc/trunk@8979 3ad0048d-3df7-0310-abae-a5850022a9f2
Diffstat (limited to 'packages/fcl-async')
-rw-r--r--packages/fcl-async/Makefile2233
-rw-r--r--packages/fcl-async/Makefile.fpc37
-rw-r--r--packages/fcl-async/src/fpasync.pp856
-rw-r--r--packages/fcl-async/src/libasync.inc482
-rw-r--r--packages/fcl-async/src/libasynch.inc109
-rw-r--r--packages/fcl-async/src/unix/asyncio.inc158
-rw-r--r--packages/fcl-async/src/unix/asyncioh.inc26
-rw-r--r--packages/fcl-async/src/unix/libasync.pp199
8 files changed, 4100 insertions, 0 deletions
diff --git a/packages/fcl-async/Makefile b/packages/fcl-async/Makefile
new file mode 100644
index 0000000000..69a40374eb
--- /dev/null
+++ b/packages/fcl-async/Makefile
@@ -0,0 +1,2233 @@
+#
+# Don't edit, this file is generated by FPCMake Version 2.0.0 [2007/10/25]
+#
+default: all
+MAKEFILETARGETS=i386-linux i386-go32v2 i386-win32 i386-os2 i386-freebsd i386-beos i386-netbsd i386-solaris i386-qnx i386-netware i386-openbsd i386-wdosx i386-darwin i386-emx i386-watcom i386-netwlibc i386-wince i386-embedded i386-symbian m68k-linux m68k-freebsd m68k-netbsd m68k-amiga m68k-atari m68k-openbsd m68k-palmos m68k-embedded powerpc-linux powerpc-netbsd powerpc-amiga powerpc-macos powerpc-darwin powerpc-morphos powerpc-embedded sparc-linux sparc-netbsd sparc-solaris sparc-embedded x86_64-linux x86_64-freebsd x86_64-win64 x86_64-embedded arm-linux arm-palmos arm-wince arm-gba arm-nds arm-embedded arm-symbian powerpc64-linux powerpc64-darwin powerpc64-embedded
+BSDs = freebsd netbsd openbsd darwin
+UNIXs = linux $(BSDs) solaris qnx
+LIMIT83fs = go32v2 os2 emx watcom
+OSNeedsComspecToRunBatch = go32v2 watcom
+FORCE:
+.PHONY: FORCE
+override PATH:=$(patsubst %/,%,$(subst \,/,$(PATH)))
+ifneq ($(findstring darwin,$(OSTYPE)),)
+inUnix=1 #darwin
+SEARCHPATH:=$(filter-out .,$(subst :, ,$(PATH)))
+else
+ifeq ($(findstring ;,$(PATH)),)
+inUnix=1
+SEARCHPATH:=$(filter-out .,$(subst :, ,$(PATH)))
+else
+SEARCHPATH:=$(subst ;, ,$(PATH))
+endif
+endif
+SEARCHPATH+=$(patsubst %/,%,$(subst \,/,$(dir $(MAKE))))
+PWD:=$(strip $(wildcard $(addsuffix /pwd.exe,$(SEARCHPATH))))
+ifeq ($(PWD),)
+PWD:=$(strip $(wildcard $(addsuffix /pwd,$(SEARCHPATH))))
+ifeq ($(PWD),)
+$(error You need the GNU utils package to use this Makefile)
+else
+PWD:=$(firstword $(PWD))
+SRCEXEEXT=
+endif
+else
+PWD:=$(firstword $(PWD))
+SRCEXEEXT=.exe
+endif
+ifndef inUnix
+ifeq ($(OS),Windows_NT)
+inWinNT=1
+else
+ifdef OS2_SHELL
+inOS2=1
+endif
+endif
+else
+ifneq ($(findstring cygdrive,$(PATH)),)
+inCygWin=1
+endif
+endif
+ifdef inUnix
+SRCBATCHEXT=.sh
+else
+ifdef inOS2
+SRCBATCHEXT=.cmd
+else
+SRCBATCHEXT=.bat
+endif
+endif
+ifdef COMSPEC
+ifneq ($(findstring $(OS_SOURCE),$(OSNeedsComspecToRunBatch)),)
+RUNBATCH=$(COMSPEC) /C
+endif
+endif
+ifdef inUnix
+PATHSEP=/
+else
+PATHSEP:=$(subst /,\,/)
+ifdef inCygWin
+PATHSEP=/
+endif
+endif
+ifdef PWD
+BASEDIR:=$(subst \,/,$(shell $(PWD)))
+ifdef inCygWin
+ifneq ($(findstring /cygdrive/,$(BASEDIR)),)
+BASENODIR:=$(patsubst /cygdrive%,%,$(BASEDIR))
+BASEDRIVE:=$(firstword $(subst /, ,$(BASENODIR)))
+BASEDIR:=$(subst /cygdrive/$(BASEDRIVE)/,$(BASEDRIVE):/,$(BASEDIR))
+endif
+endif
+else
+BASEDIR=.
+endif
+ifdef inOS2
+ifndef ECHO
+ECHO:=$(strip $(wildcard $(addsuffix /gecho$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(ECHO),)
+ECHO:=$(strip $(wildcard $(addsuffix /echo$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(ECHO),)
+ECHO=echo
+else
+ECHO:=$(firstword $(ECHO))
+endif
+else
+ECHO:=$(firstword $(ECHO))
+endif
+endif
+export ECHO
+endif
+override DEFAULT_FPCDIR=../..
+ifndef FPC
+ifdef PP
+FPC=$(PP)
+endif
+endif
+ifndef FPC
+FPCPROG:=$(strip $(wildcard $(addsuffix /fpc$(SRCEXEEXT),$(SEARCHPATH))))
+ifneq ($(FPCPROG),)
+FPCPROG:=$(firstword $(FPCPROG))
+FPC:=$(shell $(FPCPROG) -P$(CPU_TARGET) -PB)
+ifneq ($(findstring Error,$(FPC)),)
+override FPC=$(firstword $(strip $(wildcard $(addsuffix /ppc386$(SRCEXEEXT),$(SEARCHPATH)))))
+endif
+else
+override FPC=$(firstword $(strip $(wildcard $(addsuffix /ppc386$(SRCEXEEXT),$(SEARCHPATH)))))
+endif
+endif
+override FPC:=$(subst $(SRCEXEEXT),,$(FPC))
+override FPC:=$(subst \,/,$(FPC))$(SRCEXEEXT)
+FOUNDFPC:=$(strip $(wildcard $(FPC)))
+ifeq ($(FOUNDFPC),)
+FOUNDFPC=$(strip $(wildcard $(addsuffix /$(FPC),$(SEARCHPATH))))
+ifeq ($(FOUNDFPC),)
+$(error Compiler $(FPC) not found)
+endif
+endif
+ifndef FPC_COMPILERINFO
+FPC_COMPILERINFO:=$(shell $(FPC) -iVSPTPSOTO)
+endif
+ifndef FPC_VERSION
+FPC_VERSION:=$(word 1,$(FPC_COMPILERINFO))
+endif
+export FPC FPC_VERSION FPC_COMPILERINFO
+unexport CHECKDEPEND ALLDEPENDENCIES
+ifndef CPU_TARGET
+ifdef CPU_TARGET_DEFAULT
+CPU_TARGET=$(CPU_TARGET_DEFAULT)
+endif
+endif
+ifndef OS_TARGET
+ifdef OS_TARGET_DEFAULT
+OS_TARGET=$(OS_TARGET_DEFAULT)
+endif
+endif
+ifneq ($(words $(FPC_COMPILERINFO)),5)
+FPC_COMPILERINFO+=$(shell $(FPC) -iSP)
+FPC_COMPILERINFO+=$(shell $(FPC) -iTP)
+FPC_COMPILERINFO+=$(shell $(FPC) -iSO)
+FPC_COMPILERINFO+=$(shell $(FPC) -iTO)
+endif
+ifndef CPU_SOURCE
+CPU_SOURCE:=$(word 2,$(FPC_COMPILERINFO))
+endif
+ifndef CPU_TARGET
+CPU_TARGET:=$(word 3,$(FPC_COMPILERINFO))
+endif
+ifndef OS_SOURCE
+OS_SOURCE:=$(word 4,$(FPC_COMPILERINFO))
+endif
+ifndef OS_TARGET
+OS_TARGET:=$(word 5,$(FPC_COMPILERINFO))
+endif
+FULL_TARGET=$(CPU_TARGET)-$(OS_TARGET)
+FULL_SOURCE=$(CPU_SOURCE)-$(OS_SOURCE)
+ifneq ($(findstring $(OS_SOURCE),$(LIMIT83fs)),)
+TARGETSUFFIX=$(OS_TARGET)
+SOURCESUFFIX=$(OS_SOURCE)
+else
+TARGETSUFFIX=$(FULL_TARGET)
+SOURCESUFFIX=$(FULL_SOURCE)
+endif
+ifneq ($(FULL_TARGET),$(FULL_SOURCE))
+CROSSCOMPILE=1
+endif
+ifeq ($(findstring makefile,$(MAKECMDGOALS)),)
+ifeq ($(findstring $(FULL_TARGET),$(MAKEFILETARGETS)),)
+$(error The Makefile doesn't support target $(FULL_TARGET), please run fpcmake first)
+endif
+endif
+ifneq ($(findstring $(OS_TARGET),$(BSDs)),)
+BSDhier=1
+endif
+ifeq ($(OS_TARGET),linux)
+linuxHier=1
+endif
+export OS_TARGET OS_SOURCE CPU_TARGET CPU_SOURCE FULL_TARGET FULL_SOURCE TARGETSUFFIX SOURCESUFFIX CROSSCOMPILE
+ifdef FPCDIR
+override FPCDIR:=$(subst \,/,$(FPCDIR))
+ifeq ($(wildcard $(addprefix $(FPCDIR)/,rtl units)),)
+override FPCDIR=wrong
+endif
+else
+override FPCDIR=wrong
+endif
+ifdef DEFAULT_FPCDIR
+ifeq ($(FPCDIR),wrong)
+override FPCDIR:=$(subst \,/,$(DEFAULT_FPCDIR))
+ifeq ($(wildcard $(addprefix $(FPCDIR)/,rtl units)),)
+override FPCDIR=wrong
+endif
+endif
+endif
+ifeq ($(FPCDIR),wrong)
+ifdef inUnix
+override FPCDIR=/usr/local/lib/fpc/$(FPC_VERSION)
+ifeq ($(wildcard $(FPCDIR)/units),)
+override FPCDIR=/usr/lib/fpc/$(FPC_VERSION)
+endif
+else
+override FPCDIR:=$(subst /$(FPC),,$(firstword $(strip $(wildcard $(addsuffix /$(FPC),$(SEARCHPATH))))))
+override FPCDIR:=$(FPCDIR)/..
+ifeq ($(wildcard $(addprefix $(FPCDIR)/,rtl units)),)
+override FPCDIR:=$(FPCDIR)/..
+ifeq ($(wildcard $(addprefix $(FPCDIR)/,rtl units)),)
+override FPCDIR:=$(BASEDIR)
+ifeq ($(wildcard $(addprefix $(FPCDIR)/,rtl units)),)
+override FPCDIR=c:/pp
+endif
+endif
+endif
+endif
+endif
+ifndef CROSSBINDIR
+CROSSBINDIR:=$(wildcard $(FPCDIR)/bin/$(TARGETSUFFIX))
+endif
+ifndef BINUTILSPREFIX
+ifndef CROSSBINDIR
+ifdef CROSSCOMPILE
+BINUTILSPREFIX=$(CPU_TARGET)-$(OS_TARGET)-
+endif
+endif
+endif
+UNITSDIR:=$(wildcard $(FPCDIR)/units/$(TARGETSUFFIX))
+ifeq ($(UNITSDIR),)
+UNITSDIR:=$(wildcard $(FPCDIR)/units/$(OS_TARGET))
+endif
+PACKAGESDIR:=$(wildcard $(FPCDIR) $(FPCDIR)/packages $(FPCDIR)/packages/base $(FPCDIR)/packages/extra)
+override PACKAGE_NAME=fcl-async
+override PACKAGE_VERSION=2.0.0
+ifeq ($(FULL_TARGET),i386-linux)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-go32v2)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-win32)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-os2)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-freebsd)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-beos)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-netbsd)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-solaris)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-qnx)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-netware)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-openbsd)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-wdosx)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-darwin)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-emx)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-watcom)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-netwlibc)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-wince)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-embedded)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),i386-symbian)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),m68k-linux)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),m68k-freebsd)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),m68k-netbsd)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),m68k-amiga)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),m68k-atari)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),m68k-openbsd)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),m68k-palmos)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),m68k-embedded)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),powerpc-linux)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),powerpc-netbsd)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),powerpc-amiga)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),powerpc-macos)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),powerpc-darwin)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),powerpc-morphos)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),powerpc-embedded)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),sparc-linux)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),sparc-netbsd)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),sparc-solaris)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),sparc-embedded)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),x86_64-linux)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),x86_64-freebsd)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),x86_64-win64)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),x86_64-embedded)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),arm-linux)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),arm-palmos)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),arm-wince)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),arm-gba)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),arm-nds)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),arm-embedded)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),arm-symbian)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),powerpc64-linux)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),powerpc64-darwin)
+override TARGET_UNITS+=libasync fpasync
+endif
+ifeq ($(FULL_TARGET),powerpc64-embedded)
+override TARGET_UNITS+=libasync fpasync
+endif
+override INSTALL_FPCPACKAGE=y
+ifeq ($(FULL_TARGET),i386-linux)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),i386-go32v2)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-win32)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-os2)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-freebsd)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),i386-beos)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),i386-netbsd)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),i386-solaris)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),i386-qnx)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-netware)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-openbsd)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),i386-wdosx)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-darwin)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),i386-emx)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-watcom)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-netwlibc)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-wince)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-embedded)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-symbian)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),m68k-linux)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),m68k-freebsd)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),m68k-netbsd)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),m68k-amiga)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),m68k-atari)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),m68k-openbsd)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),m68k-palmos)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),m68k-embedded)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),powerpc-linux)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),powerpc-netbsd)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),powerpc-amiga)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),powerpc-macos)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),powerpc-darwin)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),powerpc-morphos)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),powerpc-embedded)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),sparc-linux)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),sparc-netbsd)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),sparc-solaris)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),sparc-embedded)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),x86_64-linux)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),x86_64-freebsd)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),x86_64-win64)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),x86_64-embedded)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),arm-linux)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),arm-palmos)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),arm-wince)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),arm-gba)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),arm-nds)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),arm-embedded)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),arm-symbian)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),powerpc64-linux)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),powerpc64-darwin)
+override COMPILER_INCLUDEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),powerpc64-embedded)
+override COMPILER_INCLUDEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-linux)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),i386-go32v2)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-win32)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-os2)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-freebsd)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),i386-beos)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),i386-netbsd)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),i386-solaris)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),i386-qnx)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-netware)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-openbsd)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),i386-wdosx)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-darwin)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),i386-emx)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-watcom)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-netwlibc)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-wince)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-embedded)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),i386-symbian)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),m68k-linux)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),m68k-freebsd)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),m68k-netbsd)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),m68k-amiga)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),m68k-atari)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),m68k-openbsd)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),m68k-palmos)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),m68k-embedded)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),powerpc-linux)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),powerpc-netbsd)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),powerpc-amiga)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),powerpc-macos)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),powerpc-darwin)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),powerpc-morphos)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),powerpc-embedded)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),sparc-linux)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),sparc-netbsd)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),sparc-solaris)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),sparc-embedded)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),x86_64-linux)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),x86_64-freebsd)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),x86_64-win64)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),x86_64-embedded)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),arm-linux)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),arm-palmos)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),arm-wince)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),arm-gba)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),arm-nds)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),arm-embedded)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),arm-symbian)
+override COMPILER_SOURCEDIR+=src
+endif
+ifeq ($(FULL_TARGET),powerpc64-linux)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),powerpc64-darwin)
+override COMPILER_SOURCEDIR+=src src/unix
+endif
+ifeq ($(FULL_TARGET),powerpc64-embedded)
+override COMPILER_SOURCEDIR+=src
+endif
+ifdef REQUIRE_UNITSDIR
+override UNITSDIR+=$(REQUIRE_UNITSDIR)
+endif
+ifdef REQUIRE_PACKAGESDIR
+override PACKAGESDIR+=$(REQUIRE_PACKAGESDIR)
+endif
+ifdef ZIPINSTALL
+ifneq ($(findstring $(OS_TARGET),$(UNIXs)),)
+UNIXHier=1
+endif
+else
+ifneq ($(findstring $(OS_SOURCE),$(UNIXs)),)
+UNIXHier=1
+endif
+endif
+ifndef INSTALL_PREFIX
+ifdef PREFIX
+INSTALL_PREFIX=$(PREFIX)
+endif
+endif
+ifndef INSTALL_PREFIX
+ifdef UNIXHier
+INSTALL_PREFIX=/usr/local
+else
+ifdef INSTALL_FPCPACKAGE
+INSTALL_BASEDIR:=/pp
+else
+INSTALL_BASEDIR:=/$(PACKAGE_NAME)
+endif
+endif
+endif
+export INSTALL_PREFIX
+ifdef INSTALL_FPCSUBDIR
+export INSTALL_FPCSUBDIR
+endif
+ifndef DIST_DESTDIR
+DIST_DESTDIR:=$(BASEDIR)
+endif
+export DIST_DESTDIR
+ifndef COMPILER_UNITTARGETDIR
+ifdef PACKAGEDIR_MAIN
+COMPILER_UNITTARGETDIR=$(PACKAGEDIR_MAIN)/units/$(TARGETSUFFIX)
+else
+COMPILER_UNITTARGETDIR=units/$(TARGETSUFFIX)
+endif
+endif
+ifndef COMPILER_TARGETDIR
+COMPILER_TARGETDIR=.
+endif
+ifndef INSTALL_BASEDIR
+ifdef UNIXHier
+ifdef INSTALL_FPCPACKAGE
+INSTALL_BASEDIR:=$(INSTALL_PREFIX)/lib/fpc/$(FPC_VERSION)
+else
+INSTALL_BASEDIR:=$(INSTALL_PREFIX)/lib/$(PACKAGE_NAME)
+endif
+else
+INSTALL_BASEDIR:=$(INSTALL_PREFIX)
+endif
+endif
+ifndef INSTALL_BINDIR
+ifdef UNIXHier
+INSTALL_BINDIR:=$(INSTALL_PREFIX)/bin
+else
+INSTALL_BINDIR:=$(INSTALL_BASEDIR)/bin
+ifdef INSTALL_FPCPACKAGE
+ifdef CROSSCOMPILE
+ifdef CROSSINSTALL
+INSTALL_BINDIR:=$(INSTALL_BINDIR)/$(SOURCESUFFIX)
+else
+INSTALL_BINDIR:=$(INSTALL_BINDIR)/$(TARGETSUFFIX)
+endif
+else
+INSTALL_BINDIR:=$(INSTALL_BINDIR)/$(TARGETSUFFIX)
+endif
+endif
+endif
+endif
+ifndef INSTALL_UNITDIR
+INSTALL_UNITDIR:=$(INSTALL_BASEDIR)/units/$(TARGETSUFFIX)
+ifdef INSTALL_FPCPACKAGE
+ifdef PACKAGE_NAME
+INSTALL_UNITDIR:=$(INSTALL_UNITDIR)/$(PACKAGE_NAME)
+endif
+endif
+endif
+ifndef INSTALL_LIBDIR
+ifdef UNIXHier
+INSTALL_LIBDIR:=$(INSTALL_PREFIX)/lib
+else
+INSTALL_LIBDIR:=$(INSTALL_UNITDIR)
+endif
+endif
+ifndef INSTALL_SOURCEDIR
+ifdef UNIXHier
+ifdef BSDhier
+SRCPREFIXDIR=share/src
+else
+ifdef linuxHier
+SRCPREFIXDIR=share/src
+else
+SRCPREFIXDIR=src
+endif
+endif
+ifdef INSTALL_FPCPACKAGE
+ifdef INSTALL_FPCSUBDIR
+INSTALL_SOURCEDIR:=$(INSTALL_PREFIX)/$(SRCPREFIXDIR)/fpc-$(FPC_VERSION)/$(INSTALL_FPCSUBDIR)/$(PACKAGE_NAME)
+else
+INSTALL_SOURCEDIR:=$(INSTALL_PREFIX)/$(SRCPREFIXDIR)/fpc-$(FPC_VERSION)/$(PACKAGE_NAME)
+endif
+else
+INSTALL_SOURCEDIR:=$(INSTALL_PREFIX)/$(SRCPREFIXDIR)/$(PACKAGE_NAME)-$(PACKAGE_VERSION)
+endif
+else
+ifdef INSTALL_FPCPACKAGE
+ifdef INSTALL_FPCSUBDIR
+INSTALL_SOURCEDIR:=$(INSTALL_BASEDIR)/source/$(INSTALL_FPCSUBDIR)/$(PACKAGE_NAME)
+else
+INSTALL_SOURCEDIR:=$(INSTALL_BASEDIR)/source/$(PACKAGE_NAME)
+endif
+else
+INSTALL_SOURCEDIR:=$(INSTALL_BASEDIR)/source
+endif
+endif
+endif
+ifndef INSTALL_DOCDIR
+ifdef UNIXHier
+ifdef BSDhier
+DOCPREFIXDIR=share/doc
+else
+ifdef linuxHier
+DOCPREFIXDIR=share/doc
+else
+DOCPREFIXDIR=doc
+endif
+endif
+ifdef INSTALL_FPCPACKAGE
+INSTALL_DOCDIR:=$(INSTALL_PREFIX)/$(DOCPREFIXDIR)/fpc-$(FPC_VERSION)/$(PACKAGE_NAME)
+else
+INSTALL_DOCDIR:=$(INSTALL_PREFIX)/$(DOCPREFIXDIR)/$(PACKAGE_NAME)-$(PACKAGE_VERSION)
+endif
+else
+ifdef INSTALL_FPCPACKAGE
+INSTALL_DOCDIR:=$(INSTALL_BASEDIR)/doc/$(PACKAGE_NAME)
+else
+INSTALL_DOCDIR:=$(INSTALL_BASEDIR)/doc
+endif
+endif
+endif
+ifndef INSTALL_EXAMPLEDIR
+ifdef UNIXHier
+ifdef INSTALL_FPCPACKAGE
+ifdef BSDhier
+INSTALL_EXAMPLEDIR:=$(INSTALL_PREFIX)/share/examples/fpc-$(FPC_VERSION)/$(PACKAGE_NAME)
+else
+ifdef linuxHier
+INSTALL_EXAMPLEDIR:=$(INSTALL_DOCDIR)/examples
+else
+INSTALL_EXAMPLEDIR:=$(INSTALL_PREFIX)/doc/fpc-$(FPC_VERSION)/examples/$(PACKAGE_NAME)
+endif
+endif
+else
+ifdef BSDhier
+INSTALL_EXAMPLEDIR:=$(INSTALL_PREFIX)/share/examples/$(PACKAGE_NAME)-$(PACKAGE_VERSION)
+else
+ifdef linuxHier
+INSTALL_EXAMPLEDIR:=$(INSTALL_DOCDIR)/examples/$(PACKAGE_NAME)-$(PACKAGE_VERSION)
+else
+INSTALL_EXAMPLEDIR:=$(INSTALL_PREFIX)/doc/$(PACKAGE_NAME)-$(PACKAGE_VERSION)
+endif
+endif
+endif
+else
+ifdef INSTALL_FPCPACKAGE
+INSTALL_EXAMPLEDIR:=$(INSTALL_BASEDIR)/examples/$(PACKAGE_NAME)
+else
+INSTALL_EXAMPLEDIR:=$(INSTALL_BASEDIR)/examples
+endif
+endif
+endif
+ifndef INSTALL_DATADIR
+INSTALL_DATADIR=$(INSTALL_BASEDIR)
+endif
+ifndef INSTALL_SHAREDDIR
+INSTALL_SHAREDDIR=$(INSTALL_PREFIX)/lib
+endif
+ifdef CROSSCOMPILE
+ifndef CROSSBINDIR
+CROSSBINDIR:=$(wildcard $(CROSSTARGETDIR)/bin/$(SOURCESUFFIX))
+ifeq ($(CROSSBINDIR),)
+CROSSBINDIR:=$(wildcard $(INSTALL_BASEDIR)/cross/$(TARGETSUFFIX)/bin/$(FULL_SOURCE))
+endif
+endif
+else
+CROSSBINDIR=
+endif
+BATCHEXT=.bat
+LOADEREXT=.as
+EXEEXT=.exe
+PPLEXT=.ppl
+PPUEXT=.ppu
+OEXT=.o
+ASMEXT=.s
+SMARTEXT=.sl
+STATICLIBEXT=.a
+SHAREDLIBEXT=.so
+SHAREDLIBPREFIX=libfp
+STATICLIBPREFIX=libp
+IMPORTLIBPREFIX=libimp
+RSTEXT=.rst
+ifeq ($(findstring 1.0.,$(FPC_VERSION)),)
+ifeq ($(OS_TARGET),go32v1)
+STATICLIBPREFIX=
+SHORTSUFFIX=v1
+endif
+ifeq ($(OS_TARGET),go32v2)
+STATICLIBPREFIX=
+SHORTSUFFIX=dos
+endif
+ifeq ($(OS_TARGET),watcom)
+STATICLIBPREFIX=
+OEXT=.obj
+ASMEXT=.asm
+SHAREDLIBEXT=.dll
+SHORTSUFFIX=wat
+endif
+ifeq ($(OS_TARGET),linux)
+BATCHEXT=.sh
+EXEEXT=
+HASSHAREDLIB=1
+SHORTSUFFIX=lnx
+endif
+ifeq ($(OS_TARGET),freebsd)
+BATCHEXT=.sh
+EXEEXT=
+HASSHAREDLIB=1
+SHORTSUFFIX=fbs
+endif
+ifeq ($(OS_TARGET),netbsd)
+BATCHEXT=.sh
+EXEEXT=
+HASSHAREDLIB=1
+SHORTSUFFIX=nbs
+endif
+ifeq ($(OS_TARGET),openbsd)
+BATCHEXT=.sh
+EXEEXT=
+HASSHAREDLIB=1
+SHORTSUFFIX=obs
+endif
+ifeq ($(OS_TARGET),win32)
+SHAREDLIBEXT=.dll
+SHORTSUFFIX=w32
+endif
+ifeq ($(OS_TARGET),os2)
+BATCHEXT=.cmd
+AOUTEXT=.out
+STATICLIBPREFIX=
+SHAREDLIBEXT=.dll
+SHORTSUFFIX=os2
+ECHO=echo
+endif
+ifeq ($(OS_TARGET),emx)
+BATCHEXT=.cmd
+AOUTEXT=.out
+STATICLIBPREFIX=
+SHAREDLIBEXT=.dll
+SHORTSUFFIX=emx
+ECHO=echo
+endif
+ifeq ($(OS_TARGET),amiga)
+EXEEXT=
+SHAREDLIBEXT=.library
+SHORTSUFFIX=amg
+endif
+ifeq ($(OS_TARGET),morphos)
+EXEEXT=
+SHAREDLIBEXT=.library
+SHORTSUFFIX=mos
+endif
+ifeq ($(OS_TARGET),atari)
+EXEEXT=.ttp
+SHORTSUFFIX=ata
+endif
+ifeq ($(OS_TARGET),beos)
+BATCHEXT=.sh
+EXEEXT=
+SHORTSUFFIX=be
+endif
+ifeq ($(OS_TARGET),solaris)
+BATCHEXT=.sh
+EXEEXT=
+SHORTSUFFIX=sun
+endif
+ifeq ($(OS_TARGET),qnx)
+BATCHEXT=.sh
+EXEEXT=
+SHORTSUFFIX=qnx
+endif
+ifeq ($(OS_TARGET),netware)
+EXEEXT=.nlm
+STATICLIBPREFIX=
+SHORTSUFFIX=nw
+endif
+ifeq ($(OS_TARGET),netwlibc)
+EXEEXT=.nlm
+STATICLIBPREFIX=
+SHORTSUFFIX=nwl
+endif
+ifeq ($(OS_TARGET),macos)
+BATCHEXT=
+EXEEXT=
+DEBUGSYMEXT=.xcoff
+SHORTSUFFIX=mac
+endif
+ifeq ($(OS_TARGET),darwin)
+BATCHEXT=.sh
+EXEEXT=
+HASSHAREDLIB=1
+SHORTSUFFIX=dwn
+endif
+ifeq ($(OS_TARGET),gba)
+EXEEXT=.gba
+SHAREDLIBEXT=.so
+SHORTSUFFIX=gba
+endif
+ifeq ($(OS_TARGET),symbian)
+SHAREDLIBEXT=.dll
+SHORTSUFFIX=symbian
+endif
+else
+ifeq ($(OS_TARGET),go32v1)
+PPUEXT=.pp1
+OEXT=.o1
+ASMEXT=.s1
+SMARTEXT=.sl1
+STATICLIBEXT=.a1
+SHAREDLIBEXT=.so1
+STATICLIBPREFIX=
+SHORTSUFFIX=v1
+endif
+ifeq ($(OS_TARGET),go32v2)
+STATICLIBPREFIX=
+SHORTSUFFIX=dos
+endif
+ifeq ($(OS_TARGET),watcom)
+STATICLIBPREFIX=
+SHORTSUFFIX=wat
+endif
+ifeq ($(OS_TARGET),linux)
+BATCHEXT=.sh
+EXEEXT=
+HASSHAREDLIB=1
+SHORTSUFFIX=lnx
+endif
+ifeq ($(OS_TARGET),freebsd)
+BATCHEXT=.sh
+EXEEXT=
+HASSHAREDLIB=1
+SHORTSUFFIX=fbs
+endif
+ifeq ($(OS_TARGET),netbsd)
+BATCHEXT=.sh
+EXEEXT=
+HASSHAREDLIB=1
+SHORTSUFFIX=nbs
+endif
+ifeq ($(OS_TARGET),openbsd)
+BATCHEXT=.sh
+EXEEXT=
+HASSHAREDLIB=1
+SHORTSUFFIX=obs
+endif
+ifeq ($(OS_TARGET),win32)
+PPUEXT=.ppw
+OEXT=.ow
+ASMEXT=.sw
+SMARTEXT=.slw
+STATICLIBEXT=.aw
+SHAREDLIBEXT=.dll
+SHORTSUFFIX=w32
+endif
+ifeq ($(OS_TARGET),os2)
+BATCHEXT=.cmd
+PPUEXT=.ppo
+ASMEXT=.so2
+OEXT=.oo2
+AOUTEXT=.out
+SMARTEXT=.sl2
+STATICLIBPREFIX=
+STATICLIBEXT=.ao2
+SHAREDLIBEXT=.dll
+SHORTSUFFIX=os2
+ECHO=echo
+endif
+ifeq ($(OS_TARGET),amiga)
+EXEEXT=
+PPUEXT=.ppu
+ASMEXT=.s
+OEXT=.o
+SMARTEXT=.sl
+STATICLIBEXT=.a
+SHAREDLIBEXT=.library
+SHORTSUFFIX=amg
+endif
+ifeq ($(OS_TARGET),atari)
+PPUEXT=.ppu
+ASMEXT=.s
+OEXT=.o
+SMARTEXT=.sl
+STATICLIBEXT=.a
+EXEEXT=.ttp
+SHORTSUFFIX=ata
+endif
+ifeq ($(OS_TARGET),beos)
+BATCHEXT=.sh
+PPUEXT=.ppu
+ASMEXT=.s
+OEXT=.o
+SMARTEXT=.sl
+STATICLIBEXT=.a
+EXEEXT=
+SHORTSUFFIX=be
+endif
+ifeq ($(OS_TARGET),solaris)
+BATCHEXT=.sh
+PPUEXT=.ppu
+ASMEXT=.s
+OEXT=.o
+SMARTEXT=.sl
+STATICLIBEXT=.a
+EXEEXT=
+SHORTSUFFIX=sun
+endif
+ifeq ($(OS_TARGET),qnx)
+BATCHEXT=.sh
+PPUEXT=.ppu
+ASMEXT=.s
+OEXT=.o
+SMARTEXT=.sl
+STATICLIBEXT=.a
+EXEEXT=
+SHORTSUFFIX=qnx
+endif
+ifeq ($(OS_TARGET),netware)
+STATICLIBPREFIX=
+PPUEXT=.ppu
+OEXT=.o
+ASMEXT=.s
+SMARTEXT=.sl
+STATICLIBEXT=.a
+SHAREDLIBEXT=.nlm
+EXEEXT=.nlm
+SHORTSUFFIX=nw
+endif
+ifeq ($(OS_TARGET),netwlibc)
+STATICLIBPREFIX=
+PPUEXT=.ppu
+OEXT=.o
+ASMEXT=.s
+SMARTEXT=.sl
+STATICLIBEXT=.a
+SHAREDLIBEXT=.nlm
+EXEEXT=.nlm
+SHORTSUFFIX=nwl
+endif
+ifeq ($(OS_TARGET),macos)
+BATCHEXT=
+PPUEXT=.ppu
+ASMEXT=.s
+OEXT=.o
+SMARTEXT=.sl
+STATICLIBEXT=.a
+EXEEXT=
+DEBUGSYMEXT=.xcoff
+SHORTSUFFIX=mac
+endif
+endif
+ifneq ($(findstring $(OS_SOURCE),$(LIMIT83fs)),)
+FPCMADE=fpcmade.$(SHORTSUFFIX)
+ZIPSUFFIX=$(SHORTSUFFIX)
+ZIPCROSSPREFIX=
+ZIPSOURCESUFFIX=src
+ZIPEXAMPLESUFFIX=exm
+else
+FPCMADE=fpcmade.$(TARGETSUFFIX)
+ZIPSOURCESUFFIX=.source
+ZIPEXAMPLESUFFIX=.examples
+ifdef CROSSCOMPILE
+ZIPSUFFIX=.$(SOURCESUFFIX)
+ZIPCROSSPREFIX=$(TARGETSUFFIX)-
+else
+ZIPSUFFIX=.$(TARGETSUFFIX)
+ZIPCROSSPREFIX=
+endif
+endif
+ifndef ECHO
+ECHO:=$(strip $(wildcard $(addsuffix /gecho$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(ECHO),)
+ECHO:=$(strip $(wildcard $(addsuffix /echo$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(ECHO),)
+ECHO= __missing_command_ECHO
+else
+ECHO:=$(firstword $(ECHO))
+endif
+else
+ECHO:=$(firstword $(ECHO))
+endif
+endif
+export ECHO
+ifndef DATE
+DATE:=$(strip $(wildcard $(addsuffix /gdate$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(DATE),)
+DATE:=$(strip $(wildcard $(addsuffix /date$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(DATE),)
+DATE= __missing_command_DATE
+else
+DATE:=$(firstword $(DATE))
+endif
+else
+DATE:=$(firstword $(DATE))
+endif
+endif
+export DATE
+ifndef GINSTALL
+GINSTALL:=$(strip $(wildcard $(addsuffix /ginstall$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(GINSTALL),)
+GINSTALL:=$(strip $(wildcard $(addsuffix /install$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(GINSTALL),)
+GINSTALL= __missing_command_GINSTALL
+else
+GINSTALL:=$(firstword $(GINSTALL))
+endif
+else
+GINSTALL:=$(firstword $(GINSTALL))
+endif
+endif
+export GINSTALL
+ifndef CPPROG
+CPPROG:=$(strip $(wildcard $(addsuffix /cp$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(CPPROG),)
+CPPROG= __missing_command_CPPROG
+else
+CPPROG:=$(firstword $(CPPROG))
+endif
+endif
+export CPPROG
+ifndef RMPROG
+RMPROG:=$(strip $(wildcard $(addsuffix /rm$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(RMPROG),)
+RMPROG= __missing_command_RMPROG
+else
+RMPROG:=$(firstword $(RMPROG))
+endif
+endif
+export RMPROG
+ifndef MVPROG
+MVPROG:=$(strip $(wildcard $(addsuffix /mv$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(MVPROG),)
+MVPROG= __missing_command_MVPROG
+else
+MVPROG:=$(firstword $(MVPROG))
+endif
+endif
+export MVPROG
+ifndef MKDIRPROG
+MKDIRPROG:=$(strip $(wildcard $(addsuffix /gmkdir$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(MKDIRPROG),)
+MKDIRPROG:=$(strip $(wildcard $(addsuffix /mkdir$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(MKDIRPROG),)
+MKDIRPROG= __missing_command_MKDIRPROG
+else
+MKDIRPROG:=$(firstword $(MKDIRPROG))
+endif
+else
+MKDIRPROG:=$(firstword $(MKDIRPROG))
+endif
+endif
+export MKDIRPROG
+ifndef ECHOREDIR
+ifndef inUnix
+ECHOREDIR=echo
+else
+ECHOREDIR=$(ECHO)
+endif
+endif
+ifndef COPY
+COPY:=$(CPPROG) -fp
+endif
+ifndef COPYTREE
+COPYTREE:=$(CPPROG) -Rfp
+endif
+ifndef MKDIRTREE
+MKDIRTREE:=$(MKDIRPROG) -p
+endif
+ifndef MOVE
+MOVE:=$(MVPROG) -f
+endif
+ifndef DEL
+DEL:=$(RMPROG) -f
+endif
+ifndef DELTREE
+DELTREE:=$(RMPROG) -rf
+endif
+ifndef INSTALL
+ifdef inUnix
+INSTALL:=$(GINSTALL) -c -m 644
+else
+INSTALL:=$(COPY)
+endif
+endif
+ifndef INSTALLEXE
+ifdef inUnix
+INSTALLEXE:=$(GINSTALL) -c -m 755
+else
+INSTALLEXE:=$(COPY)
+endif
+endif
+ifndef MKDIR
+MKDIR:=$(GINSTALL) -m 755 -d
+endif
+export ECHOREDIR COPY COPYTREE MOVE DEL DELTREE INSTALL INSTALLEXE MKDIR
+ifndef PPUMOVE
+PPUMOVE:=$(strip $(wildcard $(addsuffix /ppumove$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(PPUMOVE),)
+PPUMOVE= __missing_command_PPUMOVE
+else
+PPUMOVE:=$(firstword $(PPUMOVE))
+endif
+endif
+export PPUMOVE
+ifndef FPCMAKE
+FPCMAKE:=$(strip $(wildcard $(addsuffix /fpcmake$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(FPCMAKE),)
+FPCMAKE= __missing_command_FPCMAKE
+else
+FPCMAKE:=$(firstword $(FPCMAKE))
+endif
+endif
+export FPCMAKE
+ifndef ZIPPROG
+ZIPPROG:=$(strip $(wildcard $(addsuffix /zip$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(ZIPPROG),)
+ZIPPROG= __missing_command_ZIPPROG
+else
+ZIPPROG:=$(firstword $(ZIPPROG))
+endif
+endif
+export ZIPPROG
+ifndef TARPROG
+TARPROG:=$(strip $(wildcard $(addsuffix /gtar$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(TARPROG),)
+TARPROG:=$(strip $(wildcard $(addsuffix /tar$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(TARPROG),)
+TARPROG= __missing_command_TARPROG
+else
+TARPROG:=$(firstword $(TARPROG))
+endif
+else
+TARPROG:=$(firstword $(TARPROG))
+endif
+endif
+export TARPROG
+ASNAME=$(BINUTILSPREFIX)as
+LDNAME=$(BINUTILSPREFIX)ld
+ARNAME=$(BINUTILSPREFIX)ar
+RCNAME=$(BINUTILSPREFIX)rc
+ifneq ($(findstring 1.0.,$(FPC_VERSION)),)
+ifeq ($(OS_TARGET),win32)
+ifeq ($(CROSSBINDIR),)
+ASNAME=asw
+LDNAME=ldw
+ARNAME=arw
+endif
+endif
+endif
+ifndef ASPROG
+ifdef CROSSBINDIR
+ASPROG=$(CROSSBINDIR)/$(ASNAME)$(SRCEXEEXT)
+else
+ASPROG=$(ASNAME)
+endif
+endif
+ifndef LDPROG
+ifdef CROSSBINDIR
+LDPROG=$(CROSSBINDIR)/$(LDNAME)$(SRCEXEEXT)
+else
+LDPROG=$(LDNAME)
+endif
+endif
+ifndef RCPROG
+ifdef CROSSBINDIR
+RCPROG=$(CROSSBINDIR)/$(RCNAME)$(SRCEXEEXT)
+else
+RCPROG=$(RCNAME)
+endif
+endif
+ifndef ARPROG
+ifdef CROSSBINDIR
+ARPROG=$(CROSSBINDIR)/$(ARNAME)$(SRCEXEEXT)
+else
+ARPROG=$(ARNAME)
+endif
+endif
+AS=$(ASPROG)
+LD=$(LDPROG)
+RC=$(RCPROG)
+AR=$(ARPROG)
+PPAS=ppas$(SRCBATCHEXT)
+ifdef inUnix
+LDCONFIG=ldconfig
+else
+LDCONFIG=
+endif
+ifdef DATE
+DATESTR:=$(shell $(DATE) +%Y%m%d)
+else
+DATESTR=
+endif
+ifndef UPXPROG
+ifeq ($(OS_TARGET),go32v2)
+UPXPROG:=1
+endif
+ifeq ($(OS_TARGET),win32)
+UPXPROG:=1
+endif
+ifdef UPXPROG
+UPXPROG:=$(strip $(wildcard $(addsuffix /upx$(SRCEXEEXT),$(SEARCHPATH))))
+ifeq ($(UPXPROG),)
+UPXPROG=
+else
+UPXPROG:=$(firstword $(UPXPROG))
+endif
+else
+UPXPROG=
+endif
+endif
+export UPXPROG
+ZIPOPT=-9
+ZIPEXT=.zip
+ifeq ($(USETAR),bz2)
+TAROPT=vj
+TAREXT=.tar.bz2
+else
+TAROPT=vz
+TAREXT=.tar.gz
+endif
+override REQUIRE_PACKAGES=rtl
+ifeq ($(FULL_TARGET),i386-linux)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-go32v2)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-win32)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-os2)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-freebsd)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-beos)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-netbsd)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-solaris)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-qnx)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-netware)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-openbsd)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-wdosx)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-darwin)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-emx)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-watcom)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-netwlibc)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-wince)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-embedded)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),i386-symbian)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),m68k-linux)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),m68k-freebsd)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),m68k-netbsd)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),m68k-amiga)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),m68k-atari)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),m68k-openbsd)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),m68k-palmos)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),m68k-embedded)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),powerpc-linux)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),powerpc-netbsd)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),powerpc-amiga)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),powerpc-macos)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),powerpc-darwin)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),powerpc-morphos)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),powerpc-embedded)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),sparc-linux)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),sparc-netbsd)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),sparc-solaris)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),sparc-embedded)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),x86_64-linux)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),x86_64-freebsd)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),x86_64-win64)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),x86_64-embedded)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),arm-linux)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),arm-palmos)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),arm-wince)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),arm-gba)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),arm-nds)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),arm-embedded)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),arm-symbian)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),powerpc64-linux)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),powerpc64-darwin)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifeq ($(FULL_TARGET),powerpc64-embedded)
+REQUIRE_PACKAGES_RTL=1
+endif
+ifdef REQUIRE_PACKAGES_RTL
+PACKAGEDIR_RTL:=$(firstword $(subst /Makefile.fpc,,$(strip $(wildcard $(addsuffix /rtl/Makefile.fpc,$(PACKAGESDIR))))))
+ifneq ($(PACKAGEDIR_RTL),)
+ifneq ($(wildcard $(PACKAGEDIR_RTL)/units/$(TARGETSUFFIX)),)
+UNITDIR_RTL=$(PACKAGEDIR_RTL)/units/$(TARGETSUFFIX)
+else
+UNITDIR_RTL=$(PACKAGEDIR_RTL)
+endif
+ifdef CHECKDEPEND
+$(PACKAGEDIR_RTL)/$(FPCMADE):
+ $(MAKE) -C $(PACKAGEDIR_RTL) $(FPCMADE)
+override ALLDEPENDENCIES+=$(PACKAGEDIR_RTL)/$(FPCMADE)
+endif
+else
+PACKAGEDIR_RTL=
+UNITDIR_RTL:=$(subst /Package.fpc,,$(strip $(wildcard $(addsuffix /rtl/Package.fpc,$(UNITSDIR)))))
+ifneq ($(UNITDIR_RTL),)
+UNITDIR_RTL:=$(firstword $(UNITDIR_RTL))
+else
+UNITDIR_RTL=
+endif
+endif
+ifdef UNITDIR_RTL
+override COMPILER_UNITDIR+=$(UNITDIR_RTL)
+endif
+endif
+ifndef NOCPUDEF
+override FPCOPTDEF=$(CPU_TARGET)
+endif
+ifneq ($(OS_TARGET),$(OS_SOURCE))
+override FPCOPT+=-T$(OS_TARGET)
+endif
+ifneq ($(CPU_TARGET),$(CPU_SOURCE))
+override FPCOPT+=-P$(CPU_TARGET)
+endif
+ifeq ($(OS_SOURCE),openbsd)
+override FPCOPT+=-FD$(NEW_BINUTILS_PATH)
+endif
+ifndef CROSSBOOTSTRAP
+ifneq ($(BINUTILSPREFIX),)
+override FPCOPT+=-XP$(BINUTILSPREFIX)
+endif
+ifneq ($(BINUTILSPREFIX),)
+override FPCOPT+=-Xr$(RLINKPATH)
+endif
+endif
+ifdef UNITDIR
+override FPCOPT+=$(addprefix -Fu,$(UNITDIR))
+endif
+ifdef LIBDIR
+override FPCOPT+=$(addprefix -Fl,$(LIBDIR))
+endif
+ifdef OBJDIR
+override FPCOPT+=$(addprefix -Fo,$(OBJDIR))
+endif
+ifdef INCDIR
+override FPCOPT+=$(addprefix -Fi,$(INCDIR))
+endif
+ifdef LINKSMART
+override FPCOPT+=-XX
+endif
+ifdef CREATESMART
+override FPCOPT+=-CX
+endif
+ifdef DEBUG
+override FPCOPT+=-gl
+override FPCOPTDEF+=DEBUG
+endif
+ifdef RELEASE
+ifneq ($(findstring 2.0.,$(FPC_VERSION)),)
+ifeq ($(CPU_TARGET),i386)
+FPCCPUOPT:=-OG2p3
+endif
+ifeq ($(CPU_TARGET),powerpc)
+FPCCPUOPT:=-O1r
+endif
+else
+FPCCPUOPT:=-O2
+endif
+override FPCOPT+=-Ur -Xs $(FPCCPUOPT) -n
+override FPCOPTDEF+=RELEASE
+endif
+ifdef STRIP
+override FPCOPT+=-Xs
+endif
+ifdef OPTIMIZE
+override FPCOPT+=-O2
+endif
+ifdef VERBOSE
+override FPCOPT+=-vwni
+endif
+ifdef COMPILER_OPTIONS
+override FPCOPT+=$(COMPILER_OPTIONS)
+endif
+ifdef COMPILER_UNITDIR
+override FPCOPT+=$(addprefix -Fu,$(COMPILER_UNITDIR))
+endif
+ifdef COMPILER_LIBRARYDIR
+override FPCOPT+=$(addprefix -Fl,$(COMPILER_LIBRARYDIR))
+endif
+ifdef COMPILER_OBJECTDIR
+override FPCOPT+=$(addprefix -Fo,$(COMPILER_OBJECTDIR))
+endif
+ifdef COMPILER_INCLUDEDIR
+override FPCOPT+=$(addprefix -Fi,$(COMPILER_INCLUDEDIR))
+endif
+ifdef CROSSBINDIR
+override FPCOPT+=-FD$(CROSSBINDIR)
+endif
+ifdef COMPILER_TARGETDIR
+override FPCOPT+=-FE$(COMPILER_TARGETDIR)
+ifeq ($(COMPILER_TARGETDIR),.)
+override TARGETDIRPREFIX=
+else
+override TARGETDIRPREFIX=$(COMPILER_TARGETDIR)/
+endif
+endif
+ifdef COMPILER_UNITTARGETDIR
+override FPCOPT+=-FU$(COMPILER_UNITTARGETDIR)
+ifeq ($(COMPILER_UNITTARGETDIR),.)
+override UNITTARGETDIRPREFIX=
+else
+override UNITTARGETDIRPREFIX=$(COMPILER_UNITTARGETDIR)/
+endif
+else
+ifdef COMPILER_TARGETDIR
+override COMPILER_UNITTARGETDIR=$(COMPILER_TARGETDIR)
+override UNITTARGETDIRPREFIX=$(TARGETDIRPREFIX)
+endif
+endif
+ifdef CREATESHARED
+override FPCOPT+=-Cg
+ifeq ($(CPU_TARGET),i386)
+override FPCOPT+=-Aas
+endif
+endif
+ifeq ($(findstring 2.0.,$(FPC_VERSION)),)
+ifeq ($(OS_TARGET),linux)
+ifeq ($(CPU_TARGET),x86_64)
+override FPCOPT+=-Cg
+endif
+endif
+endif
+ifdef LINKSHARED
+endif
+ifdef OPT
+override FPCOPT+=$(OPT)
+endif
+ifdef FPCOPTDEF
+override FPCOPT+=$(addprefix -d,$(FPCOPTDEF))
+endif
+ifdef CFGFILE
+override FPCOPT+=@$(CFGFILE)
+endif
+ifdef USEENV
+override FPCEXTCMD:=$(FPCOPT)
+override FPCOPT:=!FPCEXTCMD
+export FPCEXTCMD
+endif
+override AFULL_TARGET=$(CPU_TARGET)-$(OS_TARGET)
+override AFULL_SOURCE=$(CPU_SOURCE)-$(OS_SOURCE)
+ifneq ($(AFULL_TARGET),$(AFULL_SOURCE))
+override ACROSSCOMPILE=1
+endif
+ifdef ACROSSCOMPILE
+override FPCOPT+=$(CROSSOPT)
+endif
+override COMPILER:=$(FPC) $(FPCOPT)
+ifeq (,$(findstring -s ,$(COMPILER)))
+EXECPPAS=
+else
+ifeq ($(FULL_SOURCE),$(FULL_TARGET))
+ifdef RUNBATCH
+EXECPPAS:=@$(RUNBATCH) $(PPAS)
+else
+EXECPPAS:=@$(PPAS)
+endif
+endif
+endif
+.PHONY: fpc_units
+ifneq ($(TARGET_UNITS),)
+override ALLTARGET+=fpc_units
+override UNITPPUFILES=$(addsuffix $(PPUEXT),$(TARGET_UNITS))
+override IMPLICITUNITPPUFILES=$(addsuffix $(PPUEXT),$(TARGET_IMPLICITUNITS))
+override INSTALLPPUFILES+=$(UNITPPUFILES) $(IMPLICITUNITPPUFILES)
+override CLEANPPUFILES+=$(UNITPPUFILES) $(IMPLICITUNITPPUFILES)
+endif
+fpc_units: $(COMPILER_UNITTARGETDIR) $(UNITPPUFILES)
+ifdef TARGET_RSTS
+override RSTFILES=$(addsuffix $(RSTEXT),$(TARGET_RSTS))
+override CLEANRSTFILES+=$(RSTFILES)
+endif
+.PHONY: fpc_all fpc_smart fpc_debug fpc_release fpc_shared
+$(FPCMADE): $(ALLDEPENDENCIES) $(ALLTARGET)
+ @$(ECHOREDIR) Compiled > $(FPCMADE)
+fpc_all: $(FPCMADE)
+fpc_smart:
+ $(MAKE) all LINKSMART=1 CREATESMART=1
+fpc_debug:
+ $(MAKE) all DEBUG=1
+fpc_release:
+ $(MAKE) all RELEASE=1
+.SUFFIXES: $(EXEEXT) $(PPUEXT) $(OEXT) .pas .lpr .dpr .pp .rc .res
+$(COMPILER_UNITTARGETDIR):
+ $(MKDIRTREE) $(COMPILER_UNITTARGETDIR)
+$(COMPILER_TARGETDIR):
+ $(MKDIRTREE) $(COMPILER_TARGETDIR)
+%$(PPUEXT): %.pp
+ $(COMPILER) $<
+ $(EXECPPAS)
+%$(PPUEXT): %.pas
+ $(COMPILER) $<
+ $(EXECPPAS)
+%$(EXEEXT): %.pp
+ $(COMPILER) $<
+ $(EXECPPAS)
+%$(EXEEXT): %.pas
+ $(COMPILER) $<
+ $(EXECPPAS)
+%$(EXEEXT): %.lpr
+ $(COMPILER) $<
+ $(EXECPPAS)
+%$(EXEEXT): %.dpr
+ $(COMPILER) $<
+ $(EXECPPAS)
+%.res: %.rc
+ windres -i $< -o $@
+vpath %.pp $(COMPILER_SOURCEDIR) $(COMPILER_INCLUDEDIR)
+vpath %.pas $(COMPILER_SOURCEDIR) $(COMPILER_INCLUDEDIR)
+vpath %.lpr $(COMPILER_SOURCEDIR) $(COMPILER_INCLUDEDIR)
+vpath %.dpr $(COMPILER_SOURCEDIR) $(COMPILER_INCLUDEDIR)
+vpath %.inc $(COMPILER_INCLUDEDIR)
+vpath %$(OEXT) $(COMPILER_UNITTARGETDIR)
+vpath %$(PPUEXT) $(COMPILER_UNITTARGETDIR)
+.PHONY: fpc_shared
+override INSTALLTARGET+=fpc_shared_install
+ifndef SHARED_LIBVERSION
+SHARED_LIBVERSION=$(FPC_VERSION)
+endif
+ifndef SHARED_LIBNAME
+SHARED_LIBNAME=$(PACKAGE_NAME)
+endif
+ifndef SHARED_FULLNAME
+SHARED_FULLNAME=$(SHAREDLIBPREFIX)$(SHARED_LIBNAME)-$(SHARED_LIBVERSION)$(SHAREDLIBEXT)
+endif
+ifndef SHARED_LIBUNITS
+SHARED_LIBUNITS:=$(TARGET_UNITS) $(TARGET_IMPLICITUNITS)
+override SHARED_LIBUNITS:=$(filter-out $(INSTALL_BUILDUNIT),$(SHARED_LIBUNITS))
+endif
+fpc_shared:
+ifdef HASSHAREDLIB
+ $(MAKE) all CREATESHARED=1 LINKSHARED=1 CREATESMART=1
+ifneq ($(SHARED_BUILD),n)
+ $(PPUMOVE) -q $(SHARED_LIBUNITS) -i$(COMPILER_UNITTARGETDIR) -o$(SHARED_FULLNAME) -d$(COMPILER_UNITTARGETDIR)
+endif
+else
+ @$(ECHO) Shared Libraries not supported
+endif
+fpc_shared_install:
+ifneq ($(SHARED_BUILD),n)
+ifneq ($(SHARED_LIBUNITS),)
+ifneq ($(wildcard $(COMPILER_UNITTARGETDIR)/$(SHARED_FULLNAME)),)
+ $(INSTALL) $(COMPILER_UNITTARGETDIR)/$(SHARED_FULLNAME) $(INSTALL_SHAREDDIR)
+endif
+endif
+endif
+.PHONY: fpc_install fpc_sourceinstall fpc_exampleinstall
+ifdef INSTALL_UNITS
+override INSTALLPPUFILES+=$(addsuffix $(PPUEXT),$(INSTALL_UNITS))
+endif
+ifdef INSTALL_BUILDUNIT
+override INSTALLPPUFILES:=$(filter-out $(INSTALL_BUILDUNIT)$(PPUEXT),$(INSTALLPPUFILES))
+endif
+ifdef INSTALLPPUFILES
+override INSTALLPPULINKFILES:=$(subst $(PPUEXT),$(OEXT),$(INSTALLPPUFILES)) $(addprefix $(STATICLIBPREFIX),$(subst $(PPUEXT),$(STATICLIBEXT),$(INSTALLPPUFILES))) $(addprefix $(IMPORTLIBPREFIX),$(subst $(PPUEXT),$(STATICLIBEXT),$(INSTALLPPUFILES)))
+ifneq ($(UNITTARGETDIRPREFIX),)
+override INSTALLPPUFILES:=$(addprefix $(UNITTARGETDIRPREFIX),$(notdir $(INSTALLPPUFILES)))
+override INSTALLPPULINKFILES:=$(wildcard $(addprefix $(UNITTARGETDIRPREFIX),$(notdir $(INSTALLPPULINKFILES))))
+endif
+override INSTALL_CREATEPACKAGEFPC=1
+endif
+ifdef INSTALLEXEFILES
+ifneq ($(TARGETDIRPREFIX),)
+override INSTALLEXEFILES:=$(addprefix $(TARGETDIRPREFIX),$(notdir $(INSTALLEXEFILES)))
+endif
+endif
+fpc_install: all $(INSTALLTARGET)
+ifdef INSTALLEXEFILES
+ $(MKDIR) $(INSTALL_BINDIR)
+ifdef UPXPROG
+ -$(UPXPROG) $(INSTALLEXEFILES)
+endif
+ $(INSTALLEXE) $(INSTALLEXEFILES) $(INSTALL_BINDIR)
+endif
+ifdef INSTALL_CREATEPACKAGEFPC
+ifdef FPCMAKE
+ifdef PACKAGE_VERSION
+ifneq ($(wildcard Makefile.fpc),)
+ $(FPCMAKE) -p -T$(CPU_TARGET)-$(OS_TARGET) Makefile.fpc
+ $(MKDIR) $(INSTALL_UNITDIR)
+ $(INSTALL) Package.fpc $(INSTALL_UNITDIR)
+endif
+endif
+endif
+endif
+ifdef INSTALLPPUFILES
+ $(MKDIR) $(INSTALL_UNITDIR)
+ $(INSTALL) $(INSTALLPPUFILES) $(INSTALL_UNITDIR)
+ifneq ($(INSTALLPPULINKFILES),)
+ $(INSTALL) $(INSTALLPPULINKFILES) $(INSTALL_UNITDIR)
+endif
+ifneq ($(wildcard $(LIB_FULLNAME)),)
+ $(MKDIR) $(INSTALL_LIBDIR)
+ $(INSTALL) $(LIB_FULLNAME) $(INSTALL_LIBDIR)
+ifdef inUnix
+ ln -sf $(LIB_FULLNAME) $(INSTALL_LIBDIR)/$(LIB_NAME)
+endif
+endif
+endif
+ifdef INSTALL_FILES
+ $(MKDIR) $(INSTALL_DATADIR)
+ $(INSTALL) $(INSTALL_FILES) $(INSTALL_DATADIR)
+endif
+fpc_sourceinstall: distclean
+ $(MKDIR) $(INSTALL_SOURCEDIR)
+ $(COPYTREE) $(BASEDIR)/* $(INSTALL_SOURCEDIR)
+fpc_exampleinstall: $(addsuffix _distclean,$(TARGET_EXAMPLEDIRS))
+ifdef HASEXAMPLES
+ $(MKDIR) $(INSTALL_EXAMPLEDIR)
+endif
+ifdef EXAMPLESOURCEFILES
+ $(COPY) $(EXAMPLESOURCEFILES) $(INSTALL_EXAMPLEDIR)
+endif
+ifdef TARGET_EXAMPLEDIRS
+ $(COPYTREE) $(addsuffix /*,$(TARGET_EXAMPLEDIRS)) $(INSTALL_EXAMPLEDIR)
+endif
+.PHONY: fpc_distinstall
+fpc_distinstall: install exampleinstall
+.PHONY: fpc_zipinstall fpc_zipsourceinstall fpc_zipexampleinstall
+ifndef PACKDIR
+ifndef inUnix
+PACKDIR=$(BASEDIR)/../fpc-pack
+else
+PACKDIR=/tmp/fpc-pack
+endif
+endif
+ifndef ZIPNAME
+ifdef DIST_ZIPNAME
+ZIPNAME=$(DIST_ZIPNAME)
+else
+ZIPNAME=$(PACKAGE_NAME)
+endif
+endif
+ifndef FULLZIPNAME
+FULLZIPNAME=$(ZIPCROSSPREFIX)$(ZIPPREFIX)$(ZIPNAME)$(ZIPSUFFIX)
+endif
+ifndef ZIPTARGET
+ifdef DIST_ZIPTARGET
+ZIPTARGET=DIST_ZIPTARGET
+else
+ZIPTARGET=install
+endif
+endif
+ifndef USEZIP
+ifdef inUnix
+USETAR=1
+endif
+endif
+ifndef inUnix
+USEZIPWRAPPER=1
+endif
+ifdef USEZIPWRAPPER
+ZIPPATHSEP=$(PATHSEP)
+ZIPWRAPPER=$(subst /,$(PATHSEP),$(DIST_DESTDIR)/fpczip$(SRCBATCHEXT))
+else
+ZIPPATHSEP=/
+endif
+ZIPCMD_CDPACK:=cd $(subst /,$(ZIPPATHSEP),$(PACKDIR))
+ZIPCMD_CDBASE:=cd $(subst /,$(ZIPPATHSEP),$(BASEDIR))
+ifdef USETAR
+ZIPDESTFILE:=$(DIST_DESTDIR)/$(FULLZIPNAME)$(TAREXT)
+ZIPCMD_ZIP:=$(TARPROG) cf$(TAROPT) $(ZIPDESTFILE) *
+else
+ZIPDESTFILE:=$(DIST_DESTDIR)/$(FULLZIPNAME)$(ZIPEXT)
+ZIPCMD_ZIP:=$(subst /,$(ZIPPATHSEP),$(ZIPPROG)) -Dr $(ZIPOPT) $(ZIPDESTFILE) *
+endif
+fpc_zipinstall:
+ $(MAKE) $(ZIPTARGET) INSTALL_PREFIX=$(PACKDIR) ZIPINSTALL=1
+ $(MKDIR) $(DIST_DESTDIR)
+ $(DEL) $(ZIPDESTFILE)
+ifdef USEZIPWRAPPER
+ifneq ($(ECHOREDIR),echo)
+ $(ECHOREDIR) -e "$(subst \,\\,$(ZIPCMD_CDPACK))" > $(ZIPWRAPPER)
+ $(ECHOREDIR) -e "$(subst \,\\,$(ZIPCMD_ZIP))" >> $(ZIPWRAPPER)
+ $(ECHOREDIR) -e "$(subst \,\\,$(ZIPCMD_CDBASE))" >> $(ZIPWRAPPER)
+else
+ echo $(ZIPCMD_CDPACK) > $(ZIPWRAPPER)
+ echo $(ZIPCMD_ZIP) >> $(ZIPWRAPPER)
+ echo $(ZIPCMD_CDBASE) >> $(ZIPWRAPPER)
+endif
+ifdef inUnix
+ /bin/sh $(ZIPWRAPPER)
+else
+ifdef RUNBATCH
+ $(RUNBATCH) (ZIPWRAPPER)
+else
+ $(ZIPWRAPPER)
+endif
+endif
+ $(DEL) $(ZIPWRAPPER)
+else
+ $(ZIPCMD_CDPACK) ; $(ZIPCMD_ZIP) ; $(ZIPCMD_CDBASE)
+endif
+ $(DELTREE) $(PACKDIR)
+fpc_zipsourceinstall:
+ $(MAKE) fpc_zipinstall ZIPTARGET=sourceinstall ZIPSUFFIX=$(ZIPSOURCESUFFIX)
+fpc_zipexampleinstall:
+ifdef HASEXAMPLES
+ $(MAKE) fpc_zipinstall ZIPTARGET=exampleinstall ZIPSUFFIX=$(ZIPEXAMPLESUFFIX)
+endif
+fpc_zipdistinstall:
+ $(MAKE) fpc_zipinstall ZIPTARGET=distinstall
+.PHONY: fpc_clean fpc_cleanall fpc_distclean
+ifdef EXEFILES
+override CLEANEXEFILES:=$(addprefix $(TARGETDIRPREFIX),$(CLEANEXEFILES))
+endif
+ifdef CLEAN_UNITS
+override CLEANPPUFILES+=$(addsuffix $(PPUEXT),$(CLEAN_UNITS))
+endif
+ifdef CLEANPPUFILES
+override CLEANPPULINKFILES:=$(subst $(PPUEXT),$(OEXT),$(CLEANPPUFILES)) $(addprefix $(STATICLIBPREFIX),$(subst $(PPUEXT),$(STATICLIBEXT),$(CLEANPPUFILES))) $(addprefix $(IMPORTLIBPREFIX),$(subst $(PPUEXT),$(STATICLIBEXT),$(CLEANPPUFILES)))
+ifdef DEBUGSYMEXT
+override CLEANPPULINKFILES+=$(subst $(PPUEXT),$(DEBUGSYMEXT),$(CLEANPPUFILES))
+endif
+override CLEANPPUFILES:=$(addprefix $(UNITTARGETDIRPREFIX),$(CLEANPPUFILES))
+override CLEANPPULINKFILES:=$(wildcard $(addprefix $(UNITTARGETDIRPREFIX),$(CLEANPPULINKFILES)))
+endif
+fpc_clean: $(CLEANTARGET)
+ifdef CLEANEXEFILES
+ -$(DEL) $(CLEANEXEFILES)
+endif
+ifdef CLEANPPUFILES
+ -$(DEL) $(CLEANPPUFILES)
+endif
+ifneq ($(CLEANPPULINKFILES),)
+ -$(DEL) $(CLEANPPULINKFILES)
+endif
+ifdef CLEANRSTFILES
+ -$(DEL) $(addprefix $(UNITTARGETDIRPREFIX),$(CLEANRSTFILES))
+endif
+ifdef CLEAN_FILES
+ -$(DEL) $(CLEAN_FILES)
+endif
+ifdef LIB_NAME
+ -$(DEL) $(LIB_NAME) $(LIB_FULLNAME)
+endif
+ -$(DEL) $(FPCMADE) Package.fpc $(PPAS) script.res link.res $(FPCEXTFILE) $(REDIRFILE)
+ -$(DEL) *$(ASMEXT) *_ppas$(BATCHEXT)
+fpc_cleanall: $(CLEANTARGET)
+ifdef CLEANEXEFILES
+ -$(DEL) $(CLEANEXEFILES)
+endif
+ifdef COMPILER_UNITTARGETDIR
+ifdef CLEANPPUFILES
+ -$(DEL) $(CLEANPPUFILES)
+endif
+ifneq ($(CLEANPPULINKFILES),)
+ -$(DEL) $(CLEANPPULINKFILES)
+endif
+ifdef CLEANRSTFILES
+ -$(DEL) $(addprefix $(UNITTARGETDIRPREFIX),$(CLEANRSTFILES))
+endif
+endif
+ -$(DELTREE) units
+ -$(DEL) *$(OEXT) *$(PPUEXT) *$(RSTEXT) *$(ASMEXT) *$(STATICLIBEXT) *$(SHAREDLIBEXT) *$(PPLEXT)
+ifneq ($(PPUEXT),.ppu)
+ -$(DEL) *.o *.ppu *.a
+endif
+ -$(DELTREE) *$(SMARTEXT)
+ -$(DEL) fpcmade.* Package.fpc $(PPAS) script.res link.res $(FPCEXTFILE) $(REDIRFILE)
+ -$(DEL) *_ppas$(BATCHEXT)
+ifdef AOUTEXT
+ -$(DEL) *$(AOUTEXT)
+endif
+ifdef DEBUGSYMEXT
+ -$(DEL) *$(DEBUGSYMEXT)
+endif
+fpc_distclean: cleanall
+.PHONY: fpc_baseinfo
+override INFORULES+=fpc_baseinfo
+fpc_baseinfo:
+ @$(ECHO)
+ @$(ECHO) == Package info ==
+ @$(ECHO) Package Name..... $(PACKAGE_NAME)
+ @$(ECHO) Package Version.. $(PACKAGE_VERSION)
+ @$(ECHO)
+ @$(ECHO) == Configuration info ==
+ @$(ECHO)
+ @$(ECHO) FPC.......... $(FPC)
+ @$(ECHO) FPC Version.. $(FPC_VERSION)
+ @$(ECHO) Source CPU... $(CPU_SOURCE)
+ @$(ECHO) Target CPU... $(CPU_TARGET)
+ @$(ECHO) Source OS.... $(OS_SOURCE)
+ @$(ECHO) Target OS.... $(OS_TARGET)
+ @$(ECHO) Full Source.. $(FULL_SOURCE)
+ @$(ECHO) Full Target.. $(FULL_TARGET)
+ @$(ECHO) SourceSuffix. $(SOURCESUFFIX)
+ @$(ECHO) TargetSuffix. $(TARGETSUFFIX)
+ @$(ECHO)
+ @$(ECHO) == Directory info ==
+ @$(ECHO)
+ @$(ECHO) Required pkgs... $(REQUIRE_PACKAGES)
+ @$(ECHO)
+ @$(ECHO) Basedir......... $(BASEDIR)
+ @$(ECHO) FPCDir.......... $(FPCDIR)
+ @$(ECHO) CrossBinDir..... $(CROSSBINDIR)
+ @$(ECHO) UnitsDir........ $(UNITSDIR)
+ @$(ECHO) PackagesDir..... $(PACKAGESDIR)
+ @$(ECHO)
+ @$(ECHO) GCC library..... $(GCCLIBDIR)
+ @$(ECHO) Other library... $(OTHERLIBDIR)
+ @$(ECHO)
+ @$(ECHO) == Tools info ==
+ @$(ECHO)
+ @$(ECHO) As........ $(AS)
+ @$(ECHO) Ld........ $(LD)
+ @$(ECHO) Ar........ $(AR)
+ @$(ECHO) Rc........ $(RC)
+ @$(ECHO)
+ @$(ECHO) Mv........ $(MVPROG)
+ @$(ECHO) Cp........ $(CPPROG)
+ @$(ECHO) Rm........ $(RMPROG)
+ @$(ECHO) GInstall.. $(GINSTALL)
+ @$(ECHO) Echo...... $(ECHO)
+ @$(ECHO) Shell..... $(SHELL)
+ @$(ECHO) Date...... $(DATE)
+ @$(ECHO) FPCMake... $(FPCMAKE)
+ @$(ECHO) PPUMove... $(PPUMOVE)
+ @$(ECHO) Upx....... $(UPXPROG)
+ @$(ECHO) Zip....... $(ZIPPROG)
+ @$(ECHO)
+ @$(ECHO) == Object info ==
+ @$(ECHO)
+ @$(ECHO) Target Loaders........ $(TARGET_LOADERS)
+ @$(ECHO) Target Units.......... $(TARGET_UNITS)
+ @$(ECHO) Target Implicit Units. $(TARGET_IMPLICITUNITS)
+ @$(ECHO) Target Programs....... $(TARGET_PROGRAMS)
+ @$(ECHO) Target Dirs........... $(TARGET_DIRS)
+ @$(ECHO) Target Examples....... $(TARGET_EXAMPLES)
+ @$(ECHO) Target ExampleDirs.... $(TARGET_EXAMPLEDIRS)
+ @$(ECHO)
+ @$(ECHO) Clean Units......... $(CLEAN_UNITS)
+ @$(ECHO) Clean Files......... $(CLEAN_FILES)
+ @$(ECHO)
+ @$(ECHO) Install Units....... $(INSTALL_UNITS)
+ @$(ECHO) Install Files....... $(INSTALL_FILES)
+ @$(ECHO)
+ @$(ECHO) == Install info ==
+ @$(ECHO)
+ @$(ECHO) DateStr.............. $(DATESTR)
+ @$(ECHO) ZipName.............. $(ZIPNAME)
+ @$(ECHO) ZipPrefix............ $(ZIPPREFIX)
+ @$(ECHO) ZipCrossPrefix....... $(ZIPCROSSPREFIX)
+ @$(ECHO) ZipSuffix............ $(ZIPSUFFIX)
+ @$(ECHO) FullZipName.......... $(FULLZIPNAME)
+ @$(ECHO) Install FPC Package.. $(INSTALL_FPCPACKAGE)
+ @$(ECHO)
+ @$(ECHO) Install base dir..... $(INSTALL_BASEDIR)
+ @$(ECHO) Install binary dir... $(INSTALL_BINDIR)
+ @$(ECHO) Install library dir.. $(INSTALL_LIBDIR)
+ @$(ECHO) Install units dir.... $(INSTALL_UNITDIR)
+ @$(ECHO) Install source dir... $(INSTALL_SOURCEDIR)
+ @$(ECHO) Install doc dir...... $(INSTALL_DOCDIR)
+ @$(ECHO) Install example dir.. $(INSTALL_EXAMPLEDIR)
+ @$(ECHO) Install data dir..... $(INSTALL_DATADIR)
+ @$(ECHO)
+ @$(ECHO) Dist destination dir. $(DIST_DESTDIR)
+ @$(ECHO) Dist zip name........ $(DIST_ZIPNAME)
+ @$(ECHO)
+.PHONY: fpc_info
+fpc_info: $(INFORULES)
+.PHONY: fpc_makefile fpc_makefiles fpc_makefile_sub1 fpc_makefile_sub2 \
+ fpc_makefile_dirs
+fpc_makefile:
+ $(FPCMAKE) -w -T$(OS_TARGET) Makefile.fpc
+fpc_makefile_sub1:
+ifdef TARGET_DIRS
+ $(FPCMAKE) -w -T$(OS_TARGET) $(addsuffix /Makefile.fpc,$(TARGET_DIRS))
+endif
+ifdef TARGET_EXAMPLEDIRS
+ $(FPCMAKE) -w -T$(OS_TARGET) $(addsuffix /Makefile.fpc,$(TARGET_EXAMPLEDIRS))
+endif
+fpc_makefile_sub2: $(addsuffix _makefile_dirs,$(TARGET_DIRS) $(TARGET_EXAMPLEDIRS))
+fpc_makefile_dirs: fpc_makefile_sub1 fpc_makefile_sub2
+fpc_makefiles: fpc_makefile fpc_makefile_dirs
+all: fpc_all
+debug: fpc_debug
+smart: fpc_smart
+release: fpc_release
+units: fpc_units
+examples:
+shared: fpc_shared
+install: fpc_install
+sourceinstall: fpc_sourceinstall
+exampleinstall: fpc_exampleinstall
+distinstall: fpc_distinstall
+zipinstall: fpc_zipinstall
+zipsourceinstall: fpc_zipsourceinstall
+zipexampleinstall: fpc_zipexampleinstall
+zipdistinstall: fpc_zipdistinstall
+clean: fpc_clean
+distclean: fpc_distclean
+cleanall: fpc_cleanall
+info: fpc_info
+makefiles: fpc_makefiles
+.PHONY: all debug smart release units examples shared install sourceinstall exampleinstall distinstall zipinstall zipsourceinstall zipexampleinstall zipdistinstall clean distclean cleanall info makefiles
+ifneq ($(wildcard fpcmake.loc),)
+include fpcmake.loc
+endif
+.NOTPARALLEL:
diff --git a/packages/fcl-async/Makefile.fpc b/packages/fcl-async/Makefile.fpc
new file mode 100644
index 0000000000..e7c024a85e
--- /dev/null
+++ b/packages/fcl-async/Makefile.fpc
@@ -0,0 +1,37 @@
+#
+# Makefile.fpc for libasync
+#
+
+[package]
+name=fcl-async
+version=2.0.0
+
+[target]
+units=libasync fpasync
+
+[install]
+fpcpackage=y
+
+[compiler]
+sourcedir=src
+sourcedir_linux=src/unix
+sourcedir_beos=src/unix
+sourcedir_freebsd=src/unix
+sourcedir_darwin=src/unix
+sourcedir_solaris=src/unix
+sourcedir_netbsd=src/unix
+sourcedir_openbsd=src/unix
+includedir=src
+includedir_linux=src/unix
+includedir_beos=src/unix
+includedir_freebsd=src/unix
+includedir_darwin=src/unix
+includedir_solaris=src/unix
+includedir_netbsd=src/unix
+includedir_openbsd=src/unix
+
+[default]
+fpcdir=../..
+
+[rules]
+.NOTPARALLEL:
diff --git a/packages/fcl-async/src/fpasync.pp b/packages/fcl-async/src/fpasync.pp
new file mode 100644
index 0000000000..f8e555aaf7
--- /dev/null
+++ b/packages/fcl-async/src/fpasync.pp
@@ -0,0 +1,856 @@
+{
+
+ fpAsync: Asynchronous event management for Free Pascal
+ Copyright (C) 2001-2005 by
+ Areca Systems GmbH / Sebastian Guenther, sg@freepascal.org
+
+ See the file COPYING.FPC, included in this distribution,
+ for details about the copyright.
+
+ This program 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.
+}
+
+unit fpAsync;
+
+{$MODE objfpc}
+{$H+}
+
+interface
+
+uses SysUtils, Classes, libasync;
+
+type
+
+ TNotifyEvent = procedure(Sender: TObject) of object;
+
+ EAsyncError = class(Exception)
+ private
+ FErrorCode: TAsyncResult;
+ public
+ constructor Create(AErrorCode: TAsyncResult);
+ property ErrorCode: TAsyncResult read FErrorCode;
+ end;
+
+ TEventLoop = class
+ private
+ FData: TAsyncData;
+ FFirstNotifyData: Pointer;
+ function GetIsRunning: Boolean;
+ procedure SetIsRunning(AIsRunning: Boolean);
+ protected
+ procedure CheckResult(AResultCode: TAsyncResult);
+ public
+ constructor Create;
+ destructor Destroy; override;
+ function Handle: TAsyncHandle;
+
+ // Main loop control
+ procedure Run;
+ procedure Break;
+
+ // Timer support
+ function AddTimerCallback(AMSec: LongInt; APeriodic: Boolean;
+ ACallback: TAsyncCallback; AUserData: Pointer): TAsyncTimer;
+ procedure RemoveTimerCallback(ATimer: TAsyncTimer);
+ function AddTimerNotify(AMSec: LongInt; APeriodic: Boolean;
+ ANotify: TNotifyEvent; ASender: TObject): Pointer;
+ procedure RemoveTimerNotify(AHandle: Pointer);
+
+ // I/O notification support (for files, sockets etc.)
+ procedure SetIOCallback(AHandle: Integer; ACallback: TAsyncCallback;
+ AUserData: Pointer);
+ procedure ClearIOCallback(AHandle: Integer);
+ function SetIONotify(AHandle: Integer; ANotify: TNotifyEvent;
+ ASender: TObject): Pointer;
+ procedure ClearIONotify(AHandle: Pointer);
+
+ procedure SetDataAvailableCallback(AHandle: Integer;
+ ACallback: TAsyncCallback; AUserData: Pointer);
+ procedure ClearDataAvailableCallback(AHandle: Integer);
+ function SetDataAvailableNotify(AHandle: Integer; ANotify: TNotifyEvent;
+ ASender: TObject): Pointer;
+ procedure ClearDataAvailableNotify(AHandle: Pointer);
+
+ procedure SetCanWriteCallback(AHandle: Integer; ACallback: TAsyncCallback;
+ AUserData: Pointer);
+ procedure ClearCanWriteCallback(AHandle: Integer);
+ function SetCanWriteNotify(AHandle: Integer; ANotify: TNotifyEvent;
+ ASender: TObject): Pointer;
+ procedure ClearCanWriteNotify(AHandle: Pointer);
+
+
+ class function TimerTicks: Int64;
+
+ // Properties
+ property IsRunning: Boolean read GetIsRunning write SetIsRunning;
+ end;
+
+
+// -------------------------------------------------------------------
+// Asynchronous line reader
+// -------------------------------------------------------------------
+
+ TLineNotify = procedure(const ALine: String) of object;
+
+ TGenericLineReader = class
+ protected
+ RealBuffer, FBuffer: PChar;
+ FBytesInBuffer: Integer;
+ FOnLine: TLineNotify;
+ InCallback, DoStopAndFree: Boolean;
+
+ function Read(var ABuffer; count: Integer): Integer; virtual; abstract;
+ procedure NoData; virtual; abstract;
+
+ public
+ destructor Destroy; override;
+ procedure Run; // Process as many lines as possible
+
+ property Buffer: PChar read FBuffer;
+ property BytesInBuffer: Integer read FBytesInBuffer;
+ property OnLine: TLineNotify read FOnLine write FOnLine;
+ end;
+
+ TAsyncStreamLineReader = class(TGenericLineReader)
+ protected
+ FEventLoop: TEventLoop;
+ FDataStream: TStream;
+ FBlockingStream: THandleStream;
+ FOnEOF: TNotifyEvent;
+ NotifyHandle: Pointer;
+
+ function Read(var ABuffer; count: Integer): Integer; override;
+ procedure NoData; override;
+ procedure StreamDataAvailable(UserData: TObject);
+ public
+ constructor Create(AEventLoop: TEventLoop; AStream: THandleStream);
+ constructor Create(AEventLoop: TEventLoop; ADataStream: TStream;
+ ABlockingStream: THandleStream);
+ destructor Destroy; override;
+ procedure StopAndFree; // Destroy instance after run
+
+ property EventLoop: TEventLoop read FEventLoop;
+ property DataStream: TStream read FDataStream;
+ property BlockingStream: THandleStream read FBlockingStream;
+ property OnEOF: TNotifyEvent read FOnEOF write FOnEOF;
+ end;
+
+
+// -------------------------------------------------------------------
+// Asynchronous write buffers
+// -------------------------------------------------------------------
+
+ TWriteBuffer = class(TStream)
+ protected
+ FBuffer: PChar;
+ FBytesInBuffer: Integer;
+ FBufferSent: Boolean;
+ FOnBufferEmpty: TNotifyEvent;
+ FOnBufferSent: TNotifyEvent;
+ InCallback: Boolean;
+
+ function Seek(Offset: LongInt; Origin: Word): LongInt; override;
+ function Write(const ABuffer; Count: LongInt): LongInt; override;
+ function DoRealWrite(const ABuffer; Count: Integer): Integer; virtual; abstract;
+ procedure WritingFailed; virtual; abstract;
+ procedure WantWrite; virtual; abstract;
+ procedure BufferEmpty; virtual;
+ public
+ EndOfLineMarker: String;
+
+ constructor Create;
+ destructor Destroy; override;
+ procedure WriteLine(const line: String);
+ procedure Run; // Write as many data as possible
+
+ property BytesInBuffer: Integer read FBytesInBuffer;
+ property BufferSent: Boolean read FBufferSent;
+ property OnBufferEmpty: TNotifyEvent read FOnBufferEmpty write FOnBufferEmpty;
+ property OnBufferSent: TNotifyEvent read FOnBufferSent write FOnBufferSent;
+ end;
+
+
+ TAsyncWriteStream = class(TWriteBuffer)
+ protected
+ FEventLoop: TEventLoop;
+ FDataStream: TStream;
+ FBlockingStream: THandleStream;
+ NotifyHandle: Pointer;
+ DoStopAndFree: Boolean;
+
+ function DoRealWrite(const ABuffer; Count: Integer): Integer; override;
+ procedure WritingFailed; override;
+ procedure WantWrite; override;
+ procedure CanWrite(UserData: TObject);
+ public
+ constructor Create(AEventLoop: TEventLoop; AStream: THandleStream);
+ constructor Create(AEventLoop: TEventLoop;
+ ADataStream: TStream; ABlockingStream: THandleStream);
+ destructor Destroy; override;
+ procedure StopAndFree; // Destroy instance after run
+
+ property EventLoop: TEventLoop read FEventLoop;
+ property DataStream: TStream read FDataStream;
+ property BlockingStream: THandleStream read FBlockingStream;
+ end;
+
+
+var
+ { All data written to a TWriteBuffer or descendant class will be written to
+ this stream as well: }
+ fpAsyncWriteBufferDebugStream: TStream;
+
+
+implementation
+
+type
+ PNotifyData = ^TNotifyData;
+ TNotifyData = record
+ Next: PNotifyData;
+ Notify: TNotifyEvent;
+ Sender: TObject;
+ case Boolean of
+ False: (TimerHandle: TAsyncTimer);
+ True: (FileHandle: LongInt);
+ end;
+
+
+procedure EventHandler(Data: Pointer); cdecl;
+begin
+ with PNotifyData(Data)^ do
+ Notify(Sender);
+end;
+
+
+function AddNotifyData(Obj: TEventLoop): PNotifyData;
+begin
+ New(Result);
+ Result^.Next := PNotifyData(Obj.FFirstNotifyData);
+ Obj.FFirstNotifyData := Result;
+end;
+
+procedure FreeNotifyData(Obj: TEventLoop; Data: PNotifyData);
+var
+ CurData, PrevData, NextData: PNotifyData;
+begin
+ PrevData := nil;
+ CurData := Obj.FFirstNotifyData;
+ while Assigned(CurData) do
+ begin
+ NextData := CurData^.Next;
+ if CurData = Data then
+ if Assigned(PrevData) then
+ PrevData^.Next := NextData
+ else
+ Obj.FFirstNotifyData := NextData;
+ PrevData := CurData;
+ CurData := NextData;
+ end;
+
+ Dispose(Data);
+end;
+
+
+constructor EAsyncError.Create(AErrorCode: TAsyncResult);
+begin
+ inherited Create(Format('Async I/O error %d', [Ord(AErrorCode)]));
+ FErrorCode := AErrorCode;
+end;
+
+
+constructor TEventLoop.Create;
+begin
+ asyncInit(Handle);
+end;
+
+destructor TEventLoop.Destroy;
+var
+ NotifyData, NextNotifyData: PNotifyData;
+begin
+ asyncFree(Handle);
+ NotifyData := FFirstNotifyData;
+ while Assigned(NotifyData) do
+ begin
+ NextNotifyData := NotifyData^.Next;
+ Dispose(NotifyData);
+ NotifyData := NextNotifyData;
+ end;
+end;
+
+function TEventLoop.Handle: TAsyncHandle;
+begin
+ Result := TAsyncHandle(Self);
+end;
+
+procedure TEventLoop.Run;
+begin
+ asyncRun(Handle);
+end;
+
+procedure TEventLoop.Break;
+begin
+ asyncBreak(Handle);
+end;
+
+function TEventLoop.AddTimerCallback(AMSec: LongInt; APeriodic: Boolean;
+ ACallback: TAsyncCallback; AUserData: Pointer): TAsyncTimer;
+begin
+ Result := asyncAddTimer(Handle, AMSec, APeriodic, ACallback, AUserData);
+end;
+
+procedure TEventLoop.RemoveTimerCallback(ATimer: TAsyncTimer);
+begin
+ asyncRemoveTimer(Handle, ATimer);
+end;
+
+function TEventLoop.AddTimerNotify(AMSec: LongInt; APeriodic: Boolean;
+ ANotify: TNotifyEvent; ASender: TObject): Pointer;
+var
+ UserData: PNotifyData;
+begin
+ UserData := AddNotifyData(Self);
+ UserData^.Notify := ANotify;
+ UserData^.Sender := ASender;
+ UserData^.TimerHandle :=
+ asyncAddTimer(Handle, AMSec, APeriodic, @EventHandler, UserData);
+ Result := UserData;
+end;
+
+procedure TEventLoop.RemoveTimerNotify(AHandle: Pointer);
+var
+ Data: PNotifyData;
+begin
+ Data := PNotifyData(AHandle);
+ asyncRemoveTimer(Handle, Data^.TimerHandle);
+ FreeNotifyData(Self, Data);
+end;
+
+procedure TEventLoop.SetIOCallback(AHandle: Integer; ACallback: TAsyncCallback;
+ AUserData: Pointer);
+begin
+ CheckResult(asyncSetIOCallback(Handle, AHandle, ACallback, AUserData));
+end;
+
+procedure TEventLoop.ClearIOCallback(AHandle: Integer);
+begin
+ asyncClearIOCallback(Handle, AHandle);
+end;
+
+function TEventLoop.SetIONotify(AHandle: Integer; ANotify: TNotifyEvent;
+ ASender: TObject): Pointer;
+var
+ UserData: PNotifyData;
+ ResultCode: TAsyncResult;
+begin
+ UserData := AddNotifyData(Self);
+ UserData^.Notify := ANotify;
+ UserData^.Sender := ASender;
+ UserData^.FileHandle := AHandle;
+ ResultCode := asyncSetIOCallback(Handle, AHandle, @EventHandler, UserData);
+ if ResultCode <> asyncOK then
+ begin
+ FreeNotifyData(Self, UserData);
+ raise EAsyncError.Create(ResultCode);
+ end else
+ Result := UserData;
+ {$IFDEF fpAsyncDebug}WriteLn('TEventLoop.SetIONotify: Filehandle=', AHandle, ', Result=', Integer(Result));{$ENDIF}
+end;
+
+procedure TEventLoop.ClearIONotify(AHandle: Pointer);
+var
+ Data: PNotifyData;
+begin
+ Data := PNotifyData(AHandle);
+ {$IFDEF fpAsyncDebug}WriteLn('TEventLoop.ClearIONotify: Filehandle=', Data^.FileHandle, ', Data=', Integer(AHandle));{$ENDIF}
+ asyncClearIOCallback(Handle, Data^.FileHandle);
+ FreeNotifyData(Self, Data);
+end;
+
+procedure TEventLoop.SetDataAvailableCallback(AHandle: Integer; ACallback: TAsyncCallback;
+ AUserData: Pointer);
+begin
+ CheckResult(asyncSetDataAvailableCallback(Handle, AHandle,
+ ACallback, AUserData));
+end;
+
+procedure TEventLoop.ClearDataAvailableCallback(AHandle: Integer);
+begin
+ asyncClearDataAvailableCallback(Handle, AHandle);
+end;
+
+function TEventLoop.SetDataAvailableNotify(AHandle: Integer; ANotify: TNotifyEvent;
+ ASender: TObject): Pointer;
+var
+ UserData: PNotifyData;
+ ResultCode: TAsyncResult;
+begin
+ UserData := AddNotifyData(Self);
+ UserData^.Notify := ANotify;
+ UserData^.Sender := ASender;
+ UserData^.FileHandle := AHandle;
+ ResultCode := asyncSetDataAvailableCallback(Handle, AHandle,
+ @EventHandler, UserData);
+ if ResultCode <> asyncOK then
+ begin
+ FreeNotifyData(Self, UserData);
+ raise EAsyncError.Create(ResultCode);
+ end else
+ Result := UserData;
+ {$IFDEF fpAsyncDebug}WriteLn('TEventLoop.SetDataAvailableNotify: Filehandle=', AHandle, ', Result=', Integer(Result));{$ENDIF}
+end;
+
+procedure TEventLoop.ClearDataAvailableNotify(AHandle: Pointer);
+var
+ Data: PNotifyData;
+begin
+ Data := PNotifyData(AHandle);
+ {$IFDEF fpAsyncDebug}WriteLn('TEventLoop.ClearDataAvailableNotify: Filehandle=', Data^.FileHandle, ', Data=', Integer(AHandle));{$ENDIF}
+ asyncClearDataAvailableCallback(Handle, Data^.FileHandle);
+ FreeNotifyData(Self, Data);
+end;
+
+procedure TEventLoop.SetCanWriteCallback(AHandle: Integer; ACallback: TAsyncCallback;
+ AUserData: Pointer);
+begin
+ CheckResult(asyncSetCanWriteCallback(Handle, AHandle, ACallback, AUserData));
+end;
+
+procedure TEventLoop.ClearCanWriteCallback(AHandle: Integer);
+begin
+ asyncClearCanWriteCallback(Handle, AHandle);
+end;
+
+function TEventLoop.SetCanWriteNotify(AHandle: Integer; ANotify: TNotifyEvent;
+ ASender: TObject): Pointer;
+var
+ UserData: PNotifyData;
+ ResultCode: TAsyncResult;
+begin
+ UserData := AddNotifyData(Self);
+ UserData^.Notify := ANotify;
+ UserData^.Sender := ASender;
+ UserData^.FileHandle := AHandle;
+ ResultCode := asyncSetCanWriteCallback(Handle, AHandle,
+ @EventHandler, UserData);
+ if ResultCode <> asyncOK then
+ begin
+ FreeNotifyData(Self, UserData);
+ raise EAsyncError.Create(ResultCode);
+ end else
+ Result := UserData;
+ {$IFDEF fpAsyncDebug}WriteLn('TEventLoop.SetCanWriteNotify: Filehandle=', AHandle, ', Result=', Integer(Result));{$ENDIF}
+end;
+
+procedure TEventLoop.ClearCanWriteNotify(AHandle: Pointer);
+var
+ Data: PNotifyData;
+begin
+ Data := PNotifyData(AHandle);
+ {$IFDEF fpAsyncDebug}WriteLn('TEventLoop.ClearCanWriteNotify: Filehandle=', Data^.FileHandle, ', Data=', Integer(AHandle));{$ENDIF}
+ asyncClearCanWriteCallback(Handle, Data^.FileHandle);
+ FreeNotifyData(Self, Data);
+end;
+
+class function TEventLoop.TimerTicks: Int64;
+begin
+ Result := asyncGetTicks;
+end;
+
+procedure TEventLoop.CheckResult(AResultCode: TAsyncResult);
+begin
+ if AResultCode <> asyncOK then
+ raise EAsyncError.Create(AResultCode);
+end;
+
+function TEventLoop.GetIsRunning: Boolean;
+begin
+ Result := asyncIsRunning(Handle);
+end;
+
+procedure TEventLoop.SetIsRunning(AIsRunning: Boolean);
+begin
+ if IsRunning then
+ begin
+ if not AIsRunning then
+ Run;
+ end else
+ if AIsRunning then
+ Break;
+end;
+
+
+// -------------------------------------------------------------------
+// TGenericLineReader
+// -------------------------------------------------------------------
+
+destructor TGenericLineReader.Destroy;
+begin
+ if Assigned(RealBuffer) then
+ begin
+ FreeMem(RealBuffer);
+ RealBuffer := nil;
+ end;
+ inherited Destroy;
+end;
+
+procedure TGenericLineReader.Run;
+var
+ NewData: array[0..1023] of Byte;
+ p: PChar;
+ BytesRead, OldBufSize, CurBytesInBuffer, LastEndOfLine, i, LineLength: Integer;
+ line: String;
+ FirstRun: Boolean;
+begin
+ FirstRun := True;
+ while True do
+ begin
+ BytesRead := Read(NewData, SizeOf(NewData));
+ //WriteLn('Linereader: ', BytesRead, ' bytes read');
+ if BytesRead <= 0 then
+ begin
+ if FirstRun then
+ NoData;
+ break;
+ end;
+ FirstRun := False;
+ OldBufSize := FBytesInBuffer;
+
+ // Append the new received data to the read buffer
+ Inc(FBytesInBuffer, BytesRead);
+ ReallocMem(RealBuffer, FBytesInBuffer);
+ Move(NewData, RealBuffer[OldBufSize], BytesRead);
+
+ {Process all potential lines in the current buffer. Attention: FBuffer and
+ FBytesInBuffer MUST be updated for each line, as they can be accessed from
+ within the FOnLine handler!}
+ LastEndOfLine := 0;
+ if OldBufSize > 0 then
+ i := OldBufSize - 1
+ else
+ i := 0;
+
+ CurBytesInBuffer := FBytesInBuffer;
+
+ while i <= CurBytesInBuffer - 2 do
+ begin
+ if (RealBuffer[i] = #13) or (RealBuffer[i] = #10) then
+ begin
+ LineLength := i - LastEndOfLine;
+ SetLength(line, LineLength);
+ if LineLength > 0 then
+ Move(RealBuffer[LastEndOfLine], line[1], LineLength);
+
+ if ((RealBuffer[i] = #13) and (RealBuffer[i + 1] = #10)) or
+ ((RealBuffer[i] = #10) and (RealBuffer[i + 1] = #13)) then
+ Inc(i);
+ LastEndOfLine := i + 1;
+
+ if Assigned(FOnLine) then
+ begin
+ FBuffer := RealBuffer + LastEndOfLine;
+ FBytesInBuffer := CurBytesInBuffer - LastEndOfLine;
+ InCallback := True;
+ try
+ FOnLine(line);
+ finally
+ InCallback := False;
+ end;
+ // Check if <this> has been destroyed by FOnLine:
+ if DoStopAndFree then
+ exit;
+ end;
+ end;
+ Inc(i);
+ end;
+
+ FBytesInBuffer := CurBytesInBuffer;
+
+ if LastEndOfLine > 0 then
+ begin
+ // Remove all processed lines from the buffer
+ Dec(FBytesInBuffer, LastEndOfLine);
+ GetMem(p, FBytesInBuffer);
+ Move(RealBuffer[LastEndOfLine], p^, FBytesInBuffer);
+ if Assigned(RealBuffer) then
+ FreeMem(RealBuffer);
+ RealBuffer := p;
+ end;
+ FBuffer := RealBuffer;
+ end;
+end;
+
+
+// -------------------------------------------------------------------
+// TAsyncStreamLineReader
+// -------------------------------------------------------------------
+
+constructor TAsyncStreamLineReader.Create(AEventLoop: TEventLoop;
+ AStream: THandleStream);
+begin
+ Self.Create(AEventLoop, AStream, AStream);
+end;
+
+constructor TAsyncStreamLineReader.Create(AEventLoop: TEventLoop;
+ ADataStream: TStream; ABlockingStream: THandleStream);
+begin
+ ASSERT(Assigned(ADataStream) and Assigned(ABlockingStream));
+
+ inherited Create;
+ FEventLoop := AEventLoop;
+ FDataStream := ADataStream;
+ FBlockingStream := ABlockingStream;
+ NotifyHandle := EventLoop.SetDataAvailableNotify(
+ FBlockingStream.Handle, @StreamDataAvailable, nil);
+end;
+
+destructor TAsyncStreamLineReader.Destroy;
+begin
+ inherited Destroy;
+end;
+
+procedure TAsyncStreamLineReader.StopAndFree;
+begin
+ if InCallback then
+ begin
+ if Assigned(NotifyHandle) then
+ begin
+ EventLoop.ClearDataAvailableNotify(NotifyHandle);
+ NotifyHandle := nil;
+ end;
+ DoStopAndFree := True;
+ end else
+ Self.Free;
+end;
+
+function TAsyncStreamLineReader.Read(var ABuffer; count: Integer): Integer;
+begin
+ Result := FDataStream.Read(ABuffer, count);
+end;
+
+procedure TAsyncStreamLineReader.NoData;
+var
+ s: String;
+begin
+ if (FDataStream = FBlockingStream) or (FDataStream.Position = FDataStream.Size) then
+ begin
+
+ if (FBytesInBuffer > 0) and Assigned(FOnLine) then
+ begin
+ if FBuffer[FBytesInBuffer - 1] in [#13, #10] then
+ Dec(FBytesInBuffer);
+ SetLength(s, FBytesInBuffer);
+ Move(FBuffer^, s[1], FBytesInBuffer);
+ FOnLine(s);
+ end;
+
+ EventLoop.ClearDataAvailableNotify(NotifyHandle);
+ NotifyHandle := nil;
+ if Assigned(FOnEOF) then
+ begin
+ InCallback := True;
+ try
+ FOnEOF(Self);
+ finally
+ InCallback := False;
+ end;
+ end;
+ end;
+end;
+
+procedure TAsyncStreamLineReader.StreamDataAvailable(UserData: TObject);
+begin
+ Run;
+ if DoStopAndFree then
+ Free;
+end;
+
+
+// -------------------------------------------------------------------
+// TWriteBuffer
+// -------------------------------------------------------------------
+
+procedure TWriteBuffer.BufferEmpty;
+begin
+ if Assigned(FOnBufferEmpty) then
+ begin
+ InCallback := True;
+ FOnBufferEmpty(Self);
+ InCallback := False;
+ end;
+end;
+
+constructor TWriteBuffer.Create;
+begin
+ inherited Create;
+
+ FBuffer := nil;
+ FBytesInBuffer := 0;
+ EndOfLineMarker := #10;
+end;
+
+destructor TWriteBuffer.Destroy;
+begin
+ if Assigned(FBuffer) then
+ FreeMem(FBuffer);
+ inherited Destroy;
+end;
+
+function TWriteBuffer.Seek(Offset: LongInt; Origin: Word): LongInt;
+begin
+ if ((Offset = 0) and ((Origin = soFromCurrent) or (Origin = soFromEnd))) or
+ ((Offset = FBytesInBuffer) and (Origin = soFromBeginning)) then
+ Result := FBytesInBuffer
+ else
+ // !!!: No i18n for this string - solve this problem in the FCL?!?
+ raise EStreamError.Create('Invalid stream operation');
+end;
+
+function TWriteBuffer.Write(const ABuffer; Count: LongInt): LongInt;
+begin
+ if Count > 0 then
+ begin
+ FBufferSent := False;
+ ReallocMem(FBuffer, FBytesInBuffer + Count);
+ Move(ABuffer, FBuffer[FBytesInBuffer], Count);
+ Inc(FBytesInBuffer, Count);
+ if Assigned(fpAsyncWriteBufferDebugStream) then
+ fpAsyncWriteBufferDebugStream.Write(ABuffer, Count);
+ WantWrite;
+ end;
+ Result := Count;
+end;
+
+procedure TWriteBuffer.WriteLine(const line: String);
+var
+ s: String;
+begin
+ s := line + EndOfLineMarker;
+ WriteBuffer(s[1], Length(s));
+end;
+
+procedure TWriteBuffer.Run;
+var
+ Written: Integer;
+ NewBuf: PChar;
+ Failed: Boolean;
+begin
+ Failed := True;
+ repeat
+ if FBytesInBuffer = 0 then
+ begin
+ BufferEmpty;
+ if FBufferSent then
+ exit;
+ WantWrite;
+ exit;
+ end;
+
+ Written := DoRealWrite(FBuffer[0], FBytesInBuffer);
+ if Written > 0 then
+ begin
+ Failed := False;
+ Dec(FBytesInBuffer, Written);
+ GetMem(NewBuf, FBytesInBuffer);
+ Move(FBuffer[Written], NewBuf[0], FBytesInBuffer);
+ FreeMem(FBuffer);
+ FBuffer := NewBuf;
+ end;
+ until Written <= 0;
+
+ if Failed then
+ WritingFailed;
+end;
+
+
+// -------------------------------------------------------------------
+// TAsyncWriteStream
+// -------------------------------------------------------------------
+
+function TAsyncWriteStream.DoRealWrite(const ABuffer; Count: Integer): Integer;
+begin
+ Result := FDataStream.Write(ABuffer, count);
+end;
+
+procedure TAsyncWriteStream.WritingFailed;
+begin
+ if (FDataStream <> FBlockingStream) and Assigned(NotifyHandle) then
+ begin
+ EventLoop.ClearCanWriteNotify(NotifyHandle);
+ NotifyHandle := nil;
+ end;
+end;
+
+procedure TAsyncWriteStream.WantWrite;
+begin
+ if not Assigned(NotifyHandle) then
+ NotifyHandle := EventLoop.SetCanWriteNotify(FBlockingStream.Handle,
+ @CanWrite, nil);
+end;
+
+procedure TAsyncWriteStream.CanWrite(UserData: TObject);
+begin
+ if FBytesInBuffer = 0 then
+ begin
+ if Assigned(NotifyHandle) then
+ begin
+ EventLoop.ClearCanWriteNotify(NotifyHandle);
+ NotifyHandle := nil;
+ end;
+ FBufferSent := True;
+ if Assigned(FOnBufferSent) then
+ begin
+ InCallback := True;
+ try
+ FOnBufferSent(Self);
+ finally
+ InCallback := False;
+ end;
+ end;
+ end else
+ Run;
+ if DoStopAndFree then
+ Free;
+end;
+
+constructor TAsyncWriteStream.Create(AEventLoop: TEventLoop;
+ AStream: THandleStream);
+begin
+ Self.Create(AEventLoop, AStream, AStream);
+end;
+
+constructor TAsyncWriteStream.Create(AEventLoop: TEventLoop;
+ ADataStream: TStream; ABlockingStream: THandleStream);
+begin
+ ASSERT(Assigned(ADataStream) and Assigned(ABlockingStream));
+
+ inherited Create;
+ FEventLoop := AEventLoop;
+ FDataStream := ADataStream;
+ FBlockingStream := ABlockingStream;
+end;
+
+destructor TAsyncWriteStream.Destroy;
+begin
+ if Assigned(NotifyHandle) then
+ EventLoop.ClearCanWriteNotify(NotifyHandle);
+ inherited Destroy;
+end;
+
+procedure TAsyncWriteStream.StopAndFree;
+begin
+ if InCallback then
+ begin
+ if Assigned(NotifyHandle) then
+ begin
+ EventLoop.ClearCanWriteNotify(NotifyHandle);
+ NotifyHandle := nil;
+ end;
+ DoStopAndFree := True;
+ end else
+ Self.Free;
+end;
+
+
+end.
diff --git a/packages/fcl-async/src/libasync.inc b/packages/fcl-async/src/libasync.inc
new file mode 100644
index 0000000000..0e65c4cb77
--- /dev/null
+++ b/packages/fcl-async/src/libasync.inc
@@ -0,0 +1,482 @@
+{
+
+ libasync: Asynchronous event management
+ Copyright (C) 2001-2002 by
+ Areca Systems GmbH / Sebastian Guenther, sg@freepascal.org
+
+ Common implementation
+
+ See the file COPYING.FPC, included in this distribution,
+ for details about the copyright.
+
+ This program 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.
+}
+
+type
+ PTimerData = ^TTimerData;
+ TTimerData = record
+ Next: PTimerData;
+ MSec: LongInt;
+ NextTick: Int64;
+ Callback: TAsyncCallback;
+ UserData: Pointer;
+ Periodic: Boolean;
+ end;
+
+ TCallbackTypes = set of (cbRead, cbWrite);
+
+
+{ An implementation unit has to implement the following fordward procedures,
+ and additionally asyncGetTicks }
+
+procedure InternalInit(Handle: TAsyncHandle); forward;
+
+procedure InternalFree(Handle: TAsyncHandle); forward;
+
+procedure InternalRun(Handle: TAsyncHandle; TimeOut: Int64); forward;
+
+procedure InternalInitIOCallback(Handle: TAsyncHandle; Data: PIOCallbackData;
+ InitData: Boolean; CallbackTypes: TCallbackTypes); forward;
+
+procedure InternalClearIOCallback(Handle: TAsyncHandle; IOHandle: LongInt;
+ CallbackTypes: TCallbackTypes); forward;
+
+
+
+function InitIOCallback(Handle: TAsyncHandle; IOHandle: LongInt;
+ ARead: Boolean; ReadCallback: TAsyncCallback; ReadUserData: Pointer;
+ AWrite: Boolean; WriteCallback: TAsyncCallback; WriteUserData: Pointer):
+ TAsyncResult;
+var
+ Data: PIOCallbackData;
+ NeedData: Boolean;
+ CallbackTypes: TCallbackTypes;
+begin
+ if (IOHandle < 0) or (IOHandle > MaxHandle) then
+ begin
+ Result := asyncInvalidFileHandle;
+ exit;
+ end;
+
+ NeedData := True;
+ Data := Handle^.Data.FirstIOCallback;
+ while Assigned(Data) do
+ begin
+ if Data^.IOHandle = IOHandle then
+ begin
+ if ARead then
+ begin
+ if Assigned(Data^.ReadCallback) then
+ begin
+ Result := asyncHandlerAlreadySet;
+ exit;
+ end;
+ Data^.ReadCallback := ReadCallback;
+ Data^.ReadUserData := ReadUserData;
+ end;
+ if AWrite then
+ begin
+ if Assigned(Data^.WriteCallback) then
+ begin
+ Result := asyncHandlerAlreadySet;
+ exit;
+ end;
+ Data^.WriteCallback := WriteCallback;
+ Data^.WriteUserData := WriteUserData;
+ end;
+ NeedData := False;
+ break;
+ end;
+ Data := Data^.Next;
+ end;
+
+ if NeedData then
+ begin
+ New(Data);
+ Data^.Next := Handle^.Data.FirstIOCallback;
+ Handle^.Data.FirstIOCallback := Data;
+ Data^.IOHandle := IOHandle;
+ if ARead then
+ begin
+ Data^.ReadCallback := ReadCallback;
+ Data^.ReadUserData := ReadUserData;
+ end else
+ Data^.ReadCallback := nil;
+ if AWrite then
+ begin
+ Data^.WriteCallback := WriteCallback;
+ Data^.WriteUserData := WriteUserData;
+ end else
+ Data^.WriteCallback := nil;
+ end;
+
+ CallbackTypes := [];
+ if ARead then
+ CallbackTypes := [cbRead];
+ if AWrite then
+ CallbackTypes := CallbackTypes + [cbWrite];
+ InternalInitIOCallback(Handle, Data, NeedData, CallbackTypes);
+
+ Handle^.Data.HasCallbacks := True;
+ Result := asyncOK;
+end;
+
+procedure CheckForCallbacks(Handle: TAsyncHandle);
+begin
+ if (Handle^.Data.HasCallbacks) and
+ (not Assigned(Handle^.Data.FirstIOCallback)) and
+ (not Assigned(Handle^.Data.FirstTimer)) then
+ Handle^.Data.HasCallbacks := False;
+end;
+
+
+procedure asyncInit(Handle: TAsyncHandle); cdecl;
+begin
+ InternalInit(Handle);
+end;
+
+procedure asyncFree(Handle: TAsyncHandle); cdecl;
+var
+ Timer, NextTimer: PTimerData;
+ IOCallback, NextIOCallback: PIOCallbackData;
+begin
+ InternalFree(Handle);
+
+ Timer := PTimerData(Handle^.Data.FirstTimer);
+ while Assigned(Timer) do
+ begin
+ NextTimer := Timer^.Next;
+ Dispose(Timer);
+ Timer := NextTimer;
+ end;
+
+ IOCallback := PIOCallbackData(Handle^.Data.FirstIOCallback);
+ while Assigned(IOCallback) do
+ begin
+ NextIOCallback := IOCallback^.Next;
+ Dispose(IOCallback);
+ IOCallback := NextIOCallback;
+ end;
+
+ Handle^.Data.NextIOCallback := nil;
+end;
+
+procedure asyncRun(Handle: TAsyncHandle); cdecl;
+var
+ Timer, NextTimer: PTimerData;
+ TimeOut, CurTime, NextTick: Int64;
+begin
+ if Handle^.Data.IsRunning then
+ exit;
+
+ Handle^.Data.DoBreak := False;
+ Handle^.Data.IsRunning := True;
+
+ // Prepare timers
+ if Assigned(Handle^.Data.FirstTimer) then
+ begin
+ CurTime := asyncGetTicks;
+ Timer := Handle^.Data.FirstTimer;
+ while Assigned(Timer) do
+ begin
+ Timer^.NextTick := CurTime + Timer^.MSec;
+ Timer := Timer^.Next;
+ end;
+ end;
+
+ while (not Handle^.Data.DoBreak) and Handle^.Data.HasCallbacks do
+ begin
+ Timer := Handle^.Data.FirstTimer;
+ if Assigned(Handle^.Data.FirstTimer) then
+ begin
+ // Determine when the next timer tick will happen
+ CurTime := asyncGetTicks;
+ NextTick := High(Int64);
+ Timer := Handle^.Data.FirstTimer;
+ while Assigned(Timer) do
+ begin
+ if Timer^.NextTick < NextTick then
+ NextTick := Timer^.NextTick;
+ Timer := Timer^.Next;
+ end;
+ TimeOut := NextTick - CurTime;
+ if TimeOut < 0 then
+ TimeOut := 0;
+ end else
+ TimeOut := -1;
+
+ InternalRun(Handle, TimeOut);
+
+ {if Handle^.Data.HighestHandle >= 0 then
+ begin
+ CurReadFDSet := PFDSet(Handle^.Data.FDData)[0];
+ CurWriteFDSet := PFDSet(Handle^.Data.FDData)[1];
+ AsyncResult := Select(Handle^.Data.HighestHandle + 1,
+ @CurReadFDSet, @CurWriteFDSet, nil, TimeOut);
+ end else
+ AsyncResult := Select(0, nil, nil, nil, TimeOut);
+
+ if (AsyncResult > 0) and not Handle^.Data.DoBreak then
+ begin
+ // Check for I/O events
+ Handle^.Data.CurIOCallback := Handle^.Data.FirstIOCallback;
+ while Assigned(Handle^.Data.CurIOCallback) do
+ begin
+ CurIOCallback := PIOCallbackData(Handle^.Data.CurIOCallback);
+ Handle^.Data.NextIOCallback := CurIOCallback^.Next;
+ if FD_IsSet(CurIOCallback^.IOHandle, CurReadFDSet) and
+ FD_IsSet(CurIOCallback^.IOHandle, PFDSet(Handle^.Data.FDData)[0]) and
+ Assigned(CurIOCallback^.ReadCallback) then
+ begin
+ CurIOCallback^.ReadCallback(CurIOCallback^.ReadUserData);
+ if Handle^.Data.DoBreak then
+ break;
+ end;
+
+ CurIOCallback := PIOCallbackData(Handle^.Data.CurIOCallback);
+ if Assigned(CurIOCallback) and
+ FD_IsSet(CurIOCallback^.IOHandle, CurWriteFDSet) and
+ FD_IsSet(CurIOCallback^.IOHandle, PFDSet(Handle^.Data.FDData)[1]) and
+ Assigned(CurIOCallback^.WriteCallback) then
+ begin
+ CurIOCallback^.WriteCallback(CurIOCallback^.WriteUserData);
+ if Handle^.Data.DoBreak then
+ break;
+ end;
+
+ Handle^.Data.CurIOCallback := Handle^.Data.NextIOCallback;
+ end;
+ end;}
+
+ if Assigned(Handle^.Data.FirstTimer) then
+ begin
+ // Check for triggered timers
+ CurTime := asyncGetTicks;
+ Timer := Handle^.Data.FirstTimer;
+ while Assigned(Timer) do
+ begin
+ if Timer^.NextTick <= CurTime then
+ begin
+ Timer^.Callback(Timer^.UserData);
+ NextTimer := Timer^.Next;
+ if Timer^.Periodic then
+ Inc(Timer^.NextTick, Timer^.MSec)
+ else
+ asyncRemoveTimer(Handle, Timer);
+ if Handle^.Data.DoBreak then
+ break;
+ Timer := NextTimer;
+ end else
+ Timer := Timer^.Next;
+ end;
+ end;
+
+ end;
+ Handle^.Data.CurIOCallback := nil;
+ Handle^.Data.NextIOCallback := nil;
+ Handle^.Data.IsRunning := False;
+end;
+
+procedure asyncBreak(Handle: TAsyncHandle); cdecl;
+begin
+ Handle^.Data.DoBreak := True;
+end;
+
+function asyncIsRunning(Handle: TAsyncHandle): Boolean; cdecl;
+begin
+ Result := Handle^.Data.IsRunning;
+end;
+
+function asyncAddTimer(
+ Handle: TAsyncHandle;
+ MSec: LongInt;
+ Periodic: Boolean;
+ Callback: TAsyncCallback;
+ UserData: Pointer
+ ): TAsyncTimer; cdecl;
+var
+ Data: PTimerData;
+begin
+ if not Assigned(Callback) then
+ exit;
+
+ New(Data);
+ Result := Data;
+ Data^.Next := Handle^.Data.FirstTimer;
+ Handle^.Data.FirstTimer := Data;
+ Data^.MSec := MSec;
+ Data^.Periodic := Periodic;
+ Data^.Callback := Callback;
+ Data^.UserData := UserData;
+ if Handle^.Data.IsRunning then
+ Data^.NextTick := asyncGetTicks + MSec;
+
+ Handle^.Data.HasCallbacks := True;
+end;
+
+procedure asyncRemoveTimer(
+ Handle: TAsyncHandle;
+ Timer: TASyncTimer); cdecl;
+var
+ Data, CurData, PrevData, NextData: PTimerData;
+begin
+ Data := PTimerData(Timer);
+ CurData := Handle^.Data.FirstTimer;
+ PrevData := nil;
+ while Assigned(CurData) do
+ begin
+ NextData := CurData^.Next;
+ if CurData = Data then
+ begin
+ if Assigned(PrevData) then
+ PrevData^.Next := NextData
+ else
+ Handle^.Data.FirstTimer := NextData;
+ break;
+ end;
+ PrevData := CurData;
+ CurData := NextData;
+ end;
+ Dispose(Data);
+ CheckForCallbacks(Handle);
+end;
+
+function asyncSetIOCallback(
+ Handle: TAsyncHandle;
+ IOHandle: LongInt;
+ Callback: TAsyncCallback;
+ UserData: Pointer): TAsyncResult; cdecl;
+begin
+ Result := InitIOCallback(Handle, IOHandle, True, Callback, UserData,
+ True, Callback, UserData);
+end;
+
+procedure asyncClearIOCallback(Handle: TAsyncHandle;
+ IOHandle: LongInt); cdecl;
+var
+ CurData, PrevData, NextData: PIOCallbackData;
+begin
+ CurData := Handle^.Data.FirstIOCallback;
+ PrevData := nil;
+ while Assigned(CurData) do
+ begin
+ NextData := CurData^.Next;
+ if CurData^.IOHandle = IOHandle then
+ begin
+ if Handle^.Data.CurIOCallback = CurData then
+ Handle^.Data.CurIOCallback := nil;
+ if Handle^.Data.NextIOCallback = CurData then
+ Handle^.Data.NextIOCallback := NextData;
+
+ InternalClearIOCallback(Handle, IOHandle, [cbRead, cbWrite]);
+
+ if Assigned(PrevData) then
+ PrevData^.Next := NextData
+ else
+ Handle^.Data.FirstIOCallback := NextData;
+ Dispose(CurData);
+ break;
+ end;
+ PrevData := CurData;
+ CurData := NextData;
+ end;
+ CheckForCallbacks(Handle);
+end;
+
+function asyncSetDataAvailableCallback(
+ Handle: TAsyncHandle;
+ IOHandle: LongInt;
+ Callback: TAsyncCallback;
+ UserData: Pointer): TAsyncResult; cdecl;
+begin
+ Result := InitIOCallback(Handle, IOHandle, True, Callback, UserData, False,
+ nil, nil);
+end;
+
+procedure asyncClearDataAvailableCallback(Handle: TAsyncHandle;
+ IOHandle: LongInt); cdecl;
+var
+ CurData, PrevData, NextData: PIOCallbackData;
+begin
+ CurData := Handle^.Data.FirstIOCallback;
+ PrevData := nil;
+ while Assigned(CurData) do
+ begin
+ NextData := CurData^.Next;
+ if CurData^.IOHandle = IOHandle then
+ begin
+ if Handle^.Data.CurIOCallback = CurData then
+ Handle^.Data.CurIOCallback := nil;
+ if Handle^.Data.NextIOCallback = CurData then
+ Handle^.Data.NextIOCallback := NextData;
+
+ InternalClearIOCallback(Handle, IOHandle, [cbRead]);
+
+ if Assigned(CurData^.WriteCallback) then
+ CurData^.ReadCallback := nil
+ else
+ begin
+ if Assigned(PrevData) then
+ PrevData^.Next := NextData
+ else
+ Handle^.Data.FirstIOCallback := NextData;
+ Dispose(CurData);
+ end;
+ break;
+ end;
+ PrevData := CurData;
+ CurData := NextData;
+ end;
+ CheckForCallbacks(Handle);
+end;
+
+function asyncSetCanWriteCallback(
+ Handle: TAsyncHandle;
+ IOHandle: LongInt;
+ Callback: TAsyncCallback;
+ UserData: Pointer): TAsyncResult; cdecl;
+begin
+ Result := InitIOCallback(Handle, IOHandle, False, nil, nil, True,
+ Callback, UserData);
+end;
+
+procedure asyncClearCanWriteCallback(Handle: TAsyncHandle;
+ IOHandle: LongInt); cdecl;
+var
+ CurData, PrevData, NextData: PIOCallbackData;
+begin
+ CurData := Handle^.Data.FirstIOCallback;
+ PrevData := nil;
+ while Assigned(CurData) do
+ begin
+ NextData := CurData^.Next;
+ if CurData^.IOHandle = IOHandle then
+ begin
+ if Handle^.Data.CurIOCallback = CurData then
+ Handle^.Data.CurIOCallback := nil;
+ if Handle^.Data.NextIOCallback = CurData then
+ Handle^.Data.NextIOCallback := NextData;
+
+ InternalClearIOCallback(Handle, IOHandle, [cbWrite]);
+
+ if Assigned(CurData^.ReadCallback) then
+ CurData^.WriteCallback := nil
+ else
+ begin
+ if Assigned(PrevData) then
+ PrevData^.Next := NextData
+ else
+ Handle^.Data.FirstIOCallback := NextData;
+ Dispose(CurData);
+ end;
+ break;
+ end;
+ PrevData := CurData;
+ CurData := NextData;
+ end;
+ CheckForCallbacks(Handle);
+end;
+
+
diff --git a/packages/fcl-async/src/libasynch.inc b/packages/fcl-async/src/libasynch.inc
new file mode 100644
index 0000000000..67d2419863
--- /dev/null
+++ b/packages/fcl-async/src/libasynch.inc
@@ -0,0 +1,109 @@
+{
+
+ libasync: Asynchronous event management
+ Copyright (C) 2001-2002 by
+ Areca Systems GmbH / Sebastian Guenther, sg@freepascal.org
+
+ Common interface declaration
+
+ See the file COPYING.FPC, included in this distribution,
+ for details about the copyright.
+
+ This program 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.
+}
+
+type
+ TAsyncHandleStruct = packed record
+ UserData: Pointer;
+ Data: TAsyncData;
+ end;
+ TAsyncHandle = ^TAsyncHandleStruct;
+
+ TAsyncTimer = Pointer;
+
+ TAsyncCallback = procedure(UserData: Pointer); cdecl;
+
+ TAsyncResult = (
+ asyncOK,
+ asyncInvalidHandle,
+ asyncInvalidFileHandle,
+ asyncHandlerAlreadySet);
+
+
+// Construction and destruction
+
+procedure asyncInit(
+ Handle: TAsyncHandle); cdecl;
+
+procedure asyncFree(
+ Handle: TAsyncHandle); cdecl;
+
+
+// Running and stopping the event loop
+
+procedure asyncRun(
+ Handle: TAsyncHandle); cdecl;
+
+procedure asyncBreak(
+ Handle: TAsyncHandle); cdecl;
+
+
+// Status information
+
+function asyncIsRunning(
+ Handle: TAsyncHandle
+ ): Boolean; cdecl;
+
+function asyncGetTicks: Int64; cdecl;
+
+
+// Timer management
+
+function asyncAddTimer(
+ Handle: TAsyncHandle;
+ MSec: LongInt;
+ Periodic: Boolean; // False = One-shot timer, True = Periodic timer
+ Callback: TAsyncCallback;
+ UserData: Pointer // User data for callback
+ ): TAsyncTimer; cdecl;
+
+procedure asyncRemoveTimer(
+ Handle: TAsyncHandle;
+ Timer: TASyncTimer); cdecl;
+
+
+// I/O callback management
+
+function asyncSetIOCallback(
+ Handle: TAsyncHandle;
+ IOHandle: LongInt;
+ Callback: TAsyncCallback;
+ UserData: Pointer): TAsyncResult; cdecl;
+
+procedure asyncClearIOCallback(
+ Handle: TAsyncHandle;
+ IOHandle: LongInt); cdecl;
+
+function asyncSetDataAvailableCallback(
+ Handle: TAsyncHandle;
+ IOHandle: LongInt;
+ Callback: TAsyncCallback;
+ UserData: Pointer): TAsyncResult; cdecl;
+
+procedure asyncClearDataAvailableCallback(
+ Handle: TAsyncHandle;
+ IOHandle: LongInt); cdecl;
+
+function asyncSetCanWriteCallback(
+ Handle: TAsyncHandle;
+ IOHandle: LongInt;
+ Callback: TAsyncCallback;
+ UserData: Pointer): TAsyncResult; cdecl;
+
+procedure asyncClearCanWriteCallback(
+ Handle: TAsyncHandle;
+ IOHandle: LongInt); cdecl;
+
+
diff --git a/packages/fcl-async/src/unix/asyncio.inc b/packages/fcl-async/src/unix/asyncio.inc
new file mode 100644
index 0000000000..6dc9b4a152
--- /dev/null
+++ b/packages/fcl-async/src/unix/asyncio.inc
@@ -0,0 +1,158 @@
+{
+ This file is part of the Free Component Library (FCL)
+ Copyright (c) 1999-2000 by the Free Pascal development team
+
+ See the file COPYING.FPC, included in this distribution,
+ for details about the copyright.
+
+ This program 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.
+
+ **********************************************************************}
+
+procedure TAsyncIOManager.CalcHighestHandle(max: Integer);
+var
+ i: Integer;
+begin
+ With IOData do
+ begin
+ HighestHandle := -1;
+ for i := max downto 0 do
+ if FD_IsSet(i, ReadMap) or FD_IsSet(i, WriteMap) then begin
+ HighestHandle := i;
+ break;
+ end;
+ end;
+end;
+
+function TAsyncIOManager.GetHandleAsync(AHandle: Integer): Boolean;
+begin
+ Result := (fcntl(AHandle, F_GetFl) and Open_NonBlock) <> 0;
+end;
+
+procedure TAsyncIOManager.SetHandleAsync(AHandle: Integer; AValue: Boolean);
+var
+ SavedBits: Integer;
+begin
+ SavedBits := fcntl(AHandle, F_GetFl) and not Open_NonBlock;
+ if AValue then
+ fcntl(AHandle, F_SetFl, SavedBits or Open_NonBlock)
+ else
+ fcntl(AHandle, F_SetFl, SavedBits);
+end;
+
+constructor TAsyncIOManager.Create;
+begin
+ inherited Create;
+ With IOdata do
+ begin
+ FD_Zero(ReadMap);
+ FD_Zero(WriteMap);
+ end;
+ HighestHandle := -1;
+end;
+
+procedure TAsyncIOManager.Run;
+var
+ ThisReadMap, ThisWriteMap: TFDSet;
+ i, res: Integer;
+begin
+ DoBreak := False;
+ With IOdata do
+ begin
+ while (not DoBreak) and ((HighestHandle >= 0) or (FTimeout > 0)) do begin
+ ThisReadMap := ReadMap;
+ ThisWriteMap := WriteMap;
+
+ if FTimeout > 0 then
+ res := Select(HighestHandle + 1, @ThisReadMap, @ThisWriteMap, nil, FTimeout)
+ else
+ res := Select(HighestHandle + 1, @ThisReadMap, @ThisWriteMap, nil, nil);
+ if res < 0 then
+ break;
+
+ if res = 0 then
+ ExecuteNotify(TimeoutNotify)
+ else
+ for i := 0 to HighestHandle do begin
+ if FD_IsSet(i, ThisReadMap) and FD_IsSet(i, ReadMap)then
+ ExecuteNotify(ReadNotifies[i]);
+ if FD_IsSet(i, ThisWriteMap) and FD_IsSet(i, WriteMap) then
+ ExecuteNotify(WriteNotifies[i]);
+ end;
+ end;
+ end;
+end;
+
+procedure TAsyncIOManager.BreakRun;
+begin
+ DoBreak := True;
+end;
+
+procedure TAsyncIOManager.SetReadHandler(AHandle: Integer;
+ AMethod: TAsyncIONotify; AUserData: TObject);
+begin
+ ASSERT((AHandle >= 0) and (AHandle <= MaxHandle) and Assigned(AMethod));
+ if (AHandle < 0) or (AHandle > MaxHandle) then
+ exit;
+ if AHandle > HighestHandle then
+ HighestHandle := AHandle;
+ FD_Set(AHandle, IOdata.ReadMap);
+ ReadNotifies[AHandle].Method := AMethod;
+ ReadNotifies[AHandle].UserData := AUserData;
+end;
+
+procedure TAsyncIOManager.ClearReadHandler(AHandle: Integer);
+begin
+ ASSERT((AHandle >= 0) and (AHandle <= MaxHandle));
+ if (AHandle >= 0) and (AHandle <= MaxHandle) then
+ begin
+ FD_Clr(AHandle, IOdata.ReadMap);
+ if AHandle = HighestHandle then
+ CalcHighestHandle(AHandle);
+ end;
+end;
+
+function TAsyncIOManager.GetReadHandler(AHandle: Integer): TAsyncIONotify;
+begin
+ ASSERT((AHandle >= 0) and (AHandle <= MaxHandle));
+ if (AHandle < 0) or (AHandle > MaxHandle) then
+ Result := nil
+ else
+ Result := ReadNotifies[AHandle].Method;
+end;
+
+procedure TAsyncIOManager.SetWriteHandler(AHandle: Integer;
+ AMethod: TAsyncIONotify; AUserData: TObject);
+begin
+ ASSERT((AHandle >= 0) and (AHandle <= MaxHandle) and Assigned(AMethod));
+ if (AHandle < 0) or (AHandle > MaxHandle) then
+ exit;
+
+ if AHandle > HighestHandle then
+ HighestHandle := AHandle;
+ FD_Set(AHandle, IOData.WriteMap);
+ WriteNotifies[AHandle].Method := AMethod;
+ WriteNotifies[AHandle].UserData := AUserData;
+end;
+
+procedure TAsyncIOManager.ClearWriteHandler(AHandle: Integer);
+begin
+ ASSERT((AHandle >= 0) and (AHandle <= MaxHandle));
+ if (AHandle >= 0) and (AHandle <= MaxHandle) then begin
+ FD_Clr(AHandle, IOdata.WriteMap);
+ if AHandle = HighestHandle then
+ CalcHighestHandle(AHandle);
+ end;
+end;
+
+function TAsyncIOManager.GetWriteHandler(AHandle: Integer): TAsyncIONotify;
+begin
+ ASSERT((AHandle >= 0) and (AHandle <= MaxHandle));
+ if (AHandle < 0) or (AHandle > MaxHandle) then
+ Result := nil
+ else
+ Result := WriteNotifies[AHandle].Method;
+end;
+
diff --git a/packages/fcl-async/src/unix/asyncioh.inc b/packages/fcl-async/src/unix/asyncioh.inc
new file mode 100644
index 0000000000..ab91d2b68c
--- /dev/null
+++ b/packages/fcl-async/src/unix/asyncioh.inc
@@ -0,0 +1,26 @@
+{
+ This file is part of the Free Component Library (FCL)
+ Copyright (c) 1999-2000 by the Free Pascal development team
+
+ See the file COPYING.FPC, included in this distribution,
+ for details about the copyright.
+
+ This program 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.
+
+ **********************************************************************}
+
+uses
+ Unix,
+ classes;
+
+const
+ MaxHandle = SizeOf(TFDSet) * 8 - 1;
+
+Type
+
+ TIOData = Record
+ ReadMap, WriteMap: TFDSet;
+ end;
+
diff --git a/packages/fcl-async/src/unix/libasync.pp b/packages/fcl-async/src/unix/libasync.pp
new file mode 100644
index 0000000000..c06518885b
--- /dev/null
+++ b/packages/fcl-async/src/unix/libasync.pp
@@ -0,0 +1,199 @@
+{
+
+ libasync: Asynchronous event management
+ Copyright (C) 2001-2002 by
+ Areca Systems GmbH / Sebastian Guenther, sg@freepascal.org
+
+ Unix implementation
+
+ See the file COPYING.FPC, included in this distribution,
+ for details about the copyright.
+
+ This program 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.
+}
+
+unit libasync;
+
+{$MODE objfpc}
+
+interface
+
+type
+
+ TAsyncData = record
+ IsRunning, DoBreak: Boolean;
+ HasCallbacks: Boolean; // True as long as callbacks are set
+ FirstTimer: Pointer;
+ FirstIOCallback: Pointer;
+ CurIOCallback: Pointer; // current callback being processed within 'run'
+ NextIOCallback: Pointer; // next callback to get processed within 'run'
+ FDData: Pointer;
+ HighestHandle: LongInt;
+ end;
+
+{$INCLUDE libasynch.inc}
+
+
+
+implementation
+
+uses baseunix, Unix;
+
+const
+ MaxHandle = SizeOf(TFDSet) * 8 - 1;
+
+type
+ PIOCallbackData = ^TIOCallbackData;
+ TIOCallbackData = record
+ Next: PIOCallbackData;
+ IOHandle: LongInt;
+ ReadCallback, WriteCallback: TAsyncCallback;
+ ReadUserData, WriteUserData: Pointer;
+ SavedHandleFlags: LongInt;
+ end;
+
+{$INCLUDE libasync.inc}
+
+
+
+procedure InternalInit(Handle: TAsyncHandle);
+begin
+ Handle^.Data.HighestHandle := -1;
+end;
+
+procedure InternalFree(Handle: TAsyncHandle);
+var
+ IOCallback: PIOCallbackData;
+begin
+ IOCallback := PIOCallbackData(Handle^.Data.FirstIOCallback);
+ while Assigned(IOCallback) do
+ begin
+ if (IOCallback^.SavedHandleFlags and Open_NonBlock) = 0 then
+ fpfcntl(IOCallback^.IOHandle, F_SetFl, IOCallback^.SavedHandleFlags);
+ IOCallback := IOCallback^.Next;
+ end;
+
+ if Assigned(Handle^.Data.FDData) then
+ FreeMem(Handle^.Data.FDData);
+end;
+
+procedure InternalRun(Handle: TAsyncHandle; TimeOut: Int64);
+var
+ AsyncResult: Integer;
+ CurReadFDSet, CurWriteFDSet: TFDSet;
+ CurIOCallback: PIOCallbackData;
+begin
+ if Handle^.Data.HighestHandle < 0 then
+ // No I/O checks to do, so just wait...
+ AsyncResult := fpselect(0, nil, nil, nil, TimeOut)
+ else
+ begin
+ CurReadFDSet := PFDSet(Handle^.Data.FDData)[0];
+ CurWriteFDSet := PFDSet(Handle^.Data.FDData)[1];
+ AsyncResult := fpselect(Handle^.Data.HighestHandle + 1,
+ @CurReadFDSet, @CurWriteFDSet, nil, TimeOut);
+
+ if AsyncResult > 0 then
+ begin
+ // Check for I/O events
+ Handle^.Data.CurIOCallback := Handle^.Data.FirstIOCallback;
+ while Assigned(Handle^.Data.CurIOCallback) do
+ begin
+ CurIOCallback := PIOCallbackData(Handle^.Data.CurIOCallback);
+ Handle^.Data.NextIOCallback := CurIOCallback^.Next;
+ if (fpFD_ISSET(CurIOCallback^.IOHandle,CurReadFDSet) > 0) and
+ (fpFD_ISSET(CurIOCallback^.IOHandle, PFDSet(Handle^.Data.FDData)[0]) > 0) and
+ Assigned(CurIOCallback^.ReadCallback) then
+ begin
+ CurIOCallback^.ReadCallback(CurIOCallback^.ReadUserData);
+ if Handle^.Data.DoBreak then
+ break;
+ end;
+
+ CurIOCallback := PIOCallbackData(Handle^.Data.CurIOCallback);
+ if Assigned(CurIOCallback) and
+ (fpFD_ISSET(CurIOCallback^.IOHandle, CurWriteFDSet) > 0) and
+ (fpFD_ISSET(CurIOCallback^.IOHandle, PFDSet(Handle^.Data.FDData)[1]) > 0) and
+ Assigned(CurIOCallback^.WriteCallback) then
+ begin
+ CurIOCallback^.WriteCallback(CurIOCallback^.WriteUserData);
+ if Handle^.Data.DoBreak then
+ break;
+ end;
+
+ Handle^.Data.CurIOCallback := Handle^.Data.NextIOCallback;
+ end;
+ end;
+ end;
+end;
+
+procedure InternalInitIOCallback(Handle: TAsyncHandle; Data: PIOCallbackData;
+ InitData: Boolean; CallbackTypes: TCallbackTypes);
+var
+ i: LongInt;
+begin
+ if InitData then
+ begin
+ if not Assigned(Handle^.Data.FDData) then
+ begin
+ GetMem(Handle^.Data.FDData, SizeOf(TFDSet) * 2);
+ fpFD_ZERO(PFDSet(Handle^.Data.FDData)[0]);
+ fpFD_ZERO(PFDSet(Handle^.Data.FDData)[1]);
+ end;
+ if Data^.IOHandle > Handle^.Data.HighestHandle then
+ Handle^.Data.HighestHandle := Data^.IOHandle;
+ end;
+
+ Data^.SavedHandleFlags := fpfcntl(Data^.IOHandle, F_GetFl);
+ fpfcntl(Data^.IOHandle, F_SetFl, Data^.SavedHandleFlags or Open_NonBlock);
+
+ case Data^.IOHandle of
+ StdInputHandle:
+ i := Open_RdOnly;
+ StdOutputHandle, StdErrorHandle:
+ i := Open_WrOnly;
+ else
+ i := Data^.SavedHandleFlags and Open_Accmode;
+ end;
+
+ case i of
+ Open_RdOnly:
+ if cbRead in CallbackTypes then
+ fpFD_SET(Data^.IOHandle, PFDSet(Handle^.Data.FDData)[0]);
+ Open_WrOnly:
+ if cbWrite in CallbackTypes then
+ fpFD_SET(Data^.IOHandle, PFDSet(Handle^.Data.FDData)[1]);
+ Open_RdWr:
+ begin
+ if cbRead in CallbackTypes then
+ fpFD_SET(Data^.IOHandle, PFDSet(Handle^.Data.FDData)[0]);
+ if cbWrite in CallbackTypes then
+ fpFD_SET(Data^.IOHandle, PFDSet(Handle^.Data.FDData)[1]);
+ end;
+ end;
+end;
+
+procedure InternalClearIOCallback(Handle: TAsyncHandle; IOHandle: LongInt;
+ CallbackTypes: TCallbackTypes);
+begin
+ if not Assigned(Handle) then
+ exit;
+
+ if cbRead in CallbackTypes then
+ fpFD_CLR(IOHandle, PFDSet(Handle^.Data.FDData)[0]);
+ if cbWrite in CallbackTypes then
+ fpFD_CLR(IOHandle, PFDSet(Handle^.Data.FDData)[1]);
+end;
+
+function asyncGetTicks: Int64; cdecl;
+var
+ Time: TimeVal;
+begin
+ fpGetTimeOfDay(@time,nil);
+ Result := Int64(Time.tv_Sec) * 1000 + Int64(Time.tv_USec div 1000);
+end;
+
+
+end.