116 Subscription *MySubscription = NULL;  variable
1493 						MySubscription->name)));  in maybe_reread_subscription()
1507 						MySubscription->name)));  in maybe_reread_subscription()
1516 	if (strcmp(newsub->conninfo, MySubscription->conninfo) != 0)  in maybe_reread_subscription()
1521 						MySubscription->name)));  in maybe_reread_subscription()
1530 	if (strcmp(newsub->name, MySubscription->name) != 0)  in maybe_reread_subscription()
1535 						MySubscription->name)));  in maybe_reread_subscription()
1547 	if (strcmp(newsub->slotname, MySubscription->slotname) != 0)  in maybe_reread_subscription()
1552 						MySubscription->name)));  in maybe_reread_subscription()
1561 	if (!equal(newsub->publications, MySubscription->publications))  in maybe_reread_subscription()
1566 						MySubscription->name)));  in maybe_reread_subscription()
1572 	if (newsub->dbid != MySubscription->dbid)  in maybe_reread_subscription()
1579 	FreeSubscription(MySubscription);  in maybe_reread_subscription()
1580 	MySubscription = newsub;  in maybe_reread_subscription()
1585 	SetConfigOption("synchronous_commit", MySubscription->synccommit,  in maybe_reread_subscription()
1669 	MySubscription = GetSubscription(MyLogicalRepWorker->subid, true);  in ApplyWorkerMain()
1670 	if (!MySubscription)  in ApplyWorkerMain()
1682 	if (!MySubscription->enabled)  in ApplyWorkerMain()
1687 						MySubscription->name)));  in ApplyWorkerMain()
1693 	SetConfigOption("synchronous_commit", MySubscription->synccommit,  in ApplyWorkerMain()
1704 						MySubscription->name, get_rel_name(MyLogicalRepWorker->relid))));  in ApplyWorkerMain()
1708 						MySubscription->name)));  in ApplyWorkerMain()
1714 		 MySubscription->conninfo);  in ApplyWorkerMain()
1738 		myslotname = MySubscription->slotname;  in ApplyWorkerMain()
1751 		snprintf(originname, sizeof(originname), "pg_%u", MySubscription->oid);  in ApplyWorkerMain()
1760 		LogRepWorkerWalRcvConn = walrcv_connect(MySubscription->conninfo, true,  in ApplyWorkerMain()
1761 												MySubscription->name, &err);  in ApplyWorkerMain()
1787 	options.proto.logical.publication_names = MySubscription->publications;  in ApplyWorkerMain()