/dports/science/dakota/dakota-6.13.0-release-public.src-UI/packages/external/trilinos/packages/teuchos/comm/src/ |
H A D | Teuchos_CommHelpers.cpp | 158 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 D | putfidx.c | 25 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 D | putfidx.c | 24 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 D | vtkPartitionBalancer.cxx | 94 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 D | dialog.c | 93 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 D | DefaultMpiComm_TagTests.cpp | 122 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 D | IpcChannelTest.cs | 48 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 D | TNonblockingMultiFetchClient.java | 98 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 D | TNonblockingMultiFetchClient.java | 98 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 D | TNonblockingMultiFetchClient.java | 98 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 D | TNonblockingMultiFetchClient.java | 98 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 D | TNonblockingMultiFetchClient.java | 98 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 D | TNonblockingMultiFetchClient.java | 98 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 D | TNonblockingMultiFetchClient.java | 99 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 D | TNonblockingMultiFetchClient.java | 99 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 D | TNonblockingMultiFetchClient.java | 99 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 D | SslStreamStreamToStreamTest.cs | 64 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 D | stream.go | 36 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 D | stream.go | 36 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 D | stream.go | 36 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 D | stream.go | 36 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 D | stream.go | 36 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 D | stream.go | 36 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 D | stream.go | 36 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 D | stream.go | 36 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 …]
|