Commit d93e3cb

committed

Fixed useless var.

1 parent 379b25c commit d93e3cbCopy full SHA for d93e3cb

File tree

1 file changed

+12

-14

lines changed

bin
- php-proxy-stratum-daemon.php

1 file changed

+12

-14

lines changed

`‎bin/php-proxy-stratum-daemon.php‎`

Lines changed: 12 additions & 14 deletions

Original file line number	Diff line number	Diff line change
`@@ -9,15 +9,14 @@ public function __construct() {`
`9`	`9`	`$s = new React\Socket\Server($l);`
`10`	`10`	`$s->on('connection', function ($c) use ($l) {`
`11`	`11`	`if (($o = count($this->o))<9999) {`
`12`		`- $c->l = $l;`
`13`	`12`	`$c->p = NULL;`
`14`	`13`	`$c->u = new U();`
`15`	`14`	`$this->o[$c->k=(int)$c->stream] = $c;`
`16`	`15`	`$c->on('close', function ($c) {`
`17`	`16`	`$this->k($c->k, $c, 'gone');`
`18`	`17`	`});`
`19`		`- $c->on('data', function ($d, $c) {`
`20`		`- $this->x($d, $c);`
	`18`	`+ $c->on('data', function ($d, $c) use ($l) {`
	`19`	`+ $this->x($d, $c, $l);`
`21`	`20`	`});`
`22`	`21`	`$this->l('connected, total: '.($o+1).'.');`
`23`	`22`	`} else {`
`@@ -28,10 +27,9 @@ public function __construct() {`
`28`	`27`	`$s->listen(3333, 0);`
`29`	`28`	`$w = new React\Socket\Server($l);`
`30`	`29`	`$w->on('connection', function ($c) use ($l) {`
`31`		`- $c->l = $l;`
`32`		`- $c->on('data', function ($d, $c) {`
	`30`	`+ $c->on('data', function ($d, $c) use ($l) {`
`33`	`31`	`if ($c->getRemoteAddress()=='127.0.0.1')`
`34`		`- $this->h($d, $c);`
	`32`	`+ $this->h($d, $c, $l);`
`35`	`33`	`$c->end();`
`36`	`34`	`});`
`37`	`35`	`});`
`@@ -40,7 +38,7 @@ public function __construct() {`
`40`	`38`	`$l->run();`
`41`	`39`	`}`
`42`	`40`
`43`		`- private function x($_d, $c) {`
	`41`	`+ private function x($_d, $c, $l) {`
`44`	`42`	`$_d = $c->u->d($_d);`
`45`	`43`	`if ($_d === FALSE \|\| !($d = json_decode($_d, TRUE))) $this->k($c->k, $c, 'lost');`
`46`	`44`	`else {`
`@@ -58,7 +56,7 @@ private function x($_d, $c) {`
`58`	`56`	`$c->write('{"error":null,"id":'.$d['id'].',"result":true}'."\n");`
`59`	`57`	`if (isset($d['params']) && isset($d['params'][0]) && $d['params'][0]) {`
`60`	`58`	`$c->u->u = $d['params'][0];`
`61`		`- $this->c($c);`
	`59`	`+ $this->c($l, $c);`
`62`	`60`	`} else $this->k($c->k, $c, 'unkown');`
`63`	`61`	`} else if ($c->p) {`
`64`	`62`	`if(isset($d['method']) && $d['method']=='mining.submit' && isset($d['params']) && isset($d['params'][0]) and $d['params'][0]==$c->u->P['user'])`
`@@ -70,14 +68,14 @@ private function x($_d, $c) {`
`70`	`68`	`}`
`71`	`69`	`}`
`72`	`70`
`73`		`- private function c($c, $o = 0) {`
	`71`	`+ private function c($l, $c, $o = 0) {`
`74`	`72`	`if ($c->p) $c->p->end();`
`75`	`73`	`$c->p = NULL;`
`76`	`74`	`$a = $c->u->c();`
`77`	`75`	`$c->u->P = $a[$o];`
`78`	`76`	`$n = isset($a[$o+1]) ? $o+1 : 0;`
`79`	`77`	`$x = new React\Dns\Resolver\Factory();`
`80`		`- $_c = new React\SocketClient\Connector($c->l, $x->createCached('8.8.8.8', $c->l));`
	`78`	`+ $_c = new React\SocketClient\Connector($l, $x->createCached('8.8.8.8', $l));`
`81`	`79`	`$_c->create($c->u->P['url'], $c->u->P['port'])->then(function ($s) use ($c) {`
`82`	`80`	`$c->p = $s;`
`83`	`81`	`if ($c->u->s) {`
`@@ -109,8 +107,8 @@ private function c($c, $o = 0) {`
`109`	`107`	`} else $this->k($c->k, $c, 'lost before server');`
`110`	`108`	`});`
`111`	`109`	`} else $this->k($c->k, $c, 'miss subscribe');`
`112`		`- }, function() use ($c, $n) {`
`113`		`- if ($n) $this->c($c, $n);`
	`110`	`+ }, function() use ($l, $c, $n) {`
	`111`	`+ if ($n) $this->c($l, $c, $n);`
`114`	`112`	`else $this->k($c->k, $c, 'lost pools');`
`115`	`113`	`});`
`116`	`114`	`}`
`@@ -126,7 +124,7 @@ private function k($k, $c, $m) {`
`126`	`124`	`}`
`127`	`125`	`}`
`128`	`126`
`129`		`- private function h($d, $c) {`
	`127`	`+ private function h($d, $c, $l) {`
`130`	`128`	`$r = array('result'=>NULL);`
`131`	`129`	`if (($d = json_decode($d, TRUE)) && isset($d['method']))`
`132`	`130`	`switch($d['method']) {`
`@@ -151,7 +149,7 @@ private function h($d, $c) {`
`151`	`149`	`case 'switchpool':`
`152`	`150`	`foreach($this->o as $o) {`
`153`	`151`	`if (is_null($o->u->u) \|\| $o->u->u!=$d['params'][0]) continue;`
`154`		`- $this->c($o, $d['params'][1]);`
	`152`	`+ $this->c($l, $o, $d['params'][1]);`
`155`	`153`	`}`
`156`	`154`	`break;`
`157`	`155`	`}`

0 commit comments

Comments

(0)

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit d93e3cb

File tree

1 file changed

1 file changed

`‎bin/php-proxy-stratum-daemon.php‎`

0 commit comments