| /dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/util/ |
| H A D | FileBasedWriteAheadLogRandomReader.scala | 38 val nextLength = instream.readInt() constant
39 HdfsUtils.checkState(nextLength == segment.length,
40 s"Expected message length to be ${segment.length}, but was $nextLength")
41 val buffer = new Array[Byte](nextLength)
|
| /dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/gitlab.com/yawning/obfs4.git/transports/obfs4/framing/ |
| H A D | framing.go | 214 nextLength uint16 member
243 if decoder.nextLength == 0 {
280 decoder.nextLength = length
283 if int(decoder.nextLength) > frames.Len() {
289 n, err := io.ReadFull(frames, box[:decoder.nextLength])
301 decoder.nextLength = 0
|
| /dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/gitlab.com/yawning/obfs4.git/transports/obfs4/framing/ |
| H A D | framing.go | 214 nextLength uint16 member
243 if decoder.nextLength == 0 {
280 decoder.nextLength = length
283 if int(decoder.nextLength) > frames.Len() {
289 n, err := io.ReadFull(frames, box[:decoder.nextLength])
301 decoder.nextLength = 0
|
| /dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/gitlab.com/yawning/obfs4.git/transports/obfs4/framing/ |
| H A D | framing.go | 214 nextLength uint16 member
243 if decoder.nextLength == 0 {
280 decoder.nextLength = length
283 if int(decoder.nextLength) > frames.Len() {
289 n, err := io.ReadFull(frames, box[:decoder.nextLength])
301 decoder.nextLength = 0
|
| /dports/net/ooni-mini/probe-engine-0.23.0/vendor/gitlab.com/yawning/obfs4.git/transports/obfs4/framing/ |
| H A D | framing.go | 214 nextLength uint16 member
243 if decoder.nextLength == 0 {
280 decoder.nextLength = length
283 if int(decoder.nextLength) > frames.Len() {
289 n, err := io.ReadFull(frames, box[:decoder.nextLength])
301 decoder.nextLength = 0
|
| /dports/security/obfs4proxy-tor/transports/obfs4/framing/ |
| H A D | framing.go | 214 nextLength uint16 member
243 if decoder.nextLength == 0 {
280 decoder.nextLength = length
283 if int(decoder.nextLength) > frames.Len() {
289 n, err := io.ReadFull(frames, box[:decoder.nextLength])
301 decoder.nextLength = 0
|
| /dports/mail/lurker/lurker-2.3/libesort/ |
| H A D | File.cpp | 141 long thisLength, nextLength; // total key length in inverseBuffer() local
171 nextLength = 0; in inverseBuffer()
175 nextLength <<= 8; in inverseBuffer()
176 nextLength += *nextr; in inverseBuffer()
183 nextDelta = nextLength - nextDup; in inverseBuffer()
211 thisLength = nextLength; in inverseBuffer()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/protobuf/java/core/src/main/java/com/google/protobuf/ |
| H A D | ArrayDecoders.java | 590 final int nextLength = registers.int1; in decodeStringList() local
591 if (nextLength < 0) { in decodeStringList()
593 } else if (nextLength == 0) { in decodeStringList()
598 position += nextLength; in decodeStringList()
632 final int nextLength = registers.int1; in decodeStringListRequireUtf8() local
633 if (nextLength < 0) { in decodeStringListRequireUtf8()
635 } else if (nextLength == 0) { in decodeStringListRequireUtf8()
643 position += nextLength; in decodeStringListRequireUtf8()
674 if (nextLength < 0) { in decodeBytesList()
678 } else if (nextLength == 0) { in decodeBytesList()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/protobuf/java/core/src/main/java/com/google/protobuf/ |
| H A D | ArrayDecoders.java | 590 final int nextLength = registers.int1; in decodeStringList() local
591 if (nextLength < 0) { in decodeStringList()
593 } else if (nextLength == 0) { in decodeStringList()
598 position += nextLength; in decodeStringList()
632 final int nextLength = registers.int1; in decodeStringListRequireUtf8() local
633 if (nextLength < 0) { in decodeStringListRequireUtf8()
635 } else if (nextLength == 0) { in decodeStringListRequireUtf8()
643 position += nextLength; in decodeStringListRequireUtf8()
674 if (nextLength < 0) { in decodeBytesList()
678 } else if (nextLength == 0) { in decodeBytesList()
[all …]
|
| /dports/www/uwebsockets/uWebSockets-20.8.0/src/ |
| H A D | AsyncSocket.h | 194 …std::pair<int, bool> write(const char *src, int length, bool optionally = false, int nextLength = …
254 … int written = us_socket_write(SSL, (us_socket_t *) this, src, length, nextLength != 0);
265 if (nextLength) {
266 …tData->buffer.reserve(asyncSocketData->buffer.length() + (size_t) (length - written + nextLength));
|
| /dports/editors/calligra/calligra-3.2.1/karbon/plugins/roundcorners/ |
| H A D | RoundCornersCommand.cpp | 223 qreal nextLength = nextSeg.length(); in roundPath() local
224 qreal nextSplit = nextLength > m_radius ? nextSeg.paramAtLength(m_radius) : 0.5; in roundPath()
273 qreal nextLength = nextSeg.length(); in roundPath() local
274 qreal nextSplit = nextLength > m_radius ? nextSeg.paramAtLength(m_radius) : 0.5; in roundPath()
|
| /dports/multimedia/libva-intel-media-driver/media-driver-intel-media-22.1.1/media_driver/media_softlet/agnostic/Xe_M/Xe_M_base/codec/hal/dec/avc/packet/ |
| H A D | decode_avc_slice_xe_m_base_packet.cpp | 74 uint32_t nextLength = 0; in SetAvcSliceStateParams() local
79 nextLength = (slc + 1)->slice_data_size; in SetAvcSliceStateParams()
98 avcSliceState.dwNextLength = nextLength; in SetAvcSliceStateParams()
|
| /dports/cad/sumo/sumo-1.2.0/tools/sumolib/ |
| H A D | geomhelper.py | 132 nextLength = distance(curr, next)
133 if seenLength + nextLength > offset:
135 seenLength += nextLength
|
| /dports/cad/sumo/sumo-1.2.0/src/utils/geom/ |
| H A D | PositionVector.cpp | 253 const double nextLength = (*i).distanceTo(*(i + 1)); in positionAtOffset() local
254 if (seenLength + nextLength > pos) { in positionAtOffset()
257 seenLength += nextLength; in positionAtOffset()
276 if (seenLength + nextLength > pos) { in positionAtOffset2D()
279 seenLength += nextLength; in positionAtOffset2D()
298 const double nextLength = p1.distanceTo(p2); in rotationAtOffset() local
299 if (seenLength + nextLength > pos) { in rotationAtOffset()
302 seenLength += nextLength; in rotationAtOffset()
326 const double nextLength = p1.distanceTo(p2); in slopeDegreeAtOffset() local
327 if (seenLength + nextLength > pos) { in slopeDegreeAtOffset()
[all …]
|
| /dports/textproc/kdiff3/kdiff3-1.9.4/src/ |
| H A D | fileaccess.cpp | 764 qint64 nextLength = std::min(maxLength - i, maxChunkSize); in interruptableReadFile() local
765 qint64 reallyRead = read((char*)pDestBuffer + i, nextLength); in interruptableReadFile()
766 if(reallyRead != nextLength) in interruptableReadFile()
817 qint64 nextLength = std::min(length - i, maxChunkSize); in writeFile() local
818 qint64 reallyWritten = realFile->write((char*)pSrcBuffer + i, nextLength); in writeFile()
819 if(reallyWritten != nextLength) in writeFile()
|
| /dports/deskutils/latte-dock/latte-dock-0.10.6/containment/package/contents/ui/abilities/ |
| H A D | AutoSize.qml | 192 var nextLength = factor * layoutLength;
194 } while ( (nextLength>toShrinkLimit) && (nextIconSize !== 16));
197 var intNextLength = Math.round(nextLength);
|
| /dports/biology/velvet/velvet_1.2.10/contrib/MetaVelvet-1.2.01/Velvet-1.1.06/ |
| H A D | readCoherentGraph.c | 299 Coordinate nextLength = getNodeLength(nextNode); in updateMembers() local
328 incrementFinishOffset(marker, nextLength); in updateMembers()
331 incrementFinishOffset(marker, nextLength); in updateMembers()
|
| /dports/biology/velvet/velvet_1.2.10/src/ |
| H A D | readCoherentGraph.c | 299 Coordinate nextLength = getNodeLength(nextNode); in updateMembers() local
328 incrementFinishOffset(marker, nextLength); in updateMembers()
331 incrementFinishOffset(marker, nextLength); in updateMembers()
|
| /dports/audio/qmidiarp/qmidiarp-qmidiarp-0.6.5/src/ |
| H A D | midiarp.h | 56 int nextLength; variable
|
| H A D | midiarp.cpp | 615 getNote(&nextTick, nextNote, nextVelocity, &nextLength);
621 returnLength = nextLength;
|
| /dports/cad/sumo/sumo-1.2.0/src/microsim/pedestrians/ |
| H A D | MSPModel_Striping.cpp | 664 …const double nextLength = nextLane->getEdge().isWalkingArea() ? myMinNextLengths[nextLane] : nextL… in getNextLaneObstacles() local
668 …Obstacles obs(stripes, Obstacle(nextDir == FORWARD ? nextLength : 0, 0, OBSTACLE_NEXTEND, "nextEnd… in getNextLaneObstacles()
685 … obs[ii] = Obstacle(nextDir == FORWARD ? 0 : nextLength, 0, OBSTACLE_END, "stripeEnd", 0); in getNextLaneObstacles()
691 transformToCurrentLanePositions(obs, currentDir, nextDir, currentLength, nextLength); in getNextLaneObstacles()
749 transformToCurrentLanePositions(obs, currentDir, nextDir, currentLength, nextLength); in getNextLaneObstacles()
757 …nePositions(Obstacles& obs, int currentDir, int nextDir, double currentLength, double nextLength) { in transformToCurrentLanePositions() argument
766 o.xFwd = currentLength + nextLength - o.xBack; in transformToCurrentLanePositions()
767 o.xBack = currentLength + nextLength - tmp; in transformToCurrentLanePositions()
775 o.xFwd -= nextLength; in transformToCurrentLanePositions()
776 o.xBack -= nextLength; in transformToCurrentLanePositions()
|
| /dports/lang/solidity/solidity_0.8.11/test/yulPhaser/ |
| H A D | Population.cpp | 139 auto nextLength = [counter = 0ul, maxLength]() mutable { return counter++ % maxLength; }; in BOOST_FIXTURE_TEST_CASE() local
140 auto population = Population::makeRandom(m_fitnessMetric, chromosomeCount, nextLength); in BOOST_FIXTURE_TEST_CASE()
|
| /dports/biology/velvet/velvet_1.2.10/contrib/MetaVelvet-v0.3.1/src/ |
| H A D | readCoherentGraph.c | 350 Coordinate nextLength = getNodeLength(nextNode); in updateMembers() local
379 incrementFinishOffset(marker, nextLength); in updateMembers()
382 incrementFinishOffset(marker, nextLength); in updateMembers()
|
| /dports/irc/konversation/konversation-21.12.3/src/ |
| H A D | application.cpp | 1175 int length,nextLength,patLen,repLen; in doAutoreplace() local
1181 nextLength=length; in doAutoreplace()
1194 nextLength = index+repLen; in doAutoreplace()
1201 cursorPos = nextLength; in doAutoreplace()
1211 index = line.indexOf(pattern, nextLength); in doAutoreplace()
|
| /dports/lang/elm/elm-compiler-bootstrap-0.19.1/0.19.1/packages/elm/browser/1.0.1/src/Debugger/ |
| H A D | Expando.elm | 584 nextLength = function
587 if nextLength > 18 then
593 viewExtraTinyRecord nextLength "," rest
|