anchor.diff:      lists:foreach(
           fun(SpaceId) ->
               CurrentSeq = get_current_seq(SpaceId),
  -%%            ?info("DBSync broadcast for space ~p: ~p", [SpaceId, CurrentSeq]),
  +            ?info("DBSync broadcast for space ~p: ~p", [SpaceId, CurrentSeq]),
               {ok, Providers} = oz_spaces:get_providers(provider, SpaceId),
               dbsync_proto:status_report(SpaceId, Providers -- [oneprovider:get_provider_id()], CurrentSeq)
           end, SpaceIds).
  
positive.code:             ?warning("Unknown stream crash ~p: ~p", [Stream, Reason])
      end;
  handle({async_init_stream, Since, Until, Queue}) ->
      state_update(changes_stream, fun(_) ->
          case catch init_stream(Since, infinity, Queue) of
              {ok, Pid} ->
                  Pid;
              Reason ->
                  ?warning("Unable to start stream ~p (since ~p until ~p) due to: ~p", [Queue, Since, Until, Reason]),
  
negative.code:     pong;
  
  handle(healthcheck) ->
      ensure_global_stream_active(),
      case state_get(changes_stream) of
          Stream when is_pid(Stream) ->
              ok;
  