tests: specify dir for logs

travisjeffery · Dec 5, 2016 · 8959492 · 8959492
1 parent 0e5ab15
commit 8959492
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/broker/broker_test.go b/broker/broker_test.go
@@ -42,6 +42,7 @@ func TestStoreOpen(t *testing.T) {
 	logger := simplelog.New(os.Stdout, simplelog.INFO, "jocko/broker_test")
 	s0 := New(Options{
 		DataDir:              filepath.Join(dataDir, "0"),
+		LogDir:               filepath.Join(dataDir, "0"),
 		RaftAddr:             raft0,
 		Logger:               logger,
 		TCPAddr:              "127.0.0.1:3001",
@@ -57,6 +58,7 @@ func TestStoreOpen(t *testing.T) {
 
 	s1 := New(Options{
 		DataDir:              filepath.Join(dataDir, "1"),
+		LogDir:               filepath.Join(dataDir, "1"),
 		RaftAddr:             raft1,
 		Logger:               logger,
 		TCPAddr:              raft1,
@@ -70,6 +72,7 @@ func TestStoreOpen(t *testing.T) {
 
 	s2 := New(Options{
 		DataDir:              filepath.Join(dataDir, "2"),
+		LogDir:               filepath.Join(dataDir, "2"),
 		RaftAddr:             raft2,
 		TCPAddr:              raft2,
 		Logger:               logger,

diff --git a/replicator/partition_replicator_test.go b/replicator/partition_replicator_test.go
@@ -46,6 +46,7 @@ func TestFetchMessages(t *testing.T) {
 	logger := simplelog.New(os.Stdout, simplelog.INFO, "jocko/replicator_test")
 	s0 := broker.New(broker.Options{
 		DataDir:              filepath.Join(dataDir, "0"),
+		LogDir:               filepath.Join(dataDir, "0"),
 		RaftAddr:             raft0,
 		Logger:               logger,
 		TCPAddr:              "127.0.0.1:3000",
@@ -61,6 +62,7 @@ func TestFetchMessages(t *testing.T) {
 
 	s1 := broker.New(broker.Options{
 		DataDir:              filepath.Join(dataDir, "1"),
+		LogDir:               filepath.Join(dataDir, "1"),
 		RaftAddr:             raft1,
 		Logger:               logger,
 		TCPAddr:              raft1,
@@ -74,6 +76,7 @@ func TestFetchMessages(t *testing.T) {
 
 	s2 := broker.New(broker.Options{
 		DataDir:              filepath.Join(dataDir, "2"),
+		LogDir:               filepath.Join(dataDir, "2"),
 		RaftAddr:             raft2,
 		TCPAddr:              raft2,
 		Logger:               logger,