| /third_party/node/lib/internal/fs/ |
| D | watchers.js | 70 this._handle = null;
101 if (this._handle !== null)
104 this._handle = new _StatWatcher(this[kUseBigint]);
105 this._handle[owner_symbol] = this;
106 this._handle.onchange = onchange;
116 const err = this._handle.start(toNamespacedPath(filename), interval);
139 if (this._handle === null)
142 defaultTriggerAsyncIdScope(this._handle.getAsyncId(),
146 this._handle.close();
147 this._handle = null;
[all …]
|
| /third_party/node/lib/ |
| D | net.js | 257 if (self._handle) {
258 self._handle[owner_symbol] = self;
259 self._handle.onread = onStreamRead;
260 self[async_id_symbol] = getNewAsyncId(self._handle);
271 self._handle.useUserBuffer(userBuf);
320 this._handle = options.handle; // private
321 this[async_id_symbol] = getNewAsyncId(this._handle);
328 this._handle = createHandle(fd, false);
330 err = this._handle.open(fd);
339 this[async_id_symbol] = this._handle.getAsyncId();
[all …]
|
| D | _tls_wrap.js | 170 if (owner._handle === null)
173 owner._handle.loadSession(session);
175 owner._handle.endParser();
187 owner._handle.endParser();
207 if (owner._handle === null)
212 owner._handle.sni_context = context.context || context;
223 let ctx = socket._handle.sni_context;
244 debug('server OCSPRequest done', 'handle?', !!socket._handle, 'once?', once,
253 if (socket._handle === null)
257 socket._handle.setOCSPResponse(response);
[all …]
|
| D | _http_server.js | 496 if (socket._handle && socket._handle.isStreamBase &&
497 !socket._handle._consumed) {
499 socket._handle._consumed = true;
500 parser.consume(socket._handle);
925 if (this._handle && !this._handle.reading) {
926 this._handle.reading = true;
927 this._handle.readStart();
932 if (this._handle && this._handle.reading) {
933 this._handle.reading = false;
934 this._handle.readStop();
[all …]
|
| /third_party/node/deps/npm/node_modules/minizlib/ |
| D | index.js | 38 const _handle = Symbol('handle') constant
59 this[_handle] = new realZlib[mode](opts)
73 this[_handle].on('error', er => this[_onError](new ZlibError(er)))
78 if (this[_handle]) {
79 this[_handle].close()
80 this[_handle] = null
87 assert(this[_handle], 'zlib binding closed')
88 return this[_handle].reset()
124 assert(this[_handle], 'zlib binding closed')
128 const nativeHandle = this[_handle]._handle
[all …]
|
| /third_party/node/test/parallel/ |
| D | test-handle-wrap-isrefed.js | 13 strictEqual(cp._handle.hasRef(),
16 strictEqual(cp._handle.hasRef(),
19 strictEqual(cp._handle.hasRef(),
21 cp._handle.close(common.mustCall(() =>
22 strictEqual(cp._handle.hasRef(),
90 strictEqual(server._handle.hasRef(),
95 strictEqual(server._handle.hasRef(),
100 strictEqual(server._handle.hasRef(),
104 server._handle.close(common.mustCall(() =>
105 strictEqual(server._handle.hasRef(),
|
| D | test-http-client-spurious-aborted.js | 51 const _handle = res.socket._handle;
52 _handle._close = res.socket._handle.close;
53 _handle.close = function(callback) {
54 _handle._close();
|
| D | test-net-socket-write-after-close.js | 17 client._handle.close();
37 client._handle.close();
38 client._handle = null;
|
| D | test-net-server-listen-handle.js | 105 .listen({ _handle: randomHandle('tcp') }, closeServer()); property
108 .listen({ _handle: randomHandle('tcp') }) property
133 .listen({ _handle: handles[2] }, closePipeServer(handles[2])); property
136 .listen({ _handle: handles[3] }) property
|
| /third_party/node/test/common/ |
| D | udppair.js | 12 this._handle = new JSUDPWrap();
14 this._handle.onreadstart = () => this._startReading(); function
15 this._handle.onreadstop = () => this._stopReading();
16 this._handle.onwrite =
18 this._handle.getsockname = (obj) => {
50 setImmediate(() => this._handle.onSendDone(wrap, 0));
54 this._handle.onAfterBind();
81 this._handle.emitReceived(buffer, familyInt, address, port, flags);
|
| /third_party/python/Lib/asyncio/ |
| D | windows_utils.py | 87 self._handle = handle
90 if self._handle is not None:
98 return self._handle
101 if self._handle is None:
103 return self._handle
106 if self._handle is not None:
107 CloseHandle(self._handle)
108 self._handle = None
111 if self._handle is not None:
|
| /third_party/node/test/pseudo-tty/ |
| D | test-handle-wrap-isrefed-tty.js | 13 strictEqual(tty._handle.hasRef(),
16 strictEqual(tty._handle.hasRef(),
19 strictEqual(tty._handle.hasRef(),
21 tty._handle.close(common.mustCall(() =>
22 strictEqual(tty._handle.hasRef(),
|
| /third_party/node/lib/internal/ |
| D | js_stream_socket.js | 76 if (this._handle)
77 this._handle.readBuffer(chunk);
82 if (this._handle)
83 this._handle.emitEOF();
142 const handle = this._handle;
167 const handle = this._handle;
219 const handle = this._handle;
231 assert(this._handle === null);
|
| D | child_process.js | 99 return server._handle;
112 if (!socket._handle)
133 const handle = socket._handle;
139 socket._handle = null;
258 this._handle = new Process();
259 this._handle[owner_symbol] = this;
261 this._handle.onexit = (exitCode, signalCode) => { function
272 this._handle.close();
273 this._handle = null;
383 const err = this._handle.spawn(options);
[all …]
|
| /third_party/node/lib/internal/bootstrap/switches/ |
| D | is_main_thread.js | 204 if (stdin._handle && stdin._handle.readStop) {
205 stdin._handle.reading = false;
207 stdin._handle.readStop();
218 if (!stdin._handle)
220 if (stdin._handle.reading && !stdin.readableFlowing) {
222 stdin._handle.reading = false;
223 stdin._handle.readStop();
|
| /third_party/node/lib/internal/dns/ |
| D | utils.js | 57 this._handle = new ChannelWrap(timeout, tries);
61 this._handle.cancel();
65 return ArrayPrototypeMap(this._handle.getServers(), (val) => {
82 const orig = this._handle.getServers();
123 const errorNumber = this._handle.setServers(newSet);
127 this._handle.setServers(ArrayPrototypeJoin(orig, ','));
140 this._handle.setLocalAddress(ipv4, ipv6);
|
| /third_party/flutter/engine/flutter/lib/ui/ |
| D | plugins.dart | 15 CallbackHandle.fromRawHandle(this._handle)
16 : assert(_handle != null, "'_handle' must not be null.");
18 final int _handle;
22 int toRawHandle() => _handle;
29 return _handle == typedOther._handle;
33 int get hashCode => _handle.hashCode;
|
| /third_party/flutter/engine/flutter/shell/platform/fuchsia/dart-pkg/zircon/lib/src/ |
| D | handle.dart | 22 int get _handle native 'Handle_handle';
25 String toString() => 'Handle($_handle)';
29 (other is Handle) && (_handle == other._handle);
32 int get hashCode => _handle.hashCode;
|
| /third_party/libuv/src/win/ |
| D | loop-watcher.c | 90 if (loop->next_##name##_handle == handle) { \
91 loop->next_##name##_handle = handle->name##_next; \
110 (loop)->next_##name##_handle = (loop)->name##_handles; \
112 while ((loop)->next_##name##_handle != NULL) { \
113 handle = (loop)->next_##name##_handle; \
114 (loop)->next_##name##_handle = handle->name##_next; \
|
| /third_party/ejdb/src/bindings/ejdb2_flutter/lib/ |
| D | ejdb2_flutter.dart | 187 int get _handle => _jb._handle;
252 final args = [_handle, qh, collection, qtext, _qspec, _params];
286 [_handle, null, collection, qtext, _qspec, _params]).then((v) => v as int);
300 .invokeListMethod('executeList', [_handle, null, collection, qtext, qspec, _params]);
335 EJDB2._(this._handle);
337 final int _handle;
347 if (_handle == null) {
350 return _mc.invokeMethod('close', [_handle]).catchError(_errorHandler());
365 _handle,
376 _handle,
[all …]
|
| /third_party/node/test/sequential/ |
| D | test-fs-watch.js | 131 oldhandle = w._handle;
132 w._handle = { close: w._handle.close };
149 oldhandle = w._handle;
154 w._handle = {};
|
| /third_party/node/deps/npm/node_modules/set-blocking/ |
| D | index.js | 3 if (stream._handle && stream.isTTY && typeof stream._handle.setBlocking === 'function') {
4 stream._handle.setBlocking(blocking)
|
| /third_party/python/Lib/multiprocessing/ |
| D | connection.py | 115 _handle = None variable in _ConnectionBase
124 self._handle = handle
131 if self._handle is not None:
135 if self._handle is None:
156 return self._handle is None
171 return self._handle
175 if self._handle is not None:
179 self._handle = None
277 _CloseHandle(self._handle)
280 ov, err = _winapi.WriteFile(self._handle, buf, overlapped=True)
[all …]
|
| D | popen_spawn_win32.py | 84 self._handle = hp
108 res = _winapi.WaitForSingleObject(int(self._handle), msecs)
110 code = _winapi.GetExitCodeProcess(self._handle)
123 _winapi.TerminateProcess(int(self._handle), TERMINATE)
|
| /third_party/mesa3d/src/vulkan/runtime/ |
| D | vk_object.h | 123 __driver_type ## _from_handle(__VkType _handle) \
125 struct vk_object_base *base = (struct vk_object_base *)_handle; \
162 __driver_type ## _from_handle(__VkType _handle) \
165 (struct vk_object_base *)(uintptr_t)_handle; \
|