[akka-user][deprecated] SSL/TLS negotiation

[priyanka garg]

Hi,

I am trying to create a server similar to PostgreSQL lets say it Db Service 
and also trying to connect Bi tool to this. So to implement SSL in Db 
service, i was using TCP.bindTLs, but i am not getting expected results 
because Bi tools start ssl negotiation from the second message instead of 
first.
So flow is like this.
Bi tool ---> send SSL request --> DB service
DB service --> send yes --> Bi tool
 and then bi tool starts ssl negotiation by sending client hello message.

1) But in my case when i am using TCP.bindTLs, Db service is not able to 
capture SSL request message, so it can't send "yes"

2) and if i am using TCP.bind then first two steps are okay, Bi tool also 
send client hello message, but Db service is unable to interpret the client 
hello message and even if it is able to capture client hello by some method 
, then to send server hello i have to do complete SSL implementation in DB 
service.

So i am stuck here.. Which option we should choose from the above two and 
how?

-- 
*
** New discussion forum: https://discuss.akka.io/ replacing akka-user 
google-group soon.
** This group will soon be put into read-only mode, and replaced by 
discuss.akka.io
** More details: https://akka.io/blog/news/2018/03/13/discuss.akka.io-announced
*
>> 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Re: [akka-user][deprecated] Artery Errors

[Patrik Nordwall]

Troubleshooting for /dev/shm issue is described here:
https://github.com/real-logic/aeron#troubleshooting

Perhaps you are trying to run too much on a single machine (virtual
machine, docker, or whatever) so that it's overloaded?

If you have a constrained environment it might be worth trying Artery with
TCP instead, see docs.

/Patrik

PS. Next time it might be better to ask at the new forum at
https://discuss.akka.io/

On Tue, Apr 24, 2018 at 11:17 PM, Iman  wrote:

> Hello,
> I recently switched to using Artery from netty.tcp.
> I ran into this error : Insufficient usable storage for new log of
> length=50335744 in /dev/shm (tmpfs).
> After searching for a solution, I understood that this is because I am
> using the defaults to start the media driver, which will be inside the same
> JVM of the actor. As described at AKKA documentation
> ,
> it is better to start the driver externally and have it shared among actors.
> I followed the instructions in the documentation, I even used the same
> example configuration.
>
> Now the problem is that my actors start and then after a little time they
> all fail with an exception:
>
> [ERROR] [04/24/2018 20:49:49.606] [aeron-client-conductor]
> [akka.remote.artery.aeron.ArteryAeronUdpTransport(akka://ActorClusterSystemName)]
> Fatal Aeron error ConductorServiceTimeoutException. Have to terminate
> ActorSystem because it lost contact with the external Aeron media driver.
> Possible configuration properties to mitigate the problem are
> 'client-liveness-timeout' or 'driver-timeout'. io.aeron.exceptions.
> ConductorServiceTimeoutException: Exceeded (ns): 50
>
> io.aeron.exceptions.ConductorServiceTimeoutException: Exceeded (ns):
> 50
>
> at io.aeron.ClientConductor.checkServiceInterval(ClientConductor.java:745)
>
> at io.aeron.ClientConductor.onCheckTimeouts(ClientConductor.java:720)
>
> at io.aeron.ClientConductor.service(ClientConductor.java:659)
>
> at io.aeron.ClientConductor.doWork(ClientConductor.java:151)
>
> at org.agrona.concurrent.AgentRunner.doDutyCycle(AgentRunner.java:233)
>
> at org.agrona.concurrent.AgentRunner.run(AgentRunner.java:159)
>
> at java.lang.Thread.run(Thread.java:748)
>
>
> [ERROR] [04/24/2018 20:49:49.963] [aeron-client-conductor]
> [akka.remote.artery.aeron.ArteryAeronUdpTransport(akka://ActorClusterSystemName)]
> Aeron error, org.agrona.concurrent.AgentTerminationException
>
> org.agrona.concurrent.AgentTerminationException
>
> at io.aeron.ClientConductor.doWork(ClientConductor.java:148)
>
> at org.agrona.concurrent.AgentRunner.doDutyCycle(AgentRunner.java:233)
>
> at org.agrona.concurrent.AgentRunner.run(AgentRunner.java:159)
>
> at java.lang.Thread.run(Thread.java:748)
>
>
> and then after many undelivered messages:
>
> [INFO] [04/24/2018 20:49:52.270] [ActorClusterSystemName-akka.
> remote.default-remote-dispatcher-8] [akka://actorclustersystemn...@xx.xx.
> xx.xx:2559/system/remoting-terminator] Remote daemon shut down;
> proceeding with flushing remote transports.
>
>
> Other actors in the cluster display this error message:
>
> [ERROR] [04/24/2018 20:52:27.468] 
> [ActorClusterSystemName-akka.actor.default-dispatcher-18]
> [akka://actorclustersystemn...@xx.xx.xx.xx:2557/] swallowing exception
> during message send
>
> java.lang.IllegalStateException: Aeron client conductor is closed
>
> at io.aeron.ClientConductor.ensureOpen(ClientConductor.java:635)
>
> at io.aeron.ClientConductor.addPublication(ClientConductor.java:367)
>
> at io.aeron.Aeron.addPublication(Aeron.java:247)
>
> at akka.remote.artery.aeron.AeronSink$$anon$1.(AeronSink.scala:103)
>
> at akka.remote.artery.aeron.AeronSink.createLogicAndMaterializedValu
> e(AeronSink.scala:100)
>
> at akka.stream.impl.GraphStageIsland.materializeAtomic(
> PhasedFusingActorMaterializer.scala:630)
>
> at akka.stream.impl.PhasedFusingActorMaterializer.materialize(
> PhasedFusingActorMaterializer.scala:450)
>
> at akka.stream.impl.PhasedFusingActorMaterializer.materialize(
> PhasedFusingActorMaterializer.scala:415)
>
> at akka.stream.impl.PhasedFusingActorMaterializer.materialize(
> PhasedFusingActorMaterializer.scala:406)
>
> at akka.stream.scaladsl.RunnableGraph.run(Flow.scala:588)
>
> at akka.remote.artery.Association.runOutboundOrdinaryMessagesStr
> eam(Association.scala:710)
>
> at akka.remote.artery.Association.$anonfun$runOutboundOrdinaryMessagesStr
> eam$3(Association.scala:720)
>
> at akka.remote.artery.Association.$anonfun$attachOutboundStreamRestart$1(
> Association.scala:814)
>
> at akka.remote.artery.Association$LazyQueueWrapper.
> runMaterialize(Association.scala:89)
>
> at akka.remote.artery.Association$LazyQueueWrapper.
> offer(Association.scala:93)
>
> at akka.remote.artery.Association$LazyQueueWrapper.
> offer(Association.scala:84)
>
> at akka.remote.artery.Association.send(Association.scala:379)
>
> at