From: Scott Worley Date: Sat, 28 Jul 2012 19:06:43 +0000 (-0700) Subject: Test fetch blocking X-Git-Url: http://git.scottworley.com/reliable-chat/commitdiff_plain/ca612dcb40cb644930b74c84e55218abda34e255?hp=03513e5ce2d22d140752efeb3aefa72266bd9d87 Test fetch blocking Fetch blocks until message is sent. Fetches initiated before a speak return the later-spoken value. --- diff --git a/server/server_test.go b/server/server_test.go index 9fabf81..516f62a 100644 --- a/server/server_test.go +++ b/server/server_test.go @@ -1,10 +1,11 @@ package main import "testing" +import "runtime" import "time" func TestMessageInsertAndRetreive(t *testing.T) { - say := "" + say := "'Ello, Mister Polly Parrot!" at := time.Now() var zero_time time.Time store := start_store() @@ -24,3 +25,29 @@ func TestMessageInsertAndRetreive(t *testing.T) { close(store.Get) close(store.Add) } + +func TestFetchBlocksUntilSpeak(t *testing.T) { + start_fetch_wait_count := fetch_wait_count.String() + say := "I've got a lovely fresh cuttle fish for you" + at := time.Now() + var zero_time time.Time + store := start_store() + messages_from_store := make(chan []Message, 1) + store.Get <- &StoreRequest{zero_time, messages_from_store} + for start_fetch_wait_count == fetch_wait_count.String() { + runtime.Gosched() + } + store.Add <- &Message{at, say} + messages := <-messages_from_store + if len(messages) != 1 { + t.Fail() + } + if messages[0].Time != at { + t.Fail() + } + if messages[0].Text != say { + t.Fail() + } + close(store.Get) + close(store.Add) +}