Changeset 1266 for pjproject/trunk/pjlib/src/pj/ioqueue_common_abs.c
- Timestamp:
- May 11, 2007 3:14:34 PM (18 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
pjproject/trunk/pjlib/src/pj/ioqueue_common_abs.c
r1159 r1266 302 302 } else { 303 303 pj_assert(!"Invalid operation type!"); 304 write_op->op = 0;304 write_op->op = PJ_IOQUEUE_OP_NONE; 305 305 send_rc = PJ_EBUG; 306 306 } … … 319 319 { 320 320 321 write_op->op = 0;321 write_op->op = PJ_IOQUEUE_OP_NONE; 322 322 323 323 if (h->fd_type != PJ_SOCK_DGRAM) { … … 376 376 accept_op = h->accept_list.next; 377 377 pj_list_erase(accept_op); 378 accept_op->op = 0;378 accept_op->op = PJ_IOQUEUE_OP_NONE; 379 379 380 380 /* Clear bit in fdset if there is no more pending accept */ … … 418 418 419 419 if ((read_op->op == PJ_IOQUEUE_OP_RECV_FROM)) { 420 read_op->op = 0;420 read_op->op = PJ_IOQUEUE_OP_NONE; 421 421 rc = pj_sock_recvfrom(h->fd, read_op->buf, &bytes_read, 422 422 read_op->flags, … … 424 424 read_op->rmt_addrlen); 425 425 } else if ((read_op->op == PJ_IOQUEUE_OP_RECV)) { 426 read_op->op = 0;426 read_op->op = PJ_IOQUEUE_OP_NONE; 427 427 rc = pj_sock_recv(h->fd, read_op->buf, &bytes_read, 428 428 read_op->flags); 429 429 } else { 430 430 pj_assert(read_op->op == PJ_IOQUEUE_OP_READ); 431 read_op->op = 0;431 read_op->op = PJ_IOQUEUE_OP_NONE; 432 432 /* 433 433 * User has specified pj_ioqueue_read(). … … 562 562 563 563 read_op = (struct read_operation*)op_key; 564 read_op->op = 0;564 read_op->op = PJ_IOQUEUE_OP_NONE; 565 565 566 566 /* Check if key is closing. */ … … 631 631 632 632 read_op = (struct read_operation*)op_key; 633 read_op->op = 0;633 read_op->op = PJ_IOQUEUE_OP_NONE; 634 634 635 635 /* Try to see if there's data immediately available. … … 769 769 770 770 write_op->op = PJ_IOQUEUE_OP_SEND; 771 write_op->buf = ( void*)data;771 write_op->buf = (char*)data; 772 772 write_op->size = *length; 773 773 write_op->written = 0; … … 849 849 * Check that address storage can hold the address parameter. 850 850 */ 851 PJ_ASSERT_RETURN(addrlen <= sizeof(pj_sockaddr_in), PJ_EBUG);851 PJ_ASSERT_RETURN(addrlen <= (int)sizeof(pj_sockaddr_in), PJ_EBUG); 852 852 853 853 /* … … 884 884 885 885 write_op->op = PJ_IOQUEUE_OP_SEND_TO; 886 write_op->buf = ( void*)data;886 write_op->buf = (char*)data; 887 887 write_op->size = *length; 888 888 write_op->written = 0; … … 921 921 922 922 accept_op = (struct accept_operation*)op_key; 923 accept_op->op = 0;923 accept_op->op = PJ_IOQUEUE_OP_NONE; 924 924 925 925 /* Fast track: … … 1053 1053 if (op_rec == (void*)op_key) { 1054 1054 pj_list_erase(op_rec); 1055 op_rec->op = 0;1055 op_rec->op = PJ_IOQUEUE_OP_NONE; 1056 1056 pj_mutex_unlock(key->mutex); 1057 1057 … … 1067 1067 if (op_rec == (void*)op_key) { 1068 1068 pj_list_erase(op_rec); 1069 op_rec->op = 0;1069 op_rec->op = PJ_IOQUEUE_OP_NONE; 1070 1070 pj_mutex_unlock(key->mutex); 1071 1071 … … 1081 1081 if (op_rec == (void*)op_key) { 1082 1082 pj_list_erase(op_rec); 1083 op_rec->op = 0;1083 op_rec->op = PJ_IOQUEUE_OP_NONE; 1084 1084 pj_mutex_unlock(key->mutex); 1085 1085
Note: See TracChangeset
for help on using the changeset viewer.