	.section	__TEXT,__text,regular,pure_instructions
	.build_version macos, 13, 0	sdk_version 13, 3
	.globl	_ApplyWorkerMain                ## -- Begin function ApplyWorkerMain
	.p2align	4, 0x90
_ApplyWorkerMain:                       ## @ApplyWorkerMain
	.cfi_startproc
## %bb.0:
	pushq	%rbp
	.cfi_def_cfa_offset 16
	.cfi_offset %rbp, -16
	movq	%rsp, %rbp
	.cfi_def_cfa_register %rbp
	pushq	%r15
	pushq	%r14
	pushq	%r13
	pushq	%r12
	pushq	%rbx
	subq	$72, %rsp
	.cfi_offset %rbx, -56
	.cfi_offset %r12, -48
	.cfi_offset %r13, -40
	.cfi_offset %r14, -32
	.cfi_offset %r15, -24
	movq	___stack_chk_guard@GOTPCREL(%rip), %rax
	movq	(%rax), %rax
	movq	%rax, -48(%rbp)
	callq	_DatumGetInt32
	movl	%eax, %ebx
	movq	_NAMEDATALEN@GOTPCREL(%rip), %rax
	movl	(%rax), %eax
	movq	%rax, -72(%rbp)                 ## 8-byte Spill
	callq	____chkstk_darwin
	addq	$15, %rax
	andq	$-16, %rax
	subq	%rax, %rsp
	movq	%rsp, -64(%rbp)                 ## 8-byte Spill
	movl	%ebx, %edi
	callq	_logicalrep_worker_attach
	movq	_SIGHUP@GOTPCREL(%rip), %rax
	movl	(%rax), %edi
	movq	_logicalrep_worker_sighup@GOTPCREL(%rip), %rax
	movl	(%rax), %esi
	callq	_pqsignal
	movq	_SIGTERM@GOTPCREL(%rip), %rax
	movl	(%rax), %edi
	movq	_die@GOTPCREL(%rip), %rax
	movl	(%rax), %esi
	callq	_pqsignal
	xorl	%eax, %eax
	callq	_BackgroundWorkerUnblockSignals
	xorl	%eax, %eax
	callq	_GetCurrentTimestamp
	movq	_MyLogicalRepWorker@GOTPCREL(%rip), %r15
	movq	(%r15), %rcx
	movl	%eax, 20(%rcx)
	movl	%eax, 24(%rcx)
	movl	%eax, 28(%rcx)
	leaq	L_.str(%rip), %rdi
	xorl	%esi, %esi
	callq	_load_file
	movq	_PGC_SUSET@GOTPCREL(%rip), %rax
	movl	(%rax), %edx
	movq	_PGC_S_OVERRIDE@GOTPCREL(%rip), %r14
	movl	(%r14), %ecx
	leaq	L_.str.1(%rip), %rdi
	leaq	L_.str.2(%rip), %rsi
	callq	_SetConfigOption
	movq	(%r15), %rax
	movl	12(%rax), %esi
	movl	16(%rax), %edi
	xorl	%edx, %edx
	callq	_BackgroundWorkerInitializeConnectionByOid
	movq	_TopMemoryContext@GOTPCREL(%rip), %rax
	movl	(%rax), %edi
	movq	_ALLOCSET_DEFAULT_SIZES@GOTPCREL(%rip), %rax
	movl	(%rax), %edx
	leaq	L_.str.3(%rip), %rsi
	callq	_AllocSetContextCreate
	movq	_ApplyContext@GOTPCREL(%rip), %rbx
	movl	%eax, (%rbx)
	xorl	%eax, %eax
	callq	_StartTransactionCommand
	movl	(%rbx), %edi
	callq	_MemoryContextSwitchTo
	movl	%eax, %ebx
	movq	(%r15), %rax
	movq	(%rax), %rdi
	movl	$1, %esi
	callq	_GetSubscription
	movq	_MySubscription@GOTPCREL(%rip), %r13
	movq	%rax, (%r13)
	testq	%rax, %rax
	jne	LBB0_2
## %bb.1:
	movq	_LOG@GOTPCREL(%rip), %rax
	movl	(%rax), %r12d
	movq	(%r15), %rax
	movq	(%rax), %rsi
	leaq	L_.str.4(%rip), %rdi
	xorl	%eax, %eax
	callq	_errmsg
	movl	%r12d, %edi
	movl	%eax, %esi
	callq	_ereport
	xorl	%edi, %edi
	callq	_proc_exit
LBB0_2:
	movq	_MySubscriptionValid@GOTPCREL(%rip), %rax
	movl	$1, (%rax)
	movl	%ebx, %edi
	callq	_MemoryContextSwitchTo
	movq	(%r13), %rax
	cmpl	$0, 36(%rax)
	jne	LBB0_4
