Commit 00c3061b authored by Geoff Simmons's avatar Geoff Simmons

trackrdrd: now trying a full memory barrier it writer threads before

           sending data
parent 93b0e6c4
...@@ -56,7 +56,6 @@ ...@@ -56,7 +56,6 @@
#include "vsb.h" #include "vsb.h"
#include "vpf.h" #include "vpf.h"
#include "vmb.h"
#include "libvarnish.h" #include "libvarnish.h"
#include "vsl.h" #include "vsl.h"
...@@ -816,7 +815,6 @@ OSL_Track(void *priv, enum VSL_tag_e tag, unsigned fd, unsigned len, ...@@ -816,7 +815,6 @@ OSL_Track(void *priv, enum VSL_tag_e tag, unsigned fd, unsigned len,
sprintf(reqend_str, "%s=%u.%09lu", REQEND_T_VAR, sprintf(reqend_str, "%s=%u.%09lu", REQEND_T_VAR,
(unsigned) reqend_t.tv_sec, reqend_t.tv_nsec); (unsigned) reqend_t.tv_sec, reqend_t.tv_nsec);
append(de, tag, xid, reqend_str, strlen(reqend_str)); append(de, tag, xid, reqend_str, strlen(reqend_str));
VWMB();
de->state = DATA_DONE; de->state = DATA_DONE;
MON_StatsUpdate(STATS_DONE); MON_StatsUpdate(STATS_DONE);
submit(he); submit(he);
......
...@@ -38,6 +38,7 @@ ...@@ -38,6 +38,7 @@
#include "trackrdrd.h" #include "trackrdrd.h"
#include "vas.h" #include "vas.h"
#include "miniobj.h" #include "miniobj.h"
#include "vmb.h"
#define VERSION_LEN 64 #define VERSION_LEN 64
#define CLIENT_ID_LEN 80 #define CLIENT_ID_LEN 80
...@@ -129,6 +130,7 @@ wrk_send(void **mq_worker, dataentry *entry, worker_data_t *wrk) ...@@ -129,6 +130,7 @@ wrk_send(void **mq_worker, dataentry *entry, worker_data_t *wrk)
AN(mq_worker); AN(mq_worker);
/* XXX: report entry->incomplete to backend ? */ /* XXX: report entry->incomplete to backend ? */
VMB();
errnum = mqf.send(*mq_worker, entry->data, entry->end, errnum = mqf.send(*mq_worker, entry->data, entry->end,
entry->key, entry->keylen, &err); entry->key, entry->keylen, &err);
if (errnum != 0) { if (errnum != 0) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment