dlg_db_handler.h 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123
  1. /*
  2. * Copyright (C) 2007 Voice System SRL
  3. * Copyright (C) 2011 Carsten Bock, [email protected]
  4. *
  5. * This file is part of Kamailio, a free SIP server.
  6. *
  7. * Kamailio is free software; you can redistribute it and/or modify
  8. * it under the terms of the GNU General Public License as published by
  9. * the Free Software Foundation; either version 2 of the License, or
  10. * (at your option) any later version
  11. *
  12. * Kamailio is distributed in the hope that it will be useful,
  13. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  14. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  15. * GNU General Public License for more details.
  16. *
  17. * You should have received a copy of the GNU General Public License
  18. * along with this program; if not, write to the Free Software
  19. * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
  20. *
  21. */
  22. /*!
  23. * \file
  24. * \brief Database interface
  25. * \ingroup dialog
  26. * Module: \ref dialog
  27. */
  28. #ifndef _DLG_DB_HANDLER_H_
  29. #define _DLG_DB_HANDLER_H_
  30. #include "../../str.h"
  31. #include "../../lib/srdb1/db.h"
  32. #define CALL_ID_COL "callid"
  33. #define FROM_URI_COL "from_uri"
  34. #define FROM_TAG_COL "from_tag"
  35. #define TO_URI_COL "to_uri"
  36. #define TO_TAG_COL "to_tag"
  37. #define HASH_ID_COL "hash_id"
  38. #define HASH_ENTRY_COL "hash_entry"
  39. #define STATE_COL "state"
  40. #define START_TIME_COL "start_time"
  41. #define TIMEOUT_COL "timeout"
  42. #define TO_CSEQ_COL "callee_cseq"
  43. #define FROM_CSEQ_COL "caller_cseq"
  44. #define TO_ROUTE_COL "callee_route_set"
  45. #define FROM_ROUTE_COL "caller_route_set"
  46. #define TO_CONTACT_COL "callee_contact"
  47. #define FROM_CONTACT_COL "caller_contact"
  48. #define FROM_SOCK_COL "caller_sock"
  49. #define TO_SOCK_COL "callee_sock"
  50. #define IFLAGS_COL "iflags"
  51. #define SFLAGS_COL "sflags"
  52. #define TOROUTE_NAME_COL "toroute_name"
  53. #define REQ_URI_COL "req_uri"
  54. #define XDATA_COL "xdata"
  55. #define DIALOG_TABLE_NAME "dialog"
  56. #define DLG_TABLE_VERSION 7
  57. #define DIALOG_TABLE_COL_NO 23
  58. #define VARS_HASH_ID_COL "hash_id"
  59. #define VARS_HASH_ENTRY_COL "hash_entry"
  60. #define VARS_KEY_COL "dialog_key"
  61. #define VARS_VALUE_COL "dialog_value"
  62. #define DIALOG_VARS_TABLE_NAME "dialog_vars"
  63. #define DLG_VARS_TABLE_VERSION 1
  64. #define DIALOG_VARS_TABLE_COL_NO 4
  65. /*every minute the dialogs' information will be refreshed*/
  66. #define DB_DEFAULT_UPDATE_PERIOD 60
  67. #define DB_MODE_NONE 0
  68. #define DB_MODE_REALTIME 1
  69. #define DB_MODE_DELAYED 2
  70. #define DB_MODE_SHUTDOWN 3
  71. /* Dialog table */
  72. extern str call_id_column;
  73. extern str from_uri_column;
  74. extern str from_tag_column;
  75. extern str to_uri_column;
  76. extern str to_tag_column;
  77. extern str h_id_column;
  78. extern str h_entry_column;
  79. extern str state_column;
  80. extern str start_time_column;
  81. extern str timeout_column;
  82. extern str to_cseq_column;
  83. extern str from_cseq_column;
  84. extern str to_route_column;
  85. extern str from_route_column;
  86. extern str to_contact_column;
  87. extern str from_contact_column;
  88. extern str to_sock_column;
  89. extern str from_sock_column;
  90. extern str iflags_column;
  91. extern str sflags_column;
  92. extern str toroute_name_column;
  93. extern str dialog_table_name;
  94. extern int dlg_db_mode;
  95. /* Dialog-Vars Table */
  96. extern str vars_h_id_column;
  97. extern str vars_h_entry_column;
  98. extern str vars_key_column;
  99. extern str vars_value_column;
  100. extern str dialog_vars_table_name;
  101. int init_dlg_db(const str *db_url, int dlg_hash_size, int db_update_period, int fetch_num_rows);
  102. int dlg_connect_db(const str *db_url);
  103. void destroy_dlg_db(void);
  104. int remove_dialog_from_db(struct dlg_cell * cell);
  105. int update_dialog_dbinfo(struct dlg_cell * cell);
  106. void dialog_update_db(unsigned int ticks, void * param);
  107. #endif