| /dports/devel/p5-IO-Async/IO-Async-0.800/lib/IO/Async/ |
| H A D | Handle.pm | 220 my $write_handle = delete $params{write_handle};
222 if( defined $write_handle ) {
232 $self->{write_handle} = $write_handle;
237 undef $self->{write_handle};
378 exists $params{write_handle} ? ( write_handle => $params{write_handle} ) : (),
423 my $write_handle = delete $self->{write_handle};
424 $write_handle->close if defined $write_handle;
474 my $write_handle = delete $self->{write_handle};
475 $write_handle->close if defined $write_handle;
525 sub write_handle subroutine
[all …]
|
| H A D | Channel.pm | 383 defined and $_->blocking( 1 ) for $self->{read_handle}, $self->{write_handle};
440 defined and $_->blocking( 0 ) for $self->{read_handle}, $self->{write_handle};
452 write_handle => $self->{write_handle},
505 $_ and $_->close for $self->{read_handle}, $self->{write_handle};
508 undef $_ for $self->{read_handle}, $self->{write_handle};
562 return $self->{write_handle};
|
| /dports/devel/py-oslo.vmware/oslo.vmware-3.10.0/oslo_vmware/ |
| H A D | image_transfer.py | 49 def _start_transfer(read_handle, write_handle, timeout_secs): argument
53 write_updater = _create_progress_updater(write_handle)
61 write_handle.write(data)
65 'dest': write_handle})
71 'dest': write_handle})
81 write_handle.close()
145 _start_transfer(read_handle, write_handle, timeout_secs)
169 write_handle = rw_handles.FileWriteHandle(host,
205 return write_handle.get_imported_vm()
265 context, timeout_secs, write_handle, **kwargs): argument
[all …]
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/libs/unimrcp/libs/mpf/src/ |
| H A D | mpf_audio_file_stream.c | 31 FILE *write_handle; member
48 if(file_stream->write_handle) { in mpf_audio_file_destroy()
49 fclose(file_stream->write_handle); in mpf_audio_file_destroy()
50 file_stream->write_handle = NULL; in mpf_audio_file_destroy()
94 if(file_stream->write_handle && in mpf_audio_file_frame_write()
100 file_stream->write_handle); in mpf_audio_file_frame_write()
130 file_stream->write_handle = NULL; in mpf_file_stream_create()
153 if(file_stream->write_handle) { in mpf_file_stream_modify()
154 fclose(file_stream->write_handle); in mpf_file_stream_modify()
156 file_stream->write_handle = descriptor->write_handle; in mpf_file_stream_modify()
|
| /dports/lang/racket-minimal/racket-8.3/src/rktio/ |
| H A D | rktio_ltps.c | 53 rktio_ltps_handle_t *write_handle; member
71 v->write_handle = NULL; in make_ltps_handle_pair()
278 s = v->write_handle; in rktio_ltps_add()
296 if (v->write_handle) { in rktio_ltps_add()
376 s = v->write_handle; in rktio_ltps_add()
380 v->write_handle = s; in rktio_ltps_add()
461 s = v->write_handle; in rktio_ltps_poll()
511 s = v->write_handle; in rktio_ltps_poll()
572 s = v->write_handle; in rktio_ltps_poll()
640 s = v->write_handle; in rktio_ltps_poll()
[all …]
|
| /dports/lang/racket/racket-8.3/src/rktio/ |
| H A D | rktio_ltps.c | 53 rktio_ltps_handle_t *write_handle; member
71 v->write_handle = NULL; in make_ltps_handle_pair()
278 s = v->write_handle; in rktio_ltps_add()
296 if (v->write_handle) { in rktio_ltps_add()
376 s = v->write_handle; in rktio_ltps_add()
380 v->write_handle = s; in rktio_ltps_add()
461 s = v->write_handle; in rktio_ltps_poll()
511 s = v->write_handle; in rktio_ltps_poll()
572 s = v->write_handle; in rktio_ltps_poll()
640 s = v->write_handle; in rktio_ltps_poll()
[all …]
|
| /dports/devel/aws-c-io/aws-c-io-0.10.12/tests/ |
| H A D | event_loop_test.c | 177 write_handle->data.handle = CreateNamedPipeA( in s_async_pipe_init()
205 CloseHandle(write_handle->data.handle); in s_async_pipe_clean_up()
262 struct aws_io_handle write_handle; in s_test_event_loop_completion_events() local
315 AWS_ZERO_STRUCT(*write_handle);
321 write_handle->data.fd = pipe_fds[1];
327 close(write_handle->data.fd);
346 struct aws_io_handle write_handle[2];
402 if (&data->write_handle[i] == handle) {
479 AWS_ZERO_ARRAY(data->write_handle);
595 struct aws_io_handle write_handle;
[all …]
|
| /dports/devel/p5-IO-Async/IO-Async-0.800/t/ |
| H A D | 21stream-2write.t | 54 write_handle => $wr,
134 write_handle => $wr,
189 write_handle => $wr,
220 write_handle => $wr,
257 my $stream = IO::Async::Stream->new( write_handle => $wr,
324 write_handle => $wr,
354 write_handle => $wr,
399 write_handle => $wr,
431 $stream->configure( write_handle => $wr );
457 write_handle => $wr,
[all …]
|
| H A D | 20handle.t | 61 is( $handle->write_handle, undef, '->write_handle returns undef' );
123 write_handle => $S1,
134 is( $handle->write_handle, $S1, '->write_handle returns S1' );
187 is( $handle->write_handle, $S1, '->write_handle returns S1' );
209 is( $handle->write_handle, $S1, 'subclass ->write_handle returns S1' );
279 write_handle => $Swr1,
293 $handle->write_handle->syswrite( "Still works\n" );
339 ok( !defined $handle->write_handle, '->write_handle not defined' );
355 is( $handle->write_handle, $S1, '->write_handle now S1' );
403 is( $handle->write_handle->fileno, 1, '->fileno of write_handle' );
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/benches/ |
| H A D | isolated_buffering.rs | 57 let write_handle = rt.spawn_handle_std(send.compat()); in benchmark_buffers() localVariable
59 let (writer, _stream) = rt.block_on_std(write_handle).unwrap().unwrap(); in benchmark_buffers()
79 let write_handle = rt.spawn_handle_std(async move { in benchmark_buffers() localVariable
86 rt.block_on_std(write_handle).unwrap(); in benchmark_buffers()
111 let write_handle = rt.spawn_handle_std(send.compat()); in benchmark_buffers() localVariable
112 let _ = rt.block_on_std(write_handle).unwrap().unwrap(); in benchmark_buffers()
133 let write_handle = rt.spawn_handle_std(send.compat()); in benchmark_buffers() localVariable
134 let (writer, _stream) = rt.block_on_std(write_handle).unwrap().unwrap(); in benchmark_buffers()
171 let write_handle = rt.spawn_handle_std(send.compat()); in benchmark_buffers() localVariable
173 let _ = rt.block_on_std(write_handle).unwrap().unwrap(); in benchmark_buffers()
|
| /dports/devel/py-oletools/oletools-0.54.2/oletools/ |
| H A D | crypto.py | 386 write_handle = None
393 write_handle = os.fdopen(write_descriptor, 'wb')
395 crypto_file.decrypt(write_handle)
398 write_handle.close()
399 write_handle = None
405 if write_handle:
406 write_handle.close()
|
| /dports/devel/gvfs/gvfs-1.46.2/daemon/ |
| H A D | gvfsbackendgphoto2.c | 290 g_free (write_handle->dir); in write_handle_free()
291 g_free (write_handle->name); in write_handle_free()
293 g_free (write_handle); in write_handle_free()
2893 …ype=%d cursor=%ld size=%ld\n", write_handle, write_handle->filename, (int)offset, type, write_hand… in do_seek_on_write()
2976 (write_handle->job_is_replace || write_handle->job_is_append_to)) in commit_write_handle()
2992 write_handle->dir, write_handle->name, in commit_write_handle()
2993 … write_handle->delete_before, write_handle->job_is_replace, write_handle->job_is_append_to); in commit_write_handle()
3019 monitors_emit_changed (gphoto2_backend, write_handle->dir, write_handle->name); in commit_write_handle()
3027 caches_invalidate_file (gphoto2_backend, write_handle->dir, write_handle->name); in commit_write_handle()
3045 …_debug ("close_write() %p '%s' %ld bytes total\n", write_handle, write_handle->filename, write_han… in do_close_write()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/crashpad/crashpad/util/stream/ |
| H A D | file_encoder.cc | 40 ScopedFileHandle write_handle(LoggingOpenFileForWrite( in Process() local
42 if (!write_handle.is_valid()) in Process()
54 std::make_unique<FileOutputStream>(write_handle.get()))); in Process()
60 std::make_unique<FileOutputStream>(write_handle.get()))); in Process()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/crashpad/crashpad/util/stream/ |
| H A D | file_encoder.cc | 39 ScopedFileHandle write_handle(LoggingOpenFileForWrite( in Process() local
41 if (!write_handle.is_valid()) in Process()
53 std::make_unique<FileOutputStream>(write_handle.get()))); in Process()
59 std::make_unique<FileOutputStream>(write_handle.get()))); in Process()
|
| /dports/devel/arcanist-lib/arcanist-b2e715f/src/parser/http/ |
| H A D | PhutilHTTPResponseParser.php | 22 public function setWriteHandle($write_handle) { argument
23 $this->writeHandle = $write_handle;
197 $write_handle = $this->getWriteHandle();
198 if ($write_handle) {
199 $response->setWriteHandle($write_handle);
|
| /dports/devel/arcanist/arcanist-b2e715f/src/parser/http/ |
| H A D | PhutilHTTPResponseParser.php | 22 public function setWriteHandle($write_handle) { argument
23 $this->writeHandle = $write_handle;
197 $write_handle = $this->getWriteHandle();
198 if ($write_handle) {
199 $response->setWriteHandle($write_handle);
|
| /dports/devel/py-pyinstaller/PyInstaller-3.5/tests/functional/ |
| H A D | test_updating_manifest.py | 58 with tmppath.open('wt', ensure=True, encoding='utf-8') as write_handle:
60 write_handle.write(unicode(test_manifest_which_uses_non_ascii,
63 write_handle.write(test_manifest_which_uses_non_ascii)
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/remoting/host/setup/ |
| H A D | test_util.cc | 20 base::PlatformFile write_handle; in MakePipe() local
21 if (!CreatePipe(&read_handle, &write_handle, nullptr, 0)) in MakePipe()
24 *write_file = base::File(write_handle); in MakePipe()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/crashpad/crashpad/snapshot/mac/ |
| H A D | process_reader_mac_test.cc | 109 FileHandle write_handle = WritePipeHandle(); in MachMultiprocessChild() local
112 CheckedWriteFile(write_handle, &address, sizeof(address)); in MachMultiprocessChild()
476 FileHandle write_handle = WritePipeHandle(); in MachMultiprocessChild() local
482 CheckedWriteFile(write_handle, &thread_id, sizeof(thread_id)); in MachMultiprocessChild()
488 CheckedWriteFile(write_handle, in MachMultiprocessChild()
491 CheckedWriteFile(write_handle, in MachMultiprocessChild()
501 CheckedWriteFile(write_handle, &thread_id, sizeof(thread_id)); in MachMultiprocessChild()
502 CheckedWriteFile(write_handle, in MachMultiprocessChild()
505 CheckedWriteFile(write_handle, in MachMultiprocessChild()
801 FileHandle write_handle = WritePipeHandle(); in MachMultiprocessChild() local
[all …]
|
| /dports/devel/p5-Child/Child-0.009/lib/Child/Link/ |
| H A D | IPC.pm | 28 my $write = $self->write_handle;
43 my $write = $self->write_handle;
60 my $handle = $self->write_handle;
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/crashpad/crashpad/test/ |
| H A D | multiprocess_exec_posix.cc | 104 FileHandle write_handle = WritePipeHandle(); in MultiprocessChild() local
105 ASSERT_NE(write_handle, STDIN_FILENO); in MultiprocessChild()
106 ASSERT_NE(write_handle, STDOUT_FILENO); in MultiprocessChild()
124 rv = HANDLE_EINTR(dup2(write_handle, STDOUT_FILENO)); in MultiprocessChild()
|
| /dports/devel/py-oslo.vmware/oslo.vmware-3.10.0/oslo_vmware/tests/ |
| H A D | test_image_transfer.py | 32 write_handle = mock.Mock()
33 image_transfer._start_transfer(read_handle, write_handle, None)
34 write_handle.write.assert_called_once_with(data)
100 write_handle = mock.sentinel.write_handle
101 file_write_handle_cls.return_value = write_handle
121 read_handle, write_handle, timeout_secs)
328 write_handle = mock.Mock(name='/cinder/images/tmpAbcd.vmdk')
337 context, timeout, write_handle, session=session, host=host,
346 start_transfer.assert_called_once_with(read_handle, write_handle,
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/crashpad/crashpad/snapshot/mac/ |
| H A D | process_reader_mac_test.cc | 112 FileHandle write_handle = WritePipeHandle(); in MachMultiprocessChild() local
115 CheckedWriteFile(write_handle, &address, sizeof(address)); in MachMultiprocessChild()
479 FileHandle write_handle = WritePipeHandle(); in MachMultiprocessChild() local
485 CheckedWriteFile(write_handle, &thread_id, sizeof(thread_id)); in MachMultiprocessChild()
491 CheckedWriteFile(write_handle, in MachMultiprocessChild()
494 CheckedWriteFile(write_handle, in MachMultiprocessChild()
504 CheckedWriteFile(write_handle, &thread_id, sizeof(thread_id)); in MachMultiprocessChild()
505 CheckedWriteFile(write_handle, in MachMultiprocessChild()
508 CheckedWriteFile(write_handle, in MachMultiprocessChild()
881 FileHandle write_handle = WritePipeHandle(); in MachMultiprocessChild() local
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/safe_browsing/chrome_cleaner/ |
| H A D | reporter_runner_win_unittest.cc | 168 HANDLE read_handle, write_handle; in CreateRunningProcesseses() local
169 if (!::CreatePipe(&read_handle, &write_handle, nullptr, 0)) { in CreateRunningProcesseses()
174 base::File write_pipe(write_handle); in CreateRunningProcesseses()
176 options.stdout_handle = write_handle; in CreateRunningProcesseses()
178 options.handles_to_inherit.push_back(write_handle); in CreateRunningProcesseses()
|
| /dports/net/yaz/yaz-5.31.1/src/ |
| H A D | siconv.c | 47 return cd->decoder.read_handle && cd->encoder.write_handle; in yaz_iconv_isbuiltin()
100 cd->encoder.write_handle = 0; in yaz_iconv_open()
121 if (cd->decoder.read_handle && cd->encoder.write_handle) in yaz_iconv_open()
219 r = (*cd->encoder.write_handle)(cd, &cd->encoder, in yaz_iconv()
258 r = (*cd->encoder.write_handle)(cd, &cd->encoder, in yaz_iconv()
|