272 static void sendToServer(SqlMessage *pMsg){  in sendToServer()  argument
275   pthread_mutex_init(&pMsg->clientMutex, 0);  in sendToServer()
276   pthread_cond_init(&pMsg->clientWakeup, 0);  in sendToServer()
281   pMsg->pNext = g.pQueueHead;  in sendToServer()
283     g.pQueueTail = pMsg;  in sendToServer()
285     g.pQueueHead->pPrev = pMsg;  in sendToServer()
287   pMsg->pPrev = 0;  in sendToServer()
288   g.pQueueHead = pMsg;  in sendToServer()
294   pthread_mutex_lock(&pMsg->clientMutex);  in sendToServer()
296   while( pMsg->op!=MSG_Done ){  in sendToServer()
297     pthread_cond_wait(&pMsg->clientWakeup, &pMsg->clientMutex);  in sendToServer()
299   pthread_mutex_unlock(&pMsg->clientMutex);  in sendToServer()
303   pthread_mutex_destroy(&pMsg->clientMutex);  in sendToServer()
304   pthread_cond_destroy(&pMsg->clientWakeup);  in sendToServer()
399     SqlMessage *pMsg;  in sqlite3_server()  local
407     pMsg = g.pQueueTail;  in sqlite3_server()
408     if( pMsg ){  in sqlite3_server()
409       if( pMsg->pPrev ){  in sqlite3_server()
410         pMsg->pPrev->pNext = 0;  in sqlite3_server()
414       g.pQueueTail = pMsg->pPrev;  in sqlite3_server()
417     if( pMsg==0 ) break;  in sqlite3_server()
421     pthread_mutex_lock(&pMsg->clientMutex);  in sqlite3_server()
422     switch( pMsg->op ){  in sqlite3_server()
424         pMsg->errCode = sqlite3_open(pMsg->zIn, &pMsg->pDb);  in sqlite3_server()
428         pMsg->errCode = sqlite3_prepare(pMsg->pDb, pMsg->zIn, pMsg->nByte,  in sqlite3_server()
429                                         &pMsg->pStmt, &pMsg->zOut);  in sqlite3_server()
433         pMsg->errCode = sqlite3_step(pMsg->pStmt);  in sqlite3_server()
437         pMsg->errCode = sqlite3_reset(pMsg->pStmt);  in sqlite3_server()
441         pMsg->errCode = sqlite3_finalize(pMsg->pStmt);  in sqlite3_server()
445         pMsg->errCode = sqlite3_close(pMsg->pDb);  in sqlite3_server()
452     pMsg->op = MSG_Done;  in sqlite3_server()
453     pthread_mutex_unlock(&pMsg->clientMutex);  in sqlite3_server()
454     pthread_cond_signal(&pMsg->clientWakeup);  in sqlite3_server()