Lines Matching refs:bufPtr
348 ChannelBuffer *bufPtr, int mustDiscard));
350 ChannelBuffer *bufPtr,
1437 RecycleBuffer(chanPtr, bufPtr, mustDiscard)
1439 ChannelBuffer *bufPtr; /* The buffer to recycle. */
1448 ckfree((char *) bufPtr);
1458 chanPtr->inQueueHead = bufPtr;
1459 chanPtr->inQueueTail = bufPtr;
1463 chanPtr->saveInBufPtr = bufPtr;
1474 chanPtr->curOutPtr = bufPtr;
1483 ckfree((char *) bufPtr);
1487 bufPtr->nextRemoved = 0;
1488 bufPtr->nextAdded = 0;
1489 bufPtr->nextPtr = (ChannelBuffer *) NULL;
1513 ChannelBuffer *bufPtr;
1516 bufPtr = chanPtr->outQueueHead;
1517 chanPtr->outQueueHead = bufPtr->nextPtr;
1518 RecycleBuffer(chanPtr, bufPtr, 0);
1589 ChannelBuffer *bufPtr; /* Iterates over buffered output
1635 bufPtr = chanPtr->outQueueHead;
1651 if (bufPtr == (ChannelBuffer *) NULL) {
1659 toWrite = bufPtr->nextAdded - bufPtr->nextRemoved;
1661 bufPtr->buf + bufPtr->nextRemoved, toWrite, &errorCode);
1723 bufPtr->nextRemoved += written;
1729 if (bufPtr->nextRemoved == bufPtr->nextAdded) {
1730 chanPtr->outQueueHead = bufPtr->nextPtr;
1734 RecycleBuffer(chanPtr, bufPtr, 0);
2388 ChannelBuffer *bufPtr, *nxtPtr; /* Loop variables. */
2390 bufPtr = chanPtr->inQueueHead;
2393 for (; bufPtr != (ChannelBuffer *) NULL; bufPtr = nxtPtr) {
2394 nxtPtr = bufPtr->nextPtr;
2395 RecycleBuffer(chanPtr, bufPtr, discardSavedBuffers);
2435 ChannelBuffer *bufPtr; /* New buffer to add to input queue. */
2454 bufPtr = chanPtr->inQueueTail;
2455 toRead = bufPtr->bufSize - bufPtr->nextAdded;
2458 bufPtr = chanPtr->saveInBufPtr;
2461 bufPtr = (ChannelBuffer *) ckalloc(
2463 bufPtr->bufSize = chanPtr->bufSize;
2465 bufPtr->nextRemoved = 0;
2466 bufPtr->nextAdded = 0;
2467 toRead = bufPtr->bufSize;
2469 chanPtr->inQueueHead = bufPtr;
2471 chanPtr->inQueueTail->nextPtr = bufPtr;
2473 chanPtr->inQueueTail = bufPtr;
2474 bufPtr->nextPtr = (ChannelBuffer *) NULL;
2487 bufPtr->buf + bufPtr->nextAdded, toRead, &result);
2505 bufPtr->nextAdded += nread;
2551 ChannelBuffer *bufPtr; /* The buffer from which to copy bytes. */
2566 bufPtr = chanPtr->inQueueHead;
2567 bytesInBuffer = bufPtr->nextAdded - bufPtr->nextRemoved;
2584 (VOID *)(bufPtr->buf + bufPtr->nextRemoved),
2586 bufPtr->nextRemoved += space;
2602 (VOID *)(bufPtr->buf + bufPtr->nextRemoved),
2604 bufPtr->nextRemoved += space;
2635 (bufPtr->nextRemoved < bufPtr->nextAdded);
2637 curByte = bufPtr->buf[bufPtr->nextRemoved];
2638 bufPtr->nextRemoved++;
2653 bufPtr->nextRemoved--;
2674 (bufPtr->nextRemoved < bufPtr->nextAdded); ) {
2675 curByte = bufPtr->buf[bufPtr->nextRemoved];
2676 bufPtr->nextRemoved++;
2680 if (bufPtr->nextRemoved < bufPtr->nextAdded) {
2681 if (bufPtr->buf[bufPtr->nextRemoved] == '\n') {
2682 bufPtr->nextRemoved++;
2741 bufPtr->nextRemoved -= (copied - i);
2742 while ((bufPtr->nextRemoved > 0) &&
2743 (bufPtr->buf[bufPtr->nextRemoved] !=
2745 bufPtr->nextRemoved--;
2755 if (bufPtr->nextRemoved == bufPtr->nextAdded) {
2756 chanPtr->inQueueHead = bufPtr->nextPtr;
2760 RecycleBuffer(chanPtr, bufPtr, 0);
2794 ScanBufferForEOL(chanPtr, bufPtr, translation, eofChar, bytesToEOLPtr,
2797 ChannelBuffer *bufPtr; /* Buffer to scan for EOL. */
2808 for (EOLFound = 0, rPtr = bufPtr->buf + bufPtr->nextRemoved,
2809 sPtr = bufPtr->buf + bufPtr->nextAdded,
2844 bufPtr->nextRemoved++;
2942 ChannelBuffer *bufPtr; /* Iterates over queued buffers. */
2950 for (bufPtr = chanPtr->inQueueHead,
2952 (!EOLFound) && (bufPtr != (ChannelBuffer *) NULL);
2953 bufPtr = bufPtr->nextPtr) {
2954 EOLFound = ScanBufferForEOL(chanPtr, bufPtr, chanPtr->inputTranslation,
3093 Tcl_Read(chan, bufPtr, toRead)
3095 char *bufPtr; /* Where to store input read. */
3130 return DoRead(chanPtr, bufPtr, toRead);
3152 DoRead(chanPtr, bufPtr, toRead)
3154 char *bufPtr; /* Where to store input read. */
3175 copiedNow = CopyAndTranslateBuffer(chanPtr, bufPtr + copied,
3385 ChannelBuffer *bufPtr; /* Buffer to contain the data. */
3431 bufPtr = (ChannelBuffer *) ckalloc((unsigned)
3434 bufPtr->buf[i] = str[i];
3436 bufPtr->bufSize = len;
3437 bufPtr->nextAdded = len;
3438 bufPtr->nextRemoved = 0;
3441 bufPtr->nextPtr = (ChannelBuffer *) NULL;
3442 chanPtr->inQueueHead = bufPtr;
3443 chanPtr->inQueueTail = bufPtr;
3445 bufPtr->nextPtr = (ChannelBuffer *) NULL;
3446 chanPtr->inQueueTail->nextPtr = bufPtr;
3447 chanPtr->inQueueTail = bufPtr;
3449 bufPtr->nextPtr = chanPtr->inQueueHead;
3450 chanPtr->inQueueHead = bufPtr;
3488 ChannelBuffer *bufPtr;
3551 for (bufPtr = chanPtr->inQueueHead, inputBuffered = 0;
3552 bufPtr != (ChannelBuffer *) NULL;
3553 bufPtr = bufPtr->nextPtr) {
3554 inputBuffered += (bufPtr->nextAdded - bufPtr->nextRemoved);
3556 for (bufPtr = chanPtr->outQueueHead, outputBuffered = 0;
3557 bufPtr != (ChannelBuffer *) NULL;
3558 bufPtr = bufPtr->nextPtr) {
3559 outputBuffered += (bufPtr->nextAdded - bufPtr->nextRemoved);
3694 ChannelBuffer *bufPtr;
3754 for (bufPtr = chanPtr->inQueueHead, inputBuffered = 0;
3755 bufPtr != (ChannelBuffer *) NULL;
3756 bufPtr = bufPtr->nextPtr) {
3757 inputBuffered += (bufPtr->nextAdded - bufPtr->nextRemoved);
3759 for (bufPtr = chanPtr->outQueueHead, outputBuffered = 0;
3760 bufPtr != (ChannelBuffer *) NULL;
3761 bufPtr = bufPtr->nextPtr) {
3762 outputBuffered += (bufPtr->nextAdded - bufPtr->nextRemoved);
3874 ChannelBuffer *bufPtr;
3877 for (bytesBuffered = 0, bufPtr = chanPtr->inQueueHead;
3878 bufPtr != (ChannelBuffer *) NULL;
3879 bufPtr = bufPtr->nextPtr) {
3880 bytesBuffered += (bufPtr->nextAdded - bufPtr->nextRemoved);
5225 ChannelBuffer *bufPtr; /* For iterating over queued IO. */
5320 for (IOQueued = 0, bufPtr = chanPtr->inQueueHead;
5321 bufPtr != (ChannelBuffer *) NULL;
5322 bufPtr = bufPtr->nextPtr) {
5323 IOQueued += bufPtr->nextAdded - bufPtr->nextRemoved;
5333 for (bufPtr = chanPtr->outQueueHead;
5334 bufPtr != (ChannelBuffer *) NULL;
5335 bufPtr = bufPtr->nextPtr) {
5336 IOQueued += (bufPtr->nextAdded - bufPtr->nextRemoved);
5358 for (IOQueued = 0, bufPtr = chanPtr->inQueueHead;
5359 bufPtr != (ChannelBuffer *) NULL;
5360 bufPtr = bufPtr->nextPtr) {
5361 IOQueued += bufPtr->nextAdded - bufPtr->nextRemoved;
5424 for (bufPtr = chanPtr->outQueueHead;
5425 bufPtr != (ChannelBuffer *) NULL;
5426 bufPtr = bufPtr->nextPtr) {
5427 IOQueued += (bufPtr->nextAdded - bufPtr->nextRemoved);