Home
last modified time | relevance | path

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

/third_party/nghttp2/src/
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()
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 …]
Dbuffer.h39 size_t rleft() const { return last - pos; } in rleft() function
57 count = std::min(count, rleft()); in drain()
62 count = std::min(count, rleft()); in drain_reset()
Dshrpx_connection.cc178 if (wbuf.rleft()) { in shrpx_bio_write()
211 if (conn->tls.initial_handshake_done && rbuf.rleft() == 0) { in shrpx_bio_read()
223 if (rbuf.rleft() == 0) { in shrpx_bio_read()
415 tls.wbuf.rleft()) && in tls_handshake()
416 tls.earlybuf.rleft()) { in tls_handshake()
432 << tls.earlybuf.rleft() << " bytes"; in tls_handshake()
438 tls.wbuf.rleft()) && in tls_handshake()
439 tls.earlybuf.rleft()) { in tls_handshake()
499 if (rv != 1 && tls.wbuf.rleft()) { in tls_handshake()
517 if (tls.wbuf.rleft()) { in tls_handshake()
[all …]
Dmemchunk.h320 size_t rleft() const { return len; } in rleft() function
420 size_t rleft() const { return len; } in rleft() function
421 size_t rleft_buffered() const { return memchunks.rleft(); } in rleft_buffered()
427 auto n = rleft_buffered() - rleft(); in disable_peek()
429 assert(len == memchunks.rleft()); in disable_peek()
431 len = memchunks.rleft(); in disable_peek()
536 size_t rleft() const { return chunk->len(); } in rleft() function
550 count = std::min(count, rleft()); in drain()
555 count = std::min(count, rleft()); in drain_reset()
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()
Dshrpx_client_handler.cc117 if (rb_.rleft() && on_read() != 0) { in read_clear()
120 if (rb_.rleft() == 0) { in read_clear()
134 if (rb_.rleft() == 0) { in read_clear()
218 if (rb_.rleft() && on_read() != 0) { in read_tls()
221 if (rb_.rleft() == 0) { in read_tls()
235 if (rb_.rleft() == 0) { in read_tls()
312 auto nread = std::min(left_connhd_len_, rb_.rleft()); in upstream_http2_connhd_read()
341 auto nread = std::min(left_connhd_len_, rb_.rleft()); in upstream_http1_connhd_read()
1053 input->remove(*output, input->rleft()); in perform_http2_upgrade()
1150 conn_.tls.rbuf.append(rb_.pos(), rb_.rleft()); in on_proxy_protocol_finish()
[all …]
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()
Dh2load_http2_session.cc182 if (wb.rleft() >= BACKOFF_WRITE_BUFFER_THRES) { in send_callback()
297 nghttp2_session_want_write(session_) == 0 && client_->wb.rleft() == 0) { in on_read()
313 nghttp2_session_want_write(session_) == 0 && client_->wb.rleft() == 0) { in on_write()
Dshrpx_http2_upstream.cc851 if (body->rleft() == 0) { in send_data_callback()
867 return wb->rleft() >= max_buffer_size ? NGHTTP2_ERR_PAUSE : 0; in send_data_callback()
1142 if (rb->rleft()) { in on_read()
1143 rv = nghttp2_session_mem_recv(session_, rb->pos(), rb->rleft()); in on_read()
1154 assert(static_cast<size_t>(rv) == rb->rleft()); in on_read()
1160 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in on_read()
1209 if (wb_.rleft() >= max_buffer_size_) { in on_write()
1228 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in on_write()
1442 auto nread = std::min(body->rleft(), length); in downstream_data_read_callback()
1449 std::min(nread, static_cast<size_t>(256)) + 9 + buffer->rleft()) { in downstream_data_read_callback()
[all …]
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()
Dshrpx_http_downstream_connection.cc703 downstream_->get_blocked_request_buf()->rleft() || in push_request_headers()
715 if (src->rleft()) { in process_blocked_request_buf()
719 auto chunk_size_hex = util::utox(src->rleft()); in process_blocked_request_buf()
877 if (downstream_->get_response_buf()->rleft() <= in resume_read()
1193 if (input->rleft() == 0) { in write_first()
1239 while (input->rleft() > 0) { in write_clear()
1267 if (input->rleft() == 0) { in write_clear()
1360 while (input->rleft() > 0) { in write_tls()
1391 if (input->rleft() == 0) { in write_tls()
DHttpServer.cc659 if (wb_.rleft() > 0) { in write_clear()
661 while ((nwrite = write(fd_, wb_.pos, wb_.rleft())) == -1 && in write_clear()
678 if (wb_.rleft() == 0) { in write_clear()
683 if (wb_.rleft() == 0) { in write_clear()
690 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in write_clear()
785 if (wb_.rleft() > 0) { in write_tls()
786 auto rv = SSL_write(ssl_, wb_.pos, wb_.rleft()); in write_tls()
809 if (wb_.rleft() == 0) { in write_tls()
814 if (wb_.rleft() == 0) { in write_tls()
821 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in write_tls()
Dshrpx_memcached_connection.h86 size_t left() const { return headbuf.rleft() + send_value_left; } in left()
Dshrpx_http2_session.cc1473 if (src->rleft()) { in on_frame_send_callback()
1581 if (input->rleft() == 0) { in send_data_callback()
1758 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in downstream_read()
1783 if (wb_.rleft() >= MAX_BUFFER_SIZE) { in downstream_write()
1789 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in downstream_write()
2032 if (wb_.rleft() > 0) { in write_clear()
2056 if (wb_.rleft() == 0) { in write_clear()
2138 if (wb_.rleft() > 0) { in write_tls()
2167 if (wb_.rleft() == 0) { in write_tls()
Dshrpx_https_upstream.cc586 if (rb->rleft() == 0 || handler_->get_should_close_after_write()) { in on_read()
594 auto rv = downstream->push_upload_data_chunk(rb->pos(), rb->rleft()); in on_read()
628 rb->rleft()); in on_read()
632 ? rb->rleft() in on_read()
720 if (output->rleft() > 0) { in on_write()
1519 return buf->rleft() == 0; in response_empty()
Dshrpx_downstream.cc634 return blocked_request_buf_.rleft() + request_buf_.rleft() >= in request_buf_full()
745 return response_buf_.rleft() >= downstreamconf.response_buffer_size; in response_buf_full()
1111 !resp_.connection_close && request_buf_.rleft() == 0; in can_detach_downstream_connection()
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()
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()
Dshrpx_log.h196 size_t rleft() { return last_ - begin_; } in rleft() function
Dnghttp.cc1257 nghttp2_session_want_write(session) == 0 && wb.rleft() == 0) { in on_read()
1268 if (wb.rleft() >= 16384) { in on_write()
1288 nghttp2_session_want_write(session) == 0 && wb.rleft() == 0) { in on_write()
Dhttp2_test.cc250 CU_ASSERT(0 == buf.rleft()); in test_http2_build_http1_headers_from_headers()
Dh2load.cc1017 if (wb.rleft() >= BACKOFF_WRITE_BUFFER_THRES) { in on_write()
/third_party/skia/third_party/externals/libwebp/src/dsp/
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()
/third_party/flutter/skia/third_party/externals/libwebp/src/dsp/
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()