summaryrefslogtreecommitdiffstats
path: root/fnet
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-01-13 15:09:46 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2017-01-13 15:09:46 +0100
commit71ecce0d5fc572a6e71dc9b554c57df9f6ea7827 (patch)
treec1480e7ab5806979e2173fd3911f46206a2a165c /fnet
parent2b3a7c21f8ca00502e26725d6cb4d67618d51cce (diff)
rename tub -> stash
Diffstat (limited to 'fnet')
-rw-r--r--fnet/src/tests/frt/rpc/invoke.cpp12
-rw-r--r--fnet/src/vespa/fnet/frt/values.cpp60
-rw-r--r--fnet/src/vespa/fnet/frt/values.h4
3 files changed, 38 insertions, 38 deletions
diff --git a/fnet/src/tests/frt/rpc/invoke.cpp b/fnet/src/tests/frt/rpc/invoke.cpp
index 2f5594779e9..f2c181a7ac2 100644
--- a/fnet/src/tests/frt/rpc/invoke.cpp
+++ b/fnet/src/tests/frt/rpc/invoke.cpp
@@ -104,25 +104,25 @@ public:
class EchoTest : public FRT_Invokable
{
private:
- vespalib::Stash *_echo_tub;
+ vespalib::Stash *_echo_stash;
FRT_Values *_echo_args;
EchoTest(const EchoTest &);
EchoTest &operator=(const EchoTest &);
public:
- EchoTest() : _echo_tub(NULL), _echo_args(NULL) {}
+ EchoTest() : _echo_stash(NULL), _echo_args(NULL) {}
~EchoTest()
{
delete _echo_args;
- delete _echo_tub;
+ delete _echo_stash;
}
void Init(FRT_Supervisor *supervisor)
{
- _echo_tub = new vespalib::Stash();
- _echo_args = new FRT_Values(_echo_tub);
- assert(_echo_tub != NULL && _echo_args != NULL);
+ _echo_stash = new vespalib::Stash();
+ _echo_args = new FRT_Values(_echo_stash);
+ assert(_echo_stash != NULL && _echo_args != NULL);
FRT_ReflectionBuilder rb(supervisor);
rb.DefineMethod("echo", "*", "*", true,
diff --git a/fnet/src/vespa/fnet/frt/values.cpp b/fnet/src/vespa/fnet/frt/values.cpp
index 206fa1afd44..0d6ee4a8e97 100644
--- a/fnet/src/vespa/fnet/frt/values.cpp
+++ b/fnet/src/vespa/fnet/frt/values.cpp
@@ -72,13 +72,13 @@ private:
using fnet::BlobRef;
using fnet::LocalBlob;
-FRT_Values::FRT_Values(Stash *tub)
+FRT_Values::FRT_Values(Stash * stash)
: _maxValues(0),
_numValues(0),
_typeString(NULL),
_values(NULL),
_blobs(NULL),
- _tub(tub)
+ _stash(stash)
{ }
FRT_Values::~FRT_Values() { }
@@ -126,10 +126,10 @@ FRT_Values::EnsureFree(uint32_t need)
if (cnt < 16)
cnt = 16;
- char *types = (char *) _tub->alloc(cnt + 1);
+ char *types = (char *) _stash->alloc(cnt + 1);
memcpy(types, _typeString, _numValues);
memset(types + _numValues, FRT_VALUE_NONE, cnt + 1 - _numValues);
- FRT_Value *values = (FRT_Value *) _tub->alloc(cnt * sizeof(FRT_Value));
+ FRT_Value *values = (FRT_Value *) _stash->alloc(cnt * sizeof(FRT_Value));
memcpy(values, _values, _numValues * sizeof(FRT_Value));
_maxValues = cnt;
_typeString = types;
@@ -139,7 +139,7 @@ FRT_Values::EnsureFree(uint32_t need)
uint8_t *
FRT_Values::AddInt8Array(uint32_t len) {
EnsureFree();
- uint8_t *ret = (uint8_t *) _tub->alloc(len * sizeof(uint8_t));
+ uint8_t *ret = (uint8_t *) _stash->alloc(len * sizeof(uint8_t));
_values[_numValues]._int8_array._pt = ret;
_values[_numValues]._int8_array._len = len;
_typeString[_numValues++] = FRT_VALUE_INT8_ARRAY;
@@ -149,7 +149,7 @@ FRT_Values::AddInt8Array(uint32_t len) {
void
FRT_Values::AddInt8Array(const uint8_t *array, uint32_t len) {
EnsureFree();
- uint8_t *pt = (uint8_t *) _tub->alloc(len * sizeof(uint8_t));
+ uint8_t *pt = (uint8_t *) _stash->alloc(len * sizeof(uint8_t));
_values[_numValues]._int8_array._pt = pt;
_values[_numValues]._int8_array._len = len;
_typeString[_numValues++] = FRT_VALUE_INT8_ARRAY;
@@ -159,7 +159,7 @@ FRT_Values::AddInt8Array(const uint8_t *array, uint32_t len) {
uint16_t *
FRT_Values::AddInt16Array(uint32_t len) {
EnsureFree();
- uint16_t *ret = (uint16_t *) _tub->alloc(len * sizeof(uint16_t));
+ uint16_t *ret = (uint16_t *) _stash->alloc(len * sizeof(uint16_t));
_values[_numValues]._int16_array._pt = ret;
_values[_numValues]._int16_array._len = len;
_typeString[_numValues++] = FRT_VALUE_INT16_ARRAY;
@@ -169,7 +169,7 @@ FRT_Values::AddInt16Array(uint32_t len) {
void
FRT_Values::AddInt16Array(const uint16_t *array, uint32_t len) {
EnsureFree();
- uint16_t *pt = (uint16_t *) _tub->alloc(len * sizeof(uint16_t));
+ uint16_t *pt = (uint16_t *) _stash->alloc(len * sizeof(uint16_t));
_values[_numValues]._int16_array._pt = pt;
_values[_numValues]._int16_array._len = len;
_typeString[_numValues++] = FRT_VALUE_INT16_ARRAY;
@@ -179,7 +179,7 @@ FRT_Values::AddInt16Array(const uint16_t *array, uint32_t len) {
uint32_t *
FRT_Values::AddInt32Array(uint32_t len) {
EnsureFree();
- uint32_t *ret = (uint32_t *) _tub->alloc(len * sizeof(uint32_t));
+ uint32_t *ret = (uint32_t *) _stash->alloc(len * sizeof(uint32_t));
_values[_numValues]._int32_array._pt = ret;
_values[_numValues]._int32_array._len = len;
_typeString[_numValues++] = FRT_VALUE_INT32_ARRAY;
@@ -189,7 +189,7 @@ FRT_Values::AddInt32Array(uint32_t len) {
void
FRT_Values::AddInt32Array(const uint32_t *array, uint32_t len) {
EnsureFree();
- uint32_t *pt = (uint32_t *) _tub->alloc(len * sizeof(uint32_t));
+ uint32_t *pt = (uint32_t *) _stash->alloc(len * sizeof(uint32_t));
_values[_numValues]._int32_array._pt = pt;
_values[_numValues]._int32_array._len = len;
_typeString[_numValues++] = FRT_VALUE_INT32_ARRAY;
@@ -199,7 +199,7 @@ FRT_Values::AddInt32Array(const uint32_t *array, uint32_t len) {
uint64_t *
FRT_Values::AddInt64Array(uint32_t len) {
EnsureFree();
- uint64_t *ret = (uint64_t *) _tub->alloc(len * sizeof(uint64_t));
+ uint64_t *ret = (uint64_t *) _stash->alloc(len * sizeof(uint64_t));
_values[_numValues]._int64_array._pt = ret;
_values[_numValues]._int64_array._len = len;
_typeString[_numValues++] = FRT_VALUE_INT64_ARRAY;
@@ -209,7 +209,7 @@ FRT_Values::AddInt64Array(uint32_t len) {
void
FRT_Values::AddInt64Array(const uint64_t *array, uint32_t len) {
EnsureFree();
- uint64_t *pt = (uint64_t *) _tub->alloc(len * sizeof(uint64_t));
+ uint64_t *pt = (uint64_t *) _stash->alloc(len * sizeof(uint64_t));
_values[_numValues]._int64_array._pt = pt;
_values[_numValues]._int64_array._len = len;
_typeString[_numValues++] = FRT_VALUE_INT64_ARRAY;
@@ -219,7 +219,7 @@ FRT_Values::AddInt64Array(const uint64_t *array, uint32_t len) {
float *
FRT_Values::AddFloatArray(uint32_t len) {
EnsureFree();
- float *ret = (float *) _tub->alloc(len * sizeof(float));
+ float *ret = (float *) _stash->alloc(len * sizeof(float));
_values[_numValues]._float_array._pt = ret;
_values[_numValues]._float_array._len = len;
_typeString[_numValues++] = FRT_VALUE_FLOAT_ARRAY;
@@ -229,7 +229,7 @@ FRT_Values::AddFloatArray(uint32_t len) {
void
FRT_Values::AddFloatArray(const float *array, uint32_t len) {
EnsureFree();
- float *pt = (float *) _tub->alloc(len * sizeof(float));
+ float *pt = (float *) _stash->alloc(len * sizeof(float));
_values[_numValues]._float_array._pt = pt;
_values[_numValues]._float_array._len = len;
_typeString[_numValues++] = FRT_VALUE_FLOAT_ARRAY;
@@ -239,7 +239,7 @@ FRT_Values::AddFloatArray(const float *array, uint32_t len) {
double *
FRT_Values::AddDoubleArray(uint32_t len) {
EnsureFree();
- double *ret = (double *) _tub->alloc(len * sizeof(double));
+ double *ret = (double *) _stash->alloc(len * sizeof(double));
_values[_numValues]._double_array._pt = ret;
_values[_numValues]._double_array._len = len;
_typeString[_numValues++] = FRT_VALUE_DOUBLE_ARRAY;
@@ -249,7 +249,7 @@ FRT_Values::AddDoubleArray(uint32_t len) {
void
FRT_Values::AddDoubleArray(const double *array, uint32_t len) {
EnsureFree();
- double *pt = (double *) _tub->alloc(len * sizeof(double));
+ double *pt = (double *) _stash->alloc(len * sizeof(double));
_values[_numValues]._double_array._pt = pt;
_values[_numValues]._double_array._len = len;
_typeString[_numValues++] = FRT_VALUE_DOUBLE_ARRAY;
@@ -259,7 +259,7 @@ FRT_Values::AddDoubleArray(const double *array, uint32_t len) {
void
FRT_Values::AddString(const char *str, uint32_t len) {
EnsureFree();
- _values[_numValues]._string._str = fnet::copyString(_tub->alloc(len+1), str, len);
+ _values[_numValues]._string._str = fnet::copyString(_stash->alloc(len+1), str, len);
_values[_numValues]._string._len = len;
_typeString[_numValues++] = FRT_VALUE_STRING;
}
@@ -267,7 +267,7 @@ FRT_Values::AddString(const char *str, uint32_t len) {
char *
FRT_Values::AddString(uint32_t len) {
EnsureFree();
- char *ret = (char *) _tub->alloc(len + 1);
+ char *ret = (char *) _stash->alloc(len + 1);
_values[_numValues]._string._str = ret;
_values[_numValues]._string._len = len;
_typeString[_numValues++] = FRT_VALUE_STRING;
@@ -277,7 +277,7 @@ FRT_Values::AddString(uint32_t len) {
FRT_StringValue *
FRT_Values::AddStringArray(uint32_t len) {
EnsureFree();
- FRT_StringValue *ret = (FRT_StringValue *) _tub->alloc(len * sizeof(FRT_StringValue));
+ FRT_StringValue *ret = (FRT_StringValue *) _stash->alloc(len * sizeof(FRT_StringValue));
_values[_numValues]._string_array._pt = ret;
_values[_numValues]._string_array._len = len;
_typeString[_numValues++] = FRT_VALUE_STRING_ARRAY;
@@ -287,7 +287,7 @@ FRT_Values::AddStringArray(uint32_t len) {
void
FRT_Values::AddSharedData(FRT_ISharedBlob *blob) {
EnsureFree();
- _blobs = &_tub->create<BlobRef>(nullptr, _numValues, blob, _blobs);
+ _blobs = &_stash->create<BlobRef>(nullptr, _numValues, blob, _blobs);
_values[_numValues]._data._buf = const_cast<char *>(blob->getData());
_values[_numValues]._data._len = blob->getLen();
_typeString[_numValues++] = FRT_VALUE_DATA;
@@ -295,16 +295,16 @@ FRT_Values::AddSharedData(FRT_ISharedBlob *blob) {
void
FRT_Values::AddData(vespalib::alloc::Alloc buf, uint32_t len) {
- AddSharedData(&_tub->create<LocalBlob>(std::move(buf), len));
+ AddSharedData(&_stash->create<LocalBlob>(std::move(buf), len));
}
void
FRT_Values::AddData(const char *buf, uint32_t len) {
if (len > SHARED_LIMIT) {
- return AddSharedData(&_tub->create<LocalBlob>(buf, len));
+ return AddSharedData(&_stash->create<LocalBlob>(buf, len));
}
EnsureFree();
- _values[_numValues]._data._buf = fnet::copyData(_tub->alloc(len), buf, len);
+ _values[_numValues]._data._buf = fnet::copyData(_stash->alloc(len), buf, len);
_values[_numValues]._data._len = len;
_typeString[_numValues++] = FRT_VALUE_DATA;
}
@@ -312,12 +312,12 @@ FRT_Values::AddData(const char *buf, uint32_t len) {
char *
FRT_Values::AddData(uint32_t len) {
if (len > SHARED_LIMIT) {
- LocalBlob *blob = &_tub->create<LocalBlob>(nullptr, len);
+ LocalBlob *blob = &_stash->create<LocalBlob>(nullptr, len);
AddSharedData(blob);
return blob->getInternalData();
}
EnsureFree();
- char *ret = (char *) _tub->alloc(len);
+ char *ret = (char *) _stash->alloc(len);
_values[_numValues]._data._buf = ret;
_values[_numValues]._data._len = len;
_typeString[_numValues++] = FRT_VALUE_DATA;
@@ -327,7 +327,7 @@ FRT_Values::AddData(uint32_t len) {
FRT_DataValue *
FRT_Values::AddDataArray(uint32_t len) {
EnsureFree();
- FRT_DataValue *ret = (FRT_DataValue *) _tub->alloc(len * sizeof(FRT_DataValue));
+ FRT_DataValue *ret = (FRT_DataValue *) _stash->alloc(len * sizeof(FRT_DataValue));
_values[_numValues]._data_array._pt = ret;
_values[_numValues]._data_array._len = len;
_typeString[_numValues++] = FRT_VALUE_DATA_ARRAY;
@@ -336,7 +336,7 @@ FRT_Values::AddDataArray(uint32_t len) {
void
FRT_Values::SetString(FRT_StringValue *value, const char *str, uint32_t len) {
- value->_str = fnet::copyString(_tub->alloc(len+1), str, len);
+ value->_str = fnet::copyString(_stash->alloc(len+1), str, len);
value->_len = len;
}
@@ -349,11 +349,11 @@ void
FRT_Values::SetData(FRT_DataValue *value, const char *buf, uint32_t len) {
char *mybuf = NULL;
if (len > SHARED_LIMIT) {
- LocalBlob *blob = &_tub->create<LocalBlob>(buf, len);
- _blobs = &_tub->create<BlobRef>(value, 0, blob, _blobs);
+ LocalBlob *blob = &_stash->create<LocalBlob>(buf, len);
+ _blobs = &_stash->create<BlobRef>(value, 0, blob, _blobs);
mybuf = blob->getInternalData();
} else {
- mybuf = fnet::copyData(_tub->alloc(len), buf, len);
+ mybuf = fnet::copyData(_stash->alloc(len), buf, len);
}
value->_buf = mybuf;
value->_len = len;
diff --git a/fnet/src/vespa/fnet/frt/values.h b/fnet/src/vespa/fnet/frt/values.h
index ff1ec3fa11d..fafdab30a9d 100644
--- a/fnet/src/vespa/fnet/frt/values.h
+++ b/fnet/src/vespa/fnet/frt/values.h
@@ -89,12 +89,12 @@ private:
char *_typeString;
FRT_Value *_values;
fnet::BlobRef *_blobs;
- Stash *_tub;
+ Stash *_stash;
public:
FRT_Values(const FRT_Values &) = delete;
FRT_Values &operator=(const FRT_Values &) = delete;
- FRT_Values(Stash *tub);
+ FRT_Values(Stash * stash);
~FRT_Values();
void DiscardBlobs();