Lines Matching refs:pCsr

236   FsdirCsr *pCsr = (FsdirCsr*)cur;  in fsdirNext()  local
238 if( pCsr->pDir ){ in fsdirNext()
239 pCsr->pEntry = readdir(pCsr->pDir); in fsdirNext()
240 if( pCsr->pEntry==0 ){ in fsdirNext()
241 closedir(pCsr->pDir); in fsdirNext()
242 pCsr->pDir = 0; in fsdirNext()
244 pCsr->iRowid++; in fsdirNext()
258 FsdirCsr *pCsr = (FsdirCsr*)pVtabCursor; in fsdirFilter() local
267 pCsr->iRowid = 0; in fsdirFilter()
268 sqlite3_free(pCsr->zDir); in fsdirFilter()
269 if( pCsr->pDir ){ in fsdirFilter()
270 closedir(pCsr->pDir); in fsdirFilter()
271 pCsr->pDir = 0; in fsdirFilter()
276 pCsr->zDir = sqlite3_malloc(nDir+1); in fsdirFilter()
277 if( pCsr->zDir==0 ) return SQLITE_NOMEM; in fsdirFilter()
278 memcpy(pCsr->zDir, zDir, nDir+1); in fsdirFilter()
280 pCsr->pDir = opendir(pCsr->zDir); in fsdirFilter()
288 FsdirCsr *pCsr = (FsdirCsr*)cur; in fsdirEof() local
289 return pCsr->pDir==0; in fsdirEof()
296 FsdirCsr *pCsr = (FsdirCsr*)cur; in fsdirColumn() local
299 sqlite3_result_text(ctx, pCsr->zDir, -1, SQLITE_STATIC); in fsdirColumn()
303 sqlite3_result_text(ctx, pCsr->pEntry->d_name, -1, SQLITE_TRANSIENT); in fsdirColumn()
317 FsdirCsr *pCsr = (FsdirCsr*)cur; in fsdirRowid() local
318 *pRowid = pCsr->iRowid; in fsdirRowid()
428 static void fstreeCloseFd(FstreeCsr *pCsr){ in fstreeCloseFd() argument
429 if( pCsr->fd>=0 ){ in fstreeCloseFd()
430 close(pCsr->fd); in fstreeCloseFd()
431 pCsr->fd = -1; in fstreeCloseFd()
439 FstreeCsr *pCsr = (FstreeCsr*)cur; in fstreeClose() local
440 sqlite3_finalize(pCsr->pStmt); in fstreeClose()
441 fstreeCloseFd(pCsr); in fstreeClose()
442 sqlite3_free(pCsr); in fstreeClose()
450 FstreeCsr *pCsr = (FstreeCsr*)cur; in fstreeNext() local
453 fstreeCloseFd(pCsr); in fstreeNext()
454 rc = sqlite3_step(pCsr->pStmt); in fstreeNext()
456 rc = sqlite3_finalize(pCsr->pStmt); in fstreeNext()
457 pCsr->pStmt = 0; in fstreeNext()
460 pCsr->fd = open((const char*)sqlite3_column_text(pCsr->pStmt, 0), O_RDONLY); in fstreeNext()
474 FstreeCsr *pCsr = (FstreeCsr*)pVtabCursor; in fstreeFilter() local
475 FstreeVtab *pTab = (FstreeVtab*)(pCsr->base.pVtab); in fstreeFilter()
512 fstreeCloseFd(pCsr); in fstreeFilter()
513 sqlite3_finalize(pCsr->pStmt); in fstreeFilter()
514 pCsr->pStmt = 0; in fstreeFilter()
515 rc = sqlite3_prepare_v2(pTab->db, zSql, -1, &pCsr->pStmt, 0); in fstreeFilter()
542 sqlite3_bind_text(pCsr->pStmt, 1, zDir, nDir, SQLITE_TRANSIENT); in fstreeFilter()
543 sqlite3_bind_text(pCsr->pStmt, 2, zRoot, nRoot, SQLITE_TRANSIENT); in fstreeFilter()
544 sqlite3_bind_text(pCsr->pStmt, 3, zPrefix, nPrefix, SQLITE_TRANSIENT); in fstreeFilter()
558 FstreeCsr *pCsr = (FstreeCsr*)cur; in fstreeEof() local
559 return pCsr->pStmt==0; in fstreeEof()
566 FstreeCsr *pCsr = (FstreeCsr*)cur; in fstreeColumn() local
568 sqlite3_result_value(ctx, sqlite3_column_value(pCsr->pStmt, 0)); in fstreeColumn()
571 fstat(pCsr->fd, &sBuf); in fstreeColumn()
580 nRead = read(pCsr->fd, aBuf, sBuf.st_mode); in fstreeColumn()