when CLIENT_ACCEPTED {
set seq_index 1
set bind_context 0
set unbind_context 0
TCP::collect
}
when CLIENT_DATA {
while { [TCP::payload length] > 16 } {
binary scan [TCP::payload] IH8IIa* RQTLen RQTOper RQTStatus RQTSeq p
if { [TCP::payload length] < $RQTLen } {
TCP::collect $RQTLen
return
}
switch -glob $RQTOper {
00000001 -
00000002 -
00000009 {
bind
log local0.info "SMPP:BindRequest Data: LEN:$RQTLen Command:$RQTOper Satus:$RQTStatus Seqence:$RQTSeq"
set bind_message [TCP::payload $RQTLen]
set bind_context 1
foreach smsc_node [active_members -list pool_smsc] {
set node [lindex [split $smsc_node " "] 0]:[lindex [split $smsc_node " "] 1]
set smsc($smsc_node) "0 0 0"
foreach {smsc_node_1} [array get smsc]
{
log local0.info "ARRAY_ELEMENT_1 ==> $smsc_node_1"
}
}
}
00000006 {
unbind
log local0.info "SMPP:UnbindRequest Data:LEN:$RQTLen Command:$RQTOper Satus:$RQTStatus Seqence:$RQTSeq"
set unbind_message [TCP::payload $RQTLen]
set unbind_context 1
}
00000015 {
enquire_link
log local0.info "SMPP:enquireLinkRequest Data:LEN:$RQTLen Command:$RQTOper Satus:$RQTStatus Seqence:$RQTSeq"
set enquire_message [TCP::payload $RQTLen]
foreach {smsc_node b_status u_status el_status} [array get smsc] {
array set smsc {$smsc_node "$b_status $u_status 0"}
}
}
00000004 {
submit_sm
log local0.info "SMPP:SubmitSMRequest Data:LEN:$RQTLen Command:$RQTOper Satus:$RQTStatus Seqence:$RQTSeq"
Load balance SMS AO
LB::detach
}
8* {
Response from client (deliver_sm_resp, ...)
log local0.info "SMPP:CommandResponse Data:LEN:$RQTLen Command:$RQTOper Satus:$RQTStatus Seqence:$RQTSeq"
Rewrite RQTSeq and set the correct SMS-C to respond
if { [info exists s_seq_map($RQTSeq)] } {
set old_RQTSeq [lindex $s_seq_map($RQTSeq) 0]
TCP::payload replace 12 4 [binary format I $seq_index]
use pool or node command
pool [LB::server pool] member [lindex $s_seq_map($RQTSeq) 1] [lindex $s_seq_map($RQTSeq) 2]
unset s_seq_map($RQTSeq)
} else {
Cannot route response
log local0.info "SMPP:Unkown sequence [$RQTSeq] Data:LEN:$RQTLen Command:$RQTOper Satus:$RQTStatus Seqence:$RQTSeq"
}
}
}
TCP::release $RQTLen
TCP::notify request
}
TCP::collect
}
when SERVER_CONNECTED {
TCP::collect
}
when SERVER_DATA {
while { [TCP::payload length] > 16 } {
binary scan [TCP::payload] IH8II RQTLen RQTOper RQTStatus RQTSeq p
if { [TCP::payload length] < $RQTLen } {
TCP::collect $RQTLen
return
}
switch -glob $RQTOper {
0* {
Deliver_sm, ...
Rewrite seq
TCP::payload replace 12 4 [binary format I $seq_index]
set s_seq_map($seq_index) "$RQTSeq [IP::remote_addr] [TCP::remote_port]"
incr seq_index
}
80000001 -
80000002 -
80000009 {
Bind_resp
if { $bind_context } {
switch -glob $RQTStatus {
00000000 -
0 -
00000005 {
No Error or ESME Already in Bound State
log local0.info "Bind:ResponseOK Data: Status:$RQTStatus Node: [IP::remote_addr] [TCP::remote_port] "
Added by YOSSI
set smsc("[IP::remote_addr]:[TCP::remote_port]") "1 0 0"
foreach {smsc_node b_status} [array get smsc] {
log local0.info "smsc_node_res $smsc_node"
if { $b_status eq "0 0 0" } {
log local0.info "Bind:OneMoreSMSCToBind Data:\[Node: $smsc_node \]"
log local0. " node [lindex [split $smsc_node " "] 0] port [lindex [split $smsc_node " "] 1]"
set a [lindex [split $smsc_node " "] 0]:[lindex [split $smsc_node " "] 1]
log local0.info "a $a"
pool pool_smsc member $a
TCP::collect -all
TCP::respond $bind_message
set smsc("$a") "1 0 0"
log local0.info "smsc("$a")"
return
}
}
log local0.info "Bind:NoMoreSMSCToBind Data:\[SMSC: $smsc_node \]"
}
*
{
Else - Respond back to client
log local0.info "Bind:ResponseFailed Data: Status:$RQTStatus Node: [IP::remote_addr] [TCP::remote_port] ]"
}
}
set bind_context 0
} else {
log local0.info "Bind:UnknownContext Data:Status:$RQTStatus Node: [IP::remote_addr] [TCP::remote_port] "
TCP::payload replace 0 [TCP::payload length] ""
set RQTLen 0
}
}
80000006 {
Unbind_resp
if { $unbind_context } {
log local0.info "Unbind:Response Data: Status:$RQTStatus Node: [IP::remote_addr] [TCP::remote_port] "
set memb "[IP::remote_addr] [TCP::remote_port]"
array set smsc {$memb "1 1 0"}
foreach {smsc_node b_status u_status el_status} [array get smsc] {
if {$u_status eq 0} {
log local0.info "Unbind:OneMoreSMSCToUnbind Data:\[Node: $smsc_node \]"
pool pool_smsc member $smsc_node
TCP::collect -all
TCP::respond $unbind_message
return
}
}
log local0.info "Unbind:NoMoreSMSCToUnbind Data"
} else {
log local0.info "Unbind:UnknownContext Data:Status:$RQTStatus Node: [IP::remote_addr] [TCP::remote_port] "
TCP::payload replace 0 [TCP::payload length] ""
set RQTLen 0
}
set unbind_context 0
unset smsc;
}
80000015 {
Enquire_link_resp
log local0.info "Enquire_link:Response Data: Status:$RQTStatus Node: [IP::remote_addr] [TCP::remote_port] "
set memb "[IP::remote_addr] [TCP::remote_port]"
array set smsc {$memb "1 1 0"}
foreach {smsc_node b_status u_status el_status} [array get smsc] {
if {$el_status eq 0} {
log local0.info "Enquire_link:OneMoreSMSCToEnquireLink Data:\[Node: $smsc_node \]"
pool pool_smsc member $smsc_node
TCP::collect -all
TCP::respond $enquire_message
return
}
}
log local0.info "Enquire_link:NoMoreSMSCToEnquireLink Data"
}
}
TCP::release $RQTLen
TCP::notify response
}
TCP::collect
}
Nimbostratus
