Home
last modified time | relevance | path

Searched defs:fd (Results 1 – 25 of 83) sorted by relevance

1234

/trafficserver/mgmt/api/
H A DTSControlMain.cc280 send_record_get_response(int fd, const RecRecord *rec) in send_record_get_response()
347 int *fd = static_cast<int *>(edata); in send_record_get() local
352 handle_record_get(int fd, void *req, size_t reqlen) in handle_record_get()
388 int fd; member
404 handle_record_match(int fd, void *req, size_t reqlen) in handle_record_match()
447 handle_record_set(int fd, void *req, size_t reqlen) in handle_record_set()
533 handle_reconfigure(int fd, void *req, size_t reqlen) in handle_reconfigure()
554 handle_restart(int fd, void *req, size_t reqlen) in handle_restart()
586 handle_stop(int fd, void *req, size_t reqlen) in handle_stop()
608 handle_drain(int fd, void *req, size_t reqlen) in handle_drain()
[all …]
H A DNetworkUtilsRemote.h77 int fd; member
80 #define MGMTAPI_SEND_MESSAGE(fd, optype, ...) send_mgmt_request(mgmtapi_sender(fd), (optype), __VA_… argument
H A DNetworkUtilsRemote.cc80 socket_test(int fd) in socket_test()
328 socket_write_conn(int fd, const void *msg_buf, size_t bytes) in socket_write_conn()
451 send_register_all_callbacks(int fd, CallbackTable *cb_table) in send_register_all_callbacks()
508 send_unregister_all_callbacks(int fd, CallbackTable *cb_table) in send_unregister_all_callbacks()
563 parse_generic_response(OpType optype, int fd) in parse_generic_response()
H A DNetworkMessage.cc151 send_mgmt_request(int fd, OpType optype, ...) in send_mgmt_request()
201 send_mgmt_error(int fd, OpType optype, TSMgmtError error) in send_mgmt_error()
271 send_mgmt_response(int fd, OpType optype, ...) in send_mgmt_response()
350 recv_mgmt_message(int fd, MgmtMarshallData &msg) in recv_mgmt_message()
H A DTSControlMain.h38 int fd; member
H A DNetworkUtilsLocal.cc55 preprocess_msg(int fd, void **req, size_t *reqlen) in preprocess_msg()
H A DCoreAPIShared.cc244 poll_read(int fd, int timeout) in poll_read()
265 poll_write(int fd, int timeout) in poll_write()
H A DEventControlMain.h42 int fd; // client socket member
/trafficserver/iocore/eventsystem/
H A DP_UnixSocketManager.h72 SocketManager::read(int fd, void *buf, int size, void * /* pOLP ATS_UNUSED */) in read()
99 SocketManager::readv(int fd, struct iovec *vector, size_t count) in readv()
156 SocketManager::read_vector(int fd, struct iovec *vector, size_t count, void *pOLP) in read_vector()
162 SocketManager::recv(int fd, void *buf, int size, int flags) in recv()
199 SocketManager::write(int fd, void *buf, int size, void * /* pOLP ATS_UNUSED */) in write()
224 SocketManager::writev(int fd, struct iovec *vector, size_t count) in writev()
237 SocketManager::write_vector(int fd, struct iovec *vector, size_t count, void *pOLP) in write_vector()
243 SocketManager::send(int fd, void *buf, int size, int flags) in send()
279 SocketManager::lseek(int fd, off_t offset, int whence) in lseek()
291 SocketManager::fstat(int fd, struct stat *buf) in fstat()
[all …]
H A DSocketManager.cc40 int fd, err; in accept4() local
70 int fd = ::accept4(s, addr, addrlen, flags); in accept4() local
118 ats_scoped_fd fd(::open("/proc/sys/net/ipv4/tcp_fastopen", O_RDONLY)); in fastopen_supported() local
/trafficserver/src/tscore/
H A Dink_sock.cc81 safe_fcntl(int fd, int cmd, int arg) in safe_fcntl()
91 safe_set_fl(int fd, int arg) in safe_set_fl()
103 safe_clr_fl(int fd, int arg) in safe_clr_fl()
115 safe_nonblocking(int fd) in safe_nonblocking()
121 safe_blocking(int fd) in safe_blocking()
127 read_ready(int fd, int timeout_msec) in read_ready()
146 safe_ioctl(int fd, int request, char *arg) in safe_ioctl()
197 fd_read_char(int fd) in fd_read_char()
213 fd_read_line(int fd, char *s, int len) in fd_read_line()
H A DTextBuffer.cc162 TextBuffer::rawReadFromFile(int fd) in rawReadFromFile()
190 TextBuffer::slurp(int fd) in slurp()
205 TextBuffer::readFromFD(int fd) in readFromFD()
H A Dink_file.cc99 ink_file_fd_readline(int fd, int bufsz, char *buf) in ink_file_fd_readline()
128 ink_file_fd_writestring(int fd, const char *buf) in ink_file_fd_writestring()
379 ink_file_fd_zerofill(int fd, off_t size) in ink_file_fd_zerofill()
H A DBaseLogFile.cc378 BaseLogFile::display(FILE *fd) in display()
482 int fd = elevating_open(_filename, O_RDONLY); in _read_from_file() local
526 int fd = elevating_open(_filename, O_WRONLY | O_CREAT | O_TRUNC, LOGFILE_DEFAULT_PERMS); in _write_to_file() local
H A Dtest_geometry.cc36 int fd; in main() local
/trafficserver/mgmt/utils/
H A DMgmtMarshall.cc58 socket_read_bytes(int fd, void *buf, size_t needed) in socket_read_bytes()
92 socket_write_bytes(int fd, const void *buf, ssize_t bytes) in socket_write_bytes()
119 socket_write_buffer(int fd, const MgmtMarshallData *data) in socket_write_buffer()
142 socket_read_buffer(int fd, MgmtMarshallData *data) in socket_read_buffer()
251 mgmt_message_write(int fd, const MgmtMarshallType *fields, unsigned count, ...) in mgmt_message_write()
264 mgmt_message_write_v(int fd, const MgmtMarshallType *fields, unsigned count, va_list ap) in mgmt_message_write_v()
312 mgmt_message_read(int fd, const MgmtMarshallType *fields, unsigned count, ...) in mgmt_message_read()
325 mgmt_message_read_v(int fd, const MgmtMarshallType *fields, unsigned count, va_list ap) in mgmt_message_read_v()
H A DMgmtSocket.cc214 mgmt_sendto(int fd, void *buf, int len, int flags, struct sockaddr *to, int tolen) in mgmt_sendto()
262 mgmt_write_timeout(int fd, int sec, int usec) in mgmt_write_timeout()
301 mgmt_read_timeout(int fd, int sec, int usec) in mgmt_read_timeout()
334 mgmt_get_peereid(int fd, uid_t *euid, gid_t *egid) in mgmt_get_peereid()
/trafficserver/iocore/cache/
H A DStore.cc278 get_int64(int fd, int64_t &data) in get_int64()
327 ats_scoped_fd fd; in read_config() local
473 ats_scoped_fd fd(socketManager.open(path, O_RDONLY)); in init() local
794 Store::write(int fd, const char *name) const in write()
832 Span::read(int fd) in read()
882 Store::read(int fd, char *aname) in read()
991 int fd = ::open(path, O_RDWR | O_CREAT, 0644); in clear() local
/trafficserver/iocore/net/
H A DBIO_fastopen.cc113 int fd = BIO_get_fd(bio, nullptr); in fastopen_bwrite() local
153 int fd = BIO_get_fd(bio, nullptr); in fastopen_bread() local
H A DQUICNetProcessor.cc116 int fd; in connect_re() local
180 QUICNetProcessor::main_accept(Continuation *cont, SOCKET fd, AcceptOptions const &opt) in main_accept()
H A DUnixUDPNet.cc323 int fd = NO_FD; // fd we are reading from member in UDPReadContinuation
518 UDPNetProcessor::recvfrom_re(Continuation *cont, void *token, int fd, struct sockaddr *fromaddr, so… in recvfrom_re()
563 UDPNetProcessor::sendmsg_re(Continuation *cont, void *token, int fd, struct msghdr *msg) in sendmsg_re()
599 UDPNetProcessor::sendto_re(Continuation *cont, void *token, int fd, struct sockaddr const *toaddr, … in sendto_re()
620 int res = 0, fd = -1; in CreateUDPSocket() local
741 int fd = -1; in UDPBind() local
H A DP_UnixCompletionUtil.h68 completionUtil::setInfo(Event *e, int fd, const Ptr<IOBufferBlock> &buf, int actual, int errno_) in setInfo()
74 completionUtil::setInfo(Event *e, int fd, struct msghdr *msg, int actual, int errno_) in setInfo()
H A DUnixNetProcessor.cc81 NetProcessor::main_accept(Continuation *cont, SOCKET fd, AcceptOptions const &opt) in main_accept()
90 UnixNetProcessor::accept_internal(Continuation *cont, int fd, AcceptOptions const &opt) in accept_internal()
/trafficserver/proxy/http3/test/
H A Dtest_QPACK.cc153 output_encoder_stream_data(FILE *fd, TestQUICStream *stream) in output_encoder_stream_data()
184 output_encoded_data(FILE *fd, uint64_t stream_id, IOBufferReader *header_block_reader) in output_encoded_data()
215 output_decoded_headers(FILE *fd, HTTPHdr **headers, uint64_t n) in output_decoded_headers()
242 read_block(FILE *fd, uint64_t &stream_id, uint8_t **head, uint32_t &block_len) in read_block()
286 FILE *fd = fopen(out_file, "w"); in test_encode() local
/trafficserver/proxy/logging/
H A DLogFilter.cc461 LogFilterString::display(FILE *fd) in display()
694 LogFilterInt::display(FILE *fd) in display()
864 LogFilterIP::displayRange(FILE *fd, IpMap::iterator const &iter) in displayRange()
876 LogFilterIP::displayRanges(FILE *fd) in displayRanges()
891 LogFilterIP::display(FILE *fd) in display()
1079 LogFilterList::display(FILE *fd) in display()

Completed in 131 milliseconds

1234