Lines Matching defs:pIn
12657 int nIn, const void *pIn, /* Input changeset */
13408 ** Argument pIn must point to a buffer containing a changeset nIn bytes
13420 int nIn, const void *pIn,
13472 ** int (*xInput)(void *pIn, void *pData, int *pnData),
13473 ** void *pIn,
13477 ** argument passed is a copy of the supplied pIn context pointer. The second
13526 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
13527 void *pIn, /* First arg for xInput */
13541 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
13542 void *pIn, /* First arg for xInput */
13558 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
13559 void *pIn, /* First arg for xInput */
13574 pIn, void *pData, int *pnData),
13576 int (*xInputB)(void *pIn, void *pData, int *pnData),
13582 int (*xInput)(void *pIn, void *pData, int *pnData),
13583 void *pIn,
13589 int (*xInput)(void *pIn, void *pData, int *pnData),
13590 void *pIn
13594 int (*xInput)(void *pIn, void *pData, int *pnData),
13595 void *pIn,
13609 int (*xInput)(void *pIn, void *pData, int *pnData),
13610 void *pIn
13618 int (*xInput)(void *pIn, void *pData, int *pnData),
13619 void *pIn,
35531 void *pIn; /* Argument to the thread */
35538 void *pIn /* Argument passed into xTask() */
35553 p->pIn = pIn;
35561 rc = pthread_create(&p->tid, 0, xTask, pIn);
35565 p->pOut = xTask(pIn);
35602 void *pIn; /* Argument to xTask */
35623 p->pResult = p->xTask(p->pIn);
35633 void *pIn /* Argument passed into xTask() */
35651 p->pIn = pIn;
35659 p->pResult = xTask(pIn);
35706 void *pIn; /* Argument to xTask */
35714 void *pIn /* Argument passed into xTask() */
35725 p->pIn = pIn;
35728 p->pResult = xTask(pIn);
35740 *ppOut = p->xTask(p->pIn);
36697 const char *pIn = p->u.zToken;
36699 int bHex = (pIn[0]=='0' && (pIn[1]=='x' || pIn[1]=='X'));
36704 if( *pIn!=SQLITE_DIGIT_SEPARATOR ){
36705 *pOut++ = *pIn;
36706 if( *pIn=='e' || *pIn=='E' || *pIn=='.' ) p->op = TK_FLOAT;
36708 if( (bHex==0 && (!sqlite3Isdigit(pIn[-1]) || !sqlite3Isdigit(pIn[1])))
36709 || (bHex==1 && (!sqlite3Isxdigit(pIn[-1]) || !sqlite3Isxdigit(pIn[1])))
36714 }while( *pIn++ );
38547 VList *pIn, /* The input VList. Might be NULL */
38554 int i; /* Index in pIn[] where zName is stored */
38557 assert( pIn==0 || pIn[0]>=3 ); /* Verify ok to add new elements */
38558 if( pIn==0 || pIn[1]+nInt > pIn[0] ){
38560 sqlite3_int64 nAlloc = (pIn ? 2*(sqlite3_int64)pIn[0] : 10) + nInt;
38561 VList *pOut = sqlite3DbRealloc(db, pIn, nAlloc*sizeof(int));
38562 if( pOut==0 ) return pIn;
38563 if( pIn==0 ) pOut[1] = 2;
38564 pIn = pOut;
38565 pIn[0] = nAlloc;
38567 i = pIn[1];
38568 pIn[i] = iVal;
38569 pIn[i+1] = nInt;
38570 z = (char*)&pIn[i+2];
38571 pIn[1] = i+nInt;
38572 assert( pIn[1]<=pIn[0] );
38575 return pIn;
38583 SQLITE_PRIVATE const char *sqlite3VListNumToName(VList *pIn, int iVal){
38585 if( pIn==0 ) return 0;
38586 mx = pIn[1];
38589 if( pIn[i]==iVal ) return (char*)&pIn[i+2];
38590 i += pIn[i+1];
38599 SQLITE_PRIVATE int sqlite3VListNameToNum(VList *pIn, const char *zName, int nName){
38601 if( pIn==0 ) return 0;
38602 mx = pIn[1];
38605 const char *z = (const char*)&pIn[i+2];
38606 if( strncmp(z,zName,nName)==0 && z[nName]==0 ) return pIn[i];
38607 i += pIn[i+1];
57478 static PgHdr *pcacheSortDirtyList(PgHdr *pIn){
57482 while( pIn ){
57483 p = pIn;
57484 pIn = p->pDirty;
59191 static struct RowSetEntry *rowSetEntrySort(struct RowSetEntry *pIn){
59196 while( pIn ){
59197 pNext = pIn->pRight;
59198 pIn->pRight = 0;
59200 pIn = rowSetEntryMerge(aBucket[i], pIn);
59203 aBucket[i] = pIn;
59204 pIn = pNext;
59206 pIn = aBucket[0];
59209 pIn = pIn ? rowSetEntryMerge(pIn, aBucket[i]) : aBucket[i];
59211 return pIn;
59216 ** The input, pIn, is a binary tree (or subtree) of RowSetEntry objects.
59221 struct RowSetEntry *pIn
59225 assert( pIn!=0 );
59226 if( pIn->pLeft ){
59228 rowSetTreeToList(pIn->pLeft, ppFirst, &p);
59229 p->pRight = pIn;
59231 *ppFirst = pIn;
59233 if( pIn->pRight ){
59234 rowSetTreeToList(pIn->pRight, &pIn->pRight, ppLast);
59236 *ppLast = pIn;
78045 ** Pin or unpin a cursor.
104060 Mem *pIn;
104063 pIn = &pFrame->aMem[pOp->p1 + pFrame->aOp[pFrame->pc].p1];
104064 sqlite3VdbeMemShallowCopy(pOut, pIn, MEM_Ephem);
107516 ** Launch a background thread to run xTask(pIn).
107521 void *pIn /* Argument passed into xTask() */
107524 return sqlite3ThreadCreate(&pTask->pThread, xTask, pIn);
115779 static int sqlite3InRhsIsConstant(Parse *pParse, Expr *pIn){
115782 assert( !ExprHasProperty(pIn, EP_xIsSelect) );
115783 pLHS = pIn->pLeft;
115784 pIn->pLeft = 0;
115785 res = sqlite3ExprIsConstant(pParse, pIn);
115786 pIn->pLeft = pLHS;
116628 ** Expr pIn is an IN(...) expression. This function checks that the
116633 SQLITE_PRIVATE int sqlite3ExprCheckIN(Parse *pParse, Expr *pIn){
116634 int nVector = sqlite3ExprVectorSize(pIn->pLeft);
116635 if( ExprUseXSelect(pIn) && !pParse->db->mallocFailed ){
116636 if( nVector!=pIn->x.pSelect->pEList->nExpr ){
116637 sqlite3SubselectError(pParse, pIn->x.pSelect->pEList->nExpr, nVector);
116641 sqlite3VectorErrorMsg(pParse, pIn->pLeft);
151840 ** The data to be output is contained in an array of pIn->nSdst registers
151841 ** starting at register pIn->iSdst. pDest is where the output should
151859 SelectDest *pIn, /* Coroutine supplying data */
151870 assert( pIn->eDest==SRT_Coroutine );
151880 addr2 = sqlite3VdbeAddOp4(v, OP_Compare, pIn->iSdst, regPrev+1, pIn->nSdst,
151884 sqlite3VdbeAddOp3(v, OP_Copy, pIn->iSdst, regPrev+1, pIn->nSdst-1);
151907 sqlite3VdbeAddOp3(v, OP_MakeRecord, pIn->iSdst, pIn->nSdst, r1);
151928 pIn->iSdst, pIn->nSdst);
151952 testcase( pIn->nSdst>1 );
151954 sqlite3VdbeAddOp4(v, OP_MakeRecord, pIn->iSdst, pIn->nSdst,
151955 r1, pDest->zAffSdst, pIn->nSdst);
151957 pIn->iSdst, pIn->nSdst);
151960 pIn->iSdst, pIn->nSdst);
151973 testcase( pIn->nSdst>1 );
151974 sqlite3ExprCodeMove(pParse, pIn->iSdst, pDest->iSDParm, pIn->nSdst);
151985 pDest->iSdst = sqlite3GetTempRange(pParse, pIn->nSdst);
151986 pDest->nSdst = pIn->nSdst;
151988 sqlite3ExprCodeMove(pParse, pIn->iSdst, pDest->iSdst, pIn->nSdst);
152013 sqlite3VdbeAddOp3(v, OP_MakeRecord, pIn->iSdst, pIn->nSdst, r3);
152019 pIn->iSdst + pSO->a[ii].u.x.iOrderByCol - 1,
152045 sqlite3VdbeAddOp2(v, OP_ResultRow, pIn->iSdst, pIn->nSdst);
164354 struct InLoop *pIn;
164418 pIn = pLevel->u.in.aInLoop;
164419 if( pIn ){
164421 pIn += i;
164426 pIn->addrInTop = sqlite3VdbeAddOp2(v, OP_Rowid, iTab, iOut);
164429 pIn->addrInTop = sqlite3VdbeAddOp3(v,OP_Column,iTab, iCol, iOut);
164433 pIn->iCur = iTab;
164434 pIn->eEndLoopOp = bRev ? OP_Prev : OP_Next;
164436 pIn->iBase = iTarget - i;
164437 pIn->nPrefix = i;
164439 pIn->nPrefix = 0;
164442 pIn->eEndLoopOp = OP_Noop;
164444 pIn++;
176199 struct InLoop *pIn;
176202 for(j=pLevel->u.in.nIn, pIn=&pLevel->u.in.aInLoop[j-1]; j>0; j--, pIn--){
176203 assert( sqlite3VdbeGetOp(v, pIn->addrInTop+1)->opcode==OP_IsNull
176205 sqlite3VdbeJumpHere(v, pIn->addrInTop+1);
176206 if( pIn->eEndLoopOp!=OP_Noop ){
176207 if( pIn->nPrefix ){
176212 /* For LEFT JOIN queries, cursor pIn->iCur may not have been
176220 sqlite3VdbeAddOp2(v, OP_IfNotOpen, pIn->iCur,
176227 pIn->iBase, pIn->nPrefix);
176233 sqlite3VdbeJumpHere(v, pIn->addrInTop+1);
176236 sqlite3VdbeAddOp2(v, pIn->eEndLoopOp, pIn->iCur, pIn->addrInTop);
176238 VdbeCoverageIf(v, pIn->eEndLoopOp==OP_Prev);
176239 VdbeCoverageIf(v, pIn->eEndLoopOp==OP_Next);
176241 sqlite3VdbeJumpHere(v, pIn->addrInTop-1);
233430 void *pIn; /* First argument to xInput */
236698 int (*xInput)(void *pIn, void *pData, int *pnData),
236699 void *pIn,
236721 pRet->in.pIn = pIn;
236756 int (*xInput)(void *pIn, void *pData, int *pnData),
236757 void *pIn
236759 return sessionChangesetStart(pp, xInput, pIn, 0, 0, 0, 0);
236763 int (*xInput)(void *pIn, void *pData, int *pnData),
236764 void *pIn,
236768 return sessionChangesetStart(pp, xInput, pIn, 0, 0, bInvert, 0);
236775 static void sessionDiscardData(SessionInput *pIn){
236776 if( pIn->xInput && pIn->iCurrent>=sessions_strm_chunk_size ){
236777 int nMove = pIn->buf.nBuf - pIn->iCurrent;
236780 memmove(pIn->buf.aBuf, &pIn->buf.aBuf[pIn->iCurrent], nMove);
236782 pIn->buf.nBuf -= pIn->iCurrent;
236783 pIn->iNext -= pIn->iCurrent;
236784 pIn->iCurrent = 0;
236785 pIn->nData = pIn->buf.nBuf;
236796 static int sessionInputBuffer(SessionInput *pIn, int nByte){
236798 if( pIn->xInput ){
236799 while( !pIn->bEof && (pIn->iNext+nByte)>=pIn->nData && rc==SQLITE_OK ){
236802 if( pIn->bNoDiscard==0 ) sessionDiscardData(pIn);
236803 if( SQLITE_OK==sessionBufferGrow(&pIn->buf, nNew, &rc) ){
236804 rc = pIn->xInput(pIn->pIn, &pIn->buf.aBuf[pIn->buf.nBuf], &nNew);
236806 pIn->bEof = 1;
236808 pIn->buf.nBuf += nNew;
236812 pIn->aData = pIn->buf.aBuf;
236813 pIn->nData = pIn->buf.nBuf;
236892 SessionInput *pIn, /* Input data */
236906 rc = sessionInputBuffer(pIn, 9);
236908 if( pIn->iNext>=pIn->nData ){
236911 eType = pIn->aData[pIn->iNext++];
236922 u8 *aVal = &pIn->aData[pIn->iNext];
236925 int nRem = pIn->nData - pIn->iNext;
236926 pIn->iNext += sessionVarintGetSafe(aVal, nRem, &nByte);
236927 rc = sessionInputBuffer(pIn, nByte);
236929 if( nByte<0 || nByte>pIn->nData-pIn->iNext ){
236933 rc = sessionValueSetStr(apOut[i],&pIn->aData[pIn->iNext],nByte,enc);
236934 pIn->iNext += nByte;
236939 if( (pIn->nData-pIn->iNext)<8 ){
236950 pIn->iNext += 8;
236972 static int sessionChangesetBufferTblhdr(SessionInput *pIn, int *pnByte){
236977 rc = sessionInputBuffer(pIn, 9);
236979 int nBuf = pIn->nData - pIn->iNext;
236980 nRead += sessionVarintGetSafe(&pIn->aData[pIn->iNext], nBuf, &nCol);
236991 rc = sessionInputBuffer(pIn, nRead+nCol+100);
236997 while( (pIn->iNext + nRead)<pIn->nData && pIn->aData[pIn->iNext + nRead] ){
237004 if( (pIn->iNext + nRead)<pIn->nData ) break;
237005 rc = sessionInputBuffer(pIn, nRead + 100);
237006 if( rc==SQLITE_OK && (pIn->iNext + nRead)>=pIn->nData ){
237024 SessionInput *pIn, /* Input data */
237033 rc = sessionInputBuffer(pIn, nByte + 10);
237035 eType = pIn->aData[pIn->iNext + nByte++];
237038 int nRem = pIn->nData - (pIn->iNext + nByte);
237039 nByte += sessionVarintGetSafe(&pIn->aData[pIn->iNext+nByte], nRem, &n);
237041 rc = sessionInputBuffer(pIn, nByte);
237046 if( (pIn->iNext+nByte)>pIn->nData ){
237643 int (*xInput)(void *pIn, void *pData, int *pnData),
237644 void *pIn,
237654 sInput.pIn = pIn;
238814 ** xInput/pIn:
238843 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
238844 void *pIn, /* First arg for xInput */
238865 &pIter, xInput, pIn, nChangeset, pChangeset, bInverse, 1
238959 ** Apply the changeset passed via xInput/pIn to the main database
238965 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
238966 void *pIn, /* First arg for xInput */
238981 0, 0, xInput, pIn,
238988 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
238989 void *pIn, /* First arg for xInput */
239004 0, 0, xInput, pIn,
239011 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
239012 void *pIn, /* First arg for xInput */
239025 0, 0, xInput, pIn,
239098 u8 *pIn = aRec;
239101 int nIn = sessionSerialLen(pIn);
239102 if( *pIn==0 ){
239107 memcpy(pOut, pIn, nIn);
239110 pIn += nIn;
239759 int (*xInput)(void *pIn, void *pData, int *pnData),
239760 void *pIn
239765 rc = sqlite3changeset_start_strm(&pIter, xInput, pIn);
239835 int (*xInputA)(void *pIn, void *pData, int *pnData),
239837 int (*xInputB)(void *pIn, void *pData, int *pnData),
240158 int nIn, const void *pIn,
240162 int rc = sqlite3changeset_start(&pIter, nIn, (void*)pIn);
240177 int (*xInput)(void *pIn, void *pData, int *pnData),
240178 void *pIn,
240183 int rc = sqlite3changeset_start_strm(&pIter, xInput, pIn);
241743 static char *sqlite3Fts5Strndup(int *pRc, const char *pIn, int nIn);
244940 ** Return a nul-terminated copy of the string indicated by pIn. If nIn
244947 static char *sqlite3Fts5Strndup(int *pRc, const char *pIn, int nIn){
244951 nIn = (int)strlen(pIn);
244955 memcpy(zRet, pIn, nIn);
245113 ** Argument pIn points to a character that is part of a nul-terminated
245114 ** string. Return a pointer to the first character following *pIn in
245117 static const char *fts5ConfigSkipWhitespace(const char *pIn){
245118 const char *p = pIn;
245126 ** Argument pIn points to a character that is part of a nul-terminated
245127 ** string. Return a pointer to the first character following *pIn in
245130 static const char *fts5ConfigSkipBareword(const char *pIn){
245131 const char *p = pIn;
245133 if( p==pIn ) p = 0;
245143 static const char *fts5ConfigSkipLiteral(const char *pIn){
245144 const char *p = pIn;
245164 if( *p=='\'' && 0==((p-pIn)%2) ){
245198 if( p==pIn ) p = 0;
245903 ** Argument pIn points to the first character in what is expected to be
245908 static const char *fts5ConfigSkipArgs(const char *pIn){
245909 const char *p = pIn;
257022 ** pIn is a UTF-8 encoded string, nIn bytes in size. Return the number of
257025 static int fts5IndexCharlen(const char *pIn, int nIn){
257029 if( (unsigned char)pIn[i++]>=0xc0 ){
257030 while( i<nIn && (pIn[i] & 0xc0)==0x80 ) i++;
257116 ** This function appends iterator pAppend to Fts5TokenDataIter pIn and
257121 Fts5TokenDataIter *pIn, /* Current Fts5TokenDataIter struct */
257124 Fts5TokenDataIter *pRet = pIn;
257127 if( pIn==0 || pIn->nIter==pIn->nIterAlloc ){
257128 i64 nAlloc = pIn ? pIn->nIterAlloc*2 : 16;
257131 pNew = (Fts5TokenDataIter*)sqlite3_realloc64(pIn, nByte);
257136 if( pIn==0 ) memset(pNew, 0, nByte);
Indexes created Thu Oct 01 00:25:45 UTC 2026