Skip to content

Commit

Permalink
test "verifies private data is pulled when joining a new peer with ne…
Browse files Browse the repository at this point in the history
…w certs" is very unstable. I change log level for test in integration pvtdata.

Signed-off-by: Fedor Partanskiy <[email protected]>
  • Loading branch information
pfi79 committed Oct 14, 2024
1 parent c188707 commit a8a8e5c
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 2 deletions.
1 change: 1 addition & 0 deletions gossip/comm/comm_impl.go
Original file line number Diff line number Diff line change
Expand Up @@ -577,6 +577,7 @@ func (c *commImpl) GossipStream(stream proto.Gossip_GossipStreamServer) error {
conn := c.connStore.onConnected(stream, connInfo, c.metrics)

h := func(m *protoext.SignedGossipMessage) {
c.logger.Debug("Got message1:", m)
c.msgPublisher.DeMultiplex(&ReceivedMessageImpl{
conn: conn,
SignedGossipMessage: m,
Expand Down
5 changes: 3 additions & 2 deletions integration/pvtdata/pvtdata_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -196,7 +196,7 @@ var _ = Describe("PrivateData", func() {

testPeers := []*nwo.Peer{org1peer0, org2peer0, org3peer0}
for _, peer := range testPeers {
pr := network.PeerRunner(peer)
pr := network.PeerRunner(peer, "FABRIC_LOGGING_SPEC=debug")
p := ifrit.Invoke(pr)
peerProcesses[peer.ID()] = p
Eventually(p.Ready(), network.EventuallyTimeout).Should(BeClosed())
Expand Down Expand Up @@ -264,7 +264,7 @@ var _ = Describe("PrivateData", func() {
updateConfigWithNewCertsForPeer(network, tempCryptoDir, orderer, org2Peer1)

By("starting the peer1.org2 process")
pr := network.PeerRunner(org2Peer1)
pr := network.PeerRunner(org2Peer1, "FABRIC_LOGGING_SPEC=debug")
p := ifrit.Invoke(pr)
peerProcesses[org2Peer1.ID()] = p
Eventually(p.Ready(), network.EventuallyTimeout).Should(BeClosed())
Expand Down Expand Up @@ -387,6 +387,7 @@ var _ = Describe("PrivateData", func() {
Expect(err).NotTo(HaveOccurred())
Eventually(sess, network.EventuallyTimeout).Should(gexec.Exit(0))
Expect(sess).To(gbytes.Say(`{"docType":"marblePrivateDetails","name":"marble1","price":99}`))
Expect(sess).To(gbytes.Say(`PFIPFI`))
})
})

Expand Down

0 comments on commit a8a8e5c

Please sign in to comment.