/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/nomad/drainer/ |
H A D | drain_heap_test.go | 32 case batch = <-h.NextBatch(): 59 case batch = <-h.NextBatch(): 87 case batch = <-h.NextBatch(): 123 case batch = <-h.NextBatch(): 135 case batch = <-h.NextBatch(): 146 case <-h.NextBatch(): 163 case batch = <-h.NextBatch(): 174 case batch = <-h.NextBatch():
|
H A D | drain_heap.go | 14 NextBatch() <-chan []string methodSpec 136 func (d *deadlineHeap) NextBatch() <-chan []string { func
|
/dports/sysutils/nomad/nomad-1.1.0/nomad/drainer/ |
H A D | drain_heap_test.go | 32 case batch = <-h.NextBatch(): 59 case batch = <-h.NextBatch(): 87 case batch = <-h.NextBatch(): 123 case batch = <-h.NextBatch(): 135 case batch = <-h.NextBatch(): 146 case <-h.NextBatch(): 163 case batch = <-h.NextBatch(): 174 case batch = <-h.NextBatch():
|
H A D | drain_heap.go | 14 NextBatch() <-chan []string methodSpec 136 func (d *deadlineHeap) NextBatch() <-chan []string { func
|
/dports/devel/grpc/grpc-1.42.0/test/core/transport/binder/ |
H A D | transport_stream_receiver_test.cc | 158 MockOpBatch NextBatch(int flag) const { in NextBatch() function in grpc_binder::__anon610339f40111::MockOpBatch 232 MockOpBatch t1 = t0.NextBatch(kFlagMessageData); in TEST_F() 233 MockOpBatch t2 = t1.NextBatch(kFlagSuffix); in TEST_F() 247 MockOpBatch t1 = t0.NextBatch(kFlagMessageData); in TEST_F() 250 MockOpBatch t2 = t1.NextBatch(kFlagMessageData); in TEST_F() 253 MockOpBatch t3 = t2.NextBatch(kFlagMessageData); in TEST_F() 254 MockOpBatch t4 = t3.NextBatch(kFlagMessageData); in TEST_F() 264 MockOpBatch t1 = t0.NextBatch(kFlagMessageData); in TEST_F() 265 MockOpBatch t2 = t1.NextBatch(kFlagMessageData); in TEST_F() 266 MockOpBatch t3 = t2.NextBatch(kFlagSuffix); in TEST_F()
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/matrix-org/gomatrix/ |
H A D | store.go | 24 NextBatch map[string]string member 40 s.NextBatch[userID] = nextBatchToken 45 return s.NextBatch[userID] 62 NextBatch: make(map[string]string),
|
H A D | responses.go | 29 NextBatch string `json:"next_batch"` member 165 NextBatch string `json:"next_batch"` member
|
/dports/net-im/matterbridge/matterbridge-1.22.3/vendor/github.com/matrix-org/gomatrix/ |
H A D | store.go | 24 NextBatch map[string]string member 40 s.NextBatch[userID] = nextBatchToken 45 return s.NextBatch[userID] 62 NextBatch: make(map[string]string),
|
H A D | responses.go | 29 NextBatch string `json:"next_batch"` member 165 NextBatch string `json:"next_batch"` member
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/gotools/src/github.com/mongodb/mongo-tools/mongoreplay/ |
H A D | raw_op.go | 66 NextBatch bson.Raw `bson:"nextBatch,omitempty"` 105 case commandReply.Cursor.NextBatch.Data != nil: 106 commandReply.Cursor.NextBatch.Data, _ = bson.Marshal([0]byte{})
|
H A D | util.go | 112 NextBatch []bson.Raw `bson:"nextBatch"` 122 } else if len(doc.Cursor.NextBatch) != 0 { 123 return doc.Cursor.NextBatch, nil
|
/dports/databases/mongodb42-tools/mongo-tools-r4.2.17/mongoreplay/ |
H A D | raw_op.go | 66 NextBatch bson.Raw `bson:"nextBatch,omitempty"` 105 case commandReply.Cursor.NextBatch.Data != nil: 106 commandReply.Cursor.NextBatch.Data, _ = bson.Marshal([0]byte{})
|
H A D | util.go | 112 NextBatch []bson.Raw `bson:"nextBatch"` 122 } else if len(doc.Cursor.NextBatch) != 0 { 123 return doc.Cursor.NextBatch, nil
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/cpp/src/parquet/arrow/ |
H A D | reader.cc | 193 return reader->NextBatch(records_to_read, out); in ReadSchemaField() 233 return flat_column_reader->NextBatch(records_to_read, out); in ReadColumn() 342 RETURN_NOT_OK(field_readers_[i]->NextBatch(batch_size_, &columns[i])); in ReadNext() 427 Status NextBatch(int64_t records_to_read, std::shared_ptr<ChunkedArray>* out) override { in NextBatch() function in parquet::arrow::LeafReader 487 Status NextBatch(int64_t records_to_read, std::shared_ptr<ChunkedArray>* out) override { in NextBatch() function in parquet::arrow::NestedListReader 492 RETURN_NOT_OK(item_reader_->NextBatch(records_to_read, out)); in NextBatch() 540 Status NextBatch(int64_t records_to_read, std::shared_ptr<ChunkedArray>* out) override; 665 Status StructReader::NextBatch(int64_t records_to_read, in NextBatch() function in parquet::arrow::StructReader 678 RETURN_NOT_OK(child->NextBatch(records_to_read, &field)); in NextBatch()
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/matrix-org/gomatrixserverlib/ |
H A D | federationtypes.go | 183 NextBatch string `json:"next_batch,omitempty"` member 953 NextBatch string `json:"next_batch"` member 973 NextBatch string `json:"next_batch"` 980 r.NextBatch = intermediate.NextBatch 1020 NextBatch string `json:"next_batch"` member
|
/dports/net-im/dendrite/dendrite-0.5.1/syncapi/sync/ |
H A D | requestpool.go | 167 syncReq.Response.NextBatch = syncReq.Since 191 syncReq.Response.NextBatch = types.StreamingToken{ 216 syncReq.Response.NextBatch = types.StreamingToken{
|
/dports/misc/py-tvm/incubator-tvm-0.6.1/3rdparty/dmlc-core/src/io/ |
H A D | indexed_recordio_split.cc | 156 return this->NextBatch(out_chunk, batch_size_); in NextChunk() 214 bool IndexedRecordIOSplitter::NextBatch(Blob *out_chunk, size_t batch_size) { in NextBatch() function in dmlc::io::IndexedRecordIOSplitter
|
H A D | indexed_recordio_split.h | 48 bool NextBatch(Blob *out_chunk, size_t n_records) override;
|
/dports/devel/dmlc-core/dmlc-core-0.3-123-gb3a4c71/src/io/ |
H A D | indexed_recordio_split.cc | 156 return this->NextBatch(out_chunk, batch_size_); in NextChunk() 214 bool IndexedRecordIOSplitter::NextBatch(Blob *out_chunk, size_t batch_size) { in NextBatch() function in dmlc::io::IndexedRecordIOSplitter
|
H A D | indexed_recordio_split.h | 48 bool NextBatch(Blob *out_chunk, size_t n_records) override;
|
/dports/security/vault/vault-1.8.2/vendor/go.mongodb.org/mongo-driver/mongo/integration/mtest/ |
H A D | deployment_helpers.go | 19 NextBatch BatchIdentifier = "nextBatch" const
|
/dports/net-mgmt/semaphore/semaphore-2.6.8/vendor/go.mongodb.org/mongo-driver/mongo/integration/mtest/ |
H A D | deployment_helpers.go | 19 NextBatch BatchIdentifier = "nextBatch" const
|
/dports/www/grafana8/grafana-8.3.6/vendor/go.mongodb.org/mongo-driver/mongo/integration/mtest/ |
H A D | deployment_helpers.go | 19 NextBatch BatchIdentifier = "nextBatch" const
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/go.mongodb.org/mongo-driver/mongo/integration/mtest/ |
H A D | deployment_helpers.go | 19 NextBatch BatchIdentifier = "nextBatch" const
|
/dports/databases/mongodb42-tools/mongo-tools-r4.2.17/vendor/go.mongodb.org/mongo-driver/mongo/integration/mtest/ |
H A D | deployment_helpers.go | 19 NextBatch BatchIdentifier = "nextBatch" const
|