Enterprise

Enterprise Clone Function 설명

clone.c funstion 설명

clone.c와 replication.c 비교

ent750 작성하면서 정리했다.

 clone.c 
 CLONE										REPLICATION
 cloneState()
 replState()
 getClone()
 getCloneNode()
 createClone()
 freeClone()
 addMasterClone()
 delMasterClone()
 addPendingClone()
 delPendingClone()
 getCloneName()							-> replicationGetSlaveName()
 createCloneBacklog()					-> createReplicationBacklog()
 resizeCloneBacklog()					-> resizeReplicationBacklog()
 freeCloneBacklog()						-> freeReplicationBacklog()
 feedCloneBacklog()						-> feedReplicationBacklog()
 feedCloneBacklogWithObject()		-> feedReplicationBacklogWithObject()
 canFeedCloneReplBuffer()				-> canFeedReplicaReplBuffer()
 prepareClonesToWrite()				-> prepareReplicasToWrite()
 feedToClones()							-> replicationFeedSlaves()
 	이중화, 삼중화 처리, 이중 입력 막기. 210 줄 
 	server.c propagateNow()에서 if (target & PROPAGATE_CLONE)일 때 호출 
 	
 	feedToClones()는 2곳에서 호출한다.
 		clone.c:        cloneCron() -> feedToClones(); 
 		server.c:        propagateNow() -> feedToClones();
 
 	replicationFeedSlaves()는 6곳에서 호출한다.
 		replication.c:	replicationCron() -> replicationFeedSlaves(); 
 		server.c:    sendGetackToReplicas() -> replicationFeedSlaves();
 		server.c:    propagateNow() -> replicationFeedSlaves();
 		db.c:  		propagateExpireMember() -> replicationFeedSlaves();
 		debug.c:		debug replicate -> replicationFeedSlaves();
 		rdb.c:			rdbLoadRioWithLoadingCtx() -> replicationFeedSlaves();
 
 addReplyCloneBacklog()				-> addReplyReplicationBacklog()
 	masterCloneTryPartialResync()에서 호출 
 getPsyncInitialOffsetClone()			-> getPsyncInitialOffset()
 setupCloneForFullResync()			-> replicationSetupSlaveForFullResync()
 	startBgsaveForClone()에서 호출 
 	syncCloneCommand()에서 호출 		
 setupCloneForSync()					
 	syncCloneCommand()에서 full sync 없이 sync만 할 때 호출 		
 masterCloneTryPartialResync()		-> masterTryPartialResynchronization()
 	syncCloneCommand()에서 psyncclone 요청일 때 호출 				
 startBgsaveForClone()					-> startBgsaveForReplication()
 	syncCloneCommand()에서 호출
 	updateClonesWaitingBgsave()에서 RDB 파일을 기다르는 클론이 있으면 호출
 	cloneStartPendingFork()에서 RDB 파일을 기다리는 클론이 있으면 호출		
 syncCloneCommand()					-> syncCommand()
 	1) 부분동기화 시도(psyncclone)  masterCloneTryPartialResync()
 	2) 동기화만 시작 setupCloneForSync(): 서버 시작 시각, full sync 요청이 없을 때 
 	3) Full sync 시작 setupCloneForFullResync()
 	4) RDB save 시작 startBgsaveForClone()		
 cloneconfCommand()					-> replconfCommand()	
 	ip-address <ip>, listening-port <port>
 	capa <eof|psync2>
 	ack <offset>
 	getack: offset 요청
 	server-starttime
 	sync_clone_flag <1|0>
 	sync_clone_addr <ip:port>		
 putCloneOnline()	-> ~6.x			
 clonePutOnline()							-> replicaPutOnline()
 cloneStartCommandStream()			-> replicaStartCommandStream()	
 sendBulkToClone()						-> sendBulkToSlave()
 	rdb 파일을 보내는 역할을 한다. 71 줄. 
 	updateClonesWaitingBgsave()에서 호출 
 		connSetWriteHandler(c->conn,sendBulkToClone) 		
 updateClonesWaitingBgsave()		-> updateSlavesWaitingBgsave()
 	Bgsave가 완료될 때까지 상태 정보를 업테이트합니다. 118 줄. 
 	rdb.c backgroundSaveDoneHandler()에서 호출 
 	connSetWriteHandler(c->conn,sendBulkToClone) 		
 changeCloneReplId()					-> changeReplicationId()
 clearCloneReplId2()						-> clearReplicationId2()
 shiftCloneReplId()						-> shiftReplicationId()
 cloneIsInHandshakeState()			-> slaveIsInHandshakeState()
 sendNewlineToMasterClone()		-> replicationSendNewlineToMaster()
 cloneEmptyDbCallback()				-> replicationEmptyDbCallback()
 	readSyncBulkPayloadClone()에서 호출 		
 createMasterCloneClient()				-> replicationCreateMasterClient()		
 	connSetReadHandler(clone->master->conn, readQueryFromClient);
 readSyncBulkPayloadClone()			-> readSyncBulkPayload()	
 	syncWithMasterClone()에서 connSetReadHandler(conn, readSyncBulkPayloadClone) 호출 		
 cloneTryPartialResync()					-> slaveTryPartialResynchronization()
 	마스터에게 동기화 요청을 한다. 238 줄
 	PSYNCCLONE
 	+FULLRESYNC / +SYNC / +CONTINUE
 	-NOMASTERLINK / -LOADING / -ERR
 	syncWithMasterClone()에서 호출			
 syncWithMasterClone()					-> syncWithMaster()
 	syncWithMasterClone()에서 connSetReadHandler(conn, syncWithMasterClone); 호출 
 	connectWithMasterClone()에서 connConnect(clone->conn, clone->masterhost, clone->masterport, server.bind_source_addr, syncWithMasterClone) 호출 	
 connectWithMasterClone()			-> connectWithMaster()
 	cancelCloneHandshake()에서 reconnect일 때 호출 
 	cloneCron()에서 호출 
 undoConnectWithMasterClone()	-> undoConnectWithMaster()
 cloneAbortSyncTransfer()				-> replicationAbortSyncTransfer()
 cancelCloneHandshake()				-> cancelReplicationHandshake()
 												-> replicationSetMaster()
 												-> replicationUnsetMaster()
 												-> replicationHandleMasterDisconnection()	
 startSyncCommand()					-> replicaofCommand()
 	pending_clones에 넣는 역할을 한다. 		
 endSyncCommand()
 	cached/from/pending_clones에서 지우는 역할을 한다. 
 cloneSendAck()							-> replicationSendAck()
 cloneCacheMaster()						-> replicationCacheMaster() 
 cloneCacheMasterEndSync()		
 cloneResurrectMasterClient()			-> replicationResurrectCachedMaster()
 	connSetReadHandler(clone->master->conn, readQueryFromClient)
 	connSetWriteHandler(clone->master->conn, sendReplyToClient)
 cloneCron()								-> replicationCron()
 	pending_clones에서 읽어서 connectWithMasterClone()을 호출한다. 
 cloneStartPendingFork()				-> replicationStartPendingFork()
 	cloneCron()에서 호출

readQueryFromClient()

networking.c에 있는 readQueryFromClient()에서 하는 일
실제 명령을 처리하고 AOF, Replica, Clone에 전파한다.

readQueryFromClient()	networking.c
	processInputBuffer()
		processInlineBuffer()
		processMultibulkBuffer()
		processCommandAndResetClient()
			processCommand()		server.c
				call()
					alsoPropagate()
					afterCommand()
						if (server.core_propagates) propagatePendingCommands(c);						
							propagateNow()
								feedAppendOnlyFile()
								replicationFeedSlaves()
								feedToClones() 클론에 보내는 일은 여기서 한다. 								
			commandProcessed()	명령이 실행된 후 필요한 작업을 한다.	networking.c

Email 답글이 올라오면 이메일로 알려드리겠습니다.