simon/tiny_httpd
1
0
Fork 0
mirror of https://github.com/c-cube/tiny_httpd.git synced 2025-12-06 11:15:35 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

release semaphore does not return anything anymore

Browse source
This commit is contained in:
craff 2021-12-08 16:38:59 -10:00
parent 9e9fe32347
commit e87428ae51
1 changed files with 14 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
src/Tiny_httpd.ml
View file

@ -721,8 +721,13 @@ module Sem_ = struct
let release m t =
Mutex.lock t.mutex;
t.n <- t.n + m;
let r = t.n in
Condition.broadcast t.cond;
Mutex.unlock t.mutex
let available_connection t =
(* locking necessary unless we have atomic read/write for int.*)
Mutex.lock t.mutex;
let r = t.n in
Mutex.unlock t.mutex;
r
end
@ -1125,13 +1130,17 @@ let run (self:t) : (unit,_) result =
(fun () ->
try
handle_client_ self client_sock;
let avail = Sem_.release 1 self.sem_max_connections in
_debug (fun k -> k"closing inactive connections (%d connections available)" avail)
Sem_.release 1 self.sem_max_connections;
_debug (fun k -> k
"closing inactive connections (%d connections available)"
(Sem_.available_connection self.sem_max_connections))
with
| e ->
(try Unix.close client_sock with _ -> ());
let avail = Sem_.release 1 self.sem_max_connections in
_debug (fun k -> k"closing connections on error (%d connections available)" avail);
Sem_.release 1 self.sem_max_connections;
_debug (fun k -> k
"closing connections on error (%d connections available)"
(Sem_.available_connection self.sem_max_connections));
raise e
);
with e ->