VIR_LOG_INIT("fdstream");
/* Tunnelled migration stream support */
+typedef struct virFDStreamData virFDStreamData;
+typedef virFDStreamData *virFDStreamDataPtr;
struct virFDStreamData {
int fd;
int errfd;
static int virFDStreamRemoveCallback(virStreamPtr stream)
{
- struct virFDStreamData *fdst = stream->privateData;
+ virFDStreamDataPtr fdst = stream->privateData;
int ret = -1;
if (!fdst) {
static int virFDStreamUpdateCallback(virStreamPtr stream, int events)
{
- struct virFDStreamData *fdst = stream->privateData;
+ virFDStreamDataPtr fdst = stream->privateData;
int ret = -1;
if (!fdst) {
void *opaque)
{
virStreamPtr stream = opaque;
- struct virFDStreamData *fdst = stream->privateData;
+ virFDStreamDataPtr fdst = stream->privateData;
virStreamEventCallback cb;
void *cbopaque;
virFreeCallback ff;
void *opaque,
virFreeCallback ff)
{
- struct virFDStreamData *fdst = st->privateData;
+ virFDStreamDataPtr fdst = st->privateData;
int ret = -1;
if (!fdst) {
}
static int
-virFDStreamCloseCommand(struct virFDStreamData *fdst, bool streamAbort)
+virFDStreamCloseCommand(virFDStreamDataPtr fdst, bool streamAbort)
{
char buf[1024];
ssize_t len;
static int
virFDStreamCloseInt(virStreamPtr st, bool streamAbort)
{
- struct virFDStreamData *fdst;
+ virFDStreamDataPtr fdst;
virStreamEventCallback cb;
void *opaque;
int ret;
static int virFDStreamWrite(virStreamPtr st, const char *bytes, size_t nbytes)
{
- struct virFDStreamData *fdst = st->privateData;
+ virFDStreamDataPtr fdst = st->privateData;
int ret;
if (nbytes > INT_MAX) {
static int virFDStreamRead(virStreamPtr st, char *bytes, size_t nbytes)
{
- struct virFDStreamData *fdst = st->privateData;
+ virFDStreamDataPtr fdst = st->privateData;
int ret;
if (nbytes > INT_MAX) {
int errfd,
unsigned long long length)
{
- struct virFDStreamData *fdst;
+ virFDStreamDataPtr fdst;
VIR_DEBUG("st=%p fd=%d cmd=%p errfd=%d length=%llu",
st, fd, cmd, errfd, length);
unsigned long long length,
int oflags)
{
- struct virFDStreamData *fdst = NULL;
+ virFDStreamDataPtr fdst = NULL;
struct termios rawattr;
if (virFDStreamOpenFileInternal(st, path,
void *opaque,
virFDStreamInternalCloseCbFreeOpaque fcb)
{
- struct virFDStreamData *fdst = st->privateData;
+ virFDStreamDataPtr fdst = st->privateData;
virMutexLock(&fdst->lock);