Home
last modified time | relevance | path

Searched refs:rleft (Results 1 - 25 of 25) sorted by relevance

/third_party/nghttp2/src/
H A Dbuffer_test.cc41 CU_ASSERT(0 == b.rleft()); in test_buffer_write()
46 CU_ASSERT(3 == b.rleft()); in test_buffer_write()
52 CU_ASSERT(0 == b.rleft()); in test_buffer_write()
60 CU_ASSERT(13 == b.rleft()); in test_buffer_write()
67 CU_ASSERT(0 == b.rleft()); in test_buffer_write()
73 CU_ASSERT(5 == b.rleft()); in test_buffer_write()
H A Dmemchunk_test.cc109 CU_ASSERT(17 == chunks.rleft()); in test_memchunks_append()
118 CU_ASSERT(9 == chunks.rleft()); in test_memchunks_append()
124 CU_ASSERT(0 == chunks.rleft()); in test_memchunks_append()
208 CU_ASSERT(32 == chunks.rleft()); in test_memchunks_reset()
212 CU_ASSERT(0 == chunks.rleft()); in test_memchunks_reset()
235 CU_ASSERT(32 == pchunks.rleft()); in test_peek_memchunks_append()
240 CU_ASSERT(32 == pchunks.rleft()); in test_peek_memchunks_append()
247 CU_ASSERT(20 == pchunks.rleft()); in test_peek_memchunks_append()
254 CU_ASSERT(0 == pchunks.rleft()); in test_peek_memchunks_append()
275 CU_ASSERT(20 == pchunks.rleft()); in test_peek_memchunks_disable_peek_drain()
[all...]
H A Dshrpx_connection.cc189 if (wbuf.rleft()) { in shrpx_bio_write()
222 if (conn->tls.initial_handshake_done && rbuf.rleft() == 0) { in shrpx_bio_read()
234 if (rbuf.rleft() == 0) { in shrpx_bio_read()
427 tls.wbuf.rleft()) && in tls_handshake()
428 tls.earlybuf.rleft()) { in tls_handshake()
444 << tls.earlybuf.rleft() << " bytes"; in tls_handshake()
450 tls.wbuf.rleft()) && in tls_handshake()
451 tls.earlybuf.rleft()) { in tls_handshake()
516 tls.wbuf.rleft()) { in tls_handshake()
534 if (tls.wbuf.rleft()) { in tls_handshake()
[all...]
H A Dbuffer.h39 size_t rleft() const { return last - pos; } in rleft() function
55 // Drains min(rleft(), |count|) bytes from start of the buffer.
57 count = std::min(count, rleft()); in drain()
62 count = std::min(count, rleft()); in drain_reset()
H A Dmemchunk.h404 size_t rleft() const { return len; } in rleft() function
510 size_t rleft() const { return len; } in rleft() function
511 size_t rleft_buffered() const { return memchunks.rleft(); } in rleft_buffered()
517 auto n = rleft_buffered() - rleft(); in disable_peek()
519 assert(len == memchunks.rleft()); in disable_peek()
521 len = memchunks.rleft(); in disable_peek()
540 // memchunk.rleft() must hold.
626 size_t rleft() const { return chunk->len(); } in rleft() function
640 count = std::min(count, rleft()); in drain()
645 count = std::min(count, rleft()); in drain_reset()
[all...]
H A Dshrpx_live_check.cc480 if (wb_.rleft() > 0) { in write_tls()
505 if (wb_.rleft() == 0) { in write_tls()
549 if (wb_.rleft() > 0) { in write_clear()
574 if (wb_.rleft() == 0) { in write_clear()
608 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in on_read()
641 if (wb_.rleft() >= MAX_BUFFER_SIZE) { in on_write()
647 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in on_write()
H A Dshrpx_client_handler.cc121 if (rb_.rleft() && on_read() != 0) { in read_clear()
124 if (rb_.rleft() == 0) { in read_clear()
138 if (rb_.rleft() == 0) { in read_clear()
187 assert(rb_.rleft() == 0); in proxy_protocol_peek_clear()
251 if (rb_.rleft() && on_read() != 0) { in read_tls()
254 if (rb_.rleft() == 0) { in read_tls()
268 if (rb_.rleft() == 0) { in read_tls()
359 auto nread = std::min(left_connhd_len_, rb_.rleft()); in upstream_http2_connhd_read()
388 auto nread = std::min(left_connhd_len_, rb_.rleft()); in upstream_http1_connhd_read()
1191 input->remove(*output, input->rleft()); in perform_http2_upgrade()
[all...]
H A Dshrpx_rate_limit.cc112 (SSL_pending(conn_->tls.ssl) == 0 && conn_->tls.rbuf.rleft() == 0 && in handle_tls_pending_read()
114 conn_->tls.earlybuf.rleft() == 0))) { in handle_tls_pending_read()
H A Dshrpx_http2_upstream.cc859 if (body->rleft() == 0) { in send_data_callback()
875 return wb->rleft() >= max_buffer_size ? NGHTTP2_ERR_PAUSE : 0; in send_data_callback()
1152 if (rb->rleft()) { in on_read()
1153 rv = nghttp2_session_mem_recv(session_, rb->pos(), rb->rleft()); in on_read()
1164 assert(static_cast<size_t>(rv) == rb->rleft()); in on_read()
1170 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in on_read()
1219 if (wb_.rleft() >= max_buffer_size_) { in on_write()
1238 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in on_write()
1452 auto nread = std::min(body->rleft(), length); in downstream_data_read_callback()
1459 std::min(nread, static_cast<size_t>(256)) + 9 + buffer->rleft()) { in downstream_data_read_callback()
[all...]
H A Dh2load_http2_session.cc165 if (wb.rleft() >= BACKOFF_WRITE_BUFFER_THRES) { in send_callback()
282 nghttp2_session_want_write(session_) == 0 && client_->wb.rleft() == 0) { in on_read()
298 nghttp2_session_want_write(session_) == 0 && client_->wb.rleft() == 0) { in on_write()
H A Dshrpx_http_downstream_connection.cc721 downstream_->get_blocked_request_buf()->rleft() || in push_request_headers()
733 if (src->rleft()) { in process_blocked_request_buf()
737 auto chunk_size_hex = util::utox(src->rleft()); in process_blocked_request_buf()
895 if (downstream_->get_response_buf()->rleft() <= in resume_read()
1237 if (input->rleft() == 0) { in write_first()
1295 while (input->rleft() > 0) { in write_clear()
1323 if (input->rleft() == 0) { in write_clear()
1428 while (input->rleft() > 0) { in write_tls()
1459 if (input->rleft() == 0) { in write_tls()
H A Dshrpx_memcached_connection.cc145 assert(recvbuf_.rleft() == 0); in disconnect()
620 if (buf.headbuf.rleft()) { in fill_request_buffer()
621 iov[iovcnt++] = {buf.headbuf.pos, buf.headbuf.rleft()}; in fill_request_buffer()
644 auto n = std::min(static_cast<size_t>(nwrite), buf.headbuf.rleft()); in drain_send_queue()
651 if (buf.headbuf.rleft() || buf.send_value_left) { in drain_send_queue()
H A Dshrpx_https_upstream.cc632 if (rb->rleft() == 0 || handler_->get_should_close_after_write()) { in on_read()
640 auto rv = downstream->push_upload_data_chunk(rb->pos(), rb->rleft()); in on_read()
674 rb->rleft()); in on_read()
682 rb->rleft()); in on_read()
687 ? rb->rleft() in on_read()
775 if (output->rleft() > 0) { in on_write()
1563 return buf->rleft() == 0; in response_empty()
H A DHttpServer.cc670 if (wb_.rleft() > 0) { in write_clear()
672 while ((nwrite = write(fd_, wb_.pos, wb_.rleft())) == -1 && in write_clear()
689 if (wb_.rleft() == 0) { in write_clear()
694 if (wb_.rleft() == 0) { in write_clear()
701 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in write_clear()
796 if (wb_.rleft() > 0) { in write_tls()
797 auto rv = SSL_write(ssl_, wb_.pos, wb_.rleft()); in write_tls()
820 if (wb_.rleft() == 0) { in write_tls()
825 if (wb_.rleft() == 0) { in write_tls()
832 nghttp2_session_want_write(session_) == 0 && wb_.rleft() in write_tls()
[all...]
H A Dshrpx_http2_session.cc1486 if (src->rleft()) { in on_frame_send_callback()
1594 if (input->rleft() == 0) { in send_data_callback()
1774 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in downstream_read()
1799 if (wb_.rleft() >= MAX_BUFFER_SIZE) { in downstream_write()
1805 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in downstream_write()
2048 if (wb_.rleft() > 0) { in write_clear()
2072 if (wb_.rleft() == 0) { in write_clear()
2154 if (wb_.rleft() > 0) { in write_tls()
2183 if (wb_.rleft() == 0) { in write_tls()
H A Dshrpx_memcached_connection.h86 size_t left() const { return headbuf.rleft() + send_value_left; } in left()
H A Dshrpx_http2_downstream_connection.cc185 auto nread = std::min(input->rleft(), length); in http2_data_read_callback()
186 auto input_empty = input->rleft() == nread; in http2_data_read_callback()
H A Dshrpx_log.cc176 SEVERITY_STR[severity_].c_str(), static_cast<int>(rleft()), in ~Log()
180 SEVERITY_STR[severity_].c_str(), static_cast<int>(rleft()), begin_, in ~Log()
198 filename_, linenum_, static_cast<int>(rleft()), begin_); in ~Log()
H A Dshrpx_downstream.cc644 return blocked_request_buf_.rleft() + request_buf_.rleft() >= in request_buf_full()
755 return response_buf_.rleft() >= downstreamconf.response_buffer_size; in response_buf_full()
1117 !resp_.connection_close && request_buf_.rleft() == 0; in can_detach_downstream_connection()
H A Dshrpx_log.h196 size_t rleft() { return last_ - begin_; } in rleft() function in shrpx::Log
H A Dnghttp.cc1278 nghttp2_session_want_write(session) == 0 && wb.rleft() == 0) { in on_read()
1289 if (wb.rleft() >= 16384) { in on_write()
1309 nghttp2_session_want_write(session) == 0 && wb.rleft() == 0) { in on_write()
H A Dhttp2_test.cc250 CU_ASSERT(0 == buf.rleft()); in test_http2_build_http1_headers_from_headers()
H A Dh2load.cc1254 if (wb.rleft() >= BACKOFF_WRITE_BUFFER_THRES) { in on_write()
H A Dshrpx_http3_upstream.cc2516 ULOG(INFO, this) << "response unacked_left=" << body->rleft() in http_stream_close()
/third_party/skia/third_party/externals/libwebp/src/dsp/
H A Denc_msa.c529 const v16u8 rleft = LD_UB(left); in DCMode16x16() local
530 const v8u16 dcleft = __msa_hadd_u_h(rleft, rleft); in DCMode16x16()
535 const v16u8 rleft = LD_UB(left); in DCMode16x16() local
536 const v8u16 dcleft = __msa_hadd_u_h(rleft, rleft); in DCMode16x16()

Completed in 44 milliseconds