anchor.diff:      %% Send a kEcho request to the worker
       lager:info("Sending kEcho request to worker process."),
       p_write_request(WorkerPort, ?kEcho, <<"Ping">>),
  -    {Size, Msg} = p_read_reply(WorkerPort),
  +    {ok, {Size, Msg}} = p_read_reply(WorkerPort),
       lager:info("Received kEcho reply from worker: size: ~p, msg: ~p", [Size, Msg]),
       {ok, #{worker => WorkerPort}}.
   
  
positive.code: p_read_reply(Port) ->
      receive
          {Port, {data, <<Size:32/integer-signed-little,Msg/binary>>}} ->
              {Size, Msg}
      end.
  
negative.code: -define(kGetTokenId,3).
  -define(kSubmitPayload,4).
  -define(kError,5).
  
  %% Worker comm timeout
  -define(WORKER_REPLY_TIMEOUT, 3000).
  
  
  %%%===================================================================
  