Home
last modified time | relevance | path

Searched refs:send_size (Results 1 – 18 of 18) sorted by relevance

/third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/netinet/
Dsctp_output.c7596 asoc->peers_rwnd, data_list[i]->send_size, SCTP_BASE_SYSCTL(sctp_peer_chunk_oh));
7599 (uint32_t) (data_list[i]->send_size + SCTP_BASE_SYSCTL(sctp_peer_chunk_oh)));
8063 chk->book_size = chk->send_size = (uint16_t)(to_move + SCTP_DATA_CHUNK_OVERHEAD(stcb));
8143 asoc->out_tsnlog[asoc->tsn_out_at].sz = chk->send_size;
8157 dchkh->ch.chunk_length = htons(chk->send_size);
8170 ndchkh->ch.chunk_length = htons(chk->send_size);
8173 if (chk->send_size < SCTP_SIZE32(chk->book_size)) {
8178 pads = SCTP_SIZE32(chk->book_size) - chk->send_size;
8184 chk->send_size += pads;
8676 if ((chk->send_size < (int)(mtu - omtu)) ||
[all …]
Dsctp_indata.c868 if (asoc->size_on_reasm_queue >= tchk->send_size) { in sctp_handle_old_unordered_data()
869 asoc->size_on_reasm_queue -= tchk->send_size; in sctp_handle_old_unordered_data()
872 …ize_on_reasm_queue = %u smaller than chunk length %u", asoc->size_on_reasm_queue, tchk->send_size); in sctp_handle_old_unordered_data()
1028 chk->send_size = control->length; in sctp_inject_old_unordered_data()
1066 asoc->size_on_reasm_queue += chk->send_size; in sctp_inject_old_unordered_data()
1086 asoc->size_on_reasm_queue += chk->send_size; in sctp_inject_old_unordered_data()
1346 asoc->size_on_reasm_queue -= chk->send_size; in sctp_add_chk_to_control()
1595 asoc->size_on_reasm_queue += chk->send_size; in sctp_queue_data_for_reasm()
1622 asoc->size_on_reasm_queue += chk->send_size; in sctp_queue_data_for_reasm()
2209 chk->send_size = the_len; in sctp_process_a_data_chunk()
[all …]
Dsctputil.c457 sctp_clog.x.rwnd.send_size = snd_size; in sctp_log_rwnd()
477 sctp_clog.x.rwnd.send_size = flight_size; in sctp_log_rwnd_set()
3026 if (chk->send_size > eff_mtu) { in sctp_mtu_size_reset()
3031 if (chk->send_size > eff_mtu) { in sctp_mtu_size_reset()
3555 if (chk->send_size >= chkhdr_len) { in sctp_notify_send_failed()
3556 payload_len = chk->send_size - chkhdr_len; in sctp_notify_send_failed()
3566 (chk->send_size >= chk_len) && in sctp_notify_send_failed()
3567 (chk->send_size - chk_len < 4)) { in sctp_notify_send_failed()
3568 padding_len = chk->send_size - chk_len; in sctp_notify_send_failed()
3569 payload_len = chk->send_size - chkhdr_len - padding_len; in sctp_notify_send_failed()
[all …]
Dsctp_pcb.c7848 KASSERT(chk->send_size > 0, ("chunk has zero length"));
7849 if (asoc->size_on_reasm_queue >= chk->send_size) {
7850 asoc->size_on_reasm_queue -= chk->send_size;
7853 …size_on_reasm_queue = %u smaller than chunk length %u", asoc->size_on_reasm_queue, chk->send_size);
7908 KASSERT(chk->send_size > 0, ("chunk has zero length"));
7909 if (asoc->size_on_reasm_queue >= chk->send_size) {
7910 asoc->size_on_reasm_queue -= chk->send_size;
7913 …size_on_reasm_queue = %u smaller than chunk length %u", asoc->size_on_reasm_queue, chk->send_size);
Dsctp_structs.h493 uint16_t send_size; member
Dsctp_uio.h851 uint32_t send_size; member
Dsctp_input.c3809 clen = chk->send_size;
4406 chk->book_size = chk->send_size = sizeof(struct sctp_chunkhdr);
4428 ch->chunk_length = htons(chk->send_size);
4429 SCTP_BUF_LEN(chk->data) = SCTP_SIZE32(chk->send_size);
Dsctp_timer.c679 stcb->asoc.peers_rwnd += chk->send_size;
Dsctp_cc_functions.c1416 net->cc_mod.rtcc.bw_bytes += tp1->send_size; in sctp_cwnd_update_rtcc_tsn_acknowledged()
Dsctp_usrreq.c212 if ((chk->send_size + overhead) > nxtsz) { in sctp_pathmtu_adjustment()
217 if ((chk->send_size + overhead) > nxtsz) { in sctp_pathmtu_adjustment()
/third_party/node/src/
Dnode_report_utils.cc225 int send_size = 0; in WalkHandle() local
227 uv_send_buffer_size(h, &send_size); in WalkHandle()
229 writer->json_keyvalue("sendBufferSize", send_size); in WalkHandle()
/third_party/curl/lib/
Dsmb.c388 smbc->send_size = len; in smb_send()
402 ssize_t len = smbc->send_size - smbc->sent; in smb_flush()
405 if(!smbc->send_size) in smb_flush()
417 smbc->send_size = 0; in smb_flush()
629 if(!smbc->send_size && smbc->upload_size) { in smb_send_and_recv()
640 smbc->send_size = nread; in smb_send_and_recv()
645 if(smbc->send_size) { in smb_send_and_recv()
652 if(smbc->send_size || smbc->upload_size) in smb_send_and_recv()
Dsmb.h44 size_t send_size; member
/third_party/mindspore/tests/ut/python/communication/
Dtest_comm.py134 … self.send_size = Tensor([0, part_slice*out_channel, part_slice*out_channel], mindspore.int64)
139 x = self.allswap(x, self.send_size, self.recv_size)
/third_party/mindspore/mindspore/ops/operations/
Dcomm_ops.py608 def __check__(self, tensor_in, send_size, recv_size): argument
610 validator.check_tensor_dtype_valid("send_size", send_size['dtype'], [mstype.int64],
616 validator.check_equal_int(len(send_size['shape']), 1, "send_size", self.name)
/third_party/mindspore/mindspore/ops/_grad/
Dgrad_comm_ops.py335 def bprop(x, send_size, recv_size, out, dout): argument
336 dx = all_swap_grad(dout, recv_size, send_size)
337 return (dx, zeros_like(send_size), zeros_like(recv_size))
/third_party/grpc/test/core/iomgr/ios/CFStreamTests/
DCFStreamEndpointTests.mm183 ssize_t send_size = send(svr_fd_, read_buffer, kBufferSize, 0);
184 XCTAssertGreaterThanOrEqual(send_size, 0);
/third_party/mindspore/mindspore/core/abstract/
Dprim_others.cc407 auto send_size = CheckArg<AbstractTensor>(op_name, args_spec_list, 1); in InferImplAllSwap() local
408 MS_EXCEPTION_IF_NULL(send_size); in InferImplAllSwap()