/usr/include/hphp/util/synchronizable-multi.h is in hhvm-dev 3.11.1+dfsg-1ubuntu1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
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 | /*
+----------------------------------------------------------------------+
| HipHop for PHP |
+----------------------------------------------------------------------+
| Copyright (c) 2010-2015 Facebook, Inc. (http://www.facebook.com) |
+----------------------------------------------------------------------+
| This source file is subject to version 3.01 of the PHP license, |
| that is bundled with this package in the file LICENSE, and is |
| available through the world-wide-web at the following url: |
| http://www.php.net/license/3_01.txt |
| If you did not receive a copy of the PHP license and are unable to |
| obtain it through the world-wide-web, please send a note to |
| license@php.net so we can mail you a copy immediately. |
+----------------------------------------------------------------------+
*/
#ifndef incl_HPHP_SYNCHRONIZABLE_MULTI_H_
#define incl_HPHP_SYNCHRONIZABLE_MULTI_H_
#include <vector>
#include <list>
#include "hphp/util/mutex.h"
#include "hphp/util/rank.h"
#include "hphp/util/hash-map-typedefs.h"
#include "hphp/util/functional.h"
namespace HPHP {
///////////////////////////////////////////////////////////////////////////////
/**
* A Synchronizable object that has multiple conditional variables. The benefit
* is, notify() can choose to notify the most recently waited conditional
* variable for an altered scheduling that potentially wakes up a thread with
* better thread caching.
*/
class SynchronizableMulti {
public:
explicit SynchronizableMulti(int size);
virtual ~SynchronizableMulti();
/**
* "id" is an arbitrary number that locates the conditional variable to wait
* on.
*
* "front" means adding this thread to front of the queue while waiting.
* Otherwise, the thread is pushed to the back of the queue, being the last
* to wake up, when notify() is called.
*/
void wait(int id, int q, bool front);
bool wait(int id, int q, bool front, long seconds); // false if timed out
bool wait(int id, int q, bool front, long seconds, long long nanosecs);
void notify();
void notifyAll();
void setNumGroups(int num_groups);
Mutex &getMutex() { return m_mutex;}
private:
Mutex m_mutex;
std::vector<pthread_cond_t> m_conds;
typedef std::list<pthread_cond_t*> CondPtrList;
std::vector<CondPtrList> m_cond_list_vec;
typedef std::pair<CondPtrList*, CondPtrList::iterator> CondListElem;
// iterators in std::list are valid even after element removal
typedef hphp_hash_map<pthread_cond_t*, CondListElem,
pointer_hash<pthread_cond_t> > CondIterMap;
CondIterMap m_cond_map;
bool waitImpl(int id, int q, bool front, timespec *ts);
int m_group;
};
///////////////////////////////////////////////////////////////////////////////
}
#endif // incl_HPHP_SYNCHRONIZABLE_MULTI_H_
|