Page MenuHomeFreeBSD
Files F166931767

D31235.id92490.diff
No OneTemporary
Actions

D31235.id92490.diff
View Options

Index: sys/kern/kern_umtx.c
===================================================================
--- sys/kern/kern_umtx.c
+++ sys/kern/kern_umtx.c
@@ -616,6 +616,41 @@
wakeup(uq);
}
+/*
+ * Wake up a maximum of n_wake threads that are waiting on an userland object
+ * identified by key. The remaining threads are removed from queue identified by
+ * key and added to the queue identified by key2 (requeued). The n_requeue specifies
+ * an upper limit on the number of threads that are requeued to the second queue.
+ */
+int
+umtxq_requeue(struct umtx_key *key, int n_wake, struct umtx_key *key2, int n_requeue)
+{
+ struct umtxq_queue *uh, *uh2;
+ struct umtx_q *uq;
+ int ret;
+
+ ret = 0;
+ UMTXQ_LOCKED_ASSERT(umtxq_getchain(key));
+ UMTXQ_LOCKED_ASSERT(umtxq_getchain(key2));
+ uh = umtxq_queue_lookup(key, UMTX_SHARED_QUEUE);
+ uh2 = umtxq_queue_lookup(key2, UMTX_SHARED_QUEUE);
+ if (uh != NULL) {
+ while ((uq = TAILQ_FIRST(&uh->head)) != NULL) {
+ if (++ret <= n_wake) {
+ umtxq_remove(uq);
+ wakeup_one(uq);
+ } else {
+ umtxq_remove(uq);
+ uq->uq_key = *key2;
+ umtxq_insert(uq);
+ if (ret - n_wake == n_requeue)
+ break;
+ }
+ }
+ }
+ return (ret);
+}
+
static inline int
tstohz(const struct timespec *tsp)
{
Index: sys/sys/umtx.h
===================================================================
--- sys/sys/umtx.h
+++ sys/sys/umtx.h
@@ -315,6 +315,7 @@
struct umtxq_chain *umtxq_getchain(struct umtx_key *);
void umtxq_insert_queue(struct umtx_q *, int);
void umtxq_remove_queue(struct umtx_q *, int);
+int umtxq_requeue(struct umtx_key *, int, struct umtx_key *, int);
int umtxq_signal_mask(struct umtx_key *, int, u_int);
int umtxq_sleep(struct umtx_q *, const char *, struct abs_timeout *);
void umtxq_unbusy(struct umtx_key *);

File Metadata

Mime Type
text/plain
Expires
Tue, Aug 18, 8:39 PM (4 h, 35 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
36877987
Default Alt Text
D31235.id92490.diff (1 KB)

Event Timeline