| /dports/emulators/mesen/Mesen-0.9.8-4-g4c701ad6/Core/ |
| H A D | GameConnection.cpp | 29 bool GameConnection::ExtractMessage(void *buffer, uint32_t &messageLength) in ExtractMessage() argument
33 if(messageLength > 1000000) { in ExtractMessage()
39 int packetLength = messageLength + sizeof(messageLength); in ExtractMessage()
42 memcpy(buffer, _readBuffer+sizeof(messageLength), messageLength); in ExtractMessage()
55 uint32_t messageLength; in ReadMessage() local
56 if(ExtractMessage(_messageBuffer, messageLength)) { in ReadMessage()
58 case MessageType::HandShake: return new HandShakeMessage(_messageBuffer, messageLength); in ReadMessage()
59 case MessageType::SaveState: return new SaveStateMessage(_messageBuffer, messageLength); in ReadMessage()
60 case MessageType::InputData: return new InputDataMessage(_messageBuffer, messageLength); in ReadMessage()
61 case MessageType::MovieData: return new MovieDataMessage(_messageBuffer, messageLength); in ReadMessage()
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/csharp/src/Apache.Arrow/Ipc/ |
| H A D | ArrowStreamReaderImplementation.cs | 65 if (messageLength == 0) in ReadRecordBatchAsync()
101 if (messageLength == 0) in ReadRecordBatch()
173 int messageLength = 0; in ReadMessageLengthAsync()
187 messageLength = BitUtility.ReadInt32(lengthBuffer); in ReadMessageLengthAsync()
200 messageLength = 0; in ReadMessageLengthAsync()
204 messageLength = BitUtility.ReadInt32(lengthBuffer); in ReadMessageLengthAsync()
208 return messageLength; in ReadMessageLengthAsync()
213 int messageLength = 0; in ReadMessageLength()
226 messageLength = BitUtility.ReadInt32(lengthBuffer); in ReadMessageLength()
238 messageLength = 0; in ReadMessageLength()
[all …]
|
| H A D | ArrowMemoryReaderImplementation.cs | 53 … int messageLength = BinaryPrimitives.ReadInt32LittleEndian(_buffer.Span.Slice(_bufferPosition)); in ReadNextRecordBatch()
56 if (messageLength == 0) in ReadNextRecordBatch()
61 else if (messageLength == MessageSerializer.IpcContinuationToken) in ReadNextRecordBatch()
69 … messageLength = BinaryPrimitives.ReadInt32LittleEndian(_buffer.Span.Slice(_bufferPosition)); in ReadNextRecordBatch()
72 if (messageLength == 0) in ReadNextRecordBatch()
80 CreateByteBuffer(_buffer.Slice(_bufferPosition, messageLength))); in ReadNextRecordBatch()
81 _bufferPosition += messageLength; in ReadNextRecordBatch()
|
| /dports/databases/arrow/apache-arrow-6.0.1/csharp/src/Apache.Arrow/Ipc/ |
| H A D | ArrowStreamReaderImplementation.cs | 67 if (messageLength == 0) in ReadRecordBatchAsync()
107 if (messageLength == 0) in ReadRecordBatch()
179 int messageLength = 0; in ReadMessageLengthAsync()
193 messageLength = BitUtility.ReadInt32(lengthBuffer); in ReadMessageLengthAsync()
206 messageLength = 0; in ReadMessageLengthAsync()
210 messageLength = BitUtility.ReadInt32(lengthBuffer); in ReadMessageLengthAsync()
214 return messageLength; in ReadMessageLengthAsync()
219 int messageLength = 0; in ReadMessageLength()
232 messageLength = BitUtility.ReadInt32(lengthBuffer); in ReadMessageLength()
244 messageLength = 0; in ReadMessageLength()
[all …]
|
| H A D | ArrowMemoryReaderImplementation.cs | 53 … int messageLength = BinaryPrimitives.ReadInt32LittleEndian(_buffer.Span.Slice(_bufferPosition)); in ReadNextRecordBatch()
56 if (messageLength == 0) in ReadNextRecordBatch()
61 else if (messageLength == MessageSerializer.IpcContinuationToken) in ReadNextRecordBatch()
69 … messageLength = BinaryPrimitives.ReadInt32LittleEndian(_buffer.Span.Slice(_bufferPosition)); in ReadNextRecordBatch()
72 if (messageLength == 0) in ReadNextRecordBatch()
80 CreateByteBuffer(_buffer.Slice(_bufferPosition, messageLength))); in ReadNextRecordBatch()
81 _bufferPosition += messageLength; in ReadNextRecordBatch()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/csharp/src/Apache.Arrow/Ipc/ |
| H A D | ArrowStreamReaderImplementation.cs | 65 if (messageLength == 0) in ReadRecordBatchAsync()
101 if (messageLength == 0) in ReadRecordBatch()
173 int messageLength = 0; in ReadMessageLengthAsync()
187 messageLength = BitUtility.ReadInt32(lengthBuffer); in ReadMessageLengthAsync()
200 messageLength = 0; in ReadMessageLengthAsync()
204 messageLength = BitUtility.ReadInt32(lengthBuffer); in ReadMessageLengthAsync()
208 return messageLength; in ReadMessageLengthAsync()
213 int messageLength = 0; in ReadMessageLength()
226 messageLength = BitUtility.ReadInt32(lengthBuffer); in ReadMessageLength()
238 messageLength = 0; in ReadMessageLength()
[all …]
|
| H A D | ArrowMemoryReaderImplementation.cs | 53 … int messageLength = BinaryPrimitives.ReadInt32LittleEndian(_buffer.Span.Slice(_bufferPosition)); in ReadNextRecordBatch()
56 if (messageLength == 0) in ReadNextRecordBatch()
61 else if (messageLength == MessageSerializer.IpcContinuationToken) in ReadNextRecordBatch()
69 … messageLength = BinaryPrimitives.ReadInt32LittleEndian(_buffer.Span.Slice(_bufferPosition)); in ReadNextRecordBatch()
72 if (messageLength == 0) in ReadNextRecordBatch()
80 CreateByteBuffer(_buffer.Slice(_bufferPosition, messageLength))); in ReadNextRecordBatch()
81 _bufferPosition += messageLength; in ReadNextRecordBatch()
|
| /dports/java/bouncycastle15/crypto-169/core/src/main/java/org/bouncycastle/crypto/signers/ |
| H A D | ISO9796d2Signer.java | 42 private int messageLength; field in ISO9796d2Signer
129 if (messageLength > mBuf.length) in isSameAs()
281 mBuf[messageLength] = b; in update()
284 messageLength++; in update()
303 messageLength += len; in update()
312 messageLength = 0; in reset()
376 delta -= messageLength; in generateSignature()
404 messageLength = 0; in generateSignature()
581 if (messageLength != 0) in verifySignature()
592 messageLength = 0; in verifySignature()
[all …]
|
| H A D | ISO9796d2PSSSigner.java | 54 private int messageLength; field in ISO9796d2PSSSigner
193 if (messageLength != b.length) in isSameAs()
326 mBuf[messageLength++] = b; in update()
364 messageLength = 0; in reset()
397 LtoOSP(messageLength * 8, C); in generateSignature()
401 digest.update(mBuf, 0, messageLength); in generateSignature()
465 messageLength = 0; in generateSignature()
559 messageLength = 0; in verifySignature()
568 if (messageLength != 0) in verifySignature()
572 messageLength = 0; in verifySignature()
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ |
| H A D | MessageMetadataResult.java | 39 MessageMetadataResult(int messageLength, ByteBuffer messageBuffer, Message message) { in MessageMetadataResult() argument
40 this.messageLength = messageLength; in MessageMetadataResult()
51 public static MessageMetadataResult create(ByteBuffer buffer, int messageLength) { in create() argument
52 return new MessageMetadataResult(messageLength, buffer, Message.getRootAsMessage(buffer)); in create()
61 return messageLength; in getMessageLength()
112 private final int messageLength; field in MessageMetadataResult
|
| /dports/databases/arrow/apache-arrow-6.0.1/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ |
| H A D | MessageMetadataResult.java | 39 MessageMetadataResult(int messageLength, ByteBuffer messageBuffer, Message message) { in MessageMetadataResult() argument
40 this.messageLength = messageLength; in MessageMetadataResult()
51 public static MessageMetadataResult create(ByteBuffer buffer, int messageLength) { in create() argument
52 return new MessageMetadataResult(messageLength, buffer, Message.getRootAsMessage(buffer)); in create()
61 return messageLength; in getMessageLength()
112 private final int messageLength; field in MessageMetadataResult
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/java/vector/src/main/java/org/apache/arrow/vector/ipc/message/ |
| H A D | MessageMetadataResult.java | 39 MessageMetadataResult(int messageLength, ByteBuffer messageBuffer, Message message) { in MessageMetadataResult() argument
40 this.messageLength = messageLength; in MessageMetadataResult()
51 public static MessageMetadataResult create(ByteBuffer buffer, int messageLength) { in create() argument
52 return new MessageMetadataResult(messageLength, buffer, Message.getRootAsMessage(buffer)); in create()
61 return messageLength; in getMessageLength()
112 private final int messageLength; field in MessageMetadataResult
|
| /dports/security/cryptlib/cryptlib-3.4.3/session/ |
| H A D | cmp_cry.c | 344 IN_DATALENGTH const int messageLength ) in checkMessageMAC() argument
352 assert( isReadPtr( message, messageLength ) ); in checkMessageMAC()
354 REQUIRES( messageLength > 0 && messageLength < MAX_BUFFER_SIZE ); in checkMessageMAC()
369 messageLength ); in checkMessageMAC()
384 IN_DATALENGTH const int messageLength, in checkMessageSignature() argument
394 assert( isReadPtr( message, messageLength ) ); in checkMessageSignature()
397 REQUIRES( messageLength > 0 && messageLength < MAX_BUFFER_SIZE ); in checkMessageSignature()
468 IN_LENGTH_SHORT const int messageLength,
480 assert( isReadPtr( message, messageLength ) );
485 REQUIRES( messageLength > 0 && messageLength < MAX_INTLENGTH_SHORT );
[all …]
|
| /dports/devel/log4shib/log4shib-2.0.1/src/ |
| H A D | RemoteSyslogAppender.cpp | 133 int messageLength = message.length(); in _append() local
134 char *buf = new char [messageLength + 16]; in _append()
137 memcpy (buf + preambleLength, message.data(), messageLength); in _append()
154 while (messageLength > 0) { in _append()
157 if (preambleLength + messageLength > 900) { in _append()
159 messageLength -= (900 - preambleLength); in _append()
160 std::memmove (buf + preambleLength, buf + 900, messageLength); in _append()
163 … sendto (_socket, buf, preambleLength + messageLength, 0, addrinf->ai_addr, addrinf->ai_addrlen); in _append()
|
| /dports/devel/log4cpp/log4cpp/src/ |
| H A D | RemoteSyslogAppender.cpp | 143 size_t messageLength = message.length(); in _append() local
144 char *buf = new char [messageLength + 16]; in _append()
147 memcpy (buf + preambleLength, message.data(), messageLength); in _append()
155 while (messageLength > 0) { in _append()
158 if (preambleLength + messageLength > 900) { in _append()
160 messageLength -= (900 - preambleLength); in _append()
161 std::memmove (buf + preambleLength, buf + 900, messageLength); in _append()
164 …sendto (_socket, buf, preambleLength + messageLength, 0, (struct sockaddr *) &sain, sizeof (sain)); in _append()
|
| /dports/security/bzrtp/bzrtp-1.0.6/src/ |
| H A D | packetParser.c | 110 uint16_t messageLength; in bzrtp_packetCheck() local
186 zrtpPacket->messageLength = messageLength; in bzrtp_packetCheck()
302 if (zrtpPacket->messageLength != ZRTP_HELLOACKMESSAGE_FIXED_LENGTH) { in bzrtp_packetParser()
418 if (zrtpPacket->messageLength != ZRTP_DHPARTMESSAGE_FIXED_LENGTH+pvLength) { in bzrtp_packetParser()
827 zrtpPacket->messageLength = ZRTP_HELLOACKMESSAGE_FIXED_LENGTH; in bzrtp_packetBuild()
927 zrtpPacket->messageLength = ZRTP_DHPARTMESSAGE_FIXED_LENGTH + pvLength; in bzrtp_packetBuild()
1037 zrtpPacket->messageLength = ZRTP_CONF2ACKMESSAGE_FIXED_LENGTH; in bzrtp_packetBuild()
1049 zrtpPacket->messageLength = ZRTP_PINGACKMESSAGE_FIXED_LENGTH; in bzrtp_packetBuild()
1361 zrtpPacket->messageLength = 0; /* length will be computed at packet build */ in bzrtp_createZrtpPacket()
1559 outputBuffer[2] = (uint8_t)((messageLength>>10)&0x00FF); in zrtpMessageSetHeader()
[all …]
|
| /dports/security/snoopy/snoopy-2.4.14/src/datasource/ |
| H A D | group.c | 59 int messageLength = 0; in snoopy_datasource_group() local
73 messageLength = snprintf(result, SNOOPY_DATASOURCE_MESSAGE_MAX_SIZE, "ERROR(getgrgid_r)"); in snoopy_datasource_group()
76 messageLength = snprintf(result, SNOOPY_DATASOURCE_MESSAGE_MAX_SIZE, "(undefined)"); in snoopy_datasource_group()
78 … messageLength = snprintf(result, SNOOPY_DATASOURCE_MESSAGE_MAX_SIZE, "%s", gr_gid->gr_name); in snoopy_datasource_group()
84 return messageLength; in snoopy_datasource_group()
|
| H A D | username.c | 59 int messageLength = 0; in snoopy_datasource_username() local
73 messageLength = snprintf(result, SNOOPY_DATASOURCE_MESSAGE_MAX_SIZE, "ERROR(getpwuid_r)"); in snoopy_datasource_username()
76 messageLength = snprintf(result, SNOOPY_DATASOURCE_MESSAGE_MAX_SIZE, "(undefined)"); in snoopy_datasource_username()
78 … messageLength = snprintf(result, SNOOPY_DATASOURCE_MESSAGE_MAX_SIZE, "%s", pwd_uid->pw_name); in snoopy_datasource_username()
84 return messageLength; in snoopy_datasource_username()
|
| H A D | egroup.c | 59 int messageLength = 0; in snoopy_datasource_egroup() local
73 messageLength = snprintf(result, SNOOPY_DATASOURCE_MESSAGE_MAX_SIZE, "ERROR(getgrgid_r)"); in snoopy_datasource_egroup()
76 messageLength = snprintf(result, SNOOPY_DATASOURCE_MESSAGE_MAX_SIZE, "(undefined)"); in snoopy_datasource_egroup()
78 … messageLength = snprintf(result, SNOOPY_DATASOURCE_MESSAGE_MAX_SIZE, "%s", gr_gid->gr_name); in snoopy_datasource_egroup()
84 return messageLength; in snoopy_datasource_egroup()
|
| H A D | eusername.c | 59 int messageLength = 0; in snoopy_datasource_eusername() local
73 messageLength = snprintf(result, SNOOPY_DATASOURCE_MESSAGE_MAX_SIZE, "ERROR(getpwuid_r)"); in snoopy_datasource_eusername()
76 messageLength = snprintf(result, SNOOPY_DATASOURCE_MESSAGE_MAX_SIZE, "(undefined)"); in snoopy_datasource_eusername()
78 … messageLength = snprintf(result, SNOOPY_DATASOURCE_MESSAGE_MAX_SIZE, "%s", pwd_uid->pw_name); in snoopy_datasource_eusername()
84 return messageLength; in snoopy_datasource_eusername()
|
| H A D | tty_username.c | 67 int messageLength = 0; in snoopy_datasource_tty_username() local
87 messageLength = snprintf(result, SNOOPY_DATASOURCE_MESSAGE_MAX_SIZE, "ERROR(getpwuid_r)"); in snoopy_datasource_tty_username()
90 messageLength = snprintf(result, SNOOPY_DATASOURCE_MESSAGE_MAX_SIZE, "(undefined)"); in snoopy_datasource_tty_username()
92 … messageLength = snprintf(result, SNOOPY_DATASOURCE_MESSAGE_MAX_SIZE, "%s", pwd_uid->pw_name); in snoopy_datasource_tty_username()
98 return messageLength; in snoopy_datasource_tty_username()
|
| /dports/devel/intel-graphics-compiler/intel-graphics-compiler-igc-1.0.9636/IGC/Compiler/CISACodeGen/ |
| H A D | messageEncoding.cpp | 40 uint messageLength, in Sampler() argument
58 IGC_ASSERT(messageLength > 0); in Sampler()
59 IGC_ASSERT(messageLength < 16); in Sampler()
297 const uint messageLength, in DataPortRead() argument
430 const uint messageLength, in DataPortWrite() argument
439 IGC_ASSERT(messageLength > 0); in DataPortWrite()
459 const uint messageLength, in PixelDataPort() argument
492 const uint messageLength, in UrbMessage() argument
609 unsigned int messageLength, in PixelInterpolator() argument
639 unsigned int messageLength, in PixelInterpolator() argument
[all …]
|
| /dports/security/cyrus-sasl2-sql/cyrus-sasl-2.1.28/mac/CommonKClient/mac_kclient3/Headers/KerberosSupport/ |
| H A D | ErrorLib.h | 137 extern OSStatus GetErrorLongFormat(OSStatus error, char *message, long messageLength);
138 extern OSStatus GetErrorShortFormat(OSStatus error, char *message, long messageLength);
139 extern OSStatus GetErrorManager(OSStatus error, char *message, long messageLength);
140 extern OSStatus GetErrorShortString(OSStatus error, char *message, long messageLength);
141 extern OSStatus GetErrorLongString(OSStatus error, char *message, long messageLength);
143 extern OSStatus GetErrorString(OSStatus error, char *message, long messageLength, ErrorFormat forma…
|
| /dports/security/cyrus-sasl2-gssapi/cyrus-sasl-2.1.28/mac/CommonKClient/mac_kclient3/Headers/KerberosSupport/ |
| H A D | ErrorLib.h | 137 extern OSStatus GetErrorLongFormat(OSStatus error, char *message, long messageLength);
138 extern OSStatus GetErrorShortFormat(OSStatus error, char *message, long messageLength);
139 extern OSStatus GetErrorManager(OSStatus error, char *message, long messageLength);
140 extern OSStatus GetErrorShortString(OSStatus error, char *message, long messageLength);
141 extern OSStatus GetErrorLongString(OSStatus error, char *message, long messageLength);
143 extern OSStatus GetErrorString(OSStatus error, char *message, long messageLength, ErrorFormat forma…
|
| /dports/security/cyrus-sasl2-srp/cyrus-sasl-2.1.28/mac/CommonKClient/mac_kclient3/Headers/KerberosSupport/ |
| H A D | ErrorLib.h | 137 extern OSStatus GetErrorLongFormat(OSStatus error, char *message, long messageLength);
138 extern OSStatus GetErrorShortFormat(OSStatus error, char *message, long messageLength);
139 extern OSStatus GetErrorManager(OSStatus error, char *message, long messageLength);
140 extern OSStatus GetErrorShortString(OSStatus error, char *message, long messageLength);
141 extern OSStatus GetErrorLongString(OSStatus error, char *message, long messageLength);
143 extern OSStatus GetErrorString(OSStatus error, char *message, long messageLength, ErrorFormat forma…
|