| 606 | } |
| 607 | |
| 608 | int |
| 609 | FetchSM::fetch_handler(int event, void *edata) |
| 610 | { |
| 611 | Dbg(dbg_ctl, "[%s] calling fetch_plugin", __FUNCTION__); |
| 612 | |
| 613 | if (edata == read_vio) { |
| 614 | process_fetch_read(event); |
| 615 | } else if (edata == write_vio) { |
| 616 | process_fetch_write(event); |
| 617 | } else { |
| 618 | if (fetch_flags & TS_FETCH_FLAGS_STREAM) { |
| 619 | InvokePluginExt(event); |
| 620 | return 1; |
| 621 | } |
| 622 | InvokePlugin(callback_events.failure_event_id, nullptr); |
| 623 | cleanUp(); |
| 624 | } |
| 625 | return 1; |
| 626 | } |
| 627 | |
| 628 | void |
| 629 | FetchSM::ext_init(Continuation *cont, const char *method, const char *url, const char *version, const sockaddr *client_addr, |