- tor-commits - lists.torproject.org

[translation/https_everywhere] Update translations for https_everywhere
by translation＠torproject.org 05 Mar '16

05 Mar '16

commit f2f11d24d349a270dc0b46f6d90aa7e9c0116e25 Author: Translation commit bot <translation(a)torproject.org> Date: Sat Mar 5 10:15:17 2016 +0000 Update translations for https_everywhere --- hr_HR/https-everywhere.dtd | 36 ++++++++++++++++++------------------ 1 file changed, 18 insertions(+), 18 deletions(-) diff --git a/hr_HR/https-everywhere.dtd b/hr_HR/https-everywhere.dtd index 7d00f68..cd77471 100644 --- a/hr_HR/https-everywhere.dtd +++ b/hr_HR/https-everywhere.dtd @@ -3,18 +3,18 @@ <!ENTITY https-everywhere.about.ext_description "Enkriptirajte web! Automatski koristite HTTPS sigurnost na mnogim stranicama."> <!ENTITY https-everywhere.about.version "Inačica"> <!ENTITY https-everywhere.about.created_by "Autori"> -<!ENTITY https-everywhere.about.and ", and"> +<!ENTITY https-everywhere.about.and ", i"> <!ENTITY https-everywhere.about.librarians "Autori biblioteke skupova pravila"> <!ENTITY https-everywhere.about.thanks "Zahvala"> -<!ENTITY https-everywhere.about.many_contributors "Many many contributors, including"> -<!ENTITY https-everywhere.about.noscript "Also, portions of HTTPS Everywhere are based on code from NoScript, by Giorgio Maone and others. We are grateful for their excellent work!"> +<!ENTITY https-everywhere.about.many_contributors "Puno, puno kontributora, uključujući"> +<!ENTITY https-everywhere.about.noscript "Također, dijelovi HTTPS Everywhere su zasnovani na kodu iz NoScript-a, autora Giorgio Maone i ostalih. Zahvalni smo im za odličan rad!"> <!ENTITY https-everywhere.about.contribute "Ako Vam se sviđa HTTPS Everywhere, mogli biste razmotriti"> <!ENTITY https-everywhere.about.donate_tor "doniranje Tor-u"> <!ENTITY https-everywhere.about.tor_lang_code "en"> <!ENTITY https-everywhere.about.or "ili"> <!ENTITY https-everywhere.about.donate_eff "doniranje EFF-u"> -<!ENTITY https-everywhere.menu.donate_eff_imperative "Donate to EFF"> +<!ENTITY https-everywhere.menu.donate_eff_imperative "Donirajte EFF-u"> <!ENTITY https-everywhere.menu.about "O proširenju HTTPS Everywhere"> <!ENTITY https-everywhere.menu.observatory " Podešavanje SSL Opservatorija"> <!ENTITY https-everywhere.menu.globalEnable "Omogući HTTPS Everywhere"> @@ -38,19 +38,19 @@ <!ENTITY https-everywhere.prefs.reset_default "Vrati na početno"> <!ENTITY https-everywhere.prefs.view_xml_source "Prikaži izvorni XML kod"> -<!ENTITY https-everywhere.chrome.stable_rules "Stable rules"> -<!ENTITY https-everywhere.chrome.stable_rules_description "Force encrypted connections to these websites:"> -<!ENTITY https-everywhere.chrome.experimental_rules "Experimental rules"> -<!ENTITY https-everywhere.chrome.experimental_rules_description "May cause warnings or breakage. Disabled by default."> -<!ENTITY https-everywhere.chrome.add_rule "Add a rule for this site"> -<!ENTITY https-everywhere.chrome.add_new_rule "Add a new rule for this site"> -<!ENTITY https-everywhere.chrome.always_https_for_host "Always use https for this host"> -<!ENTITY https-everywhere.chrome.host "Host:"> -<!ENTITY https-everywhere.chrome.show_advanced "Show advanced"> -<!ENTITY https-everywhere.chrome.hide_advanced "Hide advanced"> -<!ENTITY https-everywhere.chrome.rule_name "Rule name"> -<!ENTITY https-everywhere.chrome.regex "Matching regex"> -<!ENTITY https-everywhere.chrome.redirect_to "Redirect to"> -<!ENTITY https-everywhere.chrome.status_cancel_button "Cancel"> +<!ENTITY https-everywhere.chrome.stable_rules "Pravila stabilnosti"> +<!ENTITY https-everywhere.chrome.stable_rules_description "Prisili enkriptirane veze ovim stranicama:"> +<!ENTITY https-everywhere.chrome.experimental_rules "Eksperimentalna pravila"> +<!ENTITY https-everywhere.chrome.experimental_rules_description "Može prouzročiti upozorenja i kvarove. Onemogućeno pod zadano."> +<!ENTITY https-everywhere.chrome.add_rule "Dodaj pravilo za ovu stranicu"> +<!ENTITY https-everywhere.chrome.add_new_rule "Dodaj novo pravilo za ovu stranicu"> +<!ENTITY https-everywhere.chrome.always_https_for_host "Uvjek koristi https za ovog domaćina"> +<!ENTITY https-everywhere.chrome.host "Domaćin:"> +<!ENTITY https-everywhere.chrome.show_advanced "Pokaži napredno"> +<!ENTITY https-everywhere.chrome.hide_advanced "Sakrij napredno"> +<!ENTITY https-everywhere.chrome.rule_name "Ime pravila"> +<!ENTITY https-everywhere.chrome.regex "Uspoređujem regex"> +<!ENTITY https-everywhere.chrome.redirect_to "Preumsjeri na"> +<!ENTITY https-everywhere.chrome.status_cancel_button "Otkaži">

1 0

[translation/tor-launcher-network-settings_completed] Update translations for tor-launcher-network-settings_completed
by translation＠torproject.org 05 Mar '16

05 Mar '16

