/dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/ |
H A D | StateStore.scala | 171 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 D | StateStoreCoordinator.scala | 32 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 D | StateStoreRDD.scala | 54 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 D | www.thenorthface.com | 19 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 D | www.dunelm.com | 14 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 D | StateStoreSuite.scala | 340 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 D | qca_keystore.cpp | 104 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 D | qca_default.cpp | 916 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 D | Conversion.php | 54 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 D | Conversion.php | 54 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 D | qca-test.cpp | 105 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 D | store_heap_replacement.cc | 69 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 D | buyingstoreselldialog.cpp | 43 const int storeId) : in BuyingStoreSellDialog() argument 46 mStoreId(storeId) in BuyingStoreSellDialog()
|
/dports/games/manaplus/manaplus-2.1.3.17/src/net/eathena/ |
H A D | searchstorehandler.cpp | 79 const int storeId, in select() argument 86 outMsg.writeInt32(storeId, "store id"); in select()
|
H A D | buyingstorehandler.cpp | 94 const int storeId, in sell() argument 106 outMsg.writeInt32(storeId, "store id"); in sell()
|
H A D | buyingstorerecv.cpp | 134 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 D | qca-pkcs11.cpp | 208 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 D | Google_ShoppingService.php | 594 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 D | mymessagecontext.cpp | 247 … 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 D | mykeystorelist.cpp | 68 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 D | keysmngr.h | 135 #define xmlSecKeyStoreCheckId(store, storeId) \ argument 137 ((( store )->id) == ( storeId )))
|
/dports/www/squid/squid-4.15/src/tests/ |
H A D | testRock.cc | 177 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 D | MemObject.h | 95 const char *urlXXX() const { return storeId(); } in urlXXX() 99 const char *storeId() const;
|
H A D | Store.h | 140 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 D | qca-softstore.cpp | 273 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
|