Home
last modified time | relevance | path

Searched refs:msgLen (Results 1 – 25 of 1198) sorted by relevance

12345678910>>...48

/dports/net/norm/norm-1.5r6/examples/
H A DnormStreamSend.cpp116 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 DnormStreamRecv.cpp83 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 Dread.go70 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 Dread.go70 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 Dread.go70 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 Dread.go70 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 DLibraryHandler.c29 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 Dread.go70 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 Dread.go70 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 Dread.go70 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 Dread.go70 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 Duwmsg.c126 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 Duwmsg.c126 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 Duwmsg.c126 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 Duwmsg.c126 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 DBaseLdapServer.java138 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 Duwmsg.c125 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 Duwmsg.c125 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 Duwmsg.c126 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 Duwmsg.c126 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 Duwmsg.c126 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 Duwmsg.c125 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 Duwmsg.c125 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 DBaseLdapServer.java138 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 Dfte.go13 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)

12345678910>>...48