Skip to content

Commit

Permalink
netdev: Pass 'netdev_class' to ->run() and ->wait().
Browse files Browse the repository at this point in the history
This will allow run() and wait() methods to be shared between different
classes and still perform class-specific work.

Signed-off-by: Daniele Di Proietto <[email protected]>
Acked-by: Ben Pfaff <[email protected]>
  • Loading branch information
ddiproietto committed Aug 15, 2016
1 parent 3262e36 commit 1c33f0c
Show file tree
Hide file tree
Showing 6 changed files with 22 additions and 16 deletions.
6 changes: 3 additions & 3 deletions lib/netdev-bsd.c
Original file line number Diff line number Diff line change
Expand Up @@ -146,7 +146,7 @@ static void ifr_set_flags(struct ifreq *, int flags);
static int af_link_ioctl(unsigned long command, const void *arg);
#endif

static void netdev_bsd_run(void);
static void netdev_bsd_run(const struct netdev_class *);
static int netdev_bsd_get_mtu(const struct netdev *netdev_, int *mtup);

static bool
Expand Down Expand Up @@ -180,7 +180,7 @@ netdev_get_kernel_name(const struct netdev *netdev)
* interface status changes, and eventually calls all the user callbacks.
*/
static void
netdev_bsd_run(void)
netdev_bsd_run(const struct netdev_class *netdev_class OVS_UNUSED)
{
rtbsd_notifier_run();
}
Expand All @@ -190,7 +190,7 @@ netdev_bsd_run(void)
* be called.
*/
static void
netdev_bsd_wait(void)
netdev_bsd_wait(const struct netdev_class *netdev_class OVS_UNUSED)
{
rtbsd_notifier_wait();
}
Expand Down
4 changes: 2 additions & 2 deletions lib/netdev-dummy.c
Original file line number Diff line number Diff line change
Expand Up @@ -622,7 +622,7 @@ dummy_netdev_get_conn_state(struct dummy_packet_conn *conn)
}

static void
netdev_dummy_run(void)
netdev_dummy_run(const struct netdev_class *netdev_class OVS_UNUSED)
{
struct netdev_dummy *dev;

Expand All @@ -636,7 +636,7 @@ netdev_dummy_run(void)
}

static void
netdev_dummy_wait(void)
netdev_dummy_wait(const struct netdev_class *netdev_class OVS_UNUSED)
{
struct netdev_dummy *dev;

Expand Down
6 changes: 3 additions & 3 deletions lib/netdev-linux.c
Original file line number Diff line number Diff line change
Expand Up @@ -526,7 +526,7 @@ static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(5, 20);
* changes in the device miimon status, so we can use atomic_count. */
static atomic_count miimon_cnt = ATOMIC_COUNT_INIT(0);

static void netdev_linux_run(void);
static void netdev_linux_run(const struct netdev_class *);

static int netdev_linux_do_ethtool(const char *name, struct ethtool_cmd *,
int cmd, const char *cmd_name);
Expand Down Expand Up @@ -623,7 +623,7 @@ netdev_linux_miimon_enabled(void)
}

static void
netdev_linux_run(void)
netdev_linux_run(const struct netdev_class *netdev_class OVS_UNUSED)
{
struct nl_sock *sock;
int error;
Expand Down Expand Up @@ -697,7 +697,7 @@ netdev_linux_run(void)
}

static void
netdev_linux_wait(void)
netdev_linux_wait(const struct netdev_class *netdev_class OVS_UNUSED)
{
struct nl_sock *sock;

Expand Down
14 changes: 10 additions & 4 deletions lib/netdev-provider.h
Original file line number Diff line number Diff line change
Expand Up @@ -236,15 +236,21 @@ struct netdev_class {
int (*init)(void);

/* Performs periodic work needed by netdevs of this class. May be null if
* no periodic work is necessary. */
void (*run)(void);
* no periodic work is necessary.
*
* 'netdev_class' points to the class. It is useful in case the same
* function is used to implement different classes. */
void (*run)(const struct netdev_class *netdev_class);

/* Arranges for poll_block() to wake up if the "run" member function needs
* to be called. Implementations are additionally required to wake
* whenever something changes in any of its netdevs which would cause their
* ->change_seq() function to change its result. May be null if nothing is
* needed here. */
void (*wait)(void);
* needed here.
*
* 'netdev_class' points to the class. It is useful in case the same
* function is used to implement different classes. */
void (*wait)(const struct netdev_class *netdev_class);

/* ## ---------------- ## */
/* ## netdev Functions ## */
Expand Down
4 changes: 2 additions & 2 deletions lib/netdev-vport.c
Original file line number Diff line number Diff line change
Expand Up @@ -312,7 +312,7 @@ netdev_vport_update_flags(struct netdev *netdev OVS_UNUSED,
}

static void
netdev_vport_run(void)
netdev_vport_run(const struct netdev_class *netdev_class OVS_UNUSED)
{
uint64_t seq;

Expand All @@ -325,7 +325,7 @@ netdev_vport_run(void)
}

static void
netdev_vport_wait(void)
netdev_vport_wait(const struct netdev_class *netdev_class OVS_UNUSED)
{
uint64_t seq;

Expand Down
4 changes: 2 additions & 2 deletions lib/netdev.c
Original file line number Diff line number Diff line change
Expand Up @@ -160,7 +160,7 @@ netdev_run(void)
struct netdev_registered_class *rc;
CMAP_FOR_EACH (rc, cmap_node, &netdev_classes) {
if (rc->class->run) {
rc->class->run();
rc->class->run(rc->class);
}
}
}
Expand All @@ -178,7 +178,7 @@ netdev_wait(void)
struct netdev_registered_class *rc;
CMAP_FOR_EACH (rc, cmap_node, &netdev_classes) {
if (rc->class->wait) {
rc->class->wait();
rc->class->wait(rc->class);
}
}
}
Expand Down

0 comments on commit 1c33f0c

Please sign in to comment.