TFLiteBEAM
TensorFlow Lite BEAM bindings with optional EdgeTPU support.
Delegates
tflite_beam_interpreter_builder:build/2 attaches an XNNPACK delegate for you,
unless you have attached one yourself. TfLite would otherwise apply XNNPACK on its
own, invisibly, inside allocate_tensors/1 -- with a thread count nothing could
reach and no way to decline it. The acceleration is the same; where it happens is
now visible, and set_num_threads/2 still reaches it.
{ok, Resolver} = tflite_beam_ops_builtin_builtin_resolver:new(),
{ok, Builder} = tflite_beam_interpreter_builder:new(Model, Resolver),
%% your own delegate instead of the default one
{ok, Delegate} = tflite_beam_delegate:xnnpack(#{num_threads => 4}),
ok = tflite_beam_interpreter_builder:add_delegate(Builder, Delegate),
ok = tflite_beam_interpreter_builder:build(Builder, Interpreter).
tflite_beam_delegate:available/0 lists the delegate kinds this build can create:
XNNPACK on every target except armv6 and armv7l, where nothing is attached and
inference runs as it always has.
To go back to TfLite delegating by itself, ask the resolver for it:
{ok, Resolver} = tflite_beam_ops_builtin_builtin_resolver:new(#{apply_default_delegates => true}),
A delegate must outlive every interpreter built from the builder it was added to, so there is no way to detach or free one: the builder and each interpreter hold it for as long as they need it, and it goes when they do.
Delegates from a shared library
Anything implementing TfLite's delegate plugin interface --
tflite_plugin_create_delegate and tflite_plugin_destroy_delegate -- can be
loaded at runtime, which covers Edge TPU, a GPU delegate built elsewhere, and
vendor delegates this library knows nothing about:
{ok, Delegate} = tflite_beam_delegate:external("/opt/lib/libvendor_delegate.so",
#{device => 0, precision => fp16}),
ok = tflite_beam_interpreter_builder:add_delegate(Builder, Delegate).
Options are handed to the plugin as strings, which is the whole of that ABI, so
atoms and integers are converted and at most 256 pairs fit. What the keys mean is
the plugin's business. The path is resolved to an absolute one before loading,
because the loader is asked for exactly the file named -- a bare libfoo.so would
otherwise be searched for wherever the system looks, which is rarely where anyone
means. The library is not unloaded afterwards.
Threading
An interpreter, and any delegate attached to it, belongs to one process at a time.
TfLite documents tflite::Interpreter as not thread-safe and leaves serialising
access to the caller, and invoke/1 runs on a dirty scheduler, so two processes
sharing one interpreter really do run it on two OS threads at once.
The direct API mirrors the C API, which means feeding an interpreter, running it and reading the result back are three separate calls -- and nothing in the C API says they have to be treated as one. Two processes taking turns badly get each other's answers: measured on a real model, 147 wrong results in 400 calls, silently and without a crash.
The guard described below now refuses most of those, and predict/2 no longer
reads the output tensors after an invoke it was refused. What is left is the gap
between the three calls, which no per-call guard can close: the same measurement
today gives 6 wrong answers in 400 rather than 147. Six is not zero, so if more
than one process touches an interpreter, use the server.
If you want that handled for you, use tflite_beam_interpreter_server:
{ok, Server} = tflite_beam_interpreter_server:start_link(ModelPath),
Output = tflite_beam_interpreter_server:predict(Server, [Input]).
The interpreter lives inside that process, so feeding, running and reading back is
one step nothing can interleave with, and concurrent callers each get the answer to
their own input. Use with/2 for the sequences predict/2 does not cover.
The direct API is unchanged and stays available. Two things guard it:
- Calls that genuinely overlap in time are refused rather than allowed to race.
This is always on and costs a
trylockon the uncontended path. tflite_beam_interpreter:controlling_process/2gives an interpreter to one process, after which every other process is refused whether it overlaps or not. It followsgen_tcp:controlling_process/2: while an interpreter belongs to nobody any process may take it, and once it belongs to someone only that process may hand it on. A controlling process that dies releases it.
Delegates are the same story: nothing documents a TfLiteDelegate as safe to back
two interpreters simultaneously, and XNNPACK's demonstrably is not.
Coral Support
libedgetpu is itself a TfLite delegate plugin, so an Edge TPU can be attached like
any other delegate -- which means it composes with set_num_threads/2 and with
whatever else is on the builder:
{ok, Delegate} = tflite_beam_coral:edge_tpu_delegate(),
ok = tflite_beam_interpreter_builder:add_delegate(Builder, Delegate),
ok = tflite_beam_interpreter_builder:build(Builder, Interpreter).
tflite_beam_coral:make_edge_tpu_interpreter/2 still works and is unchanged. It
builds its own interpreter internally, though, so nothing set on a builder reaches
it; the delegate above is the composable route. Asking for a device that is not
there is an ordinary {error, Reason} from edge_tpu_delegate/1.
Both routes have been checked to produce identical output on a USB Coral
accelerator, running mobilenet_v2_1.0_224_inat_bird_quant_edgetpu.tflite against
libedgetpu 0.1.14 on macOS arm64.
Dependencies
For macOS
# only required if not using precompiled binaries
# for compiling libusb
brew install autoconf automake
For some Linux OSes you need to manually execute the following command to update udev rules, otherwise, libedgetpu will fail to initialize Coral devices.
bash "3rd_party/cache/${TFLITE_BEAM_CORAL_LIBEDGETPU_RUNTIME}/edgetpu_runtime/install.sh"
Compile-Time Environment Variable
TFLITE_BEAM_PREFER_PRECOMPILEDUse precompiled binaries when
TFLITE_BEAM_PREFER_PRECOMPILEDistrue. Otherwise, this library will compile from source.Defaults to
true.TFLITE_BEAM_CORAL_SUPPORTEnable Coral Support.
Defaults to
true.TFLITE_BEAM_CORAL_USB_THROTTLEThrottling USB Coral Devices. Please see the official warning here, google-coral/libedgetpu.
Defaults to
true.Note that only when
TFLITE_BEAM_CORAL_USB_THROTTLEis set toNO,:tflite_beamwill use the non-throttled libedgetpu libraries.TFLITE_BEAM_CORAL_LIBEDGETPU_LIBRARIESChoose which ones of the libedgetpu libraries to copy to the
privdirectory of the:tflite_beamapp.Default value is
native- only native libraries will be downloaded and copied.nativecorresponds to the host OS and CPU architecture when compiling this library.When set to a specific value, e.g,
darwin_arm64ordarwin_x86_64, then the corresponding one will be downloaded and copied. This option is expected to be used for cross-compiling, like with nerves.Available values for this option are:
Value OS/CPU aarch64Linux arm64 armv7lLinux armv7 armv6Linux armv6 k8Linux x86_64 x86_64Linux x86_64 riscv64Linux riscv64 darwin_arm64macOS Apple Silicon darwin_x86_64macOS x86_64
Installation
Add tflite_beam to your list of dependencies in rebar.config:
{deps, [
{tflite_beam, "0.3.12"}
]}
The 1.0.0 release candidates carry the memory-safety work described above and build the runtime from LiteRT rather than from TensorFlow. Hex never resolves a pre-release from a range, so name it exactly:
{deps, [
{tflite_beam, "1.0.0-rc1"}
]}
~> 0.3 will not reach it, which is deliberate: a two part 0.x requirement means
everything below 1.0.0, so releasing this work as 0.4.0 would have moved every
existing user onto a different upstream without their asking. Nothing in the
Erlang API was removed or renamed on the way, and the precompiled binaries ask
for exactly the glibc they asked for in 0.3.12.
Three things behave differently, each turning something silent into something you
can see. A tensor handle stops working once allocate_tensors/1, a resize or a
second build/2 has moved what it points at, instead of reading memory that has
been given to something else; fetch it again afterwards. Writing to a tensor takes
exactly its size, where a short binary used to be written as far as it went and
reported as success, leaving the rest of the tensor holding whatever was there
before. And tflite_version/0 now answers LiteRT's version rather than
TensorFlow's, which matters if you load a delegate plugin: it has to be built from
the same release, and the two version lines are not comparable, so LiteRT's 2.2.0
is newer than TensorFlow's 2.21.0 rather than older.
Documentation is published on HexDocs.
What the precompiled binaries need
Installing pulls a precompiled shared object rather than building one, so what matters is what that object was linked against, not what your machine could compile. These have held since v0.3.12:
| Target | Needs |
|---|---|
x86_64-linux-gnu | glibc 2.29 (Ubuntu 20.04, Debian 11) |
armv7l-linux-gnueabihf | glibc 2.29 (Raspberry Pi OS Bullseye) |
aarch64-linux-gnu | glibc 2.34 (Ubuntu 22.04, Debian 12) |
armv6-linux-gnueabihf | glibc 2.38 (Debian 13, or a Nerves system) |
riscv64-linux-gnu | glibc 2.38 (Debian 13, or a Nerves system) |
aarch64-apple-darwin | macOS 14 |
x86_64-apple-darwin | macOS 15 |
The figure is a floor, not a pin: anything newer works. Check yours with
ldd --version, or read it off a downloaded object with
readelf -V priv/tflite_beam.so | grep -o 'GLIBC_[0-9.]*' | sort -uV | tail -1.
armv6 and riscv64 sit higher than the rest because they are built with the
Nerves toolchains, which carry their own glibc. That suits a Nerves system, which
ships a matching one. It does not suit Raspberry Pi OS Bookworm, which has 2.36,
so on that combination build from source:
export TFLITE_BEAM_PREFER_PRECOMPILED=false
Tests
rebar3 ct
The model fixtures live in test/models/, so the suite needs no network and runs
against a precompiled install as well as a build from source.
Releasing
The precompiled tarballs only exist once the v* tag has been pushed and the
precompile matrix has finished, and the manifest that verifies them has to be
inside the published package -- so it is generated in between:
git tag -a vX.Y.Z -m "vX.Y.Z" && git push origin vX.Y.Z # matrix builds the 7 targets
scripts/generate_checksums.sh X.Y.Z # writes checksum.term
rebar3 hex publish
checksum.term is not tracked in git and does not need to be: it is packaged from
the working directory, and the tarballs it lists do not exist until the tag has
been built -- so a tracked copy would always be one release out of date.
Skipping the middle step publishes a package that cannot check what it downloads, which it says out loud on install rather than doing quietly.