Skip to content

Commit

Permalink
Code formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
@wasichu
wasichu committed Mar 18, 2018
1 parent 8da84ff commit a47b7ed
Showing 1 changed file with 99 additions and 95 deletions.
194 changes: 99 additions & 95 deletions package/Connection.tcl
View file
Expand Up @@ -752,6 +752,105 @@ oo::define ::rmq::Connection {
##
##

method connectionBlocked {data} {
::rmq::debug "Connection.Blocked"

set blocked 1
set reason [::rmq::dec_short_string $data _]
if {$BlockedCB ne ""} {
{*}$blockedCB [self] $blocked $reason
}
}

method connectionClose {{data ""} {replyCode 200} {replyText "Normal"} {cID 0} {mID 0}} {
dict set closeD data $data replyCode $replyCode replyText $replyText \
classID $cID methodID $mID

# if data is blank, we are sending this method
# otherwise, this message was received
if {$data eq ""} {
::rmq::debug "Connection.Close"
set replyCode [::rmq::enc_short $replyCode]
set replyText [::rmq::enc_short_string $replyText]
set classID [::rmq::enc_short $cID]
set methodID [::rmq::enc_short $mID]

set methodData "${replyCode}${replyText}${classID}${methodID}"
set methodData [::rmq::enc_method $::rmq::CONNECTION_CLASS \
$::rmq::CONNECTION_CLOSE $methodData]
my send [::rmq::enc_frame $::rmq::FRAME_METHOD 0 $methodData]
} else {
set replyCode [::rmq::dec_short $data _]
set replyText [::rmq::dec_short_string [string range $data 2 end] bytes]
set data [string range $data [expr {2 + $bytes}] end]
set classID [::rmq::dec_short $data _]
set methodID [::rmq::dec_short [string range $data 2 end] _]

::rmq::debug "Connection.Close (${replyCode}: $replyText) (classID $classID methodID $methodID)"

# send Connection.Close-Ok
my sendConnectionCloseOk
}
}

method connectionCloseOk {data} {
::rmq::debug "Connection.CloseOk"
my closeConnection
}

method connectionOpen {} {
::rmq::debug "Connection.Open vhost [$login getVhost]"

set vhostVal [::rmq::enc_short_string [$login getVhost]]
set reserve1 [::rmq::enc_short_string ""]
set reserve2 [::rmq::enc_byte 1]
set payload "${vhostVal}${reserve1}${reserve2}"

set methodData [::rmq::enc_method 10 40 $payload]
my send [::rmq::enc_frame 1 0 $methodData]
}

method connectionOpenOk {data} {
# this method signals the connection is ready
# and that we are no longer in a retry loop
set retries 0
set connected 1

::rmq::debug "Connection.OpenOk: connection now established"

# call user supplied callback for when Connection is ready for use
if {$connectedCB ne ""} {
{*}$connectedCB [self]
}
}

method connectionSecure {data} {
::rmq::debug "Connection.Secure"

set challenge [::rmq::dec_long_string $data _]
my connectionSecureOk $challenge
}

method connectionSecureOk {challenge} {
::rmq::debug "Connection.SecureOk"

set resp [::rmq::enc_long_string [$login saslResponse]]
set payload [::rmq::enc_method 10 21 $resp]
my send [::rmq::enc_frame 1 0 $payload]
}

#
# Connection.sendConnectionCloseOk - used to differentiate the
# sending of AMQP Connection.CloseOk method from receiving it
#
method sendConnectionCloseOk {} {
::rmq::debug "Sending Connection.CloseOk"
set methodData [::rmq::enc_method $::rmq::CONNECTION_CLASS \
$::rmq::CONNECTION_CLOSE_OK ""]
my send [::rmq::enc_frame $::rmq::FRAME_METHOD 0 $methodData]
my closeConnection
}

#
# Connection.Start - given a frame containing
# containing the Connection.Start method, return
Expand Down Expand Up @@ -906,101 +1005,6 @@ oo::define ::rmq::Connection {
my connectionOpen
}

method connectionSecure {data} {
::rmq::debug "Connection.Secure"

set challenge [::rmq::dec_long_string $data _]
my connectionSecureOk $challenge
}

method connectionSecureOk {challenge} {
::rmq::debug "Connection.SecureOk"

set resp [::rmq::enc_long_string [$login saslResponse]]
set payload [::rmq::enc_method 10 21 $resp]
my send [::rmq::enc_frame 1 0 $payload]
}

method connectionOpen {} {
::rmq::debug "Connection.Open vhost [$login getVhost]"

set vhostVal [::rmq::enc_short_string [$login getVhost]]
set reserve1 [::rmq::enc_short_string ""]
set reserve2 [::rmq::enc_byte 1]
set payload "${vhostVal}${reserve1}${reserve2}"

set methodData [::rmq::enc_method 10 40 $payload]
my send [::rmq::enc_frame 1 0 $methodData]
}

method connectionOpenOk {data} {
# this method signals the connection is ready
# and that we are no longer in a retry loop
set retries 0
set connected 1

::rmq::debug "Connection.OpenOk: connection now established"

# call user supplied callback for when Connection is ready for use
if {$connectedCB ne ""} {
{*}$connectedCB [self]
}
}

method connectionClose {{data ""} {replyCode 200} {replyText "Normal"} {cID 0} {mID 0}} {
dict set closeD data $data replyCode $replyCode replyText $replyText \
classID $cID methodID $mID

# if data is blank, we are sending this method
# otherwise, this message was received
if {$data eq ""} {
::rmq::debug "Connection.Close"
set replyCode [::rmq::enc_short $replyCode]
set replyText [::rmq::enc_short_string $replyText]
set classID [::rmq::enc_short $cID]
set methodID [::rmq::enc_short $mID]

set methodData "${replyCode}${replyText}${classID}${methodID}"
set methodData [::rmq::enc_method $::rmq::CONNECTION_CLASS \
$::rmq::CONNECTION_CLOSE $methodData]
my send [::rmq::enc_frame $::rmq::FRAME_METHOD 0 $methodData]
} else {
set replyCode [::rmq::dec_short $data _]
set replyText [::rmq::dec_short_string [string range $data 2 end] bytes]
set data [string range $data [expr {2 + $bytes}] end]
set classID [::rmq::dec_short $data _]
set methodID [::rmq::dec_short [string range $data 2 end] _]

::rmq::debug "Connection.Close (${replyCode}: $replyText) (classID $classID methodID $methodID)"

# send Connection.Close-Ok
my sendConnectionCloseOk
}
}

method connectionCloseOk {data} {
::rmq::debug "Connection.CloseOk"
my closeConnection
}

method sendConnectionCloseOk {} {
::rmq::debug "Sending Connection.CloseOk"
set methodData [::rmq::enc_method $::rmq::CONNECTION_CLASS \
$::rmq::CONNECTION_CLOSE_OK ""]
my send [::rmq::enc_frame $::rmq::FRAME_METHOD 0 $methodData]
my closeConnection
}

method connectionBlocked {data} {
::rmq::debug "Connection.Blocked"

set blocked 1
set reason [::rmq::dec_short_string $data _]
if {$BlockedCB ne ""} {
{*}$blockedCB [self] $blocked $reason
}
}

method connectionUnblocked {data} {
::rmq::debug "Connection.Unblocked"

Expand Down

0 comments on commit a47b7ed

Please sign in to comment.