1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
/*
* File: ms_thread.h
* Author: Mingqiang Zhuang
*
* Created on February 10, 2009
*
* (c) Copyright 2009, Schooner Information Technology, Inc.
* http://www.schoonerinfotech.com/
*
*/
/**
* Asynchronous memslap has the similar implementation of
* multi-threads with memcached. Asynchronous memslap creates
* one or more self-governed threads; each thread is bound with
* one CPU core if the system supports setting CPU core
* affinity. And every thread has private variables. There is
* less communication or some shared resources among all the
* threads. It can improve the performance because there are
* fewer locks and competition. In addition, each thread has a
* libevent to manage the events of network. Each thread has one
* or more self-governed concurrencies; each concurrency has one
* or more socket connections. All the concurrencies don't
* communicate with each other even though they are in the same
* thread.
*/
#ifndef MS_THREAD_H
#define MS_THREAD_H
#include <sched.h>
#include "ms_conn.h"
#ifdef __cplusplus
extern "C" {
#endif
/** Time relative to server start. Smaller than time_t on 64-bit systems. */
typedef unsigned int rel_time_t;
/* Used to store the context of each thread */
typedef struct thread_ctx
{
uint32_t thd_idx; /* the thread index */
uint32_t nconns; /* how many connections included by the thread */
uint32_t srv_idx; /* index of the thread */
int tps_perconn; /* expected throughput per connection */
int64_t exec_num_perconn; /* execute number per connection */
} ms_thread_ctx_t;
/* Used to store the private variables of each thread */
typedef struct thread
{
ms_conn_t *conn; /* conn array to store all the conn in the thread */
uint32_t nactive_conn; /* how many connects are active */
ms_thread_ctx_t *thread_ctx; /* thread context from the caller */
struct event_base *base; /* libevent handler created by this thread */
rel_time_t curr_time; /* current time */
struct event clock_event; /* clock event to time each one second */
bool initialized; /* whether clock_event has been initialized */
struct timeval startup_time; /* start time of the thread */
} ms_thread_t;
/* initialize threads */
void ms_thread_init(void);
/* cleanup some resource of threads when all the threads exit */
void ms_thread_cleanup(void);
#ifdef __cplusplus
}
#endif
#endif /* end of MS_THREAD_H */
|