database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-07-29 08:21:15 +03:00
Code Activity

Modified the sequence some params were serialized to allow

Browse Source 
fewer network/socket reads.
This commit is contained in:
Patrick LeBlanc
2019-01-28 17:27:06 -06:00
parent 4583b2e8dc
commit 918e10a9ff
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
utils/cloudio/SMComm.cpp
View File

@ -83,7 +83,7 @@ int SMComm::open(const string &filename, const int mode, struct stat *statbuf)
ByteStream *response = buffers.getByteStream(); ByteStream *response = buffers.getByteStream();
int err; int err;
*command << (uint8_t) storagemanager::OPEN << filename << mode; *command << (uint8_t) storagemanager::OPEN << mode << filename;
err = sockets.send_recv(*command, response); err = sockets.send_recv(*command, response);
if (err) if (err)
common_exit(command, response, err); common_exit(command, response, err);
@ -99,7 +99,7 @@ ssize_t SMComm::pread(const string &filename, void *buf, const size_t count, con
ByteStream *response = buffers.getByteStream(); ByteStream *response = buffers.getByteStream();
int err; int err;
*command << (uint8_t) storagemanager::READ << filename << count << offset; *command << (uint8_t) storagemanager::READ << count << offset << filename;
err = sockets.send_recv(*command, response); err = sockets.send_recv(*command, response);
if (err) if (err)
common_exit(command, response, err); common_exit(command, response, err);
@ -115,7 +115,7 @@ ssize_t SMComm::pwrite(const string &filename, const void *buf, const size_t cou
ByteStream *response = buffers.getByteStream(); ByteStream *response = buffers.getByteStream();
int err; int err;
*command << (uint8_t) storagemanager::WRITE << filename << count << offset; *command << (uint8_t) storagemanager::WRITE << count << offset << filename;
command->needAtLeast(count); command->needAtLeast(count);
uint8_t *cmdBuf = command->getInputPtr(); uint8_t *cmdBuf = command->getInputPtr();
memcpy(cmdBuf, buf, count); memcpy(cmdBuf, buf, count);
@ -133,7 +133,7 @@ ssize_t SMComm::append(const string &filename, const void *buf, const size_t cou
ByteStream *response = buffers.getByteStream(); ByteStream *response = buffers.getByteStream();
int err; int err;
*command << (uint8_t) storagemanager::APPEND << filename << count; *command << (uint8_t) storagemanager::APPEND << count << filename;
command->needAtLeast(count); command->needAtLeast(count);
uint8_t *cmdBuf = command->getInputPtr(); uint8_t *cmdBuf = command->getInputPtr();
memcpy(cmdBuf, buf, count); memcpy(cmdBuf, buf, count);