Contents

package com.game_machine.core;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.SocketTimeoutException;
import java.util.Arrays;

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

public class UdpClient {

	private static final Logger log = LoggerFactory.getLogger(UdpClient.class);
	private int port;
	private InetAddress hostAddress;
	private DatagramSocket s;
	private DatagramPacket dp;
	private int timeout;

	public UdpClient(int port, int timeout) {
		this.port = port;
		this.timeout = timeout;

		hostAddress = InetAddress.getLoopbackAddress();
		byte[] in = new byte[2048];
		dp = new DatagramPacket(in, in.length);
	}

	public Boolean connect() {
		
		try {
			s = new DatagramSocket();
			s.setSoTimeout(timeout);
			return true;
		} catch (SocketException e) {
			e.printStackTrace();
			return false;
		}
	}
	
	public byte[] send(byte[] bytes) {
		try {

			int retryCount = 0;
			int retryLimit = 3;

			DatagramPacket out = new DatagramPacket(bytes, bytes.length,
					hostAddress, port);

			
			while (true) {
				s.send(out);

				try {
					s.receive(dp);
					byte[] received = Arrays.copyOfRange(dp.getData(),
							dp.getOffset(), dp.getOffset() + dp.getLength());
					return received;
				} catch (SocketTimeoutException e) {
					try {
						Thread.sleep(retryCount + 1, 0);
					} catch (InterruptedException e1) {
						e1.printStackTrace();
					}
					if (retryCount > retryLimit) {
						log.warn("Timeout retry limit exceeded " + e + " "
								+ retryCount);
						return null;
					}
					retryCount++;
				}
			}

		} catch (SocketException e1) {
			log.warn("Socket closed " + e1);
			return null;

		} catch (IOException e) {
			e.printStackTrace();
			return null;
		}
	}
}

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
game_machine-1.0.4	java/project/src/main/java/com/game_machine/core/UdpClient.java
game_machine-1.0.2	java/project/src/main/java/com/game_machine/core/UdpClient.java