## %bb.3:
	movq	_LOG@GOTPCREL(%rip), %rcx
	movl	(%rcx), %ebx
	movq	(%rax), %rsi
	leaq	L_.str.5(%rip), %rdi
	xorl	%eax, %eax
	callq	_errmsg
	movl	%ebx, %edi
	movl	%eax, %esi
	callq	_ereport
	xorl	%edi, %edi
	callq	_proc_exit
	movq	(%r13), %rax
LBB0_4:
	movq	8(%rax), %rsi
	movq	_PGC_BACKEND@GOTPCREL(%rip), %rax
	movl	(%rax), %edx
	movl	(%r14), %ecx
	leaq	L_.str.6(%rip), %rdi
	callq	_SetConfigOption
	movq	_SUBSCRIPTIONOID@GOTPCREL(%rip), %rax
	movl	(%rax), %edi
	movq	_subscription_change_cb@GOTPCREL(%rip), %rax
	movl	(%rax), %esi
	xorl	%edx, %edx
	callq	_CacheRegisterSyscacheCallback
	xorl	%eax, %eax
	callq	_am_tablesync_worker
	movq	_LOG@GOTPCREL(%rip), %rcx
	movl	(%rcx), %r12d
	movq	(%r13), %rcx
	movq	(%rcx), %rbx
	testq	%rax, %rax
	je	LBB0_6
## %bb.5:
	movq	(%r15), %rax
	movl	8(%rax), %edi
	callq	_get_rel_name
	leaq	L_.str.7(%rip), %rdi
	movq	%rbx, %rsi
	movl	%eax, %edx
	xorl	%eax, %eax
	callq	_errmsg
	jmp	LBB0_7
LBB0_6:
	leaq	L_.str.8(%rip), %rdi
	movq	%rbx, %rsi
	xorl	%eax, %eax
	callq	_errmsg
LBB0_7:
	movq	-64(%rbp), %r14                 ## 8-byte Reload
	movl	%r12d, %edi
	movl	%eax, %esi
	callq	_ereport
	xorl	%eax, %eax
	callq	_CommitTransactionCommand
	movq	_DEBUG1@GOTPCREL(%rip), %rax
	movl	(%rax), %edi
	movq	(%r13), %rax
	movl	32(%rax), %edx
	leaq	L_.str.9(%rip), %rsi
	callq	_elog
	xorl	%eax, %eax
	callq	_am_tablesync_worker
	testq	%rax, %rax
	je	LBB0_9
## %bb.8:
	leaq	-52(%rbp), %rdi
	callq	_LogicalRepSyncTableStart
	movq	%rax, %rbx
	movq	_ApplyContext@GOTPCREL(%rip), %rax
	movl	(%rax), %edi
	callq	_MemoryContextSwitchTo
	movl	%eax, %r14d
	movq	%rbx, %rdi
	callq	_pstrdup
	movq	%rax, %r12
	movl	%r14d, %edi
	callq	_MemoryContextSwitchTo
	movq	%rbx, %rdi
	callq	_pfree
	jmp	LBB0_16
LBB0_9:
	movq	(%r13), %rax
	movq	16(%rax), %r12
	testq	%r12, %r12
	jne	LBB0_11
## %bb.10:
	movq	_ERROR@GOTPCREL(%rip), %rax
	movl	(%rax), %ebx
	leaq	L_.str.10(%rip), %rdi
	xorl	%eax, %eax
	callq	_errmsg
	movl	%ebx, %edi
	movl	%eax, %esi
	callq	_ereport
LBB0_11:
	xorl	%eax, %eax
	callq	_StartTransactionCommand
	movq	(%r13), %rax
	movl	24(%rax), %ecx
	leaq	L_.str.11(%rip), %rdx
	movq	%r14, %rdi
	movq	-72(%rbp), %rsi                 ## 8-byte Reload
                                        ## kill: def $esi killed $esi killed $rsi
	callq	_snprintf
	movq	%r14, %rdi
	movl	$1, %esi
	callq	_replorigin_by_name
	movl	%eax, %ebx
	movl	%eax, %edi
	callq	_OidIsValid
	testl	%eax, %eax
	jne	LBB0_13
## %bb.12:
	movq	%r14, %rdi
	callq	_replorigin_create
	movl	%eax, %ebx
LBB0_13:
	movl	%ebx, %edi
	callq	_replorigin_session_setup
	movq	_replorigin_session_origin@GOTPCREL(%rip), %rax
	movl	%ebx, (%rax)
	xorl	%edi, %edi
	callq	_replorigin_session_get_progress
	movl	%eax, -52(%rbp)
	xorl	%eax, %eax
	callq	_CommitTransactionCommand
	movq	(%r13), %rax
	movl	32(%rax), %edi
	movq	(%rax), %rdx
	leaq	-104(%rbp), %rcx
	movl	$1, %esi
	callq	_walrcv_connect
	movq	_wrconn@GOTPCREL(%rip), %rbx
	movq	%rax, (%rbx)
	testq	%rax, %rax
	jne	LBB0_15
