@@ -207,8 +207,12 @@ connected({call, From}, {unlock, GeneratedKey}, Data = #statem_data{connection_n
207207connected ({call , From }, register , Data = # statem_data {connection_name = Conn }) ->
208208 Ctx = registration_context (Conn , Data ),
209209 Key = node_key (Data ),
210- eetcd_kv :put (Ctx , Key , registration_value (Data )),
211- rabbit_log :debug (" etcd peer discovery: put key ~tp , done with registration" , [Key ]),
210+ case eetcd_kv :put (Ctx , Key , registration_value (Data )) of
211+ {ok , _ } ->
212+ rabbit_log :debug (" etcd peer discovery: put key ~tp , done with registration" , [Key ]);
213+ {error , Reason } ->
214+ rabbit_log :error (" etcd peer discovery: put key ~tp failed: ~p " , [Key , Reason ])
215+ end ,
212216 gen_statem :reply (From , ok ),
213217 keep_state_and_data ;
214218connected ({call , From }, unregister , Data = # statem_data {connection_name = Conn }) ->
@@ -364,9 +368,9 @@ disconnect(ConnName, #statem_data{connection_monitor = Ref}) ->
364368unregister (Conn , Data = # statem_data {node_key_lease_id = LeaseID , node_lease_keepalive_pid = KAPid }) ->
365369 Ctx = unregistration_context (Conn , Data ),
366370 Key = node_key (Data ),
367- eetcd_kv :delete (Ctx , Key ),
371+ _ = eetcd_kv :delete (Ctx , Key ),
368372 rabbit_log :debug (" etcd peer discovery: deleted key ~ts , done with unregistration" , [Key ]),
369- eetcd_lease :revoke (Ctx , LeaseID ),
373+ _ = eetcd_lease :revoke (Ctx , LeaseID ),
370374 exit (KAPid , normal ),
371375 rabbit_log :debug (" etcd peer discovery: revoked a lease ~tp for node key ~ts " , [LeaseID , Key ]),
372376 ok .
0 commit comments