Lines Matching refs:MySubscription

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