39 |
type t = { |
type t = { |
40 |
mutable sock : BasicSocket.t; |
mutable sock : BasicSocket.t; |
41 |
mutable rbuf : buf; |
mutable rbuf : buf; |
42 |
mutable wfifo : string Fifo2.t; |
mutable wfifo : string Fifo.t; |
43 |
mutable wlen : int; |
mutable wlen : int; |
44 |
mutable wfbuf : buf; |
mutable wfbuf : buf; |
45 |
mutable event_handler : handler; |
mutable event_handler : handler; |
555 |
write_power = 1; |
write_power = 1; |
556 |
read_power = 1; |
read_power = 1; |
557 |
wlen = 0; |
wlen = 0; |
558 |
wfifo = Fifo2.create (); |
wfifo = Fifo.create (); |
559 |
} in |
} in |
560 |
let sock = BasicSocket.create name fd (tcp_handler t) in |
let sock = BasicSocket.create name fd (tcp_handler t) in |
561 |
let name = (fun () -> |
let name = (fun () -> |
585 |
write_power = 1; |
write_power = 1; |
586 |
read_power = 1; |
read_power = 1; |
587 |
wlen = 0; |
wlen = 0; |
588 |
wfifo = Fifo2.create (); |
wfifo = Fifo.create (); |
589 |
} in |
} in |
590 |
let sock = create_blocking name fd (tcp_handler t) in |
let sock = create_blocking name fd (tcp_handler t) in |
591 |
t.sock <- sock; |
t.sock <- sock; |