| /dports/devel/sdbus-cpp/sdbus-cpp-1.1.0/tests/perftests/ |
| H A D | client.cpp | 109 unsigned int msgSize{}; in main() local
111 msgSize = 20; in main()
116 client.sendDataSignals(msgCount, msgSize); in main()
124 msgSize = 1000; in main()
129 client.sendDataSignals(msgCount, msgSize); in main()
137 msgSize = 20; in main()
141 auto str1 = createRandomString(msgSize/2); in main()
142 auto str2 = createRandomString(msgSize/2); in main()
150 assert(result.size() == msgSize); in main()
163 msgSize = 1000; in main()
[all …]
|
| /dports/graphics/ospray/ospray-2.8.0/modules/mpi/ospray/fb/ |
| H A D | DistributedFrameBuffer_TileMessages.cpp | 11 const size_t msgSize =
13 auto msg = std::make_shared<mpicommon::Message>(msgSize + sizeof(int));
16 std::memcpy(msg->data + sizeof(int), &tile, msgSize);
23 const size_t msgSize =
31 size_t msgSize = 0;
38 msgSize = sizeof(MasterTileMessage_RGBA_I8);
41 msgSize = sizeof(MasterTileMessage_RGBA_F32);
46 msgSize += sizeof(float) * TILE_SIZE * TILE_SIZE;
49 msgSize += 2 * sizeof(vec3f) * TILE_SIZE * TILE_SIZE;
51 return msgSize;
[all …]
|
| /dports/science/cdo/cdo-2.0.0/libcdi/src/ |
| H A D | pio_client.c | 46 int msgSize = 0; in cdiPioClientStreamOpen() local
53 msgSize += size; in cdiPioClientStreamOpen()
55 msgSize += size; in cdiPioClientStreamOpen()
57 msgSize += size; in cdiPioClientStreamOpen()
103 int msgSize = 0; in cdiPioClientStreamDefVlist_() local
108 msgSize += size; in cdiPioClientStreamDefVlist_()
111 msgBuffer = Realloc(msgBuffer, (size_t)msgSize); in cdiPioClientStreamDefVlist_()
114 msgBuffer, msgSize, &msgBufPos, comm)); in cdiPioClientStreamDefVlist_()
220 int msgSize = 0; in cdiPioClientStreamClose() local
225 msgSize += size; in cdiPioClientStreamClose()
[all …]
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/hotspot/jtreg/compiler/intrinsics/sha/ |
| H A D | TestSHA.java | 92 int msgSize = Integer.getInteger("msgSize", 1024); in main() local
97 testSHA(provider, algorithm, msgSize, offset, iters, warmupIters); in main()
100 testSHA(provider, algorithm2, msgSize, offset, iters, warmupIters); in main()
104 public static void testSHA(String provider, String algorithm, int msgSize, in testSHA() argument
108 System.out.println("msgSize = " + msgSize + " bytes"); in testSHA()
114 byte[] data = new byte[msgSize + offset]; in testSHA()
115 for (int i = 0; i < (msgSize + offset); i++) { in testSHA()
124 sha.update(data, offset, msgSize); in testSHA()
130 sha.update(data, offset, msgSize); in testSHA()
149 sha.update(data, offset, msgSize); in testSHA()
[all …]
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/hotspot/jtreg/compiler/intrinsics/sha/ |
| H A D | TestSHA.java | 92 int msgSize = Integer.getInteger("msgSize", 1024); in main() local
97 testSHA(provider, algorithm, msgSize, offset, iters, warmupIters); in main()
100 testSHA(provider, algorithm2, msgSize, offset, iters, warmupIters); in main()
104 public static void testSHA(String provider, String algorithm, int msgSize, in testSHA() argument
108 System.out.println("msgSize = " + msgSize + " bytes"); in testSHA()
114 byte[] data = new byte[msgSize + offset]; in testSHA()
115 for (int i = 0; i < (msgSize + offset); i++) { in testSHA()
124 sha.update(data, offset, msgSize); in testSHA()
130 sha.update(data, offset, msgSize); in testSHA()
149 sha.update(data, offset, msgSize); in testSHA()
[all …]
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/hotspot/jtreg/compiler/intrinsics/sha/ |
| H A D | TestSHA.java | 92 int msgSize = Integer.getInteger("msgSize", 1024); in main() local
97 testSHA(provider, algorithm, msgSize, offset, iters, warmupIters); in main()
100 testSHA(provider, algorithm2, msgSize, offset, iters, warmupIters); in main()
104 public static void testSHA(String provider, String algorithm, int msgSize, in testSHA() argument
108 System.out.println("msgSize = " + msgSize + " bytes"); in testSHA()
114 byte[] data = new byte[msgSize + offset]; in testSHA()
115 for (int i = 0; i < (msgSize + offset); i++) { in testSHA()
124 sha.update(data, offset, msgSize); in testSHA()
130 sha.update(data, offset, msgSize); in testSHA()
149 sha.update(data, offset, msgSize); in testSHA()
[all …]
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/hotspot/jtreg/compiler/intrinsics/sha/ |
| H A D | TestSHA.java | 92 int msgSize = Integer.getInteger("msgSize", 1024); in main() local
97 testSHA(provider, algorithm, msgSize, offset, iters, warmupIters); in main()
100 testSHA(provider, algorithm2, msgSize, offset, iters, warmupIters); in main()
104 public static void testSHA(String provider, String algorithm, int msgSize, in testSHA() argument
108 System.out.println("msgSize = " + msgSize + " bytes"); in testSHA()
114 byte[] data = new byte[msgSize + offset]; in testSHA()
115 for (int i = 0; i < (msgSize + offset); i++) { in testSHA()
124 sha.update(data, offset, msgSize); in testSHA()
130 sha.update(data, offset, msgSize); in testSHA()
149 sha.update(data, offset, msgSize); in testSHA()
[all …]
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/hotspot/jtreg/compiler/intrinsics/sha/ |
| H A D | TestDigest.java | 147 int msgSize = Integer.getInteger("msgSize", 1024); in main() local
152 testDigest(provider, algorithm, msgSize, offset, iters, warmupIters); in main()
155 testDigest(provider, algorithm2, msgSize, offset, iters, warmupIters); in main()
159 public static void testDigest(String provider, String algorithm, int msgSize, in testDigest() argument
163 System.out.println("msgSize = " + msgSize + " bytes"); in testDigest()
169 byte[] data = new byte[msgSize + offset]; in testDigest()
170 for (int i = 0; i < (msgSize + offset); i++) { in testDigest()
179 digest.update(data, offset, msgSize); in testDigest()
185 digest.update(data, offset, msgSize); in testDigest()
204 digest.update(data, offset, msgSize); in testDigest()
[all …]
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/hotspot/jtreg/compiler/intrinsics/sha/ |
| H A D | TestDigest.java | 147 int msgSize = Integer.getInteger("msgSize", 1024); in main() local
152 testDigest(provider, algorithm, msgSize, offset, iters, warmupIters); in main()
155 testDigest(provider, algorithm2, msgSize, offset, iters, warmupIters); in main()
159 public static void testDigest(String provider, String algorithm, int msgSize, in testDigest() argument
163 System.out.println("msgSize = " + msgSize + " bytes"); in testDigest()
169 byte[] data = new byte[msgSize + offset]; in testDigest()
170 for (int i = 0; i < (msgSize + offset); i++) { in testDigest()
179 digest.update(data, offset, msgSize); in testDigest()
185 digest.update(data, offset, msgSize); in testDigest()
204 digest.update(data, offset, msgSize); in testDigest()
[all …]
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/hotspot/jtreg/compiler/intrinsics/sha/ |
| H A D | TestSHA.java | 92 int msgSize = Integer.getInteger("msgSize", 1024); in main() local
97 testSHA(provider, algorithm, msgSize, offset, iters, warmupIters); in main()
100 testSHA(provider, algorithm2, msgSize, offset, iters, warmupIters); in main()
104 public static void testSHA(String provider, String algorithm, int msgSize, in testSHA() argument
108 System.out.println("msgSize = " + msgSize + " bytes"); in testSHA()
114 byte[] data = new byte[msgSize + offset]; in testSHA()
115 for (int i = 0; i < (msgSize + offset); i++) { in testSHA()
124 sha.update(data, offset, msgSize); in testSHA()
130 sha.update(data, offset, msgSize); in testSHA()
149 sha.update(data, offset, msgSize); in testSHA()
[all …]
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/hotspot/jtreg/compiler/intrinsics/sha/ |
| H A D | TestSHA.java | 92 int msgSize = Integer.getInteger("msgSize", 1024); in main() local
97 testSHA(provider, algorithm, msgSize, offset, iters, warmupIters); in main()
100 testSHA(provider, algorithm2, msgSize, offset, iters, warmupIters); in main()
104 public static void testSHA(String provider, String algorithm, int msgSize, in testSHA() argument
108 System.out.println("msgSize = " + msgSize + " bytes"); in testSHA()
114 byte[] data = new byte[msgSize + offset]; in testSHA()
115 for (int i = 0; i < (msgSize + offset); i++) { in testSHA()
124 sha.update(data, offset, msgSize); in testSHA()
130 sha.update(data, offset, msgSize); in testSHA()
149 sha.update(data, offset, msgSize); in testSHA()
[all …]
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/hotspot/test/compiler/intrinsics/sha/ |
| H A D | TestSHA.java | 61 int msgSize = Integer.getInteger("msgSize", 1024); in main() local
66 testSHA(provider, algorithm, msgSize, offset, iters, warmupIters); in main()
69 testSHA(provider, algorithm2, msgSize, offset, iters, warmupIters); in main()
73 static void testSHA(String provider, String algorithm, int msgSize, in testSHA() argument
77 System.out.println("msgSize = " + msgSize + " bytes"); in testSHA()
83 byte[] data = new byte[msgSize + offset]; in testSHA()
84 for (int i = 0; i < (msgSize + offset); i++) { in testSHA()
93 sha.update(data, offset, msgSize); in testSHA()
99 sha.update(data, offset, msgSize); in testSHA()
118 sha.update(data, offset, msgSize); in testSHA()
[all …]
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/hotspot/test/compiler/intrinsics/sha/ |
| H A D | TestSHA.java | 61 int msgSize = Integer.getInteger("msgSize", 1024); in main() local
66 testSHA(provider, algorithm, msgSize, offset, iters, warmupIters); in main()
69 testSHA(provider, algorithm2, msgSize, offset, iters, warmupIters); in main()
73 static void testSHA(String provider, String algorithm, int msgSize, in testSHA() argument
77 System.out.println("msgSize = " + msgSize + " bytes"); in testSHA()
83 byte[] data = new byte[msgSize + offset]; in testSHA()
84 for (int i = 0; i < (msgSize + offset); i++) { in testSHA()
93 sha.update(data, offset, msgSize); in testSHA()
99 sha.update(data, offset, msgSize); in testSHA()
118 sha.update(data, offset, msgSize); in testSHA()
[all …]
|
| /dports/games/7kaa/7kaa-2.15.4p1/src/ |
| H A D | OREMOTE2.cpp | 57 int msgSize = sizeof(uint32_t) + dataSize; in new_msg() local
63 int reqSize = sizeof(short) + msgSize; in new_msg()
77 *(short *)shortPtr = msgSize; in new_msg()
127 int msgSize = *(short *)memPtr + sizeof(short); in send_msg() local
671 *(short *)sendPtr = msgSize; in init_send_queue()
712 int msgSize; in init_receive_queue() local
718 *(short *)receivePtr = msgSize; in init_receive_queue()
729 msgSize = sizeof(uint32_t) + sizeof(short); in init_receive_queue()
732 *(short *)receivePtr = msgSize; in init_receive_queue()
741 msgSize = sizeof(uint32_t) + sizeof(short); in init_receive_queue()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/test/mpi/pt2pt/ |
| H A D | sendrecv3.c | 42 int msgSize = msgsizes[testnum]; in main() local
47 buf[i] = (int *) malloc(msgSize * sizeof(int)); in main()
49 fprintf(stderr, "Unable to allocate %d bytes\n", msgSize); in main()
52 MTEST_VG_MEM_INIT(buf[i], msgSize * sizeof(int)); in main()
60 MPI_Isend(buf[i], msgSize, MPI_INT, partner, testnum, comm, &r[i]); in main()
63 MPI_Recv(buf[i], msgSize, MPI_INT, partner, testnum, comm, MPI_STATUS_IGNORE); in main()
75 MPI_Isend(buf[i], msgSize, MPI_INT, partner, testnum, comm, &r[i]); in main()
79 MPI_Recv(buf[i], msgSize, MPI_INT, partner, testnum, comm, MPI_STATUS_IGNORE); in main()
85 msgSize, tsend); in main()
88 MTestPrintfMsg(1, "%d Isends for size = %d took %f seconds\n", nmsg, msgSize, tsend); in main()
|
| /dports/net/py-raet/raet-0.6.8/systest/load/ |
| H A D | test_road_highload.py | 57 msgSize=testing.MSG_SIZE_MED,
69 msgSize=testing.MSG_SIZE_MED,
81 msgSize=testing.MSG_SIZE_MED,
93 msgSize=testing.MSG_SIZE_MED,
105 msgSize=testing.MSG_SIZE_MED,
117 msgSize=testing.MSG_SIZE_MED,
129 msgSize=testing.MSG_SIZE_MED,
141 msgSize=testing.MSG_SIZE_MED,
153 msgSize=testing.MSG_SIZE_MED,
165 msgSize=testing.MSG_SIZE_MED,
[all …]
|
| /dports/math/cvc4/CVC4-1.7/examples/hashsmt/ |
| H A D | sha1_collision.cpp | 62 unsigned msgSize; in main() local
64 msgSize_is >> msgSize; in main()
78 hashsmt::cvc4_uchar8 *cvc4input1 = createInput(msgSize, "x", output); in main()
79 hashsmt::cvc4_uchar8 *cvc4input2 = createInput(msgSize, "y", output); in main()
83 cvc4encoder1.process_bytes(cvc4input1, msgSize); in main()
89 cvc4encoder2.process_bytes(cvc4input2, msgSize); in main()
94 …r inputEqual = (hashsmt::Word::concat(cvc4input1, msgSize) == hashsmt::Word::concat(cvc4input2, ms… in main()
|
| /dports/net-mgmt/openlldp/openlldp-0.4alpha/src/ |
| H A D | lldpneighbors.c | 34 unsigned int msgSize = 0; in main() local
62 tmp = calloc(1, msgSize + bytes + 1); in main()
65 memcpy(tmp, buf, msgSize); in main()
70 memcpy(&tmp[msgSize], msg, bytes); in main()
71 msgSize += bytes; in main()
82 printf("Read %d bytes. Total size is now: %d\n", (int)bytes, msgSize); in main()
96 msgSize = 0; in main()
|
| /dports/net/mpich2/mpich2-1.5/test/mpi/pt2pt/ |
| H A D | sendrecv3.c | 43 int msgSize = msgsizes[testnum]; in main() local
48 buf[i] = (int *)malloc( msgSize ); in main()
57 MPI_Isend( buf[i], msgSize, MPI_CHAR, partner, testnum, comm, in main()
61 MPI_Recv( buf[i], msgSize, MPI_CHAR, partner, testnum, comm, in main()
74 MPI_Isend( buf[i], msgSize, MPI_CHAR, partner, testnum, comm, in main()
79 MPI_Recv( buf[i], msgSize, MPI_CHAR, partner, testnum, comm, in main()
85 printf( "Isends for %d messages of size %d took too long (%f seconds)\n", nmsg, msgSize, tsend ); in main()
89 nmsg, msgSize, tsend ); in main()
|
| /dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/github.com/nats-io/nats.go/examples/nats-bench/ |
| H A D | main.go | 55 var msgSize = flag.Int("ms", DefaultMessageSize, "Size of the message.")
106 go runSubscriber(nc, &startwg, &donewg, *numMsgs, *msgSize)
120 go runPublisher(nc, &startwg, &donewg, pubCounts[i], *msgSize)
123 …log.Printf("Starting benchmark [msgs=%d, msgsize=%d, pubs=%d, subs=%d]\n", *numMsgs, *msgSize, *nu…
139 func runPublisher(nc *nats.Conn, startwg, donewg *sync.WaitGroup, numMsgs int, msgSize int) {
145 if msgSize > 0 {
146 msg = make([]byte, msgSize)
155 benchmark.AddPubSample(bench.NewSample(numMsgs, msgSize, start, time.Now(), nc))
160 func runSubscriber(nc *nats.Conn, startwg, donewg *sync.WaitGroup, numMsgs int, msgSize int) {
181 benchmark.AddSubSample(bench.NewSample(numMsgs, msgSize, start, end, nc))
|
| /dports/textproc/xerces-c3/xerces-c-3.2.3/src/xercesc/util/ |
| H A D | XMLException.cpp | 177 const XMLSize_t msgSize = 2047; in loadExceptText() local
178 XMLCh errText[msgSize + 1]; in loadExceptText()
181 if (!gGetMsgLoader().loadMsg(toLoad, errText, msgSize)) in loadExceptText()
207 const XMLSize_t msgSize = 4095; in loadExceptText() local
208 XMLCh errText[msgSize + 1]; in loadExceptText()
211 if (!gGetMsgLoader().loadMsg(toLoad, errText, msgSize, text1, text2, text3, text4, fMemoryManager)) in loadExceptText()
237 const XMLSize_t msgSize = 4095; in loadExceptText() local
238 XMLCh errText[msgSize + 1]; in loadExceptText()
241 if (!gGetMsgLoader().loadMsg(toLoad, errText, msgSize, text1, text2, text3, text4, fMemoryManager)) in loadExceptText()
|
| /dports/biology/py-python-libsbml/python-libsbml-5.19.0/libsbml_dependencies/xerces-c/src/xercesc/util/ |
| H A D | XMLException.cpp | 177 const XMLSize_t msgSize = 2047; in loadExceptText() local
178 XMLCh errText[msgSize + 1]; in loadExceptText()
181 if (!gGetMsgLoader().loadMsg(toLoad, errText, msgSize)) in loadExceptText()
207 const XMLSize_t msgSize = 4095; in loadExceptText() local
208 XMLCh errText[msgSize + 1]; in loadExceptText()
211 if (!gGetMsgLoader().loadMsg(toLoad, errText, msgSize, text1, text2, text3, text4, fMemoryManager)) in loadExceptText()
237 const XMLSize_t msgSize = 4095; in loadExceptText() local
238 XMLCh errText[msgSize + 1]; in loadExceptText()
241 if (!gGetMsgLoader().loadMsg(toLoad, errText, msgSize, text1, text2, text3, text4, fMemoryManager)) in loadExceptText()
|
| /dports/comms/limesuite/LimeSuite-20.10.0/src/ConnectionRemote/ |
| H A D | LMS64CProtocol_remote.cpp | 132 const int msgSize = 64; in ProcessConnections() local
133 char data[msgSize] = {0}; in ProcessConnections()
140 int brecv = recv(clientFd, data+r, msgSize-r, 0); in ProcessConnections()
157 while(r < msgSize); in ProcessConnections()
163 Write((unsigned char*)data, msgSize); in ProcessConnections()
164 Read((unsigned char*)data, msgSize); in ProcessConnections()
168 while(bsent < msgSize) in ProcessConnections()
170 int r = send(clientFd, data+bsent, msgSize-bsent, 0); in ProcessConnections()
|
| /dports/devel/poco/poco-1.10.1-all/Net/testsuite/src/ |
| H A D | WebSocketTest.cpp | 196 const int msgSize = 64000; in testWebSocketLarge() local
208 ws.setSendBufferSize(msgSize); in testWebSocketLarge()
209 ws.setReceiveBufferSize(msgSize); in testWebSocketLarge()
210 std::string payload(msgSize, 'x'); in testWebSocketLarge()
215 char buffer[msgSize + 1] = {}; in testWebSocketLarge()
221 } while (n > 0 && n < msgSize); in testWebSocketLarge()
240 ws.setSendBufferSize(msgSize); in testOneLargeFrame()
241 ws.setReceiveBufferSize(msgSize); in testOneLargeFrame()
242 std::string payload(msgSize, 'x'); in testOneLargeFrame()
244 ws.sendFrame(payload.data(), msgSize); in testOneLargeFrame()
[all …]
|
| /dports/audio/libopenmpt/libopenmpt-0.6.0+release.autotools/soundlib/ |
| H A D | MIDIEvents.cpp | 99 uint8 msgSize = 3; in GetEventLength() local
104 msgSize = 2; in GetEventLength()
111 msgSize = 2; in GetEventLength()
114 msgSize = 3; in GetEventLength()
117 msgSize = 1; in GetEventLength()
122 return msgSize; in GetEventLength()
|