Lines Matching refs:pIn
11332 int nIn, const void *pIn, /* Input changeset */
11985 int nIn, const void *pIn,
12091 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
12092 void *pIn, /* First arg for xInput */
12106 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
12107 void *pIn, /* First arg for xInput */
12122 int (*xInputA)(void *pIn, void *pData, int *pnData),
12124 int (*xInputB)(void *pIn, void *pData, int *pnData),
12130 int (*xInput)(void *pIn, void *pData, int *pnData),
12131 void *pIn,
12137 int (*xInput)(void *pIn, void *pData, int *pnData),
12138 void *pIn
12142 int (*xInput)(void *pIn, void *pData, int *pnData),
12143 void *pIn,
12157 int (*xInput)(void *pIn, void *pData, int *pnData),
12158 void *pIn
12166 int (*xInput)(void *pIn, void *pData, int *pnData),
12167 void *pIn,
31258 void *pIn; /* Argument to the thread */
31265 void *pIn /* Argument passed into xTask() */
31280 p->pIn = pIn;
31288 rc = pthread_create(&p->tid, 0, xTask, pIn);
31292 p->pOut = xTask(pIn);
31329 void *pIn; /* Argument to xTask */
31350 p->pResult = p->xTask(p->pIn);
31360 void *pIn /* Argument passed into xTask() */
31378 p->pIn = pIn;
31386 p->pResult = xTask(pIn);
31432 void *pIn; /* Argument to xTask */
31440 void *pIn /* Argument passed into xTask() */
31451 p->pIn = pIn;
31454 p->pResult = xTask(pIn);
31466 *ppOut = p->xTask(p->pIn);
33697 VList *pIn, /* The input VList. Might be NULL */
33707 assert( pIn==0 || pIn[0]>=3 ); /* Verify ok to add new elements */
33708 if( pIn==0 || pIn[1]+nInt > pIn[0] ){
33710 sqlite3_int64 nAlloc = (pIn ? 2*(sqlite3_int64)pIn[0] : 10) + nInt;
33711 VList *pOut = sqlite3DbRealloc(db, pIn, nAlloc*sizeof(int));
33712 if( pOut==0 ) return pIn;
33713 if( pIn==0 ) pOut[1] = 2;
33714 pIn = pOut;
33715 pIn[0] = nAlloc;
33717 i = pIn[1];
33718 pIn[i] = iVal;
33719 pIn[i+1] = nInt;
33720 z = (char*)&pIn[i+2];
33721 pIn[1] = i+nInt;
33722 assert( pIn[1]<=pIn[0] );
33725 return pIn;
33733 SQLITE_PRIVATE const char *sqlite3VListNumToName(VList *pIn, int iVal){
33735 if( pIn==0 ) return 0;
33736 mx = pIn[1];
33739 if( pIn[i]==iVal ) return (char*)&pIn[i+2];
33740 i += pIn[i+1];
33749 SQLITE_PRIVATE int sqlite3VListNameToNum(VList *pIn, const char *zName, int nName){
33751 if( pIn==0 ) return 0;
33752 mx = pIn[1];
33755 const char *z = (const char*)&pIn[i+2];
33756 if( strncmp(z,zName,nName)==0 && z[nName]==0 ) return pIn[i];
33757 i += pIn[i+1];
50552 static PgHdr *pcacheSortDirtyList(PgHdr *pIn){
50556 while( pIn ){
50557 p = pIn;
50558 pIn = p->pDirty;
52271 static struct RowSetEntry *rowSetEntrySort(struct RowSetEntry *pIn){
52276 while( pIn ){
52277 pNext = pIn->pRight;
52278 pIn->pRight = 0;
52280 pIn = rowSetEntryMerge(aBucket[i], pIn);
52283 aBucket[i] = pIn;
52284 pIn = pNext;
52286 pIn = aBucket[0];
52289 pIn = pIn ? rowSetEntryMerge(pIn, aBucket[i]) : aBucket[i];
52291 return pIn;
52301 struct RowSetEntry *pIn, /* Root of the input tree */
52305 assert( pIn!=0 );
52306 if( pIn->pLeft ){
52308 rowSetTreeToList(pIn->pLeft, ppFirst, &p);
52309 p->pRight = pIn;
52311 *ppFirst = pIn;
52313 if( pIn->pRight ){
52314 rowSetTreeToList(pIn->pRight, &pIn->pRight, ppLast);
52316 *ppLast = pIn;
93650 Mem *pIn;
93653 pIn = &pFrame->aMem[pOp->p1 + pFrame->aOp[pFrame->pc].p1];
93654 sqlite3VdbeMemShallowCopy(pOut, pIn, MEM_Ephem);
96829 void *pIn /* Argument passed into xTask() */
96832 return sqlite3ThreadCreate(&pTask->pThread, xTask, pIn);
104228 static int sqlite3InRhsIsConstant(Expr *pIn){
104231 assert( !ExprHasProperty(pIn, EP_xIsSelect) );
104232 pLHS = pIn->pLeft;
104233 pIn->pLeft = 0;
104234 res = sqlite3ExprIsConstant(pIn);
104235 pIn->pLeft = pLHS;
104949 SQLITE_PRIVATE int sqlite3ExprCheckIN(Parse *pParse, Expr *pIn){
104950 int nVector = sqlite3ExprVectorSize(pIn->pLeft);
104951 if( ExprUseXSelect(pIn) && !pParse->db->mallocFailed ){
104952 if( nVector!=pIn->x.pSelect->pEList->nExpr ){
104953 sqlite3SubselectError(pParse, pIn->x.pSelect->pEList->nExpr, nVector);
104957 sqlite3VectorErrorMsg(pParse, pIn->pLeft);
136343 SelectDest *pIn, /* Coroutine supplying data */
136362 addr2 = sqlite3VdbeAddOp4(v, OP_Compare, pIn->iSdst, regPrev+1, pIn->nSdst,
136366 sqlite3VdbeAddOp3(v, OP_Copy, pIn->iSdst, regPrev+1, pIn->nSdst-1);
136383 sqlite3VdbeAddOp3(v, OP_MakeRecord, pIn->iSdst, pIn->nSdst, r1);
136397 testcase( pIn->nSdst>1 );
136399 sqlite3VdbeAddOp4(v, OP_MakeRecord, pIn->iSdst, pIn->nSdst,
136400 r1, pDest->zAffSdst, pIn->nSdst);
136402 pIn->iSdst, pIn->nSdst);
136413 testcase( pIn->nSdst>1 );
136414 sqlite3ExprCodeMove(pParse, pIn->iSdst, pDest->iSDParm, pIn->nSdst);
136425 pDest->iSdst = sqlite3GetTempRange(pParse, pIn->nSdst);
136426 pDest->nSdst = pIn->nSdst;
136428 sqlite3ExprCodeMove(pParse, pIn->iSdst, pDest->iSdst, pIn->nSdst);
136443 sqlite3VdbeAddOp2(v, OP_ResultRow, pIn->iSdst, pIn->nSdst);
146953 struct InLoop *pIn;
147019 pIn = pLevel->u.in.aInLoop;
147020 if( pIn ){
147022 pIn += i;
147027 pIn->addrInTop = sqlite3VdbeAddOp2(v, OP_Rowid, iTab, iOut);
147030 pIn->addrInTop = sqlite3VdbeAddOp3(v,OP_Column,iTab, iCol, iOut);
147034 pIn->iCur = iTab;
147035 pIn->eEndLoopOp = bRev ? OP_Prev : OP_Next;
147037 pIn->iBase = iReg - i;
147038 pIn->nPrefix = i;
147040 pIn->nPrefix = 0;
147043 pIn->eEndLoopOp = OP_Noop;
147045 pIn++;
156128 struct InLoop *pIn;
156131 for(j=pLevel->u.in.nIn, pIn=&pLevel->u.in.aInLoop[j-1]; j>0; j--, pIn--){
156132 assert( sqlite3VdbeGetOp(v, pIn->addrInTop+1)->opcode==OP_IsNull
156134 sqlite3VdbeJumpHere(v, pIn->addrInTop+1);
156135 if( pIn->eEndLoopOp!=OP_Noop ){
156136 if( pIn->nPrefix ){
156149 sqlite3VdbeAddOp2(v, OP_IfNotOpen, pIn->iCur,
156156 pIn->iBase, pIn->nPrefix);
156162 sqlite3VdbeJumpHere(v, pIn->addrInTop+1);
156165 sqlite3VdbeAddOp2(v, pIn->eEndLoopOp, pIn->iCur, pIn->addrInTop);
156167 VdbeCoverageIf(v, pIn->eEndLoopOp==OP_Prev);
156168 VdbeCoverageIf(v, pIn->eEndLoopOp==OP_Next);
156170 sqlite3VdbeJumpHere(v, pIn->addrInTop-1);
208537 void *pIn; /* First argument to xInput */
211267 int (*xInput)(void *pIn, void *pData, int *pnData),
211268 void *pIn,
211290 pRet->in.pIn = pIn;
211325 int (*xInput)(void *pIn, void *pData, int *pnData),
211326 void *pIn
211328 return sessionChangesetStart(pp, xInput, pIn, 0, 0, 0, 0);
211332 int (*xInput)(void *pIn, void *pData, int *pnData),
211333 void *pIn,
211337 return sessionChangesetStart(pp, xInput, pIn, 0, 0, bInvert, 0);
211344 static void sessionDiscardData(SessionInput *pIn){
211345 if( pIn->xInput && pIn->iNext>=sessions_strm_chunk_size ){
211346 int nMove = pIn->buf.nBuf - pIn->iNext;
211349 memmove(pIn->buf.aBuf, &pIn->buf.aBuf[pIn->iNext], nMove);
211351 pIn->buf.nBuf -= pIn->iNext;
211352 pIn->iNext = 0;
211353 pIn->nData = pIn->buf.nBuf;
211364 static int sessionInputBuffer(SessionInput *pIn, int nByte){
211366 if( pIn->xInput ){
211367 while( !pIn->bEof && (pIn->iNext+nByte)>=pIn->nData && rc==SQLITE_OK ){
211370 if( pIn->bNoDiscard==0 ) sessionDiscardData(pIn);
211371 if( SQLITE_OK==sessionBufferGrow(&pIn->buf, nNew, &rc) ){
211372 rc = pIn->xInput(pIn->pIn, &pIn->buf.aBuf[pIn->buf.nBuf], &nNew);
211374 pIn->bEof = 1;
211376 pIn->buf.nBuf += nNew;
211380 pIn->aData = pIn->buf.aBuf;
211381 pIn->nData = pIn->buf.nBuf;
211460 SessionInput *pIn, /* Input data */
211474 rc = sessionInputBuffer(pIn, 9);
211476 if( pIn->iNext>=pIn->nData ){
211479 eType = pIn->aData[pIn->iNext++];
211490 u8 *aVal = &pIn->aData[pIn->iNext];
211493 pIn->iNext += sessionVarintGet(aVal, &nByte);
211494 rc = sessionInputBuffer(pIn, nByte);
211496 if( nByte<0 || nByte>pIn->nData-pIn->iNext ){
211500 rc = sessionValueSetStr(apOut[i],&pIn->aData[pIn->iNext],nByte,enc);
211501 pIn->iNext += nByte;
211514 pIn->iNext += 8;
211535 static int sessionChangesetBufferTblhdr(SessionInput *pIn, int *pnByte){
211540 rc = sessionInputBuffer(pIn, 9);
211542 nRead += sessionVarintGet(&pIn->aData[pIn->iNext + nRead], &nCol);
211553 rc = sessionInputBuffer(pIn, nRead+nCol+100);
211559 while( (pIn->iNext + nRead)<pIn->nData && pIn->aData[pIn->iNext + nRead] ){
211562 if( (pIn->iNext + nRead)<pIn->nData ) break;
211563 rc = sessionInputBuffer(pIn, nRead + 100);
211579 SessionInput *pIn, /* Input data */
211588 rc = sessionInputBuffer(pIn, nByte + 10);
211590 eType = pIn->aData[pIn->iNext + nByte++];
211593 nByte += sessionVarintGet(&pIn->aData[pIn->iNext+nByte], &n);
211595 rc = sessionInputBuffer(pIn, nByte);
212176 int (*xInput)(void *pIn, void *pData, int *pnData),
212177 void *pIn,
212187 sInput.pIn = pIn;
213339 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
213340 void *pIn, /* First arg for xInput */
213356 int rc = sessionChangesetStart(&pIter, xInput, pIn, 0, 0, bInverse, 1);
213366 int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */
213367 void *pIn, /* First arg for xInput */
213380 db, xInput, pIn, xFilter, xConflict, pCtx, 0, 0, 0
213426 u8 *pIn = aRec;
213429 int nIn = sessionSerialLen(pIn);
213430 if( *pIn==0 ){
213435 memcpy(pOut, pIn, nIn);
213438 pIn += nIn;
213800 int (*xInput)(void *pIn, void *pData, int *pnData),
213801 void *pIn
213806 rc = sqlite3changeset_start_strm(&pIter, xInput, pIn);
213868 int (*xInputA)(void *pIn, void *pData, int *pnData),
213870 int (*xInputB)(void *pIn, void *pData, int *pnData),
214191 int nIn, const void *pIn,
214195 int rc = sqlite3changeset_start(&pIter, nIn, (void*)pIn);
214210 int (*xInput)(void *pIn, void *pData, int *pnData),
214211 void *pIn,
214216 int rc = sqlite3changeset_start_strm(&pIter, xInput, pIn);
215187 static char *sqlite3Fts5Strndup(int *pRc, const char *pIn, int nIn);
218197 static char *sqlite3Fts5Strndup(int *pRc, const char *pIn, int nIn){
218201 nIn = (int)strlen(pIn);
218205 memcpy(zRet, pIn, nIn);
218365 static const char *fts5ConfigSkipWhitespace(const char *pIn){
218366 const char *p = pIn;
218378 static const char *fts5ConfigSkipBareword(const char *pIn){
218379 const char *p = pIn;
218381 if( p==pIn ) p = 0;
218391 static const char *fts5ConfigSkipLiteral(const char *pIn){
218392 const char *p = pIn;
218412 if( *p=='\'' && 0==((p-pIn)%2) ){
218446 if( p==pIn ) p = 0;
219059 static const char *fts5ConfigSkipArgs(const char *pIn){
219060 const char *p = pIn;
228413 static int fts5IndexCharlen(const char *pIn, int nIn){
228417 if( (unsigned char)pIn[i++]>=0xc0 ){
228418 while( i<nIn && (pIn[i] & 0xc0)==0x80 ) i++;