netsync.c 9.25 KB
Newer Older
1
/*****************************************************************************
2
 * netsync.c: synchronization between several network clients.
3
 *****************************************************************************
Jean-Paul Saman's avatar
Jean-Paul Saman committed
4
 * Copyright (C) 2004-2009 the VideoLAN team
5 6 7
 * $Id$
 *
 * Authors: Gildas Bazin <gbazin@videolan.org>
Jean-Paul Saman's avatar
Jean-Paul Saman committed
8
 *          Jean-Paul Saman <jpsaman@videolan.org>
9 10 11 12 13 14 15 16 17 18 19 20 21
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program 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 General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
Antoine Cellerier's avatar
Antoine Cellerier committed
22
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
23 24 25 26 27
 *****************************************************************************/

/*****************************************************************************
 * Preamble
 *****************************************************************************/
28 29 30
#ifdef HAVE_CONFIG_H
# include "config.h"
#endif
31
#include <assert.h>
32

33
#include <vlc_common.h>
34
#include <vlc_plugin.h>
Clément Stenac's avatar
Clément Stenac committed
35 36
#include <vlc_interface.h>
#include <vlc_input.h>
Jean-Paul Saman's avatar
Jean-Paul Saman committed
37
#include <vlc_playlist.h>
38

39
#include <sys/types.h>
40
#include <unistd.h>
Rémi Denis-Courmont's avatar
Rémi Denis-Courmont committed
41
#ifdef HAVE_POLL
Rémi Denis-Courmont's avatar
Rémi Denis-Courmont committed
42 43
#   include <poll.h>
#endif
44

Clément Stenac's avatar
Clément Stenac committed
45
#include <vlc_network.h>
46

47
#define NETSYNC_PORT 9875
48 49 50 51

/*****************************************************************************
 * Module descriptor
 *****************************************************************************/
52 53
static int  Open (vlc_object_t *);
static void Close(vlc_object_t *);
54

55
#define NETSYNC_TEXT N_("Network master clock")
56 57 58
#define NETSYNC_LONGTEXT N_("When set, " \
  "this VLC instance will act as the master clock for synchronization " \
  "for clients listening")
59

60 61
#define MIP_TEXT N_("Master server ip address")
#define MIP_LONGTEXT N_("The IP address of " \
62
  "the network master clock to use for clock synchronization.")
63

64
#define NETSYNC_TIMEOUT_TEXT N_("UDP timeout (in ms)")
65 66
#define NETSYNC_TIMEOUT_LONGTEXT N_("Length of time (in ms) " \
  "until aborting data reception.")
67

68 69
vlc_module_begin()
    set_shortname(N_("Network Sync"))
70
    set_description(N_("Network synchronization"))
71 72
    set_category(CAT_ADVANCED)
    set_subcategory(SUBCAT_ADVANCED_MISC)
73

74
    add_bool("netsync-master", false,
75
              NETSYNC_TEXT, NETSYNC_LONGTEXT, true)
76
    add_string("netsync-master-ip", NULL, MIP_TEXT, MIP_LONGTEXT,
77
                true)
78
    add_integer("netsync-timeout", 500,
79
                 NETSYNC_TIMEOUT_TEXT, NETSYNC_TIMEOUT_LONGTEXT, true)
80

81 82 83
    set_capability("interface", 0)
    set_callbacks(Open, Close)
vlc_module_end()
84 85 86 87

/*****************************************************************************
 * Local prototypes
 *****************************************************************************/
Laurent Aimar's avatar
Laurent Aimar committed
88 89 90 91 92
struct intf_sys_t {
    int            fd;
    int            timeout;
    bool           is_master;
    playlist_t     *playlist;
93 94

    /* */
Laurent Aimar's avatar
Laurent Aimar committed
95
    input_thread_t *input;
96
    vlc_thread_t   thread;
Laurent Aimar's avatar
Laurent Aimar committed
97
};
98 99 100

static int PlaylistEvent(vlc_object_t *, char const *cmd,
                         vlc_value_t oldval, vlc_value_t newval, void *data);
101 102 103 104

/*****************************************************************************
 * Activate: initialize and create stuff
 *****************************************************************************/
