diff options
| author | Benny Prijono <bennylp@teluu.com> | 2007-05-03 19:56:21 +0000 |
|---|---|---|
| committer | Benny Prijono <bennylp@teluu.com> | 2007-05-03 19:56:21 +0000 |
| commit | 0a2d5c3cd9d32c77fcf23976736324ebb0565d44 (patch) | |
| tree | bebc99d373b81095046eda50cc6383040beb8835 /pjlib/src/pj/ioqueue_symbian.cpp | |
| parent | abb1aee315f44c03cc3da3627a93651cdd9ca15e (diff) | |
Misc Symbian fixes, looks good
git-svn-id: http://svn.pjsip.org/repos/pjproject/trunk@1248 74dad513-b988-da41-8d7b-12977e46ad98
Diffstat (limited to 'pjlib/src/pj/ioqueue_symbian.cpp')
| -rw-r--r-- | pjlib/src/pj/ioqueue_symbian.cpp | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/pjlib/src/pj/ioqueue_symbian.cpp b/pjlib/src/pj/ioqueue_symbian.cpp index 6768cc01..73f0f04a 100644 --- a/pjlib/src/pj/ioqueue_symbian.cpp +++ b/pjlib/src/pj/ioqueue_symbian.cpp @@ -648,6 +648,10 @@ PJ_DEF(pj_status_t) pj_ioqueue_recv( pj_ioqueue_key_t *key, pj_ssize_t *length, pj_uint32_t flags ) { + // If socket has reader, delete it. + if (key->cbObj->get_pj_socket()->Reader()) + key->cbObj->get_pj_socket()->DestroyReader(); + // Clear flag flags &= ~PJ_IOQUEUE_ALWAYS_ASYNC; return key->cbObj->StartRead(op_key, buffer, length, flags, NULL, NULL); @@ -667,6 +671,10 @@ PJ_DEF(pj_status_t) pj_ioqueue_recvfrom( pj_ioqueue_key_t *key, pj_sockaddr_t *addr, int *addrlen) { + // If socket has reader, delete it. + if (key->cbObj->get_pj_socket()->Reader()) + key->cbObj->get_pj_socket()->DestroyReader(); + if (key->cbObj->IsActive()) return PJ_EBUSY; |