Home
last modified time | relevance | path

Searched refs:output_stream (Results 1 – 25 of 58) sorted by relevance

123

/third_party/grpc/test/cpp/util/
Dgrpc_tool_test.cc298 std::stringstream output_stream; in TEST_F() local
304 std::bind(PrintStream, &output_stream, std::placeholders::_1)), in TEST_F()
307 EXPECT_TRUE(0 == output_stream.tellp()); in TEST_F()
312 std::stringstream output_stream; in TEST_F() local
318 std::bind(PrintStream, &output_stream, std::placeholders::_1)), in TEST_F()
321 EXPECT_TRUE(0 == output_stream.tellp()); in TEST_F()
326 std::stringstream output_stream; in TEST_F() local
330 std::bind(PrintStream, &output_stream, in TEST_F()
334 EXPECT_TRUE(0 == output_stream.tellp()); in TEST_F()
339 std::stringstream output_stream; in TEST_F() local
[all …]
/third_party/glib/gio/
Dgsocketoutputstream.c129 GSocketOutputStream *output_stream = G_SOCKET_OUTPUT_STREAM (stream); in g_socket_output_stream_write() local
131 return g_socket_send_with_blocking (output_stream->priv->socket, in g_socket_output_stream_write()
144 GSocketOutputStream *output_stream = G_SOCKET_OUTPUT_STREAM (stream); in g_socket_output_stream_writev() local
153 res = g_socket_send_message_with_timeout (output_stream->priv->socket, NULL, in g_socket_output_stream_writev()
168 GSocketOutputStream *output_stream = G_SOCKET_OUTPUT_STREAM (pollable); in g_socket_output_stream_pollable_is_writable() local
170 return g_socket_condition_check (output_stream->priv->socket, G_IO_OUT); in g_socket_output_stream_pollable_is_writable()
179 GSocketOutputStream *output_stream = G_SOCKET_OUTPUT_STREAM (pollable); in g_socket_output_stream_pollable_write_nonblocking() local
181 return g_socket_send_with_blocking (output_stream->priv->socket, in g_socket_output_stream_pollable_write_nonblocking()
193 GSocketOutputStream *output_stream = G_SOCKET_OUTPUT_STREAM (pollable); in g_socket_output_stream_pollable_writev_nonblocking() local
201 return g_socket_send_message_with_timeout (output_stream->priv->socket, in g_socket_output_stream_pollable_writev_nonblocking()
[all …]
Dglocalfileiostream.c48 g_object_unref (file->output_stream); in G_DEFINE_TYPE()
54 _g_local_file_io_stream_new (GLocalFileOutputStream *output_stream) in _g_local_file_io_stream_new() argument
60 stream->output_stream = g_object_ref (G_OUTPUT_STREAM (output_stream)); in _g_local_file_io_stream_new()
61 _g_local_file_output_stream_set_do_close (output_stream, FALSE); in _g_local_file_io_stream_new()
62 fd = _g_local_file_output_stream_get_fd (output_stream); in _g_local_file_io_stream_new()
80 return G_LOCAL_FILE_IO_STREAM (stream)->output_stream; in g_local_file_io_stream_get_output_stream()
92 g_output_stream_close (file->output_stream, cancellable, NULL); in g_local_file_io_stream_close()
96 _g_local_file_output_stream_really_close (G_LOCAL_FILE_OUTPUT_STREAM (file->output_stream), in g_local_file_io_stream_close()
Dgfileoutputstream.c144 GOutputStream *output_stream; in g_file_output_stream_query_info() local
149 output_stream = G_OUTPUT_STREAM (stream); in g_file_output_stream_query_info()
151 if (!g_output_stream_set_pending (output_stream, error)) in g_file_output_stream_query_info()
169 g_output_stream_clear_pending (output_stream); in g_file_output_stream_query_info()
213 GOutputStream *output_stream; in g_file_output_stream_query_info_async() local
218 output_stream = G_OUTPUT_STREAM (stream); in g_file_output_stream_query_info_async()
220 if (!g_output_stream_set_pending (output_stream, &error)) in g_file_output_stream_query_info_async()
280 GOutputStream *output_stream; in g_file_output_stream_get_etag() local
285 output_stream = G_OUTPUT_STREAM (stream); in g_file_output_stream_get_etag()
287 if (!g_output_stream_is_closed (output_stream)) in g_file_output_stream_get_etag()
[all …]
Dgsimpleiostream.c58 GOutputStream *output_stream; member
85 if (stream->output_stream) in G_DEFINE_TYPE()
86 g_object_unref (stream->output_stream); in G_DEFINE_TYPE()
106 stream->output_stream = g_value_dup_object (value); in g_simple_io_stream_set_property()
130 g_value_set_object (value, stream->output_stream); in g_simple_io_stream_get_property()
152 return simple_stream->output_stream; in g_simple_io_stream_get_output_stream()
216 GOutputStream *output_stream) in g_simple_io_stream_new() argument
220 "output-stream", output_stream, in g_simple_io_stream_new()
Dgsocketconnection.c76 GOutputStream *output_stream; member
114 if (connection->priv->output_stream == NULL) in g_socket_connection_get_output_stream()
115 connection->priv->output_stream = (GOutputStream *) in g_socket_connection_get_output_stream()
118 return connection->priv->output_stream; in g_socket_connection_get_output_stream()
422 if (connection->priv->output_stream) in g_socket_connection_finalize()
423 g_object_unref (connection->priv->output_stream); in g_socket_connection_finalize()
473 if (connection->priv->output_stream) in g_socket_connection_close()
474 g_output_stream_close (connection->priv->output_stream, in g_socket_connection_close()
Dglocalfileiostream.h45 GOutputStream *output_stream; member
54 GFileIOStream * _g_local_file_io_stream_new (GLocalFileOutputStream *output_stream);
/third_party/glib/gio/tests/
Dtaptestrunner.py40 def __init__(self, output_stream, error_stream, message_log, test_output_log): argument
41 super(TAPTestResult, self).__init__(self, output_stream)
42 self.output_stream = output_stream
50 self.output_stream.write("TAP version 13\n")
78 self.output_stream.write(text)
79 self.output_stream.flush()
82 self.output_stream.write("%s %d %s" % (result, self.testsRun, test.id()))
84 self.output_stream.write(" # " + directive)
85 self.output_stream.write("\n")
86 self.output_stream.flush()
[all …]
Dtest-io-stream.c38 g_clear_object (&stream->output_stream); in G_DEFINE_TYPE()
61 return stream->output_stream; in test_io_stream_get_output_stream()
92 GOutputStream *output_stream) in test_io_stream_new() argument
97 g_return_val_if_fail (G_IS_OUTPUT_STREAM (output_stream), NULL); in test_io_stream_new()
100 stream->output_stream = g_object_ref (output_stream); in test_io_stream_new()
Dgdbus-close-pending.c56 GOutputStream *output_stream; member
73 g_object_unref (stream->output_stream); in G_DEFINE_TYPE()
93 return stream->output_stream; in my_io_stream_get_output_stream()
112 GOutputStream *output_stream) in my_io_stream_new() argument
116 g_return_val_if_fail (G_IS_OUTPUT_STREAM (output_stream), NULL); in my_io_stream_new()
119 stream->output_stream = g_object_ref (output_stream); in my_io_stream_new()
242 GOutputStream *output_stream; in my_io_stream_new_for_fds() local
246 output_stream = g_object_new (MY_TYPE_SLOW_CLOSE_OUTPUT_STREAM, in my_io_stream_new_for_fds()
249 stream = my_io_stream_new (input_stream, output_stream); in my_io_stream_new_for_fds()
251 g_object_unref (output_stream); in my_io_stream_new_for_fds()
Dtest-io-stream.h32 GOutputStream *output_stream; member
49 GOutputStream *output_stream);
/third_party/glib/gobject/tests/
Dtaptestrunner.py40 def __init__(self, output_stream, error_stream, message_log, test_output_log): argument
41 super(TAPTestResult, self).__init__(self, output_stream)
42 self.output_stream = output_stream
50 self.output_stream.write("TAP version 13\n")
78 self.output_stream.write(text)
79 self.output_stream.flush()
82 self.output_stream.write("%s %d %s" % (result, self.testsRun, test.id()))
84 self.output_stream.write(" # " + directive)
85 self.output_stream.write("\n")
86 self.output_stream.flush()
[all …]
/third_party/libsoup/libsoup/
Dsoup-cache-input-stream.c33 GOutputStream *output_stream; member
60 g_clear_object (&priv->output_stream); in notify_and_clear()
90 priv->output_stream = (GOutputStream *) g_file_replace_finish (G_FILE (source), res, &error); in file_replaced_cb()
118 g_value_set_object (value, priv->output_stream); in soup_cache_input_stream_get_property()
135 priv->output_stream = g_value_dup_object (value); in soup_cache_input_stream_set_property()
150 g_clear_object (&priv->output_stream); in soup_cache_input_stream_finalize()
195 g_assert (priv->output_stream && !g_output_stream_is_closed (priv->output_stream)); in soup_cache_input_stream_write_next_buffer()
205 g_output_stream_write_async (priv->output_stream, buffer->data, buffer->length, in soup_cache_input_stream_write_next_buffer()
234 if (priv->current_writing_buffer == NULL && priv->output_stream) in read_internal()
240 if (priv->current_writing_buffer == NULL && priv->output_stream) in read_internal()
[all …]
/third_party/flutter/skia/third_party/externals/sfntly/cpp/src/test/
Dtest_font_utils.cc40 MemoryOutputStream output_stream; in SerializeFont() local
41 factory->SerializeFont(font, &output_stream); in SerializeFont()
42 SerializeToFile(&output_stream, font_path); in SerializeFont()
83 void SerializeToFile(MemoryOutputStream* output_stream, const char* file_path) { in SerializeToFile() argument
85 assert(output_stream); in SerializeToFile()
94 fwrite(output_stream->Get(), 1, output_stream->Size(), output_file); in SerializeToFile()
Dfont_parsing_test.cc109 MemoryOutputStream output_stream; in TestTTFReadWrite() local
110 factory->SerializeFont(font, &output_stream); in TestTTFReadWrite()
111 EXPECT_GE(output_stream.Size(), SAMPLE_TTF_SIZE); in TestTTFReadWrite()
127 MemoryOutputStream output_stream; in TestTTFMemoryBasedReadWrite() local
128 factory->SerializeFont(font, &output_stream); in TestTTFMemoryBasedReadWrite()
129 EXPECT_GE(output_stream.Size(), input_buffer.size()); in TestTTFMemoryBasedReadWrite()
/third_party/skia/third_party/externals/sfntly/cpp/src/test/
Dtest_font_utils.cc40 MemoryOutputStream output_stream; in SerializeFont() local
41 factory->SerializeFont(font, &output_stream); in SerializeFont()
42 SerializeToFile(&output_stream, font_path); in SerializeFont()
83 void SerializeToFile(MemoryOutputStream* output_stream, const char* file_path) { in SerializeToFile() argument
85 assert(output_stream); in SerializeToFile()
94 fwrite(output_stream->Get(), 1, output_stream->Size(), output_file); in SerializeToFile()
Dfont_parsing_test.cc109 MemoryOutputStream output_stream; in TestTTFReadWrite() local
110 factory->SerializeFont(font, &output_stream); in TestTTFReadWrite()
111 EXPECT_GE(output_stream.Size(), SAMPLE_TTF_SIZE); in TestTTFReadWrite()
127 MemoryOutputStream output_stream; in TestTTFMemoryBasedReadWrite() local
128 factory->SerializeFont(font, &output_stream); in TestTTFMemoryBasedReadWrite()
129 EXPECT_GE(output_stream.Size(), input_buffer.size()); in TestTTFMemoryBasedReadWrite()
/third_party/flutter/skia/third_party/externals/sfntly/cpp/src/sample/subsetter/
Dsubset_util.cc89 MemoryOutputStream output_stream; in Subset() local
90 factory->SerializeFont(new_font, &output_stream); in Subset()
93 fwrite(output_stream.Get(), 1, output_stream.Size(), output_file); in Subset()
/third_party/skia/third_party/externals/sfntly/cpp/src/sample/subsetter/
Dsubset_util.cc89 MemoryOutputStream output_stream; in Subset() local
90 factory->SerializeFont(new_font, &output_stream); in Subset()
93 fwrite(output_stream.Get(), 1, output_stream.Size(), output_file); in Subset()
/third_party/flutter/skia/third_party/externals/sfntly/cpp/src/sample/subtly/
Dutils.cc73 MemoryOutputStream output_stream; in SerializeFont() local
74 factory->SerializeFont(font, &output_stream); in SerializeFont()
84 for (size_t i = 0; i < output_stream.Size(); ++i) { in SerializeFont()
85 fwrite(&(output_stream.Get()[i]), 1, 1, output_file); in SerializeFont()
/third_party/skia/third_party/externals/sfntly/cpp/src/sample/subtly/
Dutils.cc73 MemoryOutputStream output_stream; in SerializeFont() local
74 factory->SerializeFont(font, &output_stream); in SerializeFont()
84 for (size_t i = 0; i < output_stream.Size(); ++i) { in SerializeFont()
85 fwrite(&(output_stream.Get()[i]), 1, 1, output_file); in SerializeFont()
/third_party/grpc/src/compiler/
Dobjective_c_generator.cc287 grpc::protobuf::io::StringOutputStream output_stream(&output); in GetProtocol() local
288 Printer printer(&output_stream, '$'); in GetProtocol()
313 grpc::protobuf::io::StringOutputStream output_stream(&output); in GetV2Protocol() local
314 Printer printer(&output_stream, '$'); in GetV2Protocol()
333 grpc::protobuf::io::StringOutputStream output_stream(&output); in GetInterface() local
334 Printer printer(&output_stream, '$'); in GetInterface()
376 grpc::protobuf::io::StringOutputStream output_stream(&output); in GetSource() local
377 Printer printer(&output_stream, '$'); in GetSource()
/third_party/protobuf/src/google/protobuf/util/
Djson_util_test.cc561 SegmentedZeroCopyOutputStream output_stream(segments); in TEST() local
562 internal::ZeroCopyStreamByteSink byte_sink(&output_stream); in TEST()
581 SegmentedZeroCopyOutputStream output_stream(segments); in TEST() local
582 internal::ZeroCopyStreamByteSink byte_sink(&output_stream); in TEST()
603 SegmentedZeroCopyOutputStream output_stream(segments); in TEST() local
604 internal::ZeroCopyStreamByteSink byte_sink(&output_stream); in TEST()
624 io::ArrayOutputStream output_stream(proto_buffer, sizeof(proto_buffer)); in TEST_F() local
630 &input_stream, &output_stream); in TEST_F()
Djson_util.cc118 io::StringOutputStream output_stream(json_output); in BinaryToJsonString() local
119 return BinaryToJsonStream(resolver, type_url, &input_stream, &output_stream, in BinaryToJsonString()
212 io::StringOutputStream output_stream(binary_output); in JsonToBinaryString() local
213 return JsonToBinaryStream(resolver, type_url, &input_stream, &output_stream, in JsonToBinaryString()
/third_party/node/test/addons/heap-profiler/
Dbinding.cc14 } output_stream; in Test() local
15 heap_snapshot->Serialize(&output_stream, v8::HeapSnapshot::kJSON); in Test()

123