Home
last modified time | relevance | path

Searched refs:GPR_MIN (Results 1 – 22 of 22) sorted by relevance

/external/grpc-grpc/src/core/tsi/alts/frame_protector/
Dframe_handler.cc83 GPR_MIN(*bytes_size, in alts_write_frame_bytes()
98 GPR_MIN(writer->input_size - writer->input_bytes_written, *bytes_size); in alts_write_frame_bytes()
168 size_t bytes_to_write = GPR_MIN( in alts_read_frame_bytes()
200 size_t bytes_to_write = GPR_MIN(*bytes_size, reader->bytes_remaining); in alts_read_frame_bytes()
Dalts_frame_protector.cc159 size_t bytes_to_buffer = GPR_MIN(*unprotected_bytes_size, in alts_protect()
269 GPR_MIN(impl->max_unprotected_frame_size - in alts_unprotect()
293 size_t bytes_to_write = GPR_MIN( in alts_unprotect()
388 GPR_MIN(*max_protected_frame_size, kMaxFrameLength); in alts_create_frame_protector()
/external/grpc-grpc/test/core/gpr/
Duseful_test.cc31 GPR_ASSERT(GPR_MIN(1, 2) == 1); in main()
33 GPR_ASSERT(GPR_MIN(2, 1) == 1); in main()
/external/grpc-grpc/src/core/lib/iomgr/
Dtimer_generic.cc259 g_num_shards = GPR_MIN(1, 2 * gpr_cpu_num_cores()); in timer_list_init()
601 if (next != nullptr) *next = GPR_MIN(*next, min_timer); in run_some_expired_timers()
646 *next = GPR_MIN(*next, g_shard_queue[0]->min_deadline); in run_some_expired_timers()
692 *next = GPR_MIN(*next, min_timer); in timer_check()
Dwakeup_fd_cv.cc47 newsize = GPR_MIN(g_cvfds.size * 2, g_cvfds.size + MAX_TABLE_RESIZE); in cv_fd_init()
Derror.cc204 (*err)->arena_capacity = static_cast<uint8_t> GPR_MIN( in get_placement()
Dresource_quota.cc700 (gpr_atm)GPR_MIN((size_t)GPR_ATM_MAX, size)); in grpc_resource_quota_resize()
/external/grpc-grpc/test/core/tsi/alts/frame_protector/
Dframe_handler_test.cc71 size_t bytes_written = GPR_MIN(write_length, handler->buffer_size - offset); in frame()
86 size_t bytes_read = GPR_MIN(read_length, handler->buffer_size - offset); in deframe()
/external/grpc-grpc/src/core/lib/gpr/
Duseful.h24 #define GPR_MIN(a, b) ((a) < (b) ? (a) : (b)) macro
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dwriting.cc329 return static_cast<uint32_t> GPR_MIN( in max_outgoing()
331 GPR_MIN(stream_remote_window(), t_->flow_control->remote_window())); in max_outgoing()
337 uint32_t send_bytes = static_cast<uint32_t> GPR_MIN( in FlushCompressedBytes()
Dhpack_encoder.cc618 c, GPR_MIN(c->max_table_size, max_table_size)); in grpc_chttp2_hpack_compressor_set_max_usable_size()
642 max_table_size = GPR_MIN(max_table_size, c->max_usable_size); in grpc_chttp2_hpack_compressor_set_max_table_size()
Dflow_control.h275 return static_cast<uint32_t> GPR_MIN( in target_window()
Dflow_control.cc322 target *= 1 - GPR_MIN(1, (memory_pressure - kHighMemPressure) / in AdjustForMemoryPressure()
Dhpack_parser.cc1582 uint8_t* target = start + GPR_MIN(MAX_PARSE_LENGTH, end - start); in grpc_chttp2_hpack_parser_parse()
Dchttp2_transport.cc1434 s->deadline = GPR_MIN(s->deadline, s->send_initial_metadata->deadline); in perform_stream_op_locked()
/external/grpc-grpc/test/core/util/
Dtrickle_endpoint.cc183 GPR_MIN(bytes, te->write_buffer.length), in grpc_trickle_endpoint_trickle()
/external/grpc-grpc/src/core/tsi/alts/zero_copy_frame_protector/
Dalts_zero_copy_grpc_protector.cc271 GPR_MIN(*max_protected_frame_size, kMaxFrameLength); in alts_zero_copy_grpc_protector_create()
/external/grpc-grpc/test/core/channel/
Dchannel_trace_test.cc107 GPR_MIN(expected_num_event_logged, max_nodes)); in ValidateChannelTrace()
/external/grpc-grpc/src/core/lib/surface/
Dchannel.cc266 static_cast<gpr_atm>(GPR_MIN(cur - 1, (255 * cur + size) / 256))); in grpc_channel_update_call_size_estimate()
Dcall.cc358 send_deadline = GPR_MIN(send_deadline, args->parent->send_deadline); in grpc_call_create()
/external/grpc-grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc305 s->deadline = GPR_MIN(s->deadline, cs->write_buffer_deadline); in init_stream()
984 *dl = GPR_MIN(*dl, op->payload->send_initial_metadata in perform_stream_op()
/external/grpc-grpc/src/core/tsi/
Dfake_transport_security.cc423 GPR_MIN(impl->max_frame_size, in fake_zero_copy_grpc_protector_protect()