diff options
Diffstat (limited to 'storage/ndb/src/common/transporter/SHM_Transporter.unix.cpp')
-rw-r--r-- | storage/ndb/src/common/transporter/SHM_Transporter.unix.cpp | 100 |
1 files changed, 100 insertions, 0 deletions
diff --git a/storage/ndb/src/common/transporter/SHM_Transporter.unix.cpp b/storage/ndb/src/common/transporter/SHM_Transporter.unix.cpp new file mode 100644 index 00000000000..28882324fc0 --- /dev/null +++ b/storage/ndb/src/common/transporter/SHM_Transporter.unix.cpp @@ -0,0 +1,100 @@ +/* Copyright (C) 2003 MySQL AB + + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ + + +#include <ndb_global.h> + +#include "SHM_Transporter.hpp" +#include "TransporterInternalDefinitions.hpp" +#include <TransporterCallback.hpp> +#include <NdbSleep.h> +#include <NdbOut.hpp> + +#include <sys/ipc.h> +#include <sys/shm.h> + +bool +SHM_Transporter::ndb_shm_create() +{ + shmId = shmget(shmKey, shmSize, IPC_CREAT | 960); + if(shmId == -1) { + perror("shmget: "); + return false; + } + return true; +} + +bool +SHM_Transporter::ndb_shm_get() +{ + shmId = shmget(shmKey, shmSize, 0); + if(shmId == -1) { + perror("shmget: "); + return false; + } + return true; +} + +bool +SHM_Transporter::ndb_shm_attach() +{ + shmBuf = (char *)shmat(shmId, 0, 0); + if(shmBuf == 0) { + perror("shmat: "); + return false; + } + return true; +} + +bool +SHM_Transporter::checkConnected(){ + struct shmid_ds info; + const int res = shmctl(shmId, IPC_STAT, &info); + if(res == -1){ + report_error(TE_SHM_IPC_STAT); + return false; + } + + if(info.shm_nattch != 2){ + report_error(TE_SHM_DISCONNECT); + return false; + } + return true; +} + +void +SHM_Transporter::disconnectImpl(){ + if(_attached){ + const int res = shmdt(shmBuf); + if(res == -1){ + perror("shmdelete: "); + return; + } + _attached = false; + if(!isServer && _shmSegCreated) + _shmSegCreated = false; + } + + if(isServer && _shmSegCreated){ + const int res = shmctl(shmId, IPC_RMID, 0); + if(res == -1){ + report_error(TE_SHM_UNABLE_TO_REMOVE_SEGMENT); + return; + } + _shmSegCreated = false; + } + setupBuffersDone=false; +} |