import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
private void writeJsonLd(final OutputStream output, final DatasetGraph graph, final IRI... profiles) {
    final String profile = getCustomJsonLdProfile(profiles);
    final RDFFormat format = nonNull(profile) && nonNull(cache) ? JSONLD_COMPACT_FLAT : getJsonLdProfile(profiles);
    final WriterDatasetRIOT writer = RDFDataMgr.createDatasetWriter(format);
    final PrefixMap pm = RiotLib.prefixMap(graph);
    final String base = null;
    final JsonLDWriteContext ctx = new JsonLDWriteContext();
    if (nonNull(profile) && nonNull(cache)) {
        LOGGER.debug("Setting JSON-LD context with profile: {}", profile);
        final String c = cache.get(profile, p -> {
            try (final TypedInputStream res = HttpOp.execHttpGet(profile)) {
                return IOUtils.toString(res.getInputStream(), UTF_8);
            } catch (final IOException | HttpException ex) {
                LOGGER.warn("Error fetching profile {}: {}", p, ex.getMessage());
                return null;
            }
        });
        if (nonNull(c)) {
            ctx.setJsonLDContext(c);
            ctx.setJsonLDContextSubstitution("\"" + profile + "\"");
        }
    }
    writer.write(output, graph, pm, base, ctx);
}
 

import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
@Override
public UpdateRun call() throws Exception {
    UpdateRequest update = this.getUpdate();
    logger.debug("Running update:\n" + update.toString());

    // Create a remote update processor and configure it appropriately
    UpdateProcessor processor = this.createUpdateProcessor(update);
    this.customizeRequest(processor);

    long startTime = System.nanoTime();
    try {
        // Execute the update
        processor.execute();
    } catch (HttpException e) {
        // Make sure to categorize HTTP errors appropriately
        logger.error("{}", FormatUtils.formatException(e));
        return new UpdateRun(e.getMessage(), ErrorCategories.categorizeHttpError(e), System.nanoTime() - startTime);
    }

    if (this.isCancelled())
        return null;

    long endTime = System.nanoTime();
    return new UpdateRun(endTime - startTime);
}
 

import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
@Override
protected void exec() {
    try { 
        dLink.register(clientId) ;
        try { execCmd() ; }
        finally {
            //if ( dLink.isRegistered() )
                dLink.deregister();
        }
    }
    catch (HttpException ex) { throw new CmdException(messageFromHttpException(ex)) ; }
}
 

import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
@Override
public void handle(Patch patch) { 
    IndentedLineBuffer x = new IndentedLineBuffer() ;
    RDFChanges scData = new RDFChangesWriteUpdate(x) ;
    patch.play(scData);
    x.flush();
    String reqStr = x.asString() ;
    updateEndpoints.forEach((ep)->{
        try { HttpOp.execHttpPost(ep, WebContent.contentTypeSPARQLUpdate, reqStr) ; }
        catch (HttpException ex) { DPS.LOG.warn("Failed to send to "+ep) ; }
    }) ;
}
 

import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
/** Actively ping the server */
/*package*/ boolean ping() {
    try {
        getDLink().ping();
        return true ;
    } catch (HttpException ex) { return false ; }
}
 

import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
/** Run an action that contacts the patch log server.
 * Return true if the action succeeded. 
 * @param action
 * @return
 */
/*package*/ boolean exec(Consumer<DeltaLink> action) {
    if ( !connected() )
        return false;
    try {
        action.accept(getDLink());
        return true;
    } catch (HttpException ex) {
        // Registered?
        handleHttpException(ex);
        return false;
    }
}
 

import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
private void handleHttpException(HttpException ex) {
    if ( isConnectionProblem(ex) ) {
        LOG.info("Failed to connect to "+serverURL+" : "+ex.getMessage());
    } else {
        LOG.info("Unrecognized patchlog action problem: "+ex.getMessage(), ex);
    }
    // Broken.
    deltaLink.set(null);
}
 

import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
private boolean isConnectionProblem(HttpException ex) {
    if ( ex instanceof HttpNotConnectedException ) 
        return true;
    
    if ( ex.getResponseCode() > 0 )
        // Some HTTP status code -> network worked   
        return false;
    if ( ex.getCause() instanceof ConnectException /*IOException*/ )
        return true;
    if ( ex.getCause() instanceof IOException )
        return true;
    LOG.warn("Unrecognized exception: "+ex.getMessage(), ex);
    return true;
    // Unknown.
}
 

import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
@Test
public void patchserver_stop_start() {
    PatchLogServer patchLogServer = patchLogServer();
    FusekiServer server1 = fuseki1();
    try { 
        patchLogServer.stop();
        patchLogServer = null;
        
        // Should fail
        try {
            RDFConnection conn0 = RDFConnectionFactory.connect("http://localhost:"+F1_PORT+ds1) ;
            conn0.update(PREFIX+"INSERT DATA { :s :p 'update_patchserver_stop_start' }");
            Assert.fail("Should not be able to update at the moment");
        } catch (HttpException ex) {
            assertEquals(503, ex.getResponseCode());
        }
        
        patchLogServer = patchLogServer(); 

        RDFConnection conn1 = RDFConnectionFactory.connect("http://localhost:"+F1_PORT+ds1) ;
        QueryExecution qExec = conn1.query("ASK{}");
        // 500 due to offline patchLogServer.
        qExec.execAsk();
    } finally {
        server1.stop();
        if ( patchLogServer != null )
            patchLogServer.stop();
    }
}
 