105
static int Open(vlc_object_t *object)
106
{
107
    intf_thread_t *intf = (intf_thread_t*)object;
Laurent Aimar's avatar
Laurent Aimar committed
108
    intf_sys_t    *sys;
109
    int fd;
110

111 112 113 114
    if (!var_InheritBool(intf, "netsync-master")) {
        char *psz_master = var_InheritString(intf, "netsync-master-ip");
        if (psz_master == NULL) {
            msg_Err(intf, "master address not specified");
115 116
            return VLC_EGENERIC;
        }
117 118
        fd = net_ConnectUDP(VLC_OBJECT(intf), psz_master, NETSYNC_PORT, -1);
        free(psz_master);
Laurent Aimar's avatar
Laurent Aimar committed
119
    } else {
120
        fd = net_ListenUDP1(VLC_OBJECT(intf), NULL, NETSYNC_PORT);
Laurent Aimar's avatar
Laurent Aimar committed
121
    }
122

123 124
    if (fd == -1) {
        msg_Err(intf, "Netsync socket failure");
125 126
        return VLC_EGENERIC;
    }
127

Laurent Aimar's avatar
Laurent Aimar committed
128 129 130 131 132 133 134 135 136 137 138
    intf->p_sys = sys = malloc(sizeof(*sys));
    if (!sys) {
        net_Close(fd);
        return VLC_ENOMEM;
    }

    sys->fd = fd;
    sys->is_master = var_InheritBool(intf, "netsync-master");
    sys->timeout = var_InheritInteger(intf, "netsync-timeout");
    if (sys->timeout < 500)
        sys->timeout = 500;
139
    sys->playlist = pl_Get(intf);
Laurent Aimar's avatar
Laurent Aimar committed
140 141
    sys->input = NULL;

142
    var_AddCallback(sys->playlist, "input-current", PlaylistEvent, intf);
143 144 145 146 147 148
    return VLC_SUCCESS;
}

/*****************************************************************************
 * Close: destroy interface
 *****************************************************************************/
149
void Close(vlc_object_t *object)
150
{
151
    intf_thread_t *intf = (intf_thread_t*)object;
Laurent Aimar's avatar
Laurent Aimar committed
152
    intf_sys_t *sys = intf->p_sys;
153

154
    var_DelCallback(sys->playlist, "input-current", PlaylistEvent, intf);
155 156 157 158 159 160

    if (sys->input != NULL) {
        vlc_cancel(sys->thread);
        vlc_join(sys->thread, NULL);
    }

Laurent Aimar's avatar
Laurent Aimar committed
161 162
    net_Close(sys->fd);
    free(sys);
163 164
}

165
static mtime_t GetPcrSystem(input_thread_t *input)
Laurent Aimar's avatar
Laurent Aimar committed
166
{
167
    int canc = vlc_savecancel();
168
    /* TODO use the delay */
169
    mtime_t system;
170
    if (input_GetPcrSystem(input, &system, NULL))
171 172
        system = -1;
    vlc_restorecancel(canc);
Laurent Aimar's avatar
Laurent Aimar committed
173

174 175
    return system;
}
Laurent Aimar's avatar
Laurent Aimar committed
176

177 178 179 180 181 182 183 184
static void *Master(void *handle)
{
    intf_thread_t *intf = handle;
    intf_sys_t *sys = intf->p_sys;
    for (;;) {
        struct pollfd ufd = { .fd = sys->fd, .events = POLLIN, };
        uint64_t data[2];

185
        if (poll(&ufd, 1, -1) < 0)
186
            continue;
Laurent Aimar's avatar
Laurent Aimar committed
187

188 189
        /* We received something */
        struct sockaddr_storage from;
190 191 192 193 194
        socklen_t fromlen = sizeof (from);

        if (recvfrom(sys->fd, data, 8, 0,
                     (struct sockaddr *)&from, &fromlen) < 8)
            continue;
Laurent Aimar's avatar
Laurent Aimar committed
195

196 197 198
        mtime_t master_system = GetPcrSystem(sys->input);
        if (master_system < 0)
            continue;
Laurent Aimar's avatar
Laurent Aimar committed
199

200 201
        data[0] = hton64(mdate());
        data[1] = hton64(master_system);
Laurent Aimar's avatar
Laurent Aimar committed
202

203
        /* Reply to the sender */
204 205
        sendto(sys->fd, data, 16, 0,
               (struct sockaddr *)&from, fromlen);
Laurent Aimar's avatar
Laurent Aimar committed
206
#if 0
207 208 209 210 211 212 213
        /* not sure we need the client information to sync,
           since we are the master anyway */
        mtime_t client_system = ntoh64(data[0]);
        msg_Dbg(intf, "Master clockref: %"PRId64" -> %"PRId64", from %s "
                 "(date: %"PRId64")", client_system, master_system,
                 (from.ss_family == AF_INET) ? inet_ntoa(((struct sockaddr_in *)&from)->sin_addr)
                 : "non-IPv4", /*date*/ 0);
Laurent Aimar's avatar
Laurent Aimar committed
214
#endif
215
    }
216
    return NULL;
Laurent Aimar's avatar
Laurent Aimar committed
217 218
}

