X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=lib%2Fstream-provider.h;h=43c63e81beafdc671a95ca2c137eab5c94da9563;hb=591cb419cf3694e0ae66a95973e73c61bad9e03d;hp=0708c72e4a3ec043f9f044bc35bced9040216fcc;hpb=1e3f34c7693bcabae8e443ac1b246680ef9b60e2;p=sliver-openvswitch.git diff --git a/lib/stream-provider.h b/lib/stream-provider.h index 0708c72e4..43c63e81b 100644 --- a/lib/stream-provider.h +++ b/lib/stream-provider.h @@ -1,5 +1,5 @@ /* - * Copyright (c) 2009, 2010 Nicira, Inc. + * Copyright (c) 2009, 2010, 2012, 2013 Nicira, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -17,7 +17,6 @@ #ifndef STREAM_PROVIDER_H #define STREAM_PROVIDER_H 1 -#include #include #include "stream.h" @@ -40,14 +39,13 @@ struct stream { void stream_init(struct stream *, const struct stream_class *, int connect_status, const char *name); void stream_set_remote_ip(struct stream *, ovs_be32 remote_ip); -void stream_set_dscp(struct stream *, uint8_t dscp); void stream_set_remote_port(struct stream *, ovs_be16 remote_port); void stream_set_local_ip(struct stream *, ovs_be32 local_ip); void stream_set_local_port(struct stream *, ovs_be16 local_port); static inline void stream_assert_class(const struct stream *stream, const struct stream_class *class) { - assert(stream->class == class); + ovs_assert(stream->class == class); } struct stream_class { @@ -141,13 +139,15 @@ struct stream_class { struct pstream { const struct pstream_class *class; char *name; + ovs_be16 bound_port; }; void pstream_init(struct pstream *, const struct pstream_class *, const char *name); +void pstream_set_bound_port(struct pstream *, ovs_be16 bound_port); static inline void pstream_assert_class(const struct pstream *pstream, const struct pstream_class *class) { - assert(pstream->class == class); + ovs_assert(pstream->class == class); } struct pstream_class { @@ -191,6 +191,9 @@ struct pstream_class { /* Arranges for the poll loop to wake up when a connection is ready to be * accepted on 'pstream'. */ void (*wait)(struct pstream *pstream); + + /* Set DSCP value of the listening socket. */ + int (*set_dscp)(struct pstream *pstream, uint8_t dscp); }; /* Active and passive stream classes. */