Skip to content

Commit a484a90

Browse files
Use a directory name that is the hash of the clusterPeers for etcd state
1 parent 6917544 commit a484a90

File tree

3 files changed

+5
-2
lines changed

3 files changed

+5
-2
lines changed

hydra-node/hydra-node.cabal

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -149,6 +149,7 @@ library
149149
, resourcet
150150
, safe-money
151151
, serialise
152+
, SHA
152153
, sop-extras
153154
, stm
154155
, text

hydra-node/src/Hydra/Network/Etcd.hs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,8 @@ import Data.Aeson (decodeFileStrict', encodeFile)
5959
import Data.Aeson qualified as Aeson
6060
import Data.Aeson.Types (Value)
6161
import Data.ByteString qualified as BS
62+
import Data.ByteString.Lazy.Char8 qualified as LBS8
63+
import Data.Digest.Pure.SHA (sha256, showDigest)
6264
import Data.List ((\\))
6365
import Data.List qualified as List
6466
import Data.Map qualified as Map
@@ -199,7 +201,7 @@ withEtcdNetwork tracer protocolVersion config callback action = do
199201
$ concat
200202
[ -- NOTE: Must be used in clusterPeers
201203
["--name", show advertise]
202-
, ["--data-dir", persistenceDir </> "etcd"]
204+
, ["--data-dir", persistenceDir </> "etcd" </> showDigest (sha256 $ LBS8.pack clusterPeers)]
203205
, ["--listen-peer-urls", httpUrl listen]
204206
, ["--initial-advertise-peer-urls", httpUrl advertise]
205207
, ["--listen-client-urls", httpUrl clientHost]

hydra-node/test/Hydra/NetworkSpec.hs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ spec = do
111111

112112
it "emits connectivity events" $ \tracer -> do
113113
withTempDir "test-etcd" $ \tmp -> do
114-
failAfter 20 $ do
114+
failAfter 30 $ do
115115
PeerConfig3{aliceConfig, bobConfig, carolConfig} <- setup3Peers tmp
116116
-- Record and assert connectivity events from alice's perspective
117117
(recordReceived, _, waitConnectivity) <- newRecordingCallback

0 commit comments

Comments
 (0)