219
static void *Slave(void *handle)
Laurent Aimar's avatar
Laurent Aimar committed
220
{
221
    intf_thread_t *intf = handle;
Laurent Aimar's avatar
Laurent Aimar committed
222 223
    intf_sys_t *sys = intf->p_sys;

224 225 226 227 228 229
    for (;;) {
        struct pollfd ufd = { .fd = sys->fd, .events = POLLIN, };
        uint64_t data[2];

        mtime_t system = GetPcrSystem(sys->input);
        if (system < 0)
Laurent Aimar's avatar
Laurent Aimar committed
230 231
            goto wait;

232 233
        /* Send clock request to the master */
        const mtime_t send_date = mdate();
234 235 236

        data[0] = hton64(system);
        send(sys->fd, data, 8, 0);
Laurent Aimar's avatar
Laurent Aimar committed
237

238
        /* Don't block */
239
        if (poll(&ufd, 1, sys->timeout) <= 0)
240
            continue;
Jean-Paul Saman's avatar
Jean-Paul Saman committed
241

242
        const mtime_t receive_date = mdate();
243
        if (recv(sys->fd, data, 16, 0) < 16)
244
            goto wait;
245

246 247 248 249
        const mtime_t master_date   = ntoh64(data[0]);
        const mtime_t master_system = ntoh64(data[1]);
        const mtime_t diff_date = receive_date -
                                  ((receive_date - send_date) / 2 + master_date);
250

251 252
        if (master_system > 0) {
            int canc = vlc_savecancel();
253

254
            mtime_t client_system;
255
            if (!input_GetPcrSystem(sys->input, &client_system, NULL)) {
256 257 258 259 260 261 262 263 264 265 266 267
                const mtime_t diff_system = client_system - master_system - diff_date;
                if (diff_system != 0) {
                    input_ModifyPcrSystem(sys->input, true, master_system - diff_date);
#if 0
                    msg_Dbg(intf, "Slave clockref: %"PRId64" -> %"PRId64" -> %"PRId64","
                             " clock diff: %"PRId64", diff: %"PRId64"",
                             system, master_system, client_system,
                             diff_system, diff_date);
#endif
                }
            }
            vlc_restorecancel(canc);
268
        }
269 270
    wait:
        msleep(INTF_IDLE_SLEEP);
271
    }
272
    return NULL;
273
}
274

275 276
static int PlaylistEvent(vlc_object_t *object, char const *cmd,
                         vlc_value_t oldval, vlc_value_t newval, void *data)
277
{
278
    VLC_UNUSED(cmd); VLC_UNUSED(object);
279 280
    intf_thread_t  *intf = data;
    intf_sys_t     *sys = intf->p_sys;
281
    input_thread_t *input = newval.p_address;
282

283
    if (sys->input != NULL) {
284
        msg_Err(intf, "InputEvent DEAD");
285 286
        assert(oldval.p_address == sys->input);

287 288 289 290
        vlc_cancel(sys->thread);
        vlc_join(sys->thread, NULL);
    }

291
    sys->input = input;
292

293
    if (input != NULL) {
294
        if (vlc_clone(&sys->thread, sys->is_master ? Master : Slave, intf,
295
                      VLC_THREAD_PRIORITY_INPUT))
296
            sys->input = NULL;
297 298
    }
    return VLC_SUCCESS;
299 300
}