Table of Contents
rand_event([probability])
rand_set_prob(probability)
rand_reset_prob()
rand_get_prob()
sleep(time)
usleep(time)
abort()
pkg_status()
shm_status()
set_count(var_to_count, ret_var)
set_select_weight(int_list_var)
ts_usec_delta(t1_sec, t1_usec, t2_sec, t2_usec, delta)
check_time_rec(time_string, [timestamp])
get_static_lock(key)
release_static_lock(key)
get_dynamic_lock(key)
release_dynamic_lock(key)
strings_share_lock(key1, key2)
get_accurate_time(sec, usec, [str_sec_usec])
List of Tables
List of Examples
initial_probability
parameter usagehash_file
parameter usageshv_hash_size
parameter usageshvset
parameter usagevarset
parameter usagerand_event()
usagerand_set_prob()
usagerand_reset_prob()
usagerand_get_prob()
usagesleep
usageusleep
usageabort
usagepkg_status
usageshm_status
usageset_count
usageset_select_weight
usagets_usec_delta
usagecheck_time_rec
usageget_static_lock
usagerelease_static_lock
usageget_dynamic_lock
usagerelease_dynamic_lock
usagestrings_share_lock
usageget_accurate_time
usageasync sleep
usageasync usleep
usagerand_set_prob
usagerand_reset_prob
usagerand_get_prob
usagecheck_config_hash
usageget_config_hash
usageshv_set
usageshv_get
usageenv(name) pseudo-variable
usageRANDOM pseudo-variable
usagectime(name) pseudo-variable
usageshv(name) pseudo-variable
usageUseful extensions for the server configuration.
The cfgutils module can be used to introduce randomness to the behaviour of the server. It provides setup functions and the “rand_event” function. This function return either true or false, depending on a random value and a specified probability. E.g. if you set via fifo or script a probability value of 5%, then 5% of all calls to rand_event will return false. The pseudovariable “$RANDOM” could be used to introduce random values e.g. into a SIP reply.
The benefit of this module is the probability of the decision can be manipulated by external applications such as web interface or command line tools. The probability must be specified as percent value, ranging from 0 to 100.
The module exports commands to FIFO server that can be used to change the global settings via FIFO interface. The FIFO commands are: “set_prob”, “reset_prob” and “get_prob”.
This module can be used for simple load-shedding, e.g. reply 5% of the Invites with a 503 error and a adequate random Retry-After value.
The module provides as well functions to delay the execution of the server. The functions “sleep” and “usleep” could be used to let the server wait a specific time interval.
It can also hash the config file used from the server with a (weak) cryptographic hash function on startup. This value is saved and can be later compared to the actual hash, to detect modifications of this file after the server start. This functions are available as the FIFO commands “check_config_hash” and “get_config_hash”.
The module depends on the following modules (in the other words the listed modules must be loaded before this module):
none
The initial value of the probability.
Default value is “10”.
The config file name for that a hash value should be calculated on startup.
There is no default value, is no parameter is given the hash functionality is disabled.
Example 1.2. hash_file
parameter usage
modparam("cfgutils", "hash_file", "/etc/opensips/opensips.cfg")
The size of the hash table used to store the shared variables ($shv).
Default value is “64”.
Set the value of a shared variable ($shv(name)). The parameter can be set many times.
The value of the parameter has the format: _name_ '=' _type_ ':' _value_
_name_: shared variable name
_type_: type of the value
“i”: integer value
“s”: string value
_value_: value to be set
Default value is “NULL”.
Example 1.4. shvset
parameter usage
... modparam("cfgutils", "shvset", "debug=i:1") modparam("cfgutils", "shvset", "pstngw=s:sip:10.10.10.10") ...
Set the value of a script variable ($var(name)). The parameter can be set many times.
The value of the parameter has the format: _name_ '=' _type_ ':' _value_
_name_: shared variable name
_type_: type of the value
“i”: integer value
“s”: string value
_value_: value to be set
Default value is “NULL”.
Example 1.5. varset
parameter usage
... modparam("cfgutils", "varset", "init=i:1") modparam("cfgutils", "varset", "gw=s:sip:11.11.11.11;transport=tcp") ...
The number of dynamic script locks to be allocated at OpenSIPS startup. This number must be a power of 2. (i.e. 1, 2, 4, 8, 16, 32, 64 ...)
Note that the lock_pool_size parameter only affects the number of dynamic locks created at startup. The pool of static locks only depends on the number of unique static strings supplied throughout the script to the set of static lock functions.
Default value is “32”.
Generates a random floating point value between 0 - 100 and returns true if the value is less or equal to the currently set probability. If "probability" parameter is given, it will override the global parameter set by rand_set_prob().
Parameters:
probability (int, optional) - probability override
Example 1.7. rand_event()
usage
... if (rand_event()) { append_to_reply("Retry-After: 120\n"); sl_send_reply(503, "Try later"); exit; } # normal message processing follows ...
Set the “probability” of the decision.
Parameters:
probability (int) - number ranging from 0 - 99, inclusively
Reset the probability back to the initial_probability value.
Return the current probability setting, e.g. for logging purposes.
Waits "time" seconds.
Meaning of the parameters is as follows:
time (int) - time to wait in seconds
This function can be used from REQUEST_ROUTE, ONREPLY_ROUTE, FAILURE_ROUTE, BRANCH_ROUTE.
Waits "time" micro-seconds.
Meaning of the parameters is as follows:
time (int) - time to wait in micro-seconds
This function can be used from REQUEST_ROUTE, ONREPLY_ROUTE, FAILURE_ROUTE, BRANCH_ROUTE.
Debugging function that aborts the server. Depending on the configuration of the server a core dump will be created.
This function can be used from REQUEST_ROUTE, ONREPLY_ROUTE, FAILURE_ROUTE, BRANCH_ROUTE.
Debugging function that dumps the status for the private (PKG) memory. This information is logged to the default log facility, depending on the general log level and the memlog setting. You need to compile the server with activated memory debugging to get detailed informations.
This function can be used from REQUEST_ROUTE, ONREPLY_ROUTE, FAILURE_ROUTE, BRANCH_ROUTE.
Debugging function that dumps the status for the shared (SHM) memory. This information is logged to the default log facility, depending on the general log level and the memlog setting. You need to compile the server with activated memory debugging to get detailed informations.
This function can be used from REQUEST_ROUTE, ONREPLY_ROUTE, FAILURE_ROUTE, BRANCH_ROUTE.
Counts the number of values of a given variable. It makes sense to call this function only for variables that can take more values (AVPs, headers).
The result is returned in the second parameter.
This function can be used from REQUEST_ROUTE, ONREPLY_ROUTE, FAILURE_ROUTE, BRANCH_ROUTE.
This function selects an element from a set formed by the integer values of the given "int_list_var" variable. It applies the genetic algorithm - roulette-wheel selection to choose an element from a set. The probability of selecting a certain element is proportionate with its weight. It will return the index of that selected element.
This function can be used from REQUEST_ROUTE, ONREPLY_ROUTE, FAILURE_ROUTE, BRANCH_ROUTE.
Example 1.17. set_select_weight
usage
... $var(next_gw_idx) = set_select_weight($avp(gw_success_rates)); ...
This function returns the difference between two timestamps, specified in seconds and microseconds. The result is returned in the last parameter, expressed in microseconds.
This function can be used from REQUEST_ROUTE, ONREPLY_ROUTE, FAILURE_ROUTE, BRANCH_ROUTE.
Example 1.18. ts_usec_delta
usage
... ts_usec_delta($var(t1s), 300, 10, $var(t2ms), $var(result)); ...
The function returns a positive value if the specified time recurrence string matches the current time, or a negative value otherwise.
For checking some other Unix timestamp than the current one, the second parameter will contain the intended timestamp to check.
The syntax of each field is identical to the corresponding field from RFC 2445.
This function may be used from any route. It returns 1 on success and -1, -2 or -3 on failure, parsing or internal errors, respectively.
Meaning of the parameters is as follows:
time_string (string) - Time recurrence string which will be matched against the current time. Its fields are separated by "|" and the order in which they are given is: "timezone | dtstart | dtend | duration | freq | until | interval | byday | bymday | byyday | byweekno | bymonth".
None of the fields following "freq" is used unless "freq" is defined. If the string ends in multiple null fields, they can all be ommited.
The "timezone" field is optional. It represents the timezone in which to interpret the time recurrence elements (e.g. dtstart, dtend, until). By default, the system time zone is used.
timestamp (string, optional) - A specific Unix time to check. The function simply expects the actual Unix time here, there is no need to perform any timezone adjustments.
Additionally, more complex time recurrence strings may be built by connecting multiple time recurrence strings (described above) using the logical AND ("&"), OR ("/") and NEG ("!") operators. Furthermore, the expressions may be paranthesized. Some examples:
20210104T080000|20211231T180000||WEEKLY|||MO,TU,WE,TH,FR & !20210104T120000|20211231T140000||WEEKLY|||MO,TU,WE,TH,FR
This example multi-recurrence expresses the working days schedule for company X during 2021: workdays from 8-18, except the 12-14 interval, when everyone is out for lunch break and the business is closed. Since the timezone is omitted from each schedule, the operating system timezone will be used instead.
America/New_York|20210104T090000|20210104T170000||WEEKLY|||MO,TU,WE,TH,FR & !(Europe/Amsterdam|20210427T000000|20210428T000000 / Europe/London|20211227T000000|20211228T000000)
This example multi-recurrence expresses the working days schedule for US-based company Y during 2021: workdays from 9-17 (NY timezone), except european holidays such as King's Day (April 27th, NL) or the Spring Bank Holiday (May 31st, UK), when most of its workforce will have flown back to Europe.
Example 1.19. check_time_rec
usage
... # Only passing if still in 2012 and on a Bucharest-compatible timezone if (check_time_rec("Europe/Bucharest|20120101T000000|20130101T000000")) xlog("Current system time matches the given Romanian time interval\n"); ... # Only passing if less than 30 days have passed from "dtstart", system timezone if (check_time_rec("20121101T000000||p30d")) xlog("Current time matches the given interval\n"); ...
Acquire the static lock which corresponds to "key". In case the lock is taken by another process, script execution will halt until the lock is released. Attempting to acquire the lock a second time by the same process, without releasing it first, will result in a deadlock.
The static lock functions guarantee that two different strings will never point to the same lock, thus avoiding introducing unnecessary (and transparent!) synchronization between processes. Their disadvantage is the nature of their parameters (static strings), making them inappropriate in certain scenarios.
Meaning of the parameters is as follows:
key (static string) - key to be hashed in order to obtain the index of a static lock
This function can be used from REQUEST_ROUTE, FAILURE_ROUTE, ONREPLY_ROUTE, BRANCH_ROUTE, LOCAL_ROUTE, STARTUP_ROUTE, TIMER_ROUTE, EVENT_ROUTE.
Example 1.20. get_static_lock
usage
# acquire and release a static lock ... get_static_lock("Zone_1"); ... release_static_lock("Zone_1"); ...
Release the static lock corresponding to "key". Nothing will happen if the lock is not acquired.
Meaning of the parameters is as follows:
key (static string) - key to be hashed in order to obtain the index of a static lock.
This function can be used from REQUEST_ROUTE, FAILURE_ROUTE, ONREPLY_ROUTE, BRANCH_ROUTE, LOCAL_ROUTE, STARTUP_ROUTE, TIMER_ROUTE|EVENT_ROUTE.
Example 1.21. release_static_lock
usage
# acquire and release a static lock ... get_static_lock("Zone_1"); ... release_static_lock("Zone_1"); ...
Acquire the dynamic lock corresponding to "key". In case the lock is taken by another process, script execution will halt until the lock is released. Attempting to acquire the lock a second time by the same process, without releasing it first, will result in a deadlock.
The dynamic lock functions have the advantage of allowing string variables to be given as parameters, but the drawback to this is that two strings may have the same hashed value, thus pointing to the same lock. As a consequence, either two totally separate regions of the script will be synchronized (they will not execute in parallel), or a process could end up in a deadlock by acquiring two locks in a row on two different (but equally hashed) strings. To address the latter issue, use the strings_share_lock() function to test if two strings hash into the same dynamic lock.
Meaning of the parameters is as follows:
key (var) - key to be hashed in order to obtain the index of a dynamic lock from the pool
This function can be used from REQUEST_ROUTE, FAILURE_ROUTE, ONREPLY_ROUTE, BRANCH_ROUTE, LOCAL_ROUTE, STARTUP_ROUTE, TIMER_ROUTE|EVENT_ROUTE.
Example 1.22. get_dynamic_lock
usage
... # acquire and release a dynamic lock on the "Call-ID" header field value if (!get_dynamic_lock($ci)) { xlog("Error while getting dynamic lock!\n"); } ... if (!release_dynamic_lock($ci) { xlog("Error while releasing dynamic lock!\n"); } ...
Release the dynamic lock corresponding to "key". Nothing will happen if the lock is not acquired.
Meaning of the parameters is as follows:
key (var) - key to be hashed in order to obtain the index of a dynamic lock from the pool
This function can be used from REQUEST_ROUTE, FAILURE_ROUTE, ONREPLY_ROUTE, BRANCH_ROUTE, LOCAL_ROUTE, STARTUP_ROUTE, TIMER_ROUTE|EVENT_ROUTE.
Example 1.23. release_dynamic_lock
usage
... # acquire and release a dynamic lock on the "Call-ID" header field value if (!get_dynamic_lock($ci)) { xlog("Error while getting dynamic lock!\n"); } ... if (!release_dynamic_lock($ci) { xlog("Error while releasing dynamic lock!\n"); } ...
A function used to test if two strings will generate the same hash value. Its purpose is to prevent deadlocks resulted when a process successively acquires two dynamic locks on two strings which happen to point to the same lock.
Theoretically, the chance of two strings generating the same hash value decreases proportionally to the increase of the lock_pool_size parameter. In other words, the more dynamic locks you configure the module with, the higher the chance that all individual protected regions of your script will run in parallel, without waiting for each other.
Meaning of the parameters is as follows:
key1, key2 (string) - strings which will have their hash values compared
This function can be used from REQUEST_ROUTE, FAILURE_ROUTE, ONREPLY_ROUTE, BRANCH_ROUTE, LOCAL_ROUTE, STARTUP_ROUTE, TIMER_ROUTE|EVENT_ROUTE.
Example 1.24. strings_share_lock
usage
... # Proper way of acquiring two dynamic locks successively if (!get_dynamic_lock($avp(foo))) { xlog("Error while getting dynamic lock!\n"); } if (!strings_share_lock($avp(foo), $avp(bar)) { if (!get_dynamic_lock($avp(bar))) { xlog("Error while getting dynamic lock!\n"); } } ... if (!strings_share_lock($avp(foo), $avp(bar)) { if (!release_dynamic_lock($avp(bar)) { xlog("Error while releasing dynamic lock!\n"); } } if (!release_dynamic_lock($avp(foo)) { xlog("Error while releasing dynamic lock!\n"); } ...
Fetch the current Unix time epoch with microsecond precision. Optionally, print this value as a floating point number (3rd parameter).
Meaning of the parameters is as follows:
sec (int) - the current Unix timestamp (integer part)
usec (int) - the current Unix timestamp (decimal part)
str_sec_usec (string, optional) - the current Unix timestamp as a floating point number (6-digit precision)
This function can be used from REQUEST_ROUTE, FAILURE_ROUTE, ONREPLY_ROUTE, BRANCH_ROUTE, LOCAL_ROUTE, STARTUP_ROUTE, TIMER_ROUTE, EVENT_ROUTE.
Example 1.25. get_accurate_time
usage
... get_accurate_time($var(sec), $var(usec)); xlog("Current Unix timestamp: $var(sec) s, $var(usec) us\n"); ...
Waits a number of seconds. This function does exactly the same as sleep(), but in an asynchronous way. The script execution is suspended until the waiting is done; then OpenSIPS resumes the script execution via the resume route.
To read and understand more on the asynchronous functions, how to use them and what are their advantages, please refer to the OpenSIPS online Manual.
Example 1.26. async sleep
usage
{ ... async( sleep("5"), after_sleep ); } route[after_sleep] { ... }
Waits a number of micro-seconds. This function does exactly the same as usleep(), but in an asynchronous way. The script execution is suspended until the waiting is done; then OpenSIPS resumes the script execution via the resume route.
To read and understand more on the asynchronous functions, how to use them and what are their advantages, please refer to the OpenSIPS online Manual.
Example 1.27. async usleep
usage
{ ... async( usleep("1000"), after_usleep ); } route[after_usleep] { ... }
Set the probability value to the given parameter.
Parameters:
prob_proc - the parameter should be a percent value (number from 0 to 99).
Reset the probability value to the inital start value.
This command don't need a parameter.
Return the actual probability setting.
The function return the actual probability value.
Example 1.30. rand_get_prob
usage
... $ opensips-cli -x mi get_prob The actual probability is 50 percent. ...
Check if the actual config file hash is identical to the stored one.
The function returns 200 OK if the hash values are identical, 400 if there are not identical, 404 if no file for hashing has been configured and 500 on errors. Additional a short text message is printed.
Example 1.31. check_config_hash
usage
... $ opensips-cli -x mi check_config_hash The actual config file hash is identical to the stored one. ...
Return the stored config file hash.
The function returns 200 OK and the hash value on success or 404 if no file for hashing has been configured.
Example 1.32. get_config_hash
usage
... $ opensips-cli -x mi get_config_hash 1580a37104eb4de69ab9f31ce8d6e3e0 ...
Set the value of a shared variable ($shv(name)).
Parameters:
name : shared variable name
type : type of the value
“int”: integer value
“str”: string value
value : value to be set
This PV provides access to the environment variable 'name'.
Example 1.35. env(name) pseudo-variable
usage
... xlog("PATH environment variable is $env(PATH)\n"); ...
Returns a random value from the [0 - 2^31) range.
Example 1.36. RANDOM pseudo-variable
usage
... $avp(10) = ($RANDOM / 16777216); # 2^24 if ($avp(10) < 10) { $avp(10) = 10; } append_to_reply("Retry-After: $avp(10)\n"); sl_send_reply(503, "Try later"); exit; # normal message processing follows
The PV provides access to broken-down time attributes.
The “name” can be:
sec - return seconds (int 0-59)
min - return minutes (int 0-59)
hour - return hours (int 0-23)
mday - return the day of month (int 0-59)
mon - return the month (int 1-12)
year - return the year (int, e.g., 2008)
wday - return the day of week (int, 1=Sunday - 7=Saturday)
yday - return the day of year (int, 1-366)
isdst - return daylight saving time status (int, 0 - DST off, >0 DST on)
Example 1.37. ctime(name) pseudo-variable
usage
... if ($ctime(year) == 2008) { xlog("request: $rm from $fu to $ru in year 2008\n"); } ...
It is a class of pseudo-variables stored in shared memory. The value of $shv(name) is visible across all opensips processes. Each “shv” has single value and it is initialized to integer 0. You can use “shvset” parameter to initialize the shared variable. The module exports a set of MI functions to get/set the value of shared variables.
Example 1.38. shv(name) pseudo-variable
usage
... modparam("cfgutils", "shvset", "debug=i:1") ... if ($shv(debug) == 1) { xlog("request: $rm from $fu to $ru\n"); } ...
Table 2.1. Top contributors by DevScore(1), authored commits(2) and lines added/removed(3)
Name | DevScore | Commits | Lines ++ | Lines -- | |
---|---|---|---|---|---|
1. | Liviu Chircu (@liviuchircu) | 89 | 40 | 2912 | 1491 |
2. | Henning Westerholt (@henningw) | 29 | 18 | 1088 | 86 |
3. | Bogdan-Andrei Iancu (@bogdan-iancu) | 27 | 22 | 367 | 109 |
4. | Razvan Crainea (@razvancrainea) | 20 | 15 | 289 | 79 |
5. | Vlad Patrascu (@rvlad-patrascu) | 18 | 6 | 355 | 547 |
6. | Elena-Ramona Modroiu | 14 | 3 | 1183 | 7 |
7. | Daniel-Constantin Mierla (@miconda) | 12 | 10 | 84 | 32 |
8. | Anca Vamanu | 6 | 3 | 220 | 14 |
9. | Ionel Cerghit (@ionel-cerghit) | 5 | 1 | 18 | 161 |
10. | Maksym Sobolyev (@sobomax) | 4 | 2 | 15 | 8 |
All remaining contributors: Vlad Paiu (@vladpaiu), Sergio Gutierrez, Konstantin Bokarius, Walter Doekes (@wdoekes), Peter Lemenkov (@lemenkov), Edson Gellert Schubert.
(1) DevScore = author_commits + author_lines_added / (project_lines_added / project_commits) + author_lines_deleted / (project_lines_deleted / project_commits)
(2) including any documentation-related commits, excluding merge commits. Regarding imported patches/code, we do our best to count the work on behalf of the proper owner, as per the "fix_authors" and "mod_renames" arrays in opensips/doc/build-contrib.sh. If you identify any patches/commits which do not get properly attributed to you, please submit a pull request which extends "fix_authors" and/or "mod_renames".
(3) ignoring whitespace edits, renamed files and auto-generated files
Table 2.2. Most recently active contributors(1) to this module
Name | Commit Activity | |
---|---|---|
1. | Liviu Chircu (@liviuchircu) | Sep 2012 - Aug 2022 |
2. | Maksym Sobolyev (@sobomax) | Dec 2015 - Jan 2021 |
3. | Razvan Crainea (@razvancrainea) | Oct 2010 - Jan 2020 |
4. | Bogdan-Andrei Iancu (@bogdan-iancu) | Jul 2007 - Oct 2019 |
5. | Vlad Patrascu (@rvlad-patrascu) | May 2017 - Apr 2019 |
6. | Peter Lemenkov (@lemenkov) | Jun 2018 - Jun 2018 |
7. | Ionel Cerghit (@ionel-cerghit) | Dec 2015 - Dec 2015 |
8. | Walter Doekes (@wdoekes) | Jan 2015 - Jan 2015 |
9. | Vlad Paiu (@vladpaiu) | Jan 2013 - Jul 2014 |
10. | Anca Vamanu | Aug 2009 - Sep 2009 |
All remaining contributors: Sergio Gutierrez, Henning Westerholt (@henningw), Daniel-Constantin Mierla (@miconda), Elena-Ramona Modroiu, Konstantin Bokarius, Edson Gellert Schubert.
(1) including any documentation-related commits, excluding merge commits
Last edited by: Liviu Chircu (@liviuchircu), Bogdan-Andrei Iancu (@bogdan-iancu), Razvan Crainea (@razvancrainea), Peter Lemenkov (@lemenkov), Vlad Patrascu (@rvlad-patrascu), Anca Vamanu, Sergio Gutierrez, Henning Westerholt (@henningw), Daniel-Constantin Mierla (@miconda), Elena-Ramona Modroiu, Konstantin Bokarius, Edson Gellert Schubert.
Documentation Copyrights:
Copyright © 2007-2008 1und1 Internet AG
Copyright © 2007-2008 BASIS AudioNet GmbH
Copyright © 2007-2008 Elena-Ramona Modroiu