| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/ |
| D | writing.cc | 322 s_(s), in DataSendContext()
323 sending_bytes_before_(s_->sending_bytes) {} in DataSendContext()
327 0, s_->flow_control->remote_window_delta() + in stream_remote_window()
342 max_outgoing(), s_->flow_controlled_buffer.length); in FlushUncompressedBytes()
343 is_last_frame_ = send_bytes == s_->flow_controlled_buffer.length && in FlushUncompressedBytes()
344 s_->fetching_send_message == nullptr && in FlushUncompressedBytes()
345 s_->send_trailing_metadata != nullptr && in FlushUncompressedBytes()
346 grpc_metadata_batch_is_empty(s_->send_trailing_metadata); in FlushUncompressedBytes()
347 grpc_chttp2_encode_data(s_->id, &s_->flow_controlled_buffer, send_bytes, in FlushUncompressedBytes()
348 is_last_frame_, &s_->stats.outgoing, &t_->outbuf); in FlushUncompressedBytes()
[all …]
|
| /external/tensorflow/tensorflow/c/ |
| D | while_loop_test.cc | 28 CApiWhileLoopTest() : s_(TF_NewStatus()), graph_(TF_NewGraph()) {} in CApiWhileLoopTest()
32 TF_DeleteStatus(s_); in ~CApiWhileLoopTest()
41 graph_, s_, ::tensorflow::strings::StrCat("p", i).c_str()); in Init()
42 DCHECK_EQ(TF_OK, TF_GetCode(s_)) << TF_Message(s_); in Init()
49 TF_NewWhile(graph_, &inputs_[0], inputs_.size(), s_))); in Init()
50 ASSERT_EQ(TF_OK, TF_GetCode(s_)) << TF_Message(s_); in Init()
61 TF_FinishWhile(params_.get(), s_, &outputs_[0]); in ExpectOK()
62 EXPECT_EQ(TF_OK, TF_GetCode(s_)) << TF_Message(s_); in ExpectOK()
66 TF_FinishWhile(params_.get(), s_, &outputs_[0]); in ExpectError()
67 EXPECT_EQ(expected_code, TF_GetCode(s_)); in ExpectError()
[all …]
|
| D | c_api_function_test.cc | 66 : s_(TF_NewStatus()), in CApiFunctionTest()
77 TF_DeleteStatus(s_); in ~CApiFunctionTest()
92 CSession csession(host_graph_, s_); in RunT()
93 ASSERT_EQ(TF_OK, TF_GetCode(s_)) << TF_Message(s_); in RunT()
98 csession.Run(s_); in RunT()
99 ASSERT_EQ(TF_OK, TF_GetCode(s_)) << TF_Message(s_); in RunT()
117 CSession csession(host_graph_, s_); in Run()
118 ASSERT_EQ(TF_OK, TF_GetCode(s_)) << TF_Message(s_); in Run()
122 csession.Run(s_); in Run()
123 ASSERT_EQ(TF_OK, TF_GetCode(s_)) << TF_Message(s_); in Run()
[all …]
|
| D | c_api_test.cc | 1233 CApiColocationTest() : s_(TF_NewStatus()), graph_(TF_NewGraph()) {} in CApiColocationTest()
1236 feed1_ = Placeholder(graph_, s_, "feed1"); in SetUp()
1237 ASSERT_EQ(TF_OK, TF_GetCode(s_)) << TF_Message(s_); in SetUp()
1239 feed2_ = Placeholder(graph_, s_, "feed2"); in SetUp()
1240 ASSERT_EQ(TF_OK, TF_GetCode(s_)) << TF_Message(s_); in SetUp()
1242 constant_ = ScalarConst(10, graph_, s_); in SetUp()
1243 ASSERT_EQ(TF_OK, TF_GetCode(s_)) << TF_Message(s_); in SetUp()
1252 TF_DeleteStatus(s_); in ~CApiColocationTest()
1273 bytes.size(), s_); in SetViaProto()
1274 ASSERT_EQ(TF_OK, TF_GetCode(s_)) << TF_Message(s_); in SetViaProto()
[all …]
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| D | writing.cc | 318 s_(s), in DataSendContext()
319 sending_bytes_before_(s_->sending_bytes) {} in DataSendContext()
323 0, s_->flow_control->remote_window_delta() + in stream_remote_window()
338 max_outgoing(), s_->compressed_data_buffer.length); in FlushCompressedBytes()
340 (send_bytes == s_->compressed_data_buffer.length && in FlushCompressedBytes()
341 s_->flow_controlled_buffer.length == 0 && in FlushCompressedBytes()
342 s_->fetching_send_message == nullptr); in FlushCompressedBytes()
343 if (is_last_data_frame && s_->send_trailing_metadata != nullptr && in FlushCompressedBytes()
344 s_->stream_compression_ctx != nullptr) { in FlushCompressedBytes()
346 s_->stream_compression_ctx, &s_->flow_controlled_buffer, in FlushCompressedBytes()
[all …]
|
| /external/perfetto/src/base/ |
| D | subprocess_windows.cc | 64 s_->stdin_pipe = Pipe::Create(); in Start()
67 ::SetHandleInformation(*s_->stdin_pipe.rd, HANDLE_FLAG_INHERIT, 1)); in Start()
70 s_->stdouterr_pipe = Pipe::Create(); in Start()
72 ::SetHandleInformation(*s_->stdouterr_pipe.wr, HANDLE_FLAG_INHERIT, 1)); in Start()
90 start_info.hStdError = *s_->stdouterr_pipe.wr; in Start()
104 start_info.hStdOutput = *s_->stdouterr_pipe.wr; in Start()
115 start_info.hStdInput = *s_->stdin_pipe.rd; in Start()
132 s_->stdin_pipe.rd.reset(); in Start()
133 s_->stdouterr_pipe.wr.reset(); in Start()
137 s_->returncode = ERROR_FILE_NOT_FOUND; in Start()
[all …]
|
| D | subprocess_posix.cc | 214 s_->stdin_pipe = base::Pipe::Create(base::Pipe::kWrNonBlock); in Start()
215 proc_args.stdin_pipe_rd = *s_->stdin_pipe.rd; in Start()
216 s_->stdouterr_pipe = base::Pipe::Create(base::Pipe::kRdNonBlock); in Start()
217 proc_args.stdouterr_pipe_wr = *s_->stdouterr_pipe.wr; in Start()
220 s_->pid = fork(); in Start()
221 PERFETTO_CHECK(s_->pid >= 0); in Start()
222 if (s_->pid == 0) { in Start()
224 s_->stdin_pipe.wr.reset(); in Start()
225 s_->stdouterr_pipe.rd.reset(); in Start()
231 s_->status = kRunning; in Start()
[all …]
|
| D | subprocess.cc | 31 : args(a), s_(new MovableState()) {} in Subprocess()
37 s_ = std::move(other.s_); in Subprocess()
41 other.s_.reset(new MovableState()); in Subprocess()
53 if (s_->status == kRunning) in ~Subprocess()
58 PERFETTO_CHECK(s_->status == kNotStarted); in Call()
62 s_->timed_out = true; in Call()
65 PERFETTO_DCHECK(s_->status != kRunning); in Call()
66 return s_->status == kTerminated && s_->returncode == 0; in Call()
|
| /external/libtextclassifier/native/utils/base/ |
| D | status_macros.h | 31 explicit StatusAdapter(const Status& s) : s_(s) {} in StatusAdapter()
32 explicit StatusAdapter(Status&& s) : s_(std::move(s)) {} in StatusAdapter()
34 explicit StatusAdapter(const StatusOr<T>& s) : s_(s.status()) {} in StatusAdapter()
36 explicit StatusAdapter(StatusOr<T>&& s) : s_(std::move(s).status()) {} in StatusAdapter()
38 bool ok() const { return s_.ok(); } in ok()
41 const Status& status() const& { return s_; } in status()
42 Status status() && { return std::move(s_); } in status()
45 Status s_;
|
| /external/icing/icing/text_classifier/lib3/utils/base/ |
| D | status_macros.h | 29 explicit StatusAdapter(const Status& s) : s_(s) {} in StatusAdapter()
30 explicit StatusAdapter(Status&& s) : s_(std::move(s)) {} in StatusAdapter()
32 explicit StatusAdapter(const StatusOr<T>& s) : s_(s.status()) {} in StatusAdapter()
34 explicit StatusAdapter(StatusOr<T>&& s) : s_(std::move(s).status()) {} in StatusAdapter()
36 bool ok() const { return s_.ok(); } in ok()
39 const Status& status() const& { return s_; } in status()
40 Status status() && { return std::move(s_); } in status()
43 Status s_;
|
| /external/ruy/ruy/ |
| D | ruy_test.bzl | 7 name = "%s_%s_%s_%s_%s" % (name, lhs, rhs, accum, dst),
23 name = "%s_%s_%s_%s_%s" % (name, lhs, rhs, accum, dst),
|
| /external/perfetto/include/perfetto/ext/base/ |
| D | subprocess.h | 197 PlatformProcessId pid() const { return s_->pid; } in pid()
203 Status status() const { return s_->status; } in status()
204 int returncode() const { return s_->returncode; } in returncode()
205 bool timed_out() const { return s_->timed_out; } in timed_out()
209 std::string& output() { return s_->output; } in output()
210 const std::string& output() const { return s_->output; } in output()
212 const ResourceUsage& posix_rusage() const { return *s_->rusage; } in posix_rusage()
261 std::unique_ptr<MovableState> s_; variable
|
| /external/abseil-cpp/absl/strings/internal/ |
| D | ostringstream.h | 70 explicit OStringStream(std::string* s) : std::ostream(this), s_(s) {} in OStringStream()
72 std::string* str() { return s_; } in str()
73 const std::string* str() const { return s_; } in str()
74 void str(std::string* s) { s_ = s; } in str()
82 std::string* s_; variable
|
| D | ostringstream.cc | 22 assert(s_); in overflow()
24 s_->push_back(static_cast<char>(c)); in overflow()
29 assert(s_); in xsputn()
30 s_->append(s, n); in xsputn()
|
| /external/webrtc/third_party/abseil-cpp/absl/strings/internal/ |
| D | ostringstream.h | 70 explicit OStringStream(std::string* s) : std::ostream(this), s_(s) {} in OStringStream()
72 std::string* str() { return s_; } in str()
73 const std::string* str() const { return s_; } in str()
74 void str(std::string* s) { s_ = s; } in str()
82 std::string* s_; variable
|
| D | ostringstream.cc | 22 assert(s_); in overflow()
24 s_->push_back(static_cast<char>(c)); in overflow()
29 assert(s_); in xsputn()
30 s_->append(s, n); in xsputn()
|
| /external/angle/third_party/abseil-cpp/absl/strings/internal/ |
| D | ostringstream.h | 70 explicit OStringStream(std::string* s) : std::ostream(this), s_(s) {} in OStringStream()
72 std::string* str() { return s_; } in str()
73 const std::string* str() const { return s_; } in str()
74 void str(std::string* s) { s_ = s; } in str()
82 std::string* s_; variable
|
| D | ostringstream.cc | 22 assert(s_); in overflow()
24 s_->push_back(static_cast<char>(c)); in overflow()
29 assert(s_); in xsputn()
30 s_->append(s, n); in xsputn()
|
| /external/libtextclassifier/abseil-cpp/absl/strings/internal/ |
| D | ostringstream.h | 70 explicit OStringStream(std::string* s) : std::ostream(this), s_(s) {} in OStringStream()
72 std::string* str() { return s_; } in str()
73 const std::string* str() const { return s_; } in str()
74 void str(std::string* s) { s_ = s; } in str()
82 std::string* s_; variable
|
| D | ostringstream.cc | 22 assert(s_); in overflow()
24 s_->push_back(static_cast<char>(c)); in overflow()
29 assert(s_); in xsputn()
30 s_->append(s, n); in xsputn()
|
| /external/openscreen/third_party/abseil/src/absl/strings/internal/ |
| D | ostringstream.h | 70 explicit OStringStream(std::string* s) : std::ostream(this), s_(s) {} in OStringStream()
72 std::string* str() { return s_; } in str()
73 const std::string* str() const { return s_; } in str()
74 void str(std::string* s) { s_ = s; } in str()
82 std::string* s_; variable
|
| D | ostringstream.cc | 22 assert(s_); in overflow()
24 s_->push_back(static_cast<char>(c)); in overflow()
29 assert(s_); in xsputn()
30 s_->append(s, n); in xsputn()
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/strings/internal/ |
| D | ostringstream.h | 70 explicit OStringStream(std::string* s) : std::ostream(this), s_(s) {} in OStringStream()
72 std::string* str() { return s_; } in str()
73 const std::string* str() const { return s_; } in str()
74 void str(std::string* s) { s_ = s; } in str()
82 std::string* s_; variable
|
| D | ostringstream.cc | 22 assert(s_); in overflow()
24 s_->push_back(static_cast<char>(c)); in overflow()
29 assert(s_); in xsputn()
30 s_->append(s, n); in xsputn()
|
| /external/webrtc/rtc_base/ |
| D | physical_socket_server.cc | 118 s_(s), in PhysicalSocket()
122 if (s_ != INVALID_SOCKET) { in PhysicalSocket()
128 getsockopt(s_, SOL_SOCKET, SO_TYPE, (SockOptArg)&type, &len); in PhysicalSocket()
140 s_ = ::socket(family, type, 0); in Create()
147 return s_ != INVALID_SOCKET; in Create()
154 int result = ::getsockname(s_, addr, &addrlen); in GetLocalAddress()
160 << s_; in GetLocalAddress()
169 int result = ::getpeername(s_, addr, &addrlen); in GetRemoteAddress()
175 << "GetRemoteAddress: unable to get remote addr, socket=" << s_; in GetRemoteAddress()
187 ss_->network_binder()->BindSocketToNetwork(s_, bind_addr.ipaddr()); in Bind()
[all …]
|