mirror of
https://gitlab.com/libvirt/libvirt.git
synced 2024-11-02 03:11:12 +00:00
895479647b
Basically, what is needed here is to introduce new message type for the messages passed between the event loop callbacks and the worker thread that does all the I/O. The idea is that instead of a queue of read buffers we will have a queue where "hole of size X" messages appear. That way the event loop callbacks can just check the head of the queue and see if the worker thread is in data or a hole section and how long the section is. Signed-off-by: Michal Privoznik <mprivozn@redhat.com>
70 lines
2.6 KiB
C
70 lines
2.6 KiB
C
/*
|
|
* virfdstream.h: generic streams impl for file descriptors
|
|
*
|
|
* Copyright (C) 2009-2012 Red Hat, Inc.
|
|
*
|
|
* This library is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU Lesser General Public
|
|
* License as published by the Free Software Foundation; either
|
|
* version 2.1 of the License, or (at your option) any later version.
|
|
*
|
|
* This library is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public
|
|
* License along with this library. If not, see
|
|
* <http://www.gnu.org/licenses/>.
|
|
*
|
|
*/
|
|
|
|
|
|
#ifndef __VIR_FDSTREAM_H_
|
|
# define __VIR_FDSTREAM_H_
|
|
|
|
# include "internal.h"
|
|
|
|
/* internal callback, the generic one is used up by daemon stream driver */
|
|
/* the close callback is called with fdstream private data locked */
|
|
typedef void (*virFDStreamInternalCloseCb)(virStreamPtr st, void *opaque);
|
|
|
|
typedef void (*virFDStreamInternalCloseCbFreeOpaque)(void *opaque);
|
|
|
|
|
|
int virFDStreamOpen(virStreamPtr st,
|
|
int fd);
|
|
|
|
int virFDStreamConnectUNIX(virStreamPtr st,
|
|
const char *path,
|
|
bool abstract);
|
|
|
|
int virFDStreamOpenFile(virStreamPtr st,
|
|
const char *path,
|
|
unsigned long long offset,
|
|
unsigned long long length,
|
|
int oflags);
|
|
int virFDStreamCreateFile(virStreamPtr st,
|
|
const char *path,
|
|
unsigned long long offset,
|
|
unsigned long long length,
|
|
int oflags,
|
|
mode_t mode);
|
|
int virFDStreamOpenPTY(virStreamPtr st,
|
|
const char *path,
|
|
unsigned long long offset,
|
|
unsigned long long length,
|
|
int oflags);
|
|
int virFDStreamOpenBlockDevice(virStreamPtr st,
|
|
const char *path,
|
|
unsigned long long offset,
|
|
unsigned long long length,
|
|
bool sparse,
|
|
int oflags);
|
|
|
|
int virFDStreamSetInternalCloseCb(virStreamPtr st,
|
|
virFDStreamInternalCloseCb cb,
|
|
void *opaque,
|
|
virFDStreamInternalCloseCbFreeOpaque fcb);
|
|
#endif /* __VIR_FDSTREAM_H_ */
|