commit cc10b63f0818f017d7e7b7fa4100895084337714 Author: Translation commit bot <translation(a)torproject.org> Date: Sat Mar 5 08:45:46 2016 +0000 Update translations for tor-launcher-network-settings_completed --- hu/network-settings.dtd | 15 +++++++++++---- 1 file changed, 11 insertions(+), 4 deletions(-) diff --git a/hu/network-settings.dtd b/hu/network-settings.dtd index afdfafc..68d90eb 100644 --- a/hu/network-settings.dtd +++ b/hu/network-settings.dtd @@ -13,26 +13,32 @@ <!ENTITY torSettings.firstQuestion "A következők közül melyik illik jobban a szituációhoz?"> <!ENTITY torSettings.configurePrompt1 "Ennek a számítógépnek a forgalma cenzorált vagy proxizott."> -<!ENTITY torSettings.configurePrompt2 "Szükségem van híd vagy helyi proxy beállítására."> +<!ENTITY torSettings.configurePrompt2 "A Tor  hálózathoz való csatlakozás előtt be kell állítanom a hálózati hidat vagy a helyi proxyt."> <!ENTITY torSettings.configure "Beállít"> -<!ENTITY torSettings.connectPrompt2 "Szeretnék közvetlenül kapcsolódni a Tor hálózathoz."> +<!ENTITY torSettings.connectPrompt2 "Közvetlen kapcsolatot szeretnék létesíteni a Tor hálózattal."> <!ENTITY torSettings.connectPrompt3 "A legtöbb esetben ez működni fog."> <!ENTITY torSettings.connect "Csatlakozás"> <!ENTITY torSettings.proxyPageTitle "Helyi proxybeállítások"> <!ENTITY torSettings.proxyQuestion "Ez a számítgép helyi proxyn keresztül éri el az Internetet? ">  -<!ENTITY torSettings.proxyHelp "Ha nem biztos ennek a kérdésnek a megválaszolásában, kattintson az Internet beállításokra a másik böngészőjében, és tekintse meg, hog van-e benne beállítva helyiproxy."> +<!ENTITY torSettings.proxyExplanation1 "A helyi proxy a legtöbb esetben nem kell, de vállalati, iskolai vagy egyetemi hálózat esetén elfordulhat, hogy szükséges beállítani."> +<!ENTITY torSettings.proxyExplanation2 "Ha nem vagy biztos benne, hogyan válaszolj erre a kérdésre, akkor nézd meg egy másik böngésző vagy a rendszer hálózati beállításait, hogy szükséges-e proxyt beállítani."> <!ENTITY torSettings.enterProxy "Adja meg a proxy beállításokat."> <!ENTITY torSettings.bridgePageTitle "Tor hidak konfigurálása"> <!ENTITY torSettings.bridgeQuestion "Az internet szolgáltatód (ISP) blokkolja vagy cenzúrázza a kapcsolatot a Tor hálózathoz?"> -<!ENTITY torSettings.bridgeHelp "Ha nem vagy biztos a válaszban, válaszd a Nem-et.  Ha az Igen-t választod neked kell konfigurálni a Tor bridges amik nem listázott átjátszók és nehezebbé teszik a Tor hálózat kapcsolódásának a blokkolását."> +<!ENTITY torSettings.bridgeExplanation1 "Ha nem vagy biztos benne, hogyan válaszolj erre a kérdésre, válaszd a Nem lehetőséget (ha hálózati híd nélkül nem tudsz kapcsolódni a Tor hálózathoz, akkor később is hozzáadhatsz egyet)."> +<!ENTITY torSettings.bridgeExplanation2 " Ha az Igen-t választod neked kell konfigurálni a Tor Hidak-et, maleyek nem listázott csomópontok, így lehetővé nehezebbé teszik a Tor hálózathoz kapcsolódás blokkolását."> <!ENTITY torSettings.bridgeSettingsPrompt "Használhatod a szolgáltatott bridge címeket vagy beszerezhetsz egyedi bridge címeket.">  <!ENTITY torsettings.startingTor "Várakozás a Tor indulására..."> <!ENTITY torsettings.restartTor "Tor újraindítása"> +<!ENTITY torsettings.reconfigTor "Újrakonfigurál"> + +<!ENTITY torsettings.discardSettings.prompt "Beállított Tor Hidakat, vagy megadott egy helyi proxy-t.  A közvetlen kapcsolódáshoz ezeket a beállításokat el kell távolítania."> +<!ENTITY torsettings.discardSettings.proceed "Beállítások eltávolítása és Csatlakozás"> <!ENTITY torsettings.optional "Opcionális"> @@ -50,6 +56,7 @@ <!ENTITY torsettings.firewall.allowedPorts "Engedélyezett portok:"> <!ENTITY torsettings.useBridges.checkbox "Az internet szolgáltatóm (ISP) blokkolja a Tor hálózathoz való csatlakozásokat"> <!ENTITY torsettings.useBridges.default "Csatlakozás a szolgáltatott bridge címekkel."> +<!ENTITY torsettings.useBridges.note "Minden híd más megoldást használ a cenzorálás elkerülésére.  Ha egyik nem működik, próbálkozzon újra egy másikkal."> <!ENTITY torsettings.useBridges.type "Átvitel típusa:"> <!ENTITY torsettings.useBridges.custom "Addj meg egyedi bridge címeket"> <!ENTITY torsettings.useBridges.label "Addj meg egy vagy több bridge relay címet (soronként egy)">

1 0

[translation/tor-launcher-network-settings] Update translations for tor-launcher-network-settings
by translation＠torproject.org 05 Mar '16

05 Mar '16

commit 01caf7cdf0423a7f92e1e4b6bc85290a3e7ad426 Author: Translation commit bot <translation(a)torproject.org> Date: Sat Mar 5 08:45:41 2016 +0000 Update translations for tor-launcher-network-settings --- hu/network-settings.dtd | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/hu/network-settings.dtd b/hu/network-settings.dtd index 5d1c3a9..68d90eb 100644 --- a/hu/network-settings.dtd +++ b/hu/network-settings.dtd @@ -28,7 +28,7 @@ <!ENTITY torSettings.bridgePageTitle "Tor hidak konfigurálása"> <!ENTITY torSettings.bridgeQuestion "Az internet szolgáltatód (ISP) blokkolja vagy cenzúrázza a kapcsolatot a Tor hálózathoz?"> <!ENTITY torSettings.bridgeExplanation1 "Ha nem vagy biztos benne, hogyan válaszolj erre a kérdésre, válaszd a Nem lehetőséget (ha hálózati híd nélkül nem tudsz kapcsolódni a Tor hálózathoz, akkor később is hozzáadhatsz egyet)."> -<!ENTITY torSettings.bridgeExplanation2 "If you choose Yes, you will be asked to configure Tor Bridges, which are unlisted relays that make it more difficult to block connections to the Tor Network."> +<!ENTITY torSettings.bridgeExplanation2 " Ha az Igen-t választod neked kell konfigurálni a Tor Hidak-et, maleyek nem listázott csomópontok, így lehetővé nehezebbé teszik a Tor hálózathoz kapcsolódás blokkolását."> <!ENTITY torSettings.bridgeSettingsPrompt "Használhatod a szolgáltatott bridge címeket vagy beszerezhetsz egyedi bridge címeket.">  @@ -37,7 +37,7 @@ <!ENTITY torsettings.restartTor "Tor újraindítása"> <!ENTITY torsettings.reconfigTor "Újrakonfigurál"> -<!ENTITY torsettings.discardSettings.prompt "You have configured Tor bridges or you have entered local proxy settings.  To make a direct connection to the Tor network, these settings must be removed."> +<!ENTITY torsettings.discardSettings.prompt "Beállított Tor Hidakat, vagy megadott egy helyi proxy-t.  A közvetlen kapcsolódáshoz ezeket a beállításokat el kell távolítania."> <!ENTITY torsettings.discardSettings.proceed "Beállítások eltávolítása és Csatlakozás"> <!ENTITY torsettings.optional "Opcionális"> @@ -56,7 +56,7 @@ <!ENTITY torsettings.firewall.allowedPorts "Engedélyezett portok:"> <!ENTITY torsettings.useBridges.checkbox "Az internet szolgáltatóm (ISP) blokkolja a Tor hálózathoz való csatlakozásokat"> <!ENTITY torsettings.useBridges.default "Csatlakozás a szolgáltatott bridge címekkel."> -<!ENTITY torsettings.useBridges.note "Each type of bridge uses a different method to avoid censorship.  If one bridge does not work, try again using a different one."> +<!ENTITY torsettings.useBridges.note "Minden híd más megoldást használ a cenzorálás elkerülésére.  Ha egyik nem működik, próbálkozzon újra egy másikkal."> <!ENTITY torsettings.useBridges.type "Átvitel típusa:"> <!ENTITY torsettings.useBridges.custom "Addj meg egyedi bridge címeket"> <!ENTITY torsettings.useBridges.label "Addj meg egy vagy több bridge relay címet (soronként egy)">

