Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -97,16 +97,16 @@ public synchronized InputStreamToReadStream handler(Handler<Buffer> handler) {
}

class ReadResult {
int readed;
int read;

byte[] bytes = new byte[readBufferSize];

void doRead() throws IOException {
readed = inputStream.read(bytes);
read = inputStream.read(bytes);
}

Buffer toBuffer() {
return Buffer.buffer(Unpooled.wrappedBuffer(bytes).writerIndex(readed));
return Buffer.buffer(Unpooled.wrappedBuffer(bytes).writerIndex(read));
}
}

Expand Down Expand Up @@ -143,7 +143,7 @@ private synchronized void afterReadInEventloop(AsyncResult<ReadResult> ar) {

readInProgress = false;
ReadResult readResult = ar.result();
if (readResult.readed < 0) {
if (readResult.read < 0) {
handleEnd();
return;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ public boolean isLimitNewRequest() {
msCycleBegin = msNow;
}

// Configuration update and use is at the situation of multi-threaded concurrency
// Configuration update and use is at the situation of multi-thread concurrency
// It is possible that operation level updated to null,but schema level or microservice level does not updated
boolean isLimitRequest = newCount - lastRequestCount >= this.getQpsLimit();
if (isLimitRequest){
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ public class SwaggerEnvironment {
public SwaggerConsumer createConsumer(Class<?> consumerIntf, OpenAPI swagger) {
swagger = checkAndGenerateSwagger(consumerIntf, swagger);

Map<Class<?>, ContextArgumentMapperFactory> contextFactorys = SPIServiceUtils
Map<Class<?>, ContextArgumentMapperFactory> contextFactories = SPIServiceUtils
.getOrLoadSortedService(ConsumerContextArgumentMapperFactory.class)
.stream()
.collect(Collectors.toMap(ConsumerContextArgumentMapperFactory::getContextClass, Function.identity()));
Expand All @@ -79,7 +79,7 @@ public SwaggerConsumer createConsumer(Class<?> consumerIntf, OpenAPI swagger) {

ConsumerArgumentsMapperCreator creator = new ConsumerArgumentsMapperCreator(
Json.mapper().getSerializationConfig(),
contextFactorys,
contextFactories,
consumerIntf,
consumerMethod,
swaggerOperation);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ public abstract class AbstractArgumentsMapperCreator {
protected SerializationConfig serializationConfig;

// key is context class
protected Map<Class<?>, ContextArgumentMapperFactory> contextFactorys;
protected Map<Class<?>, ContextArgumentMapperFactory> contextFactories;

// consumer or producer
protected Method providerMethod;
Expand All @@ -117,10 +117,10 @@ public abstract class AbstractArgumentsMapperCreator {
protected Set<String> processedSwaggerParameters;

public AbstractArgumentsMapperCreator(SerializationConfig serializationConfig,
Map<Class<?>, ContextArgumentMapperFactory> contextFactorys, Class<?> providerClass,
Map<Class<?>, ContextArgumentMapperFactory> contextFactories, Class<?> providerClass,
Method providerMethod, SwaggerOperation swaggerOperation) {
this.serializationConfig = serializationConfig;
this.contextFactorys = contextFactorys;
this.contextFactories = contextFactories;
this.providerClass = providerClass;
this.providerMethod = providerMethod;
this.swaggerOperation = swaggerOperation;
Expand Down Expand Up @@ -198,7 +198,7 @@ protected void doCreateArgumentsMapper() {
* @return true means processed
*/
protected boolean processContextParameter(java.lang.reflect.Parameter providerParameter) {
ContextArgumentMapperFactory contextFactory = contextFactorys.get(providerParameter.getType());
ContextArgumentMapperFactory contextFactory = contextFactories.get(providerParameter.getType());
if (contextFactory == null) {
return false;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,9 +47,9 @@ public class ConsumerArgumentsMapperCreator extends AbstractArgumentsMapperCreat
private int unknownConsumerParams = 0;

public ConsumerArgumentsMapperCreator(SerializationConfig serializationConfig,
Map<Class<?>, ContextArgumentMapperFactory> contextFactorys, Class<?> consumerClass,
Map<Class<?>, ContextArgumentMapperFactory> contextFactories, Class<?> consumerClass,
Method consumerMethod, SwaggerOperation swaggerOperation) {
super(serializationConfig, contextFactorys, consumerClass, consumerMethod, swaggerOperation);
super(serializationConfig, contextFactories, consumerClass, consumerMethod, swaggerOperation);
}

private boolean isAllSameMapper() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -49,9 +49,9 @@ public class ProducerArgumentsMapperCreator extends AbstractArgumentsMapperCreat
private final Map<String, Type> swaggerParameterTypes;

public ProducerArgumentsMapperCreator(SerializationConfig serializationConfig,
Map<Class<?>, ContextArgumentMapperFactory> contextFactorys, Class<?> producerClass,
Map<Class<?>, ContextArgumentMapperFactory> contextFactories, Class<?> producerClass,
Method producerMethod, SwaggerOperation swaggerOperation) {
super(serializationConfig, contextFactorys, producerClass, producerMethod, swaggerOperation);
super(serializationConfig, contextFactories, producerClass, producerMethod, swaggerOperation);

swaggerParameterTypes = new HashMap<>();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,5 +25,5 @@ default int getOrder() {

boolean isMatch(Type providerType);

MAPPER createResponseMapper(ResponseMapperFactories<MAPPER> factorys, Type providerType);
MAPPER createResponseMapper(ResponseMapperFactories<MAPPER> factories, Type providerType);
}
Original file line number Diff line number Diff line change
Expand Up @@ -33,9 +33,9 @@ public boolean isMatch(Type consumerType) {
}

@Override
public ConsumerResponseMapper createResponseMapper(ResponseMapperFactories<ConsumerResponseMapper> factorys,
public ConsumerResponseMapper createResponseMapper(ResponseMapperFactories<ConsumerResponseMapper> factories,
Type consumerType) {
Type realConsumerType = ((ParameterizedType) consumerType).getActualTypeArguments()[0];
return factorys.createResponseMapper(realConsumerType);
return factories.createResponseMapper(realConsumerType);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ public boolean isMatch(Type consumerType) {
}

@Override
public ConsumerResponseMapper createResponseMapper(ResponseMapperFactories<ConsumerResponseMapper> factorys,
public ConsumerResponseMapper createResponseMapper(ResponseMapperFactories<ConsumerResponseMapper> factories,
Type consumerType) {
return SAME;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ public boolean isMatch(Type consumerType) {
}

@Override
public ConsumerResponseMapper createResponseMapper(ResponseMapperFactories<ConsumerResponseMapper> factorys,
public ConsumerResponseMapper createResponseMapper(ResponseMapperFactories<ConsumerResponseMapper> factories,
Type consumerType) {
return new DefaultConsumerResponseMapper();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,10 +33,10 @@ public boolean isMatch(Type consumerType) {
}

@Override
public ConsumerResponseMapper createResponseMapper(ResponseMapperFactories<ConsumerResponseMapper> factorys,
public ConsumerResponseMapper createResponseMapper(ResponseMapperFactories<ConsumerResponseMapper> factories,
Type consumerType) {
Type realConsumerType = ((ParameterizedType) consumerType).getActualTypeArguments()[0];
ConsumerResponseMapper realMapper = factorys.createResponseMapper(realConsumerType);
ConsumerResponseMapper realMapper = factories.createResponseMapper(realConsumerType);
return new OptionalConsumerResponseMapper(realMapper);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -33,9 +33,9 @@ public boolean isMatch(Type producerType) {
}

@Override
public ProducerResponseMapper createResponseMapper(ResponseMapperFactories<ProducerResponseMapper> factorys,
public ProducerResponseMapper createResponseMapper(ResponseMapperFactories<ProducerResponseMapper> factories,
Type producerType) {
Type realProducerType = ((ParameterizedType) producerType).getActualTypeArguments()[0];
return factorys.createResponseMapper(realProducerType);
return factories.createResponseMapper(realProducerType);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ public boolean isMatch(Type producerType) {
}

@Override
public ProducerResponseMapper createResponseMapper(ResponseMapperFactories<ProducerResponseMapper> factorys,
public ProducerResponseMapper createResponseMapper(ResponseMapperFactories<ProducerResponseMapper> factories,
Type producerType) {
return SAME;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ public boolean isMatch(Type producerType) {
}

@Override
public ProducerResponseMapper createResponseMapper(ResponseMapperFactories<ProducerResponseMapper> factorys,
public ProducerResponseMapper createResponseMapper(ResponseMapperFactories<ProducerResponseMapper> factories,
Type producerType) {
return new DefaultProducerResponseMapper();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,10 +33,10 @@ public boolean isMatch(Type producerType) {
}

@Override
public ProducerResponseMapper createResponseMapper(ResponseMapperFactories<ProducerResponseMapper> factorys,
public ProducerResponseMapper createResponseMapper(ResponseMapperFactories<ProducerResponseMapper> factories,
Type producerType) {
Type realProducerType = ((ParameterizedType) producerType).getActualTypeArguments()[0];
ProducerResponseMapper realMapper = factorys.createResponseMapper(realProducerType);
ProducerResponseMapper realMapper = factories.createResponseMapper(realProducerType);
return new OptionalProducerResponseMapper(realMapper);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ public boolean isMatch(Type consumerType) {
}

@Override
public ConsumerResponseMapper createResponseMapper(ResponseMapperFactories<ConsumerResponseMapper> factorys,
public ConsumerResponseMapper createResponseMapper(ResponseMapperFactories<ConsumerResponseMapper> factories,
Type consumerType) {
return new JaxrsConsumerResponseMapper();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ public boolean isMatch(Type producerType) {
}

@Override
public ProducerResponseMapper createResponseMapper(ResponseMapperFactories<ProducerResponseMapper> factorys,
public ProducerResponseMapper createResponseMapper(ResponseMapperFactories<ProducerResponseMapper> factories,
Type producerType) {
return new JaxrsProducerResponseMapper();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,10 +35,10 @@ public boolean isMatch(Type consumerType) {
}

@Override
public ConsumerResponseMapper createResponseMapper(ResponseMapperFactories<ConsumerResponseMapper> factorys,
public ConsumerResponseMapper createResponseMapper(ResponseMapperFactories<ConsumerResponseMapper> factories,
Type consumerType) {
Type realConsumerType = ((ParameterizedType) consumerType).getActualTypeArguments()[0];
ConsumerResponseMapper realMapper = factorys.createResponseMapper(realConsumerType);
ConsumerResponseMapper realMapper = factories.createResponseMapper(realConsumerType);
return new SpringmvcConsumerResponseMapper(realMapper);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -35,10 +35,10 @@ public boolean isMatch(Type producerType) {
}

@Override
public ProducerResponseMapper createResponseMapper(ResponseMapperFactories<ProducerResponseMapper> factorys,
public ProducerResponseMapper createResponseMapper(ResponseMapperFactories<ProducerResponseMapper> factories,
Type producerType) {
Type realProducerType = ((ParameterizedType) producerType).getActualTypeArguments()[0];
ProducerResponseMapper realMapper = factorys.createResponseMapper(realProducerType);
ProducerResponseMapper realMapper = factories.createResponseMapper(realProducerType);
return new SpringmvcProducerResponseMapper(realMapper);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ Response mapResponse(StatusType status, Object response) {

@SuppressWarnings("unchecked")
@Test
public void mapResponse_withoutHeader_sucess() {
public void mapResponse_withoutHeader_success() {
ResponseEntity<String[]> responseEntity =
new ResponseEntity<>(arrResult, org.springframework.http.HttpStatus.OK);
Response response = mapper.mapResponse(null, responseEntity);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@
public class TestSpringmvcProducerResponseMapperFactory {
SpringmvcProducerResponseMapperFactory factory = new SpringmvcProducerResponseMapperFactory();

ResponseMapperFactories<ProducerResponseMapper> factorys = new ResponseMapperFactories<>(
ResponseMapperFactories<ProducerResponseMapper> factories = new ResponseMapperFactories<>(
ProducerResponseMapperFactory.class);

public ResponseEntity<String[]> responseEntity() {
Expand Down Expand Up @@ -67,7 +67,7 @@ public void createResponseMapper() {
Method responseEntityMethod = ReflectUtils.findMethod(this.getClass(), "responseEntity");

ProducerResponseMapper mapper = factory
.createResponseMapper(factorys, responseEntityMethod.getGenericReturnType());
.createResponseMapper(factories, responseEntityMethod.getGenericReturnType());
MatcherAssert.assertThat(mapper, Matchers.instanceOf(SpringmvcProducerResponseMapper.class));

ResponseEntity<String[]> responseEntity = new ResponseEntity<>(new String[] {"a", "b"}, HttpStatus.OK);
Expand Down
Loading