Lines Matching refs:pIn
12367 int nIn, const void *pIn, /* Input changeset */
13101 int nIn, const void *pIn,
13207 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
13208 void *pIn, /* First arg for xInput */
13222 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
13223 void *pIn, /* First arg for xInput */
13238 int (*xInputA)(void *pIn, void *pData, int *pnData),
13240 int (*xInputB)(void *pIn, void *pData, int *pnData),
13246 int (*xInput)(void *pIn, void *pData, int *pnData),
13247 void *pIn,
13253 int (*xInput)(void *pIn, void *pData, int *pnData),
13254 void *pIn
13258 int (*xInput)(void *pIn, void *pData, int *pnData),
13259 void *pIn,
13273 int (*xInput)(void *pIn, void *pData, int *pnData),
13274 void *pIn
13282 int (*xInput)(void *pIn, void *pData, int *pnData),
13283 void *pIn,
34681 void *pIn; /* Argument to the thread */ member
34688 void *pIn /* Argument passed into xTask() */ in sqlite3ThreadCreate() argument
34703 p->pIn = pIn; in sqlite3ThreadCreate()
34711 rc = pthread_create(&p->tid, 0, xTask, pIn); in sqlite3ThreadCreate()
34715 p->pOut = xTask(pIn); in sqlite3ThreadCreate()
34752 void *pIn; /* Argument to xTask */ member
34773 p->pResult = p->xTask(p->pIn); in sqlite3ThreadProc()
34783 void *pIn /* Argument passed into xTask() */ in sqlite3ThreadCreate() argument
34801 p->pIn = pIn; in sqlite3ThreadCreate()
34809 p->pResult = xTask(pIn); in sqlite3ThreadCreate()
34855 void *pIn; /* Argument to xTask */ member
34863 void *pIn /* Argument passed into xTask() */ in sqlite3ThreadCreate() argument
34874 p->pIn = pIn; in sqlite3ThreadCreate()
34877 p->pResult = xTask(pIn); in sqlite3ThreadCreate()
34889 *ppOut = p->xTask(p->pIn); in sqlite3ThreadJoin()
35846 const char *pIn = p->u.zToken; in sqlite3DequoteNumber() local
35848 int bHex = (pIn[0]=='0' && (pIn[1]=='x' || pIn[1]=='X')); in sqlite3DequoteNumber()
35853 if( *pIn!=SQLITE_DIGIT_SEPARATOR ){ in sqlite3DequoteNumber()
35854 *pOut++ = *pIn; in sqlite3DequoteNumber()
35855 if( *pIn=='e' || *pIn=='E' || *pIn=='.' ) p->op = TK_FLOAT; in sqlite3DequoteNumber()
35857 if( (bHex==0 && (!sqlite3Isdigit(pIn[-1]) || !sqlite3Isdigit(pIn[1]))) in sqlite3DequoteNumber()
35858 || (bHex==1 && (!sqlite3Isxdigit(pIn[-1]) || !sqlite3Isxdigit(pIn[1]))) in sqlite3DequoteNumber()
35863 }while( *pIn++ ); in sqlite3DequoteNumber()
37311 VList *pIn, /* The input VList. Might be NULL */ in sqlite3VListAdd() argument
37321 assert( pIn==0 || pIn[0]>=3 ); /* Verify ok to add new elements */ in sqlite3VListAdd()
37322 if( pIn==0 || pIn[1]+nInt > pIn[0] ){ in sqlite3VListAdd()
37324 sqlite3_int64 nAlloc = (pIn ? 2*(sqlite3_int64)pIn[0] : 10) + nInt; in sqlite3VListAdd()
37325 VList *pOut = sqlite3DbRealloc(db, pIn, nAlloc*sizeof(int)); in sqlite3VListAdd()
37326 if( pOut==0 ) return pIn; in sqlite3VListAdd()
37327 if( pIn==0 ) pOut[1] = 2; in sqlite3VListAdd()
37328 pIn = pOut; in sqlite3VListAdd()
37329 pIn[0] = nAlloc; in sqlite3VListAdd()
37331 i = pIn[1]; in sqlite3VListAdd()
37332 pIn[i] = iVal; in sqlite3VListAdd()
37333 pIn[i+1] = nInt; in sqlite3VListAdd()
37334 z = (char*)&pIn[i+2]; in sqlite3VListAdd()
37335 pIn[1] = i+nInt; in sqlite3VListAdd()
37336 assert( pIn[1]<=pIn[0] ); in sqlite3VListAdd()
37339 return pIn; in sqlite3VListAdd()
37347 SQLITE_PRIVATE const char *sqlite3VListNumToName(VList *pIn, int iVal){ in sqlite3VListNumToName() argument
37349 if( pIn==0 ) return 0; in sqlite3VListNumToName()
37350 mx = pIn[1]; in sqlite3VListNumToName()
37353 if( pIn[i]==iVal ) return (char*)&pIn[i+2]; in sqlite3VListNumToName()
37354 i += pIn[i+1]; in sqlite3VListNumToName()
37363 SQLITE_PRIVATE int sqlite3VListNameToNum(VList *pIn, const char *zName, int nName){ in sqlite3VListNameToNum() argument
37365 if( pIn==0 ) return 0; in sqlite3VListNameToNum()
37366 mx = pIn[1]; in sqlite3VListNameToNum()
37369 const char *z = (const char*)&pIn[i+2]; in sqlite3VListNameToNum()
37370 if( strncmp(z,zName,nName)==0 && z[nName]==0 ) return pIn[i]; in sqlite3VListNameToNum()
37371 i += pIn[i+1]; in sqlite3VListNameToNum()
55952 static PgHdr *pcacheSortDirtyList(PgHdr *pIn){
55956 while( pIn ){
55957 p = pIn;
55958 pIn = p->pDirty;
57665 static struct RowSetEntry *rowSetEntrySort(struct RowSetEntry *pIn){
57670 while( pIn ){
57671 pNext = pIn->pRight;
57672 pIn->pRight = 0;
57674 pIn = rowSetEntryMerge(aBucket[i], pIn);
57677 aBucket[i] = pIn;
57678 pIn = pNext;
57680 pIn = aBucket[0];
57683 pIn = pIn ? rowSetEntryMerge(pIn, aBucket[i]) : aBucket[i];
57685 return pIn;
57695 struct RowSetEntry *pIn, /* Root of the input tree */
57699 assert( pIn!=0 );
57700 if( pIn->pLeft ){
57702 rowSetTreeToList(pIn->pLeft, ppFirst, &p);
57703 p->pRight = pIn;
57705 *ppFirst = pIn;
57707 if( pIn->pRight ){
57708 rowSetTreeToList(pIn->pRight, &pIn->pRight, ppLast);
57710 *ppLast = pIn;
101813 Mem *pIn;
101816 pIn = &pFrame->aMem[pOp->p1 + pFrame->aOp[pFrame->pc].p1];
101817 sqlite3VdbeMemShallowCopy(pOut, pIn, MEM_Ephem);
105242 void *pIn /* Argument passed into xTask() */
105245 return sqlite3ThreadCreate(&pTask->pThread, xTask, pIn);
113389 static int sqlite3InRhsIsConstant(Parse *pParse, Expr *pIn){
113392 assert( !ExprHasProperty(pIn, EP_xIsSelect) );
113393 pLHS = pIn->pLeft;
113394 pIn->pLeft = 0;
113395 res = sqlite3ExprIsConstant(pParse, pIn);
113396 pIn->pLeft = pLHS;
114213 SQLITE_PRIVATE int sqlite3ExprCheckIN(Parse *pParse, Expr *pIn){
114214 int nVector = sqlite3ExprVectorSize(pIn->pLeft);
114215 if( ExprUseXSelect(pIn) && !pParse->db->mallocFailed ){
114216 if( nVector!=pIn->x.pSelect->pEList->nExpr ){
114217 sqlite3SubselectError(pParse, pIn->x.pSelect->pEList->nExpr, nVector);
114221 sqlite3VectorErrorMsg(pParse, pIn->pLeft);
148142 SelectDest *pIn, /* Coroutine supplying data */
148161 addr2 = sqlite3VdbeAddOp4(v, OP_Compare, pIn->iSdst, regPrev+1, pIn->nSdst,
148165 sqlite3VdbeAddOp3(v, OP_Copy, pIn->iSdst, regPrev+1, pIn->nSdst-1);
148182 sqlite3VdbeAddOp3(v, OP_MakeRecord, pIn->iSdst, pIn->nSdst, r1);
148196 testcase( pIn->nSdst>1 );
148198 sqlite3VdbeAddOp4(v, OP_MakeRecord, pIn->iSdst, pIn->nSdst,
148199 r1, pDest->zAffSdst, pIn->nSdst);
148201 pIn->iSdst, pIn->nSdst);
148204 pIn->iSdst, pIn->nSdst);
148217 testcase( pIn->nSdst>1 );
148218 sqlite3ExprCodeMove(pParse, pIn->iSdst, pDest->iSDParm, pIn->nSdst);
148229 pDest->iSdst = sqlite3GetTempRange(pParse, pIn->nSdst);
148230 pDest->nSdst = pIn->nSdst;
148232 sqlite3ExprCodeMove(pParse, pIn->iSdst, pDest->iSdst, pIn->nSdst);
148247 sqlite3VdbeAddOp2(v, OP_ResultRow, pIn->iSdst, pIn->nSdst);
160278 struct InLoop *pIn;
160342 pIn = pLevel->u.in.aInLoop;
160343 if( pIn ){
160345 pIn += i;
160350 pIn->addrInTop = sqlite3VdbeAddOp2(v, OP_Rowid, iTab, iOut);
160353 pIn->addrInTop = sqlite3VdbeAddOp3(v,OP_Column,iTab, iCol, iOut);
160357 pIn->iCur = iTab;
160358 pIn->eEndLoopOp = bRev ? OP_Prev : OP_Next;
160360 pIn->iBase = iTarget - i;
160361 pIn->nPrefix = i;
160363 pIn->nPrefix = 0;
160366 pIn->eEndLoopOp = OP_Noop;
160368 pIn++;
171880 struct InLoop *pIn;
171883 for(j=pLevel->u.in.nIn, pIn=&pLevel->u.in.aInLoop[j-1]; j>0; j--, pIn--){
171884 assert( sqlite3VdbeGetOp(v, pIn->addrInTop+1)->opcode==OP_IsNull
171886 sqlite3VdbeJumpHere(v, pIn->addrInTop+1);
171887 if( pIn->eEndLoopOp!=OP_Noop ){
171888 if( pIn->nPrefix ){
171901 sqlite3VdbeAddOp2(v, OP_IfNotOpen, pIn->iCur,
171908 pIn->iBase, pIn->nPrefix);
171914 sqlite3VdbeJumpHere(v, pIn->addrInTop+1);
171917 sqlite3VdbeAddOp2(v, pIn->eEndLoopOp, pIn->iCur, pIn->addrInTop);
171919 VdbeCoverageIf(v, pIn->eEndLoopOp==OP_Prev);
171920 VdbeCoverageIf(v, pIn->eEndLoopOp==OP_Next);
171922 sqlite3VdbeJumpHere(v, pIn->addrInTop-1);
228226 void *pIn; /* First argument to xInput */
231456 int (*xInput)(void *pIn, void *pData, int *pnData),
231457 void *pIn,
231479 pRet->in.pIn = pIn;
231514 int (*xInput)(void *pIn, void *pData, int *pnData),
231515 void *pIn
231517 return sessionChangesetStart(pp, xInput, pIn, 0, 0, 0, 0);
231521 int (*xInput)(void *pIn, void *pData, int *pnData),
231522 void *pIn,
231526 return sessionChangesetStart(pp, xInput, pIn, 0, 0, bInvert, 0);
231533 static void sessionDiscardData(SessionInput *pIn){
231534 if( pIn->xInput && pIn->iCurrent>=sessions_strm_chunk_size ){
231535 int nMove = pIn->buf.nBuf - pIn->iCurrent;
231538 memmove(pIn->buf.aBuf, &pIn->buf.aBuf[pIn->iCurrent], nMove);
231540 pIn->buf.nBuf -= pIn->iCurrent;
231541 pIn->iNext -= pIn->iCurrent;
231542 pIn->iCurrent = 0;
231543 pIn->nData = pIn->buf.nBuf;
231554 static int sessionInputBuffer(SessionInput *pIn, int nByte){
231556 if( pIn->xInput ){
231557 while( !pIn->bEof && (pIn->iNext+nByte)>=pIn->nData && rc==SQLITE_OK ){
231560 if( pIn->bNoDiscard==0 ) sessionDiscardData(pIn);
231561 if( SQLITE_OK==sessionBufferGrow(&pIn->buf, nNew, &rc) ){
231562 rc = pIn->xInput(pIn->pIn, &pIn->buf.aBuf[pIn->buf.nBuf], &nNew);
231564 pIn->bEof = 1;
231566 pIn->buf.nBuf += nNew;
231570 pIn->aData = pIn->buf.aBuf;
231571 pIn->nData = pIn->buf.nBuf;
231650 SessionInput *pIn, /* Input data */
231664 rc = sessionInputBuffer(pIn, 9);
231666 if( pIn->iNext>=pIn->nData ){
231669 eType = pIn->aData[pIn->iNext++];
231680 u8 *aVal = &pIn->aData[pIn->iNext];
231683 pIn->iNext += sessionVarintGet(aVal, &nByte);
231684 rc = sessionInputBuffer(pIn, nByte);
231686 if( nByte<0 || nByte>pIn->nData-pIn->iNext ){
231690 rc = sessionValueSetStr(apOut[i],&pIn->aData[pIn->iNext],nByte,enc);
231691 pIn->iNext += nByte;
231696 if( (pIn->nData-pIn->iNext)<8 ){
231707 pIn->iNext += 8;
231729 static int sessionChangesetBufferTblhdr(SessionInput *pIn, int *pnByte){
231734 rc = sessionInputBuffer(pIn, 9);
231736 nRead += sessionVarintGet(&pIn->aData[pIn->iNext + nRead], &nCol);
231747 rc = sessionInputBuffer(pIn, nRead+nCol+100);
231753 while( (pIn->iNext + nRead)<pIn->nData && pIn->aData[pIn->iNext + nRead] ){
231756 if( (pIn->iNext + nRead)<pIn->nData ) break;
231757 rc = sessionInputBuffer(pIn, nRead + 100);
231773 SessionInput *pIn, /* Input data */
231782 rc = sessionInputBuffer(pIn, nByte + 10);
231784 eType = pIn->aData[pIn->iNext + nByte++];
231787 nByte += sessionVarintGet(&pIn->aData[pIn->iNext+nByte], &n);
231789 rc = sessionInputBuffer(pIn, nByte);
232386 int (*xInput)(void *pIn, void *pData, int *pnData),
232387 void *pIn,
232397 sInput.pIn = pIn;
233593 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
233594 void *pIn, /* First arg for xInput */
233610 int rc = sessionChangesetStart(&pIter, xInput, pIn, 0, 0, bInverse, 1);
233620 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
233621 void *pIn, /* First arg for xInput */
233634 db, xInput, pIn, xFilter, xConflict, pCtx, 0, 0, 0
233685 u8 *pIn = aRec;
233688 int nIn = sessionSerialLen(pIn);
233689 if( *pIn==0 ){
233694 memcpy(pOut, pIn, nIn);
233697 pIn += nIn;
234288 int (*xInput)(void *pIn, void *pData, int *pnData),
234289 void *pIn
234294 rc = sqlite3changeset_start_strm(&pIter, xInput, pIn);
234358 int (*xInputA)(void *pIn, void *pData, int *pnData),
234360 int (*xInputB)(void *pIn, void *pData, int *pnData),
234681 int nIn, const void *pIn,
234685 int rc = sqlite3changeset_start(&pIter, nIn, (void*)pIn);
234700 int (*xInput)(void *pIn, void *pData, int *pnData),
234701 void *pIn,
234706 int rc = sqlite3changeset_start_strm(&pIter, xInput, pIn);
235945 static char *sqlite3Fts5Strndup(int *pRc, const char *pIn, int nIn);
239130 static char *sqlite3Fts5Strndup(int *pRc, const char *pIn, int nIn){
239134 nIn = (int)strlen(pIn);
239138 memcpy(zRet, pIn, nIn);
239300 static const char *fts5ConfigSkipWhitespace(const char *pIn){
239301 const char *p = pIn;
239313 static const char *fts5ConfigSkipBareword(const char *pIn){
239314 const char *p = pIn;
239316 if( p==pIn ) p = 0;
239326 static const char *fts5ConfigSkipLiteral(const char *pIn){
239327 const char *p = pIn;
239347 if( *p=='\'' && 0==((p-pIn)%2) ){
239381 if( p==pIn ) p = 0;
240091 static const char *fts5ConfigSkipArgs(const char *pIn){
240092 const char *p = pIn;
251154 static int fts5IndexCharlen(const char *pIn, int nIn){
251158 if( (unsigned char)pIn[i++]>=0xc0 ){
251159 while( i<nIn && (pIn[i] & 0xc0)==0x80 ) i++;
251250 Fts5TokenDataIter *pIn, /* Current Fts5TokenDataIter struct */
251253 Fts5TokenDataIter *pRet = pIn;
251256 if( pIn==0 || pIn->nIter==pIn->nIterAlloc ){
251257 int nAlloc = pIn ? pIn->nIterAlloc*2 : 16;
251259 Fts5TokenDataIter *pNew = (Fts5TokenDataIter*)sqlite3_realloc(pIn, nByte);
251264 if( pIn==0 ) memset(pNew, 0, nByte);