luxlabs header browser preview


@class NSString, SiriCorePingInfo, NSMutableDictionary, NSObject, SiriCoreDataCompressor, SiriCoreDataDecompressor, NSMutableArray, SiriCoreSiriConnectionInfo;
@protocol OS_dispatch_data, SiriCoreSiriBackgroundConnectionDelegate, OS_dispatch_source, OS_dispatch_queue, SiriCoreConnectionProvider;

@interface SiriCoreSiriBackgroundConnection : NSObject <SiriCoreConnectionProviderDelegate> {
    NSObject<OS_dispatch_queue> *_queue;
    id<SiriCoreConnectionProvider> _connectionProvider;
    SiriCoreSiriConnectionInfo *_connectionInfo;
    NSObject<OS_dispatch_data> *_bufferedInputData;
    NSObject<OS_dispatch_data> *_bufferedProviderHeaderOutputData;
    NSObject<OS_dispatch_data> *_bufferedGeneralOutputData;
    NSObject<OS_dispatch_data> *_bufferedUncompressedData;
    SiriCoreDataDecompressor *_inputDecompressor;
    SiriCoreDataCompressor *_outputCompressor;
    struct __CFHTTPMessage { } *_httpResponseHeader;
    BOOL _isOpened;
    BOOL _isCanceled;
    BOOL _hasReportedError;
    NSMutableDictionary *_errorsForConnectionMethods;
    NSObject<OS_dispatch_source> *_aceHeaderTimerSource;
    unsigned long long _aceHeaderTimerFireCount;
    NSObject<OS_dispatch_source> *_pingTimerSource;
    unsigned int _currentPingIndex;
    SiriCorePingInfo *_pingInfo;
    unsigned long long _lastInputLength;
    void *_lastInputDataPointer;
    unsigned long long _inputLengthUnchangedCounter;
    unsigned long long _lastOutputLength;
    void *_lastOutputDataPointer;
    unsigned long long _outputLengthUnchangedCounter;
    unsigned int _currentBarrierIndex;
    NSMutableDictionary *_outstandingBarriers;
    long long _connectionMethod;
    NSObject<OS_dispatch_data> *_safetyNetBuffer;
    NSObject<OS_dispatch_queue> *_metricsQueue;
    double _firstStartTime;
    double _currentStartTime;
    double _currentOpenTime;
    double _firstByteReadTime;
    unsigned long long _startCount;
    unsigned long long _metricsCount;
    NSMutableArray *_outgoingCommandsWithSendCompletions;
    BOOL _primaryConnectionViable;
    BOOL _betterPathAvailable;
    long long _secondaryConnectionOpenState;
    id<SiriCoreConnectionProvider> _secondaryConnectionProvider;
    BOOL _dispatchedSnapshotMetrics;
    double _receivedDataTime;
}

@property (weak, nonatomic) id<SiriCoreSiriBackgroundConnectionDelegate> delegate;
@property (copy, nonatomic) NSString *peerType;
@property (copy, nonatomic) NSString *peerVersion;
@property (copy, nonatomic) NSString *productTypePrefix;
@property (retain, nonatomic) Class peerProviderClass;
@property (nonatomic) BOOL usesProxyConnection;
@property (nonatomic) BOOL deviceIsInWalkaboutExperimentGroup;
@property (nonatomic) BOOL siriConnectionUsesPeerManagedSync;
@property (readonly) unsigned long long hash;
@property (readonly) Class superclass;
@property (readonly, copy) NSString *description;
@property (readonly, copy) NSString *debugDescription;