import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
/** Perform a retryable operation. Retry only happen if HttpException happens. */
private <T> T retry(Action<T> callable, Supplier<Boolean> retryable, Supplier<String> retryMsg, Supplier<String> failureMsg) {
    for ( int i = 1 ; ; i++ ) {
        try {
            return callable.action();
        } catch (HttpException ex) {
            if ( ex.getResponseCode() == HttpSC.UNAUTHORIZED_401 ) {
                if ( retryable.get() && i < RETRIES_REGISTRATION ) {
                    if ( retryMsg != null  )
                        Delta.DELTA_HTTP_LOG.warn(retryMsg.get());
                    reregister();
                    // Retry.
                    continue;
                }
                if ( failureMsg != null )
                    throw new DeltaNotRegisteredException(failureMsg.get());
                else
                    throw new DeltaNotRegisteredException(ex.getMessage());
            }
            if ( failureMsg != null )
                // Other...
                Delta.DELTA_HTTP_LOG.warn(failureMsg.get());
            throw ex;
        }
        // Any tother exception - don't retry.
    }
}
 

import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
private RDFPatch fetchCommon(Id dsRef, String param, Object value, String valueLogStr) {
    checkLink();
    
    String url = remoteReceive;
    url = createURL(url, DeltaConst.paramDatasource, dsRef.asParam());
    url = appendURL(url, value.toString());
    url = addToken(url);
    final String s = url;
    FmtLog.info(Delta.DELTA_HTTP_LOG, "Fetch request: %s %s=%s [%s]", dsRef, param, valueLogStr, url);
    try { 
        return retry(()->{
            // [NET] Network point
            InputStream in = HttpOp.execHttpGet(s) ;
            if ( in == null )
                return null ;
            RDFPatchReaderText pr = new RDFPatchReaderText(in) ;
            RDFChangesCollector collector = new RDFChangesCollector();
            pr.apply(collector);
            return collector.getRDFPatch();
        }, ()->true, ()->"Retry fetch patch.", ()->"Failed to fetch patch.");
    }
    catch ( HttpException ex) {
        if ( ex.getResponseCode() == HttpSC.NOT_FOUND_404 )
            return null ; //throw new DeltaNotFoundException(ex.getMessage());
        throw ex;
    }
}
 

import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
public void sync() {
    try { 
        checkDeltaConnection();
        PatchLogInfo logInfo = getPatchLogInfo();
        sync(logInfo);
    } catch (HttpException ex) {
        if ( ex.getResponseCode() == -1 )
            throw new HttpException(HttpSC.SERVICE_UNAVAILABLE_503, HttpSC.getMessage(HttpSC.SERVICE_UNAVAILABLE_503), ex.getMessage());
        throw ex;
    }
}
 

import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
@Override
public Response toResponse(HttpException ex)
{
    return com.atomgraph.core.model.impl.Response.fromRequest(getRequest()).
            getResponseBuilder(toResource(ex, Response.Status.INTERNAL_SERVER_ERROR,
                    ResourceFactory.createResource("http://www.w3.org/2011/http-statusCodes#InternalServerError")).
                getModel(), getVariants()).
            status(Response.Status.INTERNAL_SERVER_ERROR).
            build();
}
 

import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
@Override
public Boolean call() throws Exception {
	final String ns = ModelFactory.createDefaultModel().createResource(uri).getNameSpace();
	if (ns404.contains(ns)) return false;
	
	try{
		return (RDFDataMgr.loadModel(uri).size() > 0);
	} catch (HttpException httpE){
		if (httpE.getResponseCode() == 404) ns404.add(ns);
		return false;
	} catch (Exception e){
		return false;
	}
}
 

import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
@Override
public Boolean call() throws Exception {
	final String ns = ResourceBaseURIOracle.extractNameSpace(uri);
	if (ns404.contains(ns)) return false;
	
	try{
		return (RDFDataMgr.loadModel(uri).size() > 0);
	} catch (HttpException httpE){
		if (httpE.getResponseCode() == 404) ns404.add(ns);
		return false;
	} catch (Exception e){
		return false;
	}
}
 

import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
protected String messageFromHttpException(HttpException ex) {
    Throwable ex2 = ex;
    if ( ex.getCause() != null )
        ex2 = ex.getCause();
    return ex2.getMessage();
}
 

import org.apache.jena.atlas.web.HttpException; //导入依赖的package包/类
/**
 * Categorizes a {@link HttpException}
 * <p>
 * Where possible this will use specific error categories such as
 * {@link #AUTHENTICATION} or {@link #HTTP_NOT_FOUND} however many possible
 * HTTP status codes are not specifically categorized and will be bucketed
 * into {@link #HTTP_CLIENT_ERROR} or {@link #HTTP_SERVER_ERROR} as
 * appropriate.
 * </p>
 * 
 * @param httpError
 *            HTTP error
 * @return Most appropriate error category
 */
public static int categorizeHttpError(HttpException httpError) {
    int status = httpError.getResponseCode();
    return categorizeHttpError(status);
}