noisy echo works, starting rubicon querier
This commit is contained in:
@@ -20,9 +20,9 @@ main([]) -> main_ii(6969);
|
|||||||
main([PortNum]) -> main_ii(list_to_integer(PortNum)).
|
main([PortNum]) -> main_ii(list_to_integer(PortNum)).
|
||||||
|
|
||||||
main_ii(PortNum) ->
|
main_ii(PortNum) ->
|
||||||
TcpOpts = [binary, {packet, 0}, {active, once}],
|
TcpOpts = [binary, {packet, 0}, {active, true}],
|
||||||
{ok, TSock} = gen_tcp:connect("localhost", PortNum, TcpOpts),
|
{ok, TSock} = gen_tcp:connect("localhost", PortNum, TcpOpts),
|
||||||
ok = inet:setopts(TSock, [{active, once}]),
|
%ok = inet:setopts(TSock, [{active, once}]),
|
||||||
{ok, NSock, _HandshakeState} = enoise:connect(TSock, noise_options()),
|
{ok, NSock, _HandshakeState} = enoise:connect(TSock, noise_options()),
|
||||||
% need keyboard process
|
% need keyboard process
|
||||||
Self = self(),
|
Self = self(),
|
||||||
@@ -37,7 +37,7 @@ noise_options() ->
|
|||||||
|
|
||||||
|
|
||||||
j_loop(JS = #js{rcv = Rcv, tsock = TSock, nsock = NSock}) ->
|
j_loop(JS = #js{rcv = Rcv, tsock = TSock, nsock = NSock}) ->
|
||||||
ok = inet:setopts(TSock, [{active, once}]),
|
%ok = inet:setopts(TSock, [{active, once}]),
|
||||||
receive
|
receive
|
||||||
{noise, NSock, Bytes} ->
|
{noise, NSock, Bytes} ->
|
||||||
NewRcv = <<Rcv/binary, Bytes/binary>>,
|
NewRcv = <<Rcv/binary, Bytes/binary>>,
|
||||||
|
|||||||
@@ -45,7 +45,7 @@ noise_options() ->
|
|||||||
% pimp process startup
|
% pimp process startup
|
||||||
p_init(Port) ->
|
p_init(Port) ->
|
||||||
p_logln("pimp startup (p_init)"),
|
p_logln("pimp startup (p_init)"),
|
||||||
Opts = [binary, {packet, 0}, {active, once}],
|
Opts = [binary, {packet, 0}, {active, true}],
|
||||||
case gen_tcp:listen(Port, Opts) of
|
case gen_tcp:listen(Port, Opts) of
|
||||||
{ok, LSock} ->
|
{ok, LSock} ->
|
||||||
ok = p_logfln("pimp starting: ~tp", [self()]),
|
ok = p_logfln("pimp starting: ~tp", [self()]),
|
||||||
@@ -157,7 +157,7 @@ h_init(LSock, HS = #hs{name = Name, daddy = Daddy, asock = none, nsock = none})
|
|||||||
|
|
||||||
|
|
||||||
h_loop(HS = #hs{name = Name, daddy = Daddy, asock = ASock, nsock = NSock}) ->
|
h_loop(HS = #hs{name = Name, daddy = Daddy, asock = ASock, nsock = NSock}) ->
|
||||||
ok = inet:setopts(ASock, [{active, once}]),
|
%ok = inet:setopts(ASock, [{active, once}]),
|
||||||
receive
|
receive
|
||||||
{noise, NSock, Data} ->
|
{noise, NSock, Data} ->
|
||||||
Data_II = string:chomp(Data),
|
Data_II = string:chomp(Data),
|
||||||
|
|||||||
Reference in New Issue
Block a user