X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=lib%2Fstream.h;h=2482bf20ceb5267e313b3ae6920aa7986cf488fa;hb=9591fefeea4b475ee0d1387486a410bbb592b050;hp=d05107dea7423f1ad990d8974f3ec669dfa464b3;hpb=f39dc942afd5fe241903aada30850a1d96122c8c;p=openvswitch diff --git a/lib/stream.h b/lib/stream.h index d05107de..2482bf20 100644 --- a/lib/stream.h +++ b/lib/stream.h @@ -20,6 +20,8 @@ #include #include #include +#include "openvswitch/types.h" +#include "vlog.h" struct pstream; struct stream; @@ -32,10 +34,10 @@ int stream_open(const char *name, struct stream **); int stream_open_block(int error, struct stream **); void stream_close(struct stream *); const char *stream_get_name(const struct stream *); -uint32_t stream_get_remote_ip(const struct stream *); -uint16_t stream_get_remote_port(const struct stream *); -uint32_t stream_get_local_ip(const struct stream *); -uint16_t stream_get_local_port(const struct stream *); +ovs_be32 stream_get_remote_ip(const struct stream *); +ovs_be16 stream_get_remote_port(const struct stream *); +ovs_be32 stream_get_local_ip(const struct stream *); +ovs_be16 stream_get_local_port(const struct stream *); int stream_connect(struct stream *); int stream_recv(struct stream *, void *buffer, size_t n); int stream_send(struct stream *, const void *buffer, size_t n); @@ -62,7 +64,7 @@ int pstream_accept(struct pstream *, struct stream **); int pstream_accept_block(struct pstream *, struct stream **); void pstream_wait(struct pstream *); -/* Convenience funtions. */ +/* Convenience functions. */ int stream_open_with_default_ports(const char *name, uint16_t default_tcp_port, @@ -72,5 +74,17 @@ int pstream_open_with_default_ports(const char *name, uint16_t default_ptcp_port, uint16_t default_pssl_port, struct pstream **); + +/* Error reporting. */ + +enum stream_content_type { + STREAM_UNKNOWN, + STREAM_OPENFLOW, + STREAM_SSL, + STREAM_JSONRPC +}; + +void stream_report_content(const void *, size_t, enum stream_content_type, + struct vlog_module *, const char *stream_name); #endif /* stream.h */