| 271 | } |
| 272 | |
| 273 | void |
| 274 | NetVCTest::write_handler(int event) |
| 275 | { |
| 276 | Dbg(dbg_ctl, "write_handler received event %d on %s", event, (test_cont_type == NET_VC_TEST_ACTIVE) ? "Active" : "Passive"); |
| 277 | |
| 278 | switch (event) { |
| 279 | case VC_EVENT_WRITE_READY: |
| 280 | if (write_vio->ndone < bytes_to_send) { |
| 281 | int left_to_send = bytes_to_send - actual_bytes_sent; |
| 282 | ink_assert(left_to_send >= 0); |
| 283 | int to_fill = std::min(left_to_send, write_bytes_to_add_per); |
| 284 | actual_bytes_sent += fill_buffer(write_buffer, &write_seed, to_fill); |
| 285 | write_vio->reenable(); |
| 286 | } |
| 287 | break; |
| 288 | case VC_EVENT_WRITE_COMPLETE: |
| 289 | write_finished(); |
| 290 | break; |
| 291 | case VC_EVENT_INACTIVITY_TIMEOUT: |
| 292 | case VC_EVENT_ACTIVE_TIMEOUT: |
| 293 | case VC_EVENT_ERROR: |
| 294 | if (expected_write_term != event && expected_write_term != VC_EVENT_NONE) { |
| 295 | record_error("write: Unexpected error or timeout"); |
| 296 | } else { |
| 297 | write_finished(); |
| 298 | } |
| 299 | break; |
| 300 | default: |
| 301 | record_error("write: Unknown event"); |
| 302 | break; |
| 303 | } |
| 304 | } |
| 305 | |
| 306 | void |
| 307 | NetVCTest::read_handler(int event) |