Home
last modified time | relevance | path

Searched refs:whisper (Results 1 – 25 of 1277) sorted by relevance

12345678910>>...52

/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/whisper/whisperv6/
H A Dwhisper.go110 whisper := &Whisper{
123 whisper.filters = NewFilters(whisper)
145 return whisper
448 whisper.keyMu.Lock()
465 whisper.keyMu.Lock()
485 whisper.keyMu.Lock()
501 whisper.keyMu.Lock()
725 go whisper.update()
738 close(whisper.quit)
797 cached, err := whisper.add(env, whisper.LightClientMode())
[all …]
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/_assets/patches/
H A D0037-whisper-metrics.patch1 diff --git a/whisper/whisperv6/metrics.go b/whisper/whisperv6/metrics.go
5 +++ b/whisper/whisperv6/metrics.go
23 diff --git a/whisper/whisperv6/whisper.go b/whisper/whisperv6/whisper.go
25 --- a/whisper/whisperv6/whisper.go
26 +++ b/whisper/whisperv6/whisper.go
28 now := uint32(whisper.timeSource().Unix())
78 whisper.statsMu.Lock()
79 whisper.stats.memoryUsed += envelope.size()
80 whisper.statsMu.Unlock()
84 delete(whisper.envelopes, v.(common.Hash))
[all …]
H A D0014-whisperv6-notifications.patch1 diff --git i/whisper/whisperv6/api.go w/whisper/whisperv6/api.go
3 --- i/whisper/whisperv6/api.go
4 +++ w/whisper/whisperv6/api.go
22 diff --git i/whisper/whisperv6/whisper.go w/whisper/whisperv6/whisper.go
24 --- i/whisper/whisperv6/whisper.go
25 +++ w/whisper/whisperv6/whisper.go
37 whisper.keyMu.Lock()
47 whisper.keyMu.Lock()
71 whisper.keyMu.Lock()
87 + whisper.keyMu.Lock()
[all …]
H A D0027-whisper-time-source.patch1 diff --git a/whisper/whisperv6/api.go b/whisper/whisperv6/api.go
3 --- a/whisper/whisperv6/api.go
4 +++ b/whisper/whisperv6/api.go
14 diff --git a/whisper/whisperv6/config.go b/whisper/whisperv6/config.go
39 diff --git a/whisper/whisperv6/envelope.go b/whisper/whisperv6/envelope.go
55 diff --git a/whisper/whisperv6/message.go b/whisper/whisperv6/message.go
85 diff --git a/whisper/whisperv6/whisper.go b/whisper/whisperv6/whisper.go
87 --- a/whisper/whisperv6/whisper.go
88 +++ b/whisper/whisperv6/whisper.go
105 whisper.filters = NewFilters(whisper)
[all …]
H A D0025-whisper-confirmations.patch1 diff --git a/whisper/whisperv6/events.go b/whisper/whisperv6/events.go
5 +++ b/whisper/whisperv6/events.go
30 diff --git a/whisper/whisperv6/peer.go b/whisper/whisperv6/peer.go
32 --- a/whisper/whisperv6/peer.go
33 +++ b/whisper/whisperv6/peer.go
46 diff --git a/whisper/whisperv6/whisper.go b/whisper/whisperv6/whisper.go
48 --- a/whisper/whisperv6/whisper.go
49 +++ b/whisper/whisperv6/whisper.go
67 return whisper
87 whisper.stats.messagesCleared++
[all …]
H A D0033-mailserver-response-contains-cursor.patch1 diff --git a/whisper/whisperv6/events.go b/whisper/whisperv6/events.go
3 --- a/whisper/whisperv6/events.go
4 +++ b/whisper/whisperv6/events.go
26 diff --git a/whisper/whisperv6/whisper.go b/whisper/whisperv6/whisper.go
28 --- a/whisper/whisperv6/whisper.go
29 +++ b/whisper/whisperv6/whisper.go
108 if whisper.mailServer != nil {
109 whisper.mailServer.Archive(envelope)
119 case e = <-whisper.messageQueue:
126 case e = <-whisper.p2pMsgQueue:
[all …]
H A D0032-send-mailserver-request-completed-code.patch1 diff --git a/whisper/whisperv6/doc.go b/whisper/whisperv6/doc.go
3 --- a/whisper/whisperv6/doc.go
4 +++ b/whisper/whisperv6/doc.go
27 diff --git a/whisper/whisperv6/events.go b/whisper/whisperv6/events.go
29 --- a/whisper/whisperv6/events.go
30 +++ b/whisper/whisperv6/events.go
68 diff --git a/whisper/whisperv6/whisper.go b/whisper/whisperv6/whisper.go
70 --- a/whisper/whisperv6/whisper.go
71 +++ b/whisper/whisperv6/whisper.go
87 p, err := whisper.getPeer(peerID)
[all …]
/dports/net/viamillipede/viamillipede-0.7/
H A Drx.c19 whisper ( 7, "rxw:%02i accepting and locked\n", rxworker->id); in rxworker()
26 { whisper ( 13, "rxw:%02d checkphrase ok\n", rxworker->id); } in rxworker()
32 whisper ( 18, "rxw:%02i send ok\n", rxworker->id ); in rxworker()
34 whisper( 1, "write fail " ); in rxworker()
96 whisper( (errno != 0)?3:19 , "rx%02i %lu[%i]-[%i]\t%c", in rxworker()
161 whisper( 5, "rxw:%02i exiting work restartme block\n", rxworker->id); in rxworker()
163 whisper( 4, "rxw:%02i done\n", rxworker->id); in rxworker()
172 whisper ( 1, "rx: tcp prep failed. this is unfortunate. " ); in rxlaunchworkers()
185 whisper ( 18, "rxw:%02i threadlaunched\n", worker_cursor); in rxlaunchworkers()
190 whisper( 7, "rx: worker group launched\n"); in rxlaunchworkers()
[all …]
H A Dtx.c79 whisper ( 4, "txingest no more stdin, send shutdown"); in txingest()
134 whisper ( 7, "rxw:%02i is dead\n", txworker->id); in txpush()
144 whisper ( 5, "tx: chosen target %s %d\n", in tx_tcp_connect_next()
207 whisper ( 18, "txw:%i expect ok \n", txworker->id); in tx_start_net()
292 whisper ( 8, "txw:%02i worker done", txworker->id); in txworker_sm()
305 whisper( 16, "txw:%i launching ", worker_cursor); in txlaunchworkers()
329 whisper ( log_level, "\nstate:leg-remainder(k)\n"); in txstatus()
332 whisper(log_level, "%c:%lu-%i\t", in txstatus()
338 whisper ( log_level, "\n"); in txstatus()
369 whisper ( 1 , "\n" ); in wat()
[all …]
H A Dplumbing.c11 whisper (1, "chaos inserted"); in chaos_fail()
30 whisper (3, "ignoring sig %i\n", errno); in bufferfill()
46 whisper (2, "negative read"); in bufferfill()
87 …if ( whisper_channel > 0 ) { whisper ( whisper_channel, "%li.%03li", secondsdiff, nanoes/1000000);… in stopwatch_stop()
108 whisper ( 1, "tx: connect failed to %s:%d fd: %i \n", host, port, ret_sockfd); in tcp_connect()
111 whisper ( 19, "trashing fd to fail %s:%d fd: %i \n", host, port, ret_sockfd); in tcp_connect()
118 whisper (8, " connected to %s:%i\n", host, port); in tcp_connect()
130 whisper (7, "bind sockid: %i\n",*socknum); in tcp_recieve_prep()
135 whisper (9, " listen sockid: %i\n",*socknum); in tcp_recieve_prep()
144 whisper (17, " accept sockid: %i\n",socknum); in tcp_accept()
[all …]
H A Dviamillipede.c33 whisper (30, " arg: %d, %s\n", arg_cursor , argv[arg_cursor]); in main()
42 whisper (3," being a server at port %i \n\n ", rxconf.port); in main()
60 whisper ( 2, "tx host: %s port:%i \n", in main()
78 whisper ( 5, "verbose set to %i\n", gverbose ); in main()
84 whisper ( 11, "checksum set to %lu", gchaos ); in main()
91 whisper ( 11, "chaos set to %lu", gchaos ); in main()
96 whisper ( 11, "checkphrase set to %s", gcheckphrase ); in main()
/dports/databases/py-whisper/whisper-1.1.3/bin/
H A Dwhisper-dump.py12 import whisper
47 = struct.unpack(whisper.metadataFormat, map[:whisper.metadataSize])
49 raise whisper.CorruptWhisperFile("Unable to unpack header")
52 archiveOffset = whisper.metadataSize
57 whisper.archiveInfoFormat,
58 map[archiveOffset:archiveOffset + whisper.archiveInfoSize]
68 'size': points * whisper.pointSize,
71 archiveOffset += whisper.archiveInfoSize
108 whisper.pointFormat,
109 map[offset:offset + whisper.pointSize]
[all …]
H A Dwhisper-fill.py18 import whisper
21 from whisper import operator
55 srcHeader = whisper.info(src)
79 (timeInfo, values) = whisper.fetch(src, fromTime, untilTime)
86 whisper.update_many(dst, pointsToWrite)
96 header = whisper.info(dst)
105 (timeInfo, values) = whisper.fetch(dst, fromTime, startFrom)
137 if options.lock is True and whisper.CAN_LOCK:
138 whisper.LOCK = True
H A Dwhisper-resize.py12 import whisper
38 ', '.join(whisper.aggregationMethods))
66 info = whisper.info(path)
68 new_archives = [whisper.parseRetentionDef(retentionDef)
89 timeinfo, values = whisper.fetch(path, fromTime, untilTime)
102 whisper.create(newfile, new_archives, xFilesFactor=xff, aggregationMethod=aggregationMethod)
132 new_info = whisper.info(newfile)
154 whisper.aggregate(aggregationMethod,
156 whisper.update_many(newfile, newdatapoints)
163 whisper.update_many(newfile, datapoints)
H A Dwhisper-create.py10 import whisper
45 ', '.join(whisper.aggregationMethods))
66 for (precision, points) in map(whisper.parseRetentionDef, args):
85 archives = [whisper.parseRetentionDef(retentionDef)
93 whisper.create(path, archives, xFilesFactor=options.xFilesFactor,
96 except whisper.WhisperException as exc:
/dports/databases/p5-Genezzo/Genezzo-0.72/lib/Genezzo/Block/
H A DRDBlkA.pm78 whisper "null!";
462 whisper $errstr;
481 whisper $errstr;
502 whisper $errstr;
518 whisper $errstr;
534 whisper $errstr;
563 whisper $errstr;
593 whisper $errstr;
685 whisper $errstr;
700 whisper $errstr;
[all …]
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/whisper/mailserver/
H A Dmailserver.go27 whisper "github.com/ethereum/go-ethereum/whisper/whisperv6" packageName
34 w *whisper.Whisper
91 func (s *WMailServer) Archive(env *whisper.Envelope) {
104 func (s *WMailServer) DeliverMail(peer *whisper.Peer, request *whisper.Envelope) {
116 func (s *WMailServer) processRequest(peer *whisper.Peer, lower, upper uint32, bloom []byte) []*whis…
117 ret := make([]*whisper.Envelope, 0)
126 var envelope whisper.Envelope
132 if whisper.BloomFilterMatch(bloom, envelope.Bloom()) {
159 f := whisper.Filter{KeySym: s.key}
184 bloom = whisper.MakeFullNodeBloom()
[all …]
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/cmd/wnode/
H A Dmain.go57 shh *whisper.Whisper
71 topic whisper.TopicType
139 topic = whisper.BytesToTopic(x)
219 cfg := &whisper.Config{
224 shh = whisper.New(cfg)
384 symFilter := whisper.Filter{
394 asymFilter := whisper.Filter{
558 params := whisper.MessageParams{
682 var xt whisper.TopicType
705 xt = whisper.BytesToTopic(x)
[all …]
/dports/www/py-graphite-web/graphite-web-1.1.8/webapp/graphite/readers/
H A Dwhisper.py12 import whisper
14 whisper = False variable
28 if bool(whisper):
29 whisper__readHeader = whisper.__readHeader
34 supported = bool(whisper)
43 self.meta_info = whisper.info(self.fs_path)
55 return whisper.fetch(self.fs_path, startTime, endTime, now=now)
80 supported = bool(whisper and gzip)
94 return whisper.file_fetch(fh, startTime, endTime, now=now)
/dports/databases/py-carbon/carbon-1.1.8/lib/carbon/
H A Ddatabase.py79 import whisper
85 aggregationMethods = whisper.aggregationMethods
96 whisper.AUTOFLUSH = True
99 if whisper.CAN_FALLOCATE:
105 if whisper.CAN_LOCK:
107 whisper.LOCK = True
113 if whisper.CAN_FADVISE:
115 whisper.FADVISE_RANDOM = True
124 whisper.update_many(path, datapoints)
172 whisper.validateArchiveList(archiveList)
[all …]
/dports/databases/p5-Genezzo/Genezzo-0.72/lib/Genezzo/SpaceMan/
H A DSMFile.pm201 whisper "bad fh tie";
277 whisper "bad fh tie";
437 whisper "bad fh tie";
553 whisper "bad fh tie";
583 whisper "bad curr extent";
862 whisper "bad curr extent";
896 whisper "bad first extent";
926 whisper "no previous block";
1124 whisper "bad fh tie";
1194 whisper "bad fh tie";
[all …]
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/whisper/shhclient/
H A Dclient.go25 whisper "github.com/ethereum/go-ethereum/whisper/whisperv6" packageName
55 func (sc *Client) Info(ctx context.Context) (whisper.Info, error) {
56 var info whisper.Info
162 func (sc *Client) Post(ctx context.Context, message whisper.NewMessage) (string, error) {
170 … *Client) SubscribeMessages(ctx context.Context, criteria whisper.Criteria, ch chan<- *whisper.Mes…
177 func (sc *Client) NewMessageFilter(ctx context.Context, criteria whisper.Criteria) (string, error) {
190 func (sc *Client) FilterMessages(ctx context.Context, id string) ([]*whisper.Message, error) {
191 var messages []*whisper.Message
/dports/databases/p5-T2/T2-0.10/bin/
H A Dt2-migrate-db.pl48 sub whisper { say(@_) if ($VERBOSITY >= 2) } subroutine
88 whisper "loading schema object";
96 whisper "loading T2::Class objects";
120 whisper "loading T2::Attribute objects";
138 whisper "loading T2::Method objects";
154 whisper "Loading T2::Association objects";
200 whisper "loading DSN information for site $site";
270 whisper "go, go, gadget Storable ;-)";
272 whisper "wahey! Storable did it!";
437 whisper "disconnecting from database";
[all …]
/dports/games/wesnoth/wesnoth-1.14.17/src/gui/widgets/
H A Dchatbox.cpp162 if(t.whisper) { in chat_input_keypress_callback()
397 const bool whisper, in find_or_create_window() argument
403 if(t.name == name && t.whisper == whisper) { in find_or_create_window()
422 if(!whisper) { in find_or_create_window()
438 if(!whisper) { in find_or_create_window()
542 if(t.whisper == false) { in close_window()
559 if(t.whisper) { in close_window()
607 if(t.whisper) { in active_window_room()
740 if(whisper) { in process_message()
762 plugin_data["whisper"] = whisper; in process_message()
[all …]
/dports/databases/py-whisper/whisper-1.1.3/contrib/
H A Dwhisper-auto-update.py9 import whisper
52 data = whisper.fetch(path, from_time, until_time)
56 except whisper.WhisperException as exc:
73 whisper.update(path, value_new, t)
75 except whisper.WhisperException as exc:

12345678910>>...52