Home
last modified time | relevance | path

Searched refs:NextBatch (Results 1 – 25 of 53) sorted by relevance

123

/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/nomad/drainer/
H A Ddrain_heap_test.go32 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 Ddrain_heap.go14 NextBatch() <-chan []string methodSpec
136 func (d *deadlineHeap) NextBatch() <-chan []string { func
/dports/sysutils/nomad/nomad-1.1.0/nomad/drainer/
H A Ddrain_heap_test.go32 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 Ddrain_heap.go14 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 Dtransport_stream_receiver_test.cc158 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 Dstore.go24 NextBatch map[string]string member
40 s.NextBatch[userID] = nextBatchToken
45 return s.NextBatch[userID]
62 NextBatch: make(map[string]string),
H A Dresponses.go29 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 Dstore.go24 NextBatch map[string]string member
40 s.NextBatch[userID] = nextBatchToken
45 return s.NextBatch[userID]
62 NextBatch: make(map[string]string),
H A Dresponses.go29 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 Draw_op.go66 NextBatch bson.Raw `bson:"nextBatch,omitempty"`
105 case commandReply.Cursor.NextBatch.Data != nil:
106 commandReply.Cursor.NextBatch.Data, _ = bson.Marshal([0]byte{})
H A Dutil.go112 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 Draw_op.go66 NextBatch bson.Raw `bson:"nextBatch,omitempty"`
105 case commandReply.Cursor.NextBatch.Data != nil:
106 commandReply.Cursor.NextBatch.Data, _ = bson.Marshal([0]byte{})
H A Dutil.go112 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 Dreader.cc193 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 Dfederationtypes.go183 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 Drequestpool.go167 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 Dindexed_recordio_split.cc156 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 Dindexed_recordio_split.h48 bool NextBatch(Blob *out_chunk, size_t n_records) override;
/dports/devel/dmlc-core/dmlc-core-0.3-123-gb3a4c71/src/io/
H A Dindexed_recordio_split.cc156 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 Dindexed_recordio_split.h48 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 Ddeployment_helpers.go19 NextBatch BatchIdentifier = "nextBatch" const
/dports/net-mgmt/semaphore/semaphore-2.6.8/vendor/go.mongodb.org/mongo-driver/mongo/integration/mtest/
H A Ddeployment_helpers.go19 NextBatch BatchIdentifier = "nextBatch" const
/dports/www/grafana8/grafana-8.3.6/vendor/go.mongodb.org/mongo-driver/mongo/integration/mtest/
H A Ddeployment_helpers.go19 NextBatch BatchIdentifier = "nextBatch" const
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/go.mongodb.org/mongo-driver/mongo/integration/mtest/
H A Ddeployment_helpers.go19 NextBatch BatchIdentifier = "nextBatch" const
/dports/databases/mongodb42-tools/mongo-tools-r4.2.17/vendor/go.mongodb.org/mongo-driver/mongo/integration/mtest/
H A Ddeployment_helpers.go19 NextBatch BatchIdentifier = "nextBatch" const

123