| /external/vm_tools/p9/wire_format_derive/ |
| D | wire_format_derive.rs | 61 fn encode<W: io::Write>(&self, _writer: &mut W) -> io::Result<()> { in p9_wire_format_inner()
104 WireFormat::encode(&self.#field, _writer)?; in encode_wire_format()
190 WireFormat::encode(&self.ident, _writer)?; in encode()
191 WireFormat::encode(&self.with_underscores, _writer)?; in encode()
192 WireFormat::encode(&self.other, _writer)?; in encode()
266 fn encode<W: io::Write>(&self, _writer: &mut W) -> io::Result<()> { in end_to_end()
267 WireFormat::encode(&self.a, _writer)?; in end_to_end()
268 WireFormat::encode(&self.b, _writer)?; in end_to_end()
269 WireFormat::encode(&self.c, _writer)?; in end_to_end()
270 WireFormat::encode(&self.d, _writer)?; in end_to_end()
[all …]
|
| /external/grpc-grpc/src/objective-c/RxLibrary/ |
| D | GRXForwardingWriter.m | 25 GRXWriter *_writer;
43 _writer = writer;
60 GRXWriter *writer = _writer;
61 _writer = nil;
72 _writer = nil;
79 return _writer ? _writer.state : GRXWriterStateFinished;
87 _writer.state = state;
93 [_writer startWithWriteable:self];
|
| /external/libchrome/mojo/public/tools/bindings/generators/cpp_templates/ |
| D | struct_macros.tmpl | 40 {{name}}_writer;
44 {{input_field}}, {{buffer}}, &{{name}}_writer, &{{name}}_validate_params,
47 {{name}}_writer.is_null() ? nullptr : {{name}}_writer.data());
49 typename decltype({{writer}}->{{name}})::BufferWriter {{name}}_writer;
50 {{name}}_writer.AllocateInline({{buffer}}, &{{writer}}->{{name}});
52 {{input_field}}, {{buffer}}, &{{name}}_writer, true, {{context}});
55 {{name}}_writer;
57 {{input_field}}, {{buffer}}, &{{name}}_writer, {{context}});
59 {{name}}_writer.is_null() ? nullptr : {{name}}_writer.data());
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | queues.py | 42 self._reader, self._writer = connection.Pipe(duplex=False)
59 return (self._ignore_epipe, self._maxsize, self._reader, self._writer,
63 (self._ignore_epipe, self._maxsize, self._reader, self._writer,
82 self._send_bytes = self._writer.send_bytes
172 self._wlock, self._writer.close, self._ignore_epipe,
341 self._reader, self._writer = connection.Pipe(duplex=False)
351 self._writer.close()
358 return (self._reader, self._writer, self._rlock, self._wlock)
361 (self._reader, self._writer, self._rlock, self._wlock) = state
375 self._writer.send_bytes(obj)
[all …]
|
| D | pool.py | 105 inqueue._writer.close()
345 self._quick_put = self._inqueue._writer.send
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | queues.py | 62 self._reader, self._writer = Pipe(duplex=False)
78 return (self._maxsize, self._reader, self._writer,
82 (self._maxsize, self._reader, self._writer,
95 self._send = self._writer.send
189 self._wlock, self._writer.close),
351 self._reader, self._writer = Pipe(duplex=False)
364 return (self._reader, self._writer, self._rlock, self._wlock)
367 (self._reader, self._writer, self._rlock, self._wlock) = state
383 self.put = self._writer.send
385 send = self._writer.send
|
| D | pool.py | 93 inqueue._writer.close()
238 self._quick_put = self._inqueue._writer.send
|
| /external/tensorflow/tensorflow/python/lib/io/ |
| D | tf_record_test.py | 526 self._writer = tf_record.TFRecordWriter(self._fn, self._options)
535 self._writer.write(record)
542 self._writer.write(record)
543 self._writer.close()
551 self._writer.write(record)
552 self._writer.flush()
558 self._writer.write(self._Record(0))
559 self._writer.close()
560 self._writer.close()
563 self._writer.write(self._Record(0))
[all …]
|
| /external/jackson-core/src/main/java/com/fasterxml/jackson/core/json/ |
| D | WriterBasedJsonGenerator.java | 30 final protected Writer _writer; field in WriterBasedJsonGenerator
108 _writer = w; in WriterBasedJsonGenerator()
125 return _writer; in getOutputTarget()
522 _writer.write(text, 0, len); in _writeString2()
613 _writer.write(text, offset, len); in writeRaw()
971 if (_writer != null) { in flush()
973 _writer.flush(); in flush()
1010 if (_writer != null) { in close()
1012 _writer.close(); in close()
1015 _writer.flush(); in close()
[all …]
|
| /external/tensorflow/tensorflow/python/debug/lib/ |
| D | dumping_callback.py | 126 self._writer = None
160 self._writer = None
176 if not self._writer:
177 self._writer = debug_events_writer.DebugEventsWriter(
181 return self._writer
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| D | process.py | 69 self._reader, self._writer = mp.Pipe(duplex=False)
74 self._writer.close()
79 self._writer.send_bytes(b"")
|
| /external/protobuf/python/google/protobuf/ |
| D | text_format.py | 103 self._writer = io.BytesIO()
105 self._writer = io.StringIO()
111 return self._writer.write(val)
114 return self._writer.close()
117 return self._writer.getvalue()
|
| /external/google-breakpad/docs/ |
| D | linux_system_calls.md | 26 src/common/windows/pdb\_source\_line\_writer.cc, and the above link. To
|
| /external/llvm-project/lld/lib/ReaderWriter/MachO/ |
| D | MachOLinkingContext.cpp | 658 if (!_writer) in writer()
659 _writer = createWriterMachO(*this); in writer()
660 return *_writer; in writer()
|
| /external/rust/crates/serde_json/src/ |
| D | ser.rs | 1843 fn end_array_value<W>(&mut self, _writer: &mut W) -> io::Result<()>
1887 fn end_object_key<W>(&mut self, _writer: &mut W) -> io::Result<()>
1907 fn end_object_value<W>(&mut self, _writer: &mut W) -> io::Result<()>
2002 fn end_array_value<W>(&mut self, _writer: &mut W) -> io::Result<()>
2057 fn end_object_value<W>(&mut self, _writer: &mut W) -> io::Result<()>
|
| /external/llvm-project/lld/include/lld/ReaderWriter/ |
| D | MachOLinkingContext.h | 486 mutable std::unique_ptr<Writer> _writer; variable
|
| /external/python/cpython2/Doc/library/ |
| D | formatter.rst | 217 .. _writer-interface:
320 .. _writer-impls:
|
| /external/python/cpython3/Doc/library/ |
| D | formatter.rst | 218 .. _writer-interface:
321 .. _writer-impls:
|
| /external/python/cpython3/Lib/test/ |
| D | _test_multiprocessing.py | 5282 self.assertTrue(queue._writer.closed)
|