MCPcopy Index your code
hub / github.com/dataease/SQLBot / clearBuffer

Function clearBuffer

frontend/public/swagger-ui-bundle.js:6381–6414  ·  view source on GitHub ↗
(s, o)

Source from the content-addressed store, hash-verified

6379 finishMaybe(s, o))
6380 }
6381 function clearBuffer(s, o) {
6382 o.bufferProcessing = !0
6383 var i = o.bufferedRequest
6384 if (s._writev && i && i.next) {
6385 var a = o.bufferedRequestCount,
6386 u = new Array(a),
6387 _ = o.corkedRequestsFree
6388 _.entry = i
6389 for (var w = 0, x = !0; i; ) ((u[w] = i), i.isBuf || (x = !1), (i = i.next), (w += 1))
6390 ;((u.allBuffers = x),
6391 doWrite(s, o, !0, o.length, u, '', _.finish),
6392 o.pendingcb++,
6393 (o.lastBufferedRequest = null),
6394 _.next
6395 ? ((o.corkedRequestsFree = _.next), (_.next = null))
6396 : (o.corkedRequestsFree = new CorkedRequest(o)),
6397 (o.bufferedRequestCount = 0))
6398 } else {
6399 for (; i; ) {
6400 var C = i.chunk,
6401 j = i.encoding,
6402 L = i.callback
6403 if (
6404 (doWrite(s, o, !1, o.objectMode ? 1 : C.length, C, j, L),
6405 (i = i.next),
6406 o.bufferedRequestCount--,
6407 o.writing)
6408 )
6409 break
6410 }
6411 null === i && (o.lastBufferedRequest = null)
6412 }
6413 ;((o.bufferedRequest = i), (o.bufferProcessing = !1))
6414 }
6415 function needFinish(s) {
6416 return (
6417 s.ending && 0 === s.length && null === s.bufferedRequest && !s.finished && !s.writing

Callers 2

WritableStateFunction · 0.85

Calls 1

doWriteFunction · 0.85

Tested by

no test coverage detected