Lines Matching refs:base
72 struct spdk_sock base;
115 struct spdk_sock_group_impl base;
435 memcpy(&sock->base.impl_opts, impl_opts, sizeof(*impl_opts));
442 if (sock->base.impl_opts.enable_quickack) {
449 spdk_sock_get_placement_id(sock->fd, sock->base.impl_opts.enable_placement_id,
697 return &sock->base;
754 if (sock->base.opts.priority) {
755 rc = setsockopt(fd, SOL_SOCKET, SO_PRIORITY, &sock->base.opts.priority, sizeof(int));
763 new_sock = uring_sock_alloc(fd, &sock->base.impl_opts, sock->zcopy);
769 return &new_sock->base;
820 if (sock->base.group_impl && spdk_pipe_reader_bytes_available(sock->recv_pipe) == 0) {
821 group = __uring_group_impl(sock->base.group_impl);
853 if (sock->base.group_impl && !sock->pending_recv) {
854 group = __uring_group_impl(sock->base.group_impl);
967 spdk_sock_group_provide_buf(sock->group->base.group, tr->buf, tr->buflen, tr->ctx);
1255 iovcnt = spdk_sock_prep_reqs(&sock->base, task->iovs, task->iov_cnt, &task->last_req, &flags);
1329 rc = spdk_sock_abort_requests(&sock->base);
1332 if (rc == 0 && sock->base.cb_fn != NULL &&
1379 _sock_prep_read(&sock->base);
1385 if (sock->base.cb_fn != NULL &&
1391 _sock_prep_read(&sock->base);
1411 if (sock->base.cb_fn != NULL &&
1417 _sock_prep_read(&sock->base);
1432 sock_complete_write_reqs(&sock->base, status, is_zcopy);
1439 _sock_prep_errqueue(&sock->base);
1445 _sock_check_zcopy(&sock->base, status);
1446 _sock_prep_errqueue(&sock->base);
1468 if (spdk_unlikely(sock->base.cb_fn == NULL)) {
1475 socks[count++] = &sock->base;
1742 spdk_sock_map_insert(&g_map, spdk_env_get_current_core(), &group_impl->base);
1745 return &group_impl->base;
1780 rc = spdk_sock_map_insert(&g_map, sock->placement_id, &group->base);
1788 _sock_prep_read(&sock->base);
1814 tracker->buflen = spdk_sock_group_get_buf(group->base.group, &tracker->buf, &tracker->ctx);
1845 TAILQ_FOREACH_SAFE(_sock, &group->base.socks, link, tmp) {