Skip to content

Commit

Permalink
Release v0.8.2
Browse files Browse the repository at this point in the history
  • Loading branch information
icorderi committed May 7, 2015
2 parents 22e2116 + f8b7dac commit 45d13e2
Show file tree
Hide file tree
Showing 7 changed files with 12 additions and 5 deletions.
3 changes: 3 additions & 0 deletions CHANGES.md
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,9 @@ This section will document changes to the library since the last release
- Pin size added to limits
- SHA1 calculation used as default on puts when algorithm and tag not specified.

## Minor changes
- The client will use WRITEBACK as default when synchronization mode not specified on PUT and DELETE.

Changes from 0.7.3 to 0.8.0
===========================

Expand Down
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
Introduction
============
The [kinetic-protocol](https://github.com/Seagate/kinetic-protocol) python client.
Requires Python 2.7.3 or higher. Python 3.x is not supported.
Requires Python 2.7.3 or higher. Python 3.x is not supported. If you want to connect through SSL on Mac OS X, you will need to have Python 2.7.9.

Installing latest stable release
================================
Expand Down
2 changes: 1 addition & 1 deletion kinetic-protocol
2 changes: 1 addition & 1 deletion kinetic/baseasync.py
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ def _async_recv(self):
except Exception as e:
self._raise(e)
else:
LOG.warn('Unsolicited status %s received but nobody listening.' % resp.status.code)
LOG.warn('Unsolicited status %s received but nobody listening. %s' % (resp.status.code, resp.status.statusMessage))
else:
seq = resp.header.ackSequence
if LOG.isEnabledFor(logging.DEBUG):
Expand Down
2 changes: 1 addition & 1 deletion kinetic/baseclient.py
Original file line number Diff line number Diff line change
Expand Up @@ -300,7 +300,7 @@ def _recv_delimited_v2(self):
# read proto message
raw_proto = self.fast_read(proto_ln)

value = None
value = ''
if value_ln > 0:
if self.defer_read:
# let user handle the read from socket
Expand Down
4 changes: 4 additions & 0 deletions kinetic/operations.py
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,10 @@ def _buildMessage(m, messageType, key, data=None, version='', new_version='',
m.body.keyValue.algorithm = common.IntegrityAlgorithms.SHA1
else:
m.body.keyValue.tag = 'l337'

if (messageType == messages.Command.PUT or messageType == messages.Command.DELETE) and synchronization == None:
synchronization = common.Synchronization.WRITEBACK

if synchronization:
m.body.keyValue.synchronization = synchronization
if version:
Expand Down
2 changes: 1 addition & 1 deletion setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
with open('requirements.txt', 'r') as f:
requires = [x.strip() for x in f if x.strip()]

version = '0.8.1'
version = '0.8.2'

setup(
name='kinetic',
Expand Down

0 comments on commit 45d13e2

Please sign in to comment.