Lines Matching refs:kRunning
35 kRunning: Symbol("running"),
6941 var { kFree, kConnected, kPending, kQueued, kRunning, kSize } = require_symbols();
6963 return this[kPool][kRunning];
6979 var { kConnected, kSize, kRunning, kPending, kQueued, kBusy, kFree, kUrl, kClose, kDestroy, kDispatch } = require_symbols();
7050 get [kRunning]() {
7052 for (const { [kRunning]: running } of this[kClients]) {
8342 kRunning,
8578 get [kRunning]() {
8680 } else if (client[kRunning] > 0) {
8686 assert(client[kRunning] === 0);
8997 assert(client[kRunning] === 1);
9002 assert(client[kRunning] === 1);
9096 assert.strictEqual(client[kRunning], 0);
9102 } else if (socket[kReset] && client[kRunning] === 0) {
9115 if (!socket[kWriting] || socket.writableNeedDrain || client[kRunning] > 1) {
9124 assert(client[kRunning] === 0 && client[kKeepAliveTimeoutValue]);
9150 if (client[kRunning] === 0 && err.code !== "UND_ERR_INFO" && err.code !== "UND_ERR_SOCKET") {
9190 } else if (client[kRunning] > 0 && err.code !== "UND_ERR_INFO") {
9196 assert(client[kRunning] === 0);
9325 assert(client[kRunning] === 0);
9383 } else if (client[kRunning] > 0 && socket[kParser].statusCode < 200) {
9405 if (client[kRunning] >= (client[kPipelining] || 1)) {
9410 if (client[kRunning] > 0) {
9429 if (client[kRunning] > 0 && !request.idempotent) {
9432 if (client[kRunning] > 0 && (request.upgrade || request.method === "CONNECT")) {
9435 if (client[kRunning] > 0 && util.bodyLength(request.body) !== 0 && (util.isStream(request.body) || util.isAsyncIterable(request.body))) {
9753 assert(contentLength !== 0 || client[kRunning] === 0, "stream body cannot be pipelined");
9812 assert(socket.destroyed || socket[kWriting] && client[kRunning] <= 1);
9868 assert(contentLength !== 0 || client[kRunning] === 0, "iterator body cannot be pipelined");
10031 assert(client[kRunning] <= 1, "pipeline should only contain this request");
10140 var { kClients, kRunning, kClose, kDestroy, kDispatch, kInterceptors } = require_symbols();
10206 get [kRunning]() {
10211 ret += client[kRunning];