## %bb.14:
	movq	_ERROR@GOTPCREL(%rip), %rax
	movl	(%rax), %r14d
	movq	-104(%rbp), %rsi
	leaq	L_.str.12(%rip), %rdi
	xorl	%eax, %eax
	callq	_errmsg
	movl	%r14d, %edi
	movl	%eax, %esi
	callq	_ereport
	movq	(%rbx), %rax
LBB0_15:
	leaq	-108(%rbp), %rsi
	movq	%rax, %rdi
	callq	_walrcv_identify_system
LBB0_16:
	movq	_SUBSCRIPTIONRELMAP@GOTPCREL(%rip), %rax
	movl	(%rax), %edi
	movq	_invalidate_syncing_table_states@GOTPCREL(%rip), %rax
	movl	(%rax), %esi
	xorl	%edx, %edx
	callq	_CacheRegisterSyscacheCallback
	movl	$1, -104(%rbp)
	movl	-52(%rbp), %eax
	movl	%eax, -80(%rbp)
	movq	%r12, -96(%rbp)
	movq	_LOGICALREP_PROTO_VERSION_NUM@GOTPCREL(%rip), %rax
	movl	(%rax), %eax
	movl	%eax, -84(%rbp)
	movq	(%r13), %rax
	movl	28(%rax), %eax
	movl	%eax, -88(%rbp)
	movq	_wrconn@GOTPCREL(%rip), %rax
	movq	(%rax), %rdi
	leaq	-104(%rbp), %rsi
	callq	_walrcv_startstreaming
	movl	-52(%rbp), %edi
	callq	_LogicalRepApplyLoop
	xorl	%edi, %edi
	callq	_proc_exit
	movq	___stack_chk_guard@GOTPCREL(%rip), %rax
	movq	(%rax), %rax
	cmpq	-48(%rbp), %rax
	jne	LBB0_18
## %bb.17:
	leaq	-40(%rbp), %rsp
	popq	%rbx
	popq	%r12
	popq	%r13
	popq	%r14
	popq	%r15
	popq	%rbp
	retq
LBB0_18:
	callq	___stack_chk_fail
	.cfi_endproc
                                        ## -- End function
	.comm	_NAMEDATALEN,4,2                ## @NAMEDATALEN
	.comm	_SIGHUP,4,2                     ## @SIGHUP
	.comm	_logicalrep_worker_sighup,4,2   ## @logicalrep_worker_sighup
	.comm	_SIGTERM,4,2                    ## @SIGTERM
	.comm	_die,4,2                        ## @die
	.comm	_MyLogicalRepWorker,8,3         ## @MyLogicalRepWorker
	.section	__TEXT,__cstring,cstring_literals
L_.str:                                 ## @.str
	.asciz	"libpqwalreceiver"

L_.str.1:                               ## @.str.1
	.asciz	"session_replication_role"

L_.str.2:                               ## @.str.2
	.asciz	"replica"

	.comm	_PGC_SUSET,4,2                  ## @PGC_SUSET
	.comm	_PGC_S_OVERRIDE,4,2             ## @PGC_S_OVERRIDE
	.comm	_TopMemoryContext,4,2           ## @TopMemoryContext
L_.str.3:                               ## @.str.3
	.asciz	"ApplyContext"

	.comm	_ALLOCSET_DEFAULT_SIZES,4,2     ## @ALLOCSET_DEFAULT_SIZES
	.comm	_ApplyContext,4,2               ## @ApplyContext
	.comm	_MySubscription,8,3             ## @MySubscription
	.comm	_LOG,4,2                        ## @LOG
L_.str.4:                               ## @.str.4
	.asciz	"logical replication apply worker for subscription %u will not start because the subscription was removed during startup"

	.comm	_MySubscriptionValid,4,2        ## @MySubscriptionValid
L_.str.5:                               ## @.str.5
	.asciz	"logical replication apply worker for subscription \"%s\" will not start because the subscription was disabled during startup"

L_.str.6:                               ## @.str.6
	.asciz	"synchronous_commit"

	.comm	_PGC_BACKEND,4,2                ## @PGC_BACKEND
	.comm	_SUBSCRIPTIONOID,4,2            ## @SUBSCRIPTIONOID
	.comm	_subscription_change_cb,4,2     ## @subscription_change_cb
L_.str.7:                               ## @.str.7
	.asciz	"logical replication table synchronization worker for subscription \"%s\", table \"%s\" has started"

