Function QueriesLog_AddQuery

src/queries_log/queries_log.c:56–98

add query to buffer

// add query to buffer
void QueriesLog_AddQuery
(
    QueriesLog log,               // queries log
	uint64_t received,            // query received timestamp
	double wait_duration,         // waiting time
	double execution_duration,    // executing time
	double report_duration,       // reporting time
	bool parameterized,           // uses parameters
	bool utilized_cache,          // utilized cache
	bool write,    	   	          // write query
	bool timeout,    		      // timeout query
	const char *query             // query string
) {
	// add query stats to buffer
	// acquire READ lock, multiple threads can be populating the circular buffer
	// simultaneously (the circular-buffer is lock-free)

	int res = pthread_rwlock_rdlock(&log->rwlock);
	ASSERT(res == 0);

	// get a slot within log's buffer
	void *slot = CircularBuffer_Reserve(log->queries);

	// dump query to slot
	LoggedQuery *q = (LoggedQuery*)(slot);

	if(q->query != NULL) {
		rm_free(q->query);
	}

	q->received           = received;
	q->wait_duration      = wait_duration;
	q->execution_duration = execution_duration;
	q->report_duration    = report_duration;
	q->parameterized      = parameterized;
	q->write              = write;
	q->timeout            = timeout;
	q->utilized_cache     = utilized_cache;
	q->query              = rm_strdup(query);

	res = pthread_rwlock_unlock(&log->rwlock);
	ASSERT(res == 0);
}

// returns number of queries in log
uint64_t QueriesLog_GetQueriesCount