Skip to content

Instantly share code, notes, and snippets.

@andrewthad

andrewthad/ProducerRequest.core.txt

Created July 11, 2019 16:04
Show Gist options
  • Save andrewthad/e33212fcffc3eebf9da9a91dc373a9c7 to your computer and use it in GitHub Desktop.
Save andrewthad/e33212fcffc3eebf9da9a91dc373a9c7 to your computer and use it in GitHub Desktop.
Download ZIP
ProducerRequest GHC Core
Raw
ProducerRequest.core.txt
==================== Tidy Core ====================
Result size of Tidy Core
= {terms: 1,859, types: 3,380, coercions: 2,902, joins: 12/46}
-- RHS size: {terms: 22, types: 60, coercions: 32, joins: 0/0}
produceRequest1
produceRequest1
= \ s1_asVO ->
case newByteArray# 1# (s1_asVO `cast` <Co:18>) of
{ (# ipv_ajvN, ipv1_ajvO #) ->
case writeWord8Array# ipv1_ajvO 0# 0## ipv_ajvN of s'#_asOP
{ __DEFAULT ->
case unsafeFreezeByteArray# ipv1_ajvO s'#_asOP of
{ (# ipv2_ajF3, ipv3_ajF4 #) ->
(# ipv2_ajF3, ByteArray ipv3_ajF4 #) `cast` <Co:14>
}
}
}
-- RHS size: {terms: 5, types: 30, coercions: 0, joins: 0/0}
produceRequest_zero
produceRequest_zero
= case runRW# produceRequest1 of { (# ipv_asKE, ipv1_asKF #) ->
ipv1_asKF
}
-- RHS size: {terms: 2, types: 0, coercions: 0, joins: 0/0}
produceRequest2
produceRequest2 = I# 0#
-- RHS size: {terms: 13, types: 6, coercions: 0, joins: 0/0}
sumSizes1
sumSizes1
= \ e_as8d acc_as8e ->
case acc_as8e of { I# x_asSR ->
case e_as8d of { ByteArray arr#_af8z ->
I# (+# x_asSR (sizeofByteArray# arr#_af8z))
}
}
-- RHS size: {terms: 60, types: 158, coercions: 0, joins: 0/2}
$wwrite8
$wwrite8
= \ @ m_sul4 ww_sulf ww1_sulg ww2_sulk w_sul6 w1_sul7 w2_sul8 ->
let {
lvl13_stmL
lvl13_stmL = get w_sul6 } in
let {
lvl14_stmN
lvl14_stmN
= case w_sul6 of
{ C:MonadState ww4_XsOi ww5_XsOk ww6_XsOm ww7_asGO ->
case ww4_XsOi of
{ C:Monad ww9_asGY ww10_XsOF ww11_asH0 ww12_asH1 ww13_asH3 ->
ww10_XsOF
ww5_XsOk
(\ s'_atrU ->
case s'_atrU of { I# x_asSR -> ww6_XsOm (I# (+# x_asSR 1#)) })
}
} } in
ww_sulf
ww2_sulk
(\ arr_as7R ->
ww_sulf
lvl13_stmL
(\ index_as7S ->
ww1_sulg
(case w1_sul7 of { C:PrimMonad ww4_asHR ww5_asHS ->
case arr_as7R of { MutableByteArray ww7_asHW ->
case index_as7S of { I# ww9_asI4 ->
ww5_asHS
(\ s#_atkH ->
case w2_sul8 of { I8# x#_atqk ->
case writeInt8Array# ww7_asHW ww9_asI4 x#_atqk s#_atkH of s'#_atkI
{ __DEFAULT ->
(# s'#_atkI, () #)
}
})
}
}
})
lvl14_stmN))
-- RHS size: {terms: 18, types: 82, coercions: 0, joins: 0/0}
write8
write8
= \ @ m_sul4 w_sul5 w1_sul6 w2_sul7 w3_sul8 ->
case w_sul5 of
{ C:MonadReader ww1_sulb ww2_sulk ww3_sull ww4_sulm ->
case ww1_sulb of
{ C:Monad ww6_sule ww7_sulf ww8_sulg ww9_sulh ww10_suli ->
$wwrite8 ww7_sulf ww8_sulg ww2_sulk w1_sul6 w2_sul7 w3_sul8
}
}
-- RHS size: {terms: 72, types: 161, coercions: 0, joins: 0/3}
$wwriteBE16
$wwriteBE16
= \ @ m_sulx ww_sulI ww1_sulJ ww2_sulN w_sulz w1_sulA w2_sulB ->
let {
lvl13_stmB
lvl13_stmB = get w_sulz } in
let {
lvl14_stmC
lvl14_stmC
= case w2_sulB of { I16# x#_afXv ->
I16#
(narrow16Int#
(word2Int#
(narrow16Word# (byteSwap16# (narrow16Word# (int2Word# x#_afXv))))))
} } in
let {
lvl15_stmE
lvl15_stmE
= case w_sulz of
{ C:MonadState ww4_XsNQ ww5_XsNS ww6_XsNU ww7_asGO ->
case ww4_XsNQ of
{ C:Monad ww9_asGY ww10_XsOd ww11_asH0 ww12_asH1 ww13_asH3 ->
ww10_XsOd
ww5_XsNS
(\ s'_atrU ->
case s'_atrU of { I# x_asSR -> ww6_XsNU (I# (+# x_asSR 2#)) })
}
} } in
ww_sulI
ww2_sulN
(\ arr_as7U ->
ww_sulI
lvl13_stmB
(\ index_as7V ->
ww1_sulJ
(case w1_sulA of { C:PrimMonad ww4_asHR ww5_asHS ->
case arr_as7U of { MutableByteArray ww7_asHW ->
case index_as7V of { I# ww9_asI4 ->
ww5_asHS
(\ s#_atkH ->
case lvl14_stmC of { I16# w3_atpU ->
case writeWord8ArrayAsInt16# ww7_asHW ww9_asI4 w3_atpU s#_atkH
of s'#_atkI
{ __DEFAULT ->
(# s'#_atkI, () #)
}
})
}
}
})
lvl15_stmE))
-- RHS size: {terms: 18, types: 82, coercions: 0, joins: 0/0}
writeBE16
writeBE16
= \ @ m_sulx w_suly w1_sulz w2_sulA w3_sulB ->
case w_suly of
{ C:MonadReader ww1_sulE ww2_sulN ww3_sulO ww4_sulP ->
case ww1_sulE of
{ C:Monad ww6_sulH ww7_sulI ww8_sulJ ww9_sulK ww10_sulL ->
$wwriteBE16 ww7_sulI ww8_sulJ ww2_sulN w1_sulz w2_sulA w3_sulB
}
}
-- RHS size: {terms: 72, types: 161, coercions: 0, joins: 0/3}
$wwriteBE32
$wwriteBE32
= \ @ m_sum0 ww_sumb ww1_sumc ww2_sumg w_sum2 w1_sum3 w2_sum4 ->
let {
lvl13_stmq
lvl13_stmq = get w_sum2 } in
let {
lvl14_stmr
lvl14_stmr
= case w2_sum4 of { I32# x#_afXj ->
I32#
(narrow32Int#
(word2Int#
(narrow32Word# (byteSwap32# (narrow32Word# (int2Word# x#_afXj))))))
} } in
let {
lvl15_stmt
lvl15_stmt
= case w_sum2 of
{ C:MonadState ww4_XsNo ww5_XsNq ww6_XsNs ww7_asGO ->
case ww4_XsNo of
{ C:Monad ww9_asGY ww10_XsNL ww11_asH0 ww12_asH1 ww13_asH3 ->
ww10_XsNL
ww5_XsNq
(\ s'_atrU ->
case s'_atrU of { I# x_asSR -> ww6_XsNs (I# (+# x_asSR 4#)) })
}
} } in
ww_sumb
ww2_sumg
(\ arr_as7X ->
ww_sumb
lvl13_stmq
(\ index_as7Y ->
ww1_sumc
(case w1_sum3 of { C:PrimMonad ww4_asHR ww5_asHS ->
case arr_as7X of { MutableByteArray ww7_asHW ->
case index_as7Y of { I# ww9_asI4 ->
ww5_asHS
(\ s#_atkH ->
case lvl14_stmr of { I32# w3_atpC ->
case writeWord8ArrayAsInt32# ww7_asHW ww9_asI4 w3_atpC s#_atkH
of s'#_atkI
{ __DEFAULT ->
(# s'#_atkI, () #)
}
})
}
}
})
lvl15_stmt))
-- RHS size: {terms: 18, types: 82, coercions: 0, joins: 0/0}
writeBE32
writeBE32
= \ @ m_sum0 w_sum1 w1_sum2 w2_sum3 w3_sum4 ->
case w_sum1 of
{ C:MonadReader ww1_sum7 ww2_sumg ww3_sumh ww4_sumi ->
case ww1_sum7 of
{ C:Monad ww6_suma ww7_sumb ww8_sumc ww9_sumd ww10_sume ->
$wwriteBE32 ww7_sumb ww8_sumc ww2_sumg w1_sum2 w2_sum3 w3_sum4
}
}
-- RHS size: {terms: 69, types: 161, coercions: 0, joins: 0/3}
$wwriteBE64
$wwriteBE64
= \ @ m_sumt ww_sumE ww1_sumF ww2_sumJ w_sumv w1_sumw w2_sumx ->
let {
lvl13_stmf
lvl13_stmf = get w_sumv } in
let {
lvl14_stmg
lvl14_stmg
= case w2_sumx of { I64# x#_afX9 ->
I64# (word2Int# (byteSwap# (int2Word# x#_afX9)))
} } in
let {
lvl15_stmi
lvl15_stmi
= case w_sumv of
{ C:MonadState ww4_XsMW ww5_XsMY ww6_XsN0 ww7_asGO ->
case ww4_XsMW of
{ C:Monad ww9_asGY ww10_XsNj ww11_asH0 ww12_asH1 ww13_asH3 ->
ww10_XsNj
ww5_XsMY
(\ s'_atrU ->
case s'_atrU of { I# x_asSR -> ww6_XsN0 (I# (+# x_asSR 8#)) })
}
} } in
ww_sumE
ww2_sumJ
(\ arr_as80 ->
ww_sumE
lvl13_stmf
(\ index_as81 ->
ww1_sumF
(case w1_sumw of { C:PrimMonad ww4_asHR ww5_asHS ->
case arr_as80 of { MutableByteArray ww7_asHW ->
case index_as81 of { I# ww9_asI4 ->
ww5_asHS
(\ s#_atkH ->
case lvl14_stmg of { I64# w3_atpk ->
case writeWord8ArrayAsInt# ww7_asHW ww9_asI4 w3_atpk s#_atkH
of s'#_atkI
{ __DEFAULT ->
(# s'#_atkI, () #)
}
})
}
}
})
lvl15_stmi))
-- RHS size: {terms: 18, types: 82, coercions: 0, joins: 0/0}
writeBE64
writeBE64
= \ @ m_sumt w_sumu w1_sumv w2_sumw w3_sumx ->
case w_sumu of
{ C:MonadReader ww1_sumA ww2_sumJ ww3_sumK ww4_sumL ->
case ww1_sumA of
{ C:Monad ww6_sumD ww7_sumE ww8_sumF ww9_sumG ww10_sumH ->
$wwriteBE64 ww7_sumE ww8_sumF ww2_sumJ w1_sumv w2_sumw w3_sumx
}
}
-- RHS size: {terms: 319, types: 474, coercions: 1,050, joins: 6/6}
$wproduceRequestRecordBatchMetadata
$wproduceRequestRecordBatchMetadata
= \ ww_sun8 ww1_sunc ww2_sung ->
case runRW#
(\ s1_asVO ->
case newByteArray# 40# (s1_asVO `cast` <Co:4>) of
{ (# ipv_ajvN, ipv1_ajvO #) ->
case writeWord8ArrayAsInt16#
(ipv1_ajvO `cast` <Co:70>)
0#
(narrow16Int# (word2Int# (narrow16Word# (byteSwap16# 0##))))
(ipv_ajvN `cast` <Co:20>)
of s'#_atkI
{ __DEFAULT ->
case writeWord8ArrayAsInt32#
(ipv1_ajvO `cast` <Co:70>)
2#
(narrow32Int#
(word2Int#
(narrow32Word#
(byteSwap32#
(narrow32Word# (int2Word# (narrow32Int# (-# ww1_sunc 1#))))))))
s'#_atkI
of s'#1_XtnN
{ __DEFAULT ->
case writeWord8ArrayAsInt#
(ipv1_ajvO `cast` <Co:70>) 6# (word2Int# (byteSwap# 0##)) s'#1_XtnN
of s'#2_XtnZ
{ __DEFAULT ->
case writeWord8ArrayAsInt#
(ipv1_ajvO `cast` <Co:70>)
14#
(word2Int# (byteSwap# 0##))
s'#2_XtnZ
of s'#3_Xtob
{ __DEFAULT ->
case writeWord8ArrayAsInt#
(ipv1_ajvO `cast` <Co:70>)
22#
(word2Int# (byteSwap# 18446744073709551615##))
s'#3_Xtob
of s'#4_Xton
{ __DEFAULT ->
case writeWord8ArrayAsInt16#
(ipv1_ajvO `cast` <Co:70>)
30#
(narrow16Int# (word2Int# (narrow16Word# (byteSwap16# 65535##))))
s'#4_Xton
of s'#5_Xtoz
{ __DEFAULT ->
case writeWord8ArrayAsInt32#
(ipv1_ajvO `cast` <Co:70>)
32#
(narrow32Int#
(word2Int# (narrow32Word# (byteSwap32# 4294967295##))))
s'#5_Xtoz
of s'#6_XtoL
{ __DEFAULT ->
case writeWord8ArrayAsInt32#
(ipv1_ajvO `cast` <Co:70>)
36#
(narrow32Int#
(word2Int#
(narrow32Word#
(byteSwap32#
(narrow32Word# (int2Word# (narrow32Int# ww1_sunc)))))))
s'#6_XtoL
of s'#7_XtoY
{ __DEFAULT ->
case unsafeFreezeByteArray# ipv1_ajvO (s'#7_XtoY `cast` <Co:32>) of
{ (# ipv2_ajF3, ipv3_ajF4 #) ->
(# ipv2_ajF3, ByteArray ipv3_ajF4 #) `cast` <Co:14>
}
}
}
}
}
}
}
}
}
})
of
{ (# ipv_asKE, ipv1_asKF #) ->
case ipv1_asKF of { ByteArray ww4_sumQ ->
case runRW#
(\ s1_XsYv ->
case newByteArray# 21# (s1_XsYv `cast` <Co:4>) of
{ (# ipv2_ajvN, ipv3_ajvO #) ->
case writeWord8ArrayAsInt#
(ipv3_ajvO `cast` <Co:70>)
0#
(word2Int# (byteSwap# 0##))
(ipv2_ajvN `cast` <Co:20>)
of s'#_atkI
{ __DEFAULT ->
case writeWord8ArrayAsInt32#
(ipv3_ajvO `cast` <Co:70>)
8#
(narrow32Int#
(word2Int#
(narrow32Word#
(byteSwap32#
(narrow32Word#
(int2Word#
(narrow32Int# (+# 49# (narrow32Int# ww2_sung)))))))))
s'#_atkI
of s'#1_XtnO
{ __DEFAULT ->
case writeWord8ArrayAsInt32#
(ipv3_ajvO `cast` <Co:70>)
12#
(narrow32Int# (word2Int# (narrow32Word# (byteSwap32# 0##))))
s'#1_XtnO
of s'#2_Xto0
{ __DEFAULT ->
case writeInt8Array# (ipv3_ajvO `cast` <Co:70>) 16# 2# s'#2_Xto0
of s'#3_Xto8
{ __DEFAULT ->
join {
exit_X2i
exit_X2i ww6_asLu
= join {
exit1_X2j
exit1_X2j ww5_asKR
= case writeWord8ArrayAsInt32#
(ipv3_ajvO `cast` <Co:70>)
17#
(narrow32Int#
(word2Int#
(narrow32Word#
(byteSwap32#
(narrow32Word#
(int2Word#
(narrow32Int# (word2Int# ww5_asKR))))))))
s'#3_Xto8
of s'#4_Xtoo
{ __DEFAULT ->
case unsafeFreezeByteArray# ipv3_ajvO (s'#4_Xtoo `cast` <Co:32>) of
{ (# ipv4_ajF3, ipv5_ajF4 #) ->
(# ipv4_ajF3, ByteArray ipv5_ajF4 #) `cast` <Co:14>
}
} } in
joinrec {
$wgo_asKQ
$wgo_asKQ ww5_asKR ww7_asKS ww8_asKT
= case <# ww7_asKS ww8_asKT of {
__DEFAULT -> jump exit1_X2j ww5_asKR;
1# ->
case indexByteArrayArray# ww_sun8 ww7_asKS of wild_asKZ
{ __DEFAULT ->
join {
exit2_X2p
exit2_X2p ww9_asL1
= jump $wgo_asKQ
(xor# 4294967295## ww9_asL1) (+# ww7_asKS 1#) ww8_asKT } in
joinrec {
$wgo1_asL0
$wgo1_asL0 ww9_asL1 ww10_asL2 ww11_asL3
= case <# ww10_asL2 ww11_asL3 of {
__DEFAULT -> jump exit2_X2p ww9_asL1;
1# ->
case indexWord8Array# wild_asKZ ww10_asL2 of wild1_asL5
{ __DEFAULT ->
case indexWord32OffAddr#
table1
(word2Int#
(xor# (narrow8Word# ww9_asL1) wild1_asL5))
of wild2_asLk
{ __DEFAULT ->
jump $wgo1_asL0
(xor# wild2_asLk (uncheckedShiftRL# ww9_asL1 8#))
(+# ww10_asL2 1#)
ww11_asL3
}
}
}; } in
jump $wgo1_asL0
(xor# ww5_asKR 4294967295##) 0# (sizeofByteArray# wild_asKZ)
}
}; } in
jump $wgo_asKQ
(xor# 4294967295## ww6_asLu) 0# (*# 3# ww1_sunc) } in
joinrec {
$wgo_asLt
$wgo_asLt ww6_asLu ww7_asLv ww8_asLw
= case <# ww7_asLv ww8_asLw of {
__DEFAULT -> jump exit_X2i ww6_asLu;
1# ->
case indexWord8Array# ww4_sumQ ww7_asLv of wild_asLC { __DEFAULT ->
case indexWord32OffAddr#
table1 (word2Int# (xor# (narrow8Word# ww6_asLu) wild_asLC))
of wild1_asLD
{ __DEFAULT ->
jump $wgo_asLt
(xor# wild1_asLD (uncheckedShiftRL# ww6_asLu 8#))
(+# ww7_asLv 1#)
ww8_asLw
}
}
}; } in
jump $wgo_asLt 4294967295## 0# 40#
}
}
}
}
})
of
{ (# ipv2_XsNo, ipv3_XsNq #) ->
case ipv3_XsNq of { ByteArray ww6_agfA ->
$w$c<> ww6_agfA ww4_sumQ
}
}
}
}
-- RHS size: {terms: 16, types: 11, coercions: 0, joins: 0/0}
produceRequestRecordBatchMetadata
produceRequestRecordBatchMetadata
= \ w_sun3 w1_sun4 w2_sun5 ->
case w_sun3 of { UnliftedArray ww1_sun8 ->
case w1_sun4 of { I# ww3_sunc ->
case w2_sun5 of { I# ww5_sung ->
$wproduceRequestRecordBatchMetadata ww1_sun8 ww3_sunc ww5_sung
}
}
}
-- RHS size: {terms: 67, types: 144, coercions: 0, joins: 0/2}
$wwriteArray
$wwriteArray
= \ @ m_sunr
ww_sunD
ww1_sunE
ww2_sunI
w_sunt
w1_sunu
w2_sunv
w3_sunw ->
let {
lvl13_stm6
lvl13_stm6 = get w_sunt } in
let {
lvl14_stm7
lvl14_stm7
= case w_sunt of
{ C:MonadState ww4_asGL ww5_asGM ww6_asGN ww7_asGO ->
case ww4_asGL of
{ C:Monad ww9_asGY ww10_asGZ ww11_asH0 ww12_asH1 ww13_asH3 ->
ww10_asGZ
ww5_asGM
(\ s'_atrU ->
case s'_atrU of { I# x_asSR ->
case w3_sunw of { I# y_asSV -> ww6_asGN (I# (+# x_asSR y_asSV)) }
})
}
} } in
ww_sunD
ww2_sunI
(\ arr_as84 ->
ww_sunD
lvl13_stm6
(\ index_as85 ->
ww1_sunE
(case arr_as84 of { MutableByteArray dst#_asGl ->
case w2_sunv of { ByteArray src#_asGp ->
primitive
w1_sunu
(\ s#_asGr ->
case w3_sunw of { I# n#_asGu ->
case index_as85 of { I# n#1_asGy ->
case copyByteArray# src#_asGp 0# dst#_asGl n#1_asGy n#_asGu s#_asGr
of s'#_asGE
{ __DEFAULT ->
(# s'#_asGE, () #)
}
}
})
}
})
lvl14_stm7))
-- RHS size: {terms: 20, types: 83, coercions: 0, joins: 0/0}
writeArray
writeArray
= \ @ m_sunr w_suns w1_sunt w2_sunu w3_sunv w4_sunw ->
case w_suns of
{ C:MonadReader ww1_sunz ww2_sunI ww3_sunJ ww4_sunK ->
case ww1_sunz of
{ C:Monad ww6_sunC ww7_sunD ww8_sunE ww9_sunF ww10_sunG ->
$wwriteArray
ww7_sunD ww8_sunE ww2_sunI w1_sunt w2_sunu w3_sunv w4_sunw
}
}
-- RHS size: {terms: 2, types: 0, coercions: 0, joins: 0/0}
makeRecordMetadata1
makeRecordMetadata1 = $wzigzag -1#
-- RHS size: {terms: 2, types: 0, coercions: 0, joins: 0/0}
makeRecordMetadata2
makeRecordMetadata2 = $wzigzag 0#
-- RHS size: {terms: 2, types: 0, coercions: 0, joins: 0/0}
makeRecordMetadata4
makeRecordMetadata4 = W8# 0##
-- RHS size: {terms: 3, types: 2, coercions: 0, joins: 0/0}
makeRecordMetadata_xs
makeRecordMetadata_xs = : makeRecordMetadata4 []
-- RHS size: {terms: 8, types: 2, coercions: 0, joins: 0/0}
makeRecordMetadata3
makeRecordMetadata3
= case $wlenAcc makeRecordMetadata_xs 0# of ww2_af6s { __DEFAULT ->
$w$sbyteArrayFromListN ww2_af6s makeRecordMetadata_xs
}
Rec {
-- RHS size: {terms: 12, types: 7, coercions: 0, joins: 0/0}
makeRecordMetadata_$sgo
makeRecordMetadata_$sgo
= \ sc_suX9 sc1_suXa ->
case sc_suX9 of { ByteArray ww1_agfA ->
case go_rvaU sc1_suXa of { ByteArray ww3_agfF ->
$w$c<> ww1_agfA ww3_agfF
}
}
-- RHS size: {terms: 16, types: 11, coercions: 0, joins: 0/0}
go_rvaU
go_rvaU
= \ ds_asSv ->
case ds_asSv of {
[] -> emptyByteArray;
: y_asSA ys_asSB ->
case y_asSA of { ByteArray ww1_agfA ->
case go_rvaU ys_asSB of { ByteArray ww3_agfF ->
$w$c<> ww1_agfA ww3_agfF
}
}
}
end Rec }
-- RHS size: {terms: 77, types: 19, coercions: 0, joins: 0/2}
$wmakeRecordMetadata
$wmakeRecordMetadata
= \ w_sunO ww_sunS ->
case makeRecordMetadata_$sgo
makeRecordMetadata3
(: makeRecordMetadata2
(: (case w_sunO of { I# ww2_srya -> $wzigzag ww2_srya })
(: makeRecordMetadata1
(: (let {
ww1_XrDF
ww1_XrDF = sizeofByteArray# ww_sunS } in
case >=# ww1_XrDF 0# of {
__DEFAULT -> varint (I# (-# (*# (negateInt# ww1_XrDF) 2#) 1#));
1# -> varint (I# (*# ww1_XrDF 2#))
})
[]))))
of
{ ByteArray arr#_af8z ->
let {
ww1_XrDL
ww1_XrDL
= +#
(+# (sizeofByteArray# arr#_af8z) (sizeofByteArray# ww_sunS))
1# } in
case >=# ww1_XrDL 0# of {
__DEFAULT ->
case varint (I# (-# (*# (negateInt# ww1_XrDL) 2#) 1#)) of
{ ByteArray ww3_agfA ->
$w$c<> ww3_agfA arr#_af8z
};
1# ->
case varint (I# (*# ww1_XrDL 2#)) of { ByteArray ww3_agfA ->
$w$c<> ww3_agfA arr#_af8z
}
}
}
-- RHS size: {terms: 8, types: 4, coercions: 0, joins: 0/0}
makeRecordMetadata
makeRecordMetadata
= \ w_sunO w1_sunP ->
case w1_sunP of { ByteArray ww1_sunS ->
$wmakeRecordMetadata w_sunO ww1_sunS
}
-- RHS size: {terms: 2, types: 0, coercions: 0, joins: 0/0}
magic
magic = I8# 2#
-- RHS size: {terms: 2, types: 0, coercions: 0, joins: 0/0}
correlationId
correlationId = I32# 48879#
-- RHS size: {terms: 1, types: 0, coercions: 0, joins: 0/0}
clientId_addr#
clientId_addr# = "ruko"#
-- RHS size: {terms: 17, types: 28, coercions: 0, joins: 0/0}
clientId
clientId
= case newMutVar# NoFinalizers realWorld# of
{ (# ipv_atP0, ipv1_atP1 #) ->
case {__pkg_ccall bytestring-0.10.8.2 Addr#
-> State# RealWorld -> (# State# RealWorld, Word# #)}_atOZ
clientId_addr# ipv_atP0
of
{ (# ds_atP5, ds2_atP6 #) ->
PS
clientId_addr# (PlainForeignPtr ipv1_atP1) 0# (word2Int# ds2_atP6)
}
}
-- RHS size: {terms: 5, types: 5, coercions: 0, joins: 0/0}
clientIdLength
clientIdLength
= case clientId of { PS dt_asLN dt1_asLO dt2_asLP dt3_asLQ ->
I# dt3_asLQ
}
-- RHS size: {terms: 8, types: 5, coercions: 0, joins: 0/0}
makeRequestMetadata1
makeRequestMetadata1
= case clientId of { PS ww1_sgI9 ww2_sgIa ww3_sgIb ww4_sgIc ->
$wfromByteString ww1_sgI9 ww2_sgIa ww3_sgIb ww4_sgIc
}
-- RHS size: {terms: 6, types: 5, coercions: 0, joins: 0/0}
makeRequestMetadata2
makeRequestMetadata2
= case clientId of { PS dt_asLN dt1_asLO dt2_asLP dt3_asLQ ->
I16# (narrow16Int# dt3_asLQ)
}
-- RHS size: {terms: 2, types: 0, coercions: 0, joins: 0/0}
produceApiVersion
produceApiVersion = I16# 7#
-- RHS size: {terms: 2, types: 0, coercions: 0, joins: 0/0}
produceApiKey
produceApiKey = I16# 0#
-- RHS size: {terms: 253, types: 359, coercions: 1,454, joins: 0/9}
$wmakeRequestMetadata
$wmakeRequestMetadata
= \ ww_suo0 ww1_suo4 ww2_suob ->
case runRW#
(\ s1_asVO ->
case clientId of { PS dt_asLN dt1_asLO dt2_asLP dt3_asLQ ->
let {
y_Xt95
y_Xt95 = sizeofByteArray# ww2_suob } in
case newByteArray#
(+# 40# (+# y_Xt95 dt3_asLQ)) (s1_asVO `cast` <Co:19>)
of
{ (# ipv_ajvN, ipv1_ajvO #) ->
case writeWord8ArrayAsInt32#
(ipv1_ajvO `cast` <Co:90>)
0#
(narrow32Int#
(word2Int#
(narrow32Word#
(byteSwap32#
(narrow32Word#
(int2Word#
(narrow32Int#
(+# 36# (+# ww_suo0 (+# y_Xt95 dt3_asLQ))))))))))
(ipv_ajvN `cast` <Co:39>)
of s'#_atkI
{ __DEFAULT ->
case writeWord8ArrayAsInt16#
(ipv1_ajvO `cast` <Co:90>)
4#
(narrow16Int# (word2Int# (narrow16Word# (byteSwap16# 0##))))
s'#_atkI
of s'#1_Xtou
{ __DEFAULT ->
case writeWord8ArrayAsInt16#
(ipv1_ajvO `cast` <Co:90>)
6#
(narrow16Int# (word2Int# (narrow16Word# (byteSwap16# 7##))))
s'#1_Xtou
of s'#2_XtoG
{ __DEFAULT ->
case writeWord8ArrayAsInt32#
(ipv1_ajvO `cast` <Co:90>)
8#
(narrow32Int# (word2Int# (narrow32Word# (byteSwap32# 48879##))))
s'#2_XtoG
of s'#3_XtoS
{ __DEFAULT ->
case makeRequestMetadata2 of { I16# x#_Xg1S ->
case writeWord8ArrayAsInt16#
(ipv1_ajvO `cast` <Co:90>)
12#
(narrow16Int#
(word2Int#
(narrow16Word# (byteSwap16# (narrow16Word# (int2Word# x#_Xg1S))))))
s'#3_XtoS
of s'#4_Xtp8
{ __DEFAULT ->
case makeRequestMetadata1 of { ByteArray src#_asGp ->
case copyByteArray#
src#_asGp 0# (ipv1_ajvO `cast` <Co:90>) 14# dt3_asLQ s'#4_Xtp8
of s'#5_asGE
{ __DEFAULT ->
let {
ipv2_stzx
ipv2_stzx = +# 14# dt3_asLQ } in
case writeWord8ArrayAsInt16#
(ipv1_ajvO `cast` <Co:90>)
ipv2_stzx
(narrow16Int# (word2Int# (narrow16Word# (byteSwap16# 65535##))))
s'#5_asGE
of s'#6_XtpD
{ __DEFAULT ->
let {
ipv3_stzA
ipv3_stzA = +# ipv2_stzx 2# } in
case writeWord8ArrayAsInt16#
(ipv1_ajvO `cast` <Co:90>)
ipv3_stzA
(narrow16Int# (word2Int# (narrow16Word# (byteSwap16# 1##))))
s'#6_XtpD
of s'#7_XtpQ
{ __DEFAULT ->
let {
ipv4_stzD
ipv4_stzD = +# ipv3_stzA 2# } in
case writeWord8ArrayAsInt32#
(ipv1_ajvO `cast` <Co:90>)
ipv4_stzD
(narrow32Int#
(word2Int#
(narrow32Word#
(byteSwap32#
(narrow32Word# (int2Word# (narrow32Int# ww1_suo4)))))))
s'#7_XtpQ
of s'#8_Xtq8
{ __DEFAULT ->
let {
ipv5_stzH
ipv5_stzH = +# ipv4_stzD 4# } in
case writeWord8ArrayAsInt32#
(ipv1_ajvO `cast` <Co:90>)
ipv5_stzH
(narrow32Int# (word2Int# (narrow32Word# (byteSwap32# 1##))))
s'#8_Xtq8
of s'#9_Xtql
{ __DEFAULT ->
let {
ipv6_stzK
ipv6_stzK = +# ipv5_stzH 4# } in
case writeWord8ArrayAsInt16#
(ipv1_ajvO `cast` <Co:90>)
ipv6_stzK
(narrow16Int#
(word2Int#
(narrow16Word#
(byteSwap16# (narrow16Word# (int2Word# (narrow16Int# y_Xt95)))))))
s'#9_Xtql
of s'#10_XtqA
{ __DEFAULT ->
let {
ipv7_stzN
ipv7_stzN = +# ipv6_stzK 2# } in
case copyByteArray#
ww2_suob 0# (ipv1_ajvO `cast` <Co:90>) ipv7_stzN y_Xt95 s'#10_XtqA
of s'#11_XsML
{ __DEFAULT ->
let {
ipv8_stzQ
ipv8_stzQ = +# ipv7_stzN y_Xt95 } in
case writeWord8ArrayAsInt32#
(ipv1_ajvO `cast` <Co:90>)
ipv8_stzQ
(narrow32Int# (word2Int# (narrow32Word# (byteSwap32# 1##))))
s'#11_XsML
of s'#12_Xtr2
{ __DEFAULT ->
let {
ipv9_stzT
ipv9_stzT = +# ipv8_stzQ 4# } in
case writeWord8ArrayAsInt32#
(ipv1_ajvO `cast` <Co:90>)
ipv9_stzT
(narrow32Int# (word2Int# (narrow32Word# (byteSwap32# 0##))))
s'#12_Xtr2
of s'#13_Xtrf
{ __DEFAULT ->
case writeWord8ArrayAsInt32#
(ipv1_ajvO `cast` <Co:90>)
(+# ipv9_stzT 4#)
(narrow32Int#
(word2Int#
(narrow32Word#
(byteSwap32# (narrow32Word# (int2Word# (narrow32Int# ww_suo0)))))))
s'#13_Xtrf
of s'#14_Xtrt
{ __DEFAULT ->
case unsafeFreezeByteArray# ipv1_ajvO (s'#14_Xtrt `cast` <Co:32>)
of
{ (# ipv10_ajF3, ipv11_ajF4 #) ->
(# ipv10_ajF3, ByteArray ipv11_ajF4 #) `cast` <Co:14>
}
}
}
}
}
}
}
}
}
}
}
}
}
}
}
}
}
}
}
})
of
{ (# ipv_asKE, ipv1_asKF #) ->
ipv1_asKF
}
-- RHS size: {terms: 19, types: 14, coercions: 0, joins: 0/0}
makeRequestMetadata
makeRequestMetadata
= \ w_sunV w1_sunW w2_sunX ->
case w_sunV of { I# ww1_suo0 ->
case w1_sunW of { I# ww3_suo4 ->
case w2_sunX of { Topic ww5_suo8 ww6_suod ww7_suoe ->
case ww5_suo8 of { ByteArray ww9_suob ->
$wmakeRequestMetadata ww1_suo0 ww3_suo4 ww9_suob
}
}
}
}
-- RHS size: {terms: 321, types: 321, coercions: 299, joins: 6/13}
$wproduceRequest
$wproduceRequest
= \ ww_suph ww1_supo ww2_supv ->
case runRW#
(\ s_asMb ->
let {
y_arqV
y_arqV = sizeofArrayArray# ww2_supv } in
let {
i#_asNm
i#_asNm = +# (*# 3# y_arqV) 2# } in
case newArrayArray# i#_asNm (s_asMb `cast` <Co:20>) of
{ (# ipv_asNr, ipv1_asNs #) ->
let {
ww3_sup9
ww3_sup9 = -# i#_asNm 1# } in
join {
$w$j_sup4
$w$j_sup4 w_sup2
= case runRW#
(\ s1_XsP7 ->
let {
i#1_XsQk
i#1_XsQk = *# 3# y_arqV } in
case newArrayArray# i#1_XsQk (s1_XsP7 `cast` <Co:20>) of
{ (# ipv2_XsQt, ipv3_XsQv #) ->
let {
ww4_suoz
ww4_suoz = -# i#1_XsQk 1# } in
join {
$w$j1_suou
$w$j1_suou w1_suos
= join {
exit_X2h
exit_X2h w2_suom
= unsafeFreezeArrayArray#
(ipv3_XsQv `cast` <Co:18>) w2_suom } in
case <# 0# y_arqV of {
__DEFAULT -> jump exit_X2h w1_suos;
1# ->
case indexByteArrayArray# ww2_supv 0# of wild_agl1
{ __DEFAULT ->
case $wmakeRecordMetadata produceRequest2 wild_agl1 of
{ ByteArray x_asYX ->
case writeByteArrayArray#
ipv3_XsQv 0# x_asYX (w1_suos `cast` <Co:16>)
of s'#_asMG
{ __DEFAULT ->
case writeByteArrayArray# ipv3_XsQv 1# wild_agl1 s'#_asMG
of s'#1_XsVL
{ __DEFAULT ->
case produceRequest_zero of { ByteArray x1_Xt8a ->
case writeByteArrayArray# ipv3_XsQv 2# x1_Xt8a s'#1_XsVL
of s'#2_XsVW
{ __DEFAULT ->
joinrec {
$wgo_suor
$wgo_suor ww5_XurU w2_XurS
= case <# ww5_XurU y_arqV of {
__DEFAULT -> jump exit_X2h w2_XurS;
1# ->
case indexByteArrayArray# ww2_supv ww5_XurU
of wild3_XgoB
{ __DEFAULT ->
case $wmakeRecordMetadata
(I# ww5_XurU) wild3_XgoB
of
{ ByteArray x2_Xt2C ->
case writeByteArrayArray#
ipv3_XsQv
(*# ww5_XurU 3#)
x2_Xt2C
(w2_XurS `cast` <Co:16>)
of s'#3_XsQn
{ __DEFAULT ->
case writeByteArrayArray#
ipv3_XsQv
(+# (*# ww5_XurU 3#) 1#)
wild3_XgoB
s'#3_XsQn
of s'#4_XsZv
{ __DEFAULT ->
case writeByteArrayArray#
ipv3_XsQv
(+# (*# ww5_XurU 3#) 2#)
x1_Xt8a
s'#4_XsZv
of s'#5_XsZK
{ __DEFAULT ->
jump $wgo_suor
(+# ww5_XurU 1#) (s'#5_XsZK `cast` <Co:15>)
}
}
}
}
}
}; } in
jump $wgo_suor 1# (s'#2_XsVW `cast` <Co:15>)
}
}
}
}
}
}
} } in
case <# ww4_suoz 0# of {
__DEFAULT ->
case produceRequest_zero of { ByteArray x_asYX ->
case writeByteArrayArray# ipv3_XsQv ww4_suoz x_asYX ipv2_XsQt
of s'#_asNM
{ __DEFAULT ->
joinrec {
$wloop_suoB
$wloop_suoB ww5_XurQ w1_XurO
= case <# ww5_XurQ 0# of {
__DEFAULT ->
case writeByteArrayArray#
ipv3_XsQv
ww5_XurQ
x_asYX
(w1_XurO `cast` <Co:16>)
of s'#1_XsR9
{ __DEFAULT ->
jump $wloop_suoB
(-# ww5_XurQ 1#) (s'#1_XsR9 `cast` <Co:15>)
};
1# -> jump $w$j1_suou w1_XurO
}; } in
jump $wloop_suoB (-# ww4_suoz 1#) (s'#_asNM `cast` <Co:15>)
}
};
1# -> jump $w$j1_suou (ipv2_XsQt `cast` <Co:19>)
}
})
of
{ (# ipv2_asMn, ipv3_asMo #) ->
let {
ipv4_stbu
ipv4_stbu = sizeofArrayArray# ipv3_asMo } in
letrec {
$wgo_suoO
$wgo_suoO
= \ ww4_suoJ ->
case ># ipv4_stbu ww4_suoJ of {
__DEFAULT -> 0#;
1# ->
case $wgo_suoO (+# ww4_suoJ 1#) of ww5_suoN { __DEFAULT ->
case indexByteArrayArray# ipv3_asMo ww4_suoJ of wild_agl1
{ __DEFAULT ->
+# ww5_suoN (sizeofByteArray# wild_agl1)
}
}
}; } in
case $wgo_suoO 0# of ww4_suoN { __DEFAULT ->
case $wproduceRequestRecordBatchMetadata ipv3_asMo y_arqV ww4_suoN
of
{ ByteArray ww6_suoR ->
case $wmakeRequestMetadata
(+# ww4_suoN (sizeofByteArray# ww6_suoR)) ww_suph ww1_supo
of
{ ByteArray x_asYX ->
case writeByteArrayArray#
ipv1_asNs 0# x_asYX (w_sup2 `cast` <Co:16>)
of s'#_asMG
{ __DEFAULT ->
case writeByteArrayArray# ipv1_asNs 1# ww6_suoR s'#_asMG
of s'#1_XsVr
{ __DEFAULT ->
case copyArrayArray#
ipv3_asMo 0# ipv1_asNs 2# (*# 3# y_arqV) s'#1_XsVr
of s'#2_asNb
{ __DEFAULT ->
unsafeFreezeArrayArray#
(ipv1_asNs `cast` <Co:18>) (s'#2_asNb `cast` <Co:15>)
}
}
}
}
}
}
} } in
case <# ww3_sup9 0# of {
__DEFAULT ->
case produceRequest_zero of { ByteArray x_asYX ->
case writeByteArrayArray# ipv1_asNs ww3_sup9 x_asYX ipv_asNr
of s'#_asNM
{ __DEFAULT ->
joinrec {
$wloop_supb
$wloop_supb ww4_Xusg w_Xuse
= case <# ww4_Xusg 0# of {
__DEFAULT ->
case writeByteArrayArray#
ipv1_asNs ww4_Xusg x_asYX (w_Xuse `cast` <Co:16>)
of s'#1_XsQZ
{ __DEFAULT ->
jump $wloop_supb (-# ww4_Xusg 1#) (s'#1_XsQZ `cast` <Co:15>)
};
1# -> jump $w$j_sup4 w_Xuse
}; } in
jump $wloop_supb (-# ww3_sup9 1#) (s'#_asNM `cast` <Co:15>)
}
};
1# -> jump $w$j_sup4 (ipv_asNr `cast` <Co:19>)
}
})
of
{ (# ipv_asMn, ipv1_asMo #) ->
ipv1_asMo
}
-- RHS size: {terms: 23, types: 18, coercions: 0, joins: 0/0}
produceRequest
produceRequest
= \ w_supc w1_supd w2_supe ->
case w_supc of { I# ww1_suph ->
case w1_supd of { Topic ww3_supl ww4_supq ww5_supr ->
case ww3_supl of { ByteArray ww7_supo ->
case w2_supe of { UnliftedArray ww9_supv ->
case $wproduceRequest ww1_suph ww7_supo ww9_supv of ww10_supz
{ __DEFAULT ->
UnliftedArray ww10_supz
}
}
}
}
}
-- RHS size: {terms: 1, types: 0, coercions: 0, joins: 0/0}
$trModule2
$trModule2 = "ProduceRequest"#
-- RHS size: {terms: 2, types: 0, coercions: 0, joins: 0/0}
$trModule1
$trModule1 = TrNameS $trModule2
-- RHS size: {terms: 1, types: 0, coercions: 0, joins: 0/0}
$trModule4
$trModule4 = "kafka-client-0.1.0.0-inplace"#
-- RHS size: {terms: 2, types: 0, coercions: 0, joins: 0/0}
$trModule3
$trModule3 = TrNameS $trModule4
-- RHS size: {terms: 3, types: 0, coercions: 0, joins: 0/0}
$trModule
$trModule = Module $trModule3 $trModule1
-- RHS size: {terms: 97, types: 99, coercions: 34, joins: 0/1}
$wsendProduceRequest
$wsendProduceRequest
= \ ww_supH ww1_supL w_supE ->
case manager of { Manager ipv_asF6 ipv1_asF7 ipv2_asF8 ->
let {
ipv4_stej
ipv4_stej
= -# 63# (word2Int# (clz# (int2Word# (+# ww_supH 1#)))) } in
case readArrayArrayArray# ipv_asF6 ipv4_stej w_supE of
{ (# ipv5_asFh, ipv6_asFi #) ->
case readArrayArrayArray#
(ipv6_asFi `cast` <Co:5>)
(+# 3# (*# 2# (-# ww_supH (uncheckedIShiftL# 1# ipv4_stej))))
ipv5_asFh
of
{ (# ipv7_asFn, ipv8_asFo #) ->
case readTVarIO# (ipv8_asFo `cast` <Co:6>) ipv7_asFn of
{ (# ipv11_atqK, ipv12_atqL #) ->
case ipv12_atqL `cast` <Co:1> of { W64# ipv13_atqP ->
case uncheckedShiftRL# ipv13_atqP 62# of {
__DEFAULT ->
$wsendManyLoop
ww_supH
(ipv8_asFo `cast` <Co:6>)
ipv13_atqP
ww1_supL
0#
(sizeofArrayArray# ww1_supL)
0#
ipv11_atqK;
0## ->
case atomically#
(\ s_atqS ->
case readTVar# (ipv8_asFo `cast` <Co:6>) s_atqS of
{ (# ipv3_atqV, ipv14_atqW #) ->
case ipv14_atqW `cast` <Co:1> of wild1_atqY { W64# x#_atr0 ->
case uncheckedShiftRL# x#_atr0 62# of {
__DEFAULT -> (# ipv3_atqV, wild1_atqY `cast` <Co:2> #);
0## -> case retry# ipv3_atqV of wild4_00 { }
}
}
})
ipv11_atqK
of
{ (# ipv10_asFt, ipv14_asFu #) ->
case ipv14_asFu `cast` <Co:1> of { W64# ww5_asRT ->
$wsendManyLoop
ww_supH
(ipv8_asFo `cast` <Co:6>)
ww5_asRT
ww1_supL
0#
(sizeofArrayArray# ww1_supL)
0#
ipv10_asFt
}
}
}
}
}
}
}
}
-- RHS size: {terms: 14, types: 12, coercions: 7, joins: 0/0}
sendProduceRequest1
sendProduceRequest1
= \ w_supB _ w2_supD w3_supE ->
case w_supB `cast` <Co:7> of { I32# ww1_supH ->
case w2_supD of { UnliftedArray ww3_supL ->
$wsendProduceRequest ww1_supH ww3_supL w3_supE
}
}
-- RHS size: {terms: 1, types: 0, coercions: 14, joins: 0/0}
sendProduceRequest
sendProduceRequest = sendProduceRequest1 `cast` <Co:14>
-- RHS size: {terms: 40, types: 133, coercions: 12, joins: 0/0}
$wrunByteArray
$wrunByteArray
= \ @ m_supW ww_suq6 ww1_suq7 ww2_suqb w_supY w1_supZ ->
ww_suq6
(case w_supY of { I# n#_ajvI ->
ww2_suqb
(\ s#_ajvK ->
case newByteArray# n#_ajvI s#_ajvK of
{ (# ipv_ajvN, ipv1_ajvO #) ->
(# ipv_ajvN, MutableByteArray ipv1_ajvO #)
})
})
(\ arr_as88 ->
ww1_suq7
((((w1_supZ `cast` <Co:8>) arr_as88) `cast` <Co:4>)
produceRequest2)
(case arr_as88 of { MutableByteArray arr#_ajEY ->
ww2_suqb
(\ s#_ajF0 ->
case unsafeFreezeByteArray# arr#_ajEY s#_ajF0 of
{ (# ipv_ajF3, ipv1_ajF4 #) ->
(# ipv_ajF3, ByteArray ipv1_ajF4 #)
})
}))
-- RHS size: {terms: 16, types: 71, coercions: 0, joins: 0/0}
runByteArray
runByteArray
= \ @ m_supW w_supX w1_supY w2_supZ ->
case w_supX of { C:PrimMonad ww1_suq2 ww2_suqb ->
case ww1_suq2 of
{ C:Monad ww4_suq5 ww5_suq6 ww6_suq7 ww7_suq8 ww8_suq9 ->
$wrunByteArray ww5_suq6 ww6_suq7 ww2_suqb w1_supY w2_supZ
}
}
-- RHS size: {terms: 29, types: 16, coercions: 0, joins: 0/2}
$sfoldrUnliftedArray
$sfoldrUnliftedArray
= \ @ b_Xf27 f_af27 z_af28 arr_af29 ->
case arr_af29 of { UnliftedArray aa#_af2e ->
let {
ipv_stkm
ipv_stkm = sizeofArrayArray# aa#_af2e } in
letrec {
$wgo_suqj
$wgo_suqj
= \ ww_suqh ->
case ># ipv_stkm ww_suqh of {
__DEFAULT -> z_af28;
1# ->
f_af27
($fPrimUnliftedByteArray_$cindexUnliftedArray# aa#_af2e ww_suqh)
($wgo_suqj (+# ww_suqh 1#))
}; } in
$wgo_suqj 0#
}
-- RHS size: {terms: 3, types: 1, coercions: 0, joins: 0/0}
sumSizes
sumSizes = $sfoldrUnliftedArray sumSizes1 produceRequest2
------ Local rules for imported ids --------
"SPEC/ProduceRequest foldrUnliftedArray @ ByteArray _"
forall @ b_af25 $dPrimUnlifted_stkf.
foldrUnliftedArray $dPrimUnlifted_stkf
= $sfoldrUnliftedArray
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment