package async
Install
Dune Dependency
Authors
Maintainers
Sources
sha256=4d817db74f95d6d59582aad69f40c2b6c2436b74154d568ea32f07f883e6619a
md5=53eab8765293a4440e9aae81faffdc25
CHANGES.md.html
v0.10
Moved
Persistent_connection
toAsync_kernel
, so that it can be used in javascript.Improved
Log.Output
to write, flush, rotate, or close allLog.Output.t
s, even if one raisesAdded
Async.print_s
for pretty printing a sexp to stdout.Removed a per-cycle allocation from the scheduler.
Fixed
Reader.load_bin_prot
to always returnError
when there is an error, rather than returnError
in some situations and raise in others.Improved the behavior of shutdown when there are errors.
Added
Scheduler.may_sleep_for_thread_fairness
, an opt-in configuration that improves thread fairness.Added to
Sys.file_exists
function afollow_symlinks
optional argument.Fixed the Async scheduler so that for top-level unhandled exceptions, it runs
at_exit
functions once, not twice.For
Writer.open_file
, exposed the syscall optional argument.Exposed
Async.ifprintf
, which had previously been mistakenly shadowed even though it doesn't block.Unified
Synchronous_time_source.t
andTime_source.t
, into a single data structure, allowing one to convert between them as needed. This involved substantive changes to Async's clock.Added function
Time_source.timing_wheel_now
.Added stable types for
Log.Level
andLog.Output.format
.Improved shutdown function so that when shutdown is forced (i.e.
at_shutdown
handlers time out), it callsPervasives.exit
, which runsat_exit
handlers. This improvesCommand.async
in this situation, due to its use of anat_exit
handler to print errors.Improved
Process.run
's error message whenworking_dir
is missing.Fixed
Rpc.Connection.create
so that it doesn't raise on a failed handshake.Significantly improved the performance of
Log.printf
when the log message won't be printed, by usingifprintf
to avoid constructing the message.Added
Socket.Address
functionsInet.to_sockaddr
andUnix.to_sockaddr
, the type specialized versions ofSocket.Address.to_sockaddr
.Added
Socket.bind_inet
, which is like bind, but restricted to Inet addresses and does not return aDeferred.t
. ChangedUdp.bind
andbind_any
to not return aDeferred.t
.Added to
File_tail.create
an optional?throttle
argument so that one can use a custom throttle andmax_concurrent_jobs
rather than a global throttle with a fixedmax_concurrent_jobs
.Renamed
Tcp
andRpc
'svia_local_interface
andvia_local_port
arguments asbind_to_address
andbind_to_port
.Made
Tcp.Server.create
andcreate_sock
's~on_handler_error
argument mandatory.In
Tcp.Server
, stopped callingon_handler_error
forWriter
error frominner_monitor
, which only indicated that the client likely closed the connection before all the bytes could be written.Renamed
Command.async
asasync_spec
andCommand.async'
asasync
. We want to encourage the use ofCommand.Param
and discourage the use ofCommand.Spec
.Changed
Async
so that in tests it uses synchronous output.Changed
Async
's default max number of open file descriptors from8_192
to the minimum of32_768
andulimit -n -H
.In the Async scheduler's main loop, avoided calling
Time_ns.now
andLinux_ext.Timerfd.set_after
unless they are needed. This saves about 50ns per cycle.Moved
Tcp
functions for specifying where to connect and where to listen into submodules:Where_to_connect
andWhere_to_listen
Changed
Tcp.to_host_and_port
from taking a string and int toTcp.Where_to_connect.of_host_and_port
, taking aHost_and_port.t
Changed
Rpc.Connection.client
to take aTcp.Where_to_connect.t
instead of~host ~port
.Changed
Synchronous_time_source.Event.abort
to return a variant type, in the same style asTime_source.Event.abort
. Addedabort_exn
andabort_if_possible
, also in the same style asTime_source.Event
.Added function
Scheduler.long_cycles
, which returns the stream of cycles whose duration exceeds a user-supplied time span. This is more efficient thancycle_times
, because it only allocates a stream element when there is a long cycle, rather than on every cycle.Made internal libraries stdless:
Async_unix
,Async_extra
.Changed
Udp.recvfrom_loop
andread_loop
functions to return a variantClosed | Stopped
rather thanunit
.Extended the
Unix.Inet_addr
module's interface to includeCore.Unix.Inet_addr
's interface.
v0.9
113.43.00
Added some expect tests of
Monitor
, in particularMonitor.handle_errors
.Added a benchmark of
Monitor.try_with
.
113.33.00
Keep up to date with interface changes in Async_kernel
, Async_extra
and Async_unix
.
113.24.00
Keep up to date with interface changes in Async_kernel
, Async_extra
and Async_unix
.
113.00.00
Added
Async.Std.Printf
module so that one doesn't unintentionally use blockingCore.Std.Printf
functions in an Async program.There was much pre-existing code that did this via:
- : open Core.Std
- open Async.Std
Async.Std.Printf
defines blocking functions (e.gprintf
,eprintf
) to cause a type error, but leaves Async-friendly functions (e.g.sprintf
,ksprintf
) untouched.Replaced uses of
Printf.*
, withCore.Std.Printf.*
where needed.
112.35.00
Include some previously-omitted benchmarks
112.24.00
Keep up to date with interface changes in Async_kernel
, Async_extra
and Async_unix
.
112.17.00
Added tests and updated examples
112.01.00
update tests
111.25.00
add a dns example
111.11.00
Updated the sound.ml example
109.53.00
Bump version number
109.14.00
Added function
Monitor.kill
, which kills a monitor and all its descendants.This prevents any jobs from ever running in the monitor again.
109.09.00
Switched
Async.Std
's toplevel bindings forDeferred.Or_error
'sbind
andmap
to useDeferred.Result
. This allows them to be used with any'error
type, rather than justError.t
.
109.05.00
Added
val _squelch_unused_module_warning_
toAsync.Std
.