Revision 084b2502 Ganeti/HTools/Luxi.hs
b/Ganeti/HTools/Luxi.hs | ||
---|---|---|
134 | 134 |
nbuf <- withTimeout queryTimeout "reading luxi response" $ |
135 | 135 |
S.recv (socket s) 4096 |
136 | 136 |
let (msg, rbuf) = break ((==) eOM) (obuf ++ nbuf) |
137 |
(if null msg
|
|
138 |
then _recv rbuf
|
|
137 |
(if null rbuf
|
|
138 |
then _recv msg
|
|
139 | 139 |
else return (msg, drop 1 rbuf)) |
140 | 140 |
cbuf <- readIORef $ rbuf s |
141 | 141 |
(msg, nbuf) <- _recv cbuf |
Also available in: Unified diff