2011-11-23 9 views
27

Haskell ve Thrift kullanarak basit bir Ping Pong yapmaya çalışıyorum. Ancak, sadece bir tekrarlama yapar ve sonra sıkışır. Problemin Haskell'den ziyade Thrift'in doğru kullanımında olduğunu varsayalım. Muhtemelen bir şey doğru şekilde temizlenmez. Bunu nasıl düzelteceğimiz konusunda eğitimli bir tahminde bulunmama yardımcı olabilecek Thrift'le deneyimi olan biri var mı?Haskell ve Thrift ile Ping Pong sıkışır

Sunucu:

echorequest :: TXT 
echorequest = TXT { 
    f_TXT_anytxt = Just "Ping" 
    } 

echoreply :: TXT 
echoreply = TXT { 
    f_TXT_anytxt = Just "Pong" 
    } 

serverFunc :: a -> (BinaryProtocol Handle, BinaryProtocol Handle) 
       -> IO Bool 
serverFunc a (h1,h2) = do 
    let t1 = getTransport h1 
    dat <- read_TXT h1 
-- the following two lines are only for debugging 
    putStrLn "Recieved data:" 
    print dat 
    write_TXT h1 echoreply 
    tFlush t1 
-- the following line is for debugging 
    putStrLn "Data written" 

    return False 


main :: IO() 
main = do 
    runBasicServer() serverFunc 4390 
    putStrLn "Server stopped" 

Müşteri:

main :: IO() 
main = do 
    h <- connectTo "127.0.0.1" $ PortNumber 4390 
    let proto = BinaryProtocol h 
    putStrLn "Client started" 
    let tryOnePing c i = do 
     write_TXT proto echorequest 
     putStrLn "ping sent" 
     tFlush h 
     w <- read_TXT proto 
     putStrLn "pong received" 
     return $ if w == echoreply then c+1 else c 
    c <- foldM tryOnePing 0 [0 .. 1000] 
    tClose h 
    print (c, 10000 - c) 
+3

sanmıyorum edecektir. Read_TXT nasıl uygulanır? Eğer 'hGetContents' gibi bir şey kullanırsa, bu sizin probleminizdir - tüm içeriğin alındığı ve baskı EOF'a kadar bloke edileceği zaman baskı bilmez. Bu muhtemelen bağlantıyı kapatmanın ve yeni bir tane açmanın yardımcı olmasındandır. –

+0

@ ThomasM.DuBuisson Bu Thrift okuma işlevidir. Bu durumda bir yapıyı okumak. –

cevap