275 |
assert(F); |
assert(F); |
276 |
assert(F->flags.open == true); |
assert(F->flags.open == true); |
277 |
|
|
278 |
F->timeout = event_base->time.sec_monotonic + (timeout / 1000); |
F->timeout = event_base->time.sec_monotonic + timeout; |
279 |
F->timeout_handler = callback; |
F->timeout_handler = callback; |
280 |
F->timeout_data = cbdata; |
F->timeout_data = cbdata; |
281 |
} |
} |
298 |
assert(F); |
assert(F); |
299 |
assert(F->flags.open == true); |
assert(F->flags.open == true); |
300 |
|
|
301 |
F->flush_timeout = event_base->time.sec_monotonic + (timeout / 1000); |
F->flush_timeout = event_base->time.sec_monotonic + timeout; |
302 |
F->flush_handler = callback; |
F->flush_handler = callback; |
303 |
F->flush_data = cbdata; |
F->flush_data = cbdata; |
304 |
} |
} |
388 |
return; /* ... and quit */ |
return; /* ... and quit */ |
389 |
} |
} |
390 |
|
|
391 |
comm_settimeout(F, timeout * 1000, comm_connect_timeout, NULL); |
comm_settimeout(F, timeout, comm_connect_timeout, NULL); |
392 |
comm_connect_tryconnect(F, NULL); |
comm_connect_tryconnect(F, NULL); |
393 |
} |
} |
394 |
|
|