| /dports/dns/knot3/knot-3.1.5/src/knot/common/ |
| H A D | fdset.c | 197 it->unprocessed = 0; in fdset_poll()
223 if (it->unprocessed > 0 && unlikely(it->unprocessed > set->n)) { in fdset_poll()
224 assert(it->unprocessed == 232); in fdset_poll()
225 it->unprocessed = 0; in fdset_poll()
244 while (it->unprocessed > 0 && fdset_it_get_idx(it) < it->idx) { in fdset_poll()
246 it->unprocessed--; in fdset_poll()
248 return it->unprocessed; in fdset_poll()
254 if (it->unprocessed > 0 && unlikely(it->unprocessed > set->n - offset)) { in fdset_poll()
255 assert(it->unprocessed == 7); in fdset_poll()
256 it->unprocessed = 0; in fdset_poll()
[all …]
|
| /dports/dns/knot3-lib/knot-3.1.5/src/knot/common/ |
| H A D | fdset.c | 197 it->unprocessed = 0; in fdset_poll()
223 if (it->unprocessed > 0 && unlikely(it->unprocessed > set->n)) { in fdset_poll()
224 assert(it->unprocessed == 232); in fdset_poll()
225 it->unprocessed = 0; in fdset_poll()
244 while (it->unprocessed > 0 && fdset_it_get_idx(it) < it->idx) { in fdset_poll()
246 it->unprocessed--; in fdset_poll()
248 return it->unprocessed; in fdset_poll()
254 if (it->unprocessed > 0 && unlikely(it->unprocessed > set->n - offset)) { in fdset_poll()
255 assert(it->unprocessed == 7); in fdset_poll()
256 it->unprocessed = 0; in fdset_poll()
[all …]
|
| /dports/mail/mailman3/mailman-3.3.1/src/mailman/model/tests/ |
| H A D | test_bounce.py | 66 events = list(self._processor.unprocessed)
83 unprocessed = list(self._processor.unprocessed)
84 self.assertEqual(len(unprocessed), 1)
85 event = unprocessed[0]
99 unprocessed = list(self._processor.unprocessed)
101 self.assertEqual(len(unprocessed), 2)
106 unprocessed = list(self._processor.unprocessed)
107 self.assertEqual(len(unprocessed), 1)
112 unprocessed = list(self._processor.unprocessed)
113 self.assertEqual(len(unprocessed), 0)
[all …]
|
| /dports/graphics/instant-meshes/instant-meshes-0.0-42-g4a083f4/src/ |
| H A D | reorder.cpp | 29 std::unordered_set<uint32_t> unprocessed(F.cols()); in reorder_mesh() local
31 unprocessed.insert(i); in reorder_mesh()
53 while (!unprocessed.empty()) { in reorder_mesh()
55 auto it = unprocessed.begin(); in reorder_mesh()
57 unprocessed.erase(it); in reorder_mesh()
85 auto it_f = unprocessed.find(f_neighbor); in reorder_mesh()
86 if (it_f != unprocessed.end()) { in reorder_mesh()
88 unprocessed.erase(f_neighbor); in reorder_mesh()
93 if (progress && unprocessed.size() % 10000 == 0) in reorder_mesh()
94 progress("Reordering mesh indices", 1-unprocessed.size() / (Float) F.cols()); in reorder_mesh()
|
| /dports/benchmarks/vegeta/vegeta-12.8.4/vendor/github.com/influxdata/tdigest/ |
| H A D | tdigest.go | 14 unprocessed CentroidList member
49 room := t.maxUnprocessed - t.unprocessed.Len()
62 t.unprocessed = append(t.unprocessed, c)
66 t.unprocessed.Len() > t.maxUnprocessed {
72 if t.unprocessed.Len() > 0 ||
76 t.unprocessed = append(t.unprocessed, t.processed...)
77 sort.Sort(&t.unprocessed)
81 t.processed = append(t.processed, t.unprocessed[0])
85 soFar := t.unprocessed[0].Weight
87 for _, centroid := range t.unprocessed[1:] {
[all …]
|
| /dports/benchmarks/ali/ali-0.7.5/vendor/github.com/influxdata/tdigest/ |
| H A D | tdigest.go | 14 unprocessed CentroidList member
49 room := t.maxUnprocessed - t.unprocessed.Len()
62 t.unprocessed = append(t.unprocessed, c)
66 t.unprocessed.Len() > t.maxUnprocessed {
72 if t.unprocessed.Len() > 0 ||
76 t.unprocessed = append(t.unprocessed, t.processed...)
77 sort.Sort(&t.unprocessed)
81 t.processed = append(t.processed, t.unprocessed[0])
85 soFar := t.unprocessed[0].Weight
87 for _, centroid := range t.unprocessed[1:] {
[all …]
|
| /dports/sysutils/ansible2/ansible-2.9.27/lib/ansible/inventory/ |
| H A D | group.py | 132 unprocessed = set(getattr(self, rel))
134 unprocessed.add(self)
139 while unprocessed:
140 seen.update(unprocessed)
150 unprocessed = new_unprocessed
211 unprocessed = set(self.child_groups)
213 while unprocessed:
214 seen.update(unprocessed)
216 to_process = unprocessed.copy()
217 unprocessed = set([])
[all …]
|
| /dports/sysutils/py-ansible-base/ansible-base-2.10.15/lib/ansible/inventory/ |
| H A D | group.py | 132 unprocessed = set(getattr(self, rel))
134 unprocessed.add(self)
139 while unprocessed:
140 seen.update(unprocessed)
150 unprocessed = new_unprocessed
211 unprocessed = set(self.child_groups)
213 while unprocessed:
214 seen.update(unprocessed)
216 to_process = unprocessed.copy()
217 unprocessed = set([])
[all …]
|
| /dports/sysutils/py-ansible-core/ansible-core-2.11.6/lib/ansible/inventory/ |
| H A D | group.py | 131 unprocessed = set(getattr(self, rel))
133 unprocessed.add(self)
138 while unprocessed:
139 seen.update(unprocessed)
149 unprocessed = new_unprocessed
210 unprocessed = set(self.child_groups)
212 while unprocessed:
213 seen.update(unprocessed)
215 to_process = unprocessed.copy()
216 unprocessed = set([])
[all …]
|
| /dports/net/py-ldap3/ldap3-2.8.1/ldap3/strategy/ |
| H A D | asynchronous.py | 65 unprocessed = b''
81 unprocessed += data
85 length = BaseStrategy.compute_ldap_message_size(unprocessed)
86 if length == -1 or len(unprocessed) < length:
88 elif len(unprocessed) >= length: # add message to message list
94 ldap_resp = decode_message_fast(unprocessed[:length])
97 ldap_resp = decoder.decode(unprocessed[:length], asn1Spec=LDAPMessage())[0]
131 unprocessed = unprocessed[length:]
132 get_more_data = False if unprocessed else True
133 listen = True if self.connection.listening or unprocessed else False
|
| H A D | sync.py | 75 unprocessed = b''
93 unprocessed += data
95 length = BaseStrategy.compute_ldap_message_size(unprocessed)
99 if len(unprocessed) < length:
103 … log(NETWORK, 'received %d bytes via <%s>', len(unprocessed[:length]), self.connection)
104 messages.append(unprocessed[:length])
105 unprocessed = unprocessed[length:]
107 if len(unprocessed) == 0:
|
| /dports/math/z3/z3-z3-4.8.13/src/opt/ |
| H A D | opt_lns.cpp | 104 if (mdl->is_false(unprocessed(i))) { in improve_bs()
112 if (mdl->is_true(unprocessed(i))) { in improve_bs()
218 switch (improve_step(mdl, unprocessed(i))) { in improve_step()
222 TRACE("opt", tout << "pruned " << mk_bounded_pp(unprocessed(i), m) << "\n";); in improve_step()
223 m_hardened.push_back(m.mk_not(unprocessed(i))); in improve_step()
225 m_unprocessed[k] = unprocessed(k + 1); in improve_step()
232 if (mdl->is_true(unprocessed(j))) { in improve_step()
236 … TRACE("opt", tout << "improved " << mk_bounded_pp(unprocessed(j), m) << "\n";); in improve_step()
237 m_hardened.push_back(unprocessed(j)); in improve_step()
241 m_unprocessed[k++] = unprocessed(j); in improve_step()
|
| /dports/math/moab/fathomteam-moab-7bde9dfb84a8/src/io/ |
| H A D | IODebugTrack.cpp | 85 Range unprocessed; in ~IODebugTrack() local
87 unprocessed.insert( 1, maxSize - 1 ); in ~IODebugTrack()
88 unprocessed = subtract( unprocessed, processed ); in ~IODebugTrack()
89 if (unprocessed.empty()) in ~IODebugTrack()
93 for (j = unprocessed.const_pair_begin(); j != unprocessed.const_pair_end(); ++j) { in ~IODebugTrack()
|
| /dports/devel/php-ice37/ice-3.7.2/cpp/src/Slice/ |
| H A D | Preprocessor.cpp | 371 string unprocessed; in printMakefileDependencies() local
375 unprocessed = string(buf); in printMakefileDependencies()
388 while((pos = unprocessed.find(" \\\n")) != string::npos) in printMakefileDependencies()
390 unprocessed.replace(pos, 3, "\n"); in printMakefileDependencies()
406 while((pos = unprocessed.find(".ice ", pos)) != string::npos) in printMakefileDependencies()
408 if(unprocessed.find(":", pos) == pos + 6) in printMakefileDependencies()
410 unprocessed.replace(pos, 5, ".ice\n"); in printMakefileDependencies()
417 unprocessed.replace(pos, 5, ".ice\n"); in printMakefileDependencies()
429 pos = unprocessed.find(suffix) + suffix.size(); in printMakefileDependencies()
433 result = unprocessed.substr(0, pos); in printMakefileDependencies()
[all …]
|
| /dports/devel/ice37/ice-3.7.2/cpp/src/Slice/ |
| H A D | Preprocessor.cpp | 371 string unprocessed; in printMakefileDependencies() local
375 unprocessed = string(buf); in printMakefileDependencies()
388 while((pos = unprocessed.find(" \\\n")) != string::npos) in printMakefileDependencies()
390 unprocessed.replace(pos, 3, "\n"); in printMakefileDependencies()
406 while((pos = unprocessed.find(".ice ", pos)) != string::npos) in printMakefileDependencies()
408 if(unprocessed.find(":", pos) == pos + 6) in printMakefileDependencies()
410 unprocessed.replace(pos, 5, ".ice\n"); in printMakefileDependencies()
417 unprocessed.replace(pos, 5, ".ice\n"); in printMakefileDependencies()
429 pos = unprocessed.find(suffix) + suffix.size(); in printMakefileDependencies()
433 result = unprocessed.substr(0, pos); in printMakefileDependencies()
[all …]
|
| /dports/devel/py-ice37/ice-3.7.2/cpp/src/Slice/ |
| H A D | Preprocessor.cpp | 371 string unprocessed; in printMakefileDependencies() local
375 unprocessed = string(buf); in printMakefileDependencies()
388 while((pos = unprocessed.find(" \\\n")) != string::npos) in printMakefileDependencies()
390 unprocessed.replace(pos, 3, "\n"); in printMakefileDependencies()
406 while((pos = unprocessed.find(".ice ", pos)) != string::npos) in printMakefileDependencies()
408 if(unprocessed.find(":", pos) == pos + 6) in printMakefileDependencies()
410 unprocessed.replace(pos, 5, ".ice\n"); in printMakefileDependencies()
417 unprocessed.replace(pos, 5, ".ice\n"); in printMakefileDependencies()
429 pos = unprocessed.find(suffix) + suffix.size(); in printMakefileDependencies()
433 result = unprocessed.substr(0, pos); in printMakefileDependencies()
[all …]
|
| /dports/games/7kaa/7kaa-2.15.4p1/src/ |
| H A D | OUNITAAT.cpp | 521 if(!unprocessed) in attack_unit()
535 while(unprocessed) in attack_unit()
579 err_when(unprocessed>2000 || unprocessed <0); in attack_unit()
795 err_when(unprocessed>2000 || unprocessed <0); in attack_firm()
796 while(unprocessed) in attack_firm()
841 err_when(unprocessed>2000 || unprocessed <0); in attack_firm()
1048 while(unprocessed) in attack_town()
1091 err_when(unprocessed>2000 || unprocessed <0); in attack_town()
1294 while(unprocessed) in attack_wall()
1337 err_when(unprocessed>2000 || unprocessed <0); in attack_wall()
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/storage/chunk/aws/ |
| H A D | mock.go | 30 unprocessed int member
45 func newMockDynamoDB(unprocessed int, provisionedErr int) *mockDynamoDBClient {
48 unprocessed: unprocessed,
97 if m.unprocessed > 0 {
98 m.unprocessed--
157 unprocessed := &dynamodb.KeysAndAttributes{
163 if m.unprocessed > 0 {
164 m.unprocessed--
165 unprocessed.Keys = append(unprocessed.Keys, readRequest)
166 resp.UnprocessedKeys[tableName] = unprocessed
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/chunk/aws/ |
| H A D | mock.go | 30 unprocessed int member
44 func newMockDynamoDB(unprocessed int, provisionedErr int) *mockDynamoDBClient {
47 unprocessed: unprocessed,
96 if m.unprocessed > 0 {
97 m.unprocessed--
156 unprocessed := &dynamodb.KeysAndAttributes{
162 if m.unprocessed > 0 {
163 m.unprocessed--
164 unprocessed.Keys = append(unprocessed.Keys, readRequest)
165 resp.UnprocessedKeys[tableName] = unprocessed
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/chunk/aws/ |
| H A D | mock.go | 30 unprocessed int member
44 func newMockDynamoDB(unprocessed int, provisionedErr int) *mockDynamoDBClient {
47 unprocessed: unprocessed,
96 if m.unprocessed > 0 {
97 m.unprocessed--
156 unprocessed := &dynamodb.KeysAndAttributes{
162 if m.unprocessed > 0 {
163 m.unprocessed--
164 unprocessed.Keys = append(unprocessed.Keys, readRequest)
165 resp.UnprocessedKeys[tableName] = unprocessed
|
| /dports/math/eprover/eprover-E-2.0/CONTROL/ |
| H A D | cco_forward_contraction.c | 469 ClauseSetDeleteNonUnits(state->unprocessed); in ProofStateFilterUnprocessed()
473 ClauseSetDeleteCopies(state->unprocessed); in ProofStateFilterUnprocessed()
478 state->unprocessed, in ProofStateFilterUnprocessed()
485 state->unprocessed, in ProofStateFilterUnprocessed()
492 state->unprocessed, in ProofStateFilterUnprocessed()
499 state->unprocessed, in ProofStateFilterUnprocessed()
506 state->unprocessed, in ProofStateFilterUnprocessed()
513 state->unprocessed, in ProofStateFilterUnprocessed()
|
| /dports/x11/alacritty/alacritty-0.9.0/alacritty_terminal/src/ |
| H A D | event_loop.rs | 219 let mut unprocessed = 0; in pty_read() localVariable
228 match self.pty.reader().read(&mut buf[unprocessed..]) { in pty_read()
230 Ok(0) if unprocessed == 0 => break, in pty_read()
231 Ok(got) => unprocessed += got, in pty_read()
235 if unprocessed == 0 { in pty_read()
248 None if unprocessed >= READ_BUFFER_SIZE => self.terminal.lock_unfair(), in pty_read()
256 writer.write_all(&buf[..unprocessed]).unwrap(); in pty_read()
260 for byte in &buf[..unprocessed] { in pty_read()
264 processed += unprocessed; in pty_read()
265 unprocessed = 0; in pty_read()
|
| /dports/audio/icecast-kh/icecast-kh-icecast-2.4.0-kh15/src/ |
| H A D | format.c | 164 int unprocessed = mpeg_complete_frames (&sync, r, 0); in format_check_frames() local
169 c->offset = bytes - (r->len + unprocessed); in format_check_frames()
187 int unprocessed = 0; in format_file_read() local
252 unprocessed = plugin->align_buffer (client, plugin); in format_file_read()
253 if (unprocessed == bytes) in format_file_read()
257 refbuf->len = unprocessed; in format_file_read()
258 unprocessed = 0; in format_file_read()
260 if (unprocessed < 0 || unprocessed > bytes) in format_file_read()
262 unprocessed = 0; in format_file_read()
266 client->intro_offset += (bytes - unprocessed); in format_file_read()
[all …]
|
| /dports/multimedia/scte35dump/scte35dump-0.1.6/cargo-crates/encoding-0.2.33/src/ |
| H A D | testutils.rs | 21 fn process_feed_ok<'a>(&mut self, processed: &Self::Input, unprocessed: &Self::Input, in process_feed_ok()
35 fn process_feed_ok<'a>(&mut self, processed: &[u8], unprocessed: &[u8], in process_feed_ok()
37 let mut input = Vec::with_capacity(processed.len() + unprocessed.len()); in process_feed_ok()
39 input.extend(unprocessed.iter().cloned()); in process_feed_ok()
96 fn process_feed_ok<'a>(&mut self, processed: &str, unprocessed: &str, in process_feed_ok()
98 let mut input = String::with_capacity(processed.len() + unprocessed.len()); in process_feed_ok()
100 input.push_str(unprocessed); in process_feed_ok()
170 ($this:expr, $processed:expr, $unprocessed:expr, $output:expr) => (
171 assert_expected!($this.process_feed_ok(&$processed, &$unprocessed, &$output),
|
| /dports/devel/sentry-cli/sentry-cli-1.71.0/cargo-crates/encoding-0.2.33/src/ |
| H A D | testutils.rs | 21 fn process_feed_ok<'a>(&mut self, processed: &Self::Input, unprocessed: &Self::Input, in process_feed_ok()
35 fn process_feed_ok<'a>(&mut self, processed: &[u8], unprocessed: &[u8], in process_feed_ok()
37 let mut input = Vec::with_capacity(processed.len() + unprocessed.len()); in process_feed_ok()
39 input.extend(unprocessed.iter().cloned()); in process_feed_ok()
96 fn process_feed_ok<'a>(&mut self, processed: &str, unprocessed: &str, in process_feed_ok()
98 let mut input = String::with_capacity(processed.len() + unprocessed.len()); in process_feed_ok()
100 input.push_str(unprocessed); in process_feed_ok()
170 ($this:expr, $processed:expr, $unprocessed:expr, $output:expr) => (
171 assert_expected!($this.process_feed_ok(&$processed, &$unprocessed, &$output),
|