@@ -124,17 +124,17 @@ terminate() ->
124
124
125
125
connection_created (Pid , Infos ) ->
126
126
ets :insert (connection_created , {Pid , Infos }),
127
- ets :update_counter (connection_churn_metrics , node (), {2 , 1 },
128
- ? CONNECTION_CHURN_METRICS ),
127
+ _ = ets :update_counter (connection_churn_metrics , node (), {2 , 1 },
128
+ ? CONNECTION_CHURN_METRICS ),
129
129
ok .
130
130
131
131
connection_closed (Pid ) ->
132
132
ets :delete (connection_created , Pid ),
133
133
ets :delete (connection_metrics , Pid ),
134
134
% % Delete marker
135
135
ets :update_element (connection_coarse_metrics , Pid , {5 , 1 }),
136
- ets :update_counter (connection_churn_metrics , node (), {3 , 1 },
137
- ? CONNECTION_CHURN_METRICS ),
136
+ _ = ets :update_counter (connection_churn_metrics , node (), {3 , 1 },
137
+ ? CONNECTION_CHURN_METRICS ),
138
138
ok .
139
139
140
140
connection_stats (Pid , Infos ) ->
@@ -148,16 +148,16 @@ connection_stats(Pid, Recv_oct, Send_oct, Reductions) ->
148
148
149
149
channel_created (Pid , Infos ) ->
150
150
ets :insert (channel_created , {Pid , Infos }),
151
- ets :update_counter (connection_churn_metrics , node (), {4 , 1 },
152
- ? CONNECTION_CHURN_METRICS ),
151
+ _ = ets :update_counter (connection_churn_metrics , node (), {4 , 1 },
152
+ ? CONNECTION_CHURN_METRICS ),
153
153
ok .
154
154
155
155
channel_closed (Pid ) ->
156
156
ets :delete (channel_created , Pid ),
157
157
ets :delete (channel_metrics , Pid ),
158
158
ets :delete (channel_process_metrics , Pid ),
159
- ets :update_counter (connection_churn_metrics , node (), {5 , 1 },
160
- ? CONNECTION_CHURN_METRICS ),
159
+ _ = ets :update_counter (connection_churn_metrics , node (), {5 , 1 },
160
+ ? CONNECTION_CHURN_METRICS ),
161
161
ok .
162
162
163
163
channel_stats (Pid , Infos ) ->
@@ -276,20 +276,20 @@ queue_stats(Name, MessagesReady, MessagesUnacknowledge, Messages, Reductions) ->
276
276
277
277
queue_declared (_Name ) ->
278
278
% % Name is not needed, but might be useful in the future.
279
- ets :update_counter (connection_churn_metrics , node (), {6 , 1 },
280
- ? CONNECTION_CHURN_METRICS ),
279
+ _ = ets :update_counter (connection_churn_metrics , node (), {6 , 1 },
280
+ ? CONNECTION_CHURN_METRICS ),
281
281
ok .
282
282
283
283
queue_created (_Name ) ->
284
284
% % Name is not needed, but might be useful in the future.
285
- ets :update_counter (connection_churn_metrics , node (), {7 , 1 },
286
- ? CONNECTION_CHURN_METRICS ),
285
+ _ = ets :update_counter (connection_churn_metrics , node (), {7 , 1 },
286
+ ? CONNECTION_CHURN_METRICS ),
287
287
ok .
288
288
289
289
queue_deleted (Name ) ->
290
290
ets :delete (queue_coarse_metrics , Name ),
291
- ets :update_counter (connection_churn_metrics , node (), {8 , 1 },
292
- ? CONNECTION_CHURN_METRICS ),
291
+ _ = ets :update_counter (connection_churn_metrics , node (), {8 , 1 },
292
+ ? CONNECTION_CHURN_METRICS ),
293
293
% % Delete markers
294
294
ets :update_element (queue_metrics , Name , {3 , 1 }),
295
295
CQX = ets :select (channel_queue_exchange_metrics , match_spec_cqx (Name )),
@@ -302,8 +302,8 @@ queue_deleted(Name) ->
302
302
end , CQ ).
303
303
304
304
queues_deleted (Queues ) ->
305
- ets :update_counter (connection_churn_metrics , node (), {8 , length (Queues )},
306
- ? CONNECTION_CHURN_METRICS ),
305
+ _ = ets :update_counter (connection_churn_metrics , node (), {8 , length (Queues )},
306
+ ? CONNECTION_CHURN_METRICS ),
307
307
[ delete_queue_metrics (Queue ) || Queue <- Queues ],
308
308
[
309
309
begin
0 commit comments