… this was suppose to be the size of the object returned in the stream.
Fixed inconsistent braces, mixed indentation, invalid comment chars (# is not valid for PHP); Switched raw var_dump to proper log output; Other minor cleanups;
…ia http (rather than https in the super class since c299dfa). My app was refusing to authenticate against the API and making this change fixed it for me...
…lect move to github;
…BACKOFF and HTTP_BACKOFF with the class members)
Stop giving lastAverage to statusUpdate() (the base class implementation does not use it, and it is very unlikely a derived version would want it) Minor change in base class version of statusUpdate: it now shows actual number of seconds since previous call, rather than number of seconds it should have been. Change heartbeat function to not take parameters, and instead use member variables.
These variables changed from being local vars in consume() to being protected class vars: statusCount, filterCheckCount, enqueueSpent, filterCheckSpent, idlePeriod, maxIdlePeriod They are initialized to zero on object construction, not in call to consume() (may affect scripts that call consume() more than once in their lifetime; but only if they were already overriding statusUpdate(), as the default version resets them every 60 seconds anyway.) Stopped checking return value of enqueueStatus(), as it is not documented anywhere that is supposed to return true, no examples show it, and nothing useful happens if true is not returned. Added $enqueueTimeMS and $filterCheckTimeMS as class vars, and therefore removed having them calculated as local vars in the default statusUpdate() function. NOTE: heartbeat not supported yet (next commit will do that)
Extract statusUpdate() out of the consume() function. Bug fix: Change query encoding from RFC1738 to RFC3986 Changed these class constants into class member vars: USER_AGENT FILTER_CHECK_MIN FILTER_UPD_MIN TCP_BACKOFF TCP_BACKOFF_MAX HTTP_BACKOFF HTTP_BACKOFF_MAX
…m/p/phirehose/issues/detail?id=1) * Bugfix: HTTP 406 if arg_separator.output is '&' (resolves http://code.google.com/p/phirehose/issues/detail?id=2) * Throw PhirehoseException, PhirehoseNetworkException, PhirehoseConnectLimitExceeded exception classes * Added support for a Phirehose::heartbeat() method to enable Phirehose status logging and reporting * Removed stray line-end whitespace
…ted by Toby P) - Fixed bug where hang could occur after reconnect to quiet streams (reported by Toby P) - Cleaned up connect() state initialization to reliably reconnect git-svn-id: http://phirehose.googlecode.com/svn/trunk@28 66cfb602-a329-11de-bb10-370f7287a6b7
- Implemented stream idle timeouts (reconnects if streams die) - Implemented per-connection DNS lookups - Fixed bug where you could get caught in reconnect loop if invalid filter predicates specified - Added getLastErrorMsg() and getLastErrorNo() methods (to deal with above) - Improved logging git-svn-id: http://phirehose.googlecode.com/svn/trunk@27 66cfb602-a329-11de-bb10-370f7287a6b7