Skip to content

Commit c859292

Browse files
committed
adding pointer to Dispather in Conseter
Signed-off-by: Scapesfear <ydivyanshu842@gmail.com>
1 parent b439b39 commit c859292

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

orderer/consensus/bdls/consenter.go

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ type Consenter struct {
7373
// Some fields from etcdraft that i feel are important for BDLS
7474
Communication cluster.Communicator
7575
TLSCert []byte
76-
Dispatcher *Dispatcher
76+
*Dispatcher
7777
OrdererConfig localconfig.TopLevel
7878
}
7979

@@ -135,6 +135,9 @@ func New(
135135

136136
// This will print the standard -----BEGIN CERTIFICATE----- block
137137
logger.Debugf("TLS Cert PEM:\n%s", srvConf.SecOpts.Certificate)
138+
logger.Debugf("TLS Key PEM:\n%s", srvConf.SecOpts.Key)
139+
logger.Debugf("okay this is conf server key%s", conf.General.TLS.PrivateKey)
140+
logger.Info("if i can get this i can get a private key to support PoC i hope")
138141

139142
consenter.Dispatcher = &Dispatcher{
140143
Logger: logger,
@@ -303,11 +306,14 @@ func createComm(clusterDialer *cluster.PredicateDialer, c *Consenter, config loc
303306
compareCert := cluster.CachePublicKeyComparisons(func(a, b []byte) bool {
304307
err := crypto.CertificatesWithSamePublicKey(a, b)
305308
if err != nil && err != crypto.ErrPubKeyMismatch {
309+
logger.Debugf("Failed to compare certificates: %v", err)
306310
crypto.LogNonPubKeyMismatchErr(logger.Errorf, err, a, b)
307311
}
308312
return err == nil
309313
})
310314

315+
logger.Debugf("***********compare cert done****************************")
316+
311317
comm := &cluster.Comm{
312318
MinimumExpirationWarningInterval: cluster.MinimumExpirationWarningInterval,
313319
CertExpWarningThreshold: config.CertExpirationWarningThreshold,
@@ -317,9 +323,11 @@ func createComm(clusterDialer *cluster.PredicateDialer, c *Consenter, config loc
317323
Connections: cluster.NewConnectionStore(clusterDialer, metrics.EgressTLSConnectionCount),
318324
Metrics: metrics,
319325
ChanExt: c,
320-
H: c.ClusterService.RequestHandler,
326+
H: c,
321327
CompareCertificate: compareCert,
322328
}
329+
330+
logger.Debugf("***********cluster communication created****************************")
323331
c.Communication = comm
324332
return comm
325333
}

0 commit comments

Comments
 (0)