Searched refs:readTimeout_ (Results 1 – 5 of 5) sorted by relevance
77 readTimeout_ = DEFAULT_READ_TIMEOUT; in this()221 auto oldReadTimeout = readTimeout_; in seekToChunk()222 scope (exit) readTimeout_ = oldReadTimeout; in seekToChunk()223 readTimeout_ = dur!"hnsecs"(0); in seekToChunk()262 return readTimeout_; in readTimeout()267 readTimeout_ = value; in readTimeout()381 if (readTimeout_ < dur!"hnsecs"(0)) { in readEvent()383 Thread.sleep(-readTimeout_); in readEvent()385 } else if (readTimeout_ == dur!"hnsecs"(0) || timeoutExpired) { in readEvent()391 Thread.sleep(readTimeout_); in readEvent()[all …]
72 private int readTimeout_ = 0; field in THttpClient170 readTimeout_ = timeout; in setReadTimeout()235 if (readTimeout_ > 0) { in getRequestConfig()236 requestConfig = RequestConfig.copy(requestConfig).setSocketTimeout(readTimeout_).build(); in getRequestConfig()359 if (readTimeout_ > 0) { in flush()360 connection.setReadTimeout(readTimeout_); in flush()
49 private int readTimeout_ = 0; field in THttpClient62 readTimeout_ = timeout; in setReadTimeout()
70 readTimeout_(NO_TAIL_READ_TIMEOUT), in TFileTransport()629 if (readTimeout_ == TAIL_READ_TIMEOUT) { in readEvent()632 } else if (readTimeout_ == NO_TAIL_READ_TIMEOUT) { in readEvent()636 } else if (readTimeout_ > 0) { in readEvent()642 THRIFT_SLEEP_USEC(readTimeout_ * 1000); in readEvent()772 } else if (readTimeout_ == TAIL_READ_TIMEOUT) { in performRecovery()
209 void setReadTimeout(int32_t readTimeout) override { readTimeout_ = readTimeout; } in setReadTimeout()210 int32_t getReadTimeout() override { return readTimeout_; } in getReadTimeout()299 int32_t readTimeout_; variable
