> On March 16, 2015, 9:24 p.m., Michael Herstine wrote: > > core/src/main/scala/kafka/network/ssl/SSLChannel.scala, line 137 > > <https://reviews.apache.org/r/31958/diff/1/?file=891658#file891658line137> > > > > Suppose SSLEngine has written the current message (via `wrap`) to > > `netOutBuffer`, but that the write call in `flush`, when invoked from > > `handshakeWrap`, didn't write the entire buffer to the underlying socket. > > > > Would not `handshakeStatus` as reported from SSLEngine now be > > `NEEDS_UNWRAP`? And wouldn't that cause us to fall through to the > > `NEEDS_UNWRAP` case? > > > > Or do we not fall through in Scala case statements?
Thanks for the review. Ideally it should be fall through to NEEDS_UNWRAP since scala case statements doesn't allow java style follow-through I am looking at alternatives. - Sriharsha ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31958/#review76640 ----------------------------------------------------------- On March 11, 2015, 9:36 p.m., Sriharsha Chintalapani wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/31958/ > ----------------------------------------------------------- > > (Updated March 11, 2015, 9:36 p.m.) > > > Review request for kafka. > > > Bugs: KAFKA-1684 > https://issues.apache.org/jira/browse/KAFKA-1684 > > > Repository: kafka > > > Description > ------- > > KAFKA-1684. Implement TLS/SSL authentication. > > > Diffs > ----- > > core/src/main/scala/kafka/network/Channel.scala PRE-CREATION > core/src/main/scala/kafka/network/SocketServer.scala > 76ce41aed6e04ac5ba88395c4d5008aca17f9a73 > core/src/main/scala/kafka/network/ssl/SSLChannel.scala PRE-CREATION > core/src/main/scala/kafka/network/ssl/SSLConnectionConfig.scala > PRE-CREATION > core/src/main/scala/kafka/server/KafkaConfig.scala > 48e33626695ad8a28b0018362ac225f11df94973 > core/src/main/scala/kafka/server/KafkaServer.scala > dddef938fabae157ed8644536eb1a2f329fb42b7 > core/src/main/scala/kafka/utils/SSLAuthUtils.scala PRE-CREATION > core/src/test/scala/unit/kafka/network/SocketServerTest.scala > 0af23abf146d99e3d6cf31e5d6b95a9e63318ddb > core/src/test/scala/unit/kafka/server/KafkaConfigConfigDefTest.scala > c124c8df5b5079e5ffbd0c4ea359562a66aaf317 > core/src/test/scala/unit/kafka/utils/TestSSLUtils.scala PRE-CREATION > > Diff: https://reviews.apache.org/r/31958/diff/ > > > Testing > ------- > > > Thanks, > > Sriharsha Chintalapani > >
