/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 D | whisper.go | 110 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 D | 0037-whisper-metrics.patch | 1 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 D | 0014-whisperv6-notifications.patch | 1 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 D | 0027-whisper-time-source.patch | 1 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 D | 0025-whisper-confirmations.patch | 1 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 D | 0033-mailserver-response-contains-cursor.patch | 1 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 D | 0032-send-mailserver-request-completed-code.patch | 1 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 D | rx.c | 19 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 D | tx.c | 79 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 D | plumbing.c | 11 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 D | viamillipede.c | 33 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 D | whisper-dump.py | 12 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 D | whisper-fill.py | 18 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 D | whisper-resize.py | 12 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 D | whisper-create.py | 10 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 D | RDBlkA.pm | 78 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 D | mailserver.go | 27 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 D | main.go | 57 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 D | whisper.py | 12 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 D | database.py | 79 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 D | SMFile.pm | 201 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 D | client.go | 25 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 D | t2-migrate-db.pl | 48 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 D | chatbox.cpp | 162 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 D | whisper-auto-update.py | 9 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:
|