Skip to content

Commit

Permalink
Silence some compiler warnings
Browse files Browse the repository at this point in the history
Change-Id: I56a3d16b73bc184aec274aa556632df7f5407c6c
  • Loading branch information
NicolasT committed Jan 25, 2013
1 parent 02ea885 commit 5d73727
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 6 deletions.
1 change: 0 additions & 1 deletion src/hope/v1.ml
Original file line number Original file line Diff line number Diff line change
Expand Up @@ -143,7 +143,6 @@ module V1(S:Core.STORE)(A:MP_ACTION_DISPATCHER) = struct
let _do_delete_prefix (ic,oc) me store stats driver = let _do_delete_prefix (ic,oc) me store stats driver =
Llio.input_string ic >>= fun prefix -> Llio.input_string ic >>= fun prefix ->
let _inner () = let _inner () =
let t0 = Unix.gettimeofday () in
D.push_cli_req driver (Core.DELETE_PREFIX prefix) >>= fun a -> D.push_cli_req driver (Core.DELETE_PREFIX prefix) >>= fun a ->
(* Statistics.new_delete_prefix stats t0; *) (* Statistics.new_delete_prefix stats t0; *)
match a with match a with
Expand Down
9 changes: 4 additions & 5 deletions src/hope/v2.ml
Original file line number Original file line Diff line number Diff line change
Expand Up @@ -169,7 +169,6 @@ let _set driver k v =
let key = Pack.input_string rest in let key = Pack.input_string rest in
Lwtc.log "DELETE_PREFIX %S" key >>= fun () -> Lwtc.log "DELETE_PREFIX %S" key >>= fun () ->
let _inner () = let _inner () =
let t0 = Unix.gettimeofday () in
D.push_cli_req driver (Core.DELETE_PREFIX key) >>= fun a -> D.push_cli_req driver (Core.DELETE_PREFIX key) >>= fun a ->
let out = Pack.make_output 64 in let out = Pack.make_output 64 in
begin begin
Expand Down Expand Up @@ -281,8 +280,8 @@ let _set driver k v =
in in
match comm with match comm with
| Common.PING -> | Common.PING ->
let client_id = Pack.input_string rest in let _client_id = Pack.input_string rest in
let cluster_id = Pack.input_string rest in let _cluster_id = Pack.input_string rest in
let msg = Printf.sprintf "Arakoon %S" Version.git_info in let msg = Printf.sprintf "Arakoon %S" Version.git_info in
output_ok_string msg output_ok_string msg
| Common.WHO_MASTER -> | Common.WHO_MASTER ->
Expand Down Expand Up @@ -548,7 +547,7 @@ let _set driver k v =
Lwtc.log "GET_NURSERY_CFG" >>= fun () -> Lwtc.log "GET_NURSERY_CFG" >>= fun () ->
V.admin_get store V.__routing_key >>= fun v -> V.admin_get store V.__routing_key >>= fun v ->
let input = Pack.make_input v 0 in let input = Pack.make_input v 0 in
let rsize = Pack.input_size input in let _rsize = Pack.input_size input in
Lwt_log.debug "Decoding routing info" >>= fun () -> Lwt_log.debug "Decoding routing info" >>= fun () ->
let r = Routing.routing_from input in let r = Routing.routing_from input in
let out = Pack.make_output 32 in let out = Pack.make_output 32 in
Expand All @@ -570,7 +569,7 @@ let _set driver k v =
Lwt_log.debug_f "Sub %s %d %d" k key_start tail_size >>= fun () -> Lwt_log.debug_f "Sub %s %d %d" k key_start tail_size >>= fun () ->
let clu_id = String.sub k key_start tail_size in let clu_id = String.sub k key_start tail_size in
let input = Pack.make_input v 0 in let input = Pack.make_input v 0 in
let input_size = Pack.input_size input in let _input_size = Pack.input_size input in
let cfg = ClientCfg.cfg_from input in let cfg = ClientCfg.cfg_from input in
Hashtbl.replace clusters clu_id cfg; Hashtbl.replace clusters clu_id cfg;
Lwt.return () Lwt.return ()
Expand Down

0 comments on commit 5d73727

Please sign in to comment.