Changeset 126 for pjproject/trunk/pjlib/src/pj/ioqueue_common_abs.c

Timestamp:

Jan 20, 2006 9:03:36 PM (18 years ago)

Author:

bennylp

Message:

Completed testing for WinCE port

File:

• pjproject/trunk/pjlib/src/pj/ioqueue_common_abs.c (modified) (5 diffs)

pjproject/trunk/pjlib/src/pj/ioqueue_common_abs.c

@@ -248 +248 @@
         if (h->fd_type == PJ_SOCK_DGRAM) {
             pj_list_erase(write_op);
-            write_op->op = 0;
 
             if (pj_list_empty(&h->write_list))
@@ -262 +261 @@
         sent = write_op->size - write_op->written;
         if (write_op->op == PJ_IOQUEUE_OP_SEND) {
+            write_op->op = 0;
             send_rc = pj_sock_send(h->fd, write_op->buf+write_op->written,
                                    &sent, write_op->flags);
         } else if (write_op->op == PJ_IOQUEUE_OP_SEND_TO) {
+            write_op->op = 0;
             send_rc = pj_sock_sendto(h->fd, 
                                      write_op->buf+write_op->written,
@@ -272 +273 @@
         } else {
             pj_assert(!"Invalid operation type!");
+            write_op->op = 0;
             send_rc = PJ_EBUG;
         }
@@ -371 +373 @@
         read_op = h->read_list.next;
         pj_list_erase(read_op);
-        read_op->op = 0;
 
         /* Clear fdset if there is no pending read. */
@@ -383 +384 @@
 
         if ((read_op->op == PJ_IOQUEUE_OP_RECV_FROM)) {
+            read_op->op = 0;
             rc = pj_sock_recvfrom(h->fd, read_op->buf, &bytes_read, 0,
                                   read_op->rmt_addr, 
                                   read_op->rmt_addrlen);
         } else if ((read_op->op == PJ_IOQUEUE_OP_RECV)) {
+            read_op->op = 0;
             rc = pj_sock_recv(h->fd, read_op->buf, &bytes_read, 0);
         } else {
             pj_assert(read_op->op == PJ_IOQUEUE_OP_READ);
+            read_op->op = 0;
             /*
              * User has specified pj_ioqueue_read().