diff options
| author | Simo Sorce <ssorce@redhat.com> | 2010-05-25 15:28:35 -0400 |
|---|---|---|
| committer | Simo Sorce <idra@samba.org> | 2011-08-13 09:54:16 -0400 |
| commit | 15efcbaa09472b306a875178ee535a06d1b01811 (patch) | |
| tree | 3916f26e079ccb3490fc12eccb6dbf9d5974e131 /source4/lib/stream | |
| parent | edc32665d0f5cfd5d86f975c8ac8e8ff100956f7 (diff) | |
| download | samba-15efcbaa09472b306a875178ee535a06d1b01811.tar.gz samba-15efcbaa09472b306a875178ee535a06d1b01811.tar.xz samba-15efcbaa09472b306a875178ee535a06d1b01811.zip | |
s4:lib: use tevent_ fns names instead of legcay event_ ones
Diffstat (limited to 'source4/lib/stream')
| -rw-r--r-- | source4/lib/stream/packet.c | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/source4/lib/stream/packet.c b/source4/lib/stream/packet.c index 98343707c1..545d518cff 100644 --- a/source4/lib/stream/packet.c +++ b/source4/lib/stream/packet.c @@ -251,14 +251,14 @@ _PUBLIC_ void packet_recv(struct packet_context *pc) bool recv_retry = false; if (pc->processing) { - EVENT_FD_NOT_READABLE(pc->fde); + TEVENT_FD_NOT_READABLE(pc->fde); pc->processing++; return; } if (pc->recv_disable) { pc->recv_need_enable = true; - EVENT_FD_NOT_READABLE(pc->fde); + TEVENT_FD_NOT_READABLE(pc->fde); return; } @@ -424,7 +424,7 @@ next_partial: if (pc->processing) { if (pc->processing > 1) { - EVENT_FD_READABLE(pc->fde); + TEVENT_FD_READABLE(pc->fde); } pc->processing = 0; } @@ -457,7 +457,7 @@ next_partial: return; } - event_add_timed(pc->ev, pc, timeval_zero(), packet_next_event, pc); + tevent_add_timer(pc->ev, pc, timeval_zero(), packet_next_event, pc); } @@ -476,11 +476,11 @@ _PUBLIC_ void packet_recv_enable(struct packet_context *pc) { if (pc->recv_need_enable) { pc->recv_need_enable = false; - EVENT_FD_READABLE(pc->fde); + TEVENT_FD_READABLE(pc->fde); } pc->recv_disable = false; if (pc->num_read != 0 && pc->packet_size >= pc->num_read) { - event_add_timed(pc->ev, pc, timeval_zero(), packet_next_event, pc); + tevent_add_timer(pc->ev, pc, timeval_zero(), packet_next_event, pc); } } @@ -523,7 +523,7 @@ _PUBLIC_ void packet_queue_run(struct packet_context *pc) /* we're out of requests to send, so don't wait for write events any more */ - EVENT_FD_NOT_WRITEABLE(pc->fde); + TEVENT_FD_NOT_WRITEABLE(pc->fde); } /* @@ -561,7 +561,7 @@ _PUBLIC_ NTSTATUS packet_send_callback(struct packet_context *pc, DATA_BLOB blob return NT_STATUS_NO_MEMORY; } - EVENT_FD_WRITEABLE(pc->fde); + TEVENT_FD_WRITEABLE(pc->fde); return NT_STATUS_OK; } |