1 0

[tordnsel/master] -funbox-strict-fields
by arlo＠torproject.org 05 Mar '16

05 Mar '16

commit bb1f4552d73638e59579dc14be3c881162303a57 Author: David Kaloper <david(a)numm.org> Date: Wed Sep 4 05:37:53 2013 +0200 -funbox-strict-fields --- src/TorDNSEL/DNS/Internals.hs | 94 +++++++++++++------------- src/TorDNSEL/DNS/Server/Internals.hs | 6 +- src/TorDNSEL/Directory/Internals.hs | 24 +++---- src/TorDNSEL/Document.hs | 10 +-- src/TorDNSEL/NetworkState/Storage/Internals.hs | 8 +-- src/TorDNSEL/NetworkState/Types.hs | 16 ++--- src/TorDNSEL/Socks/Internals.hs | 14 ++-- src/TorDNSEL/Statistics/Internals.hs | 2 +- src/TorDNSEL/TorControl/Internals.hs | 20 +++--- tordnsel.cabal | 2 +- 10 files changed, 98 insertions(+), 98 deletions(-) diff --git a/src/TorDNSEL/DNS/Internals.hs b/src/TorDNSEL/DNS/Internals.hs index b80b170..0eed2be 100644 --- a/src/TorDNSEL/DNS/Internals.hs +++ b/src/TorDNSEL/DNS/Internals.hs @@ -178,8 +178,8 @@ unsafeDecodeMessage pkt = runGet (getPacket pkt) (L.fromChunks [unPacket pkt]) -- | A value representing the current name compression targets and current -- offset (in bytes) into the datagram we're serializing. data PutState = PutState - { psTargets :: {-# UNPACK #-} !TargetMap - , psCurOff :: {-# UNPACK #-} !Offset } + { psTargets :: !TargetMap + , psCurOff :: !Offset } -- | The initial state before we start writing a datagram. initialPutState :: PutState @@ -213,7 +213,7 @@ type Offset = Int -- | A tree of labels used as compression targets. The top level represents -- top-level domain names, the second level second-level and so on. Making this -- a newtype triggers a bug in GHC 6.6. -data TargetMap = TargetMap {-# UNPACK #-} !(Map Label (Offset, TargetMap)) +data TargetMap = TargetMap !(Map Label (Offset, TargetMap)) deriving Show -- | The empty target map. @@ -265,33 +265,33 @@ compressNameStatefully name = do -- | A DNS message containing the header, question, and possibly answers. data Message = Message { -- | A message identifier set by the originator. - msgID :: {-# UNPACK #-} !Word16, + msgID :: !Word16, -- | Is this message a response? - msgQR :: {-# UNPACK #-} !Bool, + msgQR :: !Bool, -- | The kind of query in this message. - msgOpCode :: {-# UNPACK #-} !OpCode, + msgOpCode :: !OpCode, -- | Is the name server an authority for this domain name? - msgAA :: {-# UNPACK #-} !Bool, + msgAA :: !Bool, -- | Is this a truncated response? - msgTC :: {-# UNPACK #-} !Bool, + msgTC :: !Bool, -- | Does the originator desire the query to be pursued recursively? - msgRD :: {-# UNPACK #-} !Bool, + msgRD :: !Bool, -- | Does the name server support recursive queries? - msgRA :: {-# UNPACK #-} !Bool, + msgRA :: !Bool, -- | Has the data in this response been verified by the name server? - msgAD :: {-# UNPACK #-} !Bool, + msgAD :: !Bool, -- | Is non-verified data acceptable to the resolver sending this query? - msgCD :: {-# UNPACK #-} !Bool, + msgCD :: !Bool, -- | Response code set by the name server. - msgRCode :: {-# UNPACK #-} !RCode, + msgRCode :: !RCode, -- | The first question set by the originator. - msgQuestion :: {-# UNPACK #-} !Question, + msgQuestion :: !Question, -- | Answers to the question set by the name server. - msgAnswers :: {-# UNPACK #-} ![ResourceRecord], + msgAnswers :: ![ResourceRecord], -- | Authority records set by the name server. - msgAuthority :: {-# UNPACK #-} ![ResourceRecord], + msgAuthority :: ![ResourceRecord], -- | Additional records set by the name server. - msgAdditional :: {-# UNPACK #-} ![ResourceRecord] } + msgAdditional :: ![ResourceRecord] } deriving (Eq, Show) instance NFData Message where @@ -357,11 +357,11 @@ instance BinaryPacket Message where -- | A question to the name server. data Question = Question { -- | The domain name this question is about. - qName :: {-# UNPACK #-} !DomainName, + qName :: !DomainName, -- | The type of this question. We only support 'A' and *. - qType :: {-# UNPACK #-} !Type, + qType :: !Type, -- | The class of this question. We only support 'IN'. - qClass :: {-# UNPACK #-} !Class } + qClass :: !Class } deriving (Eq, Show) instance NFData Question where @@ -382,57 +382,57 @@ data ResourceRecord -- | A record containing an IPv4 address. = A { -- | The domain name to which this record pertains. - rrName :: {-# UNPACK #-} !DomainName, + rrName :: !DomainName, -- | A time interval, in seconds, that the answer may be cached. - rrTTL :: {-# UNPACK #-} !Word32, + rrTTL :: !Word32, -- | An IPv4 address. - aAddr :: {-# UNPACK #-} !HostAddress } + aAddr :: !HostAddress } -- | An authoritative name server record. | NS { -- | The domain name to which this record pertains. - rrName :: {-# UNPACK #-} !DomainName, + rrName :: !DomainName, -- | A time interval, in seconds, that the answer may be cached. - rrTTL :: {-# UNPACK #-} !Word32, + rrTTL :: !Word32, -- | The host that should be authoritative for this zone. - nsDName :: {-# UNPACK #-} !DomainName } + nsDName :: !DomainName } -- | A start of zone of authority record. | SOA { -- | The domain name to which this record pertains. - rrName :: {-# UNPACK #-} !DomainName, + rrName :: !DomainName, -- | A time interval, in seconds, that the answer may be cached. - rrTTL :: {-# UNPACK #-} !Word32, + rrTTL :: !Word32, -- | The name server that was the original source of data for this zone. - soaMName :: {-# UNPACK #-} !DomainName, + soaMName :: !DomainName, -- | A name specifying the email address of the person responsible for -- this zone. - soaRName :: {-# UNPACK #-} !DomainName, + soaRName :: !DomainName, -- | The version number of the original copy of this zone. - soaSerial :: {-# UNPACK #-} !Word32, + soaSerial :: !Word32, -- | The number of seconds before the zone should be refreshed. - soaRefresh :: {-# UNPACK #-} !Word32, + soaRefresh :: !Word32, -- | The number of seconds before a failed refresh should be retried. - soaRetry :: {-# UNPACK #-} !Word32, + soaRetry :: !Word32, -- | The number of seconds that can elapse before the zone is no longer -- authoritative. - soaExpire :: {-# UNPACK #-} !Word32, + soaExpire :: !Word32, -- | The default TTL of records that do not contain a TTL, and the TTL of -- negative responses. - soaMinimum :: {-# UNPACK #-} !Word32 } + soaMinimum :: !Word32 } -- | An unsupported record. | UnsupportedResourceRecord { -- | The domain name to which this record pertains. - rrName :: {-# UNPACK #-} !DomainName, + rrName :: !DomainName, -- | A time interval, in seconds, that the answer may be cached. - rrTTL :: {-# UNPACK #-} !Word32, + rrTTL :: !Word32, -- | The 'Type' of this record. - rrType :: {-# UNPACK #-} !Type, + rrType :: !Type, -- | The 'Class' of this record. - rrClass :: {-# UNPACK #-} !Class, + rrClass :: !Class, -- | An opaque 'ByteString' containing the resource data. - rrData :: {-# UNPACK #-} !ByteString } + rrData :: !ByteString } deriving (Eq, Show) instance NFData ResourceRecord where @@ -581,11 +581,11 @@ instance NFData OpCode where -- | The TYPE or QTYPE values that appear in resource records or questions, -- respectively. data Type - = TA -- ^ An IPv4 host address. - | TNS -- ^ An authoritative name server. - | TSOA -- ^ A start of zone of authority. - | TAny -- ^ A request for all records. - | UnsupportedType {-# UNPACK #-} !Word16 -- ^ Any other type. + = TA -- ^ An IPv4 host address. + | TNS -- ^ An authoritative name server. + | TSOA -- ^ A start of zone of authority. + | TAny -- ^ A request for all records. + | UnsupportedType !Word16 -- ^ Any other type. deriving (Eq, Show) instance NFData Type where @@ -609,8 +609,8 @@ instance Binary Type where -- | The CLASS or QCLASS values that appear in resource records or questions, -- respectively. data Class - = IN -- ^ The Internet. We only support this class. - | UnsupportedClass {-# UNPACK #-} !Word16 -- ^ Any other class. + = IN -- ^ The Internet. We only support this class. + | UnsupportedClass !Word16 -- ^ Any other class. deriving (Eq, Show) -- XXX support * diff --git a/src/TorDNSEL/DNS/Server/Internals.hs b/src/TorDNSEL/DNS/Server/Internals.hs index 8ab3637..268ca8d 100644 --- a/src/TorDNSEL/DNS/Server/Internals.hs +++ b/src/TorDNSEL/DNS/Server/Internals.hs @@ -218,11 +218,11 @@ data ExitListQuery -- <https://gitweb.torproject.org/tordnsel.git/tree/doc/torel-design.txt> = IPPort { -- | The address of the candidate exit node. - queryAddr :: {-# UNPACK #-} !HostAddress, + queryAddr :: !HostAddress, -- | The destination address. - destAddr :: {-# UNPACK #-} !HostAddress, + destAddr :: !HostAddress, -- | The destination port. - destPort :: {-# UNPACK #-} !Port + destPort :: !Port } deriving Eq instance Show ExitListQuery where diff --git a/src/TorDNSEL/Directory/Internals.hs b/src/TorDNSEL/Directory/Internals.hs index 154b30c..d7f8303 100644 --- a/src/TorDNSEL/Directory/Internals.hs +++ b/src/TorDNSEL/Directory/Internals.hs @@ -78,13 +78,13 @@ import TorDNSEL.Util -- | A router descriptor. data Descriptor = Desc { -- | The IPv4 address at which this router accepts connections. - descListenAddr :: {-# UNPACK #-} !HostAddress, + descListenAddr :: !HostAddress, -- | The time when this descriptor was generated. - descPublished :: {-# UNPACK #-} !POSIXTime, + descPublished :: !POSIXTime, -- | This router's identifier. - descRouterID :: {-# UNPACK #-} !RouterID, + descRouterID :: !RouterID, -- | This router's exit policy. - descExitPolicy :: {-# UNPACK #-} !ExitPolicy } + descExitPolicy :: !ExitPolicy } instance Show Descriptor where showsPrec _ d = cat (descRouterID d) ' ' (inet_htoa $ descListenAddr d) ' ' @@ -124,11 +124,11 @@ parseDescriptors = parseSubDocs (B.pack "router") parseDescriptor -- | A router status entry. data RouterStatus = RS { -- | This router's identifier. - rsRouterID :: {-# UNPACK #-} !RouterID, + rsRouterID :: !RouterID, -- | When this router's most recent descriptor was published. - rsPublished :: {-# UNPACK #-} !UTCTime, + rsPublished :: !UTCTime, -- | Is this router running? - rsIsRunning :: {-# UNPACK #-} !Bool } + rsIsRunning :: !Bool } deriving Show -- | Parse a router status entry. Return the result or 'throwError' in the @@ -226,15 +226,15 @@ instance Hash ExitPolicy where -- port range pattern. data Rule = Rule { -- | Whether an exit connection is allowed. - ruleType :: {-# UNPACK #-} !RuleType, + ruleType :: !RuleType, -- | The IPv4 address part of the pattern. - ruleAddress :: {-# UNPACK #-} !HostAddress, + ruleAddress :: !HostAddress, -- | The IPv4 address mask part of the pattern. - ruleMask :: {-# UNPACK #-} !HostAddress, + ruleMask :: !HostAddress, -- | The first port in the pattern's port range. - ruleBeginPort :: {-# UNPACK #-} !Port, + ruleBeginPort :: !Port, -- | The last port in the pattern's port range. - ruleEndPort :: {-# UNPACK #-} !Port + ruleEndPort :: !Port } deriving (Eq, Ord) instance Show Rule where diff --git a/src/TorDNSEL/Document.hs b/src/TorDNSEL/Document.hs index 50c986c..f4285c1 100644 --- a/src/TorDNSEL/Document.hs +++ b/src/TorDNSEL/Document.hs @@ -41,15 +41,15 @@ type Document = [Item] -- | An item consisting of a keyword, possibly arguments, and zero or more -- objects. data Item = Item - { iKey :: {-# UNPACK #-} !ByteString -- ^ Keyword - , iArg :: {-# UNPACK #-} !(Maybe ByteString) -- ^ Arguments - , iObj :: {-# UNPACK #-} ![Object] -- ^ Objects + { iKey :: !ByteString -- ^ Keyword + , iArg :: !(Maybe ByteString) -- ^ Arguments + , iObj :: ![Object] -- ^ Objects } deriving Show -- | An object consisting of a keyword and a block of base64-encoded data. data Object = Object - { objKey :: {-# UNPACK #-} !ByteString -- ^ Keyword - , objData :: {-# UNPACK #-} !ByteString -- ^ Base64-encoded data + { objKey :: !ByteString -- ^ Keyword + , objData :: !ByteString -- ^ Base64-encoded data } deriving Show -- | Parse a 'Document' from a list of lines. diff --git a/src/TorDNSEL/NetworkState/Storage/Internals.hs b/src/TorDNSEL/NetworkState/Storage/Internals.hs index 79481f6..0f79cf8 100644 --- a/src/TorDNSEL/NetworkState/Storage/Internals.hs +++ b/src/TorDNSEL/NetworkState/Storage/Internals.hs @@ -185,15 +185,15 @@ terminateStorageManager mbWait (StorageManager tellStorageManager tid) = -- same as Tor uses for storing router descriptors. data ExitAddress = ExitAddress { -- | The identity of the exit node we tested through. - eaRouterID :: {-# UNPACK #-} !RouterID, + eaRouterID :: !RouterID, -- | The current descriptor published time when the test was initiated. We -- don't perform another test until a newer descriptor arrives. - eaPublished :: {-# UNPACK #-} !UTCTime, + eaPublished :: !UTCTime, -- | When we last received a network status update for this router. This -- helps us decide when to discard a router. - eaLastStatus :: {-# UNPACK #-} !UTCTime, + eaLastStatus :: !UTCTime, -- | A map from exit address to when the address was last seen. - eaAddresses :: {-# UNPACK #-} !(Map HostAddress UTCTime) + eaAddresses :: !(Map HostAddress UTCTime) } deriving Eq instance Show ExitAddress where diff --git a/src/TorDNSEL/NetworkState/Types.hs b/src/TorDNSEL/NetworkState/Types.hs index 547ab85..25e809e 100644 --- a/src/TorDNSEL/NetworkState/Types.hs +++ b/src/TorDNSEL/NetworkState/Types.hs @@ -24,27 +24,27 @@ import TorDNSEL.Directory -- | A Tor router. data Router = Router { -- | This router's descriptor, if we have it yet. - rtrDescriptor :: {-# UNPACK #-} !(Maybe Descriptor), + rtrDescriptor :: !(Maybe Descriptor), -- | This router's exit test results, if one has been completed. - rtrTestResults :: {-# UNPACK #-} !(Maybe TestResults), + rtrTestResults :: !(Maybe TestResults), -- | Whether we think this router is running. - rtrIsRunning :: {-# UNPACK #-} !Bool, + rtrIsRunning :: !Bool, -- | The last time we received a router status entry for this router. - rtrLastStatus :: {-# UNPACK #-} !UTCTime } + rtrLastStatus :: !UTCTime } -- | The results of exit tests. data TestResults = TestResults { -- | The descriptor's published time when the last exit test was initiated. - tstPublished :: {-# UNPACK #-} !UTCTime, + tstPublished :: !UTCTime, -- | A map from exit address to when the address was last seen. - tstAddresses :: {-# UNPACK #-} !(Map HostAddress UTCTime) } + tstAddresses :: !(Map HostAddress UTCTime) } -- | Our current view of the Tor network. data NetworkState = NetworkState { -- | A map from listen address to routers. - nsAddrs :: {-# UNPACK #-} !(Map HostAddress (Set RouterID)), + nsAddrs :: !(Map HostAddress (Set RouterID)), -- | All the routers we know about. - nsRouters :: {-# UNPACK #-} !(Map RouterID Router) } + nsRouters :: !(Map RouterID Router) } -- | The empty network state. emptyNetworkState :: NetworkState diff --git a/src/TorDNSEL/Socks/Internals.hs b/src/TorDNSEL/Socks/Internals.hs index f514c44..c5ce474 100644 --- a/src/TorDNSEL/Socks/Internals.hs +++ b/src/TorDNSEL/Socks/Internals.hs @@ -78,11 +78,11 @@ withSocksConnection handle addr port io = (`E.finally` hClose handle) $ do -- | A Socks4a request. data Request = Request { -- | The Socks4 command code (with Tor extensions). - soCommand :: {-# UNPACK #-} !Command, + soCommand :: !Command, -- | The requested destination: either an IPv4 address or a domain name. - soReqDest :: {-# UNPACK #-} !Address, + soReqDest :: !Address, -- | The requested destination port. - soReqPort :: {-# UNPACK #-} !Port } + soReqPort :: !Port } -- A Socks4a command (with Tor extensions). data Command @@ -92,9 +92,9 @@ data Command -- | A Socks4 response. data Response = Response - { soResult :: {-# UNPACK #-} !Result -- ^ The result code. - , soRespAddr :: {-# UNPACK #-} !HostAddress -- ^ The destination address. - , soRespPort :: {-# UNPACK #-} !Port -- ^ The destination port. + { soResult :: !Result -- ^ The result code. + , soRespAddr :: !HostAddress -- ^ The destination address. + , soRespPort :: !Port -- ^ The destination port. } instance NFData Response where @@ -166,7 +166,7 @@ decodeResponse resp = do -- | A Socks error. data SocksError - = SocksError {-# UNPACK #-} !Result -- ^ A known Socks error code. + = SocksError !Result -- ^ A known Socks error code. | SocksProtocolError -- ^ The response doesn't follow the Socks protocol. deriving Typeable diff --git a/src/TorDNSEL/Statistics/Internals.hs b/src/TorDNSEL/Statistics/Internals.hs index cc0f799..bb390eb 100644 --- a/src/TorDNSEL/Statistics/Internals.hs +++ b/src/TorDNSEL/Statistics/Internals.hs @@ -42,7 +42,7 @@ import TorDNSEL.Util -- sent. data Stats = Stats { bytesRecv, bytesSent, dgramsRecv, positives - , negatives, others :: {-# UNPACK #-} !Integer } + , negatives, others :: !Integer } -- | The current statistics state. statsState :: MVar Stats diff --git a/src/TorDNSEL/TorControl/Internals.hs b/src/TorDNSEL/TorControl/Internals.hs index 2ea2e16..95fbbd0 100644 --- a/src/TorDNSEL/TorControl/Internals.hs +++ b/src/TorDNSEL/TorControl/Internals.hs @@ -256,21 +256,21 @@ protocolInfo (Conn _ _ protInfo _) = protInfo -- | A command to send to Tor. data Command = Command { -- | A command keyword. - comKey :: {-# UNPACK #-} !ByteString, + comKey :: !ByteString, -- | Command arguments. - comArgs :: {-# UNPACK #-} ![ByteString], + comArgs :: ![ByteString], -- | A list of lines sent in the data section. - comData :: {-# UNPACK #-} ![ByteString] + comData :: ![ByteString] } deriving Show -- | A reply sent by Tor in response to a command. data Reply = Reply { -- | A reply code. - repCode :: {-# UNPACK #-} !(Char, Char, Char) + repCode :: !(Char, Char, Char) -- | Reply text. - , repText :: {-# UNPACK #-} !ByteString + , repText :: !ByteString -- | A list of lines from the data section. - , repData :: {-# UNPACK #-} ![ByteString] + , repData :: ![ByteString] } deriving Show -- | Authenticate with Tor. Throw a 'TorControlError' if authenticating fails @@ -652,8 +652,8 @@ boolVar var = ConfVar getc (setc setConf') (setc resetConf') where -- | An asynchronous event handler. data EventHandler = EventHandler - { evCode :: {-# UNPACK #-} !ByteString -- ^ The event code. - , evHandler :: {-# UNPACK #-} !([Reply] -> IO ()) -- ^ The event handler. + { evCode :: !ByteString -- ^ The event code. + , evHandler :: !([Reply] -> IO ()) -- ^ The event handler. } -- | Register a set of handlers for asynchronous events. This deregisters any @@ -828,8 +828,8 @@ startIOManager handle = do -- | Reply types in a single sequence of replies. data ReplyType - = MidReply {-# UNPACK #-} !Reply -- ^ A reply preceding other replies. - | LastReply {-# UNPACK #-} !Reply -- ^ The last reply. + = MidReply !Reply -- ^ A reply preceding other replies. + | LastReply !Reply -- ^ The last reply. deriving Show -- | Start a thread that reads replies from @handle@ and passes them to diff --git a/tordnsel.cabal b/tordnsel.cabal index 4f0b11f..3173943 100644 --- a/tordnsel.cabal +++ b/tordnsel.cabal @@ -59,7 +59,7 @@ Other-Modules: TorDNSEL.Config HS-Source-Dirs: src Includes: sys/types.h, unistd.h, sysexits.h, netinet/in.h, openssl/rand.h Extra-Libraries: crypto -GHC-Options: -O2 -Wall -Werror +GHC-Options: -O2 -funbox-strict-fields -Wall -Werror CPP-Options: -DVERSION="0.1.1-dev" Extensions: FlexibleContexts FlexibleInstances

1 0

[tordnsel/master] rm asm flag
by arlo＠torproject.org 05 Mar '16

05 Mar '16

commit f70c637f67eb868e48aa51d42c130c568cdc9720 Author: Arlo Breault <arlolra(a)gmail.com> Date: Fri Mar 4 13:33:01 2016 -0800 rm asm flag --- tordnsel.cabal | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tordnsel.cabal b/tordnsel.cabal index 7e8d015..4f0b11f 100644 --- a/tordnsel.cabal +++ b/tordnsel.cabal @@ -83,4 +83,4 @@ Other-Modules: TorDNSEL.Config.Tests HS-Source-Dirs: src Includes: netinet/in.h, openssl/rand.h Extra-Libraries: crypto -GHC-Options: -fasm -Wall -Werror -fno-warn-missing-signatures +GHC-Options: -Wall -Werror -fno-warn-missing-signatures

1 0

[snowflake/master] use const LogTimeInterval
by serene＠torproject.org 05 Mar '16

05 Mar '16

commit 8a8273e972f8a0d9496da7f6af47e34899c07f14 Author: Serene Han <keroserene+git(a)gmail.com> Date: Sun Feb 28 13:16:12 2016 -0800 use const LogTimeInterval --- client/util.go | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/client/util.go b/client/util.go index fa04220..abefa04 100644 --- a/client/util.go +++ b/client/util.go @@ -5,6 +5,10 @@ import ( "time" ) +const ( + LogTimeInterval = 5 +) + type BytesInfo struct { outboundChan chan int inboundChan chan int @@ -33,18 +37,18 @@ func (b *BytesInfo) Log() { b.outbound += amount b.outEvents++ last := time.Now() - if time.Since(last) > time.Second*5 { + if time.Since(last) > time.Second*LogTimeInterval { last = time.Now() output() } case amount = <-b.inboundChan: b.inbound += amount b.inEvents++ - if time.Since(last) > time.Second*5 { + if time.Since(last) > time.Second*LogTimeInterval { last = time.Now() output() } - case <-time.After(time.Second * 5): + case <-time.After(time.Second * LogTimeInterval): if b.inEvents > 0 || b.outEvents > 0 { output() }

1 0

[snowflake/master] confirmation dialog on proxy close (close #23)
by serene＠torproject.org 05 Mar '16

05 Mar '16

commit d2e61e315c2bc34d28c5f0afeb982804b6abf1ba Author: Serene Han <keroserene+git(a)gmail.com> Date: Wed Mar 2 05:45:27 2016 -0800 confirmation dialog on proxy close (close #23) --- proxy/snowflake.coffee | 9 +++++++++ proxy/spec/snowflake.spec.coffee | 12 ++++++++++++ 2 files changed, 21 insertions(+) diff --git a/proxy/snowflake.coffee b/proxy/snowflake.coffee index 0df1904..90150ad 100644 --- a/proxy/snowflake.coffee +++ b/proxy/snowflake.coffee @@ -44,6 +44,8 @@ MODE = WEBRTC_CONNECTING: 1 WEBRTC_READY: 2 +CONFIRMATION_MESSAGE = "You're currently serving a Tor user via Snowflake." + # Minimum viable snowflake for now - just 1 client. class Snowflake @@ -200,4 +202,11 @@ init = -> snowflake.setRelayAddr relayAddr snowflake.beginWebRTC() +# Notification of closing tab with active proxy. +# TODO: Opt-in/out parameter or cookie +window.onbeforeunload = -> + if MODE.WEBRTC_READY == snowflake.state + return CONFIRMATION_MESSAGE + null + window.onload = init if window diff --git a/proxy/spec/snowflake.spec.coffee b/proxy/spec/snowflake.spec.coffee index be1601b..f3fbae8 100644 --- a/proxy/spec/snowflake.spec.coffee +++ b/proxy/spec/snowflake.spec.coffee @@ -23,6 +23,7 @@ snowflake = ui: fakeUI broker: sendAnswer: -> + state: MODE.INIT describe 'Snowflake', -> @@ -58,3 +59,14 @@ describe 'Snowflake', -> s = new Snowflake(new FakeBroker(), fakeUI) s.makeProxyPair() expect(s.proxyPairs.length).toBe 2 + + it 'gives a dialog when closing, only while active', -> + snowflake.state = MODE.WEBRTC_READY + msg = window.onbeforeunload() + expect(snowflake.state).toBe MODE.WEBRTC_READY + expect(msg).toBe CONFIRMATION_MESSAGE + + snowflake.state = MODE.INIT + msg = window.onbeforeunload() + expect(snowflake.state).toBe MODE.INIT + expect(msg).toBe null

1 0

[snowflake/master] prepare IceServerList client flag (#24)
by serene＠torproject.org 05 Mar '16

05 Mar '16

commit 3ec771df01770d708bd5cc8c90156ee4c7e9cff6 Author: Serene Han <keroserene+git(a)gmail.com> Date: Thu Mar 3 22:51:10 2016 -0800 prepare IceServerList client flag (#24) --- client/snowflake.go | 3 +++ client/util.go | 16 ++++++++++++++++ 2 files changed, 19 insertions(+) diff --git a/client/snowflake.go b/client/snowflake.go index 25ccfef..4af76e8 100644 --- a/client/snowflake.go +++ b/client/snowflake.go @@ -22,6 +22,7 @@ var ptInfo pt.ClientInfo // var logFile *os.File var brokerURL string var frontDomain string +var iceServers IceServerList // When a connection handler starts, +1 is written to this channel; when it // ends, -1 is written. @@ -109,6 +110,7 @@ func handler(conn *pt.SocksConn) error { // TODO: Make SOCKS acceptance more independent from WebRTC so they can // be more easily interchanged. + copyLoop(conn, remote) // <-remote.endChannel log.Println("----END---") @@ -161,6 +163,7 @@ func main() { webrtc.SetLoggingVerbosity(1) flag.StringVar(&brokerURL, "url", "", "URL of signaling broker") flag.StringVar(&frontDomain, "front", "", "front domain") + flag.Var(&iceServers, "ice", "comma-separated list of ICE servers") flag.Parse() logFile, err := os.OpenFile("snowflake.log", os.O_CREATE|os.O_APPEND|os.O_WRONLY, 0600) if err != nil { diff --git a/client/util.go b/client/util.go index abefa04..2a54f6a 100644 --- a/client/util.go +++ b/client/util.go @@ -1,7 +1,9 @@ package main import ( + "fmt" "log" + "strings" "time" ) @@ -9,6 +11,20 @@ const ( LogTimeInterval = 5 ) +type IceServerList []string + +func (i *IceServerList) String() string { + return fmt.Sprint(*i) +} + +func (i *IceServerList) Set(s string) error { + for _, server := range strings.Split(s, ",") { + // TODO: STUN / TURN url format validation? + *i = append(*i, server) + } + return nil +} + type BytesInfo struct { outboundChan chan int inboundChan chan int

1 0

[snowflake/master] provide IceServerList flag as variadic arg to webrtc Configuration (#24)
by serene＠torproject.org 05 Mar '16

05 Mar '16

commit 4e6bba559a77634c4dde38e6702e37bc4f364fd4 Author: Serene Han <keroserene+git(a)gmail.com> Date: Fri Mar 4 13:21:44 2016 -0800 provide IceServerList flag as variadic arg to webrtc Configuration (#24) --- client/snowflake.go | 3 +-- client/torrc | 3 ++- client/util.go | 6 ++++-- 3 files changed, 7 insertions(+), 5 deletions(-) diff --git a/client/snowflake.go b/client/snowflake.go index 4af76e8..4287425 100644 --- a/client/snowflake.go +++ b/client/snowflake.go @@ -63,8 +63,7 @@ func dialWebRTC() (*webRTCConn, error) { // TODO: [#3] Fetch ICE server information from Broker. // TODO: [#18] Consider TURN servers here too. - config := webrtc.NewConfiguration( - webrtc.OptionIceServer("stun:stun.l.google.com:19302")) + config := webrtc.NewConfiguration(iceServers...) broker := NewBrokerChannel(brokerURL, frontDomain) if nil == broker { diff --git a/client/torrc b/client/torrc index 9af942b..c4af61f 100644 --- a/client/torrc +++ b/client/torrc @@ -3,6 +3,7 @@ DataDirectory datadir ClientTransportPlugin snowflake exec ./client \ -url https://snowflake-reg.appspot.com/ \ --front www.google.com +-front www.google.com \ +-ice stun:stun.l.google.com:19302 Bridge snowflake 0.0.3.0:1 diff --git a/client/util.go b/client/util.go index 2a54f6a..02132f2 100644 --- a/client/util.go +++ b/client/util.go @@ -2,6 +2,7 @@ package main import ( "fmt" + "github.com/keroserene/go-webrtc" "log" "strings" "time" @@ -11,7 +12,7 @@ const ( LogTimeInterval = 5 ) -type IceServerList []string +type IceServerList []webrtc.ConfigurationOption func (i *IceServerList) String() string { return fmt.Sprint(*i) @@ -20,7 +21,8 @@ func (i *IceServerList) String() string { func (i *IceServerList) Set(s string) error { for _, server := range strings.Split(s, ",") { // TODO: STUN / TURN url format validation? - *i = append(*i, server) + option := webrtc.OptionIceServer(server) + *i = append(*i, option) } return nil }

1 0

[snowflake/master] Use a channel to safely synchronize datachannel writes, (#12)
by serene＠torproject.org 05 Mar '16

05 Mar '16

commit c3ada1b54521927809b2ae67b45684dd412dc612 Author: Serene Han <keroserene+git(a)gmail.com> Date: Fri Feb 19 16:17:17 2016 -0800 Use a channel to safely synchronize datachannel writes, (#12) clean up ice candidate log message. still need to debug the copy loop break. --- client/client_test.go | 11 +++++++++-- client/snowflake.go | 54 ++++++++++++++++++++++++++++++++++++--------------- 2 files changed, 47 insertions(+), 18 deletions(-) diff --git a/client/client_test.go b/client/client_test.go index 6ee36d9..85c2144 100644 --- a/client/client_test.go +++ b/client/client_test.go @@ -9,10 +9,12 @@ import ( type MockDataChannel struct { destination bytes.Buffer + done chan bool } func (m *MockDataChannel) Send(data []byte) { m.destination.Write(data) + m.done <- true } func (*MockDataChannel) Close() error { @@ -24,6 +26,7 @@ func TestConnect(t *testing.T) { Convey("WebRTC Connection", func() { c := new(webRTCConn) + c.BytesInfo = &BytesInfo{ inboundChan: make(chan int), outboundChan: make(chan int), inbound: 0, outbound: 0, inEvents: 0, outEvents: 0, @@ -31,15 +34,19 @@ func TestConnect(t *testing.T) { So(c.buffer.Bytes(), ShouldEqual, nil) Convey("SendData buffers when datachannel is nil", func() { - c.sendData([]byte("test")) + c.SendData([]byte("test")) c.snowflake = nil So(c.buffer.Bytes(), ShouldResemble, []byte("test")) }) Convey("SendData sends to datachannel when not nil", func() { mock := new(MockDataChannel) + mock.done = make(chan bool) + go c.SendLoop() + c.writeChannel = make(chan []byte) c.snowflake = mock - c.sendData([]byte("test")) + c.SendData([]byte("test")) + <-mock.done So(c.buffer.Bytes(), ShouldEqual, nil) So(mock.destination.Bytes(), ShouldResemble, []byte("test")) }) diff --git a/client/snowflake.go b/client/snowflake.go index eba68eb..d01ec5e 100644 --- a/client/snowflake.go +++ b/client/snowflake.go @@ -36,12 +36,15 @@ const ( func copyLoop(a, b net.Conn) { var wg sync.WaitGroup wg.Add(2) + // TODO fix the copy loop. go func() { io.Copy(b, a) + log.Println("copy loop b-a break") wg.Done() }() go func() { io.Copy(a, b) + log.Println("copy loop a-b break") wg.Done() }() wg.Wait() @@ -63,6 +66,7 @@ type webRTCConn struct { offerChannel chan *webrtc.SessionDescription answerChannel chan *webrtc.SessionDescription errorChannel chan error + writeChannel chan []byte recvPipe *io.PipeReader writePipe *io.PipeWriter buffer bytes.Buffer @@ -77,7 +81,7 @@ func (c *webRTCConn) Read(b []byte) (int, error) { } func (c *webRTCConn) Write(b []byte) (int, error) { - c.sendData(b) + c.SendData(b) return len(b), nil } @@ -133,9 +137,9 @@ func (c *webRTCConn) PreparePeerConnection() { } }() } + // Allow candidates to accumulate until OnIceComplete. pc.OnIceCandidate = func(candidate webrtc.IceCandidate) { - log.Printf("WebRTC: OnIceCandidate %s", candidate.Serialize()) - // Allow candidates to accumulate until OnIceComplete. + log.Printf(candidate.Candidate) } // TODO: This may soon be deprecated, consider OnIceGatheringStateChange. pc.OnIceComplete = func() { @@ -169,10 +173,11 @@ func (c *webRTCConn) EstablishDataChannel() error { // } // Flush the buffer, then enable datachannel. // TODO: Make this more safe - dc.Send(c.buffer.Bytes()) - log.Println("Flushed", c.buffer.Len(), "bytes") - c.buffer.Reset() + // dc.Send(c.buffer.Bytes()) + // log.Println("Flushed", c.buffer.Len(), "bytes") + // c.buffer.Reset() c.snowflake = dc + c.SendData(nil) } dc.OnClose = func() { // Disable the DataChannel as a write destination. @@ -180,7 +185,7 @@ func (c *webRTCConn) EstablishDataChannel() error { log.Println("WebRTC: DataChannel.OnClose") if nil != c.snowflake { c.snowflake = nil - // Only reset if this OnClose triggered + // Only reset if this OnClose was triggered remotely. c.Reset() } } @@ -247,21 +252,32 @@ func (c *webRTCConn) ReceiveAnswer() { }() } -func (c *webRTCConn) sendData(data []byte) { - c.BytesInfo.AddOutbound(len(data)) +func (c *webRTCConn) SendData(data []byte) { // Buffer the data in case datachannel isn't available yet. if nil == c.snowflake { log.Printf("Buffered %d bytes --> WebRTC", len(data)) c.buffer.Write(data) return } - // Otherwise, flush buffer if necessary. - for c.buffer.Len() > 0 { - c.snowflake.Send(c.buffer.Bytes()) - log.Println("Flushed", c.buffer.Len(), "bytes") - c.buffer.Reset() + go func() { + c.writeChannel <- data + }() +} + +// Expected in own goroutine. +func (c *webRTCConn) SendLoop() { + log.Println("send loop") + for data := range c.writeChannel { + // Flush buffer if necessary. + for c.buffer.Len() > 0 { + c.snowflake.Send(c.buffer.Bytes()) + log.Println("Flushed", c.buffer.Len(), "bytes") + c.buffer.Reset() + } + + c.BytesInfo.AddOutbound(len(data)) + c.snowflake.Send(data) } - c.snowflake.Send(data) } // WebRTC re-establishment loop. Expected in own goroutine. @@ -296,6 +312,7 @@ func dialWebRTC(config *webrtc.Configuration, broker *BrokerChannel) ( connection.broker = broker connection.offerChannel = make(chan *webrtc.SessionDescription) connection.answerChannel = make(chan *webrtc.SessionDescription) + connection.writeChannel = make(chan []byte) connection.errorChannel = make(chan error) connection.reset = make(chan struct{}) connection.BytesInfo = &BytesInfo{ @@ -308,6 +325,7 @@ func dialWebRTC(config *webrtc.Configuration, broker *BrokerChannel) ( connection.recvPipe, connection.writePipe = io.Pipe() go connection.ConnectLoop() + go connection.SendLoop() return connection, nil } @@ -317,8 +335,10 @@ func endWebRTC() { return } if nil != webrtcRemote.snowflake { + s := webrtcRemote.snowflake + webrtcRemote.snowflake = nil log.Printf("WebRTC: closing DataChannel") - webrtcRemote.snowflake.Close() + s.Close() } if nil != webrtcRemote.pc { log.Printf("WebRTC: closing PeerConnection") @@ -333,6 +353,7 @@ func handler(conn *pt.SocksConn) error { handlerChan <- -1 }() defer conn.Close() + log.Println("handler", conn) // TODO: [#3] Fetch ICE server information from Broker. // TODO: [#18] Consider TURN servers here too. @@ -357,6 +378,7 @@ func handler(conn *pt.SocksConn) error { } copyLoop(conn, remote) + log.Println("----END---") return nil }

1 0