Module ocs_diameter_3gpp_s6a_application_cb

Description
Data Types
Function Index
Function Details

This diameter_app behaviour callback module handles diameter messages for the 3GPP DIAMETER S6a/S6d applications in the cse application.

References

3GPP TS TS 29.272 MME and SGSN Diameter Interfaces

Description

This diameter_app behaviour callback module handles diameter messages for the 3GPP DIAMETER S6a/S6d applications in the cse application.

Data Types

capabilities()

capabilities() = #diameter_caps{}

message()

message() = tuple() | list()

packet()

packet() = #diameter_packet{}

peer()

peer() = {Peer_Ref::term(), Capabilities::capabilities()}

state()

state() = #state{}

Function Index

peer_up/3	Invoked when the peer connection is available.
peer_down/3	Invoked when the peer connection is not available.
pick_peer/5	Invoked as a consequence of a call to diameter:call/4 to select a destination peer for an outgoing request.
prepare_request/4	Invoked to return a request for encoding and transport.
prepare_retransmit/4	Invoked to return a request for encoding and retransmission.
handle_answer/5	Invoked when an answer message is received from a peer.
handle_error/5	Invoked when an error occurs before an answer message is received in response to an outgoing request.
handle_request/3	Invoked when a request message is received from the peer.
process_request/4*	Process a received DIAMETER packet.
errors/4*	Handle errors in requests.
sqn/1*	Sequence Number (SQN).
autn/4*	Network Authentication Token (AUTN).
sqn_ms/4*	Retrieve concealed `SQNms` from `AUTS`.
dif/1*	The DIF value represents the current difference between generated SEQ values for that user and the GLC.
kdf/5*	Key Derivation Function (KDF).

Function Details

peer_up/3

peer_up(ServiceName, Peer, State) -> NewState

ServiceName = diameter:service_name()
Peer = peer()
State = state()
NewState = state()

Invoked when the peer connection is available

peer_down/3

peer_down(ServiceName, Peer, State) -> NewState

ServiceName = diameter:service_name()
Peer = peer()
State = state()
NewState = state()

Invoked when the peer connection is not available

pick_peer/5

pick_peer(LocalCandidates, RemoteCandidates, ServiceName, State, Fsm) -> Result

LocalCandidates = [peer()]
RemoteCandidates = [peer()]
ServiceName = diameter:service_name()
State = state()
Fsm = pid()
NewState = state()
Selection = {ok, Peer} | {Peer, NewState}
Peer = peer() | false
Result = Selection | false

Invoked as a consequence of a call to diameter:call/4 to select a destination peer for an outgoing request.

prepare_request/4

prepare_request(Packet, ServiceName, Peer, Fsm) -> Action

Packet = packet()
ServiceName = diameter:service_name()
Peer = peer()
Fsm = pid()
Action = Send | Discard | {eval_packet, Action, PostF}
Send = {send, packet() | message()}
Discard = {discard, Reason} | discard
Reason = term()
PostF = diameter:evaluable()

Invoked to return a request for encoding and transport

prepare_retransmit/4

prepare_retransmit(Packet, ServiceName, Peer, Fsm) -> Action

Packet = packet()
ServiceName = diameter:service_name()
Peer = peer()
Fsm = pid()
Action = Send | Discard | {eval_packet, Action, PostF}
Send = {send, packet() | message()}
Discard = {discard, Reason} | discard
Reason = term()
PostF = diameter:evaluable()

Invoked to return a request for encoding and retransmission. In case of peer connection is lost alternate peer is selected.

handle_answer/5

handle_answer(Packet, Request, ServiceName, Peer, Fsm) -> Result

Packet = packet()
Request = message()
ServiceName = diameter:service_name()
Peer = peer()
Fsm = pid()
Result = term()

Invoked when an answer message is received from a peer.

handle_error/5

handle_error(Reason, Request, ServiceName, Peer, Fsm) -> Result

Reason = timeout | failover | term()
Request = message()
ServiceName = diameter:service_name()
Peer = peer()
Fsm = pid()
Result = term()

Invoked when an error occurs before an answer message is received in response to an outgoing request.

handle_request/3

handle_request(Packet, ServiceName, Peer) -> Action

Packet = packet()
ServiceName = term()
Peer = peer()
Action = Reply | {relay, [Opt]} | discard | {eval | eval_packet, Action, PostF}
Reply = {reply, packet() | message()} | {answer_message, 3000..3999 | 5000..5999} | {protocol_error, 3000..3999}
Opt = diameter:call_opt()
PostF = diameter:evaluable()

Invoked when a request message is received from the peer.

process_request/4 *

process_request(ServiceName, Capabilities, Request, Client) -> Result

ServiceName = term()
Capabilities = capabilities()
Request = term()
Client = #client{address = inet:ip_address() | undefined | '_', identifier = binary() | '_', port = inet:port_number() | undefined | '_', protocol = radius | diameter | undefined | '_', secret = binary() | undefined | '_', password_required = boolean() | '_', trusted = boolean() | '_', last_modified = tuple() | undefined | '_'}
Result = {reply, message()} | discard

Process a received DIAMETER packet.

To do

Handle S6a/S6d requests.

errors/4 *

errors(ServiceName, Capabilities, Request, Errors) -> Action

ServiceName = atom()
Capabilities = capabilities()
Request = message()
Errors = [Error]
Error = {Code, #diameter_avp{}} | Code
Code = 0..4294967295
Action = Reply | {relay, [Opt]} | discard | {eval | eval_packet, Action, PostF}
Reply = {reply, packet() | message()} | {answer_message, 3000..3999 | 5000..5999} | {protocol_error, 3000..3999}
Opt = diameter:call_opt()
PostF = diameter:evaluable()