2 +----------------------------------------------------------------------+
4 +----------------------------------------------------------------------+
5 | Copyright (c) 2010- Facebook, Inc. (http://www.facebook.com) |
6 +----------------------------------------------------------------------+
7 | This source file is subject to version 3.01 of the PHP license, |
8 | that is bundled with this package in the file LICENSE, and is |
9 | available through the world-wide-web at the following url: |
10 | http://www.php.net/license/3_01.txt |
11 | If you did not receive a copy of the PHP license and are unable to |
12 | obtain it through the world-wide-web, please send a note to |
13 | license@php.net so we can mail you a copy immediately. |
14 +----------------------------------------------------------------------+
17 #ifndef incl_HPHP_TIMEOUT_THREAD_H_
18 #define incl_HPHP_TIMEOUT_THREAD_H_
22 #include "hphp/runtime/base/types.h"
23 #include "hphp/util/base.h"
24 #include "hphp/util/process.h"
25 #include "hphp/util/synchronizable.h"
29 ///////////////////////////////////////////////////////////////////////////////
31 class TimeoutThread
: public Synchronizable
{
33 static void DeferTimeout(int seconds
);
36 TimeoutThread(int timeoutSeconds
);
39 void registerRequestThread(RequestInjectionData
* data
);
40 void removeRequestThread(RequestInjectionData
* data
);
44 void onTimer(int index
);
47 void checkForNewWorkers();
52 // m_pendingIds contains ids of threads that were added or removed
53 // and need to be processed by the worker thread
54 std::queue
<int> m_pendingIds
;
57 event_base
*m_eventBase
;
60 RequestInjectionData
* data
;
63 std::map
<int, ClientThread
> m_clients
;
66 // signal to wake up the thread
71 ///////////////////////////////////////////////////////////////////////////////
74 #endif // incl_HPHP_TIMEOUT_THREAD_H_