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