}
- URL* url = new URL(baseurl + "?req=setsalt");
+ URL *url = new URL(baseurl + "?req=setsalt");
timer->startTime();
URLConnection con = url->openConnection();
http->connect();
- OutputStream* os = http->getOutputStream();
+ OutputStream *os = http->getOutputStream();
os->write(saltTmp);
os->flush();
InputStream is = http->getInputStream();
if (is->available() > 0) {
- DataInputStream* dis = new DataInputStream(is);
+ DataInputStream *dis = new DataInputStream(is);
int salt_length = dis->readInt();
- Array<char> * tmp = new Array<char>(salt_length);
+ Array<char> *tmp = new Array<char>(salt_length);
dis->readFully(tmp);
salt = tmp;
timer->endTime();
System_arraycopy(rawData, 0, ivBytes, 0, CloudComm_IV_SIZE);
System_arraycopy(rawData, CloudComm_IV_SIZE, encryptedBytes, 0, encryptedBytes->length);
- IvParameterSpec* ivSpec = new IvParameterSpec(ivBytes);
+ IvParameterSpec *ivSpec = new IvParameterSpec(ivBytes);
- Cipher* cipher = Cipher_getInstance("AES/CTR/NoPadding");
+ Cipher *cipher = Cipher_getInstance("AES/CTR/NoPadding");
cipher->init(Cipher_DECRYPT_MODE, key, ivSpec);
return cipher->doFinal(encryptedBytes);
URL *url = buildRequest(true, sequencenumber, max);
timer->startTime();
- URLConnection * con = url->openConnection();
- HttpURLConnection * http = (HttpURLConnection *) con;
+ URLConnection *con = url->openConnection();
+ HttpURLConnection *http = (HttpURLConnection *) con;
http->setRequestMethod("POST");
http->setFixedLengthStreamingMode(chars->length);
http->setReadTimeout(CloudComm_TIMEOUT_MILLIS);
http->connect();
- OutputStream * os = http->getOutputStream();
+ OutputStream *os = http->getOutputStream();
os->write(chars);
os->flush();
try {
timer->startTime();
InputStream is = http->getInputStream();
- DataInputStream * dis = new DataInputStream(is);
- Array<char> *resptype = new char[7];
+ DataInputStream *dis = new DataInputStream(is);
+ Array<char> *resptype = new Array<char>(7);
dis->readFully(resptype);
timer->endTime();
*/
Array<Slot *> *CloudComm::processSlots(DataInputStream *dis) {
int numberofslots = dis->readInt();
- Array<int> * sizesofslots = new Array<int>(numberofslots);
+ Array<int> *sizesofslots = new Array<int>(numberofslots);
- Array<Slot*> * slots = new Array<Slot*>(numberofslots);
+ Array<Slot *> *slots = new Array<Slot *>(numberofslots);
for (int i = 0; i < numberofslots; i++)
- sizesofslots->set(i], dis->readInt());
+ sizesofslots->set(i, dis->readInt());
for (int i = 0; i < numberofslots; i++) {
-
Array<char> *rawData = new Array<char>(sizesofslots->get(i));
dis->readFully(rawData);
-
- // Array<char> * data = new char[rawData.length - IV_SIZE];
- // System.arraycopy(rawData, IV_SIZE, data, 0, data.length);
-
-
Array<char> *data = stripIVAndDecryptSlot(rawData);
-
- // data = decryptCipher.doFinal(data);
-
slots->set(i, Slot_decode(table, data, mac));
}
dis->close();
return NULL;
}
try {
- printf("Passing Locally"\m);
+ printf("Passing Locally\n");
mac->update(sendData);
Array<char> *genmac = mac->doFinal();
Array<char> *totalData = new Array<char>(sendData->length() + genmac->length());
System_arraycopy(sendData, 0, totalData, 0, sendData.length());
- System-arraycopy(genmac, 0, totalData, sendData.length, genmac->length());
+ System - arraycopy(genmac, 0, totalData, sendData.length, genmac->length());
// Encrypt the data for sending
Array<char> *iv = createIV(table->getMachineId(), table->getLocalSequenceNumber());
Array<char> *encryptedData = encryptSlotAndPrependIV(totalData, iv);
// Open a TCP socket connection to a local device
- Socket* socket = new Socket(host, port);
+ Socket *socket = new Socket(host, port);
socket->setReuseAddress(true);
- DataOutputStream* output = new DataOutputStream(socket->getOutputStream());
- DataInputStream* input = new DataInputStream(socket->getInputStream());
+ DataOutputStream *output = new DataOutputStream(socket->getOutputStream());
+ DataInputStream *input = new DataInputStream(socket->getInputStream());
timer->startTime();
// Send data to output (length of data, the data)