L_.str.8:                               ## @.str.8
	.asciz	"logical replication apply worker for subscription \"%s\" has started"

	.comm	_DEBUG1,4,2                     ## @DEBUG1
L_.str.9:                               ## @.str.9
	.asciz	"connecting to publisher using connection string \"%s\""

	.comm	_ERROR,4,2                      ## @ERROR
L_.str.10:                              ## @.str.10
	.asciz	"subscription has no replication slot set"

L_.str.11:                              ## @.str.11
	.asciz	"pg_%u"

	.comm	_replorigin_session_origin,4,2  ## @replorigin_session_origin
	.comm	_wrconn,8,3                     ## @wrconn
L_.str.12:                              ## @.str.12
	.asciz	"could not connect to the publisher: %s"

	.comm	_SUBSCRIPTIONRELMAP,4,2         ## @SUBSCRIPTIONRELMAP
	.comm	_invalidate_syncing_table_states,4,2 ## @invalidate_syncing_table_states
	.comm	_LOGICALREP_PROTO_VERSION_NUM,4,2 ## @LOGICALREP_PROTO_VERSION_NUM
.subsections_via_symbols

	.section	__TEXT,__text,regular,pure_instructions
	.build_version macos, 13, 0	sdk_version 13, 3
	.globl	_ApplyWorkerMain                ; -- Begin function ApplyWorkerMain
	.p2align	2
_ApplyWorkerMain:                       ; @ApplyWorkerMain
	.cfi_startproc
