Lines Matching refs:pIn
11741 int nIn, const void *pIn, /* Input changeset */
12394 int nIn, const void *pIn,
12500 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
12501 void *pIn, /* First arg for xInput */
12515 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
12516 void *pIn, /* First arg for xInput */
12531 int (*xInputA)(void *pIn, void *pData, int *pnData),
12533 int (*xInputB)(void *pIn, void *pData, int *pnData),
12539 int (*xInput)(void *pIn, void *pData, int *pnData),
12540 void *pIn,
12546 int (*xInput)(void *pIn, void *pData, int *pnData),
12547 void *pIn
12551 int (*xInput)(void *pIn, void *pData, int *pnData),
12552 void *pIn,
12566 int (*xInput)(void *pIn, void *pData, int *pnData),
12567 void *pIn
12575 int (*xInput)(void *pIn, void *pData, int *pnData),
12576 void *pIn,
30362 void *pIn; /* Argument to the thread */
30369 void *pIn /* Argument passed into xTask() */
30384 p->pIn = pIn;
30392 rc = pthread_create(&p->tid, 0, xTask, pIn);
30396 p->pOut = xTask(pIn);
30433 void *pIn; /* Argument to xTask */
30454 p->pResult = p->xTask(p->pIn);
30464 void *pIn /* Argument passed into xTask() */
30482 p->pIn = pIn;
30490 p->pResult = xTask(pIn);
30536 void *pIn; /* Argument to xTask */
30544 void *pIn /* Argument passed into xTask() */
30555 p->pIn = pIn;
30558 p->pResult = xTask(pIn);
30570 *ppOut = p->xTask(p->pIn);
32720 VList *pIn, /* The input VList. Might be NULL */
32730 assert( pIn==0 || pIn[0]>=3 ); /* Verify ok to add new elements */
32731 if( pIn==0 || pIn[1]+nInt > pIn[0] ){
32733 sqlite3_int64 nAlloc = (pIn ? 2*(sqlite3_int64)pIn[0] : 10) + nInt;
32734 VList *pOut = sqlite3DbRealloc(db, pIn, nAlloc*sizeof(int));
32735 if( pOut==0 ) return pIn;
32736 if( pIn==0 ) pOut[1] = 2;
32737 pIn = pOut;
32738 pIn[0] = nAlloc;
32740 i = pIn[1];
32741 pIn[i] = iVal;
32742 pIn[i+1] = nInt;
32743 z = (char*)&pIn[i+2];
32744 pIn[1] = i+nInt;
32745 assert( pIn[1]<=pIn[0] );
32748 return pIn;
32756 SQLITE_PRIVATE const char *sqlite3VListNumToName(VList *pIn, int iVal){
32758 if( pIn==0 ) return 0;
32759 mx = pIn[1];
32762 if( pIn[i]==iVal ) return (char*)&pIn[i+2];
32763 i += pIn[i+1];
32772 SQLITE_PRIVATE int sqlite3VListNameToNum(VList *pIn, const char *zName, int nName){
32774 if( pIn==0 ) return 0;
32775 mx = pIn[1];
32778 const char *z = (const char*)&pIn[i+2];
32779 if( strncmp(z,zName,nName)==0 && z[nName]==0 ) return pIn[i];
32780 i += pIn[i+1];
49508 static PgHdr *pcacheSortDirtyList(PgHdr *pIn){
49512 while( pIn ){
49513 p = pIn;
49514 pIn = p->pDirty;
51220 static struct RowSetEntry *rowSetEntrySort(struct RowSetEntry *pIn){
51225 while( pIn ){
51226 pNext = pIn->pRight;
51227 pIn->pRight = 0;
51229 pIn = rowSetEntryMerge(aBucket[i], pIn);
51232 aBucket[i] = pIn;
51233 pIn = pNext;
51235 pIn = aBucket[0];
51238 pIn = pIn ? rowSetEntryMerge(pIn, aBucket[i]) : aBucket[i];
51240 return pIn;
51250 struct RowSetEntry *pIn, /* Root of the input tree */
51254 assert( pIn!=0 );
51255 if( pIn->pLeft ){
51257 rowSetTreeToList(pIn->pLeft, ppFirst, &p);
51258 p->pRight = pIn;
51260 *ppFirst = pIn;
51262 if( pIn->pRight ){
51263 rowSetTreeToList(pIn->pRight, &pIn->pRight, ppLast);
51265 *ppLast = pIn;
91640 Mem *pIn;
91643 pIn = &pFrame->aMem[pOp->p1 + pFrame->aOp[pFrame->pc].p1];
91644 sqlite3VdbeMemShallowCopy(pOut, pIn, MEM_Ephem);
94789 void *pIn /* Argument passed into xTask() */
94792 return sqlite3ThreadCreate(&pTask->pThread, xTask, pIn);
101907 static int sqlite3InRhsIsConstant(Expr *pIn){
101910 assert( !ExprHasProperty(pIn, EP_xIsSelect) );
101911 pLHS = pIn->pLeft;
101912 pIn->pLeft = 0;
101913 res = sqlite3ExprIsConstant(pIn);
101914 pIn->pLeft = pLHS;
102610 SQLITE_PRIVATE int sqlite3ExprCheckIN(Parse *pParse, Expr *pIn){
102611 int nVector = sqlite3ExprVectorSize(pIn->pLeft);
102612 if( (pIn->flags & EP_xIsSelect) ){
102613 if( nVector!=pIn->x.pSelect->pEList->nExpr ){
102614 sqlite3SubselectError(pParse, pIn->x.pSelect->pEList->nExpr, nVector);
102618 sqlite3VectorErrorMsg(pParse, pIn->pLeft);
131767 SelectDest *pIn, /* Coroutine supplying data */
131786 addr2 = sqlite3VdbeAddOp4(v, OP_Compare, pIn->iSdst, regPrev+1, pIn->nSdst,
131790 sqlite3VdbeAddOp3(v, OP_Copy, pIn->iSdst, regPrev+1, pIn->nSdst-1);
131807 sqlite3VdbeAddOp3(v, OP_MakeRecord, pIn->iSdst, pIn->nSdst, r1);
131821 testcase( pIn->nSdst>1 );
131823 sqlite3VdbeAddOp4(v, OP_MakeRecord, pIn->iSdst, pIn->nSdst,
131824 r1, pDest->zAffSdst, pIn->nSdst);
131826 pIn->iSdst, pIn->nSdst);
131838 testcase( pIn->nSdst>1 );
131839 sqlite3ExprCodeMove(pParse, pIn->iSdst, pDest->iSDParm, pIn->nSdst);
131851 pDest->iSdst = sqlite3GetTempRange(pParse, pIn->nSdst);
131852 pDest->nSdst = pIn->nSdst;
131854 sqlite3ExprCodeMove(pParse, pIn->iSdst, pDest->iSdst, pIn->nSdst);
131869 sqlite3VdbeAddOp2(v, OP_ResultRow, pIn->iSdst, pIn->nSdst);
141250 struct InLoop *pIn;
141313 pIn = pLevel->u.in.aInLoop;
141314 if( pIn ){
141316 pIn += i;
141321 pIn->addrInTop = sqlite3VdbeAddOp2(v, OP_Rowid, iTab, iOut);
141324 pIn->addrInTop = sqlite3VdbeAddOp3(v,OP_Column,iTab, iCol, iOut);
141328 pIn->iCur = iTab;
141329 pIn->eEndLoopOp = bRev ? OP_Prev : OP_Next;
141331 pIn->iBase = iReg - i;
141332 pIn->nPrefix = i;
141335 pIn->nPrefix = 0;
141338 pIn->eEndLoopOp = OP_Noop;
141340 pIn++;
150154 struct InLoop *pIn;
150157 for(j=pLevel->u.in.nIn, pIn=&pLevel->u.in.aInLoop[j-1]; j>0; j--, pIn--){
150158 sqlite3VdbeJumpHere(v, pIn->addrInTop+1);
150159 if( pIn->eEndLoopOp!=OP_Noop ){
150160 if( pIn->nPrefix ){
150171 sqlite3VdbeAddOp2(v, OP_IfNotOpen, pIn->iCur,
150180 pIn->iBase, pIn->nPrefix);
150184 sqlite3VdbeAddOp2(v, pIn->eEndLoopOp, pIn->iCur, pIn->addrInTop);
150186 VdbeCoverageIf(v, pIn->eEndLoopOp==OP_Prev);
150187 VdbeCoverageIf(v, pIn->eEndLoopOp==OP_Next);
150189 sqlite3VdbeJumpHere(v, pIn->addrInTop-1);
201623 void *pIn; /* First argument to xInput */
204123 int (*xInput)(void *pIn, void *pData, int *pnData),
204124 void *pIn,
204145 pRet->in.pIn = pIn;
204179 int (*xInput)(void *pIn, void *pData, int *pnData),
204180 void *pIn
204182 return sessionChangesetStart(pp, xInput, pIn, 0, 0, 0);
204186 int (*xInput)(void *pIn, void *pData, int *pnData),
204187 void *pIn,
204191 return sessionChangesetStart(pp, xInput, pIn, 0, 0, bInvert);
204198 static void sessionDiscardData(SessionInput *pIn){
204199 if( pIn->xInput && pIn->iNext>=sessions_strm_chunk_size ){
204200 int nMove = pIn->buf.nBuf - pIn->iNext;
204203 memmove(pIn->buf.aBuf, &pIn->buf.aBuf[pIn->iNext], nMove);
204205 pIn->buf.nBuf -= pIn->iNext;
204206 pIn->iNext = 0;
204207 pIn->nData = pIn->buf.nBuf;
204218 static int sessionInputBuffer(SessionInput *pIn, int nByte){
204220 if( pIn->xInput ){
204221 while( !pIn->bEof && (pIn->iNext+nByte)>=pIn->nData && rc==SQLITE_OK ){
204224 if( pIn->bNoDiscard==0 ) sessionDiscardData(pIn);
204225 if( SQLITE_OK==sessionBufferGrow(&pIn->buf, nNew, &rc) ){
204226 rc = pIn->xInput(pIn->pIn, &pIn->buf.aBuf[pIn->buf.nBuf], &nNew);
204228 pIn->bEof = 1;
204230 pIn->buf.nBuf += nNew;
204234 pIn->aData = pIn->buf.aBuf;
204235 pIn->nData = pIn->buf.nBuf;
204314 SessionInput *pIn, /* Input data */
204325 rc = sessionInputBuffer(pIn, 9);
204327 if( pIn->iNext>=pIn->nData ){
204330 eType = pIn->aData[pIn->iNext++];
204340 u8 *aVal = &pIn->aData[pIn->iNext];
204343 pIn->iNext += sessionVarintGet(aVal, &nByte);
204344 rc = sessionInputBuffer(pIn, nByte);
204346 if( nByte<0 || nByte>pIn->nData-pIn->iNext ){
204350 rc = sessionValueSetStr(apOut[i],&pIn->aData[pIn->iNext],nByte,enc);
204351 pIn->iNext += nByte;
204364 pIn->iNext += 8;
204385 static int sessionChangesetBufferTblhdr(SessionInput *pIn, int *pnByte){
204390 rc = sessionInputBuffer(pIn, 9);
204392 nRead += sessionVarintGet(&pIn->aData[pIn->iNext + nRead], &nCol);
204403 rc = sessionInputBuffer(pIn, nRead+nCol+100);
204409 while( (pIn->iNext + nRead)<pIn->nData && pIn->aData[pIn->iNext + nRead] ){
204412 if( (pIn->iNext + nRead)<pIn->nData ) break;
204413 rc = sessionInputBuffer(pIn, nRead + 100);
204429 SessionInput *pIn, /* Input data */
204438 rc = sessionInputBuffer(pIn, nByte + 10);
204440 eType = pIn->aData[pIn->iNext + nByte++];
204443 nByte += sessionVarintGet(&pIn->aData[pIn->iNext+nByte], &n);
204445 rc = sessionInputBuffer(pIn, nByte);
204994 int (*xInput)(void *pIn, void *pData, int *pnData),
204995 void *pIn,
205005 sInput.pIn = pIn;
206094 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
206095 void *pIn, /* First arg for xInput */
206111 int rc = sessionChangesetStart(&pIter, xInput, pIn, 0, 0, bInverse);
206121 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
206122 void *pIn, /* First arg for xInput */
206135 db, xInput, pIn, xFilter, xConflict, pCtx, 0, 0, 0
206181 u8 *pIn = aRec;
206184 int nIn = sessionSerialLen(pIn);
206185 if( *pIn==0 ){
206190 memcpy(pOut, pIn, nIn);
206193 pIn += nIn;
206555 int (*xInput)(void *pIn, void *pData, int *pnData),
206556 void *pIn
206561 rc = sqlite3changeset_start_strm(&pIter, xInput, pIn);
206623 int (*xInputA)(void *pIn, void *pData, int *pnData),
206625 int (*xInputB)(void *pIn, void *pData, int *pnData),
206946 int nIn, const void *pIn,
206950 int rc = sqlite3changeset_start(&pIter, nIn, (void*)pIn);
206965 int (*xInput)(void *pIn, void *pData, int *pnData),
206966 void *pIn,
206971 int rc = sqlite3changeset_start_strm(&pIter, xInput, pIn);
207927 static char *sqlite3Fts5Strndup(int *pRc, const char *pIn, int nIn);
210909 static char *sqlite3Fts5Strndup(int *pRc, const char *pIn, int nIn){
210913 nIn = (int)strlen(pIn);
210917 memcpy(zRet, pIn, nIn);
211077 static const char *fts5ConfigSkipWhitespace(const char *pIn){
211078 const char *p = pIn;
211090 static const char *fts5ConfigSkipBareword(const char *pIn){
211091 const char *p = pIn;
211093 if( p==pIn ) p = 0;
211103 static const char *fts5ConfigSkipLiteral(const char *pIn){
211104 const char *p = pIn;
211124 if( *p=='\'' && 0==((p-pIn)%2) ){
211158 if( p==pIn ) p = 0;
211768 static const char *fts5ConfigSkipArgs(const char *pIn){
211769 const char *p = pIn;
220790 static int fts5IndexCharlen(const char *pIn, int nIn){
220794 if( (unsigned char)pIn[i++]>=0xc0 ){
220795 while( i<nIn && (pIn[i] & 0xc0)==0x80 ) i++;