@@ -325,7 +325,9 @@ handle_cast({lossFunction,Body}, State = #main_genserver_state{myName = MyName})
325
325
try
326
326
case binary_to_term (Body ) of
327
327
{WorkerName , SourceName , {LossTensor , _Type } , TimeNIF , BatchID , BatchTS } ->
328
- ToSend = atom_to_list (WorkerName ) ++ ? PHASE_RES_WORKER_NAME_SEPERATOR ++ atom_to_list (SourceName ) ++ ? PHASE_RES_VALUES_SEPERATOR ++ nerl_tools :string_format (" ~p " ,[LossTensor ]) ++ ? PHASE_RES_VALUES_SEPERATOR ++ float_to_list (TimeNIF ) ++ ? PHASE_RES_VALUES_SEPERATOR ++ integer_to_list (BatchID ) ++ ? PHASE_RES_VALUES_SEPERATOR ++ integer_to_list (BatchTS ),
328
+ ToSend = ? PHASE_RES_DATA_SEPARATOR ++ atom_to_list (WorkerName ) ++ ? PHASE_RES_WORKER_NAME_SEPERATOR ++ atom_to_list (SourceName ) ++
329
+ ? PHASE_RES_VALUES_SEPERATOR ++ nerl_tools :string_format (" ~p " ,[LossTensor ]) ++ ? PHASE_RES_VALUES_SEPERATOR ++ float_to_list (TimeNIF ) ++
330
+ ? PHASE_RES_VALUES_SEPERATOR ++ integer_to_list (BatchID ) ++ ? PHASE_RES_VALUES_SEPERATOR ++ integer_to_list (BatchTS ) ++ ? PHASE_RES_DATA_SEPARATOR ,
329
331
store_phase_result_data_to_send_ets ({WorkerName , BatchID , BatchTS }, ToSend );
330
332
_ELSE ->
331
333
? LOG_ERROR (" ~p Wrong loss function pattern received from client and its worker ~p " , [MyName , Body ])
@@ -349,7 +351,10 @@ handle_cast({predictRes,Body}, State) ->
349
351
(NerlTensor == <<>>) -> ? LOG_ERROR (? LOG_HEADER ++ " Got empty tensor" ), empty_nerltensor_err ;
350
352
true -> nerlNIF :nerltensor_conversion ({NerlTensor , Type }, nerlNIF :erl_type_conversion (Type )) % converting nerltensor from binary to erlang type using NerlNIF
351
353
end ,
352
- ToSend = WorkerName ++ ? PHASE_RES_WORKER_NAME_SEPERATOR ++ atom_to_list (SourceName ) ++ ? PHASE_RES_VALUES_SEPERATOR ++ nerl_tools :string_format (" ~p " ,[DecodedNerlTensor ]) ++ ? PHASE_RES_VALUES_SEPERATOR ++ integer_to_list (TimeNIF ) ++ ? PHASE_RES_VALUES_SEPERATOR ++ integer_to_list (BatchID ) ++ ? PHASE_RES_VALUES_SEPERATOR ++ integer_to_list (BatchTS ),
354
+ ToSend = ? PHASE_RES_DATA_SEPARATOR ++ WorkerName ++ ? PHASE_RES_WORKER_NAME_SEPERATOR ++ atom_to_list (SourceName ) ++
355
+ ? PHASE_RES_VALUES_SEPERATOR ++ nerl_tools :string_format (" ~p " ,[DecodedNerlTensor ]) ++ ? PHASE_RES_VALUES_SEPERATOR ++
356
+ integer_to_list (TimeNIF ) ++ ? PHASE_RES_VALUES_SEPERATOR ++ integer_to_list (BatchID ) ++ ? PHASE_RES_VALUES_SEPERATOR ++
357
+ integer_to_list (BatchTS ) ++ ? PHASE_RES_DATA_SEPARATOR ,
353
358
store_phase_result_data_to_send_ets ({WorkerName , BatchID , BatchTS }, ToSend )
354
359
catch Err :E ->
355
360
? LOG_ERROR (? LOG_HEADER ++ " Error receiving predict result ~p " ,[{Err ,E }])
@@ -473,7 +478,7 @@ store_phase_result_data_to_send_ets({WorkerName, BatchID , BatchTS}, DataToSendS
473
478
474
479
generate_phase_result_data_string_from_list ([], _ResString ) -> _ResString ;
475
480
generate_phase_result_data_string_from_list (ListOfData , ResString ) ->
476
- NewResString = ResString ++ ? PHASE_RES_DATA_SEPARATOR ++ element (? DATA_IDX ,hd (ListOfData ))++ ? PHASE_RES_DATA_SEPARATOR ,
481
+ NewResString = ResString ++ element (? DATA_IDX ,hd (ListOfData )),
477
482
generate_phase_result_data_string_from_list (tl (ListOfData ), NewResString ).
478
483
479
484
generate_phase_result_data_to_send_from_ets_as_str () ->
0 commit comments