we didn't instigate.
325815
private boolean hasFileChangedUnexpectedly() {
        synchronized (this) {
            if (mDiskWritesInFlight > 0) {
                // If we know we caused it, it's not unexpected.
                if (DEBUG) System.out.println( "disk write in flight, not unexpected.");
                return false;
            }
        }
        if (!mFile.canRead()) {
            return true;
        }
        synchronized (this) {
            return mStatTimestamp != mFile.lastModified() || mStatSize != mFile.length();
        }
    }
535281
public void join() {
    try {
      if (server != null) server.join();
      if (aggregateDaemon != null) aggregateDaemon.join();
    } catch (InterruptedException ie) {
      // do nothing
    }
  }
695382
def join(self, timeout=None):
    """"""
    return super(_StoppableDaemonThread, self).join(timeout or self.JOIN_TIMEOUT)
136532
private boolean engageInternal(Context context, String eventName) {
		Conversation conversation = getConversation();
		assertNotNull(conversation, "Attempted to engage '%s' internal event without an active conversation", eventName);
		return conversation != null && EngagementModule.engageInternal(context, conversation, eventName);
	}
30542
function noNew() {
      return finish(function(err) {
        if (err) return next(err);

        // If there was a body initially, respond that there's been no change
        if (ourEtag) return res.send(304);

        // Otherwise, respond that there's no content (yet)
        else return res.send(204);
      });
    }
693124
public static <S, D> Condition<S, D> not(Condition<S, D> condition) {
    Assert.notNull(condition, "condition");
    return new Not<S, D>(condition);
  }
433709
@Override
    public void notLeader() {
        LOG.warn("Server instance with server id {} is removed as leader", serverId);
        serviceState.becomingPassive();
        for (ActiveStateChangeHandler handler: activeStateChangeHandlers) {
            try {
                handler.instanceIsPassive();
            } catch (AtlasException e) {
                LOG.error("Error while reacting to passive state.", e);
            }
        }
        serviceState.setPassive();
    }
1196537
def unjoin(self):
        
        self.debug("()")
        if self._joined.is_set():
            packet = APPUnjoinMessage(device_id=Id.NOT_SET)
            self._send_packet(self._server_ip, self._server_port, packet)
            self._joined.clear()
            self.info("Left the audience")
715575
public Constraint not(Constraint constraint) {
        if (!(constraint instanceof Not))
            return new Not(constraint);

        return ((Not)constraint).getConstraint();
    }
654201
def cancel(self):
        
        done = self.finished.is_set()
        self.finished.set()
        return not done
1198521
def assert_is_not(expected, actual, message=None, extra=None):
    """"""
    assert expected is not actual, _assert_fail_message(
        message, expected, actual, "is", extra
    )
953894
def _wait_non_ressources(self, callback):
        """"""  # noqa: E501
        self.trigger = threading.Lock()
        self.was_ended = False
        self.trigger.acquire()
        self.trigger.acquire()
        if not self.was_ended:
            callback(self)
688886
def notCalled(cls, spy): #pylint: disable=invalid-name
        
        cls.__is_spy(spy)
        if not (not spy.called):
            raise cls.failException(cls.message)
1051788
def postinit(self, dest=None, values=None):
        
        self.dest = dest
        self.values = values
415739
def undeaf
      response = Network.post(['Conferences', self.conference_sid, 'Participant', self.call_sid], { :Deaf => false })
      Participant.new(response)
    end
1164073
def rejected(reason):
        """"""
        p = Promise()
        p._state = 'rejected'
        p.reason = reason
        return p
205277
def negated(self):
        
        query = self.copy()
        op = self.op()
        query.setOp(self.NegatedOp.get(op, op))
        query.setValue(self.value())
        return query