Lines Matching defs:pIn
9589 int nIn, const void *pIn, /* Input changeset */
10072 ** int (*xInput)(void *pIn, void *pData, int *pnData),
10073 ** void *pIn,
10077 ** argument passed is a copy of the supplied pIn context pointer. The second
10126 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
10127 void *pIn, /* First arg for xInput */
10140 int (*xInputA)(void *pIn, void *pData, int *pnData),
10142 int (*xInputB)(void *pIn, void *pData, int *pnData),
10148 int (*xInput)(void *pIn, void *pData, int *pnData),
10149 void *pIn,
10155 int (*xInput)(void *pIn, void *pData, int *pnData),
10156 void *pIn
10169 int (*xInput)(void *pIn, void *pData, int *pnData),
10170 void *pIn
26851 void *pIn; /* Argument to the thread */
26858 void *pIn /* Argument passed into xTask() */
26873 p->pIn = pIn;
26881 rc = pthread_create(&p->tid, 0, xTask, pIn);
26885 p->pOut = xTask(pIn);
26922 void *pIn; /* Argument to xTask */
26943 p->pResult = p->xTask(p->pIn);
26953 void *pIn /* Argument passed into xTask() */
26971 p->pIn = pIn;
26979 p->pResult = xTask(pIn);
27025 void *pIn; /* Argument to xTask */
27033 void *pIn /* Argument passed into xTask() */
27044 p->pIn = pIn;
27047 p->pResult = xTask(pIn);
27059 *ppOut = p->xTask(p->pIn);
29117 VList *pIn, /* The input VList. Might be NULL */
29124 int i; /* Index in pIn[] where zName is stored */
29127 assert( pIn==0 || pIn[0]>=3 ); /* Verify ok to add new elements */
29128 if( pIn==0 || pIn[1]+nInt > pIn[0] ){
29130 int nAlloc = (pIn ? pIn[0]*2 : 10) + nInt;
29131 VList *pOut = sqlite3DbRealloc(db, pIn, nAlloc*sizeof(int));
29132 if( pOut==0 ) return pIn;
29133 if( pIn==0 ) pOut[1] = 2;
29134 pIn = pOut;
29135 pIn[0] = nAlloc;
29137 i = pIn[1];
29138 pIn[i] = iVal;
29139 pIn[i+1] = nInt;
29140 z = (char*)&pIn[i+2];
29141 pIn[1] = i+nInt;
29142 assert( pIn[1]<=pIn[0] );
29145 return pIn;
29153 SQLITE_PRIVATE const char *sqlite3VListNumToName(VList *pIn, int iVal){
29155 if( pIn==0 ) return 0;
29156 mx = pIn[1];
29159 if( pIn[i]==iVal ) return (char*)&pIn[i+2];
29160 i += pIn[i+1];
29169 SQLITE_PRIVATE int sqlite3VListNameToNum(VList *pIn, const char *zName, int nName){
29171 if( pIn==0 ) return 0;
29172 mx = pIn[1];
29175 const char *z = (const char*)&pIn[i+2];
29176 if( strncmp(z,zName,nName)==0 && z[nName]==0 ) return pIn[i];
29177 i += pIn[i+1];
44813 static PgHdr *pcacheSortDirtyList(PgHdr *pIn){
44817 while( pIn ){
44818 p = pIn;
44819 pIn = p->pDirty;
46492 static struct RowSetEntry *rowSetEntrySort(struct RowSetEntry *pIn){
46497 while( pIn ){
46498 pNext = pIn->pRight;
46499 pIn->pRight = 0;
46501 pIn = rowSetEntryMerge(aBucket[i], pIn);
46504 aBucket[i] = pIn;
46505 pIn = pNext;
46507 pIn = aBucket[0];
46510 pIn = pIn ? rowSetEntryMerge(pIn, aBucket[i]) : aBucket[i];
46512 return pIn;
46517 ** The input, pIn, is a binary tree (or subtree) of RowSetEntry objects.
46522 struct RowSetEntry *pIn, /* Root of the input tree */
46526 assert( pIn!=0 );
46527 if( pIn->pLeft ){
46529 rowSetTreeToList(pIn->pLeft, ppFirst, &p);
46530 p->pRight = pIn;
46532 *ppFirst = pIn;
46534 if( pIn->pRight ){
46535 rowSetTreeToList(pIn->pRight, &pIn->pRight, ppLast);
46537 *ppLast = pIn;
84158 Mem *pIn;
84161 pIn = &pFrame->aMem[pOp->p1 + pFrame->aOp[pFrame->pc].p1];
84162 sqlite3VdbeMemShallowCopy(pOut, pIn, MEM_Ephem);
86980 ** Launch a background thread to run xTask(pIn).
86985 void *pIn /* Argument passed into xTask() */
86988 return sqlite3ThreadCreate(&pTask->pThread, xTask, pIn);
92785 static int sqlite3InRhsIsConstant(Expr *pIn){
92788 assert( !ExprHasProperty(pIn, EP_xIsSelect) );
92789 pLHS = pIn->pLeft;
92790 pIn->pLeft = 0;
92791 res = sqlite3ExprIsConstant(pIn);
92792 pIn->pLeft = pLHS;
93429 ** Expr pIn is an IN(...) expression. This function checks that the
93434 SQLITE_PRIVATE int sqlite3ExprCheckIN(Parse *pParse, Expr *pIn){
93435 int nVector = sqlite3ExprVectorSize(pIn->pLeft);
93436 if( (pIn->flags & EP_xIsSelect) ){
93437 if( nVector!=pIn->x.pSelect->pEList->nExpr ){
93438 sqlite3SubselectError(pParse, pIn->x.pSelect->pEList->nExpr, nVector);
93442 sqlite3VectorErrorMsg(pParse, pIn->pLeft);
118850 ** The data to be output is contained in pIn->iSdst. There are
118851 ** pIn->nSdst columns to be output. pDest is where the output should
118869 SelectDest *pIn, /* Coroutine supplying data */
118888 addr2 = sqlite3VdbeAddOp4(v, OP_Compare, pIn->iSdst, regPrev+1, pIn->nSdst,
118892 sqlite3VdbeAddOp3(v, OP_Copy, pIn->iSdst, regPrev+1, pIn->nSdst-1);
118909 sqlite3VdbeAddOp3(v, OP_MakeRecord, pIn->iSdst, pIn->nSdst, r1);
118923 testcase( pIn->nSdst>1 );
118925 sqlite3VdbeAddOp4(v, OP_MakeRecord, pIn->iSdst, pIn->nSdst,
118926 r1, pDest->zAffSdst, pIn->nSdst);
118927 sqlite3ExprCacheAffinityChange(pParse, pIn->iSdst, pIn->nSdst);
118929 pIn->iSdst, pIn->nSdst);
118939 assert( pIn->nSdst==1 || pParse->nErr>0 ); testcase( pIn->nSdst!=1 );
118940 sqlite3ExprCodeMove(pParse, pIn->iSdst, pDest->iSDParm, 1);
118951 pDest->iSdst = sqlite3GetTempRange(pParse, pIn->nSdst);
118952 pDest->nSdst = pIn->nSdst;
118954 sqlite3ExprCodeMove(pParse, pIn->iSdst, pDest->iSdst, pIn->nSdst);
118969 sqlite3VdbeAddOp2(v, OP_ResultRow, pIn->iSdst, pIn->nSdst);
118970 sqlite3ExprCacheAffinityChange(pParse, pIn->iSdst, pIn->nSdst);
126747 struct InLoop *pIn;
126855 pIn = pLevel->u.in.aInLoop;
126856 if( pIn ){
126858 pIn += i;
126864 pIn->addrInTop = sqlite3VdbeAddOp2(v, OP_Rowid, iTab, iOut);
126867 pIn->addrInTop = sqlite3VdbeAddOp3(v,OP_Column,iTab, iCol, iOut);
126871 pIn->iCur = iTab;
126872 pIn->eEndLoopOp = bRev ? OP_PrevIfOpen : OP_NextIfOpen;
126874 pIn->eEndLoopOp = OP_Noop;
126876 pIn++;
134694 struct InLoop *pIn;
134697 for(j=pLevel->u.in.nIn, pIn=&pLevel->u.in.aInLoop[j-1]; j>0; j--, pIn--){
134698 sqlite3VdbeJumpHere(v, pIn->addrInTop+1);
134699 if( pIn->eEndLoopOp!=OP_Noop ){
134700 sqlite3VdbeAddOp2(v, pIn->eEndLoopOp, pIn->iCur, pIn->addrInTop);
134702 VdbeCoverageIf(v, pIn->eEndLoopOp==OP_PrevIfOpen);
134703 VdbeCoverageIf(v, pIn->eEndLoopOp==OP_NextIfOpen);
134705 sqlite3VdbeJumpHere(v, pIn->addrInTop-1);
174241 void *pIn; /* First argument to xInput */
176608 int (*xInput)(void *pIn, void *pData, int *pnData),
176609 void *pIn,
176629 pRet->in.pIn = pIn;
176653 int (*xInput)(void *pIn, void *pData, int *pnData),
176654 void *pIn
176656 return sessionChangesetStart(pp, xInput, pIn, 0, 0);
176663 static void sessionDiscardData(SessionInput *pIn){
176664 if( pIn->bEof && pIn->xInput && pIn->iNext>=SESSIONS_STRM_CHUNK_SIZE ){
176665 int nMove = pIn->buf.nBuf - pIn->iNext;
176668 memmove(pIn->buf.aBuf, &pIn->buf.aBuf[pIn->iNext], nMove);
176670 pIn->buf.nBuf -= pIn->iNext;
176671 pIn->iNext = 0;
176672 pIn->nData = pIn->buf.nBuf;
176683 static int sessionInputBuffer(SessionInput *pIn, int nByte){
176685 if( pIn->xInput ){
176686 while( !pIn->bEof && (pIn->iNext+nByte)>=pIn->nData && rc==SQLITE_OK ){
176689 if( pIn->bNoDiscard==0 ) sessionDiscardData(pIn);
176690 if( SQLITE_OK==sessionBufferGrow(&pIn->buf, nNew, &rc) ){
176691 rc = pIn->xInput(pIn->pIn, &pIn->buf.aBuf[pIn->buf.nBuf], &nNew);
176693 pIn->bEof = 1;
176695 pIn->buf.nBuf += nNew;
176699 pIn->aData = pIn->buf.aBuf;
176700 pIn->nData = pIn->buf.nBuf;
176779 SessionInput *pIn, /* Input data */
176790 rc = sessionInputBuffer(pIn, 9);
176792 eType = pIn->aData[pIn->iNext++];
176802 u8 *aVal = &pIn->aData[pIn->iNext];
176805 pIn->iNext += sessionVarintGet(aVal, &nByte);
176806 rc = sessionInputBuffer(pIn, nByte);
176809 rc = sessionValueSetStr(apOut[i],&pIn->aData[pIn->iNext],nByte,enc);
176811 pIn->iNext += nByte;
176822 pIn->iNext += 8;
176843 static int sessionChangesetBufferTblhdr(SessionInput *pIn, int *pnByte){
176848 rc = sessionInputBuffer(pIn, 9);
176850 nRead += sessionVarintGet(&pIn->aData[pIn->iNext + nRead], &nCol);
176851 rc = sessionInputBuffer(pIn, nRead+nCol+100);
176856 while( (pIn->iNext + nRead)<pIn->nData && pIn->aData[pIn->iNext + nRead] ){
176859 if( (pIn->iNext + nRead)<pIn->nData ) break;
176860 rc = sessionInputBuffer(pIn, nRead + 100);
176876 SessionInput *pIn, /* Input data */
176885 rc = sessionInputBuffer(pIn, nByte + 10);
176887 eType = pIn->aData[pIn->iNext + nByte++];
176890 nByte += sessionVarintGet(&pIn->aData[pIn->iNext+nByte], &n);
176892 rc = sessionInputBuffer(pIn, nByte);
177421 int (*xInput)(void *pIn, void *pData, int *pnData),
177422 void *pIn,
177432 sInput.pIn = pIn;
178339 ** Apply the changeset passed via xInput/pIn to the main database
178345 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
178346 void *pIn, /* First arg for xInput */
178359 int rc = sqlite3changeset_start_strm(&pIter, xInput, pIn);
178724 int (*xInput)(void *pIn, void *pData, int *pnData),
178725 void *pIn
178730 rc = sqlite3changeset_start_strm(&pIter, xInput, pIn);
178792 int (*xInputA)(void *pIn, void *pData, int *pnData),
178794 int (*xInputB)(void *pIn, void *pData, int *pnData),
182075 static char *sqlite3Fts5Strndup(int *pRc, const char *pIn, int nIn);
184811 ** Return a nul-terminated copy of the string indicated by pIn. If nIn
184818 static char *sqlite3Fts5Strndup(int *pRc, const char *pIn, int nIn){
184822 nIn = (int)strlen(pIn);
184826 pIn, nIn);
184982 ** Argument pIn points to a character that is part of a nul-terminated
184983 ** string. Return a pointer to the first character following *pIn in
184986 static const char *fts5ConfigSkipWhitespace(const char *pIn){
184987 const char *p = pIn;
184995 ** Argument pIn points to a character that is part of a nul-terminated
184996 ** string. Return a pointer to the first character following *pIn in
184999 static const char *fts5ConfigSkipBareword(const char *pIn){
185000 const char *p = pIn;
185002 if( p==pIn ) p = 0;
185012 static const char *fts5ConfigSkipLiteral(const char *pIn){
185013 const char *p = pIn;
185033 if( *p=='\'' && 0==((p-pIn)%2) ){
185067 if( p==pIn ) p = 0;
185672 ** Argument pIn points to the first character in what is expected to be
185677 static const char *fts5ConfigSkipArgs(const char *pIn){
185678 const char *p = pIn;
194411 ** pIn is a UTF-8 encoded string, nIn bytes in size. Return the number of
194414 static int fts5IndexCharlen(const char *pIn, int nIn){
194418 if( (unsigned char)pIn[i++]>=0xc0 ){
194419 while( i<nIn && (pIn[i] & 0xc0)==0x80 ) i++;
