eddy147

eddy147

Once in a while I get a :noproc error:

** (stop) exited in: GenServer.call({:via, Registry, {:trip_generation_server, "804194805327673"}}, :send_to_processing, 5000)
    ** (EXIT) no process: the process is not alive or there's no process currently associated with the given name, possibly because its application isn't started
    (elixir 1.14.2) lib/gen_server.ex:1027: GenServer.call/3
    (vehicle_processing 0.1.0) lib/vehicle_processing/processor.ex:1243: VehicleProcessing.Processor.run_trip_generation_server/3
    (stdlib 4.2) gen_server.erl:1161: :gen_server.try_terminate/3
    (stdlib 4.2) gen_server.erl:1351: :gen_server.terminate/10
    (stdlib 4.2) proc_lib.erl:240: :proc_lib.init_p_do_apply/3
Last message: :check_end_of_processing
State: %VehicleProcessing.Processor.State{vehicle: nil, unique_identifier: "804194805327673", data_start_at: nil, data_stop_at: nil, last_active_at: ~U[2023-10-30 10:30:47.181818Z], parking_notification_sent: false, driver_id: %{ibutton: nil, log: nil, permission: nil}, gps_based_properties: %{distance: nil, speed: nil, time: nil}, sent_vehicle_start_trigger?: false, at_least_one_non_heartbeat_message?: true, messages: [], timer: #Reference<0.3285835207.3288072193.194993>, geofences: [], previous_trip_point: nil, gps_reference: nil, previous_state_of_charge: nil, notifications_sent: %{battery_level_low: nil, battery_range_low: nil, battery_state_of_charge_low: nil}, gps_send: 1}

I start the TripGenerationServer dynamically:

  defp run_trip_generation_server(state, f, tries) do
    if tries > 0 do
      case Registry.lookup(:trip_generation_server, state.unique_identifier) do
        [] ->
          case TripGenerationServerSupervisor.start_child(state.unique_identifier) do
            {:ok, _pid} ->
              f.(state)

            e ->
              Logger.warning(
                "Can not start TripGenerationServer #{state.unique_identifier}: #{inspect(e)}"
              )

              Process.sleep(200)
              run_trip_generation_server(state, f, tries - 1)
          end

        [{_pid, _nil}] ->
          f.(state)
      end
    else
      Logger.error("Can not startTripGenerationServer #{state.unique_identifier}")
    end

    state
  end

And I get the :noproc error when

   [{_pid, _nil}] ->
          f.(state)
defmodule VehicleProcessing.TripGenerationServerSupervisor do
  @moduledoc false

  use DynamicSupervisor
  require Logger
  alias VehicleProcessing.TripGenerationServer

  def start_link(_) do
    Logger.info("start #{__MODULE__}")
    DynamicSupervisor.start_link(__MODULE__, [], name: __MODULE__)
  end

  def start_child(unique_identifier) do
    child_spec = %{
      id: TripGenerationServer,
      start: {TripGenerationServer, :start, [unique_identifier]},
      # the child process is restarted only if it terminates abnormally,
      # i.e., with an exit reason other than :normal, :shutdown, or {:shutdown, term}
      restart: :transient,
      shutdown: :brutal_kill,
      type: :worker,
      modules: [TripGenerationServer]
    }

    DynamicSupervisor.start_child(__MODULE__, child_spec)
  end

  @impl true
  def init([]) do
    DynamicSupervisor.init(strategy: :one_for_one)
  end
end

How is this possible?
It also happens sometimes in a test, and when I run the test again, the error does not appear; or it appears in another test, totally random.

Showing Posts 1 to 4

dimitarvp

dimitarvp

At least in test env it’s possible the process is exiting before the test completes?

eddy147

eddy147 OP

That also sometimes happens, but in this case I get {:ok, pid} but still the :noprocess error.

I did not show this in my question, but in my init/1 function of the TripGenerationServer a query to the DB was called:

  def init(imei) do
    {:ok,
     %{
       imei: imei,
       from_ts: nil,
       to_ts: nil,
       should_send_to_processing: should_send_to_processing?(imei),
       trip_split_interval_in_seconds:
         Application.get_env(:vehicle_processing, :trip_split_interval_in_seconds) || 300,
       ts: now_ts()
     }, {:continue, :initial_state}}
  end

should_send_to_processing?(imei)
is a call to the DB.
I removed that, and not seen the error again in my tests.

So is it possible that we get {:ok, pid} back already before the init/1 function is complete?

dimitarvp

dimitarvp

Oh, don’t do that. I am not sure that’s your problem but always do these with handle_continue!

Also a piece from handle_call docs:

Returning {:reply, reply, new_state, {:continue, continue_arg}} is similar to {:reply, reply, new_state} except that handle_continue/2 will be invoked immediately after with continue_arg as the first argument and state as the second one.

al2o3cr

al2o3cr

One thought: TripGenerationServerSupervisor.start_child will return the child PID as soon as the process is started, but a call using a via tuple won’t succeed until the child process has registered (presumably using code in TripGenerationServer)

The error you’re seeing could happen if the callback passed to run_trip_generation_server “wins the race” and tries to make a call too early.

— All posts loaded —

Where Next? Top

Trending in Questions Top

water
I’m aware of 2 such projects, are there others? git: GitHub - team-alembic/realworld: A fullstack Phoenix LiveView application with back...
New
katta
I having some trouble figuring out if I have set myself too strict of standards for my production server. Currently I can handle 75% of r...
New
peck
Hi everyone. My team and I have been working on a fairly modest app based around video streaming and chat, but we’ve landed a customer t...
New
bradley
I really like the adapter patterns that ecto, nebulex, waffle, etc. use and would love find something similar for a key management servic...
New
unaware8150
Hello folks! So at work, we are seeing some situations where we have to define some “fixed” strings that are used across the codebase in...
New
Alvinkariuki
How Can I Optimise Compile Time Dependencies I have been building an elixir application for about 2 years now. Many modules and files ha...
New
leoschweizer
Hi, we run different LLM models across a cluster, with each node loading a configurable subset. Model-specific queues let nodes consume ...
New

Other Trending Topics Top

budgie
A little off-topic, but I feel like people here have a good head on their shoulders. I used to be quite good at making software. Was luc...
New
KristerV
Hey. Is there anyone here who creates agents in their apps? Not talking about using agents, but creating them. I’m finding it pretty diff...
New
mudasobwa
I fully migrated to my own harness from Anthropic/Gemini and I think it’s time to share it. Welcome DSH, the DeepSeek Harness, fully writ...
New
jimsynz
Beam Bots (or just BB for short) is a framework for building fault-tolerant robotics applications in Elixir using familiar OTP patterns. ...
New
juhalehtonen
There has been a thread to discuss the Stack Overflow Developer Survey on this forum every year since 2018, so here’s yet another one for...
New
budgie
I love Elixir. It’s one of 2 programming languages I’ve ever fallen in love with. But I don’t use it anymore. Serverless was the promis...
New

We're in Beta

About us Mission Statement

Options

Thread Display Mode




Thread Preview

Skip Thread Previews