emqx_cm.hrl 1.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142
  1. %%-------------------------------------------------------------------
  2. %% Copyright (c) 2022-2024 EMQ Technologies Co., Ltd. All Rights Reserved.
  3. %%
  4. %% Licensed under the Apache License, Version 2.0 (the "License");
  5. %% you may not use this file except in compliance with the License.
  6. %% You may obtain a copy of the License at
  7. %%
  8. %% http://www.apache.org/licenses/LICENSE-2.0
  9. %%
  10. %% Unless required by applicable law or agreed to in writing, software
  11. %% distributed under the License is distributed on an "AS IS" BASIS,
  12. %% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13. %% See the License for the specific language governing permissions and
  14. %% limitations under the License.
  15. %%--------------------------------------------------------------------
  16. -ifndef(EMQX_CM_HRL).
  17. -define(EMQX_CM_HRL, true).
  18. %% Tables for channel management.
  19. -define(CHAN_TAB, emqx_channel).
  20. -define(CHAN_CONN_TAB, emqx_channel_conn).
  21. -define(CHAN_INFO_TAB, emqx_channel_info).
  22. -define(CHAN_LIVE_TAB, emqx_channel_live).
  23. %% Mria table for session registration.
  24. -define(CHAN_REG_TAB, emqx_channel_registry).
  25. -define(T_KICK, 5_000).
  26. -define(T_GET_INFO, 5_000).
  27. -define(T_TAKEOVER, 15_000).
  28. -define(CM_POOL, emqx_cm_pool).
  29. %% Registered sessions.
  30. -record(channel, {
  31. chid :: emqx_types:clientid() | '_',
  32. %% pid field is extended in 5.6.0 to support recording unregistration timestamp.
  33. pid :: pid() | non_neg_integer() | '$1'
  34. }).
  35. -endif.