Lines Matching refs:kRunning
40 kRunning,
331 get [kRunning] () {
466 } else if (client[kRunning] > 0) {
476 assert(client[kRunning] === 0)
884 assert(client[kRunning] === 1)
890 assert(client[kRunning] === 1)
1016 assert.strictEqual(client[kRunning], 0)
1023 } else if (socket[kReset] && client[kRunning] === 0) {
1046 if (!socket[kWriting] || socket.writableNeedDrain || client[kRunning] > 1) {
1055 assert(client[kRunning] === 0 && client[kKeepAliveTimeoutValue])
1089 client[kRunning] === 0 &&
1147 } else if (client[kRunning] > 0 && err.code !== 'UND_ERR_INFO') {
1157 assert(client[kRunning] === 0)
1314 assert(client[kRunning] === 0)
1381 } else if (client[kRunning] > 0 && socket[kParser].statusCode < 200) {
1408 if (client[kRunning] >= (client[kPipelining] || 1)) {
1415 if (client[kRunning] > 0) {
1440 if (client[kRunning] > 0 && !request.idempotent) {
1447 if (client[kRunning] > 0 && (request.upgrade || request.method === 'CONNECT')) {
1454 if (client[kRunning] > 0 && util.bodyLength(request.body) !== 0 &&
1910 assert(contentLength !== 0 || client[kRunning] === 0, 'stream body cannot be pipelined')
1980 assert(socket.destroyed || (socket[kWriting] && client[kRunning] <= 1))
2060 assert(contentLength !== 0 || client[kRunning] === 0, 'iterator body cannot be pipelined')
2268 assert(client[kRunning] <= 1, 'pipeline should only contain this request')