@@ -669,19 +669,15 @@ int phongo_stream_close(mongoc_stream_t *stream) /* {{{ */
669
669
void php_phongo_set_timeout (php_phongo_stream_socket * base_stream , int32_t timeout_msec ) /* {{{ */
670
670
{
671
671
TSRMLS_FETCH_FROM_CTX (base_stream -> tsrm_ls );
672
+ struct timeval rtimeout = {0 , 0 };
672
673
673
674
if (timeout_msec > 0 ) {
674
- struct timeval rtimeout = {0 , 0 };
675
-
676
675
rtimeout .tv_sec = timeout_msec / 1000 ;
677
676
rtimeout .tv_usec = (timeout_msec % 1000 ) * 1000 ;
678
-
679
- php_stream_set_option (base_stream -> stream , PHP_STREAM_OPTION_READ_TIMEOUT , 0 , & rtimeout );
680
- mongoc_log (MONGOC_LOG_LEVEL_DEBUG , MONGOC_LOG_DOMAIN , "Setting timeout to: %d" , timeout_msec );
681
- } else if (timeout_msec == 0 ) {
682
- mongoc_log (MONGOC_LOG_LEVEL_DEBUG , MONGOC_LOG_DOMAIN , "Setting timeout to 0" );
683
- php_stream_set_option (base_stream -> stream , PHP_STREAM_OPTION_READ_TIMEOUT , 0 , NULL );
684
677
}
678
+
679
+ php_stream_set_option (base_stream -> stream , PHP_STREAM_OPTION_READ_TIMEOUT , 0 , & rtimeout );
680
+ mongoc_log (MONGOC_LOG_LEVEL_DEBUG , MONGOC_LOG_DOMAIN , "Setting timeout to: %d" , timeout_msec );
685
681
} /* }}} */
686
682
687
683
ssize_t phongo_stream_writev (mongoc_stream_t * stream , mongoc_iovec_t * iov , size_t iovcnt , int32_t timeout_msec ) /* {{{ */
0 commit comments