X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=lib%2Fvconn-stream.c;h=92076d999b0fa9e83908bc750fd305e5a3294b94;hb=77d14d9c7f9ce7245eff56aacd420646577892d0;hp=613b92cfbbca009f8bd6c3b670221eb35960194b;hpb=3e6c955de6fc7c50ea30ee9ea2148c6734e5df11;p=sliver-openvswitch.git diff --git a/lib/vconn-stream.c b/lib/vconn-stream.c index 613b92cfb..92076d999 100644 --- a/lib/vconn-stream.c +++ b/lib/vconn-stream.c @@ -1,5 +1,5 @@ /* - * Copyright (c) 2008, 2009, 2010, 2011, 2012 Nicira, Inc. + * Copyright (c) 2008, 2009, 2010, 2011, 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. @@ -22,7 +22,6 @@ #include #include #include "fatal-signal.h" -#include "leak-checker.h" #include "ofpbuf.h" #include "openflow/openflow.h" #include "poll-loop.h" @@ -46,7 +45,7 @@ struct vconn_stream int n_packets; }; -static struct vconn_class stream_vconn_class; +static const struct vconn_class stream_vconn_class; static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(10, 25); @@ -210,7 +209,6 @@ vconn_stream_send(struct vconn *vconn, struct ofpbuf *buffer) ofpbuf_delete(buffer); return 0; } else if (retval >= 0 || retval == -EAGAIN) { - leak_checker_claim(buffer); s->txbuf = buffer; if (retval > 0) { ofpbuf_pull(buffer, retval); @@ -235,7 +233,7 @@ vconn_stream_run(struct vconn *vconn) retval = stream_send(s->stream, s->txbuf->data, s->txbuf->size); if (retval < 0) { if (retval != -EAGAIN) { - VLOG_ERR_RL(&rl, "send: %s", strerror(-retval)); + VLOG_ERR_RL(&rl, "send: %s", ovs_strerror(-retval)); vconn_stream_clear_txbuf(s); return; } @@ -296,7 +294,7 @@ struct pvconn_pstream struct pstream *pstream; }; -static struct pvconn_class pstream_pvconn_class; +static const struct pvconn_class pstream_pvconn_class; static struct pvconn_pstream * pvconn_pstream_cast(struct pvconn *pvconn) @@ -350,7 +348,7 @@ pvconn_pstream_accept(struct pvconn *pvconn, struct vconn **new_vconnp) if (error) { if (error != EAGAIN) { VLOG_DBG_RL(&rl, "%s: accept: %s", - pstream_get_name(ps->pstream), strerror(error)); + pstream_get_name(ps->pstream), ovs_strerror(error)); } return error; } @@ -390,16 +388,16 @@ pvconn_pstream_wait(struct pvconn *pvconn) pvconn_pstream_wait \ } -static struct vconn_class stream_vconn_class = STREAM_INIT("stream"); -static struct pvconn_class pstream_pvconn_class = PSTREAM_INIT("pstream"); +static const struct vconn_class stream_vconn_class = STREAM_INIT("stream"); +static const struct pvconn_class pstream_pvconn_class = PSTREAM_INIT("pstream"); -struct vconn_class tcp_vconn_class = STREAM_INIT("tcp"); -struct pvconn_class ptcp_pvconn_class = PSTREAM_INIT("ptcp"); +const struct vconn_class tcp_vconn_class = STREAM_INIT("tcp"); +const struct pvconn_class ptcp_pvconn_class = PSTREAM_INIT("ptcp"); -struct vconn_class unix_vconn_class = STREAM_INIT("unix"); -struct pvconn_class punix_pvconn_class = PSTREAM_INIT("punix"); +const struct vconn_class unix_vconn_class = STREAM_INIT("unix"); +const struct pvconn_class punix_pvconn_class = PSTREAM_INIT("punix"); #ifdef HAVE_OPENSSL -struct vconn_class ssl_vconn_class = STREAM_INIT("ssl"); -struct pvconn_class pssl_pvconn_class = PSTREAM_INIT("pssl"); +const struct vconn_class ssl_vconn_class = STREAM_INIT("ssl"); +const struct pvconn_class pssl_pvconn_class = PSTREAM_INIT("pssl"); #endif