Added a check to see if the operation has been cancelled. (stream_write):
2001-11-19 Jeffrey Stedfast <fejj@ximian.com> * camel-tcp-stream-ssl.c (stream_read): Added a check to see if the operation has been cancelled. (stream_write): Same. svn path=/trunk/; revision=14751
This commit is contained in:

committed by
Jeffrey Stedfast

parent
5d3580719a
commit
9b0ffde9c0
@ -1,3 +1,9 @@
|
|||||||
|
2001-11-19 Jeffrey Stedfast <fejj@ximian.com>
|
||||||
|
|
||||||
|
* camel-tcp-stream-ssl.c (stream_read): Added a check to see if
|
||||||
|
the operation has been cancelled.
|
||||||
|
(stream_write): Same.
|
||||||
|
|
||||||
2001-11-19 Jeffrey Stedfast <fejj@ximian.com>
|
2001-11-19 Jeffrey Stedfast <fejj@ximian.com>
|
||||||
|
|
||||||
Updates for compliance with rfc2231
|
Updates for compliance with rfc2231
|
||||||
|
@ -183,6 +183,11 @@ stream_read (CamelStream *stream, char *buffer, size_t n)
|
|||||||
ssize_t nread;
|
ssize_t nread;
|
||||||
|
|
||||||
do {
|
do {
|
||||||
|
if (camel_operation_cancel_check (NULL)) {
|
||||||
|
errno = EINTR;
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
|
||||||
nread = PR_Read (tcp_stream_ssl->priv->sockfd, buffer, n);
|
nread = PR_Read (tcp_stream_ssl->priv->sockfd, buffer, n);
|
||||||
if (nread == -1)
|
if (nread == -1)
|
||||||
set_errno (PR_GetError ());
|
set_errno (PR_GetError ());
|
||||||
@ -198,6 +203,11 @@ stream_write (CamelStream *stream, const char *buffer, size_t n)
|
|||||||
ssize_t w, written = 0;
|
ssize_t w, written = 0;
|
||||||
|
|
||||||
do {
|
do {
|
||||||
|
if (camel_operation_cancel_check (NULL)) {
|
||||||
|
errno = EINTR;
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
|
||||||
do {
|
do {
|
||||||
w = PR_Write (tcp_stream_ssl->priv->sockfd, buffer + written, n - written);
|
w = PR_Write (tcp_stream_ssl->priv->sockfd, buffer + written, n - written);
|
||||||
if (w == -1)
|
if (w == -1)
|
||||||
|
Reference in New Issue
Block a user