Home
last modified time | relevance | path

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

12345678910>>...23

/dports/science/dakota/dakota-6.13.0-release-public.src-UI/packages/external/trilinos/packages/teuchos/comm/src/
H A DTeuchos_CommHelpers.cpp158 T recvBuf[], in gatherImpl() argument
212 T recvBuf[], in scatterImpl() argument
266 T recvBuf[], in reduceImpl() argument
319 T recvBuf[], in gathervImpl() argument
1306 long recvBuf[], in gather() argument
1318 long recvBuf[], in gatherv() argument
1493 int recvBuf[], in gather() argument
1505 int recvBuf[], in gatherv() argument
1518 int recvBuf[], in scatter() argument
1529 int recvBuf[], in reduce() argument
[all …]
/dports/net/mpich2/mpich2-1.5/test/mpi/rma/
H A Dputfidx.c25 int *recvBuf = 0, *srcBuf = 0; in main() local
58 recvBuf = (int *) malloc( totsize * sizeof(int) ); in main()
61 if (!recvBuf || !srcBuf) { in main()
68 recvBuf[i] = -1; in main()
77 MPI_Win_create( recvBuf, totsize * extent, extent, in main()
94 if (recvBuf[i] != i) { in main()
98 i, recvBuf[i], i ); in main()
109 free( recvBuf ); in main()
/dports/net/mpich/mpich-3.4.3/test/mpi/rma/
H A Dputfidx.c24 int *recvBuf = 0, *srcBuf = 0; in main() local
57 recvBuf = (int *) malloc(totsize * sizeof(int)); in main()
60 if (!recvBuf || !srcBuf) { in main()
67 recvBuf[i] = -1; in main()
76 MPI_Win_create(recvBuf, totsize * extent, extent, MPI_INFO_NULL, comm, &win); in main()
90 if (recvBuf[i] != i) { in main()
93 printf("recvBuf[%d] = %d should = %d\n", i, recvBuf[i], i); in main()
103 free(recvBuf); in main()
/dports/math/vtk9/VTK-9.1.0/Filters/Parallel/
H A DvtkPartitionBalancer.cxx94 std::vector<int> recvBuf(this->Controller->GetNumberOfProcesses()); in RequestData() local
96 this->Controller->AllGather(&numberOfNonNullPartitionsInInput, recvBuf.data(), 1); in RequestData()
101 const int numberOfPartitions = std::accumulate(recvBuf.begin(), recvBuf.end(), 0); in RequestData()
102 const int offset = std::accumulate(recvBuf.begin(), recvBuf.begin() + localProcessId, 0); in RequestData()
109 const int numberOfPartitions = *std::max_element(recvBuf.begin(), recvBuf.end()); in RequestData()
/dports/finance/aqbanking/aqbanking-6.2.10/src/libs/plugins/backends/aqebics/client/
H A Ddialog.c93 GWEN_BUFFER *recvBuf; in EBC_Dialog_ExchangeMessages() local
100 recvBuf=GWEN_Buffer_new(0, 1024, 0, 1); in EBC_Dialog_ExchangeMessages()
121 GWEN_Buffer_free(recvBuf); in EBC_Dialog_ExchangeMessages()
128 rv=GWEN_HttpSession_RecvPacket(sess, recvBuf); in EBC_Dialog_ExchangeMessages()
131 GWEN_Buffer_free(recvBuf); in EBC_Dialog_ExchangeMessages()
139 fprintf(stderr, "%s\n", GWEN_Buffer_GetStart(recvBuf)); in EBC_Dialog_ExchangeMessages()
145 mResponse=EB_Msg_fromBuffer(GWEN_Buffer_GetStart(recvBuf), in EBC_Dialog_ExchangeMessages()
146 GWEN_Buffer_GetUsedBytes(recvBuf)); in EBC_Dialog_ExchangeMessages()
147 GWEN_Buffer_free(recvBuf); in EBC_Dialog_ExchangeMessages()
/dports/science/dakota/dakota-6.13.0-release-public.src-UI/packages/external/trilinos/packages/teuchos/comm/test/Comm/
H A DDefaultMpiComm_TagTests.cpp122 ArrayRCP<int> recvBuf (2); in TEUCHOS_UNIT_TEST() local
140 for (size_type k = 0; k < recvBuf.size (); ++k) { in TEUCHOS_UNIT_TEST()
141 recvBuf[k] = -1; in TEUCHOS_UNIT_TEST()
193 for (size_type k = 0; k < recvBuf.size (); ++k) { in TEUCHOS_UNIT_TEST()
194 recvBuf[k] = -1; in TEUCHOS_UNIT_TEST()
245 for (size_type k = 0; k < recvBuf.size (); ++k) { in TEUCHOS_UNIT_TEST()
246 recvBuf[k] = -1; in TEUCHOS_UNIT_TEST()
335 ArrayRCP<int> recvBuf (2); in TEUCHOS_UNIT_TEST() local
361 recvBuf[k] = -1; in TEUCHOS_UNIT_TEST()
399 recvBuf[k] = -1; in TEUCHOS_UNIT_TEST()
[all …]
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Runtime.Remoting/Test/
H A DIpcChannelTest.cs48 byte[] recvBuf = client.Send (sendBuf); in Bug609381()
50 Assert.IsNotNull (recvBuf); in Bug609381()
51 Assert.AreNotSame (sendBuf, recvBuf); in Bug609381()
52 Assert.AreEqual (count, recvBuf.Length); in Bug609381()
53 Assert.AreEqual (42, recvBuf [recvBuf.Length - 1]); in Bug609381()
56 recvBuf = null; in Bug609381()
/dports/devel/thrift-cpp/thrift-0.14.0/lib/java/src/org/apache/thrift/
H A DTNonblockingMultiFetchClient.java98 private ByteBuffer[] recvBuf; field in TNonblockingMultiFetchClient
109 recvBuf = null; in TNonblockingMultiFetchClient()
151 recvBuf = null; in fetch()
156 return recvBuf; in fetch()
181 return recvBuf; in fetch()
208 recvBuf = new ByteBuffer[numTotalServers]; in run()
226 recvBuf[i] = ByteBuffer.allocate(4); in run()
307 int bytesRead = sChannel.read(recvBuf[index]); in run()
313 recvBuf[index].remaining()==0) { in run()
316 frameSize[index] = recvBuf[index].getInt(0); in run()
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/thrift/lib/java/src/org/apache/thrift/
H A DTNonblockingMultiFetchClient.java98 private ByteBuffer[] recvBuf; field in TNonblockingMultiFetchClient
109 recvBuf = null; in TNonblockingMultiFetchClient()
151 recvBuf = null; in fetch()
156 return recvBuf; in fetch()
181 return recvBuf; in fetch()
208 recvBuf = new ByteBuffer[numTotalServers]; in run()
226 recvBuf[i] = ByteBuffer.allocate(4); in run()
307 int bytesRead = sChannel.read(recvBuf[index]); in run()
313 recvBuf[index].remaining()==0) { in run()
316 frameSize[index] = recvBuf[index].getInt(0); in run()
[all …]
/dports/devel/py-thrift/thrift-0.14.0/lib/java/src/org/apache/thrift/
H A DTNonblockingMultiFetchClient.java98 private ByteBuffer[] recvBuf; field in TNonblockingMultiFetchClient
109 recvBuf = null; in TNonblockingMultiFetchClient()
151 recvBuf = null; in fetch()
156 return recvBuf; in fetch()
181 return recvBuf; in fetch()
208 recvBuf = new ByteBuffer[numTotalServers]; in run()
226 recvBuf[i] = ByteBuffer.allocate(4); in run()
307 int bytesRead = sChannel.read(recvBuf[index]); in run()
313 recvBuf[index].remaining()==0) { in run()
316 frameSize[index] = recvBuf[index].getInt(0); in run()
[all …]
/dports/devel/thrift-c_glib/thrift-0.14.0/lib/java/src/org/apache/thrift/
H A DTNonblockingMultiFetchClient.java98 private ByteBuffer[] recvBuf; field in TNonblockingMultiFetchClient
109 recvBuf = null; in TNonblockingMultiFetchClient()
151 recvBuf = null; in fetch()
156 return recvBuf; in fetch()
181 return recvBuf; in fetch()
208 recvBuf = new ByteBuffer[numTotalServers]; in run()
226 recvBuf[i] = ByteBuffer.allocate(4); in run()
307 int bytesRead = sChannel.read(recvBuf[index]); in run()
313 recvBuf[index].remaining()==0) { in run()
316 frameSize[index] = recvBuf[index].getInt(0); in run()
[all …]
/dports/devel/thrift/thrift-0.14.0/lib/java/src/org/apache/thrift/
H A DTNonblockingMultiFetchClient.java98 private ByteBuffer[] recvBuf; field in TNonblockingMultiFetchClient
109 recvBuf = null; in TNonblockingMultiFetchClient()
151 recvBuf = null; in fetch()
156 return recvBuf; in fetch()
181 return recvBuf; in fetch()
208 recvBuf = new ByteBuffer[numTotalServers]; in run()
226 recvBuf[i] = ByteBuffer.allocate(4); in run()
307 int bytesRead = sChannel.read(recvBuf[index]); in run()
313 recvBuf[index].remaining()==0) { in run()
316 frameSize[index] = recvBuf[index].getInt(0); in run()
[all …]
/dports/devel/node-thrift/thrift-0.14.0/lib/java/src/org/apache/thrift/
H A DTNonblockingMultiFetchClient.java98 private ByteBuffer[] recvBuf; field in TNonblockingMultiFetchClient
109 recvBuf = null; in TNonblockingMultiFetchClient()
151 recvBuf = null; in fetch()
156 return recvBuf; in fetch()
181 return recvBuf; in fetch()
208 recvBuf = new ByteBuffer[numTotalServers]; in run()
226 recvBuf[i] = ByteBuffer.allocate(4); in run()
307 int bytesRead = sChannel.read(recvBuf[index]); in run()
313 recvBuf[index].remaining()==0) { in run()
316 frameSize[index] = recvBuf[index].getInt(0); in run()
[all …]
/dports/net/storj/storj-1.45.3/vendor/github.com/apache/thrift/lib/java/src/org/apache/thrift/
H A DTNonblockingMultiFetchClient.java99 private ByteBuffer[] recvBuf; field in TNonblockingMultiFetchClient
110 recvBuf = null; in TNonblockingMultiFetchClient()
152 recvBuf = null; in fetch()
157 return recvBuf; in fetch()
182 return recvBuf; in fetch()
209 recvBuf = new ByteBuffer[numTotalServers]; in run()
227 recvBuf[i] = ByteBuffer.allocate(4); in run()
315 int bytesRead = sChannel.read(recvBuf[index]); in run()
321 recvBuf[index].remaining()==0) { in run()
324 frameSize[index] = recvBuf[index].getInt(0); in run()
[all …]
/dports/www/fabio/fabio-1.5.14/vendor/github.com/apache/thrift/thrift-da1169d75b15/lib/java/src/org/apache/thrift/
H A DTNonblockingMultiFetchClient.java99 private ByteBuffer[] recvBuf; field in TNonblockingMultiFetchClient
110 recvBuf = null; in TNonblockingMultiFetchClient()
152 recvBuf = null; in fetch()
157 return recvBuf; in fetch()
182 return recvBuf; in fetch()
209 recvBuf = new ByteBuffer[numTotalServers]; in run()
227 recvBuf[i] = ByteBuffer.allocate(4); in run()
315 int bytesRead = sChannel.read(recvBuf[index]); in run()
321 recvBuf[index].remaining()==0) { in run()
324 frameSize[index] = recvBuf[index].getInt(0); in run()
[all …]
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/apache/thrift/lib/java/src/org/apache/thrift/
H A DTNonblockingMultiFetchClient.java99 private ByteBuffer[] recvBuf; field in TNonblockingMultiFetchClient
110 recvBuf = null; in TNonblockingMultiFetchClient()
152 recvBuf = null; in fetch()
157 return recvBuf; in fetch()
182 return recvBuf; in fetch()
209 recvBuf = new ByteBuffer[numTotalServers]; in run()
227 recvBuf[i] = ByteBuffer.allocate(4); in run()
315 int bytesRead = sChannel.read(recvBuf[index]); in run()
321 recvBuf[index].remaining()==0) { in run()
324 frameSize[index] = recvBuf[index].getInt(0); in run()
[all …]
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.Security/tests/FunctionalTests/
H A DSslStreamStreamToStreamTest.cs64 byte[] recvBuf = new byte[_sampleMsg.Length]; in SslStream_StreamToStream_Successive_ClientWrite_Sync_Success()
79 … bytesRead += serverSslStream.Read(recvBuf, bytesRead, _sampleMsg.Length - bytesRead); in SslStream_StreamToStream_Successive_ClientWrite_Sync_Success()
82 … Assert.True(VerifyOutput(recvBuf, _sampleMsg), "verify first read data is as expected."); in SslStream_StreamToStream_Successive_ClientWrite_Sync_Success()
89 … bytesRead += serverSslStream.Read(recvBuf, bytesRead, _sampleMsg.Length - bytesRead); in SslStream_StreamToStream_Successive_ClientWrite_Sync_Success()
92 … Assert.True(VerifyOutput(recvBuf, _sampleMsg), "verify second read data is as expected."); in SslStream_StreamToStream_Successive_ClientWrite_Sync_Success()
99 byte[] recvBuf = new byte[_sampleMsg.Length]; in SslStream_StreamToStream_Successive_ClientWrite_WithZeroBytes_Success()
116 … bytesRead += serverSslStream.Read(recvBuf, bytesRead, _sampleMsg.Length - bytesRead); in SslStream_StreamToStream_Successive_ClientWrite_WithZeroBytes_Success()
119 … Assert.True(VerifyOutput(recvBuf, _sampleMsg), "verify first read data is as expected."); in SslStream_StreamToStream_Successive_ClientWrite_WithZeroBytes_Success()
128 … bytesRead += serverSslStream.Read(recvBuf, bytesRead, _sampleMsg.Length - bytesRead); in SslStream_StreamToStream_Successive_ClientWrite_WithZeroBytes_Success()
130 … Assert.True(VerifyOutput(recvBuf, _sampleMsg), "verify second read data is as expected."); in SslStream_StreamToStream_Successive_ClientWrite_WithZeroBytes_Success()
[all …]
/dports/sysutils/helmfile/vault-f6547fa8e820/vendor/github.com/hashicorp/yamux/
H A Dstream.go36 recvBuf *bytes.Buffer member
97 if s.recvBuf == nil || s.recvBuf.Len() == 0 {
111 if s.recvBuf == nil || s.recvBuf.Len() == 0 {
117 n, _ = s.recvBuf.Read(b)
247 if s.recvBuf != nil {
248 bufLen = uint32(s.recvBuf.Len())
418 if s.recvBuf == nil {
421 s.recvBuf = bytes.NewBuffer(make([]byte, 0, length))
423 if _, err := io.Copy(s.recvBuf, conn); err != nil {
466 if s.recvBuf != nil && s.recvBuf.Len() == 0 {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-kv/vendor/github.com/hashicorp/yamux/
H A Dstream.go36 recvBuf *bytes.Buffer member
97 if s.recvBuf == nil || s.recvBuf.Len() == 0 {
111 if s.recvBuf == nil || s.recvBuf.Len() == 0 {
117 n, _ = s.recvBuf.Read(b)
247 if s.recvBuf != nil {
248 bufLen = uint32(s.recvBuf.Len())
418 if s.recvBuf == nil {
421 s.recvBuf = bytes.NewBuffer(make([]byte, 0, length))
423 if _, err := io.Copy(s.recvBuf, conn); err != nil {
466 if s.recvBuf != nil && s.recvBuf.Len() == 0 {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-terraform/vendor/github.com/hashicorp/yamux/
H A Dstream.go36 recvBuf *bytes.Buffer member
97 if s.recvBuf == nil || s.recvBuf.Len() == 0 {
111 if s.recvBuf == nil || s.recvBuf.Len() == 0 {
117 n, _ = s.recvBuf.Read(b)
247 if s.recvBuf != nil {
248 bufLen = uint32(s.recvBuf.Len())
418 if s.recvBuf == nil {
421 s.recvBuf = bytes.NewBuffer(make([]byte, 0, length))
423 if _, err := io.Copy(s.recvBuf, conn); err != nil {
466 if s.recvBuf != nil && s.recvBuf.Len() == 0 {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-gcp/vendor/github.com/hashicorp/yamux/
H A Dstream.go36 recvBuf *bytes.Buffer member
97 if s.recvBuf == nil || s.recvBuf.Len() == 0 {
111 if s.recvBuf == nil || s.recvBuf.Len() == 0 {
117 n, _ = s.recvBuf.Read(b)
247 if s.recvBuf != nil {
248 bufLen = uint32(s.recvBuf.Len())
418 if s.recvBuf == nil {
421 s.recvBuf = bytes.NewBuffer(make([]byte, 0, length))
423 if _, err := io.Copy(s.recvBuf, conn); err != nil {
466 if s.recvBuf != nil && s.recvBuf.Len() == 0 {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-mongodbatlas/vendor/github.com/hashicorp/yamux/
H A Dstream.go36 recvBuf *bytes.Buffer member
97 if s.recvBuf == nil || s.recvBuf.Len() == 0 {
111 if s.recvBuf == nil || s.recvBuf.Len() == 0 {
117 n, _ = s.recvBuf.Read(b)
247 if s.recvBuf != nil {
248 bufLen = uint32(s.recvBuf.Len())
418 if s.recvBuf == nil {
421 s.recvBuf = bytes.NewBuffer(make([]byte, 0, length))
423 if _, err := io.Copy(s.recvBuf, conn); err != nil {
466 if s.recvBuf != nil && s.recvBuf.Len() == 0 {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-auth-jwt/vendor/github.com/hashicorp/yamux/
H A Dstream.go36 recvBuf *bytes.Buffer member
97 if s.recvBuf == nil || s.recvBuf.Len() == 0 {
111 if s.recvBuf == nil || s.recvBuf.Len() == 0 {
117 n, _ = s.recvBuf.Read(b)
247 if s.recvBuf != nil {
248 bufLen = uint32(s.recvBuf.Len())
418 if s.recvBuf == nil {
421 s.recvBuf = bytes.NewBuffer(make([]byte, 0, length))
423 if _, err := io.Copy(s.recvBuf, conn); err != nil {
466 if s.recvBuf != nil && s.recvBuf.Len() == 0 {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-auth-kubernetes/vendor/github.com/hashicorp/yamux/
H A Dstream.go36 recvBuf *bytes.Buffer member
97 if s.recvBuf == nil || s.recvBuf.Len() == 0 {
111 if s.recvBuf == nil || s.recvBuf.Len() == 0 {
117 n, _ = s.recvBuf.Read(b)
247 if s.recvBuf != nil {
248 bufLen = uint32(s.recvBuf.Len())
418 if s.recvBuf == nil {
421 s.recvBuf = bytes.NewBuffer(make([]byte, 0, length))
423 if _, err := io.Copy(s.recvBuf, conn); err != nil {
466 if s.recvBuf != nil && s.recvBuf.Len() == 0 {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-alicloud/vendor/github.com/hashicorp/yamux/
H A Dstream.go36 recvBuf *bytes.Buffer member
97 if s.recvBuf == nil || s.recvBuf.Len() == 0 {
111 if s.recvBuf == nil || s.recvBuf.Len() == 0 {
117 n, _ = s.recvBuf.Read(b)
247 if s.recvBuf != nil {
248 bufLen = uint32(s.recvBuf.Len())
418 if s.recvBuf == nil {
421 s.recvBuf = bytes.NewBuffer(make([]byte, 0, length))
423 if _, err := io.Copy(s.recvBuf, conn); err != nil {
466 if s.recvBuf != nil && s.recvBuf.Len() == 0 {
[all …]

12345678910>>...23