| /external/libevent/ |
| D | event_iocp.c | 66 struct event_iocp_port *port = port_; in loop() local
67 long ms = port->ms; in loop()
68 HANDLE p = port->port; in loop()
79 EnterCriticalSection(&port->lock); in loop()
80 if (port->shutdown) { in loop()
81 if (--port->n_live_threads == 0) in loop()
82 ReleaseSemaphore(port->shutdownSemaphore, 1, in loop()
84 LeaveCriticalSection(&port->lock); in loop()
87 LeaveCriticalSection(&port->lock); in loop()
95 EnterCriticalSection(&port->lock); in loop()
[all …]
|
| /external/tensorflow/tensorflow/stream_executor/platform/default/ |
| D | dso_loader.h | 37 port::StatusOr<void*> GetCudaDriverDsoHandle();
38 port::StatusOr<void*> GetCudaRuntimeDsoHandle();
39 port::StatusOr<void*> GetCublasDsoHandle();
40 port::StatusOr<void*> GetCublasLtDsoHandle();
41 port::StatusOr<void*> GetCufftDsoHandle();
42 port::StatusOr<void*> GetCurandDsoHandle();
43 port::StatusOr<void*> GetCusolverDsoHandle();
44 port::StatusOr<void*> GetCusparseDsoHandle();
45 port::StatusOr<void*> GetCuptiDsoHandle();
46 port::StatusOr<void*> GetCudnnDsoHandle();
[all …]
|
| D | dso_loader.cc | 43 port::StatusOr<void*> GetDsoHandle(const string& name, const string& version) { in GetDsoHandle()
44 auto filename = port::Env::Default()->FormatLibraryFileName(name, version); in GetDsoHandle()
46 port::Status status = in GetDsoHandle()
47 port::Env::Default()->LoadDynamicLibrary(filename.c_str(), &dso_handle); in GetDsoHandle()
61 return port::Status(port::error::FAILED_PRECONDITION, message); in GetDsoHandle()
66 port::StatusOr<void*> GetCudaDriverDsoHandle() { in GetCudaDriverDsoHandle()
80 port::StatusOr<void*> GetCudaRuntimeDsoHandle() { in GetCudaRuntimeDsoHandle()
84 port::StatusOr<void*> GetCublasDsoHandle() { in GetCublasDsoHandle()
88 port::StatusOr<void*> GetCublasLtDsoHandle() { in GetCublasLtDsoHandle()
92 port::StatusOr<void*> GetCufftDsoHandle() { in GetCufftDsoHandle()
[all …]
|
| /external/selinux/libsepol/src/ |
| D | port_record.c | 63 const sepol_port_t * port, in hidden_def()
68 (handle, port->low, port->high, port->proto, key_ptr) < 0) { in hidden_def()
71 sepol_port_get_proto_str(port->proto), in hidden_def()
72 port->low, port->high); in hidden_def()
85 int sepol_port_compare(const sepol_port_t * port, const sepol_port_key_t * key) in sepol_port_compare() argument
88 if ((port->low == key->low) && in sepol_port_compare()
89 (port->high == key->high) && (port->proto == key->proto)) in sepol_port_compare()
92 if (port->low < key->low) in sepol_port_compare()
95 else if (key->low < port->low) in sepol_port_compare()
98 else if (port->high < key->high) in sepol_port_compare()
[all …]
|
| D | ibendport_record.c | 17 int port; member
28 int port; member
51 int port, in sepol_ibendport_key_create() argument
66 tmp_key->port = port; in sepol_ibendport_key_create()
77 ibdev_name, port); in sepol_ibendport_key_create()
84 const char **ibdev_name, int *port) in hidden_def()
87 *port = key->port; in hidden_def()
97 (handle, ibendport->ibdev_name, ibendport->port, key_ptr) < 0) { in hidden_def()
100 ibendport->port); in hidden_def()
122 if ((ibendport->port == key->port) && !rc) in sepol_ibendport_compare()
[all …]
|
| D | ports.c | 57 ocontext_t ** port, const sepol_port_t * data) in port_from_record() argument
76 tmp_port->u.port.protocol = tmp_proto; in port_from_record()
79 tmp_port->u.port.low_port = low; in port_from_record()
80 tmp_port->u.port.high_port = high; in port_from_record()
81 if (tmp_port->u.port.low_port > tmp_port->u.port.high_port) { in port_from_record()
83 tmp_port->u.port.low_port, tmp_port->u.port.high_port); in port_from_record()
96 *port = tmp_port; in port_from_record()
116 ocontext_t * port, sepol_port_t ** record) in port_to_record() argument
119 int proto = port->u.port.protocol; in port_to_record()
120 int low = port->u.port.low_port; in port_to_record()
[all …]
|
| /external/autotest/server/cros/servo/ |
| D | pd_console.py | 100 def execute_pd_state_cmd(self, port): argument
114 pd_cmd = cmd +" " + str(port) + " " + subcmd
130 (port, key))
134 def get_pd_state(self, port): argument
141 def get_pd_port(self, port): argument
147 pd_dict = self.execute_pd_state_cmd(port)
150 def get_pd_role(self, port): argument
156 pd_dict = self.execute_pd_state_cmd(port)
159 def get_pd_flags(self, port): argument
165 pd_dict = self.execute_pd_state_cmd(port)
[all …]
|
| /external/libchrome/mojo/core/ports/ |
| D | node.cc | 82 bool CanAcceptMoreMessages(const Port* port) { in CanAcceptMoreMessages() argument
85 uint64_t next_sequence_num = port->message_queue.next_sequence_num(); in CanAcceptMoreMessages()
86 if (port->state == Port::kClosed) in CanAcceptMoreMessages()
88 if (port->peer_closed || port->remove_proxy_on_last_message) { in CanAcceptMoreMessages()
89 if (port->last_sequence_num_to_receive == next_sequence_num - 1) in CanAcceptMoreMessages()
133 auto* port = locker.port(); in CanShutdownCleanly() local
134 if (port->peer_node_name != name_ && port->state != Port::kReceiving) { in CanShutdownCleanly()
138 << port->peer_node_name << " is blocking shutdown of " in CanShutdownCleanly()
139 << "node " << name_ << " (state=" << port->state << ")"; in CanShutdownCleanly()
170 scoped_refptr<Port> port(new Port(kInitialSequenceNum, kInitialSequenceNum)); in CreateUninitializedPort() local
[all …]
|
| /external/selinux/libsemanage/src/ |
| D | port_record.c | 27 int semanage_port_compare(const semanage_port_t * port, in semanage_port_compare() argument
31 return sepol_port_compare(port, key); in semanage_port_compare()
36 int semanage_port_compare2(const semanage_port_t * port, in hidden_def()
40 return sepol_port_compare2(port, port2); in hidden_def()
45 hidden int semanage_port_compare2_qsort(const semanage_port_t ** port, in hidden_def()
49 return sepol_port_compare2(*port, *port2); in hidden_def()
61 const semanage_port_t * port, in semanage_port_key_extract() argument
65 return sepol_port_key_extract(handle->sepolh, port, key_ptr); in semanage_port_key_extract()
79 int semanage_port_get_proto(const semanage_port_t * port) in hidden_def()
82 return sepol_port_get_proto(port); in hidden_def()
[all …]
|
| /external/autotest/client/site_tests/usbpd_GFU/ |
| D | usbpd_GFU.py | 65 def _is_gfu(self, port): argument
72 return port.is_amode_supported(self.GOOGLE_VID)
74 def _is_in_rw(self, port): argument
81 flash_info = port.get_flash_info()
95 def _modify_rw(self, port, rw=None, tries=3): argument
117 port.ec_command('flashpd 0 %d %s' % (port.index, rw),
126 if rw != '/dev/null' and not self._is_in_rw(port):
128 port.index)
135 msg = self._reader.get_last_msg([r'%s.*is in RO' % port.index,
140 port.index)
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/service/interpreter/ |
| D | executor.h | 56 port::Status Init(int device_ordinal, DeviceOptions device_options) override { in Init()
57 return port::Status::OK(); in Init()
60 port::Status GetKernel(const MultiKernelLoaderSpec &spec, in GetKernel()
62 return port::UnimplementedError("Not Implemented"); in GetKernel()
64 port::Status Launch(Stream *stream, const ThreadDim &thread_dims, in Launch()
67 return port::UnimplementedError("Not Implemented"); in Launch()
92 port::Status MemZero(Stream *stream, DeviceMemoryBase *location, in MemZero()
94 return port::InternalError("Interpreter can not memzero"); in MemZero()
96 port::Status Memset(Stream *stream, DeviceMemoryBase *location, uint8 pattern, in Memset()
98 return port::InternalError("Interpreter can not memset"); in Memset()
[all …]
|
| /external/python/cpython2/Demo/sockets/ |
| D | gopher.py | 41 def open_socket(host, port): argument
42 if not port:
43 port = DEF_PORT
44 elif type(port) == type(''):
45 port = string.atoi(port)
47 s.connect((host, port))
51 def send_request(selector, host, port): argument
52 s = open_socket(host, port)
58 def get_menu(selector, host, port): argument
59 f = send_request(selector, host, port)
[all …]
|
| /external/tensorflow/tensorflow/stream_executor/gpu/ |
| D | gpu_driver.h | 63 static port::Status Init();
68 static port::StatusOr<GpuDeviceHandle> DeviceFromContext(GpuContext* context);
91 static port::Status InitEvent(GpuContext* context, GpuEventHandle* result,
97 static port::Status DestroyEvent(GpuContext* context, GpuEventHandle* event);
155 static port::StatusOr<VmemSpan> ReserveVirtualMemory(GpuContext* context,
166 static port::StatusOr<uint64> GetMinAllocationGranularity(
177 static port::StatusOr<GenericMemoryHandle> CreateMemoryHandle(
189 static port::Status MapMemory(
206 static port::Status GetDevice(int device_ordinal, GpuDeviceHandle* device);
210 static port::Status GetDeviceName(GpuDeviceHandle device,
[all …]
|
| /external/igt-gpu-tools/lib/ |
| D | igt_chamelium.h | 109 unsigned int chamelium_port_get_type(const struct chamelium_port *port);
111 struct chamelium_port *port,
113 const char *chamelium_port_get_name(struct chamelium_port *port);
116 void chamelium_plug(struct chamelium *chamelium, struct chamelium_port *port);
117 void chamelium_unplug(struct chamelium *chamelium, struct chamelium_port *port);
119 struct chamelium_port *port);
121 struct chamelium_port *port,
124 struct chamelium_port *port, ...);
126 struct chamelium_port *port,
129 struct chamelium_port *port, int delay_ms,
[all …]
|
| /external/nist-sip/java/gov/nist/core/net/ |
| D | DefaultNetworkLayer.java | 69 public ServerSocket createServerSocket(int port, int backlog, in createServerSocket() argument
71 return new ServerSocket(port, backlog, bindAddress); in createServerSocket()
74 public Socket createSocket(InetAddress address, int port) in createSocket() argument
76 return new Socket(address, port); in createSocket()
83 public DatagramSocket createDatagramSocket(int port, InetAddress laddr) in createDatagramSocket() argument
88 MulticastSocket ds = new MulticastSocket( port ); in createDatagramSocket()
94 } else return new DatagramSocket(port, laddr); in createDatagramSocket()
98 public SSLServerSocket createSSLServerSocket(int port, int backlog, in createSSLServerSocket() argument
101 port, backlog, bindAddress); in createSSLServerSocket()
105 public SSLSocket createSSLSocket(InetAddress address, int port) in createSSLSocket() argument
[all …]
|
| /external/tensorflow/tensorflow/stream_executor/rocm/ |
| D | rocm_diagnostics.cc | 51 string DriverVersionStatusToString(port::StatusOr<DriverVersion> version) { in DriverVersionStatusToString()
59 port::StatusOr<DriverVersion> StringToDriverVersion(const string& value) { in StringToDriverVersion()
62 return port::Status{port::error::INVALID_ARGUMENT, in StringToDriverVersion()
71 if (!port::safe_strto32(pieces[0], &major)) { in StringToDriverVersion()
72 return port::Status{ in StringToDriverVersion()
73 port::error::INVALID_ARGUMENT, in StringToDriverVersion()
78 if (!port::safe_strto32(pieces[1], &minor)) { in StringToDriverVersion()
79 return port::Status{ in StringToDriverVersion()
80 port::error::INVALID_ARGUMENT, in StringToDriverVersion()
85 if (pieces.size() == 3 && !port::safe_strto32(pieces[2], &patch)) { in StringToDriverVersion()
[all …]
|
| D | rocm_driver.cc | 49 return port::InternalError(absl::StrCat( \
125 port::ThreadPool* GetDriverExecutor() { in GetDriverExecutor()
126 static port::ThreadPool* thread_pool = new port::ThreadPool( in GetDriverExecutor()
127 port::Env::Default(), port::ThreadOptions(), "rocm_driver", 1); in GetDriverExecutor()
162 << " :: " << port::CurrentStackTrace(); in SynchronizeOrDie()
292 static port::Status InternalInit() { in InternalInit()
301 return port::Status::OK(); in InternalInit()
306 return port::Status{port::error::ABORTED, in InternalInit()
312 /* static */ port::Status GpuDriver::Init() { in Init()
315 static port::Status* init_retval = [] { in Init()
[all …]
|
| /external/selinux/libsemanage/tests/ |
| D | test_port.c | 132 semanage_port_t *port; in get_port_nth() local
143 port = records[idx]; in get_port_nth()
149 return port; in get_port_nth()
155 semanage_port_t *port; in get_port_key_nth() local
161 port = get_port_nth(idx); in get_port_key_nth()
163 res = semanage_port_key_extract(sh, port, &key); in get_port_key_nth()
173 semanage_port_t *port; in add_local_port() local
178 port = get_port_nth(port_idx); in add_local_port()
180 CU_ASSERT_FATAL(semanage_port_key_extract(sh, port, &key) >= 0); in add_local_port()
183 CU_ASSERT_FATAL(semanage_port_modify_local(sh, key, port) >= 0); in add_local_port()
[all …]
|
| /external/tensorflow/tensorflow/stream_executor/ |
| D | multi_platform_manager.cc | 33 port::Status RegisterPlatform(std::unique_ptr<Platform> platform)
36 port::StatusOr<Platform*> PlatformWithName(absl::string_view target)
39 port::StatusOr<Platform*> PlatformWithId(const Platform::Id& id)
42 port::StatusOr<Platform*> PlatformWithName(absl::string_view target,
46 port::StatusOr<Platform*> PlatformWithId(const Platform::Id& id,
50 port::StatusOr<Platform*> InitializePlatformWithName(
53 port::StatusOr<Platform*> InitializePlatformWithId(
57 port::StatusOr<std::vector<Platform*>> PlatformsWithFilter(
62 port::Status RegisterListener(std::unique_ptr<Listener> listener)
68 port::StatusOr<Platform*> LookupByNameLocked(absl::string_view target)
[all …]
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | resolve_address_custom.cc | 41 char* port; member
51 if (strcmp(r->port, svc[i][0]) == 0) { in retry_named_port_failure()
52 gpr_free(r->port); in retry_named_port_failure()
53 r->port = gpr_strdup(svc[i][1]); in retry_named_port_failure()
56 resolve_address_vtable->resolve(r->host, r->port, res); in retry_named_port_failure()
62 resolve_address_vtable->resolve_async(r, r->host, r->port); in retry_named_port_failure()
84 gpr_free(r->port); in grpc_custom_resolve_callback()
90 char** port) { in try_split_host_port() argument
93 gpr_split_host_port(name, host, port); in try_split_host_port()
101 if (*port == nullptr) { in try_split_host_port()
[all …]
|
| /external/tensorflow/tensorflow/core/platform/windows/ |
| D | net.cc | 35 bool IsPortAvailable(int* port, bool is_tcp) { in IsPortAvailable() argument
43 CHECK_GE(*port, 0); in IsPortAvailable()
44 CHECK_LE(*port, 65535); in IsPortAvailable()
63 addr.sin_port = htons((uint16_t)*port); in IsPortAvailable()
66 LOG(WARNING) << "bind(port=" << *port in IsPortAvailable()
83 if (*port == 0) { in IsPortAvailable()
84 *port = actual_port; in IsPortAvailable()
86 CHECK_EQ(*port, actual_port); in IsPortAvailable()
111 int port; in PickUnusedPortOrDie() local
116 port = GetCurrentProcessId() % (65536 - 30000) + 30000; in PickUnusedPortOrDie()
[all …]
|
| /external/tensorflow/tensorflow/core/platform/default/ |
| D | net.cc | 39 bool IsPortAvailable(int* port, bool is_tcp) { in IsPortAvailable() argument
47 CHECK_GE(*port, 0); in IsPortAvailable()
48 CHECK_LE(*port, MAX_EPHEMERAL_PORT); in IsPortAvailable()
67 addr.sin_port = htons(static_cast<uint16_t>(*port)); in IsPortAvailable()
69 LOG(WARNING) << "bind(port=" << *port << ") failed: " << strerror(errno); in IsPortAvailable()
88 if (*port == 0) { in IsPortAvailable()
89 *port = actual_port; in IsPortAvailable()
91 CHECK_EQ(*port, actual_port); in IsPortAvailable()
111 int port; in PickUnusedPortOrDie() local
116 port = getpid() % (MAX_EPHEMERAL_PORT - MIN_EPHEMERAL_PORT) + in PickUnusedPortOrDie()
[all …]
|
| /external/tensorflow/tensorflow/stream_executor/cuda/ |
| D | cuda_diagnostics.cc | 61 std::string DriverVersionStatusToString(port::StatusOr<DriverVersion> version) { in DriverVersionStatusToString()
69 port::StatusOr<DriverVersion> StringToDriverVersion(const std::string &value) { in StringToDriverVersion()
72 return port::Status( in StringToDriverVersion()
73 port::error::INVALID_ARGUMENT, in StringToDriverVersion()
83 if (!port::safe_strto32(pieces[0], &major)) { in StringToDriverVersion()
84 return port::Status( in StringToDriverVersion()
85 port::error::INVALID_ARGUMENT, in StringToDriverVersion()
90 if (!port::safe_strto32(pieces[1], &minor)) { in StringToDriverVersion()
91 return port::Status( in StringToDriverVersion()
92 port::error::INVALID_ARGUMENT, in StringToDriverVersion()
[all …]
|
| /external/tcpdump/tests/ |
| D | mstp-v.out | 2 port-role Root, CIST root-id 0000.00:1f:27:b4:7d:80, CIST ext-pathcost 200000
3 CIST regional-root-id 8000.00:16:46:b5:8c:80, CIST port-id 8012,
8 MSTI 1, Flags [Learn, Forward, Agreement, Topology change ACK], port-role Designated
10 MSTI bridge-prio 6, port-prio 8, hops 20
11 MSTI 2, Flags [Learn, Forward, Agreement, Topology change ACK], port-role Root
13 MSTI bridge-prio 8, port-prio 8, hops 20
15 port-role Designated, CIST root-id 0000.00:1f:27:b4:7d:80, CIST ext-pathcost 200000
16 CIST regional-root-id 8000.00:16:46:b5:8c:80, CIST port-id 800f,
21 MSTI 1, Flags [Learn, Forward, Agreement, Topology change ACK], port-role Root
23 MSTI bridge-prio 8, port-prio 8, hops 20
[all …]
|
| /external/grpc-grpc/test/core/util/ |
| D | port.cc | 42 static int free_chosen_port(int port) { in free_chosen_port() argument
49 if (chosen_ports[i] == port) { in free_chosen_port()
58 grpc_free_port_using_server(port); in free_chosen_port()
73 static void chose_port(int port) { in chose_port() argument
80 chosen_ports[num_chosen_ports - 1] = port; in chose_port()
84 int port = grpc_pick_port_using_server(); in grpc_pick_unused_port_impl() local
85 if (port != 0) { in grpc_pick_unused_port_impl()
86 chose_port(port); in grpc_pick_unused_port_impl()
89 return port; in grpc_pick_unused_port_impl()
93 int port = grpc_pick_unused_port(); in grpc_pick_unused_port_or_die_impl() local
[all …]
|