| /dports/audio/spotify-tui/spotify-tui-0.25.0/cargo-crates/futures-util-0.3.5/src/stream/futures_unordered/ |
| H A D | task.rs | 10 pub(super) struct Task<Fut> { struct
16 pub(super) next_all: AtomicPtr<Task<Fut>>, argument
19 pub(super) prev_all: UnsafeCell<*const Task<Fut>>, argument
27 pub(super) next_ready_to_run: AtomicPtr<Task<Fut>>, argument
36 // `Task` can be sent across threads safely because it ensures that argument
41 unsafe impl<Fut> Send for Task<Fut> {} implementation
42 unsafe impl<Fut> Sync for Task<Fut> {} implementation
44 impl<Fut> ArcWake for Task<Fut> { implementation
71 impl<Fut> Task<Fut> { implementation
102 impl<Fut> Drop for Task<Fut> { implementation
|
| /dports/multimedia/neolink/neolink-cf54129/cargo-crates/futures-util-0.3.16/src/stream/futures_unordered/ |
| H A D | task.rs | 10 pub(super) struct Task<Fut> { struct
16 pub(super) next_all: AtomicPtr<Task<Fut>>, argument
19 pub(super) prev_all: UnsafeCell<*const Task<Fut>>, argument
27 pub(super) next_ready_to_run: AtomicPtr<Task<Fut>>, argument
36 // `Task` can be sent across threads safely because it ensures that argument
41 unsafe impl<Fut> Send for Task<Fut> {} implementation
42 unsafe impl<Fut> Sync for Task<Fut> {} implementation
44 impl<Fut> ArcWake for Task<Fut> { implementation
71 impl<Fut> Task<Fut> { impl
102 impl<Fut> Drop for Task<Fut> { implementation
|
| /dports/x11/wmfocus/wmfocus-1.2.0/cargo-crates/futures-util-0.3.15/src/stream/futures_unordered/ |
| H A D | task.rs | 10 pub(super) struct Task<Fut> { struct
16 pub(super) next_all: AtomicPtr<Task<Fut>>, argument
19 pub(super) prev_all: UnsafeCell<*const Task<Fut>>, argument
27 pub(super) next_ready_to_run: AtomicPtr<Task<Fut>>, argument
36 // `Task` can be sent across threads safely because it ensures that argument
41 unsafe impl<Fut> Send for Task<Fut> {} implementation
42 unsafe impl<Fut> Sync for Task<Fut> {} implementation
44 impl<Fut> ArcWake for Task<Fut> { implementation
71 impl<Fut> Task<Fut> { implementation
102 impl<Fut> Drop for Task<Fut> { implementation
|
| /dports/www/monolith/monolith-2.6.1/cargo-crates/futures-util-0.3.15/src/stream/futures_unordered/ |
| H A D | task.rs | 10 pub(super) struct Task<Fut> { struct
16 pub(super) next_all: AtomicPtr<Task<Fut>>, argument
19 pub(super) prev_all: UnsafeCell<*const Task<Fut>>, argument
27 pub(super) next_ready_to_run: AtomicPtr<Task<Fut>>, argument
36 // `Task` can be sent across threads safely because it ensures that argument
41 unsafe impl<Fut> Send for Task<Fut> {} implementation
42 unsafe impl<Fut> Sync for Task<Fut> {} implementation
44 impl<Fut> ArcWake for Task<Fut> { implementation
71 impl<Fut> Task<Fut> { implementation
102 impl<Fut> Drop for Task<Fut> { implementation
|
| /dports/sysutils/tealdeer/tealdeer-1.4.1/cargo-crates/futures-util-0.3.5/src/stream/futures_unordered/ |
| H A D | task.rs | 10 pub(super) struct Task<Fut> { struct
16 pub(super) next_all: AtomicPtr<Task<Fut>>, argument
19 pub(super) prev_all: UnsafeCell<*const Task<Fut>>, argument
27 pub(super) next_ready_to_run: AtomicPtr<Task<Fut>>, argument
36 // `Task` can be sent across threads safely because it ensures that argument
41 unsafe impl<Fut> Send for Task<Fut> {} implementation
42 unsafe impl<Fut> Sync for Task<Fut> {} implementation
44 impl<Fut> ArcWake for Task<Fut> { implementation
71 impl<Fut> Task<Fut> { implementation
102 impl<Fut> Drop for Task<Fut> { implementation
|
| /dports/x11/sirula/sirula-1.0.0/cargo-crates/futures-util-0.3.17/src/stream/futures_unordered/ |
| H A D | task.rs | 10 pub(super) struct Task<Fut> { struct
16 pub(super) next_all: AtomicPtr<Task<Fut>>, argument
19 pub(super) prev_all: UnsafeCell<*const Task<Fut>>, argument
27 pub(super) next_ready_to_run: AtomicPtr<Task<Fut>>, argument
36 // `Task` can be sent across threads safely because it ensures that argument
41 unsafe impl<Fut> Send for Task<Fut> {} implementation
42 unsafe impl<Fut> Sync for Task<Fut> {} implementation
44 impl<Fut> ArcWake for Task<Fut> { implementation
71 impl<Fut> Task<Fut> { impl
102 impl<Fut> Drop for Task<Fut> { implementation
|
| /dports/devel/py-maturin/maturin-0.11.3/cargo-crates/futures-util-0.3.16/src/stream/futures_unordered/ |
| H A D | task.rs | 10 pub(super) struct Task<Fut> { struct
16 pub(super) next_all: AtomicPtr<Task<Fut>>, argument
19 pub(super) prev_all: UnsafeCell<*const Task<Fut>>, argument
27 pub(super) next_ready_to_run: AtomicPtr<Task<Fut>>, argument
36 // `Task` can be sent across threads safely because it ensures that argument
41 unsafe impl<Fut> Send for Task<Fut> {} implementation
42 unsafe impl<Fut> Sync for Task<Fut> {} implementation
44 impl<Fut> ArcWake for Task<Fut> { implementation
71 impl<Fut> Task<Fut> { impl
102 impl<Fut> Drop for Task<Fut> { implementation
|
| /dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta3/ |
| H A D | task.pb.go | 78 type Task struct { struct
165 XXX_NoUnkeyedLiteral struct{} `json:"-"`
166 XXX_unrecognized []byte `json:"-"`
167 XXX_sizecache int32 `json:"-"`
172 func (*Task) ProtoMessage() {}
186 func (m *Task) XXX_Size() int {
189 func (m *Task) XXX_DiscardUnknown() {
195 func (m *Task) GetName() string {
260 func (m *Task) GetDispatchCount() int32 {
267 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/net/grpcui/grpcui-1.1.0/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta3/ |
| H A D | task.pb.go | 78 type Task struct { struct
165 XXX_NoUnkeyedLiteral struct{} `json:"-"`
166 XXX_unrecognized []byte `json:"-"`
167 XXX_sizecache int32 `json:"-"`
172 func (*Task) ProtoMessage() {}
186 func (m *Task) XXX_Size() int {
189 func (m *Task) XXX_DiscardUnknown() {
195 func (m *Task) GetName() string {
260 func (m *Task) GetDispatchCount() int32 {
267 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/net/grpcui/grpcui-1.1.0/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2/ |
| H A D | task.pb.go | 78 type Task struct { struct
163 XXX_NoUnkeyedLiteral struct{} `json:"-"`
164 XXX_unrecognized []byte `json:"-"`
165 XXX_sizecache int32 `json:"-"`
170 func (*Task) ProtoMessage() {}
184 func (m *Task) XXX_Size() int {
187 func (m *Task) XXX_DiscardUnknown() {
193 func (m *Task) GetName() string {
258 func (m *Task) GetDispatchCount() int32 {
265 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/security/lego/lego-4.5.3/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2/ |
| H A D | task.pb.go | 78 type Task struct { struct
163 XXX_NoUnkeyedLiteral struct{} `json:"-"`
164 XXX_unrecognized []byte `json:"-"`
165 XXX_sizecache int32 `json:"-"`
170 func (*Task) ProtoMessage() {}
184 func (m *Task) XXX_Size() int {
187 func (m *Task) XXX_DiscardUnknown() {
193 func (m *Task) GetName() string {
258 func (m *Task) GetDispatchCount() int32 {
265 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/security/lego/lego-4.5.3/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta3/ |
| H A D | task.pb.go | 78 type Task struct { struct
165 XXX_NoUnkeyedLiteral struct{} `json:"-"`
166 XXX_unrecognized []byte `json:"-"`
167 XXX_sizecache int32 `json:"-"`
172 func (*Task) ProtoMessage() {}
186 func (m *Task) XXX_Size() int {
189 func (m *Task) XXX_DiscardUnknown() {
195 func (m *Task) GetName() string {
260 func (m *Task) GetDispatchCount() int32 {
267 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/net/evans/evans-0.9.1/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta3/ |
| H A D | task.pb.go | 78 type Task struct { struct
165 XXX_NoUnkeyedLiteral struct{} `json:"-"`
166 XXX_unrecognized []byte `json:"-"`
167 XXX_sizecache int32 `json:"-"`
172 func (*Task) ProtoMessage() {}
186 func (m *Task) XXX_Size() int {
189 func (m *Task) XXX_DiscardUnknown() {
195 func (m *Task) GetName() string {
260 func (m *Task) GetDispatchCount() int32 {
267 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/net/evans/evans-0.9.1/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2/ |
| H A D | task.pb.go | 78 type Task struct { struct
163 XXX_NoUnkeyedLiteral struct{} `json:"-"`
164 XXX_unrecognized []byte `json:"-"`
165 XXX_sizecache int32 `json:"-"`
170 func (*Task) ProtoMessage() {}
184 func (m *Task) XXX_Size() int {
187 func (m *Task) XXX_DiscardUnknown() {
193 func (m *Task) GetName() string {
258 func (m *Task) GetDispatchCount() int32 {
265 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/www/pomerium/pomerium-0.8.3/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2/ |
| H A D | task.pb.go | 78 type Task struct { struct
163 XXX_NoUnkeyedLiteral struct{} `json:"-"`
164 XXX_unrecognized []byte `json:"-"`
165 XXX_sizecache int32 `json:"-"`
170 func (*Task) ProtoMessage() {}
184 func (m *Task) XXX_Size() int {
187 func (m *Task) XXX_DiscardUnknown() {
193 func (m *Task) GetName() string {
258 func (m *Task) GetDispatchCount() int32 {
265 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/www/pomerium/pomerium-0.8.3/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta3/ |
| H A D | task.pb.go | 78 type Task struct { struct
165 XXX_NoUnkeyedLiteral struct{} `json:"-"`
166 XXX_unrecognized []byte `json:"-"`
167 XXX_sizecache int32 `json:"-"`
172 func (*Task) ProtoMessage() {}
186 func (m *Task) XXX_Size() int {
189 func (m *Task) XXX_DiscardUnknown() {
195 func (m *Task) GetName() string {
260 func (m *Task) GetDispatchCount() int32 {
267 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/audio/murmur-cli/murmur-cli-8f83169/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta3/ |
| H A D | task.pb.go | 78 type Task struct { struct
165 XXX_NoUnkeyedLiteral struct{} `json:"-"`
166 XXX_unrecognized []byte `json:"-"`
167 XXX_sizecache int32 `json:"-"`
172 func (*Task) ProtoMessage() {}
186 func (m *Task) XXX_Size() int {
189 func (m *Task) XXX_DiscardUnknown() {
195 func (m *Task) GetName() string {
260 func (m *Task) GetDispatchCount() int32 {
267 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta3/ |
| H A D | task.pb.go | 78 type Task struct { struct
165 XXX_NoUnkeyedLiteral struct{} `json:"-"`
166 XXX_unrecognized []byte `json:"-"`
167 XXX_sizecache int32 `json:"-"`
172 func (*Task) ProtoMessage() {}
186 func (m *Task) XXX_Size() int {
189 func (m *Task) XXX_DiscardUnknown() {
195 func (m *Task) GetName() string {
260 func (m *Task) GetDispatchCount() int32 {
267 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/sysutils/go-wtf/wtf-0.21.0/vendor/google.golang.org/genproto/go-genproto-eb59cef1c072/googleapis/cloud/tasks/v2beta3/ |
| H A D | task.pb.go | 78 type Task struct { struct
165 XXX_NoUnkeyedLiteral struct{} `json:"-"`
166 XXX_unrecognized []byte `json:"-"`
167 XXX_sizecache int32 `json:"-"`
172 func (*Task) ProtoMessage() {}
186 func (m *Task) XXX_Size() int {
189 func (m *Task) XXX_DiscardUnknown() {
195 func (m *Task) GetName() string {
260 func (m *Task) GetDispatchCount() int32 {
267 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/misc/concourse/concourse-6.7.2/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta3/ |
| H A D | task.pb.go | 78 type Task struct { struct
165 XXX_NoUnkeyedLiteral struct{} `json:"-"`
166 XXX_unrecognized []byte `json:"-"`
167 XXX_sizecache int32 `json:"-"`
172 func (*Task) ProtoMessage() {}
186 func (m *Task) XXX_Size() int {
189 func (m *Task) XXX_DiscardUnknown() {
195 func (m *Task) GetName() string {
260 func (m *Task) GetDispatchCount() int32 {
267 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/misc/concourse/concourse-6.7.2/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2/ |
| H A D | task.pb.go | 78 type Task struct { struct
163 XXX_NoUnkeyedLiteral struct{} `json:"-"`
164 XXX_unrecognized []byte `json:"-"`
165 XXX_sizecache int32 `json:"-"`
170 func (*Task) ProtoMessage() {}
184 func (m *Task) XXX_Size() int {
187 func (m *Task) XXX_DiscardUnknown() {
193 func (m *Task) GetName() string {
258 func (m *Task) GetDispatchCount() int32 {
265 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2/ |
| H A D | task.pb.go | 78 type Task struct { struct
163 XXX_NoUnkeyedLiteral struct{} `json:"-"`
164 XXX_unrecognized []byte `json:"-"`
165 XXX_sizecache int32 `json:"-"`
170 func (*Task) ProtoMessage() {}
184 func (m *Task) XXX_Size() int {
187 func (m *Task) XXX_DiscardUnknown() {
193 func (m *Task) GetName() string {
258 func (m *Task) GetDispatchCount() int32 {
265 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta3/ |
| H A D | task.pb.go | 78 type Task struct { struct
165 XXX_NoUnkeyedLiteral struct{} `json:"-"`
166 XXX_unrecognized []byte `json:"-"`
167 XXX_sizecache int32 `json:"-"`
172 func (*Task) ProtoMessage() {}
186 func (m *Task) XXX_Size() int {
189 func (m *Task) XXX_DiscardUnknown() {
195 func (m *Task) GetName() string {
260 func (m *Task) GetDispatchCount() int32 {
267 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/google.golang.org/genproto/googleapis/cloud/tasks/v2beta3/ |
| H A D | task.pb.go | 78 type Task struct { struct
165 XXX_NoUnkeyedLiteral struct{} `json:"-"`
166 XXX_unrecognized []byte `json:"-"`
167 XXX_sizecache int32 `json:"-"`
172 func (*Task) ProtoMessage() {}
186 func (m *Task) XXX_Size() int {
189 func (m *Task) XXX_DiscardUnknown() {
195 func (m *Task) GetName() string {
260 func (m *Task) GetDispatchCount() int32 {
267 func (m *Task) GetResponseCount() int32 {
[all …]
|
| /dports/devel/mutagen/mutagen-0.11.8/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta3/ |
| H A D | task.pb.go | 78 type Task struct { struct
165 XXX_NoUnkeyedLiteral struct{} `json:"-"`
166 XXX_unrecognized []byte `json:"-"`
167 XXX_sizecache int32 `json:"-"`
172 func (*Task) ProtoMessage() {}
186 func (m *Task) XXX_Size() int {
189 func (m *Task) XXX_DiscardUnknown() {
195 func (m *Task) GetName() string {
260 func (m *Task) GetDispatchCount() int32 {
267 func (m *Task) GetResponseCount() int32 {
[all …]
|