<commit_before>package com.ociweb.iot.hardware.impl;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.ociweb.gl.api.MsgRuntime;
import com.ociweb.gl.impl.schema.TrafficAckSchema;
import com.ociweb.gl.impl.schema.TrafficReleaseSchema;
import com.ociweb.gl.impl.stage.AbstractTrafficOrderedStage;
import com.ociweb.iot.hardware.HardwareImpl;
import com.ociweb.pronghorn.iot.rs232.RS232Clientable;
import com.ociweb.pronghorn.pipe.Pipe;
import com.ociweb.pronghorn.pipe.PipeReader;
import com.ociweb.pronghorn.stage.scheduling.GraphManager;



public class SerialDataWriterStage extends AbstractTrafficOrderedStage {

	private Pipe<SerialOutputSchema>[] fromCommandChannels;
	private RS232Clientable rs232Client;
	private static final Logger logger = LoggerFactory.getLogger(SerialDataWriterStage.class);
	private byte[] backing;
	private int length;
	private int mask;
	private int pos;
	private int pipeIdx = -1;

	public SerialDataWriterStage(GraphManager graphManager,
			MsgRuntime<?,?> runtime,
			Pipe<SerialOutputSchema>[] ccToAdOut, //many stages requesting writes
			Pipe<TrafficReleaseSchema>[] goPipe, //traffic releases for each
			Pipe<TrafficAckSchema>[] ackPipe, 
			HardwareImpl hardware, RS232Clientable rs232Client) {
		
		super(graphManager, runtime, hardware, ccToAdOut, goPipe, ackPipe);
		
		assert(noNulls(ccToAdOut));
		assert(noNulls(goPipe));
	    assert(noNulls(ackPipe));
	       <commit_msg>remove not required null check<commit_after>package com.ociweb.iot.hardware.impl;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.ociweb.gl.api.MsgRuntime;
import com.ociweb.gl.impl.schema.TrafficAckSchema;
import com.ociweb.gl.impl.schema.TrafficReleaseSchema;
import com.ociweb.gl.impl.stage.AbstractTrafficOrderedStage;
import com.ociweb.iot.hardware.HardwareImpl;
import com.ociweb.pronghorn.iot.rs232.RS232Clientable;
import com.ociweb.pronghorn.pipe.Pipe;
import com.ociweb.pronghorn.pipe.PipeReader;
import com.ociweb.pronghorn.stage.scheduling.GraphManager;



public class SerialDataWriterStage extends AbstractTrafficOrderedStage {

	private Pipe<SerialOutputSchema>[] fromCommandChannels;
	private RS232Clientable rs232Client;
	private static final Logger logger = LoggerFactory.getLogger(SerialDataWriterStage.class);
	private byte[] backing;
	private int length;
	private int mask;
	private int pos;
	private int pipeIdx = -1;

	public SerialDataWriterStage(GraphManager graphManager,
			MsgRuntime<?,?> runtime,
			Pipe<SerialOutputSchema>[] ccToAdOut, //many stages requesting writes
			Pipe<TrafficReleaseSchema>[] goPipe, //traffic releases for each
			Pipe<TrafficAckSchema>[] ackPipe, 
			HardwareImpl hardware, RS232Clientable rs232Client) {
		
		super(graphManager, runtime, hardware, ccToAdOut, goPipe, ackPipe);
		
		assert(noNulls(ccToAdOut));
	       
{'fraction_non_alphanumeric': 0.09446598519562918, 'fraction_numerical': 0.014804370814240395, 'mean_word_length': 5.955882352941177, 'pattern_counts': {'":': 0, '<': 13, '<?xml version=': 0, '>': 13, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '6441064', 'n_tokens_mistral': 993, 'n_tokens_neox': 912, 'n_words': 180}