Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

have histogram ets tables created by a folsom process

  • Loading branch information...
commit 1d66048d3983640d8326cc020527cb082689c499 1 parent 56918d9
@joewilliams joewilliams authored
View
4 include/folsom.hrl
@@ -14,7 +14,7 @@
-record(uniform, {
size = 5000,
n = 1,
- reservoir = ets:new(folsom_uniform,[set]),
+ reservoir = folsom_metrics_histogram_ets:new(folsom_uniform,[set, {write_concurrency, true}, public]),
seed = now()
}).
@@ -31,7 +31,7 @@
-record(none, {
size = 5000,
n = 0,
- reservoir = ets:new(folsom_none,[ordered_set])
+ reservoir = folsom_metrics_histogram_ets:new(folsom_none,[ordered_set, {write_concurrency, true}, public])
}).
-record(histogram, {
View
148 src/folsom_metrics_histogram_ets.erl
@@ -0,0 +1,148 @@
+%%%
+%%% Copyright 2011, Boundary
+%%%
+%%% Licensed under the Apache License, Version 2.0 (the "License");
+%%% you may not use this file except in compliance with the License.
+%%% You may obtain a copy of the License at
+%%%
+%%% http://www.apache.org/licenses/LICENSE-2.0
+%%%
+%%% Unless required by applicable law or agreed to in writing, software
+%%% distributed under the License is distributed on an "AS IS" BASIS,
+%%% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+%%% See the License for the specific language governing permissions and
+%%% limitations under the License.
+%%%
+
+
+%%%-------------------------------------------------------------------
+%%% File: folsom_metrics_histogram_ets.erl
+%%% @author joe williams <j@boundary.com>
+%%% @doc
+%%% this module creates ets tables for histograms as to be the parent
+%%% process for those histograms so the apps using folsom dont have to
+%%% @end
+%%%------------------------------------------------------------------
+
+-module(folsom_metrics_histogram_ets).
+
+-behaviour(gen_server).
+
+%% API
+-export([start_link/0, new/2]).
+
+%% gen_server callbacks
+-export([init/1, handle_call/3, handle_cast/2, handle_info/2,
+ terminate/2, code_change/3]).
+
+-define(SERVER, ?MODULE).
+
+-record(state, {}).
+
+%%%===================================================================
+%%% API
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @doc
+%% Starts the server
+%%
+%% @spec start_link() -> {ok, Pid} | ignore | {error, Error}
+%% @end
+%%--------------------------------------------------------------------
+start_link() ->
+ gen_server:start_link({local, ?SERVER}, ?MODULE, [], []).
+
+%%%===================================================================
+%%% gen_server callbacks
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Initializes the server
+%%
+%% @spec init(Args) -> {ok, State} |
+%% {ok, State, Timeout} |
+%% ignore |
+%% {stop, Reason}
+%% @end
+%%--------------------------------------------------------------------
+init([]) ->
+ {ok, #state{}}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling call messages
+%%
+%% @spec handle_call(Request, From, State) ->
+%% {reply, Reply, State} |
+%% {reply, Reply, State, Timeout} |
+%% {noreply, State} |
+%% {noreply, State, Timeout} |
+%% {stop, Reason, Reply, State} |
+%% {stop, Reason, State}
+%% @end
+%%--------------------------------------------------------------------
+handle_call({new, {Table, Opts}}, _From, State) ->
+ Reply = ets:new(Table, Opts),
+ {reply, Reply, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling cast messages
+%%
+%% @spec handle_cast(Msg, State) -> {noreply, State} |
+%% {noreply, State, Timeout} |
+%% {stop, Reason, State}
+%% @end
+%%--------------------------------------------------------------------
+handle_cast(_Msg, State) ->
+ {noreply, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling all non call/cast messages
+%%
+%% @spec handle_info(Info, State) -> {noreply, State} |
+%% {noreply, State, Timeout} |
+%% {stop, Reason, State}
+%% @end
+%%--------------------------------------------------------------------
+handle_info(_Info, State) ->
+ {noreply, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% This function is called by a gen_server when it is about to
+%% terminate. It should be the opposite of Module:init/1 and do any
+%% necessary cleaning up. When it returns, the gen_server terminates
+%% with Reason. The return value is ignored.
+%%
+%% @spec terminate(Reason, State) -> void()
+%% @end
+%%--------------------------------------------------------------------
+terminate(_Reason, _State) ->
+ ok.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Convert process state when code is changed
+%%
+%% @spec code_change(OldVsn, State, Extra) -> {ok, NewState}
+%% @end
+%%--------------------------------------------------------------------
+code_change(_OldVsn, State, _Extra) ->
+ {ok, State}.
+
+%%%===================================================================
+%%% Internal functions
+%%%===================================================================
+
+new(Table, Opts) ->
+ gen_server:call(?SERVER, {new, {Table, Opts}}).
View
8 src/folsom_sup.erl
@@ -81,11 +81,15 @@ init([]) ->
Shutdown = 2000,
Type = worker,
- AChild = {folsom_meter_timer_server,
+ TimerServer = {folsom_meter_timer_server,
{folsom_meter_timer_server, start_link, []},
Restart, Shutdown, Type, [folsom_meter_timer_server]},
- {ok, {SupFlags, [AChild]}}.
+ HistETSServer = {folsom_metrics_histogram_ets,
+ {folsom_metrics_histogram_ets, start_link, []},
+ Restart, Shutdown, Type, [folsom_metrics_histogram_ets]},
+
+ {ok, {SupFlags, [TimerServer, HistETSServer]}}.
%%%===================================================================
%%% Internal functions
Please sign in to comment.
Something went wrong with that request. Please try again.