Home
last modified time | relevance | path

Searched +full:override +full:- +full:pull (Results 1 – 25 of 392) sorted by relevance

12345678910>>...16

/third_party/mindspore/mindspore-src/source/mindspore/ccsrc/minddata/dataset/engine/datasetops/source/
Dmappable_leaf_op.h2 * Copyright 2021-2022 Huawei Technologies Co., Ltd
8 * http://www.apache.org/licenses/LICENSE-2.0
51 /// \param int32_t num_wkrs - Num of workers reading images in parallel
52 /// \param int32_t queue_size - connector queue size
53 /// \param td::unique_ptr<Sampler> sampler - sampler tells the source what to read
63 Status operator()() override;
67 std::string Name() const override { return "MappableLeafPp"; } in Name()
71 /// \param[in] path - The path of the image that needs to be decrypted.
72 /// \param[in] decrypt - Image decryption function. Default: None, no decryption.
73 /// \param[out] tensor - Returned tensor.
[all …]
Dgenerator_op.h2 * Copyright 2019-2023 Huawei Technologies Co., Ltd
8 * http://www.apache.org/licenses/LICENSE-2.0
52 /// \param out - The output stream to write output to
53 /// \param show_all - A bool to control if you want to show all info or just a summary
54 void Print(std::ostream &out, bool show_all) const override;
58 /// \param out - reference to the output stream being overloaded
59 /// \param generator_op - reference to the GeneratorOp to display
60 /// \return - the output stream must be returned
66 /// Class functor operator () override.
70 Status operator()() override;
[all …]
Dnonmappable_leaf_op.h2 * Copyright 2021-2023 Huawei Technologies Co., Ltd
8 * http://www.apache.org/licenses/LICENSE-2.0
56 // @param num_workers - number of worker threads reading data from tf_file files.
57 // @param worker_connector_size - size of each internal queue.
58 // @param total_num_rows - Number of rows to read
59 // @param dataset_files_list - list of filepaths for the dataset files.
60 …// @param op_connector_size - size of each queue in the connector that the child operator pulls fr…
61 // @param columns_to_load - the names of the columns to load data from.
62 // @param shuffle_files - whether or not to shuffle the files before reading data.
63 // @param equal_rows_per_shard - whether or not to get equal rows for each process.
[all …]
Dmindrecord_op.h2 * Copyright 2019-2022 Huawei Technologies Co., Ltd
8 * http://www.apache.org/licenses/LICENSE-2.0
57 // @param num_mind_record_workers - The number of workers for the op (run by ShardReader)
58 // @param dataset_file - dataset files
59 // @param op_connector_queue_size - The output connector queue size
60 // @param columns_to_load - The list of columns to use (column name)
61 // @param operators - ShardOperators for Shuffle, Category, Sample
62 // @param sampler - sampler tells MindRecordOp what to read
71 ~MindRecordOp() override;
74 /// @param out - The output stream to write output to
[all …]
/third_party/mindspore/mindspore-src/source/mindspore/ccsrc/minddata/dataset/engine/datasetops/
Dshuffle_op.h2 * Copyright 2019-2023 Huawei Technologies Co., Ltd
8 * http://www.apache.org/licenses/LICENSE-2.0
51 // @param shuffle_size - The size for the shuffle buffer
52 // @param shuffle_seed - The seed to use for random number generation
53 // @param op_connector_size - The output connector queue size
60 // @param out - The output stream to write output to
61 // @param show_all - A bool to control if you want to show all info or just a summary
62 void Print(std::ostream &out, bool show_all) const override;
66 // @param out - reference to the output stream being overloaded
67 // @param so - reference to the ShuffleOp to display
[all …]
Dtake_op.h2 * Copyright 2020-2023 Huawei Technologies Co., Ltd
8 * http://www.apache.org/licenses/LICENSE-2.0
31 // @param count - The number of takes to do
38 // \param[in] out - The output stream to write output to
39 // \param[in] show_all - A bool to control if you want to show all info or just a summary
40 void Print(std::ostream &out, bool show_all) const override;
44 // \param[in] out - reference to the output stream being overloaded
45 // \param[in] ro - reference to the TakeOp to display
46 // @return - the output stream must be returned
55 Status operator()() override;
[all …]
Dzip_op.h2 * Copyright 2019-2023 Huawei Technologies Co., Ltd
8 * http://www.apache.org/licenses/LICENSE-2.0
36 // @param op_connector_size - connector size
42 Status EofReceived(int32_t) override;
44 Status EoeReceived(int32_t) override;
47 // \param[in] out - output stream to print to
48 // \param[in] show_all - if it should print everything
49 void Print(std::ostream &out, bool show_all) const override;
57 // Class functor operator () override.
61 Status operator()() override;
[all …]
Depoch_ctrl_op.h2 * Copyright 2020-2023 Huawei Technologies Co., Ltd
8 * http://www.apache.org/licenses/LICENSE-2.0
35 // @param out - The output stream to write output to
36 // @param show_all - A bool to control if you want to show all info or just a summary
37 void Print(std::ostream &out, bool show_all) const override;
38 std::string Name() const override { return kEpochCtrlOp; } in Name()
45 Status GetNextRow(TensorRow *row) override;
47 // Base-class override for handling cases when an eoe is received.
48 // @param worker_id - The worker id
49 Status EoeReceived(int32_t worker_id) override;
[all …]
Drename_op.h2 * Copyright 2019-2023 Huawei Technologies Co., Ltd
8 * http://www.apache.org/licenses/LICENSE-2.0
44 void Print(std::ostream &out, bool show_all) const override;
52 // Class functor operator () override.
56 Status operator()() override;
60 std::string Name() const override { return kRenameOp; } in Name()
63 /// \param row[out] - Fetched TensorRow
65 Status GetNextRow(TensorRow *row) override;
67 /// \brief In pull mode, gets the next row
68 /// \param row[out] - Fetched TensorRow
[all …]
Drepeat_op.h2 * Copyright 2019-2021 Huawei Technologies Co., Ltd
8 * http://www.apache.org/licenses/LICENSE-2.0
31 // @param count - The number of repeats to do
38 // @param out - The output stream to write output to
39 // @param show_all - A bool to control if you want to show all info or just a summary
40 void Print(std::ostream &out, bool show_all) const override;
44 // @param out - reference to the output stream being overloaded
45 // @param ro - reference to the RepeatOp to display
46 // @return - the output stream must be returned
52 // Class functor operator () override.
[all …]
Dsend_bridge_op.h8 * http://www.apache.org/licenses/LICENSE-2.0
58 void Print(std::ostream &out, bool show_all) const override;
70 // Class functor operator () override.
74 // op's Connector and distributes them to the local queues. Workers pull from the local queues.
76 Status operator()() override;
80 std::string Name() const override { return kSendBridgeOp; } in Name()
85 Status SendQuitFlagToWorker(int32_t worker_id) override;
87 Status GetNextRowPullMode(TensorRow *const row) override;
98 Status WorkerEntry(int32_t worker_id) override; // In: workerId assigned by tree_
106 /// \brief Gets the implementation status for operator in pull mode
[all …]
Dreceive_bridge_op.h8 * http://www.apache.org/licenses/LICENSE-2.0
64 void Print(std::ostream &out, bool show_all) const override;
76 // Class functor operator () override.
80 // op's Connector and distributes them to the local queues. Workers pull from the local queues.
82 Status operator()() override;
86 std::string Name() const override { return kReceiveBridgeOp; } in Name()
91 Status SendQuitFlagToWorker(int32_t worker_id) override;
93 Status GetNextRowPullMode(TensorRow *const row) override;
108 Status WorkerEntry(int32_t worker_id) override; // In: workerId assigned by tree_
117 /// \brief Gets the implementation status for operator in pull mode
[all …]
Dskip_op.h2 * Copyright 2020-2022 Huawei Technologies Co., Ltd
8 * http://www.apache.org/licenses/LICENSE-2.0
31 // @param count - The number of skips to do
38 // @param out - The output stream to write output to
39 // @param show_all - A bool to control if you want to show all info or just a summary
40 void Print(std::ostream &out, bool show_all) const override;
42 // Class functor operator () override.
46 Status operator()() override;
50 std::string Name() const override { return kSkipOp; } in Name()
51 Status GetNextRow(TensorRow *row) override;
[all …]
Dproject_op.h2 * Copyright 2019-2023 Huawei Technologies Co., Ltd
8 * http://www.apache.org/licenses/LICENSE-2.0
30 // @param columnsToProject -
37 // @param out - The output stream to write output to.
38 // @param show_all - A bool to control if you want to show all info or just a summary.
39 void Print(std::ostream &out, bool show_all) const override;
43 // @param out - reference to the output stream being overloaded.
44 // @param project_op - reference to the ProjectOp to display.
45 // @return - the output stream must be returned.
51 // Class functor operator () override.
[all …]
/third_party/mindspore/mindspore-src/source/mindspore/ccsrc/minddata/dataset/engine/consumers/
Dpull_based_tree_consumer.h2 * Copyright 2021-2023 Huawei Technologies Co., Ltd
8 * http://www.apache.org/licenses/LICENSE-2.0
33 /// Consumer that iterates over the dataset and returns the rows one by one as a in a pull based fa…
41 ~PullBasedIteratorConsumer() override = default;
43 Status Init(const std::shared_ptr<DatasetNode> &root) override;
54 Status GetNextAsVector(std::vector<TensorPtr> *const out) override;
59 Status GetNextAsMap(std::unordered_map<std::string, TensorPtr> *const out) override;
64 …extAsOrderedPair(std::vector<std::pair<std::string, std::shared_ptr<Tensor>>> *const vec) override;
67 /// \note Reset is NOT supported for pull-based iterators.
71 Status Reset(int64_t step, int64_t dataset_size) override { in Reset()
[all …]
/third_party/skia/third_party/externals/angle2/src/compiler/translator/
DASTMetadataHLSL.cpp3 // Use of this source code is governed by a BSD-style license that can be
35 ASSERT(index < metadataList->size()); in PullGradient()
56 node->traverse(this); in traverse()
63 mMetadata->mUsesGradient = true; in onGradient()
67 mMetadata->mControlFlowsContainingGradient.insert(mParents.back()); in onGradient()
82 if (mMetadata->mControlFlowsContainingGradient.count(node) > 0 && !mParents.empty()) in visitControlFlow()
84 mMetadata->mControlFlowsContainingGradient.insert(mParents.back()); in visitControlFlow()
89 bool visitLoop(Visit visit, TIntermLoop *loop) override in visitLoop()
95 bool visitIfElse(Visit visit, TIntermIfElse *ifElse) override in visitIfElse()
101 bool visitAggregate(Visit visit, TIntermAggregate *node) override in visitAggregate()
[all …]
/third_party/grpc/src/core/resolver/
Dresolver.h8 // http://www.apache.org/licenses/LICENSE-2.0
39 /// This interface is designed to support both push-based and pull-based
40 /// mechanisms. A push-based mechanism is one where the resolver will
43 /// with the name changes. A pull-based mechanism is one where the resolver
57 /// An optional human-readable note describing context about the resolution,
60 /// has a non-OK status. For example, a resolver that returns an empty
67 // If non-null, this callback will be invoked when the LB policy has
70 // resolvers, if the reported status is non-OK, then the resolver
93 ~Resolver() override = default;
101 /// This is useful for pull-based implementations to decide when to
[all …]
/third_party/typescript/.github/workflows/
Dcodeql.yml1 name: "Code scanning - action"
7 - cron: '0 19 * * 0'
10 CodeQL-Build:
12 # CodeQL runs on ubuntu-latest and windows-latest
13 runs-on: ubuntu-latest
16 - name: Checkout repository
20 # a pull request then we can checkout the head.
21 fetch-depth: 2
23 # If this run was triggered by a pull request event, then checkout
24 # the head of the pull request instead of the merge commit.
[all …]
/third_party/elfio/.github/workflows/
Dcodeql-analysis.yml10 - cron: '0 15 * * 5'
15 runs-on: ubuntu-latest
18 fail-fast: false
20 # Override automatic language detection by changing the below list
24 …b.com/en/github/finding-security-vulnerabilities-and-errors-in-your-code/configuring-code-scanning…
27 - name: Checkout repository
31 # a pull request then we can checkout the head.
32 fetch-depth: 2
34 # If this run was triggered by a pull request event, then checkout
35 # the head of the pull request instead of the merge commit.
[all …]
/third_party/skia/third_party/externals/oboe/src/flowgraph/
DFlowGraphNode.h8 * http://www.apache.org/licenses/LICENSE-2.0
39 // run-time deallocation in audio thread.
122 * Set false if you want to pull the data from the input ports in the onProcess() method.
141 static constexpr int64_t kInitialCallCount = -1;
168 // Ports are often declared public. So let's make them non-copyable.
189 * This port contains a 32-bit float buffer that can contain several frames of data.
255 * That may pull data from its inputs and recursively
259 int32_t pullData(int64_t framePosition, int32_t numFrames) override;
262 void pullReset() override;
277 // Add to parent so it can pull data from each input. in FlowGraphPortFloatInput()
[all …]
/third_party/flatbuffers/snap/
Dsnapcraft.yaml3 adopt-info: flatc
25 - -GUnix Makefiles
26 - -DCMAKE_BUILD_TYPE=Release
27 build-packages:
28 - g++
29 - git
30 override-pull: |
31 snapcraftctl pull
32 tag=$(git describe --tags --abbrev=0)
33 count=$(git rev-list $tag.. --count)
[all …]
/third_party/grpc/test/core/call/
Dclient_call_test.cc7 // http://www.apache.org/licenses/LICENSE-2.0
41 return authority_.has_value() ? absl::optional<Slice>(authority_->Copy()) in authority()
69 auto arena = SimpleArenaAllocator()->MakeArena(); in InitCall()
70 arena->SetContext<grpc_event_engine::experimental::EventEngine>( in InitCall()
83 // Pull in CqVerifier types for ergonomics
91 cq_verifier_->Expect(CqVerifier::tag(tag), std::move(result), whence);
98 cq_verifier_->VerifyEmpty(timeout.value_or(Duration::Seconds(1)), whence);
102 cq_verifier_->Verify(
118 void Orphaned() override {} in Orphaned()
119 void StartCall(UnstartedCallHandler handler) override { in StartCall()
[all …]
/third_party/rust/rust/src/tools/miri/
DREADME.md4 [mid-level intermediate representation][mir] (MIR). It can run binaries and
6 [undefined behavior](https://doc.rust-lang.org/reference/behavior-considered-undefined.html),
9 * Out-of-bounds memory accesses and use-after-free
31 byte-level data manipulation works correctly both on little-endian and
32 big-endian systems. See
33 [cross-interpretation](#cross-interpretation-running-for-different-targets)
36 Miri has already discovered some [real-world bugs](#bugs-found-by-miri). If you
44 `MIRIFLAGS="-Zmiri-disable-isolation"` to access the real system APIs instead.
54 means a guarantee that it is UB-free when these questions get answered.
58 still run fine in Miri -- but might break (including causing UB) on different
[all …]
/third_party/mindspore/mindspore-src/source/mindspore/ccsrc/minddata/dataset/engine/datasetops/map_op/
Dmap_op.h2 * Copyright 2019-2022 Huawei Technologies Co., Ltd
8 * http://www.apache.org/licenses/LICENSE-2.0
92 void Print(std::ostream &out, bool show_all) const override;
104 // Class functor operator () override.
108 // op's Connector and distributes them to the local queues. Workers pull from the local queues.
110 Status operator()() override;
114 std::string Name() const override { return kMapOp; } in Name()
119 Status SendWaitFlagToWorker(int32_t worker_id) override;
124 Status SendQuitFlagToWorker(int32_t worker_id) override;
127 // @Return the vector of tensor ops by non-const reference
[all …]
/third_party/grpc/src/ruby/ext/grpc/
Dextconf.rb7 # http://www.apache.org/licenses/LICENSE-2.0
24 cross_compiling = ENV['RCD_HOST_RUBY_VERSION'] # set by rake-compiler-dock in build containers
43 # rake-compiler-dock sets the -s LDFLAG when building rubies for
44 # cross compilation, and this -s flag propagates into RbConfig. Stripping
49 flags = flags.reject {|flag| flag == '-s'}
76 # build grpc C-core
95 ENV['ARFLAGS'] = '-o'
98 # Don't embed on TruffleRuby (constant-time crypto is unsafe with Sulong, slow build times)
106 ENV['ARCH_FLAGS'] = '-arch arm64'
108 ENV['ARCH_FLAGS'] = '-arch i386 -arch x86_64'
[all …]

12345678910>>...16