2 ** NetXMS - Network Management System
3 ** Copyright (C) 2003, 2004 Victor Kirhenshtein
5 ** This program is free software; you can redistribute it and/or modify
6 ** it under the terms of the GNU General Public License as published by
7 ** the Free Software Foundation; either version 2 of the License, or
8 ** (at your option) any later version.
10 ** This program is distributed in the hope that it will be useful,
11 ** but WITHOUT ANY WARRANTY; without even the implied warranty of
12 ** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 ** GNU General Public License for more details.
15 ** You should have received a copy of the GNU General Public License
16 ** along with this program; if not, write to the Free Software
17 ** Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
30 Queue
*g_pLazyRequestQueue
= NULL
;
37 static CONDITION m_hCondWriteThreadFinished
= NULL
;
41 // Put SQL request into queue for later execution
44 void QueueSQLRequest(char *szQuery
)
46 g_pLazyRequestQueue
->Put(strdup(szQuery
));
51 // Database "lazy" write thread
54 void DBWriteThread(void *pArg
)
58 m_hCondWriteThreadFinished
= ConditionCreate(FALSE
);
61 pQuery
= (char *)g_pLazyRequestQueue
->GetOrBlock();
62 if (pQuery
== INVALID_POINTER_VALUE
) // End-of-job indicator
65 DBQuery(g_hCoreDB
, pQuery
);
68 ConditionSet(m_hCondWriteThreadFinished
);
73 // Stop writer thread and wait while all queries will be executed
76 void StopDBWriter(void)
78 g_pLazyRequestQueue
->Put(INVALID_POINTER_VALUE
);
79 if (m_hCondWriteThreadFinished
!= NULL
)
81 ConditionWait(m_hCondWriteThreadFinished
, INFINITE
);
82 ConditionDestroy(m_hCondWriteThreadFinished
);