Home
last modified time | relevance | path

Searched refs:ep (Results 1 – 25 of 598) sorted by relevance

12345678910>>...24

/external/grpc-grpc/src/core/lib/security/transport/
Dsecure_endpoint.cc69 secure_endpoint* ep = secure_ep; in destroy() local
70 grpc_endpoint_destroy(ep->wrapped_ep); in destroy()
71 tsi_frame_protector_destroy(ep->protector); in destroy()
72 tsi_zero_copy_grpc_protector_destroy(ep->zero_copy_protector); in destroy()
73 grpc_slice_buffer_destroy_internal(&ep->leftover_bytes); in destroy()
74 grpc_slice_unref_internal(ep->read_staging_buffer); in destroy()
75 grpc_slice_unref_internal(ep->write_staging_buffer); in destroy()
76 grpc_slice_buffer_destroy_internal(&ep->output_buffer); in destroy()
77 grpc_slice_buffer_destroy_internal(&ep->source_buffer); in destroy()
78 gpr_mu_destroy(&ep->protector_mu); in destroy()
[all …]
/external/u-boot/drivers/usb/gadget/
Datmel_usba_udc.c29 static void next_fifo_transaction(struct usba_ep *ep, struct usba_request *req) in next_fifo_transaction() argument
35 if (transaction_len > ep->ep.maxpacket) { in next_fifo_transaction()
36 transaction_len = ep->ep.maxpacket; in next_fifo_transaction()
38 } else if (transaction_len == ep->ep.maxpacket && req->req.zero) { in next_fifo_transaction()
43 ep->ep.name, req, transaction_len, in next_fifo_transaction()
46 memcpy(ep->fifo, req->req.buf + req->req.actual, transaction_len); in next_fifo_transaction()
47 usba_ep_writel(ep, SET_STA, USBA_TX_PK_RDY); in next_fifo_transaction()
51 static void submit_request(struct usba_ep *ep, struct usba_request *req) in submit_request() argument
54 ep->ep.name, req, req->req.length, req->using_dma); in submit_request()
59 next_fifo_transaction(ep, req); in submit_request()
[all …]
Depautoconf.c48 struct usb_ep *ep, in ep_matches() argument
57 if (NULL != ep->driver_data) in ep_matches()
66 if ('e' != ep->name[0]) in ep_matches()
72 if ('-' != ep->name[2]) { in ep_matches()
73 tmp = strrchr(ep->name, '-'); in ep_matches()
98 tmp = ep->name + strlen(ep->name); in ep_matches()
128 if (ep->maxpacket < max) in ep_matches()
146 if (isdigit(ep->name[2])) { in ep_matches()
147 u8 num = simple_strtoul(&ep->name[2], NULL, 10); in ep_matches()
163 int size = ep->maxpacket; in ep_matches()
[all …]
Ddwc2_udc_otg.c84 static int dwc2_ep_enable(struct usb_ep *ep,
86 static int dwc2_ep_disable(struct usb_ep *ep);
87 static struct usb_request *dwc2_alloc_request(struct usb_ep *ep,
89 static void dwc2_free_request(struct usb_ep *ep, struct usb_request *);
91 static int dwc2_queue(struct usb_ep *ep, struct usb_request *, gfp_t gfp_flags);
92 static int dwc2_dequeue(struct usb_ep *ep, struct usb_request *);
93 static int dwc2_fifo_status(struct usb_ep *ep);
94 static void dwc2_fifo_flush(struct usb_ep *ep);
96 static void dwc2_ep0_kick(struct dwc2_udc *dev, struct dwc2_ep *ep);
99 static int write_fifo_ep0(struct dwc2_ep *ep, struct dwc2_request *req);
[all …]
Dat91_udc.c71 static void done(struct at91_ep *ep, struct at91_request *req, int status) in done() argument
73 unsigned stopped = ep->stopped; in done()
74 struct at91_udc *udc = ep->udc; in done()
82 VDBG("%s done %p, status %d\n", ep->ep.name, req, status); in done()
84 ep->stopped = 1; in done()
86 req->req.complete(&ep->ep, &req->req); in done()
88 ep->stopped = stopped; in done()
91 if (list_empty(&ep->queue) && ep->int_mask != (1 << 0)) in done()
92 at91_udp_write(udc, AT91_UDP_IDR, ep->int_mask); in done()
122 static int read_fifo (struct at91_ep *ep, struct at91_request *req) in read_fifo() argument
[all …]
Dpxa25x_udc.c185 if (dev->ep[i].desc == NULL) in dump_state()
187 debug("udccs%d = %02x\n", i, *dev->ep->reg_udccs); in dump_state()
206 static void pxa25x_ep_fifo_flush(struct usb_ep *ep);
297 struct pxa25x_ep *ep; in pxa25x_ep_enable() local
300 ep = container_of(_ep, struct pxa25x_ep, ep); in pxa25x_ep_enable()
301 if (!_ep || !desc || ep->desc || _ep->name == ep0name in pxa25x_ep_enable()
303 || ep->bEndpointAddress != desc->bEndpointAddress in pxa25x_ep_enable()
304 || ep->fifo_size < in pxa25x_ep_enable()
311 if (ep->bmAttributes != desc->bmAttributes in pxa25x_ep_enable()
312 && ep->bmAttributes != USB_ENDPOINT_XFER_BULK in pxa25x_ep_enable()
[all …]
Ddwc2_udc_otg_xfer_dma.c92 static int setdma_rx(struct dwc2_ep *ep, struct dwc2_request *req) in setdma_rx() argument
96 u32 ep_num = ep_index(ep); in setdma_rx()
100 ep_num ? DMA_BUFFER_SIZE : ep->ep.maxpacket); in setdma_rx()
102 ep->len = length; in setdma_rx()
103 ep->dma_buf = buf; in setdma_rx()
108 pktcnt = (length - 1)/(ep->ep.maxpacket) + 1; in setdma_rx()
112 invalidate_dcache_range((unsigned long) ep->dma_buf, in setdma_rx()
113 (unsigned long) ep->dma_buf + in setdma_rx()
114 ROUND(ep->len, CONFIG_SYS_CACHELINE_SIZE)); in setdma_rx()
116 writel((unsigned long) ep->dma_buf, &reg->out_endp[ep_num].doepdma); in setdma_rx()
[all …]
Dfotg210.c31 struct usb_ep ep; member
45 struct fotg210_ep *ep; member
56 struct fotg210_ep ep[1 + CFG_NUM_ENDPOINTS]; member
78 int ep = ep_addr & USB_ENDPOINT_NUMBER_MASK; in ep_reset() local
83 setbits_le32(&regs->iep[ep - 1], IEP_RESET); in ep_reset()
85 clrbits_le32(&regs->iep[ep - 1], IEP_RESET); in ep_reset()
87 clrbits_le32(&regs->iep[ep - 1], IEP_STALL); in ep_reset()
90 setbits_le32(&regs->oep[ep - 1], OEP_RESET); in ep_reset()
92 clrbits_le32(&regs->oep[ep - 1], OEP_RESET); in ep_reset()
94 clrbits_le32(&regs->oep[ep - 1], OEP_STALL); in ep_reset()
[all …]
Dci_udc.c84 static int ci_ep_enable(struct usb_ep *ep,
86 static int ci_ep_disable(struct usb_ep *ep);
87 static int ci_ep_queue(struct usb_ep *ep,
89 static int ci_ep_dequeue(struct usb_ep *ep, struct usb_request *req);
91 ci_ep_alloc_request(struct usb_ep *ep, unsigned int gfp_flags);
92 static void ci_ep_free_request(struct usb_ep *ep, struct usb_request *_req);
259 ci_ep_alloc_request(struct usb_ep *ep, unsigned int gfp_flags) in ci_ep_alloc_request() argument
261 struct ci_ep *ci_ep = container_of(ep, struct ci_ep, ep); in ci_ep_alloc_request()
283 static void ci_ep_free_request(struct usb_ep *ep, struct usb_request *req) in ci_ep_free_request() argument
285 struct ci_ep *ci_ep = container_of(ep, struct ci_ep, ep); in ci_ep_free_request()
[all …]
/external/grpc-grpc/src/core/lib/iomgr/
Dendpoint_cfstream.cc63 static void CFStreamFree(CFStreamEndpoint* ep) { in CFStreamFree() argument
64 grpc_resource_user_unref(ep->resource_user); in CFStreamFree()
65 CFRelease(ep->read_stream); in CFStreamFree()
66 CFRelease(ep->write_stream); in CFStreamFree()
67 CFSTREAM_HANDLE_UNREF(ep->stream_sync, "free"); in CFStreamFree()
68 gpr_free(ep->peer_string); in CFStreamFree()
69 gpr_free(ep); in CFStreamFree()
73 #define EP_REF(ep, reason) CFStreamRef((ep), (reason), __FILE__, __LINE__) argument
74 #define EP_UNREF(ep, reason) CFStreamUnref((ep), (reason), __FILE__, __LINE__) argument
75 static void CFStreamUnref(CFStreamEndpoint* ep, const char* reason, in CFStreamUnref() argument
[all …]
Dendpoint.cc25 void grpc_endpoint_read(grpc_endpoint* ep, grpc_slice_buffer* slices, in grpc_endpoint_read() argument
27 ep->vtable->read(ep, slices, cb); in grpc_endpoint_read()
30 void grpc_endpoint_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in grpc_endpoint_write() argument
32 ep->vtable->write(ep, slices, cb, arg); in grpc_endpoint_write()
35 void grpc_endpoint_add_to_pollset(grpc_endpoint* ep, grpc_pollset* pollset) { in grpc_endpoint_add_to_pollset() argument
36 ep->vtable->add_to_pollset(ep, pollset); in grpc_endpoint_add_to_pollset()
39 void grpc_endpoint_add_to_pollset_set(grpc_endpoint* ep, in grpc_endpoint_add_to_pollset_set() argument
41 ep->vtable->add_to_pollset_set(ep, pollset_set); in grpc_endpoint_add_to_pollset_set()
44 void grpc_endpoint_delete_from_pollset_set(grpc_endpoint* ep, in grpc_endpoint_delete_from_pollset_set() argument
46 ep->vtable->delete_from_pollset_set(ep, pollset_set); in grpc_endpoint_delete_from_pollset_set()
[all …]
Dendpoint.h39 void (*read)(grpc_endpoint* ep, grpc_slice_buffer* slices, grpc_closure* cb);
40 void (*write)(grpc_endpoint* ep, grpc_slice_buffer* slices, grpc_closure* cb,
42 void (*add_to_pollset)(grpc_endpoint* ep, grpc_pollset* pollset);
43 void (*add_to_pollset_set)(grpc_endpoint* ep, grpc_pollset_set* pollset);
44 void (*delete_from_pollset_set)(grpc_endpoint* ep, grpc_pollset_set* pollset);
45 void (*shutdown)(grpc_endpoint* ep, grpc_error* why);
46 void (*destroy)(grpc_endpoint* ep);
47 grpc_resource_user* (*get_resource_user)(grpc_endpoint* ep);
48 char* (*get_peer)(grpc_endpoint* ep);
49 int (*get_fd)(grpc_endpoint* ep);
[all …]
/external/u-boot/board/ti/common/
Dboard_detect.c83 uchar *ep, int epsize) in ti_i2c_eeprom_read() argument
95 return i2c_read(dev_addr, offset, alen, ep, epsize); in ti_i2c_eeprom_read()
123 u32 header, u32 size, uint8_t *ep) in ti_i2c_eeprom_get() argument
168 rc = i2c_read(dev_addr, 0x0, byte, ep, size); in ti_i2c_eeprom_get()
177 struct ti_common_eeprom *ep; in ti_i2c_eeprom_am_set() local
182 ep = TI_EEPROM_DATA; in ti_i2c_eeprom_am_set()
183 if (ep->header == TI_EEPROM_HEADER_MAGIC) in ti_i2c_eeprom_am_set()
187 memset(ep, 0, sizeof(*ep)); in ti_i2c_eeprom_am_set()
188 strncpy(ep->name, name, TI_EEPROM_HDR_NAME_LEN); in ti_i2c_eeprom_am_set()
189 strncpy(ep->version, rev, TI_EEPROM_HDR_REV_LEN); in ti_i2c_eeprom_am_set()
[all …]
/external/u-boot/include/linux/usb/
Dgadget.h94 void (*complete)(struct usb_ep *ep,
113 int (*enable) (struct usb_ep *ep,
115 int (*disable) (struct usb_ep *ep);
117 struct usb_request *(*alloc_request) (struct usb_ep *ep,
119 void (*free_request) (struct usb_ep *ep, struct usb_request *req);
121 int (*queue) (struct usb_ep *ep, struct usb_request *req,
123 int (*dequeue) (struct usb_ep *ep, struct usb_request *req);
125 int (*set_halt) (struct usb_ep *ep, int value);
126 int (*set_wedge)(struct usb_ep *ep);
127 int (*fifo_status) (struct usb_ep *ep);
[all …]
/external/python/cpython2/Lib/test/
Dtest_epoll.py70 ep = select.epoll(16)
73 self.assertTrue(ep.fileno() > 0, ep.fileno())
74 self.assertTrue(not ep.closed)
75 ep.close()
76 self.assertTrue(ep.closed)
77 self.assertRaises(ValueError, ep.fileno)
90 ep = select.epoll(2)
92 ep.register(server.fileno(), select.EPOLLIN | select.EPOLLOUT)
93 ep.register(client.fileno(), select.EPOLLIN | select.EPOLLOUT)
95 ep.close()
[all …]
/external/python/cpython3/Lib/test/
Dtest_epoll.py69 ep = select.epoll(16)
72 self.assertTrue(ep.fileno() > 0, ep.fileno())
73 self.assertTrue(not ep.closed)
74 ep.close()
75 self.assertTrue(ep.closed)
76 self.assertRaises(ValueError, ep.fileno)
99 with select.epoll(16) as ep:
100 self.assertGreater(ep.fileno(), 0)
101 self.assertFalse(ep.closed)
102 self.assertTrue(ep.closed)
[all …]
/external/u-boot/drivers/usb/musb/
Dmusb_udc.c59 #define GET_ENDPOINT(dev,ep) \ argument
60 (((struct usb_device_instance *)(dev))->bus->endpoint_array + ep)
118 w = readw(&musbr->ep[0].ep0.csr0); in musb_db_regs()
124 b = readb(&musbr->ep[0].ep0.configdata); in musb_db_regs()
133 w = readw(&musbr->ep[1].epN.rxmaxp); in musb_db_regs()
136 w = readw(&musbr->ep[1].epN.rxcsr); in musb_db_regs()
139 w = readw(&musbr->ep[1].epN.txmaxp); in musb_db_regs()
142 w = readw(&musbr->ep[1].epN.txcsr); in musb_db_regs()
211 csr0 = readw(&musbr->ep[0].ep0.csr0); in musb_peri_ep0_stall()
213 writew(csr0, &musbr->ep[0].ep0.csr0); in musb_peri_ep0_stall()
[all …]
/external/python/cpython2/Objects/
Ddictobject.c327 register PyDictEntry *ep; in lookdict() local
332 ep = &ep0[i]; in lookdict()
333 if (ep->me_key == NULL || ep->me_key == key) in lookdict()
334 return ep; in lookdict()
336 if (ep->me_key == dummy) in lookdict()
337 freeslot = ep; in lookdict()
339 if (ep->me_hash == hash) { in lookdict()
340 startkey = ep->me_key; in lookdict()
346 if (ep0 == mp->ma_table && ep->me_key == startkey) { in lookdict()
348 return ep; in lookdict()
[all …]
/external/tcpdump/
Dprint-ahcp.c101 ahcp_time_print(netdissect_options *ndo, const u_char *cp, const u_char *ep) in ahcp_time_print() argument
107 if (cp + 4 != ep) in ahcp_time_print()
121 ND_TCHECK2(*cp, ep - cp); in ahcp_time_print()
129 ahcp_seconds_print(netdissect_options *ndo, const u_char *cp, const u_char *ep) in ahcp_seconds_print() argument
131 if (cp + 4 != ep) in ahcp_seconds_print()
139 ND_TCHECK2(*cp, ep - cp); in ahcp_seconds_print()
147 ahcp_ipv6_addresses_print(netdissect_options *ndo, const u_char *cp, const u_char *ep) in ahcp_ipv6_addresses_print() argument
151 while (cp < ep) { in ahcp_ipv6_addresses_print()
152 if (cp + 16 > ep) in ahcp_ipv6_addresses_print()
163 ND_TCHECK2(*cp, ep - cp); in ahcp_ipv6_addresses_print()
[all …]
Dprint-openflow-1.0.c739 const u_char *cp, const u_char *ep, const u_int len) in of10_data_print() argument
752 return ep; in of10_data_print()
757 const u_char *cp, const u_char *ep, const u_int len) in of10_bsn_message_print() argument
899 if (fn_printn(ndo, cp, len - 8, ep)) { in of10_bsn_message_print()
920 if (fn_printn(ndo, cp, len - 4, ep)) { in of10_bsn_message_print()
957 return ep; in of10_bsn_message_print()
962 const u_char *cp, const u_char *ep, const u_int len) in of10_bsn_actions_print() argument
1031 return ep; in of10_bsn_actions_print()
1036 const u_char *cp, const u_char *ep, const u_int len) in of10_vendor_action_print() argument
1052 return decoder(ndo, cp, ep, len - 4); in of10_vendor_action_print()
[all …]
/external/grpc-grpc/test/core/util/
Dtrickle_endpoint.cc49 static void te_read(grpc_endpoint* ep, grpc_slice_buffer* slices, in te_read() argument
51 trickle_endpoint* te = reinterpret_cast<trickle_endpoint*>(ep); in te_read()
64 static void te_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in te_write() argument
66 trickle_endpoint* te = reinterpret_cast<trickle_endpoint*>(ep); in te_write()
81 static void te_add_to_pollset(grpc_endpoint* ep, grpc_pollset* pollset) { in te_add_to_pollset() argument
82 trickle_endpoint* te = reinterpret_cast<trickle_endpoint*>(ep); in te_add_to_pollset()
86 static void te_add_to_pollset_set(grpc_endpoint* ep, in te_add_to_pollset_set() argument
88 trickle_endpoint* te = reinterpret_cast<trickle_endpoint*>(ep); in te_add_to_pollset_set()
92 static void te_delete_from_pollset_set(grpc_endpoint* ep, in te_delete_from_pollset_set() argument
94 trickle_endpoint* te = reinterpret_cast<trickle_endpoint*>(ep); in te_delete_from_pollset_set()
[all …]
Dmock_endpoint.cc43 static void me_read(grpc_endpoint* ep, grpc_slice_buffer* slices, in me_read() argument
45 mock_endpoint* m = reinterpret_cast<mock_endpoint*>(ep); in me_read()
57 static void me_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in me_write() argument
59 mock_endpoint* m = reinterpret_cast<mock_endpoint*>(ep); in me_write()
66 static void me_add_to_pollset(grpc_endpoint* ep, grpc_pollset* pollset) {} in me_add_to_pollset() argument
68 static void me_add_to_pollset_set(grpc_endpoint* ep, in me_add_to_pollset_set() argument
71 static void me_delete_from_pollset_set(grpc_endpoint* ep, in me_delete_from_pollset_set() argument
74 static void me_shutdown(grpc_endpoint* ep, grpc_error* why) { in me_shutdown() argument
75 mock_endpoint* m = reinterpret_cast<mock_endpoint*>(ep); in me_shutdown()
88 static void me_destroy(grpc_endpoint* ep) { in me_destroy() argument
[all …]
/external/u-boot/board/gdsys/common/
Dcmd_ioloop.c62 FPGA_SET_REG(fpga, ep.rx_tx_status, status); in io_check_status()
67 FPGA_SET_REG(fpga, ep.rx_tx_status, status); in io_check_status()
99 FPGA_SET_REG(fpga, ep.transmit_data, *p++); in io_send()
102 FPGA_SET_REG(fpga, ep.transmit_data, k); in io_send()
104 FPGA_SET_REG(fpga, ep.rx_tx_control, in io_send()
115 FPGA_GET_REG(fpga, ep.rx_tx_status, &rx_tx_status); in io_receive()
123 FPGA_GET_REG(fpga, ep.receive_data, &rx); in io_receive()
125 FPGA_GET_REG(fpga, ep.rx_tx_status, &rx_tx_status); in io_receive()
139 FPGA_GET_REG(fpga, ep.rx_tx_status, &rx_tx_status); in io_reflect()
142 FPGA_GET_REG(fpga, ep.receive_data, &buffer[k++]); in io_reflect()
[all …]
/external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/
Dmath.cpp23 [](std::exception_ptr ep){ in __anon97cb0d520402() argument
24 try {std::rethrow_exception(ep);} in __anon97cb0d520402()
51 [](std::exception_ptr ep){ in __anon97cb0d520902() argument
52 try {std::rethrow_exception(ep);} in __anon97cb0d520902()
81 [](std::exception_ptr ep){ in __anon97cb0d520e02() argument
82 try {std::rethrow_exception(ep);} in __anon97cb0d520e02()
109 [](std::exception_ptr ep){ in __anon97cb0d521302() argument
110 try {std::rethrow_exception(ep);} in __anon97cb0d521302()
128 [](std::exception_ptr ep){ in __anon97cb0d521602() argument
129 try {std::rethrow_exception(ep);} in __anon97cb0d521602()
[all …]
/external/wayland/src/
Devent-loop.c56 struct epoll_event *ep);
75 struct epoll_event *ep) in wl_event_source_fd_dispatch() argument
81 if (ep->events & EPOLLIN) in wl_event_source_fd_dispatch()
83 if (ep->events & EPOLLOUT) in wl_event_source_fd_dispatch()
85 if (ep->events & EPOLLHUP) in wl_event_source_fd_dispatch()
87 if (ep->events & EPOLLERR) in wl_event_source_fd_dispatch()
101 struct epoll_event ep; in add_source() local
112 memset(&ep, 0, sizeof ep); in add_source()
114 ep.events |= EPOLLIN; in add_source()
116 ep.events |= EPOLLOUT; in add_source()
[all …]

12345678910>>...24