; %bb.0:
	stp	x28, x27, [sp, #-96]!           ; 16-byte Folded Spill
	.cfi_def_cfa_offset 96
	stp	x26, x25, [sp, #16]             ; 16-byte Folded Spill
	stp	x24, x23, [sp, #32]             ; 16-byte Folded Spill
	stp	x22, x21, [sp, #48]             ; 16-byte Folded Spill
	stp	x20, x19, [sp, #64]             ; 16-byte Folded Spill
	stp	x29, x30, [sp, #80]             ; 16-byte Folded Spill
	add	x29, sp, #80
	.cfi_def_cfa w29, 16
	.cfi_offset w30, -8
	.cfi_offset w29, -16
	.cfi_offset w19, -24
	.cfi_offset w20, -32
	.cfi_offset w21, -40
	.cfi_offset w22, -48
	.cfi_offset w23, -56
	.cfi_offset w24, -64
	.cfi_offset w25, -72
	.cfi_offset w26, -80
	.cfi_offset w27, -88
	.cfi_offset w28, -96
	sub	sp, sp, #64
Lloh0:
	adrp	x8, ___stack_chk_guard@GOTPAGE
Lloh1:
	ldr	x8, [x8, ___stack_chk_guard@GOTPAGEOFF]
Lloh2:
	ldr	x8, [x8]
	stur	x8, [x29, #-88]
	bl	_DatumGetInt32
Lloh3:
	adrp	x8, _NAMEDATALEN@GOTPAGE
Lloh4:
	ldr	x8, [x8, _NAMEDATALEN@GOTPAGEOFF]
Lloh5:
	ldr	w20, [x8]
	mov	x9, x20
Lloh6:
	adrp	x16, ___chkstk_darwin@GOTPAGE
Lloh7:
	ldr	x16, [x16, ___chkstk_darwin@GOTPAGEOFF]
	blr	x16
	mov	x8, sp
	add	x9, x20, #15
	and	x9, x9, #0x1fffffff0
	sub	x19, x8, x9
	mov	sp, x19
	bl	_logicalrep_worker_attach
Lloh8:
	adrp	x8, _SIGHUP@GOTPAGE
Lloh9:
	ldr	x8, [x8, _SIGHUP@GOTPAGEOFF]
Lloh10:
	ldr	w0, [x8]
Lloh11:
	adrp	x8, _logicalrep_worker_sighup@GOTPAGE
Lloh12:
	ldr	x8, [x8, _logicalrep_worker_sighup@GOTPAGEOFF]
Lloh13:
	ldr	w1, [x8]
	bl	_pqsignal
Lloh14:
	adrp	x8, _SIGTERM@GOTPAGE
Lloh15:
	ldr	x8, [x8, _SIGTERM@GOTPAGEOFF]
Lloh16:
	ldr	w0, [x8]
Lloh17:
	adrp	x8, _die@GOTPAGE
Lloh18:
	ldr	x8, [x8, _die@GOTPAGEOFF]
Lloh19:
	ldr	w1, [x8]
	bl	_pqsignal
	bl	_BackgroundWorkerUnblockSignals
	bl	_GetCurrentTimestamp
Lloh20:
	adrp	x25, _MyLogicalRepWorker@GOTPAGE
Lloh21:
	ldr	x25, [x25, _MyLogicalRepWorker@GOTPAGEOFF]
	ldr	x8, [x25]
	stp	w0, w0, [x8, #20]
	str	w0, [x8, #28]
Lloh22:
	adrp	x0, l_.str@PAGE
Lloh23:
	add	x0, x0, l_.str@PAGEOFF
	mov	w1, #0
	bl	_load_file
Lloh24:
	adrp	x8, _PGC_SUSET@GOTPAGE
Lloh25:
	ldr	x8, [x8, _PGC_SUSET@GOTPAGEOFF]
Lloh26:
	ldr	w2, [x8]
Lloh27:
	adrp	x26, _PGC_S_OVERRIDE@GOTPAGE
Lloh28:
	ldr	x26, [x26, _PGC_S_OVERRIDE@GOTPAGEOFF]
	ldr	w3, [x26]
Lloh29:
	adrp	x0, l_.str.1@PAGE
Lloh30:
	add	x0, x0, l_.str.1@PAGEOFF
Lloh31:
	adrp	x1, l_.str.2@PAGE
Lloh32:
	add	x1, x1, l_.str.2@PAGEOFF
	bl	_SetConfigOption
	ldr	x8, [x25]
	ldp	w1, w0, [x8, #12]
	mov	w2, #0
	bl	_BackgroundWorkerInitializeConnectionByOid
Lloh33:
	adrp	x8, _TopMemoryContext@GOTPAGE
Lloh34:
	ldr	x8, [x8, _TopMemoryContext@GOTPAGEOFF]
Lloh35:
	ldr	w0, [x8]
Lloh36:
	adrp	x8, _ALLOCSET_DEFAULT_SIZES@GOTPAGE
Lloh37:
	ldr	x8, [x8, _ALLOCSET_DEFAULT_SIZES@GOTPAGEOFF]
Lloh38:
	ldr	w2, [x8]
Lloh39:
	adrp	x1, l_.str.3@PAGE
Lloh40:
	add	x1, x1, l_.str.3@PAGEOFF
	bl	_AllocSetContextCreate
Lloh41:
	adrp	x24, _ApplyContext@GOTPAGE
Lloh42:
	ldr	x24, [x24, _ApplyContext@GOTPAGEOFF]
	str	w0, [x24]
	bl	_StartTransactionCommand
	ldr	w0, [x24]
	bl	_MemoryContextSwitchTo
	mov	x21, x0
	ldr	x8, [x25]
	ldr	x0, [x8]
	mov	w28, #1
	mov	w1, #1
	bl	_GetSubscription
Lloh43:
	adrp	x23, _MySubscription@GOTPAGE
Lloh44:
	ldr	x23, [x23, _MySubscription@GOTPAGEOFF]
	str	x0, [x23]
Lloh45:
	adrp	x27, _LOG@GOTPAGE
Lloh46:
	ldr	x27, [x27, _LOG@GOTPAGEOFF]
	cbnz	x0, LBB0_2
; %bb.1:
	ldr	w22, [x27]
	ldr	x8, [x25]
	ldr	x8, [x8]
	str	x8, [sp, #-16]!
Lloh47:
	adrp	x0, l_.str.4@PAGE
Lloh48:
	add	x0, x0, l_.str.4@PAGEOFF
	bl	_errmsg
	add	sp, sp, #16
	mov	x1, x0
	mov	x0, x22
	bl	_ereport
	mov	w0, #0
	bl	_proc_exit
LBB0_2:
Lloh49:
	adrp	x8, _MySubscriptionValid@GOTPAGE
Lloh50:
	ldr	x8, [x8, _MySubscriptionValid@GOTPAGEOFF]
Lloh51:
	str	w28, [x8]
	mov	x0, x21
	bl	_MemoryContextSwitchTo
	ldr	x8, [x23]
	ldr	w9, [x8, #36]
	cbnz	w9, LBB0_4
; %bb.3:
	ldr	w21, [x27]
	ldr	x8, [x8]
	str	x8, [sp, #-16]!
Lloh52:
	adrp	x0, l_.str.5@PAGE
Lloh53:
	add	x0, x0, l_.str.5@PAGEOFF
	bl	_errmsg
	add	sp, sp, #16
	mov	x1, x0
	mov	x0, x21
	bl	_ereport
	mov	w0, #0
	bl	_proc_exit
	ldr	x8, [x23]
LBB0_4:
	ldr	x1, [x8, #8]
Lloh54:
	adrp	x8, _PGC_BACKEND@GOTPAGE
Lloh55:
	ldr	x8, [x8, _PGC_BACKEND@GOTPAGEOFF]
Lloh56:
	ldr	w2, [x8]
	ldr	w3, [x26]
Lloh57:
	adrp	x0, l_.str.6@PAGE
Lloh58:
	add	x0, x0, l_.str.6@PAGEOFF
	bl	_SetConfigOption
Lloh59:
	adrp	x8, _SUBSCRIPTIONOID@GOTPAGE
Lloh60:
	ldr	x8, [x8, _SUBSCRIPTIONOID@GOTPAGEOFF]
Lloh61:
	ldr	w0, [x8]
Lloh62:
	adrp	x8, _subscription_change_cb@GOTPAGE
Lloh63:
	ldr	x8, [x8, _subscription_change_cb@GOTPAGEOFF]
Lloh64:
	ldr	w1, [x8]
	mov	w2, #0
	bl	_CacheRegisterSyscacheCallback
	bl	_am_tablesync_worker
	ldr	w21, [x27]
	ldr	x8, [x23]
	ldr	x22, [x8]
	cbz	x0, LBB0_6
; %bb.5:
	ldr	x8, [x25]
	ldr	w0, [x8, #8]
	bl	_get_rel_name
                                        ; kill: def $w0 killed $w0 def $x0
	stp	x22, x0, [sp, #-16]!
Lloh65:
	adrp	x0, l_.str.7@PAGE
Lloh66:
	add	x0, x0, l_.str.7@PAGEOFF
	b	LBB0_7
LBB0_6:
	str	x22, [sp, #-16]!
Lloh67:
	adrp	x0, l_.str.8@PAGE
Lloh68:
	add	x0, x0, l_.str.8@PAGEOFF
LBB0_7:
	bl	_errmsg
	add	sp, sp, #16
	mov	x1, x0
	mov	x0, x21
	bl	_ereport
	bl	_CommitTransactionCommand
Lloh69:
	adrp	x8, _DEBUG1@GOTPAGE
Lloh70:
	ldr	x8, [x8, _DEBUG1@GOTPAGEOFF]
Lloh71:
	ldr	w0, [x8]
	ldr	x8, [x23]
	ldr	w2, [x8, #32]
Lloh72:
	adrp	x1, l_.str.9@PAGE
Lloh73:
	add	x1, x1, l_.str.9@PAGEOFF
	bl	_elog
	bl	_am_tablesync_worker
Lloh74:
	adrp	x25, _wrconn@GOTPAGE
Lloh75:
	ldr	x25, [x25, _wrconn@GOTPAGEOFF]
	cbz	x0, LBB0_9
; %bb.8:
	sub	x0, x29, #92
	bl	_LogicalRepSyncTableStart
	mov	x19, x0
	ldr	w0, [x24]
	bl	_MemoryContextSwitchTo
	mov	x20, x0
	mov	x0, x19
	bl	_pstrdup
	mov	x21, x0
	mov	x0, x20
	bl	_MemoryContextSwitchTo
	mov	x0, x19
	bl	_pfree
	b	LBB0_16
LBB0_9:
	ldr	x8, [x23]
	ldr	x21, [x8, #16]
	cbnz	x21, LBB0_11
; %bb.10:
Lloh76:
	adrp	x8, _ERROR@GOTPAGE
Lloh77:
	ldr	x8, [x8, _ERROR@GOTPAGEOFF]
Lloh78:
	ldr	w22, [x8]
Lloh79:
	adrp	x0, l_.str.10@PAGE
Lloh80:
	add	x0, x0, l_.str.10@PAGEOFF
	bl	_errmsg
	mov	x1, x0
	mov	x0, x22
	bl	_ereport
LBB0_11:
	bl	_StartTransactionCommand
	ldr	x8, [x23]
	ldr	w3, [x8, #24]
Lloh81:
	adrp	x2, l_.str.11@PAGE
Lloh82:
	add	x2, x2, l_.str.11@PAGEOFF
	mov	x0, x19
	mov	x1, x20
	bl	_snprintf
	mov	x0, x19
	mov	w1, #1
	bl	_replorigin_by_name
	mov	x20, x0
	bl	_OidIsValid
	cbnz	w0, LBB0_13
; %bb.12:
	mov	x0, x19
	bl	_replorigin_create
	mov	x20, x0
LBB0_13:
	mov	x0, x20
	bl	_replorigin_session_setup
Lloh83:
	adrp	x8, _replorigin_session_origin@GOTPAGE
Lloh84:
	ldr	x8, [x8, _replorigin_session_origin@GOTPAGEOFF]
Lloh85:
	str	w20, [x8]
	mov	w0, #0
	bl	_replorigin_session_get_progress
	stur	w0, [x29, #-92]
	bl	_CommitTransactionCommand
	ldr	x8, [x23]
	ldr	w0, [x8, #32]
	ldr	x2, [x8]
	sub	x3, x29, #128
	mov	w1, #1
	bl	_walrcv_connect
	str	x0, [x25]
	cbnz	x0, LBB0_15
; %bb.14:
Lloh86:
	adrp	x8, _ERROR@GOTPAGE
Lloh87:
	ldr	x8, [x8, _ERROR@GOTPAGEOFF]
Lloh88:
	ldr	w19, [x8]
	ldur	x8, [x29, #-128]
	str	x8, [sp, #-16]!
Lloh89:
	adrp	x0, l_.str.12@PAGE
Lloh90:
	add	x0, x0, l_.str.12@PAGEOFF
	bl	_errmsg
	add	sp, sp, #16
	mov	x1, x0
	mov	x0, x19
	bl	_ereport
	ldr	x0, [x25]
LBB0_15:
	sub	x1, x29, #132
	bl	_walrcv_identify_system
LBB0_16:
Lloh91:
	adrp	x8, _SUBSCRIPTIONRELMAP@GOTPAGE
Lloh92:
	ldr	x8, [x8, _SUBSCRIPTIONRELMAP@GOTPAGEOFF]
Lloh93:
	ldr	w0, [x8]
Lloh94:
	adrp	x8, _invalidate_syncing_table_states@GOTPAGE
Lloh95:
	ldr	x8, [x8, _invalidate_syncing_table_states@GOTPAGEOFF]
Lloh96:
	ldr	w1, [x8]
	mov	w2, #0
	bl	_CacheRegisterSyscacheCallback
	mov	w8, #1
	stur	w8, [x29, #-128]
	ldur	w8, [x29, #-92]
	stur	w8, [x29, #-104]
	stur	x21, [x29, #-120]
Lloh97:
	adrp	x8, _LOGICALREP_PROTO_VERSION_NUM@GOTPAGE
Lloh98:
	ldr	x8, [x8, _LOGICALREP_PROTO_VERSION_NUM@GOTPAGEOFF]
Lloh99:
	ldr	w8, [x8]
	ldr	x9, [x23]
	ldr	w9, [x9, #28]
	stp	w9, w8, [x29, #-112]
	ldr	x0, [x25]
	sub	x1, x29, #128
	bl	_walrcv_startstreaming
	ldur	w0, [x29, #-92]
	bl	_LogicalRepApplyLoop
	mov	w0, #0
	bl	_proc_exit
	ldur	x8, [x29, #-88]
Lloh100:
	adrp	x9, ___stack_chk_guard@GOTPAGE
Lloh101:
	ldr	x9, [x9, ___stack_chk_guard@GOTPAGEOFF]
Lloh102:
	ldr	x9, [x9]
	cmp	x9, x8
	b.ne	LBB0_18
; %bb.17:
	sub	sp, x29, #80
	ldp	x29, x30, [sp, #80]             ; 16-byte Folded Reload
	ldp	x20, x19, [sp, #64]             ; 16-byte Folded Reload
	ldp	x22, x21, [sp, #48]             ; 16-byte Folded Reload
	ldp	x24, x23, [sp, #32]             ; 16-byte Folded Reload
	ldp	x26, x25, [sp, #16]             ; 16-byte Folded Reload
	ldp	x28, x27, [sp], #96             ; 16-byte Folded Reload
	ret
LBB0_18:
	bl	___stack_chk_fail
	.loh AdrpLdrGot	Lloh45, Lloh46
	.loh AdrpLdrGot	Lloh43, Lloh44
	.loh AdrpLdrGot	Lloh41, Lloh42
	.loh AdrpAdd	Lloh39, Lloh40
	.loh AdrpLdrGotLdr	Lloh36, Lloh37, Lloh38
	.loh AdrpLdrGotLdr	Lloh33, Lloh34, Lloh35
	.loh AdrpAdd	Lloh31, Lloh32
	.loh AdrpAdd	Lloh29, Lloh30
	.loh AdrpLdrGot	Lloh27, Lloh28
	.loh AdrpLdrGotLdr	Lloh24, Lloh25, Lloh26
	.loh AdrpAdd	Lloh22, Lloh23
	.loh AdrpLdrGot	Lloh20, Lloh21
	.loh AdrpLdrGotLdr	Lloh17, Lloh18, Lloh19
	.loh AdrpLdrGotLdr	Lloh14, Lloh15, Lloh16
	.loh AdrpLdrGotLdr	Lloh11, Lloh12, Lloh13
	.loh AdrpLdrGotLdr	Lloh8, Lloh9, Lloh10
	.loh AdrpLdrGot	Lloh6, Lloh7
	.loh AdrpLdrGotLdr	Lloh3, Lloh4, Lloh5
	.loh AdrpLdrGotLdr	Lloh0, Lloh1, Lloh2
	.loh AdrpAdd	Lloh47, Lloh48
	.loh AdrpLdrGotStr	Lloh49, Lloh50, Lloh51
	.loh AdrpAdd	Lloh52, Lloh53
	.loh AdrpLdrGotLdr	Lloh62, Lloh63, Lloh64
	.loh AdrpLdrGotLdr	Lloh59, Lloh60, Lloh61
	.loh AdrpAdd	Lloh57, Lloh58
	.loh AdrpLdrGotLdr	Lloh54, Lloh55, Lloh56
	.loh AdrpAdd	Lloh65, Lloh66
	.loh AdrpAdd	Lloh67, Lloh68
	.loh AdrpLdrGot	Lloh74, Lloh75
	.loh AdrpAdd	Lloh72, Lloh73
	.loh AdrpLdrGotLdr	Lloh69, Lloh70, Lloh71
	.loh AdrpAdd	Lloh79, Lloh80
	.loh AdrpLdrGotLdr	Lloh76, Lloh77, Lloh78
	.loh AdrpAdd	Lloh81, Lloh82
	.loh AdrpLdrGotStr	Lloh83, Lloh84, Lloh85
	.loh AdrpAdd	Lloh89, Lloh90
	.loh AdrpLdrGotLdr	Lloh86, Lloh87, Lloh88
	.loh AdrpLdrGotLdr	Lloh100, Lloh101, Lloh102
	.loh AdrpLdrGotLdr	Lloh97, Lloh98, Lloh99
	.loh AdrpLdrGotLdr	Lloh94, Lloh95, Lloh96
	.loh AdrpLdrGotLdr	Lloh91, Lloh92, Lloh93
	.cfi_endproc
                                        ; -- End function
	.comm	_NAMEDATALEN,4,2                ; @NAMEDATALEN
	.comm	_SIGHUP,4,2                     ; @SIGHUP
	.comm	_logicalrep_worker_sighup,4,2   ; @logicalrep_worker_sighup
	.comm	_SIGTERM,4,2                    ; @SIGTERM
	.comm	_die,4,2                        ; @die
	.comm	_MyLogicalRepWorker,8,3         ; @MyLogicalRepWorker
	.section	__TEXT,__cstring,cstring_literals
l_.str:                                 ; @.str
	.asciz	"libpqwalreceiver"

l_.str.1:                               ; @.str.1
	.asciz	"session_replication_role"

l_.str.2:                               ; @.str.2
	.asciz	"replica"

	.comm	_PGC_SUSET,4,2                  ; @PGC_SUSET
	.comm	_PGC_S_OVERRIDE,4,2             ; @PGC_S_OVERRIDE
	.comm	_TopMemoryContext,4,2           ; @TopMemoryContext
l_.str.3:                               ; @.str.3
	.asciz	"ApplyContext"

	.comm	_ALLOCSET_DEFAULT_SIZES,4,2     ; @ALLOCSET_DEFAULT_SIZES
	.comm	_ApplyContext,4,2               ; @ApplyContext
	.comm	_MySubscription,8,3             ; @MySubscription
	.comm	_LOG,4,2                        ; @LOG
l_.str.4:                               ; @.str.4
	.asciz	"logical replication apply worker for subscription %u will not start because the subscription was removed during startup"

	.comm	_MySubscriptionValid,4,2        ; @MySubscriptionValid
l_.str.5:                               ; @.str.5
	.asciz	"logical replication apply worker for subscription \"%s\" will not start because the subscription was disabled during startup"

l_.str.6:                               ; @.str.6
	.asciz	"synchronous_commit"

	.comm	_PGC_BACKEND,4,2                ; @PGC_BACKEND
	.comm	_SUBSCRIPTIONOID,4,2            ; @SUBSCRIPTIONOID
	.comm	_subscription_change_cb,4,2     ; @subscription_change_cb
l_.str.7:                               ; @.str.7
	.asciz	"logical replication table synchronization worker for subscription \"%s\", table \"%s\" has started"

l_.str.8:                               ; @.str.8
	.asciz	"logical replication apply worker for subscription \"%s\" has started"

	.comm	_DEBUG1,4,2                     ; @DEBUG1
l_.str.9:                               ; @.str.9
	.asciz	"connecting to publisher using connection string \"%s\""

	.comm	_ERROR,4,2                      ; @ERROR
l_.str.10:                              ; @.str.10
	.asciz	"subscription has no replication slot set"

l_.str.11:                              ; @.str.11
	.asciz	"pg_%u"

	.comm	_replorigin_session_origin,4,2  ; @replorigin_session_origin
	.comm	_wrconn,8,3                     ; @wrconn
l_.str.12:                              ; @.str.12
	.asciz	"could not connect to the publisher: %s"

	.comm	_SUBSCRIPTIONRELMAP,4,2         ; @SUBSCRIPTIONRELMAP
	.comm	_invalidate_syncing_table_states,4,2 ; @invalidate_syncing_table_states
	.comm	_LOGICALREP_PROTO_VERSION_NUM,4,2 ; @LOGICALREP_PROTO_VERSION_NUM
.subsections_via_symbols
