/dports/net/norm/norm-1.5r6/examples/ |
H A D | normStreamSend.cpp | 116 UINT16 msgHeader = htons(msgLen); in main() 122 unsigned int bytesWritten = NormStreamWrite(stream, msgData, msgLen); in main() 123 bool vacancy = (bytesWritten == msgLen); in main() 134 delayTime = (msgRate > 0.0) ? ((double)msgLen / msgRate) : 0.0; in main() 200 if (keepSending && (bytesWritten < msgLen)) in main() 204 if (bytesWritten == msgLen) in main() 258 msgHeader = htons(msgLen); in main() 260 memset(msgData+2, data, msgLen-3); // n-byte message content in main() 261 msgData[msgLen - 1] = '\0'; // 1-byte NULL-termination in main() 262 bytesWritten = NormStreamWrite(stream, msgData, msgLen); in main() [all …]
|
H A D | normStreamRecv.cpp | 83 UINT16 msgLen = 0; in main() local 101 msgLen = msgIndex = 0; // init stream reading state in main() 153 msgLen = msgIndex = 0; in main() 159 memcpy(&msgLen, msgBuffer, 2); in main() 160 msgLen = ntohs(msgLen); in main() 161 if ((msgLen < 2) || (msgLen > MSG_LENGTH_MAX)) in main() 164 msgLen = msgIndex = 0; in main() 170 unsigned int numBytes = msgLen - msgIndex; in main() 174 msgLen = msgIndex = 0; in main() 180 if (msgIndex == msgLen) in main() [all …]
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/daemon/logger/local/ |
H A D | read.go | 70 msgLen := binary.BigEndian.Uint32(buf) 81 if msgLen != binary.BigEndian.Uint32(buf) { 86 offset -= int64(msgLen) 128 msgLen := int(binary.BigEndian.Uint32(buf[:read])) 130 if len(buf) < msgLen+encodeBinaryLen { 131 buf = make([]byte, msgLen+encodeBinaryLen) 133 if msgLen <= initialBufSize { 136 buf = buf[:msgLen+encodeBinaryLen] 140 return decodeLogEntry(rdr, proto, buf, msgLen) 151 n, err = io.ReadFull(rdr, buf[read:msgLen+encodeBinaryLen]) [all …]
|
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/daemon/logger/local/ |
H A D | read.go | 70 msgLen := binary.BigEndian.Uint32(buf) 81 if msgLen != binary.BigEndian.Uint32(buf) { 86 offset -= int64(msgLen) 128 msgLen := int(binary.BigEndian.Uint32(buf[:read])) 130 if len(buf) < msgLen+encodeBinaryLen { 131 buf = make([]byte, msgLen+encodeBinaryLen) 133 if msgLen <= initialBufSize { 136 buf = buf[:msgLen+encodeBinaryLen] 140 return decodeLogEntry(rdr, proto, buf, msgLen) 151 n, err = io.ReadFull(rdr, buf[read:msgLen+encodeBinaryLen]) [all …]
|
/dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/daemon/logger/local/ |
H A D | read.go | 70 msgLen := binary.BigEndian.Uint32(buf) 81 if msgLen != binary.BigEndian.Uint32(buf) { 86 offset -= int64(msgLen) 128 msgLen := int(binary.BigEndian.Uint32(buf[:read])) 130 if len(buf) < msgLen+encodeBinaryLen { 131 buf = make([]byte, msgLen+encodeBinaryLen) 133 if msgLen <= initialBufSize { 136 buf = buf[:msgLen+encodeBinaryLen] 140 return decodeLogEntry(rdr, proto, buf, msgLen) 151 n, err = io.ReadFull(rdr, buf[read:msgLen+encodeBinaryLen]) [all …]
|
/dports/sysutils/docker/docker-ce-18.09.5/components/engine/daemon/logger/local/ |
H A D | read.go | 70 msgLen := binary.BigEndian.Uint32(buf) 81 if msgLen != binary.BigEndian.Uint32(buf) { 86 offset -= int64(msgLen) 128 msgLen := int(binary.BigEndian.Uint32(buf[:read])) 130 if len(buf) < msgLen+encodeBinaryLen { 131 buf = make([]byte, msgLen+encodeBinaryLen) 133 if msgLen <= initialBufSize { 136 buf = buf[:msgLen+encodeBinaryLen] 140 return decodeLogEntry(rdr, proto, buf, msgLen) 151 n, err = io.ReadFull(rdr, buf[read:msgLen+encodeBinaryLen]) [all …]
|
/dports/math/ipopt/Ipopt-3.12.13/Ipopt/src/contrib/LinearSolverLoader/ |
H A D | LibraryHandler.c | 29 soHandle_t LSL_loadLib(const char *libName, char *msgBuf, int msgLen) in LSL_loadLib() argument 34 …mysnprintf(msgBuf, msgLen, "loadLib error: Do not know how to handle shared libraries on this oper… in LSL_loadLib() 39 mysnprintf(msgBuf, msgLen, "loadLib error: no library name given (libName is NULL)"); in LSL_loadLib() 46 …mysnprintf(msgBuf, msgLen, "Windows error while loading dynamic library %s, error = %d.\n(see http… in LSL_loadLib() 51 strncpy(msgBuf, dlerror(), msgLen); in LSL_loadLib() 52 msgBuf[msgLen-1]=0; in LSL_loadLib() 91 symtype LSL_loadSym (soHandle_t h, const char *symName, char *msgBuf, int msgLen) in LSL_loadSym() argument 161 …mysnprintf(msgBuf, msgLen, "Cannot find symbol %s in dynamic library, error = %d.", symName, GetLa… in LSL_loadSym() 168 strncpy(msgBuf, err, msgLen); in LSL_loadSym() 169 msgBuf[msgLen-1]=0; in LSL_loadSym()
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/daemon/logger/local/ |
H A D | read.go | 70 msgLen := binary.BigEndian.Uint32(buf) 81 if msgLen != binary.BigEndian.Uint32(buf) { 86 offset -= int64(msgLen) 136 msgLen := int(binary.BigEndian.Uint32(d.buf[:read])) 138 if len(d.buf) < msgLen+encodeBinaryLen { 139 d.buf = make([]byte, msgLen+encodeBinaryLen) 141 if msgLen <= initialBufSize { 144 d.buf = d.buf[:msgLen+encodeBinaryLen] 148 return decodeLogEntry(d.rdr, d.proto, d.buf, msgLen) 181 n, err = io.ReadFull(rdr, buf[read:msgLen+encodeBinaryLen]) [all …]
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/docker/daemon/logger/local/ |
H A D | read.go | 70 msgLen := binary.BigEndian.Uint32(buf) 81 if msgLen != binary.BigEndian.Uint32(buf) { 86 offset -= int64(msgLen) 136 msgLen := int(binary.BigEndian.Uint32(d.buf[:read])) 138 if len(d.buf) < msgLen+encodeBinaryLen { 139 d.buf = make([]byte, msgLen+encodeBinaryLen) 141 if msgLen <= initialBufSize { 144 d.buf = d.buf[:msgLen+encodeBinaryLen] 148 return decodeLogEntry(d.rdr, d.proto, d.buf, msgLen) 181 n, err = io.ReadFull(rdr, buf[read:msgLen+encodeBinaryLen]) [all …]
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/daemon/logger/local/ |
H A D | read.go | 70 msgLen := binary.BigEndian.Uint32(buf) 81 if msgLen != binary.BigEndian.Uint32(buf) { 86 offset -= int64(msgLen) 136 msgLen := int(binary.BigEndian.Uint32(d.buf[:read])) 138 if len(d.buf) < msgLen+encodeBinaryLen { 139 d.buf = make([]byte, msgLen+encodeBinaryLen) 141 if msgLen <= initialBufSize { 144 d.buf = d.buf[:msgLen+encodeBinaryLen] 148 return decodeLogEntry(d.rdr, d.proto, d.buf, msgLen) 181 n, err = io.ReadFull(rdr, buf[read:msgLen+encodeBinaryLen]) [all …]
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/daemon/logger/local/ |
H A D | read.go | 70 msgLen := binary.BigEndian.Uint32(buf) 81 if msgLen != binary.BigEndian.Uint32(buf) { 86 offset -= int64(msgLen) 136 msgLen := int(binary.BigEndian.Uint32(d.buf[:read])) 138 if len(d.buf) < msgLen+encodeBinaryLen { 139 d.buf = make([]byte, msgLen+encodeBinaryLen) 141 if msgLen <= initialBufSize { 144 d.buf = d.buf[:msgLen+encodeBinaryLen] 148 return decodeLogEntry(d.rdr, d.proto, d.buf, msgLen) 181 n, err = io.ReadFull(rdr, buf[read:msgLen+encodeBinaryLen]) [all …]
|
/dports/devel/icu/icu/source/extra/uconv/ |
H A D | uwmsg.c | 126 int32_t msgLen; in u_wmsg() local 142 msg = ures_getStringByKey(gBundle, tag, &msgLen, &err); in u_wmsg() 151 if((msgLen + resultLength) <= UPRV_LENGTHOF(result)) { in u_wmsg() 152 memcpy(result, msg, msgLen * U_SIZEOF_UCHAR); in u_wmsg() 153 memcpy(result + msgLen, gNoFormatting, resultLength); in u_wmsg() 154 resultLength += msgLen; in u_wmsg() 157 uprint(msg,msgLen, fp, &err); in u_wmsg() 163 resultLength = u_vformatMessage(uloc_getDefault(), msg, msgLen, result, resultLength, ap, &err); in u_wmsg() 176 uprint(msg,msgLen, fp, &err); in u_wmsg() 221 int32_t msgLen; in u_wmsg_errorName() local [all …]
|
/dports/devel/icu-lx/icu/source/extra/uconv/ |
H A D | uwmsg.c | 126 int32_t msgLen; in u_wmsg() local 142 msg = ures_getStringByKey(gBundle, tag, &msgLen, &err); in u_wmsg() 151 if((msgLen + resultLength) <= UPRV_LENGTHOF(result)) { in u_wmsg() 152 memcpy(result, msg, msgLen * U_SIZEOF_UCHAR); in u_wmsg() 153 memcpy(result + msgLen, gNoFormatting, resultLength); in u_wmsg() 154 resultLength += msgLen; in u_wmsg() 157 uprint(msg,msgLen, fp, &err); in u_wmsg() 163 resultLength = u_vformatMessage(uloc_getDefault(), msg, msgLen, result, resultLength, ap, &err); in u_wmsg() 176 uprint(msg,msgLen, fp, &err); in u_wmsg() 221 int32_t msgLen; in u_wmsg_errorName() local [all …]
|
/dports/lang/v8/v8-9.6.180.12/third_party/icu/source/extra/uconv/ |
H A D | uwmsg.c | 126 int32_t msgLen; in u_wmsg() local 142 msg = ures_getStringByKey(gBundle, tag, &msgLen, &err); in u_wmsg() 151 if((msgLen + resultLength) <= UPRV_LENGTHOF(result)) { in u_wmsg() 152 memcpy(result, msg, msgLen * U_SIZEOF_UCHAR); in u_wmsg() 153 memcpy(result + msgLen, gNoFormatting, resultLength); in u_wmsg() 154 resultLength += msgLen; in u_wmsg() 157 uprint(msg,msgLen, fp, &err); in u_wmsg() 163 resultLength = u_vformatMessage(uloc_getDefault(), msg, msgLen, result, resultLength, ap, &err); in u_wmsg() 176 uprint(msg,msgLen, fp, &err); in u_wmsg() 221 int32_t msgLen; in u_wmsg_errorName() local [all …]
|
/dports/www/firefox-esr/firefox-91.8.0/intl/icu/source/extra/uconv/ |
H A D | uwmsg.c | 126 int32_t msgLen; in u_wmsg() local 142 msg = ures_getStringByKey(gBundle, tag, &msgLen, &err); in u_wmsg() 151 if((msgLen + resultLength) <= UPRV_LENGTHOF(result)) { in u_wmsg() 152 memcpy(result, msg, msgLen * U_SIZEOF_UCHAR); in u_wmsg() 153 memcpy(result + msgLen, gNoFormatting, resultLength); in u_wmsg() 154 resultLength += msgLen; in u_wmsg() 157 uprint(msg,msgLen, fp, &err); in u_wmsg() 163 resultLength = u_vformatMessage(uloc_getDefault(), msg, msgLen, result, resultLength, ap, &err); in u_wmsg() 176 uprint(msg,msgLen, fp, &err); in u_wmsg() 221 int32_t msgLen; in u_wmsg_errorName() local [all …]
|
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/jdk/com/sun/jndi/ldap/lib/ |
H A D | BaseLdapServer.java | 138 int msgLen = -1; in handleConnection() local 143 if (msgLen <= 0) { in handleConnection() 144 msgLen = LdapMessage.getMessageLength(buffer.toByteArray()); in handleConnection() 147 if (msgLen > 0 && buffer.size() >= msgLen) { in handleConnection() 148 if (buffer.size() > msgLen) { in handleConnection() 150 request = Arrays.copyOf(tmpBuffer, msgLen); in handleConnection() 152 buffer.write(tmpBuffer, msgLen, tmpBuffer.length - msgLen); in handleConnection() 157 msgLen = -1; in handleConnection() 160 "bytes received {0}, expected {1}", buffer.size(), msgLen); in handleConnection()
|
/dports/lang/spidermonkey78/firefox-78.9.0/intl/icu/source/extra/uconv/ |
H A D | uwmsg.c | 125 int32_t msgLen; in u_wmsg() local 141 msg = ures_getStringByKey(gBundle, tag, &msgLen, &err); in u_wmsg() 150 if((msgLen + resultLength) <= UPRV_LENGTHOF(result)) { in u_wmsg() 151 memcpy(result, msg, msgLen * U_SIZEOF_UCHAR); in u_wmsg() 152 memcpy(result + msgLen, gNoFormatting, resultLength); in u_wmsg() 153 resultLength += msgLen; in u_wmsg() 156 uprint(msg,msgLen, fp, &err); in u_wmsg() 162 resultLength = u_vformatMessage(uloc_getDefault(), msg, msgLen, result, resultLength, ap, &err); in u_wmsg() 175 uprint(msg,msgLen, fp, &err); in u_wmsg() 220 int32_t msgLen; in u_wmsg_errorName() local [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/icu/source/extra/uconv/ |
H A D | uwmsg.c | 125 int32_t msgLen; in u_wmsg() local 141 msg = ures_getStringByKey(gBundle, tag, &msgLen, &err); in u_wmsg() 150 if((msgLen + resultLength) <= UPRV_LENGTHOF(result)) { in u_wmsg() 151 memcpy(result, msg, msgLen * U_SIZEOF_UCHAR); in u_wmsg() 152 memcpy(result + msgLen, gNoFormatting, resultLength); in u_wmsg() 153 resultLength += msgLen; in u_wmsg() 156 uprint(msg,msgLen, fp, &err); in u_wmsg() 162 resultLength = u_vformatMessage(uloc_getDefault(), msg, msgLen, result, resultLength, ap, &err); in u_wmsg() 175 uprint(msg,msgLen, fp, &err); in u_wmsg() 220 int32_t msgLen; in u_wmsg_errorName() local [all …]
|
/dports/www/firefox/firefox-99.0/intl/icu/source/extra/uconv/ |
H A D | uwmsg.c | 126 int32_t msgLen; in u_wmsg() local 142 msg = ures_getStringByKey(gBundle, tag, &msgLen, &err); in u_wmsg() 151 if((msgLen + resultLength) <= UPRV_LENGTHOF(result)) { in u_wmsg() 152 memcpy(result, msg, msgLen * U_SIZEOF_UCHAR); in u_wmsg() 153 memcpy(result + msgLen, gNoFormatting, resultLength); in u_wmsg() 154 resultLength += msgLen; in u_wmsg() 157 uprint(msg,msgLen, fp, &err); in u_wmsg() 163 resultLength = u_vformatMessage(uloc_getDefault(), msg, msgLen, result, resultLength, ap, &err); in u_wmsg() 176 uprint(msg,msgLen, fp, &err); in u_wmsg() 221 int32_t msgLen; in u_wmsg_errorName() local [all …]
|
/dports/mail/thunderbird/thunderbird-91.8.0/intl/icu/source/extra/uconv/ |
H A D | uwmsg.c | 126 int32_t msgLen; in u_wmsg() local 142 msg = ures_getStringByKey(gBundle, tag, &msgLen, &err); in u_wmsg() 151 if((msgLen + resultLength) <= UPRV_LENGTHOF(result)) { in u_wmsg() 152 memcpy(result, msg, msgLen * U_SIZEOF_UCHAR); in u_wmsg() 153 memcpy(result + msgLen, gNoFormatting, resultLength); in u_wmsg() 154 resultLength += msgLen; in u_wmsg() 157 uprint(msg,msgLen, fp, &err); in u_wmsg() 163 resultLength = u_vformatMessage(uloc_getDefault(), msg, msgLen, result, resultLength, ap, &err); in u_wmsg() 176 uprint(msg,msgLen, fp, &err); in u_wmsg() 221 int32_t msgLen; in u_wmsg_errorName() local [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/icu/source/extra/uconv/ |
H A D | uwmsg.c | 126 int32_t msgLen; in u_wmsg() local 142 msg = ures_getStringByKey(gBundle, tag, &msgLen, &err); in u_wmsg() 151 if((msgLen + resultLength) <= UPRV_LENGTHOF(result)) { in u_wmsg() 152 memcpy(result, msg, msgLen * U_SIZEOF_UCHAR); in u_wmsg() 153 memcpy(result + msgLen, gNoFormatting, resultLength); in u_wmsg() 154 resultLength += msgLen; in u_wmsg() 157 uprint(msg,msgLen, fp, &err); in u_wmsg() 163 resultLength = u_vformatMessage(uloc_getDefault(), msg, msgLen, result, resultLength, ap, &err); in u_wmsg() 176 uprint(msg,msgLen, fp, &err); in u_wmsg() 221 int32_t msgLen; in u_wmsg_errorName() local [all …]
|
/dports/www/firefox-legacy/firefox-52.8.0esr/intl/icu/source/extra/uconv/ |
H A D | uwmsg.c | 125 int32_t msgLen; in u_wmsg() local 141 msg = ures_getStringByKey(gBundle, tag, &msgLen, &err); in u_wmsg() 150 if((msgLen + resultLength) <= UPRV_LENGTHOF(result)) { in u_wmsg() 151 memcpy(result, msg, msgLen * U_SIZEOF_UCHAR); in u_wmsg() 152 memcpy(result + msgLen, gNoFormatting, resultLength); in u_wmsg() 153 resultLength += msgLen; in u_wmsg() 156 uprint(msg,msgLen, fp, &err); in u_wmsg() 161 resultLength = u_vformatMessage(uloc_getDefault(), msg, msgLen, result, resultLength, ap, &err); in u_wmsg() 174 uprint(msg,msgLen, fp, &err); in u_wmsg() 219 int32_t msgLen; in u_wmsg_errorName() local [all …]
|
/dports/lang/spidermonkey60/firefox-60.9.0/intl/icu/source/extra/uconv/ |
H A D | uwmsg.c | 125 int32_t msgLen; in u_wmsg() local 141 msg = ures_getStringByKey(gBundle, tag, &msgLen, &err); in u_wmsg() 150 if((msgLen + resultLength) <= UPRV_LENGTHOF(result)) { in u_wmsg() 151 memcpy(result, msg, msgLen * U_SIZEOF_UCHAR); in u_wmsg() 152 memcpy(result + msgLen, gNoFormatting, resultLength); in u_wmsg() 153 resultLength += msgLen; in u_wmsg() 156 uprint(msg,msgLen, fp, &err); in u_wmsg() 161 resultLength = u_vformatMessage(uloc_getDefault(), msg, msgLen, result, resultLength, ap, &err); in u_wmsg() 174 uprint(msg,msgLen, fp, &err); in u_wmsg() 219 int32_t msgLen; in u_wmsg_errorName() local [all …]
|
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/com/sun/jndi/ldap/lib/ |
H A D | BaseLdapServer.java | 138 int msgLen = -1; in handleConnection() local 143 if (msgLen <= 0) { in handleConnection() 144 msgLen = LdapMessage.getMessageLength(buffer.toByteArray()); in handleConnection() 147 if (msgLen > 0 && buffer.size() >= msgLen) { in handleConnection() 148 if (buffer.size() > msgLen) { in handleConnection() 150 request = Arrays.copyOf(tmpBuffer, msgLen); in handleConnection() 152 buffer.write(tmpBuffer, msgLen, tmpBuffer.length - msgLen); in handleConnection() 157 msgLen = -1; in handleConnection() 160 "bytes received {0}, expected {1}", buffer.size(), msgLen); in handleConnection()
|
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/github.com/redjack/marionette/plugins/tg/ |
H A D | fte.go | 13 msgLen int member 17 func NewFTECipher(key, regex string, msgLen int, useCapacity bool) *FTECipher { 21 msgLen: msgLen, 34 cipher, err := fsm.Cipher(c.regex, c.msgLen) 42 cipher, err := fsm.Cipher(c.regex, c.msgLen) 50 cipher, err := fsm.Cipher(c.regex, c.msgLen)
|