Packages
rabbit_common
3.6.8
4.2.1
4.2.0
retired
4.2.0-rc.1
retired
4.1.6
4.1.5
retired
4.1.5-rc.2
retired
4.1.5-rc.1
4.0.3
4.0.3-rc.1
4.0.2
4.0.2-rc.2
4.0.2-rc.1
4.0.1
4.0.0
4.0.0-rc.2
4.0.0-rc.1
3.13.7
3.13.6
3.13.5
3.13.4
3.13.3
3.13.2
3.13.2-rc.1
3.13.1
3.13.0
3.13.0-rc.6
3.13.0-rc.5
3.13.0-rc.4
3.13.0-rc.3
3.13.0-rc.2
3.13.0-rc.1
3.12.14
3.12.13
3.12.12
3.12.11
3.12.10
3.12.9
3.12.8
3.12.7
3.12.6
3.12.5
3.12.4
3.12.3
3.12.2
3.12.1
3.12.0
3.12.0-rc.4
3.12.0-rc.3
3.12.0-rc.2
3.12.0-rc.1
3.11.28
3.11.27
3.11.26
3.11.25
3.11.24
3.11.23
3.11.22
3.11.21
3.11.20
3.11.19
3.11.18
3.11.17
3.11.16
3.11.15
3.11.14
3.11.13
3.11.12
3.11.11
3.11.10
3.11.9
3.11.8
3.11.7
3.11.6
3.11.5
3.11.4
3.11.3
3.11.2
3.11.1
3.11.0
3.11.0-rc.2
3.11.0-rc.1
3.11.0-1
3.10.25
3.10.24
3.10.23
3.10.22
3.10.21
3.10.20
3.10.19
3.10.18
3.10.17
3.10.16
3.10.15
3.10.14
3.10.13
3.10.12
3.10.11
3.10.10
3.10.9
3.10.8
3.10.7
3.10.6
3.10.5
3.10.4
3.10.3
3.10.2
3.10.1
3.10.0
3.10.0-rc.6
3.10.0-rc.5
3.9.29
3.9.28
3.9.27
3.9.26
3.9.25
3.9.24
3.9.23
3.9.22
3.9.21
3.9.20
3.9.19
3.9.18
3.9.17
3.9.16
3.9.15
3.9.11
3.9.10
3.9.9
3.9.8
3.9.7
3.9.6
3.9.5
3.9.4
3.9.3
3.9.2
3.9.1
3.8.35
3.8.34
3.8.33
3.8.32
3.8.31
3.8.30
3.8.26
3.8.25
3.8.24
3.8.23
3.8.22
3.8.21
3.8.20
3.8.19
3.8.14
3.8.12-rc.3
3.8.12-rc.2
3.8.12-rc.1
3.8.11
3.8.10
3.8.10-rc.6
3.8.10-rc.5
3.8.10-rc.1
3.8.9
3.8.8
3.8.7
3.8.6
3.8.6-rc.2
3.8.6-rc.1
3.8.5
3.8.5-rc.2
3.8.5-rc.1
3.8.4
3.8.4-rc.3
3.8.4-rc.1
3.8.3
3.8.3-rc.2
3.8.3-rc.1
3.8.2
3.8.2-rc.1
3.8.1
3.8.1-rc.1
3.8.0
3.8.0-rc.3
3.8.0-rc.2
3.8.0-rc.1
3.7.28
3.7.27
3.7.27-rc.2
3.7.27-rc.1
3.7.26
3.7.25
3.7.25-rc.1
3.7.24
3.7.24-rc.2
3.7.24-rc.1
3.7.23
3.7.23-rc.1
3.7.22
3.7.22-rc.2
3.7.22-rc.1
3.7.21
3.7.20
3.7.20-rc.2
3.7.20-rc.1
3.7.19
3.7.18
3.7.18-rc.1
3.7.17
3.7.17-rc.3
3.7.17-rc.2
3.7.17-rc.1
retired
3.7.16
retired
3.7.16-rc.4
retired
3.7.16-rc.3
retired
3.7.16-rc.2
retired
3.7.16-rc.1
retired
3.7.16-beta.1
3.7.15
3.7.14
3.7.14-rc.2
3.7.14-rc.1
3.7.13
3.7.13-rc.2
3.7.13-rc.1
3.7.12
3.7.12-rc.2
3.7.12-rc.1
3.7.11
3.7.11-rc.2
3.7.11-rc.1
3.7.10-rc.4
3.7.10-rc.3
3.7.10-rc.2
3.7.10-rc.1
3.7.9
3.7.9-rc.3
3.7.9-rc.2
3.7.8
3.7.8-rc.4
3.7.8-rc.3
3.7.8-rc.2
3.7.8-rc.1
3.7.7
3.7.7-rc.2
3.7.7-rc.1
3.7.6
3.7.6-rc.2
3.7.6-rc.1
3.7.5
3.7.5-rc.1
3.7.4
3.7.4-rc.4
3.7.4-rc.3
3.7.4-rc.2
3.7.4-rc.1
3.7.3
3.7.3-rc.2
3.7.3-rc.1
3.7.2
3.7.1
3.7.0-rc.2
3.7.0-alpha.544
3.7.0-alpha.542
3.6.16
3.6.16-rc.1
3.6.15
3.6.15-rc.1
3.6.14
3.6.13
3.6.12
3.6.11
3.6.10
3.6.9
3.6.8
3.6.7
3.6.7-pre.1
3.5.6
3.5.0
3.4.0
3.3.5
3.0.2
0.0.0-rc.1
Modules shared by rabbitmq-server and rabbitmq-erlang-client
Current section
Files
Jump to
Current section
Files
src/time_compat.erl
%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 2014-2015. All Rights Reserved.
%%
%% Licensed under the Apache License, Version 2.0 (the "License");
%% you may not use this file except in compliance with the License.
%% You may obtain a copy of the License at
%%
%% http://www.apache.org/licenses/LICENSE-2.0
%%
%% Unless required by applicable law or agreed to in writing, software
%% distributed under the License is distributed on an "AS IS" BASIS,
%% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
%% See the License for the specific language governing permissions and
%% limitations under the License.
%%
%% %CopyrightEnd%
%%
%%
%% If your code need to be able to execute on ERTS versions both
%% earlier and later than 7.0, the best approach is to use the new
%% time API introduced in ERTS 7.0 and implement a fallback
%% solution using the old primitives to be used on old ERTS
%% versions. This way your code can automatically take advantage
%% of the improvements in the API when available. This is an
%% example of how to implement such an API, but it can be used
%% as is if you want to. Just add (a preferrably renamed version of)
%% this module to your project, and call the API via this module
%% instead of calling the BIFs directly.
%%
-module(time_compat).
%% We don't want warnings about the use of erlang:now/0 in
%% this module.
-compile(nowarn_deprecated_function).
%%
%% We don't use
%% -compile({nowarn_deprecated_function, [{erlang, now, 0}]}).
%% since this will produce warnings when compiled on systems
%% where it has not yet been deprecated.
%%
%% Declare versioned functions to allow dynamic code loading,
%% depending on the Erlang version running. See 'code_version.erl' for details
-erlang_version_support(
[{18,
[{monotonic_time, 0, monotonic_time_pre_18, monotonic_time_post_18},
{monotonic_time, 1, monotonic_time_pre_18, monotonic_time_post_18},
{erlang_system_time, 0, erlang_system_time_pre_18, erlang_system_time_post_18},
{erlang_system_time, 1, erlang_system_time_pre_18, erlang_system_time_post_18},
{os_system_time, 0, os_system_time_pre_18, os_system_time_post_18},
{os_system_time, 1, os_system_time_pre_18, os_system_time_post_18},
{time_offset, 0, time_offset_pre_18, time_offset_post_18},
{time_offset, 1, time_offset_pre_18, time_offset_post_18},
{convert_time_unit, 3, convert_time_unit_pre_18, convert_time_unit_post_18},
{timestamp, 0, timestamp_pre_18, timestamp_post_18},
{unique_integer, 0, unique_integer_pre_18, unique_integer_post_18},
{unique_integer, 1, unique_integer_pre_18, unique_integer_post_18}]}
]).
-export([monotonic_time/0,
monotonic_time_pre_18/0,
monotonic_time_post_18/0,
monotonic_time/1,
monotonic_time_pre_18/1,
monotonic_time_post_18/1,
erlang_system_time/0,
erlang_system_time_pre_18/0,
erlang_system_time_post_18/0,
erlang_system_time/1,
erlang_system_time_pre_18/1,
erlang_system_time_post_18/1,
os_system_time/0,
os_system_time_pre_18/0,
os_system_time_post_18/0,
os_system_time/1,
os_system_time_pre_18/1,
os_system_time_post_18/1,
time_offset/0,
time_offset_pre_18/0,
time_offset_post_18/0,
time_offset/1,
time_offset_pre_18/1,
time_offset_post_18/1,
convert_time_unit/3,
convert_time_unit_pre_18/3,
convert_time_unit_post_18/3,
timestamp/0,
timestamp_pre_18/0,
timestamp_post_18/0,
unique_integer/0,
unique_integer_pre_18/0,
unique_integer_post_18/0,
unique_integer/1,
unique_integer_pre_18/1,
unique_integer_post_18/1,
monitor/2,
system_info/1,
system_flag/2]).
monotonic_time() ->
code_version:update(?MODULE),
time_compat:monotonic_time().
monotonic_time_post_18() ->
erlang:monotonic_time().
monotonic_time_pre_18() ->
erlang_system_time_fallback().
monotonic_time(Unit) ->
code_version:update(?MODULE),
time_compat:monotonic_time(Unit).
monotonic_time_post_18(Unit) ->
erlang:monotonic_time(Unit).
monotonic_time_pre_18(Unit) ->
%% Use Erlang system time as monotonic time
STime = erlang_system_time_fallback(),
convert_time_unit_fallback(STime, native, Unit).
erlang_system_time() ->
code_version:update(?MODULE),
time_compat:erlang_system_time().
erlang_system_time_post_18() ->
erlang:system_time().
erlang_system_time_pre_18() ->
erlang_system_time_fallback().
erlang_system_time(Unit) ->
code_version:update(?MODULE),
time_compat:erlang_system_time(Unit).
erlang_system_time_post_18(Unit) ->
erlang:system_time(Unit).
erlang_system_time_pre_18(Unit) ->
STime = erlang_system_time_fallback(),
convert_time_unit_fallback(STime, native, Unit).
os_system_time() ->
code_version:update(?MODULE),
time_compat:os_system_time().
os_system_time_post_18() ->
os:system_time().
os_system_time_pre_18() ->
os_system_time_fallback().
os_system_time(Unit) ->
code_version:update(?MODULE),
time_compat:os_system_time(Unit).
os_system_time_post_18(Unit) ->
os:system_time(Unit).
os_system_time_pre_18(Unit) ->
STime = os_system_time_fallback(),
convert_time_unit_fallback(STime, native, Unit).
time_offset() ->
code_version:update(?MODULE),
time_compat:time_offset().
time_offset_post_18() ->
erlang:time_offset().
time_offset_pre_18() ->
%% Erlang system time and Erlang monotonic
%% time are always aligned
0.
time_offset(Unit) ->
code_version:update(?MODULE),
time_compat:time_offset(Unit).
time_offset_post_18(Unit) ->
erlang:time_offset(Unit).
time_offset_pre_18(Unit) ->
_ = integer_time_unit(Unit),
%% Erlang system time and Erlang monotonic
%% time are always aligned
0.
convert_time_unit(Time, FromUnit, ToUnit) ->
code_version:update(?MODULE),
time_compat:convert_time_unit(Time, FromUnit, ToUnit).
convert_time_unit_post_18(Time, FromUnit, ToUnit) ->
try
erlang:convert_time_unit(Time, FromUnit, ToUnit)
catch
error:Error ->
erlang:error(Error, [Time, FromUnit, ToUnit])
end.
convert_time_unit_pre_18(Time, FromUnit, ToUnit) ->
try
convert_time_unit_fallback(Time, FromUnit, ToUnit)
catch
_:_ ->
erlang:error(badarg, [Time, FromUnit, ToUnit])
end.
timestamp() ->
code_version:update(?MODULE),
time_compat:timestamp().
timestamp_post_18() ->
erlang:timestamp().
timestamp_pre_18() ->
erlang:now().
unique_integer() ->
code_version:update(?MODULE),
time_compat:unique_integer().
unique_integer_post_18() ->
erlang:unique_integer().
unique_integer_pre_18() ->
{MS, S, US} = erlang:now(),
(MS*1000000+S)*1000000+US.
unique_integer(Modifiers) ->
code_version:update(?MODULE),
time_compat:unique_integer(Modifiers).
unique_integer_post_18(Modifiers) ->
erlang:unique_integer(Modifiers).
unique_integer_pre_18(Modifiers) ->
case is_valid_modifier_list(Modifiers) of
true ->
%% now() converted to an integer
%% fullfill the requirements of
%% all modifiers: unique, positive,
%% and monotonic...
{MS, S, US} = erlang:now(),
(MS*1000000+S)*1000000+US;
false ->
erlang:error(badarg, [Modifiers])
end.
monitor(Type, Item) ->
try
erlang:monitor(Type, Item)
catch
error:Error ->
case {Error, Type, Item} of
{badarg, time_offset, clock_service} ->
%% Time offset is final and will never change.
%% Return a dummy reference, there will never
%% be any need for 'CHANGE' messages...
make_ref();
_ ->
erlang:error(Error, [Type, Item])
end
end.
system_info(Item) ->
try
erlang:system_info(Item)
catch
error:badarg ->
case Item of
time_correction ->
case erlang:system_info(tolerant_timeofday) of
enabled -> true;
disabled -> false
end;
time_warp_mode ->
no_time_warp;
time_offset ->
final;
NotSupArg when NotSupArg == os_monotonic_time_source;
NotSupArg == os_system_time_source;
NotSupArg == start_time;
NotSupArg == end_time ->
%% Cannot emulate this...
erlang:error(notsup, [NotSupArg]);
_ ->
erlang:error(badarg, [Item])
end;
error:Error ->
erlang:error(Error, [Item])
end.
system_flag(Flag, Value) ->
try
erlang:system_flag(Flag, Value)
catch
error:Error ->
case {Error, Flag, Value} of
{badarg, time_offset, finalize} ->
%% Time offset is final
final;
_ ->
erlang:error(Error, [Flag, Value])
end
end.
%%
%% Internal functions
%%
integer_time_unit(native) -> 1000*1000;
integer_time_unit(nano_seconds) -> 1000*1000*1000;
integer_time_unit(micro_seconds) -> 1000*1000;
integer_time_unit(milli_seconds) -> 1000;
integer_time_unit(seconds) -> 1;
integer_time_unit(I) when is_integer(I), I > 0 -> I;
integer_time_unit(BadRes) -> erlang:error(badarg, [BadRes]).
erlang_system_time_fallback() ->
{MS, S, US} = erlang:now(),
(MS*1000000+S)*1000000+US.
os_system_time_fallback() ->
{MS, S, US} = os:timestamp(),
(MS*1000000+S)*1000000+US.
convert_time_unit_fallback(Time, FromUnit, ToUnit) ->
FU = integer_time_unit(FromUnit),
TU = integer_time_unit(ToUnit),
case Time < 0 of
true -> TU*Time - (FU - 1);
false -> TU*Time
end div FU.
is_valid_modifier_list([positive|Ms]) ->
is_valid_modifier_list(Ms);
is_valid_modifier_list([monotonic|Ms]) ->
is_valid_modifier_list(Ms);
is_valid_modifier_list([]) ->
true;
is_valid_modifier_list(_) ->
false.