- (id)initWithQueue:(id)a0;
- (id)init;
- (void)dealloc;
- (void)_closeConnection;
- (void)barrier:(id /* block */)a0;
- (void).cxx_destruct;
- (void)cancel;
- (BOOL)_usingNetwork;
- (id)_connectionType;
- (void)probeConnection;
- (Class)_providerClass;
- (void)_handleAcePong:(unsigned int)a0;
- (void)_handleAcePing:(unsigned int)a0;
- (id)_httpHeaderData;
- (void)_pingTimerFired;
- (BOOL)_usingPOPOnPeer;
- (id)_aceHeaderData;
- (void)_aceHeaderTimeoutFired:(id)a0 afterTimeout:(double)a1;
- (id)_bestErrorBetweenError:(id)a0 peerError:(id)a1;
- (void)_bufferGeneralData:(id)a0;
- (BOOL)_canFallBackFromError:(id)a0;
- (void)_cancelOutstandingBarriers;
- (void)_cancelSecondaryConnection;
- (long long)_checkForProgressOnReadingData;
- (long long)_checkPings;
- (void)_closeConnectionAndPrepareForReconnect:(BOOL)a0;
- (void)_connectionHasBytesAvailable:(id)a0;
- (id)_connectionMethodDescription;
- (BOOL)_consumeAceDataWithData:(id)a0 bytesRead:(unsigned long long *)a1 error:(id *)a2;
- (BOOL)_consumeAceHeaderWithData:(id)a0 bytesRead:(unsigned long long *)a1 error:(id *)a2;
- (BOOL)_consumeHTTPHeaderWithData:(id)a0 bytesRead:(unsigned long long *)a1 error:(id *)a2;
- (void)_didEncounterError:(id)a0;
- (void)_fallBackToNextConnectionMethod:(long long)a0 fromError:(id)a1 afterDelay:(double)a2;
- (void)_fallBackToNextConnectionMethodWithError:(id)a0 orElse:(id /* block */)a1;
- (void)_forceTriggerRetry;
- (void)_getCellularMetrics:(id)a0;
- (id)_getInitialPayloadWithBufferedLength:(unsigned long long *)a0 forceReconnect:(BOOL)a1;
- (void)_getWifiMetrics:(id)a0;
- (void)_handleAceEnd;
- (void)_handleAceNop;
- (void)_handleAceObject:(id)a0;
- (void)_handleBarrierReply:(unsigned int)a0;
- (void)_handlePacket:(struct { unsigned char x0; unsigned int x1; } *)a0;
- (BOOL)_hasBufferedDataOrOutstandingPings;
- (BOOL)_hasReadACEHeader;
- (BOOL)_hasReadHTTPHeader;
- (id)_headerDataForURL:(id)a0 aceHost:(id)a1 languageCode:(id)a2 syncAssistantId:(id)a3;
- (void)_initializeBufferedGeneralOutputDataWithInitialPayload:(BOOL)a0;
- (void)_networkProviderDidOpen;
- (long long)_nextConnectionMethod;
- (long long)_normalizeSNR:(long long)a0;
- (void)_prepareProviderHeaderWithForceReconnect:(BOOL)a0;
- (void)_resumePingTimer;
- (void)_scheduleAceHeaderTimeoutTimerWithInterval:(double)a0;
- (BOOL)_sendAcePingWithId:(unsigned int)a0 error:(id *)a1;
- (BOOL)_sendAcePongWithId:(unsigned int)a0 error:(id *)a1;
- (void)_sendGeneralData:(id)a0;
- (void)_setNetworkProvider:(id)a0;
- (void)_setupReadHandlerOnProvider;
- (BOOL)_shouldTrySameConnectionMethodForMethod:(long long)a0 error:(id)a1;
- (void)_startNetworkProviderWithInfo:(id)a0;
- (void)_startSecondaryConnection;
- (void)_startWithConnectionInfo:(id)a0 proposedFallbackMethod:(long long)a1 allowFallbackToNewMethod:(BOOL)a2;
- (BOOL)_tcpInfoIndicatesPoorLinkQuality;
- (BOOL)_tryParsingHTTPHeaderData:(id)a0 partialMessage:(struct __CFHTTPMessage { } *)a1 statusCode:(long long *)a2 bytesRead:(unsigned long long *)a3 error:(id *)a4;
- (id)_tryReadingAceHeaderFromData:(id)a0 bytesParsed:(unsigned long long *)a1 error:(id *)a2;
- (BOOL)_tryReadingHTTPHeaderData:(id)a0 withMessage:(struct __CFHTTPMessage { } *)a1 bytesRead:(unsigned long long *)a2 error:(id *)a3;
- (BOOL)_tryReadingParsedDataFromBytes:(const void *)a0 length:(unsigned long long)a1 packet:(struct { unsigned char x0; unsigned int x1; } *)a2 object:(id *)a3 bytesParsed:(unsigned long long *)a4 error:(id *)a5;
- (void)_tryToWriteBufferedOutputData;
- (void)_updateBuffersForInitialPayload:(id)a0 bufferedLength:(unsigned long long)a1 forceReconnect:(BOOL)a2;
- (BOOL)_usingFlorence;
- (BOOL)_usingPOP;
- (BOOL)_usingPeer;
- (BOOL)_wifiOrCellularMayBeBetterThanCurrentStream;
- (id)analysisInfo;
- (void)connectionProvider:(id)a0 receivedError:(id)a1;
- (void)connectionProvider:(id)a0 receivedViabilityChangeNotification:(BOOL)a1;
- (void)connectionProviderReceivedBetterRouteNotification:(id)a0;
- (id)getConnectionMethodUsed;
- (void)getConnectionMetrics:(id)a0 withCompletion:(id /* block */)a1;
- (void)sendCommand:(id)a0 moreComing:(BOOL)a1 errorHandler:(id /* block */)a2;
- (void)sendCommands:(id)a0 errorHandler:(id /* block */)a1;
- (void)setSendPings:(BOOL)a0;
- (void)startHeartBeat;
- (void)startWithConnectionInfo:(id)a0;
- (void)stopHeartBeat;
- (void)updateActiveBackgroundConnectionWithSecondary;

@end