Home
last modified time | relevance | path

Searched refs:key (Results 1 – 25 of 200) sorted by relevance

12345678

/thrift-3.4.0/contrib/fb303/java/src/
DFacebookBase.java53 public void deleteCounter(String key) { in deleteCounter() argument
54 counters_.remove(key); in deleteCounter()
57 public void resetCounter(String key) { in resetCounter() argument
58 counters_.put(key, 0L); in resetCounter()
61 public long incrementCounter(String key) { in incrementCounter() argument
62 long val = getCounter(key) + 1; in incrementCounter()
63 counters_.put(key, val); in incrementCounter()
67 public long incrementCounter(String key, long increment) { in incrementCounter() argument
68 long val = getCounter(key) + increment; in incrementCounter()
69 counters_.put(key, val); in incrementCounter()
[all …]
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/async/
DTAsyncMethodCall.java148 SelectionKey key; in start() local
151 key = transport.registerSelector(sel, SelectionKey.OP_WRITE); in start()
154 key = transport.registerSelector(sel, SelectionKey.OP_CONNECT); in start()
159 registerForFirstWrite(key); in start()
163 key.attach(this); in start()
166 void registerForFirstWrite(SelectionKey key) throws IOException { in registerForFirstWrite() argument
168 key.interestOps(SelectionKey.OP_WRITE); in registerForFirstWrite()
182 void transition(SelectionKey key) { in transition() argument
184 if (!key.isValid()) { in transition()
185 key.cancel(); in transition()
[all …]
/thrift-3.4.0/contrib/fb303/py/fb303/
DFacebookBase.py47 def resetCounter(self, key): argument
48 self.counters[key] = 0
50 def getCounter(self, key): argument
51 if self.counters.has_key(key):
52 return self.counters[key]
55 def incrementCounter(self, key): argument
56 self.counters[key] = self.getCounter(key) + 1
58 def setOption(self, key, value): argument
61 def getOption(self, key): argument
/thrift-3.4.0/test/crossrunner/
Dcollect.py86 def intersection(key, o1, o2): argument
89 def cached_set(o, key): argument
90 v = o[key]
93 o[key] = v
95 return cached_set(o1, key) & cached_set(o2, key)
97 def intersect_with_spec(key, o1, o2): argument
104 v = o[key]
107 o[key] = v
115 def maybe_max(key, o1, o2, default): argument
117 v1 = o1.get(key)
[all …]
/thrift-3.4.0/lib/go/thrift/
Dheader_context_test.go30 key = "foo"
35 ctx = SetHeader(ctx, key, value)
39 got, ok := GetHeader(ctx, key)
41 t.Fatalf("Cannot get header %q back after setting it.", key)
56 ctx = context.WithValue(ctx, otherType(key), otherValue)
75 ctx := UnsetHeader(ctx, key)
77 if _, ok := GetHeader(ctx, key); ok {
78 t.Errorf("GetHeader returned ok on unset key %q", key)
96 for _, key := range keys {
97 value, ok := GetHeader(ctx, key)
[all …]
Dheader_context.go39 func SetHeader(ctx context.Context, key, value string) context.Context { argument
42 headerKey(key),
48 func UnsetHeader(ctx context.Context, key string) context.Context {
51 headerKey(key),
57 func GetHeader(ctx context.Context, key string) (value string, ok bool) {
58 if v := ctx.Value(headerKey(key)); v != nil {
105 for key, value := range headers {
106 ctx = SetHeader(ctx, key, value)
107 keys = append(keys, key)
/thrift-3.4.0/tutorial/cl/
Dshared-implementation.lisp17 (defun shared.shared-service-implementation:get-struct (key)
18 (format t "getStruct(~a)~%" key)
19 (gethash key *structs*))
21 (defun add-log (key value)
22 (setf (gethash key *structs*)
24 :key key
/thrift-3.4.0/lib/haxe/src/org/apache/thrift/helper/
DInt64Map.hx53 private function GetLowMap( key : haxe.Int64, canCreate : Bool) : IntMap< T> {
55 return GetSubMap( Int64.getHigh(key), canCreate);
57 return GetSubMap( key.high, canCreate);
62 private function GetLowIndex( key : haxe.Int64) : haxe.Int32 {
64 return Int64.getLow(key);
66 return key.low;
71 private function NullCheck( key : haxe.Int64) : Bool {
73 return (key != null);
82 Maps `key` to `value`.
83 If `key` already has a mapping, the previous value disappears.
[all …]
/thrift-3.4.0/test/keys/keygen/
Dmake-serverkey.sh30 rm *.key 2> /dev/null
71 -keyout server.key \
82 cat server.crt server.key > server.pem
87 winpty openssl pkcs12 -export -clcerts -in server.crt -inkey server.key -out server.p12
91 winpty openssl genrsa -out client.key
99 -key client.key \
104 winpty openssl x509 -req -days 3000 -in client.csr -CA CA.pem -CAkey server.key -set_serial 01 -out…
109 winpty openssl pkcs12 -export -clcerts -in client.crt -inkey client.key -out client.p12
119 openssl genrsa -out client_v3.key
126 -key client_v3.key \
[all …]
/thrift-3.4.0/contrib/fb303/cpp/
DFacebookBase.cpp34 void FacebookBase::setOption(const std::string& key, const std::string& value) { in setOption() argument
36 options_[key] = value; in setOption()
39 void FacebookBase::getOption(std::string& _return, const std::string& key) { in getOption() argument
41 _return = options_[key]; in getOption()
49 int64_t FacebookBase::incrementCounter(const std::string& key, int64_t amount) { in incrementCounter() argument
53 ReadWriteCounterMap::iterator it = counters_.find(key); in incrementCounter()
58 it = counters_.find(key); in incrementCounter()
60 counters_[key].value = amount; in incrementCounter()
74 int64_t FacebookBase::setCounter(const std::string& key, int64_t value) { in setCounter() argument
78 ReadWriteCounterMap::iterator it = counters_.find(key); in setCounter()
[all …]
/thrift-3.4.0/test/keys/
DREADME.md14 we use the following parameters for test key and certificate creation
23 ### create self-signed server key and certificate
25 openssl req -new -x509 -nodes -days 3000 -out server.crt -keyout server.key
27 cat server.crt server.key > server.pem
31 openssl pkcs12 -export -clcerts -in server.crt -inkey server.key -out server.p12
33 ### create client key and certificate
35 openssl genrsa -out client.key
39 openssl req -new -key client.key -out client.csr
41 sign the client certificate with the server.key
43 …openssl x509 -req -days 3000 -in client.csr -CA CA.pem -CAkey server.key -set_serial 01 -out clien…
[all …]
/thrift-3.4.0/lib/swift/Sources/
DTMap.swift31 public func indexForKey(_ key: Key) -> Index? { in indexForKey()
32 return storage.index(forKey: key) in indexForKey()
35 public mutating func updateValue(_ value: Value, forKey key: Key) -> Value? { in updateValue()
36 return storage.updateValue(value, forKey: key) in updateValue()
39 public mutating func removeValueForKey(_ key: Key) -> Value? { in removeValueForKey()
40 return storage.removeValue(forKey: key) in removeValueForKey()
57 public subscript (key: Key) -> Value? {
59 return storage[key]
62 storage[key] = newValue
108 for (key, value) in elements {
[all …]
/thrift-3.4.0/lib/cl/READMES/
Dreadme-cassandra.lisp33 collect (loop for key being each hash-key of (cassandra:describe-keyspace *c* space)
35 collect (cons key
36 (loop for key being each hash-key of value
38 collect (cons key value)))))
52 (loop for key being each hash-key
55 collect (cons key
56 … (loop for key being each hash-key of value
58 … collect (cons key value))))))))
/thrift-3.4.0/test/c_glib/src/
Dthrift_test_handler.c248 gpointer key; in thrift_test_handler_test_map() local
258 &key, in thrift_test_handler_test_map()
268 printf ("%d => %d", *(gint32 *)key, *(gint32 *)value); in thrift_test_handler_test_map()
271 *new_key = *(gint32 *)key; in thrift_test_handler_test_map()
288 gpointer key; in thrift_test_handler_test_string_map() local
298 &key, in thrift_test_handler_test_string_map()
308 printf ("%s => %s", (gchar *)key, (gchar *)value); in thrift_test_handler_test_string_map()
310 new_key = g_strdup ((gchar *)key); in thrift_test_handler_test_string_map()
326 gpointer key; in thrift_test_handler_test_set() local
335 &key, in thrift_test_handler_test_set()
[all …]
/thrift-3.4.0/compiler/cpp/src/thrift/generate/
Dgo_validator_generator.cc144 std::string key = (*it)->get_name(); in generate_enum_field_validator() local
146 if (key == "vt.in") { in generate_enum_field_validator()
198 } else if (key == "vt.not_in") { in generate_enum_field_validator()
240 } else if (key == "vt.defined_only") { in generate_enum_field_validator()
249 << "return thrift.NewValidationException(thrift.VALIDATION_FAILED, \"" + key + "\", \"" in generate_enum_field_validator()
250 << context.field_symbol << "\", \"" << context.field_symbol << " not valid, rule " << key in generate_enum_field_validator()
265 std::string key = (*it)->get_name(); in generate_bool_field_validator() local
267 if (key == "vt.const") { in generate_bool_field_validator()
282 << "return thrift.NewValidationException(thrift.VALIDATION_FAILED, \"" + key + "\", \"" in generate_bool_field_validator()
283 << context.field_symbol << "\", \"" << context.field_symbol << " not valid, rule " << key in generate_bool_field_validator()
[all …]
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/server/
DTNonblockingServer.java175 SelectionKey key = selectedKeys.next(); in select() local
179 if (!key.isValid()) { in select()
180 cleanupSelectionKey(key); in select()
186 if (key.isAcceptable()) { in select()
188 } else if (key.isReadable()) { in select()
190 handleRead(key); in select()
191 } else if (key.isWritable()) { in select()
193 handleWrite(key); in select()
195 LOGGER.warn("Unexpected state in select! " + key.interestOps()); in select()
DTThreadedSelectorServer.java397 SelectionKey key = selectedKeys.next(); in select() local
401 if (!key.isValid()) { in select()
405 if (key.isAcceptable()) { in select()
408 LOGGER.warn("Unexpected state in select! " + key.interestOps()); in select()
557 SelectionKey key = selectedKeys.next(); in select() local
561 if (!key.isValid()) { in select()
562 cleanupSelectionKey(key); in select()
566 if (key.isReadable()) { in select()
568 handleRead(key); in select()
569 } else if (key.isWritable()) { in select()
[all …]
/thrift-3.4.0/lib/js/test/
Dphantom-client.js54 for (var key in opts) {
55 keys['--' + key + '='] = key;
106 for (var key in map1) {
107 checkRecursively(map1[key], map2[key]);
219 for (var key in mapTestOutput) {
220 equal(mapTestOutput[key], mapTestInput[key]);
232 for (var key in mapTestOutput) {
233 equal(mapTestOutput[key], mapTestInput[key]);
303 for (var key in mapMapTestOutput) {
304 for (var key2 in mapMapTestOutput[key]) {
[all …]
Dtest-async.js40 for (let key in map1) {
41 checkRecursively(assert, map1[key], map2[key]);
206 for (let key in result) {
207 assert.equal(result[key], mapTestInput[key]);
222 for (let key in result) {
223 assert.equal(result[key], mapTestInput[key]);
279 for (let key in result) {
280 for (let key2 in result[key]) {
281 assert.equal(result[key][key2], mapMapTestExpectedResult[key][key2]);
/thrift-3.4.0/lib/ts/test/
Dphantom-client.ts62 for (var key in opts) {
63 keys['--' + key + '='] = key;
114 for (var key in map1) { variable
115 checkRecursively(map1[key], map2[key]);
227 for (var key in mapTestOutput) { variable
228 equal(mapTestOutput[key], mapTestInput[key]);
240 for (var key in mapTestOutput) { variable
241 equal(mapTestOutput[key], mapTestInput[key]);
272 for (var key in mapMapTestOutput) { variable
273 for (var key2 in mapMapTestOutput[key]) { variable
[all …]
/thrift-3.4.0/lib/nodejs/lib/thrift/
Dheader_transport.js132 var validateHeaders = function(key, value) { argument
133 if (typeof key !== 'string' || typeof value !== 'string') {
163 THeaderTransport.prototype.setReadHeader = function(key, value) { argument
164 validateHeaders(key, value);
165 this.rheaders[key] = value;
176 THeaderTransport.prototype.setWriteHeader = function(key, value) { argument
177 validateHeaders(key, value);
178 this.wheaders[key] = value;
267 var key = varintHelper.readString();
269 this.setReadHeader(key, value);
[all …]
/thrift-3.4.0/lib/php/src/
DThrift.php117 $key = $val = null;
119 $xfer += $input->$kread($key);
124 $key = new $class();
125 $xfer += $key->read($input);
128 $xfer += $this->_readMap($key, $kspec, $input);
131 $xfer += $this->_readList($key, $kspec, $input, false);
134 $xfer += $this->_readList($key, $kspec, $input, true);
158 $var[$key] = $val;
288 foreach ($var as $key => $val) {
290 $xfer += $output->$kwrite($key);
[all …]
/thrift-3.4.0/lib/php/lib/Base/
DTBase.php87 $key = $val = null;
89 $xfer += $input->$kread($key);
94 $key = new $class();
95 $xfer += $key->read($input);
98 $xfer += $this->_readMap($key, $kspec, $input);
101 $xfer += $this->_readList($key, $kspec, $input, false);
104 $xfer += $this->_readList($key, $kspec, $input, true);
128 $var[$key] = $val;
258 foreach ($var as $key => $val) {
260 $xfer += $output->$kwrite($key);
[all …]
/thrift-3.4.0/lib/php/lib/Exception/
DTException.php89 $key = $val = null;
91 $xfer += $input->$kread($key);
96 $key = new $class();
97 $xfer += $key->read($input);
100 $xfer += $this->_readMap($key, $kspec, $input);
103 $xfer += $this->_readList($key, $kspec, $input, false);
106 $xfer += $this->_readList($key, $kspec, $input, true);
130 $var[$key] = $val;
260 foreach ($var as $key => $val) {
262 $xfer += $output->$kwrite($key);
[all …]
/thrift-3.4.0/contrib/fb303/php/
DFacebookBase.php52 public function getCounter($key) { argument
56 public function setOption($key, $value) { argument
60 public function getOption($key) { argument

12345678