|
Packit |
979a56 |
/*
|
|
Packit |
979a56 |
* Copyright (C) 2010 Red Hat, Inc.
|
|
Packit |
979a56 |
*
|
|
Packit |
979a56 |
* Author: Angus Salkeld <asalkeld@redhat.com>
|
|
Packit |
979a56 |
*
|
|
Packit |
979a56 |
* This file is part of libqb.
|
|
Packit |
979a56 |
*
|
|
Packit |
979a56 |
* libqb is free software: you can redistribute it and/or modify
|
|
Packit |
979a56 |
* it under the terms of the GNU Lesser General Public License as published by
|
|
Packit |
979a56 |
* the Free Software Foundation, either version 2.1 of the License, or
|
|
Packit |
979a56 |
* (at your option) any later version.
|
|
Packit |
979a56 |
*
|
|
Packit |
979a56 |
* libqb is distributed in the hope that it will be useful,
|
|
Packit |
979a56 |
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
Packit |
979a56 |
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
Packit |
979a56 |
* GNU Lesser General Public License for more details.
|
|
Packit |
979a56 |
*
|
|
Packit |
979a56 |
* You should have received a copy of the GNU Lesser General Public License
|
|
Packit |
979a56 |
* along with libqb. If not, see <http://www.gnu.org/licenses/>.
|
|
Packit |
979a56 |
*/
|
|
Packit |
979a56 |
#include "os_base.h"
|
|
Packit |
979a56 |
#include <poll.h>
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
#include "ipc_int.h"
|
|
Packit |
979a56 |
#include "util_int.h"
|
|
Packit |
979a56 |
#include "ringbuffer_int.h"
|
|
Packit |
979a56 |
#include <qb/qbdefs.h>
|
|
Packit |
979a56 |
#include <qb/qbatomic.h>
|
|
Packit |
979a56 |
#include <qb/qbloop.h>
|
|
Packit |
979a56 |
#include <qb/qbrb.h>
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
/*
|
|
Packit |
979a56 |
* client functions
|
|
Packit |
979a56 |
* --------------------------------------------------------
|
|
Packit |
979a56 |
*/
|
|
Packit |
979a56 |
static void
|
|
Packit |
979a56 |
qb_ipcc_shm_disconnect(struct qb_ipcc_connection *c)
|
|
Packit |
979a56 |
{
|
|
Packit |
979a56 |
void (*rb_destructor)(struct qb_ringbuffer_s *) = c->is_connected
|
|
Packit |
979a56 |
? qb_rb_close
|
|
Packit |
979a56 |
: qb_rb_force_close;
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
qb_ipcc_us_sock_close(c->setup.u.us.sock);
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
rb_destructor(qb_rb_lastref_and_ret(&c->request.u.shm.rb));
|
|
Packit |
979a56 |
rb_destructor(qb_rb_lastref_and_ret(&c->response.u.shm.rb));
|
|
Packit |
979a56 |
rb_destructor(qb_rb_lastref_and_ret(&c->event.u.shm.rb));
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
static ssize_t
|
|
Packit |
979a56 |
qb_ipc_shm_send(struct qb_ipc_one_way *one_way,
|
|
Packit |
979a56 |
const void *msg_ptr, size_t msg_len)
|
|
Packit |
979a56 |
{
|
|
Packit |
979a56 |
return qb_rb_chunk_write(one_way->u.shm.rb, msg_ptr, msg_len);
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
static ssize_t
|
|
Packit |
979a56 |
qb_ipc_shm_sendv(struct qb_ipc_one_way *one_way,
|
|
Packit |
979a56 |
const struct iovec *iov, size_t iov_len)
|
|
Packit |
979a56 |
{
|
|
Packit |
979a56 |
char *dest;
|
|
Packit |
979a56 |
int32_t res = 0;
|
|
Packit |
979a56 |
int32_t total_size = 0;
|
|
Packit |
979a56 |
int32_t i;
|
|
Packit |
979a56 |
char *pt = NULL;
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
if (one_way->u.shm.rb == NULL) {
|
|
Packit |
979a56 |
return -ENOTCONN;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
for (i = 0; i < iov_len; i++) {
|
|
Packit |
979a56 |
total_size += iov[i].iov_len;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
dest = qb_rb_chunk_alloc(one_way->u.shm.rb, total_size);
|
|
Packit |
979a56 |
if (dest == NULL) {
|
|
Packit |
979a56 |
return -errno;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
pt = dest;
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
for (i = 0; i < iov_len; i++) {
|
|
Packit |
979a56 |
memcpy(pt, iov[i].iov_base, iov[i].iov_len);
|
|
Packit |
979a56 |
pt += iov[i].iov_len;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
res = qb_rb_chunk_commit(one_way->u.shm.rb, total_size);
|
|
Packit |
979a56 |
if (res < 0) {
|
|
Packit |
979a56 |
return res;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
return total_size;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
static ssize_t
|
|
Packit |
979a56 |
qb_ipc_shm_recv(struct qb_ipc_one_way *one_way,
|
|
Packit |
979a56 |
void *msg_ptr, size_t msg_len, int32_t ms_timeout)
|
|
Packit |
979a56 |
{
|
|
Packit |
979a56 |
if (one_way->u.shm.rb == NULL) {
|
|
Packit |
979a56 |
return -ENOTCONN;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
return qb_rb_chunk_read(one_way->u.shm.rb,
|
|
Packit |
979a56 |
(void *)msg_ptr, msg_len, ms_timeout);
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
static ssize_t
|
|
Packit |
979a56 |
qb_ipc_shm_peek(struct qb_ipc_one_way *one_way, void **data_out,
|
|
Packit |
979a56 |
int32_t ms_timeout)
|
|
Packit |
979a56 |
{
|
|
Packit |
979a56 |
ssize_t rc;
|
|
Packit |
979a56 |
if (one_way->u.shm.rb == NULL) {
|
|
Packit |
979a56 |
return -ENOTCONN;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
rc = qb_rb_chunk_peek(one_way->u.shm.rb, data_out, ms_timeout);
|
|
Packit |
979a56 |
if (rc == 0) {
|
|
Packit |
979a56 |
return -EAGAIN;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
return rc;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
static void
|
|
Packit |
979a56 |
qb_ipc_shm_reclaim(struct qb_ipc_one_way *one_way)
|
|
Packit |
979a56 |
{
|
|
Packit |
979a56 |
qb_rb_chunk_reclaim(one_way->u.shm.rb);
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
static void
|
|
Packit |
979a56 |
qb_ipc_shm_fc_set(struct qb_ipc_one_way *one_way, int32_t fc_enable)
|
|
Packit |
979a56 |
{
|
|
Packit |
979a56 |
int32_t *fc;
|
|
Packit |
979a56 |
fc = qb_rb_shared_user_data_get(one_way->u.shm.rb);
|
|
Packit |
979a56 |
qb_util_log(LOG_TRACE, "setting fc to %d", fc_enable);
|
|
Packit |
979a56 |
qb_atomic_int_set(fc, fc_enable);
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
static int32_t
|
|
Packit |
979a56 |
qb_ipc_shm_fc_get(struct qb_ipc_one_way *one_way)
|
|
Packit |
979a56 |
{
|
|
Packit |
979a56 |
int32_t *fc;
|
|
Packit |
979a56 |
int32_t rc = qb_rb_refcount_get(one_way->u.shm.rb);
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
if (rc != 2) {
|
|
Packit |
979a56 |
return -ENOTCONN;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
fc = qb_rb_shared_user_data_get(one_way->u.shm.rb);
|
|
Packit |
979a56 |
return qb_atomic_int_get(fc);
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
static ssize_t
|
|
Packit |
979a56 |
qb_ipc_shm_q_len_get(struct qb_ipc_one_way *one_way)
|
|
Packit |
979a56 |
{
|
|
Packit |
979a56 |
if (one_way->u.shm.rb == NULL) {
|
|
Packit |
979a56 |
return -ENOTCONN;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
return qb_rb_chunks_used(one_way->u.shm.rb);
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
int32_t
|
|
Packit |
979a56 |
qb_ipcc_shm_connect(struct qb_ipcc_connection * c,
|
|
Packit |
979a56 |
struct qb_ipc_connection_response * response)
|
|
Packit |
979a56 |
{
|
|
Packit |
979a56 |
int32_t res = 0;
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
c->funcs.send = qb_ipc_shm_send;
|
|
Packit |
979a56 |
c->funcs.sendv = qb_ipc_shm_sendv;
|
|
Packit |
979a56 |
c->funcs.recv = qb_ipc_shm_recv;
|
|
Packit |
979a56 |
c->funcs.fc_get = qb_ipc_shm_fc_get;
|
|
Packit |
979a56 |
c->funcs.disconnect = qb_ipcc_shm_disconnect;
|
|
Packit |
979a56 |
c->needs_sock_for_poll = QB_TRUE;
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
if (strlen(c->name) > (NAME_MAX - 20)) {
|
|
Packit |
979a56 |
errno = EINVAL;
|
|
Packit |
979a56 |
return -errno;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
c->request.u.shm.rb = qb_rb_open(response->request,
|
|
Packit |
979a56 |
c->request.max_msg_size,
|
|
Packit |
979a56 |
QB_RB_FLAG_SHARED_PROCESS,
|
|
Packit |
979a56 |
sizeof(int32_t));
|
|
Packit |
979a56 |
if (c->request.u.shm.rb == NULL) {
|
|
Packit |
979a56 |
res = -errno;
|
|
Packit |
979a56 |
qb_util_perror(LOG_ERR, "qb_rb_open:REQUEST");
|
|
Packit |
979a56 |
goto return_error;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
c->response.u.shm.rb = qb_rb_open(response->response,
|
|
Packit |
979a56 |
c->response.max_msg_size,
|
|
Packit |
979a56 |
QB_RB_FLAG_SHARED_PROCESS, 0);
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
if (c->response.u.shm.rb == NULL) {
|
|
Packit |
979a56 |
res = -errno;
|
|
Packit |
979a56 |
qb_util_perror(LOG_ERR, "qb_rb_open:RESPONSE");
|
|
Packit |
979a56 |
goto cleanup_request;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
c->event.u.shm.rb = qb_rb_open(response->event,
|
|
Packit |
979a56 |
c->response.max_msg_size,
|
|
Packit |
979a56 |
QB_RB_FLAG_SHARED_PROCESS, 0);
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
if (c->event.u.shm.rb == NULL) {
|
|
Packit |
979a56 |
res = -errno;
|
|
Packit |
979a56 |
qb_util_perror(LOG_ERR, "qb_rb_open:EVENT");
|
|
Packit |
979a56 |
goto cleanup_request_response;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
return 0;
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
cleanup_request_response:
|
|
Packit |
979a56 |
qb_rb_close(qb_rb_lastref_and_ret(&c->response.u.shm.rb));
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
cleanup_request:
|
|
Packit |
979a56 |
qb_rb_close(qb_rb_lastref_and_ret(&c->request.u.shm.rb));
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
return_error:
|
|
Packit |
979a56 |
errno = -res;
|
|
Packit |
979a56 |
qb_util_perror(LOG_ERR, "connection failed");
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
return res;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
/*
|
|
Packit |
979a56 |
* service functions
|
|
Packit |
979a56 |
* --------------------------------------------------------
|
|
Packit |
979a56 |
*/
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
static void
|
|
Packit |
979a56 |
qb_ipcs_shm_disconnect(struct qb_ipcs_connection *c)
|
|
Packit |
979a56 |
{
|
|
Packit |
979a56 |
if (c->state == QB_IPCS_CONNECTION_ESTABLISHED ||
|
|
Packit |
979a56 |
c->state == QB_IPCS_CONNECTION_ACTIVE) {
|
|
Packit |
979a56 |
if (c->setup.u.us.sock > 0) {
|
|
Packit |
979a56 |
(void)c->service->poll_fns.dispatch_del(c->setup.u.us.sock);
|
|
Packit |
979a56 |
qb_ipcc_us_sock_close(c->setup.u.us.sock);
|
|
Packit |
979a56 |
c->setup.u.us.sock = -1;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
if (c->state == QB_IPCS_CONNECTION_SHUTTING_DOWN ||
|
|
Packit |
979a56 |
c->state == QB_IPCS_CONNECTION_ACTIVE) {
|
|
Packit |
979a56 |
if (c->response.u.shm.rb) {
|
|
Packit |
979a56 |
qb_rb_close(qb_rb_lastref_and_ret(&c->response.u.shm.rb));
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
if (c->event.u.shm.rb) {
|
|
Packit |
979a56 |
qb_rb_close(qb_rb_lastref_and_ret(&c->event.u.shm.rb));
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
if (c->request.u.shm.rb) {
|
|
Packit |
979a56 |
qb_rb_close(qb_rb_lastref_and_ret(&c->request.u.shm.rb));
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
}
|
|
Packit Service |
268c65 |
remove_tempdir(c->description);
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
static int32_t
|
|
Packit |
979a56 |
qb_ipcs_shm_rb_open(struct qb_ipcs_connection *c,
|
|
Packit |
979a56 |
struct qb_ipc_one_way *ow,
|
|
Packit |
979a56 |
const char *rb_name)
|
|
Packit |
979a56 |
{
|
|
Packit |
979a56 |
int32_t res = 0;
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
ow->u.shm.rb = qb_rb_open(rb_name,
|
|
Packit |
979a56 |
ow->max_msg_size,
|
|
Packit |
979a56 |
QB_RB_FLAG_CREATE |
|
|
Packit |
979a56 |
QB_RB_FLAG_SHARED_PROCESS,
|
|
Packit |
979a56 |
sizeof(int32_t));
|
|
Packit |
979a56 |
if (ow->u.shm.rb == NULL) {
|
|
Packit |
979a56 |
res = -errno;
|
|
Packit |
979a56 |
qb_util_perror(LOG_ERR, "qb_rb_open:%s", rb_name);
|
|
Packit |
979a56 |
return res;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
res = qb_rb_chown(ow->u.shm.rb, c->auth.uid, c->auth.gid);
|
|
Packit |
979a56 |
if (res != 0) {
|
|
Packit |
979a56 |
qb_util_perror(LOG_ERR, "qb_rb_chown:%s", rb_name);
|
|
Packit |
979a56 |
goto cleanup;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
res = qb_rb_chmod(ow->u.shm.rb, c->auth.mode);
|
|
Packit |
979a56 |
if (res != 0) {
|
|
Packit |
979a56 |
qb_util_perror(LOG_ERR, "qb_rb_chmod:%s", rb_name);
|
|
Packit |
979a56 |
goto cleanup;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
return res;
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
cleanup:
|
|
Packit |
979a56 |
qb_rb_close(qb_rb_lastref_and_ret(&ow->u.shm.rb));
|
|
Packit |
979a56 |
return res;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
static int32_t
|
|
Packit |
979a56 |
qb_ipcs_shm_connect(struct qb_ipcs_service *s,
|
|
Packit |
979a56 |
struct qb_ipcs_connection *c,
|
|
Packit |
979a56 |
struct qb_ipc_connection_response *r)
|
|
Packit |
979a56 |
{
|
|
Packit |
979a56 |
int32_t res;
|
|
Packit Service |
6411c4 |
char dirname[PATH_MAX];
|
|
Packit Service |
6411c4 |
char *slash;
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
qb_util_log(LOG_DEBUG, "connecting to client [%d]", c->pid);
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
snprintf(r->request, NAME_MAX, "%s-request-%s",
|
|
Packit Service |
268c65 |
c->description, s->name);
|
|
Packit |
979a56 |
snprintf(r->response, NAME_MAX, "%s-response-%s",
|
|
Packit Service |
268c65 |
c->description, s->name);
|
|
Packit |
979a56 |
snprintf(r->event, NAME_MAX, "%s-event-%s",
|
|
Packit Service |
268c65 |
c->description, s->name);
|
|
Packit |
e4589f |
|
|
Packit Service |
6411c4 |
/* Set correct ownership if qb_ipcs_connection_auth_set() has been used */
|
|
Packit Service |
6411c4 |
strlcpy(dirname, c->description, sizeof(dirname));
|
|
Packit Service |
6411c4 |
slash = strrchr(dirname, '/');
|
|
Packit Service |
6411c4 |
if (slash) {
|
|
Packit Service |
6411c4 |
*slash = '\0';
|
|
Packit Service |
6411c4 |
(void)chown(dirname, c->auth.uid, c->auth.gid);
|
|
Packit Service |
6411c4 |
}
|
|
Packit Service |
6411c4 |
|
|
Packit |
979a56 |
res = qb_ipcs_shm_rb_open(c, &c->request,
|
|
Packit |
979a56 |
r->request);
|
|
Packit |
979a56 |
if (res != 0) {
|
|
Packit |
979a56 |
goto cleanup;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
res = qb_ipcs_shm_rb_open(c, &c->response,
|
|
Packit |
979a56 |
r->response);
|
|
Packit |
979a56 |
if (res != 0) {
|
|
Packit |
979a56 |
goto cleanup_request;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
res = qb_ipcs_shm_rb_open(c, &c->event,
|
|
Packit |
979a56 |
r->event);
|
|
Packit |
979a56 |
if (res != 0) {
|
|
Packit |
979a56 |
goto cleanup_request_response;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
res = s->poll_fns.dispatch_add(s->poll_priority,
|
|
Packit |
979a56 |
c->setup.u.us.sock,
|
|
Packit |
979a56 |
POLLIN | POLLPRI | POLLNVAL,
|
|
Packit |
979a56 |
c, qb_ipcs_dispatch_connection_request);
|
|
Packit |
979a56 |
if (res != 0) {
|
|
Packit |
979a56 |
qb_util_log(LOG_ERR,
|
|
Packit |
979a56 |
"Error adding socket to mainloop (%s).",
|
|
Packit |
979a56 |
c->description);
|
|
Packit |
979a56 |
goto cleanup_request_response_event;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
r->hdr.error = 0;
|
|
Packit |
979a56 |
return 0;
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
cleanup_request_response_event:
|
|
Packit |
979a56 |
qb_rb_close(qb_rb_lastref_and_ret(&c->event.u.shm.rb));
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
cleanup_request_response:
|
|
Packit |
979a56 |
qb_rb_close(qb_rb_lastref_and_ret(&c->response.u.shm.rb));
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
cleanup_request:
|
|
Packit |
979a56 |
qb_rb_close(qb_rb_lastref_and_ret(&c->request.u.shm.rb));
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
cleanup:
|
|
Packit |
979a56 |
r->hdr.error = res;
|
|
Packit |
979a56 |
errno = -res;
|
|
Packit |
979a56 |
qb_util_perror(LOG_ERR, "shm connection FAILED");
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
return res;
|
|
Packit |
979a56 |
}
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
void
|
|
Packit |
979a56 |
qb_ipcs_shm_init(struct qb_ipcs_service *s)
|
|
Packit |
979a56 |
{
|
|
Packit |
979a56 |
s->funcs.connect = qb_ipcs_shm_connect;
|
|
Packit |
979a56 |
s->funcs.disconnect = qb_ipcs_shm_disconnect;
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
s->funcs.recv = qb_ipc_shm_recv;
|
|
Packit |
979a56 |
s->funcs.peek = qb_ipc_shm_peek;
|
|
Packit |
979a56 |
s->funcs.reclaim = qb_ipc_shm_reclaim;
|
|
Packit |
979a56 |
s->funcs.send = qb_ipc_shm_send;
|
|
Packit |
979a56 |
s->funcs.sendv = qb_ipc_shm_sendv;
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
s->funcs.fc_set = qb_ipc_shm_fc_set;
|
|
Packit |
979a56 |
s->funcs.q_len_get = qb_ipc_shm_q_len_get;
|
|
Packit |
979a56 |
|
|
Packit |
979a56 |
s->needs_sock_for_poll = QB_TRUE;
|
|
Packit |
979a56 |
}
|