文档章节

LVM分布式服务clvmd分析

LastRitter
 LastRitter
发布于 2017/09/12 14:17
字数 326
阅读 27
收藏 0
LVM

上层接口

LVM命令与clvmd之间使用本地套接字进行通信。

  • 报文结构
$ cat daemons/clvmd/clvm.h
...

struct clvm_header {
	uint8_t  cmd;	        /* See below */
	uint8_t  flags;	        /* See below */
	uint16_t xid;	        /* Transaction ID */
	uint32_t clientid;	/* Only used in Daemon->Daemon comms */
	int32_t  status;	/* For replies, whether request succeeded */
	uint32_t arglen;	/* Length of argument below.
				   If >1500 then it will be passed
				   around the cluster in the system LV */
	char node[1];		/* Actually a NUL-terminated string, node name.
				   If this is empty then the command is
				   forwarded to all cluster nodes unless
				   FLAG_LOCAL or FLAG_REMOTE is also set. */
	char args[1];		/* Arguments for the command follow the
				   node name, This member is only
				   valid if the node name is empty */
} __attribute__ ((packed));

...
  • 标志
...

/* Flags */
#define CLVMD_FLAG_LOCAL	1	/* Only do this on the local node */
#define CLVMD_FLAG_SYSTEMLV	2	/* Data in system LV under my node name */
#define CLVMD_FLAG_NODEERRS	4	/* Reply has errors in node-specific portion */
#define CLVMD_FLAG_REMOTE	8	/* Do this on all nodes except for the local node */


...
  • 套接字路径
...

/* Name of the local socket to communicate between lvm and clvmd */
#define CLVMD_SOCKNAME		DEFAULT_RUN_DIR "/clvmd.sock"


...
  • 命令和响应
...

/* Internal commands & replies */
#define CLVMD_CMD_REPLY    1
#define CLVMD_CMD_VERSION  2	/* Send version around cluster when we start */
#define CLVMD_CMD_GOAWAY   3	/* Die if received this - we are running
				   an incompatible version */
#define CLVMD_CMD_TEST     4	/* Just for mucking about */

#define CLVMD_CMD_LOCK              30
#define CLVMD_CMD_UNLOCK            31


/* Lock/Unlock commands */
#define CLVMD_CMD_LOCK_LV           50
#define CLVMD_CMD_LOCK_VG           51
#define CLVMD_CMD_LOCK_QUERY	    52

/* Misc functions */
#define CLVMD_CMD_REFRESH	    40
#define CLVMD_CMD_GET_CLUSTERNAME   41
#define CLVMD_CMD_SET_DEBUG	    42
#define CLVMD_CMD_VG_BACKUP	    43
#define CLVMD_CMD_RESTART	    44
#define CLVMD_CMD_SYNC_NAMES	    45

...
  • 执行范围
...

/* Used internally by some callers, but not part of the protocol.*/
#ifndef NODE_ALL
#  define NODE_ALL	"*"
#  define NODE_LOCAL	"."
#  define NODE_REMOTE	"^"
#endif

...

底层接口

  • CoroSync
  • OpenAIS
  • CMan
  • 单节点

© 著作权归作者所有

共有 人打赏支持
LastRitter
粉丝 35
博文 36
码字总数 168045
作品 0
武汉
高级程序员
LVM故障导致RHCS启动故障

1、故障提示 抓取资源管理日志发现提示如下错误 tail -f /var/log/cluster/rgmanager.log May 6 18:21:24 yktdb1 rgmanager[17425]: State change: Local UP May 6 18:21:24 yktdb1 rgmanage......

fish2shoes
2017/05/07
0
0
【HA】RHCS + IB + ISCSI+ext4/gfs2

封装虚拟机BASE(母机): 1. 删除自启动项 /etc/udev/rules.d/70-persistent-net.rules 这样网络设备就为eth0,而不是eth1 2. 更改网络配置文件 vi /etc/sysconfig/selinux 设置为不启用 3. 禁...

千树一木
2017/02/18
0
0
Linux 常用服务整理,以及操作

1.查看Linux启动的服务 2.停止所有服务并且在下次系统启动时不再启动,如下所示: 如果想查看当前处于运行状态的服务,用如下语句过滤即可 3.如果只是想当前的设置状态有效,在系统重启动后即...

WolfX
2016/03/01
49
0
RHCS实验之二、RHCS配置

RHCS配置 逻辑拓扑: 地址规划: 节点1 mysql01.test.com 192.168.64.101 节点2 mysql02.test.com 192.168.64.102 节点提供服务的地址为192.168.64.254 存储 storage.test.com 192.168.64.10......

sunx990
2017/02/14
0
0
RHCS图形界面建立GFS共享上

一、环境 主机: 四台linux Centos6.5主机 网络: Openstack.storage:IP1:152.55.249.64 RHCS管理和存储节点 IP2:192.168.249.64 Openstack.node1:IP1:152.55.249.65 业务1 IP2:192.168.2......

zsaisai
2015/05/28
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

以太坊总结

一、概念说明 1.以太坊(Ethereum blockchain)由V神(Vitalik Buterin)发明,是一个交易记录的永久数据库,它以一个“无信任”的交易系统来运行,不需要任何第三方信任机构即可进行点对点的...

盼望明天
28分钟前
1
0
Java并发工具类——AtomicInteger

基本类型int的递增等操作并不是线程安全的,加上synchronized又会影响性能,因此在并发情况下我们应该使用AtomicInteger,下面通过一个例子验证一哈。 public class TestAtomicInteger {...

东都大狼狗
30分钟前
1
0
基于CentOS7.2系统对RabbitMQ单机版安装过程

准备虚拟机系统 我的系统如下 系统版本7.2 安装perl yum install perl 安装wget工具 yum install -y wget 安装相关依赖工具 yum install ncurses ncurses-base ncurses-devel ncurses-libs ...

凌晨一点
34分钟前
1
0
Maven常用命令

Maven常用命令 说到命令,则不得不提一下环境变量,在之前的博文中简单提了一下环境变量的配置,这里具体说一下。说完环境变量的配置,然后就是Maven的常用命令,这里说的是常用的几个命令,...

星汉
51分钟前
0
0
Flink操作mysql kafka和hbase

主程序 package com.streaming.flink;import java.util.Properties;import org.apache.flink.api.common.functions.FlatMapFunction;import org.apache.flink.api.common.functi......

守望者之父
今天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部