summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authormagnus <mfeuer@jaguarlandrover.com>2014-10-17 15:56:59 -0700
committermagnus <mfeuer@jaguarlandrover.com>2014-10-17 15:56:59 -0700
commite41bfd2776232a3f8589f77f10ba5ca7443ff295 (patch)
tree00d733fecd7625ee5b15aa79fea07976bdb7605d
parent2957285a2b58ab230be5dc4e086067c4ac0c805a (diff)
downloadrvi_core-e41bfd2776232a3f8589f77f10ba5ca7443ff295.tar.gz
Fixed bug where large tcp packets got fragmented and unreadable by the receiving bert rpc datat link
Signed-off-by: magnus <mfeuer@jaguarlandrover.com>
-rw-r--r--components/data_link_bert_rpc/src/data_link_bert_rpc_rpc.erl2
-rw-r--r--components/data_link_bert_rpc/src/listener.erl2
2 files changed, 2 insertions, 2 deletions
diff --git a/components/data_link_bert_rpc/src/data_link_bert_rpc_rpc.erl b/components/data_link_bert_rpc/src/data_link_bert_rpc_rpc.erl
index fb8c648..b236666 100644
--- a/components/data_link_bert_rpc/src/data_link_bert_rpc_rpc.erl
+++ b/components/data_link_bert_rpc/src/data_link_bert_rpc_rpc.erl
@@ -100,7 +100,7 @@ connect_remote(IP, Port) ->
%% Setup a new outbound connection
?info(" data_link_bert:connect_remote(): Connecting ~p:~p",
[IP, Port]),
- case gen_tcp:connect(IP, Port, [binary, {packet, 0}]) of
+ case gen_tcp:connect(IP, Port, [binary, {packet, 4}]) of
{ ok, Sock } ->
?info(" data_link_bert:connect_remote(): Connected ~p:~p",
[IP, Port]),
diff --git a/components/data_link_bert_rpc/src/listener.erl b/components/data_link_bert_rpc/src/listener.erl
index aa886c1..2eb0d0c 100644
--- a/components/data_link_bert_rpc/src/listener.erl
+++ b/components/data_link_bert_rpc/src/listener.erl
@@ -60,7 +60,7 @@ terminate(_Reason, _State) ->
ok.
sock_opts() ->
- [binary, {active, once}, {packet, 0}].
+ [binary, {active, once}, {packet, 4}].
new_connection(IP, Port, Sock, State) ->
?debug("listener:new_connection(): Peer IP: ~p (ignored)", [IP]),