Home
last modified time | relevance | path

Searched refs:storeId (Results 1 – 25 of 71) sorted by relevance

123

/dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/
H A DStateStore.scala171 storeId: StateStoreId,
181 storeId,
183 reportActiveStoreInstance(storeId)
190 def unload(storeId: StateStoreId): Unit = loadedProviders.synchronized {
191 loadedProviders.remove(storeId)
195 def isLoaded(storeId: StateStoreId): Boolean = loadedProviders.synchronized {
196 loadedProviders.contains(storeId)
254 private def reportActiveStoreInstance(storeId: StateStoreId): Unit = {
258 coordinatorRef.foreach(_.reportActiveInstance(storeId, host, executorId))
259 logDebug(s"Reported that the loaded instance $storeId is active")
[all …]
H A DStateStoreCoordinator.scala32 private case class ReportActiveInstance(storeId: StateStoreId, host: String, executorId: String)
35 private case class VerifyIfInstanceActive(storeId: StateStoreId, executorId: String)
38 private case class GetLocation(storeId: StateStoreId)
83 storeId: StateStoreId,
86 rpcEndpointRef.send(ReportActiveInstance(storeId, host, executorId))
90 private[state] def verifyIfInstanceActive(storeId: StateStoreId, executorId: String): Boolean = {
91 rpcEndpointRef.askWithRetry[Boolean](VerifyIfInstanceActive(storeId, executorId))
95 private[state] def getLocation(storeId: StateStoreId): Option[String] = {
96 rpcEndpointRef.askWithRetry[Option[String]](GetLocation(storeId))
H A DStateStoreRDD.scala54 val storeId = StateStoreId(checkpointLocation, operatorId, partition.index) constant
55 storeCoordinator.flatMap(_.getLocation(storeId)).toSeq
60 val storeId = StateStoreId(checkpointLocation, operatorId, partition.index) constant
62 storeId, keySchema, valueSchema, storeVersion, storeConf, confBroadcast.value.value)
/dports/www/py-protego/Protego-0.1.16/tests/test_data/
H A Dwww.thenorthface.com19 Disallow: /*storeId=201*
20 Noindex: /*storeId=201*
21 Disallow: /*storeId=202*
22 Noindex: /*storeId=202*
23 Disallow: /*storeId=212*
24 Noindex: /*storeId=212*
25 Disallow: /*storeId=208*
26 Noindex: /*storeId=208*
27 Disallow: /*storeId=216*
28 Noindex: /*storeId=216*
H A Dwww.dunelm.com14 Disallow: /*storeId=*
38 Disallow: /*storeId=*
60 Disallow: /*storeId=*
/dports/devel/spark/spark-2.1.1/sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/state/
H A DStateStoreSuite.scala340 val storeId = StateStoreId(dir, 0, 0) constant
365 StateStore.unload(storeId)
366 assert(!StateStore.isLoaded(storeId))
369 assert(StateStore.isLoaded(storeId))
387 val storeId = StateStoreId(dir, opId, 0) constant
444 assert(!StateStore.isLoaded(storeId))
449 assert(StateStore.isLoaded(storeId))
459 assert(StateStore.isLoaded(storeId))
466 assert(!StateStore.isLoaded(storeId))
486 val storeId = StateStoreId(dir, 0, 0) constant
[all …]
/dports/devel/qca/qca-2.3.4/src/
H A Dqca_keystore.cpp104 QString storeId; member in QCA::KeyStoreTracker::Item
277 if (i.storeId == storeId) { in entry()
473 i.storeId = c->storeId(id); in updateStores()
775 const QString storeId = this->storeId(); in ensureAvailable() local
828 ksm_available(storeId); in start()
835 if (_storeId == storeId) { in ksm_available()
882 d->storeId = e.storeId(); in KeyStoreEntryWatcher()
1173 return d->item.storeId; in id()
1406 if (i->storeId == storeId) in getItem()
1483 here += i.storeId; in do_update()
[all …]
H A Dqca_default.cpp916 static QString entry_serialize(const QString &storeId, in entry_serialize() argument
925 out += storeId; in entry_serialize()
935 QString * storeId, in entry_deserialize() argument
949 *storeId = list[1]; in entry_deserialize()
972 _storeId = storeId; in DefaultKeyStoreEntry()
981 _storeId = storeId; in DefaultKeyStoreEntry()
1006 QString storeId() const override in storeId() function in QCA::DefaultKeyStoreEntry
1048 QString storeId, storeName, id, name, typestr, datastr; in deserialize() local
1058 c = new DefaultKeyStoreEntry(cert, storeId, storeName, provider); in deserialize()
1063 c = new DefaultKeyStoreEntry(crl, storeId, storeName, provider); in deserialize()
[all …]
/dports/www/orangehrm/orangehrm-4.9/symfony/lib/vendor/google/apiclient-services/src/Google/Service/Doubleclicksearch/
H A DConversion.php54 public $storeId; variable in Google_Service_Doubleclicksearch_Conversion
317 public function setStoreId($storeId) argument
319 $this->storeId = $storeId;
323 return $this->storeId;
/dports/www/owncloud/owncloud/apps/files_external/3rdparty/google/apiclient-services/src/Google/Service/Doubleclicksearch/
H A DConversion.php54 public $storeId; variable in Google_Service_Doubleclicksearch_Conversion
317 public function setStoreId($storeId) argument
319 $this->storeId = $storeId;
323 return $this->storeId;
/dports/devel/qca/qca-2.3.4/plugins/qca-test/
H A Dqca-test.cpp105 QString storeId; member in TestKeyStore
211 KeyStoreInfo info(store->type, store->storeId, store->name); in endSign()
492 virtual QString storeId() const in storeId() function in TestKeyStoreEntryContext
529 kse->_storeId = store->storeId; in make_entry()
570 ks1.storeId = "store1"; in TestKeyStoreListContext()
577 ks2.storeId = "store2"; in TestKeyStoreListContext()
632 virtual QString storeId(int id) const in storeId() function in TestKeyStoreListContext
637 return data.stores[at].storeId; in storeId()
675 kse->_storeId = store.storeId; in entryList()
691 kse->_storeId = store.storeId; in entryPassive()
/dports/www/squid/squid-4.15/src/repl/heap/
H A Dstore_heap_replacement.cc69 debugs(81, 3, "storeId=" << e->mem_obj->storeId()); in HeapKeyGen_StoreEntry_LFUDA()
107 debugs(81, 3, "storeId=" << e->mem_obj->storeId()); in HeapKeyGen_StoreEntry_GDSF()
128 debugs(81, 3, "storeId=" << e->mem_obj->storeId()); in HeapKeyGen_StoreEntry_LRU()
/dports/games/manaplus/manaplus-2.1.3.17/src/gui/windows/
H A Dbuyingstoreselldialog.cpp43 const int storeId) : in BuyingStoreSellDialog() argument
46 mStoreId(storeId) in BuyingStoreSellDialog()
/dports/games/manaplus/manaplus-2.1.3.17/src/net/eathena/
H A Dsearchstorehandler.cpp79 const int storeId, in select() argument
86 outMsg.writeInt32(storeId, "store id"); in select()
H A Dbuyingstorehandler.cpp94 const int storeId, in sell() argument
106 outMsg.writeInt32(storeId, "store id"); in sell()
H A Dbuyingstorerecv.cpp134 const int storeId = msg.readInt32("store id"); in processBuyingStoreItemsList() local
144 storeId); in processBuyingStoreItemsList()
/dports/devel/qca/qca-2.3.4/plugins/qca-pkcs11/
H A Dqca-pkcs11.cpp208 QString storeId(int id) const override;
928 _storeId = storeId; in pkcs11KeyStoreEntryContext()
994 QString storeId() const override in storeId() function in pkcs11QCAPlugin::pkcs11KeyStoreEntryContext
1436 QString storeId, storeName; in _tokenPrompt() local
1447 storeId = context->storeId(); in _tokenPrompt()
1452 storeId = _tokenId2storeId(token_id); in _tokenPrompt()
1473 QString storeId, storeName; in _pinPrompt() local
1486 storeId = context->storeId(); in _pinPrompt()
1491 storeId = _tokenId2storeId(token_id); in _pinPrompt()
1658 QString storeId; in _tokenId2storeId() local
[all …]
/dports/www/groupoffice/groupoffice-6.4.231-php-71/modules/googledrive/google-api-php-client/src/contrib/
H A DGoogle_ShoppingService.php594 public $storeId; variable in Google_ProductsStores
616 public function setStoreId($storeId) { argument
617 $this->storeId = $storeId;
620 return $this->storeId;
1166 public $storeId; variable in Google_ShoppingModelProductJsonV1Inventories
1201 public function setStoreId($storeId) { argument
1202 $this->storeId = $storeId;
1205 return $this->storeId;
/dports/devel/qca/qca-2.3.4/plugins/qca-gnupg/
H A Dmymessagecontext.cpp247 … KeyStoreInfo(KeyStore::PGPKeyring, keyStoreList->storeId(0), keyStoreList->name(0)), in waitForFinished()
259 …tokenAsker.ask(KeyStoreInfo(KeyStore::PGPKeyring, keyStoreList->storeId(0), keyStoreList->name(0)), in waitForFinished()
375 KeyStoreInfo(KeyStore::PGPKeyring, keyStoreList->storeId(0), keyStoreList->name(0)), in gpg_needPassphrase()
384 …KeyStoreInfo(KeyStore::PGPKeyring, keyStoreList->storeId(0), keyStoreList->name(0)), KeyStoreEntry… in gpg_needCard()
H A Dmykeystorelist.cpp68 QString MyKeyStoreList::storeId(int) const in storeId() function in gpgQCAPlugin::MyKeyStoreList
126 c->_storeId = storeId(0); in entryList()
146 c->_storeId = storeId(0); in entry()
173 c->_storeId = storeId(0); in entryPassive()
/dports/security/xmlsec1/xmlsec1-1.2.29/include/xmlsec/
H A Dkeysmngr.h135 #define xmlSecKeyStoreCheckId(store, storeId) \ argument
137 ((( store )->id) == ( storeId )))
/dports/www/squid/squid-4.15/src/tests/
H A DtestRock.cc177 storeId(const int i) in storeId() function
191 storeCreateEntry(storeId(i), "dummy log url", flags, Http::METHOD_GET); in createEntry()
218 return storeGetPublic(storeId(i), Http::METHOD_GET); in getEntry()
/dports/www/squid/squid-4.15/src/
H A DMemObject.h95 const char *urlXXX() const { return storeId(); } in urlXXX()
99 const char *storeId() const;
H A DStore.h140 void createMemObject(const char *storeId, const char *logUri, const HttpRequestMethod &aMethod);
143 void ensureMemObject(const char *storeId, const char *logUri, const HttpRequestMethod &aMethod);
431 StoreEntry *storeCreatePureEntry(const char *storeId, const char *logUrl, const HttpRequestMethod&);
/dports/devel/qca/qca-2.3.4/plugins/qca-softstore/
H A Dqca-softstore.cpp273 QString storeId, storeName; in _ensureAccess() local
282 storeId = context->storeId(); in _ensureAccess()
301 … asker.ask(KeyStoreInfo(KeyStore::SmartCard, storeId, storeName), entry, context); in _ensureAccess()
312 …asker.ask(Event::StylePassphrase, KeyStoreInfo(KeyStore::User, storeId, storeName), entry, context… in _ensureAccess()
570 QString storeId() const override in storeId() function in softstoreQCAPlugin::softstoreKeyStoreEntryContext
695 QString storeId(int id) const override in storeId() function in softstoreQCAPlugin::softstoreKeyStoreListContext

123