diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-13 15:09:46 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-13 15:09:46 +0100 |
commit | 71ecce0d5fc572a6e71dc9b554c57df9f6ea7827 (patch) | |
tree | c1480e7ab5806979e2173fd3911f46206a2a165c /fnet | |
parent | 2b3a7c21f8ca00502e26725d6cb4d67618d51cce (diff) |
rename tub -> stash
Diffstat (limited to 'fnet')
-rw-r--r-- | fnet/src/tests/frt/rpc/invoke.cpp | 12 | ||||
-rw-r--r-- | fnet/src/vespa/fnet/frt/values.cpp | 60 | ||||
-rw-r--r-- | fnet/src/vespa/fnet/frt/values.h | 4 |
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(); |