Home
last modified time | relevance | path

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

12345678910>>...18

/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/osc/pt2pt/
H A Dosc_pt2pt_frag.h64 size_t request_len) in ompi_osc_pt2pt_frag_alloc_non_buffered() argument
113 size_t request_len, ompi_osc_pt2pt_frag_t **buffer, in _ompi_osc_pt2pt_frag_alloc() argument
122 request_len = OPAL_ALIGN(request_len, 8, size_t); in _ompi_osc_pt2pt_frag_alloc()
124 if (request_len > mca_osc_pt2pt_component.buffer_size) { in _ompi_osc_pt2pt_frag_alloc()
130 "buffered: %d", (unsigned long) request_len, target, long_send, buffered)); in _ompi_osc_pt2pt_frag_alloc()
136 curr = ompi_osc_pt2pt_frag_alloc_non_buffered (module, peer, request_len); in _ompi_osc_pt2pt_frag_alloc()
151 curr = ompi_osc_pt2pt_frag_alloc_non_buffered (module, peer, request_len); in _ompi_osc_pt2pt_frag_alloc()
161 curr->top += request_len; in _ompi_osc_pt2pt_frag_alloc()
162 curr->remain_len -= request_len; in _ompi_osc_pt2pt_frag_alloc()
170 size_t request_len, ompi_osc_pt2pt_frag_t **buffer, in ompi_osc_pt2pt_frag_alloc() argument
[all …]
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/osc/pt2pt/
H A Dosc_pt2pt_frag.h64 size_t request_len) in ompi_osc_pt2pt_frag_alloc_non_buffered() argument
113 size_t request_len, ompi_osc_pt2pt_frag_t **buffer, in _ompi_osc_pt2pt_frag_alloc() argument
122 request_len = OPAL_ALIGN(request_len, 8, size_t); in _ompi_osc_pt2pt_frag_alloc()
124 if (request_len > mca_osc_pt2pt_component.buffer_size) { in _ompi_osc_pt2pt_frag_alloc()
130 "buffered: %d", (unsigned long) request_len, target, long_send, buffered)); in _ompi_osc_pt2pt_frag_alloc()
136 curr = ompi_osc_pt2pt_frag_alloc_non_buffered (module, peer, request_len); in _ompi_osc_pt2pt_frag_alloc()
151 curr = ompi_osc_pt2pt_frag_alloc_non_buffered (module, peer, request_len); in _ompi_osc_pt2pt_frag_alloc()
161 curr->top += request_len; in _ompi_osc_pt2pt_frag_alloc()
162 curr->remain_len -= request_len; in _ompi_osc_pt2pt_frag_alloc()
170 size_t request_len, ompi_osc_pt2pt_frag_t **buffer, in ompi_osc_pt2pt_frag_alloc() argument
[all …]
/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/osc/rdma/
H A Dosc_rdma_frag.h37 static inline int ompi_osc_rdma_frag_alloc (ompi_osc_rdma_module_t *module, size_t request_len, in ompi_osc_rdma_frag_alloc() argument
45 request_len = OPAL_ALIGN(request_len, 8, size_t); in ompi_osc_rdma_frag_alloc()
47 if (request_len > (mca_osc_rdma_component.buffer_size >> 1)) { in ompi_osc_rdma_frag_alloc()
89 my_index = opal_atomic_fetch_add_64 (&curr->curr_index, request_len); in ompi_osc_rdma_frag_alloc()
91 my_index = opal_atomic_fetch_add_32 (&curr->curr_index, request_len); in ompi_osc_rdma_frag_alloc()
93 if (my_index + request_len > mca_osc_rdma_component.buffer_size) { in ompi_osc_rdma_frag_alloc()
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/osc/rdma/
H A Dosc_rdma_frag.h37 static inline int ompi_osc_rdma_frag_alloc (ompi_osc_rdma_module_t *module, size_t request_len, in ompi_osc_rdma_frag_alloc() argument
45 request_len = OPAL_ALIGN(request_len, 8, size_t); in ompi_osc_rdma_frag_alloc()
47 if (request_len > (mca_osc_rdma_component.buffer_size >> 1)) { in ompi_osc_rdma_frag_alloc()
89 my_index = opal_atomic_fetch_add_64 (&curr->curr_index, request_len); in ompi_osc_rdma_frag_alloc()
91 my_index = opal_atomic_fetch_add_32 (&curr->curr_index, request_len); in ompi_osc_rdma_frag_alloc()
93 if (my_index + request_len > mca_osc_rdma_component.buffer_size) { in ompi_osc_rdma_frag_alloc()
/dports/databases/timescaledb/timescaledb-2.5.1/src/net/
H A Dhttp.c62 size_t request_len; in ts_http_send_and_recv() local
67 built_request = ts_http_request_build(req, &request_len); in ts_http_send_and_recv()
72 while (request_len > 0) in ts_http_send_and_recv()
74 ret = ts_connection_write(conn, built_request + write_off, request_len); in ts_http_send_and_recv()
76 if (ret < 0 || ret > request_len) in ts_http_send_and_recv()
83 request_len -= ret; in ts_http_send_and_recv()
/dports/devel/ga/ga-5.8/armci/src/common/
H A Daggregate.c26 short int request_len ; /* number of requests */ member
82 aggr[(index)]->request_len = (len); \
111 aggr[index]->request_len = 0; in _armci_agg_get_bufferid()
148 rid = aggr[index]->request_len; /* index of giov descriptor */ in _armci_agg_get_descriptor()
176 aggr[index]->request_len++; in _armci_agg_get_descriptor()
307 armci_me, nb_handle->proc, index, aggr[index]->request_len); in armci_agg_complete()
312 if(aggr[index]->request_len) { in armci_agg_complete()
318 if((rc=PARMCI_NbPutV(aggr[index]->darr, aggr[index]->request_len, in armci_agg_complete()
332 if((rc=PARMCI_PutV(aggr[index]->darr, aggr[index]->request_len, in armci_agg_complete()
337 if((rc=PARMCI_GetV(aggr[index]->darr, aggr[index]->request_len, in armci_agg_complete()
[all …]
/dports/devel/ga/ga-5.8/armci/src-gemini/
H A Daggregate.c22 short int request_len ; /* number of requests */ member
78 aggr[(index)]->request_len = (len); \
106 aggr[index]->request_len = 0; in _armci_agg_get_bufferid()
143 rid = aggr[index]->request_len; /* index of giov descriptor */ in _armci_agg_get_descriptor()
171 aggr[index]->request_len++; in _armci_agg_get_descriptor()
302 armci_me, nb_handle->proc, index, aggr[index]->request_len); in armci_agg_complete()
307 if(aggr[index]->request_len) { in armci_agg_complete()
313 if((rc=PARMCI_NbPutV(aggr[index]->darr, aggr[index]->request_len, in armci_agg_complete()
327 if((rc=PARMCI_PutV(aggr[index]->darr, aggr[index]->request_len, in armci_agg_complete()
332 if((rc=PARMCI_GetV(aggr[index]->darr, aggr[index]->request_len, in armci_agg_complete()
[all …]
/dports/devel/ga/ga-5.8/armci/src-portals/
H A Daggregate.c22 short int request_len ; /* number of requests */ member
78 aggr[(index)]->request_len = (len); \
106 aggr[index]->request_len = 0; in _armci_agg_get_bufferid()
143 rid = aggr[index]->request_len; /* index of giov descriptor */ in _armci_agg_get_descriptor()
171 aggr[index]->request_len++; in _armci_agg_get_descriptor()
302 armci_me, nb_handle->proc, index, aggr[index]->request_len); in armci_agg_complete()
307 if(aggr[index]->request_len) { in armci_agg_complete()
313 if((rc=PARMCI_NbPutV(aggr[index]->darr, aggr[index]->request_len, in armci_agg_complete()
327 if((rc=PARMCI_PutV(aggr[index]->darr, aggr[index]->request_len, in armci_agg_complete()
332 if((rc=PARMCI_GetV(aggr[index]->darr, aggr[index]->request_len, in armci_agg_complete()
[all …]
/dports/databases/timescaledb/timescaledb-2.5.1/test/src/net/
H A Dtest_http.c191 size_t request_len; in ts_test_http_request_build() local
203 serialized = ts_http_request_build(req, &request_len); in ts_test_http_request_build()
205 cmp_res = !strncmp(expected_response, serialized, request_len); in ts_test_http_request_build()
222 serialized = ts_http_request_build(req, &request_len); in ts_test_http_request_build()
224 TestAssertTrue(!strncmp(expected_response, serialized, request_len)); in ts_test_http_request_build()
236 serialized = ts_http_request_build(req, &request_len); in ts_test_http_request_build()
238 TestAssertTrue(!strncmp(expected_response, serialized, request_len)); in ts_test_http_request_build()
248 TestAssertTrue(!ts_http_request_build(req, &request_len)); in ts_test_http_request_build()
/dports/security/tor/tor-0.4.6.8/src/feature/rend/
H A Drendmid.h16 size_t request_len);
18 size_t request_len);
20 size_t request_len);
22 size_t request_len);
H A Drendmid.c30 size_t request_len) in rend_mid_establish_rendezvous() argument
61 if (request_len != REND_COOKIE_LEN) { in rend_mid_establish_rendezvous()
103 size_t request_len) in rend_mid_rendezvous() argument
118 if (request_len < REND_COOKIE_LEN) { in rend_mid_rendezvous()
121 (int)request_len, (unsigned)circ->p_circ_id); in rend_mid_rendezvous()
153 request_len-REND_COOKIE_LEN, NULL)) { in rend_mid_rendezvous()
/dports/security/tor-devel/tor-0.4.7.2-alpha/src/feature/rend/
H A Drendmid.h16 size_t request_len);
18 size_t request_len);
20 size_t request_len);
22 size_t request_len);
H A Drendmid.c30 size_t request_len) in rend_mid_establish_rendezvous() argument
61 if (request_len != REND_COOKIE_LEN) { in rend_mid_establish_rendezvous()
103 size_t request_len) in rend_mid_rendezvous() argument
118 if (request_len < REND_COOKIE_LEN) { in rend_mid_rendezvous()
121 (int)request_len, (unsigned)circ->p_circ_id); in rend_mid_rendezvous()
157 request_len-REND_COOKIE_LEN, NULL)) { in rend_mid_rendezvous()
/dports/devel/gamin/gamin-0.1.10/server/
H A Dgam_connection.c318 *data = (char *) &conn->request + conn->request_len; in gam_connection_get_data()
319 *size = sizeof(GAMPacket) - conn->request_len; in gam_connection_get_data()
457 g_assert(conn->request_len >= 0); in gam_connection_data()
460 conn->request_len += len; in gam_connection_data()
467 if (conn->request_len < (int) GAM_PACKET_HEADER_LEN) { in gam_connection_data()
502 if (conn->request_len < req->len) { in gam_connection_data()
517 conn->request_len -= req->len; in gam_connection_data()
518 if (conn->request_len == 0) in gam_connection_data()
528 if ((conn->request_len > 0) && (req != &conn->request)) in gam_connection_data()
529 memmove(&conn->request, req, conn->request_len); in gam_connection_data()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/remoting/host/security_key/
H A Dsecurity_key_auth_handler_posix_unittest.cc120 int request_len = sizeof(kRequestData); in WriteRequestData() local
125 request_len); in WriteRequestData()
128 while (bytes_written < request_len) { in WriteRequestData()
135 ASSERT_LE(bytes_written, request_len); in WriteRequestData()
138 ASSERT_EQ(request_len, bytes_written); in WriteRequestData()
149 void WaitForData(net::UnixDomainClientSocket* socket, int request_len) { in WaitForData() argument
151 base::MakeRefCounted<net::IOBuffer>(request_len); in WaitForData()
154 request_len); in WaitForData()
157 while (bytes_read < request_len) { in WaitForData()
164 ASSERT_LE(bytes_read, request_len); in WaitForData()
[all …]
/dports/science/PETSc/petsc-3.14.1/src/sys/webclient/
H A Dclient.c112 size_t request_len,headlen,bodylen,contentlen,pathlen,hostlen,typelen,contenttypelen = 0; in PetscHTTPBuildRequest() local
142 …request_len = typelen + 1 + pathlen + hostlen + 100 + headlen + contenttypelen + contentlen + body… in PetscHTTPBuildRequest()
143 ierr = PetscMalloc1(request_len,&request);CHKERRQ(ierr); in PetscHTTPBuildRequest()
157 ierr = PetscStrlen(request,&request_len);CHKERRQ(ierr); in PetscHTTPBuildRequest()
189 size_t request_len,len; in PetscHTTPSRequest() local
195 ierr = PetscStrlen(request,&request_len);CHKERRQ(ierr); in PetscHTTPSRequest()
197 r = SSL_write(ssl,request,(int)request_len); in PetscHTTPSRequest()
200 …if (request_len != (size_t)r) SETERRQ(PETSC_COMM_SELF,PETSC_ERR_LIB,"Incomplete write to SSL socke… in PetscHTTPSRequest()
277 size_t request_len; in PetscHTTPRequest() local
282 ierr = PetscStrlen(request,&request_len);CHKERRQ(ierr); in PetscHTTPRequest()
[all …]
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/in_http/
H A Dhttp_conn.c39 size_t request_len; in http_conn_event() local
108 request_len = (size_t)(request_end - conn->buf_data); in http_conn_event()
110 if (0 < (conn->buf_len - request_len)) { in http_conn_event()
111 memmove(conn->buf_data, &conn->buf_data[request_len], in http_conn_event()
112 conn->buf_len - request_len); in http_conn_event()
114 conn->buf_data[conn->buf_len - request_len] = '\0'; in http_conn_event()
115 conn->buf_len -= request_len; in http_conn_event()
118 memset(conn->buf_data, 0, request_len); in http_conn_event()
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/i2c/busses/
H A Di2c-cros-ec-tunnel.c180 int request_len; in ec_i2c_xfer() local
186 request_len = ec_i2c_count_message(i2c_msgs, num); in ec_i2c_xfer()
187 if (request_len < 0) { in ec_i2c_xfer()
188 dev_warn(dev, "Error constructing message %d\n", request_len); in ec_i2c_xfer()
189 return request_len; in ec_i2c_xfer()
199 alloc_size = max(request_len, response_len); in ec_i2c_xfer()
212 msg->outsize = request_len; in ec_i2c_xfer()
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/i2c/busses/
H A Di2c-cros-ec-tunnel.c180 int request_len; in ec_i2c_xfer() local
186 request_len = ec_i2c_count_message(i2c_msgs, num); in ec_i2c_xfer()
187 if (request_len < 0) { in ec_i2c_xfer()
188 dev_warn(dev, "Error constructing message %d\n", request_len); in ec_i2c_xfer()
189 return request_len; in ec_i2c_xfer()
199 alloc_size = max(request_len, response_len); in ec_i2c_xfer()
212 msg->outsize = request_len; in ec_i2c_xfer()
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/i2c/busses/
H A Di2c-cros-ec-tunnel.c180 int request_len; in ec_i2c_xfer() local
186 request_len = ec_i2c_count_message(i2c_msgs, num); in ec_i2c_xfer()
187 if (request_len < 0) { in ec_i2c_xfer()
188 dev_warn(dev, "Error constructing message %d\n", request_len); in ec_i2c_xfer()
189 return request_len; in ec_i2c_xfer()
199 alloc_size = max(request_len, response_len); in ec_i2c_xfer()
212 msg->outsize = request_len; in ec_i2c_xfer()
/dports/security/tor-devel/tor-0.4.7.2-alpha/src/feature/hs/
H A Dhs_intropoint.c408 size_t request_len) in handle_establish_intro() argument
426 request, request_len); in handle_establish_intro()
501 size_t request_len) in hs_intro_received_establish_intro() argument
506 if (request_len == 0) { in hs_intro_received_establish_intro()
521 return handle_establish_intro(circ, request, request_len); in hs_intro_received_establish_intro()
630 size_t request_len) in handle_introduce1() argument
644 request_len); in handle_introduce1()
697 (char *) request, request_len, NULL)) { in handle_introduce1()
758 size_t request_len) in hs_intro_received_introduce1() argument
764 if (request_len < DIGEST_LEN) { in hs_intro_received_introduce1()
[all …]
H A Dhs_intropoint.h29 size_t request_len);
31 size_t request_len);
56 const uint8_t *request, size_t request_len);
/dports/security/tor/tor-0.4.6.8/src/feature/hs/
H A Dhs_intropoint.c408 size_t request_len) in handle_establish_intro() argument
426 request, request_len); in handle_establish_intro()
501 size_t request_len) in hs_intro_received_establish_intro() argument
506 if (request_len == 0) { in hs_intro_received_establish_intro()
521 return handle_establish_intro(circ, request, request_len); in hs_intro_received_establish_intro()
630 size_t request_len) in handle_introduce1() argument
644 request_len); in handle_introduce1()
697 (char *) request, request_len, NULL)) { in handle_introduce1()
758 size_t request_len) in hs_intro_received_introduce1() argument
764 if (request_len < DIGEST_LEN) { in hs_intro_received_introduce1()
[all …]
H A Dhs_intropoint.h29 size_t request_len);
31 size_t request_len);
56 const uint8_t *request, size_t request_len);
/dports/security/md5deep/hashdeep-cd2ed74/src/
H A Dhash.cpp76 bool file_data_hasher_t::compute_hash(uint64_t request_start,uint64_t request_len, in compute_hash() argument
94 while (request_len>0){ in compute_hash()
102 uint64_t toread = min(request_len,file_data_hasher_t::MD5DEEP_IDEAL_BLOCK_SIZE); // and shrink in compute_hash()
170 request_len -= toread; in compute_hash()
383 uint64_t request_len = fdht->stat_bytes; // by default, hash the file in hash() local
385 request_len = fdht->ocb->piecewise_size; in hash()
394 bool r = fdht->compute_hash(request_start,request_len,&hc_piece,hc_file); in hash()
400 request_start += request_len; in hash()

12345678910>>...18