| /third_party/curl/tests/server/ |
| D | util.c | 8 * Copyright (C) 1998 - 2021, Daniel Stenberg, <daniel@haxx.se>, et al.
118 epoch_offset = time(NULL) - tv.tv_sec; in logmsg()
126 (int)now->tm_hour, (int)now->tm_min, (int)now->tm_sec, in logmsg()
176 logmsg("Error initialising winsock -- aborting"); in win32_init()
184 logmsg("No suitable winsock.dll found -- aborting"); in win32_init()
221 * -1 = system call error, or invalid timeout value
239 return -1; in wait_ms()
257 if(r != -1) in wait_ms()
262 pending_ms = timeout_ms - (int)timediff(tvnow(), initial_tv); in wait_ms()
265 } while(r == -1); in wait_ms()
[all …]
|
| /third_party/node/src/ |
| D | node_watchdog.cc | 24 #include "async_wrap-inl.h"
25 #include "debug_utils-inl.h"
26 #include "env-inl.h"
30 #include "util-inl.h"
53 uv_stop(&w->loop_); in Watchdog()
86 // timer handle. in Run()
87 uv_run(&wd->loop_, UV_RUN_DEFAULT); in Run()
90 // Close the timer handle on this side and let ~Watchdog() close async_ in Run()
91 uv_close(reinterpret_cast<uv_handle_t*>(&wd->timer_), nullptr); in Run()
96 *w->timed_out_ = true; in Timer()
[all …]
|
| /third_party/e2fsprogs/lib/ss/ |
| D | pager.c | 71 * handle SIGINT sensibly
72 * allow finer control -- put-page-break-here
81 return(-1); in ss_pager_create()
84 case -1: in ss_pager_create()
85 return(-1); in ss_pager_create()
90 if (dup2(filedes[0], 0) == -1) in ss_pager_create()
121 return -1; in write_all()
123 count -= ret; in write_all()
137 (void) signal(SIGINT, SIG_DFL); in ss_page_stdin()
139 sigdelset(&mask, SIGINT); in ss_page_stdin()
|
| /third_party/python/Lib/test/ |
| D | test_file_eintr.py | 9 # - gregory.p.smith
92 [sys.executable, '-u', '-c',
94 'signal.signal(signal.SIGINT, '
120 self._process.send_signal(signal.SIGINT)
124 self.fail('reader process failed to handle our signals.')
153 """readline() must handle signals and not lose data."""
161 """readlines() must handle signals and not lose data."""
169 """readall() must handle signals and not lose data."""
198 """BufferedReader.read() must handle signals and not lose data."""
216 'infile = io.open(sys.stdin.fileno(), encoding="utf-8", newline=None) ;'
[all …]
|
| /third_party/libuv/docs/src/ |
| D | signal.rst | 4 :c:type:`uv_signal_t` --- Signal handle
7 Signal handles implement Unix style signal handling on a per-event loop bases.
10 -------------
14 * SIGINT is normally delivered when the user presses CTRL+C. However, like
25 32-bit libuv app is running on 64-bit system, SIGWINCH will be emulated. In
27 For a writable :c:type:`uv_tty_t` handle libuv will only detect size changes
28 when the cursor is moved. When a readable :c:type:`uv_tty_t` handle is used,
29 resizing of the console buffer will be detected only if the handle is in raw
40 .. versionchanged:: 1.31.0 32-bit libuv SIGWINCH support on 64-bit Windows was
44 ----------
[all …]
|
| /third_party/python/Modules/ |
| D | signalmodule.c | 2 /* Signal module -- many thanks to Lance Ellinghaus */
51 # define SIG_ERR ((PyOS_sighandler_t)(-1))
78 - only the main thread can set a signal handler
79 - only the main thread runs the signal handler
80 - signals can be delivered to any thread
81 - any thread can get a signal handler
85 signals as a means of inter-thread communication, since not all
90 generated by the keyboard (e.g. SIGINT) are delivered to all
102 /* func is atomic to ensure that PyErr_SetInterrupt is async-signal-safe
109 #define INVALID_FD ((SOCKET_T)-1)
[all …]
|
| /third_party/node/deps/npm/node_modules/is-callable/ |
| D | .istanbul.yml | 5 - .js
6 - .jsx
7 default-excludes: true
11 preserve-comments: false
12 complete-copy: false
13 save-baseline: false
14 baseline-file: ./coverage/coverage-baseline.raw.json
15 include-all-sources: false
16 include-pid: false
17 es-modules: false
[all …]
|
| /third_party/libwebsockets/minimal-examples/http-server/minimal-http-server-eventlib/ |
| D | minimal-http-server-eventlib.c | 2 * lws-minimal-http-server-eventlib
4 * Written in 2010-2019 by Andy Green <andy@warmcat.com>
13 * "./mount-origin" of the directory it was started in.
24 /* .mount_next */ NULL, /* linked-list "next" */
26 /* .origin */ "./mount-origin", /* serve from dir */
43 void signal_cb(void *handle, int signum) in signal_cb() argument
47 case SIGINT: in signal_cb()
68 * -DCMAKE_BUILD_TYPE=DEBUG instead of =RELEASE */ in main()
73 if ((p = lws_cmdline_option(argc, argv, "-d"))) in main()
78 lwsl_user(" [-s (ssl)] [--uv (libuv)] [--ev (libev)] [--event (libevent)]\n"); in main()
[all …]
|
| /third_party/libwebsockets/lib/plat/windows/ |
| D | private-lib-plat-windows.h | 2 * libwebsockets - small server side websockets and web server implementation
4 * Copyright (C) 2010 - 2019 Andy Green <andy@warmcat.com>
24 * Included from lib/private-lib-core.h if defined(WIN32) || defined(_WIN32)
55 #define lws_set_blocking_send(wsi) wsi->sock_send_blocking = 1
103 #ifndef SIGINT
104 #define SIGINT 2 macro
161 typedef HANDLE lws_filefd_type;
|
| /third_party/openssl/crypto/ui/ |
| D | ui_openssl.c | 2 * Copyright 2001-2022 The OpenSSL Project Authors. All Rights Reserved.
17 * need for #define _POSIX_C_SOURCE arises whenever you pass -ansi to gcc
19 * sigaction and fileno included. -pedantic would be more appropriate for the
20 * intended purposes, but we can't prevent users from adding -ansi.
243 fprintf(tty_out, "Verifying - %s", UI_get0_output_string(uis)); in read_string()
285 int maxsize = BUFSIZ - 1; in read_string_inner()
312 wresult[numread-2] == L'\r' && in read_string_inner()
313 wresult[numread-1] == L'\n') { in read_string_inner()
314 wresult[numread-2] = L'\n'; in read_string_inner()
315 numread--; in read_string_inner()
[all …]
|
| /third_party/ltp/testcases/kernel/controllers/memcg/functional/ |
| D | memcg_process.c | 1 // SPDX-License-Identifier: GPL-2.0-or-later
49 {"mmap-anon", 0, NULL, MMAP_ANON},
50 {"mmap-file", 0, NULL, MMAP_FILE},
51 {"mmap-lock1", 0, NULL, MMAP_LOCK1},
52 {"mmap-lock2", 0, NULL, MMAP_LOCK2},
68 while ((c = getopt_long(argc, argv, "k:s:", long_opts, NULL)) != -1) { in process_options()
76 errx(1, "wrong -s argument!"); in process_options()
126 if (munmap(p, memsize) == -1) in mmap_anon()
156 if (munmap(p, memsize) == -1) in mmap_file()
177 if (munmap(p, memsize) == -1) in mmap_lock1()
[all …]
|
| /third_party/grpc/examples/ruby/ |
| D | greeter_server.rb | 9 # http://www.apache.org/licenses/LICENSE-2.0
41 s.handle(GreeterServer)
42 # Runs the server with SIGHUP, SIGINT and SIGQUIT signal handlers to
|
| /third_party/libwebsockets/minimal-examples/http-server/minimal-http-server-eventlib-smp/ |
| D | minimal-http-server-eventlib-smp.c | 2 * lws-minimal-http-server-eventlib-smp
4 * Written in 2010-2019 by Andy Green <andy@warmcat.com>
13 * "./mount-origin" of the directory it was started in.
36 /* .mount_next */ NULL, /* linked-list "next" */
38 /* .origin */ "./mount-origin", /* serve from dir */
67 void signal_cb(void *handle, int signum) in signal_cb() argument
73 case SIGINT: in signal_cb()
96 * -DCMAKE_BUILD_TYPE=DEBUG instead of =RELEASE */ in main()
101 if ((p = lws_cmdline_option(argc, argv, "-d"))) in main()
106 lwsl_user(" [-s (ssl)] [--uv (libuv)] [--ev (libev)] [--event (libevent)]\n"); in main()
[all …]
|
| /third_party/curl/docs/examples/ |
| D | crawler.c | 9 * Copyright (C) 2018 - 2020 Jeroen Ooms <jeroenooms@gmail.com>
13 * gcc crawler.c $(pkg-config --cflags --libs libxml-2.0 libcurl)
17 * Web crawler based on curl and libxml2 to stress-test curl with
55 char *ptr = realloc(mem->buf, mem->size + realsize); in grow_buffer()
61 mem->buf = ptr; in grow_buffer()
62 memcpy(&(mem->buf[mem->size]), contents, realsize); in grow_buffer()
63 mem->size += realsize; in grow_buffer()
69 CURL *handle = curl_easy_init(); in make_handle() local
72 curl_easy_setopt(handle, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_2TLS); in make_handle()
73 curl_easy_setopt(handle, CURLOPT_URL, url); in make_handle()
[all …]
|
| /third_party/python/Doc/library/ |
| D | _thread.rst | 1 :mod:`_thread` --- Low-level threading API
5 :synopsis: Low-level threading API.
8 single: light-weight processes
9 single: processes, light-weight
13 --------------
15 This module provides low-level primitives for working with multiple threads
16 (also called :dfn:`light-weight processes` or :dfn:`tasks`) --- multiple threads of
19 The :mod:`threading` module provides an easier to use and higher-level
33 Raised on thread-specific errors.
36 This is now a synonym of the built-in :exc:`RuntimeError`.
[all …]
|
| /third_party/libuv/src/win/ |
| D | signal.c | 26 #include "handle-inl.h"
27 #include "req-inl.h"
37 int uv__signal_start(uv_signal_t* handle,
57 if (w1->signum < w2->signum) return -1; in uv__signal_compare()
58 if (w1->signum > w2->signum) return 1; in uv__signal_compare()
62 if ((uintptr_t) w1->loop < (uintptr_t) w2->loop) return -1; in uv__signal_compare()
63 if ((uintptr_t) w1->loop > (uintptr_t) w2->loop) return 1; in uv__signal_compare()
65 if ((uintptr_t) w1 < (uintptr_t) w2) return -1; in uv__signal_compare()
82 uv_signal_t* handle; in RB_GENERATE_STATIC() local
92 for (handle = RB_NFIND(uv_signal_tree_s, &uv__signal_tree, &lookup); in RB_GENERATE_STATIC()
[all …]
|
| /third_party/grpc/src/ruby/end2end/ |
| D | sig_handling_client.rb | 9 # http://www.apache.org/licenses/LICENSE-2.0
51 opts.on('--client_control_port=P', String) do |p|
54 opts.on('--server_port=P', String) do |p|
64 STDERR.puts 'SIGINT received'
75 srv.handle(control_service)
|
| /third_party/libwebsockets/minimal-examples/http-server/minimal-http-server-eventlib-demos/ |
| D | minimal-http-server-eventlib-demos.c | 2 * lws-minimal-http-server-eventlib
4 * Written in 2010-2019 by Andy Green <andy@warmcat.com>
13 * "./mount-origin" of the directory it was started in.
32 { "http-only", lws_callback_http_dummy, 0, 0, 0, NULL, 0 },
45 NULL, /* linked-list pointer to next*/
47 "./mount-origin/candide-uncompressed.zip", /* handler */
63 (struct lws_http_mount *)&mount_ziptest_uncomm, /* linked-list pointer to next*/
65 "./mount-origin/candide.zip", /* handler */
82 (struct lws_http_mount *)&mount_ziptest, /* linked-list pointer to next*/
84 "protocol-post-demo", /* handler */
[all …]
|
| /third_party/node/deps/uvwasi/src/ |
| D | uv_mapping.c | 133 #ifdef SIGINT in uvwasi__translate_to_uv_signal()
134 case UVWASI_SIGINT: return SIGINT; in uvwasi__translate_to_uv_signal()
187 default: return -1; in uvwasi__translate_to_uv_signal()
193 /* TODO(cjihrig): Handle overflow. */ in uvwasi__timespec_to_timestamp()
194 return (uvwasi_timestamp_t) ts->tv_sec * NANOS_PER_SEC + ts->tv_nsec; in uvwasi__timespec_to_timestamp()
201 mode = stat->st_mode; in uvwasi__stat_to_filetype()
235 fs->st_dev = stat->st_dev; in uvwasi__stat_to_filestat()
236 fs->st_ino = stat->st_ino; in uvwasi__stat_to_filestat()
237 fs->st_nlink = stat->st_nlink; in uvwasi__stat_to_filestat()
238 fs->st_size = stat->st_size; in uvwasi__stat_to_filestat()
[all …]
|
| /third_party/libuv/docs/code/pipe-echo-server/ |
| D | main.c | 21 free(wr->buf.base); in free_write_req()
25 void alloc_buffer(uv_handle_t *handle, size_t suggested_size, uv_buf_t *buf) { in alloc_buffer() argument
26 buf->base = malloc(suggested_size); in alloc_buffer()
27 buf->len = suggested_size; in alloc_buffer()
40 req->buf = uv_buf_init(buf->base, nread); in echo_read()
41 uv_write((uv_write_t*) req, client, &req->buf, 1, echo_write); in echo_read()
51 free(buf->base); in echo_read()
55 if (status == -1) { in on_new_connection()
82 signal(SIGINT, remove_sock); in main()
|
| /third_party/boost/libs/asio/example/cpp03/http/server2/ |
| D | server.cpp | 5 // Copyright (c) 2003-2021 Christopher M. Kohlhoff (chris at kohlhoff dot com)
25 // Register to handle the signals that indicate when the server should exit. in server()
28 signals_.add(SIGINT); in server()
56 acceptor_.async_accept(new_connection_->socket(), in start_accept()
65 new_connection_->start(); in handle_accept()
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/http/server2/ |
| D | server.cpp | 5 // Copyright (c) 2003-2020 Christopher M. Kohlhoff (chris at kohlhoff dot com)
25 // Register to handle the signals that indicate when the server should exit. in server()
28 signals_.add(SIGINT); in server()
56 acceptor_.async_accept(new_connection_->socket(), in start_accept()
65 new_connection_->start(); in handle_accept()
|
| /third_party/wayland-ivi-extension/ivi-layermanagement-examples/simple-weston-client/src/ |
| D | simple-weston-client.c | 35 #include <wayland-cursor.h>
36 #include <ivi-application-client-protocol.h>
41 #include "weston-debug-client-protocol.h"
105 "left-arrow"
117 wlcontext->enable_cursor = (uint8_t)strtol(option, &end, 0); in get_bkgnd_settings_cursor_info()
119 wlcontext->enable_cursor = 0; in get_bkgnd_settings_cursor_info()
126 bkgnd_settings->surface_id = strtol(option, &end, 0); in get_bkgnd_settings_cursor_info()
128 bkgnd_settings->surface_id = 10; in get_bkgnd_settings_cursor_info()
130 bkgnd_settings->surface_width = 1; in get_bkgnd_settings_cursor_info()
131 bkgnd_settings->surface_height = 1; in get_bkgnd_settings_cursor_info()
[all …]
|
| /third_party/boost/libs/asio/example/cpp03/http/server/ |
| D | server.cpp | 5 // Copyright (c) 2003-2021 Christopher M. Kohlhoff (chris at kohlhoff dot com)
27 // Register to handle the signals that indicate when the server should exit. in server()
30 signals_.add(SIGINT); in server()
62 acceptor_.async_accept(new_connection_->socket(), in start_accept()
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/http/server/ |
| D | server.cpp | 5 // Copyright (c) 2003-2020 Christopher M. Kohlhoff (chris at kohlhoff dot com)
27 // Register to handle the signals that indicate when the server should exit. in server()
30 signals_.add(SIGINT); in server()
62 acceptor_.async_accept(new_connection_->socket(), in start_accept()
|