diff options
| author | peter <peter@3ad0048d-3df7-0310-abae-a5850022a9f2> | 2007-10-28 21:26:51 +0000 |
|---|---|---|
| committer | peter <peter@3ad0048d-3df7-0310-abae-a5850022a9f2> | 2007-10-28 21:26:51 +0000 |
| commit | 9a1c84e2531f3f115297d745fa9f03b322e5e881 (patch) | |
| tree | b6e0165c05e881ee4bc595ed417dd9a315e0d15c /packages/fcl-async | |
| parent | 77722a04c495e3d5b8200c8641f56d364009f1f1 (diff) | |
| download | fpc-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/Makefile | 2233 | ||||
| -rw-r--r-- | packages/fcl-async/Makefile.fpc | 37 | ||||
| -rw-r--r-- | packages/fcl-async/src/fpasync.pp | 856 | ||||
| -rw-r--r-- | packages/fcl-async/src/libasync.inc | 482 | ||||
| -rw-r--r-- | packages/fcl-async/src/libasynch.inc | 109 | ||||
| -rw-r--r-- | packages/fcl-async/src/unix/asyncio.inc | 158 | ||||
| -rw-r--r-- | packages/fcl-async/src/unix/asyncioh.inc | 26 | ||||
| -rw-r--r-- | packages/fcl-async/src/unix/libasync.pp | 199 |
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. |
